summaryrefslogtreecommitdiff
path: root/src/namestore/test_namestore_api_remove.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/namestore/test_namestore_api_remove.c')
-rw-r--r--src/namestore/test_namestore_api_remove.c204
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
38static struct GNUNET_NAMESTORE_Handle *nsh; 38static struct GNUNET_NAMESTORE_Handle *nsh;
@@ -51,19 +51,19 @@ static struct GNUNET_NAMESTORE_QueueEntry *nsqe;
51 51
52 52
53static void 53static void
54cleanup () 54cleanup()
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 */
75static void 75static void
76endbadly (void *cls) 76endbadly(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
88static void 88static void
89end (void *cls) 89end(void *cls)
90{ 90{
91 cleanup (); 91 cleanup();
92 res = 0; 92 res = 0;
93} 93}
94 94
95 95
96static void 96static void
97remove_cont (void *cls, 97remove_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
122static void 122static void
123put_cont (void *cls, 123put_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
155static void 155static void
156run (void *cls, 156run(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
203int 203int
204main (int argc, char *argv[]) 204main(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