com.gigaspaces.internal.server.space.redolog.storage.bytebuffer

Class StorageSegment

java.lang.Object

com.gigaspaces.internal.server.space.redolog.storage.bytebuffer.StorageSegment

public class StorageSegment
extends Object

A single segment inside a ByteBufferRedoLogFileStorage

Since:

7.1

Author:

eitany

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	StorageSegment.SegmentCursor

Constructor Summary

Constructors

Constructor and Description
StorageSegment(IByteBufferStorageFactory storageProvider, IStorageSegmentsMediator segmentsMediator, int maxReaders)

Method Summary

Modifier and Type	Method and Description
void	addIndex(int packetCountFromLastIndex, long distanceFromLastIndex)
long	adjustReader(IByteBufferStorageCursor reader, long packetPosition)
void	clear()
void	decreaseNumOfPackets(long numOfPackets)
void	decreaseWeight(long weight)
void	delete()
StorageSegment.SegmentCursor	getCursorForReading()
StorageSegment.SegmentCursor	getCursorForWriting()
long	getIndexPosition(int packetPosition)
String	getName()
int	getNumOfDeletedPackets()
long	getNumOfPackets()
long	getPosition()
int	getUnindexedLength()
int	getUnindexedPackets()
long	getWeight()
void	increaseNumOfPackets(long numOfPackets)
void	increaseWeight(long weight)
void	sealWriter()
com.gigaspaces.internal.server.space.redolog.storage.bytebuffer.StorageSegment.Index	searchIndex(long packetPosition)
void	setUnindexedState(int unindexedLength, int unindexedPacketsCount)

Methods inherited from class java.lang.Object

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

Constructor Detail

StorageSegment

public StorageSegment(IByteBufferStorageFactory storageProvider,
                      IStorageSegmentsMediator segmentsMediator,
                      int maxReaders)
               throws ByteBufferStorageException

Throws:

ByteBufferStorageException

Method Detail

getName

public String getName()

getCursorForWriting

public StorageSegment.SegmentCursor getCursorForWriting()

sealWriter

public void sealWriter()

getCursorForReading

public StorageSegment.SegmentCursor getCursorForReading()
                                                 throws ByteBufferStorageException

Throws:

ByteBufferStorageException

clear

public void clear()
           throws ByteBufferStorageException

Throws:

ByteBufferStorageException

getPosition

public long getPosition()

increaseNumOfPackets

public void increaseNumOfPackets(long numOfPackets)

getNumOfPackets

public long getNumOfPackets()

getNumOfDeletedPackets

public int getNumOfDeletedPackets()

delete

public void delete()

decreaseNumOfPackets

public void decreaseNumOfPackets(long numOfPackets)

setUnindexedState

public void setUnindexedState(int unindexedLength,
                              int unindexedPacketsCount)

getUnindexedLength

public int getUnindexedLength()

getUnindexedPackets

public int getUnindexedPackets()

addIndex

public void addIndex(int packetCountFromLastIndex,
                     long distanceFromLastIndex)

adjustReader

public long adjustReader(IByteBufferStorageCursor reader,
                         long packetPosition)

getIndexPosition

public long getIndexPosition(int packetPosition)

searchIndex

public com.gigaspaces.internal.server.space.redolog.storage.bytebuffer.StorageSegment.Index searchIndex(long packetPosition)

increaseWeight

public void increaseWeight(long weight)

decreaseWeight

public void decreaseWeight(long weight)

getWeight

public long getWeight()