diff --git a/source/dnode/mgmt/main/dndExec.c b/source/dnode/mgmt/main/dndExec.c index b2d5732706..830cca34e0 100644 --- a/source/dnode/mgmt/main/dndExec.c +++ b/source/dnode/mgmt/main/dndExec.c @@ -89,7 +89,7 @@ static int32_t dndNewProc(SMgmtWrapper *pWrapper, ENodeType n) { } static void dndProcessProcHandle(void *handle) { - dInfo("handle:%p, the child process dies and send an offline rsp", handle); + dWarn("handle:%p, the child process dies and send an offline rsp", handle); SRpcMsg rpcMsg = {.handle = handle, .code = TSDB_CODE_DND_OFFLINE}; rpcSendResponse(&rpcMsg); } diff --git a/source/dnode/mgmt/main/dndInt.c b/source/dnode/mgmt/main/dndInt.c index e85fe8a9fc..089377c302 100644 --- a/source/dnode/mgmt/main/dndInt.c +++ b/source/dnode/mgmt/main/dndInt.c @@ -106,7 +106,7 @@ SDnode *dndCreate(const SDnodeOpt *pOption) { } if (dndInitMsgHandle(pDnode) != 0) { - dError("failed to msg handles since %s", terrstr()); + dError("failed to init msg handles since %s", terrstr()); goto _OVER; } diff --git a/source/util/test/procTest.cpp b/source/util/test/procTest.cpp index 04a227e52b..1d1c9f66ae 100644 --- a/source/util/test/procTest.cpp +++ b/source/util/test/procTest.cpp @@ -10,16 +10,14 @@ */ #include -#include "sut.h" #include "tprocess.h" #include "tqueue.h" #include "trpc.h" +#include "tlog.h" class UtilTesProc : public ::testing::Test { public: void SetUp() override { - test.InitLog("/tmp/td"); - // uDebugFlag = 207; shm.id = -1; for (int32_t i = 0; i < 4000; ++i) { body[i] = i % 26 + 'a'; @@ -29,19 +27,24 @@ class UtilTesProc : public ::testing::Test { head.msgType = 2; head.noResp = 3; head.persistHandle = 4; + + taosRemoveDir("/tmp/td"); + taosMkDir("/tmp/td"); + tstrncpy(tsLogDir, "/tmp/td", PATH_MAX); + if (taosInitLog("taosdlog", 1) != 0) { + printf("failed to init log file\n"); + } } void TearDown() override { taosDropShm(&shm); } public: static SRpcMsg head; static char body[4000]; - static Testbase test; static SShm shm; static void SetUpTestSuite() {} static void TearDownTestSuite() {} }; -Testbase UtilTesProc::test; SShm UtilTesProc::shm; char UtilTesProc::body[4000]; SRpcMsg UtilTesProc::head;