xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

ci(stream):add stream unit test

This commit is contained in:
54liuyao 2024-12-23 19:10:10 +08:00
parent 4adf24b466
commit 0452c21ff6
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
source/libs/stream/test/streamCheckPointTest.cpp
View File

@ -2,6 +2,7 @@
#include "tstream.h" #include "tstream.h"
#include "streamInt.h" #include "streamInt.h"
#include "tcs.h" #include "tcs.h"
#include "tglobal.h"
#pragma GCC diagnostic push #pragma GCC diagnostic push
#pragma GCC diagnostic ignored "-Wwrite-strings" #pragma GCC diagnostic ignored "-Wwrite-strings"
@ -386,10 +387,12 @@ TEST(sstreamTaskGetTriggerRecvStatusTest, streamTaskGetTriggerRecvStatusFnTest)
EXPECT_NE(code, TSDB_CODE_SUCCESS); EXPECT_NE(code, TSDB_CODE_SUCCESS);
tcsInit(); tcsInit();
extern int8_t tsS3EpNum;
tsS3EpNum = 1;
code = uploadCheckpointToS3("123", "/tmp/backend5/stream"); code = uploadCheckpointToS3("123", "/tmp/backend5/stream");
EXPECT_EQ(code, TSDB_CODE_SUCCESS); EXPECT_EQ(code, TSDB_CODE_SUCCESS);
code = downloadCheckpointByNameS3("123", "/root/download", "123"); code = downloadCheckpointByNameS3("123", "/root/download", "");
EXPECT_EQ(code, TSDB_CODE_SUCCESS); EXPECT_NE(code, TSDB_CODE_OUT_OF_RANGE);
} }