|
|
@ -264,12 +264,12 @@ func (ds *dbSyncer) sendSyncCmd(master, auth_type, passwd string, tlsEnable bool |
|
|
|
select { |
|
|
|
select { |
|
|
|
case nsize := <-wait: |
|
|
|
case nsize := <-wait: |
|
|
|
if nsize == 0 { |
|
|
|
if nsize == 0 { |
|
|
|
log.Infof("dbSyncer[%v] + waiting rdb done", ds.id) |
|
|
|
log.Infof("dbSyncer[%v] + waiting source rdb", ds.id) |
|
|
|
} else { |
|
|
|
} else { |
|
|
|
return c, nsize |
|
|
|
return c, nsize |
|
|
|
} |
|
|
|
} |
|
|
|
case <-time.After(time.Second): |
|
|
|
case <-time.After(time.Second): |
|
|
|
log.Infof("dbSyncer[%v] - waiting rdb done", ds.id) |
|
|
|
log.Infof("dbSyncer[%v] - waiting source rdb", ds.id) |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|