diff options
| author | 李佳 <[email protected]> | 2024-04-12 11:41:14 +0000 |
|---|---|---|
| committer | 李佳 <[email protected]> | 2024-04-12 11:41:14 +0000 |
| commit | f40db506ee7570e836ac97b7806a679bc36da155 (patch) | |
| tree | e4483ca1d2a28079c57ab6f0ac055dfe08c47915 /test/http_decoder_gtest.cpp | |
| parent | 55ac6e270ae37299e2bce3a47a3d784e29dcae14 (diff) | |
| parent | 094d0f8e45931b195e358989d2843a298e9fd567 (diff) | |
Merge branch 'api-unit-test' into 'develop'
Add unit tests.
See merge request stellar/http_decoder!5
Diffstat (limited to 'test/http_decoder_gtest.cpp')
| -rw-r--r-- | test/http_decoder_gtest.cpp | 17 |
1 files changed, 13 insertions, 4 deletions
diff --git a/test/http_decoder_gtest.cpp b/test/http_decoder_gtest.cpp index 5eaf1db..a853080 100644 --- a/test/http_decoder_gtest.cpp +++ b/test/http_decoder_gtest.cpp @@ -28,6 +28,8 @@ extern "C" #include "stellar/session_mq.h" #include "md5.h" int commit_test_result_json(cJSON *node, const char *name); + extern int http_decoder_test_entry(struct session *sess, int topic_id, const void *data,void *cb_arg); + static HTTP_DECODER_PLUG_ENTRY_FUN_T g_entry_fun = http_decoder_test_entry; } #endif @@ -52,6 +54,8 @@ static int g_header_count = 1; static int g_exdata_idx = 0; static int g_topic_id = 0; + + #if 0 void output_http_req_line(struct http_request_line *req_line) { @@ -318,7 +322,7 @@ http_decoder_test_entry(struct session *sess, int topic_id, const void *data, req_line_to_json(gtest_plug_exdata->result_jnode[HTTP_TRANSACTION_REQ], &req_line); break; case HTTP_MESSAGE_REQ_HEADER: - while (http_message_header_next(msg, &header) > 0) + while (http_message_header_next(msg, &header) >= 0) { http_header_to_json(gtest_plug_exdata->result_jnode[HTTP_TRANSACTION_REQ], &header); } @@ -338,7 +342,7 @@ http_decoder_test_entry(struct session *sess, int topic_id, const void *data, res_line_to_json(gtest_plug_exdata->result_jnode[HTTP_TRANSACTION_RES], &res_line); break; case HTTP_MESSAGE_RES_HEADER: - while (http_message_header_next(msg, &header) > 0) + while (http_message_header_next(msg, &header) >= 0) { http_header_to_json(gtest_plug_exdata->result_jnode[HTTP_TRANSACTION_RES], &header); } @@ -399,8 +403,8 @@ extern "C" void *http_decoder_test_init(struct stellar *st) exit(-1); } - session_mq_subscribe_topic(st, g_topic_id, http_decoder_test_entry, NULL); - printf("http_decoder_test_init OK!\n"); + session_mq_subscribe_topic(st, g_topic_id, g_entry_fun, NULL); + // printf("http_decoder_test_init OK!\n"); return NULL; } @@ -413,4 +417,9 @@ extern "C" void http_decoder_test_exit(void *test_ctx) } printf("http_decoder_test_exit OK!\n"); +} + +extern "C" void http_decoder_plug_set_entry_fuc(HTTP_DECODER_PLUG_ENTRY_FUN_T entry_fun) +{ + g_entry_fun = entry_fun; }
\ No newline at end of file |