diff --git a/codec-classes-quic/src/main/java/io/netty/incubator/codec/quic/QuicheQuicChannel.java b/codec-classes-quic/src/main/java/io/netty/incubator/codec/quic/QuicheQuicChannel.java index ec8d88880..3527dc689 100644 --- a/codec-classes-quic/src/main/java/io/netty/incubator/codec/quic/QuicheQuicChannel.java +++ b/codec-classes-quic/src/main/java/io/netty/incubator/codec/quic/QuicheQuicChannel.java @@ -860,8 +860,8 @@ StreamRecvResult streamRecv(long streamId, ByteBuf buffer) throws Exception { /** * Receive some data on a QUIC connection. */ - void recv(InetSocketAddress recipient, InetSocketAddress sender, ByteBuf buffer) { - ((QuicChannelUnsafe) unsafe()).connectionRecv(recipient, sender, buffer); + void recv(InetSocketAddress sender, InetSocketAddress recipient, ByteBuf buffer) { + ((QuicChannelUnsafe) unsafe()).connectionRecv(sender, recipient, buffer); } void writable() { @@ -1373,7 +1373,7 @@ private void fireConnectCloseEventIfNeeded(long connAddr) { } } - void connectionRecv(InetSocketAddress recipient, InetSocketAddress sender, ByteBuf buffer) { + void connectionRecv(InetSocketAddress sender, InetSocketAddress recipient, ByteBuf buffer) { if (isConnDestroyed()) { return; } diff --git a/codec-classes-quic/src/main/java/io/netty/incubator/codec/quic/QuicheQuicCodec.java b/codec-classes-quic/src/main/java/io/netty/incubator/codec/quic/QuicheQuicCodec.java index 38f2699ca..9db50164e 100644 --- a/codec-classes-quic/src/main/java/io/netty/incubator/codec/quic/QuicheQuicCodec.java +++ b/codec-classes-quic/src/main/java/io/netty/incubator/codec/quic/QuicheQuicCodec.java @@ -266,12 +266,12 @@ public void process(InetSocketAddress sender, InetSocketAddress recipient, ByteB type, version, scid, dcid, token); if (channel != null) { - // Add to queue first, we might be able to safe some flushes and consolidate them + // Add to queue first, we might be able to save some flushes and consolidate them // in channelReadComplete(...) this way. if (channel.markInFireChannelReadCompleteQueue()) { needsFireChannelReadComplete.add(channel); } - channel.recv(recipient, sender, buffer); + channel.recv(sender, recipient, buffer); } } }