317318319320321322323324325326327
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); } } /** * getData is an idemnpotent operation. Retry before throwing exception
345346347348349350351352353354355
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); } } /** * setData is NOT an idempotent operation. Retry may cause BadVersion Exception
391392393394395396397398399400401
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); isRetry = true; } } /**
470471472473474475476477478479480
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); isRetry = true; } } private String createSequential(String path, byte[] data,
505506507508509510511512513514515
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).
559560561562563564565566567568569
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); } } private String findPreviousSequentialNode(String path) throws KeeperException, InterruptedException {
147148149150151152153154155156157
175176177178179180181182183184185
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); } } /** * exists is an idempotent operation. Retry before throwing exception
202203204205206207208209210211212
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); } } private void retryOrThrow(RetryCounter retryCounter, KeeperException e, String opName) throws KeeperException {
239240241242243244245246247248249
default: throw e; } } retryCounter.sleepUntilNextRetry(); retryCounter.useRetry(); } } /** * getChildren is an idempotent operation. Retry before throwing exception