TD-1673
This commit is contained in:
parent
6f549a28fd
commit
b772c35b45
|
@ -148,7 +148,7 @@ static void *dnodeProcessMnodePeerQueue(void *param) {
|
|||
|
||||
while (1) {
|
||||
if (taosReadQitemFromQset(tsMPeerQset, &type, (void **)&pPeerMsg, &unUsed) == 0) {
|
||||
dDebug("dnodeProcessMnodePeerQueue: got no message from qset, exiting...");
|
||||
dDebug("qset:%p, mnode peer got no message from qset, exiting", tsMPeerQset);
|
||||
break;
|
||||
}
|
||||
|
||||
|
|
|
@ -156,7 +156,7 @@ static void *dnodeProcessMnodeReadQueue(void *param) {
|
|||
|
||||
while (1) {
|
||||
if (taosReadQitemFromQset(tsMReadQset, &type, (void **)&pReadMsg, &unUsed) == 0) {
|
||||
dDebug("dnodeProcessMnodeReadQueue: got no message from qset, exiting...");
|
||||
dDebug("qset:%p, mnode read got no message from qset, exiting", tsMReadQset);
|
||||
break;
|
||||
}
|
||||
|
||||
|
|
|
@ -158,7 +158,7 @@ static void *dnodeProcessMnodeWriteQueue(void *param) {
|
|||
|
||||
while (1) {
|
||||
if (taosReadQitemFromQset(tsMWriteQset, &type, (void **)&pWrite, &unUsed) == 0) {
|
||||
dDebug("dnodeProcessMnodeWriteQueue: got no message from qset, exiting...");
|
||||
dDebug("qset:%p, mnode write got no message from qset, exiting", tsMWriteQset);
|
||||
break;
|
||||
}
|
||||
|
||||
|
|
|
@ -226,7 +226,7 @@ static void *dnodeProcessMgmtQueue(void *param) {
|
|||
|
||||
while (1) {
|
||||
if (taosReadQitemFromQset(tsMgmtQset, &type, (void **) &pMsg, &handle) == 0) {
|
||||
dDebug("dnode mgmt got no message from qset, exit ...");
|
||||
dDebug("qset:%p, dnode mgmt got no message from qset, exit", tsMgmtQset);
|
||||
break;
|
||||
}
|
||||
|
||||
|
|
|
@ -199,7 +199,7 @@ static void *dnodeProcessReadQueue(void *param) {
|
|||
|
||||
while (1) {
|
||||
if (taosReadQitemFromQset(readQset, &type, (void **)&pReadMsg, &pVnode) == 0) {
|
||||
dDebug("dnodeProcessReadQueee: got no message from qset, exiting...");
|
||||
dDebug("qset:%p dnode read got no message from qset, exiting", readQset);
|
||||
break;
|
||||
}
|
||||
|
||||
|
|
|
@ -222,7 +222,7 @@ static void *dnodeProcessWriteQueue(void *param) {
|
|||
while (1) {
|
||||
numOfMsgs = taosReadAllQitemsFromQset(pWorker->qset, pWorker->qall, &pVnode);
|
||||
if (numOfMsgs == 0) {
|
||||
dDebug("dnodeProcessWriteQueee: got no message from qset, exiting...");
|
||||
dDebug("qset:%p, dnode write got no message from qset, exiting", pWorker->qset);
|
||||
break;
|
||||
}
|
||||
|
||||
|
|
|
@ -1038,7 +1038,7 @@ static void *sdbWorkerFp(void *param) {
|
|||
while (1) {
|
||||
numOfMsgs = taosReadAllQitemsFromQset(tsSdbWriteQset, tsSdbWriteQall, &unUsed);
|
||||
if (numOfMsgs == 0) {
|
||||
sdbDebug("sdbWorkerFp: got no message from qset, exiting...");
|
||||
sdbDebug("qset:%p, sdb got no message from qset, exiting", tsSdbWriteQset);
|
||||
break;
|
||||
}
|
||||
|
||||
|
|
|
@ -67,7 +67,7 @@ static void *httpProcessResultQueue(void *param) {
|
|||
|
||||
while (1) {
|
||||
if (taosReadQitemFromQset(tsHttpQset, &type, (void **)&pMsg, &unUsed) == 0) {
|
||||
httpDebug("httpResultQueue: got no message from qset, exiting...");
|
||||
httpDebug("qset:%p, http queue got no message from qset, exiting", tsHttpQset);
|
||||
break;
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue