Big merge from experimental to bleeding edge.

samples/tests/samples/chat/chat_server_test.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.
 //
 // VMOptions=
 // VMOptions=--short_socket_read
 // VMOptions=--short_socket_write
 // VMOptions=--short_socket_read --short_socket_write
 
 import 'dart:io';
 import 'dart:isolate';
-import 'dart:json';
+import 'dart:json' as json;
 import '../../../chat/chat_server_lib.dart';
 
 // Message to start chat test client running in an isolate.
 class ChatTestClientStart {
   ChatTestClientStart(int this.totalClients,
                       int this.messagesToSend,
                       int this.messagesToReceive,
                       int this.port);
 
   int totalClients;
@@ skipping 27 matching lines @@
   int joinCount;
   int messageCount;
   int receiveMessageNumber;  // Number of messages received.
 
   void leave() {
     HttpClientRequest request;
     HttpClientResponse response;
 
     void leaveResponseHandler(String data) {
       Expect.equals(HttpStatus.OK, response.statusCode);
-      var responseData = JSON.parse(data);
+      var responseData = json.parse(data);
       Expect.equals("leave", responseData["response"]);
 
       // Test done.
       statusPort.send("Test succeeded", null);
     }
 
     Map leaveRequest = new Map();
     leaveRequest["request"] = "leave";
     leaveRequest["sessionId"] = sessionId;
     HttpClientConnection conn = httpClient.post("127.0.0.1", port, "/leave");
     conn.onRequest = (HttpClientRequest request) {
-      request.outputStream.writeString(JSON.stringify(leaveRequest));
+      request.outputStream.writeString(json.stringify(leaveRequest));
       request.outputStream.close();
     };
     conn.onResponse = (HttpClientResponse r) {
       response = r;
       StringInputStream stream = new StringInputStream(response.inputStream);
       StringBuffer body = new StringBuffer();
       stream.onData = () => body.add(stream.read());
       stream.onClosed = () => leaveResponseHandler(body.toString());
     };
   }
 
   void receive() {
     HttpClientRequest request;
     HttpClientResponse response;
 
     void receiveResponseHandler(String data) {
       Expect.equals(HttpStatus.OK, response.statusCode);
-      var responseData = JSON.parse(data);
+      var responseData = json.parse(data);
       Expect.equals("receive", responseData["response"]);
       Expect.equals(null, responseData["disconnect"]);
       for (int i = 0; i < responseData["messages"].length; i++) {
         Map message = responseData["messages"][i];
         if (message["type"] == "join") {
           joinCount++;
         } else if (message["type"] == "message") {
           messageCount++;
         } else {
           Expect.equals("leave", message["type"]);
@@ skipping 22 matching lines @@
       }
     }
 
     Map receiveRequest = new Map();
     receiveRequest["request"] = "receive";
     receiveRequest["sessionId"] = sessionId;
     receiveRequest["nextMessage"] = receiveMessageNumber;
     HttpClientConnection conn =
         httpClient.post("127.0.0.1", port, "/receive");
     conn.onRequest = (HttpClientRequest request) {
-      request.outputStream.writeString(JSON.stringify(receiveRequest));
+      request.outputStream.writeString(json.stringify(receiveRequest));
       request.outputStream.close();
     };
     conn.onResponse = (HttpClientResponse r) {
       response = r;
       StringInputStream stream = new StringInputStream(response.inputStream);
       StringBuffer body = new StringBuffer();
       stream.onData = () => body.add(stream.read());
       stream.onClosed = () => receiveResponseHandler(body.toString());
     };
   }
 
   void sendMessage() {
     HttpClientRequest request;
     HttpClientResponse response;
 
     void sendResponseHandler(String data) {
       Expect.equals(HttpStatus.OK, response.statusCode);
-      var responseData = JSON.parse(data);
+      var responseData = json.parse(data);
       Expect.equals("message", responseData["response"]);
       sendMessageNumber++;
       if (sendMessageNumber < messagesToSend) {
         sendMessage();
       } else {
         receive();
       }
     }
 
     Map messageRequest = new Map();
     messageRequest["request"] = "message";
     messageRequest["sessionId"] = sessionId;
     messageRequest["message"] = "message $sendMessageNumber";
     HttpClientConnection conn =
         httpClient.post("127.0.0.1", port, "/message");
     conn.onRequest = (HttpClientRequest request) {
-      request.outputStream.writeString(JSON.stringify(messageRequest));
+      request.outputStream.writeString(json.stringify(messageRequest));
       request.outputStream.close();
     };
     conn.onResponse = (HttpClientResponse r) {
       response = r;
       StringInputStream stream = new StringInputStream(response.inputStream);
       StringBuffer body = new StringBuffer();
       stream.onData = () => body.add(stream.read());
       stream.onClosed = () => sendResponseHandler(body.toString());
     };
   }
 
   void join() {
     HttpClientRequest request;
     HttpClientResponse response;
 
     void joinResponseHandler(String data) {
       Expect.equals(HttpStatus.OK, response.statusCode);
-      var responseData = JSON.parse(data);
+      var responseData = json.parse(data);
       Expect.equals("join", responseData["response"]);
       sessionId = responseData["sessionId"];
       Expect.isTrue(sessionId != null);
 
       joinCount = 0;
       messageCount = 0;
       sendMessageNumber = 0;
       receiveMessageNumber = 0;
       sendMessage();
     }
 
     Map joinRequest = new Map();
     joinRequest["request"] = "join";
     joinRequest["handle"] = "test1";
     HttpClientConnection conn = httpClient.post("127.0.0.1", port, "/join");
     conn.onRequest = (HttpClientRequest request) {
-      request.outputStream.writeString(JSON.stringify(joinRequest));
+      request.outputStream.writeString(json.stringify(joinRequest));
       request.outputStream.close();
     };
     conn.onResponse = (HttpClientResponse r) {
       response = r;
       StringInputStream stream = new StringInputStream(response.inputStream);
       StringBuffer body = new StringBuffer();
       stream.onData = () => body.add(stream.read());
       stream.onClosed = () => joinResponseHandler(body.toString());
     };
   }
@@ skipping 37 matching lines @@
                                           message.port);
               clientPorts[i].send(command, clientStatusPorts[i].toSendPort());
             }
           } else if (message.isError) {
             print("Could not start server - probably error \"Address already in use\" from bind.");
             serverStatusPort.close();
           }
         });
 
     // Prepare the requested number of clients.
-    clientPorts = new List<SendPort>(clientCount);
+    clientPorts = new List<SendPort>.fixedLength(clientCount);
     int liveClientsCount = 0;
-    clientStatusPorts = new List<ReceivePort>(clientCount);
+    clientStatusPorts = new List<ReceivePort>.fixedLength(clientCount);
     for (int i = 0; i < clientCount; i++) {
       ReceivePort statusPort = new ReceivePort();
       statusPort.receive((var message, SendPort replyTo) {
         // First and only message from the client indicates that
         // the test is done.
         Expect.equals("Test succeeded", message);
         statusPort.close();
         finishedClients++;
 
         // If all clients are finished shutdown the server.
@@ skipping 56 matching lines @@
   TestMain testMain = new TestMain.run(10, 2);
 }
 
 
 void main() {
   testOneClient();
   testTwoClients();
   testTwoClientsMoreMessages();
   testTenClients();
 }