本文整理了Java中com.hazelcast.instance.Node.isLiteMember()
方法的一些代码示例,展示了Node.isLiteMember()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Node.isLiteMember()
方法的具体详情如下:
包路径:com.hazelcast.instance.Node
类名称:Node
方法名:isLiteMember
暂无
代码示例来源:origin: hazelcast/hazelcast-jet
int getMemberGroupsSize() {
int size = memberGroupsSize;
if (size > 0) {
return size;
}
// size = 0 means service is not initialized yet.
// return 1 if current node is a data member since there should be at least one member group
return node.isLiteMember() ? 0 : 1;
}
代码示例来源:origin: com.hazelcast/hazelcast-all
int getMemberGroupsSize() {
int size = memberGroupsSize;
if (size > 0) {
return size;
}
// size = 0 means service is not initialized yet.
// return 1 if current node is a data member since there should be at least one member group
return node.isLiteMember() ? 0 : 1;
}
代码示例来源:origin: hazelcast/hazelcast-jet
if (node.isLiteMember()) {
return true;
代码示例来源:origin: com.hazelcast/hazelcast-all
if (node.isLiteMember()) {
return true;
代码示例来源:origin: hazelcast/hazelcast-jet
/**
* Send a {@link WhoisMasterOp} to designated address.
*
* @param toAddress the address to which the operation will be sent.
* @return {@code true} if the operation was sent, otherwise {@code false}.
*/
public boolean sendMasterQuestion(Address toAddress) {
checkNotNull(toAddress, "No endpoint is specified!");
BuildInfo buildInfo = node.getBuildInfo();
final Address thisAddress = node.getThisAddress();
JoinMessage joinMessage = new JoinMessage(Packet.VERSION, buildInfo.getBuildNumber(), node.getVersion(),
thisAddress, clusterService.getThisUuid(), node.isLiteMember(), node.createConfigCheck());
return nodeEngine.getOperationService().send(new WhoisMasterOp(joinMessage), toAddress);
}
代码示例来源:origin: com.hazelcast/hazelcast-all
/**
* Send a {@link WhoisMasterOp} to designated address.
*
* @param toAddress the address to which the operation will be sent.
* @return {@code true} if the operation was sent, otherwise {@code false}.
*/
public boolean sendMasterQuestion(Address toAddress) {
checkNotNull(toAddress, "No endpoint is specified!");
BuildInfo buildInfo = node.getBuildInfo();
final Address thisAddress = node.getThisAddress();
JoinMessage joinMessage = new JoinMessage(Packet.VERSION, buildInfo.getBuildNumber(), node.getVersion(),
thisAddress, clusterService.getThisUuid(), node.isLiteMember(), node.createConfigCheck());
return nodeEngine.getOperationService().send(new WhoisMasterOp(joinMessage), toAddress);
}
代码示例来源:origin: hazelcast/hazelcast-jet
private void handleActiveAndJoined(JoinMessage joinMessage) {
if (!(joinMessage instanceof JoinRequest)) {
logDroppedMessage(joinMessage);
return;
}
ClusterServiceImpl clusterService = node.getClusterService();
Address masterAddress = clusterService.getMasterAddress();
if (clusterService.isMaster()) {
JoinMessage response = new JoinMessage(Packet.VERSION, node.getBuildInfo().getBuildNumber(), node.getVersion(),
node.getThisAddress(), node.getThisUuid(), node.isLiteMember(), node.createConfigCheck());
node.multicastService.send(response);
} else if (joinMessage.getAddress().equals(masterAddress)) {
MemberImpl master = node.getClusterService().getMember(masterAddress);
if (master != null && !master.getUuid().equals(joinMessage.getUuid())) {
String message = "New join request has been received from current master. Suspecting " + masterAddress;
logger.warning(message);
// I just make a local suspicion. Probably other nodes will eventually suspect as well.
clusterService.suspectMember(master, message, false);
}
}
}
代码示例来源:origin: com.hazelcast/hazelcast-all
private void handleActiveAndJoined(JoinMessage joinMessage) {
if (!(joinMessage instanceof JoinRequest)) {
logDroppedMessage(joinMessage);
return;
}
ClusterServiceImpl clusterService = node.getClusterService();
Address masterAddress = clusterService.getMasterAddress();
if (clusterService.isMaster()) {
JoinMessage response = new JoinMessage(Packet.VERSION, node.getBuildInfo().getBuildNumber(), node.getVersion(),
node.getThisAddress(), node.getThisUuid(), node.isLiteMember(), node.createConfigCheck());
node.multicastService.send(response);
} else if (joinMessage.getAddress().equals(masterAddress)) {
MemberImpl master = node.getClusterService().getMember(masterAddress);
if (master != null && !master.getUuid().equals(joinMessage.getUuid())) {
String message = "New join request has been received from current master. Suspecting " + masterAddress;
logger.warning(message);
// I just make a local suspicion. Probably other nodes will eventually suspect as well.
clusterService.suspectMember(master, message, false);
}
}
}
代码示例来源:origin: com.hazelcast/hazelcast-all
public TimedMemberState createTimedMemberState() {
MemberStateImpl memberState = new MemberStateImpl();
Collection<StatisticsAwareService> services = instance.node.nodeEngine.getServices(StatisticsAwareService.class);
TimedMemberState timedMemberState = new TimedMemberState();
createMemberState(memberState, services);
timedMemberState.setMaster(instance.node.isMaster());
timedMemberState.setMemberList(new ArrayList<String>());
if (timedMemberState.isMaster()) {
Set<Member> memberSet = instance.getCluster().getMembers();
for (Member member : memberSet) {
MemberImpl memberImpl = (MemberImpl) member;
Address address = memberImpl.getAddress();
timedMemberState.getMemberList().add(address.getHost() + ":" + address.getPort());
}
}
timedMemberState.setMemberState(memberState);
GroupConfig groupConfig = instance.getConfig().getGroupConfig();
timedMemberState.setClusterName(groupConfig.getName());
SSLConfig sslConfig = instance.getConfig().getNetworkConfig().getSSLConfig();
timedMemberState.setSslEnabled(sslConfig != null && sslConfig.isEnabled());
timedMemberState.setLite(instance.node.isLiteMember());
SocketInterceptorConfig interceptorConfig = instance.getConfig().getNetworkConfig().getSocketInterceptorConfig();
timedMemberState.setSocketInterceptorEnabled(interceptorConfig != null && interceptorConfig.isEnabled());
boolean scriptingEnabled = instance.node.getProperties().getBoolean(GroupProperty.SCRIPTING_ENABLED);
timedMemberState.setScriptingEnabled(scriptingEnabled);
return timedMemberState;
}
代码示例来源:origin: hazelcast/hazelcast-jet
public TimedMemberState createTimedMemberState() {
MemberStateImpl memberState = new MemberStateImpl();
Collection<StatisticsAwareService> services = instance.node.nodeEngine.getServices(StatisticsAwareService.class);
TimedMemberState timedMemberState = new TimedMemberState();
createMemberState(memberState, services);
timedMemberState.setMaster(instance.node.isMaster());
timedMemberState.setMemberList(new ArrayList<String>());
if (timedMemberState.isMaster()) {
Set<Member> memberSet = instance.getCluster().getMembers();
for (Member member : memberSet) {
MemberImpl memberImpl = (MemberImpl) member;
Address address = memberImpl.getAddress();
timedMemberState.getMemberList().add(address.getHost() + ":" + address.getPort());
}
}
timedMemberState.setMemberState(memberState);
GroupConfig groupConfig = instance.getConfig().getGroupConfig();
timedMemberState.setClusterName(groupConfig.getName());
SSLConfig sslConfig = instance.getConfig().getNetworkConfig().getSSLConfig();
timedMemberState.setSslEnabled(sslConfig != null && sslConfig.isEnabled());
timedMemberState.setLite(instance.node.isLiteMember());
SocketInterceptorConfig interceptorConfig = instance.getConfig().getNetworkConfig().getSocketInterceptorConfig();
timedMemberState.setSocketInterceptorEnabled(interceptorConfig != null && interceptorConfig.isEnabled());
ManagementCenterConfig managementCenterConfig = instance.node.getConfig().getManagementCenterConfig();
timedMemberState.setScriptingEnabled(managementCenterConfig.isScriptingEnabled());
return timedMemberState;
}
代码示例来源:origin: hazelcast/hazelcast-jet
@Override
public void run(DiagnosticsLogWriter writer) {
writer.startSection("HazelcastInstance");
writer.writeKeyValueEntry("thisAddress", nodeEngine.getNode().getThisAddress().toString());
writer.writeKeyValueEntry("isRunning", nodeEngine.getNode().isRunning());
writer.writeKeyValueEntry("isLite", nodeEngine.getNode().isLiteMember());
writer.writeKeyValueEntry("joined", nodeEngine.getNode().getClusterService().isJoined());
NodeState state = nodeEngine.getNode().getState();
writer.writeKeyValueEntry("nodeState", state == null ? "null" : state.toString());
writer.writeKeyValueEntry("clusterId", nodeEngine.getClusterService().getClusterId());
writer.writeKeyValueEntry("clusterSize", nodeEngine.getClusterService().getSize());
writer.writeKeyValueEntry("isMaster", nodeEngine.getClusterService().isMaster());
Address masterAddress = nodeEngine.getClusterService().getMasterAddress();
writer.writeKeyValueEntry("masterAddress", masterAddress == null ? "null" : masterAddress.toString());
writer.startSection("Members");
for (Member member : nodeEngine.getClusterService().getMemberImpls()) {
writer.writeEntry(member.getAddress().toString());
}
writer.endSection();
writer.endSection();
}
}
代码示例来源:origin: com.hazelcast/hazelcast-all
@Override
public void run(DiagnosticsLogWriter writer) {
writer.startSection("HazelcastInstance");
writer.writeKeyValueEntry("thisAddress", nodeEngine.getNode().getThisAddress().toString());
writer.writeKeyValueEntry("isRunning", nodeEngine.getNode().isRunning());
writer.writeKeyValueEntry("isLite", nodeEngine.getNode().isLiteMember());
writer.writeKeyValueEntry("joined", nodeEngine.getNode().getClusterService().isJoined());
NodeState state = nodeEngine.getNode().getState();
writer.writeKeyValueEntry("nodeState", state == null ? "null" : state.toString());
writer.writeKeyValueEntry("clusterId", nodeEngine.getClusterService().getClusterId());
writer.writeKeyValueEntry("clusterSize", nodeEngine.getClusterService().getSize());
writer.writeKeyValueEntry("isMaster", nodeEngine.getClusterService().isMaster());
Address masterAddress = nodeEngine.getClusterService().getMasterAddress();
writer.writeKeyValueEntry("masterAddress", masterAddress == null ? "null" : masterAddress.toString());
writer.startSection("Members");
for (Member member : nodeEngine.getClusterService().getMemberImpls()) {
writer.writeEntry(member.getAddress().toString());
}
writer.endSection();
writer.endSection();
}
}
内容来源于网络,如有侵权,请联系作者删除!