mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2024-01-19 02:48:24 +00:00
send needle data instead of raw needle body
This commit is contained in:
parent
c4d7ee6c5c
commit
aa64f2ac4c
|
@ -41,7 +41,7 @@ func (scanner *VolumeFileScanner4ReadAll) VisitNeedle(n *needle.Needle, offset i
|
||||||
|
|
||||||
sendErr := scanner.stream.Send(&volume_server_pb.ReadAllNeedlesResponse{
|
sendErr := scanner.stream.Send(&volume_server_pb.ReadAllNeedlesResponse{
|
||||||
NeedleId: uint64(n.Id),
|
NeedleId: uint64(n.Id),
|
||||||
NeedleBlob: needleBody,
|
NeedleBlob: n.Data,
|
||||||
})
|
})
|
||||||
if sendErr != nil {
|
if sendErr != nil {
|
||||||
return sendErr
|
return sendErr
|
||||||
|
|
Loading…
Reference in a new issue