@Test (expected = NotAllMetaRegionsOnlineException.class) public void testTimeoutWaitForMeta() throws IOException, InterruptedException { final CatalogTracker ct = constructAndStartCatalogTracker(); ct.waitForMeta(100); }
public void waitForMeta() throws InterruptedException { synchronized (metaAvailable) { while (!stopped && !metaAvailable.get()) { metaAvailable.wait(); } } }
CatalogTracker { public void waitForMeta() throws InterruptedException { synchronized (metaAvailable) { while (!stopped && !metaAvailable.get()) { metaAvailable.wait(); } } } }
CatalogTracker { public void waitForMeta() throws InterruptedException { synchronized (metaAvailable) { while (!stopped && !metaAvailable.get()) { metaAvailable.wait(); } } } CatalogTracker(final HConnection connection);  CatalogTracker(final ZooKeeperWatcher zk, final HConnection connection,
      final Abortable abortable);  CatalogTracker(final ZooKeeperWatcher zk, final HConnection connection,
      final Abortable abortable, final int defaultTimeout); }
CatalogTracker { public void waitForMeta() throws InterruptedException { synchronized (metaAvailable) { while (!stopped && !metaAvailable.get()) { metaAvailable.wait(); } } } CatalogTracker(final HConnection connection);  CatalogTracker(final ZooKeeperWatcher zk, final HConnection connection,
      final Abortable abortable);  CatalogTracker(final ZooKeeperWatcher zk, final HConnection connection,
      final Abortable abortable, final int defaultTimeout); void start(); void stop(); HServerAddress getRootLocation(); HServerAddress getMetaLocation(); void waitForRoot(); HRegionInterface waitForRootServerConnection(long timeout); HRegionInterface waitForRootServerConnectionDefault(); void waitForMeta(); HServerAddress waitForMeta(long timeout); HRegionInterface waitForMetaServerConnection(long timeout); HRegionInterface waitForMetaServerConnectionDefault(); boolean verifyRootRegionLocation(final long timeout); boolean verifyMetaRegionLocation(final long timeout); HConnection getConnection(); }
CatalogTracker { public void waitForMeta() throws InterruptedException { synchronized (metaAvailable) { while (!stopped && !metaAvailable.get()) { metaAvailable.wait(); } } } CatalogTracker(final HConnection connection);  CatalogTracker(final ZooKeeperWatcher zk, final HConnection connection,
      final Abortable abortable);  CatalogTracker(final ZooKeeperWatcher zk, final HConnection connection,
      final Abortable abortable, final int defaultTimeout); void start(); void stop(); HServerAddress getRootLocation(); HServerAddress getMetaLocation(); void waitForRoot(); HRegionInterface waitForRootServerConnection(long timeout); HRegionInterface waitForRootServerConnectionDefault(); void waitForMeta(); HServerAddress waitForMeta(long timeout); HRegionInterface waitForMetaServerConnection(long timeout); HRegionInterface waitForMetaServerConnectionDefault(); boolean verifyRootRegionLocation(final long timeout); boolean verifyMetaRegionLocation(final long timeout); HConnection getConnection(); static final byte [] ROOT_REGION; static final byte [] META_REGION; }