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

ZenPing介绍

暂无

代码示例

代码示例来源：origin: org.elasticsearch/elasticsearch

private ZenPing.PingCollection pingAndWait(TimeValue timeout) {
  final CompletableFuture<ZenPing.PingCollection> response = new CompletableFuture<>();
  try {
    zenPing.ping(response::complete, timeout);
  } catch (Exception ex) {
    // logged later
    response.completeExceptionally(ex);
  }
  try {
    return response.get();
  } catch (InterruptedException e) {
    logger.trace("pingAndWait interrupted");
    return new ZenPing.PingCollection();
  } catch (ExecutionException e) {
    logger.warn("Ping execution failed", e);
    return new ZenPing.PingCollection();
  }
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Override
protected void doStart() {
  DiscoveryNode localNode = transportService.getLocalNode();
  assert localNode != null;
  synchronized (stateMutex) {
    // set initial state
    assert committedState.get() == null;
    assert localNode != null;
    ClusterState.Builder builder = clusterApplier.newClusterStateBuilder();
    ClusterState initialState = builder
      .blocks(ClusterBlocks.builder()
        .addGlobalBlock(STATE_NOT_RECOVERED_BLOCK)
        .addGlobalBlock(discoverySettings.getNoMasterBlock()))
      .nodes(DiscoveryNodes.builder().add(localNode).localNodeId(localNode.getId()))
      .build();
    committedState.set(initialState);
    clusterApplier.setInitialState(initialState);
    nodesFD.setLocalNode(localNode);
    joinThreadControl.start();
  }
  zenPing.start();
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

private ZenPing.PingCollection pingAndWait(TimeValue timeout) {
  final CompletableFuture<ZenPing.PingCollection> response = new CompletableFuture<>();
  try {
    zenPing.ping(response::complete, timeout);
  } catch (Exception ex) {
    // logged later
    response.completeExceptionally(ex);
  }
  try {
    return response.get();
  } catch (InterruptedException e) {
    logger.trace("pingAndWait interrupted");
    return new ZenPing.PingCollection();
  } catch (ExecutionException e) {
    logger.warn("Ping execution failed", e);
    return new ZenPing.PingCollection();
  }
}

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

@Override
protected void doStart() {
  nodesFD.setLocalNode(clusterService.localNode());
  joinThreadControl.start();
  zenPing.start(this);
  this.nodeJoinController = new NodeJoinController(clusterService, allocationService, electMaster, settings);
  this.nodeRemovalExecutor = new NodeRemovalClusterStateTaskExecutor(allocationService, electMaster, this::submitRejoin, logger);
}

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

private ZenPing.PingCollection pingAndWait(TimeValue timeout) {
  final CompletableFuture<ZenPing.PingCollection> response = new CompletableFuture<>();
  try {
    zenPing.ping(response::complete, timeout);
  } catch (Exception ex) {
    // logged later
    response.completeExceptionally(ex);
  }
  try {
    return response.get();
  } catch (InterruptedException e) {
    logger.trace("pingAndWait interrupted");
    return new ZenPing.PingCollection();
  } catch (ExecutionException e) {
    logger.warn("Ping execution failed", e);
    return new ZenPing.PingCollection();
  }
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

@Override
protected void doStart() {
  DiscoveryNode localNode = transportService.getLocalNode();
  assert localNode != null;
  synchronized (stateMutex) {
    // set initial state
    assert committedState.get() == null;
    assert localNode != null;
    ClusterState.Builder builder = clusterApplier.newClusterStateBuilder();
    ClusterState initialState = builder
      .blocks(ClusterBlocks.builder()
        .addGlobalBlock(STATE_NOT_RECOVERED_BLOCK)
        .addGlobalBlock(discoverySettings.getNoMasterBlock()))
      .nodes(DiscoveryNodes.builder().add(localNode).localNodeId(localNode.getId()))
      .build();
    committedState.set(initialState);
    clusterApplier.setInitialState(initialState);
    nodesFD.setLocalNode(localNode);
    joinThreadControl.start();
  }
  zenPing.start();
}

代码示例来源：origin: apache/servicemix-bundles

private ZenPing.PingCollection pingAndWait(TimeValue timeout) {
  final CompletableFuture<ZenPing.PingCollection> response = new CompletableFuture<>();
  try {
    zenPing.ping(response::complete, timeout);
  } catch (Exception ex) {
    // logged later
    response.completeExceptionally(ex);
  }
  try {
    return response.get();
  } catch (InterruptedException e) {
    logger.trace("pingAndWait interrupted");
    return new ZenPing.PingCollection();
  } catch (ExecutionException e) {
    logger.warn("Ping execution failed", e);
    return new ZenPing.PingCollection();
  }
}

代码示例来源：origin: apache/servicemix-bundles

@Override
protected void doStart() {
  DiscoveryNode localNode = transportService.getLocalNode();
  assert localNode != null;
  synchronized (stateMutex) {
    // set initial state
    assert committedState.get() == null;
    assert localNode != null;
    ClusterState.Builder builder = clusterApplier.newClusterStateBuilder();
    ClusterState initialState = builder
      .blocks(ClusterBlocks.builder()
        .addGlobalBlock(STATE_NOT_RECOVERED_BLOCK)
        .addGlobalBlock(discoverySettings.getNoMasterBlock()))
      .nodes(DiscoveryNodes.builder().add(localNode).localNodeId(localNode.getId()))
      .build();
    committedState.set(initialState);
    clusterApplier.setInitialState(initialState);
    nodesFD.setLocalNode(localNode);
    joinThreadControl.start();
  }
  zenPing.start();
}