mirrors/seaweedfs
1
0
Fork 0
mirror of https://github.com/chrislusf/seaweedfs synced 2024-07-02 07:06:44 +02:00
Code Issues Projects Releases Wiki Activity

go fmt

Browse source
This commit is contained in:
Chris Lu 2019-11-27 12:34:57 -08:00
parent 46294b42e6
commit 586798ecc0
3 changed files with 7 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
weed/pb/proto_read_write_test.go
View file

@ -18,7 +18,7 @@ func TestJsonpMarshalUnmarshal(t *testing.T) {
m := jsonpb.Marshaler{
EmitDefaults: true,
Indent: " ",
Indent: " ",
}
if text, err := m.MarshalToString(tv); err != nil {
@ -40,5 +40,4 @@ func TestJsonpMarshalUnmarshal(t *testing.T) {
fmt.Printf("unmarshalled: %+v\n", tv1)
}

2
weed/server/volume_grpc_tier.go
View file

@ -35,4 +35,4 @@ func uploadFileToRemote(ctx context.Context, req *volume_server_pb.VolumeTierCop
println("copying dat file of", f.Name(), "to remote")
return nil
}
}

10
weed/shell/command_volume_tier.go
View file

@ -82,11 +82,11 @@ func doVolumeTier(ctx context.Context, commandEnv *CommandEnv, collection string
// mark the volume as readonly
/*
err = markVolumeReadonly(ctx, commandEnv.option.GrpcDialOption, needle.VolumeId(vid), locations)
if err != nil {
return fmt.Errorf("mark volume %d as readonly on %s: %v", vid, locations[0].Url, err)
}
*/
err = markVolumeReadonly(ctx, commandEnv.option.GrpcDialOption, needle.VolumeId(vid), locations)
if err != nil {
return fmt.Errorf("mark volume %d as readonly on %s: %v", vid, locations[0].Url, err)
}
*/
// copy the .dat file to remote tier
err = copyDatToRemoteTier(ctx, commandEnv.option.GrpcDialOption, needle.VolumeId(vid), collection, locations[0].Url, dest)