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

fixing client init

ipc07
Karchnu 2020-07-14 17:02:14 +02:00
parent 3665fe0eac
commit f4c9ccad60
2 changed files with 18 additions and 17 deletions

View File

@ -2,6 +2,23 @@
class IPC::Client < IPC::Context
property server_fd : Int32?
# By default, this is a client.
def initialize(service_name : String)
super()
serverfd = 0
r = LibIPC.ipc_connection(self.pointer, service_name, pointerof(serverfd))
if r.error_code != 0
m = String.new r.error_message.to_slice
raise Exception.new "error during connection establishment: #{m}"
end
@server_fd = serverfd
# Very important as there are filesystem side-effects.
at_exit { close }
end
def read
unless (fd = @server_fd).nil?
message = LibIPC::Message.new
@ -15,21 +32,4 @@ class IPC::Client < IPC::Context
raise "Client not connected to a server"
end
end
# By default, this is a client.
def initialize(service_name : String)
super()
serverfd = 0
r = LibIPC.ipc_connection(self.pointer, service_name, pointerof(serverfd))
if r.error_code != 0
m = String.new r.error_message.to_slice
raise Exception.new "error during connection establishment: #{m}"
end
@server_fd = server_fd
# Very important as there are filesystem side-effects.
at_exit { close }
end
end

View File

@ -5,6 +5,7 @@ client = IPC::Client.new "pong"
server_fd = client.server_fd
if server_fd.nil?
puts "there is no server_fd!!"
exit 1
end