[fix] retry may error.

tans.tan · tans.tan · commit 84f9497a15fa · 2023-05-01T19:30:16.000+08:00
diff --git a/net/src/main/java/com/tans/tfiletransporter/netty/extensions/DefaultServerManager.kt b/net/src/main/java/com/tans/tfiletransporter/netty/extensions/DefaultServerManager.kt
@@ -37,15 +37,16 @@ class DefaultServerManager(
     ) {
         val server = servers.find { it.couldHandle(msg.type) }
         if (server != null) {
+            val isNew = !handledMessageId.contains(msg.messageId)
+            handledMessageId[msg.messageId] = Unit
             server.dispatchRequest(
                 localAddress = localAddress,
                 remoteAddress = remoteAddress,
                 msg = msg,
                 converterFactory = converterFactory,
                 connectionTask = task,
-                isNewRequest = !handledMessageId.contains(msg.messageId)
+                isNewRequest = isNew
             )
-            handledMessageId[msg.messageId] = Unit
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -37,15 +37,16 @@ class DefaultServerManager(`
`37`	`37`	`) {`
`38`	`38`	`val server = servers.find { it.couldHandle(msg.type) }`
`39`	`39`	`if (server != null) {`
	`40`	`+ val isNew = !handledMessageId.contains(msg.messageId)`
	`41`	`+ handledMessageId[msg.messageId] = Unit`
`40`	`42`	`server.dispatchRequest(`
`41`	`43`	`localAddress = localAddress,`
`42`	`44`	`remoteAddress = remoteAddress,`
`43`	`45`	`msg = msg,`
`44`	`46`	`converterFactory = converterFactory,`
`45`	`47`	`connectionTask = task,`
`46`		`- isNewRequest = !handledMessageId.contains(msg.messageId)`
	`48`	`+ isNewRequest = isNew`
`47`	`49`	`)`
`48`		`- handledMessageId[msg.messageId] = Unit`
`49`	`50`	`}`
`50`	`51`	`}`
`51`	`52`