xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

refactor: fix syntax error.

This commit is contained in:
Haojun Liao 2023-11-13 09:14:04 +08:00
parent 3bdee86dea
commit 44da5833bb
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
source/util/src/tcompression.c
View File

@ -435,7 +435,7 @@ int32_t tsDecompressStringImp(const char *const input, int32_t compressedSize, c
// TODO: Take care here, we assumes little endian encoding. // TODO: Take care here, we assumes little endian encoding.
int32_t tsCompressTimestampImp(const char *const input, const int32_t nelements, char *const output) { int32_t tsCompressTimestampImp(const char *const input, const int32_t nelements, char *const output) {
int32_t _pos = 1; int32_t _pos = 1;
int32_t longBytes = tDataTypes[TSDB_DATA_TYPE_BIGINT].bytes; int32_t longBytes = LONG_BYTES;
ASSERTS(nelements >= 0, "nelements is negative"); ASSERTS(nelements >= 0, "nelements is negative");
@ -532,7 +532,7 @@ _exit_over:
} }
int32_t tsDecompressTimestampImp(const char *const input, const int32_t nelements, char *const output) { int32_t tsDecompressTimestampImp(const char *const input, const int32_t nelements, char *const output) {
int64_t longBytes = tDataTypes[TSDB_DATA_TYPE_BIGINT].bytes; int64_t longBytes = LONG_BYTES;
ASSERTS(nelements >= 0, "nelements is negative"); ASSERTS(nelements >= 0, "nelements is negative");
if (nelements == 0) return 0; if (nelements == 0) return 0;
@ -605,7 +605,7 @@ int32_t tsDecompressTimestampImp(const char *const input, const int32_t nelement
/* --------------------------------------------Double Compression ---------------------------------------------- */ /* --------------------------------------------Double Compression ---------------------------------------------- */
void encodeDoubleValue(uint64_t diff, uint8_t flag, char *const output, int32_t *const pos) { void encodeDoubleValue(uint64_t diff, uint8_t flag, char *const output, int32_t *const pos) {
int32_t longBytes = tDataTypes[TSDB_DATA_TYPE_BIGINT].bytes; int32_t longBytes = LONG_BYTES;
uint8_t nbytes = (flag & INT8MASK(3)) + 1; uint8_t nbytes = (flag & INT8MASK(3)) + 1;
int32_t nshift = (longBytes * BITS_PER_BYTE - nbytes * BITS_PER_BYTE) * (flag >> 3); int32_t nshift = (longBytes * BITS_PER_BYTE - nbytes * BITS_PER_BYTE) * (flag >> 3);
@ -703,7 +703,7 @@ int32_t tsCompressDoubleImp(const char *const input, const int32_t nelements, ch
} }
FORCE_INLINE uint64_t decodeDoubleValue(const char *const input, int32_t *const ipos, uint8_t flag) { FORCE_INLINE uint64_t decodeDoubleValue(const char *const input, int32_t *const ipos, uint8_t flag) {
int32_t longBytes = tDataTypes[TSDB_DATA_TYPE_BIGINT].bytes; int32_t longBytes = LONG_BYTES;
uint64_t diff = 0ul; uint64_t diff = 0ul;
int32_t nbytes = (flag & 0x7) + 1; int32_t nbytes = (flag & 0x7) + 1;