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

Unified Diff: mojo/services/public/js/mojo.js

Issue 728133002: Update mojo sdk to rev e01f9a49449381a5eb430c1fd88bf2cae73ec35a (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: android + ios gyp fixes Created 6 years, 1 month 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
Index: mojo/services/public/js/mojo.js
diff --git a/mojo/services/public/js/mojo.js b/mojo/services/public/js/mojo.js
new file mode 100644
index 0000000000000000000000000000000000000000..ad0ed0c3a0984be8e4c776b2605266ae22d19c67
--- /dev/null
+++ b/mojo/services/public/js/mojo.js
@@ -0,0 +1,169 @@
+// 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/services/public/js/mojo", [
+ "mojo/public/interfaces/application/service_provider.mojom",
+ "mojo/public/js/connection",
+ "mojo/public/js/core",
+ "services/js/bridge",
+], function(service, connection, core, bridge) {
+
+ function Shell() {
+ this.applications_ = new Map();
+ }
+
+ Shell.prototype.connectToApplication = function(url) {
+ var application = this.applications_.get(url);
+ if (application)
+ return application;
+ application = new ServiceProvider(bridge.connectToApplication(url));
+ this.applications_.set(url, application);
+ return application;
+ };
+
+ Shell.prototype.connectToService = function (url, service, client) {
+ return this.connectToApplication(url).connectToService(service, client);
+ };
+
+ Shell.prototype.close = function() {
+ shell().applications_.forEach(function(application, url) {
+ application.close();
+ });
+ shell().applications_.clear();
+ };
+
+ var shellValue = null;
+
+ function shell() {
+ if (!shellValue)
+ shellValue = new Shell();
+ return shellValue;
+ }
+
+ var requestorValue = null;
+
+ function requestor() {
+ if (!requestorValue) {
+ var handle = bridge.requestorMessagePipeHandle();
+ requestorValue = handle && new ServiceProvider(handle);
+ }
+ return requestorValue;
+ }
+
+ function connectToServiceImpl(serviceName, serviceHandle) {
+ var provider = this.providers_.get(serviceName);
+ if (!provider) {
+ this.pendingRequests_.set(serviceName, serviceHandle);
+ return;
+ }
+
+ var serviceConnection = new connection.Connection(
+ serviceHandle,
+ provider.service.delegatingStubClass,
+ provider.service.client && provider.service.client.proxyClass);
+
+ serviceConnection.local.connection$ = serviceConnection;
+ serviceConnection.local.delegate$ =
+ new provider.factory(serviceConnection.remote);
+
+ provider.connections.push(serviceConnection);
+ }
+
+ function ServiceProvider(messagePipeHandle) {
+ // TODO(hansmuller): if messagePipeHandle is null, throw an exception.
+ this.connections_ = new Map();
+ this.providers_ = new Map();
+ this.pendingRequests_ = new Map();
+ this.connection_ = null;
+ this.handle_ = messagePipeHandle;
+ this.connection_ = new connection.Connection(
+ this.handle_,
+ service.ServiceProvider.client.delegatingStubClass,
+ service.ServiceProvider.proxyClass);
+ this.connection_.local.delegate$ = {
+ connectToService: connectToServiceImpl.bind(this)
+ };
+ }
+
+ ServiceProvider.prototype.provideService = function(service, factory) {
+ // TODO(hansmuller): if !factory, remove provider and close its connections.
+ // TODO(hansmuller): if this.connection_ is null, throw an error.
+ var provider = {
+ service: service,
+ factory: factory,
+ connections: [],
+ };
+ this.providers_.set(service.name, provider);
+
+ if (this.pendingRequests_.has(service.name)) {
+ connectToServiceImpl(service.name, pendingRequests_.get(service.name));
+ pendingRequests_.delete(service.name);
+ }
+
+ return this;
+ };
+
+ ServiceProvider.prototype.connectToService = function(service, client) {
+ // TODO(hansmuler): if service.name isn't defined, throw an error.
+ // TODO(hansmuller): if this.connection_ is null, throw an error.
+ var serviceConnection = this.connections_.get(service.name);
+ if (serviceConnection)
+ return serviceConnection.remote;
+
+ var pipe = core.createMessagePipe();
+ this.connection_.remote.connectToService(service.name, pipe.handle1);
+ var clientClass = client && service.client.delegatingStubClass;
+ var serviceConnection =
+ new connection.Connection(pipe.handle0, clientClass, service.proxyClass);
+ if (serviceConnection.local)
+ serviceConnection.local.delegate$ = client;
+
+ this.connections_.set(service.name, serviceConnection);
+ return serviceConnection.remote;
+ };
+
+ ServiceProvider.prototype.close = function() {
+ if (!this.connection_)
+ return;
+
+ try {
+ // Outgoing connections
+ this.connections_.forEach(function(connection, serviceName) {
+ connection.close();
+ });
+ // Incoming connections
+ this.providers_.forEach(function(provider, serviceName) {
+ provider.connections.forEach(function(connection) {
+ connection.close();
+ });
+ });
+ this.connection_.close();
+ } finally {
+ this.connections_ = null;
+ this.providers_ = null;
+ this.pendingRequests_ = null;
+ this.connection_ = null;
+ this.handle_ = null;
+
+ shell().applications_.forEach(function(application, url) {
+ if (application === this)
+ shell().applications_.delete(url);
+ }, this);
+ }
+ };
+
+ function quit() {
+ if (requestorValue)
+ requestor().close();
+ if (shellValue)
+ shell().close();
+ bridge.quit();
+ }
+
+ var exports = {};
+ exports.requestor = requestor;
+ exports.shell = shell;
+ exports.quit = quit;
+ return exports;
+});
« no previous file with comments | « mojo/services/public/interfaces/window_manager/window_manager.mojom ('k') | mojo/services/public/mojo_services_public.gyp » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698