diff --git a/storage-manager/src/S3Storage.cpp b/storage-manager/src/S3Storage.cpp index 0195341e4..1113768c8 100644 --- a/storage-manager/src/S3Storage.cpp +++ b/storage-manager/src/S3Storage.cpp @@ -241,6 +241,7 @@ int S3Storage::getObject(const string &_sourceKey, boost::shared_array s3err_msgs[err], bucket.c_str(), sourceKey.c_str()); if (skipRetryableErrors) { + errno = EAGAIN; return -1; } sleep(5); @@ -335,6 +336,7 @@ int S3Storage::putObject(const boost::shared_array data, size_t len, co " Retrying...", s3err_msgs[s3err], bucket.c_str(), destKey.c_str()); if (skipRetryableErrors) { + errno = EAGAIN; return -1; } sleep(5); @@ -373,6 +375,7 @@ int S3Storage::deleteObject(const string &_key) s3err_msgs[s3err], bucket.c_str(), key.c_str()); if (skipRetryableErrors) { + errno = EAGAIN; return -1; } sleep(5); @@ -412,6 +415,7 @@ int S3Storage::copyObject(const string &_sourceKey, const string &_destKey) " destkey = %s. Retrying...", s3err_msgs[s3err], bucket.c_str(), sourceKey.c_str(), destKey.c_str()); if (skipRetryableErrors) { + errno = EAGAIN; return -1; } sleep(5); @@ -465,6 +469,7 @@ int S3Storage::exists(const string &_key, bool *out) s3err_msgs[s3err], bucket.c_str(), key.c_str()); if (skipRetryableErrors) { + errno = EAGAIN; return -1; } sleep(5);