@Test public void testInitialProcessIsNoop() { _transport.process(); }
@Override public void process() throws TransportException { _processingStarted = true; try { init(); int beforePosition = _inputProcessor.position(); _inputProcessor.process(); _bytesInput += beforePosition - _inputProcessor.position(); } catch (TransportException e) { _head_closed = true; throw e; } }
TransportImpl extends EndpointImpl implements ProtonJTransport, FrameBody.FrameBodyHandler<Integer>,
        FrameHandler, TransportOutputWriter, TransportInternal { @Override public void process() throws TransportException { _processingStarted = true; try { init(); int beforePosition = _inputProcessor.position(); _inputProcessor.process(); _bytesInput += beforePosition - _inputProcessor.position(); } catch (TransportException e) { _head_closed = true; throw e; } } }
TransportImpl extends EndpointImpl implements ProtonJTransport, FrameBody.FrameBodyHandler<Integer>,
        FrameHandler, TransportOutputWriter, TransportInternal { @Override public void process() throws TransportException { _processingStarted = true; try { init(); int beforePosition = _inputProcessor.position(); _inputProcessor.process(); _bytesInput += beforePosition - _inputProcessor.position(); } catch (TransportException e) { _head_closed = true; throw e; } } TransportImpl();   TransportImpl(int maxFrameSize); }
TransportImpl extends EndpointImpl implements ProtonJTransport, FrameBody.FrameBodyHandler<Integer>,
        FrameHandler, TransportOutputWriter, TransportInternal { @Override public void process() throws TransportException { _processingStarted = true; try { init(); int beforePosition = _inputProcessor.position(); _inputProcessor.process(); _bytesInput += beforePosition - _inputProcessor.position(); } catch (TransportException e) { _head_closed = true; throw e; } } TransportImpl();   TransportImpl(int maxFrameSize); @Override void trace(int levels); @Override int getMaxFrameSize(); @Override int getRemoteMaxFrameSize(); @Override void setInitialRemoteMaxFrameSize(int remoteMaxFrameSize); @Override void setMaxFrameSize(int maxFrameSize); @Override int getChannelMax(); @Override void setChannelMax(int channelMax); @Override int getRemoteChannelMax(); @Override ErrorCondition getCondition(); @Override void setCondition(ErrorCondition error); @Override void bind(Connection conn); @Override void unbind(); @Override int input(byte[] bytes, int offset, int length); TransportResult oldApiCheckStateBeforeInput(int inputLength); @Override int output(byte[] bytes, final int offset, final int size); @Override boolean writeInto(ByteBuffer outputBuffer); @Override Sasl sasl(); @Override Ssl ssl(SslDomain sslDomain, SslPeerDetails sslPeerDetails); @Override Ssl ssl(SslDomain sslDomain); @Override void handleOpen(Open open, Binary payload, Integer channel); @Override void handleBegin(Begin begin, Binary payload, Integer channel); @Override void handleAttach(Attach attach, Binary payload, Integer channel); @Override void handleFlow(Flow flow, Binary payload, Integer channel); @Override void handleTransfer(Transfer transfer, Binary payload, Integer channel); @Override void handleDisposition(Disposition disposition, Binary payload, Integer channel); @Override void handleDetach(Detach detach, Binary payload, Integer channel); @Override void handleEnd(End end, Binary payload, Integer channel); @Override void handleClose(Close close, Binary payload, Integer channel); @Override boolean handleFrame(TransportFrame frame); @Override void closed(TransportException error); @Override boolean isHandlingFrames(); @Override ProtocolTracer getProtocolTracer(); @Override void setProtocolTracer(ProtocolTracer protocolTracer); @Override ByteBuffer getInputBuffer(); @Override TransportResult processInput(); @Override ByteBuffer getOutputBuffer(); @Override void outputConsumed(); @Override int capacity(); @Override ByteBuffer tail(); @Override void process(); @Override void close_tail(); @Override int pending(); @Override ByteBuffer head(); @Override void pop(int bytes); @Override void setIdleTimeout(int timeout); @Override int getIdleTimeout(); @Override int getRemoteIdleTimeout(); @Override long tick(long now); @Override long getFramesOutput(); @Override long getFramesInput(); @Override void close_head(); @Override boolean isClosed(); @Override String toString(); void setFrameHandler(FrameHandler frameHandler); void setSelectable(Selectable selectable); Selectable getSelectable(); void setReactor(Reactor reactor); Reactor getReactor(); @Override void setEmitFlowEventOnSend(boolean emitFlowEventOnSend); @Override boolean isEmitFlowEventOnSend(); @Override void setUseReadOnlyOutputBuffer(boolean value); @Override boolean isUseReadOnlyOutputBuffer(); @Override void addTransportLayer(TransportLayer layer); @Override void setOutboundFrameSizeLimit(int limit); @Override int getOutboundFrameSizeLimit(); }
TransportImpl extends EndpointImpl implements ProtonJTransport, FrameBody.FrameBodyHandler<Integer>,
        FrameHandler, TransportOutputWriter, TransportInternal { @Override public void process() throws TransportException { _processingStarted = true; try { init(); int beforePosition = _inputProcessor.position(); _inputProcessor.process(); _bytesInput += beforePosition - _inputProcessor.position(); } catch (TransportException e) { _head_closed = true; throw e; } } TransportImpl();   TransportImpl(int maxFrameSize); @Override void trace(int levels); @Override int getMaxFrameSize(); @Override int getRemoteMaxFrameSize(); @Override void setInitialRemoteMaxFrameSize(int remoteMaxFrameSize); @Override void setMaxFrameSize(int maxFrameSize); @Override int getChannelMax(); @Override void setChannelMax(int channelMax); @Override int getRemoteChannelMax(); @Override ErrorCondition getCondition(); @Override void setCondition(ErrorCondition error); @Override void bind(Connection conn); @Override void unbind(); @Override int input(byte[] bytes, int offset, int length); TransportResult oldApiCheckStateBeforeInput(int inputLength); @Override int output(byte[] bytes, final int offset, final int size); @Override boolean writeInto(ByteBuffer outputBuffer); @Override Sasl sasl(); @Override Ssl ssl(SslDomain sslDomain, SslPeerDetails sslPeerDetails); @Override Ssl ssl(SslDomain sslDomain); @Override void handleOpen(Open open, Binary payload, Integer channel); @Override void handleBegin(Begin begin, Binary payload, Integer channel); @Override void handleAttach(Attach attach, Binary payload, Integer channel); @Override void handleFlow(Flow flow, Binary payload, Integer channel); @Override void handleTransfer(Transfer transfer, Binary payload, Integer channel); @Override void handleDisposition(Disposition disposition, Binary payload, Integer channel); @Override void handleDetach(Detach detach, Binary payload, Integer channel); @Override void handleEnd(End end, Binary payload, Integer channel); @Override void handleClose(Close close, Binary payload, Integer channel); @Override boolean handleFrame(TransportFrame frame); @Override void closed(TransportException error); @Override boolean isHandlingFrames(); @Override ProtocolTracer getProtocolTracer(); @Override void setProtocolTracer(ProtocolTracer protocolTracer); @Override ByteBuffer getInputBuffer(); @Override TransportResult processInput(); @Override ByteBuffer getOutputBuffer(); @Override void outputConsumed(); @Override int capacity(); @Override ByteBuffer tail(); @Override void process(); @Override void close_tail(); @Override int pending(); @Override ByteBuffer head(); @Override void pop(int bytes); @Override void setIdleTimeout(int timeout); @Override int getIdleTimeout(); @Override int getRemoteIdleTimeout(); @Override long tick(long now); @Override long getFramesOutput(); @Override long getFramesInput(); @Override void close_head(); @Override boolean isClosed(); @Override String toString(); void setFrameHandler(FrameHandler frameHandler); void setSelectable(Selectable selectable); Selectable getSelectable(); void setReactor(Reactor reactor); Reactor getReactor(); @Override void setEmitFlowEventOnSend(boolean emitFlowEventOnSend); @Override boolean isEmitFlowEventOnSend(); @Override void setUseReadOnlyOutputBuffer(boolean value); @Override boolean isUseReadOnlyOutputBuffer(); @Override void addTransportLayer(TransportLayer layer); @Override void setOutboundFrameSizeLimit(int limit); @Override int getOutboundFrameSizeLimit();  }