Add serialization support to the JS DataSender and DataReceiver.

extensions/renderer/resources/data_receiver.js

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 define('data_receiver', [
     'async_waiter',
     'device/serial/data_stream.mojom',
     'mojo/public/js/bindings/core',
     'mojo/public/js/bindings/router',
 ], function(asyncWaiter, dataStream, core, router) {
@@ skipping 174 matching lines @@
     this.shutDown_ = true;
     this.router_.close();
     this.waiter_.stop();
     core.close(this.receivePipe_);
     if (this.receive_) {
       this.receive_.dispatchFatalError(this.fatalErrorValue_);
       this.receive_ = null;
     }
   };
 
+  DataReceiver.prototype.serialize = function() {

[raymes, 2014/09/17 02:05:04]

Please add comments to these :)

[Sam McNally, 2014/09/17 08:07:14]

Done.

+    this.waiter_.stop();
+    if (this.receive_) {
+      this.receive_.dispatchFatalError(this.fatalErrorValue_);
+      this.receive_ = null;
+    }
+    var serialized = {
+      source: this.router_.connector_.handle_,
+      data_pipe: this.receivePipe_,
+      fatal_error_value: this.fatalErrorValue_,
+      bytes_received: this.bytesReceived_,
+      paused: this.paused_,
+      shut_down: this.shutDown_,
+    };
+    this.router_.connector_.handle_ = null;
+    this.router_.close();
+    this.shutDown_ = true;
+    return Promise.resolve(serialized);
+  };
+
+  DataReceiver.deserialize = function(serialized) {
+    var receiver = $Object.create(DataReceiver.prototype);
+    receiver.deserialize_(serialized);
+    return receiver;
+  };
+
+  DataReceiver.prototype.deserialize_ = function(serialized) {
+    this.receivePipe_ = serialized.data_pipe;
+    this.fatalErrorValue_ = serialized.fatal_error_value;
+    this.bytesReceived_ = serialized.bytes_received;
+    this.paused_ = serialized.paused;
+    this.shutDown_ = serialized.shut_down;
+    this.router_ = new router.Router(serialized.source);
+    this.router_.setIncomingReceiver(this);
+    this.source_ = new dataStream.DataSourceProxy(this.router_);
+    this.waiter_ = new asyncWaiter.AsyncWaiter(this.receivePipe_,
+                                               core.HANDLE_SIGNAL_READABLE,
+                                               this.onHandleReady_.bind(this));
+  };
+
   /**
    * Receive data from the DataSource.
    * @return {Promise.<ArrayBuffer>} A promise to the received data. If an error
    *     occurs, the promise will reject with an Error object with a property
    *     error containing the error code.
    * @throws Will throw if this has encountered a fatal error or another receive
    *     is in progress.
    */
   DataReceiver.prototype.receive = function() {
     if (this.shutDown_)
@@ skipping 63 matching lines @@
       this.receive_ = null;
       this.waiter_.stop();
       this.paused_ = true;
       return;
     }
     this.pendingError_ = pendingError;
   };
 
   return {DataReceiver: DataReceiver};
 });