diff options
Diffstat (limited to 'src/namestore/test_namestore_api_zone_iteration_nick.c')
-rw-r--r-- | src/namestore/test_namestore_api_zone_iteration_nick.c | 463 |
1 files changed, 231 insertions, 232 deletions
diff --git a/src/namestore/test_namestore_api_zone_iteration_nick.c b/src/namestore/test_namestore_api_zone_iteration_nick.c index 069c6d831..739e71c05 100644 --- a/src/namestore/test_namestore_api_zone_iteration_nick.c +++ b/src/namestore/test_namestore_api_zone_iteration_nick.c | |||
@@ -11,12 +11,12 @@ | |||
11 | WITHOUT ANY WARRANTY; without even the implied warranty of | 11 | WITHOUT ANY WARRANTY; without even the implied warranty of |
12 | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU | 12 | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU |
13 | Affero General Public License for more details. | 13 | Affero General Public License for more details. |
14 | 14 | ||
15 | You should have received a copy of the GNU Affero General Public License | 15 | You should have received a copy of the GNU Affero General Public License |
16 | along with this program. If not, see <http://www.gnu.org/licenses/>. | 16 | along with this program. If not, see <http://www.gnu.org/licenses/>. |
17 | 17 | ||
18 | SPDX-License-Identifier: AGPL3.0-or-later | 18 | SPDX-License-Identifier: AGPL3.0-or-later |
19 | */ | 19 | */ |
20 | /** | 20 | /** |
21 | * @file namestore/test_namestore_api_zone_iteration.c | 21 | * @file namestore/test_namestore_api_zone_iteration.c |
22 | * @brief testcase for zone iteration functionality: iterate all zones | 22 | * @brief testcase for zone iteration functionality: iterate all zones |
@@ -32,7 +32,7 @@ | |||
32 | #define ZONE_NICK_1 "nick1" | 32 | #define ZONE_NICK_1 "nick1" |
33 | #define ZONE_NICK_2 "nick2" | 33 | #define ZONE_NICK_2 "nick2" |
34 | 34 | ||
35 | #define TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 100) | 35 | #define TIMEOUT GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 100) |
36 | 36 | ||
37 | 37 | ||
38 | static struct GNUNET_NAMESTORE_Handle * nsh; | 38 | static struct GNUNET_NAMESTORE_Handle * nsh; |
@@ -69,266 +69,266 @@ static struct GNUNET_NAMESTORE_QueueEntry *nsqe; | |||
69 | * @param tc scheduler context | 69 | * @param tc scheduler context |
70 | */ | 70 | */ |
71 | static void | 71 | static void |
72 | end (void *cls) | 72 | end(void *cls) |
73 | { | 73 | { |
74 | if (NULL != zi) | 74 | if (NULL != zi) |
75 | { | 75 | { |
76 | GNUNET_NAMESTORE_zone_iteration_stop (zi); | 76 | GNUNET_NAMESTORE_zone_iteration_stop(zi); |
77 | zi = NULL; | 77 | zi = NULL; |
78 | } | 78 | } |
79 | if (nsh != NULL) | 79 | if (nsh != NULL) |
80 | { | 80 | { |
81 | GNUNET_NAMESTORE_disconnect (nsh); | 81 | GNUNET_NAMESTORE_disconnect(nsh); |
82 | nsh = NULL; | 82 | nsh = NULL; |
83 | } | 83 | } |
84 | GNUNET_free_non_null (s_name_1); | 84 | GNUNET_free_non_null(s_name_1); |
85 | GNUNET_free_non_null (s_name_2); | 85 | GNUNET_free_non_null(s_name_2); |
86 | GNUNET_free_non_null (s_name_3); | 86 | GNUNET_free_non_null(s_name_3); |
87 | 87 | ||
88 | if (s_rd_1 != NULL) | 88 | if (s_rd_1 != NULL) |
89 | { | 89 | { |
90 | GNUNET_free ((void *)s_rd_1->data); | 90 | GNUNET_free((void *)s_rd_1->data); |
91 | GNUNET_free (s_rd_1); | 91 | GNUNET_free(s_rd_1); |
92 | } | 92 | } |
93 | if (s_rd_2 != NULL) | 93 | if (s_rd_2 != NULL) |
94 | { | 94 | { |
95 | GNUNET_free ((void *)s_rd_2->data); | 95 | GNUNET_free((void *)s_rd_2->data); |
96 | GNUNET_free (s_rd_2); | 96 | GNUNET_free(s_rd_2); |
97 | } | 97 | } |
98 | if (s_rd_3 != NULL) | 98 | if (s_rd_3 != NULL) |
99 | { | 99 | { |
100 | GNUNET_free ((void *)s_rd_3->data); | 100 | GNUNET_free((void *)s_rd_3->data); |
101 | GNUNET_free (s_rd_3); | 101 | GNUNET_free(s_rd_3); |
102 | } | 102 | } |
103 | 103 | ||
104 | if (privkey != NULL) | 104 | if (privkey != NULL) |
105 | { | 105 | { |
106 | GNUNET_free (privkey); | 106 | GNUNET_free(privkey); |
107 | privkey = NULL; | 107 | privkey = NULL; |
108 | } | 108 | } |
109 | if (privkey2 != NULL) | 109 | if (privkey2 != NULL) |
110 | { | 110 | { |
111 | GNUNET_free (privkey2); | 111 | GNUNET_free(privkey2); |
112 | privkey2 = NULL; | 112 | privkey2 = NULL; |
113 | } | 113 | } |
114 | } | 114 | } |
115 | 115 | ||
116 | 116 | ||
117 | static int | 117 | static int |
118 | check_zone_1 (const char *label, unsigned int rd_count, | 118 | check_zone_1(const char *label, unsigned int rd_count, |
119 | const struct GNUNET_GNSRECORD_Data *rd) | 119 | const struct GNUNET_GNSRECORD_Data *rd) |
120 | { | 120 | { |
121 | for (unsigned int c = 0; c< rd_count ; c++) | 121 | for (unsigned int c = 0; c < rd_count; c++) |
122 | { | ||
123 | if ( (rd[c].record_type == GNUNET_GNSRECORD_TYPE_NICK) && | ||
124 | (0 != strcmp (rd[c].data, ZONE_NICK_1)) ) | ||
125 | { | 122 | { |
126 | GNUNET_break (0); | 123 | if ((rd[c].record_type == GNUNET_GNSRECORD_TYPE_NICK) && |
127 | return GNUNET_YES; | 124 | (0 != strcmp(rd[c].data, ZONE_NICK_1))) |
125 | { | ||
126 | GNUNET_break(0); | ||
127 | return GNUNET_YES; | ||
128 | } | ||
128 | } | 129 | } |
129 | } | ||
130 | return GNUNET_NO; | 130 | return GNUNET_NO; |
131 | } | 131 | } |
132 | 132 | ||
133 | 133 | ||
134 | static int | 134 | static int |
135 | check_zone_2 (const char *label, | 135 | check_zone_2(const char *label, |
136 | unsigned int rd_count, | 136 | unsigned int rd_count, |
137 | const struct GNUNET_GNSRECORD_Data *rd) | 137 | const struct GNUNET_GNSRECORD_Data *rd) |
138 | { | 138 | { |
139 | for (unsigned int c = 0; c< rd_count ; c++) | 139 | for (unsigned int c = 0; c < rd_count; c++) |
140 | { | ||
141 | if ( (rd[c].record_type == GNUNET_GNSRECORD_TYPE_NICK) && | ||
142 | (0 != strcmp (rd[c].data, ZONE_NICK_2)) ) | ||
143 | { | 140 | { |
144 | GNUNET_break (0); | 141 | if ((rd[c].record_type == GNUNET_GNSRECORD_TYPE_NICK) && |
145 | return GNUNET_YES; | 142 | (0 != strcmp(rd[c].data, ZONE_NICK_2))) |
143 | { | ||
144 | GNUNET_break(0); | ||
145 | return GNUNET_YES; | ||
146 | } | ||
146 | } | 147 | } |
147 | } | ||
148 | return GNUNET_NO; | 148 | return GNUNET_NO; |
149 | } | 149 | } |
150 | 150 | ||
151 | 151 | ||
152 | static void | 152 | static void |
153 | zone_proc_end (void *cls) | 153 | zone_proc_end(void *cls) |
154 | { | 154 | { |
155 | zi = NULL; | 155 | zi = NULL; |
156 | res = 0; | 156 | res = 0; |
157 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 157 | GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, |
158 | "Received last result, iteration done after receing %u results\n", | 158 | "Received last result, iteration done after receing %u results\n", |
159 | returned_records); | 159 | returned_records); |
160 | GNUNET_SCHEDULER_shutdown (); | 160 | GNUNET_SCHEDULER_shutdown(); |
161 | } | 161 | } |
162 | 162 | ||
163 | 163 | ||
164 | static void | 164 | static void |
165 | zone_proc (void *cls, | 165 | zone_proc(void *cls, |
166 | const struct GNUNET_CRYPTO_EcdsaPrivateKey *zone, | 166 | const struct GNUNET_CRYPTO_EcdsaPrivateKey *zone, |
167 | const char *label, | 167 | const char *label, |
168 | unsigned int rd_count, | 168 | unsigned int rd_count, |
169 | const struct GNUNET_GNSRECORD_Data *rd) | 169 | const struct GNUNET_GNSRECORD_Data *rd) |
170 | { | 170 | { |
171 | int failed = GNUNET_NO; | 171 | int failed = GNUNET_NO; |
172 | 172 | ||
173 | GNUNET_assert (NULL != zone); | 173 | GNUNET_assert(NULL != zone); |
174 | if (0 == GNUNET_memcmp (zone, privkey)) | 174 | if (0 == GNUNET_memcmp(zone, privkey)) |
175 | { | 175 | { |
176 | failed = check_zone_1 (label, rd_count, rd); | 176 | failed = check_zone_1(label, rd_count, rd); |
177 | if (GNUNET_YES == failed) | 177 | if (GNUNET_YES == failed) |
178 | GNUNET_break (0); | 178 | GNUNET_break(0); |
179 | } | 179 | } |
180 | else if (0 == GNUNET_memcmp (zone, privkey2)) | 180 | else if (0 == GNUNET_memcmp(zone, privkey2)) |
181 | { | 181 | { |
182 | failed = check_zone_2 (label, rd_count, rd); | 182 | failed = check_zone_2(label, rd_count, rd); |
183 | if (GNUNET_YES == failed) | 183 | if (GNUNET_YES == failed) |
184 | GNUNET_break (0); | 184 | GNUNET_break(0); |
185 | } | 185 | } |
186 | else | 186 | else |
187 | { | 187 | { |
188 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, | 188 | GNUNET_log(GNUNET_ERROR_TYPE_ERROR, |
189 | "Received invalid zone\n"); | 189 | "Received invalid zone\n"); |
190 | failed = GNUNET_YES; | 190 | failed = GNUNET_YES; |
191 | GNUNET_break (0); | 191 | GNUNET_break(0); |
192 | } | 192 | } |
193 | 193 | ||
194 | if (failed == GNUNET_NO) | 194 | if (failed == GNUNET_NO) |
195 | { | 195 | { |
196 | returned_records ++; | 196 | returned_records++; |
197 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 197 | GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, |
198 | "Telling namestore to send the next result\n"); | 198 | "Telling namestore to send the next result\n"); |
199 | GNUNET_NAMESTORE_zone_iterator_next (zi, | 199 | GNUNET_NAMESTORE_zone_iterator_next(zi, |
200 | 1); | 200 | 1); |
201 | } | 201 | } |
202 | else | 202 | else |
203 | { | 203 | { |
204 | GNUNET_break (0); | 204 | GNUNET_break(0); |
205 | res = 1; | 205 | res = 1; |
206 | GNUNET_SCHEDULER_shutdown (); | 206 | GNUNET_SCHEDULER_shutdown(); |
207 | } | 207 | } |
208 | } | 208 | } |
209 | 209 | ||
210 | 210 | ||
211 | static void | 211 | static void |
212 | fail_cb (void *cls) | 212 | fail_cb(void *cls) |
213 | { | 213 | { |
214 | GNUNET_assert (0); | 214 | GNUNET_assert(0); |
215 | } | 215 | } |
216 | 216 | ||
217 | 217 | ||
218 | static void | 218 | static void |
219 | put_cont (void *cls, | 219 | put_cont(void *cls, |
220 | int32_t success, | 220 | int32_t success, |
221 | const char *emsg) | 221 | const char *emsg) |
222 | { | 222 | { |
223 | static int c = 0; | 223 | static int c = 0; |
224 | 224 | ||
225 | if (success == GNUNET_OK) | 225 | if (success == GNUNET_OK) |
226 | { | 226 | { |
227 | c++; | 227 | c++; |
228 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Created record %u \n", c); | 228 | GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Created record %u \n", c); |
229 | } | 229 | } |
230 | else | 230 | else |
231 | { | 231 | { |
232 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Failed to created records: `%s'\n", | 232 | GNUNET_log(GNUNET_ERROR_TYPE_ERROR, "Failed to created records: `%s'\n", |
233 | emsg); | 233 | emsg); |
234 | GNUNET_break (0); | 234 | GNUNET_break(0); |
235 | GNUNET_SCHEDULER_shutdown (); | 235 | GNUNET_SCHEDULER_shutdown(); |
236 | return; | 236 | return; |
237 | } | 237 | } |
238 | 238 | ||
239 | if (c == 3) | 239 | if (c == 3) |
240 | { | ||
241 | res = 1; | ||
242 | returned_records = 0; | ||
243 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "All records created, starting iteration over all zones \n"); | ||
244 | zi = GNUNET_NAMESTORE_zone_iteration_start (nsh, | ||
245 | NULL, | ||
246 | &fail_cb, | ||
247 | NULL, | ||
248 | &zone_proc, | ||
249 | NULL, | ||
250 | &zone_proc_end, | ||
251 | NULL); | ||
252 | if (zi == NULL) | ||
253 | { | 240 | { |
254 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Failed to create zone iterator\n"); | 241 | res = 1; |
255 | GNUNET_break (0); | 242 | returned_records = 0; |
256 | GNUNET_SCHEDULER_shutdown (); | 243 | GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "All records created, starting iteration over all zones \n"); |
257 | return; | 244 | zi = GNUNET_NAMESTORE_zone_iteration_start(nsh, |
245 | NULL, | ||
246 | &fail_cb, | ||
247 | NULL, | ||
248 | &zone_proc, | ||
249 | NULL, | ||
250 | &zone_proc_end, | ||
251 | NULL); | ||
252 | if (zi == NULL) | ||
253 | { | ||
254 | GNUNET_log(GNUNET_ERROR_TYPE_ERROR, "Failed to create zone iterator\n"); | ||
255 | GNUNET_break(0); | ||
256 | GNUNET_SCHEDULER_shutdown(); | ||
257 | return; | ||
258 | } | ||
258 | } | 259 | } |
259 | } | ||
260 | } | 260 | } |
261 | 261 | ||
262 | 262 | ||
263 | static struct GNUNET_GNSRECORD_Data * | 263 | static struct GNUNET_GNSRECORD_Data * |
264 | create_record (unsigned int count) | 264 | create_record(unsigned int count) |
265 | { | 265 | { |
266 | struct GNUNET_GNSRECORD_Data * rd; | 266 | struct GNUNET_GNSRECORD_Data * rd; |
267 | 267 | ||
268 | rd = GNUNET_new_array (count, | 268 | rd = GNUNET_new_array(count, |
269 | struct GNUNET_GNSRECORD_Data); | 269 | struct GNUNET_GNSRECORD_Data); |
270 | for (unsigned int c = 0; c < count; c++) | 270 | for (unsigned int c = 0; c < count; c++) |
271 | { | 271 | { |
272 | rd[c].expiration_time = GNUNET_TIME_relative_to_absolute (GNUNET_TIME_UNIT_HOURS).abs_value_us; | 272 | rd[c].expiration_time = GNUNET_TIME_relative_to_absolute(GNUNET_TIME_UNIT_HOURS).abs_value_us; |
273 | rd[c].record_type = TEST_RECORD_TYPE; | 273 | rd[c].record_type = TEST_RECORD_TYPE; |
274 | rd[c].data_size = 50; | 274 | rd[c].data_size = 50; |
275 | rd[c].data = GNUNET_malloc(50); | 275 | rd[c].data = GNUNET_malloc(50); |
276 | rd[c].flags = 0; | 276 | rd[c].flags = 0; |
277 | memset ((char *) rd[c].data, 'a', 50); | 277 | memset((char *)rd[c].data, 'a', 50); |
278 | } | 278 | } |
279 | return rd; | 279 | return rd; |
280 | } | 280 | } |
281 | 281 | ||
282 | 282 | ||
283 | static void | 283 | static void |
284 | nick_2_cont (void *cls, | 284 | nick_2_cont(void *cls, |
285 | int32_t success, | 285 | int32_t success, |
286 | const char *emsg) | 286 | const char *emsg) |
287 | { | 287 | { |
288 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 288 | GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, |
289 | "Nick added : %s\n", | 289 | "Nick added : %s\n", |
290 | (success == GNUNET_OK) ? "SUCCESS" : "FAIL"); | 290 | (success == GNUNET_OK) ? "SUCCESS" : "FAIL"); |
291 | 291 | ||
292 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Created record 1\n"); | 292 | GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Created record 1\n"); |
293 | 293 | ||
294 | GNUNET_asprintf(&s_name_1, "dummy1"); | 294 | GNUNET_asprintf(&s_name_1, "dummy1"); |
295 | s_rd_1 = create_record(1); | 295 | s_rd_1 = create_record(1); |
296 | GNUNET_NAMESTORE_records_store (nsh, privkey, s_name_1, | 296 | GNUNET_NAMESTORE_records_store(nsh, privkey, s_name_1, |
297 | 1, s_rd_1, | 297 | 1, s_rd_1, |
298 | &put_cont, NULL); | 298 | &put_cont, NULL); |
299 | 299 | ||
300 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 300 | GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, |
301 | "Created record 2 \n"); | 301 | "Created record 2 \n"); |
302 | GNUNET_asprintf(&s_name_2, "dummy2"); | 302 | GNUNET_asprintf(&s_name_2, "dummy2"); |
303 | s_rd_2 = create_record(1); | 303 | s_rd_2 = create_record(1); |
304 | GNUNET_NAMESTORE_records_store (nsh, privkey, s_name_2, | 304 | GNUNET_NAMESTORE_records_store(nsh, privkey, s_name_2, |
305 | 1, s_rd_2, &put_cont, NULL); | 305 | 1, s_rd_2, &put_cont, NULL); |
306 | 306 | ||
307 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 307 | GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, |
308 | "Created record 3\n"); | 308 | "Created record 3\n"); |
309 | 309 | ||
310 | /* name in different zone */ | 310 | /* name in different zone */ |
311 | GNUNET_asprintf(&s_name_3, "dummy3"); | 311 | GNUNET_asprintf(&s_name_3, "dummy3"); |
312 | s_rd_3 = create_record(1); | 312 | s_rd_3 = create_record(1); |
313 | GNUNET_NAMESTORE_records_store (nsh, privkey2, s_name_3, | 313 | GNUNET_NAMESTORE_records_store(nsh, privkey2, s_name_3, |
314 | 1, s_rd_3, | 314 | 1, s_rd_3, |
315 | &put_cont, NULL); | 315 | &put_cont, NULL); |
316 | } | 316 | } |
317 | 317 | ||
318 | 318 | ||
319 | static void | 319 | static void |
320 | nick_1_cont (void *cls, int32_t success, const char *emsg) | 320 | nick_1_cont(void *cls, int32_t success, const char *emsg) |
321 | { | 321 | { |
322 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 322 | GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, |
323 | "Nick 1 added : %s\n", | 323 | "Nick 1 added : %s\n", |
324 | (success == GNUNET_OK) ? "SUCCESS" : "FAIL"); | 324 | (success == GNUNET_OK) ? "SUCCESS" : "FAIL"); |
325 | 325 | ||
326 | nsqe = GNUNET_NAMESTORE_set_nick (nsh, privkey2, ZONE_NICK_2, &nick_2_cont, &privkey2); | 326 | nsqe = GNUNET_NAMESTORE_set_nick(nsh, privkey2, ZONE_NICK_2, &nick_2_cont, &privkey2); |
327 | if (NULL == nsqe) | 327 | if (NULL == nsqe) |
328 | { | 328 | { |
329 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, | 329 | GNUNET_log(GNUNET_ERROR_TYPE_ERROR, |
330 | _("Namestore cannot store no block\n")); | 330 | _("Namestore cannot store no block\n")); |
331 | } | 331 | } |
332 | } | 332 | } |
333 | 333 | ||
334 | 334 | ||
@@ -338,70 +338,69 @@ nick_1_cont (void *cls, int32_t success, const char *emsg) | |||
338 | * start the actual tests by filling the zone. | 338 | * start the actual tests by filling the zone. |
339 | */ | 339 | */ |
340 | static void | 340 | static void |
341 | empty_zone_proc (void *cls, | 341 | empty_zone_proc(void *cls, |
342 | const struct GNUNET_CRYPTO_EcdsaPrivateKey *zone, | 342 | const struct GNUNET_CRYPTO_EcdsaPrivateKey *zone, |
343 | const char *label, | 343 | const char *label, |
344 | unsigned int rd_count, | 344 | unsigned int rd_count, |
345 | const struct GNUNET_GNSRECORD_Data *rd) | 345 | const struct GNUNET_GNSRECORD_Data *rd) |
346 | { | 346 | { |
347 | GNUNET_assert (nsh == cls); | 347 | GNUNET_assert(nsh == cls); |
348 | 348 | ||
349 | if (NULL != zone) | 349 | if (NULL != zone) |
350 | { | 350 | { |
351 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, | 351 | GNUNET_log(GNUNET_ERROR_TYPE_ERROR, |
352 | _("Expected empty zone but received zone private key\n")); | 352 | _("Expected empty zone but received zone private key\n")); |
353 | GNUNET_break (0); | 353 | GNUNET_break(0); |
354 | GNUNET_SCHEDULER_shutdown (); | 354 | GNUNET_SCHEDULER_shutdown(); |
355 | return; | 355 | return; |
356 | } | 356 | } |
357 | if ((NULL != label) || (NULL != rd) || (0 != rd_count)) | 357 | if ((NULL != label) || (NULL != rd) || (0 != rd_count)) |
358 | { | 358 | { |
359 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, | 359 | GNUNET_log(GNUNET_ERROR_TYPE_ERROR, |
360 | _("Expected no zone content but received data\n")); | 360 | _("Expected no zone content but received data\n")); |
361 | GNUNET_break (0); | 361 | GNUNET_break(0); |
362 | GNUNET_SCHEDULER_shutdown (); | 362 | GNUNET_SCHEDULER_shutdown(); |
363 | return; | 363 | return; |
364 | } | 364 | } |
365 | GNUNET_assert (0); | 365 | GNUNET_assert(0); |
366 | } | 366 | } |
367 | 367 | ||
368 | 368 | ||
369 | static void | 369 | static void |
370 | empty_zone_end (void *cls) | 370 | empty_zone_end(void *cls) |
371 | { | 371 | { |
372 | GNUNET_assert (nsh == cls); | 372 | GNUNET_assert(nsh == cls); |
373 | zi = NULL; | 373 | zi = NULL; |
374 | privkey = GNUNET_CRYPTO_ecdsa_key_create (); | 374 | privkey = GNUNET_CRYPTO_ecdsa_key_create(); |
375 | GNUNET_assert (privkey != NULL); | 375 | GNUNET_assert(privkey != NULL); |
376 | privkey2 = GNUNET_CRYPTO_ecdsa_key_create (); | 376 | privkey2 = GNUNET_CRYPTO_ecdsa_key_create(); |
377 | GNUNET_assert (privkey2 != NULL); | 377 | GNUNET_assert(privkey2 != NULL); |
378 | 378 | ||
379 | nsqe = GNUNET_NAMESTORE_set_nick (nsh, | 379 | nsqe = GNUNET_NAMESTORE_set_nick(nsh, |
380 | privkey, | 380 | privkey, |
381 | ZONE_NICK_1, | 381 | ZONE_NICK_1, |
382 | &nick_1_cont, | 382 | &nick_1_cont, |
383 | &privkey); | 383 | &privkey); |
384 | if (NULL == nsqe) | 384 | if (NULL == nsqe) |
385 | { | 385 | { |
386 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, | 386 | GNUNET_log(GNUNET_ERROR_TYPE_ERROR, |
387 | _("Namestore cannot store no block\n")); | 387 | _("Namestore cannot store no block\n")); |
388 | } | 388 | } |
389 | |||
390 | } | 389 | } |
391 | 390 | ||
392 | 391 | ||
393 | static void | 392 | static void |
394 | run (void *cls, | 393 | run(void *cls, |
395 | const struct GNUNET_CONFIGURATION_Handle *cfg, | 394 | const struct GNUNET_CONFIGURATION_Handle *cfg, |
396 | struct GNUNET_TESTING_Peer *peer) | 395 | struct GNUNET_TESTING_Peer *peer) |
397 | { | 396 | { |
398 | nsh = GNUNET_NAMESTORE_connect (cfg); | 397 | nsh = GNUNET_NAMESTORE_connect(cfg); |
399 | GNUNET_break (NULL != nsh); | 398 | GNUNET_break(NULL != nsh); |
400 | GNUNET_SCHEDULER_add_shutdown (&end, | 399 | GNUNET_SCHEDULER_add_shutdown(&end, |
401 | NULL); | 400 | NULL); |
402 | /* first, iterate over empty namestore */ | 401 | /* first, iterate over empty namestore */ |
403 | zi = GNUNET_NAMESTORE_zone_iteration_start(nsh, | 402 | zi = GNUNET_NAMESTORE_zone_iteration_start(nsh, |
404 | NULL, | 403 | NULL, |
405 | &fail_cb, | 404 | &fail_cb, |
406 | NULL, | 405 | NULL, |
407 | &empty_zone_proc, | 406 | &empty_zone_proc, |
@@ -409,12 +408,12 @@ run (void *cls, | |||
409 | &empty_zone_end, | 408 | &empty_zone_end, |
410 | nsh); | 409 | nsh); |
411 | if (NULL == zi) | 410 | if (NULL == zi) |
412 | { | 411 | { |
413 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, | 412 | GNUNET_log(GNUNET_ERROR_TYPE_ERROR, |
414 | "Failed to create zone iterator\n"); | 413 | "Failed to create zone iterator\n"); |
415 | GNUNET_break (0); | 414 | GNUNET_break(0); |
416 | GNUNET_SCHEDULER_shutdown (); | 415 | GNUNET_SCHEDULER_shutdown(); |
417 | } | 416 | } |
418 | } | 417 | } |
419 | 418 | ||
420 | 419 | ||
@@ -422,24 +421,24 @@ run (void *cls, | |||
422 | 421 | ||
423 | 422 | ||
424 | int | 423 | int |
425 | main (int argc, char *argv[]) | 424 | main(int argc, char *argv[]) |
426 | { | 425 | { |
427 | const char *plugin_name; | 426 | const char *plugin_name; |
428 | char *cfg_name; | 427 | char *cfg_name; |
429 | 428 | ||
430 | SETUP_CFG (plugin_name, cfg_name); | 429 | SETUP_CFG(plugin_name, cfg_name); |
431 | res = 1; | 430 | res = 1; |
432 | if (0 != | 431 | if (0 != |
433 | GNUNET_TESTING_peer_run ("test-namestore-api-zone-iteration-nick", | 432 | GNUNET_TESTING_peer_run("test-namestore-api-zone-iteration-nick", |
434 | cfg_name, | 433 | cfg_name, |
435 | &run, | 434 | &run, |
436 | NULL)) | 435 | NULL)) |
437 | { | 436 | { |
438 | res = 1; | 437 | res = 1; |
439 | } | 438 | } |
440 | GNUNET_DISK_purge_cfg_dir (cfg_name, | 439 | GNUNET_DISK_purge_cfg_dir(cfg_name, |
441 | "GNUNET_TEST_HOME"); | 440 | "GNUNET_TEST_HOME"); |
442 | GNUNET_free (cfg_name); | 441 | GNUNET_free(cfg_name); |
443 | return res; | 442 | return res; |
444 | } | 443 | } |
445 | 444 | ||