Index: tests/standalone/io/secure_server_stream_test.dart |
diff --git a/tests/standalone/io/secure_server_stream_test.dart b/tests/standalone/io/secure_server_stream_test.dart |
deleted file mode 100644 |
index d99e93e1d22d519dc22a56f7c5ddac0cadbafaa7..0000000000000000000000000000000000000000 |
--- a/tests/standalone/io/secure_server_stream_test.dart |
+++ /dev/null |
@@ -1,101 +0,0 @@ |
-// 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. |
- |
-import "dart:io"; |
-import "dart:isolate"; |
- |
-const SERVER_ADDRESS = "127.0.0.1"; |
-const HOST_NAME = "localhost"; |
- |
-class SecureTestServer { |
- void onConnection(Socket connection) { |
- numConnections++; |
- var input = connection.inputStream; |
- String received = ""; |
- input.onData = () { |
- received = received.concat(new String.fromCharCodes(input.read())); |
- }; |
- input.onClosed = () { |
- Expect.isTrue(received.contains("Hello from client ")); |
- String name = received.substring(received.indexOf("client ") + 7); |
- connection.outputStream.write("Welcome, client $name".charCodes); |
- connection.outputStream.close(); |
- }; |
- } |
- |
- void errorHandlerServer(Exception e) { |
- Expect.fail("Server socket error $e"); |
- } |
- |
- int start() { |
- server = new SecureServerSocket(SERVER_ADDRESS, 0, 10, "CN=$HOST_NAME"); |
- Expect.isNotNull(server); |
- server.onConnection = onConnection; |
- server.onError = errorHandlerServer; |
- return server.port; |
- } |
- |
- void stop() { |
- server.close(); |
- } |
- |
- int numConnections = 0; |
- SecureServerSocket server; |
-} |
- |
-class SecureTestClient { |
- SecureTestClient(int this.port, String this.name) { |
- socket = new SecureSocket(HOST_NAME, port); |
- numRequests++; |
- socket.outputStream.write("Hello from client $name".charCodes); |
- socket.outputStream.close(); |
- socket.inputStream.onData = () { |
- reply = reply.concat(new String.fromCharCodes(socket.inputStream.read())); |
- }; |
- socket.inputStream.onClosed = this.done; |
- reply = ""; |
- } |
- |
- void done() { |
- Expect.equals("Welcome, client $name", reply); |
- numReplies++; |
- if (numReplies == CLIENT_NAMES.length) { |
- Expect.equals(numRequests, numReplies); |
- EndTest(); |
- } |
- } |
- |
- static int numRequests = 0; |
- static int numReplies = 0; |
- |
- int port; |
- String name; |
- SecureSocket socket; |
- String reply; |
-} |
- |
-Function EndTest; |
- |
-const CLIENT_NAMES = const ['able', 'baker', 'camera', 'donut', 'echo']; |
- |
-void main() { |
- ReceivePort keepAlive = new ReceivePort(); |
- Path scriptDir = new Path(new Options().script).directoryPath; |
- Path certificateDatabase = scriptDir.append('pkcert'); |
- SecureSocket.initialize(database: certificateDatabase.toNativePath(), |
- password: 'dartdart'); |
- |
- var server = new SecureTestServer(); |
- int port = server.start(); |
- |
- EndTest = () { |
- Expect.equals(CLIENT_NAMES.length, server.numConnections); |
- server.stop(); |
- keepAlive.close(); |
- }; |
- |
- for (var x in CLIENT_NAMES) { |
- new SecureTestClient(port, x); |
- } |
-} |