flasn4nt
/
grpc-java
mirror of https://github.com/grpc/grpc-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

reframe comments

This commit is contained in:
AgraVator 2025-07-23 10:27:10 +05:30
parent c7135618ae
commit ca8e9ede7e
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
core/src/main/java/io/grpc/internal/DelayedClientTransport.java
View File

@ -201,8 +201,8 @@ final class DelayedClientTransport implements ManagedClientTransport {
} }
/** /**
* Prevents creating any new streams. Buffered streams are not failed and may still proceed * Prevents creating any new streams. Buffered streams are not failed and may still proceed
* when {@link #reprocess} is called. The delayed transport will be terminated when there is no * when {@link #reprocess} is called. The delayed transport will be terminated when there is no
* more buffered streams. * more buffered streams.
*/ */
@Override @Override

2
core/src/main/java/io/grpc/internal/InternalSubchannel.java
View File

@ -656,7 +656,7 @@ final class InternalSubchannel implements InternalInstrumented<ChannelStats>, Tr
Preconditions.checkState(state.getState() == CONNECTING, Preconditions.checkState(state.getState() == CONNECTING,
"Expected state is CONNECTING, actual state is %s", state.getState()); "Expected state is CONNECTING, actual state is %s", state.getState());
addressIndex.increment(); addressIndex.increment();
// Continue reconnecting with remaining addresses. // Continue to reconnect if there are still addresses to try.
if (!addressIndex.isValid()) { if (!addressIndex.isValid()) {
pendingTransport = null; pendingTransport = null;
addressIndex.reset(); addressIndex.reset();

2
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java
View File

@ -92,7 +92,7 @@ final class PickFirstLeafLoadBalancer extends LoadBalancer {
return Status.FAILED_PRECONDITION.withDescription("Already shut down"); return Status.FAILED_PRECONDITION.withDescription("Already shut down");
} }
// Check weather or not this is a petiole policy, which is based off of an address attribute // Check whether this is a petiole policy, which is based off of an address attribute
Boolean isPetiolePolicy = resolvedAddresses.getAttributes().get(IS_PETIOLE_POLICY); Boolean isPetiolePolicy = resolvedAddresses.getAttributes().get(IS_PETIOLE_POLICY);
this.notAPetiolePolicy = isPetiolePolicy == null || !isPetiolePolicy; this.notAPetiolePolicy = isPetiolePolicy == null || !isPetiolePolicy;