本文整理了Java中com.hazelcast.instance.Node.getNodeExtension()
方法的一些代码示例,展示了Node.getNodeExtension()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Node.getNodeExtension()
方法的具体详情如下:
包路径:com.hazelcast.instance.Node
类名称:Node
方法名:getNodeExtension
暂无
代码示例来源:origin: hazelcast/hazelcast-jet
boolean setInitialized() {
if (!initialized) {
initialized = true;
node.getNodeExtension().onPartitionStateChange();
return true;
}
return false;
}
代码示例来源:origin: hazelcast/hazelcast-jet
private void notifyBeforeStateChange(ClusterState oldState, ClusterState requestedState, boolean isTransient) {
if (requestedState != null) {
node.getNodeExtension().beforeClusterStateChange(oldState, requestedState, isTransient);
}
}
代码示例来源:origin: com.hazelcast/hazelcast-all
private void notifyBeforeStateChange(ClusterState oldState, ClusterState requestedState, boolean isTransient) {
if (requestedState != null) {
node.getNodeExtension().beforeClusterStateChange(oldState, requestedState, isTransient);
}
}
代码示例来源:origin: hazelcast/hazelcast-jet
private void setClusterStateAndVersion(ClusterState newState, Version newVersion, boolean isTransient) {
this.state = newState;
this.clusterVersion = newVersion;
stateLockRef.set(LockGuard.NOT_LOCKED);
changeNodeState(newState);
node.getNodeExtension().onClusterStateChange(newState, isTransient);
node.getNodeExtension().onClusterVersionChange(newVersion);
}
代码示例来源:origin: hazelcast/hazelcast-jet
private void doSetClusterState(ClusterState newState, boolean isTransient) {
this.state = newState;
stateLockRef.set(LockGuard.NOT_LOCKED);
changeNodeState(newState);
node.getNodeExtension().onClusterStateChange(newState, isTransient);
}
代码示例来源:origin: hazelcast/hazelcast-jet
private <T> T createService(Class<T> service) {
Node node = nodeEngine.getNode();
NodeExtension nodeExtension = node.getNodeExtension();
return nodeExtension.createService(service);
}
代码示例来源:origin: hazelcast/hazelcast-jet
private void createClusterHotRestartStatus(MemberStateImpl memberState) {
final ClusterHotRestartStatusDTO state =
instance.node.getNodeExtension().getInternalHotRestartService().getCurrentClusterHotRestartStatus();
memberState.setClusterHotRestartStatus(state);
}
代码示例来源:origin: hazelcast/hazelcast-jet
/** Verifies that the node startup is completed. */
private void verifyNodeStarted() {
NodeEngineImpl nodeEngine = (NodeEngineImpl) getNodeEngine();
nodeStartCompleted = nodeEngine.getNode().getNodeExtension().isStartCompleted();
if (!nodeStartCompleted) {
throw new IllegalStateException("Migration operation is received before startup is completed. "
+ "Sender: " + getCallerAddress());
}
}
代码示例来源:origin: com.hazelcast/hazelcast-all
/** Verifies that the node startup is completed. */
private void verifyNodeStarted() {
NodeEngineImpl nodeEngine = (NodeEngineImpl) getNodeEngine();
nodeStartCompleted = nodeEngine.getNode().getNodeExtension().isStartCompleted();
if (!nodeStartCompleted) {
throw new IllegalStateException("Migration operation is received before startup is completed. "
+ "Sender: " + getCallerAddress());
}
}
代码示例来源:origin: hazelcast/hazelcast-jet
@Override
public void writeResponse(ManagementCenterService mcs, JsonObject out) throws Exception {
Node node = mcs.getHazelcastInstance().node;
final InternalHotRestartService hotRestartService = node.getNodeExtension().getInternalHotRestartService();
final boolean done = hotRestartService.triggerPartialStart();
String result = done ? SUCCESS_RESULT : FAILED_RESULT;
out.add("result", result);
}
代码示例来源:origin: com.hazelcast/hazelcast-all
void onMemberRemove(MemberImpl deadMember) {
// sync calls
node.getPartitionService().memberRemoved(deadMember);
nodeEngine.onMemberLeft(deadMember);
node.getNodeExtension().onMemberListChange();
}
代码示例来源:origin: hazelcast/hazelcast-jet
private boolean isMemberExcludedFromHotRestart() {
final NodeExtension nodeExtension = node.getNodeExtension();
return !nodeExtension.isStartCompleted()
&& nodeExtension.getInternalHotRestartService().isMemberExcluded(node.getThisAddress(), node.getThisUuid());
}
代码示例来源:origin: hazelcast/hazelcast-jet
public SystemLogPlugin(NodeEngineImpl nodeEngine) {
this(nodeEngine.getProperties(),
nodeEngine.getNode().connectionManager,
nodeEngine.getHazelcastInstance(),
nodeEngine.getLogger(SystemLogPlugin.class),
nodeEngine.getNode().getNodeExtension());
}
代码示例来源:origin: com.hazelcast/hazelcast-all
private boolean shouldResetHotRestartData() {
final NodeExtension nodeExtension = node.getNodeExtension();
return !nodeExtension.isStartCompleted()
&& nodeExtension.getInternalHotRestartService().isMemberExcluded(node.getThisAddress(), node.getThisUuid());
}
代码示例来源:origin: hazelcast/hazelcast-jet
private void createHotRestartState(MemberStateImpl memberState) {
final HotRestartService hotRestartService = instance.node.getNodeExtension().getHotRestartService();
boolean hotBackupEnabled = hotRestartService.isHotBackupEnabled();
String hotBackupDirectory = hotRestartService.getBackupDirectory();
final HotRestartStateImpl state = new HotRestartStateImpl(hotRestartService.getBackupTaskStatus(),
hotBackupEnabled, hotBackupDirectory);
memberState.setHotRestartState(state);
}
代码示例来源:origin: hazelcast/hazelcast-jet
@Override
public final void join() {
blacklistedAddresses.clear();
doJoin();
if (!clusterService.isJoined() && isMemberExcludedFromHotRestart()) {
logger.warning("Could not join to the cluster because hot restart data must be reset.");
node.getNodeExtension().getInternalHotRestartService().forceStartBeforeJoin();
reset();
doJoin();
}
postJoin();
}
代码示例来源:origin: com.hazelcast/hazelcast-all
@Override
public final void join() {
blacklistedAddresses.clear();
doJoin();
if (!clusterService.isJoined() && shouldResetHotRestartData()) {
logger.warning("Could not join to the cluster because hot restart data must be reset.");
node.getNodeExtension().getInternalHotRestartService().resetHotRestartData();
reset();
doJoin();
}
postJoin();
}
代码示例来源:origin: hazelcast/hazelcast-jet
@Override
public void run() {
if (!node.isRunning() || !node.getNodeExtension().isStartCompleted()
|| !partitionService.areMigrationTasksAllowed()) {
return;
}
nodeEngine.getOperationService().executeOnPartitions(new PartitionAntiEntropyTaskFactory(), getLocalPartitions());
}
代码示例来源:origin: hazelcast/hazelcast-jet
void initializeAndProcessMessage() throws Throwable {
if (!node.getNodeExtension().isStartCompleted()) {
throw new HazelcastInstanceNotActiveException("Hazelcast instance is not ready yet!");
}
parameters = decodeClientMessage(clientMessage);
Credentials credentials = endpoint.getCredentials();
interceptBefore(credentials);
checkPermissions(endpoint);
processMessage();
interceptAfter(credentials);
}
代码示例来源:origin: hazelcast/hazelcast-jet
private boolean isNodeStartCompleted() {
NodeEngineImpl nodeEngine = (NodeEngineImpl) getNodeEngine();
boolean startCompleted = nodeEngine.getNode().getNodeExtension().isStartCompleted();
if (!startCompleted) {
ILogger logger = getLogger();
if (logger.isFinestEnabled()) {
logger.finest("Anti-entropy operation for partitionId=" + getPartitionId()
+ ", replicaIndex=" + getReplicaIndex() + " is received before startup is completed.");
}
}
return startCompleted;
}
内容来源于网络,如有侵权,请联系作者删除!