replace InetSocketAddress decoding/encoding with side-stack argument passing
Signed-off-by: Ludovic Orban <lorban@bitronix.be>
This commit is contained in:
parent
ee900b1a8d
commit
6267089b4f
|
@ -188,10 +188,9 @@ public class QuicConnection extends AbstractConnection
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public void write(Callback callback, ByteBuffer... buffers)
|
public void write(Callback callback, InetSocketAddress remoteAddress, ByteBuffer... buffers)
|
||||||
{
|
{
|
||||||
InetSocketAddress address = ServerDatagramEndPoint.INET_ADDRESS_ARGUMENT.pop();
|
flusher.offer(callback, remoteAddress, buffers);
|
||||||
flusher.offer(callback, address, buffers);
|
|
||||||
flusher.iterate();
|
flusher.iterate();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -302,8 +302,7 @@ public class QuicSession
|
||||||
return Action.IDLE;
|
return Action.IDLE;
|
||||||
}
|
}
|
||||||
BufferUtil.flipToFlush(cipherBuffer, pos);
|
BufferUtil.flipToFlush(cipherBuffer, pos);
|
||||||
ServerDatagramEndPoint.INET_ADDRESS_ARGUMENT.push(remoteAddress);
|
connection.write(this, remoteAddress, cipherBuffer);
|
||||||
connection.write(this, cipherBuffer);
|
|
||||||
return Action.SCHEDULED;
|
return Action.SCHEDULED;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue