org.gridgain.grid.persistentstore.snapshot.file

Class DigestSnapshotOutputStreamWrapper

java.lang.Object

org.gridgain.grid.persistentstore.snapshot.file.DigestSnapshotOutputStreamWrapper

All Implemented Interfaces:

AutoCloseable, org.gridgain.grid.internal.processors.cache.database.snapshot.DigestSnapshotOutputStream, org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOutputStream

public class DigestSnapshotOutputStreamWrapper
extends Object
implements org.gridgain.grid.internal.processors.cache.database.snapshot.DigestSnapshotOutputStream

A wrapper class that implements DigestSnapshotOutputStream interface.

Constructor Summary

Constructors

Constructor and Description
DigestSnapshotOutputStreamWrapper(org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOutputStream snapStream, DigestOutputStream digestStream) Constructor for the wrapper instance.

Method Summary

Modifier and Type	Method and Description
void	close() Close method.
byte[]	digest()
void	plainWrite(ByteBuffer data) Writes plain data to stream.
long	position() Returns this stream's position.
void	write(ByteBuffer data) Writes the given page.

Methods inherited from class java.lang.Object

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

Constructor Detail

DigestSnapshotOutputStreamWrapper

public DigestSnapshotOutputStreamWrapper(org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOutputStream snapStream,
                                         DigestOutputStream digestStream)

Constructor for the wrapper instance. Parameters must correspond to each other. There's no elegant way to check that in code, so we have to trust the caller.

Parameters:

snapStream - Snapshot output stream to delegate calls to.

digestStream - Output stream that's eventually used by snapStream to write data to file.

Method Detail

write

public void write(ByteBuffer data)
           throws IgniteCheckedException

Writes the given page.

Specified by:

write in interface org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOutputStream

Parameters:

data - Page data or metadata.

Throws:

IgniteCheckedException - Exception in case of write.

plainWrite

public void plainWrite(ByteBuffer data)
                throws IgniteCheckedException

Writes plain data to stream. It is used for writing a WAL record.

Specified by:

plainWrite in interface org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOutputStream

Parameters:

data - Plain data.

Throws:

IgniteCheckedException - If IO exception has happened.

close

public void close()
           throws IgniteCheckedException

Close method.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOutputStream

Throws:

IgniteCheckedException - in case of IO failure.

position

public long position()

Returns this stream's position.

Specified by:

position in interface org.gridgain.grid.internal.processors.cache.database.snapshot.SnapshotOutputStream

Returns:

This stream's position, a non-negative integer counting the number of bytes written to the stream.

digest

public byte[] digest()

Specified by:

digest in interface org.gridgain.grid.internal.processors.cache.database.snapshot.DigestSnapshotOutputStream

Returns:

Digest computed over stream data.