class SOCKS::Enhanced::State::WebSocket
- SOCKS::Enhanced::State::WebSocket
- SOCKS::Enhanced::State
- Reference
- Object
Defined in:
socks/enhanced/state/websocket.crConstructors
Instance Method Summary
- #allow_connection_pause? : Bool
- #allow_connection_reuse? : Bool
- #allowConnectionPause : Atomic(Int8)
- #allowConnectionReuse : Atomic(Int8)
- #any_done=(value : Bool)
- #any_done? : Bool
- #anyDone : Atomic(Int8)
- #connection_identifier
- #connection_identifier=(value : UUID | Nil)
- #final_command_flag? : CommandFlag | Nil
- #maximum_receive_sequence : Int8
- #maximum_receive_sequence=(value : Int8)
- #maximum_sent_sequence : Int8
- #maximum_sent_sequence=(value : Int8)
- #maximumReceiveSequence : Atomic(Int8)
- #maximumSentSequence : Atomic(Int8)
- #mutex : Mutex
- #notify_peer_incoming(io : HTTP::WebSocket::Protocol)
- #ping(io : HTTP::WebSocket::Protocol, slice : Bytes | Nil)
- #pong(io : HTTP::WebSocket::Protocol, slice : Bytes | Nil)
- #process_client_side_connection_pause_pending!(io : HTTP::WebSocket::Protocol) : QueueFlag
- #process_negotiate(io : HTTP::WebSocket::Protocol, source : IO) : Exception | Nil
- #process_response_pending_command_negotiate(io : HTTP::WebSocket::Protocol)
- #process_server_side_connection_pause_pending!(io : HTTP::WebSocket::Protocol, connection_identifier : UUID, pause_pool : PausePool) : PausePool::Entry | Nil
- #read(io : HTTP::WebSocket::Protocol, slice : Bytes) : Int32
- #reading : Atomic(Int8)
- #reading=(value : Bool)
- #reading? : Bool
- #receive_buffer_end_of_reached? : Bool
- #receive_end_of_reached? : Bool
- #receive_sequence_reset
- #receiveBuffer : IO::Memory
- #received_command=(value : Tuple(Int64, CommandFlag))
- #received_command? : Tuple(Int64, CommandFlag) | Nil
- #received_command_flag? : CommandFlag | Nil
- #received_passive_ask_command=(value : Bool)
- #received_passive_ask_command? : Bool
- #received_send_reply_command=(value : Bool)
- #received_send_reply_command? : Bool
- #receivedCommand : Tuple(Int64, CommandFlag) | Nil
- #receivedPassiveAskCommand : Atomic(Int8)
- #receivedSendReplyCommand : Atomic(Int8)
- #receiveMutex : Mutex
- #receiveRescueBuffer : IO::Memory
- #receiveRound : Atomic(UInt64)
- #receiveSequence : Atomic(Int8)
- #reply_passive_ask_command=(value : Bool)
- #reply_passive_ask_command? : Bool
- #replyPassiveAskCommand : Atomic(Int8)
- #resynchronize(io : HTTP::WebSocket::Protocol)
- #send_active_ask_command=(value : Bool)
- #send_active_ask_command? : Bool
- #send_command=(value : Tuple(Int64, CommandFlag))
- #send_command? : Tuple(Int64, CommandFlag) | Nil
- #send_command_flag? : CommandFlag | Nil
- #sendActiveAskCommand : Atomic(Int8)
- #sendCommand : Tuple(Int64, CommandFlag) | Nil
- #sent_sequence_reset
- #sentBufferSet : Set(Bytes)
- #sentMutex : Mutex
- #sentRound : Atomic(UInt64)
- #sentSequence : Atomic(Int8)
- #synchronize(io : HTTP::WebSocket::Protocol, synchronize_flag : SynchronizeFlag, ignore_incoming_alert : Bool = true) : RBFlag
- #synchronizeMutex : Mutex
- #synchronizing : Atomic(Int8)
- #synchronizing=(value : Bool)
- #synchronizing? : Bool
- #transporting : Atomic(Int8)
- #transporting=(value : Bool)
- #transporting? : Bool
- #update_receive_rescue_buffer(slice : Bytes) : Bool
- #write(io : HTTP::WebSocket::Protocol, slice : Bytes) : Nil
- #writing : Atomic(Int8)
- #writing=(value : Bool)
- #writing? : Bool
Constructor Detail
Instance Method Detail
def process_server_side_connection_pause_pending!(io : HTTP::WebSocket::Protocol, connection_identifier : UUID, pause_pool : PausePool) : PausePool::Entry | Nil
#
def synchronize(io : HTTP::WebSocket::Protocol, synchronize_flag : SynchronizeFlag, ignore_incoming_alert : Bool = true) : RBFlag
#