Package org.apache.hadoop.ozone.container.common.statemachine.commandhandler

Class ClosePipelineCommandHandler

java.lang.Object

org.apache.hadoop.ozone.container.common.statemachine.commandhandler.ClosePipelineCommandHandler

All Implemented Interfaces:

CommandHandler

public class ClosePipelineCommandHandler
extends Object
implements CommandHandler

Handler for close pipeline command received from SCM.

Constructor Summary

Constructors

Constructor	Description
ClosePipelineCommandHandler(BiFunction<org.apache.ratis.protocol.RaftPeer,org.apache.ratis.grpc.GrpcTlsConfig,org.apache.ratis.client.RaftClient> newRaftClient, Executor executor)	Constructs a closePipelineCommand handler.
ClosePipelineCommandHandler(org.apache.hadoop.hdds.conf.ConfigurationSource conf, Executor executor)	Constructs a closePipelineCommand handler.

Method Summary

Modifier and Type	Method	Description
long	getAverageRunTime()	Returns the average time this function takes to run.
org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMCommandProto.Type	getCommandType()	Returns the command type that this command handler handles.
int	getInvocationCount()	Returns number of times this handler has been invoked.
int	getQueuedCount()	Returns the queued command count for this handler.
long	getTotalRunTime()	Returns the total time this function takes to run.
void	handle(SCMCommand<?> command, OzoneContainer ozoneContainer, StateContext context, SCMConnectionManager connectionManager)	Handles a given SCM command.
boolean	isPipelineCloseInProgress(UUID pipelineID)	Returns true if pipeline close is in progress, else false.

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.statemachine.commandhandler.CommandHandler

getThreadPoolActivePoolSize, getThreadPoolMaxPoolSize, stop, updateCommandStatus

Constructor Details

ClosePipelineCommandHandler

public ClosePipelineCommandHandler(org.apache.hadoop.hdds.conf.ConfigurationSource conf,
 Executor executor)

Constructs a closePipelineCommand handler.

ClosePipelineCommandHandler

public ClosePipelineCommandHandler(BiFunction<org.apache.ratis.protocol.RaftPeer,org.apache.ratis.grpc.GrpcTlsConfig,org.apache.ratis.client.RaftClient> newRaftClient,
 Executor executor)

Constructs a closePipelineCommand handler.

Method Details

isPipelineCloseInProgress

public boolean isPipelineCloseInProgress(UUID pipelineID)

Returns true if pipeline close is in progress, else false.

Returns:

boolean

handle

public void handle(SCMCommand<?> command,
 OzoneContainer ozoneContainer,
 StateContext context,
 SCMConnectionManager connectionManager)

Handles a given SCM command.

Specified by:

handle in interface CommandHandler

Parameters:

command - - SCM Command

ozoneContainer - - Ozone Container.

context - - Current Context.

connectionManager - - The SCMs that we are talking to.

getCommandType

public org.apache.hadoop.hdds.protocol.proto.StorageContainerDatanodeProtocolProtos.SCMCommandProto.Type getCommandType()

Returns the command type that this command handler handles.

Specified by:

getCommandType in interface CommandHandler

Returns:

Type

getInvocationCount

public int getInvocationCount()

Returns number of times this handler has been invoked.

Specified by:

getInvocationCount in interface CommandHandler

Returns:

int

getAverageRunTime

public long getAverageRunTime()

Returns the average time this function takes to run.

Specified by:

getAverageRunTime in interface CommandHandler

Returns:

long

getTotalRunTime

public long getTotalRunTime()

Description copied from interface: CommandHandler

Returns the total time this function takes to run.

Specified by:

getTotalRunTime in interface CommandHandler

Returns:

long

getQueuedCount

public int getQueuedCount()

Description copied from interface: CommandHandler

Returns the queued command count for this handler.

Specified by:

getQueuedCount in interface CommandHandler

Returns:

The number of queued commands inside this handler.