class Tcp::Multiplex::Base

Included Modules

Direct Known Subclasses

Defined in:

tcp-multiplex-base.cr

Constant Summary

DEMUX_TYPE_MGM = Bytes.new(2, 1)
DEMUX_TYPE_RECV = Bytes.new(1, 0)
DEMUX_TYPE_SEND = Bytes.new(1, 1)
MGM_COMMAND_CLOSE_CLIENT = 58.to_u8

Constructors

Instance Method Summary

Instance methods inherited from module Tcp::Multiplex::Helpers

byte_next(value : UInt8) : UInt8 byte_next, bytes_to_u16(slice : Bytes) : UInt16 bytes_to_u16, bytes_to_u32(slice : Bytes) : UInt32 bytes_to_u32, exit_control : Int exit_control, int_to_bytes(int : Int) : Bytes int_to_bytes, md5(slice : Bytes) : String md5, ports_s_to_n(ports : String) : Array(UInt16) ports_s_to_n

Constructor Detail

def self.new(bind_addr : String, bind_ports : String, hop_addr : String, hop_ports : String, fibers : UInt16) #

[View source]

Instance Method Detail

def close_endp_ch_with_delay(channel : Channel) #

[View source]
def data_flow_demux_ch_to_demux_pch_pool(channel : Channel(Bytes)) #

[View source]
def data_flow_demux_pch_to_demux_sock(socket : TCPSocket, channel : Channel) #

[View source]
def data_flow_demux_sock_to_demux_ch(socket : TCPSocket, channel : Channel(Bytes), side_ch : Channel(Bytes)) #

[View source]
def data_flow_endp_ch_to_endp_sock(socket : TCPSocket, channel : Channel(Bytes)) #

[View source]
def data_flow_endp_sock_to_endp_ch(socket : TCPSocket, channel : Channel(Bytes), socket_h : Bytes | Nil = nil) #

[View source]
def read_management_socket(socket : TCPSocket) #

[View source]