com.cloudtran.replicator.ssdStore
Class SSDLocalStoreThread

java.lang.Object
  extended by java.lang.Thread
      extended by com.cloudtran.replicator.ssdStore.SSDLocalStoreThread
All Implemented Interfaces:
Runnable

public class SSDLocalStoreThread
extends Thread


Nested Class Summary
 
Nested classes/interfaces inherited from class java.lang.Thread
Thread.State, Thread.UncaughtExceptionHandler
 
Field Summary
 LinkedBlockingQueue<Object> ssdQueue
           
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
SSDLocalStoreThread(String directoryPath)
           
 
Method Summary
 void closeFile()
           
 void openFile(int fileNumber)
          This opens a file based on the given file number.
 void run()
          This should be writing out the BAWB or the ACKs
 String toString()
           
 
Methods inherited from class java.lang.Thread
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, yield
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

ssdQueue

public LinkedBlockingQueue<Object> ssdQueue
Constructor Detail

SSDLocalStoreThread

public SSDLocalStoreThread(String directoryPath)
Method Detail

run

public void run()
This should be writing out the BAWB or the ACKs

Specified by:
run in interface Runnable
Overrides:
run in class Thread

openFile

public void openFile(int fileNumber)
This opens a file based on the given file number. It resets the number of blocks available in the file It immediately writes out a file header.

Parameters:
fileNumber -

closeFile

public void closeFile()

toString

public String toString()
Overrides:
toString in class Thread