public final class LockServiceImpl extends Object implements InternalLockService, ManagedService, RemoteService, MembershipAwareService, MigrationAwareService, ClientAwareService
SERVICE_NAME
Constructor and Description |
---|
LockServiceImpl(NodeEngine nodeEngine) |
Modifier and Type | Method and Description |
---|---|
void |
beforeMigration(PartitionMigrationEvent partitionMigrationEvent) |
void |
cancelEviction(ObjectNamespace namespace,
Data key)
Cancel scheduled lock eviction.
|
void |
clearLockStore(int partitionId,
ObjectNamespace namespace) |
void |
clearPartitionReplica(int partitionId) |
void |
clientDisconnected(String clientUuid)
Invoked when a client disconnects from a member.
|
void |
commitMigration(PartitionMigrationEvent event) |
DistributedObject |
createDistributedObject(String objectId)
Creates a distributed object.
|
LockStore |
createLockStore(int partitionId,
ObjectNamespace namespace) |
void |
destroyDistributedObject(String objectId)
Destroys a distributed object.
|
Collection<LockResource> |
getAllLocks() |
LockStoreContainer |
getLockContainer(int partitionId) |
LockStoreImpl |
getLockStore(int partitionId,
ObjectNamespace namespace) |
long |
getMaxLeaseTimeInMillis() |
static long |
getMaxLeaseTimeInMillis(GroupProperties groupProperties) |
void |
init(NodeEngine nodeEngine,
Properties properties)
Initializes this ManagedService
|
void |
memberAdded(MembershipServiceEvent event)
Invoked when a new member is added to the cluster.
|
void |
memberAttributeChanged(MemberAttributeServiceEvent event)
Invoked when a member attribute is changed.
|
void |
memberRemoved(MembershipServiceEvent event)
Invoked when an existing member leaves the cluster.
|
Operation |
prepareReplicationOperation(PartitionReplicationEvent event) |
void |
registerLockStoreConstructor(String serviceName,
ConstructorFunction<ObjectNamespace,LockStoreInfo> constructorFunction) |
void |
reset()
reset this ManagedService back to initial state.
|
void |
rollbackMigration(PartitionMigrationEvent event) |
void |
scheduleEviction(ObjectNamespace namespace,
Data key,
int version,
long delay)
Schedule lock eviction.
|
void |
shutdown(boolean terminate)
Shuts down this ManagedService.
|
public LockServiceImpl(NodeEngine nodeEngine)
public static long getMaxLeaseTimeInMillis(GroupProperties groupProperties)
public void init(NodeEngine nodeEngine, Properties properties)
ManagedService
init
in interface ManagedService
nodeEngine
- the NodeEngine that this ManagedService belongs to.properties
- the Properties. Can be used to pass settings to the service.public void reset()
ManagedService
reset
in interface ManagedService
public void shutdown(boolean terminate)
ManagedService
shutdown
in interface ManagedService
terminate
- true to shut down the ManagedServicepublic long getMaxLeaseTimeInMillis()
getMaxLeaseTimeInMillis
in interface LockService
public void registerLockStoreConstructor(String serviceName, ConstructorFunction<ObjectNamespace,LockStoreInfo> constructorFunction)
registerLockStoreConstructor
in interface LockService
public LockStore createLockStore(int partitionId, ObjectNamespace namespace)
createLockStore
in interface LockService
public void clearLockStore(int partitionId, ObjectNamespace namespace)
clearLockStore
in interface LockService
public void scheduleEviction(ObjectNamespace namespace, Data key, int version, long delay)
InternalLockService
scheduleEviction
in interface InternalLockService
namespace
- namespace of the lockkey
- locked keyversion
- version of a lock to evict.delay
- delay in mspublic void cancelEviction(ObjectNamespace namespace, Data key)
InternalLockService
cancelEviction
in interface InternalLockService
namespace
- namespace of the lockkey
- locked keypublic LockStoreContainer getLockContainer(int partitionId)
public LockStoreImpl getLockStore(int partitionId, ObjectNamespace namespace)
public void memberAdded(MembershipServiceEvent event)
MembershipAwareService
memberAdded
in interface MembershipAwareService
event
- the event for a new member added to the clusterpublic void memberRemoved(MembershipServiceEvent event)
MembershipAwareService
memberRemoved
in interface MembershipAwareService
event
- the event for an existing member leaving the clusterpublic void memberAttributeChanged(MemberAttributeServiceEvent event)
MembershipAwareService
memberAttributeChanged
in interface MembershipAwareService
event
- the event for a member attribute being changedpublic Collection<LockResource> getAllLocks()
getAllLocks
in interface LockService
public void beforeMigration(PartitionMigrationEvent partitionMigrationEvent)
beforeMigration
in interface MigrationAwareService
public Operation prepareReplicationOperation(PartitionReplicationEvent event)
prepareReplicationOperation
in interface MigrationAwareService
public void commitMigration(PartitionMigrationEvent event)
commitMigration
in interface MigrationAwareService
public void rollbackMigration(PartitionMigrationEvent event)
rollbackMigration
in interface MigrationAwareService
public void clearPartitionReplica(int partitionId)
clearPartitionReplica
in interface MigrationAwareService
public DistributedObject createDistributedObject(String objectId)
RemoteService
createDistributedObject
in interface RemoteService
objectId
- the name for the created distributed objectpublic void destroyDistributedObject(String objectId)
RemoteService
destroyDistributedObject
in interface RemoteService
objectId
- the name of the distributed object to destroypublic void clientDisconnected(String clientUuid)
ClientAwareService
clientDisconnected
in interface ClientAwareService
clientUuid
- the Uuid of the client that disconnected from a memberCopyright © 2015 Hazelcast, Inc.. All Rights Reserved.