提交 45b93280 编写于 作者: L Liu Jicong

refactor: support submitreq2

上级 c5dc7e82
...@@ -221,10 +221,10 @@ typedef struct SSnapContext { ...@@ -221,10 +221,10 @@ typedef struct SSnapContext {
} SSnapContext; } SSnapContext;
typedef struct STqReader { typedef struct STqReader {
const SSubmitReq *pMsg; // const SSubmitReq *pMsg;
// SSubmitBlk *pBlock; // SSubmitBlk *pBlock;
// SSubmitMsgIter msgIter; // SSubmitMsgIter msgIter;
// SSubmitBlkIter blkIter; // SSubmitBlkIter blkIter;
int64_t ver; int64_t ver;
SPackedSubmit msg2; SPackedSubmit msg2;
......
...@@ -673,10 +673,8 @@ int32_t tqProcessPollReq(STQ* pTq, SRpcMsg* pMsg) { ...@@ -673,10 +673,8 @@ int32_t tqProcessPollReq(STQ* pTq, SRpcMsg* pMsg) {
req.epoch, TD_VID(pTq->pVnode), fetchVer, pHead->msgType); req.epoch, TD_VID(pTq->pVnode), fetchVer, pHead->msgType);
if (pHead->msgType == TDMT_VND_SUBMIT) { if (pHead->msgType == TDMT_VND_SUBMIT) {
SSubmitReq* pCont = (SSubmitReq*)&pHead->body;
SPackedSubmit submit = { SPackedSubmit submit = {
.msgStr = pCont, .msgStr = pHead->body,
.msgLen = pHead->bodyLen, .msgLen = pHead->bodyLen,
.ver = pHead->version, .ver = pHead->version,
}; };
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册