526527528529530531532533534535536
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); isRetry = true; } } private String createSequential(String path, byte[] data,
561562563564565566567568569570571
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).
618619620621622623624625626627628
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); } } finally { if (traceScope != null) traceScope.close(); } }
148149150151152153154155156157158
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); isRetry = true; } } /**
176177178179180181182183184185186
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); } } /** * exists is an idempotent operation. Retry before throwing exception
203204205206207208209210211212213
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); } } private void retryOrThrow(RetryCounter retryCounter, KeeperException e, String opName) throws KeeperException {
240241242243244245246247248249250
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); } } /** * getChildren is an idempotent operation. Retry before throwing exception
267268269270271272273274275276277
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); } } /** * getData is an idempotent operation. Retry before throwing exception
295296297298299300301302303304305
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); } } /** * getData is an idemnpotent operation. Retry before throwing exception
323324325326327328329330331332333
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); } } /** * setData is NOT an idempotent operation. Retry may cause BadVersion