Toggle navigation
Home
org.apache.ignite.internal.util.nio.GridCommunicationClient to org.apache.ignite.internal.util.nio.GridCommunicationClient[]
No. of Instances - 44
No. of Commits - 3
No. of Projects - {'ignite'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Cascading Type Change (Similar)
GridCommunicationClient
to
GridCommunicationClient[]
GridCommunicationClient
to
GridCommunicationClient[]
GridCommunicationClient
to
GridCommunicationClient[]
GridCommunicationClient
to
GridCommunicationClient[]
GridCommunicationClient
to
GridCommunicationClient[]
GridCommunicationClient
to
GridCommunicationClient[]
Rename Method invocation
get
to
remove
get
to
remove
get
to
remove
get
to
remove
get
to
remove
get
to
remove
Rename Variable
client
to
clients0
client
to
clients0
client
to
clients0
client
to
clients0
client
to
clients0
client
to
clients0
client
to
clients0
client
to
clients0
client
to
clients0
client
to
clients0
client
to
clients0
client
to
clients0
client
to
clients0
client
to
clients0
client
to
clients0
client
to
clients0
client
to
clients0
client
to
clients0
Add or Remove Method invocation
GridTestUtils.waitForCondition(new PA(){ @Override public boolean apply(){ return clients.isEmpty(); } } ,getTestTimeout())
to
GridTestUtils.waitForCondition(new PA(){ @Override public boolean apply(){ for ( GridCommunicationClient[] clients0 : clients.values()) { for ( GridCommunicationClient client : clients0) { if (client != null) return false; } } return true; } } ,getTestTimeout())
sb.append(" [key=").append(entry.getKey()).append(", msgsSent=").append(desc.sent()).append(", msgsAckedByRmt=").append(desc.acked()).append(", reserveCnt=").append(desc.reserveCount()).append(", descIdHash=").append(System.identityHashCode(desc)).append(']')
to
sb.append(" [key=").append(entry.getKey()).append(", msgsSent=").append(desc.sent()).append(", msgsAckedByRmt=").append(desc.acked()).append(", reserveCnt=").append(desc.reserveCount()).append(", connected=").append(desc.connected()).append(", reserved=").append(desc.reserved()).append(", descIdHash=").append(System.identityHashCode(desc)).append(']')
GridTestUtils.waitForCondition(new PA(){ @Override public boolean apply(){ return clients.isEmpty(); } } ,getTestTimeout())
to
GridTestUtils.waitForCondition(new PA(){ @Override public boolean apply(){ for ( GridCommunicationClient[] clients0 : clients.values()) { for ( GridCommunicationClient client : clients0) { if (client != null) return false; } } return true; } } ,getTestTimeout())
GridTestUtils.waitForCondition(new PA(){ @Override public boolean apply(){ return clients.isEmpty(); } } ,getTestTimeout())
to
GridTestUtils.waitForCondition(new PA(){ @Override public boolean apply(){ for ( GridCommunicationClient[] clients0 : clients.values()) { for ( GridCommunicationClient client : clients0) { if (client != null) return false; } } return true; } } ,getTestTimeout())