HazelcastAPI ClusterJoinManager Arayüzü

Giriş

Şu satırı dahil ederiz

import com.hazelcast.internal.cluster.impl.ClusterJoinManager;

startJoinRequest metodu

Akış şöyle

JoinRequestOp.run()

  ClusterJoinManager.handleJoinRequest

    ClusterJoinManager.executeJoinRequest

      ClusterJoinManager.startJoinRequest

Kod şöyle

private void startJoinRequest(MemberInfo memberInfo) {
  long now = Clock.currentTimeMillis();
  ...
  final MemberInfo existing = joiningMembers.put(memberInfo.getAddress(), memberInfo);
  if (existing == null) {
    sendMasterAnswer(memberInfo.getAddress());
    ...
  } else if (!existing.getUuid().equals(memberInfo.getUuid())) {
    logger.warning("Received a new join request from " + memberInfo.getAddress()
      + " with a new UUID " + memberInfo.getUuid()
        + ". Previous UUID was " + existing.getUuid());
  }
  if (now >= timeToStartJoin) {
    startJoin();
  }
}

Master join isteği alınca sendMasterAnswer() içinde cevabı gönderiyor.

startJoin metodu

FinalizeJoinOp ile member listesi gönderilir.