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

Unified Diff: mojo/public/bindings/js/connector.js

Issue 223233002: Mojo: Move mojo/public/bindings/js to mojo/public/js/bindings. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: rebase & restore ordering Created 6 years, 9 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 side-by-side diff with in-line comments
Download patch
« no previous file with comments | « mojo/public/bindings/js/connection.js ('k') | mojo/public/bindings/js/constants.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: mojo/public/bindings/js/connector.js
diff --git a/mojo/public/bindings/js/connector.js b/mojo/public/bindings/js/connector.js
deleted file mode 100644
index 2aa9a9f23f428a67518c5d7bd317adab15a1ba29..0000000000000000000000000000000000000000
--- a/mojo/public/bindings/js/connector.js
+++ /dev/null
@@ -1,103 +0,0 @@
-// 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("mojo/public/bindings/js/connector", [
- "mojo/public/bindings/js/codec",
- "mojo/bindings/js/core",
- "mojo/bindings/js/support",
-], function(codec, core, support) {
-
- function Connector(handle) {
- this.handle_ = handle;
- this.dropWrites_ = false;
- this.error_ = false;
- this.incomingReceiver_ = null;
- this.readWaitCookie_ = null;
-
- this.waitToReadMore_();
- }
-
- Connector.prototype.close = function() {
- if (this.readWaitCookie_) {
- support.cancelWait(this.readWaitCookie_);
- this.readWaitCookie_ = null;
- }
- if (this.handle_ != core.kInvalidHandle) {
- core.close(this.handle_);
- this.handle_ = core.kInvalidHandle;
- }
- };
-
- Connector.prototype.accept = function(message) {
- if (this.error_)
- return false;
-
- if (this.dropWrites_)
- return true;
-
- var result = core.writeMessage(this.handle_,
- message.memory,
- message.handles,
- core.WRITE_MESSAGE_FLAG_NONE);
-
- switch (result) {
- case core.RESULT_OK:
- // The handles were successfully transferred, so we don't own them
- // anymore.
- message.handles = [];
- break;
- case core.RESULT_FAILED_PRECONDITION:
- // There's no point in continuing to write to this pipe since the other
- // end is gone. Avoid writing any future messages. Hide write failures
- // from the caller since we'd like them to continue consuming any
- // backlog of incoming messages before regarding the message pipe as
- // closed.
- this.dropWrites_ = true;
- break;
- default:
- // This particular write was rejected, presumably because of bad input.
- // The pipe is not necessarily in a bad state.
- return false;
- }
- return true;
- };
-
- Connector.prototype.setIncomingReceiver = function(receiver) {
- this.incomingReceiver_ = receiver;
- };
-
- Connector.prototype.encounteredError = function() {
- return this.error_;
- }
-
- Connector.prototype.waitToReadMore_ = function() {
- this.readWaitCookie_ = support.asyncWait(this.handle_,
- core.WAIT_FLAG_READABLE,
- this.readMore_.bind(this));
- };
-
- Connector.prototype.readMore_ = function(result) {
- for (;;) {
- var read = core.readMessage(this.handle_,
- core.READ_MESSAGE_FLAG_NONE);
- if (read.result == core.RESULT_SHOULD_WAIT) {
- this.waitToReadMore_();
- return;
- }
- if (read.result != core.RESULT_OK) {
- this.error_ = true;
- return;
- }
- // TODO(abarth): Should core.readMessage return a Uint8Array?
- var memory = new Uint8Array(read.buffer);
- var message = new codec.Message(memory, read.handles);
- if (this.incomingReceiver_)
- this.incomingReceiver_.accept(message);
- }
- };
-
- var exports = {};
- exports.Connector = Connector;
- return exports;
-});
« no previous file with comments | « mojo/public/bindings/js/connection.js ('k') | mojo/public/bindings/js/constants.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698