|
@ -14,7 +14,7 @@ import ( |
|
|
"github.com/chrislusf/seaweedfs/weed/filer2" |
|
|
"github.com/chrislusf/seaweedfs/weed/filer2" |
|
|
"github.com/chrislusf/seaweedfs/weed/glog" |
|
|
"github.com/chrislusf/seaweedfs/weed/glog" |
|
|
"github.com/chrislusf/seaweedfs/weed/pb/filer_pb" |
|
|
"github.com/chrislusf/seaweedfs/weed/pb/filer_pb" |
|
|
"github.com/satori/go.uuid" |
|
|
|
|
|
|
|
|
"github.com/google/uuid" |
|
|
) |
|
|
) |
|
|
|
|
|
|
|
|
type InitiateMultipartUploadResult struct { |
|
|
type InitiateMultipartUploadResult struct { |
|
@ -23,7 +23,7 @@ type InitiateMultipartUploadResult struct { |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
func (s3a *S3ApiServer) createMultipartUpload(ctx context.Context, input *s3.CreateMultipartUploadInput) (output *InitiateMultipartUploadResult, code ErrorCode) { |
|
|
func (s3a *S3ApiServer) createMultipartUpload(ctx context.Context, input *s3.CreateMultipartUploadInput) (output *InitiateMultipartUploadResult, code ErrorCode) { |
|
|
uploadId, _ := uuid.NewV4() |
|
|
|
|
|
|
|
|
uploadId, _ := uuid.NewRandom() |
|
|
uploadIdString := uploadId.String() |
|
|
uploadIdString := uploadId.String() |
|
|
|
|
|
|
|
|
if err := s3a.mkdir(ctx, s3a.genUploadsFolder(*input.Bucket), uploadIdString, func(entry *filer_pb.Entry) { |
|
|
if err := s3a.mkdir(ctx, s3a.genUploadsFolder(*input.Bucket), uploadIdString, func(entry *filer_pb.Entry) { |
|
|