Skip to content

Commit 0f31715

Browse files
committed
fix: server alive timeout
1 parent a5a0c24 commit 0f31715

File tree

1 file changed

+1
-21
lines changed

1 file changed

+1
-21
lines changed

src/UDPClusterManager.ts

Lines changed: 1 addition & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -148,8 +148,7 @@ export class UDPClusterManager extends ClusterManager {
148148
type: 'udp4',
149149
reuseAddr: true,
150150
reusePort: true,
151-
})
152-
.bind(options.broadcastPort, address);
151+
}).bind(options.broadcastPort, address);
153152
}
154153

155154
this.socket.on(
@@ -165,10 +164,6 @@ export class UDPClusterManager extends ClusterManager {
165164
private startListening(): void {
166165
this.listenBroadcastedMessages(
167166
message => {
168-
console.log('Received message:', {
169-
message,
170-
timestamp: new Date().toISOString(),
171-
});
172167
this.anyCluster(cluster => {
173168
UDPClusterManager.processMessageOnCluster(
174169
cluster,
@@ -239,11 +234,6 @@ export class UDPClusterManager extends ClusterManager {
239234
aliveTimeoutCorrection: number,
240235
existingServer: boolean = true,
241236
): void {
242-
console.log('Server alive renewal:', {
243-
server,
244-
message,
245-
});
246-
247237
if (server.timer === undefined && existingServer) {
248238
return;
249239
}
@@ -260,21 +250,11 @@ export class UDPClusterManager extends ClusterManager {
260250
return;
261251
}
262252

263-
console.log('Server alive timeout - existing server:', {
264-
existing
265-
});
266-
267253
const now = Date.now();
268254
const delta = now - (existing.timestamp || now);
269255
const currentTimeout = (existing.timeout || 0) +
270256
aliveTimeoutCorrection;
271257

272-
console.log('Server alive - should remove:', {
273-
delta,
274-
currentTimeout,
275-
more: delta >= currentTimeout,
276-
});
277-
278258
if (delta >= currentTimeout) {
279259
cluster.remove(server);
280260
}

0 commit comments

Comments
 (0)