diff --git a/jetty-http3/http3-server/src/main/java/org/eclipse/jetty/http3/server/QuicConnection.java b/jetty-http3/http3-server/src/main/java/org/eclipse/jetty/http3/server/QuicConnection.java index 7c1b16fe3ca..1c9b8d11989 100644 --- a/jetty-http3/http3-server/src/main/java/org/eclipse/jetty/http3/server/QuicConnection.java +++ b/jetty-http3/http3-server/src/main/java/org/eclipse/jetty/http3/server/QuicConnection.java @@ -143,13 +143,14 @@ public class QuicConnection extends AbstractConnection { session = new QuicSession(connector, quicheConnection, this, remoteAddress); sessions.putIfAbsent(quicheConnectionId, session); + session.flush(); if (LOG.isDebugEnabled()) LOG.debug("created QUIC session {}", session); } + continue; } - if (session != null) - session.process(remoteAddress, cipherBuffer); + session.process(remoteAddress, cipherBuffer); } } catch (Throwable x) diff --git a/jetty-http3/http3-server/src/main/java/org/eclipse/jetty/http3/server/ServerDatagramEndPoint.java b/jetty-http3/http3-server/src/main/java/org/eclipse/jetty/http3/server/ServerDatagramEndPoint.java index aea2cc198b1..0e35a3c6e3c 100644 --- a/jetty-http3/http3-server/src/main/java/org/eclipse/jetty/http3/server/ServerDatagramEndPoint.java +++ b/jetty-http3/http3-server/src/main/java/org/eclipse/jetty/http3/server/ServerDatagramEndPoint.java @@ -200,7 +200,7 @@ public class ServerDatagramEndPoint extends IdleTimeout implements EndPoint, Man public Runnable onSelected() { // TODO: need to handle both read and write events. - selectionKey.interestOps(~SelectionKey.OP_READ); + //selectionKey.interestOps(~SelectionKey.OP_READ); return () ->