isolate in frog: hiding internal implementation classes, couple minor fixes.

lib/isolate/frog/ports.dart

 // Copyright (c) 2012, 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.
 
 /** Common functionality to all send ports. */
 class _BaseSendPort implements SendPort {
   /** Id for the destination isolate. */
   final int _isolateId;
 
   _BaseSendPort(this._isolateId);
@@ skipping 36 matching lines @@
 /** A send port that delivers messages in-memory via native JavaScript calls. */
 class _NativeJsSendPort extends _BaseSendPort implements SendPort {
   final _ReceivePortImpl _receivePort;
 
   const _NativeJsSendPort(this._receivePort, int isolateId) : super(isolateId);
 
   void send(var message, [SendPort replyTo = null]) {
     _waitForPendingPorts([message, replyTo], () {
       checkReplyTo(replyTo);
       // Check that the isolate still runs and the port is still open
-      final isolate = globalState.isolates[_isolateId];
+      final isolate = _globalState.isolates[_isolateId];
       if (isolate == null) return;
       if (_receivePort._callback == null) return;
 
       // We force serialization/deserialization as a simple way to ensure
       // isolate communication restrictions are respected between isolates that
       // live in the same worker. [_NativeJsSendPort] delivers both messages
       // from the same worker and messages from other workers. In particular,
       // messages sent from a worker via a [_WorkerSendPort] are received at
       // [_processWorkerMessage] and forwarded to a native port. In such cases,
-      // here we'll see [globalState.currentContext == null].
-      final shouldSerialize = globalState.currentContext != null
-          && globalState.currentContext.id != _isolateId;
+      // here we'll see [_globalState.currentContext == null].
+      final shouldSerialize = _globalState.currentContext != null
+          && _globalState.currentContext.id != _isolateId;
       var msg = message;
       var reply = replyTo;
       if (shouldSerialize) {
         msg = _serializeMessage(msg);
         reply = _serializeMessage(reply);
       }
-      globalState.topEventLoop.enqueue(isolate, () {
+      _globalState.topEventLoop.enqueue(isolate, () {
         if (_receivePort._callback != null) {
           if (shouldSerialize) {
             msg = _deserializeMessage(msg);
             reply = _deserializeMessage(reply);
           }
           _receivePort._callback(msg, reply);
         }
       }, 'receive ' + message);
     });
   }
@@ skipping 14 matching lines @@
 
   void send(var message, [SendPort replyTo = null]) {
     _waitForPendingPorts([message, replyTo], () {
       checkReplyTo(replyTo);
       final workerMessage = _serializeMessage({
           'command': 'message',
           'port': this,
           'msg': message,
           'replyTo': replyTo});
 
-      if (globalState.isWorker) {
+      if (_globalState.isWorker) {
         // communication from one worker to another go through the main worker:
-        globalState.mainWorker.postMessage(workerMessage);
+        _globalState.mainWorker.postMessage(workerMessage);
       } else {
-        globalState.workers[_workerId].postMessage(workerMessage);
+        _globalState.workers[_workerId].postMessage(workerMessage);
       }
     });
   }
 
   bool operator ==(var other) {
     return (other is _WorkerSendPort) &&
         (_workerId == other._workerId) &&
         (_isolateId == other._isolateId) &&
         (_receivePortId == other._receivePortId);
   }
@@ skipping 67 matching lines @@
 }
 
 /** Implementation of a multi-use [ReceivePort] on top of JavaScript. */
 class _ReceivePortImpl implements ReceivePort {
   int _id;
   Function _callback;
   static int _nextFreeId = 1;
 
   _ReceivePortImpl()
       : _id = _nextFreeId++ {
-    globalState.currentContext.register(_id, this);
+    _globalState.currentContext.register(_id, this);
   }
 
   void receive(void onMessage(var message, SendPort replyTo)) {
     _callback = onMessage;
   }
 
   void close() {
     _callback = null;
-    globalState.currentContext.unregister(_id);
+    _globalState.currentContext.unregister(_id);
   }
 
   SendPort toSendPort() {
-    return new _NativeJsSendPort(this, globalState.currentContext.id);
+    return new _NativeJsSendPort(this, _globalState.currentContext.id);
   }
 }
 
 /** Implementation of a single-shot [ReceivePort]. */
 class _ReceivePortSingleShotImpl implements ReceivePort {
 
   _ReceivePortSingleShotImpl() : _port = new _ReceivePortImpl() { }
 
   void receive(void callback(var message, SendPort replyTo)) {
     _port.receive((var message, SendPort replyTo) {
@@ skipping 48 matching lines @@
     // map.getValues().forEach(_dispatch);
     map.getValues().forEach((e) => _dispatch(e));
   }
 
   visitBufferingSendPort(_BufferingSendPort port) {
     if (port._port == null) {
       ports.add(port._futurePort);
     }
   }
 }