[#9254] Cleanup

pinpoint-apm · Oct 19, 2022 · 9162b26 · 9162b26
1 parent bcd9389
commit 9162b26
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 5 deletions.
diff --git a/...ain/java/com/navercorp/pinpoint/profiler/context/storage/AsyncQueueingUriStatStorage.java b/...ain/java/com/navercorp/pinpoint/profiler/context/storage/AsyncQueueingUriStatStorage.java
@@ -133,7 +133,10 @@ private void addUriData(AgentUriStatData agentUriStatData, UriStatInfo uriStatIn
 
         public void executePollTimeout() {
             long currentBaseTimestamp = clock.millis();
-            checkAndFlushOldData(currentBaseTimestamp);
+            boolean flush = checkAndFlushOldData(currentBaseTimestamp);
+            if (flush) {
+                LOGGER.debug("checkAndFlushOldData {}", flush);
+            }
         }
 
 

diff --git a/...java/com/navercorp/pinpoint/profiler/context/storage/AsyncQueueingUriStatStorageTest.java b/...java/com/navercorp/pinpoint/profiler/context/storage/AsyncQueueingUriStatStorageTest.java
@@ -57,7 +57,8 @@ private void storageTest(int collectInterval, int storeCount) {
             Uninterruptibles.sleepUninterruptibly(sleepTime + 2, TimeUnit.MILLISECONDS);
 
             for (int i = 0; i < storeCount; i++) {
-                storeRandomValue(storage);
+                final long timestamp = System.currentTimeMillis();
+                storeRandomValue(storage, timestamp);
             }
 
             Assertions.assertNull(storage.poll());
@@ -68,7 +69,6 @@ private void storageTest(int collectInterval, int storeCount) {
 
             AgentUriStatData poll = storage.poll();
             Assertions.assertNotNull(poll);
-
             Set<Map.Entry<URIKey, EachUriStatData>> allUriStatData = poll.getAllUriStatData();
             storeCount -= allUriStatData
                     .stream()
@@ -85,8 +85,8 @@ private void storageTest(int collectInterval, int storeCount) {
         }
     }
 
-    private void storeRandomValue(AsyncQueueingUriStatStorage storage) {
-        final long timestamp = System.currentTimeMillis();
+    private void storeRandomValue(AsyncQueueingUriStatStorage storage, long timestamp) {
+        timestamp = System.currentTimeMillis();
         storage.store(URI_EXAMPLES[RANDOM.nextInt(URI_EXAMPLES.length)], RANDOM.nextBoolean(), timestamp - RANDOM.nextInt(10000), timestamp);
     }