Obsolete
/
libipc-old
Archived
3
0
Fork 0

Crystal bindings are in good shape.

master
Philippe Pittoli 2023-01-21 05:52:18 +01:00
parent 9696190e99
commit 368513bca5
1 changed files with 51 additions and 53 deletions

View File

@ -1,26 +1,25 @@
@[Link("ipc")]
lib LibIPC
# enum EventType
# Error # Self explanatory.
# Connection # New user.
# Disconnection # User disconnected.
# MessageRx # Message received.
# MessageTx # Message sent.
# Timer # Timeout in the poll(2) function.
# External # Message received from a non IPC socket.
# SwitchRx # Switch subsystem: message received.
# SwitchTx # Switch subsystem: message send.
# end
enum EventType
Error # Self explanatory.
Connection # New user.
Disconnection # User disconnected.
MessageRx # Message received.
MessageTx # Message sent.
Timer # Timeout in the poll(2) function.
External # Message received from a non IPC socket.
SwitchRx # Switch subsystem: message received.
SwitchTx # Switch subsystem: message send.
end
fun init = ipc_context_init (Void**) : LibC::Int
fun deinit = ipc_context_deinit (Void*) : Void
# Connection functions.
# Context is allocated, ipcd is requested and the connection/initialisation is performed.
fun service_init = ipc_service_init (Void*, LibC::Int*, LibC::Char*, LibC::UInt16T) : LibC::Int
fun connect_service = ipc_connect_service(Void*, LibC::Int*, LibC::Char*, LibC::UInt16T) : LibC::Int
fun wait = ipc_wait_event(Void*, Char*, LibC::UInt64T*, LibC::Int*, Char*, LibC::UInt64T*) : LibC::Int
# Context EventType index fd buffer buflen
fun wait = ipc_wait_event(Void*, UInt8*, LibC::UInt64T*, LibC::Int*, UInt8*, LibC::UInt64T*) : LibC::Int
# Sending a message NOW.
# WARNING: unbuffered send do not wait the fd to become available.
@ -30,16 +29,12 @@ lib LibIPC
fun read = ipc_read_fd (Void*, LibC::Int, UInt8*, LibC::UInt64T*);
# # Closing connections.
# fun ipc_close(Pointer(Void), index : LibC::UInt64T) : LibC::Int
# fun ipc_close_all(Pointer(Void)) : LibC::Int
# Closing connections.
fun ipc_close(Void*, index : LibC::UInt64T) : LibC::Int
fun ipc_close_all(Void*) : LibC::Int
end
# TODO: Write documentation for `Some::Crystal::App`
module Some::Crystal::App
VERSION = "0.1.0"
# TODO: Put your code here
def test_without_wait()
ctx : Pointer(Void) = Pointer(Void).null
LibIPC.init (pointerof(ctx))
fd : Int32 = 0
@ -48,38 +43,41 @@ module Some::Crystal::App
LibIPC.write(ctx, fd, "Hello", 5)
buflen : LibC::UInt64T = 10
#buffer = uninitialized UInt8[10]
buffer = Array(UInt8).new(10, 88)
#buffer[0] = 'a'
#buffer[1] = 'b'
#buffer[2] = 'c'
#buffer[3] = 'd'
#buffer[4] = 'e'
#buffer[5] = 'f'
#pp! buffer[0]
#pp! buffer[1]
#pp! buffer[2]
#pp! buffer[3]
#pp! buffer[4]
#pp! buffer[5]
buffer = uninitialized UInt8[10]
LibIPC.read(ctx, fd, buffer.to_unsafe, pointerof(buflen))
pp! buflen
pp! buffer.size
buffer[buflen] = 0
str = String.new(buffer.to_unsafe)
pp! str
#received = String.build do |str|
# count = buflen
# while count > 0
# str << buffer[buflen - count]
# count -= 1
# end
#end
#pp! received
#received = Slice.new(buffer.to_unsafe, buflen)
##puts "Buffer is: [#{received}]"
received = String.new(buffer.to_unsafe, buflen)
pp! received
LibIPC.deinit (ctx)
end
def test_with_wait()
ctx : Pointer(Void) = Pointer(Void).null
LibIPC.init (pointerof(ctx))
fd : Int32 = 0
LibIPC.connect_service(ctx, pointerof(fd), "pong", 4)
pp! fd
LibIPC.write(ctx, fd, "Hello", 5)
buflen : LibC::UInt64T = 10
buffer = uninitialized UInt8[10]
eventtype : UInt8 = 0
index : LibC::UInt64T = 0
LibIPC.wait(ctx, pointerof(eventtype), pointerof(index), pointerof(fd), buffer.to_unsafe, pointerof(buflen))
pp! "After waiting: ", LibIPC::EventType.new(eventtype), fd, index, buflen
received = String.new(buffer.to_unsafe, buflen)
pp! received
LibIPC.deinit (ctx)
end
# TODO: Write documentation for `Some::Crystal::App`
module Some::Crystal::App
VERSION = "0.1.0"
test_without_wait
test_with_wait
end