com.hazelcast.impl

Class ConcurrentMapManager

java.lang.Object

com.hazelcast.impl.BaseManager

com.hazelcast.impl.ConcurrentMapManager

public class ConcurrentMapManager
extends BaseManager

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ConcurrentMapManager.MClearQuick
class	ConcurrentMapManager.MContainsValue
class	ConcurrentMapManager.MEmpty
class	ConcurrentMapManager.MLockMap

Nested classes/interfaces inherited from class com.hazelcast.impl.BaseManager

BaseManager.ConnectionAwareOp, BaseManager.ResponseQueueCall, BaseManager.ResponsiveOperationHandler, BaseManager.ReturnResponseProcess, BaseManager.TargetAwareOp

Field Summary

Fields inherited from class com.hazelcast.impl.BaseManager

BATCH_OPS_EXECUTOR_NAME, dataMemberCount, INTERNAL_OPS_EXECUTOR_NAME, localIdGen, logger, lsMembers, mapCalls, mapMembers, maxOperationLimit, maxOperationTimeout, node, qServiceThreadPacketCache, redoGiveUpThreshold, redoLogThreshold, redoWaitMillis, responsePollTimeout, systemLogService, thisAddress, thisMember

Method Summary

Methods

Modifier and Type	Method and Description
void	addWanMergeListener(WanMergeListener listener)
void	destroy(String name)
void	destroyEndpointThreads(Address endpoint, Set<Integer> threadIds)
void	executeCleanup(CMap cmap, boolean force)
void	flush(String name)
protected Address	getBackupMember(int partitionId, int replicaIndex)
Map<String,CMap>	getCMaps()
Address	getKeyOwner(Data key)
Address	getKeyOwner(Request req)
LocalMapStatsImpl	getLocalMapStats(String name)
CMap	getMap(String name)
CMap	getOrCreateMap(String name)
int	getPartitionCount()
int	getPartitionId(Data key)
int	getPartitionId(Request req)
PartitionInfo	getPartitionInfo(int partitionId)
PartitionManager	getPartitionManager()
Address	getPartitionOwner(int partitionId)
boolean	isMigrating(Request req)
boolean	isMigrating(Request req, int replica)
boolean	lock(String name, Object key, long timeout)
void	mergeWanRecord(DataRecordEntry mergingEntry) Should be called from ExecutorService threads.
long	newRecordId()
void	onRestart()
boolean	putFromLoad(String name, Object key, Object value)
void	putTransient(String name, Object key, Object value, long ttl)
Pairs	queryMap(CMap cmap, ClusterOperation operation, Predicate predicate)
void	removeWanMergeListener(WanMergeListener listener)
void	reset()
void	shutdown()
void	startCleanup(boolean now, boolean force)
void	syncForAdd()
void	syncForDead(MemberImpl deadMember)

Methods inherited from class com.hazelcast.impl.BaseManager

addRemoteCall, checkServiceThread, createRemotelyProcessablePacket, createSimpleMapEntry, enqueueAndReturn, enqueueAndWait, enqueueAndWait, getInstanceType, getMasterAddress, getMembers, getNextMemberAfter, getNextMemberAfter, getNode, getPacketProcessor, getRemoteCall, getThisAddress, handleInterruptedException, handleResponse, isActive, isLiteMember, isMaster, logRedo, obtainPacket, obtainPacket, registerPacketProcessor, releasePacket, removeRemoteCall, rethrowException, returnRedoResponse, returnResponse, returnResponse, send, send, sendEvents, sendOrReleasePacket, sendOrReleasePacket, sendProcessableTo, sendProcessableTo, sendProcessableToAll, sendResponse, sendResponse, sendResponseFailure

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getPartitionManager

public PartitionManager getPartitionManager()

addWanMergeListener

public void addWanMergeListener(WanMergeListener listener)

removeWanMergeListener

public void removeWanMergeListener(WanMergeListener listener)

onRestart

public void onRestart()

reset

public void reset()

shutdown

public void shutdown()

flush

public void flush(String name)

syncForDead

public void syncForDead(MemberImpl deadMember)

syncForAdd

public void syncForAdd()

mergeWanRecord

public void mergeWanRecord(DataRecordEntry mergingEntry)

Should be called from ExecutorService threads.

Parameters:

mergingEntry -

getPartitionCount

public int getPartitionCount()

getCMaps

public Map<String,CMap> getCMaps()

destroyEndpointThreads

public void destroyEndpointThreads(Address endpoint,
                          Set<Integer> threadIds)

getPartitionInfo

public PartitionInfo getPartitionInfo(int partitionId)

startCleanup

public void startCleanup(boolean now,
                boolean force)

executeCleanup

public void executeCleanup(CMap cmap,
                  boolean force)

lock

public boolean lock(String name,
           Object key,
           long timeout)

putTransient

public void putTransient(String name,
                Object key,
                Object value,
                long ttl)

putFromLoad

public boolean putFromLoad(String name,
                  Object key,
                  Object value)

destroy

public void destroy(String name)

getBackupMember

protected Address getBackupMember(int partitionId,
                      int replicaIndex)

getLocalMapStats

public LocalMapStatsImpl getLocalMapStats(String name)

getKeyOwner

public Address getKeyOwner(Request req)

getPartitionOwner

public Address getPartitionOwner(int partitionId)

getKeyOwner

public Address getKeyOwner(Data key)

isMigrating

public boolean isMigrating(Request req)

isMigrating

public boolean isMigrating(Request req,
                  int replica)

Overrides:

isMigrating in class BaseManager

getPartitionId

public int getPartitionId(Request req)

getPartitionId

public final int getPartitionId(Data key)

newRecordId

public long newRecordId()

getMap

public CMap getMap(String name)

getOrCreateMap

public CMap getOrCreateMap(String name)

queryMap

public Pairs queryMap(CMap cmap,
             ClusterOperation operation,
             Predicate predicate)
               throws QueryException

Throws:

QueryException