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

Side by Side Diff: pkg/browser/lib/interop.js

Issue 26092003: Maintain referential integrity of proxy instances in dart:js (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 7 years, 2 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 unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « no previous file | sdk/lib/js/dart2js/js_dart2js.dart » ('j') | sdk/lib/js/dart2js/js_dart2js.dart » ('J')
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 // --------------------------------------------------------------------------- 5 // ---------------------------------------------------------------------------
6 // Support for JS interoperability 6 // Support for JS interoperability
7 // --------------------------------------------------------------------------- 7 // ---------------------------------------------------------------------------
8 function SendPortSync() { 8 function SendPortSync() {
9 } 9 }
10 10
11 function ReceivePortSync() { 11 function ReceivePortSync() {
12 this.id = ReceivePortSync.id++; 12 this.id = ReceivePortSync.id++;
13 ReceivePortSync.map[this.id] = this; 13 ReceivePortSync.map[this.id] = this;
14 } 14 }
15 15
16 // Type for remote proxies to Dart objects with dart2js. 16 // Type for remote proxies to Dart objects with dart2js.
17 function DartProxy(o) { 17 function DartObject(o) {
18 this.o = o; 18 this.o = o;
19 } 19 }
20 20
21 (function() { 21 (function() {
22 // Serialize the following types as follows: 22 // Serialize the following types as follows:
23 // - primitives / null: unchanged 23 // - primitives / null: unchanged
24 // - lists: [ 'list', internal id, list of recursively serialized elements ] 24 // - lists: [ 'list', internal id, list of recursively serialized elements ]
25 // - maps: [ 'map', internal id, map of keys and recursively serialized value s ] 25 // - maps: [ 'map', internal id, map of keys and recursively serialized value s ]
26 // - send ports: [ 'sendport', type, isolate id, port id ] 26 // - send ports: [ 'sendport', type, isolate id, port id ]
27 // 27 //
(...skipping 215 matching lines...) Expand 10 before | Expand all | Expand 10 after
243 this.port = new ReceivePortSync(); 243 this.port = new ReceivePortSync();
244 this.sendPort = this.port.toSendPort(); 244 this.sendPort = this.port.toSendPort();
245 } 245 }
246 246
247 // Number of valid IDs. This is the number of objects (global and local) 247 // Number of valid IDs. This is the number of objects (global and local)
248 // kept alive by this table. 248 // kept alive by this table.
249 ProxiedObjectTable.prototype.count = function () { 249 ProxiedObjectTable.prototype.count = function () {
250 return Object.keys(this.map).length; 250 return Object.keys(this.map).length;
251 } 251 }
252 252
253 var _dartRefPropertyName = "_$dart_ref";
254
253 // Adds an object to the table and return an ID for serialization. 255 // Adds an object to the table and return an ID for serialization.
254 ProxiedObjectTable.prototype.add = function (obj) { 256 ProxiedObjectTable.prototype.add = function (obj) {
255 for (var ref in this.map) { 257 var ref = obj[_dartRefPropertyName];
256 var o = this.map[ref]; 258 if (ref == null) {
257 if (o === obj) { 259 ref = this.name + '-' + this._nextId++;
258 return ref; 260 this.map[ref] = obj;
259 } 261 Object.defineProperty(obj, _dartRefPropertyName, { value: ref });
260 } 262 }
261 var ref = this.name + '-' + this._nextId++;
262 this.map[ref] = obj;
263 return ref; 263 return ref;
264 } 264 }
265 265
266 // Gets the object or function corresponding to this ID. 266 // Gets the object or function corresponding to this ID.
267 ProxiedObjectTable.prototype.get = function (id) { 267 ProxiedObjectTable.prototype.get = function (id) {
268 if (!this.map.hasOwnProperty(id)) { 268 if (!this.map.hasOwnProperty(id)) {
269 throw 'Proxy ' + id + ' has been invalidated.' 269 throw 'Proxy ' + id + ' has been invalidated.'
270 } 270 }
271 return this.map[id]; 271 return this.map[id];
272 } 272 }
(...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after
321 return [ 'throws', e.toString() ]; 321 return [ 'throws', e.toString() ];
322 } 322 }
323 }); 323 });
324 } 324 }
325 325
326 // Singleton for local proxied objects. 326 // Singleton for local proxied objects.
327 var proxiedObjectTable = new ProxiedObjectTable(); 327 var proxiedObjectTable = new ProxiedObjectTable();
328 proxiedObjectTable._initialize() 328 proxiedObjectTable._initialize()
329 329
330 // Type for remote proxies to Dart objects. 330 // Type for remote proxies to Dart objects.
331 function DartProxy(id, sendPort) { 331 function DartObject(id, sendPort) {
332 this.id = id; 332 this.id = id;
333 this.port = sendPort; 333 this.port = sendPort;
334 } 334 }
335 335
336 // Serializes JS types to SendPortSync format: 336 // Serializes JS types to SendPortSync format:
337 // - primitives -> primitives 337 // - primitives -> primitives
338 // - sendport -> sendport 338 // - sendport -> sendport
339 // - Function -> [ 'funcref', function-id, sendport ] 339 // - Function -> [ 'funcref', function-id, sendport ]
340 // - Object -> [ 'objref', object-id, sendport ] 340 // - Object -> [ 'objref', object-id, sendport ]
341 function serialize(message) { 341 function serialize(message) {
(...skipping 12 matching lines...) Expand all
354 // Remote function proxy. 354 // Remote function proxy.
355 var remoteId = message._dart_id; 355 var remoteId = message._dart_id;
356 var remoteSendPort = message._dart_port; 356 var remoteSendPort = message._dart_port;
357 return [ 'funcref', remoteId, remoteSendPort ]; 357 return [ 'funcref', remoteId, remoteSendPort ];
358 } else { 358 } else {
359 // Local function proxy. 359 // Local function proxy.
360 return [ 'funcref', 360 return [ 'funcref',
361 proxiedObjectTable.add(message), 361 proxiedObjectTable.add(message),
362 proxiedObjectTable.sendPort ]; 362 proxiedObjectTable.sendPort ];
363 } 363 }
364 } else if (message instanceof DartProxy) { 364 } else if (message instanceof DartObject) {
365 // Remote object proxy. 365 // Remote object proxy.
366 return [ 'objref', message.id, message.port ]; 366 return [ 'objref', message.id, message.port ];
367 } else { 367 } else {
368 // Local object proxy. 368 // Local object proxy.
369 return [ 'objref', 369 return [ 'objref',
370 proxiedObjectTable.add(message), 370 proxiedObjectTable.add(message),
371 proxiedObjectTable.sendPort ]; 371 proxiedObjectTable.sendPort ];
372 } 372 }
373 } 373 }
374 374
(...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after
410 if (result[0] == 'throws') throw deserialize(result[1]); 410 if (result[0] == 'throws') throw deserialize(result[1]);
411 return deserialize(result[1]); 411 return deserialize(result[1]);
412 }; 412 };
413 // Cache the remote id and port. 413 // Cache the remote id and port.
414 f._dart_id = id; 414 f._dart_id = id;
415 f._dart_port = port; 415 f._dart_port = port;
416 return f; 416 return f;
417 } 417 }
418 } 418 }
419 419
420 // Creates a DartProxy to forwards to the remote object. 420 // Creates a DartObject to forwards to the remote object.
421 function deserializeObject(message) { 421 function deserializeObject(message) {
422 var id = message[1]; 422 var id = message[1];
423 var port = message[2]; 423 var port = message[2];
424 // TODO(vsm): Add a more robust check for a local SendPortSync. 424 // TODO(vsm): Add a more robust check for a local SendPortSync.
425 if ("receivePort" in port) { 425 if ("receivePort" in port) {
426 // Local object. 426 // Local object.
427 return proxiedObjectTable.get(id); 427 return proxiedObjectTable.get(id);
428 } else { 428 } else {
429 // Remote object. 429 // Remote object.
430 return new DartProxy(id, port); 430 return new DartObject(id, port);
431 } 431 }
432 } 432 }
433 433
434 // Remote handler to construct a new JavaScript object given its 434 // Remote handler to construct a new JavaScript object given its
435 // serialized constructor and arguments. 435 // serialized constructor and arguments.
436 function construct(args) { 436 function construct(args) {
437 args = args.map(deserialize); 437 args = args.map(deserialize);
438 var constructor = args[0]; 438 var constructor = args[0];
439 args = Array.prototype.slice.call(args, 1); 439 args = Array.prototype.slice.call(args, 1);
440 440
(...skipping 91 matching lines...) Expand 10 before | Expand all | Expand 10 after
532 port.receive(f); 532 port.receive(f);
533 window.registerPort(name, port.toSendPort()); 533 window.registerPort(name, port.toSendPort());
534 } 534 }
535 535
536 makeGlobalPort('dart-js-context', context); 536 makeGlobalPort('dart-js-context', context);
537 makeGlobalPort('dart-js-create', construct); 537 makeGlobalPort('dart-js-create', construct);
538 makeGlobalPort('dart-js-instanceof', proxyInstanceof); 538 makeGlobalPort('dart-js-instanceof', proxyInstanceof);
539 makeGlobalPort('dart-js-delete-property', proxyDeleteProperty); 539 makeGlobalPort('dart-js-delete-property', proxyDeleteProperty);
540 makeGlobalPort('dart-js-convert', proxyConvert); 540 makeGlobalPort('dart-js-convert', proxyConvert);
541 })(); 541 })();
OLDNEW
« no previous file with comments | « no previous file | sdk/lib/js/dart2js/js_dart2js.dart » ('j') | sdk/lib/js/dart2js/js_dart2js.dart » ('J')

Powered by Google App Engine
This is Rietveld 408576698