aboutsummaryrefslogtreecommitdiff
path: root/src/include/gnunet_datastore_service.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/include/gnunet_datastore_service.h')
-rw-r--r--src/include/gnunet_datastore_service.h118
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 */
74struct GNUNET_DATASTORE_Handle * 74struct GNUNET_DATASTORE_Handle *
75GNUNET_DATASTORE_connect (const struct GNUNET_CONFIGURATION_Handle *cfg); 75GNUNET_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 */
85void 85void
86GNUNET_DATASTORE_disconnect (struct GNUNET_DATASTORE_Handle *h, 86GNUNET_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 */
125struct GNUNET_DATASTORE_QueueEntry * 125struct GNUNET_DATASTORE_QueueEntry *
126GNUNET_DATASTORE_reserve (struct GNUNET_DATASTORE_Handle *h, 126GNUNET_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 */
158struct GNUNET_DATASTORE_QueueEntry * 158struct GNUNET_DATASTORE_QueueEntry *
159GNUNET_DATASTORE_put (struct GNUNET_DATASTORE_Handle *h, 159GNUNET_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 */
195struct GNUNET_DATASTORE_QueueEntry * 195struct GNUNET_DATASTORE_QueueEntry *
196GNUNET_DATASTORE_release_reserve (struct GNUNET_DATASTORE_Handle *h, 196GNUNET_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 */
222struct GNUNET_DATASTORE_QueueEntry * 222struct GNUNET_DATASTORE_QueueEntry *
223GNUNET_DATASTORE_remove (struct GNUNET_DATASTORE_Handle *h, 223GNUNET_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 */
279struct GNUNET_DATASTORE_QueueEntry * 279struct GNUNET_DATASTORE_QueueEntry *
280GNUNET_DATASTORE_get_key (struct GNUNET_DATASTORE_Handle *h, 280GNUNET_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 */
307struct GNUNET_DATASTORE_QueueEntry * 307struct GNUNET_DATASTORE_QueueEntry *
308GNUNET_DATASTORE_get_zero_anonymity (struct GNUNET_DATASTORE_Handle *h, 308GNUNET_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 */
335struct GNUNET_DATASTORE_QueueEntry * 335struct GNUNET_DATASTORE_QueueEntry *
336GNUNET_DATASTORE_get_for_replication (struct GNUNET_DATASTORE_Handle *h, 336GNUNET_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 */
350void 350void
351GNUNET_DATASTORE_cancel (struct GNUNET_DATASTORE_QueueEntry *qe); 351GNUNET_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 */