mirror of
https://github.com/whyour/qinglong.git
synced 2025-11-09 16:16:07 +08:00
Improve logging accuracy for worker restarts
- Fixed log messages to accurately reflect worker state - Added proper logging after gRPC worker is confirmed ready - Improved HTTP worker restart logging with PID - Addresses code review feedback for better clarity Co-authored-by: whyour <22700758+whyour@users.noreply.github.com>
This commit is contained in:
parent
2baf352350
commit
95939bbea5
13
back/app.ts
13
back/app.ts
|
|
@ -76,20 +76,21 @@ class Application {
|
||||||
}). Restarting...`,
|
}). Restarting...`,
|
||||||
);
|
);
|
||||||
// If gRPC worker died, restart it and wait for it to be ready
|
// If gRPC worker died, restart it and wait for it to be ready
|
||||||
// before potentially needing to restart HTTP worker
|
|
||||||
if (metadata.serviceType === 'grpc') {
|
if (metadata.serviceType === 'grpc') {
|
||||||
const newGrpcWorker = this.forkWorker('grpc');
|
const newGrpcWorker = this.forkWorker('grpc');
|
||||||
this.waitForWorkerReady(newGrpcWorker, 30000).catch((error) => {
|
this.waitForWorkerReady(newGrpcWorker, 30000)
|
||||||
|
.then(() => {
|
||||||
|
Logger.info('gRPC worker restarted and ready');
|
||||||
|
})
|
||||||
|
.catch((error) => {
|
||||||
Logger.error('Failed to restart gRPC worker:', error);
|
Logger.error('Failed to restart gRPC worker:', error);
|
||||||
process.exit(1);
|
process.exit(1);
|
||||||
});
|
});
|
||||||
} else {
|
} else {
|
||||||
// For HTTP worker, just restart it
|
// For HTTP worker, just restart it
|
||||||
this.forkWorker(metadata.serviceType);
|
const newWorker = this.forkWorker(metadata.serviceType);
|
||||||
|
Logger.info(`Restarted ${metadata.serviceType} worker (PID: ${newWorker.process.pid})`);
|
||||||
}
|
}
|
||||||
Logger.info(
|
|
||||||
`Restarted ${metadata.serviceType} worker`,
|
|
||||||
);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
this.workerMetadataMap.delete(worker.id);
|
this.workerMetadataMap.delete(worker.id);
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue
Block a user