neurocyte/thespian
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Compare commits

base: neurocyte:42a98a44e7590fd6e952b75523e5c0f4fa0e6c97
Branches Tags
neurocyte:master
...
compare: neurocyte:a7b2354ad2fbe9d2b3629a455f2e823b463c18eb
Branches Tags
neurocyte:master

2 commits
42a98a44e7 ... a7b2354ad2

Author SHA1 Message Date
CJ van den Berg
a7b2354ad2
fix: remove descriptor error log messages 2025-04-30 14:48:35 +02:00
CJ van den Berg
733831c30e
fix: release fd from stream_descriptor to prevent double or prematurely close 2025-04-30 14:46:47 +02:00
2 changed files with 3 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
src/executor_asio.cpp
View file

@ -622,6 +622,8 @@ struct watcher_impl {
: ctx{strand.ref->ctx}, strand_{strand.ref->strand_}, : ctx{strand.ref->ctx}, strand_{strand.ref->strand_},
fd_{*ctx->asio, fd} {} fd_{*ctx->asio, fd} {}
~watcher_impl() { fd_.release(); }
void wait_read(watcher::handler h) { void wait_read(watcher::handler h) {
if (!read_in_progress_) { if (!read_in_progress_) {
read_in_progress_ = true; read_in_progress_ = true;

2
src/thespian.zig
View file

@ -756,7 +756,7 @@ pub const file_descriptor = struct {
const Self = @This(); const Self = @This();
pub fn init(tag_: []const u8, fd: i32) !Self { pub fn init(tag_: []const u8, fd: i32) !Self {
return .{ .handle = c.thespian_file_descriptor_create(tag_.ptr, fd) orelse return log_last_error(error.ThespianFileDescriptorInitFailed) }; return .{ .handle = c.thespian_file_descriptor_create(tag_.ptr, fd) orelse return error.ThespianFileDescriptorInitFailed };
} }
pub fn wait_write(self: *const Self) !void { pub fn wait_write(self: *const Self) !void {