diff options
| author | Chris Lu <chris.lu@gmail.com> | 2019-04-18 00:18:29 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2019-04-18 00:18:29 -0700 |
| commit | b09e8dbb377562e6d61bf40b5dbadc3a3edd1360 (patch) | |
| tree | 79d086d0bd92a693de8f1afa958d254d53d097ea /weed/server/volume_grpc_copy_incremental.go | |
| parent | 13ad5c196656c586e908defce9b6d8e717663625 (diff) | |
| download | seaweedfs-b09e8dbb377562e6d61bf40b5dbadc3a3edd1360.tar.xz seaweedfs-b09e8dbb377562e6d61bf40b5dbadc3a3edd1360.zip | |
add VolumeStreamFollow, but not used yet
Diffstat (limited to 'weed/server/volume_grpc_copy_incremental.go')
| -rw-r--r-- | weed/server/volume_grpc_copy_incremental.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/server/volume_grpc_copy_incremental.go b/weed/server/volume_grpc_copy_incremental.go index 41b7a798c..06e7017e8 100644 --- a/weed/server/volume_grpc_copy_incremental.go +++ b/weed/server/volume_grpc_copy_incremental.go @@ -18,9 +18,9 @@ func (vs *VolumeServer) VolumeIncrementalCopy(req *volume_server_pb.VolumeIncrem } stopOffset := v.Size() - foundOffset, isLastOne, err := v.BinarySearchByAppendAtNs(req.Since) + foundOffset, isLastOne, err := v.BinarySearchByAppendAtNs(req.SinceNs) if err != nil { - return fmt.Errorf("fail to locate by appendAtNs %d: %s", req.Since, err) + return fmt.Errorf("fail to locate by appendAtNs %d: %s", req.SinceNs, err) } if isLastOne { |