Package org.apache.hadoop.ozone.container.common.states.datanode

Class InitDatanodeState

java.lang.Object

org.apache.hadoop.ozone.container.common.states.datanode.InitDatanodeState

All Implemented Interfaces:

Callable<DatanodeStateMachine.DatanodeStates>, DatanodeState

public class InitDatanodeState
extends Object
implements DatanodeState, Callable<DatanodeStateMachine.DatanodeStates>

Init Datanode State is the task that gets run when we are in Init State.

Constructor Summary

Constructors

Constructor	Description
InitDatanodeState(org.apache.hadoop.hdds.conf.ConfigurationSource conf, SCMConnectionManager connectionManager, StateContext context)	Create InitDatanodeState Task.

Method Summary

Modifier and Type	Method	Description
DatanodeStateMachine.DatanodeStates	await(long time, TimeUnit timeUnit)	Wait for execute to finish.
DatanodeStateMachine.DatanodeStates	call()	Computes a result, or throws an exception if unable to do so.
void	execute(ExecutorService executor)	Executes one or more tasks that is needed by this state.
void	onEnter()	Called before entering this state.
void	onExit()	Called After exiting this state.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.ozone.container.common.states.DatanodeState

clear

Constructor Details

InitDatanodeState

public InitDatanodeState(org.apache.hadoop.hdds.conf.ConfigurationSource conf,
 SCMConnectionManager connectionManager,
 StateContext context)

Create InitDatanodeState Task.

Parameters:

conf - - Conf

connectionManager - - Connection Manager

context - - Current Context

Method Details

call

public DatanodeStateMachine.DatanodeStates call()
                                         throws Exception

Computes a result, or throws an exception if unable to do so.

Specified by:

call in interface Callable<DatanodeStateMachine.DatanodeStates>

Returns:

computed result

Throws:

Exception - if unable to compute a result

onEnter

public void onEnter()

Called before entering this state.

Specified by:

onEnter in interface DatanodeState

onExit

public void onExit()

Called After exiting this state.

Specified by:

onExit in interface DatanodeState

execute

public void execute(ExecutorService executor)

Executes one or more tasks that is needed by this state.

Specified by:

execute in interface DatanodeState

Parameters:

executor - - ExecutorService

await

public DatanodeStateMachine.DatanodeStates await(long time,
 TimeUnit timeUnit)
                                          throws InterruptedException,
ExecutionException,
TimeoutException

Wait for execute to finish.

Specified by:

await in interface DatanodeState

Parameters:

time - - Time

timeUnit - - Unit of time.

Throws:

InterruptedException

ExecutionException

TimeoutException