-
Notifications
You must be signed in to change notification settings - Fork 24.9k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Asynchronously connect to remote clusters #44825
Conversation
Pinging @elastic/es-distributed |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I've left a few questions mainly around the need for a number of uses of the mutex
.
server/src/main/java/org/elasticsearch/transport/RemoteClusterConnection.java
Outdated
Show resolved
Hide resolved
server/src/main/java/org/elasticsearch/transport/RemoteClusterConnection.java
Show resolved
Hide resolved
server/src/main/java/org/elasticsearch/transport/RemoteClusterConnection.java
Outdated
Show resolved
Hide resolved
server/src/main/java/org/elasticsearch/transport/RemoteClusterConnection.java
Outdated
Show resolved
Hide resolved
server/src/main/java/org/elasticsearch/transport/RemoteClusterConnection.java
Outdated
Show resolved
Hide resolved
server/src/main/java/org/elasticsearch/transport/RemoteClusterConnection.java
Show resolved
Hide resolved
server/src/main/java/org/elasticsearch/transport/RemoteClusterConnection.java
Outdated
Show resolved
Hide resolved
server/src/main/java/org/elasticsearch/transport/RemoteClusterConnection.java
Outdated
Show resolved
Hide resolved
server/src/main/java/org/elasticsearch/transport/RemoteClusterConnection.java
Show resolved
Hide resolved
server/src/main/java/org/elasticsearch/transport/RemoteClusterConnection.java
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@original-brownbear I have reworked the synchronization bit, and moved to a list instead of a blocking queue (I find it easier to think about it in terms of a simple list + mutex). Can you have another look?
@elasticmachine run elasticsearch-ci/2 (unrelated watcher issue) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM, thanks @ywelsch :)
server/src/main/java/org/elasticsearch/transport/RemoteClusterConnection.java
Show resolved
Hide resolved
@elasticmachine run elasticsearch-ci/packaging-sample |
Jenkins run elasticsearch-ci/bwc |
Refactors RemoteClusterConnection so that it no longer blockingly connects to remote clusters. Relates to #40150
Refactors RemoteClusterConnection so that it no longer blockingly connects to remote clusters. Relates to #40150
Refactors
RemoteClusterConnection
so that it no longer blockingly connects to remote clusters.Relates to #40150