File tree Expand file tree Collapse file tree 1 file changed +9
-9
lines changed
core/src/main/java/io/grpc/internal Expand file tree Collapse file tree 1 file changed +9
-9
lines changed Original file line number Diff line number Diff line change @@ -640,6 +640,15 @@ public void transportShutdown(final Status s) {
640640 addressIndex .getCurrentEagAttributes (), LoadBalancer .ATTR_LOCALITY_NAME ),
641641 null , null
642642 ));
643+ subchannelMetrics .recordDisconnection (buildLabelSet (
644+ getAttributeOrDefault (
645+ addressIndex .getCurrentEagAttributes (), NameResolver .ATTR_BACKEND_SERVICE ),
646+ getAttributeOrDefault (
647+ addressIndex .getCurrentEagAttributes (), LoadBalancer .ATTR_LOCALITY_NAME ),
648+ "Peer Pressure" ,
649+ extractSecurityLevel (
650+ addressIndex .getCurrentEagAttributes ().get (GrpcAttributes .ATTR_SECURITY_LEVEL ))
651+ ));
643652 syncContext .execute (new Runnable () {
644653 @ Override
645654 public void run () {
@@ -694,15 +703,6 @@ public void transportTerminated() {
694703 for (ClientTransportFilter filter : transportFilters ) {
695704 filter .transportTerminated (transport .getAttributes ());
696705 }
697- subchannelMetrics .recordDisconnection (buildLabelSet (
698- getAttributeOrDefault (
699- addressIndex .getCurrentEagAttributes (), NameResolver .ATTR_BACKEND_SERVICE ),
700- getAttributeOrDefault (
701- addressIndex .getCurrentEagAttributes (), LoadBalancer .ATTR_LOCALITY_NAME ),
702- "Peer Pressure" ,
703- extractSecurityLevel (
704- addressIndex .getCurrentEagAttributes ().get (GrpcAttributes .ATTR_SECURITY_LEVEL ))
705- ));
706706 syncContext .execute (new Runnable () {
707707 @ Override
708708 public void run () {
You can’t perform that action at this time.
0 commit comments