diff options
| author | pengxuanzheng <[email protected]> | 2020-10-20 17:21:31 +0800 |
|---|---|---|
| committer | pengxuanzheng <[email protected]> | 2020-11-02 19:00:22 +0800 |
| commit | 8ba2e43c9e468dae6aaf72ae112752d0a2e267e8 (patch) | |
| tree | db1ca4ee3ab505719cdd1f0238da22b6142d39e1 | |
| parent | e5f5062f51ea4ea7af418e1161e3139ae9fea984 (diff) | |
修改测试代码
| -rw-r--r-- | example/performance/HosClientPerformance.cpp | 11 |
1 files changed, 8 insertions, 3 deletions
diff --git a/example/performance/HosClientPerformance.cpp b/example/performance/HosClientPerformance.cpp index 8dd43a5a..3b42b892 100644 --- a/example/performance/HosClientPerformance.cpp +++ b/example/performance/HosClientPerformance.cpp @@ -199,6 +199,7 @@ static int upload_buff(char * buff, int buff_len, int test_times, thread_info_t conf_t *conf = &thread_info->conf; char file_size[128]; char append_size[128]; + size_t drop_cnt = 0; fd = hos_open_fd(thread_info->handle, conf->bucket, conf->object, callback, NULL, thread_info->thread_num, conf->mode); #if 0 @@ -277,11 +278,15 @@ static int upload_buff(char * buff, int buff_len, int test_times, thread_info_t clock_gettime(CLOCK_MONOTONIC, &tstart); for (i = 0; i < test_times; i++) { - hos_write(fd, buff, buff_len, thread_info->thread_num); + if (hos_write(fd, buff, buff_len, thread_info->thread_num) != HOS_CLIENT_OK) + { + //printf("error: hos_write error\n"); + drop_cnt++; + } } clock_gettime(CLOCK_MONOTONIC, &ttmp); time = calc_time(tstart, ttmp); - time /= test_times; + time /= (test_times - drop_cnt); sprintf(file_size, "%dk", buff_len / 1024); sprintf(append_size, "%luk", conf->append_size / 1024); @@ -309,7 +314,7 @@ static void *put_object_thread(void *ptr) char *buff = NULL; char file_name[100][256]; struct stat s_buf; - int test_times = 1000; + int test_times = 100; buff = (char *)malloc(30 * 1024 * 1024); if (buff == NULL) |