Merge branch 'release/0.9.10-5'
This commit is contained in:
@@ -66,7 +66,7 @@ class Reader {
|
|||||||
await utils.sleep(refreshPause);
|
await utils.sleep(refreshPause);
|
||||||
|
|
||||||
i++;
|
i++;
|
||||||
if (i > 120*1000/refreshPause) {//2 мин ждем телодвижений воркера
|
if (i > 180*1000/refreshPause) {//3 мин ждем телодвижений воркера
|
||||||
throw new Error('Слишком долгое время ожидания');
|
throw new Error('Слишком долгое время ожидания');
|
||||||
}
|
}
|
||||||
//проверка воркера
|
//проверка воркера
|
||||||
|
|||||||
@@ -136,7 +136,7 @@ class WebSocketController {
|
|||||||
break;
|
break;
|
||||||
|
|
||||||
i++;
|
i++;
|
||||||
if (i > 2*60*1000/refreshPause) {//2 мин ждем телодвижений воркера
|
if (i > 3*60*1000/refreshPause) {//3 мин ждем телодвижений воркера
|
||||||
this.send({state: 'error', error: 'Время ожидания процесса истекло'}, req, ws);
|
this.send({state: 'error', error: 'Время ожидания процесса истекло'}, req, ws);
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -6,7 +6,7 @@ const LimitedQueue = require('../../LimitedQueue');
|
|||||||
const textUtils = require('./textUtils');
|
const textUtils = require('./textUtils');
|
||||||
const utils = require('../../utils');
|
const utils = require('../../utils');
|
||||||
|
|
||||||
const queue = new LimitedQueue(3, 20, 3*60*1000);//3 минуты ожидание подвижек
|
const queue = new LimitedQueue(3, 20, 2*60*1000);//2 минуты ожидание подвижек
|
||||||
|
|
||||||
class ConvertBase {
|
class ConvertBase {
|
||||||
constructor(config) {
|
constructor(config) {
|
||||||
|
|||||||
Reference in New Issue
Block a user