Fix deadlock in process exit handling

runtime/bin/process_impl.dart

 // Copyright (c) 2011, 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.
 
 class _ProcessStartStatus {
   int _errorCode;  // Set to OS error code if process start failed.
   String _errorMessage;  // Set to OS error message if process start failed.
 }
 
 
@@ skipping 20 matching lines @@
 
   void start() {
     var status = new _ProcessStartStatus();
     bool success = _start(
         _path, _arguments, _in, _out, _err, _exitHandler, status);
     if (!success) {
       close();
       throw new ProcessException(status._errorMessage, status._errorCode);
     }
     _started = true;
-    if (_exitHandlerCallback !== null) {
-      setExitHandler(_exitHandlerCallback);
-    }
+
+    // Setup an exit handler to handle internal cleanup and possible
+    // callback when a process terminates.
+    _exitHandler.setDataHandler(() {
+        List<int> buffer = new List<int>(8);
+        SocketInputStream input = _exitHandler.inputStream;
+
+        int exitCode(List<int> ints) {
+          return ints[4] + (ints[5] << 8) + (ints[6] << 16) + (ints[7] << 24);
+        }
+
+        int exitPid(List<int> ints) {
+          return ints[0] + (ints[1] << 8) + (ints[2] << 16) + (ints[3] << 24);
+        }
+
+        void handleExit() {
+          _processExit(exitPid(buffer));
+          if (_exitHandlerCallback != null) {
+            _exitHandlerCallback(exitCode(buffer));
+          }
+        }
+
+        void readData() {
+          handleExit();
+        }
+
+        bool result = input.read(buffer, 0, 8, readData);
+        if (result) {
+          handleExit();
+        }
+      });
   }
 
   bool _start(String path,
               List<String> arguments,
               Socket input,
               Socket output,
               Socket error,
               Socket exitHandler,
               _ProcessStartStatus status) native "Process_Start";
 
+  void _processExit(int pid) native "Process_Exit";
+
   InputStream get stdoutStream() {
     if (_closed) {
       throw new ProcessException("Process closed");
     }
     return _in.inputStream;
   }
 
   InputStream get stderrStream() {
     if (_closed) {
       throw new ProcessException("Process closed");
@@ skipping 35 matching lines @@
     _closed = true;
   }
 
   void setExitHandler(void callback(int exitCode)) {
     if (_closed) {
       throw new ProcessException("Process closed");
     }
     if (_killed) {
       throw new ProcessException("Process killed");
     }
-    if (_started) {
-      _exitHandler.setDataHandler(() {
-        List<int> buffer = new List<int>(4);
-        SocketInputStream input = _exitHandler.inputStream;
-
-        int getExitValue(List<int> ints) {
-          return ints[0] + (ints[1] << 8) + (ints[2] << 16) + (ints[3] << 24);
-        }
-
-        void readData() {
-          callback(getExitValue(buffer));
-        }
-
-        bool result = input.read(buffer, 0, 4, readData);
-        if (result) {
-          callback(getExitValue(buffer));
-        }
-      });
-    } else {
-      _exitHandlerCallback = callback;
-    }
+    _exitHandlerCallback = callback;
   }
 
   String _path;
-
   ObjectArray<String> _arguments;
-
   Socket _in;
-
   Socket _out;
-
   Socket _err;
-
   Socket _exitHandler;
-
   int _pid;
-
   bool _closed;
-
   bool _killed;
-
   bool _started;
-
   var _exitHandlerCallback;
 }