diff options
| author | Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.com> | 2022-10-31 23:33:04 +0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-10-31 11:33:04 -0700 |
| commit | c0deaa494857eeb5bdb96d1a4fabbd3f825a741e (patch) | |
| tree | 9a15dacab863f227b355e64f4f0d6531f430f90e /weed/shell/commands.go | |
| parent | bd459db5fb03fdd73adba70524f042c3535b9424 (diff) | |
| download | seaweedfs-c0deaa494857eeb5bdb96d1a4fabbd3f825a741e.tar.xz seaweedfs-c0deaa494857eeb5bdb96d1a4fabbd3f825a741e.zip | |
[volume.fsck] check needles status from volume server (#3926)
check needles status from volume server
Diffstat (limited to 'weed/shell/commands.go')
| -rw-r--r-- | weed/shell/commands.go | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/weed/shell/commands.go b/weed/shell/commands.go index 66fdcb6bd..af6888458 100644 --- a/weed/shell/commands.go +++ b/weed/shell/commands.go @@ -169,3 +169,18 @@ func readNeedleMeta(grpcDialOption grpc.DialOption, volumeServer pb.ServerAddres ) return } + +func readNeedleStatus(grpcDialOption grpc.DialOption, sourceVolumeServer pb.ServerAddress, volumeId uint32, needleValue needle_map.NeedleValue) (resp *volume_server_pb.VolumeNeedleStatusResponse, err error) { + err = operation.WithVolumeServerClient(false, sourceVolumeServer, grpcDialOption, + func(client volume_server_pb.VolumeServerClient) error { + if resp, err = client.VolumeNeedleStatus(context.Background(), &volume_server_pb.VolumeNeedleStatusRequest{ + VolumeId: volumeId, + NeedleId: uint64(needleValue.Key), + }); err != nil { + return err + } + return nil + }, + ) + return +} |