X-Git-Url: https://git.librecmc.org/?a=blobdiff_plain;f=src%2Ffs%2Ffs_list_indexed.c;h=d76fd3e78fe8c032240b543d056f8e95fe52e68d;hb=ed51bc86aad5044b88ce4fc3641cc920c8186863;hp=5850fd94ef633628d209bf916d25af09102270c5;hpb=38b29592cf2e8b816cab68579e07e2477153f739;p=oweals%2Fgnunet.git diff --git a/src/fs/fs_list_indexed.c b/src/fs/fs_list_indexed.c index 5850fd94e..d76fd3e78 100644 --- a/src/fs/fs_list_indexed.c +++ b/src/fs/fs_list_indexed.c @@ -1,6 +1,6 @@ /* This file is part of GNUnet. - (C) 2003, 2004, 2006, 2009 Christian Grothoff (and other contributing authors) + Copyright (C) 2003, 2004, 2006, 2009 Christian Grothoff (and other contributing authors) GNUnet is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published @@ -28,13 +28,13 @@ #include "gnunet_constants.h" #include "gnunet_fs_service.h" #include "gnunet_protocols.h" -#include "fs.h" +#include "fs_api.h" /** * Context for "GNUNET_FS_get_indexed_files". */ -struct GetIndexedContext +struct GNUNET_FS_GetIndexedContext { /** * Handle to global FS context. @@ -59,7 +59,7 @@ struct GetIndexedContext /** * Continuation to trigger at the end. */ - GNUNET_SCHEDULER_Task cont; + GNUNET_SCHEDULER_TaskCallback cont; /** * Closure for cont. @@ -72,81 +72,58 @@ struct GetIndexedContext * Function called on each response from the FS * service with information about indexed files. * - * @param cls closure (of type "struct GetIndexedContext*") + * @param cls closure (of type "struct GNUNET_FS_GetIndexedContext*") * @param msg message with indexing information */ static void -handle_index_info (void *cls, - const struct GNUNET_MessageHeader *msg) +handle_index_info (void *cls, const struct GNUNET_MessageHeader *msg) { - struct GetIndexedContext *gic = cls; + struct GNUNET_FS_GetIndexedContext *gic = cls; const struct IndexInfoMessage *iim; uint16_t msize; const char *filename; if (NULL == msg) - { - GNUNET_log (GNUNET_ERROR_TYPE_WARNING, - _("Failed to receive response for `%s' request from `%s' service.\n"), - "GET_INDEXED", - "fs"); - GNUNET_SCHEDULER_add_continuation (gic->h->sched, - gic->cont, - gic->cont_cls, - GNUNET_SCHEDULER_REASON_TIMEOUT); - GNUNET_CLIENT_disconnect (gic->client, GNUNET_NO); - GNUNET_free (gic); - return; - } + { + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + _ + ("Failed to receive response for `%s' request from `%s' service.\n"), + "GET_INDEXED", "fs"); + (void) gic->iterator (gic->iterator_cls, NULL, NULL); + GNUNET_FS_get_indexed_files_cancel (gic); + return; + } if (ntohs (msg->type) == GNUNET_MESSAGE_TYPE_FS_INDEX_LIST_END) - { - /* normal end-of-list */ - GNUNET_SCHEDULER_add_continuation (gic->h->sched, - gic->cont, - gic->cont_cls, - GNUNET_SCHEDULER_REASON_PREREQ_DONE); - GNUNET_CLIENT_disconnect (gic->client, GNUNET_NO); - GNUNET_free (gic); - return; - } + { + /* normal end-of-list */ + (void) gic->iterator (gic->iterator_cls, NULL, NULL); + GNUNET_FS_get_indexed_files_cancel (gic); + return; + } msize = ntohs (msg->size); - iim = (const struct IndexInfoMessage*) msg; - filename = (const char*) &iim[1]; - if ( (ntohs (msg->type) != GNUNET_MESSAGE_TYPE_FS_INDEX_LIST_ENTRY) || - (msize <= sizeof (struct IndexInfoMessage)) || - (filename[msize-sizeof (struct IndexInfoMessage) -1] != '\0') ) - { - /* bogus reply */ - GNUNET_log (GNUNET_ERROR_TYPE_WARNING, - _("Failed to receive valid response for `%s' request from `%s' service.\n"), - "GET_INDEXED", - "fs"); - GNUNET_SCHEDULER_add_continuation (gic->h->sched, - gic->cont, - gic->cont_cls, - GNUNET_SCHEDULER_REASON_TIMEOUT); - GNUNET_CLIENT_disconnect (gic->client, GNUNET_NO); - GNUNET_free (gic); - return; - } - if (GNUNET_OK != - gic->iterator (gic->iterator_cls, - filename, - &iim->file_id)) - { - GNUNET_SCHEDULER_add_continuation (gic->h->sched, - gic->cont, - gic->cont_cls, - GNUNET_SCHEDULER_REASON_PREREQ_DONE); - GNUNET_CLIENT_disconnect (gic->client, GNUNET_NO); - GNUNET_free (gic); - return; - } + iim = (const struct IndexInfoMessage *) msg; + filename = (const char *) &iim[1]; + if ((ntohs (msg->type) != GNUNET_MESSAGE_TYPE_FS_INDEX_LIST_ENTRY) || + (msize <= sizeof (struct IndexInfoMessage)) || + (filename[msize - sizeof (struct IndexInfoMessage) - 1] != '\0')) + { + /* bogus reply */ + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + _ + ("Failed to receive valid response for `%s' request from `%s' service.\n"), + "GET_INDEXED", "fs"); + (void) gic->iterator (gic->iterator_cls, NULL, NULL); + GNUNET_FS_get_indexed_files_cancel (gic); + return; + } + if (GNUNET_OK != gic->iterator (gic->iterator_cls, filename, &iim->file_id)) + { + GNUNET_FS_get_indexed_files_cancel (gic); + return; + } /* get more */ - GNUNET_CLIENT_receive (gic->client, - &handle_index_info, - gic, - GNUNET_CONSTANTS_SERVICE_TIMEOUT); + GNUNET_CLIENT_receive (gic->client, &handle_index_info, gic, + GNUNET_CONSTANTS_SERVICE_TIMEOUT); } @@ -156,53 +133,52 @@ handle_index_info (void *cls, * @param h handle to the file sharing subsystem * @param iterator function to call on each indexed file * @param iterator_cls closure for iterator - * @param cont continuation to call when done; - * reason should be "TIMEOUT" (on - * error) or "PREREQ_DONE" (on success) - * @param cont_cls closure for cont + * @return NULL on error ('iter' is not called) */ -void +struct GNUNET_FS_GetIndexedContext * GNUNET_FS_get_indexed_files (struct GNUNET_FS_Handle *h, - GNUNET_FS_IndexedFileProcessor iterator, - void *iterator_cls, - GNUNET_SCHEDULER_Task cont, - void *cont_cls) + GNUNET_FS_IndexedFileProcessor iterator, + void *iterator_cls) { struct GNUNET_CLIENT_Connection *client; - struct GetIndexedContext *gic; + struct GNUNET_FS_GetIndexedContext *gic; struct GNUNET_MessageHeader msg; - client = GNUNET_CLIENT_connect (h->sched, - "fs", - h->cfg); + client = GNUNET_CLIENT_connect ("fs", h->cfg); if (NULL == client) - { - GNUNET_log (GNUNET_ERROR_TYPE_WARNING, - _("Failed to not connect to `%s' service.\n"), - "fs"); - GNUNET_SCHEDULER_add_continuation (h->sched, - cont, - cont_cls, - GNUNET_SCHEDULER_REASON_TIMEOUT); - return; - } - - gic = GNUNET_malloc (sizeof (struct GetIndexedContext)); + { + GNUNET_log (GNUNET_ERROR_TYPE_WARNING, + _("Failed to not connect to `%s' service.\n"), "fs"); + return NULL; + } + gic = GNUNET_new (struct GNUNET_FS_GetIndexedContext); gic->h = h; gic->client = client; gic->iterator = iterator; gic->iterator_cls = iterator_cls; - gic->cont = cont; - gic->cont_cls = cont_cls; msg.size = htons (sizeof (struct GNUNET_MessageHeader)); msg.type = htons (GNUNET_MESSAGE_TYPE_FS_INDEX_LIST_GET); GNUNET_assert (GNUNET_OK == - GNUNET_CLIENT_transmit_and_get_response (client, - &msg, - GNUNET_CONSTANTS_SERVICE_TIMEOUT, - GNUNET_YES, - &handle_index_info, - gic)); + GNUNET_CLIENT_transmit_and_get_response (client, &msg, + GNUNET_CONSTANTS_SERVICE_TIMEOUT, + GNUNET_YES, + &handle_index_info, + gic)); + return gic; } + +/** + * Cancel iteration over all indexed files. + * + * @param gic operation to cancel + */ +void +GNUNET_FS_get_indexed_files_cancel (struct GNUNET_FS_GetIndexedContext *gic) +{ + GNUNET_CLIENT_disconnect (gic->client); + GNUNET_free (gic); +} + + /* end of fs_list_indexed.c */