diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/hos_client.cpp | 3 | ||||
| -rw-r--r-- | src/hos_common.h | 1 |
2 files changed, 2 insertions, 2 deletions
diff --git a/src/hos_client.cpp b/src/hos_client.cpp index 3029af92..b4ec4113 100644 --- a/src/hos_client.cpp +++ b/src/hos_client.cpp @@ -232,7 +232,6 @@ static void hos_client_create() g_hos_handle.buckets = outcome.GetResult().GetBuckets(); g_hos_handle.count++; - g_hos_handle.executor = std::dynamic_pointer_cast<Aws::Utils::Threading::PooledThreadExecutor>(config.executor); g_hos_handle.task_num = (size_t *)calloc(hos_conf->thread_num, sizeof(size_t)); g_hos_handle.task_context = (size_t *)calloc(hos_conf->thread_num, sizeof(size_t)); @@ -510,6 +509,8 @@ static int hos_putobject_async(Aws::S3::Model::PutObjectRequest& request, size_t } } + atomic_sub(&((*fd)->position), 1); + return HOS_SEND_FAILED; } diff --git a/src/hos_common.h b/src/hos_common.h index 303fa626..fdc7c654 100644 --- a/src/hos_common.h +++ b/src/hos_common.h @@ -93,7 +93,6 @@ typedef struct hos_client_handle_s Aws::S3::S3ClientMock *S3Client; #endif Aws::Vector<Aws::S3::Model::Bucket> buckets; - std::shared_ptr<Aws::Utils::Threading::PooledThreadExecutor> executor; size_t count; /* 记录了有多少个对象在使用hos */ hos_config_t hos_config; hos_func_thread_t hos_func; |