Home | History | Annotate | Download | only in sdk 
      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
      3 // found in the LICENSE file.
      4 
      5 
      6 /**
      7  * @constructor
      8  * @param {!WebInspector.Target} mainTarget
      9  * @param {!WebInspector.TargetManager} targetManager
     10  */
     11 WebInspector.WorkerTargetManager = function(mainTarget, targetManager)
     12 {
     13     this._mainTarget = mainTarget;
     14     this._targetManager = targetManager;
     15     mainTarget.workerManager.addEventListener(WebInspector.WorkerManager.Events.WorkerAdded, this._onWorkerAdded, this);
     16     mainTarget.workerManager.addEventListener(WebInspector.WorkerManager.Events.WorkersCleared, this._onWorkersCleared, this);
     17     WebInspector.profilingLock().addEventListener(WebInspector.Lock.Events.StateChanged, this._onProfilingStateChanged, this);
     18     this._onProfilingStateChanged();
     19     this._lastAnonymousTargetId = 0;
     20 }
     21 
     22 WebInspector.WorkerTargetManager.prototype = {
     23     _onProfilingStateChanged: function()
     24     {
     25         var acquired = WebInspector.profilingLock().isAcquired();
     26         this._mainTarget.workerAgent().setAutoconnectToWorkers(!acquired);
     27     },
     28 
     29     /**
     30      * @param {!WebInspector.Event} event
     31      */
     32     _onWorkerAdded: function(event)
     33     {
     34         var data = /** @type {{workerId: number, url: string, inspectorConnected: boolean}} */ (event.data);
     35         new WebInspector.WorkerConnection(this._mainTarget, data.workerId, data.inspectorConnected, onConnectionReady.bind(this));
     36 
     37         /**
     38          * @this {WebInspector.WorkerTargetManager}
     39          * @param {!InspectorBackendClass.Connection} connection
     40          */
     41         function onConnectionReady(connection)
     42         {
     43             var parsedURL = data.url.asParsedURL();
     44             var workerId = parsedURL ? parsedURL.lastPathComponent : "#" + (++this._lastAnonymousTargetId);
     45             this._targetManager.createTarget(WebInspector.UIString("Worker %s", workerId), connection, targetCreated);
     46         }
     47 
     48         /**
     49          * @param {?WebInspector.Target} target
     50          */
     51         function targetCreated(target)
     52         {
     53             if (target && data.inspectorConnected)
     54                 target.runtimeAgent().run();
     55         }
     56     },
     57 
     58     _onWorkersCleared: function()
     59     {
     60         this._lastAnonymousTargetId = 0;
     61     }
     62 }
     63 
     64 /**
     65  * @constructor
     66  * @extends {InspectorBackendClass.Connection}
     67  * @param {!WebInspector.Target} target
     68  * @param {number} workerId
     69  * @param {boolean} inspectorConnected
     70  * @param {!function(!InspectorBackendClass.Connection)} onConnectionReady
     71  */
     72 WebInspector.WorkerConnection = function(target, workerId, inspectorConnected, onConnectionReady)
     73 {
     74     InspectorBackendClass.Connection.call(this);
     75     //FIXME: remove resourceTreeModel and others from worker targets
     76     this.suppressErrorsForDomains(["Worker", "Page", "CSS", "DOM", "DOMStorage", "Database", "Network", "IndexedDB"]);
     77     this._target = target;
     78     this._workerId = workerId;
     79     this._workerAgent = target.workerAgent();
     80     target.workerManager.addEventListener(WebInspector.WorkerManager.Events.MessageFromWorker, this._dispatchMessageFromWorker, this);
     81     target.workerManager.addEventListener(WebInspector.WorkerManager.Events.WorkerRemoved, this._onWorkerRemoved, this);
     82     target.workerManager.addEventListener(WebInspector.WorkerManager.Events.WorkersCleared, this._close, this);
     83     if (!inspectorConnected)
     84         this._workerAgent.connectToWorker(workerId, onConnectionReady.bind(null, this));
     85     else
     86         onConnectionReady.call(null, this);
     87 }
     88 
     89 WebInspector.WorkerConnection.prototype = {
     90 
     91     /**
     92      * @param {!WebInspector.Event} event
     93      */
     94     _dispatchMessageFromWorker: function(event)
     95     {
     96         var data = /** @type {{workerId: number, command: string, message: !Object}} */ (event.data);
     97         if (data.workerId === this._workerId)
     98             this.dispatch(data.message);
     99     },
    100 
    101     /**
    102      * @param {!Object} messageObject
    103      */
    104     sendMessage: function(messageObject)
    105     {
    106         this._workerAgent.sendMessageToWorker(this._workerId, messageObject);
    107     },
    108 
    109     /**
    110      * @param {!WebInspector.Event} event
    111      */
    112     _onWorkerRemoved: function(event)
    113     {
    114         var workerId = /** @type {number} */ (event.data);
    115         if (workerId === this._workerId)
    116             this._close();
    117     },
    118 
    119     _close: function()
    120     {
    121         this._target.workerManager.removeEventListener(WebInspector.WorkerManager.Events.MessageFromWorker, this._dispatchMessageFromWorker, this);
    122         this._target.workerManager.removeEventListener(WebInspector.WorkerManager.Events.WorkerRemoved, this._onWorkerRemoved, this);
    123         this._target.workerManager.removeEventListener(WebInspector.WorkerManager.Events.WorkersCleared, this._close, this);
    124         this.connectionClosed("worker_terminated");
    125     },
    126 
    127     __proto__: InspectorBackendClass.Connection.prototype
    128 }
    129