Index: runtime/bin/builtin.dart |
diff --git a/runtime/bin/builtin.dart b/runtime/bin/builtin.dart |
index eddfdebe082463b568f6ea7fd14250e7612e7475..70451878b9e9413edc870386166abd18397bce54 100644 |
--- a/runtime/bin/builtin.dart |
+++ b/runtime/bin/builtin.dart |
@@ -10,6 +10,10 @@ import 'dart:_internal'; |
import 'dart:isolate'; |
import 'dart:typed_data'; |
+// Embedder sets this to true if the --trace-loading flag was passed on the |
+// command line. |
+bool _traceLoading = false; |
+ |
// Before handling an embedder entrypoint we finalize the setup of the |
// dart:_builtin library. |
@@ -52,40 +56,40 @@ Uri _uriBase() { |
_getUriBaseClosure() => _uriBase; |
- |
// Asynchronous loading of resources. |
-// The embedder forwards most loading requests to this library. |
- |
-// See Dart_LibraryTag in dart_api.h |
-const _Dart_kScriptTag = null; |
-const _Dart_kImportTag = 0; |
-const _Dart_kSourceTag = 1; |
-const _Dart_kCanonicalizeUrl = 2; |
-const _Dart_kResourceLoad = 3; |
- |
-// Embedder sets this to true if the --trace-loading flag was passed on the |
-// command line. |
-bool _traceLoading = false; |
- |
-// This is currently a build time flag only. We measure the time from the first |
-// load request (opening the receive port) to completing the last load |
-// request (closing the receive port). Future, deferred load operations will |
-// add to this time. |
-bool _timeLoading = false; |
-Stopwatch _stopwatch; |
+// The embedder forwards loading requests to the service isolate. |
// A port for communicating with the service isolate for I/O. |
SendPort _loadPort; |
-// The receive port for a load request. Multiple sources can be fetched in |
-// a single load request. |
-RawReceivePort _dataPort; |
-// A request id valid only for the current load cycle (while the number of |
-// outstanding load requests is greater than 0). Can be reset when loading is |
-// completed. |
-int _reqId = 0; |
-// An unordered hash map mapping from request id to a particular load request. |
-// Once there are no outstanding load requests the current load has finished. |
-HashMap _reqMap = new HashMap(); |
+ |
+// The isolateId used to communicate with the service isolate for I/O. |
+int _isolateId; |
+ |
+// Requests made to the service isolate over the load port. |
+ |
+// Extra requests. Keep these in sync between loader.dart and builtin.dart. |
+const _Dart_kInitLoader = 4; // Initialize the loader. |
+const _Dart_kResourceLoad = 5; // Resource class support. |
+const _Dart_kGetPackageRootUri = 6; // Uri of the packages/ directory. |
+const _Dart_kGetPackageConfigUri = 7; // Uri of the .packages file. |
+const _Dart_kResolvePackageUri = 8; // Resolve a package: uri. |
+ |
+// Make a request to the loader. Future will complete with result which is |
+// either a Uri or a List<int>. |
+Future _makeLoaderRequest(int tag, String uri) { |
+ assert(_isolateId != null); |
+ assert(_loadPort != null); |
+ Completer completer = new Completer(); |
+ RawReceivePort port = new RawReceivePort(); |
+ port.handler = (msg) { |
+ // Close the port. |
+ port.close(); |
+ completer.complete(msg); |
+ }; |
+ _loadPort.send([_traceLoading, _isolateId, tag, port.sendPort, uri]); |
+ return completer.future; |
+} |
+ |
// The current working directory when the embedder was launched. |
Uri _workingDirectory; |
@@ -93,29 +97,8 @@ Uri _workingDirectory; |
// package imports can be resolved relative to it. The root script is the basis |
// for the root library in the VM. |
Uri _rootScript; |
- |
-// Packages are either resolved looking up in a map or resolved from within a |
-// package root. |
-bool get _packagesReady => |
- (_packageRoot != null) || (_packageMap != null) || (_packageError != null); |
-// Error string set if there was an error resolving package configuration. |
-// For example not finding a .packages file or packages/ directory, malformed |
-// .packages file or any other related error. |
-String _packageError = null; |
-// The directory to look in to resolve "package:" scheme URIs. By detault it is |
-// the 'packages' directory right next to the script. |
-Uri _packageRoot = null; // Used to be _rootScript.resolve('packages/'); |
-// The map describing how certain package names are mapped to Uris. |
-Uri _packageConfig = null; |
-Map<String, Uri> _packageMap = null; |
- |
-// A list of pending packags which have been requested while resolving the |
-// location of the package root or the contents of the package map. |
-List<_LoadRequest> _pendingPackageLoads = []; |
- |
-// If we have outstanding loads or pending package loads waiting for resolution, |
-// then we do have pending loads. |
-bool _pendingLoads() => !_reqMap.isEmpty || !_pendingPackageLoads.isEmpty; |
+// The package root set on the command line. |
+Uri _packageRoot; |
// Special handling for Windows paths so that they are compatible with URI |
// handling. |
@@ -128,47 +111,6 @@ _log(msg) { |
_print("* $_logId $msg"); |
} |
-// A class wrapping the load error message in an Error object. |
-class _LoadError extends Error { |
- final _LoadRequest request; |
- final String message; |
- _LoadError(this.request, this.message); |
- |
- String toString() { |
- var context = request._context; |
- if (context == null || context is! String) { |
- return 'Could not load "${request._uri}": $message'; |
- } else { |
- return 'Could not import "${request._uri}" from "$context": $message'; |
- } |
- } |
-} |
- |
-// Class collecting all of the information about a particular load request. |
-class _LoadRequest { |
- final int _id = _reqId++; |
- final int _tag; |
- final String _uri; |
- final Uri _resourceUri; |
- final _context; |
- |
- _LoadRequest(this._tag, this._uri, this._resourceUri, this._context) { |
- assert(_reqMap[_id] == null); |
- _reqMap[_id] = this; |
- } |
- |
- toString() => "LoadRequest($_id, $_tag, $_uri, $_resourceUri, $_context)"; |
-} |
- |
- |
-// Native calls provided by the embedder. |
-void _signalDoneLoading() native "Builtin_DoneLoading"; |
-void _loadScriptCallback(int tag, String uri, String libraryUri, Uint8List data) |
- native "Builtin_LoadSource"; |
-void _asyncLoadErrorCallback(uri, libraryUri, error) |
- native "Builtin_AsyncLoadError"; |
- |
- |
_sanitizeWindowsPath(path) { |
// For Windows we need to massage the paths a bit according to |
// http://blogs.msdn.com/b/ie/archive/2006/12/06/file-uris-in-windows.aspx |
@@ -193,7 +135,6 @@ _sanitizeWindowsPath(path) { |
return fixedPath; |
} |
- |
_trimWindowsPath(path) { |
// Convert /X:/ to X:/. |
if (_isWindows == false) { |
@@ -211,7 +152,6 @@ _trimWindowsPath(path) { |
return path; |
} |
- |
// Ensure we have a trailing slash character. |
_enforceTrailingSlash(uri) { |
if (!uri.endsWith('/')) { |
@@ -220,7 +160,6 @@ _enforceTrailingSlash(uri) { |
return uri; |
} |
- |
// Embedder Entrypoint: |
// The embedder calls this method with the current working directory. |
void _setWorkingDirectory(cwd) { |
@@ -236,7 +175,6 @@ void _setWorkingDirectory(cwd) { |
} |
} |
- |
// Embedder Entrypoint: |
// The embedder calls this method with a custom package root. |
_setPackageRoot(String packageRoot) { |
@@ -266,265 +204,8 @@ _setPackageRoot(String packageRoot) { |
} |
} |
- |
-// Given a uri with a 'package' scheme, return a Uri that is prefixed with |
-// the package root. |
-Uri _resolvePackageUri(Uri uri) { |
- assert(uri.scheme == "package"); |
- assert(_packagesReady); |
- |
- if (!uri.host.isEmpty) { |
- var path = '${uri.host}${uri.path}'; |
- var right = 'package:$path'; |
- var wrong = 'package://$path'; |
- |
- throw "URIs using the 'package:' scheme should look like " |
- "'$right', not '$wrong'."; |
- } |
- |
- if (_traceLoading) { |
- _log('Resolving package with uri path: ${uri.path}'); |
- } |
- var resolvedUri; |
- if (_packageError != null) { |
- if (_traceLoading) { |
- _log("Resolving package with pending resolution error: $_packageError"); |
- } |
- throw _packageError; |
- } else if (_packageRoot != null) { |
- resolvedUri = _packageRoot.resolve(uri.path); |
- } else { |
- var packageName = uri.pathSegments[0]; |
- var mapping = _packageMap[packageName]; |
- if (_traceLoading) { |
- _log("Mapped '$packageName' package to '$mapping'"); |
- } |
- if (mapping == null) { |
- throw "No mapping for '$packageName' package when resolving '$uri'."; |
- } |
- var path; |
- if (uri.path.length > packageName.length) { |
- path = uri.path.substring(packageName.length + 1); |
- } else { |
- // Handle naked package resolution to the default package name: |
- // package:foo is equivalent to package:foo/foo.dart |
- assert(uri.path.length == packageName.length); |
- path = "$packageName.dart"; |
- } |
- if (_traceLoading) { |
- _log("Path to be resolved in package: $path"); |
- } |
- resolvedUri = mapping.resolve(path); |
- } |
- if (_traceLoading) { |
- _log("Resolved '$uri' to '$resolvedUri'."); |
- } |
- return resolvedUri; |
-} |
- |
- |
-// Resolves the script uri in the current working directory iff the given uri |
-// did not specify a scheme (e.g. a path to a script file on the command line). |
-Uri _resolveScriptUri(String scriptName) { |
- if (_traceLoading) { |
- _log("Resolving script: $scriptName"); |
- } |
- if (_workingDirectory == null) { |
- throw 'No current working directory set.'; |
- } |
- scriptName = _sanitizeWindowsPath(scriptName); |
- |
- var scriptUri = Uri.parse(scriptName); |
- if (scriptUri.scheme == '') { |
- // Script does not have a scheme, assume that it is a path, |
- // resolve it against the working directory. |
- scriptUri = _workingDirectory.resolveUri(scriptUri); |
- } |
- |
- // Remember the root script URI so that we can resolve packages based on |
- // this location. |
- _rootScript = scriptUri; |
- |
- if (_traceLoading) { |
- _log('Resolved entry point to: $_rootScript'); |
- } |
- return scriptUri; |
-} |
- |
- |
-void _finishLoadRequest(_LoadRequest req) { |
- if (req != null) { |
- // Now that we are done with loading remove the request from the map. |
- var tmp = _reqMap.remove(req._id); |
- assert(tmp == req); |
- if (_traceLoading) { |
- _log("Loading of ${req._uri} finished: " |
- "${_reqMap.length} requests remaining, " |
- "${_pendingPackageLoads.length} packages pending."); |
- } |
- } |
- |
- if (!_pendingLoads() && (_dataPort != null)) { |
- _stopwatch.stop(); |
- // Close the _dataPort now that there are no more requests outstanding. |
- if (_traceLoading || _timeLoading) { |
- _log("Closing loading port: ${_stopwatch.elapsedMilliseconds} ms"); |
- } |
- _dataPort.close(); |
- _dataPort = null; |
- _reqId = 0; |
- _signalDoneLoading(); |
- } |
-} |
- |
- |
-void _handleLoaderReply(msg) { |
- int id = msg[0]; |
- var dataOrError = msg[1]; |
- assert((id >= 0) && (id < _reqId)); |
- var req = _reqMap[id]; |
- try { |
- if (dataOrError is Uint8List) { |
- // Successfully loaded the data. |
- if (req._tag == _Dart_kResourceLoad) { |
- Completer c = req._context; |
- c.complete(dataOrError); |
- } else { |
- // TODO: Currently a compilation error while loading the script is |
- // fatal for the isolate. _loadScriptCallback() does not return and |
- // the number of requests remains out of sync. |
- _loadScriptCallback(req._tag, req._uri, req._context, dataOrError); |
- } |
- _finishLoadRequest(req); |
- } else { |
- assert(dataOrError is String); |
- var error = new _LoadError(req, dataOrError.toString()); |
- _asyncLoadError(req, error, null); |
- } |
- } catch(e, s) { |
- // Wrap inside a _LoadError unless we are already propagating a |
- // previous _LoadError. |
- var error = (e is _LoadError) ? e : new _LoadError(req, e.toString()); |
- assert(req != null); |
- _asyncLoadError(req, error, s); |
- } |
-} |
- |
- |
-void _startLoadRequest(int tag, String uri, Uri resourceUri, context) { |
- if (_dataPort == null) { |
- if (_traceLoading) { |
- _log("Initializing load port."); |
- } |
- // Allocate the Stopwatch if necessary. |
- if (_stopwatch == null) { |
- _stopwatch = new Stopwatch(); |
- } |
- assert(_dataPort == null); |
- _dataPort = new RawReceivePort(_handleLoaderReply); |
- _stopwatch.start(); |
- } |
- // Register the load request and send it to the VM service isolate. |
- var req = new _LoadRequest(tag, uri, resourceUri, context); |
- |
- assert(_dataPort != null); |
- var msg = new List(4); |
- msg[0] = _dataPort.sendPort; |
- msg[1] = _traceLoading; |
- msg[2] = req._id; |
- msg[3] = resourceUri.toString(); |
- _loadPort.send(msg); |
- |
- if (_traceLoading) { |
- _log("Loading of $resourceUri for $uri started with id: ${req._id}. " |
- "${_reqMap.length} requests remaining, " |
- "${_pendingPackageLoads.length} packages pending."); |
- } |
-} |
- |
- |
-RawReceivePort _packagesPort; |
- |
-void _handlePackagesReply(msg) { |
- // Make sure to close the _packagePort before any other action. |
- _packagesPort.close(); |
- _packagesPort = null; |
- |
- if (_traceLoading) { |
- _log("Got packages reply: $msg"); |
- } |
- if (msg is String) { |
- if (_traceLoading) { |
- _log("Got failure response on package port: '$msg'"); |
- } |
- // Remember the error message. |
- _packageError = msg; |
- } else if (msg is List) { |
- if (msg.length == 1) { |
- if (_traceLoading) { |
- _log("Received package root: '${msg[0]}'"); |
- } |
- _packageRoot = Uri.parse(msg[0]); |
- } else { |
- // First entry contains the location of the loaded .packages file. |
- assert((msg.length % 2) == 0); |
- assert(msg.length >= 2); |
- assert(msg[1] == null); |
- _packageConfig = Uri.parse(msg[0]); |
- _packageMap = new Map<String, Uri>(); |
- for (var i = 2; i < msg.length; i+=2) { |
- // TODO(iposva): Complain about duplicate entries. |
- _packageMap[msg[i]] = Uri.parse(msg[i+1]); |
- } |
- if (_traceLoading) { |
- _log("Setup package map: $_packageMap"); |
- } |
- } |
- } else { |
- _packageError = "Bad type of packages reply: ${msg.runtimeType}"; |
- if (_traceLoading) { |
- _log(_packageError); |
- } |
- } |
- |
- // Resolve all pending package loads now that we know how to resolve them. |
- while (_pendingPackageLoads.length > 0) { |
- // Order does not matter as we queue all of the requests up right now. |
- var req = _pendingPackageLoads.removeLast(); |
- // Call the registered closure, to handle the delayed action. |
- req(); |
- } |
- // Reset the pending package loads to empty. So that we eventually can |
- // finish loading. |
- _pendingPackageLoads = []; |
- // Make sure that the receive port is closed if no other loads are pending. |
- _finishLoadRequest(null); |
-} |
- |
- |
-void _requestPackagesMap() { |
- assert(_packagesPort == null); |
- assert(_rootScript != null); |
- // Create a port to receive the packages map on. |
- _packagesPort = new RawReceivePort(_handlePackagesReply); |
- var sp = _packagesPort.sendPort; |
- |
- var msg = new List(4); |
- msg[0] = sp; |
- msg[1] = _traceLoading; |
- msg[2] = -1; |
- msg[3] = _rootScript.toString(); |
- _loadPort.send(msg); |
- |
- if (_traceLoading) { |
- _log("Requested packages map for '$_rootScript'."); |
- } |
-} |
- |
- |
// Embedder Entrypoint: |
-// Request the load of a particular packages map. |
-void _loadPackagesMap(String packagesParam) { |
+void _setPackagesMap(String packagesParam) { |
if (!_setupCompleted) { |
_setupHooks(); |
} |
@@ -550,147 +231,36 @@ void _loadPackagesMap(String packagesParam) { |
if (_traceLoading) { |
_log('Resolved packages map to: $packagesUri'); |
} |
- |
- // Request the loading and parsing of the packages map at the specified URI. |
- // Create a port to receive the packages map on. |
- assert(_packagesPort == null); |
- _packagesPort = new RawReceivePort(_handlePackagesReply); |
- var sp = _packagesPort.sendPort; |
- |
- var msg = new List(4); |
- msg[0] = sp; |
- msg[1] = _traceLoading; |
- msg[2] = -2; |
- msg[3] = packagesUriStr; |
- _loadPort.send(msg); |
- |
- // Signal that the resolution of the packages map has started. But in this |
- // case it is not tied to a particular request. |
- _pendingPackageLoads.add(() { |
- // Nothing to be done beyond registering that there is pending package |
- // resolution requested by having an empty entry. |
- if (_traceLoading) { |
- _log("Skipping dummy deferred request."); |
- } |
- }); |
- |
- if (_traceLoading) { |
- _log("Requested packages map at '$packagesUri'."); |
- } |
} |
- |
-void _asyncLoadError(_LoadRequest req, _LoadError error, StackTrace stack) { |
+// Resolves the script uri in the current working directory iff the given uri |
+// did not specify a scheme (e.g. a path to a script file on the command line). |
+String _resolveScriptUri(String scriptName) { |
if (_traceLoading) { |
- _log("_asyncLoadError(${req._uri}), error: $error\nstack: $stack"); |
- } |
- if (req._tag == _Dart_kResourceLoad) { |
- Completer c = req._context; |
- c.completeError(error, stack); |
- } else { |
- String libraryUri = req._context; |
- if (req._tag == _Dart_kImportTag) { |
- // When importing a library, the libraryUri is the imported |
- // uri. |
- libraryUri = req._uri; |
- } |
- _asyncLoadErrorCallback(req._uri, libraryUri, error); |
- } |
- _finishLoadRequest(req); |
-} |
- |
- |
-_loadDataFromLoadPort(int tag, String uri, Uri resourceUri, context) { |
- try { |
- _startLoadRequest(tag, uri, resourceUri, context); |
- } catch (e, s) { |
- if (_traceLoading) { |
- _log("Exception when communicating with service isolate: $e"); |
- } |
- // Register a dummy load request so we can fail to load it. |
- var req = new _LoadRequest(tag, uri, resourceUri, context); |
- |
- // Wrap inside a _LoadError unless we are already propagating a previously |
- // seen _LoadError. |
- var error = (e is _LoadError) ? e : new _LoadError(req, e.toString()); |
- _asyncLoadError(req, error, s); |
+ _log("Resolving script: $scriptName"); |
} |
-} |
- |
- |
-// Loading a package URI needs to first map the package name to a loadable |
-// URI. |
-_loadPackage(int tag, String uri, Uri resourceUri, context) { |
- if (_packagesReady) { |
- var resolvedUri; |
- try { |
- resolvedUri = _resolvePackageUri(resourceUri); |
- } catch (e, s) { |
- if (_traceLoading) { |
- _log("Exception ($e) when resolving package URI: $resourceUri"); |
- } |
- // Register a dummy load request so we can fail to load it. |
- var req = new _LoadRequest(tag, uri, resourceUri, context); |
- |
- // Wrap inside a _LoadError unless we are already propagating a previously |
- // seen _LoadError. |
- var error = (e is _LoadError) ? e : new _LoadError(req, e.toString()); |
- _asyncLoadError(req, error, s); |
- } |
- _loadData(tag, uri, resolvedUri, context); |
- } else { |
- if (_pendingPackageLoads.isEmpty) { |
- // Package resolution has not been setup yet, and this is the first |
- // request for package resolution & loading. |
- _requestPackagesMap(); |
- } |
- // Register the action of loading this package once the package resolution |
- // is ready. |
- _pendingPackageLoads.add(() { |
- if (_traceLoading) { |
- _log("Handling deferred package request: " |
- "$tag, $uri, $resourceUri, $context"); |
- } |
- _loadPackage(tag, uri, resourceUri, context); |
- }); |
- if (_traceLoading) { |
- _log("Pending package load of '$uri': " |
- "${_pendingPackageLoads.length} pending"); |
- } |
+ if (_workingDirectory == null) { |
+ throw 'No current working directory set.'; |
} |
-} |
- |
+ scriptName = _sanitizeWindowsPath(scriptName); |
-// Load the data associated with the resourceUri. |
-_loadData(int tag, String uri, Uri resourceUri, context) { |
- if (resourceUri.scheme == 'package') { |
- // package based uris need to be resolved to the correct loadable location. |
- // The logic of which is handled seperately, and then _loadData is called |
- // recursively. |
- _loadPackage(tag, uri, resourceUri, context); |
- } else { |
- _loadDataFromLoadPort(tag, uri, resourceUri, context); |
+ var scriptUri = Uri.parse(scriptName); |
+ if (scriptUri.scheme == '') { |
+ // Script does not have a scheme, assume that it is a path, |
+ // resolve it against the working directory. |
+ scriptUri = _workingDirectory.resolveUri(scriptUri); |
} |
-} |
+ // Remember the root script URI so that we can resolve packages based on |
+ // this location. |
+ _rootScript = scriptUri; |
-// Embedder Entrypoint: |
-// Asynchronously loads script data through a http[s] or file uri. |
-_loadDataAsync(int tag, String uri, String libraryUri) { |
- if (!_setupCompleted) { |
- _setupHooks(); |
- } |
- var resourceUri; |
- if (tag == _Dart_kScriptTag) { |
- resourceUri = _resolveScriptUri(uri); |
- uri = resourceUri.toString(); |
- } else { |
- resourceUri = Uri.parse(uri); |
+ if (_traceLoading) { |
+ _log('Resolved entry point to: $_rootScript'); |
} |
- _loadData(tag, uri, resourceUri, libraryUri); |
+ return scriptUri.toString(); |
} |
- |
// Embedder Entrypoint: |
// Function called by standalone embedder to resolve uris when the VM requests |
// Dart_kCanonicalizeUrl from the tag handler. |
@@ -712,99 +282,6 @@ String _resolveUri(String base, String userString) { |
return result; |
} |
- |
- |
-// Handling of access to the package root or package map from user code. |
-_triggerPackageResolution(action) { |
- if (_packagesReady) { |
- // Packages are ready. Execute the action now. |
- action(); |
- } else { |
- if (_pendingPackageLoads.isEmpty) { |
- // Package resolution has not been setup yet, and this is the first |
- // request for package resolution & loading. |
- _requestPackagesMap(); |
- } |
- // Register the action for when the package resolution is ready. |
- _pendingPackageLoads.add(action); |
- } |
-} |
- |
- |
-Future<Uri> _getPackageRootFuture() { |
- if (_traceLoading) { |
- _log("Request for package root from user code."); |
- } |
- var completer = new Completer<Uri>(); |
- _triggerPackageResolution(() { |
- completer.complete(_packageRoot); |
- }); |
- return completer.future; |
-} |
- |
- |
-Future<Uri> _getPackageConfigFuture() { |
- if (_traceLoading) { |
- _log("Request for package config from user code."); |
- } |
- var completer = new Completer<Uri>(); |
- _triggerPackageResolution(() { |
- completer.complete(_packageConfig); |
- }); |
- return completer.future; |
-} |
- |
- |
-Future<Uri> _resolvePackageUriFuture(Uri packageUri) async { |
- if (_traceLoading) { |
- _log("Request for package Uri resolution from user code: $packageUri"); |
- } |
- if (packageUri.scheme != "package") { |
- if (_traceLoading) { |
- _log("Non-package Uri, returning unmodified: $packageUri"); |
- } |
- // Return the incoming parameter if not passed a package: URI. |
- return packageUri; |
- } |
- |
- if (!_packagesReady) { |
- if (_traceLoading) { |
- _log("Trigger loading by requesting the package config."); |
- } |
- // Make sure to trigger package resolution. |
- var dummy = await _getPackageConfigFuture(); |
- } |
- assert(_packagesReady); |
- |
- var result; |
- try { |
- result = _resolvePackageUri(packageUri); |
- } catch (e, s) { |
- // Any error during resolution will resolve this package as not mapped, |
- // which is indicated by a null return. |
- if (_traceLoading) { |
- _log("Exception ($e) when resolving package URI: $packageUri"); |
- } |
- result = null; |
- } |
- if (_traceLoading) { |
- _log("Resolved '$packageUri' to '$result'"); |
- } |
- return result; |
-} |
- |
- |
-// Handling of Resource class by dispatching to the load port. |
-Future<List<int>> _resourceReadAsBytes(Uri uri) { |
- var completer = new Completer<List<int>>(); |
- // Request the load of the resource associating the completer as the context |
- // for the load. |
- _loadData(_Dart_kResourceLoad, uri.toString(), uri, completer); |
- // Return the future that will be triggered once the resource has been loaded. |
- return completer.future; |
-} |
- |
- |
// Embedder Entrypoint (gen_snapshot): |
// Resolve relative paths relative to working directory. |
String _resolveInWorkingDirectory(String fileName) { |
@@ -828,6 +305,11 @@ String _resolveInWorkingDirectory(String fileName) { |
return uri.toString(); |
} |
+// Only used by vm/cc unit tests. |
+Uri _resolvePackageUri(Uri uri) { |
+ assert(_packageRoot != null); |
+ return _packageRoot.resolve(uri.path); |
+} |
// Returns either a file path or a URI starting with http[s]:, as a String. |
String _filePathFromUri(String userUri) { |
@@ -857,7 +339,6 @@ String _filePathFromUri(String userUri) { |
} |
} |
- |
// Embedder Entrypoint. |
_libraryFilePath(String libraryUri) { |
if (!_setupCompleted) { |
@@ -873,7 +354,6 @@ _libraryFilePath(String libraryUri) { |
return _filePathFromUri(path); |
} |
- |
// Register callbacks and hooks with the rest of the core libraries. |
_setupHooks() { |
_setupCompleted = true; |
@@ -883,3 +363,54 @@ _setupHooks() { |
VMLibraryHooks.packageConfigUriFuture = _getPackageConfigFuture; |
VMLibraryHooks.resolvePackageUriFuture = _resolvePackageUriFuture; |
} |
+ |
+// Handling of Resource class by dispatching to the load port. |
+Future<List<int>> _resourceReadAsBytes(Uri uri) async { |
+ List response = await _makeLoaderRequest(_Dart_kResourceLoad, uri.toString()); |
+ if (response[3] is String) { |
+ // Throw the error. |
+ throw response[3]; |
+ } else { |
+ return response[3]; |
+ } |
+} |
+ |
+Future<Uri> _getPackageRootFuture() { |
+ if (_traceLoading) { |
+ _log("Request for package root from user code."); |
+ } |
+ return _makeLoaderRequest(_Dart_kGetPackageRootUri, null); |
+} |
+ |
+Future<Uri> _getPackageConfigFuture() { |
+ if (_traceLoading) { |
+ _log("Request for package config from user code."); |
+ } |
+ assert(_loadPort != null); |
+ return _makeLoaderRequest(_Dart_kGetPackageConfigUri, null); |
+} |
+ |
+Future<Uri> _resolvePackageUriFuture(Uri packageUri) async { |
+ if (_traceLoading) { |
+ _log("Request for package Uri resolution from user code: $packageUri"); |
+ } |
+ if (packageUri.scheme != "package") { |
+ if (_traceLoading) { |
+ _log("Non-package Uri, returning unmodified: $packageUri"); |
+ } |
+ // Return the incoming parameter if not passed a package: URI. |
+ return packageUri; |
+ } |
+ var result = await _makeLoaderRequest(_Dart_kResolvePackageUri, |
+ packageUri.toString()); |
+ if (result is! Uri) { |
+ if (_traceLoading) { |
+ _log("Exception when resolving package URI: $packageUri"); |
+ } |
+ result = null; |
+ } |
+ if (_traceLoading) { |
+ _log("Resolved '$packageUri' to '$result'"); |
+ } |
+ return result; |
+} |