org.corfudb.infrastructure.log

Class InMemoryStreamLog

java.lang.Object

org.corfudb.infrastructure.log.InMemoryStreamLog

All Implemented Interfaces:

StreamLog, StreamLogWithRankedAddressSpace

public class InMemoryStreamLog
extends Object
implements StreamLog, StreamLogWithRankedAddressSpace

This class implements the StreamLog interface using a Java hash map. The stream log is only stored in-memory and not persisted. This should only be used for testing. Created by maithem on 7/21/16.

Constructor Summary

Constructors

Constructor and Description
InMemoryStreamLog() Returns an object that stores a stream log in memory.

Method Summary

Modifier and Type	Method and Description
void	append(List<LogData> entries) Append a range of consecutive entries ordered by their addresses.
void	append(long address, LogData entry) Append an entry to the stream log.
void	close() Close the stream log.
void	compact() Remove all trimmed addresses from the StreamLog.
TailsResponse	getAllTails() Get global and all stream tails.
long	getLogTail() Get the global log tail.
StreamsAddressResponse	getStreamsAddressSpace() Get the address space for every stream.
TailsResponse	getTails(List<UUID> streams) Get the global tail and stream tails.
long	getTrimMark() Get the first untrimmed address in the address space.
void	prefixTrim(long address) Prefix trim the global log.
LogData	read(long address) Given an address, read the corresponding stream entry.
void	reset() Clears all data and resets all segment handlers.
void	sync(boolean force) Sync the stream log file to secondary storage.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.corfudb.infrastructure.log.StreamLogWithRankedAddressSpace

assertAppendPermittedUnsafe

Methods inherited from interface org.corfudb.infrastructure.log.StreamLog

getOverwriteCauseForAddress

Constructor Detail

InMemoryStreamLog

public InMemoryStreamLog()

Returns an object that stores a stream log in memory.

Method Detail

append

public void append(List<LogData> entries)

Description copied from interface: StreamLog

Append a range of consecutive entries ordered by their addresses. Entries that are trimmed, or overwrites other addresses are ignored (i.e. they are not written) and an OverwriteException is not thrown.

Specified by:

append in interface StreamLog

append

public void append(long address,
                   LogData entry)

Description copied from interface: StreamLog

Append an entry to the stream log.

Specified by:

append in interface StreamLog

Parameters:

address - address of append entry

entry - entry to append to the log

prefixTrim

public void prefixTrim(long address)

Description copied from interface: StreamLog

Prefix trim the global log.

Specified by:

prefixTrim in interface StreamLog

Parameters:

address - address to trim the log up to

getTails

public TailsResponse getTails(List<UUID> streams)

Description copied from interface: StreamLog

Get the global tail and stream tails.

Specified by:

getTails in interface StreamLog

getLogTail

public long getLogTail()

Description copied from interface: StreamLog

Get the global log tail.

Specified by:

getLogTail in interface StreamLog

getAllTails

public TailsResponse getAllTails()

Description copied from interface: StreamLog

Get global and all stream tails.

Specified by:

getAllTails in interface StreamLog

getStreamsAddressSpace

public StreamsAddressResponse getStreamsAddressSpace()

Description copied from interface: StreamLog

Get the address space for every stream.

Specified by:

getStreamsAddressSpace in interface StreamLog

getTrimMark

public long getTrimMark()

Description copied from interface: StreamLog

Get the first untrimmed address in the address space.

Specified by:

getTrimMark in interface StreamLog

read

public LogData read(long address)

Description copied from interface: StreamLog

Given an address, read the corresponding stream entry.

Specified by:

read in interface StreamLog

Parameters:

address - address to read from the log

Returns:

Stream entry if it exists, otherwise return null

sync

public void sync(boolean force)

Description copied from interface: StreamLog

Sync the stream log file to secondary storage.

Specified by:

sync in interface StreamLog

Parameters:

force - force data to secondary storage if true

close

public void close()

Description copied from interface: StreamLog

Close the stream log.

Specified by:

close in interface StreamLog

compact

public void compact()

Description copied from interface: StreamLog

Remove all trimmed addresses from the StreamLog.

Specified by:

compact in interface StreamLog

reset

public void reset()

Description copied from interface: StreamLog

Clears all data and resets all segment handlers.

Specified by:

reset in interface StreamLog