aboutsummaryrefslogtreecommitdiffhomepage
diff options
context:
space:
mode:
-rw-r--r--server/initializers/constants.js5
-rw-r--r--server/models/video.js4
2 files changed, 7 insertions, 2 deletions
diff --git a/server/initializers/constants.js b/server/initializers/constants.js
index 7fcf5b01b..467816f2c 100644
--- a/server/initializers/constants.js
+++ b/server/initializers/constants.js
@@ -40,6 +40,10 @@ const SEARCHABLE_COLUMNS = {
40 VIDEOS: [ 'name', 'magnetUri', 'podUrl', 'author', 'tags' ] 40 VIDEOS: [ 'name', 'magnetUri', 'podUrl', 'author', 'tags' ]
41} 41}
42 42
43// Seeds in parallel we send to electron when "seed all"
44// Once a video is in seeding state we seed another video etc
45const SEEDS_IN_PARALLEL = 3
46
43// Sortable columns per schema 47// Sortable columns per schema
44const SORTABLE_COLUMNS = { 48const SORTABLE_COLUMNS = {
45 VIDEOS: [ 'name', '-name', 'duration', '-duration', 'createdDate', '-createdDate' ] 49 VIDEOS: [ 'name', '-name', 'duration', '-duration', 'createdDate', '-createdDate' ]
@@ -83,6 +87,7 @@ module.exports = {
83 REQUESTS_LIMIT: REQUESTS_LIMIT, 87 REQUESTS_LIMIT: REQUESTS_LIMIT,
84 RETRY_REQUESTS: RETRY_REQUESTS, 88 RETRY_REQUESTS: RETRY_REQUESTS,
85 SEARCHABLE_COLUMNS: SEARCHABLE_COLUMNS, 89 SEARCHABLE_COLUMNS: SEARCHABLE_COLUMNS,
90 SEEDS_IN_PARALLEL: SEEDS_IN_PARALLEL,
86 SORTABLE_COLUMNS: SORTABLE_COLUMNS, 91 SORTABLE_COLUMNS: SORTABLE_COLUMNS,
87 THUMBNAILS_SIZE: THUMBNAILS_SIZE, 92 THUMBNAILS_SIZE: THUMBNAILS_SIZE,
88 THUMBNAILS_STATIC_PATH: THUMBNAILS_STATIC_PATH, 93 THUMBNAILS_STATIC_PATH: THUMBNAILS_STATIC_PATH,
diff --git a/server/models/video.js b/server/models/video.js
index 98f43a06d..396aa505d 100644
--- a/server/models/video.js
+++ b/server/models/video.js
@@ -1,7 +1,7 @@
1'use strict' 1'use strict'
2 2
3const config = require('config') 3const config = require('config')
4const each = require('async/each') 4const eachLimit = require('async/eachLimit')
5const ffmpeg = require('fluent-ffmpeg') 5const ffmpeg = require('fluent-ffmpeg')
6const fs = require('fs') 6const fs = require('fs')
7const parallel = require('async/parallel') 7const parallel = require('async/parallel')
@@ -235,7 +235,7 @@ function seedAllExisting (callback) {
235 listOwned.call(this, function (err, videos) { 235 listOwned.call(this, function (err, videos) {
236 if (err) return callback(err) 236 if (err) return callback(err)
237 237
238 each(videos, function (video, callbackEach) { 238 eachLimit(videos, constants.SEEDS_IN_PARALLEL, function (video, callbackEach) {
239 const videoPath = pathUtils.join(uploadsDir, video.filename) 239 const videoPath = pathUtils.join(uploadsDir, video.filename)
240 seed(videoPath, callbackEach) 240 seed(videoPath, callbackEach)
241 }, callback) 241 }, callback)