Skip to content

Commit

Permalink
ignite-5955 Skip disconnected clients in GridAbstractTest.awaitTopolo…
Browse files Browse the repository at this point in the history
…gyChange
  • Loading branch information
zstan authored and sboikov committed Dec 25, 2017
1 parent 5439eb2 commit 100bf0b
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -119,6 +119,7 @@
import static org.apache.ignite.IgniteSystemProperties.IGNITE_DISCO_FAILED_CLIENT_RECONNECT_DELAY;
import static org.apache.ignite.cache.CacheAtomicityMode.TRANSACTIONAL;
import static org.apache.ignite.cache.CacheWriteSynchronizationMode.FULL_SYNC;
import static org.apache.ignite.internal.GridKernalState.DISCONNECTED;
import static org.apache.ignite.testframework.config.GridTestProperties.BINARY_MARSHALLER_USE_SIMPLE_NAME_MAPPER;

/**
Expand Down Expand Up @@ -2102,7 +2103,7 @@ private void awaitTopologyChange() throws IgniteInterruptedCheckedException {
for (Ignite g : G.allGrids()) {
final GridKernalContext ctx = ((IgniteKernal)g).context();

if (ctx.isStopping() || !g.active())
if (ctx.isStopping() || ctx.gateway().getState() == DISCONNECTED || !g.active())
continue;

AffinityTopologyVersion topVer = ctx.discovery().topologyVersionEx();
Expand Down

0 comments on commit 100bf0b

Please sign in to comment.