6ea3b56205de19ceac89762d9c20c3fe62ab13b9
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 17
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public testManyClients() : void renamed to public testManyClientsForceServerMode() : void in class org.apache.ignite.internal.processors.cache.distributed.IgniteCacheManyClientsTest | From | To | |
| Change Parameter Type | 2 | ||
| Change Parameter Type sock : Socket to sockStream : SocketStream in method public setSocket(sockStream SocketStream, rmtNodeId UUID) : void in class org.apache.ignite.spi.discovery.tcp.ClientImpl.SocketReader | From | To | |
| Change Parameter Type sock : Socket to sock : SocketStream in method private SocketClosedMessage(sock SocketStream) in class org.apache.ignite.spi.discovery.tcp.ClientImpl.SocketClosedMessage | From | To | |
| Rename Variable | 2 | ||
| Rename Variable srvIdx : BlockingQueue<Integer> to srvStopIdxs : BlockingQueue<Integer> in method public testMultiThreadedClientsServersRestart() : void in class org.apache.ignite.spi.discovery.tcp.TcpDiscoveryMultiThreadedTest | From | To | |
| Rename Variable localNode : ClusterNode to locNode : ClusterNode in method private sendMessage0(node ClusterNode, msg Message, ackC IgniteInClosure<IgniteException>) : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi | From | To | |
| Change Return Type | 3 | ||
| Change Return Type T3<Socket,Integer,Boolean> to T3<SocketStream,Integer,Boolean> in method private sendJoinRequest(recon boolean, addr InetSocketAddress) : T3<SocketStream,Integer,Boolean> in class org.apache.ignite.spi.discovery.tcp.ClientImpl | From | To | |
| Change Return Type void to boolean in method public onNodeLeft() : boolean in class org.apache.ignite.internal.util.nio.GridNioRecoveryDescriptor | From | To | |
| Change Return Type T2<Socket,Boolean> to T2<SocketStream,Boolean> in method private joinTopology(recon boolean, timeout long) : T2<SocketStream,Boolean> in class org.apache.ignite.spi.discovery.tcp.ClientImpl | From | To | |
| Move Attribute | 2 | ||
| Move Attribute private sock : Socket from class org.apache.ignite.spi.discovery.tcp.ClientImpl.Reconnector to private sock : Socket from class org.apache.ignite.spi.discovery.tcp.ClientImpl.SocketStream | From | To | |
| Move Attribute private sock : Socket from class org.apache.ignite.spi.discovery.tcp.ClientImpl.SocketReader to private sock : Socket from class org.apache.ignite.spi.discovery.tcp.ClientImpl.SocketStream | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute sock : Socket to sockStream : SocketStream in class org.apache.ignite.spi.discovery.tcp.ClientImpl.SocketReader | From | To | |
| Change Variable Type | 3 | ||
| Change Variable Type sockAndRes : T3<Socket,Integer,Boolean> to sockAndRes : T3<SocketStream,Integer,Boolean> in method private joinTopology(recon boolean, timeout long) : T2<SocketStream,Boolean> in class org.apache.ignite.spi.discovery.tcp.ClientImpl | From | To | |
| Change Variable Type joinRes : T2<Socket,Boolean> to joinRes : T2<SocketStream,Boolean> in method private tryJoin() : void in class org.apache.ignite.spi.discovery.tcp.ClientImpl.MessageWorker | From | To | |
| Change Variable Type joinRes : T2<Socket,Boolean> to joinRes : T2<SocketStream,Boolean> in method protected body() : void in class org.apache.ignite.spi.discovery.tcp.ClientImpl.Reconnector | From | To | |
| Extract Variable | 3 | ||
| Extract Variable nodeFailedMsg : TcpDiscoveryNodeFailedMessage in method private processClientReconnectMessage(msg TcpDiscoveryClientReconnectMessage) : void from class org.apache.ignite.spi.discovery.tcp.ServerImpl.RingMessageWorker | From | To | |
| Extract Variable nodeFailedMsg : TcpDiscoveryNodeFailedMessage in method private processHeartbeatMessage(msg TcpDiscoveryHeartbeatMessage) : void from class org.apache.ignite.spi.discovery.tcp.ServerImpl.RingMessageWorker | From | To | |
| Extract Variable locNode : ClusterNode in method public dumpDebugInfo() : void from class org.apache.ignite.internal.IgniteKernal | From | To | |
| Extract Method | 1 | ||
| Extract Method private sendMessageToClients(msg TcpDiscoveryAbstractMessage) : void extracted from private sendMessageAcrossRing(msg TcpDiscoveryAbstractMessage) : void in class org.apache.ignite.spi.discovery.tcp.ServerImpl.RingMessageWorker | From | To | |
| Change Attribute Type | 4 | ||
| Change Attribute Type currSock : Socket to currSock : SocketStream in class org.apache.ignite.spi.discovery.tcp.ClientImpl.MessageWorker | From | To | |
| Change Attribute Type msgs : ArrayDeque<TcpDiscoveryAbstractMessage> to msgs : GridBoundedLinkedHashSet<TcpDiscoveryAbstractMessage> in class org.apache.ignite.spi.discovery.tcp.ServerImpl.EnsuredMessageHistory | From | To | |
| Change Attribute Type sock : Socket to sock : SocketStream in class org.apache.ignite.spi.discovery.tcp.ClientImpl.SocketClosedMessage | From | To | |
| Change Attribute Type sock : Socket to sockStream : SocketStream in class org.apache.ignite.spi.discovery.tcp.ClientImpl.SocketReader | From | To | |
| Inline Variable | 2 | ||
| Inline Variable startTime : long in method public onKernalStart() : void from class org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPreloader | From | To | |
| Inline Variable descs : Map<String,DynamicCacheDescriptor> in method public collectDiscoveryData(nodeId UUID) : Serializable from class org.apache.ignite.internal.processors.cache.GridCacheProcessor | From | To | |
| Rename Parameter | 3 | ||
| Rename Parameter ackClosure : IgniteInClosure<IgniteException> to ackC : IgniteInClosure<IgniteException> in method private sendMessage0(node ClusterNode, msg Message, ackC IgniteInClosure<IgniteException>) : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi | From | To | |
| Rename Parameter ackClosure : IgniteInClosure<IgniteException> to ackC : IgniteInClosure<IgniteException> in method public sendMessage(node ClusterNode, msg Message, ackC IgniteInClosure<IgniteException>) : void in class org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi | From | To | |
| Rename Parameter sock : Socket to sockStream : SocketStream in method public setSocket(sockStream SocketStream, rmtNodeId UUID) : void in class org.apache.ignite.spi.discovery.tcp.ClientImpl.SocketReader | From | To |