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

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

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

Node.isMaster介绍

暂无

代码示例

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

  1. @Override
  2. public boolean hasOnGoingMigration() {
  3.   return hasOnGoingMigrationLocal()
  4.       || (!node.isMaster() && partitionReplicaStateChecker.hasOnGoingMigrationMaster(Level.FINEST));
  5. }

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

  1. @Override
  2. public boolean hasOnGoingMigration() {
  3.   return hasOnGoingMigrationLocal()
  4.       || (!node.isMaster() && partitionReplicaStateChecker.hasOnGoingMigrationMaster(Level.FINEST));
  5. }

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

  1. public void onMessage(Object msg) {
  2.     if (msg instanceof SplitBrainJoinMessage) {
  3.       SplitBrainJoinMessage joinRequest = (SplitBrainJoinMessage) msg;
  4.       Address thisAddress = node.getThisAddress();
  5.       // only master nodes execute the SplitBrainHandler that processes SplitBrainJoinMessages
  6.       if (!thisAddress.equals(joinRequest.getAddress()) && node.isMaster()) {
  7.         deque.addFirst(joinRequest);
  8.       }
  9.     }
  10.   }
  11. }

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

  1. public void onMessage(Object msg) {
  2.     if (msg instanceof SplitBrainJoinMessage) {
  3.       SplitBrainJoinMessage joinRequest = (SplitBrainJoinMessage) msg;
  4.       Address thisAddress = node.getThisAddress();
  5.       // only master nodes execute the SplitBrainHandler that processes SplitBrainJoinMessages
  6.       if (!thisAddress.equals(joinRequest.getAddress()) && node.isMaster()) {
  7.         deque.addFirst(joinRequest);
  8.       }
  9.     }
  10.   }
  11. }

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

  1. @Override
  2. public PartitionRuntimeState firstArrangement() {
  3.   if (!node.isMaster()) {
  4.     triggerMasterToAssignPartitions();
  5.     return null;
  6.   }
  7.   lock.lock();
  8.   try {
  9.     if (!partitionStateManager.isInitialized()) {
  10.       Set<Address> excludedAddresses = migrationManager.getShutdownRequestedAddresses();
  11.       if (partitionStateManager.initializePartitionAssignments(excludedAddresses)) {
  12.         publishPartitionRuntimeState();
  13.       }
  14.     }
  15.     return createPartitionStateInternal();
  16.   } finally {
  17.     lock.unlock();
  18.   }
  19. }

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

  1. @Override
  2. public PartitionRuntimeState firstArrangement() {
  3.   if (!node.isMaster()) {
  4.     triggerMasterToAssignPartitions();
  5.     return null;
  6.   }
  7.   lock.lock();
  8.   try {
  9.     if (!partitionStateManager.isInitialized()) {
  10.       Set<Member> excludedMembers = migrationManager.getShutdownRequestedMembers();
  11.       if (partitionStateManager.initializePartitionAssignments(excludedMembers)) {
  12.         publishPartitionRuntimeState();
  13.       }
  14.     }
  15.     return createPartitionStateInternal();
  16.   } finally {
  17.     lock.unlock();
  18.   }
  19. }

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

  1. @Override
  2. public void memberAdded(Member member) {
  3.   logger.fine("Adding " + member);
  4.   lock.lock();
  5.   try {
  6.     lastMaster = node.getClusterService().getMasterAddress();
  7.     if (!member.localMember()) {
  8.       partitionStateManager.updateMemberGroupsSize();
  9.     }
  10.     if (node.isMaster()) {
  11.       if (partitionStateManager.isInitialized()) {
  12.         migrationManager.triggerControlTask();
  13.       }
  14.     }
  15.   } finally {
  16.     lock.unlock();
  17.   }
  18. }

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

  1. @Override
  2. public void memberAdded(MemberImpl member) {
  3.   logger.fine("Adding " + member);
  4.   lock.lock();
  5.   try {
  6.     lastMaster = node.getClusterService().getMasterAddress();
  7.     if (!member.localMember()) {
  8.       partitionStateManager.updateMemberGroupsSize();
  9.     }
  10.     if (node.isMaster()) {
  11.       if (partitionStateManager.isInitialized()) {
  12.         migrationManager.triggerControlTask();
  13.       }
  14.     }
  15.   } finally {
  16.     lock.unlock();
  17.   }
  18. }

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

  1. @Override
  2. public void memberAdded(MembershipEvent membershipEvent) {
  3.   try {
  4.     Member member = membershipEvent.getMember();
  5.     if (member != null && instance.node.isMaster() && urlChanged) {
  6.       UpdateManagementCenterUrlOperation operation
  7.           = new UpdateManagementCenterUrlOperation(managementCenterUrl);
  8.       resolveFuture(callOnMember(member, operation));
  9.     }
  10.   } catch (Exception e) {
  11.     logger.warning("Web server url cannot be send to the newly joined member", e);
  12.   }
  13. }

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

  1. @Override
  2. public void memberAdded(MembershipEvent membershipEvent) {
  3.   try {
  4.     Member member = membershipEvent.getMember();
  5.     if (member != null && instance.node.isMaster() && urlChanged) {
  6.       UpdateManagementCenterUrlOperation operation
  7.           = new UpdateManagementCenterUrlOperation(managementCenterUrl);
  8.       resolveFuture(callOnMember(member, operation));
  9.     }
  10.   } catch (Exception e) {
  11.     logger.warning("Web server url cannot be send to the newly joined member", e);
  12.   }
  13. }

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

  1. public PartitionServiceState getPartitionServiceState() {
  2.   if (partitionService.isFetchMostRecentPartitionTableTaskRequired()) {
  3.     return FETCHING_PARTITION_TABLE;
  4.   }
  5.   if (hasMissingReplicaOwners()) {
  6.     return REPLICA_NOT_OWNED;
  7.   }
  8.   if (migrationManager.hasOnGoingMigration()) {
  9.     return MIGRATION_LOCAL;
  10.   }
  11.   if (!node.isMaster() && hasOnGoingMigrationMaster(Level.OFF)) {
  12.     return MIGRATION_ON_MASTER;
  13.   }
  14.   if (!checkAndTriggerReplicaSync()) {
  15.     return REPLICA_NOT_SYNC;
  16.   }
  17.   return SAFE;
  18. }

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

  1. public PartitionServiceState getPartitionServiceState() {
  2.   if (partitionService.isFetchMostRecentPartitionTableTaskRequired()) {
  3.     return FETCHING_PARTITION_TABLE;
  4.   }
  5.   if (hasMissingReplicaOwners()) {
  6.     return REPLICA_NOT_OWNED;
  7.   }
  8.   if (migrationManager.hasOnGoingMigration()) {
  9.     return MIGRATION_LOCAL;
  10.   }
  11.   if (!node.isMaster() && hasOnGoingMigrationMaster(Level.OFF)) {
  12.     return MIGRATION_ON_MASTER;
  13.   }
  14.   if (!checkAndTriggerReplicaSync()) {
  15.     return REPLICA_NOT_SYNC;
  16.   }
  17.   return SAFE;
  18. }

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

  1. @Override
  2. public void replicaChanged(PartitionReplicaChangeEvent event) {
  3.   final int partitionId = event.getPartitionId();
  4.   final int replicaIndex = event.getReplicaIndex();
  5.   if (replicaIndex == 0) {
  6.     partitionService.getReplicaManager().cancelReplicaSync(partitionId);
  7.   }
  8.   if (node.isMaster()) {
  9.     partitionService.getPartitionStateManager().incrementVersion();
  10.   }
  11.   callListeners(event);
  12. }

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

  1. @Override
  2. public void replicaChanged(PartitionReplicaChangeEvent event) {
  3.   final int partitionId = event.getPartitionId();
  4.   final int replicaIndex = event.getReplicaIndex();
  5.   if (replicaIndex == 0) {
  6.     partitionService.getReplicaManager().cancelReplicaSync(partitionId);
  7.   }
  8.   if (node.isMaster()) {
  9.     partitionService.getPartitionStateManager().incrementVersion();
  10.   }
  11.   callListeners(event);
  12. }

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

  1. @Override
  2. public Address getPartitionOwner(int partitionId) {
  3.   if (!partitionStateManager.isInitialized()) {
  4.     firstArrangement();
  5.   }
  6.   final InternalPartition partition = partitionStateManager.getPartitionImpl(partitionId);
  7.   if (partition.getOwnerReplicaOrNull() == null && !node.isMaster()) {
  8.     if (!isClusterFormedByOnlyLiteMembers()) {
  9.       triggerMasterToAssignPartitions();
  10.     }
  11.   }
  12.   return partition.getOwnerOrNull();
  13. }

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

  1. @Override
  2. public Address getPartitionOwner(int partitionId) {
  3.   if (!partitionStateManager.isInitialized()) {
  4.     firstArrangement();
  5.   }
  6.   final InternalPartition partition = partitionStateManager.getPartitionImpl(partitionId);
  7.   if (partition.getOwnerOrNull() == null && !node.isMaster()) {
  8.     if (!isClusterFormedByOnlyLiteMembers()) {
  9.       triggerMasterToAssignPartitions();
  10.     }
  11.   }
  12.   return partition.getOwnerOrNull();
  13. }

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

  1. void sendPartitionRuntimeState(Address target) {
  2.   assert partitionStateManager.isInitialized();
  3.   assert node.isMaster();
  4.   assert areMigrationTasksAllowed();
  5.   PartitionRuntimeState partitionState = createPartitionStateInternal();
  6.   assert partitionState != null;
  7.   if (logger.isFineEnabled()) {
  8.     logger.fine("Sending partition state, version: " + partitionState.getVersion() + ", to " + target);
  9.   }
  10.   OperationService operationService = nodeEngine.getOperationService();
  11.   PartitionStateOperation op = new PartitionStateOperation(partitionState, true);
  12.   operationService.invokeOnTarget(SERVICE_NAME, op, target);
  13. }

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

  1. /** Clears the migration queue and triggers the control task. Called on the master node. */
  2. void triggerControlTask() {
  3.   migrationQueue.clear();
  4.   if (!node.getClusterService().isJoined()) {
  5.     logger.fine("Node is not joined, will not trigger ControlTask");
  6.     return;
  7.   }
  8.   if (!node.isMaster()) {
  9.     logger.fine("Node is not master, will not trigger ControlTask");
  10.     return;
  11.   }
  12.   migrationQueue.add(new ControlTask());
  13.   if (logger.isFinestEnabled()) {
  14.     logger.finest("Migration queue is cleared and control task is scheduled");
  15.   }
  16. }

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

  1. /** Clears the migration queue and triggers the control task. Called on the master node. */
  2. void triggerControlTask() {
  3.   migrationQueue.clear();
  4.   if (!node.getClusterService().isJoined()) {
  5.     logger.fine("Node is not joined, will not trigger ControlTask");
  6.     return;
  7.   }
  8.   if (!node.isMaster()) {
  9.     logger.fine("Node is not master, will not trigger ControlTask");
  10.     return;
  11.   }
  12.   migrationQueue.add(new ControlTask());
  13.   if (logger.isFinestEnabled()) {
  14.     logger.finest("Migration queue is cleared and control task is scheduled");
  15.   }
  16. }

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

  1. @Override
  2.   public void run() {
  3.     if (node.isMaster()) {
  4.       MigrationManager migrationManager = partitionService.getMigrationManager();
  5.       boolean migrationAllowed = migrationManager.isMigrationAllowed()
  6.           && !partitionService.isFetchMostRecentPartitionTableTaskRequired();
  7.       if (!migrationAllowed) {
  8.         logger.fine("Not publishing partition runtime state since migration is not allowed.");
  9.         return;
  10.       }
  12.       if (migrationManager.hasOnGoingMigration()) {
  13.         logger.info("Remaining migration tasks in queue => " + partitionService.getMigrationQueueSize());
  14.       }
  16.       if (node.getState() == NodeState.ACTIVE) {
  17.         partitionService.publishPartitionRuntimeState();
  18.       }
  19.     }
  20.   }
  21. }

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

Node

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Node类方法

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