diff --git a/synchronizer/manager.go b/synchronizer/manager.go index b2e2d575..0659eed2 100644 --- a/synchronizer/manager.go +++ b/synchronizer/manager.go @@ -48,7 +48,7 @@ type Manager interface { Start() Stop() IsRunning() bool - StartBGSyng(mstatus chan int, shouldRetry bool, onReady func()) error + StartBGSync(status chan int, shouldRetry bool, onReady func()) error } // ManagerImpl struct @@ -255,10 +255,10 @@ func (s *ManagerImpl) enableStreaming() { s.hcMonitor.Reset(hc.LargeSegments, int(nextExp.Seconds())) } -func (m *ManagerImpl) StartBGSyng(mstatus chan int, shouldRetry bool, onReady func()) error { +func (m *ManagerImpl) StartBGSync(status chan int, shouldRetry bool, onReady func()) error { attemptInit := func() bool { go m.Start() - status := <-mstatus + status := <-status switch status { case Ready: onReady() diff --git a/synchronizer/manager_test.go b/synchronizer/manager_test.go index dfda0b21..2d1aaceb 100644 --- a/synchronizer/manager_test.go +++ b/synchronizer/manager_test.go @@ -925,7 +925,7 @@ func TestStartBGSyncSuccessFirstTry(t *testing.T) { readyCalled := false onReady := func() { readyCalled = true } - err := manager.StartBGSyng(status, false, onReady) + err := manager.StartBGSync(status, false, onReady) if err != nil { t.Error("Should not return error on successful first try") } @@ -968,7 +968,7 @@ func TestStartBGSyncFailNoSnapshot(t *testing.T) { readyCalled := false onReady := func() { readyCalled = true } - err := manager.StartBGSyng(status, false, onReady) + err := manager.StartBGSync(status, false, onReady) if err != errUnrecoverable { t.Error("Should return errUnrecoverable when sync fails and no snapshot available") } @@ -1011,7 +1011,7 @@ func TestStartBGSyncFailWithSnapshot(t *testing.T) { readyCalled := false onReady := func() { readyCalled = true } - err := manager.StartBGSyng(status, true, onReady) + err := manager.StartBGSync(status, true, onReady) if err != errRetrying { t.Error("Should return errRetrying when sync fails but snapshot is available") } diff --git a/synchronizer/redis.go b/synchronizer/redis.go index 708962af..40f9ebc9 100644 --- a/synchronizer/redis.go +++ b/synchronizer/redis.go @@ -41,6 +41,6 @@ func (m *ManagerRedisImpl) IsRunning() bool { return m.running.IsSet() } -func (m *ManagerRedisImpl) StartBGSyng(mstatus chan int, shouldRetry bool, onReady func()) error { +func (m *ManagerRedisImpl) StartBGSync(status chan int, shouldRetry bool, onReady func()) error { return nil }