|
@@ -217,23 +217,14 @@ main(List<String> args) {
|
|
var isolates = int.parse(arguments['isolates']);
|
|
var isolates = int.parse(arguments['isolates']);
|
|
var dbConnections = int.parse(arguments['dbconnections']) ~/ isolates;
|
|
var dbConnections = int.parse(arguments['dbconnections']) ~/ isolates;
|
|
|
|
|
|
- ServerSocket.bind(arguments['address'], int.parse(arguments['port']))
|
|
|
|
|
|
+ ServerSocket
|
|
|
|
+ .bind(arguments['address'], int.parse(arguments['port']), shared: true)
|
|
.then((server) {
|
|
.then((server) {
|
|
- var ref = server.reference;
|
|
|
|
for (int i = 1; i < isolates; i++) {
|
|
for (int i = 1; i < isolates; i++) {
|
|
- Isolate.spawn(startInIsolate, [ref, dbConnections]);
|
|
|
|
|
|
+ _startServer(server, dbConnections);
|
|
}
|
|
}
|
|
- _startServer(server, dbConnections);
|
|
|
|
- });
|
|
|
|
-
|
|
|
|
-}
|
|
|
|
-
|
|
|
|
-void startInIsolate(args) {
|
|
|
|
- var ref = args[0];
|
|
|
|
- var dbConnections = args[1];
|
|
|
|
- ref.create().then((server) {
|
|
|
|
- _startServer(server, dbConnections);
|
|
|
|
});
|
|
});
|
|
|
|
+
|
|
}
|
|
}
|
|
|
|
|
|
_startServer(serverSocket, dbConnections) {
|
|
_startServer(serverSocket, dbConnections) {
|