388389390391392393394395396397398
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); } } finally { if (traceScope != null) traceScope.close(); } }
440441442443444445446447448449450
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); isRetry = true; } } finally { if (traceScope != null) traceScope.close(); }
528529530531532533534535536537538
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); isRetry = true; } } private String createSequential(String path, byte[] data,
563564565566567568569570571572573
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); } } /** * Convert Iterable of {@link ZKOp} we got into the ZooKeeper.Op * instances to actually pass to multi (need to do this in order to appendMetaData).
620621622623624625626627628629630
170171172173174175176177178179180
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); isRetry = true; } } /**
198199200201202203204205206207208
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); } } /** * exists is an idempotent operation. Retry before throwing exception
225226227228229230231232233234235
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); } } private void retryOrThrow(RetryCounter retryCounter, KeeperException e, String opName) throws KeeperException {
262263264265266267268269270271272
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); } } /** * getChildren is an idempotent operation. Retry before throwing exception
289290291292293294295296297298299
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); } } /** * getData is an idempotent operation. Retry before throwing exception