com.hazelcast.concurrent.semaphore

Class SemaphoreContainer

java.lang.Object

com.hazelcast.concurrent.semaphore.SemaphoreContainer

All Implemented Interfaces:

DataSerializable

public class SemaphoreContainer
extends Object
implements DataSerializable

Field Summary

Fields

Modifier and Type	Field and Description
static int	INITIAL_CAPACITY

Constructor Summary

Constructors

Constructor and Description
SemaphoreContainer()
SemaphoreContainer(int partitionId, SemaphoreConfig config)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	acquire(int permitCount, String caller)
int	drain(String caller)
int	getAsyncBackupCount()
int	getAvailable()
int	getPartitionId()
int	getSyncBackupCount()
int	getTotalBackupCount()
boolean	init(int permitCount)
boolean	isAvailable(int permitCount)
boolean	memberRemoved(String caller)
void	readData(ObjectDataInput in) Reads fields from the input stream
boolean	reduce(int permitCount)
void	release(int permitCount, String caller)
void	setInitialized()
String	toString()
void	writeData(ObjectDataOutput out) Writes object fields to output stream

Methods inherited from class java.lang.Object

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

Field Detail

INITIAL_CAPACITY

public static final int INITIAL_CAPACITY

See Also:

Constant Field Values

Constructor Detail

SemaphoreContainer

public SemaphoreContainer()

SemaphoreContainer

public SemaphoreContainer(int partitionId,
                  SemaphoreConfig config)

Method Detail

memberRemoved

public boolean memberRemoved(String caller)

init

public boolean init(int permitCount)

getAvailable

public int getAvailable()

isAvailable

public boolean isAvailable(int permitCount)

acquire

public boolean acquire(int permitCount,
              String caller)

drain

public int drain(String caller)

reduce

public boolean reduce(int permitCount)

release

public void release(int permitCount,
           String caller)

getPartitionId

public int getPartitionId()

getSyncBackupCount

public int getSyncBackupCount()

getAsyncBackupCount

public int getAsyncBackupCount()

setInitialized

public void setInitialized()

getTotalBackupCount

public int getTotalBackupCount()

writeData

public void writeData(ObjectDataOutput out)
               throws IOException

Description copied from interface: DataSerializable

Writes object fields to output stream

Specified by:

writeData in interface DataSerializable

Parameters:

out - output

Throws:

IOException

readData

public void readData(ObjectDataInput in)
              throws IOException

Description copied from interface: DataSerializable

Reads fields from the input stream

Specified by:

readData in interface DataSerializable

Parameters:

in - input

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object