Fix deadlock with highest queued slot update logic

jeffyanta · jeffyanta · commit 666d16849fad · 2024-10-21T09:09:26.000-04:00
diff --git a/geyser/handler_memory.go b/geyser/handler_memory.go
@@ -200,6 +200,7 @@ func (h *MemoryAccountWithDataUpdateHandler) onStateObserved(ctx context.Context
 	h.highestQueuedSlotUpdateMu.RLock()
 	highestQueuedSlotUpdate = h.highestQueuedSlotUpdate[base58MemoryAccountAddress]
 	if observedAtSlot < highestQueuedSlotUpdate {
+		h.highestQueuedSlotUpdateMu.RUnlock()
 		return nil
 	}
 	h.highestQueuedSlotUpdateMu.RUnlock()

Original file line number	Diff line number	Diff line change
`@@ -200,6 +200,7 @@ func (h *MemoryAccountWithDataUpdateHandler) onStateObserved(ctx context.Context`
`200`	`200`	`h.highestQueuedSlotUpdateMu.RLock()`
`201`	`201`	`highestQueuedSlotUpdate = h.highestQueuedSlotUpdate[base58MemoryAccountAddress]`
`202`	`202`	`if observedAtSlot < highestQueuedSlotUpdate {`
	`203`	`+ h.highestQueuedSlotUpdateMu.RUnlock()`
`203`	`204`	`return nil`
`204`	`205`	`}`
`205`	`206`	`h.highestQueuedSlotUpdateMu.RUnlock()`