1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
|
/* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/. */
Components.utils.import("resource://gre/modules/XPCOMUtils.jsm");
const Cc = Components.classes;
const Ci = Components.interfaces;
const CATEGORY_WAKEUP_REQUEST = "wakeup-request";
function MessageWakeupService() { };
MessageWakeupService.prototype =
{
classID: Components.ID("{f9798742-4f7b-4188-86ba-48b116412b29}"),
QueryInterface: XPCOMUtils.generateQI([Ci.nsIObserver]),
messagesData: [],
get messageManager() {
if (!this._messageManager)
this._messageManager = Cc["@mozilla.org/parentprocessmessagemanager;1"].
getService(Ci.nsIMessageListenerManager);
return this._messageManager;
},
requestWakeup: function(aMessageName, aCid, aIid, aMethod) {
this.messagesData[aMessageName] = {
cid: aCid,
iid: aIid,
method: aMethod,
};
this.messageManager.addMessageListener(aMessageName, this);
},
receiveMessage: function(aMessage) {
let data = this.messagesData[aMessage.name];
// TODO: When bug 593407 is ready, stop doing the wrappedJSObject hack
// and use this line instead:
// QueryInterface(Ci.nsIMessageListener);
let service = Cc[data.cid][data.method](Ci[data.iid]).
wrappedJSObject;
// The receiveMessage() call itself may spin an event loop, and we
// do not want to swap listeners in that - it would cause the current
// message to be answered by two listeners. So, we call that first,
// then queue the swap for the next event loop
let ret = service.receiveMessage(aMessage);
if (data.timer) {
// Handle the case of two such messages happening in quick succession
data.timer.cancel();
data.timer = null;
}
data.timer = Cc["@mozilla.org/timer;1"].createInstance(Ci.nsITimer);
let self = this;
data.timer.initWithCallback(function() {
self.messageManager.addMessageListener(aMessage.name, service);
self.messageManager.removeMessageListener(aMessage.name, self);
delete self.messagesData[aMessage.name];
}, 0, Ci.nsITimer.TYPE_ONE_SHOT);
return ret;
},
observe: function TM_observe(aSubject, aTopic, aData) {
switch (aTopic) {
case "profile-after-change":
{
var catMan = Cc["@mozilla.org/categorymanager;1"].
getService(Ci.nsICategoryManager);
var entries = catMan.enumerateCategory(CATEGORY_WAKEUP_REQUEST);
while (entries.hasMoreElements()) {
var entry = entries.getNext().QueryInterface(Ci.nsISupportsCString).data;
var value = catMan.getCategoryEntry(CATEGORY_WAKEUP_REQUEST, entry);
var parts = value.split(",");
var cid = parts[0];
var iid = parts[1];
var method = parts[2];
var messages = parts.slice(3);
messages.forEach(function(messageName) {
this.requestWakeup(messageName, cid, iid, method);
}, this);
}
}
break;
}
},
};
var components = [MessageWakeupService];
this.NSGetFactory = XPCOMUtils.generateNSGetFactory(components);
|
