com.addthis.muxy

Class ReadMuxStreamDirectory

java.lang.Object

com.addthis.muxy.ReadMuxStreamDirectory

Direct Known Subclasses:

MuxStreamDirectory

public class ReadMuxStreamDirectory
extends Object

stream multiplexer. allows for a large number of append-only streams to exist inside of a much smaller number of on-disk files. files consist of a series of fast-skip blocks. each block contains a linked list of bytes for 1 or more streams.

Field Summary

Fields

Modifier and Type	Field and Description
protected AtomicLong	closeTime
protected static int	DEFAULT_MAP_SIZE
protected boolean	deleteFreed
protected Path	dirDataFile
protected Path	dirMetaFile
protected MuxyEventListener	eventListener
protected static DecimalFormat	fileFormat
protected static int	MAX_RECORDS_READ
protected AtomicBoolean	releaseComplete
protected int	startFile
protected Path	streamDirectory
protected com.addthis.muxy.MuxDirectory	streamDirectoryConfig
protected Map<Integer,MuxStream>	streamDirectoryMap
protected FileChannel	writeMutexFile
protected FileLock	writeMutexLock

Constructor Summary

Constructors

Constructor and Description
ReadMuxStreamDirectory(Path dir)
ReadMuxStreamDirectory(Path dir, MuxyEventListener listener)

Method Summary

Modifier and Type	Method and Description
MuxStream	findStream(int streamID)
protected static String	formatFileName(int blockFile)
Collection<Path>	getActiveFiles()
protected Path	getFileByID(int fileID)
static Path	getFileByID(Path streamDirectory, int fileID)
Collection<MuxStream>	listStreams()
protected void	publishEvent(MuxyStreamEvent ID, Object target)
protected void	readMetaLog()
int	size()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_MAP_SIZE

protected static final int DEFAULT_MAP_SIZE

MAX_RECORDS_READ

protected static final int MAX_RECORDS_READ

fileFormat

protected static final DecimalFormat fileFormat

streamDirectory

protected final Path streamDirectory

dirMetaFile

protected final Path dirMetaFile

dirDataFile

protected final Path dirDataFile

streamDirectoryMap

protected final Map<Integer,MuxStream> streamDirectoryMap

streamDirectoryConfig

protected final com.addthis.muxy.MuxDirectory streamDirectoryConfig

releaseComplete

protected final AtomicBoolean releaseComplete

closeTime

protected final AtomicLong closeTime

writeMutexFile

protected FileChannel writeMutexFile

writeMutexLock

protected FileLock writeMutexLock

eventListener

protected MuxyEventListener eventListener

deleteFreed

protected boolean deleteFreed

startFile

protected int startFile

Constructor Detail

ReadMuxStreamDirectory

public ReadMuxStreamDirectory(Path dir)
                       throws Exception

Throws:

Exception

ReadMuxStreamDirectory

public ReadMuxStreamDirectory(Path dir,
                              MuxyEventListener listener)
                       throws Exception

Throws:

Exception

Method Detail

formatFileName

protected static String formatFileName(int blockFile)

getFileByID

protected Path getFileByID(int fileID)

getFileByID

public static Path getFileByID(Path streamDirectory,
                               int fileID)

publishEvent

protected void publishEvent(MuxyStreamEvent ID,
                            Object target)

readMetaLog

protected void readMetaLog()
                    throws IOException

Throws:

IOException

listStreams

public Collection<MuxStream> listStreams()
                                  throws IOException

Throws:

IOException

size

public int size()

findStream

public MuxStream findStream(int streamID)
                     throws IOException

Throws:

IOException

getActiveFiles

public Collection<Path> getActiveFiles()
                                throws IOException

Throws:

IOException