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

bbgo: use backoff for graceful cancel

Browse Source
This commit is contained in:
c9s 2023-07-20 12:44:57 +08:00
parent f1a105cc06
commit a3c16a4117
No known key found for this signature in database
GPG Key ID: 7385E7E464CB0A54
1 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
pkg/bbgo/order_executor_general.go
View File

@ -15,6 +15,7 @@ import (
"github.com/c9s/bbgo/pkg/fixedpoint" "github.com/c9s/bbgo/pkg/fixedpoint"
"github.com/c9s/bbgo/pkg/types" "github.com/c9s/bbgo/pkg/types"
"github.com/c9s/bbgo/pkg/util" "github.com/c9s/bbgo/pkg/util"
"github.com/c9s/bbgo/pkg/util/backoff"
) )
var ErrExceededSubmitOrderRetryLimit = errors.New("exceeded submit order retry limit") var ErrExceededSubmitOrderRetryLimit = errors.New("exceeded submit order retry limit")
@ -429,15 +430,10 @@ func (e *GeneralOrderExecutor) GracefulCancelActiveOrderBook(ctx context.Context
return nil return nil
} }
if err := activeOrders.GracefulCancel(ctx, e.session.Exchange); err != nil { defer e.tradeCollector.Process()
// Retry once
if err = activeOrders.GracefulCancel(ctx, e.session.Exchange); err != nil {
return errors.Wrap(err, "graceful cancel error")
}
}
e.tradeCollector.Process() op := func() error { return activeOrders.GracefulCancel(ctx, e.session.Exchange) }
return nil return backoff.RetryGeneral(ctx, op)
} }
// GracefulCancel cancels all active maker orders if orders are not given, otherwise cancel all the given orders // GracefulCancel cancels all active maker orders if orders are not given, otherwise cancel all the given orders