Searched refs:MESSAGE_MAX_BYTES (Results 1 - 3 of 3) sorted by relevance
| /third_party/lz4/examples/ |
| H A D | HCStreaming_ringBuffer.c | 32 MESSAGE_MAX_BYTES = 1024, enumerator
33 RING_BUFFER_BYTES = 1024 * 8 + MESSAGE_MAX_BYTES,
34 DEC_BUFFER_BYTES = RING_BUFFER_BYTES + MESSAGE_MAX_BYTES // Intentionally larger to test unsynchronized ring buffers
66 // Read random length ([1,MESSAGE_MAX_BYTES]) data to the ring buffer. in test_compress()
68 const int randomLength = (rand() % MESSAGE_MAX_BYTES) + 1; in test_compress()
72 #define CMPBUFSIZE (LZ4_COMPRESSBOUND(MESSAGE_MAX_BYTES)) in test_compress()
83 if(inpOffset >= RING_BUFFER_BYTES - MESSAGE_MAX_BYTES) in test_compress()
115 lz4StreamDecode, cmpBuf, decPtr, cmpBytes, MESSAGE_MAX_BYTES); in test_decompress()
123 if(decOffset >= DEC_BUFFER_BYTES - MESSAGE_MAX_BYTES) in test_decompress()
|
| H A D | blockStreaming_ringBuffer.c | 25 MESSAGE_MAX_BYTES = 1024, enumerator
26 RING_BUFFER_BYTES = 1024 * 8 + MESSAGE_MAX_BYTES,
27 DECODE_RING_BUFFER = RING_BUFFER_BYTES + MESSAGE_MAX_BYTES /* Intentionally larger, to test unsynchronized ring buffers */
57 // Read random length ([1,MESSAGE_MAX_BYTES]) data to the ring buffer. in test_compress()
59 const int randomLength = (rand() % MESSAGE_MAX_BYTES) + 1; in test_compress()
64 #define CMPBUFSIZE (LZ4_COMPRESSBOUND(MESSAGE_MAX_BYTES)) in test_compress()
74 if(inpOffset >= RING_BUFFER_BYTES - MESSAGE_MAX_BYTES) inpOffset = 0; in test_compress()
102 lz4StreamDecode, cmpBuf, decPtr, cmpBytes, MESSAGE_MAX_BYTES); in test_decompress()
108 if(decOffset >= DECODE_RING_BUFFER - MESSAGE_MAX_BYTES) decOffset = 0; in test_decompress()
|
| H A D | blockStreaming_lineByLine.c | 151 MESSAGE_MAX_BYTES = 1024, in main() enumerator
152 RING_BUFFER_BYTES = 1024 * 256 + MESSAGE_MAX_BYTES, in main()
178 test_compress(outFp, inpFp, MESSAGE_MAX_BYTES, RING_BUFFER_BYTES); in main()
189 test_decompress(outFp, inpFp, MESSAGE_MAX_BYTES, RING_BUFFER_BYTES); in main()
|
Completed in 2 milliseconds