aboutsummaryrefslogtreecommitdiff
path: root/src/peerstore/test_peerstore_api_iterate.c
diff options
context:
space:
mode:
authorOmar Tarabai <tarabai@devegypt.com>2014-06-05 09:08:28 +0000
committerOmar Tarabai <tarabai@devegypt.com>2014-06-05 09:08:28 +0000
commitf8a8dad6b6ff2d1dd28098372f203264b2caa060 (patch)
tree51760410f7176970b68f386d8665a51968e6e6ab /src/peerstore/test_peerstore_api_iterate.c
parentecc4ae9b8bbd5e5433b83a1527cd9b83487e9bec (diff)
downloadgnunet-f8a8dad6b6ff2d1dd28098372f203264b2caa060.tar.gz
gnunet-f8a8dad6b6ff2d1dd28098372f203264b2caa060.zip
peerstore: additional test cases
Diffstat (limited to 'src/peerstore/test_peerstore_api_iterate.c')
-rw-r--r--src/peerstore/test_peerstore_api_iterate.c168
1 files changed, 168 insertions, 0 deletions
diff --git a/src/peerstore/test_peerstore_api_iterate.c b/src/peerstore/test_peerstore_api_iterate.c
new file mode 100644
index 000000000..0655be25f
--- /dev/null
+++ b/src/peerstore/test_peerstore_api_iterate.c
@@ -0,0 +1,168 @@
1/*
2 This file is part of GNUnet.
3 (C)
4
5 GNUnet is free software; you can redistribute it and/or modify
6 it under the terms of the GNU General Public License as published
7 by the Free Software Foundation; either version 3, or (at your
8 option) any later version.
9
10 GNUnet is distributed in the hope that it will be useful, but
11 WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 General Public License for more details.
14
15 You should have received a copy of the GNU General Public License
16 along with GNUnet; see the file COPYING. If not, write to the
17 Free Software Foundation, Inc., 59 Temple Place - Suite 330,
18 Boston, MA 02111-1307, USA.
19*/
20/**
21 * @file peerstore/test_peerstore_api_iterate.c
22 * @brief testcase for peerstore iteration operation
23 */
24#include "platform.h"
25#include "gnunet_util_lib.h"
26#include "gnunet_testing_lib.h"
27#include "gnunet_peerstore_service.h"
28
29static int ok = 1;
30
31struct GNUNET_PEERSTORE_Handle *h;
32
33char *ss = "test_peerstore_api_iterate";
34struct GNUNET_PeerIdentity p1;
35struct GNUNET_PeerIdentity p2;
36char *k1 = "test_peerstore_api_iterate_key1";
37char *k2 = "test_peerstore_api_iterate_key2";
38char *k3 = "test_peerstore_api_iterate_key3";
39char *val = "test_peerstore_api_iterate_val";
40int count = 0;
41
42static int
43iter3_cb(void *cls,
44 struct GNUNET_PEERSTORE_Record *record,
45 char *emsg)
46{
47 if(NULL != emsg)
48 return GNUNET_NO;
49 if(NULL != record)
50 {
51 count++;
52 return GNUNET_YES;
53 }
54 GNUNET_assert(count == 3);
55 ok = 0;
56 GNUNET_PEERSTORE_disconnect(h);
57 GNUNET_SCHEDULER_shutdown();
58 return GNUNET_YES;
59}
60
61static int
62iter2_cb(void *cls,
63 struct GNUNET_PEERSTORE_Record *record,
64 char *emsg)
65{
66 if(NULL != emsg)
67 return GNUNET_NO;
68 if(NULL != record)
69 {
70 count++;
71 return GNUNET_YES;
72 }
73 GNUNET_assert(count == 2);
74 count = 0;
75 GNUNET_PEERSTORE_iterate(h,
76 ss,
77 NULL,
78 NULL,
79 GNUNET_TIME_UNIT_FOREVER_REL,
80 iter3_cb,
81 NULL);
82 return GNUNET_YES;
83}
84
85static int
86iter1_cb(void *cls,
87 struct GNUNET_PEERSTORE_Record *record,
88 char *emsg)
89{
90 if(NULL != emsg)
91 return GNUNET_NO;
92 if(NULL != record)
93 {
94 count++;
95 return GNUNET_YES;
96 }
97 GNUNET_assert(count == 1);
98 count = 0;
99 GNUNET_PEERSTORE_iterate(h,
100 ss,
101 &p1,
102 NULL,
103 GNUNET_TIME_UNIT_FOREVER_REL,
104 iter2_cb,
105 NULL);
106 return GNUNET_YES;
107}
108
109static void
110run (void *cls,
111 const struct GNUNET_CONFIGURATION_Handle *cfg,
112 struct GNUNET_TESTING_Peer *peer)
113{
114 h = GNUNET_PEERSTORE_connect(cfg);
115 GNUNET_assert(NULL != h);
116 memset (&p1, 1, sizeof (p1));
117 memset (&p2, 2, sizeof (p2));
118 GNUNET_PEERSTORE_store(h,
119 ss,
120 &p1,
121 k1,
122 val,
123 strlen(val) + 1,
124 GNUNET_TIME_UNIT_FOREVER_ABS,
125 GNUNET_PEERSTORE_STOREOPTION_REPLACE,
126 NULL,
127 NULL);
128 GNUNET_PEERSTORE_store(h,
129 ss,
130 &p1,
131 k2,
132 val,
133 strlen(val) + 1,
134 GNUNET_TIME_UNIT_FOREVER_ABS,
135 GNUNET_PEERSTORE_STOREOPTION_REPLACE,
136 NULL,
137 NULL);
138 GNUNET_PEERSTORE_store(h,
139 ss,
140 &p2,
141 k3,
142 val,
143 strlen(val) + 1,
144 GNUNET_TIME_UNIT_FOREVER_ABS,
145 GNUNET_PEERSTORE_STOREOPTION_REPLACE,
146 NULL,
147 NULL);
148 GNUNET_PEERSTORE_iterate(h,
149 ss,
150 &p1,
151 k1,
152 GNUNET_TIME_UNIT_FOREVER_REL,
153 iter1_cb,
154 NULL);
155}
156
157int
158main (int argc, char *argv[])
159{
160 if (0 != GNUNET_TESTING_service_run ("test-gnunet-peerstore",
161 "peerstore",
162 "test_peerstore_api_data.conf",
163 &run, NULL))
164 return 1;
165 return ok;
166}
167
168/* end of test_peerstore_api_iterate.c */