Eclipse
/
jetty.project
mirror of https://github.com/jetty/jetty.project.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

remove unneeded parameter 

Signed-off-by: Ludovic Orban <lorban@bitronix.be>
This commit is contained in:
Ludovic Orban 2021-03-23 14:35:20 +01:00 committed by Simone Bordet
parent a2cb2a69e6
commit 2e5ff2ddc3
6 changed files with 8 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
jetty-http3/http3-client/src/main/java/org/eclipse/jetty/http3/client/ClientQuicConnection.java
View File

@ -54,7 +54,7 @@ public class ClientQuicConnection extends QuicConnection
{ {
InetSocketAddress remoteAddress = (InetSocketAddress)context.get(ClientDatagramConnector.REMOTE_SOCKET_ADDRESS_CONTEXT_KEY); InetSocketAddress remoteAddress = (InetSocketAddress)context.get(ClientDatagramConnector.REMOTE_SOCKET_ADDRESS_CONTEXT_KEY);
QuicheConnection quicheConnection = QuicheConnection.connect(getQuicheConfig(), remoteAddress); QuicheConnection quicheConnection = QuicheConnection.connect(getQuicheConfig(), remoteAddress);
QuicSession session = new ClientQuicSession(getExecutor(), getScheduler(), getByteBufferPool(), null, quicheConnection, this, remoteAddress, context); QuicSession session = new ClientQuicSession(getExecutor(), getScheduler(), getByteBufferPool(), quicheConnection, this, remoteAddress, context);
pendingSessions.put(remoteAddress, session); pendingSessions.put(remoteAddress, session);
session.flush(); // send the response packet(s) that connect generated. session.flush(); // send the response packet(s) that connect generated.
if (LOG.isDebugEnabled()) if (LOG.isDebugEnabled())

4
jetty-http3/http3-client/src/main/java/org/eclipse/jetty/http3/client/ClientQuicSession.java
View File

@ -33,9 +33,9 @@ public class ClientQuicSession extends QuicSession
{ {
private final Map<String, Object> context; private final Map<String, Object> context;
protected ClientQuicSession(Executor executor, Scheduler scheduler, ByteBufferPool byteBufferPool, QuicheConnectionId quicheConnectionId, QuicheConnection quicheConnection, QuicConnection connection, InetSocketAddress remoteAddress, Map<String, Object> context) protected ClientQuicSession(Executor executor, Scheduler scheduler, ByteBufferPool byteBufferPool, QuicheConnection quicheConnection, QuicConnection connection, InetSocketAddress remoteAddress, Map<String, Object> context)
{ {
super(executor, scheduler, byteBufferPool, quicheConnectionId, quicheConnection, connection, remoteAddress); super(executor, scheduler, byteBufferPool, quicheConnection, connection, remoteAddress);
this.context = context; this.context = context;
} }

2
jetty-http3/http3-client/src/test/java/org/eclipse/jetty/http3/client/End2EndClientTest.java
View File

@ -77,7 +77,7 @@ public class End2EndClientTest
} }
@Test @Test
public void name() throws Exception public void simple() throws Exception
{ {
HttpClientTransportOverQuic transport = new HttpClientTransportOverQuic(); HttpClientTransportOverQuic transport = new HttpClientTransportOverQuic();
HttpClient client = new HttpClient(transport); HttpClient client = new HttpClient(transport);

3
jetty-http3/http3-common/src/main/java/org/eclipse/jetty/http3/common/QuicSession.java
View File

@ -56,11 +56,10 @@ public abstract class QuicSession
private InetSocketAddress remoteAddress; private InetSocketAddress remoteAddress;
private QuicheConnectionId quicheConnectionId; private QuicheConnectionId quicheConnectionId;
protected QuicSession(Executor executor, Scheduler scheduler, ByteBufferPool byteBufferPool, QuicheConnectionId quicheConnectionId, QuicheConnection quicheConnection, QuicConnection connection, InetSocketAddress remoteAddress) protected QuicSession(Executor executor, Scheduler scheduler, ByteBufferPool byteBufferPool, QuicheConnection quicheConnection, QuicConnection connection, InetSocketAddress remoteAddress)
{ {
this.scheduler = scheduler; this.scheduler = scheduler;
this.byteBufferPool = byteBufferPool; this.byteBufferPool = byteBufferPool;
this.quicheConnectionId = quicheConnectionId;
this.quicheConnection = quicheConnection; this.quicheConnection = quicheConnection;
this.connection = connection; this.connection = connection;
this.remoteAddress = remoteAddress; this.remoteAddress = remoteAddress;

2
jetty-http3/http3-server/src/main/java/org/eclipse/jetty/http3/server/ServerQuicConnection.java
View File

@ -79,7 +79,7 @@ public class ServerQuicConnection extends QuicConnection
} }
else else
{ {
QuicSession session = new ServerQuicSession(getExecutor(), getScheduler(), byteBufferPool, null, quicheConnection, this, remoteAddress, connector); QuicSession session = new ServerQuicSession(getExecutor(), getScheduler(), byteBufferPool, quicheConnection, this, remoteAddress, connector);
session.flush(); // send the response packet(s) that tryAccept generated. session.flush(); // send the response packet(s) that tryAccept generated.
return session; return session;
} }

4
jetty-http3/http3-server/src/main/java/org/eclipse/jetty/http3/server/ServerQuicSession.java
View File

@ -32,9 +32,9 @@ public class ServerQuicSession extends QuicSession
{ {
private final Connector connector; private final Connector connector;
protected ServerQuicSession(Executor executor, Scheduler scheduler, ByteBufferPool byteBufferPool, QuicheConnectionId quicheConnectionId, QuicheConnection quicheConnection, QuicConnection connection, InetSocketAddress remoteAddress, Connector connector) protected ServerQuicSession(Executor executor, Scheduler scheduler, ByteBufferPool byteBufferPool, QuicheConnection quicheConnection, QuicConnection connection, InetSocketAddress remoteAddress, Connector connector)
{ {
super(executor, scheduler, byteBufferPool, quicheConnectionId, quicheConnection, connection, remoteAddress); super(executor, scheduler, byteBufferPool, quicheConnection, connection, remoteAddress);
this.connector = connector; this.connector = connector;
} }