github-repos/mirai
1
0
Fork 0
mirror of https://github.com/mamoe/mirai.git synced 2025-02-11 09:58:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

Rearrange functions in NettyNetworkHandler

Browse Source
This commit is contained in:
Him188 2021-06-23 15:09:01 +08:00
parent 76e57d4aae
commit 8d4eb45386
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
mirai-core/src/commonMain/kotlin/network/impl/netty/NettyNetworkHandler.kt
View File

@ -36,13 +36,6 @@ internal open class NettyNetworkHandler(
context: NetworkHandlerContext,
private val address: SocketAddress,
) : NetworkHandlerSupport(context) {
override fun close(cause: Throwable?) {
if (state == State.CLOSED) return // already
super.close(cause) // see the `init` block at line 213, just above [NettyState]
}
private fun closeSuper(cause: Throwable?) = super.close(cause)
final override tailrec suspend fun sendPacketImpl(packet: OutgoingPacket) {
val state = _state as NettyState
if (state.sendPacketImpl(packet)) return
@ -201,6 +194,13 @@ internal open class NettyNetworkHandler(
// states
///////////////////////////////////////////////////////////////////////////
override fun close(cause: Throwable?) {
if (state == State.CLOSED) return // already
super.close(cause)
// when coroutine scope completed, state is already set to CLOSED,
// see the following `init` block.
}
init {
coroutineContext.job.invokeOnCompletion { e ->
setState { StateClosed(e?.unwrapCancellationException()) }
@ -384,7 +384,7 @@ internal open class NettyNetworkHandler(
val exception: Throwable?
) : NettyState(State.CLOSED) {
init {
closeSuper(exception)
close(exception)
}
override fun getCause(): Throwable? = exception