dorkbox
/
Network
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

fixed up comments

master
Robinson 2023-11-28 20:52:58 +01:00
parent 41b3acf147
commit 5c4d64f3f1
No known key found for this signature in database
GPG Key ID: 8E7DB78588BD6F5C
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/dorkbox/network/connection/ListenerManager.kt
View File

@ -413,14 +413,14 @@ internal class ListenerManager<CONNECTION: Connection>(private val logger: Logge
*
* This is run directly on the thread that calls it!
*
* @return true if the connection will have pending messages enabled. False if pending messages for this connection should be disabled.
* @return true if the connection will have buffered messages enabled. False if buffered messages for this connection should be disabled.
*/
fun notifyEnableBufferedMessages(clientAddress: InetAddress?, clientTagName: String): Boolean {
// by default, there is a SINGLE rule that will always exist, and will always PERMIT pending messages.
// by default, there is a SINGLE rule that will always exist, and will always PERMIT buffered messages.
// This is so the array types can be setup (the compiler needs SOMETHING there)
val list = onConnectBufferedMessageFilterList
// if there is a rule, a connection must match for it to enable pending messages
// if there is a rule, a connection must match for it to enable buffered messages
list.forEach {
if (it.invoke(clientAddress, clientTagName)) {
return true
@ -428,8 +428,8 @@ internal class ListenerManager<CONNECTION: Connection>(private val logger: Logge
}
// default if nothing matches
// NO RULES ADDED -> ALLOW Pending Messages
// RULES ADDED -> DISABLE Pending Messages
// NO RULES ADDED -> ALLOW Buffered Messages
// RULES ADDED -> DISABLE Buffered Messages
return list.isEmpty()
}