lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-09-19 22:57:56 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

use alternative assign request

Browse Source
This commit is contained in:
Chris Lu
2020-11-17 00:36:21 -08:00
parent 9add554feb
commit b04375a3d1
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
weed/operation/assign_file_id.go
View File

@@ -50,14 +50,14 @@ func Assign(server string, grpcDialOption grpc.DialOption, primaryRequest *Volum
lastError = WithMasterServerClient(server, grpcDialOption, func(masterClient master_pb.SeaweedClient) error { lastError = WithMasterServerClient(server, grpcDialOption, func(masterClient master_pb.SeaweedClient) error {
req := &master_pb.AssignRequest{ req := &master_pb.AssignRequest{
Count: primaryRequest.Count, Count: request.Count,
Replication: primaryRequest.Replication, Replication: request.Replication,
Collection: primaryRequest.Collection, Collection: request.Collection,
Ttl: primaryRequest.Ttl, Ttl: request.Ttl,
DataCenter: primaryRequest.DataCenter, DataCenter: request.DataCenter,
Rack: primaryRequest.Rack, Rack: request.Rack,
DataNode: primaryRequest.DataNode, DataNode: request.DataNode,
WritableVolumeCount: primaryRequest.WritableVolumeCount, WritableVolumeCount: request.WritableVolumeCount,
} }
resp, grpcErr := masterClient.Assign(context.Background(), req) resp, grpcErr := masterClient.Assign(context.Background(), req)
if grpcErr != nil { if grpcErr != nil {