Package org.eclipse.jetty.http2
Class HTTP2Stream
java.lang.Object
org.eclipse.jetty.io.IdleTimeout
org.eclipse.jetty.http2.HTTP2Stream
- All Implemented Interfaces:
Closeable,AutoCloseable,Stream,IStream,org.eclipse.jetty.util.Attachable,org.eclipse.jetty.util.Callback,org.eclipse.jetty.util.component.Dumpable,org.eclipse.jetty.util.thread.Invocable
public class HTTP2Stream
extends org.eclipse.jetty.io.IdleTimeout
implements IStream, org.eclipse.jetty.util.Callback, org.eclipse.jetty.util.component.Dumpable
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.eclipse.jetty.util.Callback
org.eclipse.jetty.util.Callback.Completable, org.eclipse.jetty.util.Callback.Completing, org.eclipse.jetty.util.Callback.NestedNested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Dumpable
org.eclipse.jetty.util.component.Dumpable.DumpableContainerNested classes/interfaces inherited from interface org.eclipse.jetty.util.thread.Invocable
org.eclipse.jetty.util.thread.Invocable.InvocationTypeNested classes/interfaces inherited from interface org.eclipse.jetty.http2.IStream
IStream.FrameListNested classes/interfaces inherited from interface org.eclipse.jetty.http2.api.Stream
Stream.Listener -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final AtomicReference<Object> private final AtomicReference<ConcurrentMap<String, Object>> private final AtomicReference<CloseState> private booleanprivate longprivate Throwableprivate Stream.Listenerprivate final booleanprivate booleanprivate static final org.eclipse.jetty.util.log.Loggerprivate final AtomicIntegerprivate booleanprivate org.eclipse.jetty.util.Callbackprivate final AtomicIntegerprivate final ISessionprivate final intprivate final longFields inherited from interface org.eclipse.jetty.util.Callback
NOOPFields inherited from interface org.eclipse.jetty.util.component.Dumpable
KEYFields inherited from interface org.eclipse.jetty.util.thread.Invocable
__nonBlocking -
Constructor Summary
ConstructorsConstructorDescriptionHTTP2Stream(org.eclipse.jetty.util.thread.Scheduler scheduler, ISession session, int streamId, boolean local) -
Method Summary
Modifier and TypeMethodDescriptionprivate ConcurrentMap<String, Object> voidclose()Forcibly closes this stream.voidcommit()Marks this stream as committed.voidSends the given DATAframe.dump()voiddump(Appendable out, String indent) private org.eclipse.jetty.util.CallbackendWrite()voidgetAttribute(String key) intgetId()org.eclipse.jetty.util.thread.Invocable.InvocationTypeintintvoidheaders(HeadersFrame frame, org.eclipse.jetty.util.Callback callback) Sends the given HEADERSframe.booleanisClosed()booleanprivate booleanisFailed()booleanisLocal()booleanbooleanisOpen()booleanbooleanisReset()booleanprivate voidnotifyClosed(Stream stream) private voidnotifyData(Stream stream, DataFrame frame, org.eclipse.jetty.util.Callback callback) private voidnotifyFailure(Stream stream, FailureFrame frame, org.eclipse.jetty.util.Callback callback) private booleannotifyIdleTimeout(Stream stream, Throwable failure) private voidnotifyNewStream(Stream stream) private voidnotifyReset(Stream stream, ResetFrame frame, org.eclipse.jetty.util.Callback callback) voidonClose()private voidprivate voidonFailure(FailureFrame frame, org.eclipse.jetty.util.Callback callback) private voidonHeaders(HeadersFrame frame, org.eclipse.jetty.util.Callback callback) protected voidonIdleExpired(TimeoutException timeout) private voidonNewStream(org.eclipse.jetty.util.Callback callback) private voidonPush(PushPromiseFrame frame, org.eclipse.jetty.util.Callback callback) private voidonReset(ResetFrame frame, org.eclipse.jetty.util.Callback callback) private voidonWindowUpdate(WindowUpdateFrame frame, org.eclipse.jetty.util.Callback callback) voidProcesses the givenframe, belonging to this stream.voidpush(PushPromiseFrame frame, org.eclipse.jetty.util.Promise<Stream> promise, Stream.Listener listener) Sends the given PUSH_PROMISEframe.removeAttribute(String key) voidreset(ResetFrame frame, org.eclipse.jetty.util.Callback callback) Sends the given RST_STREAMframe.voidsend(IStream.FrameList frameList, org.eclipse.jetty.util.Callback callback) Sends the given list of frames.voidsetAttachment(Object attachment) voidsetAttribute(String key, Object value) voidsetListener(Stream.Listener listener) private booleanstartWrite(org.eclipse.jetty.util.Callback callback) voidtoString()booleanupdateClose(boolean update, CloseState.Event event) Updates the close state of this stream.private booleanprivate booleanprivate booleanintupdateRecvWindow(int delta) Updates the stream receive window by the givendelta.intupdateSendWindow(int delta) Updates the stream send window by the givendelta.private voidupdateStreamCount(int deltaStream, int deltaClosing) Methods inherited from class org.eclipse.jetty.io.IdleTimeout
checkIdleTimeout, getIdleFor, getIdleTimeout, getScheduler, notIdle, onOpen, setIdleTimeoutMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.eclipse.jetty.util.component.Dumpable
dumpSelfMethods inherited from interface org.eclipse.jetty.http2.api.Stream
getIdleTimeout, setIdleTimeout
-
Field Details
-
LOG
private static final org.eclipse.jetty.util.log.Logger LOG -
attachment
-
attributes
-
closeState
-
sendWindow
-
recvWindow
-
timeStamp
private final long timeStamp -
session
-
streamId
private final int streamId -
local
private final boolean local -
sendCallback
private org.eclipse.jetty.util.Callback sendCallback -
failure
-
localReset
private boolean localReset -
remoteReset
private boolean remoteReset -
listener
-
dataLength
private long dataLength -
committed
private boolean committed
-
-
Constructor Details
-
HTTP2Stream
public HTTP2Stream(org.eclipse.jetty.util.thread.Scheduler scheduler, ISession session, int streamId, boolean local)
-
-
Method Details
-
getId
public int getId() -
getAttachment
- Specified by:
getAttachmentin interfaceorg.eclipse.jetty.util.Attachable
-
setAttachment
- Specified by:
setAttachmentin interfaceorg.eclipse.jetty.util.Attachable
-
isLocal
public boolean isLocal() -
getSession
- Specified by:
getSessionin interfaceIStream- Specified by:
getSessionin interfaceStream- Returns:
- the session this stream is associated to
-
send
Description copied from interface:IStreamSends the given list of frames.
Typically used to send HTTP headers along with content and possibly trailers.
-
headers
Description copied from interface:StreamSends the given HEADERS
frame.Typically used to send an HTTP response or to send the HTTP response trailers.
-
push
public void push(PushPromiseFrame frame, org.eclipse.jetty.util.Promise<Stream> promise, Stream.Listener listener) Description copied from interface:StreamSends the given PUSH_PROMISE
frame. -
data
Description copied from interface:StreamSends the given DATA
frame. -
reset
Description copied from interface:StreamSends the given RST_STREAM
frame. -
startWrite
private boolean startWrite(org.eclipse.jetty.util.Callback callback) -
getAttribute
- Specified by:
getAttributein interfaceStream- Parameters:
key- the attribute key- Returns:
- an arbitrary object associated with the given key to this stream or null if no object can be found for the given key.
- See Also:
-
setAttribute
- Specified by:
setAttributein interfaceStream- Parameters:
key- the attribute keyvalue- an arbitrary object to associate with the given key to this stream- See Also:
-
removeAttribute
- Specified by:
removeAttributein interfaceStream- Parameters:
key- the attribute key- Returns:
- the arbitrary object associated with the given key to this stream
- See Also:
-
isReset
public boolean isReset() -
isFailed
private boolean isFailed() -
isResetOrFailed
public boolean isResetOrFailed()- Specified by:
isResetOrFailedin interfaceIStream- Returns:
- whether this stream has been reset (locally or remotely) or has been failed
- See Also:
-
isClosed
public boolean isClosed() -
isRemotelyClosed
public boolean isRemotelyClosed()- Specified by:
isRemotelyClosedin interfaceIStream- Returns:
- whether the stream is closed remotely.
- See Also:
-
isLocallyClosed
public boolean isLocallyClosed() -
commit
public void commit()Description copied from interface:IStreamMarks this stream as committed. -
isCommitted
public boolean isCommitted()- Specified by:
isCommittedin interfaceIStream- Returns:
- whether bytes for this stream have been sent to the remote peer.
- See Also:
-
isOpen
public boolean isOpen()- Specified by:
isOpenin classorg.eclipse.jetty.io.IdleTimeout
-
onIdleExpired
- Specified by:
onIdleExpiredin classorg.eclipse.jetty.io.IdleTimeout
-
attributes
-
getListener
- Specified by:
getListenerin interfaceIStream- Returns:
- the
Stream.Listenerassociated with this stream - See Also:
-
setListener
- Specified by:
setListenerin interfaceIStream- Parameters:
listener- theStream.Listenerassociated with this stream- See Also:
-
process
Description copied from interface:IStreamProcesses the given
frame, belonging to this stream. -
onNewStream
private void onNewStream(org.eclipse.jetty.util.Callback callback) -
onHeaders
-
onData
-
onReset
-
onPush
-
onWindowUpdate
-
onFailure
-
updateClose
Description copied from interface:IStreamUpdates the close state of this stream.
- Specified by:
updateClosein interfaceIStream- Parameters:
update- whether to update the close stateevent- the event that caused the close state update- Returns:
- whether the stream has been fully closed by this invocation
-
updateCloseAfterReceived
private boolean updateCloseAfterReceived() -
updateCloseBeforeSend
private boolean updateCloseBeforeSend() -
updateCloseAfterSend
private boolean updateCloseAfterSend() -
getSendWindow
public int getSendWindow() -
getRecvWindow
public int getRecvWindow() -
updateSendWindow
public int updateSendWindow(int delta) Description copied from interface:IStreamUpdates the stream send window by the given
delta.- Specified by:
updateSendWindowin interfaceIStream- Parameters:
delta- the delta value (positive or negative) to add to the stream send window- Returns:
- the previous value of the stream send window
-
updateRecvWindow
public int updateRecvWindow(int delta) Description copied from interface:IStreamUpdates the stream receive window by the given
delta.- Specified by:
updateRecvWindowin interfaceIStream- Parameters:
delta- the delta value (positive or negative) to add to the stream receive window- Returns:
- the previous value of the stream receive window
-
close
public void close()Description copied from interface:IStreamForcibly closes this stream.
-
onClose
public void onClose()- Overrides:
onClosein classorg.eclipse.jetty.io.IdleTimeout
-
updateStreamCount
private void updateStreamCount(int deltaStream, int deltaClosing) -
succeeded
public void succeeded()- Specified by:
succeededin interfaceorg.eclipse.jetty.util.Callback
-
failed
- Specified by:
failedin interfaceorg.eclipse.jetty.util.Callback
-
getInvocationType
public org.eclipse.jetty.util.thread.Invocable.InvocationType getInvocationType()- Specified by:
getInvocationTypein interfaceorg.eclipse.jetty.util.thread.Invocable
-
endWrite
private org.eclipse.jetty.util.Callback endWrite() -
notifyNewStream
-
notifyData
-
notifyReset
-
notifyIdleTimeout
-
notifyFailure
private void notifyFailure(Stream stream, FailureFrame frame, org.eclipse.jetty.util.Callback callback) -
notifyClosed
-
dump
- Specified by:
dumpin interfaceorg.eclipse.jetty.util.component.Dumpable
-
dump
- Specified by:
dumpin interfaceorg.eclipse.jetty.util.component.Dumpable- Throws:
IOException
-
toString
-