chore: code format
This commit is contained in:
parent
e7c2c62e5c
commit
e360094f8a
|
@ -2012,9 +2012,9 @@ char* dumpBlockData(SSDataBlock* pDataBlock, const char* flag, char** pDataBuf)
|
||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
#if 0
|
#if 0
|
||||||
int32_t buildSubmitReqFromDataBlock(SSubmitReq2** pReq, const SSDataBlock* pDataBlock, STSchema* pTSchema, int32_t vgId,
|
int32_t buildSubmitReqFromDataBlock(SSubmitReq** pReq, const SSDataBlock* pDataBlock, STSchema* pTSchema, int32_t vgId,
|
||||||
tb_uid_t suid) {
|
tb_uid_t suid) {
|
||||||
int32_t bufSize = sizeof(SSubmitReq2);
|
int32_t bufSize = sizeof(SSubmitReq);
|
||||||
int32_t sz = 1;
|
int32_t sz = 1;
|
||||||
for (int32_t i = 0; i < sz; ++i) {
|
for (int32_t i = 0; i < sz; ++i) {
|
||||||
const SDataBlockInfo* pBlkInfo = &pDataBlock->info;
|
const SDataBlockInfo* pBlkInfo = &pDataBlock->info;
|
||||||
|
|
|
@ -224,7 +224,7 @@ static int32_t tdProcessTSmaInsertImpl(SSma *pSma, int64_t indexUid, const char
|
||||||
SRpcMsg submitReqMsg = {
|
SRpcMsg submitReqMsg = {
|
||||||
.msgType = TDMT_VND_SUBMIT,
|
.msgType = TDMT_VND_SUBMIT,
|
||||||
.pCont = pSubmitReq,
|
.pCont = pSubmitReq,
|
||||||
.contLen = ntohl(contLen),
|
.contLen = ntohl(pSubmitReq->length),
|
||||||
};
|
};
|
||||||
|
|
||||||
if (tmsgPutToQueue(&pSma->pVnode->msgCb, WRITE_QUEUE, &submitReqMsg) < 0) {
|
if (tmsgPutToQueue(&pSma->pVnode->msgCb, WRITE_QUEUE, &submitReqMsg) < 0) {
|
||||||
|
|
Loading…
Reference in New Issue