daiduo/TurboPFor-Integer-Compression
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

.

Browse Source
This commit is contained in:
powturbo
2015-05-28 17:11:34 +02:00
parent 55156d368e
commit 17da1dd142
1 changed files with 94 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

94
ext/MaskedVByte/src/varintencode.c Normal file
View File

@ -0,0 +1,94 @@
#include "../include/varintencode.h"
size_t vbyte_encode_delta(uint32_t *in, size_t length, uint8_t *bout, uint32_t prev) {
uint8_t *initbout = bout; size_t k;
for (k = 0; k < length; ++k) {
const uint32_t val = in[k] - prev;
prev = in[k];
if (val < (1U << 7)) {
*bout = val & 0x7F;
++bout;
} else if (val < (1U << 14)) {
*bout = (uint8_t)((val & 0x7F) | (1U << 7));
++bout;
*bout = (uint8_t)(val >> 7);
++bout;
} else if (val < (1U << 21)) {
*bout = (uint8_t)((val & 0x7F) | (1U << 7));
++bout;
*bout = (uint8_t)(((val >> 7) & 0x7F) | (1U << 7));
++bout;
*bout = (uint8_t)(val >> 14);
++bout;
} else if (val < (1U << 28)) {
*bout = (uint8_t)((val & 0x7F) | (1U << 7));
++bout;
*bout = (uint8_t)(((val >> 7) & 0x7F) | (1U << 7));
++bout;
*bout = (uint8_t)(((val >> 14) & 0x7F) | (1U << 7));
++bout;
*bout = (uint8_t)(val >> 21);
++bout;
} else {
*bout = (uint8_t)((val & 0x7F) | (1U << 7));
++bout;
*bout = (uint8_t)(((val >> 7) & 0x7F) | (1U << 7));
++bout;
*bout = (uint8_t)(((val >> 14) & 0x7F) | (1U << 7));
++bout;
*bout = (uint8_t)(((val >> 21) & 0x7F) | (1U << 7));
++bout;
*bout = (uint8_t)(val >> 28);
++bout;
}
}
return bout - initbout;
}
size_t vbyte_encode(uint32_t *in, size_t length, uint8_t *bout) {
uint8_t *initbout = bout; size_t k;
for (k = 0; k < length; ++k) {
const uint32_t val = in[k];
if (val < (1U << 7)) {
*bout = val & 0x7F;
++bout;
} else if (val < (1U << 14)) {
*bout = (uint8_t)((val & 0x7F) | (1U << 7));
++bout;
*bout = (uint8_t)(val >> 7);
++bout;
} else if (val < (1U << 21)) {
*bout = (uint8_t)((val & 0x7F) | (1U << 7));
++bout;
*bout = (uint8_t)(((val >> 7) & 0x7F) | (1U << 7));
++bout;
*bout = (uint8_t)(val >> 14);
++bout;
} else if (val < (1U << 28)) {
*bout = (uint8_t)((val & 0x7F) | (1U << 7));
++bout;
*bout = (uint8_t)(((val >> 7) & 0x7F) | (1U << 7));
++bout;
*bout = (uint8_t)(((val >> 14) & 0x7F) | (1U << 7));
++bout;
*bout = (uint8_t)(val >> 21);
++bout;
} else {
*bout = (uint8_t)((val & 0x7F) | (1U << 7));
++bout;
*bout = (uint8_t)(((val >> 7) & 0x7F) | (1U << 7));
++bout;
*bout = (uint8_t)(((val >> 14) & 0x7F) | (1U << 7));
++bout;
*bout = (uint8_t)(((val >> 21) & 0x7F) | (1U << 7));
++bout;
*bout = (uint8_t)(val >> 28);
++bout;
}
}
return bout - initbout;
}