dart:io | Enable multithreaded secure networking encryption.

tests/standalone/io/raw_socket_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.
 //
 // VMOptions=
 // VMOptions=--short_socket_read
 // VMOptions=--short_socket_write
 // VMOptions=--short_socket_read --short_socket_write
 
 import "package:expect/expect.dart";
@@ skipping 110 matching lines @@
     Expect.isTrue(server.port > 0);
     RawSocket.connect("127.0.0.1", server.port).then((_) {
       server.listen((_) {
         server.close();
         port.close();
       });
     });
   });
 }
 
-void testSimpleReadWrite() {
+void testSimpleReadWrite({bool dropReads}) {
   // This test creates a server and a client connects. The client then
   // writes and the server echos. When the server has finished its
   // echo it half-closes. When the client gets the close event is
   // closes fully.
   ReceivePort port = new ReceivePort();
 
   const messageSize = 1000;
+  int serverReadCount = 0;
+  int clientReadCount = 0;
 
   List<int> createTestData() {
     return new List<int>.generate(messageSize, (index) => index & 0xff);
   }
 
   void verifyTestData(List<int> data) {
     Expect.equals(messageSize, data.length);
     List<int> expected = createTestData();
     for (int i = 0; i < messageSize; i++) {
       Expect.equals(expected[i], data[i]);
     }
   }
 
   RawServerSocket.bind(InternetAddress.LOOPBACK_IP_V4, 0).then((server) {
     server.listen((client) {
       int bytesRead = 0;
       int bytesWritten = 0;
       List<int> data = new List<int>(messageSize);
 
       client.writeEventsEnabled = false;
       client.listen((event) {
         switch (event) {
           case RawSocketEvent.READ:
+            if (dropReads) {
+              if (serverReadCount != 10) {
+                serverReadCount++;
+                break;
+              } else {
+                serverReadCount = 0;
+              }
+            }
             Expect.isTrue(bytesWritten == 0);
             Expect.isTrue(client.available() > 0);
-            var buffer = client.read();
+            var buffer = client.read(200);
             data.setRange(bytesRead, bytesRead + buffer.length, buffer);
             bytesRead += buffer.length;
             if (bytesRead == data.length) {
               verifyTestData(data);
               client.writeEventsEnabled = true;
             }
             break;
           case RawSocketEvent.WRITE:
             Expect.isFalse(client.writeEventsEnabled);
             bytesWritten += client.write(
@@ skipping 15 matching lines @@
 
     RawSocket.connect("127.0.0.1", server.port).then((socket) {
       int bytesRead = 0;
       int bytesWritten = 0;
       List<int> data = createTestData();
 
       socket.listen((event) {
         switch (event) {
           case RawSocketEvent.READ:
             Expect.isTrue(socket.available() > 0);
+            if (dropReads) {
+              if (clientReadCount != 10) {
+                clientReadCount++;
+                break;
+              } else {
+                clientReadCount = 0;
+              }
+            }
             var buffer = socket.read();
             data.setRange(bytesRead, bytesRead + buffer.length, buffer);
             bytesRead += buffer.length;
             break;
           case RawSocketEvent.WRITE:
             Expect.isTrue(bytesRead == 0);
             Expect.isFalse(socket.writeEventsEnabled);
             bytesWritten += socket.write(
                 data, bytesWritten, data.length - bytesWritten);
             if (bytesWritten < data.length) {
@@ skipping 131 matching lines @@
 }
 
 main() {
   testArguments();
   testSimpleBind();
   testCloseOneEnd("client");
   testCloseOneEnd("server");
   testInvalidBind();
   testSimpleConnect();
   testServerListenAfterConnect();
-  testSimpleReadWrite();
+  testSimpleReadWrite(dropReads: false);
+  testSimpleReadWrite(dropReads: true);
   testPauseServerSocket();
   testPauseSocket();
 }