diff options
| author | zhihao.qu <zhihao.qu@ly.com> | 2022-06-15 13:33:20 +0800 |
|---|---|---|
| committer | zhihao.qu <zhihao.qu@ly.com> | 2022-06-15 13:33:20 +0800 |
| commit | 4d0d1848c648c3e2e6596451fa20eabc468239dc (patch) | |
| tree | c3ba7f6463e2c9ff889021c9002e79363ea07676 | |
| parent | 42d04c581b174d21ecbd137bac87256adeaa9fd3 (diff) | |
| download | seaweedfs-4d0d1848c648c3e2e6596451fa20eabc468239dc.tar.xz seaweedfs-4d0d1848c648c3e2e6596451fa20eabc468239dc.zip | |
fix(filer.sync): modify clientName format : from -> to
| -rw-r--r-- | weed/command/filer_sync.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/command/filer_sync.go b/weed/command/filer_sync.go index dca4e693f..b7da1baf9 100644 --- a/weed/command/filer_sync.go +++ b/weed/command/filer_sync.go @@ -216,7 +216,7 @@ func doSubscribeFilerMetaChanges(clientId int32, grpcDialOption grpc.DialOption, } var lastLogTsNs = time.Now().Nanosecond() - var clientName = fmt.Sprintf("syncTo_%s_From_%s", string(targetFiler), string(sourceFiler)) + var clientName = fmt.Sprintf("syncFrom_%s_To_%s", string(sourceFiler), string(targetFiler)) processEventFnWithOffset := pb.AddOffsetFunc(processEventFn, 3*time.Second, func(counter int64, lastTsNs int64) error { now := time.Now().Nanosecond() glog.V(0).Infof("sync %s to %s progressed to %v %0.2f/sec", sourceFiler, targetFiler, time.Unix(0, lastTsNs), float64(counter)/(float64(now-lastLogTsNs)/1e9)) |