recoverC back to size 1

This commit is contained in:
chiahung 2023-11-07 15:21:48 +08:00
parent 7de49155eb
commit e6fc006747

View File

@ -30,7 +30,7 @@ func (s *Strategy) initializeRecoverC() bool {
if s.recoverC == nil {
s.logger.Info("initializing recover channel")
s.recoverC = make(chan struct{}, 10)
s.recoverC = make(chan struct{}, 1)
} else {
s.logger.Info("recover channel is already initialized, trigger active orders recover")
isInitialize = true