Package org.apache.bookkeeper.proto.checksum

Class CRC32DigestManager

java.lang.Object

org.apache.bookkeeper.proto.checksum.DigestManager

org.apache.bookkeeper.proto.checksum.CRC32DigestManager

class CRC32DigestManager
extends DigestManager

Digest manager for CRC32 checksum.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static interface	CRC32DigestManager.CRC32Digest	Interface that abstracts different implementations of the CRC32 digest.

Nested classes/interfaces inherited from class org.apache.bookkeeper.proto.checksum.DigestManager

DigestManager.RecoveryData

Field Summary

Fields inherited from class org.apache.bookkeeper.proto.checksum.DigestManager

LAC_METADATA_LENGTH, ledgerId, macCodeLength, METADATA_LENGTH, useV2Protocol

Constructor Summary

Constructors

Constructor	Description
CRC32DigestManager(long ledgerId, boolean useV2Protocol, io.netty.buffer.ByteBufAllocator allocator)

Method Summary

Modifier and Type	Method	Description
(package private) boolean	acceptsMemoryAddressBuffer()
(package private) int	getMacCodeLength()
(package private) int	internalUpdate(int digest, byte[] buffer, int offset, int len)
(package private) int	internalUpdate(int digest, io.netty.buffer.ByteBuf data, int offset, int len)
(package private) boolean	isInt32Digest()
(package private) void	populateValueAndReset(int digest, io.netty.buffer.ByteBuf buf)

Methods inherited from class org.apache.bookkeeper.proto.checksum.DigestManager

computeDigestAndPackageForSending, computeDigestAndPackageForSendingLac, generateMasterKey, instantiate, update, verifyDigestAndReturnData, verifyDigestAndReturnLac, verifyDigestAndReturnLastConfirmed

Methods inherited from class java.lang.Object

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

Constructor Details

CRC32DigestManager

public CRC32DigestManager(long ledgerId,
 boolean useV2Protocol,
 io.netty.buffer.ByteBufAllocator allocator)

Method Details

getMacCodeLength

int getMacCodeLength()

Specified by:

getMacCodeLength in class DigestManager

populateValueAndReset

void populateValueAndReset(int digest,
 io.netty.buffer.ByteBuf buf)

Specified by:

populateValueAndReset in class DigestManager

internalUpdate

int internalUpdate(int digest,
 io.netty.buffer.ByteBuf data,
 int offset,
 int len)

Specified by:

internalUpdate in class DigestManager

internalUpdate

int internalUpdate(int digest,
 byte[] buffer,
 int offset,
 int len)

Specified by:

internalUpdate in class DigestManager

isInt32Digest

boolean isInt32Digest()

Specified by:

isInt32Digest in class DigestManager

acceptsMemoryAddressBuffer

boolean acceptsMemoryAddressBuffer()

Specified by:

acceptsMemoryAddressBuffer in class DigestManager