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

fix depth reset

Browse Source
This commit is contained in:
c9s 2021-05-26 01:27:42 +08:00
parent 07ded04a9b
commit 06e982124b
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
pkg/exchange/binance/depthframe.go
View File

@ -154,20 +154,20 @@ func (f *DepthFrame) loadDepthSnapshot() error {
}
func (f *DepthFrame) PushEvent(e DepthEvent) {
select {
case <-f.resetC:
f.reset()
default:
}
f.snapshotMutex.Lock()
snapshot := f.snapshotDepth
f.snapshotMutex.Unlock()
// before the snapshot is loaded, we need to buffer the events until we loaded the snapshot.
if snapshot == nil {
select {
case <-f.resetC:
f.reset()
default:
// buffer the events until we loaded the snapshot
f.bufferEvent(e)
}
// buffer the events until we loaded the snapshot
f.bufferEvent(e)
go f.once.Do(func() {
if err := f.loadDepthSnapshot(); err != nil {