Fixed index out of bounds for pending RMI
This commit is contained in:
parent
424750e345
commit
c13fb205cf
|
@ -50,7 +50,7 @@ internal class RmiResponseManager(private val logger: KLogger, private val actio
|
||||||
private val rmiWaiterCache = Channel<RmiWaiter>(maxValuesInCache)
|
private val rmiWaiterCache = Channel<RmiWaiter>(maxValuesInCache)
|
||||||
|
|
||||||
private val pendingLock = ReentrantReadWriteLock()
|
private val pendingLock = ReentrantReadWriteLock()
|
||||||
private val pending = arrayOfNulls<Any?>(maxValuesInCache)
|
private val pending = arrayOfNulls<Any?>(maxValuesInCache+1) // +1 because it's possible to have the value 65535 in the cache
|
||||||
|
|
||||||
init {
|
init {
|
||||||
// create a shuffled list of ID's. This operation is ONLY performed ONE TIME per endpoint!
|
// create a shuffled list of ID's. This operation is ONLY performed ONE TIME per endpoint!
|
||||||
|
|
Loading…
Reference in New Issue
Block a user