本文整理了Java中org.apache.accumulo.server.zookeeper.ZooLock.<init>()方法的一些代码示例，展示了ZooLock.<init>()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZooLock.<init>()方法的具体详情如下：
包路径：org.apache.accumulo.server.zookeeper.ZooLock
类名称：ZooLock
方法名：<init>

ZooLock.<init>介绍

暂无

代码示例

代码示例来源：origin: org.apache.accumulo/accumulo-gc

private void getZooLock(HostAndPort addr) throws KeeperException, InterruptedException {
 String path = ZooUtil.getRoot(getInstance()) + Constants.ZGC_LOCK;
 LockWatcher lockWatcher = new LockWatcher() {
  @Override
  public void lostLock(LockLossReason reason) {
   Halt.halt("GC lock in zookeeper lost (reason = " + reason + "), exiting!", 1);
  }
  @Override
  public void unableToMonitorLockNode(final Throwable e) {
   // ACCUMULO-3651 Level changed to error and FATAL added to message for slf4j compatibility
   Halt.halt(-1, new Runnable() {
    @Override
    public void run() {
     log.error("FATAL: No longer able to monitor lock node ", e);
    }
   });
  }
 };
 while (true) {
  lock = new ZooLock(path);
  if (lock.tryLock(lockWatcher,
    new ServerServices(addr.toString(), Service.GC_CLIENT).toString().getBytes())) {
   log.debug("Got GC ZooKeeper lock");
   return;
  }
  log.debug("Failed to get GC ZooKeeper lock, will retry");
  sleepUninterruptibly(1, TimeUnit.SECONDS);
 }
}

代码示例来源：origin: org.apache.accumulo/accumulo-server

private void getMasterLock(final String zMasterLoc) throws KeeperException, InterruptedException {
 log.info("trying to get master lock");
 final String masterClientAddress = org.apache.accumulo.core.util.AddressUtil.toString(new InetSocketAddress(hostname, getSystemConfiguration().getPort(
   Property.MASTER_CLIENTPORT)));
 while (true) {
  MasterLockWatcher masterLockWatcher = new MasterLockWatcher();
  masterLock = new ZooLock(zMasterLoc);
  masterLock.lockAsync(masterLockWatcher, masterClientAddress.getBytes(UTF_8));
  masterLockWatcher.waitForChange();
  if (masterLockWatcher.acquiredLock) {
   break;
  }
  if (!masterLockWatcher.failedToAcquireLock) {
   throw new IllegalStateException("master lock in unknown state");
  }
  masterLock.tryToCancelAsyncLockOrUnlock();
  UtilWaitThread.sleep(TIME_TO_WAIT_BETWEEN_LOCK_CHECKS);
 }
 setMasterState(MasterState.HAVE_LOCK);
}

代码示例来源：origin: org.apache.accumulo/accumulo-master

private void getMasterLock(final String zMasterLoc) throws KeeperException, InterruptedException {
 log.info("trying to get master lock");
 final String masterClientAddress = hostname + ":"
   + getConfiguration().getPort(Property.MASTER_CLIENTPORT)[0];
 while (true) {
  MasterLockWatcher masterLockWatcher = new MasterLockWatcher();
  masterLock = new ZooLock(zMasterLoc);
  masterLock.lockAsync(masterLockWatcher, masterClientAddress.getBytes());
  masterLockWatcher.waitForChange();
  if (masterLockWatcher.acquiredLock) {
   break;
  }
  if (!masterLockWatcher.failedToAcquireLock) {
   throw new IllegalStateException("master lock in unknown state");
  }
  masterLock.tryToCancelAsyncLockOrUnlock();
  sleepUninterruptibly(TIME_TO_WAIT_BETWEEN_LOCK_CHECKS, TimeUnit.MILLISECONDS);
 }
 setMasterState(MasterState.HAVE_LOCK);
}

代码示例来源：origin: org.apache.accumulo/accumulo-server

tabletServerLock = new ZooLock(zPath);

代码示例来源：origin: org.apache.accumulo/accumulo-server

private void getZooLock(InetSocketAddress addr) throws KeeperException, InterruptedException {
 String address = AddressUtil.toString(addr);
 String path = ZooUtil.getRoot(HdfsZooInstance.getInstance()) + Constants.ZGC_LOCK;
 LockWatcher lockWatcher = new LockWatcher() {
  public void lostLock(LockLossReason reason) {
   Halt.halt("GC lock in zookeeper lost (reason = " + reason + "), exiting!");
  }
  @Override
  public void unableToMonitorLockNode(final Throwable e) {
   Halt.halt(-1, new Runnable() {
    @Override
    public void run() {
     log.fatal("No longer able to monitor lock node ", e);
    }
   });
  }
 };
 while (true) {
  lock = new ZooLock(path);
  if (lock.tryLock(lockWatcher, new ServerServices(address, Service.GC_CLIENT).toString().getBytes(UTF_8))) {
   break;
  }
  UtilWaitThread.sleep(1000);
 }
}

代码示例来源：origin: org.apache.accumulo/accumulo-tserver

tabletServerLock = new ZooLock(zPath);

代码示例来源：origin: org.apache.accumulo/accumulo-test

zoo.putPersistentData(zPath, new byte[] {}, NodeExistsPolicy.SKIP);
ZooLock zlock = new ZooLock(zPath);

代码示例来源：origin: org.apache.accumulo/accumulo-server

monitorLock = new ZooLock(monitorLockPath);
monitorLock.lockAsync(monitorLockWatcher, new byte[0]);

代码示例来源：origin: org.apache.accumulo/accumulo-monitor

monitorLock = new ZooLock(monitorLockPath);
monitorLock.lockAsync(monitorLockWatcher, new byte[0]);

代码示例来源：origin: org.apache.accumulo/accumulo-test

IZooReaderWriter zoo = ZooReaderWriter.getInstance();
zoo.putPersistentData(zPath, new byte[0], NodeExistsPolicy.OVERWRITE);
ZooLock zl = new ZooLock(zPath);
boolean gotLock = zl.tryLock(new LockWatcher() {