release chan struct{}
}
+func newSyncerGatedSync() *SyncerGatedSync {
+ return &SyncerGatedSync{
+ started: make(chan struct{}, 100),
+ release: make(chan struct{}),
+ }
+}
+
func (g *SyncerGatedSync) Sync() error {
g.mutex.Lock()
return g.count
}
-func newSyncerGatedSync() *SyncerGatedSync {
- return &SyncerGatedSync{
- started: make(chan struct{}, 100),
- release: make(chan struct{}),
- }
-}
-
// syncerRunKilledWriter starts the writer child on the chat in root, kills it
// with SIGKILL after it acknowledged count messages, and returns the number of
// messages that it acknowledged.