remove unused ReadNeedleBlobRequest.needle_id

fix https://github.com/seaweedfs/seaweedfs/issues/3853
This commit is contained in:
chrislu 2022-10-13 23:10:46 -07:00
parent f5d4952d73
commit dcd0743a35
4 changed files with 749 additions and 760 deletions

View file

@ -11,6 +11,7 @@ import (
// This is a compile-time assertion to ensure that this generated file // This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against. // is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7 const _ = grpc.SupportPackageIsVersion7
// SeaweedClient is the client API for Seaweed service. // SeaweedClient is the client API for Seaweed service.

View file

@ -279,7 +279,6 @@ message CopyFileResponse {
message ReadNeedleBlobRequest { message ReadNeedleBlobRequest {
uint32 volume_id = 1; uint32 volume_id = 1;
uint64 needle_id = 2;
int64 offset = 3; // actual offset int64 offset = 3; // actual offset
int32 size = 4; int32 size = 4;
} }

File diff suppressed because it is too large Load diff

View file

@ -195,7 +195,6 @@ func (c *commandVolumeCheckDisk) readSourceNeedleBlob(sourceVolumeServer pb.Serv
err = operation.WithVolumeServerClient(false, sourceVolumeServer, c.env.option.GrpcDialOption, func(client volume_server_pb.VolumeServerClient) error { err = operation.WithVolumeServerClient(false, sourceVolumeServer, c.env.option.GrpcDialOption, func(client volume_server_pb.VolumeServerClient) error {
resp, err := client.ReadNeedleBlob(context.Background(), &volume_server_pb.ReadNeedleBlobRequest{ resp, err := client.ReadNeedleBlob(context.Background(), &volume_server_pb.ReadNeedleBlobRequest{
VolumeId: volumeId, VolumeId: volumeId,
NeedleId: uint64(needleValue.Key),
Offset: needleValue.Offset.ToActualOffset(), Offset: needleValue.Offset.ToActualOffset(),
Size: int32(needleValue.Size), Size: int32(needleValue.Size),
}) })