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

try fix window com error

This commit is contained in:
54liuyao 2024-12-20 14:23:04 +08:00
parent 5212710947
commit 89dc02012b
1 changed files with 37 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -2,6 +2,31 @@
#include "tstream.h" #include "tstream.h"
#include "streamInt.h" #include "streamInt.h"
#pragma GCC diagnostic push
#pragma GCC diagnostic ignored "-Wwrite-strings"
#pragma GCC diagnostic ignored "-Wunused-function"
#pragma GCC diagnostic ignored "-Wunused-variable"
#pragma GCC diagnostic ignored "-Wsign-compare"
#pragma GCC diagnostic ignored "-Wsign-compare"
#pragma GCC diagnostic ignored "-Wformat"
#pragma GCC diagnostic ignored "-Wint-to-pointer-cast"
#pragma GCC diagnostic ignored "-Wpointer-arith"
void initTaskLock(SStreamTask* pTask) {
TdThreadMutexAttr attr = {0};
int32_t code = taosThreadMutexAttrInit(&attr);
ASSERT_EQ(code, TSDB_CODE_SUCCESS);
code = taosThreadMutexAttrSetType(&attr, PTHREAD_MUTEX_RECURSIVE);
ASSERT_EQ(code, TSDB_CODE_SUCCESS);
code = taosThreadMutexInit(&pTask->lock, &attr);
ASSERT_EQ(code, TSDB_CODE_SUCCESS);
code = taosThreadMutexAttrDestroy(&attr);
ASSERT_EQ(code, TSDB_CODE_SUCCESS);
}
TEST(streamCheckpointTest, StreamTaskProcessCheckpointTriggerRsp) { TEST(streamCheckpointTest, StreamTaskProcessCheckpointTriggerRsp) {
SStreamTask* pTask = NULL; SStreamTask* pTask = NULL;
int64_t uid = 1111111111111111; int64_t uid = 1111111111111111;
@ -10,6 +35,8 @@ TEST(streamCheckpointTest, StreamTaskProcessCheckpointTriggerRsp) {
false, 1, &pTask); false, 1, &pTask);
ASSERT_EQ(code, TSDB_CODE_SUCCESS); ASSERT_EQ(code, TSDB_CODE_SUCCESS);
initTaskLock(pTask);
code = streamTaskCreateActiveChkptInfo(&pTask->chkInfo.pActiveInfo); code = streamTaskCreateActiveChkptInfo(&pTask->chkInfo.pActiveInfo);
ASSERT_EQ(code, TSDB_CODE_SUCCESS); ASSERT_EQ(code, TSDB_CODE_SUCCESS);
@ -46,6 +73,8 @@ TEST(streamCheckpointTest, StreamTaskSetFailedCheckpointId) {
false, 1, &pTask); false, 1, &pTask);
ASSERT_EQ(code, TSDB_CODE_SUCCESS); ASSERT_EQ(code, TSDB_CODE_SUCCESS);
initTaskLock(pTask);
code = streamTaskCreateActiveChkptInfo(&pTask->chkInfo.pActiveInfo); code = streamTaskCreateActiveChkptInfo(&pTask->chkInfo.pActiveInfo);
ASSERT_EQ(code, TSDB_CODE_SUCCESS); ASSERT_EQ(code, TSDB_CODE_SUCCESS);
@ -75,6 +104,8 @@ TEST(UploadCheckpointDataTest, UploadSuccess) {
false, 1, &pTask); false, 1, &pTask);
ASSERT_EQ(code, TSDB_CODE_SUCCESS); ASSERT_EQ(code, TSDB_CODE_SUCCESS);
initTaskLock(pTask);
code = streamTaskCreateActiveChkptInfo(&pTask->chkInfo.pActiveInfo); code = streamTaskCreateActiveChkptInfo(&pTask->chkInfo.pActiveInfo);
ASSERT_EQ(code, TSDB_CODE_SUCCESS); ASSERT_EQ(code, TSDB_CODE_SUCCESS);
@ -113,6 +144,8 @@ TEST(UploadCheckpointDataTest, UploadDisabled) {
false, 1, &pTask); false, 1, &pTask);
ASSERT_EQ(code, TSDB_CODE_SUCCESS); ASSERT_EQ(code, TSDB_CODE_SUCCESS);
initTaskLock(pTask);
code = streamTaskCreateActiveChkptInfo(&pTask->chkInfo.pActiveInfo); code = streamTaskCreateActiveChkptInfo(&pTask->chkInfo.pActiveInfo);
ASSERT_EQ(code, TSDB_CODE_SUCCESS); ASSERT_EQ(code, TSDB_CODE_SUCCESS);
@ -152,6 +185,8 @@ TEST(StreamTaskAlreadySendTriggerTest, AlreadySendTrigger) {
false, 1, &pTask); false, 1, &pTask);
ASSERT_EQ(code, TSDB_CODE_SUCCESS); ASSERT_EQ(code, TSDB_CODE_SUCCESS);
initTaskLock(pTask);
code = streamTaskCreateActiveChkptInfo(&pTask->chkInfo.pActiveInfo); code = streamTaskCreateActiveChkptInfo(&pTask->chkInfo.pActiveInfo);
ASSERT_EQ(code, TSDB_CODE_SUCCESS); ASSERT_EQ(code, TSDB_CODE_SUCCESS);
@ -190,6 +225,8 @@ TEST(ChkptTriggerRecvMonitorHelperTest, chkptTriggerRecvMonitorHelper) {
false, 1, &pTask); false, 1, &pTask);
ASSERT_EQ(code, TSDB_CODE_SUCCESS); ASSERT_EQ(code, TSDB_CODE_SUCCESS);
initTaskLock(pTask);
const char *path = "/tmp/backend5/stream"; const char *path = "/tmp/backend5/stream";
code = streamMetaOpen((path), NULL, NULL, NULL, 0, 0, NULL, &pTask->pMeta); code = streamMetaOpen((path), NULL, NULL, NULL, 0, 0, NULL, &pTask->pMeta);
ASSERT_EQ(code, TSDB_CODE_SUCCESS); ASSERT_EQ(code, TSDB_CODE_SUCCESS);