| Index: pkg/front_end/lib/src/vm/reload.dart
|
| diff --git a/pkg/front_end/lib/src/vm/reload.dart b/pkg/front_end/lib/src/vm/reload.dart
|
| deleted file mode 100644
|
| index 806ef594c4f9f468a34ce8fa2dc73146de8eb130..0000000000000000000000000000000000000000
|
| --- a/pkg/front_end/lib/src/vm/reload.dart
|
| +++ /dev/null
|
| @@ -1,96 +0,0 @@
|
| -// Copyright (c) 2017, 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.
|
| -
|
| -/// A helper library to connect to an existing VM and trigger a hot-reload via
|
| -/// its service protocol.
|
| -///
|
| -/// Usage:
|
| -///
|
| -/// ```
|
| -/// var reloader = new VmReloader();
|
| -/// await reloader.reload(uriToEntryScript);
|
| -/// ...
|
| -/// await reloader.disconnect();
|
| -/// ```
|
| -library front_end.src.vm.reload;
|
| -
|
| -import 'dart:async';
|
| -import 'package:json_rpc_2/json_rpc_2.dart' as json_rpc;
|
| -import 'package:stream_channel/stream_channel.dart';
|
| -import 'package:web_socket_channel/io.dart';
|
| -
|
| -/// A user API to trigger hot reloads on a running VM via the VM's service
|
| -/// protocol.
|
| -class VmReloader {
|
| - /// Port used to connect to the vm service protocol, typically 8181.
|
| - final int port;
|
| -
|
| - /// An peer point used to send service protocol messages. The service
|
| - /// protocol uses JSON rpc on top of web-sockets.
|
| - json_rpc.Peer get rpc => _rpc ??= _createPeer();
|
| - json_rpc.Peer _rpc;
|
| -
|
| - /// The main isolate ID of the running VM. Needed to indicate to the VM which
|
| - /// isolate to reload.
|
| - FutureOr<String> get mainId async => _mainId ??= await _computeMainId();
|
| - String _mainId;
|
| -
|
| - VmReloader([this.port = 8181]);
|
| -
|
| - /// Establishes the JSON rpc connection.
|
| - json_rpc.Peer _createPeer() {
|
| - StreamChannel socket =
|
| - new IOWebSocketChannel.connect('ws://127.0.0.1:$port/ws');
|
| - var peer = new json_rpc.Peer(socket);
|
| - peer.listen().then((_) {
|
| - if (VERBOSE_DEBUG) print('connection to vm-service closed');
|
| - return disconnect();
|
| - }).catchError((e) {
|
| - if (VERBOSE_DEBUG) print('error connecting to the vm-service');
|
| - return disconnect();
|
| - });
|
| - return peer;
|
| - }
|
| -
|
| - /// Retrieves the ID of the main isolate using the service protocol.
|
| - Future<String> _computeMainId() async {
|
| - var vm = await rpc.sendRequest('getVM');
|
| - var isolates = vm['isolates'];
|
| - for (var isolate in isolates) {
|
| - if (isolate['name'].contains(r'$main')) {
|
| - return isolate['id'];
|
| - }
|
| - }
|
| - return isolates.first['id'];
|
| - }
|
| -
|
| - /// Send a request to the VM to reload sources from [entryUri].
|
| - ///
|
| - /// This will establish a connection with the VM assuming it is running on the
|
| - /// local machine and listening on [port] for service protocol requests.
|
| - ///
|
| - /// The result is the JSON map received from the reload request.
|
| - Future<Map> reload(Uri entryUri) async {
|
| - var id = await mainId;
|
| - var result = await rpc.sendRequest('reloadSources', {
|
| - 'isolateId': id,
|
| - 'rootLibUri': entryUri.path,
|
| - });
|
| - return result;
|
| - }
|
| -
|
| - /// Close any connections used to communicate with the VM.
|
| - Future disconnect() async {
|
| - if (_rpc == null) return null;
|
| - this._mainId = null;
|
| - if (!_rpc.isClosed) {
|
| - var future = _rpc.close();
|
| - _rpc = null;
|
| - return future;
|
| - }
|
| - return null;
|
| - }
|
| -}
|
| -
|
| -const VERBOSE_DEBUG = false;
|
|
|