AstralTransRocketries/minosoft
1
0
Fork 0
mirror of https://gitlab.bixilon.de/bixilon/minosoft.git synced 2025-09-19 12:25:12 -04:00
Code Issues Packages Projects Releases Wiki Activity

netty: pause packet sending/receiving

Browse Source
This commit is contained in:
Bixilon 2022-01-10 08:56:57 +01:00
parent 8b07835d08
commit 9254b4d195
No known key found for this signature in database
GPG Key ID: 5CAD791931B09AC4
1 changed files with 31 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
src/main/java/de/bixilon/minosoft/protocol/network/network/client/NettyClient.kt
View File

@ -14,6 +14,7 @@
package de.bixilon.minosoft.protocol.network.network.client
import de.bixilon.kutil.cast.CastUtil.nullCast
import de.bixilon.kutil.concurrent.pool.DefaultThreadPool
import de.bixilon.kutil.watcher.DataWatcher.Companion.watched
import de.bixilon.minosoft.config.profile.profiles.other.OtherProfileManager
import de.bixilon.minosoft.gui.eros.dialog.ErosErrorReport.Companion.report
@ -84,6 +85,8 @@ class NettyClient(
var encrypted: Boolean = false
private set
private var channel: Channel? = null
private val packetQueue: MutableList<C2SPacket> = mutableListOf() // Used for pause sending
private var sendingPaused = false
fun connect(address: ServerAddress, epoll: Boolean) {
state = ProtocolStates.HANDSHAKING
@ -105,10 +108,10 @@ class NettyClient(
}
fun setupEncryption(encrypt: Cipher, decrypt: Cipher) {
val channel = requireChannel()
if (encrypted) {
throw IllegalStateException("Already encrypted!")
}
val channel = channel ?: throw IllegalStateException("No channel!")
channel.pipeline().addBefore(LengthEncoder.NAME, PacketEncryptor.NAME, PacketEncryptor(encrypt))
channel.pipeline().addBefore(LengthDecoder.NAME, PacketDecryptor.NAME, PacketDecryptor(decrypt))
encrypted = true
@ -122,16 +125,27 @@ class NettyClient(
connected = false
}
fun pauseSending(pause: Boolean) {}
fun pauseReceiving(pause: Boolean) {}
fun pauseSending(pause: Boolean) {
this.sendingPaused = pause
if (!sendingPaused) {
DefaultThreadPool += {
for (packet in packetQueue) {
send(packet)
}
}
}
}
fun pauseReceiving(pause: Boolean) {
val channel = requireChannel()
channel.config()?.isAutoRead = !pause
}
fun send(packet: C2SPacket) {
if (!connected) {
throw IllegalStateException("Can not send packet when not connected!")
}
val channel = this.channel
if (channel == null || !channel.isActive) {
throw IllegalStateException("Channel not null or not active!")
val channel = requireChannel()
if (sendingPaused) {
packetQueue += packet
return
}
packet.log((connection.nullCast<PlayConnection>()?.profiles?.other ?: OtherProfileManager.selected).log.reducedProtocolLog)
@ -172,6 +186,14 @@ class NettyClient(
}
}
fun requireChannel(): Channel {
val channel = this.channel
if (!connected || channel == null) {
throw IllegalStateException("Not connected!")
}
return channel
}
companion object {
private val NIO_THREAD_POOL by lazy { NioEventLoopGroup(NamedThreadFactory("Nio#%d")) }
private val EPOLL_THREAD_POOL by lazy { EpollEventLoopGroup(NamedThreadFactory("Epoll#%d")) }