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

Code cleanup

Browse Source
This commit is contained in:
Robinson 2022-03-24 01:27:01 +01:00
parent b597bcd497
commit b0a29d6837
No known key found for this signature in database
GPG Key ID: 8E7DB78588BD6F5C
5 changed files with 7 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/dorkbox/network/connection/ConnectionManager.kt
View File

@ -15,9 +15,9 @@
*/ */
package dorkbox.network.connection package dorkbox.network.connection
import dorkbox.util.collections.ConcurrentEntry import dorkbox.collections.ConcurrentEntry
import dorkbox.util.collections.ConcurrentIterator import dorkbox.collections.ConcurrentIterator
import dorkbox.util.collections.ConcurrentIterator.headREF import dorkbox.collections.ConcurrentIterator.headREF
// .equals() compares the identity on purpose,this because we cannot create two separate objects that are somehow equal to each other. // .equals() compares the identity on purpose,this because we cannot create two separate objects that are somehow equal to each other.
@Suppress("UNCHECKED_CAST") @Suppress("UNCHECKED_CAST")
@ -38,7 +38,6 @@ internal open class ConnectionManager<CONNECTION: Connection>() {
/** /**
* Removes a custom connection to the server. * Removes a custom connection to the server.
* *
*
* This should only be used in situations where there can be DIFFERENT types of connections (such as a 'web-based' connection) and * This should only be used in situations where there can be DIFFERENT types of connections (such as a 'web-based' connection) and
* you want *this* server instance to manage listeners + message dispatch * you want *this* server instance to manage listeners + message dispatch
* *

1
src/dorkbox/network/connection/CryptoManagement.kt
View File

@ -23,7 +23,6 @@ import dorkbox.network.serialization.AeronInput
import dorkbox.network.serialization.AeronOutput import dorkbox.network.serialization.AeronOutput
import dorkbox.network.serialization.SettingsStore import dorkbox.network.serialization.SettingsStore
import dorkbox.util.entropy.Entropy import dorkbox.util.entropy.Entropy
import dorkbox.util.exceptions.SecurityException
import mu.KLogger import mu.KLogger
import java.math.BigInteger import java.math.BigInteger
import java.net.InetAddress import java.net.InetAddress

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

@ -15,11 +15,11 @@
*/ */
package dorkbox.network.connection package dorkbox.network.connection
import dorkbox.collections.IdentityMap
import dorkbox.network.ipFilter.IpFilterRule import dorkbox.network.ipFilter.IpFilterRule
import dorkbox.os.OS import dorkbox.os.OS
import dorkbox.util.classes.ClassHelper import dorkbox.util.classes.ClassHelper
import dorkbox.util.classes.ClassHierarchy import dorkbox.util.classes.ClassHierarchy
import dorkbox.util.collections.IdentityMap
import kotlinx.atomicfu.atomic import kotlinx.atomicfu.atomic
import kotlinx.coroutines.sync.Mutex import kotlinx.coroutines.sync.Mutex
import kotlinx.coroutines.sync.withLock import kotlinx.coroutines.sync.withLock

4
src/dorkbox/network/rmi/RemoteObjectStorage.kt
View File

@ -15,10 +15,10 @@
*/ */
package dorkbox.network.rmi package dorkbox.network.rmi
import dorkbox.util.collections.LockFreeIntBiMap import dorkbox.collections.LockFreeIntBiMap
import mu.KLogger import mu.KLogger
import org.agrona.collections.IntArrayList import org.agrona.collections.IntArrayList
import java.util.concurrent.locks.ReentrantReadWriteLock import java.util.concurrent.locks.*
import kotlin.concurrent.write import kotlin.concurrent.write
/** /**

2
src/dorkbox/network/rmi/RmiManagerConnections.kt
View File

@ -15,6 +15,7 @@
*/ */
package dorkbox.network.rmi package dorkbox.network.rmi
import dorkbox.collections.LockFreeIntMap
import dorkbox.network.connection.Connection import dorkbox.network.connection.Connection
import dorkbox.network.connection.ListenerManager import dorkbox.network.connection.ListenerManager
import dorkbox.network.rmi.messages.ConnectionObjectCreateRequest import dorkbox.network.rmi.messages.ConnectionObjectCreateRequest
@ -23,7 +24,6 @@ import dorkbox.network.rmi.messages.ConnectionObjectDeleteRequest
import dorkbox.network.rmi.messages.ConnectionObjectDeleteResponse import dorkbox.network.rmi.messages.ConnectionObjectDeleteResponse
import dorkbox.network.serialization.Serialization import dorkbox.network.serialization.Serialization
import dorkbox.util.classes.ClassHelper import dorkbox.util.classes.ClassHelper
import dorkbox.util.collections.LockFreeIntMap
import mu.KLogger import mu.KLogger
class RmiManagerConnections<CONNECTION: Connection> internal constructor( class RmiManagerConnections<CONNECTION: Connection> internal constructor(