Skip to content

Instantly share code, notes, and snippets.

java.util.concurrent.CompletionException: io.atomix.copycat.error.ApplicationException: an application error occurred
at java.util.concurrent.CompletableFuture.reportJoin(CompletableFuture.java:375) ~[na:1.8.0_121]
at java.util.concurrent.CompletableFuture.join(CompletableFuture.java:1934) ~[na:1.8.0_121]
at io.atomix.catalyst.concurrent.BlockingFuture.join(BlockingFuture.java:68) ~[atomix-all-1.0.2.jar!/:na]
at atomixstuff.Main.main(Main.kt:90) ~[classes!/:na]
at atomixstuff.Main$start$1.run(Main.kt:42) [classes!/:na]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_121]
Caused by: io.atomix.copycat.error.ApplicationException: an application error occurred
at io.atomix.copycat.error.CopycatError$Type$4.createException(CopycatError.java:113) ~[atomix-all-1.0.2.jar!/:na]
at io.atomix.copycat.client.session.ClientSessionSubmitter$CommandAttempt.accept(ClientSessionSubmitter.java:282) ~[atomix-all-1.0.2.jar!/:na]
val value = replica.getLong("long-value").join()
value.onChange { change -> log.info("Changed: {} -> {}", change.oldValue(), change.newValue()) }
while (true) {
// the same
}
val value = replica.getLong("long-value").join()
while (true) {
val random = ThreadLocalRandom.current()
try {
log.info("Incrementing")
val f = value.incrementAndGet().join()
log.info("New value: {}", f)
Thread.sleep(random.nextLong(1000, 3000))
} catch (e: Exception) {
@redvasily
redvasily / subprocess_example.py
Created July 4, 2012 09:27
A python example for reading standard output from external process
p = subprocess.Popen(["ls"], shell=True,
stdout=subprocess.PIPE, close_fds=True)
data = p.communicate()[0]
if p.returncode:
sys.stderr.write('Bad exit code from hg\n')
sys.exit(1)
@redvasily
redvasily / ssh-wrapper.py
Created June 1, 2012 09:45
Ssh wrapper to be used with bcvi
#!/usr/bin/env python
import os
import sys
import time
import subprocess
def main():
host = sys.argv[1] if len(sys.argv) > 1 else None
[core]
pager = ""
[user]
name = Vasily Sulatskov
email = redvasily@gmail.com
[alias]
co = checkout
ci = commit
[core]
pager = ""
[user]
name = Vasily Sulatskov
email = redvasily@gmail.com
[alias]
co = checkout
ci = commit