diff options
Diffstat (limited to 'src/namestore/test_namestore_api_store.c')
-rw-r--r-- | src/namestore/test_namestore_api_store.c | 132 |
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 | ||
38 | static struct GNUNET_NAMESTORE_Handle *nsh; | 38 | static struct GNUNET_NAMESTORE_Handle *nsh; |
@@ -49,19 +49,19 @@ static struct GNUNET_NAMESTORE_QueueEntry *nsqe; | |||
49 | 49 | ||
50 | 50 | ||
51 | static void | 51 | static void |
52 | cleanup () | 52 | cleanup() |
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 | */ |
73 | static void | 73 | static void |
74 | endbadly (void *cls) | 74 | endbadly(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 | ||
86 | static void | 86 | static void |
87 | end (void *cls) | 87 | end(void *cls) |
88 | { | 88 | { |
89 | cleanup (); | 89 | cleanup(); |
90 | res = 0; | 90 | res = 0; |
91 | } | 91 | } |
92 | 92 | ||
93 | 93 | ||
94 | static void | 94 | static void |
95 | put_cont (void *cls, int32_t success, const char *emsg) | 95 | put_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 | ||
111 | static void | 111 | static void |
112 | run (void *cls, | 112 | run(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 | ||
154 | int | 154 | int |
155 | main (int argc, char *argv[]) | 155 | main(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 | ||