Examples of stopAndWait()

Examples of ca.uhn.hl7v2.app.SimpleServer.stopAndWait()

140
141
142
143
144
145
146
147
148
149
150
         * for an example of this.
         */
        connectionHub.discard(connection);
       
        // Stop the receiving server and client
        server.stopAndWait();
        ConnectionHub.shutdown();

    }

}
View Full Code Here

Examples of co.cask.tephra.TransactionManager.stopAndWait()

138
139
140
141
142
143
144
145
146
147
148
      Transaction tx2 = txManager.startShort();
      Assert.assertTrue(txManager.canCommit(tx2, Collections.singleton(b)));
      // start a tx3
      Transaction tx3 = txManager.startShort();
      // restart
      txManager.stopAndWait();
      TransactionSnapshot origState = txManager.getCurrentState();
      LOG.info("Orig state: " + origState);

      Thread.sleep(100);
      // starts a new tx manager
View Full Code Here

Examples of co.cask.tephra.coprocessor.TransactionStateCache.stopAndWait()

268
269
270
271
272
273
274
275
    cache.startAndWait();
    // verify that the transaction snapshot read matches what we wrote in setupBeforeClass()
    TransactionSnapshot cachedSnapshot = cache.getLatestState();
    assertNotNull(cachedSnapshot);
    assertEquals(invalidSet, cachedSnapshot.getInvalid());
    cache.stopAndWait();
  }
}
View Full Code Here

Examples of co.cask.tephra.persist.HDFSTransactionStateStorage.stopAndWait()

113
114
115
116
117
118
119
120
121
122
123
        new HashMap<Long, Set<ChangeId>>(), new TreeMap<Long, Set<ChangeId>>());
    HDFSTransactionStateStorage tmpStorage =
      new HDFSTransactionStateStorage(conf, new SnapshotCodecProvider(conf));
    tmpStorage.startAndWait();
    tmpStorage.writeSnapshot(snapshot);
    tmpStorage.stopAndWait();
  }

  @AfterClass
  public static void shutdownAfterClass() throws Exception {
    dfsCluster.shutdown();
View Full Code Here

Examples of com.cloudera.kitten.appmaster.service.ApplicationMasterServiceImpl.stopAndWait()

33
34
35
36
37
38
39
40
41
42
43
    ApplicationMasterService service = new ApplicationMasterServiceImpl(params, getConf());
    service.startAndWait();
    while (service.hasRunningContainers()) {
      Thread.sleep(1000);
    }
    service.stopAndWait();
    return 0;
  }

  public static void main(String[] args) throws Exception {
    try {
View Full Code Here

Examples of com.google.common.util.concurrent.Service.stopAndWait()

157
158
159
160
161
162
163
164
165
166
167
        }
      }, Threads.SAME_THREAD_EXECUTOR);

      Assert.assertTrue(runLatch.await(2, TimeUnit.SECONDS));

      service.stopAndWait();

      zkClientService.stopAndWait();
    } finally {
      zkServer.stopAndWait();
    }
View Full Code Here

Examples of com.google.common.util.concurrent.Service.stopAndWait()

156
157
158
159
160
161
162
163
164
165
166
        }
      }, Threads.SAME_THREAD_EXECUTOR);

      Assert.assertTrue(runLatch.await(2, TimeUnit.SECONDS));

      service.stopAndWait();

      zkClientService.stopAndWait();
    } finally {
      zkServer.stopAndWait();
    }
View Full Code Here

Examples of org.apache.twill.api.TwillController.stopAndWait()

84
85
86
87
88
89
90
91
92
93
94
      } catch (TimeoutException e) {
        // OK, expected.
      }
    }

    controller.stopAndWait();
  }

  private boolean expireAppMasterZKSession(TwillController controller, long timeout, TimeUnit timeoutUnit) {
    MBeanServer mbeanServer = MBeanRegistry.getInstance().getPlatformMBeanServer();
    QueryExp query = Query.isInstanceOf(new StringValueExp(ConnectionMXBean.class.getName()));
View Full Code Here

Examples of org.apache.twill.api.TwillController.stopAndWait()

49
50
51
52
53
54
55
56
57
58
59
    try {
      ServiceDiscovered discovered = controller.discoverService("sleep");
      Assert.assertTrue(YarnTestUtils.waitForSize(discovered, 2, 60));
    } finally {
      controller.stopAndWait();
    }
  }


  /**
 
View Full Code Here

Examples of org.apache.twill.api.TwillController.stopAndWait()

57
58
59
60
61
62
63
64
65
66
67
    ListenableFuture<Service.State> completion = Services.getCompletionFuture(controller);
    try {
      completion.get(60, TimeUnit.SECONDS);
    } finally {
      controller.stopAndWait();
    }
  }

  /**
   * An application that contains two {@link ServiceRunnable}.
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.