diff options
Diffstat (limited to 'src/include/gnunet_datastore_service.h')
-rw-r--r-- | src/include/gnunet_datastore_service.h | 118 |
1 files changed, 59 insertions, 59 deletions
diff --git a/src/include/gnunet_datastore_service.h b/src/include/gnunet_datastore_service.h index b5b9d4306..e4cd4a915 100644 --- a/src/include/gnunet_datastore_service.h +++ b/src/include/gnunet_datastore_service.h | |||
@@ -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 | /** | 21 | /** |
22 | * @author Christian Grothoff | 22 | * @author Christian Grothoff |
@@ -72,7 +72,7 @@ struct GNUNET_DATASTORE_Handle; | |||
72 | * @return handle to use to access the service | 72 | * @return handle to use to access the service |
73 | */ | 73 | */ |
74 | struct GNUNET_DATASTORE_Handle * | 74 | struct GNUNET_DATASTORE_Handle * |
75 | GNUNET_DATASTORE_connect (const struct GNUNET_CONFIGURATION_Handle *cfg); | 75 | GNUNET_DATASTORE_connect(const struct GNUNET_CONFIGURATION_Handle *cfg); |
76 | 76 | ||
77 | 77 | ||
78 | /** | 78 | /** |
@@ -83,8 +83,8 @@ GNUNET_DATASTORE_connect (const struct GNUNET_CONFIGURATION_Handle *cfg); | |||
83 | * @param drop set to #GNUNET_YES to delete all data in datastore (!) | 83 | * @param drop set to #GNUNET_YES to delete all data in datastore (!) |
84 | */ | 84 | */ |
85 | void | 85 | void |
86 | GNUNET_DATASTORE_disconnect (struct GNUNET_DATASTORE_Handle *h, | 86 | GNUNET_DATASTORE_disconnect(struct GNUNET_DATASTORE_Handle *h, |
87 | int drop); | 87 | int drop); |
88 | 88 | ||
89 | 89 | ||
90 | /** | 90 | /** |
@@ -123,11 +123,11 @@ typedef void | |||
123 | * (or rather, will already have been invoked) | 123 | * (or rather, will already have been invoked) |
124 | */ | 124 | */ |
125 | struct GNUNET_DATASTORE_QueueEntry * | 125 | struct GNUNET_DATASTORE_QueueEntry * |
126 | GNUNET_DATASTORE_reserve (struct GNUNET_DATASTORE_Handle *h, | 126 | GNUNET_DATASTORE_reserve(struct GNUNET_DATASTORE_Handle *h, |
127 | uint64_t amount, | 127 | uint64_t amount, |
128 | uint32_t entries, | 128 | uint32_t entries, |
129 | GNUNET_DATASTORE_ContinuationWithStatus cont, | 129 | GNUNET_DATASTORE_ContinuationWithStatus cont, |
130 | void *cont_cls); | 130 | void *cont_cls); |
131 | 131 | ||
132 | 132 | ||
133 | /** | 133 | /** |
@@ -156,20 +156,20 @@ GNUNET_DATASTORE_reserve (struct GNUNET_DATASTORE_Handle *h, | |||
156 | * (or rather, will already have been invoked) | 156 | * (or rather, will already have been invoked) |
157 | */ | 157 | */ |
158 | struct GNUNET_DATASTORE_QueueEntry * | 158 | struct GNUNET_DATASTORE_QueueEntry * |
159 | GNUNET_DATASTORE_put (struct GNUNET_DATASTORE_Handle *h, | 159 | GNUNET_DATASTORE_put(struct GNUNET_DATASTORE_Handle *h, |
160 | uint32_t rid, | 160 | uint32_t rid, |
161 | const struct GNUNET_HashCode *key, | 161 | const struct GNUNET_HashCode *key, |
162 | size_t size, | 162 | size_t size, |
163 | const void *data, | 163 | const void *data, |
164 | enum GNUNET_BLOCK_Type type, | 164 | enum GNUNET_BLOCK_Type type, |
165 | uint32_t priority, | 165 | uint32_t priority, |
166 | uint32_t anonymity, | 166 | uint32_t anonymity, |
167 | uint32_t replication, | 167 | uint32_t replication, |
168 | struct GNUNET_TIME_Absolute expiration, | 168 | struct GNUNET_TIME_Absolute expiration, |
169 | unsigned int queue_priority, | 169 | unsigned int queue_priority, |
170 | unsigned int max_queue_size, | 170 | unsigned int max_queue_size, |
171 | GNUNET_DATASTORE_ContinuationWithStatus cont, | 171 | GNUNET_DATASTORE_ContinuationWithStatus cont, |
172 | void *cont_cls); | 172 | void *cont_cls); |
173 | 173 | ||
174 | 174 | ||
175 | /** | 175 | /** |
@@ -193,11 +193,11 @@ GNUNET_DATASTORE_put (struct GNUNET_DATASTORE_Handle *h, | |||
193 | * (or rather, will already have been invoked) | 193 | * (or rather, will already have been invoked) |
194 | */ | 194 | */ |
195 | struct GNUNET_DATASTORE_QueueEntry * | 195 | struct GNUNET_DATASTORE_QueueEntry * |
196 | GNUNET_DATASTORE_release_reserve (struct GNUNET_DATASTORE_Handle *h, | 196 | GNUNET_DATASTORE_release_reserve(struct GNUNET_DATASTORE_Handle *h, |
197 | uint32_t rid, unsigned int queue_priority, | 197 | uint32_t rid, unsigned int queue_priority, |
198 | unsigned int max_queue_size, | 198 | unsigned int max_queue_size, |
199 | GNUNET_DATASTORE_ContinuationWithStatus cont, | 199 | GNUNET_DATASTORE_ContinuationWithStatus cont, |
200 | void *cont_cls); | 200 | void *cont_cls); |
201 | 201 | ||
202 | 202 | ||
203 | /** | 203 | /** |
@@ -220,14 +220,14 @@ GNUNET_DATASTORE_release_reserve (struct GNUNET_DATASTORE_Handle *h, | |||
220 | * (or rather, will already have been invoked) | 220 | * (or rather, will already have been invoked) |
221 | */ | 221 | */ |
222 | struct GNUNET_DATASTORE_QueueEntry * | 222 | struct GNUNET_DATASTORE_QueueEntry * |
223 | GNUNET_DATASTORE_remove (struct GNUNET_DATASTORE_Handle *h, | 223 | GNUNET_DATASTORE_remove(struct GNUNET_DATASTORE_Handle *h, |
224 | const struct GNUNET_HashCode *key, | 224 | const struct GNUNET_HashCode *key, |
225 | size_t size, | 225 | size_t size, |
226 | const void *data, | 226 | const void *data, |
227 | unsigned int queue_priority, | 227 | unsigned int queue_priority, |
228 | unsigned int max_queue_size, | 228 | unsigned int max_queue_size, |
229 | GNUNET_DATASTORE_ContinuationWithStatus cont, | 229 | GNUNET_DATASTORE_ContinuationWithStatus cont, |
230 | void *cont_cls); | 230 | void *cont_cls); |
231 | 231 | ||
232 | 232 | ||
233 | /** | 233 | /** |
@@ -277,15 +277,15 @@ typedef void | |||
277 | * cancel | 277 | * cancel |
278 | */ | 278 | */ |
279 | struct GNUNET_DATASTORE_QueueEntry * | 279 | struct GNUNET_DATASTORE_QueueEntry * |
280 | GNUNET_DATASTORE_get_key (struct GNUNET_DATASTORE_Handle *h, | 280 | GNUNET_DATASTORE_get_key(struct GNUNET_DATASTORE_Handle *h, |
281 | uint64_t next_uid, | 281 | uint64_t next_uid, |
282 | bool random, | 282 | bool random, |
283 | const struct GNUNET_HashCode *key, | 283 | const struct GNUNET_HashCode *key, |
284 | enum GNUNET_BLOCK_Type type, | 284 | enum GNUNET_BLOCK_Type type, |
285 | unsigned int queue_priority, | 285 | unsigned int queue_priority, |
286 | unsigned int max_queue_size, | 286 | unsigned int max_queue_size, |
287 | GNUNET_DATASTORE_DatumProcessor proc, | 287 | GNUNET_DATASTORE_DatumProcessor proc, |
288 | void *proc_cls); | 288 | void *proc_cls); |
289 | 289 | ||
290 | 290 | ||
291 | /** | 291 | /** |
@@ -305,13 +305,13 @@ GNUNET_DATASTORE_get_key (struct GNUNET_DATASTORE_Handle *h, | |||
305 | * cancel | 305 | * cancel |
306 | */ | 306 | */ |
307 | struct GNUNET_DATASTORE_QueueEntry * | 307 | struct GNUNET_DATASTORE_QueueEntry * |
308 | GNUNET_DATASTORE_get_zero_anonymity (struct GNUNET_DATASTORE_Handle *h, | 308 | GNUNET_DATASTORE_get_zero_anonymity(struct GNUNET_DATASTORE_Handle *h, |
309 | uint64_t next_uid, | 309 | uint64_t next_uid, |
310 | unsigned int queue_priority, | 310 | unsigned int queue_priority, |
311 | unsigned int max_queue_size, | 311 | unsigned int max_queue_size, |
312 | enum GNUNET_BLOCK_Type type, | 312 | enum GNUNET_BLOCK_Type type, |
313 | GNUNET_DATASTORE_DatumProcessor proc, | 313 | GNUNET_DATASTORE_DatumProcessor proc, |
314 | void *proc_cls); | 314 | void *proc_cls); |
315 | 315 | ||
316 | 316 | ||
317 | /** | 317 | /** |
@@ -333,11 +333,11 @@ GNUNET_DATASTORE_get_zero_anonymity (struct GNUNET_DATASTORE_Handle *h, | |||
333 | * cancel | 333 | * cancel |
334 | */ | 334 | */ |
335 | struct GNUNET_DATASTORE_QueueEntry * | 335 | struct GNUNET_DATASTORE_QueueEntry * |
336 | GNUNET_DATASTORE_get_for_replication (struct GNUNET_DATASTORE_Handle *h, | 336 | GNUNET_DATASTORE_get_for_replication(struct GNUNET_DATASTORE_Handle *h, |
337 | unsigned int queue_priority, | 337 | unsigned int queue_priority, |
338 | unsigned int max_queue_size, | 338 | unsigned int max_queue_size, |
339 | GNUNET_DATASTORE_DatumProcessor proc, | 339 | GNUNET_DATASTORE_DatumProcessor proc, |
340 | void *proc_cls); | 340 | void *proc_cls); |
341 | 341 | ||
342 | 342 | ||
343 | 343 | ||
@@ -348,7 +348,7 @@ GNUNET_DATASTORE_get_for_replication (struct GNUNET_DATASTORE_Handle *h, | |||
348 | * @param qe operation to cancel | 348 | * @param qe operation to cancel |
349 | */ | 349 | */ |
350 | void | 350 | void |
351 | GNUNET_DATASTORE_cancel (struct GNUNET_DATASTORE_QueueEntry *qe); | 351 | GNUNET_DATASTORE_cancel(struct GNUNET_DATASTORE_QueueEntry *qe); |
352 | 352 | ||
353 | 353 | ||
354 | #if 0 /* keep Emacsens' auto-indent happy */ | 354 | #if 0 /* keep Emacsens' auto-indent happy */ |