| // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file |
| // for details. All rights reserved. Use of this source code is governed by a |
| // BSD-style license that can be found in the LICENSE file. |
| |
| part of vmservice; |
| |
| class RunningIsolate implements ServiceRequestRouter { |
| final SendPort sendPort; |
| String name = 'Unknown'; |
| |
| RunningIsolate(this.sendPort); |
| |
| Future sendMessage(List request) { |
| final completer = new Completer.sync(); |
| final receivePort = new ReceivePort(); |
| sendServiceMessage(sendPort, receivePort, request); |
| receivePort.receive((value, ignoreReplyTo) { |
| receivePort.close(); |
| if (value is Exception) { |
| completer.completeError(value); |
| } else { |
| completer.complete(value); |
| } |
| }); |
| return completer.future; |
| } |
| |
| Future route(ServiceRequest request) { |
| // Send message to isolate. |
| var message = request.toServiceCallMessage(); |
| return sendMessage(message).then((response) { |
| request.setResponse(response); |
| return new Future.value(request); |
| }); |
| } |
| |
| void _sendNameRequest() { |
| var request = new ServiceRequest(); |
| request.parse(Uri.parse('/name')); |
| sendMessage(request.toServiceCallMessage()).then(_handleNameResponse); |
| } |
| |
| void _handleNameResponse(String responseString) { |
| try { |
| var response = JSON.parse(responseString); |
| name = response['name']; |
| } catch (e) { |
| name = 'Error retrieving isolate name.'; |
| return; |
| } |
| if (name == null) { |
| name = 'Error retrieving isolate name.'; |
| } |
| } |
| } |