96 lines
3.6 KiB
Zig
96 lines
3.6 KiB
Zig
// Example of a `pong` client using the C bindings.
|
|
const std = @import("std");
|
|
|
|
// Only bindings are available.
|
|
const libipc = @cImport({
|
|
@cInclude("../../../libipc.h");
|
|
});
|
|
|
|
const SERVICE = "pong";
|
|
const SERVICE_LEN = 4;
|
|
const MAX_MSG_SIZE = 10000;
|
|
|
|
pub fn main() !u8 {
|
|
var ctx : *anyopaque = undefined;
|
|
var ret : c_int = 0;
|
|
var servicefd : c_int = undefined;
|
|
var buffer : [MAX_MSG_SIZE]u8 = undefined;
|
|
var size : usize = MAX_MSG_SIZE;
|
|
var event_type : u8 = undefined;
|
|
var index : usize = 0;
|
|
var originfd : c_int = undefined;
|
|
|
|
std.debug.print("Init context.\n", .{});
|
|
ret = libipc.ipc_context_init (@ptrCast(&ctx));
|
|
|
|
if (ret != 0) {
|
|
std.debug.print("Cannot init context.\n", .{});
|
|
return 1;
|
|
}
|
|
|
|
defer {
|
|
std.debug.print("Deinit context.\n", .{});
|
|
libipc.ipc_context_deinit (@ptrCast(&ctx));
|
|
}
|
|
|
|
std.debug.print ("Connect to a 'pong' service.\n", .{});
|
|
ret = libipc.ipc_connect_service (ctx, &servicefd, SERVICE, SERVICE_LEN);
|
|
|
|
if (ret != 0) {
|
|
std.debug.print("Cannot connect to a service.\n", .{});
|
|
return 1;
|
|
}
|
|
|
|
std.debug.print ("Let's schedule a message.\n", .{});
|
|
ret = libipc.ipc_schedule (ctx, servicefd, "hello, plz bounce me", 21);
|
|
|
|
if (ret != 0) {
|
|
std.debug.print("Cannot schedule a message.\n", .{});
|
|
return 1;
|
|
}
|
|
|
|
std.debug.print("Let's set the timer to one second.\n", .{});
|
|
libipc.ipc_context_timer (ctx, 1000);
|
|
|
|
var should_continue : bool = true;
|
|
// var event_count : u32 = 0;
|
|
|
|
std.debug.print("Let's loop over events.\n", .{});
|
|
while(should_continue) {
|
|
size = MAX_MSG_SIZE;
|
|
var newfd : c_int = undefined;
|
|
const pbuffer : [*c]u8 = &buffer;
|
|
ret = libipc.ipc_wait_event (ctx, &event_type, &index, &originfd, &newfd, pbuffer, &size);
|
|
if (ret != 0) {
|
|
std.debug.print("Error while waiting for an event.", .{});
|
|
return 1;
|
|
}
|
|
|
|
// event_count += 1;
|
|
// std.debug.print("EVENT n°{d} type {d}\t", .{ event_count, event_type });
|
|
|
|
switch (event_type) {
|
|
libipc.ERROR => { std.debug.print("Error.", .{}); return 1; },
|
|
libipc.EXTERNAL => { std.debug.print("External (shouldn't happen).", .{}); return 1; },
|
|
libipc.SWITCH_RX => { std.debug.print("Switch RX (shouldn't happen).", .{}); return 1; },
|
|
libipc.SWITCH_TX => { std.debug.print("Switch TX (shouldn't happen).", .{}); return 1; },
|
|
libipc.CONNECTION => { std.debug.print("Connection (shouldn't happen).", .{}); return 1; },
|
|
libipc.DISCONNECTION => { std.debug.print("Disconnection (shouldn't happen).", .{}); return 1; },
|
|
libipc.TIMER => { std.debug.print("TIMER.\n", .{}); },
|
|
libipc.MESSAGE_TX => { std.debug.print("A message has been sent.\n", .{}); },
|
|
libipc.MESSAGE_RX => {
|
|
if (size == 0) {
|
|
std.debug.print("No message returned.\n", .{});
|
|
return 1;
|
|
}
|
|
buffer[size] = 0;
|
|
std.debug.print("Response (size {d}): {s}.\n", .{ size, buffer[0..size] });
|
|
// We received the response, quitting.
|
|
should_continue = false;
|
|
},
|
|
else => { std.debug.print("Unknown IPC message type.\n", .{}); return 1; },
|
|
}
|
|
}
|
|
|
|
return 0;
|
|
}
|