Class StableStore

java.lang.Object

com.swiftmq.impl.store.standard.cache.StableStore

All Implemented Interfaces:

com.swiftmq.swiftlet.mgmt.event.MgmtListener, com.swiftmq.swiftlet.timer.event.TimerListener, EventListener

public class StableStore
extends Object
implements com.swiftmq.swiftlet.timer.event.TimerListener, com.swiftmq.swiftlet.mgmt.event.MgmtListener

Field Summary

Fields

Modifier and Type	Field	Description
protected StoreContext	ctx
protected RandomAccessFile	file
protected long	fileLength
protected String	filename
static final String	FILENAME
protected PriorityQueue<Integer>	freePages
protected int	initialPages
protected final AtomicInteger	nFree
protected final AtomicInteger	numberPages
protected String	path

Constructor Summary

Constructors

Constructor	Description
StableStore(StoreContext ctx, String path, int initialPages)
StableStore(StoreContext ctx, String path, int initialPages, boolean offline)
StableStore(StoreContext ctx, String path, int initialPages, boolean offline, boolean freePoolEnabled)

Method Summary

Modifier and Type	Method	Description
void	adminToolActivated()
void	adminToolDeactivated()
void	close()
void	copy(String destPath)
static void	copyToNewSize(String sourceFilename, String destFilename, int oldSize, int newSize)
protected Page	create()
Page	createPage(int pageNo)
void	deleteStore()
void	ensure(int pageNo)
protected void	ensurePage(int pageNo)
void	free(Page page)
Page	get(int pageNo)
int	getnFree()
int	getNumberPages()
boolean	isCheckPointActive()
protected Page	loadPage(int pageNo)
void	performTimeAction()
void	put(Page page)
void	reset()
void	setCheckPointActive(boolean checkPointActive)
void	setFreePoolEnabled(boolean freePoolEnabled)
void	setNumberPages(int numberPages)
void	shrink()
void	shrinkFile()
void	sync()
String	toString()
void	truncateToPage(int pageNo)
protected void	writePage(Page p)

Methods inherited from class Object

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

Field Details

FILENAME

public static final String FILENAME

See Also:

• Constant Field Values

ctx

protected StoreContext ctx

path

protected String path

freePages

protected PriorityQueue<Integer> freePages

nFree

protected final AtomicInteger nFree

file

protected RandomAccessFile file

filename

protected String filename

fileLength

protected volatile long fileLength

numberPages

protected final AtomicInteger numberPages

initialPages

protected int initialPages

Constructor Details

StableStore

public StableStore(StoreContext ctx,
 String path,
 int initialPages)
            throws Exception

Throws:

Exception

StableStore

public StableStore(StoreContext ctx,
 String path,
 int initialPages,
 boolean offline)
            throws Exception

Throws:

Exception

StableStore

public StableStore(StoreContext ctx,
 String path,
 int initialPages,
 boolean offline,
 boolean freePoolEnabled)
            throws Exception

Throws:

Exception

Method Details

getnFree

public int getnFree()

isCheckPointActive

public boolean isCheckPointActive()

setCheckPointActive

public void setCheckPointActive(boolean checkPointActive)

setFreePoolEnabled

public void setFreePoolEnabled(boolean freePoolEnabled)

adminToolActivated

public void adminToolActivated()

Specified by:

adminToolActivated in interface com.swiftmq.swiftlet.mgmt.event.MgmtListener

adminToolDeactivated

public void adminToolDeactivated()

Specified by:

adminToolDeactivated in interface com.swiftmq.swiftlet.mgmt.event.MgmtListener

performTimeAction

public void performTimeAction()

Specified by:

performTimeAction in interface com.swiftmq.swiftlet.timer.event.TimerListener

copyToNewSize

public static void copyToNewSize(String sourceFilename,
 String destFilename,
 int oldSize,
 int newSize)
                          throws Exception

Throws:

Exception

setNumberPages

public void setNumberPages(int numberPages)

createPage

public Page createPage(int pageNo)

ensurePage

protected void ensurePage(int pageNo)
                   throws Exception

Throws:

Exception

sync

public void sync()
          throws Exception

Throws:

Exception

truncateToPage

public void truncateToPage(int pageNo)
                    throws Exception

Throws:

Exception

loadPage

protected Page loadPage(int pageNo)
                 throws Exception

Throws:

Exception

getNumberPages

public int getNumberPages()

create

protected Page create()
               throws Exception

Throws:

Exception

ensure

public void ensure(int pageNo)
            throws Exception

Throws:

Exception

get

public Page get(int pageNo)
         throws Exception

Throws:

Exception

put

public void put(Page page)
         throws Exception

Throws:

Exception

free

public void free(Page page)
          throws Exception

Throws:

Exception

writePage

protected void writePage(Page p)
                  throws Exception

Throws:

Exception

shrinkFile

public void shrinkFile()
                throws Exception

Throws:

Exception

shrink

public void shrink()
            throws Exception

Throws:

Exception

deleteStore

public void deleteStore()
                 throws Exception

Throws:

Exception

copy

public void copy(String destPath)
          throws Exception

Throws:

Exception

close

public void close()
           throws Exception

Throws:

Exception

reset

public void reset()
           throws Exception

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object