summaryrefslogtreecommitdiff
path: root/example
diff options
context:
space:
mode:
authorpengxuanzheng <[email protected]>2020-09-24 11:24:42 +0800
committerpengxuanzheng <[email protected]>2020-11-02 18:59:51 +0800
commit6039e30be1d20e42cda67a41a98feaaf9cc13ab4 (patch)
treeb444b71f668782330e9286279e821536319f52c2 /example
parentb3e7de2b213931626a3c856355d44bb112b83274 (diff)
修改example名称
Diffstat (limited to 'example')
-rwxr-xr-xexample/singleThreadbin17088 -> 0 bytes
-rw-r--r--example/single_thread.cpp150
-rw-r--r--example/single_thread.cpp_old115
3 files changed, 0 insertions, 265 deletions
diff --git a/example/singleThread b/example/singleThread
deleted file mode 100755
index bf348577..00000000
--- a/example/singleThread
+++ /dev/null
Binary files differ
diff --git a/example/single_thread.cpp b/example/single_thread.cpp
deleted file mode 100644
index 71a4e6a4..00000000
--- a/example/single_thread.cpp
+++ /dev/null
@@ -1,150 +0,0 @@
-/*************************************************************************
- > File Name: single_thread.cpp
- > Author: pxz
- > Created Time: Fri 11 Sep 2020 09:52:05 AM CST
- ************************************************************************/
-extern "C"
-{
-#include<stdio.h>
-#include<stdlib.h>
-#include<unistd.h>
-#include<string.h>
-#include<time.h>
-}
-#include"../src/hos_client.h"
-
-//#define test_times 10000
-
-#define debuginfo (void)
-
-typedef struct userdata_s
-{
- struct timespec *finished;
-}userdata_t;
-
-static size_t calc_time(struct timespec start, struct timespec end)
-{
- return (end.tv_sec * 1000 * 1000 * 1000 + end.tv_nsec -
- (start.tv_sec * 1000 * 1000 * 1000 + start.tv_nsec));
-}
-
-int file_to_buffer(const char *file, char *buffer, size_t *len)
-{
- FILE *fp = fopen(file, "r");
- int num = 0;
- *len = 0;
- if (fp == NULL)
- {
- debuginfo("fopen file failed:%s\n", file);
- return -1;
- }
- do{
- num = fread(&buffer[*len], 1, 4096, fp);
- if (num < 0)
- {
- return -1;
- }
- *len += num;
- }while(num == 4096);
- fclose(fp);
- return 0;
-}
-
-void callback(bool result, const char *error, void *userdata)
-{
- userdata_t *data = (userdata_t *)userdata;
- clock_gettime(CLOCK_MONOTONIC, data->finished);
- return ;
-}
-
-int main(int argc, char *argv[])
-{
- if (argc != 4)
- {
- debuginfo("usege: singThread [bucket name] [object name]\n");
- return -1;
- }
- struct timespec start, end, finished;
- size_t time;
- int i = 0;
- char *bucket = argv[1];
- char *object = argv[2];
- int test_times = atoi(argv[3]);
- //int test_times = 10000;
- //char *buf = (char *)malloc(1024 * 1024 * 4);
- char buf[1024 * 1024 * 4];
- size_t buf_size;
- int mode = FILE_MODE;
- size_t fd = 0;
- userdata_t data = {&finished};
-
- file_to_buffer(object, buf, &buf_size);
-
- debuginfo("hos_client_init start ...\n");
- hos_client_handle handle = hos_client_create("http://192.168.44.10:9098/hos/", "default", "default", 4);
- if (handle == NULL)
- {
- debuginfo("error:hos_client_handle\n");
- return -1;
- }
- debuginfo("hos_client_init success ... \n");
-
- debuginfo("hos_create_bucket start ... \n");
- if(hos_create_bucket(handle, bucket))
- {
- debuginfo("hos_create_bucket failed ... \n");
- return -1;
- }
- debuginfo("hos_create_bucket success ... \n");
-
- debuginfo("hos_verify_bucket start ... \n");
- if(!hos_verify_bucket(handle, bucket))
- {
- debuginfo("hos_verify_bucket failed ... \n");
- return -1;
- }
- debuginfo("hos_verify_bucket success ... \n");
-
-#if 0
- fd = hos_open_fd(handle, bucket, object, callback, (void *)&data, 0, mode);
- debuginfo("hos_upload_file start ...\n");
- clock_gettime(CLOCK_MONOTONIC, &start);
- for (i = 0; i < test_times; i++)
- {
- hos_write(fd, object, 0, 0);
- }
- clock_gettime(CLOCK_MONOTONIC, &end);
- time = calc_time(start, end);
- time /= test_times;
- printf("hos_upload_file spent %llu ns\n", time);
- debuginfo("hos_upload_file end ...\n");
-#else
-
- mode = BUFF_MODE;
- fd = 0;
- fd = hos_open_fd(handle, bucket, object, callback, (void *)&data, 0, mode);
- debuginfo("hos_upload_buf start ...\n");
- clock_gettime(CLOCK_MONOTONIC, &start);
- for (i = 0; i < test_times; i++)
- {
- hos_write(fd, buf, buf_size, 0);
- }
- clock_gettime(CLOCK_MONOTONIC, &end);
- time = calc_time(start, end);
- time /= test_times;
- printf("hos_upload_buf spent %llu ns\n", time);
- debuginfo("hos_upload_buf end ...\n");
-
-#endif
- debuginfo("hos_client_close start ...\n");
- if (hos_client_destory(handle) == 0)
- {
- time = calc_time(start, finished);
- time /= test_times;
- printf("hos upload finished spent %llu ns\n", time);
- }
-
- debuginfo("hos_client_close end ...\n");
-
- return 0;
-}
diff --git a/example/single_thread.cpp_old b/example/single_thread.cpp_old
deleted file mode 100644
index c11f6dcd..00000000
--- a/example/single_thread.cpp_old
+++ /dev/null
@@ -1,115 +0,0 @@
-/*************************************************************************
- > File Name: single_thread.cpp
- > Author: pxz
- > Created Time: Fri 11 Sep 2020 09:52:05 AM CST
- ************************************************************************/
-extern "C"
-{
-#include<stdio.h>
-#include<unistd.h>
-#include<string.h>
-#include<time.h>
-}
-#include"../src/hos_client.h"
-
-#define MAX_TEST_TIMES 10
-
-static size_t calc_time(struct timespec start, struct timespec end)
-{
- return (end.tv_sec * 1000 * 1000 * 1000 + end.tv_nsec -
- (start.tv_sec * 1000 * 1000 * 1000 + start.tv_nsec));
-}
-
-void callback(bool result, const char *error, void *userdata)
-{
- //printf("result : %s\n", result ? "true":"false");
- if (result)
- return ;
- //printf("error: %s\n", error);
- //printf("userdata:%s\n", (char *)userdata);
- return ;
-}
-
-int main(int argc, char *argv[])
-{
- if (argc != 3)
- {
- printf("usege: singThread [bucket name] [object name]\n");
- return -1;
- }
- struct timespec start, end;
- size_t time;
- int i = 0;
- char *bucket = argv[1];
- char *object = argv[2];
- printf("hos_client_init start ...\n");
- hos_client_handle handle = hos_client_create("http://192.168.44.12:9098/hos/", "default", "default", 4);
- if (handle == NULL)
- {
- printf("error:hos_client_handle\n");
- return -1;
- }
- printf("hos_client_init success ... \n");
-
- printf("hos_create_bucket start ... \n");
- if(hos_create_bucket(handle, bucket))
- {
- printf("hos_create_bucket failed ... \n");
- return -1;
- }
- printf("hos_create_bucket success ... \n");
-
- printf("hos_verify_bucket start ... \n");
- if(!hos_verify_bucket(handle, bucket))
- {
- printf("hos_verify_bucket failed ... \n");
- return -1;
- }
- printf("hos_verify_bucket success ... \n");
-
- printf("hos_upload_file start ...\n");
-#if 1
- clock_gettime(CLOCK_MONOTONIC, &start);
- for (i = 0; i < MAX_TEST_TIMES; i++)
- {
- hos_upload_file(handle, bucket, object, callback, (void *)"this is userdata", 0);
- }
- clock_gettime(CLOCK_MONOTONIC, &end);
- time = calc_time(start, end);
- time /= MAX_TEST_TIMES;
- printf("hos_upload_file spent %llu ns\n", time);
-#if 0
- for (i = 0; i < MAX_TEST_TIMES; i++)
- {
- hos_close_fd(i, 0);
- }
-#endif
- printf("hos_upload_file end ...\n");
-#else
-
- const char *buf = "this is hos_upload_buf\n";
- size_t buf_len = strlen(buf);
- printf("hos_upload_buf start ...\n");
- clock_gettime(CLOCK_MONOTONIC, &start);
- for (i = 1; i <= MAX_TEST_TIMES; i++)
- {
- hos_upload_buf(handle, bucket, object, buf, buf_len, callback, (void *)"this is userdata", 0);
- }
- clock_gettime(CLOCK_MONOTONIC, &end);
- time = calc_time(start, end);
- time /= MAX_TEST_TIMES;
- printf("hos_upload_buf spent %llu ns\n", time);
-
- for (i = 1; i <= MAX_TEST_TIMES; i++)
- {
- hos_close_fd(i, 0);
- }
- printf("hos_upload_buf end ...\n");
-
-#endif
- printf("hos_client_close start ...\n");
- hos_client_destory(handle);
- printf("hos_client_close end ...\n");
-
- return 0;
-}