authorgravatar for hello@nektro.netMeghan Denny <hello@nektro.net> 2026-04-14 05:16:17 -07:00
committergravatar for hello@nektro.netMeghan Denny <hello@nektro.net> 2026-04-14 05:16:17 -07:00
loga9c03af8e170ea8adf6538f49d6853639d5aa932
tree3bda78f184afe06fd3e2156a4f73a1addf812794
parent4d582b1398ee864a942901fc3095a295b6b794e9
signaturebadge-check Signed by SSH key SHA256:4hHJbtBRU58AYXwjL7fkz2fnQHdiye8x1QpTCQ0sHNw

use Z_SYNC_FLUSH

1 files changed, 2 insertions(+), 1 deletions(-)

git.zig+2-1
...@@ -1147,6 +1147,7 @@ pub const Repository = struct {...@@ -1147,6 +1147,7 @@ pub const Repository = struct {
1147 try list.ensureUnusedCapacity(r.gpa, size);1147 try list.ensureUnusedCapacity(r.gpa, size);
1148 // try std.compress.flate.inflate.decompress(.zlib, bufr.anyReadable(), list.writer(r.gpa));1148 // try std.compress.flate.inflate.decompress(.zlib, bufr.anyReadable(), list.writer(r.gpa));
1149 try inflate_decompress(compressed_content, &list, r.gpa);1149 try inflate_decompress(compressed_content, &list, r.gpa);
1150 std.debug.assert(list.items.len == size);
1150 // std.log.debug("transformation data=[{d}]{d}", .{ list.items.len, list.items });1151 // std.log.debug("transformation data=[{d}]{d}", .{ list.items.len, list.items });
11511152
1152 var unpackedobj_fbs = nio.FixedBufferStream([]const u8).init(list.items);1153 var unpackedobj_fbs = nio.FixedBufferStream([]const u8).init(list.items);
...@@ -1390,7 +1391,7 @@ fn inflate_decompress(in: []const u8, out: *std.ArrayListUnmanaged(u8), allocato...@@ -1390,7 +1391,7 @@ fn inflate_decompress(in: []const u8, out: *std.ArrayListUnmanaged(u8), allocato
1390 strm.next_out = &buf;1391 strm.next_out = &buf;
1391 strm.avail_out = buf.len;1392 strm.avail_out = buf.len;
1392 // std.log.debug("inflate_decompress: -> {*} {*} {d} {d}", .{ strm.next_in, strm.next_out, strm.avail_in, strm.avail_out });1393 // std.log.debug("inflate_decompress: -> {*} {*} {d} {d}", .{ strm.next_in, strm.next_out, strm.avail_in, strm.avail_out });
1393 const ret: ZlibCode = @enumFromInt(z.inflate(&strm, z.Z_FINISH));1394 const ret: ZlibCode = @enumFromInt(z.inflate(&strm, z.Z_SYNC_FLUSH));
1394 // std.log.debug("inflate_decompress: <- {*} {*} {d} {d} {s}", .{ strm.next_in, strm.next_out, strm.avail_in, strm.avail_out, @tagName(ret) });1395 // std.log.debug("inflate_decompress: <- {*} {*} {d} {d} {s}", .{ strm.next_in, strm.next_out, strm.avail_in, strm.avail_out, @tagName(ret) });
1395 std.debug.assert(ret != .Z_STREAM_ERROR);1396 std.debug.assert(ret != .Z_STREAM_ERROR);
1396 // if (ret == .Z_BUF_ERROR) std.log.err("{s}", .{strm.msg});1397 // if (ret == .Z_BUF_ERROR) std.log.err("{s}", .{strm.msg});