nodejs
diff --git a/‎src/node_zlib.cc‎
Lines changed: 2 additions & 1 deletion b/‎src/node_zlib.cc‎
Lines changed: 2 additions & 1 deletion
diff --git a/‎test/fixtures/pseudo-multimember-gzip.gz‎
161 Bytes b/‎test/fixtures/pseudo-multimember-gzip.gz‎
161 Bytes
diff --git a/‎test/fixtures/pseudo-multimember-gzip.z‎
148 Bytes b/‎test/fixtures/pseudo-multimember-gzip.z‎
148 Bytes
diff --git a/‎test/parallel/test-zlib-from-concatenated-gzip.js‎
Lines changed: 22 additions & 0 deletions b/‎test/parallel/test-zlib-from-concatenated-gzip.js‎
Lines changed: 22 additions & 0 deletions
@@ -258,7 +258,8 @@ class ZCtx : public AsyncWrap {
           }
         }
         while (ctx->strm_.avail_in >= GZIP_MIN_HEADER_SIZE &&
-               ctx->mode_ == GUNZIP) {
+               ctx->mode_ == GUNZIP &&
+               ctx->err_ == Z_STREAM_END) {
           // Bytes remain in input buffer. Perhaps this is another compressed
           // member in the same archive, or just trailing garbage.
           // Check the header to find out.
 
@@ -4,6 +4,8 @@
 const common = require('../common');
 const assert = require('assert');
 const zlib = require('zlib');
+const path = require('path');
+const fs = require('fs');
 
 const data = Buffer.concat([
   zlib.gzipSync('abc'),
@@ -16,3 +18,23 @@ zlib.gunzip(data, common.mustCall((err, result) => {
   assert.ifError(err);
   assert.equal(result, 'abcdef', 'result should match original string');
 }));
+
+// files that have the "right" magic bytes for starting a new gzip member
+// in the middle of themselves, even if they are part of a single
+// regularly compressed member
+const pmmFileZlib = path.join(common.fixturesDir, 'pseudo-multimember-gzip.z');
+const pmmFileGz = path.join(common.fixturesDir, 'pseudo-multimember-gzip.gz');
+
+const pmmExpected = zlib.inflateSync(fs.readFileSync(pmmFileZlib));
+const pmmResultBuffers = [];
+
+fs.createReadStream(pmmFileGz)
+  .pipe(zlib.createGunzip())
+  .on('error', (err) => {
+    assert.ifError(err);
+  })
+  .on('data', (data) => pmmResultBuffers.push(data))
+  .on('finish', common.mustCall(() => {
+    assert.deepStrictEqual(Buffer.concat(pmmResultBuffers), pmmExpected,
+      'result should match original random garbage');
+  }));
Original file line number	Diff line number	Diff line change
@@ -258,7 +258,8 @@ class ZCtx : public AsyncWrap {
258	258	}
259	259	}
260	260	while (ctx->strm_.avail_in >= GZIP_MIN_HEADER_SIZE &&
261		- ctx->mode_ == GUNZIP) {
	261	+ ctx->mode_ == GUNZIP &&
	262	+ ctx->err_ == Z_STREAM_END) {
262	263	// Bytes remain in input buffer. Perhaps this is another compressed
263	264	// member in the same archive, or just trailing garbage.
264	265	// Check the header to find out.