Minor rename in FakePoolMetrics

eclipse-vertx · Aug 10, 2024 · b3690c7 · b3690c7
1 parent 63a4697
commit b3690c7
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 15 deletions.
diff --git a/vertx-core/src/test/java/io/vertx/test/fakemetrics/FakePoolMetrics.java b/vertx-core/src/test/java/io/vertx/test/fakemetrics/FakePoolMetrics.java
@@ -29,7 +29,7 @@ public class FakePoolMetrics implements PoolMetrics<Object, Object> {
   private final AtomicInteger pending = new AtomicInteger();
   private final AtomicInteger releaseCount = new AtomicInteger();
   private final AtomicInteger enqueueCount = new AtomicInteger();
-  private final AtomicInteger acquired = new AtomicInteger();
+  private final AtomicInteger inUse = new AtomicInteger();
   private final AtomicBoolean closed = new AtomicBoolean();
 
   public FakePoolMetrics(String name, int maxSize) {
@@ -53,13 +53,13 @@ public void dequeue(Object queueMetric) {
 
   @Override
   public Object begin() {
-    acquired.incrementAndGet();
+    inUse.incrementAndGet();
     return TASK_BEGIN;
   }
 
   public void end(Object t) {
     assert t == TASK_BEGIN;
-    acquired.decrementAndGet();
+    inUse.decrementAndGet();
     releaseCount.incrementAndGet();
   }
 
@@ -99,17 +99,17 @@ public int pending() {
   }
 
   /**
-   * @return the number of elements currently borrowed from the pool
+   * @return the number of elements currently in use from the pool
    */
-  public int borrowed() {
-    return acquired.get();
+  public int inUse() {
+    return inUse.get();
   }
 
   /**
    * @return the number of available elements currently in the pool
    */
   public int available() {
-    return maxSize - acquired.get();
+    return maxSize - inUse.get();
   }
 
   /**

diff --git a/vertx-core/src/test/java/io/vertx/tests/metrics/MetricsTest.java b/vertx-core/src/test/java/io/vertx/tests/metrics/MetricsTest.java
@@ -952,7 +952,7 @@ public void testThreadPoolMetricsWithExecuteBlocking() {
             if (metrics.available() > 0) {
               hadIdle.set(true);
             }
-            if (metrics.borrowed() > 0) {
+            if (metrics.inUse() > 0) {
               hadRunning.set(true);
             }
           }
@@ -966,7 +966,7 @@ public void testThreadPoolMetricsWithExecuteBlocking() {
     assertTrue(hadRunning.get());
 
     assertEquals(metrics.available(), getOptions().getWorkerPoolSize());
-    assertEquals(metrics.borrowed(), 0);
+    assertEquals(metrics.inUse(), 0);
     assertEquals(metrics.pending(), 0);
   }
 
@@ -997,7 +997,7 @@ public void testThreadPoolMetricsWithInternalExecuteBlocking() {
           fail(e);
           Thread.currentThread().interrupt();
         }
-        if (metrics.borrowed() > 0) {
+        if (metrics.inUse() > 0) {
           hadRunning.set(true);
         }
         if (metrics.pending() > 0) {
@@ -1018,7 +1018,7 @@ public void testThreadPoolMetricsWithInternalExecuteBlocking() {
     assertTrue(hadRunning.get());
 
     assertEquals(metrics.available(), getOptions().getWorkerPoolSize());
-    assertEquals(metrics.borrowed(), 0);
+    assertEquals(metrics.inUse(), 0);
     assertEquals(metrics.pending(), 0);
   }
 
@@ -1054,7 +1054,7 @@ public void testThreadPoolMetricsWithWorkerVerticle() throws Exception {
             if (metrics.available() > 0) {
               hadIdle.set(true);
             }
-            if (metrics.borrowed() > 0) {
+            if (metrics.inUse() > 0) {
               hadRunning.set(true);
             }
 
@@ -1087,7 +1087,7 @@ public void testThreadPoolMetricsWithWorkerVerticle() throws Exception {
     assertTrue("Had running tasks", hadRunning.get());
 
     assertEquals(getOptions().getWorkerPoolSize(), metrics.available());
-    assertEquals(0, metrics.borrowed());
+    assertEquals(0, metrics.inUse());
     assertEquals(0, metrics.pending());
   }
 
@@ -1124,7 +1124,7 @@ public void testThreadPoolMetricsWithNamedExecuteBlocking() throws InterruptedEx
             if (metrics.available() > 0) {
               hadIdle.set(true);
             }
-            if (metrics.borrowed() > 0) {
+            if (metrics.inUse() > 0) {
               hadRunning.set(true);
             }
           });
@@ -1136,7 +1136,7 @@ public void testThreadPoolMetricsWithNamedExecuteBlocking() throws InterruptedEx
     assertTrue(hadRunning.get());
 
     assertEquals(metrics.available(), 10);
-    assertEquals(metrics.borrowed(), 0);
+    assertEquals(metrics.inUse(), 0);
     assertEquals(metrics.pending(), 0);
   }