Skip to content
This repository was archived by the owner on Feb 21, 2024. It is now read-only.

Commit 060e5e3

Browse files
authored
Merge pull request #1607 from jaffee/1606-store-event-race
fix race on replicationClosing channel
2 parents e426c42 + 847132d commit 060e5e3

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

translate.go

+1-3
Original file line numberDiff line numberDiff line change
@@ -337,9 +337,7 @@ func (s *TranslateFile) monitorReplication() {
337337
}
338338

339339
select {
340-
case <-s.closing:
341-
return
342-
case <-s.replicationClosing:
340+
case <-ctx.Done():
343341
return
344342
case <-time.After(s.replicationRetryInterval):
345343
log.Printf("pilosa: reconnecting to primary replica")

0 commit comments

Comments
 (0)