org.I0Itec.zkclient.exception.ZkInterruptedException.<init>()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(6.0k)|赞(0)|评价(0)|浏览(118)

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

ZkInterruptedException.<init>介绍

暂无

代码示例

代码示例来源:origin: com.101tec/zkclient

public InMemoryConnection() {
  try {
    create("/", null, CreateMode.PERSISTENT);
  } catch (KeeperException e) {
    throw ZkException.create(e);
  } catch (InterruptedException e) {
    Thread.currentThread().interrupt();
    throw new ZkInterruptedException(e);
  }
}

代码示例来源:origin: com.github.sgroschupf/zkclient

public InMemoryConnection() {
  try {
    create("/", null, CreateMode.PERSISTENT);
  } catch (KeeperException e) {
    throw ZkException.create(e);
  } catch (InterruptedException e) {
    Thread.currentThread().interrupt();
    throw new ZkInterruptedException(e);
  }
}

代码示例来源:origin: com.101tec/zkclient

private void acquireEventLock() {
  try {
    getEventLock().lockInterruptibly();
  } catch (InterruptedException e) {
    throw new ZkInterruptedException(e);
  }
}

代码示例来源:origin: com.alibaba.otter/shared.common

private void acquireEventLock() {
  try {
    getEventLock().lockInterruptibly();
  } catch (InterruptedException e) {
    throw new ZkInterruptedException(e);
  }
}

代码示例来源:origin: com.github.sgroschupf/zkclient

private void acquireEventLock() {
  try {
    getEventLock().lockInterruptibly();
  } catch (InterruptedException e) {
    throw new ZkInterruptedException(e);
  }
}

代码示例来源:origin: org.apache.helix/helix-core

private void acquireEventLock() {
 try {
  getEventLock().lockInterruptibly();
 } catch (InterruptedException e) {
  throw new ZkInterruptedException(e);
 }
}

代码示例来源:origin: apache/helix

private void acquireEventLock() {
 try {
  getEventLock().lockInterruptibly();
 } catch (InterruptedException e) {
  throw new ZkInterruptedException(e);
 }
}

代码示例来源:origin: com.github.sgroschupf/zkclient

private void startSingleZkServer(final int tickTime, final File dataDir, final File dataLogDir, final int port) {
  try {
    _zk = new ZooKeeperServer(dataDir, dataLogDir, tickTime);
    _zk.setMinSessionTimeout(_minSessionTimeout);
    _nioFactory = new NIOServerCnxn.Factory(new InetSocketAddress(port));
    _nioFactory.startup(_zk);
  } catch (IOException e) {
    throw new ZkException("Unable to start single ZooKeeper server.", e);
  } catch (InterruptedException e) {
    throw new ZkInterruptedException(e);
  }
}

代码示例来源:origin: com.101tec/zkclient

private void startSingleZkServer(final int tickTime, final File dataDir, final File dataLogDir, final int port) {
  try {
    _zk = new ZooKeeperServer(dataDir, dataLogDir, tickTime);
    _zk.setMinSessionTimeout(_minSessionTimeout);
    _nioFactory = new NIOServerCnxnFactory();
    int maxClientConnections = 0; // 0 means unlimited
    _nioFactory.configure(new InetSocketAddress(port), maxClientConnections);
    _nioFactory.startup(_zk);
  } catch (IOException e) {
    throw new ZkException("Unable to start single ZooKeeper server.", e);
  } catch (InterruptedException e) {
    throw new ZkInterruptedException(e);
  }
}

代码示例来源:origin: com.101tec/zkclient

public long getCreationTime(String path) {
  acquireEventLock();
  try {
    return _connection.getCreateTime(path);
  } catch (KeeperException e) {
    throw ZkException.create(e);
  } catch (InterruptedException e) {
    throw new ZkInterruptedException(e);
  } finally {
    getEventLock().unlock();
  }
}

代码示例来源:origin: org.apache.helix/helix-core

public long getCreationTime(String path) {
 acquireEventLock();
 try {
  return _connection.getCreateTime(path);
 } catch (KeeperException e) {
  throw ZkException.create(e);
 } catch (InterruptedException e) {
  throw new ZkInterruptedException(e);
 } finally {
  getEventLock().unlock();
 }
}

代码示例来源:origin: apache/samza

@Test
public void testCloseShouldRetryOnceOnInterruptedException() {
 ZkClient zkClient = Mockito.mock(ZkClient.class);
 ZkUtils zkUtils = new ZkUtils(KEY_BUILDER, zkClient, CONNECTION_TIMEOUT_MS, SESSION_TIMEOUT_MS, new NoOpMetricsRegistry());
 Mockito.doThrow(new ZkInterruptedException(new InterruptedException()))
     .doAnswer(invocation -> null)
     .when(zkClient).close();
 zkUtils.close();
 Mockito.verify(zkClient, Mockito.times(2)).close();
}

代码示例来源:origin: com.101tec/zkclient

private void reconnect() {
  getEventLock().lock();
  try {
    _connection.close();
    _connection.connect(this);
  } catch (InterruptedException e) {
    throw new ZkInterruptedException(e);
  } finally {
    getEventLock().unlock();
  }
}

代码示例来源:origin: com.github.sgroschupf/zkclient

private void reconnect() {
  getEventLock().lock();
  try {
    _connection.close();
    _connection.connect(this);
  } catch (InterruptedException e) {
    throw new ZkInterruptedException(e);
  } finally {
    getEventLock().unlock();
  }
}

代码示例来源:origin: org.apache.helix/helix-core

private void reconnect() {
 getEventLock().lock();
 try {
  _connection.close();
  _connection.connect(this);
 } catch (InterruptedException e) {
  throw new ZkInterruptedException(e);
 } finally {
  getEventLock().unlock();
 }
}

代码示例来源:origin: apache/helix

private void reconnect() {
 getEventLock().lock();
 try {
  ZkConnection connection = ((ZkConnection) getConnection());
  connection.reconnect(this);
 } catch (InterruptedException e) {
  throw new ZkInterruptedException(e);
 } finally {
  getEventLock().unlock();
 }
}

代码示例来源:origin: apache/helix

public long getCreationTime(String path) {
 acquireEventLock();
 try {
  return getConnection().getCreateTime(path);
 } catch (KeeperException e) {
  throw ZkException.create(e);
 } catch (InterruptedException e) {
  throw new ZkInterruptedException(e);
 } finally {
  getEventLock().unlock();
 }
}

代码示例来源:origin: com.github.sgroschupf/zkclient

public long getCreationTime(String path) {
  try {
    getEventLock().lockInterruptibly();
    return _connection.getCreateTime(path);
  } catch (KeeperException e) {
    throw ZkException.create(e);
  } catch (InterruptedException e) {
    throw new ZkInterruptedException(e);
  } finally {
    getEventLock().unlock();
  }
}

代码示例来源:origin: com.alibaba.otter/shared.common

public long getCreationTime(String path) {
  try {
    getEventLock().lockInterruptibly();
    return _connection.getCreateTime(path);
  } catch (KeeperException e) {
    throw ZkException.create(e);
  } catch (InterruptedException e) {
    throw new ZkInterruptedException(e);
  } finally {
    getEventLock().unlock();
  }
}

代码示例来源:origin: com.alibaba.otter/shared.common

private void reconnect() {
  getEventLock().lock();
  try {
    _connection.close();
    _connection.connect(this);
  } catch (InterruptedException e) {
    throw new ZkInterruptedException(e);
  } finally {
    getEventLock().unlock();
  }
}

相关文章

ZkInterruptedException类方法