database/mariadb-columnstore-engine
1
0
Fork 0
mirror of https://github.com/mariadb-corporation/mariadb-columnstore-engine.git synced 2025-08-07 03:22:57 +03:00
Code Activity

Set errno before returning.

Browse Source
This commit is contained in:
benthompson15
2020-05-08 17:29:09 -05:00
parent 2951dbed39
commit 0b32ad8107
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
storage-manager/src/S3Storage.cpp
View File

@@ -241,6 +241,7 @@ int S3Storage::getObject(const string &_sourceKey, boost::shared_array<uint8_t>
s3err_msgs[err], bucket.c_str(), sourceKey.c_str()); s3err_msgs[err], bucket.c_str(), sourceKey.c_str());
if (skipRetryableErrors) if (skipRetryableErrors)
{ {
errno = EAGAIN;
return -1; return -1;
} }
sleep(5); sleep(5);
@@ -335,6 +336,7 @@ int S3Storage::putObject(const boost::shared_array<uint8_t> data, size_t len, co
" Retrying...", s3err_msgs[s3err], bucket.c_str(), destKey.c_str()); " Retrying...", s3err_msgs[s3err], bucket.c_str(), destKey.c_str());
if (skipRetryableErrors) if (skipRetryableErrors)
{ {
errno = EAGAIN;
return -1; return -1;
} }
sleep(5); sleep(5);
@@ -373,6 +375,7 @@ int S3Storage::deleteObject(const string &_key)
s3err_msgs[s3err], bucket.c_str(), key.c_str()); s3err_msgs[s3err], bucket.c_str(), key.c_str());
if (skipRetryableErrors) if (skipRetryableErrors)
{ {
errno = EAGAIN;
return -1; return -1;
} }
sleep(5); 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()); " destkey = %s. Retrying...", s3err_msgs[s3err], bucket.c_str(), sourceKey.c_str(), destKey.c_str());
if (skipRetryableErrors) if (skipRetryableErrors)
{ {
errno = EAGAIN;
return -1; return -1;
} }
sleep(5); sleep(5);
@@ -465,6 +469,7 @@ int S3Storage::exists(const string &_key, bool *out)
s3err_msgs[s3err], bucket.c_str(), key.c_str()); s3err_msgs[s3err], bucket.c_str(), key.c_str());
if (skipRetryableErrors) if (skipRetryableErrors)
{ {
errno = EAGAIN;
return -1; return -1;
} }
sleep(5); sleep(5);