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

Unified Diff: tests/standalone/io/socket_close_test.dart

Issue 2771453003: Format all tests. (Closed)
Patch Set: Format files Created 3 years, 8 months 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 side-by-side diff with in-line comments
Download patch
Index: tests/standalone/io/socket_close_test.dart
diff --git a/tests/standalone/io/socket_close_test.dart b/tests/standalone/io/socket_close_test.dart
index c00b89fba504bc96a0f30f4001f6a1be84996818..dd256b6b1a0162c3a6613fd4ed419e5f5d4ed20f 100644
--- a/tests/standalone/io/socket_close_test.dart
+++ b/tests/standalone/io/socket_close_test.dart
@@ -19,7 +19,6 @@ import "package:expect/expect.dart";
const SERVERSHUTDOWN = -1;
const ITERATIONS = 10;
-
Future sendReceive(SendPort port, message) {
ReceivePort receivePort = new ReceivePort();
port.send([message, receivePort.sendPort]);
@@ -27,7 +26,6 @@ Future sendReceive(SendPort port, message) {
}
class SocketClose {
-
SocketClose.start(this._mode, this._done)
: _sendPort = null,
_readBytes = 0,
@@ -47,7 +45,6 @@ class SocketClose {
}
void sendData() {
-
void dataHandler(bytes) {
switch (_mode) {
case 0:
@@ -102,8 +99,7 @@ class SocketClose {
}
void connectHandler(socket) {
- socket.listen(
- dataHandler,
+ socket.listen(dataHandler,
onDone: () => closeHandler(socket),
onError: (error) => errorHandler(socket));
@@ -128,14 +124,14 @@ class SocketClose {
break;
case 4:
writeHello();
- socket.close(); // Half close.
+ socket.close(); // Half close.
break;
case 5:
writeHello();
break;
case 6:
writeHello();
- socket.close(); // Half close.
+ socket.close(); // Half close.
break;
default:
Expect.fail("Unknown test mode");
@@ -159,7 +155,9 @@ class SocketClose {
}
void shutdown() {
- sendReceive(_sendPort, SERVERSHUTDOWN).then((_) { _done(); });
+ sendReceive(_sendPort, SERVERSHUTDOWN).then((_) {
+ _done();
+ });
switch (_mode) {
case 0:
@@ -200,21 +198,18 @@ class SocketClose {
Function _done;
}
-
class ConnectionData {
ConnectionData(Socket this.connection) : readBytes = 0;
Socket connection;
int readBytes;
}
-
void startSocketCloseServer(SendPort replyTo) {
var server = new SocketCloseServer();
replyTo.send(server.dispatchSendPort);
}
class SocketCloseServer {
-
static const HOST = "127.0.0.1";
SocketCloseServer() : _dispatchPort = new ReceivePort() {
@@ -242,7 +237,9 @@ class SocketCloseServer {
Expect.fail("No data expected");
break;
case 1:
- readBytes(bytes, () { _dataEvents++; });
+ readBytes(bytes, () {
+ _dataEvents++;
+ });
break;
case 2:
readBytes(bytes, () {
@@ -268,7 +265,7 @@ class SocketCloseServer {
readBytes(bytes, () {
_dataEvents++;
writeHello();
- connection.close(); // Half close.
+ connection.close(); // Half close.
});
break;
default:
@@ -287,10 +284,7 @@ class SocketCloseServer {
_iterations++;
- connection.listen(
- dataHandler,
- onDone: closeHandler,
- onError: errorHandler);
+ connection.listen(dataHandler, onDone: closeHandler, onError: errorHandler);
}
void errorHandlerServer(e) {
@@ -353,13 +347,10 @@ class SocketCloseServer {
_mode = command;
ServerSocket.bind("127.0.0.1", 0).then((server) {
_server = server;
- _server.listen(
- (socket) {
- var data = new ConnectionData(socket);
- connectionHandler(data);
- },
- onError: errorHandlerServer
- );
+ _server.listen((socket) {
+ var data = new ConnectionData(socket);
+ connectionHandler(data);
+ }, onError: errorHandlerServer);
replyTo.send(_server.port);
});
} else {
@@ -378,7 +369,6 @@ class SocketCloseServer {
int _mode;
}
-
main() {
// Run the close test in these different "modes".
// 0: Client closes without sending at all.

Powered by Google App Engine
This is Rietveld 408576698