Implement mergeGeneratedSequences()

diff --git a/lib/compress/zstd_compress.c b/lib/compress/zstd_compress.c
index 61eb5234dae82a9feacb8c86720677ed89e393c7..238e6d7a2b8cbe0e2c2f3c73e574c54d47a19636 100644 (file)
--- a/lib/compress/zstd_compress.c
+++ b/lib/compress/zstd_compress.c
@@ -2551,7 +2551,7 @@ static void ZSTD_copyBlockSequences(ZSTD_CCtx* zc)
 }
 
 size_t ZSTD_generateSequences(ZSTD_CCtx* zc, ZSTD_Sequence* outSeqs,
-    size_t outSeqsSize, const void* src, size_t srcSize, ZSTD_sequenceFormat_e format)
+                              size_t outSeqsSize, const void* src, size_t srcSize)
 {
     const size_t dstCapacity = ZSTD_compressBound(srcSize);
     void* dst = ZSTD_customMalloc(dstCapacity, ZSTD_defaultCMem);
@@ -2567,27 +2567,23 @@ size_t ZSTD_generateSequences(ZSTD_CCtx* zc, ZSTD_Sequence* outSeqs,
 
     ZSTD_compress2(zc, dst, dstCapacity, src, srcSize);
     ZSTD_customFree(dst, ZSTD_defaultCMem);
+    return zc->seqCollector.seqIndex;
+}
 
-    if (format == ZSTD_sf_noBlockDelimiters) {
-        /* Remove all block delimiters and append them to the next sequence's literals
-         * and do not emit last literals at all
-         */
-        size_t in = 0;
-        size_t out = 0;
-        for (; in < zc->seqCollector.seqIndex; ++in) {
-            if (seqCollector.seqStart[in].offset == 0 && seqCollector.seqStart[in].matchLength == 0) {
-                if (in != zc->seqCollector.seqIndex - 1) {
-                    seqCollector.seqStart[in+1].litLength += seqCollector.seqStart[in].litLength;
-                }
-            } else {
-                seqCollector.seqStart[out] = seqCollector.seqStart[in];
-                ++out;
+size_t ZSTD_mergeGeneratedSequences(ZSTD_Sequence* sequences, size_t seqsSize) {
+    size_t in = 0;
+    size_t out = 0;
+    for (; in < seqsSize; ++in) {
+        if (sequences[in].offset == 0 && sequences[in].matchLength == 0) {
+            if (in != seqsSize - 1) {
+                sequences[in+1].litLength += sequences[in].litLength;
             }
+        } else {
+            sequences[out] = sequences[in];
+            ++out;
         }
-        zc->seqCollector.seqIndex = out;
     }
-
-    return zc->seqCollector.seqIndex;
+    return out;
 }
 
 /* Returns true if the given block is a RLE block */