Keep track of when a socket has been destroyed

tests/standalone/io/echo_server_stream_test.dart

 // 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.
 //
 // Echo server test program to test socket streams.
 //
 // VMOptions=
 // VMOptions=--short_socket_read
 // VMOptions=--short_socket_write
 // VMOptions=--short_socket_read --short_socket_write
 
 library ServerTest;
 
 import "package:expect/expect.dart";
 import "dart:async";
 import "dart:io";
 import "dart:isolate";
 part "testing_server.dart";
 
+int count = 0;
 class EchoServerGame {
 
   static const MSGSIZE = 10;
   static const MESSAGES = 100;
   static const FIRSTCHAR = 65;
 
   EchoServerGame.start()
       : _receivePort = new ReceivePort(),
         _sendPort = null,
         _buffer = new List<int>(MSGSIZE),
         _messages = 0 {
     for (int i = 0; i < MSGSIZE; i++) {
       _buffer[i] = FIRSTCHAR + i;
     }
     _sendPort = spawnFunction(startEchoServer);
     initialize();
   }
 
   void sendData() {
     int offset = 0;
     List<int> data;
 
     void onData(List<int> data) {
+      print("onData");

[Anders Johnsen, 2013/05/08 13:11:47]

Debug stuff in this file.

       int bytesRead = data.length;
       for (int i = 0; i < data.length; i++) {
         Expect.equals(FIRSTCHAR + i + offset, data[i]);
       }
       offset += bytesRead;
     }
 
     void onClosed() {
+      print("onClosed ${++count}");
       Expect.equals(MSGSIZE, offset);
       _messages++;
       if (_messages < MESSAGES) {
         sendData();
       } else {
         shutdown();
       }
     }
 
     void errorHandler(e) {
       String msg = "Socket error $e";
       var trace = getAttachedStackTrace(e);
       if (trace != null) msg += "\nStackTrace: $trace";
       Expect.fail(msg);
     }
 
     void connectHandler() {
       _socket.listen(onData,
                      onError: errorHandler,
                      onDone: onClosed);
       _socket.add(_buffer);
       _socket.close();
+      print("After close");
       data = new List<int>(MSGSIZE);
     }
 
     Socket.connect(TestingServer.HOST, _port).then((s) {
+      print("After connect");
       _socket = s;
       connectHandler();
     });
   }
 
   void initialize() {
     _receivePort.receive((var message, SendPort replyTo) {
       _port = message;
       sendData();
     });
@@ skipping 22 matching lines @@
 
 class EchoServer extends TestingServer {
 
   static const int MSGSIZE = EchoServerGame.MSGSIZE;
 
   void onConnection(Socket connection) {
     List<int> buffer = new List<int>(MSGSIZE);
     int offset = 0;
 
     void dataReceived(List<int> data) {
+      print("dataReceived");
       int bytesRead;
       bytesRead = data.length;
       if (bytesRead > 0) {
         buffer.setRange(offset, offset + data.length, data);
         offset += bytesRead;
         for (int i = 0; i < offset; i++) {
           Expect.equals(EchoServerGame.FIRSTCHAR + i, buffer[i]);
         }
         if (offset == MSGSIZE) {
           connection.add(buffer);
           connection.close();
         }
       }
     }
 
     void errorHandler(e) {
       String msg = "Socket error $e";
       var trace = getAttachedStackTrace(e);
       if (trace != null) msg += "\nStackTrace: $trace";
       Expect.fail(msg);
     }
 
     connection.listen(dataReceived, onError: errorHandler);
   }
 }
 
 main() {
   EchoServerGame echoServerGame = new EchoServerGame.start();
 }