| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 define('data_sender', [ | 5 define('data_sender', [ |
| 6 'async_waiter', | 6 'async_waiter', |
| 7 'device/serial/data_stream.mojom', | 7 'device/serial/data_stream.mojom', |
| 8 'device/serial/data_stream_serialization.mojom', | 8 'device/serial/data_stream_serialization.mojom', |
| 9 'mojo/public/js/bindings/core', | 9 'mojo/public/js/bindings/core', |
| 10 'mojo/public/js/bindings/router', | 10 'mojo/public/js/bindings/router', |
| (...skipping 164 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 175 flags: core.CREATE_DATA_PIPE_OPTIONS_FLAG_NONE, | 175 flags: core.CREATE_DATA_PIPE_OPTIONS_FLAG_NONE, |
| 176 elementNumBytes: 1, | 176 elementNumBytes: 1, |
| 177 capacityNumBytes: bufferSize, | 177 capacityNumBytes: bufferSize, |
| 178 }; | 178 }; |
| 179 var sendPipe = core.createDataPipe(dataPipeOptions); | 179 var sendPipe = core.createDataPipe(dataPipeOptions); |
| 180 this.init_(handle, sendPipe.producerHandle, fatalErrorValue); | 180 this.init_(handle, sendPipe.producerHandle, fatalErrorValue); |
| 181 this.sink_.init(sendPipe.consumerHandle); | 181 this.sink_.init(sendPipe.consumerHandle); |
| 182 } | 182 } |
| 183 | 183 |
| 184 DataSender.prototype = | 184 DataSender.prototype = |
| 185 $Object.create(dataStreamMojom.DataSinkClientStub.prototype); | 185 $Object.create(dataStreamMojom.DataSinkClient.stubClass.prototype); |
| 186 | 186 |
| 187 /** | 187 /** |
| 188 * Closes this DataSender. | 188 * Closes this DataSender. |
| 189 */ | 189 */ |
| 190 DataSender.prototype.close = function() { | 190 DataSender.prototype.close = function() { |
| 191 if (this.shutDown_) | 191 if (this.shutDown_) |
| 192 return; | 192 return; |
| 193 this.shutDown_ = true; | 193 this.shutDown_ = true; |
| 194 this.waiter_.stop(); | 194 this.waiter_.stop(); |
| 195 this.router_.close(); | 195 this.router_.close(); |
| (...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 235 /** | 235 /** |
| 236 * The [Router]{@link module:mojo/public/js/bindings/router.Router} for the | 236 * The [Router]{@link module:mojo/public/js/bindings/router.Router} for the |
| 237 * connection to the DataSink. | 237 * connection to the DataSink. |
| 238 * @private | 238 * @private |
| 239 */ | 239 */ |
| 240 this.router_ = new routerModule.Router(sink); | 240 this.router_ = new routerModule.Router(sink); |
| 241 /** | 241 /** |
| 242 * The connection to the DataSink. | 242 * The connection to the DataSink. |
| 243 * @private | 243 * @private |
| 244 */ | 244 */ |
| 245 this.sink_ = new dataStreamMojom.DataSinkProxy(this.router_); | 245 this.sink_ = new dataStreamMojom.DataSink.proxyClass(this.router_); |
| 246 this.router_.setIncomingReceiver(this); | 246 this.router_.setIncomingReceiver(this); |
| 247 /** | 247 /** |
| 248 * The async waiter used to wait for | 248 * The async waiter used to wait for |
| 249 * {@link module:data_sender.DataSender#sendPipe_} to be writable. | 249 * {@link module:data_sender.DataSender#sendPipe_} to be writable. |
| 250 * @type {!module:async_waiter.AsyncWaiter} | 250 * @type {!module:async_waiter.AsyncWaiter} |
| 251 * @private | 251 * @private |
| 252 */ | 252 */ |
| 253 this.waiter_ = new asyncWaiter.AsyncWaiter( | 253 this.waiter_ = new asyncWaiter.AsyncWaiter( |
| 254 this.sendPipe_, core.HANDLE_SIGNAL_WRITABLE, | 254 this.sendPipe_, core.HANDLE_SIGNAL_WRITABLE, |
| 255 this.onHandleReady_.bind(this)); | 255 this.onHandleReady_.bind(this)); |
| (...skipping 212 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 468 // Note: Only the first PendingSend in |pendingSends_| will have data to | 468 // Note: Only the first PendingSend in |pendingSends_| will have data to |
| 469 // flush as only the first can have written data to the data pipe. | 469 // flush as only the first can have written data to the data pipe. |
| 470 bytesToFlush += result.bytesToFlush; | 470 bytesToFlush += result.bytesToFlush; |
| 471 } | 471 } |
| 472 this.callCancelCallback_(); | 472 this.callCancelCallback_(); |
| 473 return Promise.resolve({bytes_to_flush: bytesToFlush}); | 473 return Promise.resolve({bytes_to_flush: bytesToFlush}); |
| 474 }; | 474 }; |
| 475 | 475 |
| 476 return {DataSender: DataSender}; | 476 return {DataSender: DataSender}; |
| 477 }); | 477 }); |
| OLD | NEW |