fix push method

This commit is contained in:
Pascal Fischer
2025-10-08 21:27:36 +02:00
parent f13c6ba1b8
commit 409e2013cc

View File

@@ -28,13 +28,13 @@ func (b *UpdateBuffer) Push(update *UpdateMessage) {
if b.update == nil || update.Update.NetworkMap.Serial > b.update.Update.NetworkMap.Serial || b.update.Update.NetworkMap.Serial == 0 { if b.update == nil || update.Update.NetworkMap.Serial > b.update.Update.NetworkMap.Serial || b.update.Update.NetworkMap.Serial == 0 {
if b.update == nil { if b.update == nil {
b.metrics.CountBufferPush() b.metrics.CountBufferPush()
return } else {
b.metrics.CountBufferOverwrite()
} }
b.update = update b.update = update
b.cond.Signal() b.cond.Signal()
b.metrics.CountBufferOverwrite()
return return
} }