| 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("mojo/public/js/bindings", [ | 5 (function() { |
| 6 "mojo/public/js/core", | 6 var internal = mojoBindings.internal; |
| 7 "mojo/public/js/lib/control_message_proxy", | |
| 8 "mojo/public/js/interface_types", | |
| 9 "mojo/public/js/router", | |
| 10 ], function(core, controlMessageProxy, types, router) { | |
| 11 | |
| 12 // --------------------------------------------------------------------------- | 7 // --------------------------------------------------------------------------- |
| 13 | 8 |
| 14 function makeRequest(interfacePtr) { | 9 function makeRequest(interfacePtr) { |
| 15 var pipe = core.createMessagePipe(); | 10 var pipe = Mojo.createMessagePipe(); |
| 16 interfacePtr.ptr.bind(new types.InterfacePtrInfo(pipe.handle0, 0)); | 11 interfacePtr.ptr.bind(new mojoBindings.InterfacePtrInfo(pipe.handle0, 0)); |
| 17 return new types.InterfaceRequest(pipe.handle1); | 12 return new mojoBindings.InterfaceRequest(pipe.handle1); |
| 18 } | 13 } |
| 19 | 14 |
| 20 // --------------------------------------------------------------------------- | 15 // --------------------------------------------------------------------------- |
| 21 | 16 |
| 22 // Operations used to setup/configure an interface pointer. Exposed as the | 17 // Operations used to setup/configure an interface pointer. Exposed as the |
| 23 // |ptr| field of generated interface pointer classes. | 18 // |ptr| field of generated interface pointer classes. |
| 24 // |ptrInfoOrHandle| could be omitted and passed into bind() later. | 19 // |ptrInfoOrHandle| could be omitted and passed into bind() later. |
| 25 function InterfacePtrController(interfaceType, ptrInfoOrHandle) { | 20 function InterfacePtrController(interfaceType, ptrInfoOrHandle) { |
| 26 this.version = 0; | 21 this.version = 0; |
| 27 | 22 |
| 28 this.interfaceType_ = interfaceType; | 23 this.interfaceType_ = interfaceType; |
| 29 this.router_ = null; | 24 this.router_ = null; |
| 30 this.proxy_ = null; | 25 this.proxy_ = null; |
| 31 | 26 |
| 32 // |router_| is lazily initialized. |handle_| is valid between bind() and | 27 // |router_| is lazily initialized. |handle_| is valid between bind() and |
| 33 // the initialization of |router_|. | 28 // the initialization of |router_|. |
| 34 this.handle_ = null; | 29 this.handle_ = null; |
| 35 this.controlMessageProxy_ = null; | 30 this.controlMessageProxy_ = null; |
| 36 | 31 |
| 37 if (ptrInfoOrHandle) | 32 if (ptrInfoOrHandle) |
| 38 this.bind(ptrInfoOrHandle); | 33 this.bind(ptrInfoOrHandle); |
| 39 } | 34 } |
| 40 | 35 |
| 41 InterfacePtrController.prototype.bind = function(ptrInfoOrHandle) { | 36 InterfacePtrController.prototype.bind = function(ptrInfoOrHandle) { |
| 42 this.reset(); | 37 this.reset(); |
| 43 | 38 |
| 44 if (ptrInfoOrHandle instanceof types.InterfacePtrInfo) { | 39 if (ptrInfoOrHandle instanceof mojoBindings.InterfacePtrInfo) { |
| 45 this.version = ptrInfoOrHandle.version; | 40 this.version = ptrInfoOrHandle.version; |
| 46 this.handle_ = ptrInfoOrHandle.handle; | 41 this.handle_ = ptrInfoOrHandle.handle; |
| 47 } else { | 42 } else { |
| 48 this.handle_ = ptrInfoOrHandle; | 43 this.handle_ = ptrInfoOrHandle; |
| 49 } | 44 } |
| 50 }; | 45 }; |
| 51 | 46 |
| 52 InterfacePtrController.prototype.isBound = function() { | 47 InterfacePtrController.prototype.isBound = function() { |
| 53 return this.router_ !== null || this.handle_ !== null; | 48 return this.router_ !== null || this.handle_ !== null; |
| 54 }; | 49 }; |
| 55 | 50 |
| 56 // Although users could just discard the object, reset() closes the pipe | 51 // Although users could just discard the object, reset() closes the pipe |
| 57 // immediately. | 52 // immediately. |
| 58 InterfacePtrController.prototype.reset = function() { | 53 InterfacePtrController.prototype.reset = function() { |
| 59 this.version = 0; | 54 this.version = 0; |
| 60 if (this.router_) { | 55 if (this.router_) { |
| 61 this.router_.close(); | 56 this.router_.close(); |
| 62 this.router_ = null; | 57 this.router_ = null; |
| 63 | 58 |
| 64 this.proxy_ = null; | 59 this.proxy_ = null; |
| 65 } | 60 } |
| 66 if (this.handle_) { | 61 if (this.handle_) { |
| 67 core.close(this.handle_); | 62 this.handle_.close(); |
| 68 this.handle_ = null; | 63 this.handle_ = null; |
| 69 } | 64 } |
| 70 }; | 65 }; |
| 71 | 66 |
| 72 InterfacePtrController.prototype.setConnectionErrorHandler | 67 InterfacePtrController.prototype.setConnectionErrorHandler |
| 73 = function(callback) { | 68 = function(callback) { |
| 74 if (!this.isBound()) | 69 if (!this.isBound()) |
| 75 throw new Error("Cannot set connection error handler if not bound."); | 70 throw new Error("Cannot set connection error handler if not bound."); |
| 76 | 71 |
| 77 this.configureProxyIfNecessary_(); | 72 this.configureProxyIfNecessary_(); |
| 78 this.router_.setErrorHandler(callback); | 73 this.router_.setErrorHandler(callback); |
| 79 }; | 74 }; |
| 80 | 75 |
| 81 InterfacePtrController.prototype.passInterface = function() { | 76 InterfacePtrController.prototype.passInterface = function() { |
| 82 var result; | 77 var result; |
| 83 if (this.router_) { | 78 if (this.router_) { |
| 84 // TODO(yzshen): Fix Router interface to support extracting handle. | 79 // TODO(yzshen): Fix Router interface to support extracting handle. |
| 85 result = new types.InterfacePtrInfo( | 80 result = new mojoBindings.InterfacePtrInfo( |
| 86 this.router_.connector_.handle_, this.version); | 81 this.router_.connector_.handle_, this.version); |
| 87 this.router_.connector_.handle_ = null; | 82 this.router_.connector_.handle_ = null; |
| 88 } else { | 83 } else { |
| 89 // This also handles the case when this object is not bound. | 84 // This also handles the case when this object is not bound. |
| 90 result = new types.InterfacePtrInfo(this.handle_, this.version); | 85 result = new mojoBindings.InterfacePtrInfo(this.handle_, this.version); |
| 91 this.handle_ = null; | 86 this.handle_ = null; |
| 92 } | 87 } |
| 93 | 88 |
| 94 this.reset(); | 89 this.reset(); |
| 95 return result; | 90 return result; |
| 96 }; | 91 }; |
| 97 | 92 |
| 98 InterfacePtrController.prototype.getProxy = function() { | 93 InterfacePtrController.prototype.getProxy = function() { |
| 99 this.configureProxyIfNecessary_(); | 94 this.configureProxyIfNecessary_(); |
| 100 return this.proxy_; | 95 return this.proxy_; |
| 101 }; | 96 }; |
| 102 | 97 |
| 103 InterfacePtrController.prototype.enableTestingMode = function() { | 98 InterfacePtrController.prototype.enableTestingMode = function() { |
| 104 this.configureProxyIfNecessary_(); | 99 this.configureProxyIfNecessary_(); |
| 105 return this.router_.enableTestingMode(); | 100 return this.router_.enableTestingMode(); |
| 106 }; | 101 }; |
| 107 | 102 |
| 108 InterfacePtrController.prototype.configureProxyIfNecessary_ = function() { | 103 InterfacePtrController.prototype.configureProxyIfNecessary_ = function() { |
| 109 if (!this.handle_) | 104 if (!this.handle_) |
| 110 return; | 105 return; |
| 111 | 106 |
| 112 this.router_ = new router.Router(this.handle_); | 107 this.router_ = new internal.Router(this.handle_); |
| 113 this.handle_ = null; | 108 this.handle_ = null; |
| 114 this.router_ .setPayloadValidators([this.interfaceType_.validateResponse]); | 109 this.router_ .setPayloadValidators([this.interfaceType_.validateResponse]); |
| 115 | 110 |
| 116 this.controlMessageProxy_ = new | 111 this.controlMessageProxy_ = new internal.ControlMessageProxy(this.router_); |
| 117 controlMessageProxy.ControlMessageProxy(this.router_); | |
| 118 | 112 |
| 119 this.proxy_ = new this.interfaceType_.proxyClass(this.router_); | 113 this.proxy_ = new this.interfaceType_.proxyClass(this.router_); |
| 120 }; | 114 }; |
| 121 | 115 |
| 122 InterfacePtrController.prototype.queryVersion = function() { | 116 InterfacePtrController.prototype.queryVersion = function() { |
| 123 function onQueryVersion(version) { | 117 function onQueryVersion(version) { |
| 124 this.version = version; | 118 this.version = version; |
| 125 return version; | 119 return version; |
| 126 } | 120 } |
| 127 | 121 |
| (...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 172 Binding.prototype.createInterfacePtrAndBind = function() { | 166 Binding.prototype.createInterfacePtrAndBind = function() { |
| 173 var ptr = new this.interfaceType_.ptrClass(); | 167 var ptr = new this.interfaceType_.ptrClass(); |
| 174 // TODO(yzshen): Set the version of the interface pointer. | 168 // TODO(yzshen): Set the version of the interface pointer. |
| 175 this.bind(makeRequest(ptr)); | 169 this.bind(makeRequest(ptr)); |
| 176 return ptr; | 170 return ptr; |
| 177 } | 171 } |
| 178 | 172 |
| 179 Binding.prototype.bind = function(requestOrHandle) { | 173 Binding.prototype.bind = function(requestOrHandle) { |
| 180 this.close(); | 174 this.close(); |
| 181 | 175 |
| 182 var handle = requestOrHandle instanceof types.InterfaceRequest ? | 176 var handle = requestOrHandle instanceof mojoBindings.InterfaceRequest ? |
| 183 requestOrHandle.handle : requestOrHandle; | 177 requestOrHandle.handle : requestOrHandle; |
| 184 if (!core.isHandle(handle)) | 178 if (!handle instanceof MojoHandle) |
| 185 return; | 179 return; |
| 186 | 180 |
| 187 this.stub_ = new this.interfaceType_.stubClass(this.impl_); | 181 this.stub_ = new this.interfaceType_.stubClass(this.impl_); |
| 188 this.router_ = new router.Router(handle, this.interfaceType_.kVersion); | 182 this.router_ = new internal.Router(handle, this.interfaceType_.kVersion); |
| 189 this.router_.setIncomingReceiver(this.stub_); | 183 this.router_.setIncomingReceiver(this.stub_); |
| 190 this.router_ .setPayloadValidators([this.interfaceType_.validateRequest]); | 184 this.router_ .setPayloadValidators([this.interfaceType_.validateRequest]); |
| 191 }; | 185 }; |
| 192 | 186 |
| 193 Binding.prototype.close = function() { | 187 Binding.prototype.close = function() { |
| 194 if (!this.isBound()) | 188 if (!this.isBound()) |
| 195 return; | 189 return; |
| 196 | 190 |
| 197 this.router_.close(); | 191 this.router_.close(); |
| 198 this.router_ = null; | 192 this.router_ = null; |
| 199 this.stub_ = null; | 193 this.stub_ = null; |
| 200 }; | 194 }; |
| 201 | 195 |
| 202 Binding.prototype.setConnectionErrorHandler | 196 Binding.prototype.setConnectionErrorHandler |
| 203 = function(callback) { | 197 = function(callback) { |
| 204 if (!this.isBound()) | 198 if (!this.isBound()) |
| 205 throw new Error("Cannot set connection error handler if not bound."); | 199 throw new Error("Cannot set connection error handler if not bound."); |
| 206 this.router_.setErrorHandler(callback); | 200 this.router_.setErrorHandler(callback); |
| 207 }; | 201 }; |
| 208 | 202 |
| 209 Binding.prototype.unbind = function() { | 203 Binding.prototype.unbind = function() { |
| 210 if (!this.isBound()) | 204 if (!this.isBound()) |
| 211 return new types.InterfaceRequest(null); | 205 return new mojoBindings.InterfaceRequest(null); |
| 212 | 206 |
| 213 var result = new types.InterfaceRequest(this.router_.connector_.handle_); | 207 var result = new mojoBindings.InterfaceRequest( |
| 208 this.router_.connector_.handle_); |
| 214 this.router_.connector_.handle_ = null; | 209 this.router_.connector_.handle_ = null; |
| 215 this.close(); | 210 this.close(); |
| 216 return result; | 211 return result; |
| 217 }; | 212 }; |
| 218 | 213 |
| 219 Binding.prototype.enableTestingMode = function() { | 214 Binding.prototype.enableTestingMode = function() { |
| 220 return this.router_.enableTestingMode(); | 215 return this.router_.enableTestingMode(); |
| 221 }; | 216 }; |
| 222 | 217 |
| 223 // --------------------------------------------------------------------------- | 218 // --------------------------------------------------------------------------- |
| (...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 266 this.errorHandler_ = callback; | 261 this.errorHandler_ = callback; |
| 267 }; | 262 }; |
| 268 | 263 |
| 269 BindingSet.prototype.onConnectionError = function(bindingId) { | 264 BindingSet.prototype.onConnectionError = function(bindingId) { |
| 270 this.bindings_.delete(bindingId); | 265 this.bindings_.delete(bindingId); |
| 271 | 266 |
| 272 if (this.errorHandler_) | 267 if (this.errorHandler_) |
| 273 this.errorHandler_(); | 268 this.errorHandler_(); |
| 274 }; | 269 }; |
| 275 | 270 |
| 276 var exports = {}; | |
| 277 exports.InterfacePtrInfo = types.InterfacePtrInfo; | |
| 278 exports.InterfaceRequest = types.InterfaceRequest; | |
| 279 exports.makeRequest = makeRequest; | |
| 280 exports.InterfacePtrController = InterfacePtrController; | |
| 281 exports.Binding = Binding; | |
| 282 exports.BindingSet = BindingSet; | |
| 283 | 271 |
| 284 return exports; | 272 mojoBindings.makeRequest = makeRequest; |
| 285 }); | 273 mojoBindings.Binding = Binding; |
| 274 mojoBindings.BindingSet = BindingSet; |
| 275 mojoBindings.InterfacePtrController = InterfacePtrController; |
| 276 })(); |
| OLD | NEW |