Spike Curtis 005ea536a5 fix: fix Listen/Unlisten race on Pubsub (#15315) ...

Fixes #15312

When we need to `Unlisten()` for an event, instead of immediately removing the event from the `p.queues`, we store a channel to signal any goroutines trying to Subscribe to the same event when we are done. On `Subscribe`, if the channel is present, wait for it before calling `Listen` to ensure the ordering is correct.

2024-11-01 14:35:26 +04:00

..

psmock

chore: fix TestMeasureLatency/MeasureLatencyRecvTimeout flake (#13301)

2024-05-16 13:42:42 -05:00

latency.go

feat: measure pubsub latencies and expose metrics (#13126)

2024-05-10 12:31:49 +00:00

pubsub_internal_test.go

fix: fix Listen/Unlisten race on Pubsub (#15315)

2024-11-01 14:35:26 +04:00

pubsub_linux_test.go

fix: fix MeasureLatencyRecvTimeout to accept send=0 (#13477)

2024-06-05 18:27:56 +04:00

pubsub_memory_test.go

chore: add /v2 to import module path (#9072)

2023-08-18 18:55:43 +00:00

pubsub_memory.go

feat: make pgCoordinator generally available (#8419)

2023-07-12 13:35:29 +04:00

pubsub_test.go

test(coderd/database/pubsub): fix data race in err assignment (#15306)

2024-10-31 22:37:19 +02:00

pubsub.go

fix: fix Listen/Unlisten race on Pubsub (#15315)

2024-11-01 14:35:26 +04:00

watchdog_test.go

chore: spin clock library out to coder/quartz repo (#13777)

2024-07-03 15:02:54 +04:00

watchdog.go

chore: spin clock library out to coder/quartz repo (#13777)

2024-07-03 15:02:54 +04:00