com.hazelcast.instance.Node.getLocalMember()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(8.0k)|赞(0)|评价(0)|浏览(303)

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

Node.getLocalMember介绍

暂无

代码示例

代码示例来源：origin: hazelcast/hazelcast-jet

  1. @Override
  2. public MemberImpl getLocalMember() {
  3.   return node.getLocalMember();
  4. }

代码示例来源：origin: hazelcast/hazelcast-jet

  1. @Override
  2. public MemberImpl getLocalMember() {
  3.   return node.getLocalMember();
  4. }

代码示例来源：origin: hazelcast/hazelcast-jet

  1. @Override
  2. public Member getLocalEndpoint() {
  3.   return node.getLocalMember();
  4. }

代码示例来源：origin: com.hazelcast/hazelcast-all

  1. @Override
  2. public MemberImpl getLocalMember() {
  3.   return node.getLocalMember();
  4. }

代码示例来源：origin: com.hazelcast/hazelcast-all

  1. @Override
  2. public Member getLocalEndpoint() {
  3.   return node.getLocalMember();
  4. }

代码示例来源：origin: com.hazelcast/hazelcast-all

  1. @Override
  2. public MemberImpl getLocalMember() {
  3.   return node.getLocalMember();
  4. }

代码示例来源：origin: com.hazelcast/hazelcast-all

  1. public boolean isLiteMember() {
  2.   return getLocalMember().isLiteMember();
  3. }

代码示例来源：origin: hazelcast/hazelcast-jet

  1. public boolean isLiteMember() {
  2.   return getLocalMember().isLiteMember();
  3. }

代码示例来源：origin: hazelcast/hazelcast-jet

  1. void reset() {
  2.   initialized = false;
  3.   stateVersion.set(0);
  4.   // local member uuid changes during ClusterService reset
  5.   PartitionReplica localReplica = PartitionReplica.from(node.getLocalMember());
  6.   for (InternalPartitionImpl partition : partitions) {
  7.     partition.reset(localReplica);
  8.   }
  9. }

代码示例来源：origin: hazelcast/hazelcast-code-samples

  1. private static void closeConnectionBetween(HazelcastInstance h1, HazelcastInstance h2) {
  2.     if (h1 == null || h2 == null) {
  3.       return;
  4.     }
  5.     Node n1 = getNode(h1);
  6.     Node n2 = getNode(h2);
  7.     if (n1 != null && n2 != null) {
  8.       n1.clusterService.suspectMember(n2.getLocalMember(), null, true);
  9.       n2.clusterService.suspectMember(n1.getLocalMember(), null, true);
  10.     }
  11.   }
  12. }

代码示例来源：origin: hazelcast/hazelcast-jet

  1. public void reset() {
  2.   Throwable cause = new LocalMemberResetException(node.getLocalMember() + " has reset.");
  3.   invocationRegistry.reset(cause);
  4. }

代码示例来源：origin: com.hazelcast/hazelcast-all

  1. public void reset() {
  2.   Throwable cause = new LocalMemberResetException(node.getLocalMember() + " has reset.");
  3.   invocationRegistry.reset(cause);
  4. }

代码示例来源：origin: hazelcast/hazelcast-jet

  1. private void logMigrationCommitFailure(MigrationInfo migration, Throwable t) {
  2.   boolean memberLeft = t instanceof MemberLeftException
  3.         || t.getCause() instanceof TargetNotMemberException
  4.         || t.getCause() instanceof HazelcastInstanceNotActiveException;
  5.   PartitionReplica destination = migration.getDestination();
  6.   if (memberLeft) {
  7.     if (destination.isIdentical(node.getLocalMember())) {
  8.       logger.fine("Migration commit failed for " + migration
  9.           + " since this node is shutting down.");
  10.       return;
  11.     }
  12.     logger.warning("Migration commit failed for " + migration
  13.           + " since destination " + destination + " left the cluster");
  14.   } else {
  15.     logger.severe("Migration commit to " + destination + " failed for " + migration, t);
  16.   }
  17. }

代码示例来源：origin: hazelcast/hazelcast-jet

  1. public PartitionStateManager(Node node, InternalPartitionServiceImpl partitionService, PartitionListener listener) {
  2.   this.node = node;
  3.   this.logger = node.getLogger(getClass());
  4.   this.partitionService = partitionService;
  5.   this.partitionCount = partitionService.getPartitionCount();
  6.   this.partitions = new InternalPartitionImpl[partitionCount];
  7.   PartitionReplica localReplica = PartitionReplica.from(node.getLocalMember());
  8.   for (int i = 0; i < partitionCount; i++) {
  9.     this.partitions[i] = new InternalPartitionImpl(i, listener, localReplica);
  10.   }
  11.   memberGroupFactory = MemberGroupFactoryFactory.newMemberGroupFactory(node.getConfig().getPartitionGroupConfig(),
  12.       node.getDiscoveryService());
  13.   partitionStateGenerator = new PartitionStateGeneratorImpl();
  14. }

代码示例来源：origin: hazelcast/hazelcast-jet

  1. private void ensureNoPartitionProblems(Operation op) {
  2.   int partitionId = op.getPartitionId();
  3.   if (partitionId < 0) {
  4.     return;
  5.   }
  6.   if (partitionId != getPartitionId()) {
  7.     throw new IllegalStateException("wrong partition, expected: " + getPartitionId() + " but found:" + partitionId);
  8.   }
  9.   if (internalPartition == null) {
  10.     internalPartition = nodeEngine.getPartitionService().getPartition(partitionId);
  11.   }
  12.   if (!isAllowedToRetryDuringMigration(op) && internalPartition.isMigrating()) {
  13.     throw new PartitionMigratingException(thisAddress, partitionId,
  14.         op.getClass().getName(), op.getServiceName());
  15.   }
  16.   PartitionReplica owner = internalPartition.getReplica(op.getReplicaIndex());
  17.   if (op.validatesTarget() && (owner == null || !owner.isIdentical(node.getLocalMember()))) {
  18.     Member target = owner != null ? node.getClusterService().getMember(owner.address(), owner.uuid()) : null;
  19.     throw new WrongTargetException(node.getLocalMember(), target, partitionId, op.getReplicaIndex(),
  20.         op.getClass().getName(), op.getServiceName());
  21.   }
  22. }

代码示例来源：origin: hazelcast/hazelcast-jet

  1. /**
  2.  * Sends promotions to the destination and commits the {@code migrations} if successful. Called on the master node.
  3.  *
  4.  * @param destination the promotion destination
  5.  * @param migrations  the promotion migrations
  6.  * @return if the promotions were successful
  7.  */
  8. private boolean commitPromotionMigrations(PartitionReplica destination, Collection<MigrationInfo> migrations) {
  9.   internalMigrationListener.onPromotionStart(MigrationParticipant.MASTER, migrations);
  10.   boolean success = commitPromotionsToDestination(destination, migrations);
  11.   boolean local = destination.isIdentical(node.getLocalMember());
  12.   if (!local) {
  13.     processPromotionCommitResult(destination, migrations, success);
  14.   }
  15.   internalMigrationListener.onPromotionComplete(MigrationParticipant.MASTER, migrations, success);
  16.   partitionService.publishPartitionRuntimeState();
  17.   return success;
  18. }

代码示例来源：origin: hazelcast/hazelcast-jet

  1. public JoinRequest createJoinRequest(boolean withCredentials) {
  2.   final Credentials credentials = (withCredentials && securityContext != null)
  3.       ? securityContext.getCredentialsFactory().newCredentials() : null;
  4.   final Set<String> excludedMemberUuids = nodeExtension.getInternalHotRestartService().getExcludedMemberUuids();
  5.   MemberImpl localMember = getLocalMember();
  6.   return new JoinRequest(Packet.VERSION, buildInfo.getBuildNumber(), version, address,
  7.       localMember.getUuid(), localMember.isLiteMember(), createConfigCheck(), credentials,
  8.       localMember.getAttributes(), excludedMemberUuids);
  9. }

代码示例来源：origin: com.hazelcast/hazelcast-all

  1. public JoinRequest createJoinRequest(boolean withCredentials) {
  2.   final Credentials credentials = (withCredentials && securityContext != null)
  3.       ? securityContext.getCredentialsFactory().newCredentials() : null;
  4.   final Set<String> excludedMemberUuids = nodeExtension.getInternalHotRestartService().getExcludedMemberUuids();
  5.   MemberImpl localMember = getLocalMember();
  6.   return new JoinRequest(Packet.VERSION, buildInfo.getBuildNumber(), version, address,
  7.       localMember.getUuid(), localMember.isLiteMember(), createConfigCheck(), credentials,
  8.       localMember.getAttributes(), excludedMemberUuids);
  9. }

代码示例来源：origin: hazelcast/hazelcast-jet

  1. public SplitBrainJoinMessage createSplitBrainJoinMessage() {
  2.   MemberImpl localMember = getLocalMember();
  3.   boolean liteMember = localMember.isLiteMember();
  4.   Collection<Address> memberAddresses = clusterService.getMemberAddresses();
  5.   int dataMemberCount = clusterService.getSize(DATA_MEMBER_SELECTOR);
  6.   Version clusterVersion = clusterService.getClusterVersion();
  7.   int memberListVersion = clusterService.getMembershipManager().getMemberListVersion();
  8.   return new SplitBrainJoinMessage(Packet.VERSION, buildInfo.getBuildNumber(), version, address, localMember.getUuid(),
  9.       liteMember, createConfigCheck(), memberAddresses, dataMemberCount, clusterVersion, memberListVersion);
  10. }

代码示例来源：origin: com.hazelcast/hazelcast-all

  1. public SplitBrainJoinMessage createSplitBrainJoinMessage() {
  2.   MemberImpl localMember = getLocalMember();
  3.   boolean liteMember = localMember.isLiteMember();
  4.   Collection<Address> memberAddresses = clusterService.getMemberAddresses();
  5.   int dataMemberCount = clusterService.getSize(DATA_MEMBER_SELECTOR);
  6.   Version clusterVersion = clusterService.getClusterVersion();
  7.   int memberListVersion = clusterService.getMembershipManager().getMemberListVersion();
  8.   return new SplitBrainJoinMessage(Packet.VERSION, buildInfo.getBuildNumber(), version, address, localMember.getUuid(),
  9.       liteMember, createConfigCheck(), memberAddresses, dataMemberCount, clusterVersion, memberListVersion);
  10. }

内容来源于网络，如有侵权，请联系作者删除！

Node

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Node类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com