alluxio.worker.block

Class TestSpecificMasterBlockSync

java.lang.Object

alluxio.worker.block.SpecificMasterBlockSync

alluxio.worker.block.TestSpecificMasterBlockSync

All Implemented Interfaces:

HeartbeatExecutor, Closeable, AutoCloseable

@NotThreadSafe
public final class TestSpecificMasterBlockSync
extends SpecificMasterBlockSync

A test SpecificMasterBlockSync that adds some interfaces for testing.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.worker.block.SpecificMasterBlockSync

SpecificMasterBlockSync.Metrics

Constructor Summary

Constructors

Constructor and Description
TestSpecificMasterBlockSync(BlockWorker blockWorker, BlockMasterClient masterClient, BlockHeartbeatReporter heartbeatReporter) Creates a new instance of SpecificMasterBlockSync.

Method Summary

Modifier and Type	Method and Description
protected void	beforeHeartbeat()
void	failHeartbeat() Fails the heartbeat and lets it throws an exception.
int	getRegistrationSuccessCount()
protected void	registerWithMasterInternal()
void	restoreHeartbeat() Restores the heartbeat.

Methods inherited from class alluxio.worker.block.SpecificMasterBlockSync

close, heartbeat, isRegistered

Methods inherited from class java.lang.Object

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

Constructor Detail

TestSpecificMasterBlockSync

public TestSpecificMasterBlockSync(BlockWorker blockWorker,
                                   BlockMasterClient masterClient,
                                   BlockHeartbeatReporter heartbeatReporter)
                            throws IOException

Creates a new instance of SpecificMasterBlockSync.

Parameters:

blockWorker - the BlockWorker this syncer is updating to

masterClient - the block master client

heartbeatReporter - the heartbeat reporter

Throws:

IOException

Method Detail

restoreHeartbeat

public void restoreHeartbeat()

Restores the heartbeat.

failHeartbeat

public void failHeartbeat()

Fails the heartbeat and lets it throws an exception.

getRegistrationSuccessCount

public int getRegistrationSuccessCount()

Returns:

registration success count

registerWithMasterInternal

protected void registerWithMasterInternal()
                                   throws IOException,
                                          FailedToAcquireRegisterLeaseException

Overrides:

registerWithMasterInternal in class SpecificMasterBlockSync

Throws:

IOException

FailedToAcquireRegisterLeaseException

beforeHeartbeat

protected void beforeHeartbeat()

Overrides:

beforeHeartbeat in class SpecificMasterBlockSync