|
|
|
@ -58,7 +58,7 @@ func isGenerationCompatible(actualGeneration, requestedGeneration uint32) bool { |
|
|
|
// VolumeEcShardsGenerate generates the .ecx and .ec00 ~ .ec13 files
|
|
|
|
func (vs *VolumeServer) VolumeEcShardsGenerate(ctx context.Context, req *volume_server_pb.VolumeEcShardsGenerateRequest) (*volume_server_pb.VolumeEcShardsGenerateResponse, error) { |
|
|
|
|
|
|
|
glog.V(0).Infof("VolumeEcShardsGenerate volume %d generation %d collection %s", |
|
|
|
glog.V(0).Infof("VolumeEcShardsGenerate volume %d generation %d collection %s", |
|
|
|
req.VolumeId, req.Generation, req.Collection) |
|
|
|
|
|
|
|
v := vs.store.GetVolume(needle.VolumeId(req.VolumeId)) |
|
|
|
@ -177,7 +177,7 @@ func (vs *VolumeServer) VolumeEcShardsRebuild(ctx context.Context, req *volume_s |
|
|
|
// VolumeEcShardsCopy copy the .ecx and some ec data slices
|
|
|
|
func (vs *VolumeServer) VolumeEcShardsCopy(ctx context.Context, req *volume_server_pb.VolumeEcShardsCopyRequest) (*volume_server_pb.VolumeEcShardsCopyResponse, error) { |
|
|
|
|
|
|
|
glog.V(0).Infof("VolumeEcShardsCopy volume %d generation %d shards %v from %s collection %s", |
|
|
|
glog.V(0).Infof("VolumeEcShardsCopy volume %d generation %d shards %v from %s collection %s", |
|
|
|
req.VolumeId, req.Generation, req.ShardIds, req.SourceDataNode, req.Collection) |
|
|
|
|
|
|
|
var location *storage.DiskLocation |
|
|
|
@ -344,7 +344,7 @@ func checkEcVolumeStatus(bName string, location *storage.DiskLocation) (hasEcxFi |
|
|
|
|
|
|
|
func (vs *VolumeServer) VolumeEcShardsMount(ctx context.Context, req *volume_server_pb.VolumeEcShardsMountRequest) (*volume_server_pb.VolumeEcShardsMountResponse, error) { |
|
|
|
|
|
|
|
glog.V(0).Infof("VolumeEcShardsMount volume %d generation %d shards %v collection %s", |
|
|
|
glog.V(0).Infof("VolumeEcShardsMount volume %d generation %d shards %v collection %s", |
|
|
|
req.VolumeId, req.Generation, req.ShardIds, req.Collection) |
|
|
|
|
|
|
|
for _, shardId := range req.ShardIds { |
|
|
|
@ -366,7 +366,7 @@ func (vs *VolumeServer) VolumeEcShardsMount(ctx context.Context, req *volume_ser |
|
|
|
|
|
|
|
func (vs *VolumeServer) VolumeEcShardsUnmount(ctx context.Context, req *volume_server_pb.VolumeEcShardsUnmountRequest) (*volume_server_pb.VolumeEcShardsUnmountResponse, error) { |
|
|
|
|
|
|
|
glog.V(0).Infof("VolumeEcShardsUnmount volume %d generation %d shards %v", |
|
|
|
glog.V(0).Infof("VolumeEcShardsUnmount volume %d generation %d shards %v", |
|
|
|
req.VolumeId, req.Generation, req.ShardIds) |
|
|
|
|
|
|
|
for _, shardId := range req.ShardIds { |
|
|
|
|