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, ParserListener, Container, Destroyable, Dumpable, Dumpable.DumpableContainer, LifeCycle
Direct Known Subclasses:
HTTP3SessionClient
public abstract class HTTP3Session extends ContainerLifeCycle implements Session, ParserListener

  • Constructor Details

  • Method Details

    • getProtocolSession

      public ProtocolSession getProtocolSession()

    • getListener

      public Session.Listener getListener()

    • 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 int getMaxLocalStreams()

    • goAway

      public CompletableFuture<Void> goAway(boolean graceful)
      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
      Returns:
      the CompletableFuture that gets notified when the frame has been sent

    • newGoAwayFrame

      protected GoAwayFrame newGoAwayFrame(boolean graceful)

    • shutdown

      public CompletableFuture<Void> shutdown()

    • getIdleTimeout

      public long getIdleTimeout()

    • getStreamIdleTimeout

      public long getStreamIdleTimeout()

    • setStreamIdleTimeout

      public void setStreamIdleTimeout(long streamIdleTimeout)

    • createStream

      protected HTTP3Stream createStream(QuicStreamEndPoint endPoint, Consumer<Throwable> fail)

    • getOrCreateStream

      protected HTTP3Stream getOrCreateStream(QuicStreamEndPoint endPoint)

    • newHTTP3Stream

      protected abstract HTTP3Stream newHTTP3Stream(QuicStreamEndPoint endPoint, boolean local)

    • getStream

      protected HTTP3Stream getStream(long streamId)

    • removeStream

      public void removeStream(HTTP3Stream stream, Throwable failure)

    • writeControlFrame

      public abstract void writeControlFrame(Frame frame, Callback callback)

    • writeMessageFrame

      public abstract void writeMessageFrame(long streamId, Frame frame, Callback callback)

    • onPreface

      public Map<Long,Long> onPreface()

    • onSettings

      public void onSettings(SettingsFrame frame)
      Specified by:
      onSettings in interface ParserListener

    • onHeaders

      public void onHeaders(long streamId, HeadersFrame frame, boolean wasBlocked)
      Specified by:
      onHeaders in interface ParserListener

    • onData

      public void onData(long streamId, DataFrame frame)
      Specified by:
      onData in interface ParserListener

    • onGoAway

      public void onGoAway(GoAwayFrame frame)
      Specified by:
      onGoAway in interface ParserListener

    • onIdleTimeout

      public boolean onIdleTimeout()

    • inwardClose

      public void inwardClose(long error, String reason)

      Called when a 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
      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 inwardClose(long, String).

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

    • onStreamFailure

      public void onStreamFailure(long streamId, long error, Throwable failure)
      Specified by:
      onStreamFailure in interface ParserListener

    • onSessionFailure

      public void onSessionFailure(long error, String reason, Throwable failure)
      Specified by:
      onSessionFailure in interface ParserListener

    • 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