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

fix(util): change the load of __m128i value.

This commit is contained in:
Haojun Liao 2024-06-20 18:34:31 +08:00
parent e1cb4e021f
commit 852857eae9
1 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
source/util/src/tdecompress.c
View File

@ -351,18 +351,18 @@ int32_t tsDecompressTimestampAvx2(const char *const input, const int32_t nelemen
int8_t nbytes1 = flags & INT8MASK(4); // range of nbytes starts from 0 to 7 int8_t nbytes1 = flags & INT8MASK(4); // range of nbytes starts from 0 to 7
int8_t nbytes2 = (flags >> 4) & INT8MASK(4); int8_t nbytes2 = (flags >> 4) & INT8MASK(4);
__m128i data1; __m128i data1 = _mm_setzero_si128();
if (nbytes1 == 0) { if (nbytes1 > 0) {
data1 = _mm_setzero_si128(); int64_t tmp = 0;
} else { memcpy(&tmp, (const void*) (input + ipos), nbytes1);
memcpy(&data1, (const void*) (input + ipos), nbytes1); data1 = _mm_set1_epi64x(tmp);
} }
__m128i data2; __m128i data2 = _mm_setzero_si128();
if (nbytes2 == 0) { if (nbytes2 > 0) {
data2 = _mm_setzero_si128(); int64_t tmp = 0;
} else { memcpy(&tmp, (const void*) (input + ipos + nbytes1), nbytes2);
memcpy(&data2, (const void*) (input + ipos + nbytes1), nbytes2); data2 = _mm_set1_epi64x(tmp);
} }
data2 = _mm_broadcastq_epi64(data2); data2 = _mm_broadcastq_epi64(data2);