Package org.eclipse.jetty.http2
Class HTTP2Connection
java.lang.Object
org.eclipse.jetty.io.AbstractConnection
org.eclipse.jetty.http2.HTTP2Connection
- All Implemented Interfaces:
Closeable,AutoCloseable,org.eclipse.jetty.io.Connection,org.eclipse.jetty.io.WriteFlusher.Listener
- Direct Known Subclasses:
HTTP2ClientConnectionFactory.HTTP2ClientConnection,HTTP2ServerConnection
public class HTTP2Connection
extends org.eclipse.jetty.io.AbstractConnection
implements org.eclipse.jetty.io.WriteFlusher.Listener
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprivate classprotected classprivate classprivate classNested classes/interfaces inherited from interface org.eclipse.jetty.io.Connection
org.eclipse.jetty.io.Connection.Listener, org.eclipse.jetty.io.Connection.UpgradeFrom, org.eclipse.jetty.io.Connection.UpgradeTo -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final intprivate final org.eclipse.jetty.io.ByteBufferPoolprivate final AtomicLongprotected static final org.eclipse.jetty.util.log.Loggerprivate static final booleanprivate final HTTP2Connection.HTTP2Producerprivate final ISessionprivate final org.eclipse.jetty.util.thread.ExecutionStrategy -
Constructor Summary
ConstructorsConstructorDescriptionHTTP2Connection(org.eclipse.jetty.io.ByteBufferPool byteBufferPool, Executor executor, org.eclipse.jetty.io.EndPoint endPoint, ISession session, int bufferSize) HTTP2Connection(org.eclipse.jetty.io.ByteBufferPool byteBufferPool, Executor executor, org.eclipse.jetty.io.EndPoint endPoint, Parser parser, ISession session, int bufferSize) Deprecated. -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()protected voiddispatch()private intfill(org.eclipse.jetty.io.EndPoint endPoint, ByteBuffer buffer) longlonglonglongprotected Parserprivate voidprotected voidvoidonClose()voidvoidonFlushed(long bytes) booleanvoidonOpen()private RunnablepollTask()protected voidproduce()protected voidsetInputBuffer(ByteBuffer buffer) wrapParserListener(Parser.Listener listener) Methods inherited from class org.eclipse.jetty.io.AbstractConnection
addListener, failedCallback, fillInterested, getCreatedTimeStamp, getEndPoint, getExecutor, getInputBufferSize, isFillInterested, onFillInterestedFailed, onReadTimeout, removeListener, setInputBufferSize, toConnectionString, toString, tryFillInterested, tryFillInterested
-
Field Details
-
LOG
protected static final org.eclipse.jetty.util.log.Logger LOG -
PEC_MODE
private static final boolean PEC_MODE -
tasks
-
producer
-
bytesIn
-
byteBufferPool
private final org.eclipse.jetty.io.ByteBufferPool byteBufferPool -
session
-
bufferSize
private final int bufferSize -
strategy
private final org.eclipse.jetty.util.thread.ExecutionStrategy strategy
-
-
Constructor Details
-
HTTP2Connection
@Deprecated public HTTP2Connection(org.eclipse.jetty.io.ByteBufferPool byteBufferPool, Executor executor, org.eclipse.jetty.io.EndPoint endPoint, Parser parser, ISession session, int bufferSize) Deprecated. -
HTTP2Connection
-
-
Method Details
-
getMessagesIn
public long getMessagesIn()- Specified by:
getMessagesInin interfaceorg.eclipse.jetty.io.Connection- Overrides:
getMessagesInin classorg.eclipse.jetty.io.AbstractConnection
-
getMessagesOut
public long getMessagesOut()- Specified by:
getMessagesOutin interfaceorg.eclipse.jetty.io.Connection- Overrides:
getMessagesOutin classorg.eclipse.jetty.io.AbstractConnection
-
getBytesIn
public long getBytesIn()- Specified by:
getBytesInin interfaceorg.eclipse.jetty.io.Connection- Overrides:
getBytesInin classorg.eclipse.jetty.io.AbstractConnection
-
getBytesOut
public long getBytesOut()- Specified by:
getBytesOutin interfaceorg.eclipse.jetty.io.Connection- Overrides:
getBytesOutin classorg.eclipse.jetty.io.AbstractConnection
-
getSession
-
getParser
-
setInputBuffer
-
wrapParserListener
-
onOpen
public void onOpen()- Specified by:
onOpenin interfaceorg.eclipse.jetty.io.Connection- Overrides:
onOpenin classorg.eclipse.jetty.io.AbstractConnection
-
onClose
public void onClose()- Specified by:
onClosein interfaceorg.eclipse.jetty.io.Connection- Overrides:
onClosein classorg.eclipse.jetty.io.AbstractConnection
-
onFillable
public void onFillable()- Specified by:
onFillablein classorg.eclipse.jetty.io.AbstractConnection
-
fill
-
onIdleExpired
public boolean onIdleExpired()- Specified by:
onIdleExpiredin interfaceorg.eclipse.jetty.io.Connection- Overrides:
onIdleExpiredin classorg.eclipse.jetty.io.AbstractConnection
-
offerTask
-
produce
protected void produce() -
dispatch
protected void dispatch() -
close
public void close()- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Specified by:
closein interfaceorg.eclipse.jetty.io.Connection- Overrides:
closein classorg.eclipse.jetty.io.AbstractConnection
-
offerTask
-
pollTask
-
onFlushed
- Specified by:
onFlushedin interfaceorg.eclipse.jetty.io.WriteFlusher.Listener- Throws:
IOException
-