@@ -216,7 +216,8 @@ public void testMetricsSingleUseQuery() {
216
216
assertEquals (fakeServerTiming .get (), gfeLatencyValue , 0 );
217
217
218
218
assertFalse (checkIfMetricExists (metricReader , BuiltInMetricsConstant .AFE_LATENCIES_NAME ));
219
- assertFalse (checkIfMetricExists (metricReader , BuiltInMetricsConstant .AFE_CONNECTIVITY_ERROR_NAME ));
219
+ assertFalse (
220
+ checkIfMetricExists (metricReader , BuiltInMetricsConstant .AFE_CONNECTIVITY_ERROR_NAME ));
220
221
}
221
222
222
223
@ Test
@@ -396,7 +397,8 @@ public void testNoServerTimingHeader() throws IOException, InterruptedException
396
397
MetricData gfeConnectivityMetricData =
397
398
getMetricData (metricReader , BuiltInMetricsConstant .GFE_CONNECTIVITY_ERROR_NAME );
398
399
assertThat (getAggregatedValue (gfeConnectivityMetricData , expectedAttributes )).isEqualTo (1 );
399
- assertFalse (checkIfMetricExists (metricReader , BuiltInMetricsConstant .AFE_CONNECTIVITY_ERROR_NAME ));
400
+ assertFalse (
401
+ checkIfMetricExists (metricReader , BuiltInMetricsConstant .AFE_CONNECTIVITY_ERROR_NAME ));
400
402
spannerNoHeader .close ();
401
403
serverNoHeader .shutdown ();
402
404
serverNoHeader .awaitTermination ();
@@ -439,8 +441,8 @@ private boolean checkIfMetricExists(InMemoryMetricReader reader, String metricNa
439
441
String fullMetricName = BuiltInMetricsConstant .METER_NAME + "/" + metricName ;
440
442
441
443
for (int attemptsLeft = 1000 ; attemptsLeft > 0 ; attemptsLeft --) {
442
- boolean exists = reader . collectAllMetrics (). stream ()
443
- .anyMatch (md -> md .getName ().equals (fullMetricName ));
444
+ boolean exists =
445
+ reader . collectAllMetrics (). stream () .anyMatch (md -> md .getName ().equals (fullMetricName ));
444
446
if (exists ) {
445
447
return true ;
446
448
}
@@ -455,7 +457,6 @@ private boolean checkIfMetricExists(InMemoryMetricReader reader, String metricNa
455
457
return false ;
456
458
}
457
459
458
-
459
460
private long getAggregatedValue (MetricData metricData , Attributes attributes ) {
460
461
switch (metricData .getType ()) {
461
462
case HISTOGRAM :
0 commit comments