TransportImpl

Undocumented in source.
class TransportImpl : EndpointImpl , ProtonJTransport , FrameBodyHandler!int, FrameHandler , TransportOutputWriter , TransportInternal {}

Constructors

this
this()

Application code should use {@link hunt.proton.engine.Transport.Factory#create()} instead

this
this(int maxFrameSize)

Creates a transport with the given maximum frame size. Note that the maximumFrameSize also determines the size of the output buffer.

Members

Functions

addTransportLayer
void addTransportLayer(TransportLayer layer)
Undocumented in source. Be warned that the author may not have intended to support it.
bind
void bind(Connection conn)
Undocumented in source. Be warned that the author may not have intended to support it.
capacity
int capacity()
Undocumented in source. Be warned that the author may not have intended to support it.
close_head
void close_head()
Undocumented in source. Be warned that the author may not have intended to support it.
close_tail
void close_tail()
Undocumented in source. Be warned that the author may not have intended to support it.
closed
void closed(TransportException error)
Undocumented in source. Be warned that the author may not have intended to support it.
copy
FrameBody copy()
Undocumented in source. Be warned that the author may not have intended to support it.
doFree
void doFree()
Undocumented in source. Be warned that the author may not have intended to support it.
getChannelMax
int getChannelMax()
Undocumented in source. Be warned that the author may not have intended to support it.
getCondition
ErrorCondition getCondition()
Undocumented in source. Be warned that the author may not have intended to support it.
getConnectionImpl
ConnectionImpl getConnectionImpl()
Undocumented in source. Be warned that the author may not have intended to support it.
getFramesInput
long getFramesInput()
Undocumented in source. Be warned that the author may not have intended to support it.
getFramesOutput
long getFramesOutput()
Undocumented in source. Be warned that the author may not have intended to support it.
getIdleTimeout
int getIdleTimeout()
Undocumented in source. Be warned that the author may not have intended to support it.
getInputBuffer
ByteBuffer getInputBuffer()
Undocumented in source. Be warned that the author may not have intended to support it.
getMaxFrameSize
int getMaxFrameSize()
Undocumented in source. Be warned that the author may not have intended to support it.
getOutboundFrameSizeLimit
int getOutboundFrameSizeLimit()
Undocumented in source. Be warned that the author may not have intended to support it.
getOutputBuffer
ByteBuffer getOutputBuffer()
Undocumented in source. Be warned that the author may not have intended to support it.
getProtocolTracer
ProtocolTracer getProtocolTracer()
Undocumented in source. Be warned that the author may not have intended to support it.
getReactor
Reactor getReactor()
Undocumented in source. Be warned that the author may not have intended to support it.
getRemoteChannelMax
int getRemoteChannelMax()
Undocumented in source. Be warned that the author may not have intended to support it.
getRemoteIdleTimeout
int getRemoteIdleTimeout()
Undocumented in source. Be warned that the author may not have intended to support it.
getRemoteMaxFrameSize
int getRemoteMaxFrameSize()
Undocumented in source. Be warned that the author may not have intended to support it.
getSelectable
Selectable getSelectable()
Undocumented in source. Be warned that the author may not have intended to support it.
handleAttach
void handleAttach(Attach attach, Binary payload, int channel)
Undocumented in source. Be warned that the author may not have intended to support it.
handleBegin
void handleBegin(Begin begin, Binary payload, int channel)
Undocumented in source. Be warned that the author may not have intended to support it.
handleClose
void handleClose(Close close, Binary payload, int channel)
Undocumented in source. Be warned that the author may not have intended to support it.
handleDetach
void handleDetach(Detach detach, Binary payload, int channel)
Undocumented in source. Be warned that the author may not have intended to support it.
handleDisposition
void handleDisposition(Disposition disposition, Binary payload, int channel)
Undocumented in source. Be warned that the author may not have intended to support it.
handleEnd
void handleEnd(End end, Binary payload, int channel)
Undocumented in source. Be warned that the author may not have intended to support it.
handleFlow
void handleFlow(Flow flow, Binary payload, int channel)
Undocumented in source. Be warned that the author may not have intended to support it.
handleFrame
bool handleFrame(TransportFrame frame)
Undocumented in source. Be warned that the author may not have intended to support it.
handleOpen
void handleOpen(Open open, Binary payload, int channel)
Undocumented in source. Be warned that the author may not have intended to support it.
handleTransfer
void handleTransfer(Transfer transfer, Binary payload, int channel)
Undocumented in source. Be warned that the author may not have intended to support it.
head
ByteBuffer head()
Undocumented in source. Be warned that the author may not have intended to support it.
input
int input(byte[] bytes, int offset, int length)
Undocumented in source. Be warned that the author may not have intended to support it.
invoke
void invoke(FrameBodyHandler!int handler, Binary payload, int context)
Undocumented in source. Be warned that the author may not have intended to support it.
isClosed
bool isClosed()
Undocumented in source. Be warned that the author may not have intended to support it.
isEmitFlowEventOnSend
bool isEmitFlowEventOnSend()
Undocumented in source. Be warned that the author may not have intended to support it.
isFrameTracingEnabled
bool isFrameTracingEnabled()
Undocumented in source. Be warned that the author may not have intended to support it.
isHandlingFrames
bool isHandlingFrames()
Undocumented in source. Be warned that the author may not have intended to support it.
isTraceFramesEnabled
bool isTraceFramesEnabled()
Undocumented in source. Be warned that the author may not have intended to support it.
isUseReadOnlyOutputBuffer
bool isUseReadOnlyOutputBuffer()
Undocumented in source. Be warned that the author may not have intended to support it.
localClose
void localClose()
Undocumented in source. Be warned that the author may not have intended to support it.
localOpen
void localOpen()
Undocumented in source. Be warned that the author may not have intended to support it.
log
void log(string event, TransportFrame frame)
Undocumented in source. Be warned that the author may not have intended to support it.
log
void log(string event, SaslFrameBody frameBody)
Undocumented in source. Be warned that the author may not have intended to support it.
log
void log(string event, String headerDescription)
Undocumented in source. Be warned that the author may not have intended to support it.
oldApiCheckStateBeforeInput
TransportResult oldApiCheckStateBeforeInput(int inputLength)

This method is public as it is used by Python layer. @see hunt.proton.engine.Transport#input(byte[], int, int)

output
int output(byte[] bytes, int offset, int size)
Undocumented in source. Be warned that the author may not have intended to support it.
outputConsumed
void outputConsumed()
Undocumented in source. Be warned that the author may not have intended to support it.
pending
int pending()
Undocumented in source. Be warned that the author may not have intended to support it.
pop
void pop(int bytes)
Undocumented in source. Be warned that the author may not have intended to support it.
postFinal
void postFinal()
Undocumented in source. Be warned that the author may not have intended to support it.
process
void process()
Undocumented in source. Be warned that the author may not have intended to support it.
processInput
TransportResult processInput()
Undocumented in source. Be warned that the author may not have intended to support it.
put
void put(Type type, Object context)
Undocumented in source. Be warned that the author may not have intended to support it.
sasl
Sasl sasl()
Undocumented in source. Be warned that the author may not have intended to support it.
setChannelMax
void setChannelMax(int channelMax)
Undocumented in source. Be warned that the author may not have intended to support it.
setCondition
void setCondition(ErrorCondition error)
Undocumented in source. Be warned that the author may not have intended to support it.
setEmitFlowEventOnSend
void setEmitFlowEventOnSend(bool emitFlowEventOnSend)
Undocumented in source. Be warned that the author may not have intended to support it.
setFrameHandler
void setFrameHandler(FrameHandler frameHandler)

Override the default frame handler. Must be called before the transport starts being used (e.g. {@link #getInputBuffer()}, {@link #getOutputBuffer()}, {@link #ssl(SslDomain)} etc).

setIdleTimeout
void setIdleTimeout(int timeout)
Undocumented in source. Be warned that the author may not have intended to support it.
setInitialRemoteMaxFrameSize
void setInitialRemoteMaxFrameSize(int remoteMaxFrameSize)
Undocumented in source. Be warned that the author may not have intended to support it.
setMaxFrameSize
void setMaxFrameSize(int maxFrameSize)
Undocumented in source. Be warned that the author may not have intended to support it.
setOutboundFrameSizeLimit
void setOutboundFrameSizeLimit(int limit)
Undocumented in source. Be warned that the author may not have intended to support it.
setProtocolTracer
void setProtocolTracer(ProtocolTracer protocolTracer)
Undocumented in source. Be warned that the author may not have intended to support it.
setReactor
void setReactor(Reactor reactor)
Undocumented in source. Be warned that the author may not have intended to support it.
setSelectable
void setSelectable(Selectable selectable)
Undocumented in source. Be warned that the author may not have intended to support it.
setUseReadOnlyOutputBuffer
void setUseReadOnlyOutputBuffer(bool value)
Undocumented in source. Be warned that the author may not have intended to support it.
ssl
Ssl ssl(SslDomain sslDomain, SslPeerDetails sslPeerDetails)

{@inheritDoc}

ssl
Ssl ssl(SslDomain sslDomain)
Undocumented in source. Be warned that the author may not have intended to support it.
tail
ByteBuffer tail()
Undocumented in source. Be warned that the author may not have intended to support it.
tick
long tick(long now)
Undocumented in source. Be warned that the author may not have intended to support it.
toString
string toString()
Undocumented in source. Be warned that the author may not have intended to support it.
trace
void trace(int levels)
Undocumented in source. Be warned that the author may not have intended to support it.
unbind
void unbind()
Undocumented in source. Be warned that the author may not have intended to support it.
writeFrame
void writeFrame(int channel, FrameBody frameBody, ReadableBuffer payload, Runnable onPayloadTooLarge)
Undocumented in source. Be warned that the author may not have intended to support it.
writeInto
bool writeInto(ByteBuffer outputBuffer)
Undocumented in source. Be warned that the author may not have intended to support it.

Static variables

BUFFER_RELEASE_THRESHOLD
int BUFFER_RELEASE_THRESHOLD;
Undocumented in source.
INCOMING
string INCOMING;
Undocumented in source.
OUTGOING
string OUTGOING;
Undocumented in source.

Inherited Members

From EndpointImpl

freed
bool freed;
Undocumented in source.
incref
void incref()
Undocumented in source. Be warned that the author may not have intended to support it.
decref
void decref()
Undocumented in source. Be warned that the author may not have intended to support it.
postFinal
void postFinal()
Undocumented in source.
localOpen
void localOpen()
Undocumented in source.
localClose
void localClose()
Undocumented in source.
open
void open()
Undocumented in source. Be warned that the author may not have intended to support it.
close
void close()
Undocumented in source. Be warned that the author may not have intended to support it.
getLocalState
EndpointState getLocalState()
Undocumented in source. Be warned that the author may not have intended to support it.
getRemoteState
EndpointState getRemoteState()
Undocumented in source. Be warned that the author may not have intended to support it.
getCondition
ErrorCondition getCondition()
Undocumented in source. Be warned that the author may not have intended to support it.
setCondition
void setCondition(ErrorCondition condition)
Undocumented in source. Be warned that the author may not have intended to support it.
getRemoteCondition
ErrorCondition getRemoteCondition()
Undocumented in source. Be warned that the author may not have intended to support it.
setLocalState
void setLocalState(EndpointState localState)
Undocumented in source. Be warned that the author may not have intended to support it.
setRemoteState
void setRemoteState(EndpointState remoteState)
Undocumented in source. Be warned that the author may not have intended to support it.
modified
void modified()
Undocumented in source. Be warned that the author may not have intended to support it.
modified
void modified(bool emit)
Undocumented in source. Be warned that the author may not have intended to support it.
getConnectionImpl
ConnectionImpl getConnectionImpl()
Undocumented in source.
clearModified
void clearModified()
Undocumented in source. Be warned that the author may not have intended to support it.
isModified
bool isModified()
Undocumented in source. Be warned that the author may not have intended to support it.
transportNext
EndpointImpl transportNext()
Undocumented in source. Be warned that the author may not have intended to support it.
transportPrev
EndpointImpl transportPrev()
Undocumented in source. Be warned that the author may not have intended to support it.
doFree
void doFree()
Undocumented in source.
free
void free()
Undocumented in source. Be warned that the author may not have intended to support it.
setTransportNext
void setTransportNext(EndpointImpl transportNext)
Undocumented in source. Be warned that the author may not have intended to support it.
setTransportPrev
void setTransportPrev(EndpointImpl transportPrevious)
Undocumented in source. Be warned that the author may not have intended to support it.
getContext
Object getContext()
Undocumented in source. Be warned that the author may not have intended to support it.
setContext
void setContext(Object context)
Undocumented in source. Be warned that the author may not have intended to support it.
attachments
Record attachments()
Undocumented in source. Be warned that the author may not have intended to support it.

From ProtonJTransport

setProtocolTracer
void setProtocolTracer(ProtocolTracer protocolTracer)
Undocumented in source.
getProtocolTracer
ProtocolTracer getProtocolTracer()
Undocumented in source.

From FrameHandler

handleFrame
bool handleFrame(TransportFrame frame)

@throws IllegalStateException if I am not currently accepting input @see #isHandlingFrames() @return false on end of stream

closed
void closed(TransportException error)
Undocumented in source.
isHandlingFrames
bool isHandlingFrames()

Returns whether I am currently able to handle frames. MUST be checked before calling {@link #handleFrame(TransportFrame)}.

From TransportOutputWriter

writeInto
bool writeInto(ByteBuffer outputBuffer)

Writes my pending output bytes into outputBuffer. Does not subsequently flip it. Returns true on end of stream.

closed
void closed(TransportException error)
Undocumented in source.

From TransportInternal

addTransportLayer
void addTransportLayer(TransportLayer layer)

Add a {@link TransportLayer} to the transport, wrapping the input and output process handlers in the state they currently exist. No effect if the given layer was previously added.

setUseReadOnlyOutputBuffer
void setUseReadOnlyOutputBuffer(bool value)
Undocumented in source.
isUseReadOnlyOutputBuffer
bool isUseReadOnlyOutputBuffer()
Undocumented in source.

Meta