|
Change Parameter Type reconnect : boolean to connIdx : int in method package DisconnectedSessionInfo(recoveryDesc GridNioRecoveryDescriptor, connIdx int) in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.DisconnectedSessionInfo |
From |
To |
|
Change Parameter Type order : long to idx : int in method package ConnectionKey(nodeId UUID, idx int, connCnt long) in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.ConnectionKey |
From |
To |
|
Change Parameter Type recoveryDescs : ConcurrentMap<ClientKey,GridNioRecoveryDescriptor> to recoveryDescs : ConcurrentMap<ConnectionKey,GridNioRecoveryDescriptor> in method private cleanupRecovery(recoveryDescs ConcurrentMap<ConnectionKey,GridNioRecoveryDescriptor>) : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.CommunicationWorker |
From |
To |
|
Change Parameter Type recoveryDescs : ConcurrentMap<ClientKey,GridNioRecoveryDescriptor> to recoveryDescs : ConcurrentMap<ConnectionKey,GridNioRecoveryDescriptor> in method private recoveryDescriptor(recoveryDescs ConcurrentMap<ConnectionKey,GridNioRecoveryDescriptor>, node ClusterNode, key ConnectionKey) : GridNioRecoveryDescriptor in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Rename Variable client : GridCommunicationClient to curClients : GridCommunicationClient[] in method private removeNodeClient(nodeId UUID, rmvClient GridCommunicationClient) : boolean in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Rename Variable client : GridCommunicationClient to clients0 : GridCommunicationClient[] in method public onClientDisconnected(reconnectFut IgniteFuture<?>) : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Rename Variable client : GridCommunicationClient to clients0 : GridCommunicationClient[] in method protected onContextDestroyed0() : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Rename Variable rmtNodeId : UUID to connKey : ConnectionKey in method public reader(ses GridNioSession, msgFactory MessageFactory) : MessageReader in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.ShmemWorker.body.readerFactory |
From |
To |
|
Rename Variable rmtNodeId : UUID to key : ConnectionKey in method public reader(ses GridNioSession, msgFactory MessageFactory) : MessageReader in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.resetNioServer.readerFactory |
From |
To |
|
Rename Variable client : GridCommunicationClient to clients0 : GridCommunicationClient[] in method public simulateNodeFailure() : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Rename Variable client : GridCommunicationClient to clients0 : GridCommunicationClient[] in method public spiStop() : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Rename Variable other : ClientKey to key : ConnectionKey in method public equals(o Object) : boolean in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.ConnectionKey |
From |
To |
|
Rename Variable client : GridCommunicationClient to clients0 : GridCommunicationClient[] in method package closeSessions(ignite Ignite) : boolean in class org.apache.ignite.internal.processors.cache.distributed.IgniteCacheMessageRecoveryAbstractTest |
From |
To |
|
Rename Variable client : GridCommunicationClient to clients0 : GridCommunicationClient[] in method package onNodeLeft(nodeId UUID) : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Rename Variable rmtNodeId : UUID to key : ConnectionKey in method public writer(ses GridNioSession) : MessageWriter in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.resetNioServer.writerFactory |
From |
To |
|
Rename Variable rmtNodeId : UUID to connKey : ConnectionKey in method public writer(ses GridNioSession) : MessageWriter in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.ShmemWorker.body.writerFactory |
From |
To |
|
Rename Variable recoverySnd : GridNioRecoveryDescriptor to recoveryDesc : GridNioRecoveryDescriptor in method private cleanupRecovery(recoveryDescs ConcurrentMap<ConnectionKey,GridNioRecoveryDescriptor>) : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.CommunicationWorker |
From |
To |
|
Change Variable Type client : GridCommunicationClient to curClients : GridCommunicationClient[] in method private removeNodeClient(nodeId UUID, rmvClient GridCommunicationClient) : boolean in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Change Variable Type client : GridCommunicationClient to clients0 : GridCommunicationClient[] in method public onClientDisconnected(reconnectFut IgniteFuture<?>) : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Change Variable Type client : GridCommunicationClient to clients0 : GridCommunicationClient[] in method protected onContextDestroyed0() : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Change Variable Type e : Map.Entry<ClientKey,GridNioRecoveryDescriptor> to e : Map.Entry<ConnectionKey,GridNioRecoveryDescriptor> in method private cleanupRecovery(recoveryDescs ConcurrentMap<ConnectionKey,GridNioRecoveryDescriptor>) : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.CommunicationWorker |
From |
To |
|
Change Variable Type rmtNodeId : UUID to connKey : ConnectionKey in method public reader(ses GridNioSession, msgFactory MessageFactory) : MessageReader in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.ShmemWorker.body.readerFactory |
From |
To |
|
Change Variable Type e : Map.Entry<UUID,GridCommunicationClient> to e : Map.Entry<UUID,GridCommunicationClient[]> in method private processIdle() : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.CommunicationWorker |
From |
To |
|
Change Variable Type rmtNodeId : UUID to key : ConnectionKey in method public reader(ses GridNioSession, msgFactory MessageFactory) : MessageReader in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.resetNioServer.readerFactory |
From |
To |
|
Change Variable Type entry : Map.Entry<ClientKey,GridNioRecoveryDescriptor> to entry : Map.Entry<ConnectionKey,GridNioRecoveryDescriptor> in method public dumpStats() : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Change Variable Type clients : ConcurrentMap<UUID,GridCommunicationClient> to clients : ConcurrentMap<UUID,GridCommunicationClient[]> in method protected afterTest() : void in class org.apache.ignite.spi.communication.tcp.GridTcpCommunicationSpiMultithreadedSelfTest |
From |
To |
|
Change Variable Type left : Set<ClientKey> to left : Set<ConnectionKey> in method private cleanupRecovery(recoveryDescs ConcurrentMap<ConnectionKey,GridNioRecoveryDescriptor>) : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.CommunicationWorker |
From |
To |
|
Change Variable Type id : UUID to id : ConnectionKey in method private checkClientQueueSize(ses GridNioSession, msgQueueSize int) : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Change Variable Type client : GridCommunicationClient to clients0 : GridCommunicationClient[] in method public simulateNodeFailure() : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Change Variable Type clients : Map<UUID,GridCommunicationClient> to clients : Map<UUID,GridCommunicationClient[]> in method package closeSessions(ignite Ignite) : boolean in class org.apache.ignite.internal.processors.cache.distributed.IgniteCacheMessageRecoveryAbstractTest |
From |
To |
|
Change Variable Type client : GridCommunicationClient to clients0 : GridCommunicationClient[] in method public spiStop() : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Change Variable Type client : GridCommunicationClient to clients0 : GridCommunicationClient[] in method package closeSessions(ignite Ignite) : boolean in class org.apache.ignite.internal.processors.cache.distributed.IgniteCacheMessageRecoveryAbstractTest |
From |
To |
|
Change Variable Type other : ClientKey to key : ConnectionKey in method public equals(o Object) : boolean in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.ConnectionKey |
From |
To |
|
Change Variable Type id : ClientKey to id : ConnectionKey in method private cleanupRecovery(recoveryDescs ConcurrentMap<ConnectionKey,GridNioRecoveryDescriptor>) : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.CommunicationWorker |
From |
To |
|
Change Variable Type rmtNodeId : UUID to key : ConnectionKey in method public writer(ses GridNioSession) : MessageWriter in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.resetNioServer.writerFactory |
From |
To |
|
Change Variable Type client : GridCommunicationClient to clients0 : GridCommunicationClient[] in method package onNodeLeft(nodeId UUID) : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Change Variable Type entry : Map.Entry<UUID,GridCommunicationClient> to entry : Map.Entry<UUID,GridCommunicationClient[]> in method public dumpStats() : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Change Variable Type id : ClientKey to key : ConnectionKey in method private recoveryDescriptor(recoveryDescs ConcurrentMap<ConnectionKey,GridNioRecoveryDescriptor>, node ClusterNode, key ConnectionKey) : GridNioRecoveryDescriptor in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Change Variable Type clients : ConcurrentMap<UUID,GridCommunicationClient> to clients : ConcurrentMap<UUID,GridCommunicationClient[]> in method protected afterTest() : void in class org.apache.ignite.spi.communication.tcp.GridTcpCommunicationSpiAbstractTest |
From |
To |
|
Change Variable Type rmtNodeId : UUID to connKey : ConnectionKey in method public writer(ses GridNioSession) : MessageWriter in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.ShmemWorker.body.writerFactory |
From |
To |
|
Change Attribute Type outRecDescs : ConcurrentMap<ClientKey,GridNioRecoveryDescriptor> to outRecDescs : ConcurrentMap<ConnectionKey,GridNioRecoveryDescriptor> in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Change Attribute Type recoveryDescs : ConcurrentMap<ClientKey,GridNioRecoveryDescriptor> to recoveryDescs : ConcurrentMap<ConnectionKey,GridNioRecoveryDescriptor> in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Change Attribute Type inRecDescs : ConcurrentMap<ClientKey,GridNioRecoveryDescriptor> to inRecDescs : ConcurrentMap<ConnectionKey,GridNioRecoveryDescriptor> in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Change Attribute Type clientFuts : ConcurrentMap<UUID,GridFutureAdapter<GridCommunicationClient>> to clientFuts : ConcurrentMap<ConnectionKey,GridFutureAdapter<GridCommunicationClient>> in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Change Attribute Type clients : ConcurrentMap<UUID,GridCommunicationClient> to clients : ConcurrentMap<UUID,GridCommunicationClient[]> in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi |
From |
To |
|
Change Attribute Type readBalanceIdx : AtomicInteger to readBalanceIdx : int in class org.apache.ignite.internal.util.nio.GridNioServer |
From |
To |
|
Change Attribute Type order : long to idx : int in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.ConnectionKey |
From |
To |
|
Change Attribute Type reconnect : boolean to connIdx : int in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi.DisconnectedSessionInfo |
From |
To |
|
Change Attribute Type writeBalanceIdx : AtomicInteger to writeBalanceIdx : int in class org.apache.ignite.internal.util.nio.GridNioServer |
From |
To |