From 5c47ce456e5b6ec31709573ceaca48e3ff80f767 Mon Sep 17 00:00:00 2001 From: Ritesh H Shukla Date: Tue, 15 Sep 2020 18:44:58 -0700 Subject: [PATCH] Run replication in the background (#10491) --- cmd/object-handlers.go | 6 +++--- cmd/web-handlers.go | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/cmd/object-handlers.go b/cmd/object-handlers.go index 90137421c..8eb76554a 100644 --- a/cmd/object-handlers.go +++ b/cmd/object-handlers.go @@ -1251,7 +1251,7 @@ func (api objectAPIHandlers) CopyObjectHandler(w http.ResponseWriter, r *http.Re response := generateCopyObjectResponse(objInfo.ETag, objInfo.ModTime) encodedSuccessResponse := encodeResponse(response) if mustReplicate(ctx, r, dstBucket, dstObject, objInfo.UserDefined, objInfo.ReplicationStatus.String()) { - defer replicateObject(GlobalContext, dstBucket, dstObject, objInfo.VersionID, objectAPI, &eventArgs{ + go replicateObject(GlobalContext, dstBucket, dstObject, objInfo.VersionID, objectAPI, &eventArgs{ EventName: event.ObjectCreatedCopy, BucketName: dstBucket, Object: objInfo, @@ -1567,7 +1567,7 @@ func (api objectAPIHandlers) PutObjectHandler(w http.ResponseWriter, r *http.Req } } if mustReplicate(ctx, r, bucket, object, metadata, "") { - defer replicateObject(GlobalContext, bucket, object, objInfo.VersionID, objectAPI, &eventArgs{ + go replicateObject(GlobalContext, bucket, object, objInfo.VersionID, objectAPI, &eventArgs{ EventName: event.ObjectCreatedPut, BucketName: bucket, Object: objInfo, @@ -2645,7 +2645,7 @@ func (api objectAPIHandlers) CompleteMultipartUploadHandler(w http.ResponseWrite setPutObjHeaders(w, objInfo, false) if mustReplicate(ctx, r, bucket, object, objInfo.UserDefined, objInfo.ReplicationStatus.String()) { - defer replicateObject(GlobalContext, bucket, object, objInfo.VersionID, objectAPI, &eventArgs{ + go replicateObject(GlobalContext, bucket, object, objInfo.VersionID, objectAPI, &eventArgs{ EventName: event.ObjectCreatedCompleteMultipartUpload, BucketName: bucket, Object: objInfo, diff --git a/cmd/web-handlers.go b/cmd/web-handlers.go index 6a0cee208..6854f18dc 100644 --- a/cmd/web-handlers.go +++ b/cmd/web-handlers.go @@ -1166,7 +1166,7 @@ func (web *webAPIHandlers) Upload(w http.ResponseWriter, r *http.Request) { } } if mustReplicate { - defer replicateObject(GlobalContext, bucket, object, objInfo.VersionID, objectAPI, &eventArgs{ + go replicateObject(GlobalContext, bucket, object, objInfo.VersionID, objectAPI, &eventArgs{ EventName: event.ObjectCreatedPut, BucketName: bucket, Object: objInfo,