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

Side by Side Diff: sdk/lib/html/src/Isolates.dart

Issue 11453027: Fixed a lot of dartanalyzer static analysis issues with the html lib. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 8 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
OLDNEW
1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file 1 // Copyright (c) 2012, 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 html; 5 part of html;
6 6
7 _serialize(var message) { 7 _serialize(var message) {
8 return new _JsSerializer().traverse(message); 8 return new _JsSerializer().traverse(message);
9 } 9 }
10 10
11 class _JsSerializer extends _Serializer { 11 class _JsSerializer extends _Serializer {
12 12
13 visitSendPortSync(SendPortSync x) { 13 visitSendPortSync(SendPortSync x) {
14 if (x is _JsSendPortSync) return visitJsSendPortSync(x); 14 if (x is _JsSendPortSync) return visitJsSendPortSync(x);
15 if (x is _LocalSendPortSync) return visitLocalSendPortSync(x); 15 if (x is _LocalSendPortSync) return visitLocalSendPortSync(x);
16 if (x is _RemoteSendPortSync) return visitRemoteSendPortSync(x); 16 if (x is _RemoteSendPortSync) return visitRemoteSendPortSync(x);
17 throw "Unknown port type $x"; 17 throw "Unknown port type $x";
18 } 18 }
19 19
20 visitJsSendPortSync(_JsSendPortSync x) { 20 visitJsSendPortSync(_JsSendPortSync x) {
21 return [ 'sendport', 'nativejs', x._id ]; 21 return [ 'sendport', 'nativejs', x._id ];
22 } 22 }
23 23
24 visitLocalSendPortSync(_LocalSendPortSync x) { 24 visitLocalSendPortSync(_LocalSendPortSync x) {
25 return [ 'sendport', 'dart', 25 return [ 'sendport', 'dart',
26 ReceivePortSync._isolateId, x._receivePort._portId ]; 26 ReceivePortSync._isolateId, x._receivePort._portId ];
27 } 27 }
28 28
29 visitSendPort(SendPort x) {
30 throw new UnimplementedError('Asynchronous send port not yet implemented.');
31 }
32
29 visitRemoteSendPortSync(_RemoteSendPortSync x) { 33 visitRemoteSendPortSync(_RemoteSendPortSync x) {
30 return [ 'sendport', 'dart', 34 return [ 'sendport', 'dart',
Anton Muhin 2012/12/06 14:50:40 that probably fits a single line now. Maybe even
31 x._receivePort._isolateId, x._receivePort._portId ]; 35 x._isolateId, x._portId ];
32 } 36 }
33 } 37 }
34 38
35 _deserialize(var message) { 39 _deserialize(var message) {
36 return new _JsDeserializer().deserialize(message); 40 return new _JsDeserializer().deserialize(message);
37 } 41 }
38 42
39 43
40 class _JsDeserializer extends _Deserializer { 44 class _JsDeserializer extends _Deserializer {
41 45
(...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after
79 int _portId; 83 int _portId;
80 _RemoteSendPortSync(this._isolateId, this._portId); 84 _RemoteSendPortSync(this._isolateId, this._portId);
81 85
82 callSync(var message) { 86 callSync(var message) {
83 var serialized = _serialize(message); 87 var serialized = _serialize(message);
84 var result = _call(_isolateId, _portId, serialized); 88 var result = _call(_isolateId, _portId, serialized);
85 return _deserialize(result); 89 return _deserialize(result);
86 } 90 }
87 91
88 static _call(int isolateId, int portId, var message) { 92 static _call(int isolateId, int portId, var message) {
89 var target = 'dart-port-$isolateId-$portId'; 93 var target = 'dart-port-$isolateId-$portId';
90 // TODO(vsm): Make this re-entrant. 94 // TODO(vsm): Make this re-entrant.
91 // TODO(vsm): Set this up set once, on the first call. 95 // TODO(vsm): Set this up set once, on the first call.
92 var source = '$target-result'; 96 var source = '$target-result';
93 var result = null; 97 var result = null;
94 var listener = (Event e) { 98 var listener = (Event e) {
95 result = JSON.parse(_getPortSyncEventData(e)); 99 result = JSON.parse(_getPortSyncEventData(e));
96 }; 100 };
97 window.on[source].add(listener); 101 window.on[source].add(listener);
98 _dispatchEvent(target, [source, message]); 102 _dispatchEvent(target, [source, message]);
99 window.on[source].remove(listener); 103 window.on[source].remove(listener);
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after
144 _portIdCount = 0; 148 _portIdCount = 0;
145 _portMap = new Map<int, ReceivePortSync>(); 149 _portMap = new Map<int, ReceivePortSync>();
146 } 150 }
147 _portId = _portIdCount++; 151 _portId = _portIdCount++;
148 _portMap[_portId] = this; 152 _portMap[_portId] = this;
149 } 153 }
150 154
151 static int get _isolateId { 155 static int get _isolateId {
152 // TODO(vsm): Make this coherent with existing isolate code. 156 // TODO(vsm): Make this coherent with existing isolate code.
153 if (_cachedIsolateId == null) { 157 if (_cachedIsolateId == null) {
154 _cachedIsolateId = _getNewIsolateId(); 158 _cachedIsolateId = _getNewIsolateId();
155 } 159 }
156 return _cachedIsolateId; 160 return _cachedIsolateId;
157 } 161 }
158 162
159 static String _getListenerName(isolateId, portId) => 163 static String _getListenerName(isolateId, portId) =>
160 'dart-port-$isolateId-$portId'; 164 'dart-port-$isolateId-$portId';
161 String get _listenerName => _getListenerName(_isolateId, _portId); 165 String get _listenerName => _getListenerName(_isolateId, _portId);
162 166
163 void receive(callback(var message)) { 167 void receive(callback(var message)) {
164 _callback = callback; 168 _callback = callback;
165 if (_listener == null) { 169 if (_listener == null) {
166 _listener = (Event e) { 170 _listener = (Event e) {
167 var data = JSON.parse(_getPortSyncEventData(e)); 171 var data = JSON.parse(_getPortSyncEventData(e));
168 var replyTo = data[0]; 172 var replyTo = data[0];
169 var message = _deserialize(data[1]); 173 var message = _deserialize(data[1]);
170 var result = _callback(message); 174 var result = _callback(message);
(...skipping 22 matching lines...) Expand all
193 } 197 }
194 198
195 get _isolateId => ReceivePortSync._isolateId; 199 get _isolateId => ReceivePortSync._isolateId;
196 200
197 void _dispatchEvent(String receiver, var message) { 201 void _dispatchEvent(String receiver, var message) {
198 var event = new CustomEvent(receiver, false, false, JSON.stringify(message)); 202 var event = new CustomEvent(receiver, false, false, JSON.stringify(message));
199 window.$dom_dispatchEvent(event); 203 window.$dom_dispatchEvent(event);
200 } 204 }
201 205
202 String _getPortSyncEventData(CustomEvent event) => event.detail; 206 String _getPortSyncEventData(CustomEvent event) => event.detail;
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698