diff options
Diffstat (limited to 'src/namestore/test_namestore_api_remove.c')
-rw-r--r-- | src/namestore/test_namestore_api_remove.c | 204 |
1 files changed, 102 insertions, 102 deletions
diff --git a/src/namestore/test_namestore_api_remove.c b/src/namestore/test_namestore_api_remove.c index 4c3d55efc..b2334667e 100644 --- a/src/namestore/test_namestore_api_remove.c +++ b/src/namestore/test_namestore_api_remove.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.c | 21 | * @file namestore/test_namestore_api.c |
22 | * @brief testcase for namestore_api.c to: remove record | 22 | * @brief testcase for namestore_api.c to: remove record |
@@ -32,7 +32,7 @@ | |||
32 | 32 | ||
33 | #define TEST_RECORD_DATA 'a' | 33 | #define TEST_RECORD_DATA 'a' |
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; |
@@ -51,19 +51,19 @@ static struct GNUNET_NAMESTORE_QueueEntry *nsqe; | |||
51 | 51 | ||
52 | 52 | ||
53 | static void | 53 | static void |
54 | cleanup () | 54 | cleanup() |
55 | { | 55 | { |
56 | if (NULL != nsh) | 56 | if (NULL != nsh) |
57 | { | 57 | { |
58 | GNUNET_NAMESTORE_disconnect (nsh); | 58 | GNUNET_NAMESTORE_disconnect(nsh); |
59 | nsh = NULL; | 59 | nsh = NULL; |
60 | } | 60 | } |
61 | if (NULL != privkey) | 61 | if (NULL != privkey) |
62 | { | 62 | { |
63 | GNUNET_free (privkey); | 63 | GNUNET_free(privkey); |
64 | privkey = NULL; | 64 | privkey = NULL; |
65 | } | 65 | } |
66 | GNUNET_SCHEDULER_shutdown (); | 66 | GNUNET_SCHEDULER_shutdown(); |
67 | } | 67 | } |
68 | 68 | ||
69 | 69 | ||
@@ -73,127 +73,127 @@ cleanup () | |||
73 | * @param cls handle to use to re-connect. | 73 | * @param cls handle to use to re-connect. |
74 | */ | 74 | */ |
75 | static void | 75 | static void |
76 | endbadly (void *cls) | 76 | endbadly(void *cls) |
77 | { | 77 | { |
78 | if (NULL != nsqe) | 78 | if (NULL != nsqe) |
79 | { | 79 | { |
80 | GNUNET_NAMESTORE_cancel (nsqe); | 80 | GNUNET_NAMESTORE_cancel(nsqe); |
81 | nsqe = NULL; | 81 | nsqe = NULL; |
82 | } | 82 | } |
83 | cleanup (); | 83 | cleanup(); |
84 | res = 1; | 84 | res = 1; |
85 | } | 85 | } |
86 | 86 | ||
87 | 87 | ||
88 | static void | 88 | static void |
89 | end (void *cls) | 89 | end(void *cls) |
90 | { | 90 | { |
91 | cleanup (); | 91 | cleanup(); |
92 | res = 0; | 92 | res = 0; |
93 | } | 93 | } |
94 | 94 | ||
95 | 95 | ||
96 | static void | 96 | static void |
97 | remove_cont (void *cls, | 97 | remove_cont(void *cls, |
98 | int32_t success, | 98 | int32_t success, |
99 | const char *emsg) | 99 | const char *emsg) |
100 | { | 100 | { |
101 | nsqe = NULL; | 101 | nsqe = NULL; |
102 | if (GNUNET_YES != success) | 102 | if (GNUNET_YES != success) |
103 | { | 103 | { |
104 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, | 104 | GNUNET_log(GNUNET_ERROR_TYPE_ERROR, |
105 | _("Records could not be removed: `%s'\n"), | 105 | _("Records could not be removed: `%s'\n"), |
106 | emsg); | 106 | emsg); |
107 | if (NULL != endbadly_task) | 107 | if (NULL != endbadly_task) |
108 | GNUNET_SCHEDULER_cancel (endbadly_task); | 108 | GNUNET_SCHEDULER_cancel(endbadly_task); |
109 | endbadly_task = GNUNET_SCHEDULER_add_now (&endbadly, | 109 | endbadly_task = GNUNET_SCHEDULER_add_now(&endbadly, |
110 | NULL); | 110 | NULL); |
111 | return; | 111 | return; |
112 | } | 112 | } |
113 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, | 113 | GNUNET_log(GNUNET_ERROR_TYPE_INFO, |
114 | "Records were removed, perform lookup\n"); | 114 | "Records were removed, perform lookup\n"); |
115 | removed = GNUNET_YES; | 115 | removed = GNUNET_YES; |
116 | if (NULL != endbadly_task) | 116 | if (NULL != endbadly_task) |
117 | GNUNET_SCHEDULER_cancel (endbadly_task); | 117 | GNUNET_SCHEDULER_cancel(endbadly_task); |
118 | GNUNET_SCHEDULER_add_now (&end, NULL); | 118 | GNUNET_SCHEDULER_add_now(&end, NULL); |
119 | } | 119 | } |
120 | 120 | ||
121 | 121 | ||
122 | static void | 122 | static void |
123 | put_cont (void *cls, | 123 | put_cont(void *cls, |
124 | int32_t success, | 124 | int32_t success, |
125 | const char *emsg) | 125 | const char *emsg) |
126 | { | 126 | { |
127 | const char *name = cls; | 127 | const char *name = cls; |
128 | 128 | ||
129 | GNUNET_assert (NULL != cls); | 129 | GNUNET_assert(NULL != cls); |
130 | nsqe = NULL; | 130 | nsqe = NULL; |
131 | if (GNUNET_SYSERR == success) | 131 | if (GNUNET_SYSERR == success) |
132 | { | 132 | { |
133 | GNUNET_break (0); | 133 | GNUNET_break(0); |
134 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, | 134 | GNUNET_log(GNUNET_ERROR_TYPE_ERROR, |
135 | "Namestore could not store record: `%s'\n", | 135 | "Namestore could not store record: `%s'\n", |
136 | emsg); | 136 | emsg); |
137 | if (endbadly_task != NULL) | 137 | if (endbadly_task != NULL) |
138 | GNUNET_SCHEDULER_cancel (endbadly_task); | 138 | GNUNET_SCHEDULER_cancel(endbadly_task); |
139 | endbadly_task = GNUNET_SCHEDULER_add_now (&endbadly, NULL); | 139 | endbadly_task = GNUNET_SCHEDULER_add_now(&endbadly, NULL); |
140 | return; | 140 | return; |
141 | } | 141 | } |
142 | 142 | ||
143 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 143 | GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, |
144 | "Name store added record for `%s': %s\n", | 144 | "Name store added record for `%s': %s\n", |
145 | name, | 145 | name, |
146 | (success == GNUNET_OK) ? "SUCCESS" : "FAIL"); | 146 | (success == GNUNET_OK) ? "SUCCESS" : "FAIL"); |
147 | nsqe = GNUNET_NAMESTORE_records_store (nsh, | 147 | nsqe = GNUNET_NAMESTORE_records_store(nsh, |
148 | privkey, | 148 | privkey, |
149 | name, | 149 | name, |
150 | 0, NULL, | 150 | 0, NULL, |
151 | &remove_cont, (void *) name); | 151 | &remove_cont, (void *)name); |
152 | } | 152 | } |
153 | 153 | ||
154 | 154 | ||
155 | static void | 155 | static void |
156 | run (void *cls, | 156 | run(void *cls, |
157 | const struct GNUNET_CONFIGURATION_Handle *cfg, | 157 | const struct GNUNET_CONFIGURATION_Handle *cfg, |
158 | struct GNUNET_TESTING_Peer *peer) | 158 | struct GNUNET_TESTING_Peer *peer) |
159 | { | 159 | { |
160 | struct GNUNET_GNSRECORD_Data rd; | 160 | struct GNUNET_GNSRECORD_Data rd; |
161 | const char * name = "dummy.dummy.gnunet"; | 161 | const char * name = "dummy.dummy.gnunet"; |
162 | 162 | ||
163 | endbadly_task = GNUNET_SCHEDULER_add_delayed (TIMEOUT, | 163 | endbadly_task = GNUNET_SCHEDULER_add_delayed(TIMEOUT, |
164 | &endbadly, | 164 | &endbadly, |
165 | NULL); | 165 | NULL); |
166 | privkey = GNUNET_CRYPTO_ecdsa_key_create (); | 166 | privkey = GNUNET_CRYPTO_ecdsa_key_create(); |
167 | GNUNET_assert (privkey != NULL); | 167 | GNUNET_assert(privkey != NULL); |
168 | GNUNET_CRYPTO_ecdsa_key_get_public (privkey, | 168 | GNUNET_CRYPTO_ecdsa_key_get_public(privkey, |
169 | &pubkey); | 169 | &pubkey); |
170 | 170 | ||
171 | removed = GNUNET_NO; | 171 | removed = GNUNET_NO; |
172 | 172 | ||
173 | rd.expiration_time = GNUNET_TIME_absolute_get().abs_value_us; | 173 | rd.expiration_time = GNUNET_TIME_absolute_get().abs_value_us; |
174 | rd.record_type = TEST_RECORD_TYPE; | 174 | rd.record_type = TEST_RECORD_TYPE; |
175 | rd.data_size = TEST_RECORD_DATALEN; | 175 | rd.data_size = TEST_RECORD_DATALEN; |
176 | rd.data = GNUNET_malloc (TEST_RECORD_DATALEN); | 176 | rd.data = GNUNET_malloc(TEST_RECORD_DATALEN); |
177 | rd.flags = 0; | 177 | rd.flags = 0; |
178 | memset ((char *) rd.data, | 178 | memset((char *)rd.data, |
179 | 'a', | 179 | 'a', |
180 | TEST_RECORD_DATALEN); | 180 | TEST_RECORD_DATALEN); |
181 | 181 | ||
182 | nsh = GNUNET_NAMESTORE_connect (cfg); | 182 | nsh = GNUNET_NAMESTORE_connect(cfg); |
183 | GNUNET_break (NULL != nsh); | 183 | GNUNET_break(NULL != nsh); |
184 | nsqe = GNUNET_NAMESTORE_records_store (nsh, | 184 | nsqe = GNUNET_NAMESTORE_records_store(nsh, |
185 | privkey, | 185 | privkey, |
186 | name, | 186 | name, |
187 | 1, | 187 | 1, |
188 | &rd, | 188 | &rd, |
189 | &put_cont, | 189 | &put_cont, |
190 | (void *) name); | 190 | (void *)name); |
191 | if (NULL == nsqe) | 191 | if (NULL == nsqe) |
192 | { | 192 | { |
193 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, | 193 | GNUNET_log(GNUNET_ERROR_TYPE_ERROR, |
194 | _("Namestore cannot store no block\n")); | 194 | _("Namestore cannot store no block\n")); |
195 | } | 195 | } |
196 | GNUNET_free ((void *)rd.data); | 196 | GNUNET_free((void *)rd.data); |
197 | } | 197 | } |
198 | 198 | ||
199 | 199 | ||
@@ -201,24 +201,24 @@ run (void *cls, | |||
201 | 201 | ||
202 | 202 | ||
203 | int | 203 | int |
204 | main (int argc, char *argv[]) | 204 | main(int argc, char *argv[]) |
205 | { | 205 | { |
206 | const char *plugin_name; | 206 | const char *plugin_name; |
207 | char *cfg_name; | 207 | char *cfg_name; |
208 | 208 | ||
209 | SETUP_CFG (plugin_name, cfg_name); | 209 | SETUP_CFG(plugin_name, cfg_name); |
210 | res = 1; | 210 | res = 1; |
211 | if (0 != | 211 | if (0 != |
212 | GNUNET_TESTING_peer_run ("test-namestore-api-remove", | 212 | GNUNET_TESTING_peer_run("test-namestore-api-remove", |
213 | cfg_name, | 213 | cfg_name, |
214 | &run, | 214 | &run, |
215 | NULL)) | 215 | NULL)) |
216 | { | 216 | { |
217 | res = 1; | 217 | res = 1; |
218 | } | 218 | } |
219 | GNUNET_DISK_purge_cfg_dir (cfg_name, | 219 | GNUNET_DISK_purge_cfg_dir(cfg_name, |
220 | "GNUNET_TEST_HOME"); | 220 | "GNUNET_TEST_HOME"); |
221 | GNUNET_free (cfg_name); | 221 | GNUNET_free(cfg_name); |
222 | return res; | 222 | return res; |
223 | } | 223 | } |
224 | 224 | ||