Obsolete
/
libipc-old
Archived
3
0
Fork 0
Code

Receive msg example: rm unix socket path.

master
Philippe Pittoli 2022-12-21 19:05:58 +01:00
parent 2bb06db137
commit a39ce64b7b
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
zig-impl/src/receive-msg.zig
View File

@ -19,6 +19,12 @@ fn waiting_for_connection(stream: *net.StreamServer
return stream.accept(); return stream.accept();
} }
fn remove_unix_socket(path: []const u8) void {
std.fs.deleteFileAbsolute(path) catch |err| switch(err) {
else => { print("error: {}\n", .{err}); }
};
}
fn receive_msg(stream: net.Stream) !void { fn receive_msg(stream: net.Stream) !void {
var buffer: [1000]u8 = undefined; var buffer: [1000]u8 = undefined;
var fbs = std.io.fixedBufferStream(&buffer); var fbs = std.io.fixedBufferStream(&buffer);
@ -38,8 +44,10 @@ pub fn main() !u8 {
var path = "/tmp/.TEST_USOCK"; var path = "/tmp/.TEST_USOCK";
print("Init UNIX server to {s}...\n", .{path}); print("Init UNIX server to {s}...\n", .{path});
var stream = server_init(); var stream = server_init();
defer stream.deinit();
print("Waiting for a connection...\n", .{}); print("Waiting for a connection...\n", .{});
var connection = try waiting_for_connection(&stream, path); var connection = try waiting_for_connection(&stream, path);
defer remove_unix_socket(path);
print("Someone is connected! Receiving a message...\n", .{}); print("Someone is connected! Receiving a message...\n", .{});
try receive_msg(connection.stream); try receive_msg(connection.stream);
print("Disconnection...\n", .{}); print("Disconnection...\n", .{});