@@ -210,7 +210,8 @@ public void testMetricsSingleUseQuery() {
210
210
assertEquals (fakeServerTiming .get (), gfeLatencyValue , 0 );
211
211
212
212
assertFalse (checkIfMetricExists (metricReader , BuiltInMetricsConstant .AFE_LATENCIES_NAME ));
213
- assertFalse (checkIfMetricExists (metricReader , BuiltInMetricsConstant .AFE_CONNECTIVITY_ERROR_NAME ));
213
+ assertFalse (
214
+ checkIfMetricExists (metricReader , BuiltInMetricsConstant .AFE_CONNECTIVITY_ERROR_NAME ));
214
215
}
215
216
216
217
@ Test
@@ -390,7 +391,8 @@ public void testNoServerTimingHeader() throws IOException, InterruptedException
390
391
MetricData gfeConnectivityMetricData =
391
392
getMetricData (metricReader , BuiltInMetricsConstant .GFE_CONNECTIVITY_ERROR_NAME );
392
393
assertThat (getAggregatedValue (gfeConnectivityMetricData , expectedAttributes )).isEqualTo (1 );
393
- assertFalse (checkIfMetricExists (metricReader , BuiltInMetricsConstant .AFE_CONNECTIVITY_ERROR_NAME ));
394
+ assertFalse (
395
+ checkIfMetricExists (metricReader , BuiltInMetricsConstant .AFE_CONNECTIVITY_ERROR_NAME ));
394
396
spannerNoHeader .close ();
395
397
serverNoHeader .shutdown ();
396
398
serverNoHeader .awaitTermination ();
@@ -433,8 +435,8 @@ private boolean checkIfMetricExists(InMemoryMetricReader reader, String metricNa
433
435
String fullMetricName = BuiltInMetricsConstant .METER_NAME + "/" + metricName ;
434
436
435
437
for (int attemptsLeft = 1000 ; attemptsLeft > 0 ; attemptsLeft --) {
436
- boolean exists = reader . collectAllMetrics (). stream ()
437
- .anyMatch (md -> md .getName ().equals (fullMetricName ));
438
+ boolean exists =
439
+ reader . collectAllMetrics (). stream () .anyMatch (md -> md .getName ().equals (fullMetricName ));
438
440
if (exists ) {
439
441
return true ;
440
442
}
@@ -449,7 +451,6 @@ private boolean checkIfMetricExists(InMemoryMetricReader reader, String metricNa
449
451
return false ;
450
452
}
451
453
452
-
453
454
private long getAggregatedValue (MetricData metricData , Attributes attributes ) {
454
455
switch (metricData .getType ()) {
455
456
case HISTOGRAM :
0 commit comments