Package org.jgroups.raft.filelog

Class LogEntryStorage

java.lang.Object

org.jgroups.raft.filelog.LogEntryStorage

public class LogEntryStorage
extends Object

Stores the LogEntry into a file.

Since:

0.5.4

Author:

Pedro Ruivo

Constructor Summary

Constructors

Constructor	Description
LogEntryStorage(File parentDir, boolean fsync)

Method Summary

Modifier and Type	Method	Description
void	close()
void	delete()
void	forEach(ObjLongConsumer<LogEntry> consumer, long startIndex, long endIndex)
long	getCachedFileSize()
long	getFirstAppended()
long	getLastAppended()
LogEntry	getLogEntry(long index)
void	open()
void	reinitializeTo(long index, LogEntry firstEntry)
void	reload()
long	removeNew(long index)
void	removeOld(long index)
void	useFsync(boolean value)
int	write(long startIndex, LogEntries entries)

Methods inherited from class java.lang.Object

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

Constructor Details

LogEntryStorage

public LogEntryStorage(File parentDir,
 boolean fsync)

Method Details

open

public void open()
          throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Throws:

IOException

delete

public void delete()
            throws IOException

Throws:

IOException

reload

public void reload()
            throws IOException

Throws:

IOException

getFirstAppended

public long getFirstAppended()

getLastAppended

public long getLastAppended()

getCachedFileSize

public long getCachedFileSize()

getLogEntry

public LogEntry getLogEntry(long index)
                     throws IOException

Throws:

IOException

write

public int write(long startIndex,
 LogEntries entries)
          throws IOException

Throws:

IOException

removeOld

public void removeOld(long index)
               throws IOException

Throws:

IOException

reinitializeTo

public void reinitializeTo(long index,
 LogEntry firstEntry)
                    throws IOException

Throws:

IOException

removeNew

public long removeNew(long index)
               throws IOException

Throws:

IOException

forEach

public void forEach(ObjLongConsumer<LogEntry> consumer,
 long startIndex,
 long endIndex)
             throws IOException

Throws:

IOException

useFsync

public void useFsync(boolean value)