diff --git a/src/models/StratumV1Client.ts b/src/models/StratumV1Client.ts index 582fd89..2860b96 100644 --- a/src/models/StratumV1Client.ts +++ b/src/models/StratumV1Client.ts @@ -294,8 +294,8 @@ export class StratumV1Client extends EasyUnsubscribe { } const now = Date.now(); const diffSeconds = (now - time.getTime()) / 1000; - // five minutes - if (diffSeconds > 5 * 60) { + // fifteen minutes + if (diffSeconds > 15 * 60) { console.log('Watchdog ending session'); this.promiseSocket.socket.emit('end', true); } diff --git a/src/models/StratumV1ClientStatistics.ts b/src/models/StratumV1ClientStatistics.ts index 11c908c..3a6df6b 100644 --- a/src/models/StratumV1ClientStatistics.ts +++ b/src/models/StratumV1ClientStatistics.ts @@ -3,7 +3,7 @@ import { ClientEntity } from '../ORM/client/client.entity'; const CACHE_SIZE = 30; const TARGET_SUBMISSION_PER_SECOND = 10; -const MIN_DIFF = 0.000001; +const MIN_DIFF = 1e-9; export class StratumV1ClientStatistics { private submissionCacheStart: Date; diff --git a/src/services/stratum-v1.service.ts b/src/services/stratum-v1.service.ts index 574dce0..856b72c 100644 --- a/src/services/stratum-v1.service.ts +++ b/src/services/stratum-v1.service.ts @@ -76,8 +76,7 @@ export class StratumV1Service implements OnModuleInit { await this.clientService.delete(client.extraNonceAndSessionId); const clientCount = await this.clientService.connectedClientCount(); - console.log(`Socket error:`, error); - console.log(`Client disconnected: ${promiseSocket.socket.remoteAddress}, ${client.extraNonceAndSessionId}, ${clientCount} total clients`); + console.log(`Client disconnected, socket error: ${promiseSocket.socket.remoteAddress}, ${client.extraNonceAndSessionId}, ${clientCount} total clients`); });