Skip to content

Commit 8bb2a91

Browse files
committed
fíx HostHandler concurrency (DE-663)
1 parent 02b6e56 commit 8bb2a91

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

Diff for: core/src/main/java/com/arangodb/internal/net/FallbackHostHandler.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626

2727
import java.util.ArrayList;
2828
import java.util.List;
29+
import java.util.concurrent.CopyOnWriteArrayList;
2930

3031
/**
3132
* @author Mark Vollmary
@@ -41,7 +42,7 @@ public class FallbackHostHandler implements HostHandler {
4142

4243
public FallbackHostHandler(final HostResolver resolver) {
4344
this.resolver = resolver;
44-
lastFailExceptions = new ArrayList<>();
45+
lastFailExceptions = new CopyOnWriteArrayList<>();
4546
reset();
4647
hosts = resolver.getHosts();
4748
current = lastSuccess = hosts.getHostsList().get(0);

Diff for: core/src/main/java/com/arangodb/internal/net/RoundRobinHostHandler.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@
2828

2929
import java.util.ArrayList;
3030
import java.util.List;
31+
import java.util.concurrent.CopyOnWriteArrayList;
3132

3233
/**
3334
* @author Mark Vollmary
@@ -45,7 +46,7 @@ public class RoundRobinHostHandler implements HostHandler {
4546
public RoundRobinHostHandler(final HostResolver resolver) {
4647
super();
4748
this.resolver = resolver;
48-
lastFailExceptions = new ArrayList<>();
49+
lastFailExceptions = new CopyOnWriteArrayList<>();
4950
hosts = resolver.getHosts();
5051
current = 0L;
5152
reset();

0 commit comments

Comments
 (0)