Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1916)

Side by Side Diff: tests/standalone/src/EchoServerTest.dart

Issue 8386029: Consistently use setters to set event handlers in native APIs. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 9 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
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
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
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
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 }
OLDNEW
« no previous file with comments | « tests/standalone/src/EchoServerStreamTest.dart ('k') | tests/standalone/src/SocketCloseTest.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698