| 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 for testing sockets. | 5 // Echo server test program for testing sockets. |
| 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 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 47 int bytesRead = 0; | 47 int bytesRead = 0; |
| 48 | 48 |
| 49 void handleRead() { | 49 void handleRead() { |
| 50 bytesRead += _socket.readList( | 50 bytesRead += _socket.readList( |
| 51 bufferReceived, bytesRead, MSGSIZE - bytesRead); | 51 bufferReceived, bytesRead, MSGSIZE - bytesRead); |
| 52 if (bytesRead < MSGSIZE) { | 52 if (bytesRead < MSGSIZE) { |
| 53 // We check every time the whole buffer to verify data integrity. | 53 // We check every time the whole buffer to verify data integrity. |
| 54 for (int i = 0; i < bytesRead; i++) { | 54 for (int i = 0; i < bytesRead; i++) { |
| 55 Expect.equals(FIRSTCHAR + i, bufferReceived[i]); | 55 Expect.equals(FIRSTCHAR + i, bufferReceived[i]); |
| 56 } | 56 } |
| 57 _socket.setDataHandler(handleRead); | 57 _socket.dataHandler = handleRead; |
| 58 } else { | 58 } else { |
| 59 // We check every time the whole buffer to verify data integrity. | 59 // We check every time the whole buffer to verify data integrity. |
| 60 for (int i = 0; i < MSGSIZE; i++) { | 60 for (int i = 0; i < MSGSIZE; i++) { |
| 61 Expect.equals(FIRSTCHAR + i, bufferReceived[i]); | 61 Expect.equals(FIRSTCHAR + i, bufferReceived[i]); |
| 62 } | 62 } |
| 63 _messages++; | 63 _messages++; |
| 64 _socket.close(); | 64 _socket.close(); |
| 65 if (_messages < MESSAGES) { | 65 if (_messages < MESSAGES) { |
| 66 sendData(); | 66 sendData(); |
| 67 } else { | 67 } else { |
| (...skipping 16 matching lines...) Expand all Loading... |
| 84 | 84 |
| 85 void connectHandler() { | 85 void connectHandler() { |
| 86 | 86 |
| 87 void writeMessage() { | 87 void writeMessage() { |
| 88 int bytesWritten = 0; | 88 int bytesWritten = 0; |
| 89 | 89 |
| 90 void handleWrite() { | 90 void handleWrite() { |
| 91 bytesWritten += _socket.writeList( | 91 bytesWritten += _socket.writeList( |
| 92 _buffer, bytesWritten, MSGSIZE - bytesWritten); | 92 _buffer, bytesWritten, MSGSIZE - bytesWritten); |
| 93 if (bytesWritten < MSGSIZE) { | 93 if (bytesWritten < MSGSIZE) { |
| 94 _socket.setWriteHandler(handleWrite); | 94 _socket.writeHandler = handleWrite; |
| 95 } | 95 } |
| 96 } | 96 } |
| 97 | 97 |
| 98 handleWrite(); | 98 handleWrite(); |
| 99 } | 99 } |
| 100 | 100 |
| 101 _socket.setDataHandler(messageHandler); | 101 _socket.dataHandler = messageHandler; |
| 102 _socket.setCloseHandler(closeHandler); | 102 _socket.closeHandler = closeHandler; |
| 103 _socket.setErrorHandler(errorHandler); | 103 _socket.errorHandler = errorHandler; |
| 104 writeMessage(); | 104 writeMessage(); |
| 105 } | 105 } |
| 106 | 106 |
| 107 _socket = new Socket(EchoServer.HOST, _port); | 107 _socket = new Socket(EchoServer.HOST, _port); |
| 108 if (_socket !== null) { | 108 if (_socket !== null) { |
| 109 _socket.setConnectHandler(connectHandler); | 109 _socket.connectHandler = connectHandler; |
| 110 } else { | 110 } else { |
| 111 Expect.fail("socket creation failed"); | 111 Expect.fail("socket creation failed"); |
| 112 } | 112 } |
| 113 } | 113 } |
| 114 | 114 |
| 115 void start() { | 115 void start() { |
| 116 _receivePort.receive((var message, SendPort replyTo) { | 116 _receivePort.receive((var message, SendPort replyTo) { |
| 117 _port = message; | 117 _port = message; |
| 118 sendData(); | 118 sendData(); |
| 119 }); | 119 }); |
| (...skipping 30 matching lines...) Expand all Loading... |
| 150 | 150 |
| 151 void handleRead() { | 151 void handleRead() { |
| 152 int read = _client.readList(buffer, bytesRead, msgSize - bytesRead); | 152 int read = _client.readList(buffer, bytesRead, msgSize - bytesRead); |
| 153 if (read > 0) { | 153 if (read > 0) { |
| 154 bytesRead += read; | 154 bytesRead += read; |
| 155 if (bytesRead < msgSize) { | 155 if (bytesRead < msgSize) { |
| 156 // We check every time the whole buffer to verify data integrity. | 156 // We check every time the whole buffer to verify data integrity. |
| 157 for (int i = 0; i < bytesRead; i++) { | 157 for (int i = 0; i < bytesRead; i++) { |
| 158 Expect.equals(EchoServerGame.FIRSTCHAR + i, buffer[i]); | 158 Expect.equals(EchoServerGame.FIRSTCHAR + i, buffer[i]); |
| 159 } | 159 } |
| 160 _client.setDataHandler(handleRead); | 160 _client.dataHandler = handleRead; |
| 161 } else { | 161 } else { |
| 162 // We check every time the whole buffer to verify data integrity. | 162 // We check every time the whole buffer to verify data integrity. |
| 163 for (int i = 0; i < msgSize; i++) { | 163 for (int i = 0; i < msgSize; i++) { |
| 164 Expect.equals(EchoServerGame.FIRSTCHAR + i, buffer[i]); | 164 Expect.equals(EchoServerGame.FIRSTCHAR + i, buffer[i]); |
| 165 } | 165 } |
| 166 | 166 |
| 167 void writeMessage() { | 167 void writeMessage() { |
| 168 | 168 |
| 169 int bytesWritten = 0; | 169 int bytesWritten = 0; |
| 170 | 170 |
| 171 void handleWrite() { | 171 void handleWrite() { |
| 172 int written = _client.writeList( | 172 int written = _client.writeList( |
| 173 buffer, bytesWritten, msgSize - bytesWritten); | 173 buffer, bytesWritten, msgSize - bytesWritten); |
| 174 bytesWritten += written; | 174 bytesWritten += written; |
| 175 if (bytesWritten < msgSize) { | 175 if (bytesWritten < msgSize) { |
| 176 _client.setWriteHandler(handleWrite); | 176 _client.writeHandler = handleWrite; |
| 177 } | 177 } |
| 178 } | 178 } |
| 179 handleWrite(); | 179 handleWrite(); |
| 180 } | 180 } |
| 181 writeMessage(); | 181 writeMessage(); |
| 182 } | 182 } |
| 183 } | 183 } |
| 184 } | 184 } |
| 185 | 185 |
| 186 handleRead(); | 186 handleRead(); |
| 187 } | 187 } |
| 188 | 188 |
| 189 void closeHandler() { | 189 void closeHandler() { |
| 190 _client.close(); | 190 _client.close(); |
| 191 } | 191 } |
| 192 | 192 |
| 193 void errorHandler() { | 193 void errorHandler() { |
| 194 print("Socket error"); | 194 print("Socket error"); |
| 195 _client.close(); | 195 _client.close(); |
| 196 } | 196 } |
| 197 | 197 |
| 198 _client = _server.accept(); | 198 _client = _server.accept(); |
| 199 _client.setDataHandler(messageHandler); | 199 _client.dataHandler = messageHandler; |
| 200 _client.setCloseHandler(closeHandler); | 200 _client.closeHandler = closeHandler; |
| 201 _client.setErrorHandler(errorHandler); | 201 _client.errorHandler = errorHandler; |
| 202 } | 202 } |
| 203 | 203 |
| 204 void errorHandlerServer() { | 204 void errorHandlerServer() { |
| 205 print("Server socket error"); | 205 print("Server socket error"); |
| 206 _server.close(); | 206 _server.close(); |
| 207 } | 207 } |
| 208 | 208 |
| 209 this.port.receive((message, SendPort replyTo) { | 209 this.port.receive((message, SendPort replyTo) { |
| 210 if (message == EchoServerGame.SERVERINIT) { | 210 if (message == EchoServerGame.SERVERINIT) { |
| 211 _server = new ServerSocket(HOST, 0, 10); | 211 _server = new ServerSocket(HOST, 0, 10); |
| 212 Expect.equals(true, _server !== null); | 212 Expect.equals(true, _server !== null); |
| 213 _server.setConnectionHandler(connectionHandler); | 213 _server.connectionHandler = connectionHandler; |
| 214 _server.setErrorHandler(errorHandlerServer); | 214 _server.errorHandler = errorHandlerServer; |
| 215 replyTo.send(_server.port, null); | 215 replyTo.send(_server.port, null); |
| 216 } else if (message == EchoServerGame.SERVERSHUTDOWN) { | 216 } else if (message == EchoServerGame.SERVERSHUTDOWN) { |
| 217 _server.close(); | 217 _server.close(); |
| 218 this.port.close(); | 218 this.port.close(); |
| 219 } | 219 } |
| 220 }); | 220 }); |
| 221 } | 221 } |
| 222 | 222 |
| 223 ServerSocket _server; | 223 ServerSocket _server; |
| 224 } | 224 } |
| 225 | 225 |
| 226 main() { | 226 main() { |
| 227 EchoServerTest.testMain(); | 227 EchoServerTest.testMain(); |
| 228 } | 228 } |
| OLD | NEW |