diff options
| author | pengxuanzheng <[email protected]> | 2021-09-27 15:53:52 +0800 |
|---|---|---|
| committer | pengxuanzheng <[email protected]> | 2021-09-27 15:53:52 +0800 |
| commit | 1d46e5f3647e1bebaa5142247c7d6601b4010821 (patch) | |
| tree | 369c7f6d4a536a671f75fa2677eb8fc246531bd5 | |
| parent | f9bce9d590407cea1ab9764f7c10342ffb4eb795 (diff) | |
🐞 fix(TSG-7946): 修复position误增加的bug
| -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; |
