Skip to content

Commit 84e1154

Browse files
committed
increased number of workers, removed unused import/variables
1 parent ded23de commit 84e1154

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

streamer/streamer.js

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
var kue = require('kue');
22
var cluster = require('cluster');
33
var bodyParser = require('body-parser');
4-
var fs = require('fs')
54
var queue = kue.createQueue({
65
redis: {
76
port: process.env.REDIS_PORT,
@@ -30,8 +29,6 @@ var m_admin = require('./lib/admin');
3029

3130
var active_pids = {};
3231

33-
const streamer_bindir = __dirname + path.sep + 'bin';
34-
3532
queue.on( 'error', function(err) {
3633
if ( cluster.isMaster) {
3734
utility.printErr(null, err);
@@ -246,7 +243,7 @@ if (cluster.isMaster) {
246243

247244
//var nworkers = require('os').cpus().length - 1;
248245
// TODO: make nworkers configurable
249-
var nworkers = 2;
246+
var nworkers = 4;
250247
for (var i = 0; i < nworkers; i++) {
251248
create_worker();
252249
}

0 commit comments

Comments
 (0)