diff options
| author | Chris Lu <chris.lu@gmail.com> | 2021-09-27 01:53:41 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2021-09-27 01:53:41 -0700 |
| commit | aa64f2ac4cc0008b7670bd7c253d17185fd108b5 (patch) | |
| tree | 039704f8aa06e7d40345746a5ef37e67f579975c /weed/server/volume_grpc_read_all.go | |
| parent | c4d7ee6c5cb039f8503c24718ba927f7347a8289 (diff) | |
| download | seaweedfs-aa64f2ac4cc0008b7670bd7c253d17185fd108b5.tar.xz seaweedfs-aa64f2ac4cc0008b7670bd7c253d17185fd108b5.zip | |
send needle data instead of raw needle body
Diffstat (limited to 'weed/server/volume_grpc_read_all.go')
| -rw-r--r-- | weed/server/volume_grpc_read_all.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/server/volume_grpc_read_all.go b/weed/server/volume_grpc_read_all.go index f1f79a2e3..6e7b30dbd 100644 --- a/weed/server/volume_grpc_read_all.go +++ b/weed/server/volume_grpc_read_all.go @@ -41,7 +41,7 @@ func (scanner *VolumeFileScanner4ReadAll) VisitNeedle(n *needle.Needle, offset i sendErr := scanner.stream.Send(&volume_server_pb.ReadAllNeedlesResponse{ NeedleId: uint64(n.Id), - NeedleBlob: needleBody, + NeedleBlob: n.Data, }) if sendErr != nil { return sendErr |