| ... | ... | @@ -819,7 +819,6 @@ pub const Repository = struct { |
| 819 | 819 | var list: nio.AllocatingWriter = .init(r.gpa); |
| 820 | 820 | errdefer list.deinit(); |
| 821 | 821 | try list.ensureUnusedCapacity(512); |
| 822 | | // try std.compress.flate.inflate.decompress(.zlib, bufr.anyReadable(), list.writer()); |
| 823 | 822 | try inflate_decompress(compressed_content, &list); |
| 824 | 823 | const data = list.items; |
| 825 | 824 | const header = data[0..std.mem.indexOfScalar(u8, data, 0).?]; |
| ... | ... | @@ -962,7 +961,6 @@ pub const Repository = struct { |
| 962 | 961 | var list: nio.AllocatingWriter = .init(r.gpa); |
| 963 | 962 | errdefer list.deinit(); |
| 964 | 963 | try list.ensureUnusedCapacity(512); |
| 965 | | // try std.compress.flate.inflate.decompress(.zlib, bufr.anyReadable(), list.writer()); |
| 966 | 964 | try inflate_decompress(compressed_content, &list); |
| 967 | 965 | const _type = std.meta.stringToEnum(RefType, @tagName(ty)).?; |
| 968 | 966 | const content = try list.toOwnedSlice(); |
| ... | ... | @@ -1004,7 +1002,6 @@ pub const Repository = struct { |
| 1004 | 1002 | var list: nio.AllocatingWriter = .init(r.gpa); |
| 1005 | 1003 | defer list.deinit(); |
| 1006 | 1004 | try list.ensureUnusedCapacity(size); |
| 1007 | | // try std.compress.flate.inflate.decompress(.zlib, bufr.anyReadable(), list.writer(r.gpa)); |
| 1008 | 1005 | try inflate_decompress(compressed_content, &list); |
| 1009 | 1006 | std.debug.assert(list.items.len == size); |
| 1010 | 1007 | // std.log.debug("maybe_oid={?s} size={d}", .{ maybe_oid, size }); |
| ... | ... | @@ -1641,6 +1638,17 @@ const z = @cImport({ |
| 1641 | 1638 | }); |
| 1642 | 1639 | |
| 1643 | 1640 | fn inflate_decompress(in: []const u8, out: *nio.AllocatingWriter) !void { |
| 1641 | // { |
| 1642 | // var reader: std.Io.Reader = .fixed(in); |
| 1643 | // var buf: [std.compress.flate.max_window_len]u8 = @splat(0); |
| 1644 | // var d: std.compress.flate.Decompress = .init(&reader, .zlib, &buf); |
| 1645 | // var w = out.anyWritable().toStd(&.{}); |
| 1646 | // _ = d.reader.streamRemaining(&w.sw) catch |err| switch (err) { |
| 1647 | // error.ReadFailed => return d.err.?, |
| 1648 | // error.WriteFailed => return error.OutOfMemory, |
| 1649 | // }; |
| 1650 | // return; |
| 1651 | // } |
| 1644 | 1652 | var strm: z.z_stream = std.mem.zeroes(z.z_stream); |
| 1645 | 1653 | { |
| 1646 | 1654 | const ret: ZlibCode = @enumFromInt(z.inflateInit(&strm)); |