Java 类org.apache.hadoop.hbase.zookeeper.lock.ZKInterProcessReadWriteLock 实例源码

private InterProcessLock createTableLock() {
  String tableLockZNode = ZKUtil.joinZNode(zkWatcher.tableLockZNode,
      tableName.getNameAsString());

  ZooKeeperProtos.TableLock data = ZooKeeperProtos.TableLock.newBuilder()
    .setTableName(ProtobufUtil.toProtoTableName(tableName))
    .setLockOwner(ProtobufUtil.toServerName(serverName))
    .setThreadId(Thread.currentThread().getId())
    .setPurpose(purpose)
    .setIsShared(isShared)
    .setCreateTime(EnvironmentEdgeManager.currentTime()).build();
  byte[] lockMetadata = toBytes(data);

  InterProcessReadWriteLock lock = new ZKInterProcessReadWriteLock(zkWatcher, tableLockZNode,
    METADATA_HANDLER);
  return isShared ? lock.readLock(lockMetadata) : lock.writeLock(lockMetadata);
}

private InterProcessLock createTableLock() {
  String tableLockZNode = ZKUtil.joinZNode(zkWatcher.tableLockZNode,
      tableName.getNameAsString());

  ZooKeeperProtos.TableLock data = ZooKeeperProtos.TableLock.newBuilder()
    .setTableName(ProtobufUtil.toProtoTableName(tableName))
    .setLockOwner(ProtobufUtil.toServerName(serverName))
    .setThreadId(Thread.currentThread().getId())
    .setPurpose(purpose)
    .setIsShared(isShared)
    .setCreateTime(EnvironmentEdgeManager.currentTime()).build();
  byte[] lockMetadata = toBytes(data);

  InterProcessReadWriteLock lock = new ZKInterProcessReadWriteLock(zkWatcher, tableLockZNode,
    METADATA_HANDLER);
  return isShared ? lock.readLock(lockMetadata) : lock.writeLock(lockMetadata);
}

private InterProcessLock createTableLock() {
  String tableLockZNode = ZKUtil.joinZNode(zkWatcher.tableLockZNode,
      tableName.getNameAsString());

  ZooKeeperProtos.TableLock data = ZooKeeperProtos.TableLock.newBuilder()
    .setTableName(ProtobufUtil.toProtoTableName(tableName))
    .setLockOwner(ProtobufUtil.toServerName(serverName))
    .setThreadId(Thread.currentThread().getId())
    .setPurpose(purpose)
    .setIsShared(isShared)
    .setCreateTime(EnvironmentEdgeManager.currentTimeMillis()).build();
  byte[] lockMetadata = toBytes(data);

  InterProcessReadWriteLock lock = new ZKInterProcessReadWriteLock(zkWatcher, tableLockZNode,
    METADATA_HANDLER);
  return isShared ? lock.readLock(lockMetadata) : lock.writeLock(lockMetadata);
}

private InterProcessLock createTableLock() {
  String tableLockZNode = ZKUtil.joinZNode(zkWatcher.tableLockZNode,
      tableName.getNameAsString());

  ZooKeeperProtos.TableLock data = ZooKeeperProtos.TableLock.newBuilder()
    .setTableName(ProtobufUtil.toProtoTableName(tableName))
    .setLockOwner(ProtobufUtil.toServerName(serverName))
    .setThreadId(Thread.currentThread().getId())
    .setPurpose(purpose)
    .setIsShared(isShared)
    .setCreateTime(EnvironmentEdgeManager.currentTimeMillis()).build();
  byte[] lockMetadata = toBytes(data);

  InterProcessReadWriteLock lock = new ZKInterProcessReadWriteLock(zkWatcher, tableLockZNode,
    METADATA_HANDLER);
  return isShared ? lock.readLock(lockMetadata) : lock.writeLock(lockMetadata);
}

private InterProcessLock createTableLock() {
  String tableLockZNode = ZKUtil.joinZNode(zkWatcher.tableLockZNode,
      tableName.getNameAsString());

  ZooKeeperProtos.TableLock data = ZooKeeperProtos.TableLock.newBuilder()
    .setTableName(ProtobufUtil.toProtoTableName(tableName))
    .setLockOwner(ProtobufUtil.toServerName(serverName))
    .setThreadId(Thread.currentThread().getId())
    .setPurpose(purpose)
    .setIsShared(isShared)
    .setCreateTime(EnvironmentEdgeManager.currentTimeMillis()).build();
  byte[] lockMetadata = toBytes(data);

  InterProcessReadWriteLock lock = new ZKInterProcessReadWriteLock(zkWatcher, tableLockZNode,
    METADATA_HANDLER);
  return isShared ? lock.readLock(lockMetadata) : lock.writeLock(lockMetadata);
}

public void visitAllLocks(MetadataHandler handler) throws IOException {
  for (String tableName : getTableNames()) {
    String tableLockZNode = ZKUtil.joinZNode(zkWatcher.tableLockZNode, tableName);
    ZKInterProcessReadWriteLock lock = new ZKInterProcessReadWriteLock(
        zkWatcher, tableLockZNode, null);
    lock.readLock(null).visitLocks(handler);
    lock.writeLock(null).visitLocks(handler);
  }
}

public void visitAllLocks(MetadataHandler handler) throws IOException {
  for (String tableName : getTableNames()) {
    String tableLockZNode = ZKUtil.joinZNode(zkWatcher.tableLockZNode, tableName);
    ZKInterProcessReadWriteLock lock = new ZKInterProcessReadWriteLock(
        zkWatcher, tableLockZNode, null);
    lock.readLock(null).visitLocks(handler);
    lock.writeLock(null).visitLocks(handler);
  }
}

public void visitAllLocks(MetadataHandler handler) throws IOException {
  for (String tableName : getTableNames()) {
    String tableLockZNode = ZKUtil.joinZNode(zkWatcher.tableLockZNode, tableName);
    ZKInterProcessReadWriteLock lock = new ZKInterProcessReadWriteLock(
        zkWatcher, tableLockZNode, null);
    lock.readLock(null).visitLocks(handler);
    lock.writeLock(null).visitLocks(handler);
  }
}

public void visitAllLocks(MetadataHandler handler) throws IOException {
  for (String tableName : getTableNames()) {
    String tableLockZNode = ZKUtil.joinZNode(zkWatcher.tableLockZNode, tableName);
    ZKInterProcessReadWriteLock lock = new ZKInterProcessReadWriteLock(
        zkWatcher, tableLockZNode, null);
    lock.readLock(null).visitLocks(handler);
    lock.writeLock(null).visitLocks(handler);
  }
}

public void visitAllLocks(MetadataHandler handler) throws IOException {
  for (String tableName : getTableNames()) {
    String tableLockZNode = ZKUtil.joinZNode(zkWatcher.tableLockZNode, tableName);
    ZKInterProcessReadWriteLock lock = new ZKInterProcessReadWriteLock(
        zkWatcher, tableLockZNode, null);
    lock.readLock(null).visitLocks(handler);
    lock.writeLock(null).visitLocks(handler);
  }
}