class IPC::Context

Direct Known Subclasses

Defined in:

cbor.cr
ipc/context.cr
json.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(context : LibIPC::Ctx) #

[View source]
def self.new #

[View source]
def self.new(name : String, &block : Proc(IPC::Event::Events | Exception, Nil)) #

[View source]

Instance Method Detail

def <<(fd : Int) #

[View source]
def base_timer : Int32 #

TODO FIXME: base timer default is 30 seconds, INFTIM was causing trouble.


[View source]
def base_timer=(base_timer : Int32) #

TODO FIXME: base timer default is 30 seconds, INFTIM was causing trouble.


[View source]
def close #

[View source]
def context : LibIPC::Ctx #

[View source]
def event : LibIPC::Event #

On message reception, the message is contained into the event structure. This message is automatically deallocated on the next ipc_wait_event call. Therefore, we must keep this structure.


[View source]
def event=(event : LibIPC::Event) #

On message reception, the message is contained into the event structure. This message is automatically deallocated on the next ipc_wait_event call. Therefore, we must keep this structure.


[View source]
def loop(&block : Proc(IPC::Event::Events | Exception, Nil)) #

[View source]
def pointer #

sanitizer


[View source]
def pp #

[View source]
def read(index : UInt32) #

[View source]
def remove_fd(fd : Int32) #

[View source]
def remove_index(index : UInt32) #

[View source]
def send(fd : Int32, utype : UInt8, payload : Bytes) #

[View source]
def send(fd : Int32, utype : UInt8, payload : String) #

[View source]
def send(fd : Int32, message : IPC::CBOR) #

[View source]
def send(fd : Int32, message : IPC::JSON) #

[View source]
def send(message : LibIPC::Message) #

[View source]
def send(message : IPC::Message) #

[View source]
def send_now(fd : Int32, utype : UInt8, payload : Bytes) #

[View source]
def send_now(fd : Int32, utype : UInt8, payload : String) #

[View source]
def send_now(fd : Int32, message : IPC::CBOR) #

[View source]
def send_now(fd : Int32, message : IPC::JSON) #

[View source]
def send_now(message : LibIPC::Message) #

[View source]
def send_now(message : IPC::Message) #

[View source]
def timer : Int32 #

[View source]
def timer=(timer : Int32) #

[View source]
def wait_event : IPC::Event::Events | Exception #

[View source]