diff --git a/src/redis-shake/dump.go b/src/redis-shake/dump.go
index 9c3998e..5d4e146 100644
--- a/src/redis-shake/dump.go
+++ b/src/redis-shake/dump.go
@@ -141,10 +141,10 @@ func (dd *dbDumper) sendCmd(master, auth_type, passwd string, tlsEnable bool) (n
 		select {
 		case nsize = <-wait:
 			if nsize == 0 {
-				log.Infof("routine[%v] + waiting rdb done", dd.id)
+				log.Infof("routine[%v] + waiting source rdb", dd.id)
 			}
 		case <-time.After(time.Second):
-			log.Infof("routine[%v] - waiting rdb done", dd.id)
+			log.Infof("routine[%v] - waiting source rdb", dd.id)
 		}
 	}
 	return c, nsize
diff --git a/src/redis-shake/sync.go b/src/redis-shake/sync.go
index 534fc8c..24f1266 100644
--- a/src/redis-shake/sync.go
+++ b/src/redis-shake/sync.go
@@ -264,12 +264,12 @@ func (ds *dbSyncer) sendSyncCmd(master, auth_type, passwd string, tlsEnable bool
 		select {
 		case nsize := <-wait:
 			if nsize == 0 {
-				log.Infof("dbSyncer[%v] + waiting rdb done", ds.id)
+				log.Infof("dbSyncer[%v] + waiting source rdb", ds.id)
 			} else {
 				return c, nsize
 			}
 		case <-time.After(time.Second):
-			log.Infof("dbSyncer[%v] - waiting rdb done", ds.id)
+			log.Infof("dbSyncer[%v] - waiting source rdb", ds.id)
 		}
 	}
 }