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

ZooLock.getLockID介绍

暂无

代码示例

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

private String lockString(ZooLock mlock) {
 return mlock.getLockID().serialize(ZooUtil.getRoot(instance) + Constants.ZMASTER_LOCK);
}

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

private static void retryZooKeeperUpdate(ClientContext context, ZooLock zooLock,
  ZooOperation op) {
 while (true) {
  try {
   IZooReaderWriter zoo = ZooReaderWriter.getInstance();
   if (zoo.isLockHeld(zooLock.getLockID())) {
    op.run(zoo);
   }
   break;
  } catch (Exception e) {
   log.error("Unexpected exception {}", e.getMessage(), e);
  }
  sleepUninterruptibly(1, TimeUnit.SECONDS);
 }
}

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

private String lockString(ZooLock mlock) {
 return mlock.getLockID()
   .serialize(ZooUtil.getRoot(context.getInstance()) + Constants.ZMASTER_LOCK);
}

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

public static void putLockID(ZooLock zooLock, Mutation m) {
 TabletsSection.ServerColumnFamily.LOCK_COLUMN.put(m, new Value(zooLock.getLockID()
   .serialize(ZooUtil.getRoot(HdfsZooInstance.getInstance()) + "/").getBytes(UTF_8)));
}

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

public static void putLockID(ZooLock zooLock, Mutation m) {
 Constants.METADATA_LOCK_COLUMN.put(m, new Value(zooLock.getLockID().serialize(ZooUtil.getRoot(HdfsZooInstance.getInstance()) + "/").getBytes(UTF_8)));
}

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

if (!zoo.isLockHeld(tabletServer.getLock().getLockID())) {
 throw new IllegalStateException();

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

public static void addLogEntry(TCredentials credentials, LogEntry entry, ZooLock zooLock) {
 if (entry.extent.isRootTablet()) {
  String root = getZookeeperLogLocation();
  while (true) {
   try {
    IZooReaderWriter zoo = ZooReaderWriter.getInstance();
    if (zoo.isLockHeld(zooLock.getLockID()))
     zoo.putPersistentData(root + "/" + entry.filename, entry.toBytes(), NodeExistsPolicy.OVERWRITE);
    break;
   } catch (KeeperException e) {
    log.error(e, e);
   } catch (InterruptedException e) {
    log.error(e, e);
   } catch (IOException e) {
    log.error(e, e);
   }
   UtilWaitThread.sleep(1000);
  }
 } else {
  String value = StringUtil.join(entry.logSet, ";") + "|" + entry.tabletId;
  Mutation m = new Mutation(entry.extent.getMetadataEntry());
  m.put(Constants.METADATA_LOG_COLUMN_FAMILY, new Text(entry.server + "/" + entry.filename), new Value(value.getBytes(UTF_8)));
  update(credentials, zooLock, m);
 }
}

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

lockID = tabletServerLock.getLockID()
  .serialize(ZooUtil.getRoot(getInstance()) + Constants.ZTSERVERS + "/");
return;

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

if (extent.isRootTablet()) {
 try {
  if (!zoo.isLockHeld(tabletServer.getLock().getLockID())) {
   throw new IllegalStateException();

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

public static void removeUnusedWALEntries(KeyExtent extent, List<LogEntry> logEntries, ZooLock zooLock) {
 if (extent.isRootTablet()) {
  for (LogEntry entry : logEntries) {
   String root = getZookeeperLogLocation();
   while (true) {
    try {
     IZooReaderWriter zoo = ZooReaderWriter.getInstance();
     if (zoo.isLockHeld(zooLock.getLockID()))
      zoo.recursiveDelete(root + "/" + entry.filename, NodeMissingPolicy.SKIP);
     break;
    } catch (Exception e) {
     log.error(e, e);
    }
    UtilWaitThread.sleep(1000);
   }
  }
 } else {
  Mutation m = new Mutation(extent.getMetadataEntry());
  for (LogEntry entry : logEntries) {
   m.putDelete(Constants.METADATA_LOG_COLUMN_FAMILY, new Text(entry.server + "/" + entry.filename));
  }
  update(SecurityConstants.getSystemCredentials(), zooLock, m);
 }
}

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

if (!zoo.isLockHeld(tablet.getTabletServer().getLock().getLockID())) {
 throw new IllegalStateException();

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

if (tablet.getExtent().isRootTablet()) {
 try {
  if (!zoo.isLockHeld(tablet.getTabletServer().getLock().getLockID())) {
   throw new IllegalStateException();