Package org.eclipse.jetty.http2
Class HTTP2Connection
- java.lang.Object
-
- org.eclipse.jetty.io.AbstractConnection
-
- org.eclipse.jetty.http2.HTTP2Connection
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.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 Classes Modifier and Type Class Description private class
HTTP2Connection.FillableCallback
protected class
HTTP2Connection.HTTP2Producer
private class
HTTP2Connection.NetworkBuffer
private class
HTTP2Connection.ParserListener
-
Field Summary
Fields Modifier and Type Field Description private int
bufferSize
private org.eclipse.jetty.io.ByteBufferPool
byteBufferPool
private java.util.concurrent.atomic.AtomicLong
bytesIn
protected static org.eclipse.jetty.util.log.Logger
LOG
private static boolean
PEC_MODE
private HTTP2Connection.HTTP2Producer
producer
private ISession
session
private org.eclipse.jetty.util.thread.ExecutionStrategy
strategy
private java.util.Queue<java.lang.Runnable>
tasks
-
Constructor Summary
Constructors Constructor Description HTTP2Connection(org.eclipse.jetty.io.ByteBufferPool byteBufferPool, java.util.concurrent.Executor executor, org.eclipse.jetty.io.EndPoint endPoint, ISession session, int bufferSize)
HTTP2Connection(org.eclipse.jetty.io.ByteBufferPool byteBufferPool, java.util.concurrent.Executor executor, org.eclipse.jetty.io.EndPoint endPoint, Parser parser, ISession session, int bufferSize)
Deprecated.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
protected void
dispatch()
private int
fill(org.eclipse.jetty.io.EndPoint endPoint, java.nio.ByteBuffer buffer)
long
getBytesIn()
long
getBytesOut()
long
getMessagesIn()
long
getMessagesOut()
protected Parser
getParser()
ISession
getSession()
private void
offerTask(java.lang.Runnable task)
protected void
offerTask(java.lang.Runnable task, boolean dispatch)
void
onClose()
void
onFillable()
void
onFlushed(long bytes)
boolean
onIdleExpired()
void
onOpen()
private java.lang.Runnable
pollTask()
protected void
produce()
protected void
setInputBuffer(java.nio.ByteBuffer buffer)
Parser.Listener
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 Detail
-
LOG
protected static final org.eclipse.jetty.util.log.Logger LOG
-
PEC_MODE
private static final boolean PEC_MODE
-
tasks
private final java.util.Queue<java.lang.Runnable> tasks
-
producer
private final HTTP2Connection.HTTP2Producer producer
-
bytesIn
private final java.util.concurrent.atomic.AtomicLong bytesIn
-
byteBufferPool
private final org.eclipse.jetty.io.ByteBufferPool byteBufferPool
-
session
private final ISession session
-
bufferSize
private final int bufferSize
-
strategy
private final org.eclipse.jetty.util.thread.ExecutionStrategy strategy
-
-
Constructor Detail
-
HTTP2Connection
@Deprecated public HTTP2Connection(org.eclipse.jetty.io.ByteBufferPool byteBufferPool, java.util.concurrent.Executor executor, org.eclipse.jetty.io.EndPoint endPoint, Parser parser, ISession session, int bufferSize)
Deprecated.
-
HTTP2Connection
public HTTP2Connection(org.eclipse.jetty.io.ByteBufferPool byteBufferPool, java.util.concurrent.Executor executor, org.eclipse.jetty.io.EndPoint endPoint, ISession session, int bufferSize)
-
-
Method Detail
-
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
public ISession getSession()
-
getParser
protected Parser getParser()
-
setInputBuffer
protected void setInputBuffer(java.nio.ByteBuffer buffer)
-
wrapParserListener
public Parser.Listener wrapParserListener(Parser.Listener listener)
-
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
private int fill(org.eclipse.jetty.io.EndPoint endPoint, java.nio.ByteBuffer buffer)
-
onIdleExpired
public boolean onIdleExpired()
- Specified by:
onIdleExpired
in interfaceorg.eclipse.jetty.io.Connection
- Overrides:
onIdleExpired
in classorg.eclipse.jetty.io.AbstractConnection
-
offerTask
protected void offerTask(java.lang.Runnable task, boolean dispatch)
-
produce
protected void produce()
-
dispatch
protected void dispatch()
-
close
public void close()
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Specified by:
close
in interfaceorg.eclipse.jetty.io.Connection
- Overrides:
close
in classorg.eclipse.jetty.io.AbstractConnection
-
offerTask
private void offerTask(java.lang.Runnable task)
-
pollTask
private java.lang.Runnable pollTask()
-
onFlushed
public void onFlushed(long bytes) throws java.io.IOException
- Specified by:
onFlushed
in interfaceorg.eclipse.jetty.io.WriteFlusher.Listener
- Throws:
java.io.IOException
-
-