tests: internal: Add a test case for entry-specific interval

Signed-off-by: Hiroshi Hatake <hiroshi@chronosphere.io>

Author: cosmo0920

tests/internal/log.c

@@ -215,12 +215,54 @@ static void suppress_interval_shorter_than_cache_timeout()
     check_suppress_interval(3, 1, 2, FLB_FALSE);
 }
 
+static void suppress_interval_preserved_during_cache_replacement()
+{
+    int ret;
+    struct flb_worker worker = {0};
+    struct flb_worker *previous_worker;
+    struct flb_log_cache_entry *entry;
+
+    worker.log_cache = flb_log_cache_create(1, 2);
+    TEST_CHECK(worker.log_cache != NULL);
+    if (!worker.log_cache) {
+        return;
+    }
+
+    previous_worker = flb_worker_get();
+    FLB_TLS_SET(flb_worker_ctx, &worker);
+
+    ret = flb_log_suppress_check(3, TEST_RECORD_01);
+    TEST_CHECK(ret == FLB_FALSE);
+
+    entry = flb_log_cache_exists(worker.log_cache,
+                                 TEST_RECORD_01, TEST_RECORD_01_SIZE);
+    TEST_CHECK(entry != NULL);
+    if (entry) {
+        entry->timestamp = time(NULL) - 2;
+    }
+
+    ret = flb_log_suppress_check(3, TEST_RECORD_02);
+    TEST_CHECK(ret == FLB_FALSE);
+
+    entry = flb_log_cache_exists(worker.log_cache,
+                                 TEST_RECORD_02, TEST_RECORD_02_SIZE);
+    TEST_CHECK(entry != NULL);
+
+    ret = flb_log_suppress_check(3, TEST_RECORD_01);
+    TEST_CHECK(ret == FLB_TRUE);
+
+    FLB_TLS_SET(flb_worker_ctx, previous_worker);
+    flb_log_cache_destroy(worker.log_cache);
+}
+
 TEST_LIST = {
     { "cache_basic_timeout" , cache_basic_timeout },
     { "cache_one_slot"      , cache_one_slot      },
     { "suppress_interval_longer_than_cache_timeout",
       suppress_interval_longer_than_cache_timeout },
     { "suppress_interval_shorter_than_cache_timeout",
       suppress_interval_shorter_than_cache_timeout },
+    { "suppress_interval_preserved_during_cache_replacement",
+      suppress_interval_preserved_during_cache_replacement },
     { 0 }
 };