gfwleak/stellar-stellar
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

🧪 test(mq test case): more test case

Browse Source
This commit is contained in:
yangwei
2024-09-14 10:51:02 +08:00
parent 364f8c84a3
commit a23411f453
2 changed files with 65 additions and 1095 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
include/stellar/mq.h
View File

@@ -14,9 +14,9 @@ struct mq_runtime *mq_runtime_new(struct mq_schema *s);
void mq_runtime_free(struct mq_runtime *s); void mq_runtime_free(struct mq_runtime *s);
typedef void mq_msg_free_cb_func(void *msg, void *msg_free_arg); typedef void mq_msg_free_cb_func(void *msg, void *msg_free_arg);
typedef void on_msg_cb_func(int topic_id, const void *msg, void *on_msg_arg); typedef void on_msg_cb_func(int topic_id, void *msg, void *on_msg_arg);
typedef void on_msg_dispatch_cb_func(int topic_id, typedef void on_msg_dispatch_cb_func(int topic_id,
const void *msg, void *msg,
on_msg_cb_func* on_msg_cb, on_msg_cb_func* on_msg_cb,
void *on_msg_cb_arg, void *on_msg_cb_arg,
void *dispatch_arg); void *dispatch_arg);

1156
infra/mq/test/gtest_mq_main.cpp
View File

File diff suppressed because it is too large Load Diff