language-servers/roc
1
0
Fork 0
mirror of https://github.com/roc-lang/roc.git synced 2025-12-23 08:48:03 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 8

rename, fix hash [skip ci]

Browse source
This commit is contained in:
Anton-4 2025-10-14 13:55:37 +02:00
parent 5914c7b259
commit dfebfb2f22
No known key found for this signature in database
2 changed files with 12 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

2
build.zig.zon
View file

@ -10,7 +10,7 @@
},
.roc_deps_aarch64_macos_none = .{
.url = "https://github.com/roc-lang/roc-bootstrap/releases/download/zig-0.15.1/aarch64-macos-none.tar.xz?response-content-disposition=attachment",
.hash = "122044a065bfe8f6286901b110a1b0b5a764f9fcb2d142a5eeb3423527e95419427",
.hash = "N-V-__8AAJuttw4mNdQg3ig107ac4uyAhcFPznGHmpnmX58C",
.lazy = true,
},
.roc_deps_aarch64_linux_musl = .{

23
src/bundle/streaming_writer.zig
View file

@ -9,25 +9,24 @@ const c = @cImport({
@cInclude("zstd.h");
});
const Writer = std.io.Writer;
const Error = Writer.Error;
const WriterError = std.io.Writer.Error;
/// A writer that compresses data with zstd and computes a hash incrementally
pub const CompressingHashWriter = struct {
allocator_ptr: *std.mem.Allocator,
ctx: *c.ZSTD_CCtx,
hasher: std.crypto.hash.Blake3,
output_writer: *Writer,
output_writer: *std.io.Writer,
out_buffer: []u8,
finished: bool,
interface: Writer,
interface: std.io.Writer,
const Self = @This();
pub fn init(
allocator_ptr: *std.mem.Allocator,
compression_level: c_int,
output_writer: *Writer,
output_writer: *std.io.Writer,
allocForZstd: *const fn (?*anyopaque, usize) callconv(.c) ?*anyopaque,
freeForZstd: *const fn (?*anyopaque, ?*anyopaque) callconv(.c) void,
) !Self {
@ -76,17 +75,17 @@ pub const CompressingHashWriter = struct {
self.allocator_ptr.free(self.interface.buffer);
}
fn flush(w: *Writer) Error!void {
fn flush(w: *std.io.Writer) WriterError!void {
const self: *Self = @alignCast(@fieldParentPtr("interface", w));
if (self.finished and w.end != 0) return Error.WriteFailed;
if (self.finished and w.end != 0) return WriterError.WriteFailed;
_ = self.compressAndHash(w.buffer[0..w.end], false) catch return error.WriteFailed;
w.end = 0;
return;
}
fn drain(w: *Writer, data: []const []const u8, splat: usize) Error!usize {
fn drain(w: *std.io.Writer, data: []const []const u8, splat: usize) WriterError!usize {
const self: *Self = @alignCast(@fieldParentPtr("interface", w));
if (self.finished) return Error.WriteFailed;
if (self.finished) return WriterError.WriteFailed;
_ = self.compressAndHash(w.buffer[0..w.end], false) catch return error.WriteFailed;
w.end = 0;
if (data.len == 0) return 0;
@ -105,7 +104,7 @@ pub const CompressingHashWriter = struct {
return written;
}
fn compressAndHash(self: *Self, data: []const u8, end_stream: bool) Error!usize {
fn compressAndHash(self: *Self, data: []const u8, end_stream: bool) WriterError!usize {
var in_buf = c.ZSTD_inBuffer{ .src = data.ptr, .size = data.len, .pos = 0 };
const mode: c_uint = if (end_stream) c.ZSTD_e_end else c.ZSTD_e_continue;
while (in_buf.pos < in_buf.size or end_stream) {
@ -113,7 +112,7 @@ pub const CompressingHashWriter = struct {
const remaining = c.ZSTD_compressStream2(self.ctx, &out_buf, &in_buf, mode);
if (c.ZSTD_isError(remaining) != 0) {
return Error.WriteFailed;
return WriterError.WriteFailed;
}
if (out_buf.pos > 0) {
@ -127,7 +126,7 @@ pub const CompressingHashWriter = struct {
return 0;
}
pub fn finish(self: *Self) Error!void {
pub fn finish(self: *Self) WriterError!void {
if (self.finished) return;
_ = self.compressAndHash(self.interface.buffer[0..self.interface.end], true) catch return error.WriteFailed;
self.interface.end = 0;