Class HTTP3Session

java.lang.Object
org.eclipse.jetty.util.component.AbstractLifeCycle
org.eclipse.jetty.util.component.ContainerLifeCycle
org.eclipse.jetty.http3.HTTP3Session
All Implemented Interfaces:
Session, Container, Destroyable, Dumpable, Dumpable.DumpableContainer, LifeCycle
Direct Known Subclasses:
HTTP3SessionClient
public abstract class HTTP3Session extends ContainerLifeCycle implements Session

  • Constructor Details

  • Method Details

    • getProtocolSession

      public ProtocolSession getProtocolSession()

    • getListener

      public Session.Listener getListener()

    • getParserListener

      public ParserListener getParserListener()

    • onOpen

      public void onOpen()

    • getLocalSocketAddress

      public SocketAddress getLocalSocketAddress()
      Description copied from interface: Session
      Get the local socket address this session is bound to.
      Specified by:
      getLocalSocketAddress in interface Session
      Returns:
      the local socket address this session is bound to

    • getRemoteSocketAddress

      public SocketAddress getRemoteSocketAddress()
      Description copied from interface: Session
      Get the remote socket address this session is connected to.
      Specified by:
      getRemoteSocketAddress in interface Session
      Returns:
      the remote socket address this session is connected to

    • getStreams

      public Collection<Stream> getStreams()
      Specified by:
      getStreams in interface Session
      Returns:
      a snapshot of all the streams currently belonging to this session

    • getMaxLocalStreams

      public long getMaxLocalStreams()

    • goAway

      public void goAway(boolean graceful, Promise.Invocable<Session> promise)
      Description copied from interface: Session

      Initiates the shutdown of this session by sending a GOAWAY frame to the other peer.

      Specified by:
      goAway in interface Session
      Parameters:
      graceful - whether the shutdown should be graceful
      promise - the Promise.Invocable that gets notified when the frame has been sent

    • newGoAwayFrame

      protected GoAwayFrame newGoAwayFrame(boolean graceful)

    • shutdown

      public CompletableFuture<Session> shutdown()

    • getIdleTimeout

      public long getIdleTimeout()

    • getStreamIdleTimeout

      public long getStreamIdleTimeout()

    • setStreamIdleTimeout

      public void setStreamIdleTimeout(long streamIdleTimeout)

    • createStream

      protected HTTP3Stream createStream(StreamEndPoint endPoint)

    • newHTTP3Stream

      protected abstract HTTP3Stream newHTTP3Stream(StreamEndPoint endPoint, boolean local)

    • getStream

      protected HTTP3Stream getStream(long streamId)

    • writeControlFrame

      public abstract void writeControlFrame(Frame frame, Callback callback)

    • writeMessageFrame

      public abstract void writeMessageFrame(StreamEndPoint streamEndPoint, Frame frame, Callback callback)

    • onPreface

      public Map<Long,Long> onPreface()

    • onHeaders

      protected void onHeaders(long streamId, HeadersFrame frame, boolean wasBlocked)

    • onData

      protected void onData(long streamId, DataFrame frame)

    • onSettings

      protected void onSettings(SettingsFrame frame)

    • onGoAway

      protected void onGoAway(GoAwayFrame frame)

    • onStreamFailure

      public void onStreamFailure(long streamId, long error, Throwable failure)

    • onSessionFailure

      public void onSessionFailure(long error, String reason, Throwable failure)

    • onIdleTimeout

      public boolean onIdleTimeout(TimeoutException timeout)

    • close

      public void close(long error, String reason, Promise.Invocable<Session> promise)

      Called when an external event wants to initiate the close of this session locally, for example a close at the network level (due to e.g. stopping a component) or a timeout.

      The correspondent passive event, where it's the remote peer that initiates the close, is delivered via onClose(long, String).

      Parameters:
      error - the close error
      reason - the close reason
      promise - the Promise.Invocable that gets notified when the close is complete
      See Also:

    • onClose

      public void onClose(long error, String reason)

      Called when the local peer receives a close initiated by the remote peer.

      The correspondent active event, where it's the local peer that initiates the close, it's delivered via close(long, String, Promise.Invocable).

      Parameters:
      error - the close error
      reason - the close reason

    • isClosed

      public boolean isClosed()

    • dump

      public void dump(Appendable out, String indent) throws IOException
      Description copied from interface: Dumpable
      Dump this object (and children) into an Appendable using the provided indent after any new lines. The indent should not be applied to the first object dumped.
      Specified by:
      dump in interface Dumpable
      Overrides:
      dump in class ContainerLifeCycle
      Parameters:
      out - The appendable to dump to
      indent - The indent to apply after any new lines.
      Throws:
      IOException - if unable to write to Appendable

    • toString

      public String toString()
      Overrides:
      toString in class AbstractLifeCycle