Skip to content

T
TDengine

taosdata / TDengine
12 个月 前同步成功

通知 1180
Star 22014
Fork 4786
T
TDengine

体验新版 GitCode，发现更多精彩内容 >>

提交 f464ecb9 编写于 作者: dengyihao's avatar dengyihao
浏览文件
操作

fix: rpc query limit

上级 7d71a07a
隐藏空白更改
内联 并排
Showing with 55 addition and 54 deletion
source/util/test/procTest.cpp
浏览文件 @ f464ecb9
...@@ -16,11 +16,11 @@ ...@@ -16,11 +16,11 @@
typedef struct STestMsg { typedef struct STestMsg {
uint16_t msgType; uint16_t msgType;
void *pCont; void * pCont;
int contLen; int contLen;
int32_t code; int32_t code;
void *handle; // rpc handle returned to app void * handle; // rpc handle returned to app
void *ahandle; // app handle set by client void * ahandle; // app handle set by client
int noResp; // has response or not(default 0, 0: resp, 1: no resp); int noResp; // has response or not(default 0, 0: resp, 1: no resp);
int persistHandle; // persist handle or not int persistHandle; // persist handle or not
} STestMsg; } STestMsg;
...@@ -37,7 +37,7 @@ class UtilTesProc : public ::testing::Test { ...@@ -37,7 +37,7 @@ class UtilTesProc : public ::testing::Test {
head.msgType = 2; head.msgType = 2;
head.noResp = 3; head.noResp = 3;
head.persistHandle = 4; head.persistHandle = 4;
tsRpcQueueMemoryAllowed = 1024 * 1024 * 64;
taosRemoveDir("/tmp/td"); taosRemoveDir("/tmp/td");
taosMkDir("/tmp/td"); taosMkDir("/tmp/td");
tstrncpy(tsLogDir, "/tmp/td", PATH_MAX); tstrncpy(tsLogDir, "/tmp/td", PATH_MAX);
...@@ -64,18 +64,18 @@ TEST_F(UtilTesProc, 00_Init_Cleanup) { ...@@ -64,18 +64,18 @@ TEST_F(UtilTesProc, 00_Init_Cleanup) {
shm.size = 1023; shm.size = 1023;
SProcCfg cfg = {(ProcConsumeFp)NULL, SProcCfg cfg = {(ProcConsumeFp)NULL,
(ProcMallocFp)taosAllocateQitem, (ProcMallocFp)taosAllocateQitem,
(ProcFreeFp)taosFreeQitem, (ProcFreeFp)taosFreeQitem,
(ProcMallocFp)taosMemoryMalloc, (ProcMallocFp)taosMemoryMalloc,
(ProcFreeFp)taosMemoryMalloc, (ProcFreeFp)taosMemoryMalloc,
(ProcConsumeFp)NULL, (ProcConsumeFp)NULL,
(ProcMallocFp)taosMemoryMalloc, (ProcMallocFp)taosMemoryMalloc,
(ProcFreeFp)taosMemoryFree, (ProcFreeFp)taosMemoryFree,
(ProcMallocFp)taosMemoryMalloc, (ProcMallocFp)taosMemoryMalloc,
(ProcFreeFp)taosMemoryMalloc, (ProcFreeFp)taosMemoryMalloc,
shm, shm,
&shm, &shm,
"1234"}; "1234"};
SProcObj *proc = taosProcInit(&cfg); SProcObj *proc = taosProcInit(&cfg);
ASSERT_EQ(proc, nullptr); ASSERT_EQ(proc, nullptr);
...@@ -105,18 +105,18 @@ TEST_F(UtilTesProc, 01_Push_Pop_Child) { ...@@ -105,18 +105,18 @@ TEST_F(UtilTesProc, 01_Push_Pop_Child) {
shm.size = 3000; shm.size = 3000;
ASSERT_EQ(taosCreateShm(&shm, 1235, shm.size), 0); ASSERT_EQ(taosCreateShm(&shm, 1235, shm.size), 0);
SProcCfg cfg = {(ProcConsumeFp)ConsumeChild1, SProcCfg cfg = {(ProcConsumeFp)ConsumeChild1,
(ProcMallocFp)taosAllocateQitem, (ProcMallocFp)taosAllocateQitem,
(ProcFreeFp)taosFreeQitem, (ProcFreeFp)taosFreeQitem,
(ProcMallocFp)taosMemoryMalloc, (ProcMallocFp)taosMemoryMalloc,
(ProcFreeFp)taosMemoryFree, (ProcFreeFp)taosMemoryFree,
(ProcConsumeFp)NULL, (ProcConsumeFp)NULL,
(ProcMallocFp)taosMemoryMalloc, (ProcMallocFp)taosMemoryMalloc,
(ProcFreeFp)taosMemoryFree, (ProcFreeFp)taosMemoryFree,
(ProcMallocFp)taosMemoryMalloc, (ProcMallocFp)taosMemoryMalloc,
(ProcFreeFp)taosMemoryFree, (ProcFreeFp)taosMemoryFree,
shm, shm,
(void *)((int64_t)1235), (void *)((int64_t)1235),
"1235_c"}; "1235_c"};
SProcObj *cproc = taosProcInit(&cfg); SProcObj *cproc = taosProcInit(&cfg);
ASSERT_NE(cproc, nullptr); ASSERT_NE(cproc, nullptr);
...@@ -163,18 +163,18 @@ TEST_F(UtilTesProc, 02_Push_Pop_Parent) { ...@@ -163,18 +163,18 @@ TEST_F(UtilTesProc, 02_Push_Pop_Parent) {
shm.size = 3000; shm.size = 3000;
ASSERT_EQ(taosCreateShm(&shm, 1236, shm.size), 0); ASSERT_EQ(taosCreateShm(&shm, 1236, shm.size), 0);
SProcCfg cfg = {(ProcConsumeFp)NULL, SProcCfg cfg = {(ProcConsumeFp)NULL,
(ProcMallocFp)taosAllocateQitem, (ProcMallocFp)taosAllocateQitem,
(ProcFreeFp)taosFreeQitem, (ProcFreeFp)taosFreeQitem,
(ProcMallocFp)taosMemoryMalloc, (ProcMallocFp)taosMemoryMalloc,
(ProcFreeFp)taosMemoryFree, (ProcFreeFp)taosMemoryFree,
(ProcConsumeFp)ConsumeParent1, (ProcConsumeFp)ConsumeParent1,
(ProcMallocFp)taosMemoryMalloc, (ProcMallocFp)taosMemoryMalloc,
(ProcFreeFp)taosMemoryFree, (ProcFreeFp)taosMemoryFree,
(ProcMallocFp)taosMemoryMalloc, (ProcMallocFp)taosMemoryMalloc,
(ProcFreeFp)taosMemoryFree, (ProcFreeFp)taosMemoryFree,
shm, shm,
(void *)((int64_t)1236), (void *)((int64_t)1236),
"1236_c"}; "1236_c"};
SProcObj *cproc = taosProcInit(&cfg); SProcObj *cproc = taosProcInit(&cfg);
ASSERT_NE(cproc, nullptr); ASSERT_NE(cproc, nullptr);
...@@ -217,18 +217,18 @@ TEST_F(UtilTesProc, 03_Handle) { ...@@ -217,18 +217,18 @@ TEST_F(UtilTesProc, 03_Handle) {
shm.size = 3000; shm.size = 3000;
ASSERT_EQ(taosCreateShm(&shm, 1237, shm.size), 0); ASSERT_EQ(taosCreateShm(&shm, 1237, shm.size), 0);
SProcCfg cfg = {(ProcConsumeFp)ConsumeChild3, SProcCfg cfg = {(ProcConsumeFp)ConsumeChild3,
(ProcMallocFp)taosAllocateQitem, (ProcMallocFp)taosAllocateQitem,
(ProcFreeFp)taosFreeQitem, (ProcFreeFp)taosFreeQitem,
(ProcMallocFp)taosMemoryMalloc, (ProcMallocFp)taosMemoryMalloc,
(ProcFreeFp)taosMemoryFree, (ProcFreeFp)taosMemoryFree,
(ProcConsumeFp)NULL, (ProcConsumeFp)NULL,
(ProcMallocFp)taosMemoryMalloc, (ProcMallocFp)taosMemoryMalloc,
(ProcFreeFp)taosMemoryFree, (ProcFreeFp)taosMemoryFree,
(ProcMallocFp)taosMemoryMalloc, (ProcMallocFp)taosMemoryMalloc,
(ProcFreeFp)taosMemoryFree, (ProcFreeFp)taosMemoryFree,
shm, shm,
(void *)((int64_t)1235), (void *)((int64_t)1235),
"1237_p"}; "1237_p"};
SProcObj *cproc = taosProcInit(&cfg); SProcObj *cproc = taosProcInit(&cfg);
ASSERT_NE(cproc, nullptr); ASSERT_NE(cproc, nullptr);
...@@ -236,7 +236,8 @@ TEST_F(UtilTesProc, 03_Handle) { ...@@ -236,7 +236,8 @@ TEST_F(UtilTesProc, 03_Handle) {
int32_t i = 0; int32_t i = 0;
for (i = 0; i < 20; ++i) { for (i = 0; i < 20; ++i) {
head.handle = (void *)((int64_t)i); head.handle = (void *)((int64_t)i);
ASSERT_EQ(taosProcPutToChildQ(cproc, &head, sizeof(STestMsg), body, i, (void *)((int64_t)i), i, PROC_FUNC_REQ), 0); ASSERT_EQ(taosProcPutToChildQ(cproc, &head, sizeof(STestMsg), body, i, (void *)((int64_t)i), i, PROC_FUNC_REQ),
0);
} }
cfg.isChild = true; cfg.isChild = true;
...@@ -247,7 +248,7 @@ TEST_F(UtilTesProc, 03_Handle) { ...@@ -247,7 +248,7 @@ TEST_F(UtilTesProc, 03_Handle) {
taosProcCleanup(pproc); taosProcCleanup(pproc);
int64_t ref = 0; int64_t ref = 0;
ref = taosProcRemoveHandle(cproc, (void *)((int64_t)3)); ref = taosProcRemoveHandle(cproc, (void *)((int64_t)3));
EXPECT_EQ(ref, 3); EXPECT_EQ(ref, 3);
ref = taosProcRemoveHandle(cproc, (void *)((int64_t)5)); ref = taosProcRemoveHandle(cproc, (void *)((int64_t)5));
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或