Skip to content

Commit e4abf96

Browse files
committed
test/kvs: pass counter as arg instead of global
Problem: Some unit tests in test/kvs_wait_version.c use a global variable for counting. Instead, a counter should be passed as an argument to the callback. Remove the global counting variable. Pass a local variable as an argument to a callback instead.
1 parent 5d57888 commit e4abf96

File tree

1 file changed

+12
-11
lines changed

1 file changed

+12
-11
lines changed

src/modules/kvs/test/kvs_wait_version.c

Lines changed: 12 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,6 @@
2525
#include "ccan/str/str.h"
2626

2727
const char *root_ref = "1234"; /* random string, doesn't matter for tests */
28-
int count = 0;
2928

3029
void basic_corner_case_tests (void)
3130
{
@@ -43,7 +42,8 @@ void basic_corner_case_tests (void)
4342

4443
void cb (flux_t *h, flux_msg_handler_t *mh, const flux_msg_t *msg, void *arg)
4544
{
46-
count++;
45+
int *count = arg;
46+
(*count)++;
4747
}
4848

4949
void basic_api_tests (void)
@@ -52,6 +52,7 @@ void basic_api_tests (void)
5252
struct cache *cache;
5353
struct kvsroot *root;
5454
flux_msg_t *msg;
55+
int count = 0;
5556

5657
if (!(cache = cache_create (NULL)))
5758
BAIL_OUT ("cache_create");
@@ -72,11 +73,11 @@ void basic_api_tests (void)
7273

7374
msg = flux_msg_create (FLUX_MSGTYPE_REQUEST);
7475

75-
ok (!kvs_wait_version_add (root, cb, NULL, NULL, msg, NULL, 2),
76+
ok (!kvs_wait_version_add (root, cb, NULL, NULL, msg, &count, 2),
7677
"kvs_wait_version_add w/ seq = 2 works");
77-
ok (!kvs_wait_version_add (root, cb, NULL, NULL, msg, NULL, 3),
78+
ok (!kvs_wait_version_add (root, cb, NULL, NULL, msg, &count, 3),
7879
"kvs_wait_version_add w/ seq = 3 works");
79-
ok (!kvs_wait_version_add (root, cb, NULL, NULL, msg, NULL, 4),
80+
ok (!kvs_wait_version_add (root, cb, NULL, NULL, msg, &count, 4),
8081
"kvs_wait_version_add w/ seq = 4 works");
8182

8283
ok (zlist_size (root->wait_version_list) == 3,
@@ -118,11 +119,11 @@ void basic_api_tests (void)
118119
ok (zlist_size (root->wait_version_list) == 0,
119120
"wait_version_list is length 0");
120121

121-
ok (!kvs_wait_version_add (root, cb, NULL, NULL, msg, NULL, 5),
122+
ok (!kvs_wait_version_add (root, cb, NULL, NULL, msg, &count, 5),
122123
"kvs_wait_version_add w/ seq = 5 works");
123-
ok (!kvs_wait_version_add (root, cb, NULL, NULL, msg, NULL, 6),
124+
ok (!kvs_wait_version_add (root, cb, NULL, NULL, msg, &count, 6),
124125
"kvs_wait_version_add w/ seq = 6 works");
125-
ok (!kvs_wait_version_add (root, cb, NULL, NULL, msg, NULL, 7),
126+
ok (!kvs_wait_version_add (root, cb, NULL, NULL, msg, &count, 7),
126127
"kvs_wait_version_add w/ seq = 7 works");
127128

128129
ok (zlist_size (root->wait_version_list) == 3,
@@ -141,11 +142,11 @@ void basic_api_tests (void)
141142
/* cover some alternate insertion pattern, descending and
142143
* duplicate numbers */
143144

144-
ok (!kvs_wait_version_add (root, cb, NULL, NULL, msg, NULL, 9),
145+
ok (!kvs_wait_version_add (root, cb, NULL, NULL, msg, &count, 9),
145146
"kvs_wait_version_add w/ seq = 9 works");
146-
ok (!kvs_wait_version_add (root, cb, NULL, NULL, msg, NULL, 8),
147+
ok (!kvs_wait_version_add (root, cb, NULL, NULL, msg, &count, 8),
147148
"kvs_wait_version_add w/ seq = 8 works");
148-
ok (!kvs_wait_version_add (root, cb, NULL, NULL, msg, NULL, 8),
149+
ok (!kvs_wait_version_add (root, cb, NULL, NULL, msg, &count, 8),
149150
"kvs_wait_version_add w/ seq = 8 works");
150151

151152
ok (zlist_size (root->wait_version_list) == 3,

0 commit comments

Comments
 (0)