diff options
author | Chocobozzz <florian.bigard@gmail.com> | 2017-02-26 19:27:08 +0100 |
---|---|---|
committer | Chocobozzz <florian.bigard@gmail.com> | 2017-02-26 20:01:26 +0100 |
commit | f282639b07deee1e35403bd86c46ea521fb4845e (patch) | |
tree | 574b389ca2b03ffd4a5dadcf634d72c3d88593e6 /server/lib/base-request-scheduler.js | |
parent | 9c2c18f3ab2cf18aeb1eb38da48f0ba553f5d9be (diff) | |
download | PeerTube-f282639b07deee1e35403bd86c46ea521fb4845e.tar.gz PeerTube-f282639b07deee1e35403bd86c46ea521fb4845e.tar.zst PeerTube-f282639b07deee1e35403bd86c46ea521fb4845e.zip |
Server: request scheduler refractoring
Diffstat (limited to 'server/lib/base-request-scheduler.js')
-rw-r--r-- | server/lib/base-request-scheduler.js | 8 |
1 files changed, 0 insertions, 8 deletions
diff --git a/server/lib/base-request-scheduler.js b/server/lib/base-request-scheduler.js index d15680c25..309c1a261 100644 --- a/server/lib/base-request-scheduler.js +++ b/server/lib/base-request-scheduler.js | |||
@@ -95,14 +95,6 @@ module.exports = class BaseRequestScheduler { | |||
95 | const requestToMake = requestsToMakeGrouped[hashKey] | 95 | const requestToMake = requestsToMakeGrouped[hashKey] |
96 | const toPod = requestToMake.toPod | 96 | const toPod = requestToMake.toPod |
97 | 97 | ||
98 | // Maybe the pod is not our friend anymore so simply remove it | ||
99 | if (!toPod) { | ||
100 | const requestIdsToDelete = requestToMake.ids | ||
101 | |||
102 | logger.info('Removing %d "%s" of unexisting pod %s.', requestIdsToDelete.length, this.description, requestToMake.toPod.id) | ||
103 | return this.getRequestToPodModel().removePodOf(requestIdsToDelete, requestToMake.toPod.id, callbackEach) | ||
104 | } | ||
105 | |||
106 | this.makeRequest(toPod, requestToMake.endpoint, requestToMake.datas, (success) => { | 98 | this.makeRequest(toPod, requestToMake.endpoint, requestToMake.datas, (success) => { |
107 | if (success === false) { | 99 | if (success === false) { |
108 | badPods.push(requestToMake.toPod.id) | 100 | badPods.push(requestToMake.toPod.id) |