diff options
Diffstat (limited to 'src/namestore/test_namestore_api_zone_to_name.c')
-rw-r--r-- | src/namestore/test_namestore_api_zone_to_name.c | 274 |
1 files changed, 137 insertions, 137 deletions
diff --git a/src/namestore/test_namestore_api_zone_to_name.c b/src/namestore/test_namestore_api_zone_to_name.c index cb580572e..0c02c9a52 100644 --- a/src/namestore/test_namestore_api_zone_to_name.c +++ b/src/namestore/test_namestore_api_zone_to_name.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_to_name.c | 21 | * @file namestore/test_namestore_api_zone_to_name.c |
22 | * @brief testcase for zone to name translation | 22 | * @brief testcase for zone to name translation |
@@ -35,7 +35,7 @@ | |||
35 | 35 | ||
36 | #define TEST_RECORD_DATA 'a' | 36 | #define TEST_RECORD_DATA 'a' |
37 | 37 | ||
38 | #define TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 100) | 38 | #define TIMEOUT GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 100) |
39 | 39 | ||
40 | 40 | ||
41 | static struct GNUNET_NAMESTORE_Handle *nsh; | 41 | static struct GNUNET_NAMESTORE_Handle *nsh; |
@@ -61,180 +61,180 @@ static struct GNUNET_NAMESTORE_QueueEntry *qe; | |||
61 | * @param cls handle to use to re-connect. | 61 | * @param cls handle to use to re-connect. |
62 | */ | 62 | */ |
63 | static void | 63 | static void |
64 | endbadly (void *cls) | 64 | endbadly(void *cls) |
65 | { | 65 | { |
66 | (void) cls; | 66 | (void)cls; |
67 | GNUNET_SCHEDULER_shutdown (); | 67 | GNUNET_SCHEDULER_shutdown(); |
68 | res = 1; | 68 | res = 1; |
69 | } | 69 | } |
70 | 70 | ||
71 | 71 | ||
72 | static void | 72 | static void |
73 | end (void *cls) | 73 | end(void *cls) |
74 | { | 74 | { |
75 | if (NULL != qe) | 75 | if (NULL != qe) |
76 | { | 76 | { |
77 | GNUNET_NAMESTORE_cancel (qe); | 77 | GNUNET_NAMESTORE_cancel(qe); |
78 | qe = NULL; | 78 | qe = NULL; |
79 | } | 79 | } |
80 | if (NULL != endbadly_task) | 80 | if (NULL != endbadly_task) |
81 | { | 81 | { |
82 | GNUNET_SCHEDULER_cancel (endbadly_task); | 82 | GNUNET_SCHEDULER_cancel(endbadly_task); |
83 | endbadly_task = NULL; | 83 | endbadly_task = NULL; |
84 | } | 84 | } |
85 | if (NULL != privkey) | 85 | if (NULL != privkey) |
86 | { | 86 | { |
87 | GNUNET_free (privkey); | 87 | GNUNET_free(privkey); |
88 | privkey = NULL; | 88 | privkey = NULL; |
89 | } | 89 | } |
90 | if (NULL != nsh) | 90 | if (NULL != nsh) |
91 | { | 91 | { |
92 | GNUNET_NAMESTORE_disconnect (nsh); | 92 | GNUNET_NAMESTORE_disconnect(nsh); |
93 | nsh = NULL; | 93 | nsh = NULL; |
94 | } | 94 | } |
95 | } | 95 | } |
96 | 96 | ||
97 | 97 | ||
98 | static void | 98 | static void |
99 | zone_to_name_proc (void *cls, | 99 | zone_to_name_proc(void *cls, |
100 | const struct GNUNET_CRYPTO_EcdsaPrivateKey *zone_key, | 100 | const struct GNUNET_CRYPTO_EcdsaPrivateKey *zone_key, |
101 | const char *n, | 101 | const char *n, |
102 | unsigned int rd_count, | 102 | unsigned int rd_count, |
103 | const struct GNUNET_GNSRECORD_Data *rd) | 103 | const struct GNUNET_GNSRECORD_Data *rd) |
104 | { | 104 | { |
105 | int fail = GNUNET_NO; | 105 | int fail = GNUNET_NO; |
106 | 106 | ||
107 | qe = NULL; | 107 | qe = NULL; |
108 | if ( (NULL == zone_key) && | 108 | if ((NULL == zone_key) && |
109 | (NULL == n) && | 109 | (NULL == n) && |
110 | (0 == rd_count) && | 110 | (0 == rd_count) && |
111 | (NULL == rd) ) | 111 | (NULL == rd)) |
112 | { | ||
113 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
114 | "No result found\n"); | ||
115 | res = 1; | ||
116 | } | ||
117 | else | ||
118 | { | ||
119 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
120 | "Result found: `%s'\n", | ||
121 | n); | ||
122 | if ( (NULL == n) || | ||
123 | (0 != strcmp (n, | ||
124 | s_name))) | ||
125 | { | 112 | { |
126 | fail = GNUNET_YES; | 113 | GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, |
127 | GNUNET_break (0); | 114 | "No result found\n"); |
128 | } | 115 | res = 1; |
129 | if (1 != rd_count) | ||
130 | { | ||
131 | fail = GNUNET_YES; | ||
132 | GNUNET_break (0); | ||
133 | } | 116 | } |
134 | if ( (NULL == zone_key) || | 117 | else |
135 | (0 != GNUNET_memcmp (zone_key, | ||
136 | privkey))) | ||
137 | { | 118 | { |
138 | fail = GNUNET_YES; | 119 | GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, |
139 | GNUNET_break (0); | 120 | "Result found: `%s'\n", |
121 | n); | ||
122 | if ((NULL == n) || | ||
123 | (0 != strcmp(n, | ||
124 | s_name))) | ||
125 | { | ||
126 | fail = GNUNET_YES; | ||
127 | GNUNET_break(0); | ||
128 | } | ||
129 | if (1 != rd_count) | ||
130 | { | ||
131 | fail = GNUNET_YES; | ||
132 | GNUNET_break(0); | ||
133 | } | ||
134 | if ((NULL == zone_key) || | ||
135 | (0 != GNUNET_memcmp(zone_key, | ||
136 | privkey))) | ||
137 | { | ||
138 | fail = GNUNET_YES; | ||
139 | GNUNET_break(0); | ||
140 | } | ||
141 | if (fail == GNUNET_NO) | ||
142 | res = 0; | ||
143 | else | ||
144 | res = 1; | ||
140 | } | 145 | } |
141 | if (fail == GNUNET_NO) | 146 | GNUNET_SCHEDULER_add_now(&end, |
142 | res = 0; | 147 | NULL); |
143 | else | ||
144 | res = 1; | ||
145 | } | ||
146 | GNUNET_SCHEDULER_add_now (&end, | ||
147 | NULL); | ||
148 | } | 148 | } |
149 | 149 | ||
150 | 150 | ||
151 | static void | 151 | static void |
152 | error_cb (void *cls) | 152 | error_cb(void *cls) |
153 | { | 153 | { |
154 | (void) cls; | 154 | (void)cls; |
155 | qe = NULL; | 155 | qe = NULL; |
156 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, | 156 | GNUNET_log(GNUNET_ERROR_TYPE_ERROR, |
157 | "Not found!\n"); | 157 | "Not found!\n"); |
158 | GNUNET_SCHEDULER_shutdown (); | 158 | GNUNET_SCHEDULER_shutdown(); |
159 | res = 2; | 159 | res = 2; |
160 | } | 160 | } |
161 | 161 | ||
162 | 162 | ||
163 | static void | 163 | static void |
164 | put_cont (void *cls, | 164 | put_cont(void *cls, |
165 | int32_t success, | 165 | int32_t success, |
166 | const char *emsg) | 166 | const char *emsg) |
167 | { | 167 | { |
168 | char *name = cls; | 168 | char *name = cls; |
169 | 169 | ||
170 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 170 | GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, |
171 | "Name store added record for `%s': %s\n", | 171 | "Name store added record for `%s': %s\n", |
172 | name, | 172 | name, |
173 | (success == GNUNET_OK) ? "SUCCESS" : emsg); | 173 | (success == GNUNET_OK) ? "SUCCESS" : emsg); |
174 | if (success == GNUNET_OK) | 174 | if (success == GNUNET_OK) |
175 | { | 175 | { |
176 | res = 0; | 176 | res = 0; |
177 | 177 | ||
178 | qe = GNUNET_NAMESTORE_zone_to_name (nsh, | 178 | qe = GNUNET_NAMESTORE_zone_to_name(nsh, |
179 | privkey, | 179 | privkey, |
180 | &s_zone_value, | 180 | &s_zone_value, |
181 | &error_cb, | 181 | &error_cb, |
182 | NULL, | 182 | NULL, |
183 | &zone_to_name_proc, | 183 | &zone_to_name_proc, |
184 | NULL); | 184 | NULL); |
185 | } | 185 | } |
186 | else | 186 | else |
187 | { | 187 | { |
188 | res = 1; | 188 | res = 1; |
189 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, | 189 | GNUNET_log(GNUNET_ERROR_TYPE_ERROR, |
190 | "Failed to put records for name `%s'\n", | 190 | "Failed to put records for name `%s'\n", |
191 | name); | 191 | name); |
192 | GNUNET_SCHEDULER_add_now (&end, | 192 | GNUNET_SCHEDULER_add_now(&end, |
193 | NULL); | 193 | NULL); |
194 | } | 194 | } |
195 | } | 195 | } |
196 | 196 | ||
197 | 197 | ||
198 | static void | 198 | static void |
199 | run (void *cls, | 199 | run(void *cls, |
200 | const struct GNUNET_CONFIGURATION_Handle *cfg, | 200 | const struct GNUNET_CONFIGURATION_Handle *cfg, |
201 | struct GNUNET_TESTING_Peer *peer) | 201 | struct GNUNET_TESTING_Peer *peer) |
202 | { | 202 | { |
203 | (void) cls; | 203 | (void)cls; |
204 | (void) peer; | 204 | (void)peer; |
205 | endbadly_task = GNUNET_SCHEDULER_add_delayed (TIMEOUT, | 205 | endbadly_task = GNUNET_SCHEDULER_add_delayed(TIMEOUT, |
206 | &endbadly, | 206 | &endbadly, |
207 | NULL); | 207 | NULL); |
208 | GNUNET_SCHEDULER_add_shutdown (&end, | 208 | GNUNET_SCHEDULER_add_shutdown(&end, |
209 | NULL); | 209 | NULL); |
210 | GNUNET_asprintf (&s_name, "dummy"); | 210 | GNUNET_asprintf(&s_name, "dummy"); |
211 | privkey = GNUNET_CRYPTO_ecdsa_key_create (); | 211 | privkey = GNUNET_CRYPTO_ecdsa_key_create(); |
212 | GNUNET_assert (NULL != privkey); | 212 | GNUNET_assert(NULL != privkey); |
213 | /* get public key */ | 213 | /* get public key */ |
214 | GNUNET_CRYPTO_ecdsa_key_get_public (privkey, | 214 | GNUNET_CRYPTO_ecdsa_key_get_public(privkey, |
215 | &pubkey); | 215 | &pubkey); |
216 | 216 | ||
217 | GNUNET_CRYPTO_random_block (GNUNET_CRYPTO_QUALITY_WEAK, | 217 | GNUNET_CRYPTO_random_block(GNUNET_CRYPTO_QUALITY_WEAK, |
218 | &s_zone_value, | 218 | &s_zone_value, |
219 | sizeof (s_zone_value)); | 219 | sizeof(s_zone_value)); |
220 | { | 220 | { |
221 | struct GNUNET_GNSRECORD_Data rd; | 221 | struct GNUNET_GNSRECORD_Data rd; |
222 | 222 | ||
223 | rd.expiration_time = GNUNET_TIME_absolute_get().abs_value_us; | 223 | rd.expiration_time = GNUNET_TIME_absolute_get().abs_value_us; |
224 | rd.record_type = GNUNET_GNSRECORD_TYPE_PKEY; | 224 | rd.record_type = GNUNET_GNSRECORD_TYPE_PKEY; |
225 | rd.data_size = sizeof (s_zone_value); | 225 | rd.data_size = sizeof(s_zone_value); |
226 | rd.data = &s_zone_value; | 226 | rd.data = &s_zone_value; |
227 | rd.flags = 0; | 227 | rd.flags = 0; |
228 | 228 | ||
229 | nsh = GNUNET_NAMESTORE_connect (cfg); | 229 | nsh = GNUNET_NAMESTORE_connect(cfg); |
230 | GNUNET_break (NULL != nsh); | 230 | GNUNET_break(NULL != nsh); |
231 | GNUNET_NAMESTORE_records_store (nsh, | 231 | GNUNET_NAMESTORE_records_store(nsh, |
232 | privkey, | 232 | privkey, |
233 | s_name, | 233 | s_name, |
234 | 1, | 234 | 1, |
235 | &rd, | 235 | &rd, |
236 | &put_cont, | 236 | &put_cont, |
237 | NULL); | 237 | NULL); |
238 | } | 238 | } |
239 | } | 239 | } |
240 | 240 | ||
@@ -243,26 +243,26 @@ run (void *cls, | |||
243 | 243 | ||
244 | 244 | ||
245 | int | 245 | int |
246 | main (int argc, | 246 | main(int argc, |
247 | char *argv[]) | 247 | char *argv[]) |
248 | { | 248 | { |
249 | const char *plugin_name; | 249 | const char *plugin_name; |
250 | char *cfg_name; | 250 | char *cfg_name; |
251 | 251 | ||
252 | (void) argc; | 252 | (void)argc; |
253 | SETUP_CFG (plugin_name, cfg_name); | 253 | SETUP_CFG(plugin_name, cfg_name); |
254 | res = 1; | 254 | res = 1; |
255 | if (0 != | 255 | if (0 != |
256 | GNUNET_TESTING_peer_run ("test-namestore-api-zone-to-name", | 256 | GNUNET_TESTING_peer_run("test-namestore-api-zone-to-name", |
257 | cfg_name, | 257 | cfg_name, |
258 | &run, | 258 | &run, |
259 | NULL)) | 259 | NULL)) |
260 | { | 260 | { |
261 | res = 1; | 261 | res = 1; |
262 | } | 262 | } |
263 | GNUNET_DISK_purge_cfg_dir (cfg_name, | 263 | GNUNET_DISK_purge_cfg_dir(cfg_name, |
264 | "GNUNET_TEST_HOME"); | 264 | "GNUNET_TEST_HOME"); |
265 | GNUNET_free (cfg_name); | 265 | GNUNET_free(cfg_name); |
266 | return res; | 266 | return res; |
267 | } | 267 | } |
268 | 268 | ||