class Transfer
- Transfer
- Reference
- Object
Defined in:
socks/extra/transfer.crConstructors
Instance Method Summary
- #aliveInterval : Time::Span
- #aliveInterval=(aliveInterval : Time::Span)
- #any_done? : Bool
- #check_exceed_threshold?(any_side_bytes_exceed : Bool) : Bool
- #cleanup(sd_flag : SDFlag, reset : Bool = true)
- #cleanup
- #concurrentFibers : Set(Fiber)
- #concurrentMutex : Mutex
- #destination : IO
- #destination=(destination : IO)
- #exceedThresholdFlag : Atomic(ExceedThresholdFlag)
- #exceedThresholdFlag=(exceedThresholdFlag : Atomic(ExceedThresholdFlag))
- #finishCallback : Proc(Transfer, UInt64, UInt64, Nil) | Nil
- #finishCallback=(finishCallback : Proc(Transfer, UInt64, UInt64, Nil) | Nil)
- #finished?
- #first_alive_time : Time
- #firstAliveTime : Atomic(Int64)
- #get_monitor_receive_state(all : Bool = false) : Hash(Int64, UInt64) | Nil
- #get_monitor_sent_state(all : Bool = false) : Hash(Int64, UInt64) | Nil
- #heartbeat_counter : Atomic(UInt64)
- #heartbeatCallback : Proc(Transfer, Time::Span, Bool) | Nil
- #heartbeatCallback=(heartbeatCallback : Proc(Transfer, Time::Span, Bool) | Nil)
- #heartbeatCounter : Atomic(UInt64)
- #heartbeatInterval : Time::Span
- #heartbeatInterval=(heartbeatInterval : Time::Span)
- #last_alive_time : Time
- #lastAliveTime : Atomic(Int64)
- #monitor : Atomic(Int8)
- #monitor? : Bool
- #monitorCapacity : Atomic(Int8)
- #monitorState : Hash(SRFlag, Hash(Int64, UInt64)) | Nil
- #mutex : Mutex
- #perform
- #receive_done? : Bool
- #receive_exception=(value : Exception | Nil)
- #receive_exception? : Exception | Nil
- #receivedBytes : Atomic(UInt64)
- #receiveDone : Atomic(Int8)
- #reset_monitor_state : Bool
- #reset_settings!(reset_socket_switch_seconds : Bool = true, reset_socket_switch_bytes : Bool = true, reset_socket_switch_expression : Bool = true) : Bool
- #reset_socket(sd_flag : SDFlag)
- #reset_socket
- #sent_done? : Bool
- #sent_exception=(value : Exception | Nil)
- #sent_exception? : Exception | Nil
- #sentBytes : Atomic(UInt64)
- #sentDone : Atomic(Int8)
- #socketSwitchBytes : Atomic(UInt64)
- #socketSwitchBytes=(socketSwitchBytes : Atomic(UInt64))
- #socketSwitchExpression : Atomic(SocketSwitchExpressionFlag)
- #socketSwitchExpression=(socketSwitchExpression : Atomic(SocketSwitchExpressionFlag))
- #socketSwitchSeconds : Atomic(UInt64)
- #socketSwitchSeconds=(socketSwitchSeconds : Atomic(UInt64))
- #source : IO
- #source=(source : IO)
- #strict_check_receive_exceed_threshold? : Bool
- #strict_check_sent_exceed_threshold? : Bool
Constructor Detail
def self.new(source : IO, destination : IO, finishCallback : Proc(Transfer, UInt64, UInt64, Nil) | Nil = nil, heartbeatCallback : Proc(Transfer, Time::Span, Bool) | Nil = nil)
#
Instance Method Detail
def reset_settings!(reset_socket_switch_seconds : Bool = true, reset_socket_switch_bytes : Bool = true, reset_socket_switch_expression : Bool = true) : Bool
#
def socketSwitchExpression=(socketSwitchExpression : Atomic(SocketSwitchExpressionFlag))
#