OpenCloud
/
PeerTube
mirror of https://github.com/Chocobozzz/PeerTube
1
0
Fork 0
Code Issues Releases Wiki Activity

Server: limit actions for each request between pods

pull/10/head
Chocobozzz 2016-07-06 19:59:01 +02:00
parent 4fea95df04
commit b359546358
2 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
server/initializers/constants.js
View File

@ -24,6 +24,9 @@ const PODS_SCORE = {
// Number of requests in parallel we can make // Number of requests in parallel we can make
const REQUESTS_IN_PARALLEL = 10 const REQUESTS_IN_PARALLEL = 10
// How many requests we put in request (request scheduler)
const REQUESTS_LIMIT = 10
// Number of requests to retry for replay requests module // Number of requests to retry for replay requests module
const RETRY_REQUESTS = 5 const RETRY_REQUESTS = 5
@ -71,6 +74,7 @@ module.exports = {
PAGINATION_COUNT_DEFAULT: PAGINATION_COUNT_DEFAULT, PAGINATION_COUNT_DEFAULT: PAGINATION_COUNT_DEFAULT,
PODS_SCORE: PODS_SCORE, PODS_SCORE: PODS_SCORE,
REQUESTS_IN_PARALLEL: REQUESTS_IN_PARALLEL, REQUESTS_IN_PARALLEL: REQUESTS_IN_PARALLEL,
REQUESTS_LIMIT: REQUESTS_LIMIT,
RETRY_REQUESTS: RETRY_REQUESTS, RETRY_REQUESTS: RETRY_REQUESTS,
SEARCHABLE_COLUMNS: SEARCHABLE_COLUMNS, SEARCHABLE_COLUMNS: SEARCHABLE_COLUMNS,
SORTABLE_COLUMNS: SORTABLE_COLUMNS, SORTABLE_COLUMNS: SORTABLE_COLUMNS,

6
server/models/request.js
View File

@ -102,7 +102,7 @@ function makeRequest (toPod, requestsToMake, callback) {
function makeRequests () { function makeRequests () {
const self = this const self = this
list.call(self, function (err, requests) { listWithLimit.call(self, constants.REQUESTS_LIMIT, function (err, requests) {
if (err) { if (err) {
logger.error('Cannot get the list of requests.', { err: err }) logger.error('Cannot get the list of requests.', { err: err })
return // Abort return // Abort
@ -269,8 +269,8 @@ function updatePodsScore (goodPods, badPods) {
}) })
} }
function list (callback) { function listWithLimit (limit, callback) {
this.find({ }, { _id: 1, request: 1, to: 1 }).sort({ _id: 1 }).exec(callback) this.find({ }, { _id: 1, request: 1, to: 1 }).sort({ _id: 1 }).limit(limit).exec(callback)
} }
function removeAll (callback) { function removeAll (callback) {