Package io.deephaven.io.log.impl

Class LogOutputBaseImpl

java.lang.Object

io.deephaven.io.log.impl.LogOutputBaseImpl

All Implemented Interfaces:

LogOutput, ByteBufferSink

Direct Known Subclasses:

LogOutputCsvImpl

public abstract class LogOutputBaseImpl
extends Object
implements LogOutput, ByteBufferSink

Nested Class Summary

Nested classes/interfaces inherited from interface io.deephaven.base.log.LogOutput

LogOutput.LongFormatter, LogOutput.Null, LogOutput.ObjFormatter<T>, LogOutput.ObjIntIntFormatter<T>, LogOutput.ObjObjFormatter<T,U>

Field Summary

Fields

Modifier and Type	Field	Description
protected final ByteBufferOutputStream	stream

Fields inherited from interface io.deephaven.base.log.LogOutput

APPENDABLE_ARRAY_FORMATTER, APPENDABLE_COLLECTION_FORMATTER, BASIC_FORMATTER, BOOLEAN_ARRAY_FORMATTER, INT_ARRAY_FORMATTER, LOCAL_DATE_TIME_FORMATTER, MILLIS_FROM_EPOCH_FORMATTER, millisFormatter, NULL, NULL_TERMINATED_STRING_FORMATTER, SOCKADDR_FORMATTER, STRING_ARRAY_FORMATTER, STRING_COLLECTION_FORMATTER

Constructor Summary

Constructors

Constructor	Description
LogOutputBaseImpl(LogBufferPool bufferPool)

Method Summary

Modifier and Type	Method	Description
ByteBuffer	acceptBuffer(ByteBuffer b, int need)	Dispose of the contents of the buffer b, probably by writing them to a channel, and return a new buffer in which writing can continue.
LogOutput	clear()
LogOutput	close()
void	close(ByteBuffer b)	Dispose of the contents of the final buffer in an output sequence, probably by writing them to a channel.
ByteBuffer	getBuffer(int i)
int	getBufferCount()
int	getEndOfHeaderOffset()
LogOutput	markEndOfHeader()
int	relativeSize()
int	size()
LogOutput	start()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.base.log.LogOutput

append, append, append, append, append, append, append, append, append, append, append, append, append, append, append, append, append, append, append, append, append, append, appendDouble, appendDouble, appendTimestamp, appendTimestampMicros, nf, nl

Field Details

stream

protected final ByteBufferOutputStream stream

Constructor Details

LogOutputBaseImpl

public LogOutputBaseImpl(LogBufferPool bufferPool)

Method Details

markEndOfHeader

public LogOutput markEndOfHeader()

Specified by:

markEndOfHeader in interface LogOutput

getEndOfHeaderOffset

public int getEndOfHeaderOffset()

Specified by:

getEndOfHeaderOffset in interface LogOutput

acceptBuffer

public ByteBuffer acceptBuffer(ByteBuffer b,
 int need)

Description copied from interface: ByteBufferSink

Dispose of the contents of the buffer b, probably by writing them to a channel, and return a new buffer in which writing can continue. The returned buffer must have at least need bytes of space remaining. The return value may be the same buffer, as long as it's remaining() value has been increased to be >= need.

Specified by:

acceptBuffer in interface ByteBufferSink

Parameters:

b - the buffer whose contents need to be disposed of.

Returns:

the buffer in which further output should be written.

close

public void close(ByteBuffer b)
           throws IOException

Description copied from interface: ByteBufferSink

Dispose of the contents of the final buffer in an output sequence, probably by writing them to a channel. Note that the argument buffer may be empty. Then do whatever it takes to release the resources of the sink, probably by closing a channel.

Specified by:

close in interface ByteBufferSink

Throws:

IOException

start

public LogOutput start()

Specified by:

start in interface LogOutput

close

public LogOutput close()

Specified by:

close in interface LogOutput

relativeSize

public int relativeSize()

Specified by:

relativeSize in interface LogOutput

size

public int size()

Specified by:

size in interface LogOutput

getBufferCount

public int getBufferCount()

Specified by:

getBufferCount in interface LogOutput

getBuffer

public ByteBuffer getBuffer(int i)

Specified by:

getBuffer in interface LogOutput

clear

public LogOutput clear()

Specified by:

clear in interface LogOutput