提交 e73129fd 编写于 作者: H Haojun Liao

refactor: do some internal refactor.

上级 7f29a4a6
...@@ -284,6 +284,7 @@ int32_t tsDecompressINTImp(const char *const input, const int32_t nelements, cha ...@@ -284,6 +284,7 @@ int32_t tsDecompressINTImp(const char *const input, const int32_t nelements, cha
int64_t* p = (int64_t*) output; int64_t* p = (int64_t*) output;
if (selector == 0 || selector == 1) { if (selector == 0 || selector == 1) {
#if 0
int32_t batch = elems >> 2; int32_t batch = elems >> 2;
int32_t remainder = elems & 0x3; int32_t remainder = elems & 0x3;
int32_t gBatch = (nelements - count) >> 2; int32_t gBatch = (nelements - count) >> 2;
...@@ -305,6 +306,10 @@ int32_t tsDecompressINTImp(const char *const input, const int32_t nelements, cha ...@@ -305,6 +306,10 @@ int32_t tsDecompressINTImp(const char *const input, const int32_t nelements, cha
} }
count += minRemain; count += minRemain;
#endif
for (int32_t i = 0; i < elems && count < nelements; i++, count++) {
p[_pos++] = prev_value;
}
} else { } else {
int32_t batch = elems >> 2; int32_t batch = elems >> 2;
int32_t remain = elems & 0x03; int32_t remain = elems & 0x03;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册