tursom/TursomServer
0
0
Fork 0
mirror of https://github.com/tursom/TursomServer.git synced 2025-02-08 02:30:36 +08:00
Code Issues Packages Projects Releases Wiki Activity

已经超时的套接字不应该有任何操作

Browse Source
This commit is contained in:
tursom 2019-10-16 22:51:05 +08:00
parent acfe8fda0a
commit 2dd2e8c5fb
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
socket/socket-async/src/main/kotlin/cn/tursom/socket/AsyncNioSocket.kt
View File

@ -86,6 +86,7 @@ class AsyncNioSocket(override val key: SelectionKey, override val nioThread: INi
buffer,
it,
timer.exec(timeout) {
key.attach(null)
try {
it.resumeWithException(TimeoutException())
} catch (e: Exception) {
@ -112,6 +113,7 @@ class AsyncNioSocket(override val key: SelectionKey, override val nioThread: INi
buffer,
it,
timer.exec(timeout) {
key.attach(null)
try {
it.resumeWithException(TimeoutException())
} catch (e: Exception) {
@ -138,6 +140,7 @@ class AsyncNioSocket(override val key: SelectionKey, override val nioThread: INi
buffer,
it,
timer.exec(timeout) {
key.attach(null)
try {
it.resumeWithException(TimeoutException())
} catch (e: Exception) {
@ -164,6 +167,7 @@ class AsyncNioSocket(override val key: SelectionKey, override val nioThread: INi
buffer,
it,
timer.exec(timeout) {
key.attach(null)
try {
it.resumeWithException(TimeoutException())
} catch (e: Exception) {
@ -210,7 +214,7 @@ class AsyncNioSocket(override val key: SelectionKey, override val nioThread: INi
override fun handleRead(key: SelectionKey, nioThread: INioThread) {
key.interestOps(0)
val context = key.attachment() as Context
val context = key.attachment() as Context? ?: return
context.timeoutTask?.cancel()
if (context is SingleContext) {
val channel = key.channel() as SocketChannel
@ -226,7 +230,7 @@ class AsyncNioSocket(override val key: SelectionKey, override val nioThread: INi
override fun handleWrite(key: SelectionKey, nioThread: INioThread) {
key.interestOps(0)
val context = key.attachment() as Context
val context = key.attachment() as Context? ?: return
context.timeoutTask?.cancel()
if (context is SingleContext) {
val channel = key.channel() as SocketChannel