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

Merge pull request #1827 from c9s/kbearXD/depth/fix-fetch-and-try

Browse Source 
FIX: do not reset snapshot and once in tryFetch
This commit is contained in:
kbearXD 2024-11-16 15:27:06 +08:00 committed by GitHub
commit cd6393fa3f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/depth/buffer.go
View File

@ -148,8 +148,8 @@ func (b *Buffer) fetchAndPush() error {
if len(b.buffer) > 0 {
// the snapshot is too early
if finalUpdateID < b.buffer[0].FirstUpdateID-1 {
b.resetSnapshot()
b.emitReset()
// reset buffer
b.buffer = nil
b.mu.Unlock()
return fmt.Errorf("depth snapshot is too early, final update %d is < the first update id %d", finalUpdateID, b.buffer[0].FirstUpdateID)
}
@ -163,8 +163,8 @@ func (b *Buffer) fetchAndPush() error {
}
if u.FirstUpdateID > finalUpdateID+1 {
b.resetSnapshot()
b.emitReset()
// reset buffer
b.buffer = nil
b.mu.Unlock()
return fmt.Errorf("there is a missing depth update, the update id %d > final update id %d + 1", u.FirstUpdateID, finalUpdateID)
}