com.hazelcast.client.cp.internal.datastructures.semaphore

Class RaftSessionlessSemaphoreProxy

java.lang.Object

com.hazelcast.client.spi.ClientProxy

com.hazelcast.client.cp.internal.datastructures.semaphore.RaftSessionlessSemaphoreProxy

All Implemented Interfaces:

DistributedObject, ISemaphore

public class RaftSessionlessSemaphoreProxy
extends ClientProxy
implements ISemaphore

Client-side sessionless proxy of Raft-based ISemaphore

Field Summary

Fields inherited from class com.hazelcast.client.spi.ClientProxy

name

Constructor Summary

Constructors

Constructor and Description
RaftSessionlessSemaphoreProxy(ClientContext context, RaftGroupId groupId, String proxyName, String objectName)

Method Summary

Modifier and Type	Method and Description
void	acquire()
void	acquire(int permits)
int	availablePermits()
int	drainPermits()
CPGroupId	getGroupId()
String	getPartitionKey()
void	increasePermits(int increase)
boolean	init(int permits)
void	onDestroy() Called before proxy is destroyed.
void	reducePermits(int reduction)
void	release()
void	release(int permits)
boolean	tryAcquire()
boolean	tryAcquire(int permits)
boolean	tryAcquire(int permits, long timeout, TimeUnit unit)
boolean	tryAcquire(long timeout, TimeUnit unit)

Methods inherited from class com.hazelcast.client.spi.ClientProxy

deregisterListener, destroy, destroyLocally, destroyRemotely, equals, getClient, getConnectedServerVersion, getContext, getDistributedObjectName, getId, getName, getSerializationService, getServiceName, hashCode, invoke, invoke, invokeOnAddress, invokeOnPartition, invokeOnPartitionInterruptibly, onInitialize, onShutdown, postDestroy, preDestroy, registerListener, setContext, toData, toObject

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.core.ISemaphore

getName

Methods inherited from interface com.hazelcast.core.DistributedObject

destroy, getServiceName

Constructor Detail

RaftSessionlessSemaphoreProxy

public RaftSessionlessSemaphoreProxy(ClientContext context,
                                     RaftGroupId groupId,
                                     String proxyName,
                                     String objectName)

Method Detail

init

public boolean init(int permits)

Specified by:

init in interface ISemaphore

acquire

public void acquire()

Specified by:

acquire in interface ISemaphore

acquire

public void acquire(int permits)

Specified by:

acquire in interface ISemaphore

tryAcquire

public boolean tryAcquire()

Specified by:

tryAcquire in interface ISemaphore

tryAcquire

public boolean tryAcquire(int permits)

Specified by:

tryAcquire in interface ISemaphore

tryAcquire

public boolean tryAcquire(long timeout,
                          TimeUnit unit)

Specified by:

tryAcquire in interface ISemaphore

tryAcquire

public boolean tryAcquire(int permits,
                          long timeout,
                          TimeUnit unit)

Specified by:

tryAcquire in interface ISemaphore

release

public void release()

Specified by:

release in interface ISemaphore

release

public void release(int permits)

Specified by:

release in interface ISemaphore

availablePermits

public int availablePermits()

Specified by:

availablePermits in interface ISemaphore

drainPermits

public int drainPermits()

Specified by:

drainPermits in interface ISemaphore

reducePermits

public void reducePermits(int reduction)

Specified by:

reducePermits in interface ISemaphore

increasePermits

public void increasePermits(int increase)

Specified by:

increasePermits in interface ISemaphore

getPartitionKey

public String getPartitionKey()

Specified by:

getPartitionKey in interface DistributedObject

Overrides:

getPartitionKey in class ClientProxy

onDestroy

public void onDestroy()

Description copied from class: ClientProxy

Called before proxy is destroyed. Overriding implementations should clean/release resources created during initialization.

Overrides:

onDestroy in class ClientProxy

getGroupId

public CPGroupId getGroupId()