File tree Expand file tree Collapse file tree 3 files changed +7
-7
lines changed Expand file tree Collapse file tree 3 files changed +7
-7
lines changed Original file line number Diff line number Diff line change @@ -48,7 +48,7 @@ type Manager interface {
4848 Start ()
4949 Stop ()
5050 IsRunning () bool
51- StartBGSyng ( mstatus chan int , shouldRetry bool , onReady func ()) error
51+ StartBGSync ( status chan int , shouldRetry bool , onReady func ()) error
5252}
5353
5454// ManagerImpl struct
@@ -255,10 +255,10 @@ func (s *ManagerImpl) enableStreaming() {
255255 s .hcMonitor .Reset (hc .LargeSegments , int (nextExp .Seconds ()))
256256}
257257
258- func (m * ManagerImpl ) StartBGSyng ( mstatus chan int , shouldRetry bool , onReady func ()) error {
258+ func (m * ManagerImpl ) StartBGSync ( status chan int , shouldRetry bool , onReady func ()) error {
259259 attemptInit := func () bool {
260260 go m .Start ()
261- status := <- mstatus
261+ status := <- status
262262 switch status {
263263 case Ready :
264264 onReady ()
Original file line number Diff line number Diff line change @@ -925,7 +925,7 @@ func TestStartBGSyncSuccessFirstTry(t *testing.T) {
925925 readyCalled := false
926926 onReady := func () { readyCalled = true }
927927
928- err := manager .StartBGSyng (status , false , onReady )
928+ err := manager .StartBGSync (status , false , onReady )
929929 if err != nil {
930930 t .Error ("Should not return error on successful first try" )
931931 }
@@ -968,7 +968,7 @@ func TestStartBGSyncFailNoSnapshot(t *testing.T) {
968968 readyCalled := false
969969 onReady := func () { readyCalled = true }
970970
971- err := manager .StartBGSyng (status , false , onReady )
971+ err := manager .StartBGSync (status , false , onReady )
972972 if err != errUnrecoverable {
973973 t .Error ("Should return errUnrecoverable when sync fails and no snapshot available" )
974974 }
@@ -1011,7 +1011,7 @@ func TestStartBGSyncFailWithSnapshot(t *testing.T) {
10111011 readyCalled := false
10121012 onReady := func () { readyCalled = true }
10131013
1014- err := manager .StartBGSyng (status , true , onReady )
1014+ err := manager .StartBGSync (status , true , onReady )
10151015 if err != errRetrying {
10161016 t .Error ("Should return errRetrying when sync fails but snapshot is available" )
10171017 }
Original file line number Diff line number Diff line change @@ -41,6 +41,6 @@ func (m *ManagerRedisImpl) IsRunning() bool {
4141 return m .running .IsSet ()
4242}
4343
44- func (m * ManagerRedisImpl ) StartBGSyng ( mstatus chan int , shouldRetry bool , onReady func ()) error {
44+ func (m * ManagerRedisImpl ) StartBGSync ( status chan int , shouldRetry bool , onReady func ()) error {
4545 return nil
4646}
You can’t perform that action at this time.
0 commit comments