Index: runtime/vm/service/message.dart |
diff --git a/runtime/vm/service/message.dart b/runtime/vm/service/message.dart |
deleted file mode 100644 |
index 043c941f1889966b6affa5ec711baff7bd80327e..0000000000000000000000000000000000000000 |
--- a/runtime/vm/service/message.dart |
+++ /dev/null |
@@ -1,152 +0,0 @@ |
-// 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 Message { |
- final Completer _completer = new Completer.sync(); |
- bool get completed => _completer.isCompleted; |
- /// Future of response. |
- Future<String> get response => _completer.future; |
- Client client; |
- |
- // Client-side identifier for this message. |
- final serial; |
- |
- // In new messages. |
- final String method; |
- |
- // In old messages. |
- final List path = new List(); |
- |
- final Map params = new Map(); |
- |
- void _setPath(List<String> pathSegments) { |
- if (pathSegments == null) { |
- return; |
- } |
- pathSegments.forEach((String segment) { |
- if (segment == null || segment == '') { |
- return; |
- } |
- path.add(segment); |
- }); |
- } |
- |
- Message.fromJsonRpc(this.client, Map map) |
- : serial = map['id'], method = map['method'] { |
- if (map['params'] != null) { |
- params.addAll(map['params']); |
- } |
- } |
- |
- static String _methodNameFromUri(Uri uri) { |
- if (uri == null) { |
- return ''; |
- } |
- if (uri.pathSegments.length == 0) { |
- return ''; |
- } |
- return uri.pathSegments[0]; |
- } |
- |
- Message.fromUri(this.client, Uri uri) |
- : serial = '', method = _methodNameFromUri(uri) { |
- params.addAll(uri.queryParameters); |
- } |
- |
- Message.forIsolate(this.client, Uri uri, RunningIsolate isolate) |
- : serial = '', method = _methodNameFromUri(uri) { |
- params.addAll(uri.queryParameters); |
- params['isolateId'] = isolate.serviceId; |
- } |
- |
- Uri toUri() { |
- return new Uri(path: method, queryParameters: params); |
- } |
- |
- dynamic toJson() { |
- return { |
- 'path': path, |
- 'params': params |
- }; |
- } |
- |
- // Calls toString on all non-String elements of [list]. We do this so all |
- // elements in the list are strings, making consumption by C++ simpler. |
- // This has a side effect that boolean literal values like true become 'true' |
- // and thus indistinguishable from the string literal 'true'. |
- List _makeAllString(List list) { |
- if (list == null) { |
- return null; |
- } |
- for (var i = 0; i < list.length; i++) { |
- if (list[i] is String) { |
- continue; |
- } |
- list[i] = list[i].toString(); |
- } |
- return list; |
- } |
- |
- Future<String> send(SendPort sendPort) { |
- final receivePort = new RawReceivePort(); |
- receivePort.handler = (value) { |
- receivePort.close(); |
- _completer.complete(value); |
- }; |
- var keys = _makeAllString(params.keys.toList(growable:false)); |
- var values = _makeAllString(params.values.toList(growable:false)); |
- var request = new List(6) |
- ..[0] = 0 // Make room for OOB message type. |
- ..[1] = receivePort.sendPort |
- ..[2] = serial |
- ..[3] = method |
- ..[4] = keys |
- ..[5] = values; |
- if (!sendIsolateServiceMessage(sendPort, request)) { |
- _completer.complete(JSON.encode({ |
- 'type': 'ServiceError', |
- 'id': '', |
- 'kind': 'InternalError', |
- 'message': 'could not send message [${serial}] to isolate', |
- })); |
- } |
- return _completer.future; |
- } |
- |
- Future<String> sendToVM() { |
- final receivePort = new RawReceivePort(); |
- receivePort.handler = (value) { |
- receivePort.close(); |
- _completer.complete(value); |
- }; |
- var keys = _makeAllString(params.keys.toList(growable:false)); |
- var values = _makeAllString(params.values.toList(growable:false)); |
- var request = new List(6) |
- ..[0] = 0 // Make room for OOB message type. |
- ..[1] = receivePort.sendPort |
- ..[2] = serial |
- ..[3] = method |
- ..[4] = keys |
- ..[5] = values; |
- sendRootServiceMessage(request); |
- return _completer.future; |
- } |
- |
- void setResponse(String response) { |
- _completer.complete(response); |
- } |
- |
- void setErrorResponse(int code, String details) { |
- _completer.complete(encodeRpcError(this, code, |
- details: '$method: $details')); |
- } |
-} |
- |
-bool sendIsolateServiceMessage(SendPort sp, List m) |
- native "VMService_SendIsolateServiceMessage"; |
- |
-void sendRootServiceMessage(List m) |
- native "VMService_SendRootServiceMessage"; |