Toggle navigation
Home
java.lang.Long to org.apache.ignite.internal.util.typedef.T2<java.lang.Integer, java.lang.Long>
No. of Instances - 10
No. of Commits - 1
No. of Projects - {'ignite'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Jdk -> Internal
Mapping:
Cascading Type Change (Different)
TreeMap<>
to
LinkedHashMap<>
TreeMap<>
to
LinkedHashMap<>
Cascading Type Change (Similar)
Map<Long,DiscoveryEvent>
to
Map<T2<Integer,Long>,DiscoveryEvent>
Add or Remove Method invocation
GridTestUtils.waitForCondition(new GridAbsPredicate(){ @SuppressWarnings("SynchronizationOnLocalVariableOrMethodParameter") @Override public boolean apply(){ Map<T2<Integer,Long>,DiscoveryEvent> nodeEvts=evts.get(nodeId); if (nodeEvts == null) { info("No events for node: " + nodeId); return false; } synchronized (nodeEvts) { for ( DiscoveryEvent expEvt : expEvts) { DiscoveryEvent evt0=nodeEvts.get(expEvt.topologyVersion()); if (evt0 == null) { info("No event for version: " + expEvt.topologyVersion()); return false; } assertEquals("Unexpected event [topVer=" + expEvt.topologyVersion() + ", exp="+ U.gridEventName(expEvt.type())+ ", evt="+ evt0+ ']',expEvt.type(),evt0.type()); } } return true; } } ,30000)
to
GridTestUtils.waitForCondition(new GridAbsPredicate(){ @SuppressWarnings("SynchronizationOnLocalVariableOrMethodParameter") @Override public boolean apply(){ Map<T2<Integer,Long>,DiscoveryEvent> nodeEvts=evts.get(nodeId); if (nodeEvts == null) { info("No events for node: " + nodeId); return false; } synchronized (nodeEvts) { for ( DiscoveryEvent expEvt : expEvts) { DiscoveryEvent evt0=nodeEvts.get(new T2<>(clusterNum.get(),expEvt.topologyVersion())); if (evt0 == null) { info("No event for version: " + expEvt.topologyVersion()); return false; } assertEquals("Unexpected event [topVer=" + expEvt.topologyVersion() + ", exp="+ U.gridEventName(expEvt.type())+ ", evt="+ evt0+ ']',expEvt.type(),evt0.type()); } } return true; } } ,30000)