Bindings: context init+deinit, connect+init service, write msg ok.

zig-impl/src/bindings.zig

@@ -0,0 +1,62 @@
+const std = @import("std");
+const print = std.debug.print;
+const ipc = @import("./main.zig");
+const Context = ipc.Context;
+const Message = ipc.Message;
+
+export fn ipc_context_init (ptr: **Context) callconv(.C) i32 {
+    ptr.* = std.heap.c_allocator.create(Context) catch return -1;
+
+    ptr.*.* = Context.init(std.heap.c_allocator) catch |err| {
+        print ("libipc: error while init context: {}\n", .{err});
+        return -1;
+    };
+    return 0;
+}
+
+export fn ipc_server_init(ctx: *Context, servicefd: *i32, service_name: [*]const u8, service_name_len: u16) callconv(.C) i32 {
+    var streamserver = ctx.server_init (service_name[0..service_name_len]) catch return -1;
+    servicefd.* = streamserver.sockfd.?;
+    return 0;
+}
+
+export fn ipc_connect_service (ctx: *Context, servicefd: *i32, service_name: [*]const u8, service_name_len: u16) i32 {
+    var fd = ctx.connect_ipc (service_name[0..service_name_len]) catch return -1;
+    servicefd.* = fd;
+    return 0;
+}
+
+export fn ipc_context_deinit (ctx: *Context) callconv(.C) void {
+    ctx.deinit();
+}
+
+export fn ipc_write (ctx: *Context, servicefd: i32, mcontent: [*]const u8, mlen: u32) i32 {
+
+    var buffer: [100000]u8 = undefined;
+    var fba = std.heap.FixedBufferAllocator.init(&buffer);
+
+    var message = Message.init(servicefd, fba.allocator(), mcontent[0..mlen]) catch return -1;
+    ctx.write(message) catch return -1;
+    return 0;
+}
+
+// pub fn schedule (ctx: *Context, m: Message) !void
+// pub fn read_fd (ctx: *Context, fd: i32) !?Message
+// pub fn read (ctx: *Context, index: usize) !?Message
+// 
+// pub fn wait_event(ctx: *Context) !Event
+// 
+// pub fn close_fd(ctx: *Context, fd: i32) !void
+// pub fn close(ctx: *Context, index: usize) !void
+
+
+// // TODO (specifically in the bindings, not in the structure).
+// //change_timer
+// 
+// // Later.
+// // pub fn add_external (ctx: *Context, newfd: i32) !void
+// // pub fn add_switch(ctx: *Context, fd1: i32, fd2: i32) !void
+// // pub fn set_switch_callbacks(ctx: *Context, fd: i
+// 
+// // doubt it could really be useful
+// //pub fn close_all(ctx: *Context) !void

zig-impl/test-bindings/pong.c

@@ -1,8 +1,12 @@
 #include <stdio.h>
 #include <stdlib.h>
 
+#define SERVICE "pong"
+#define SERVICE_LEN 4
+
 int main(void) {
 	int ret = 0;
+	int servicefd = 0;
 
 	printf ("Init context.\n");
 	void *ctx = NULL;
@@ -15,23 +19,23 @@ int main(void) {
 
 	printf ("Context initiated.\n");
 
-#if 0
 	printf ("Connect to a 'pong' service.\n");
-	ret = ipc_connect_service (ctx, &servicefd, "pong");
+	ret = ipc_connect_service (ctx, &servicefd, SERVICE, SERVICE_LEN);
 
 	if (ret != 0) {
 		printf ("Cannot connect to a service.\n");
 		return 1;
 	}
 
-	printf ("Let's send a message.\n", ret);
-	ret = ipc_write (ctx, servicefd, "hello, plz bounce me");
+	printf ("Let's send a message.\n");
+	ret = ipc_write (ctx, servicefd, "hello, plz bounce me", 21);
 
 	if (ret != 0) {
 		printf ("Cannot write to the service.\n");
 		return 1;
 	}
 
+#if 0
 	// TODO: loop over ipc_wait
 	int event_type, index, originfd = 0;
 	unsigned int size = 0;