Only return eventhandler tokens in stacks of 8, to avoid runtime calls.

runtime/bin/socket_patch.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.
 
 patch class RawServerSocket {
   /* patch */ static Future<RawServerSocket> bind(address,
                                                   int port,
                                                   {int backlog: 0,
                                                    bool v6Only: false}) {
     return _RawServerSocket.bind(address, port, backlog, v6Only);
@@ skipping 337 matching lines @@
   static const int ERROR_EVENT = 2;
   static const int CLOSED_EVENT = 3;
   static const int DESTROYED_EVENT = 4;
   static const int FIRST_EVENT = READ_EVENT;
   static const int LAST_EVENT = DESTROYED_EVENT;
   static const int EVENT_COUNT = LAST_EVENT - FIRST_EVENT + 1;
 
   static const int CLOSE_COMMAND = 8;
   static const int SHUTDOWN_READ_COMMAND = 9;
   static const int SHUTDOWN_WRITE_COMMAND = 10;
   static const int RETURN_TOKEN_COMMAND = 11;

[Søren Gjesse, 2014/03/25 13:31:22]

Please update this section with information that the lower bits are used for
token count for the RETURN_TOKEN_COMMAND.

[Anders Johnsen, 2014/03/25 13:43:35]

Done.

   static const int FIRST_COMMAND = CLOSE_COMMAND;
   static const int LAST_COMMAND = RETURN_TOKEN_COMMAND;
 
   // Type flag send to the eventhandler providing additional
   // information on the type of the file descriptor.
   static const int LISTENING_SOCKET = 16;
   static const int PIPE_SOCKET = 17;
   static const int TYPE_NORMAL_SOCKET = 0;
   static const int TYPE_LISTENING_SOCKET = 1 << LISTENING_SOCKET;
   static const int TYPE_PIPE = 1 << PIPE_SOCKET;
@@ skipping 34 matching lines @@
   final int typeFlags;
 
   // Holds the port of the socket, 0 if not known.
   int localPort = 0;
 
   // Holds the address used to connect or bind the socket.
   InternetAddress address;
 
   int available = 0;
 
+  int returnTokens = 0;
+
   bool sendReadEvents = false;
   bool readEventIssued = false;
 
   bool sendWriteEvents = false;
   bool writeEventIssued = false;
   bool writeAvailable = false;
 
   // Statistics.
   int totalRead = 0;
   int totalWritten = 0;
@@ skipping 388 matching lines @@
           if (!isClosing) {
             reportError(nativeGetError(), "");
           }
         } else if (!isClosed) {
           // If the connection is closed right after it's accepted, there's a
           // chance the close-handler is not set.
           if (handler != null) handler();
         }
       }
     }
-    if (eventPort != null && !isClosing && !isClosed) {
-      sendToEventHandler(1 << RETURN_TOKEN_COMMAND);
+    if (eventPort != null && !isClosing && !isClosed && !isListening) {
+      returnTokens++;
+      if (returnTokens == 8) {
+        // Return in batches of 8.

[Søren Gjesse, 2014/03/25 13:31:22]

assert(1 << FIRST_COMMAND < returnTokens)

[Anders Johnsen, 2014/03/25 13:43:35]

Done.

+        sendToEventHandler((1 << RETURN_TOKEN_COMMAND) | returnTokens);
+        returnTokens = 0;
+      }
     }
   }
 
   void setHandlers({read, write, error, closed, destroyed}) {
     eventHandlers[READ_EVENT] = read;
     eventHandlers[WRITE_EVENT] = write;
     eventHandlers[ERROR_EVENT] = error;
     eventHandlers[CLOSED_EVENT] = closed;
     eventHandlers[DESTROYED_EVENT] = destroyed;
   }
@@ skipping 921 matching lines @@
                        String address,
                        List<int> in_addr,
                        int port) {
   return new Datagram(
       data,
       new _InternetAddress(address, null, in_addr),
       port);
 }
 
 String _socketsStats() => _SocketsObservatory.toJSON();