summaryrefslogtreecommitdiff
path: root/src/namestore/test_namestore_api_store.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/namestore/test_namestore_api_store.c')
-rw-r--r--src/namestore/test_namestore_api_store.c132
1 files changed, 66 insertions, 66 deletions
diff --git a/src/namestore/test_namestore_api_store.c b/src/namestore/test_namestore_api_store.c
index 0dbad8ce3..622227471 100644
--- a/src/namestore/test_namestore_api_store.c
+++ b/src/namestore/test_namestore_api_store.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_store.c 21 * @file namestore/test_namestore_api_store.c
22 * @brief testcase for namestore_api.c: store a record 22 * @brief testcase for namestore_api.c: store a 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;
@@ -49,19 +49,19 @@ static struct GNUNET_NAMESTORE_QueueEntry *nsqe;
49 49
50 50
51static void 51static void
52cleanup () 52cleanup()
53{ 53{
54 if (NULL != nsh) 54 if (NULL != nsh)
55 { 55 {
56 GNUNET_NAMESTORE_disconnect (nsh); 56 GNUNET_NAMESTORE_disconnect(nsh);
57 nsh = NULL; 57 nsh = NULL;
58 } 58 }
59 if (NULL != privkey) 59 if (NULL != privkey)
60 { 60 {
61 GNUNET_free (privkey); 61 GNUNET_free(privkey);
62 privkey = NULL; 62 privkey = NULL;
63 } 63 }
64 GNUNET_SCHEDULER_shutdown (); 64 GNUNET_SCHEDULER_shutdown();
65} 65}
66 66
67 67
@@ -71,80 +71,80 @@ cleanup ()
71 * @param cls handle to use to re-connect. 71 * @param cls handle to use to re-connect.
72 */ 72 */
73static void 73static void
74endbadly (void *cls) 74endbadly(void *cls)
75{ 75{
76 if (NULL != nsqe) 76 if (NULL != nsqe)
77 { 77 {
78 GNUNET_NAMESTORE_cancel (nsqe); 78 GNUNET_NAMESTORE_cancel(nsqe);
79 nsqe = NULL; 79 nsqe = NULL;
80 } 80 }
81 cleanup (); 81 cleanup();
82 res = 1; 82 res = 1;
83} 83}
84 84
85 85
86static void 86static void
87end (void *cls) 87end(void *cls)
88{ 88{
89 cleanup (); 89 cleanup();
90 res = 0; 90 res = 0;
91} 91}
92 92
93 93
94static void 94static void
95put_cont (void *cls, int32_t success, const char *emsg) 95put_cont(void *cls, int32_t success, const char *emsg)
96{ 96{
97 const char *name = cls; 97 const char *name = cls;
98 98
99 nsqe = NULL; 99 nsqe = NULL;
100 GNUNET_assert (NULL != cls); 100 GNUNET_assert(NULL != cls);
101 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 101 GNUNET_log(GNUNET_ERROR_TYPE_DEBUG,
102 "Name store added record for `%s': %s\n", 102 "Name store added record for `%s': %s\n",
103 name, 103 name,
104 (success == GNUNET_OK) ? "SUCCESS" : "FAIL"); 104 (success == GNUNET_OK) ? "SUCCESS" : "FAIL");
105 GNUNET_SCHEDULER_cancel (endbadly_task); 105 GNUNET_SCHEDULER_cancel(endbadly_task);
106 endbadly_task = NULL; 106 endbadly_task = NULL;
107 GNUNET_SCHEDULER_add_now (&end, NULL); 107 GNUNET_SCHEDULER_add_now(&end, NULL);
108} 108}
109 109
110 110
111static void 111static void
112run (void *cls, 112run(void *cls,
113 const struct GNUNET_CONFIGURATION_Handle *cfg, 113 const struct GNUNET_CONFIGURATION_Handle *cfg,
114 struct GNUNET_TESTING_Peer *peer) 114 struct GNUNET_TESTING_Peer *peer)
115{ 115{
116 struct GNUNET_GNSRECORD_Data rd; 116 struct GNUNET_GNSRECORD_Data rd;
117 const char * name = "dummy.dummy.gnunet"; 117 const char * name = "dummy.dummy.gnunet";
118 118
119 endbadly_task = GNUNET_SCHEDULER_add_delayed (TIMEOUT, 119 endbadly_task = GNUNET_SCHEDULER_add_delayed(TIMEOUT,
120 &endbadly, NULL); 120 &endbadly, NULL);
121 privkey = GNUNET_CRYPTO_ecdsa_key_create (); 121 privkey = GNUNET_CRYPTO_ecdsa_key_create();
122 GNUNET_assert (privkey != NULL); 122 GNUNET_assert(privkey != NULL);
123 GNUNET_CRYPTO_ecdsa_key_get_public (privkey, &pubkey); 123 GNUNET_CRYPTO_ecdsa_key_get_public(privkey, &pubkey);
124 124
125 125
126 rd.expiration_time = GNUNET_TIME_absolute_get().abs_value_us; 126 rd.expiration_time = GNUNET_TIME_absolute_get().abs_value_us;
127 rd.record_type = TEST_RECORD_TYPE; 127 rd.record_type = TEST_RECORD_TYPE;
128 rd.data_size = TEST_RECORD_DATALEN; 128 rd.data_size = TEST_RECORD_DATALEN;
129 rd.data = GNUNET_malloc (TEST_RECORD_DATALEN); 129 rd.data = GNUNET_malloc(TEST_RECORD_DATALEN);
130 rd.flags = 0; 130 rd.flags = 0;
131 memset ((char *) rd.data, 'a', TEST_RECORD_DATALEN); 131 memset((char *)rd.data, 'a', TEST_RECORD_DATALEN);
132 132
133 nsh = GNUNET_NAMESTORE_connect (cfg); 133 nsh = GNUNET_NAMESTORE_connect(cfg);
134 GNUNET_break (NULL != nsh); 134 GNUNET_break(NULL != nsh);
135 nsqe = GNUNET_NAMESTORE_records_store (nsh, 135 nsqe = GNUNET_NAMESTORE_records_store(nsh,
136 privkey, 136 privkey,
137 name, 137 name,
138 1, 138 1,
139 &rd, 139 &rd,
140 &put_cont, 140 &put_cont,
141 (void *) name); 141 (void *)name);
142 if (NULL == nsqe) 142 if (NULL == nsqe)
143 { 143 {
144 GNUNET_log (GNUNET_ERROR_TYPE_ERROR, 144 GNUNET_log(GNUNET_ERROR_TYPE_ERROR,
145 _("Namestore cannot store no block\n")); 145 _("Namestore cannot store no block\n"));
146 } 146 }
147 GNUNET_free ((void *)rd.data); 147 GNUNET_free((void *)rd.data);
148} 148}
149 149
150 150
@@ -152,24 +152,24 @@ run (void *cls,
152 152
153 153
154int 154int
155main (int argc, char *argv[]) 155main(int argc, char *argv[])
156{ 156{
157 const char *plugin_name; 157 const char *plugin_name;
158 char *cfg_name; 158 char *cfg_name;
159 159
160 SETUP_CFG (plugin_name, cfg_name); 160 SETUP_CFG(plugin_name, cfg_name);
161 res = 1; 161 res = 1;
162 if (0 != 162 if (0 !=
163 GNUNET_TESTING_peer_run ("test-namestore-api", 163 GNUNET_TESTING_peer_run("test-namestore-api",
164 cfg_name, 164 cfg_name,
165 &run, 165 &run,
166 NULL)) 166 NULL))
167 { 167 {
168 res = 1; 168 res = 1;
169 } 169 }
170 GNUNET_DISK_purge_cfg_dir (cfg_name, 170 GNUNET_DISK_purge_cfg_dir(cfg_name,
171 "GNUNET_TEST_HOME"); 171 "GNUNET_TEST_HOME");
172 GNUNET_free (cfg_name); 172 GNUNET_free(cfg_name);
173 return res; 173 return res;
174} 174}
175 175