-
Notifications
You must be signed in to change notification settings - Fork 3.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
api: Javadoc changes for io.grpc.LoadBalancer method signatures #11623
base: master
Are you sure you want to change the base?
Conversation
…h Duration" This reverts commit ab97045.
Below points have been addressed: javadoc for public void handleResolvedAddresses(ResolvedAddresses resolvedAddresses)
javadoc for public Status acceptResolvedAddresses(ResolvedAddresses resolvedAddresses)
|
@@ -179,12 +179,12 @@ public void handleResolvedAddresses(ResolvedAddresses resolvedAddresses) { | |||
* EquivalentAddressGroup} addresses should be considered equivalent but may be flattened into a | |||
* single list if needed. | |||
* | |||
* <p>Implementations can choose to reject the given addresses by returning {@code false}. | |||
* <p>Implementations can choose to reject the given addresses by returning {@code UNAVAILABLE}. |
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.
Replace with {@code Status.UNAVAILABLE} . Also below.
…d and related changes
@@ -263,7 +263,7 @@ public void shutdown() { | |||
new EquivalentAddressGroup(new SocketAddress(){})); | |||
ResolvedAddresses addresses = ResolvedAddresses.newBuilder().setAddresses(servers) | |||
.setAttributes(attrs).build(); | |||
balancer.handleResolvedAddresses(addresses); |
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.
We discussed not to change this test.
@@ -197,7 +201,7 @@ public Status acceptResolvedAddresses(ResolvedAddresses resolvedAddresses) { | |||
return unavailableStatus; | |||
} else { | |||
if (recursionCount++ == 0) { | |||
handleResolvedAddresses(resolvedAddresses); | |||
//handleResolvedAddresses(resolvedAddresses); |
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.
Why have you commented this out?
// parent policies, where they fail to call switchTo(). So we will use the exception to try | ||
// to notice those bugs quickly, as it will fail very loudly. | ||
throw new IllegalStateException( | ||
"GracefulSwitchLoadBalancer must switch to a load balancing policy before handling" |
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.
This must be added instead to acceptResolvedAddresses.
@@ -240,9 +240,8 @@ public void handleResolvedAddresses_delegatesToAcceptResolvedAddresses() { | |||
|
|||
LoadBalancer balancer = new LoadBalancer() { | |||
@Override | |||
public Status acceptResolvedAddresses(ResolvedAddresses resolvedAddresses) { | |||
public void handleResolvedAddresses(ResolvedAddresses resolvedAddresses) { | |||
resultCapture.set(resolvedAddresses); |
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.
Why this change? Revert.
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.
Rolled back please review
Javadoc changes for io.grpc.LoadBalancer
Fixes #11194