aboutsummaryrefslogtreecommitdiff
path: root/src/fs/gnunet-service-fs_pr.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/fs/gnunet-service-fs_pr.h')
-rw-r--r--src/fs/gnunet-service-fs_pr.h38
1 files changed, 14 insertions, 24 deletions
diff --git a/src/fs/gnunet-service-fs_pr.h b/src/fs/gnunet-service-fs_pr.h
index 2f89f6e73..f2e7bcf62 100644
--- a/src/fs/gnunet-service-fs_pr.h
+++ b/src/fs/gnunet-service-fs_pr.h
@@ -238,10 +238,9 @@ struct GSF_PendingRequest *GSF_pending_request_create_ (enum
238 * @param replies_seen hash codes of replies that we've seen 238 * @param replies_seen hash codes of replies that we've seen
239 * @param replies_seen_count size of the replies_seen array 239 * @param replies_seen_count size of the replies_seen array
240 */ 240 */
241void 241void GSF_pending_request_update_ (struct GSF_PendingRequest *pr,
242GSF_pending_request_update_ (struct GSF_PendingRequest *pr, 242 const GNUNET_HashCode * replies_seen,
243 const GNUNET_HashCode * replies_seen, 243 unsigned int replies_seen_count);
244 unsigned int replies_seen_count);
245 244
246 245
247/** 246/**
@@ -264,9 +263,8 @@ struct GSF_PendingRequestData *GSF_pending_request_get_data_ (struct
264 * @param pra another pending request 263 * @param pra another pending request
265 * @return GNUNET_OK if the requests are compatible 264 * @return GNUNET_OK if the requests are compatible
266 */ 265 */
267int 266int GSF_pending_request_is_compatible_ (struct GSF_PendingRequest *pra,
268GSF_pending_request_is_compatible_ (struct GSF_PendingRequest *pra, 267 struct GSF_PendingRequest *prb);
269 struct GSF_PendingRequest *prb);
270 268
271 269
272/** 270/**
@@ -278,15 +276,9 @@ GSF_pending_request_is_compatible_ (struct GSF_PendingRequest *pra,
278 * @param buf where to copy the message (can be NULL) 276 * @param buf where to copy the message (can be NULL)
279 * @return number of bytes needed (if buf_size too small) or used 277 * @return number of bytes needed (if buf_size too small) or used
280 */ 278 */
281size_t 279size_t GSF_pending_request_get_message_ (struct GSF_PendingRequest
282 280 *pr, size_t buf_size,
283 281 void *buf);
284
285
286
287
288GSF_pending_request_get_message_ (struct GSF_PendingRequest *pr,
289 size_t buf_size, void *buf);
290 282
291 283
292/** 284/**
@@ -295,8 +287,8 @@ GSF_pending_request_get_message_ (struct GSF_PendingRequest *pr,
295 * @param pr request to cancel 287 * @param pr request to cancel
296 * @param full_cleanup fully purge the request 288 * @param full_cleanup fully purge the request
297 */ 289 */
298void 290void GSF_pending_request_cancel_ (struct GSF_PendingRequest *pr,
299GSF_pending_request_cancel_ (struct GSF_PendingRequest *pr, int full_cleanup); 291 int full_cleanup);
300 292
301 293
302/** 294/**
@@ -335,9 +327,8 @@ void GSF_iterate_pending_requests_ (GSF_PendingRequestIterator it, void *cls);
335 * GNUNET_SYSERR if the message was malformed (close connection, 327 * GNUNET_SYSERR if the message was malformed (close connection,
336 * do not cache under any circumstances) 328 * do not cache under any circumstances)
337 */ 329 */
338int 330int GSF_handle_p2p_content_ (struct GSF_ConnectedPeer *cp,
339GSF_handle_p2p_content_ (struct GSF_ConnectedPeer *cp, 331 const struct GNUNET_MessageHeader *message);
340 const struct GNUNET_MessageHeader *message);
341 332
342 333
343/** 334/**
@@ -369,9 +360,8 @@ typedef void (*GSF_LocalLookupContinuation) (void *cls,
369 * @param cont function to call at the end 360 * @param cont function to call at the end
370 * @param cont_cls closure for cont 361 * @param cont_cls closure for cont
371 */ 362 */
372void 363void GSF_local_lookup_ (struct GSF_PendingRequest *pr,
373GSF_local_lookup_ (struct GSF_PendingRequest *pr, 364 GSF_LocalLookupContinuation cont, void *cont_cls);
374 GSF_LocalLookupContinuation cont, void *cont_cls);
375 365
376 366
377/** 367/**