Chromium Code Reviews| Index: runtime/bin/builtin.dart |
| diff --git a/runtime/bin/builtin.dart b/runtime/bin/builtin.dart |
| index 8b4c0604840816f85bdd7f62d520019d2b9acf93..ce49b718a22238073b21aa6e5d564216b1ca8917 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) { |
|
turnidge
2016/06/03 22:42:11
I wonder if we should have named constants for the
|
| + // 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; |
| +} |