coosld/ceremonyclient
1
0
Fork 0
mirror of https://github.com/QuilibriumNetwork/ceremonyclient.git synced 2026-02-26 21:07:26 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

do not respawn worker if filter loaded from store is empty

Browse Source
This commit is contained in:
Vasyl Tretiakov 2025-10-29 21:45:30 +02:00
parent 9e1014dd34
commit aaca4dccf8
1 changed files with 14 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
node/worker/manager.go
View File

@ -540,18 +540,21 @@ func (w *WorkerManager) loadWorkersFromStore() error {
allocatedCount++
}
totalStorage += uint64(worker.TotalStorage)
svc, err := w.getIPCOfWorker(worker.CoreId)
if err != nil {
w.logger.Error("could not obtain IPC for worker", zap.Error(err))
continue
}
_, err = svc.Respawn(w.ctx, &protobufs.RespawnRequest{
Filter: worker.Filter,
})
if err != nil {
w.logger.Error("could not respawn worker", zap.Error(err))
continue
if len(worker.Filter) > 0 {
svc, err := w.getIPCOfWorker(worker.CoreId)
if err != nil {
w.logger.Error("could not obtain IPC for worker", zap.Error(err))
continue
}
_, err = svc.Respawn(w.ctx, &protobufs.RespawnRequest{
Filter: worker.Filter,
})
if err != nil {
w.logger.Error("could not respawn worker", zap.Error(err))
continue
}
}
}