com.hazelcast.internal.hidensity.impl

Class DefaultHiDensityRecordProcessor<R extends HiDensityRecord>

java.lang.Object

com.hazelcast.internal.hidensity.impl.DefaultHiDensityRecordProcessor<R>

Type Parameters:

R - type of the HiDensityRecord to be processed

All Implemented Interfaces:

HiDensityRecordAccessor<R>, HiDensityRecordProcessor<R>, MemoryBlockProcessor<R>, com.hazelcast.memory.MemoryBlockAccessor<R>

Direct Known Subclasses:

CacheHiDensityRecordProcessor

public class DefaultHiDensityRecordProcessor<R extends HiDensityRecord>
extends Object
implements HiDensityRecordProcessor<R>

Field Summary

Fields

Modifier and Type	Field and Description
protected Queue<com.hazelcast.memory.MemoryBlock>	deferredBlocksQueue
protected com.hazelcast.memory.HazelcastMemoryManager	memoryManager
protected HiDensityRecordAccessor<R>	recordAccessor
protected EnterpriseSerializationService	serializationService
protected HiDensityStorageInfo	storageInfo

Constructor Summary

Constructors

Constructor and Description
DefaultHiDensityRecordProcessor(EnterpriseSerializationService serializationService, HiDensityRecordAccessor<R> recordAccessor, com.hazelcast.memory.HazelcastMemoryManager memoryManager, HiDensityStorageInfo storageInfo)

Method Summary

Modifier and Type	Method and Description
void	addDeferredDispose(com.hazelcast.memory.MemoryBlock memoryBlock) Adds given MemoryBlock to this HiDensityRecordProcessor to be disposed later.
long	allocate(long size)
com.hazelcast.nio.serialization.Data	convertData(com.hazelcast.nio.serialization.Data data, com.hazelcast.nio.serialization.DataType dataType)
long	decreaseUsedMemory(long size) Decreases the used memory for the underlying Hi-Density storage (cache, ...) as the decreasedMemory.
long	dispose(long address)
long	dispose(R block)
void	disposeData(com.hazelcast.nio.serialization.Data data)
long	disposeData(long address) Disposes (frees) the data at the specified address.
long	disposeData(NativeMemoryData data) Disposes (frees) the specified NativeMemoryData.
void	disposeDeferredBlocks() Disposes added MemoryBlock instances.
long	disposeValue(R record) Disposes (frees) the value of the specified HiDensityRecord.
void	free(long address, long size)
com.hazelcast.memory.HazelcastMemoryManager	getMemoryManager()
EnterpriseSerializationService	getSerializationService()
long	getSize(long address, long expectedSize) Gets the size of given address.
long	getSize(com.hazelcast.memory.MemoryBlock memoryBlock) Gets the size of given memoryBlock.
HiDensityStorageInfo	getStorageInfo()
long	getUsedMemory() Returns the used memory for the underlying Hi-Density storage (cache, ...).
long	increaseUsedMemory(long size) Increases the used memory for the underlying Hi-Density storage (cache, ...) as the increasedMemory.
boolean	isEqual(long address1, long address2)
boolean	isEqual(long address, R value)
R	newRecord() Creates an empty HiDensityRecord.
R	read(long address)
NativeMemoryData	readData(long valueAddress) Reads an off-heap based data from given address.
Object	readValue(R record) Reads the value of specified HiDensityRecord.
com.hazelcast.nio.serialization.Data	toData(Object obj, com.hazelcast.nio.serialization.DataType dataType)
Object	toObject(Object data)
com.hazelcast.internal.memory.MemoryAllocator	unwrapMemoryAllocator()

Methods inherited from class java.lang.Object

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

Field Detail

serializationService

protected final EnterpriseSerializationService serializationService

recordAccessor

protected final HiDensityRecordAccessor<R extends HiDensityRecord> recordAccessor

memoryManager

protected final com.hazelcast.memory.HazelcastMemoryManager memoryManager

storageInfo

protected final HiDensityStorageInfo storageInfo

deferredBlocksQueue

protected final Queue<com.hazelcast.memory.MemoryBlock> deferredBlocksQueue

Constructor Detail

DefaultHiDensityRecordProcessor

public DefaultHiDensityRecordProcessor(EnterpriseSerializationService serializationService,
                                       HiDensityRecordAccessor<R> recordAccessor,
                                       com.hazelcast.memory.HazelcastMemoryManager memoryManager,
                                       HiDensityStorageInfo storageInfo)

Method Detail

isEqual

public boolean isEqual(long address,
                       R value)

Specified by:

isEqual in interface com.hazelcast.memory.MemoryBlockAccessor<R extends HiDensityRecord>

isEqual

public boolean isEqual(long address1,
                       long address2)

Specified by:

isEqual in interface com.hazelcast.memory.MemoryBlockAccessor<R extends HiDensityRecord>

read

public R read(long address)

Specified by:

read in interface com.hazelcast.memory.MemoryBlockAccessor<R extends HiDensityRecord>

dispose

public long dispose(long address)

Specified by:

dispose in interface com.hazelcast.memory.MemoryBlockAccessor<R extends HiDensityRecord>

dispose

public long dispose(R block)

Specified by:

dispose in interface com.hazelcast.memory.MemoryBlockAccessor<R extends HiDensityRecord>

newRecord

public R newRecord()

Description copied from interface: HiDensityRecordAccessor

Creates an empty HiDensityRecord.

Specified by:

newRecord in interface HiDensityRecordAccessor<R extends HiDensityRecord>

Returns:

the created HiDensityRecord

readData

public NativeMemoryData readData(long valueAddress)

Description copied from interface: HiDensityRecordAccessor

Reads an off-heap based data from given address.

Specified by:

readData in interface HiDensityRecordAccessor<R extends HiDensityRecord>

Parameters:

valueAddress - the address of the data stored as off-heap

Returns:

the data stored as off-heap

readValue

public Object readValue(R record)

Description copied from interface: HiDensityRecordAccessor

Reads the value of specified HiDensityRecord.

Specified by:

readValue in interface HiDensityRecordAccessor<R extends HiDensityRecord>

Parameters:

record - the HiDensityRecord whose value will be read

Returns:

the value of specified HiDensityRecord

disposeValue

public long disposeValue(R record)

Description copied from interface: HiDensityRecordAccessor

Disposes (frees) the value of the specified HiDensityRecord.

Specified by:

disposeValue in interface HiDensityRecordAccessor<R extends HiDensityRecord>

Parameters:

record - the HiDensityRecord whose value will be disposed

Returns:

size of disposed HiDensityRecord

disposeData

public long disposeData(NativeMemoryData data)

Description copied from interface: HiDensityRecordAccessor

Disposes (frees) the specified NativeMemoryData.

Specified by:

disposeData in interface HiDensityRecordAccessor<R extends HiDensityRecord>

Parameters:

data - the NativeMemoryData whose value will be disposed

Returns:

size of disposed data

disposeData

public long disposeData(long address)

Description copied from interface: HiDensityRecordAccessor

Disposes (frees) the data at the specified address.

Specified by:

disposeData in interface HiDensityRecordAccessor<R extends HiDensityRecord>

Parameters:

address - the address of the NativeMemoryData whose value will be disposed

Returns:

size of disposed data at given address

toData

public com.hazelcast.nio.serialization.Data toData(Object obj,
                                                   com.hazelcast.nio.serialization.DataType dataType)

Specified by:

toData in interface MemoryBlockProcessor<R extends HiDensityRecord>

toObject

public Object toObject(Object data)

Specified by:

toObject in interface MemoryBlockProcessor<R extends HiDensityRecord>

convertData

public com.hazelcast.nio.serialization.Data convertData(com.hazelcast.nio.serialization.Data data,
                                                        com.hazelcast.nio.serialization.DataType dataType)

Specified by:

convertData in interface MemoryBlockProcessor<R extends HiDensityRecord>

disposeData

public void disposeData(com.hazelcast.nio.serialization.Data data)

Specified by:

disposeData in interface MemoryBlockProcessor<R extends HiDensityRecord>

allocate

public long allocate(long size)

Specified by:

allocate in interface MemoryBlockProcessor<R extends HiDensityRecord>

free

public void free(long address,
                 long size)

Specified by:

free in interface MemoryBlockProcessor<R extends HiDensityRecord>

addDeferredDispose

public void addDeferredDispose(com.hazelcast.memory.MemoryBlock memoryBlock)

Description copied from interface: HiDensityRecordProcessor

Adds given MemoryBlock to this HiDensityRecordProcessor to be disposed later. Possibly at the end of (succeeded or failed) operation.

Specified by:

addDeferredDispose in interface HiDensityRecordProcessor<R extends HiDensityRecord>

Parameters:

memoryBlock - the MemoryBlock to be disposed later

disposeDeferredBlocks

public void disposeDeferredBlocks()

Description copied from interface: HiDensityRecordProcessor

Disposes added MemoryBlock instances.

Specified by:

disposeDeferredBlocks in interface HiDensityRecordProcessor<R extends HiDensityRecord>

getSize

public long getSize(com.hazelcast.memory.MemoryBlock memoryBlock)

Description copied from interface: HiDensityRecordAccessor

Gets the size of given memoryBlock.

Specified by:

getSize in interface HiDensityRecordAccessor<R extends HiDensityRecord>

Parameters:

memoryBlock - MemoryBlock whose size will be calculated

Returns:

the size of memory block

getSize

public long getSize(long address,
                    long expectedSize)

Description copied from interface: HiDensityRecordAccessor

Gets the size of given address.

Specified by:

getSize in interface HiDensityRecordAccessor<R extends HiDensityRecord>

Parameters:

address - the address whose size will be calculated

expectedSize - the expected size of address

Returns:

the size of address

unwrapMemoryAllocator

public com.hazelcast.internal.memory.MemoryAllocator unwrapMemoryAllocator()

Specified by:

unwrapMemoryAllocator in interface MemoryBlockProcessor<R extends HiDensityRecord>

getUsedMemory

public long getUsedMemory()

Description copied from interface: HiDensityRecordProcessor

Returns the used memory for the underlying Hi-Density storage (cache, ...).

Specified by:

getUsedMemory in interface HiDensityRecordProcessor<R extends HiDensityRecord>

Returns:

the used memory for the underlying Hi-Density storage (cache, ...)

increaseUsedMemory

public long increaseUsedMemory(long size)

Description copied from interface: HiDensityRecordProcessor

Increases the used memory for the underlying Hi-Density storage (cache, ...) as the increasedMemory.

Specified by:

increaseUsedMemory in interface HiDensityRecordProcessor<R extends HiDensityRecord>

Parameters:

size - the memory size to be added to used memory

Returns:

the used memory for the underlying Hi-Density storage (cache, ...)

decreaseUsedMemory

public long decreaseUsedMemory(long size)

Description copied from interface: HiDensityRecordProcessor

Decreases the used memory for the underlying Hi-Density storage (cache, ...) as the decreasedMemory.

Specified by:

decreaseUsedMemory in interface HiDensityRecordProcessor<R extends HiDensityRecord>

Parameters:

size - the memory size to be removed from used memory

Returns:

the used memory for the underlying Hi-Density storage (cache, ...)

getMemoryManager

public com.hazelcast.memory.HazelcastMemoryManager getMemoryManager()

getSerializationService

public EnterpriseSerializationService getSerializationService()

getStorageInfo

public HiDensityStorageInfo getStorageInfo()