aboutsummaryrefslogtreecommitdiff
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.c208
1 files changed, 104 insertions, 104 deletions
diff --git a/src/namestore/test_namestore_api_remove.c b/src/namestore/test_namestore_api_remove.c
index b2334667e..10160cd13 100644
--- a/src/namestore/test_namestore_api_remove.c
+++ b/src/namestore/test_namestore_api_remove.c
@@ -32,12 +32,12 @@
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;
39 39
40static struct GNUNET_SCHEDULER_Task * endbadly_task; 40static struct GNUNET_SCHEDULER_Task *endbadly_task;
41 41
42static struct GNUNET_CRYPTO_EcdsaPrivateKey *privkey; 42static struct GNUNET_CRYPTO_EcdsaPrivateKey *privkey;
43 43
@@ -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