ZSTD_REP_NUM

diff --git a/lib/zstd_compress.c b/lib/zstd_compress.c
index 2ee25cc934062798d15c39f1b607926e878bc7e5..60bbd8444043c2b5e3b9da4fd3d163cdf8a73851 100644 (file)
--- a/lib/zstd_compress.c
+++ b/lib/zstd_compress.c
@@ -627,8 +627,10 @@ size_t ZSTD_compressSequences(ZSTD_CCtx* zc,
     /* CTable for Offset codes */
     {   /* create Offset codes */
         size_t i; for (i=0; i<nbSeq; i++) {
-            offCodeTable[i] = (BYTE)ZSTD_highbit(offsetTable[i]) + 1;
-            if (offsetTable[i]==0) offCodeTable[i]=0;
+            if (offsetTable[i] < ZSTD_REP_NUM) 
+                offCodeTable[i] = 0;
+            else
+                offCodeTable[i] = (BYTE)ZSTD_highbit(offsetTable[i]) + 1;
         }
     }
     max = MaxOff;
@@ -774,7 +776,7 @@ MEM_STATIC void ZSTD_storeSeq(seqStore_t* seqStorePtr, size_t litLength, const B
     else *(seqStorePtr->litLength++) = (BYTE)litLength;
 
     /* match offset */
-    *(seqStorePtr->offset++) = (U32)offsetCode;
+    *(seqStorePtr->offset++) = (U32)offsetCode + ZSTD_REP_NUM - 1;
 
     /* match Length */
     if (matchCode >= MaxML) {

diff --git a/lib/zstd_decompress.c b/lib/zstd_decompress.c
index 60136b6155d5362941779d05fe25491300e6f947..9bbbd5c1ccffb4551c1e29b4c2955aef21618d5b 100644 (file)
--- a/lib/zstd_decompress.c
+++ b/lib/zstd_decompress.c
@@ -657,8 +657,10 @@ static void ZSTD_decodeSequence(seq_t* seq, seqState_t* seqState, const U32 mls)
         offset = offsetPrefix[offsetCode] + BIT_readBits(&(seqState->DStream), nbBits);
         if (MEM_32bits()) BIT_reloadDStream(&(seqState->DStream));
         if (offsetCode==0) offset = prevOffset;   /* repcode, cmove */
+        else offset -= ZSTD_REP_NUM - 1;
         if (offsetCode | !litLength) seqState->prevOffset = seq->offset;   /* cmove */
         FSE_decodeSymbol(&(seqState->stateOffb), &(seqState->DStream));    /* update */
+//    printf("offsetCode=%d nbBits=%d offset=%d\n", offsetCode, nbBits, (int)offset); fflush(stdout);
     }
 
     /* Literal length update */

diff --git a/lib/zstd_internal.h b/lib/zstd_internal.h
index de78bb6f9174930f1a06cfa6b49d21d6c7f72840..cccd801f5886c4e2d248393b06dfd21bdf767379 100644 (file)
--- a/lib/zstd_internal.h
+++ b/lib/zstd_internal.h
@@ -66,6 +66,7 @@
 
 #define ZSTD_OPT_NUM    (1<<12)
 #define ZSTD_DICT_MAGIC  0xEC30A435
+#define ZSTD_REP_NUM    4
 
 #define KB *(1 <<10)
 #define MB *(1 <<20)

diff --git a/programs/bench.c b/programs/bench.c
index e0db60e5b6bfbdf1d1988968f2bdeddfd02751e5..fd4f9b54718045b274eed31d412ebe7e6f039de6 100644 (file)
--- a/programs/bench.c
+++ b/programs/bench.c
@@ -89,7 +89,6 @@
 #endif
 
 #define NBLOOPS    3
-#define TIMELOOP   2500
 
 #define KB *(1 <<10)
 #define MB *(1 <<20)
@@ -281,6 +280,7 @@ static int BMK_benchMem(const void* srcBuffer, size_t srcSize,
     }   }   }
 
     /* warmimg up memory */
+    int timeloop = additionalParam; //2500;
     ZSTD_setAdditionalParam(refCtx, additionalParam);
     RDG_genBuffer(compressedBuffer, maxCompressedSize, 0.10, 0.50, 1);
 
@@ -305,7 +305,7 @@ static int BMK_benchMem(const void* srcBuffer, size_t srcSize,
             milliTime = BMK_GetMilliStart();
             while (BMK_GetMilliStart() == milliTime);
             milliTime = BMK_GetMilliStart();
-            while (BMK_GetMilliSpan(milliTime) < TIMELOOP) {
+            while (BMK_GetMilliSpan(milliTime) < timeloop) {
                 ZSTD_compressBegin_advanced(refCtx, dictBuffer, dictBufferSize, ZSTD_getParams(cLevel, MAX(dictBufferSize, largestBlockSize)));
                 for (blockNb=0; blockNb<nbBlocks; blockNb++) {
                     size_t rSize = ZSTD_compress_usingPreparedCCtx(ctx, refCtx,
@@ -334,7 +334,7 @@ static int BMK_benchMem(const void* srcBuffer, size_t srcSize,
             while (BMK_GetMilliStart() == milliTime);
             milliTime = BMK_GetMilliStart();
 
-            for ( ; BMK_GetMilliSpan(milliTime) < TIMELOOP; nbLoops++) {
+            for ( ; BMK_GetMilliSpan(milliTime) < timeloop; nbLoops++) {
                 ZSTD_decompressBegin_usingDict(refDCtx, dictBuffer, dictBufferSize);
                 for (blockNb=0; blockNb<nbBlocks; blockNb++) {
                     size_t regenSize = ZSTD_decompress_usingPreparedDCtx(dctx, refDCtx,