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

Add Info log for gRPC LB's init response

This commit is contained in:
ZhouyihaiDing 2021-06-29 16:08:27 -07:00 committed by Eric Anderson
parent dd2a422193
commit 22aa8fcef1
2 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java
View File

@ -690,11 +690,12 @@ final class GrpclbState {
if (closed) {
return;
}
logger.log(
ChannelLogLevel.DEBUG, "[grpclb-<{0}>] Got an LB response: {1}", serviceName, response);
LoadBalanceResponseTypeCase typeCase = response.getLoadBalanceResponseTypeCase();
if (!initialResponseReceived) {
logger.log(
ChannelLogLevel.INFO,
"[grpclb-<{0}>] Got an LB initial response: {1}", serviceName, response);
if (typeCase != LoadBalanceResponseTypeCase.INITIAL_RESPONSE) {
logger.log(
ChannelLogLevel.WARNING,
@ -710,6 +711,9 @@ final class GrpclbState {
return;
}
logger.log(
ChannelLogLevel.DEBUG, "[grpclb-<{0}>] Got an LB response: {1}", serviceName, response);
if (typeCase == LoadBalanceResponseTypeCase.FALLBACK_RESPONSE) {
// Force entering fallback requested by balancer.
cancelFallbackTimer();

4
grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java
View File

@ -929,7 +929,7 @@ public class GrpclbLoadBalancerTest {
logs.clear();
lbResponseObserver.onNext(buildInitialResponse());
assertThat(logs).containsExactly(
"DEBUG: [grpclb-<api.google.com>] Got an LB response: " + buildInitialResponse());
"INFO: [grpclb-<api.google.com>] Got an LB initial response: " + buildInitialResponse());
logs.clear();
lbResponseObserver.onNext(buildLbResponse(backends1));
@ -2522,7 +2522,7 @@ public class GrpclbLoadBalancerTest {
logs.clear();
lbResponseObserver.onNext(buildInitialResponse());
assertThat(logs).containsExactly(
"DEBUG: [grpclb-<api.google.com>] Got an LB response: " + buildInitialResponse());
"INFO: [grpclb-<api.google.com>] Got an LB initial response: " + buildInitialResponse());
logs.clear();
lbResponseObserver.onNext(buildLbResponse(backends1));