move filer assign volume grpc errror to response

This commit is contained in:
Chris Lu
2020-02-25 17:15:09 -08:00
parent bc38b72a20
commit 0841bedb15
9 changed files with 139 additions and 113 deletions

View File

@@ -80,6 +80,9 @@ func (fs *FilerSink) fetchAndWrite(ctx context.Context, sourceChunk *filer_pb.Fi
glog.V(0).Infof("assign volume failure %v: %v", request, err)
return err
}
if resp.Error != "" {
return fmt.Errorf("assign volume failure %v: %v", request, resp.Error)
}
fileId, host, auth = resp.FileId, resp.Url, security.EncodedJwt(resp.Auth)