| OLD | NEW |
| 1 // Copyright (c) 2011, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2011, the Dart project authors. Please see the AUTHORS file |
| 2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
| 3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
| 4 // | 4 // |
| 5 // Echo server test program to test socket streams. | 5 // Echo server test program to test socket streams. |
| 6 // | 6 // |
| 7 // VMOptions= | 7 // VMOptions= |
| 8 // VMOptions=--short_socket_read | 8 // VMOptions=--short_socket_read |
| 9 // VMOptions=--short_socket_write | 9 // VMOptions=--short_socket_write |
| 10 // VMOptions=--short_socket_read --short_socket_write | 10 // VMOptions=--short_socket_read --short_socket_write |
| (...skipping 72 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 83 } else { | 83 } else { |
| 84 shutdown(); | 84 shutdown(); |
| 85 } | 85 } |
| 86 } | 86 } |
| 87 } | 87 } |
| 88 | 88 |
| 89 if (_messages % 2 == 0) data = new List<int>(MSGSIZE); | 89 if (_messages % 2 == 0) data = new List<int>(MSGSIZE); |
| 90 inputStream.dataHandler = dataReceived; | 90 inputStream.dataHandler = dataReceived; |
| 91 } | 91 } |
| 92 | 92 |
| 93 _socket.setCloseHandler(closeHandler); | 93 _socket.closeHandler = closeHandler; |
| 94 _socket.setErrorHandler(errorHandler); | 94 _socket.errorHandler = errorHandler; |
| 95 stream.write(_buffer); | 95 stream.write(_buffer); |
| 96 dataSent(); | 96 dataSent(); |
| 97 } | 97 } |
| 98 | 98 |
| 99 _socket = new Socket(EchoServer.HOST, _port); | 99 _socket = new Socket(EchoServer.HOST, _port); |
| 100 if (_socket !== null) { | 100 if (_socket !== null) { |
| 101 _socket.setConnectHandler(connectHandler); | 101 _socket.connectHandler = connectHandler; |
| 102 } else { | 102 } else { |
| 103 Expect.fail("socket creation failed"); | 103 Expect.fail("socket creation failed"); |
| 104 } | 104 } |
| 105 } | 105 } |
| 106 | 106 |
| 107 void start() { | 107 void start() { |
| 108 _receivePort.receive((var message, SendPort replyTo) { | 108 _receivePort.receive((var message, SendPort replyTo) { |
| 109 _port = message; | 109 _port = message; |
| 110 sendData(); | 110 sendData(); |
| 111 }); | 111 }); |
| (...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 157 } | 157 } |
| 158 | 158 |
| 159 void errorHandler() { | 159 void errorHandler() { |
| 160 print("Socket error"); | 160 print("Socket error"); |
| 161 _client.close(); | 161 _client.close(); |
| 162 } | 162 } |
| 163 | 163 |
| 164 _client = _server.accept(); | 164 _client = _server.accept(); |
| 165 inputStream = _client.inputStream; | 165 inputStream = _client.inputStream; |
| 166 inputStream.dataHandler = dataReceived; | 166 inputStream.dataHandler = dataReceived; |
| 167 _client.setCloseHandler(closeHandler); | 167 _client.closeHandler = closeHandler; |
| 168 _client.setErrorHandler(errorHandler); | 168 _client.errorHandler = errorHandler; |
| 169 } | 169 } |
| 170 | 170 |
| 171 void errorHandlerServer() { | 171 void errorHandlerServer() { |
| 172 print("Server socket error"); | 172 print("Server socket error"); |
| 173 _server.close(); | 173 _server.close(); |
| 174 } | 174 } |
| 175 | 175 |
| 176 this.port.receive((message, SendPort replyTo) { | 176 this.port.receive((message, SendPort replyTo) { |
| 177 if (message == EchoServerGame.SERVERINIT) { | 177 if (message == EchoServerGame.SERVERINIT) { |
| 178 _server = new ServerSocket(HOST, 0, 10); | 178 _server = new ServerSocket(HOST, 0, 10); |
| 179 Expect.equals(true, _server !== null); | 179 Expect.equals(true, _server !== null); |
| 180 _server.setConnectionHandler(connectionHandler); | 180 _server.connectionHandler = connectionHandler; |
| 181 _server.setErrorHandler(errorHandlerServer); | 181 _server.errorHandler = errorHandlerServer; |
| 182 replyTo.send(_server.port, null); | 182 replyTo.send(_server.port, null); |
| 183 } else if (message == EchoServerGame.SERVERSHUTDOWN) { | 183 } else if (message == EchoServerGame.SERVERSHUTDOWN) { |
| 184 _server.close(); | 184 _server.close(); |
| 185 this.port.close(); | 185 this.port.close(); |
| 186 } | 186 } |
| 187 }); | 187 }); |
| 188 } | 188 } |
| 189 | 189 |
| 190 ServerSocket _server; | 190 ServerSocket _server; |
| 191 } | 191 } |
| 192 | 192 |
| 193 main() { | 193 main() { |
| 194 EchoServerStreamTest.testMain(); | 194 EchoServerStreamTest.testMain(); |
| 195 } | 195 } |
| OLD | NEW |