q3aql/webui-aria2
q3aql/webui-aria2
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix subscriptions race.

Browse Source
This commit is contained in:
Nils Maier 2014-01-09 04:18:44 +01:00
parent f6df1689c2
commit 3843bf34f5
1 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
js/services/rpc/rpc.js
View File

@ -38,7 +38,11 @@ function(syscall, time, alerts, utils, rootScope, uri) {
clearTimeout(timeout);
timeout = null;
if (!subscriptions.length) {
subscriptions = _.filter(subscriptions, function(e) {
return !!e && e.once !== 2;
});
var subs = subscriptions.slice();
if (!subs.length) {
timeout = setTimeout(update, time);
return;
}
@ -48,15 +52,13 @@ function(syscall, time, alerts, utils, rootScope, uri) {
syscall.init(currentConf);
}
subscriptions = _.filter(subscriptions, function(e) { return !!e });
var params = _.map(subscriptions, function(s) {
var params = _.map(subs, function(s) {
return {
methodName: s.name,
params: s.params && s.params.length ? s.params : undefined
};
});
syscall.invoke({
name: 'system.multicall',
params: [params],
@ -73,15 +75,16 @@ function(syscall, time, alerts, utils, rootScope, uri) {
var cbs = [];
_.each(data.result, function(d, i) {
var handle = subscriptions[i];
var handle = subs[i];
if (handle) {
if (d.code) {
console.error(handle, d);
alerts.addAlert(d.message, 'error');
}
// run them later as the cb itself can mutate the subscriptions
cbs.push({cb: handle.cb, data: d});
if (handle.once) {
subscriptions[i] = null;
handle.once = 2;
}
}
});