Browse Source
fix naming typo (#3465)
Co-authored-by: root <root@HQ-10MSTD3EY.roblox.local>
pull/3472/head
Eric Yang
2 years ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with
2 additions and
2 deletions
-
weed/server/volume_grpc_read_all.go
|
|
@ -10,14 +10,14 @@ import ( |
|
|
func (vs *VolumeServer) ReadAllNeedles(req *volume_server_pb.ReadAllNeedlesRequest, stream volume_server_pb.VolumeServer_ReadAllNeedlesServer) (err error) { |
|
|
func (vs *VolumeServer) ReadAllNeedles(req *volume_server_pb.ReadAllNeedlesRequest, stream volume_server_pb.VolumeServer_ReadAllNeedlesServer) (err error) { |
|
|
|
|
|
|
|
|
for _, vid := range req.VolumeIds { |
|
|
for _, vid := range req.VolumeIds { |
|
|
if err := vs.streaReadOneVolume(needle.VolumeId(vid), stream, err); err != nil { |
|
|
|
|
|
|
|
|
if err := vs.streamReadOneVolume(needle.VolumeId(vid), stream, err); err != nil { |
|
|
return err |
|
|
return err |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
return nil |
|
|
return nil |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
func (vs *VolumeServer) streaReadOneVolume(vid needle.VolumeId, stream volume_server_pb.VolumeServer_ReadAllNeedlesServer, err error) error { |
|
|
|
|
|
|
|
|
func (vs *VolumeServer) streamReadOneVolume(vid needle.VolumeId, stream volume_server_pb.VolumeServer_ReadAllNeedlesServer, err error) error { |
|
|
v := vs.store.GetVolume(vid) |
|
|
v := vs.store.GetVolume(vid) |
|
|
if v == nil { |
|
|
if v == nil { |
|
|
return fmt.Errorf("not found volume id %d", vid) |
|
|
return fmt.Errorf("not found volume id %d", vid) |
|
|
|
