🐞 fix(TSG-7946): 修复position误增加的bug
This commit is contained in:
@@ -232,7 +232,6 @@ static void hos_client_create()
|
|||||||
|
|
||||||
g_hos_handle.buckets = outcome.GetResult().GetBuckets();
|
g_hos_handle.buckets = outcome.GetResult().GetBuckets();
|
||||||
g_hos_handle.count++;
|
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_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));
|
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;
|
return HOS_SEND_FAILED;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -93,7 +93,6 @@ typedef struct hos_client_handle_s
|
|||||||
Aws::S3::S3ClientMock *S3Client;
|
Aws::S3::S3ClientMock *S3Client;
|
||||||
#endif
|
#endif
|
||||||
Aws::Vector<Aws::S3::Model::Bucket> buckets;
|
Aws::Vector<Aws::S3::Model::Bucket> buckets;
|
||||||
std::shared_ptr<Aws::Utils::Threading::PooledThreadExecutor> executor;
|
|
||||||
size_t count; /* 记录了有多少个对象在使用hos */
|
size_t count; /* 记录了有多少个对象在使用hos */
|
||||||
hos_config_t hos_config;
|
hos_config_t hos_config;
|
||||||
hos_func_thread_t hos_func;
|
hos_func_thread_t hos_func;
|
||||||
|
|||||||
Reference in New Issue
Block a user