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

Side by Side Diff: tests/standalone/src/EchoServerStreamTest.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
« no previous file with comments | « tests/standalone/src/DirectoryTest.dart ('k') | tests/standalone/src/EchoServerTest.dart » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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 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
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
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 }
OLDNEW
« no previous file with comments | « tests/standalone/src/DirectoryTest.dart ('k') | tests/standalone/src/EchoServerTest.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698