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

Class RunningDatanodeState

java.lang.Object

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

All Implemented Interfaces:

DatanodeState

public class RunningDatanodeState
extends Object
implements DatanodeState

Class that implements handshake with SCM.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
DatanodeStateMachine.DatanodeStates	await(long duration, TimeUnit timeUnit)	Wait for execute to finish.
void	clear()	Clean up some resources.
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.
void	setExecutorCompletionService(ExecutorCompletionService e)

Methods inherited from class java.lang.Object

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

Constructor Details

RunningDatanodeState

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

Method Details

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

setExecutorCompletionService

public void setExecutorCompletionService(ExecutorCompletionService e)

await

public DatanodeStateMachine.DatanodeStates await(long duration,
 TimeUnit timeUnit)
                                          throws InterruptedException

Wait for execute to finish.

Specified by:

await in interface DatanodeState

Parameters:

duration - - Time

timeUnit - - Unit of duration.

Throws:

InterruptedException

clear

public void clear()

Description copied from interface: DatanodeState

Clean up some resources.

Specified by:

clear in interface DatanodeState