Add individual HTTP request to web socket upgrade support

tests/standalone/io/web_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 "dart:async";
@@ skipping 270 matching lines @@
               });
         });
       }
 
       for (int i = 0; i < totalConnections; i++) {
         webSocketConnection();
       }
     });
   }
 
+  testIndivitualUpgrade(int connections) {
+    createServer().then((server) {
+      int closeCount = 0;

[Anders Johnsen, 2013/03/04 14:41:57]

Unused?

[Søren Gjesse, 2013/03/04 15:50:15]

Removed.

+      server.listen((request) {
+          if (WebSocketTransformer.isUpgradeRequest(request)) {
+            WebSocketTransformer.upgrade(request).then((webSocket) {
+                webSocket.listen((_) { webSocket.close(); });
+                webSocket.send("Hello");
+            });
+          } else {
+            Expect.isFalse(WebSocketTransformer.isUpgradeRequest(request));
+            request.response.statusCode = HttpStatus.OK;
+            request.response.close();
+          }
+      });
+
+      var futures = [];
+
+      var wsProtocol = '${secure ? "wss" : "ws"}';
+      var baseWsUrl = '$wsProtocol://$HOST_NAME:${server.port}/';
+      var httpProtocol = '${secure ? "https" : "http"}';
+      var baseHttpUrl = '$httpProtocol://$HOST_NAME:${server.port}/';
+      HttpClient client = new HttpClient();
+
+      for (int i = 0; i < connections; i++) {
+        var completer1 = new Completer();
+        futures.add(completer1.future);
+        WebSocket.connect('${baseWsUrl}')
+            .then((websocket) {
+                websocket.listen((_) { websocket.close(); },
+                               onDone: completer1.complete);
+            });
+
+        var completer2 = new Completer();
+        futures.add(completer2.future);
+        client.openUrl("GET", new Uri.fromString('${baseHttpUrl}'))

[Anders Johnsen, 2013/03/04 14:41:57]

Add the result of client.openUrl directl to futures instead of using a
completer.

[Søren Gjesse, 2013/03/04 15:50:15]

Done.

+             .then((request) => request.close())
+             .then((response) {
+               response.listen((_) { });
+               Expect.equals(HttpStatus.OK, response.statusCode);
+               completer2.complete();
+             });
+      }
+
+      Future.wait(futures).then((_) {
+        server.close();
+        client.close();
+      });
+    });
+  }
+
   void runTests() {
     testRequestResponseClientCloses(2, null, null);
     testRequestResponseClientCloses(2, 3001, null);
     testRequestResponseClientCloses(2, 3002, "Got tired");
     testRequestResponseServerCloses(2, null, null);
     testRequestResponseServerCloses(2, 3001, null);
     testRequestResponseServerCloses(2, 3002, "Got tired");
     testMessageLength(125);
     testMessageLength(126);
     testMessageLength(127);
     testMessageLength(65535);
     testMessageLength(65536);
     testDoubleCloseClient();
     testDoubleCloseServer();
     testNoUpgrade();
     testUsePOST();
     testConnections(10, 3002, "Got tired");
+    testIndivitualUpgrade(5);
   }
 }
 
 
 void initializeSSL() {
   var testPkcertDatabase =
       new Path(new Options().script).directoryPath.append("pkcert/");
   SecureSocket.initialize(database: testPkcertDatabase.toNativePath(),
                           password: "dartdart");
 }
 
 
 main() {
   new SecurityConfiguration(secure: false).runTests();
   initializeSSL();
   new SecurityConfiguration(secure: true).runTests();
 }