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

Side by Side Diff: runtime/bin/vmservice/server.dart

Issue 106193003: Cleanup VM service (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 7 years 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 | « runtime/bin/vmservice/running_isolates.dart ('k') | runtime/bin/vmservice/service_request.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) 2013, the Dart project authors. Please see the AUTHORS file 1 // Copyright (c) 2013, 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 part of vmservice_io; 5 part of vmservice_io;
6 6
7 class Server { 7 class Server {
8 int port; 8 int port;
9 static ContentType jsonContentType = ContentType.parse('application/json'); 9 static ContentType jsonContentType = ContentType.parse('application/json');
10 final VmService service; 10 final VmService service;
11 HttpServer _server; 11 HttpServer _server;
12 12
13 Server(this.service, this.port); 13 Server(this.service, this.port);
14 14
15 void _sendResponse(HttpRequest request, String response) {
16 request.response..headers.contentType = jsonContentType
17 ..write(response)
18 ..close();
19 }
20
15 void _requestHandler(HttpRequest request) { 21 void _requestHandler(HttpRequest request) {
16 // Allow cross origin requests. 22 // Allow cross origin requests.
17 request.response.headers.add('Access-Control-Allow-Origin', '*'); 23 request.response.headers.add('Access-Control-Allow-Origin', '*');
18 24
19 final String path = 25 final String path =
20 request.uri.path == '/' ? '/index.html' : request.uri.path; 26 request.uri.path == '/' ? '/index.html' : request.uri.path;
21 27
22 var resource = Resource.resources[path]; 28 var resource = Resource.resources[path];
23 if (resource != null) { 29 if (resource != null) {
24 // Serving up a static resource (e.g. .css, .html, .png). 30 // Serving up a static resource (e.g. .css, .html, .png).
25 request.response.headers.contentType = 31 request.response.headers.contentType =
26 ContentType.parse(resource.mimeType); 32 ContentType.parse(resource.mimeType);
27 request.response.add(resource.data); 33 request.response.add(resource.data);
28 request.response.close(); 34 request.response.close();
29 return; 35 return;
30 } 36 }
31 37
32 var serviceRequest = new ServiceRequest(); 38 var serviceRequest = new ServiceRequest();
33 var r = serviceRequest.parse(request.uri); 39 var r = serviceRequest.parse(request.uri);
34 if (!r) { 40 if (r) {
35 // Did not understand the request uri.
36 serviceRequest.setErrorResponse('Invalid request uri: ${request.uri}');
37 } else {
38 var f = service.runningIsolates.route(serviceRequest); 41 var f = service.runningIsolates.route(serviceRequest);
39 if (f != null) { 42 assert(f != null);
40 f.then((_) { 43 f.then((_) {
41 request.response.headers.contentType = jsonContentType; 44 _sendResponse(request, serviceRequest.response);
42 request.response.write(serviceRequest.response); 45 }).catchError((e) {
43 request.response.close(); 46 // Error replying over HTTP.
44 }).catchError((e) { }); 47 });
45 return; 48 return;
46 } else {
47 // Nothing responds to this type of request.
48 serviceRequest.setErrorResponse('No route for: $path');
49 }
50 } 49 }
51 50 _sendResponse(request, serviceRequest.response);
52 request.response.headers.contentType = jsonContentType;
53 request.response.write(serviceRequest.response);
54 request.response.close();
55 } 51 }
56 52
57 Future startServer() { 53 Future startServer() {
58 return HttpServer.bind(InternetAddress.LOOPBACK_IP_V4, port).then((s) { 54 return HttpServer.bind(InternetAddress.LOOPBACK_IP_V4, port).then((s) {
59 // Only display message when port is automatically selected. 55 // Only display message when port is automatically selected.
60 var display_message = (port == 0); 56 var display_message = (port == 0);
61 // Retrieve port. 57 // Retrieve port.
62 port = s.port; 58 port = s.port;
63 _server = s; 59 _server = s;
64 _server.listen(_requestHandler); 60 _server.listen(_requestHandler);
65 if (display_message) { 61 if (display_message) {
66 print('VmService listening on port $port'); 62 print('VmService listening on port $port');
67 } 63 }
68 return s; 64 return s;
69 }); 65 });
70 } 66 }
71 } 67 }
OLDNEW
« no previous file with comments | « runtime/bin/vmservice/running_isolates.dart ('k') | runtime/bin/vmservice/service_request.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698