List of timedOut() Examples

Examples of timedOut()

bitronix.tm.BitronixTransaction.timedOut()
com.sun.jdi.event.MonitorWaitedEvent.timedout()
Returns whether the wait has timed out or been interrupted. @return true if the wait is timed out.
com.volantis.shared.net.impl.TimingOutTask.timedOut()
Check whether this task has timed out. @return True if it has timed out, false otherwise.
hudson.plugins.perforce.utils.TimedStreamCloser.timedOut()
org.apache.hadoop.ipc.Server.Connection.timedOut()
org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse.timedOut()
true if the waitForXXX has timeout out and did not match.
org.jbehave.core.model.StoryDuration.timedOut()

Examples of org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse.timedOut()

        startNode("node4", settings);


        logger.info("Running Cluster Health");
        clusterHealth = client("node1").admin().cluster().health(clusterHealthRequest().waitForGreenStatus().waitForActiveShards(10)).actionGet();
        logger.info("Done Cluster Health, status " + clusterHealth.status());
        assertThat(clusterHealth.timedOut(), equalTo(false));
        assertThat(clusterHealth.status(), equalTo(ClusterHealthStatus.GREEN));


        logger.info("--> shutting down the nodes");
        client("node1").admin().cluster().prepareNodesShutdown().setDelay("10ms").setExit(false).execute().actionGet();
        Thread.sleep(2000);

View Full Code Here

Examples of org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse.timedOut()

        startNode("node4", settings);


        logger.info("Running Cluster Health");
        clusterHealth = client("node1").admin().cluster().health(clusterHealthRequest().waitForGreenStatus().waitForActiveShards(10)).actionGet();
        logger.info("Done Cluster Health, status " + clusterHealth.status());
        assertThat(clusterHealth.timedOut(), equalTo(false));
        assertThat(clusterHealth.status(), equalTo(ClusterHealthStatus.GREEN));


        IndicesStatusResponse statusResponse = client("node1").admin().indices().prepareStatus("test").setRecovery(true).execute().actionGet();
        for (IndexShardStatus indexShardStatus : statusResponse.index("test")) {
            for (ShardStatus shardStatus : indexShardStatus) {

View Full Code Here

Examples of org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse.timedOut()

        startNode("server1");


        logger.info("Running Cluster Health (waiting for node to startup properly)");
        ClusterHealthResponse clusterHealth = client("server1").admin().cluster().health(clusterHealthRequest().waitForGreenStatus()).actionGet();
        logger.info("Done Cluster Health, status " + clusterHealth.status());
        assertThat(clusterHealth.timedOut(), equalTo(false));
        assertThat(clusterHealth.status(), equalTo(ClusterHealthStatus.GREEN));


        client("server1").admin().indices().create(createIndexRequest("test")).actionGet();


        closeNode("server1");

View Full Code Here

Examples of org.jbehave.core.model.StoryDuration.timedOut()

          Future<ThrowableStory> future = runningStory.getFuture();
          if (!future.isDone()) {
            allDone = false;
            StoryDuration duration = runningStory.getDuration();
            runningStory.updateDuration();
            if (duration.timedOut()) {
              embedderMonitor.storyTimeout(story, duration);
              storyRunner.cancelStory(story, duration);
              future.cancel(true);
              if (embedderControls.failOnStoryTimeout()) {
                throw new StoryExecutionFailed(story.getPath(),

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.