com.gigaspaces.internal.cluster.node.impl.directPersistency.ioImpl

Class DirectPersistencyBlobStoreIO

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.directPersistency.ioImpl.DirectPersistencyBlobStoreIO

All Implemented Interfaces:

IDirectPersistencyIoHandler

public class DirectPersistencyBlobStoreIO
extends Object
implements IDirectPersistencyIoHandler

The actual i/o of DirectPersistencyOpInfo objects

Since:

10.2

Author:

yechielf

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DirectPersistencyBlobStoreIO.DirectPersistencyOpIterBlobStoreIO
static class	DirectPersistencyBlobStoreIO.DirectPersistencyOverflowIterBlobStoreIO

Field Summary

Fields inherited from interface com.gigaspaces.internal.cluster.node.impl.directPersistency.ioImpl.IDirectPersistencyIoHandler

BULK_SIZE

Constructor Summary

Constructors

Constructor and Description
DirectPersistencyBlobStoreIO(CacheManager cacheManager, Logger logger, long currentGenerationId)

Method Summary

Modifier and Type	Method and Description
IDirectPersistencyOpInfo	get(long getGenerationId, long sequenceNumber)
List<EmbeddedSyncTransferredInfo>	getAllTransferredInfo(EmbeddedSyncHandler h, Collection<Long> generations)
EmbeddedRelevantGenerationIdsInfo	getEmbeddedRelevantGenerationIdsInfo()
DirectPersistencyOverflowListSegment	getOverflowSegment(long generationId, long seq)
static String	getOverflowSegmentStorageKey(long gen, long seq)
DirectPersistencySyncAdminInfo	getSyncAdminIfExists()
void	insert(DirectPersistencyOverflowListSegment segment)
void	insert(DirectPersistencySyncAdminInfo ai)
void	insert(EmbeddedRelevantGenerationIdsInfo ai)
void	insert(EmbeddedSyncTransferredInfo ai)
void	insert(IDirectPersistencyOpInfo entry)
Iterator<IDirectPersistencyOpInfo>	iterateOps(boolean currentGeneration)
Iterator<DirectPersistencyOverflowListSegment>	iterateOverflow(boolean currentGeneration)
void	remove(DirectPersistencyOverflowListSegment segment)
void	remove(EmbeddedSyncTransferredInfo ai)
void	remove(IDirectPersistencyOpInfo entry)
void	removeOpsBulk(List<IDirectPersistencyOpInfo> ops)
void	removeOvfBulk(List<DirectPersistencyOverflowListSegment> ovfs)
void	removePhantom(String uid, boolean checkExistance, long generationId, long seq)
void	update(DirectPersistencyOverflowListSegment segment)
void	update(DirectPersistencySyncAdminInfo ai)
void	update(EmbeddedRelevantGenerationIdsInfo ai)
void	update(EmbeddedSyncTransferredInfo ai)
void	update(IDirectPersistencyOpInfo entry)

Methods inherited from class java.lang.Object

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

Constructor Detail

DirectPersistencyBlobStoreIO

public DirectPersistencyBlobStoreIO(CacheManager cacheManager,
                                    Logger logger,
                                    long currentGenerationId)

Method Detail

getOverflowSegmentStorageKey

public static String getOverflowSegmentStorageKey(long gen,
                                                  long seq)

insert

public void insert(IDirectPersistencyOpInfo entry)

Specified by:

insert in interface IDirectPersistencyIoHandler

remove

public void remove(IDirectPersistencyOpInfo entry)

Specified by:

remove in interface IDirectPersistencyIoHandler

update

public void update(IDirectPersistencyOpInfo entry)

Specified by:

update in interface IDirectPersistencyIoHandler

get

public IDirectPersistencyOpInfo get(long getGenerationId,
                                    long sequenceNumber)

Specified by:

get in interface IDirectPersistencyIoHandler

iterateOps

public Iterator<IDirectPersistencyOpInfo> iterateOps(boolean currentGeneration)

Specified by:

iterateOps in interface IDirectPersistencyIoHandler

removeOpsBulk

public void removeOpsBulk(List<IDirectPersistencyOpInfo> ops)

Specified by:

removeOpsBulk in interface IDirectPersistencyIoHandler

insert

public void insert(DirectPersistencyOverflowListSegment segment)

Specified by:

insert in interface IDirectPersistencyIoHandler

remove

public void remove(DirectPersistencyOverflowListSegment segment)

Specified by:

remove in interface IDirectPersistencyIoHandler

update

public void update(DirectPersistencyOverflowListSegment segment)

Specified by:

update in interface IDirectPersistencyIoHandler

getOverflowSegment

public DirectPersistencyOverflowListSegment getOverflowSegment(long generationId,
                                                               long seq)

Specified by:

getOverflowSegment in interface IDirectPersistencyIoHandler

iterateOverflow

public Iterator<DirectPersistencyOverflowListSegment> iterateOverflow(boolean currentGeneration)

Specified by:

iterateOverflow in interface IDirectPersistencyIoHandler

removeOvfBulk

public void removeOvfBulk(List<DirectPersistencyOverflowListSegment> ovfs)

Specified by:

removeOvfBulk in interface IDirectPersistencyIoHandler

insert

public void insert(DirectPersistencySyncAdminInfo ai)

Specified by:

insert in interface IDirectPersistencyIoHandler

update

public void update(DirectPersistencySyncAdminInfo ai)

Specified by:

update in interface IDirectPersistencyIoHandler

getSyncAdminIfExists

public DirectPersistencySyncAdminInfo getSyncAdminIfExists()

Specified by:

getSyncAdminIfExists in interface IDirectPersistencyIoHandler

removePhantom

public void removePhantom(String uid,
                          boolean checkExistance,
                          long generationId,
                          long seq)

Specified by:

removePhantom in interface IDirectPersistencyIoHandler

insert

public void insert(EmbeddedSyncTransferredInfo ai)

Specified by:

insert in interface IDirectPersistencyIoHandler

update

public void update(EmbeddedSyncTransferredInfo ai)

Specified by:

update in interface IDirectPersistencyIoHandler

remove

public void remove(EmbeddedSyncTransferredInfo ai)

Specified by:

remove in interface IDirectPersistencyIoHandler

getEmbeddedRelevantGenerationIdsInfo

public EmbeddedRelevantGenerationIdsInfo getEmbeddedRelevantGenerationIdsInfo()

Specified by:

getEmbeddedRelevantGenerationIdsInfo in interface IDirectPersistencyIoHandler

update

public void update(EmbeddedRelevantGenerationIdsInfo ai)

Specified by:

update in interface IDirectPersistencyIoHandler

insert

public void insert(EmbeddedRelevantGenerationIdsInfo ai)

Specified by:

insert in interface IDirectPersistencyIoHandler

getAllTransferredInfo

public List<EmbeddedSyncTransferredInfo> getAllTransferredInfo(EmbeddedSyncHandler h,
                                                               Collection<Long> generations)

Specified by:

getAllTransferredInfo in interface IDirectPersistencyIoHandler