refactor tranport
This commit is contained in:
parent
a0abe67432
commit
1685fab216
|
@ -1806,10 +1806,11 @@ static void cliBatchDealReq(queue* wq, SCliThrd* pThrd) {
|
||||||
|
|
||||||
SCliMsg* pMsg = QUEUE_DATA(h, SCliMsg, q);
|
SCliMsg* pMsg = QUEUE_DATA(h, SCliMsg, q);
|
||||||
|
|
||||||
if (pMsg->type == Normal) {
|
// if (pMsg->type == Normal) {
|
||||||
cliBuildBatch(pMsg, h, pThrd);
|
// cliBuildBatch(pMsg, h, pThrd);
|
||||||
count++;
|
// continue;
|
||||||
}
|
// // count++;
|
||||||
|
// }
|
||||||
if (pMsg->type == Normal && REQUEST_NO_RESP(&pMsg->msg)) {
|
if (pMsg->type == Normal && REQUEST_NO_RESP(&pMsg->msg)) {
|
||||||
cliBuildBatch(pMsg, h, pThrd);
|
cliBuildBatch(pMsg, h, pThrd);
|
||||||
continue;
|
continue;
|
||||||
|
|
Loading…
Reference in New Issue