This commit is contained in:
Hongze Cheng 2024-03-12 09:48:28 +08:00
parent 31a9b64fb0
commit 4b791d67ba
3 changed files with 6 additions and 4 deletions

View File

@ -171,7 +171,8 @@ static FORCE_INLINE int32_t tBufferPutF64(SBuffer *buffer, double value) {
// reader // reader
// SBufferReader // SBufferReader
static int32_t tBufferReaderInit(SBufferReader *reader, uint32_t offset, SBuffer *buffer) { static int32_t tBufferReaderInit(SBufferReader *reader, uint32_t offset, SBuffer *buffer) {
(*reader) = BUFFER_READER_INITIALIZER(offset, buffer); reader->offset = offset;
reader->buffer = buffer;
return 0; return 0;
} }

View File

@ -5776,7 +5776,7 @@ static int32_t columnDefNodeToField(SNodeList* pList, SArray** pArray) {
field.flags |= COL_SMA_ON; field.flags |= COL_SMA_ON;
} }
if (pCol->is_pk) { if (pCol->is_pk) {
field.flags != COL_IS_KEY; field.flags |= COL_IS_KEY;
} }
taosArrayPush(*pArray, &field); taosArrayPush(*pArray, &field);
} }
@ -6158,7 +6158,7 @@ static void toSchema(const SColumnDefNode* pCol, col_id_t colId, SSchema* pSchem
flags |= COL_SMA_ON; flags |= COL_SMA_ON;
} }
if (pCol->is_pk) { if (pCol->is_pk) {
flags != COL_IS_KEY; flags |= COL_IS_KEY;
} }
pSchema->colId = colId; pSchema->colId = colId;
pSchema->type = pCol->dataType.type; pSchema->type = pCol->dataType.type;

View File

@ -250,7 +250,8 @@ TEST(BufferTest, forwardWriteAndRead) {
} }
// read // read
SBufferReader reader = BUFFER_READER_INITIALIZER(0, &buffer); SBufferReader reader;
tBufferReaderInit(&reader, 0, &buffer);
/* fix-len struct */ /* fix-len struct */
STestStruct testStruct2 = {1, 2}; STestStruct testStruct2 = {1, 2};