Modifier and Type | Field and Description |
---|---|
Address |
JoinRequest.address |
protected Address |
Master.address
The address.
|
Address |
AddOrRemoveConnection.address |
Address |
JoinRequest.to |
Modifier and Type | Method and Description |
---|---|
Address |
MemberInfo.getAddress() |
Address |
Master.getAddress()
Gets the address.
|
Address |
ClusterManager.AsyncRemotelyBooleanOp.getTarget() |
Modifier and Type | Method and Description |
---|---|
MemberImpl |
ClusterManager.addMember(Address address,
NodeType nodeType,
String nodeUuid) |
boolean |
ClusterManager.checkAuthorization(String groupName,
String groupPassword,
Address target) |
JoinInfo |
JoinInfo.copy(boolean newRequest,
Address newAddress,
int memberCount) |
protected MemberImpl |
ClusterManager.createMember(Address address,
NodeType nodeType,
String nodeUuid,
String ipV6ScopeId) |
void |
ClusterManager.disconnectExistingCalls(Address deadAddress) |
MemberImpl |
ClusterManager.getMember(Address address) |
Member |
ClusterImpl.getMember(Address address) |
void |
ClusterManager.invalidateScheduledActionsFor(Address endpoint,
Set<Integer> threadIds) |
void |
ClusterManager.AsyncRemotelyBooleanOp.onDisconnect(Address dead) |
void |
ClusterManager.sendClusterMergeToOthers(Address newTargetAddress) |
boolean |
ClusterManager.sendJoinRequest(Address toAddress,
boolean withCredentials) |
void |
Master.setAddress(Address address)
Sets the address.
|
Constructor and Description |
---|
AddOrRemoveConnection(Address address,
boolean add) |
Bind(Address localAddress) |
Bind(Address localAddress,
Address targetAddress,
boolean replyBack) |
ClusterManager.AsyncRemotelyBooleanOp(AbstractRemotelyCallable<Boolean> arp,
Address target,
boolean canTimeout) |
ClusterManager.NoneMemberAsyncRemotelyBooleanOp(AbstractRemotelyCallable<Boolean> arp,
Address target,
boolean canTimeout) |
JoinInfo(ILogger logger,
boolean request,
Address address,
Config config,
NodeType type,
byte packetVersion,
int buildNumber,
int memberCount,
int tryCount,
String nodeUuid) |
JoinRequest(Address to,
Address address,
Config config,
NodeType type,
byte packetVersion,
int buildNumber,
String nodeUuid) |
JoinRequest(Address address,
Config config,
NodeType type,
byte packetVersion,
int buildNumber,
String nodeUuid) |
Master(Address originAddress)
Instantiates a new isMaster.
|
MemberInfo(Address address) |
MemberInfo(Address address,
NodeType nodeType,
String uuid) |
MemberRemover(Address deadAddress) |
Modifier and Type | Method and Description |
---|---|
List<Address> |
TcpIpConfig.getAddresses() |
Modifier and Type | Method and Description |
---|---|
TcpIpConfig |
TcpIpConfig.addAddress(Address address) |
Modifier and Type | Field and Description |
---|---|
protected Address |
MemberImpl.address |
Address |
Request.caller |
Address |
Request.lockAddress |
protected Address |
BaseManager.TargetAwareOp.target |
Address |
Request.target |
protected Address |
AbstractJoiner.targetAddress |
protected Address |
BaseManager.thisAddress |
Modifier and Type | Field and Description |
---|---|
protected Map<Address,MemberImpl> |
BaseManager.mapMembers |
Modifier and Type | Method and Description |
---|---|
Address |
MemberImpl.getAddress() |
protected Address |
ConcurrentMapManager.getBackupMember(int partitionId,
int replicaIndex) |
protected Address |
ConcurrentMapManager.MLockMap.getFirstAddressToMakeCall() |
Address |
ConcurrentMapManager.getKeyOwner(Data key) |
Address |
ConcurrentMapManager.getKeyOwner(Request req) |
Address |
AbstractRecord.getLockAddress() |
Address |
Record.getLockAddress() |
Address |
AbstractSimpleRecord.getLockAddress() |
Address |
Node.getMasterAddress() |
protected Address |
BaseManager.getMasterAddress() |
Address |
PartitionManager.getOwner(int partitionId) |
Address |
ConcurrentMapManager.getPartitionOwner(int partitionId) |
protected Address |
BaseManager.ResponseQueueCall.getTarget() |
Address |
BaseManager.TargetAwareOp.getTarget() |
Address |
Node.getThisAddress() |
Address |
BaseManager.getThisAddress() |
Modifier and Type | Method and Description |
---|---|
Set<Address> |
Node.getFailedConnections() |
Map<Address,Boolean> |
AbstractRecord.getListeners() |
Map<Address,Boolean> |
Record.getListeners() |
Map<Address,Boolean> |
AbstractSimpleRecord.getListeners() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractRecord.addListener(Address address,
boolean returnValue) |
void |
Record.addListener(Address address,
boolean returnValue) |
void |
TopicManager.TopicInstance.addListener(Address address,
boolean includeValue) |
void |
AbstractSimpleRecord.addListener(Address address,
boolean returnValue) |
void |
CMap.addListener(Data key,
Address address,
boolean includeValue) |
void |
ConcurrentMapManager.destroyEndpointThreads(Address endpoint,
Set<Integer> threadIds) |
void |
PartitionManager.doMigrate(int partitionId,
int replicaIndex,
RecordSet recordSet,
Address from) |
void |
Node.failedConnection(Address address) |
void |
PartitionManager.fireMigrationEvent(MigrationStatus status,
int partitionId,
Address from,
Address to) |
CostAwareRecordList |
PartitionManager.getActivePartitionRecords(int partitionId,
int replicaIndex,
Address newAddress,
boolean diffOnly) |
MemberImpl |
PartitionManager.getMember(Address address) |
protected MemberImpl |
BaseManager.getNextMemberAfter(Address address,
boolean skipSuperClient,
int distance) |
protected MemberImpl |
BaseManager.getNextMemberAfter(List<MemberImpl> lsMembers,
Address address,
boolean skipSuperClient,
int distance) |
boolean |
AbstractRecord.lock(int threadId,
Address address) |
boolean |
Record.lock(int threadId,
Address address) |
boolean |
AbstractSimpleRecord.lock(int threadId,
Address address) |
void |
CMap.onDisconnect(Address deadAddress) |
void |
BaseManager.ConnectionAwareOp.onDisconnect(Address dead) |
void |
BaseManager.TargetAwareOp.onDisconnect(Address dead) |
void |
CMap.onDisconnect(Record record,
Address deadAddress) |
void |
AbstractRecord.removeListener(Address address) |
void |
Record.removeListener(Address address) |
void |
TopicManager.TopicInstance.removeListener(Address address) |
void |
AbstractSimpleRecord.removeListener(Address address) |
void |
CMap.removeListener(Data key,
Address address) |
protected boolean |
BaseManager.send(Packet packet,
Address address)
Do not forget to release packet if send fails.
|
void |
BaseManager.sendEvents(int eventType,
String name,
Data key,
Data value,
Map<Address,Boolean> mapListeners,
Address callerAddress,
boolean fireAndForget) |
protected boolean |
BaseManager.sendOrReleasePacket(Packet packet,
Address address) |
boolean |
BaseManager.sendProcessableTo(RemotelyProcessable rp,
Address address) |
protected boolean |
BaseManager.sendResponse(Packet packet,
Address address) |
boolean |
CountDownLatchProxyImpl.setCount(int count,
Address ownerAddress) |
boolean |
CountDownLatchProxy.setCount(int count,
Address ownerAddress) |
void |
Request.setLocal(ClusterOperation operation,
String name,
Data key,
Data value,
int blockId,
long timeout,
long ttl,
Address thisAddress) |
void |
Node.setMasterAddress(Address master) |
void |
AbstractJoiner.setTargetAddress(Address targetAddress) |
void |
Joiner.setTargetAddress(Address targetAddress) |
void |
ListenerManager.syncForAdd(Address newAddress) |
void |
BlockingQueueManager.syncForDead(Address deadAddress) |
void |
ListenerManager.syncForDead(Address deadAddress) |
void |
TopicManager.syncForDead(Address deadAddress) |
boolean |
AbstractRecord.testLock(int threadId,
Address address) |
boolean |
Record.testLock(int threadId,
Address address) |
boolean |
AbstractSimpleRecord.testLock(int threadId,
Address address) |
boolean |
AbstractRecord.unlock(int threadId,
Address address) |
boolean |
Record.unlock(int threadId,
Address address) |
boolean |
AbstractSimpleRecord.unlock(int threadId,
Address address) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractJoiner.connectAndSendJoinRequest(Collection<Address> colPossibleAddresses) |
void |
BaseManager.sendEvents(int eventType,
String name,
Data key,
Data value,
Map<Address,Boolean> mapListeners,
Address callerAddress,
boolean fireAndForget) |
void |
AbstractRecord.setMapListeners(Map<Address,Boolean> mapListeners) |
void |
Record.setMapListeners(Map<Address,Boolean> mapListeners) |
void |
AbstractSimpleRecord.setMapListeners(Map<Address,Boolean> mapListeners) |
Constructor and Description |
---|
ClientHandlerService.CountDownLatchLeave(Address deadAddress) |
DestroyEndpointThreadsCallable(Address endpoint,
Set<Integer> threadIds) |
MemberImpl(Address address,
boolean localMember) |
MemberImpl(Address address,
boolean localMember,
NodeType nodeType,
String uuid) |
MergeClusters(Address newTargetAddress) |
TcpIpJoiner.MasterAnswer(Address respondingAddress,
boolean approved) |
Modifier and Type | Method and Description |
---|---|
Address |
AddressAwareException.getAddress() |
Address |
CallState.getCaller() |
Address |
CallKey.getCallerAddress() |
Address |
DistributedLock.getLockAddress() |
Address |
DataRecordEntry.getLockAddress() |
Address |
DistributedCountDownLatch.getOwnerAddress() |
Modifier and Type | Method and Description |
---|---|
Map<Address,Boolean> |
DataRecordEntry.getListeners() |
Modifier and Type | Method and Description |
---|---|
void |
DistributedSemaphore.attachDetach(Integer permitsDelta,
Address address) |
int |
DistributedSemaphore.getAttached(Address address) |
CallState |
SystemLogService.getCallState(Address callerAddress,
int callerThreadId) |
CallState |
SystemLogService.getCallStateForCallId(long callId,
Address callerAddress,
int callerThreadId) |
CallState |
SystemLogService.getOrCreateCallState(long callId,
Address callerAddress,
int callerThreadId) |
boolean |
DistributedLock.isLockedBy(Address address,
int threadId) |
boolean |
DistributedCountDownLatch.isOwnerOrMemberAddress(Address deadAddress) |
boolean |
DistributedLock.lock(Address address,
int threadId) |
boolean |
DistributedSemaphore.onDisconnect(Address deadAddress) |
void |
Call.onDisconnect(Address dead) |
void |
DistributedSemaphore.release(int permits,
Address address) |
boolean |
DistributedCountDownLatch.setCount(int count,
Address memberAddress,
Address ownerAddress) |
boolean |
DistributedLock.testLock(int threadId,
Address address) |
boolean |
DistributedSemaphore.tryAcquire(int permits,
Address address) |
boolean |
DistributedLock.unlock(Address address,
int threadId) |
Constructor and Description |
---|
AddressAwareException(Exception exception,
Address address) |
CallKey(Address callerAddress,
int callerThreadId) |
CallState(long callId,
Address caller,
int callerThreadId) |
DistributedLock(Address address,
int threadId) |
DistributedLock(Address lockAddress,
int lockThreadId,
int lockCount) |
Modifier and Type | Method and Description |
---|---|
Address |
MapConfigRequest.getTarget() |
Modifier and Type | Method and Description |
---|---|
Set<Address> |
ExecuteScriptRequest.getTargets() |
Modifier and Type | Method and Description |
---|---|
void |
MapConfigRequest.setTarget(Address target) |
Constructor and Description |
---|
MapConfigRequest(String map,
Address target) |
ThreadDumpRequest(Address target,
boolean deadlock) |
Constructor and Description |
---|
ClusterRuntimeState(Collection<Member> members,
PartitionInfo[] partitions,
MigratingPartition migratingPartition,
Map<Address,Connection> connections,
Collection<Record> lockedRecords) |
ExecuteScriptRequest(String script,
String engine,
Set<Address> targets,
Map<String,Object> bindings) |
Modifier and Type | Method and Description |
---|---|
Address |
MemberStateImpl.getAddress() |
Modifier and Type | Method and Description |
---|---|
void |
MemberStateImpl.setAddress(Address address) |
Modifier and Type | Field and Description |
---|---|
protected Address |
MigratingPartition.from |
protected Address |
MigratingPartition.to |
Modifier and Type | Method and Description |
---|---|
Address |
MigratingPartition.getFromAddress() |
Address |
PartitionReplicaChangeEvent.getNewAddress() |
Address |
PartitionReplicaChangeEvent.getOldAddress() |
Address |
PartitionInfo.getOwner() |
Address |
PartitionInfo.getReplicaAddress(int index) |
Address |
MigratingPartition.getToAddress() |
Modifier and Type | Method and Description |
---|---|
int |
PartitionInfo.getReplicaIndexOf(Address address) |
boolean |
PartitionInfo.isBackup(Address address,
int backupCount) |
boolean |
PartitionInfo.isOwnerOrBackup(Address address,
int backupCount) |
boolean |
PartitionInfo.onDeadAddress(Address deadAddress) |
void |
MigrationRequestTask.setFromAddress(Address from) |
void |
PartitionInfo.setReplicaAddress(int index,
Address address) |
Modifier and Type | Method and Description |
---|---|
protected void |
PartitionRuntimeState.addMemberInfo(MemberInfo memberInfo,
Map<Address,Integer> addressIndexes,
int memberIndex) |
protected void |
PartitionRuntimeState.setPartitions(PartitionInfo[] partitions,
Map<Address,Integer> addressIndexes) |
Constructor and Description |
---|
MigratingPartition(int partitionId,
int replicaIndex,
Address from,
Address to) |
MigrationRequestTask(int partitionId,
Address from,
Address to,
int replicaIndex,
boolean migration) |
MigrationRequestTask(int partitionId,
Address from,
Address to,
int replicaIndex,
boolean migration,
boolean diffOnly) |
MigrationTask(int partitionId,
CostAwareRecordList costAwareRecordList,
int replicaIndex,
Address from,
boolean compress) |
PartitionReplicaChangeEvent(int partitionId,
int replicaIndex,
Address oldAddress,
Address newAddress) |
Modifier and Type | Method and Description |
---|---|
Address |
MemberState.getAddress() |
Modifier and Type | Field and Description |
---|---|
Address |
Packet.lockAddress |
Modifier and Type | Method and Description |
---|---|
Address |
Connection.getEndPoint() |
Address |
IOService.getThisAddress() |
Address |
NodeIOService.getThisAddress() |
Modifier and Type | Method and Description |
---|---|
Map<Address,Connection> |
ConnectionManager.getReadonlyConnectionMap() |
Modifier and Type | Method and Description |
---|---|
void |
ConnectionManager.attachConnection(Address address,
Connection conn) |
boolean |
ConnectionManager.bind(Connection connection,
Address remoteEndPoint,
Address localEndpoint,
boolean replyBack) |
Connection |
ConnectionManager.detachAndGetConnection(Address address) |
void |
IOService.disconnectExistingCalls(Address deadEndpoint) |
void |
NodeIOService.disconnectExistingCalls(Address deadEndpoint) |
Connection |
ConnectionManager.getConnection(Address address) |
Connection |
ConnectionManager.getOrConnect(Address address) |
Connection |
ConnectionManager.getOrConnect(Address address,
boolean silent) |
void |
IOService.onFailedConnection(Address address) |
void |
NodeIOService.onFailedConnection(Address address) |
void |
IOService.removeEndpoint(Address endpoint) |
void |
NodeIOService.removeEndpoint(Address endPoint) |
void |
Connection.setEndPoint(Address endPoint) |
void |
IOService.shouldConnectTo(Address address) |
void |
NodeIOService.shouldConnectTo(Address address) |
Constructor and Description |
---|
Address(Address address) |
SocketConnector(ConnectionManager connectionManager,
Address address,
boolean silent) |
Copyright © 2013 Hazelcast, Inc.. All rights reserved.