org.corfudb.infrastructure.log

Interface StreamLogWithRankedAddressSpace

All Superinterfaces:

StreamLog

All Known Implementing Classes:

InMemoryStreamLog, StreamLogFiles

public interface StreamLogWithRankedAddressSpace
extends StreamLog

Stream log that is able to compare the data on the same log address using the rank and type.

Created by Konstantin Spirov on 3/15/2017.

Method Summary

Modifier and Type	Method and Description
default void	assertAppendPermittedUnsafe(long address, LogData newEntry) Check whether the data can be appended to a given log address.

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

append, append, close, compact, getAllTails, getLogTail, getOverwriteCauseForAddress, getStreamsAddressSpace, getTails, getTrimMark, prefixTrim, read, reset, sync

Method Detail

assertAppendPermittedUnsafe

default void assertAppendPermittedUnsafe(long address,
                                         LogData newEntry)
                                  throws DataOutrankedException,
                                         ValueAdoptedException

Check whether the data can be appended to a given log address. Note that it is not permitted multiple threads to access the same log address concurrently through this method, this method does not lock or synchronize. This method needs

Parameters:

address - log address of append

newEntry - log entry to append

Throws:

DataOutrankedException - if the log entry cannot be assigned to this log address as there is a data with higher rank

ValueAdoptedException - if the new message is a proposal during the two phase recovery write and there is an existing data at this log address already.