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 class
protected class
private class
private class
Nested 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 int
private final org.eclipse.jetty.io.ByteBufferPool
private final AtomicLong
protected static final org.eclipse.jetty.util.log.Logger
private static final boolean
private final HTTP2Connection.HTTP2Producer
private final ISession
private 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 TypeMethodDescriptionvoid
close()
protected void
dispatch()
private int
fill
(org.eclipse.jetty.io.EndPoint endPoint, ByteBuffer buffer) long
long
long
long
protected Parser
private void
protected void
void
onClose()
void
void
onFlushed
(long bytes) boolean
void
onOpen()
private Runnable
pollTask()
protected void
produce()
protected void
setInputBuffer
(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:
getMessagesIn
in interfaceorg.eclipse.jetty.io.Connection
- Overrides:
getMessagesIn
in classorg.eclipse.jetty.io.AbstractConnection
-
getMessagesOut
public long getMessagesOut()- Specified by:
getMessagesOut
in interfaceorg.eclipse.jetty.io.Connection
- Overrides:
getMessagesOut
in classorg.eclipse.jetty.io.AbstractConnection
-
getBytesIn
public long getBytesIn()- Specified by:
getBytesIn
in interfaceorg.eclipse.jetty.io.Connection
- Overrides:
getBytesIn
in classorg.eclipse.jetty.io.AbstractConnection
-
getBytesOut
public long getBytesOut()- Specified by:
getBytesOut
in interfaceorg.eclipse.jetty.io.Connection
- Overrides:
getBytesOut
in classorg.eclipse.jetty.io.AbstractConnection
-
getSession
-
getParser
-
setInputBuffer
-
wrapParserListener
-
onOpen
public void onOpen()- Specified by:
onOpen
in interfaceorg.eclipse.jetty.io.Connection
- Overrides:
onOpen
in classorg.eclipse.jetty.io.AbstractConnection
-
onClose
public void onClose()- Specified by:
onClose
in interfaceorg.eclipse.jetty.io.Connection
- Overrides:
onClose
in classorg.eclipse.jetty.io.AbstractConnection
-
onFillable
public void onFillable()- Specified by:
onFillable
in classorg.eclipse.jetty.io.AbstractConnection
-
fill
-
onIdleExpired
public boolean onIdleExpired()- Specified by:
onIdleExpired
in interfaceorg.eclipse.jetty.io.Connection
- Overrides:
onIdleExpired
in classorg.eclipse.jetty.io.AbstractConnection
-
offerTask
-
produce
protected void produce() -
dispatch
protected void dispatch() -
close
public void close()- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Specified by:
close
in interfaceorg.eclipse.jetty.io.Connection
- Overrides:
close
in classorg.eclipse.jetty.io.AbstractConnection
-
offerTask
-
pollTask
-
onFlushed
- Specified by:
onFlushed
in interfaceorg.eclipse.jetty.io.WriteFlusher.Listener
- Throws:
IOException
-