config: разблокировать SyncQueues при ошибке setQueueRedrivePolicy
This commit is contained in:
@@ -129,6 +129,9 @@ func LoadYamlConfig(filename string, env string) []string {
|
|||||||
err := setQueueRedrivePolicy(models.SyncQueues.Queues, q, queue.RedrivePolicy)
|
err := setQueueRedrivePolicy(models.SyncQueues.Queues, q, queue.RedrivePolicy)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Errorf("err: %s", err)
|
log.Errorf("err: %s", err)
|
||||||
|
// Разблокировать глобальный мьютекс перед выходом — иначе все
|
||||||
|
// операции с очередями зависнут навсегда (deadlock).
|
||||||
|
models.SyncQueues.Unlock()
|
||||||
return ports
|
return ports
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user