Package org.apache.solr.common.cloud
Class ZkCmdExecutor
- java.lang.Object
-
- org.apache.solr.common.cloud.ZkCmdExecutor
-
public class ZkCmdExecutor extends Object
-
-
Constructor Summary
Constructors Constructor Description ZkCmdExecutor(int timeoutms)ZkCmdExecutor(int timeoutms, ConnectionManager.IsClosed isClosed)TODO: At this point, this should probably take a SolrZkClient in its constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description longgetRetryDelay()protected voidretryDelay(int attemptCount)Performs a retry delay if this is not the first attempt<T> TretryOperation(ZkOperation<T> operation)Perform the given operation, retrying if the connection failsvoidsetRetryDelay(long retryDelay)
-
-
-
Constructor Detail
-
ZkCmdExecutor
public ZkCmdExecutor(int timeoutms)
-
ZkCmdExecutor
public ZkCmdExecutor(int timeoutms, ConnectionManager.IsClosed isClosed)TODO: At this point, this should probably take a SolrZkClient in its constructor.- Parameters:
timeoutms- the client timeout for the ZooKeeper clients that will be used with this class.
-
-
Method Detail
-
getRetryDelay
public long getRetryDelay()
-
setRetryDelay
public void setRetryDelay(long retryDelay)
-
retryOperation
public <T> T retryOperation(ZkOperation<T> operation) throws org.apache.zookeeper.KeeperException, InterruptedException
Perform the given operation, retrying if the connection fails- Throws:
org.apache.zookeeper.KeeperExceptionInterruptedException
-
retryDelay
protected void retryDelay(int attemptCount) throws InterruptedExceptionPerforms a retry delay if this is not the first attempt- Parameters:
attemptCount- the number of the attempts performed so far- Throws:
InterruptedException
-
-