aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/models/request.js
diff options
context:
space:
mode:
authorChocobozzz <florian.bigard@gmail.com>2016-07-18 17:17:52 +0200
committerChocobozzz <florian.bigard@gmail.com>2016-07-18 17:17:52 +0200
commit1a42c9e2c0fb64cdbebd81b311736e752f591e0a (patch)
treee893324d730878257491428ffca634a92f1eea05 /server/models/request.js
parentd56ec0d4129160a6e3b51ace3766bb325db1f101 (diff)
downloadPeerTube-1a42c9e2c0fb64cdbebd81b311736e752f591e0a.tar.gz
PeerTube-1a42c9e2c0fb64cdbebd81b311736e752f591e0a.tar.zst
PeerTube-1a42c9e2c0fb64cdbebd81b311736e752f591e0a.zip
Server: udpate async to 2.0.0
Diffstat (limited to 'server/models/request.js')
-rw-r--r--server/models/request.js12
1 files changed, 7 insertions, 5 deletions
diff --git a/server/models/request.js b/server/models/request.js
index 248ab3303..4d521919a 100644
--- a/server/models/request.js
+++ b/server/models/request.js
@@ -1,8 +1,10 @@
1'use strict' 1'use strict'
2 2
3const async = require('async') 3const each = require('async/each')
4const eachLimit = require('async/eachLimit')
4const map = require('lodash/map') 5const map = require('lodash/map')
5const mongoose = require('mongoose') 6const mongoose = require('mongoose')
7const waterfall = require('async/waterfall')
6 8
7const constants = require('../initializers/constants') 9const constants = require('../initializers/constants')
8const logger = require('../helpers/logger') 10const logger = require('../helpers/logger')
@@ -136,7 +138,7 @@ function makeRequests () {
136 const goodPods = [] 138 const goodPods = []
137 const badPods = [] 139 const badPods = []
138 140
139 async.eachLimit(Object.keys(requestsToMake), constants.REQUESTS_IN_PARALLEL, function (toPodId, callbackEach) { 141 eachLimit(Object.keys(requestsToMake), constants.REQUESTS_IN_PARALLEL, function (toPodId, callbackEach) {
140 const requestToMake = requestsToMake[toPodId] 142 const requestToMake = requestsToMake[toPodId]
141 143
142 // FIXME: mongodb request inside a loop :/ 144 // FIXME: mongodb request inside a loop :/
@@ -183,7 +185,7 @@ function makeRequests () {
183 185
184// Remove pods with a score of 0 (too many requests where they were unreachable) 186// Remove pods with a score of 0 (too many requests where they were unreachable)
185function removeBadPods () { 187function removeBadPods () {
186 async.waterfall([ 188 waterfall([
187 function findBadPods (callback) { 189 function findBadPods (callback) {
188 Pod.listBadPods(function (err, pods) { 190 Pod.listBadPods(function (err, pods) {
189 if (err) { 191 if (err) {
@@ -217,7 +219,7 @@ function removeBadPods () {
217 return callback(null) 219 return callback(null)
218 } 220 }
219 221
220 async.each(videosList, function (video, callbackEach) { 222 each(videosList, function (video, callbackEach) {
221 video.remove(callbackEach) 223 video.remove(callbackEach)
222 }, function (err) { 224 }, function (err) {
223 if (err) { 225 if (err) {
@@ -237,7 +239,7 @@ function removeBadPods () {
237 return callback(null) 239 return callback(null)
238 } 240 }
239 241
240 async.each(pods, function (pod, callbackEach) { 242 each(pods, function (pod, callbackEach) {
241 pod.remove(callbackEach) 243 pod.remove(callbackEach)
242 }, function (err) { 244 }, function (err) {
243 if (err) return callback(err) 245 if (err) return callback(err)