Handle closing of HTTP client and server

runtime/bin/socket_impl.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.
 
 
 class _SocketBase {
   // Bit flags used when communicating between the eventhandler and
   // dart code. The EVENT flags are used to indicate events of
   // interest when sending a message from dart code to the
   // eventhandler. When receiving a message from the eventhandler the
@@ skipping 21 matching lines @@
 
   static final int _FIRST_COMMAND = _CLOSE_COMMAND;
   static final int _LAST_COMMAND = _SHUTDOWN_WRITE_COMMAND;
 
   _SocketBase () {
     _handlerMap = new List(_LAST_EVENT + 1);
     _handlerMask = 0;
     _canActivateHandlers = true;
     _id = -1;
     _EventHandler._start();
+    _hashCode = _nextHashCode;
+    _nextHashCode = (_nextHashCode + 1) & 0xFFFFFFF;
   }
 
   // Multiplexes socket events to the socket handlers.
   void _multiplex(int event_mask) {
     _canActivateHandlers = false;
     for (int i = _FIRST_EVENT; i <= _LAST_EVENT; i++) {
       if (((event_mask & (1 << i)) != 0)) {
         if ((i == _CLOSE_EVENT) && this is _Socket && _id >= 0) {
           _closedRead = true;
           if (_closedWrite) _close();
@@ skipping 119 matching lines @@
 
   void _sendToEventHandler(int data) {
     if (_handler === null) {
       _handler = new ReceivePort();
       _handler.receive((var message, ignored) { _multiplex(message); });
     }
     assert(_id >= 0);
     _EventHandler._sendData(_id, _handler, data);
   }
 
+  int hashCode() => _hashCode;
+
   abstract bool _isListenSocket();
   abstract bool _isPipe();
 
   // Socket id is set from native. -1 indicates that the socket was closed.
   int _id;
 
   // Dedicated ReceivePort for socket events.
   ReceivePort _handler;
 
   // Poll event to handler map.
   List _handlerMap;
 
   // Indicates for which poll events the socket registered handlers.
   int _handlerMask;
 
   // Indicates if native interrupts can be activated.
   bool _canActivateHandlers;
 
   // Holds the port of the socket, null if not known.
   int _port;
+
+  // Hash code for the socket. Currently this is just a counter.
+  int _hashCode;
+  static int _nextHashCode = 0;
 }
 
 
 class _ServerSocket extends _SocketBase implements ServerSocket {
   // Constructor for server socket. First a socket object is allocated
   // in which the native socket is stored. After that _createBind
   // is called which creates a file descriptor and binds the given address
   // and port to the socket. Null is returned if file descriptor creation or
   // bind failed.
   factory _ServerSocket(String bindAddress, int port, int backlog) {
@@ skipping 261 matching lines @@
   bool _seenFirstOutEvent = false;
   bool _closedRead = false;
   bool _closedWrite = false;
   bool _pipe = false;
   Function _clientConnectHandler;
   Function _clientWriteHandler;
   SocketInputStream _inputStream;
   SocketOutputStream _outputStream;
 }