Obsolete/ipc.cr-old
Archived
3
0
Fork 0
Code

API change.

Browse Source
This commit is contained in:
Philippe PITTOLI 2019-06-06 00:37:12 +02:00
parent c4d82297c6
commit 6eb59dceff
1 changed files with 21 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
src/ipc.cr
View File

@ -190,8 +190,8 @@ class IPC::Event
end end
class IPC::Connection class IPC::Connection
@closed = false getter connection : LibIPC::Connection
@connection : LibIPC::Connection getter closed = false
# connection already established # connection already established
def initialize(c : LibIPC::Connection) def initialize(c : LibIPC::Connection)
@ -241,7 +241,7 @@ class IPC::Connection
raise Exception.new "error reading a message: #{m}" raise Exception.new "error reading a message: #{m}"
end end
IPC::Message.new message.mtype, message.type, message.payload IPC::Message.new message.type, message.user_type, String.new(message.payload)
end end
def close def close
@ -250,7 +250,7 @@ class IPC::Connection
r = LibIPC.ipc_close(pointerof(@connection)) r = LibIPC.ipc_close(pointerof(@connection))
if r != 0 if r != 0
m = String.new LibIPC.ipc_errors_get (r) m = String.new LibIPC.ipc_errors_get (r)
raise Exception.new "cannot close correctly the connection: #{m}" raise Exception.new "cannot correctly close the connection: #{m}"
end end
@closed = true @closed = true
@ -281,7 +281,16 @@ class IPC::Service
close close
end end
def add_file_descriptor (fd : Int) def << (connection : IPC::Connection)
c = connection.connection
r = LibIPC.ipc_add(pointerof(@connections), pointerof(c))
if r != 0
m = String.new LibIPC.ipc_errors_get (r)
raise Exception.new "cannot add an arbitrary file descriptor: #{m}"
end
end
def << (fd : Int)
r = LibIPC.ipc_add_fd(pointerof(@connections), fd) r = LibIPC.ipc_add_fd(pointerof(@connections), fd)
if r != 0 if r != 0
m = String.new LibIPC.ipc_errors_get (r) m = String.new LibIPC.ipc_errors_get (r)
@ -289,14 +298,13 @@ class IPC::Service
end end
end end
# TODO: not implemented in libipc, yet. def remove_fd (fd : Int)
# def del_file_descriptor (fd : Int) r = LibIPC.ipc_del_fd(pointerof(@connections), fd)
# r = LibIPC.ipc_del_fd(pointerof(@connections), fd) if r != 0
# if r != 0 m = String.new LibIPC.ipc_errors_get (r)
# m = String.new LibIPC.ipc_errors_get (r) raise Exception.new "cannot remove an arbitrary file descriptor: #{m}"
# raise Exception.new "cannot remove an arbitrary file descriptor: #{m}" end
# end end
# end
def close def close
return if @closed return if @closed