diff options
| author | Eric Yang <lanqingy@usc.edu> | 2022-08-18 23:25:32 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-08-18 23:25:32 -0700 |
| commit | b6f99c4d83ec7eda931790953b1b6854357a2cce (patch) | |
| tree | 3be99eb1d034575d505164637abdfe0ed8eff43c /weed/server/volume_grpc_read_all.go | |
| parent | 5702727db512d3ef5073125387aad84779ba914d (diff) | |
| download | seaweedfs-b6f99c4d83ec7eda931790953b1b6854357a2cce.tar.xz seaweedfs-b6f99c4d83ec7eda931790953b1b6854357a2cce.zip | |
fix naming typo (#3465)
Co-authored-by: root <root@HQ-10MSTD3EY.roblox.local>
Diffstat (limited to 'weed/server/volume_grpc_read_all.go')
| -rw-r--r-- | weed/server/volume_grpc_read_all.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/server/volume_grpc_read_all.go b/weed/server/volume_grpc_read_all.go index 6f75dba97..3f3ecf0b5 100644 --- a/weed/server/volume_grpc_read_all.go +++ b/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) { 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 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) if v == nil { return fmt.Errorf("not found volume id %d", vid) |