Module org.elasticsearch.server
Class TransportVerifyShardBeforeCloseAction
java.lang.Object
org.elasticsearch.action.support.TransportAction<TransportVerifyShardBeforeCloseAction.ShardRequest,ReplicationResponse>
org.elasticsearch.action.support.replication.TransportReplicationAction<TransportVerifyShardBeforeCloseAction.ShardRequest,TransportVerifyShardBeforeCloseAction.ShardRequest,ReplicationResponse>
org.elasticsearch.action.admin.indices.close.TransportVerifyShardBeforeCloseAction
public class TransportVerifyShardBeforeCloseAction
extends TransportReplicationAction<TransportVerifyShardBeforeCloseAction.ShardRequest,TransportVerifyShardBeforeCloseAction.ShardRequest,ReplicationResponse>
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic final classNested classes/interfaces inherited from class org.elasticsearch.action.support.replication.TransportReplicationAction
TransportReplicationAction.ConcreteReplicaRequest<R extends TransportRequest>, TransportReplicationAction.ConcreteShardRequest<R extends TransportRequest>, TransportReplicationAction.PrimaryActionExecution, TransportReplicationAction.PrimaryResult<ReplicaRequest extends ReplicationRequest<ReplicaRequest>,Response extends ReplicationResponse>, TransportReplicationAction.ReplicaActionExecution, TransportReplicationAction.ReplicaResponse, TransportReplicationAction.ReplicaResult, TransportReplicationAction.ReplicasProxy, TransportReplicationAction.RetryOnReplicaException, TransportReplicationAction.SyncGlobalCheckpointAfterOperation -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final Stringstatic final ActionType<ReplicationResponse> Fields inherited from class org.elasticsearch.action.support.replication.TransportReplicationAction
clusterService, executor, forceExecutionOnPrimary, indicesService, REPLICATION_INITIAL_RETRY_BACKOFF_BOUND, REPLICATION_RETRY_TIMEOUT, shardStateAction, threadPool, transportOptions, transportPrimaryAction, transportReplicaAction, transportServiceFields inherited from class org.elasticsearch.action.support.TransportAction
actionName, taskManager -
Constructor Summary
ConstructorsConstructorDescriptionTransportVerifyShardBeforeCloseAction(Settings settings, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction stateAction, ActionFilters actionFilters) -
Method Summary
Modifier and TypeMethodDescriptionprotected voidacquirePrimaryOperationPermit(IndexShard primary, TransportVerifyShardBeforeCloseAction.ShardRequest request, ActionListener<Releasable> onAcquired) Executes the logic for acquiring one or more operation permit on a primary shard.protected voidacquireReplicaOperationPermit(IndexShard replica, TransportVerifyShardBeforeCloseAction.ShardRequest request, ActionListener<Releasable> onAcquired, long primaryTerm, long globalCheckpoint, long maxSeqNoOfUpdateOrDeletes) Executes the logic for acquiring one or more operation permit on a replica shard.protected ReplicationResponseprotected voidshardOperationOnPrimary(TransportVerifyShardBeforeCloseAction.ShardRequest shardRequest, IndexShard primary, ActionListener<TransportReplicationAction.PrimaryResult<TransportVerifyShardBeforeCloseAction.ShardRequest, ReplicationResponse>> listener) Primary operation on node with primary copy.protected voidshardOperationOnReplica(TransportVerifyShardBeforeCloseAction.ShardRequest shardRequest, IndexShard replica, ActionListener<TransportReplicationAction.ReplicaResult> listener) Execute the specified replica operation.Methods inherited from class org.elasticsearch.action.support.replication.TransportReplicationAction
adaptResponse, checkOperationLimits, checkPrimaryLimits, checkReplicaLimits, doExecute, globalBlockLevel, handlePrimaryRequest, handleReplicaRequest, indexBlockLevel, resolveRequest, retryPrimaryException, transportOptionsMethods inherited from class org.elasticsearch.action.support.TransportAction
execute, executeDirect, localOnly
-
Field Details
-
NAME
- See Also:
-
TYPE
-
-
Constructor Details
-
TransportVerifyShardBeforeCloseAction
@Inject public TransportVerifyShardBeforeCloseAction(Settings settings, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction stateAction, ActionFilters actionFilters)
-
-
Method Details
-
newResponseInstance
-
acquirePrimaryOperationPermit
protected void acquirePrimaryOperationPermit(IndexShard primary, TransportVerifyShardBeforeCloseAction.ShardRequest request, ActionListener<Releasable> onAcquired) Description copied from class:TransportReplicationActionExecutes the logic for acquiring one or more operation permit on a primary shard. The default is to acquire a single permit but this method can be overridden to acquire more. -
acquireReplicaOperationPermit
protected void acquireReplicaOperationPermit(IndexShard replica, TransportVerifyShardBeforeCloseAction.ShardRequest request, ActionListener<Releasable> onAcquired, long primaryTerm, long globalCheckpoint, long maxSeqNoOfUpdateOrDeletes) Description copied from class:TransportReplicationActionExecutes the logic for acquiring one or more operation permit on a replica shard. The default is to acquire a single permit but this method can be overridden to acquire more. -
shardOperationOnPrimary
protected void shardOperationOnPrimary(TransportVerifyShardBeforeCloseAction.ShardRequest shardRequest, IndexShard primary, ActionListener<TransportReplicationAction.PrimaryResult<TransportVerifyShardBeforeCloseAction.ShardRequest, ReplicationResponse>> listener) Description copied from class:TransportReplicationActionPrimary operation on node with primary copy.- Specified by:
shardOperationOnPrimaryin classTransportReplicationAction<TransportVerifyShardBeforeCloseAction.ShardRequest,TransportVerifyShardBeforeCloseAction.ShardRequest, ReplicationResponse> - Parameters:
shardRequest- the request to the primary shardprimary- the primary shard to perform the operation on
-
shardOperationOnReplica
protected void shardOperationOnReplica(TransportVerifyShardBeforeCloseAction.ShardRequest shardRequest, IndexShard replica, ActionListener<TransportReplicationAction.ReplicaResult> listener) Description copied from class:TransportReplicationActionExecute the specified replica operation. This is done under a permit fromIndexShard.acquireReplicaOperationPermit(long, long, long, ActionListener, Executor).- Specified by:
shardOperationOnReplicain classTransportReplicationAction<TransportVerifyShardBeforeCloseAction.ShardRequest,TransportVerifyShardBeforeCloseAction.ShardRequest, ReplicationResponse> - Parameters:
shardRequest- the request to the replica shardreplica- the replica shard to perform the operation on
-
newReplicasProxy
protected ReplicationOperation.Replicas<TransportVerifyShardBeforeCloseAction.ShardRequest> newReplicasProxy()
-