1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
|
#include <fluent-bit/flb_sds.h>
#include <fluent-bit/flb_mem.h>
#include <fluent-bit/flb_log.h>
#include "flb_tests_internal.h"
#define TIMEOUT 5
#define TEST_RECORD_01 "this is a test message"
#define TEST_RECORD_01_SIZE sizeof(TEST_RECORD_01) - 1
#define TEST_RECORD_02 "other type of message"
#define TEST_RECORD_02_SIZE sizeof(TEST_RECORD_02) - 1
static int check_interval(int timeout, int *interval)
{
if (!TEST_CHECK( (*interval >= timeout - 1) && *interval <= timeout) ) {
TEST_MSG("interval error. got=%d expect=%d-%d", *interval, timeout -1 ,timeout);
return -1;
}
return 0;
}
static int update_and_check_interval(int timeout, int ret, int *interval)
{
int ret_val;
if (ret == FLB_TRUE) {
*interval += 1;
return 0;
}
/* false means timeout. check interval. */
ret_val = check_interval(timeout, interval);
*interval = 0; /* reset interval */
return ret_val;
}
static void cache_basic_timeout()
{
int i;
int ret;
int ret_1;
int ret_2;
int timeout = 5;
int interval1 = 0;
int interval2 = 0;
struct flb_log_cache *cache;
struct flb_log_cache_entry *entry;
printf("\n");
cache = flb_log_cache_create(10, 0);
TEST_CHECK(cache == NULL);
cache = flb_log_cache_create(5, 4);
TEST_CHECK(cache != NULL);
/* cache must be empty */
entry = flb_log_cache_exists(cache, TEST_RECORD_01, TEST_RECORD_01_SIZE);
TEST_CHECK(entry == NULL);
/* upon trying to check for a suppress and if not found, it must be added */
ret_1 = flb_log_cache_check_suppress(cache, TEST_RECORD_01, TEST_RECORD_01_SIZE);
TEST_CHECK(ret_1 == FLB_FALSE);
/* double check that it was added */
entry = flb_log_cache_exists(cache, TEST_RECORD_01, TEST_RECORD_01_SIZE);
TEST_CHECK(entry != NULL);
printf("------------------------\n");
/* reset */
flb_log_cache_destroy(cache);
/* create a new cache */
cache = flb_log_cache_create(timeout, 4);
TEST_CHECK(cache != NULL);
ret_1 = flb_log_cache_check_suppress(cache, TEST_RECORD_01, TEST_RECORD_01_SIZE);
ret_2 = flb_log_cache_check_suppress(cache, TEST_RECORD_02, TEST_RECORD_02_SIZE);
TEST_CHECK(ret_1 == FLB_FALSE);
TEST_CHECK(ret_2 == FLB_FALSE);
sleep(1);
interval1++;
interval2++;
for (i = 1; i < 10; i++) {
ret_1 = flb_log_cache_check_suppress(cache, TEST_RECORD_01, TEST_RECORD_01_SIZE);
ret = update_and_check_interval(timeout, ret_1, &interval1);
if (!TEST_CHECK(ret == 0)) {
TEST_MSG("update_and_check_interval for TEST_RECORD_01 failed. i=%d", i);
}
ret_2 = flb_log_cache_check_suppress(cache, TEST_RECORD_02, TEST_RECORD_02_SIZE);
ret = update_and_check_interval(timeout, ret_2, &interval2);
if (!TEST_CHECK(ret == 0)) {
TEST_MSG("update_and_check_interval for TEST_RECORD_02 failed. i=%d", i);
}
sleep(1);
}
ret_1 = flb_log_cache_check_suppress(cache, TEST_RECORD_01, TEST_RECORD_01_SIZE);
ret = update_and_check_interval(timeout, ret_1, &interval1);
TEST_CHECK(ret == 0);
ret_2 = flb_log_cache_check_suppress(cache, TEST_RECORD_02, TEST_RECORD_02_SIZE);
ret = update_and_check_interval(timeout, ret_2, &interval2);
TEST_CHECK(ret == 0);
flb_log_cache_destroy(cache);
}
static void cache_one_slot()
{
int i;
int ret_1;
int ret_2;
struct flb_log_cache *cache;
printf("\n");
cache = flb_log_cache_create(2, 1);
TEST_CHECK(cache != NULL);
for (i = 0; i < 10; i++) {
if (i == 0) {
ret_1 = flb_log_cache_check_suppress(cache, TEST_RECORD_01, TEST_RECORD_01_SIZE);
TEST_CHECK(ret_1 == FLB_FALSE);
ret_1 = flb_log_cache_check_suppress(cache, TEST_RECORD_01, TEST_RECORD_01_SIZE);
TEST_CHECK(ret_1 == FLB_TRUE);
}
else {
ret_2 = flb_log_cache_check_suppress(cache, TEST_RECORD_02, TEST_RECORD_02_SIZE);
ret_1 = flb_log_cache_check_suppress(cache, TEST_RECORD_01, TEST_RECORD_01_SIZE);
TEST_CHECK(ret_1 == FLB_FALSE);
TEST_CHECK(ret_2 == FLB_FALSE);
}
sleep(1);
}
flb_log_cache_destroy(cache);
}
TEST_LIST = {
{ "cache_basic_timeout" , cache_basic_timeout },
{ "cache_one_slot" , cache_one_slot },
{ 0 }
};
|
