lychiyu/bbgo_origin
1
0
Fork 0
mirror of https://github.com/c9s/bbgo.git synced 2024-11-10 09:11:55 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

bbgo.sync when syncActiveOrders

Browse Source
This commit is contained in:
chiahung 2023-11-07 10:56:19 +08:00
parent dcff850c64
commit c8becbe4f5
1 changed files with 12 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
pkg/strategy/grid2/active_order_recover.go
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{}, 1)
s.recoverC = make(chan struct{}, 10)
} else {
s.logger.Info("recover channel is already initialized, trigger active orders recover")
isInitialize = true
@ -66,22 +66,26 @@ func (s *Strategy) recoverActiveOrdersPeriodically(ctx context.Context) {
exchange: s.session.Exchange,
}
var lastRecoverTime time.Time
for {
select {
case <-ctx.Done():
return
case <-ticker.C:
if err := syncActiveOrders(ctx, opts); err != nil {
log.WithError(err).Errorf("unable to sync active orders")
}
s.recoverC <- struct{}{}
bbgo.Sync(ctx, s)
case <-s.recoverC:
if err := syncActiveOrders(ctx, opts); err != nil {
log.WithError(err).Errorf("unable to sync active orders")
if !time.Now().After(lastRecoverTime.Add(10 * time.Minute)) {
continue
}
if err := syncActiveOrders(ctx, opts); err != nil {
log.WithError(err).Errorf("unable to sync active orders")
} else {
lastRecoverTime = time.Now()
}
}
}
}