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

Issues Search
    My Issues | Starred     Open | Closed | All

Unified Diff: samples/chat/chat_server_lib.dart

Issue 10837070: Remove old isolate API and update all code in the repository to use (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Fix namespace comment. Created 8 years, 5 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
« runtime/vm/snapshot_test.dart ('K') | « samples/chat/chat_server.dart ('k') | samples/dartcombat/player.dart » ('j') | samples/dartcombat/player.dart » ('J')
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: samples/chat/chat_server_lib.dart
diff --git a/samples/chat/chat_server_lib.dart b/samples/chat/chat_server_lib.dart
index a892a1987921d4e0ddaba4d6040b48a00cf578a8..929729aa3c8566d9544f6c64e182c8aa0edfefcc 100644
--- a/samples/chat/chat_server_lib.dart
+++ b/samples/chat/chat_server_lib.dart
@@ -7,23 +7,28 @@
#import("dart:isolate");
#import("dart:json");
+void startChatServer() {
+ var server = new ChatServer();
+ server.init();
+ port.receive((message, replyTo) {
kasperl 2012/08/03 05:20:27 port.receive(server.dispatch)?
Mads Ager (google) 2012/08/03 05:51:35 D'oh! Done for all of them.
+ server.dispatch(message, replyTo);
+ });
+}
+
class ChatServer extends IsolatedServer {
}
class ServerMain {
- ServerMain.start(IsolatedServer server,
+ ServerMain.start(SendPort serverPort,
String hostAddress,
int tcpPort,
[int listenBacklog = 5])
: _statusPort = new ReceivePort(),
- _serverPort = null {
- server.spawn().then((SendPort port) {
- _serverPort = port;
- _start(hostAddress, tcpPort, listenBacklog);
- });
+ _serverPort = serverPort {
// We can only guess this is the right URL. At least it gives a
// hint to the user.
print('Server starting http://${hostAddress}:${tcpPort}/');
+ _start(hostAddress, tcpPort, listenBacklog);
}
void _start(String hostAddress, int tcpPort, int listenBacklog) {
@@ -287,7 +292,7 @@ class ChatServerStatus {
}
-class IsolatedServer extends Isolate {
+class IsolatedServer {
static final String redirectPageHtml = """
<html>
<head><title>Welcome to the dart server</title></head>
@@ -520,7 +525,7 @@ class IsolatedServer extends Isolate {
};
}
- void main() {
+ void init() {
_logRequests = false;
_topic = new Topic();
_serverStart = new Date.now();
@@ -530,76 +535,76 @@ class IsolatedServer extends Isolate {
// Start a timer for cleanup events.
_cleanupTimer =
new Timer.repeating(10000, (timer) => _topic._handleTimer(timer));
+ }
- // Start timer for periodic logging.
- void _handleLogging(Timer timer) {
- if (_logging) {
- print("${_messageRate.rate} messages/s "
- "(total $_messageCount messages)");
- }
+ // Start timer for periodic logging.
+ void _handleLogging(Timer timer) {
+ if (_logging) {
+ print("${_messageRate.rate} messages/s "
+ "(total $_messageCount messages)");
}
+ }
- this.port.receive((var message, SendPort replyTo) {
- if (message.isStart) {
- _host = message.host;
- _port = message.port;
- _logging = message.logging;
- replyTo.send(new ChatServerStatus.starting(), null);
- _server = new HttpServer();
- _server.defaultRequestHandler = _notFoundHandler;
- _server.addRequestHandler(
- (request) => request.path == "/",
- (HttpRequest request, HttpResponse response) =>
- redirectPageHandler(
- request, response, "dart_client/index.html"));
- _server.addRequestHandler(
- (request) => request.path == "/js_client/index.html",
- (HttpRequest request, HttpResponse response) =>
- fileHandler(request, response));
- _server.addRequestHandler(
- (request) => request.path == "/js_client/code.js",
- (HttpRequest request, HttpResponse response) =>
- fileHandler(request, response));
- _server.addRequestHandler(
- (request) => request.path == "/dart_client/index.html",
- (HttpRequest request, HttpResponse response) =>
- fileHandler(request, response));
- _server.addRequestHandler(
- (request) => request.path == "/out.js",
- (HttpRequest request, HttpResponse response) =>
- fileHandler(request, response));
- _server.addRequestHandler(
- (request) => request.path == "/favicon.ico",
- (HttpRequest request, HttpResponse response) =>
- fileHandler(request, response, "static/favicon.ico"));
-
- _server.addRequestHandler(
- (request) => request.path == "/join", _joinHandler);
- _server.addRequestHandler(
- (request) => request.path == "/leave", _leaveHandler);
- _server.addRequestHandler(
- (request) => request.path == "/message", _messageHandler);
- _server.addRequestHandler(
- (request) => request.path == "/receive", _receiveHandler);
- try {
- _server.listen(_host, _port, backlog: message.backlog);
- replyTo.send(new ChatServerStatus.started(_server.port), null);
- _loggingTimer = new Timer.repeating(1000, _handleLogging);
- } catch (var e) {
- replyTo.send(new ChatServerStatus.error(e.toString()), null);
- }
- } else if (message.isStop) {
- replyTo.send(new ChatServerStatus.stopping(), null);
- stop();
- replyTo.send(new ChatServerStatus.stopped(), null);
+ void dispatch(message, replyTo) {
+ if (message.isStart) {
+ _host = message.host;
+ _port = message.port;
+ _logging = message.logging;
+ replyTo.send(new ChatServerStatus.starting(), null);
+ _server = new HttpServer();
+ _server.defaultRequestHandler = _notFoundHandler;
+ _server.addRequestHandler(
+ (request) => request.path == "/",
+ (HttpRequest request, HttpResponse response) =>
+ redirectPageHandler(
+ request, response, "dart_client/index.html"));
+ _server.addRequestHandler(
+ (request) => request.path == "/js_client/index.html",
+ (HttpRequest request, HttpResponse response) =>
+ fileHandler(request, response));
+ _server.addRequestHandler(
+ (request) => request.path == "/js_client/code.js",
+ (HttpRequest request, HttpResponse response) =>
+ fileHandler(request, response));
+ _server.addRequestHandler(
+ (request) => request.path == "/dart_client/index.html",
+ (HttpRequest request, HttpResponse response) =>
+ fileHandler(request, response));
+ _server.addRequestHandler(
+ (request) => request.path == "/out.js",
+ (HttpRequest request, HttpResponse response) =>
+ fileHandler(request, response));
+ _server.addRequestHandler(
+ (request) => request.path == "/favicon.ico",
+ (HttpRequest request, HttpResponse response) =>
+ fileHandler(request, response, "static/favicon.ico"));
+
+ _server.addRequestHandler(
+ (request) => request.path == "/join", _joinHandler);
+ _server.addRequestHandler(
+ (request) => request.path == "/leave", _leaveHandler);
+ _server.addRequestHandler(
+ (request) => request.path == "/message", _messageHandler);
+ _server.addRequestHandler(
+ (request) => request.path == "/receive", _receiveHandler);
+ try {
+ _server.listen(_host, _port, backlog: message.backlog);
+ replyTo.send(new ChatServerStatus.started(_server.port), null);
+ _loggingTimer = new Timer.repeating(1000, _handleLogging);
+ } catch (var e) {
+ replyTo.send(new ChatServerStatus.error(e.toString()), null);
}
- });
+ } else if (message.isStop) {
+ replyTo.send(new ChatServerStatus.stopping(), null);
+ stop();
+ replyTo.send(new ChatServerStatus.stopped(), null);
+ }
}
stop() {
_server.close();
_cleanupTimer.cancel();
- this.port.close();
+ port.close();
}
String _host;
« runtime/vm/snapshot_test.dart ('K') | « samples/chat/chat_server.dart ('k') | samples/dartcombat/player.dart » ('j') | samples/dartcombat/player.dart » ('J')

Powered by Google App Engine
This is Rietveld 408576698