diff options
-rw-r--r-- | src/fs/gnunet-service-fs_cp.c | 20 | ||||
-rw-r--r-- | src/gns/gnunet-service-gns_resolver.c | 1 | ||||
-rw-r--r-- | src/include/gnunet_disk_lib.h | 17 | ||||
-rw-r--r-- | src/util/disk.c | 1 |
4 files changed, 21 insertions, 18 deletions
diff --git a/src/fs/gnunet-service-fs_cp.c b/src/fs/gnunet-service-fs_cp.c index 561d73c0d..f5b5213bc 100644 --- a/src/fs/gnunet-service-fs_cp.c +++ b/src/fs/gnunet-service-fs_cp.c | |||
@@ -1336,15 +1336,15 @@ peer_transmit_timeout (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
1336 | /** | 1336 | /** |
1337 | * Transmit a message to the given peer as soon as possible. | 1337 | * Transmit a message to the given peer as soon as possible. |
1338 | * If the peer disconnects before the transmission can happen, | 1338 | * If the peer disconnects before the transmission can happen, |
1339 | * the callback is invoked with a 'NULL' buffer. | 1339 | * the callback is invoked with a `NULL` @a buffer. |
1340 | * | 1340 | * |
1341 | * @param cp target peer | 1341 | * @param cp target peer |
1342 | * @param is_query is this a query (GNUNET_YES) or content (GNUNET_NO) or neither (GNUNET_SYSERR) | 1342 | * @param is_query is this a query (#GNUNET_YES) or content (#GNUNET_NO) or neither (#GNUNET_SYSERR) |
1343 | * @param priority how important is this request? | 1343 | * @param priority how important is this request? |
1344 | * @param timeout when does this request timeout (call gmc with error) | 1344 | * @param timeout when does this request timeout (call gmc with error) |
1345 | * @param size number of bytes we would like to send to the peer | 1345 | * @param size number of bytes we would like to send to the peer |
1346 | * @param gmc function to call to get the message | 1346 | * @param gmc function to call to get the message |
1347 | * @param gmc_cls closure for gmc | 1347 | * @param gmc_cls closure for @a gmc |
1348 | * @return handle to cancel request | 1348 | * @return handle to cancel request |
1349 | */ | 1349 | */ |
1350 | struct GSF_PeerTransmitHandle * | 1350 | struct GSF_PeerTransmitHandle * |
@@ -1573,10 +1573,10 @@ struct IterationContext | |||
1573 | /** | 1573 | /** |
1574 | * Function that calls the callback for each peer. | 1574 | * Function that calls the callback for each peer. |
1575 | * | 1575 | * |
1576 | * @param cls the 'struct IterationContext*' | 1576 | * @param cls the `struct IterationContext *` |
1577 | * @param key identity of the peer | 1577 | * @param key identity of the peer |
1578 | * @param value the 'struct GSF_ConnectedPeer*' | 1578 | * @param value the `struct GSF_ConnectedPeer *` |
1579 | * @return GNUNET_YES to continue iteration | 1579 | * @return #GNUNET_YES to continue iteration |
1580 | */ | 1580 | */ |
1581 | static int | 1581 | static int |
1582 | call_iterator (void *cls, const struct GNUNET_HashCode * key, void *value) | 1582 | call_iterator (void *cls, const struct GNUNET_HashCode * key, void *value) |
@@ -1593,7 +1593,7 @@ call_iterator (void *cls, const struct GNUNET_HashCode * key, void *value) | |||
1593 | * Iterate over all connected peers. | 1593 | * Iterate over all connected peers. |
1594 | * | 1594 | * |
1595 | * @param it function to call for each peer | 1595 | * @param it function to call for each peer |
1596 | * @param it_cls closure for it | 1596 | * @param it_cls closure for @a it |
1597 | */ | 1597 | */ |
1598 | void | 1598 | void |
1599 | GSF_iterate_connected_peers_ (GSF_ConnectedPeerIterator it, void *it_cls) | 1599 | GSF_iterate_connected_peers_ (GSF_ConnectedPeerIterator it, void *it_cls) |
@@ -1794,7 +1794,7 @@ GSF_connected_peer_init_ () | |||
1794 | GNUNET_CONFIGURATION_get_value_filename (GSF_cfg, "fs", | 1794 | GNUNET_CONFIGURATION_get_value_filename (GSF_cfg, "fs", |
1795 | "RESPECT", | 1795 | "RESPECT", |
1796 | &respectDirectory)); | 1796 | &respectDirectory)); |
1797 | GNUNET_DISK_directory_create (respectDirectory); | 1797 | GNUNET_break (GNUNET_OK == GNUNET_DISK_directory_create (respectDirectory)); |
1798 | GNUNET_SCHEDULER_add_with_priority (GNUNET_SCHEDULER_PRIORITY_HIGH, | 1798 | GNUNET_SCHEDULER_add_with_priority (GNUNET_SCHEDULER_PRIORITY_HIGH, |
1799 | &cron_flush_respect, NULL); | 1799 | &cron_flush_respect, NULL); |
1800 | } | 1800 | } |
@@ -1806,7 +1806,7 @@ GSF_connected_peer_init_ () | |||
1806 | * @param cls closure, unused | 1806 | * @param cls closure, unused |
1807 | * @param key current key code | 1807 | * @param key current key code |
1808 | * @param value value in the hash map (peer entry) | 1808 | * @param value value in the hash map (peer entry) |
1809 | * @return GNUNET_YES (we should continue to iterate) | 1809 | * @return #GNUNET_YES (we should continue to iterate) |
1810 | */ | 1810 | */ |
1811 | static int | 1811 | static int |
1812 | clean_peer (void *cls, const struct GNUNET_HashCode * key, void *value) | 1812 | clean_peer (void *cls, const struct GNUNET_HashCode * key, void *value) |
@@ -1837,7 +1837,7 @@ GSF_connected_peer_done_ () | |||
1837 | * @param cls the 'struct GSF_LocalClient*' to look for | 1837 | * @param cls the 'struct GSF_LocalClient*' to look for |
1838 | * @param key current key code | 1838 | * @param key current key code |
1839 | * @param value value in the hash map (peer entry) | 1839 | * @param value value in the hash map (peer entry) |
1840 | * @return GNUNET_YES (we should continue to iterate) | 1840 | * @return #GNUNET_YES (we should continue to iterate) |
1841 | */ | 1841 | */ |
1842 | static int | 1842 | static int |
1843 | clean_local_client (void *cls, const struct GNUNET_HashCode * key, void *value) | 1843 | clean_local_client (void *cls, const struct GNUNET_HashCode * key, void *value) |
diff --git a/src/gns/gnunet-service-gns_resolver.c b/src/gns/gnunet-service-gns_resolver.c index 458e21b9d..676efafe5 100644 --- a/src/gns/gnunet-service-gns_resolver.c +++ b/src/gns/gnunet-service-gns_resolver.c | |||
@@ -1641,6 +1641,7 @@ handle_namestore_block_response (void *cls, | |||
1641 | { | 1641 | { |
1642 | /* fail longest-standing DHT request */ | 1642 | /* fail longest-standing DHT request */ |
1643 | rx = GNUNET_CONTAINER_heap_peek (dht_lookup_heap); | 1643 | rx = GNUNET_CONTAINER_heap_peek (dht_lookup_heap); |
1644 | GNUNET_assert (NULL != rx); | ||
1644 | rx->proc (rx->proc_cls, 0, NULL); | 1645 | rx->proc (rx->proc_cls, 0, NULL); |
1645 | GNS_resolver_lookup_cancel (rx); | 1646 | GNS_resolver_lookup_cancel (rx); |
1646 | } | 1647 | } |
diff --git a/src/include/gnunet_disk_lib.h b/src/include/gnunet_disk_lib.h index 12d3345c5..9f106db11 100644 --- a/src/include/gnunet_disk_lib.h +++ b/src/include/gnunet_disk_lib.h | |||
@@ -722,7 +722,7 @@ GNUNET_DISK_directory_test (const char *fil, int is_readable); | |||
722 | * caution. | 722 | * caution. |
723 | * | 723 | * |
724 | * @param filename the file to remove | 724 | * @param filename the file to remove |
725 | * @return GNUNET_OK on success, GNUNET_SYSERR on error | 725 | * @return #GNUNET_OK on success, #GNUNET_SYSERR on error |
726 | */ | 726 | */ |
727 | int | 727 | int |
728 | GNUNET_DISK_directory_remove (const char *filename); | 728 | GNUNET_DISK_directory_remove (const char *filename); |
@@ -732,7 +732,7 @@ GNUNET_DISK_directory_remove (const char *filename); | |||
732 | * Implementation of "mkdir -p" | 732 | * Implementation of "mkdir -p" |
733 | * | 733 | * |
734 | * @param dir the directory to create | 734 | * @param dir the directory to create |
735 | * @returns GNUNET_SYSERR on failure, GNUNET_OK otherwise | 735 | * @returns #GNUNET_SYSERR on failure, #GNUNET_OK otherwise |
736 | */ | 736 | */ |
737 | int | 737 | int |
738 | GNUNET_DISK_directory_create (const char *dir); | 738 | GNUNET_DISK_directory_create (const char *dir); |
@@ -744,8 +744,8 @@ GNUNET_DISK_directory_create (const char *dir); | |||
744 | * @param fh file handle | 744 | * @param fh file handle |
745 | * @param lockStart absolute position from where to lock | 745 | * @param lockStart absolute position from where to lock |
746 | * @param lockEnd absolute position until where to lock | 746 | * @param lockEnd absolute position until where to lock |
747 | * @param excl GNUNET_YES for an exclusive lock | 747 | * @param excl #GNUNET_YES for an exclusive lock |
748 | * @return GNUNET_OK on success, GNUNET_SYSERR on error | 748 | * @return #GNUNET_OK on success, #GNUNET_SYSERR on error |
749 | */ | 749 | */ |
750 | int | 750 | int |
751 | GNUNET_DISK_file_lock (struct GNUNET_DISK_FileHandle *fh, OFF_T lockStart, | 751 | GNUNET_DISK_file_lock (struct GNUNET_DISK_FileHandle *fh, OFF_T lockStart, |
@@ -753,11 +753,12 @@ GNUNET_DISK_file_lock (struct GNUNET_DISK_FileHandle *fh, OFF_T lockStart, | |||
753 | 753 | ||
754 | 754 | ||
755 | /** | 755 | /** |
756 | * Unlock a part of a file | 756 | * Unlock a part of a file. |
757 | * | ||
757 | * @param fh file handle | 758 | * @param fh file handle |
758 | * @param unlockStart absolute position from where to unlock | 759 | * @param unlockStart absolute position from where to unlock |
759 | * @param unlockEnd absolute position until where to unlock | 760 | * @param unlockEnd absolute position until where to unlock |
760 | * @return GNUNET_OK on success, GNUNET_SYSERR on error | 761 | * @return #GNUNET_OK on success, #GNUNET_SYSERR on error |
761 | */ | 762 | */ |
762 | int | 763 | int |
763 | GNUNET_DISK_file_unlock (struct GNUNET_DISK_FileHandle *fh, OFF_T unlockStart, | 764 | GNUNET_DISK_file_unlock (struct GNUNET_DISK_FileHandle *fh, OFF_T unlockStart, |
@@ -776,7 +777,7 @@ GNUNET_DISK_filename_canonicalize (char *fn); | |||
776 | * @brief Change owner of a file | 777 | * @brief Change owner of a file |
777 | * @param filename file to change | 778 | * @param filename file to change |
778 | * @param user new owner of the file | 779 | * @param user new owner of the file |
779 | * @return GNUNET_OK on success, GNUNET_SYSERR on failure | 780 | * @return #GNUNET_OK on success, #GNUNET_SYSERR on failure |
780 | */ | 781 | */ |
781 | int | 782 | int |
782 | GNUNET_DISK_file_change_owner (const char *filename, const char *user); | 783 | GNUNET_DISK_file_change_owner (const char *filename, const char *user); |
@@ -823,7 +824,7 @@ GNUNET_DISK_file_map (const struct GNUNET_DISK_FileHandle *h, | |||
823 | * Unmap a file | 824 | * Unmap a file |
824 | * | 825 | * |
825 | * @param h mapping handle | 826 | * @param h mapping handle |
826 | * @return GNUNET_OK on success, GNUNET_SYSERR otherwise | 827 | * @return #GNUNET_OK on success, #GNUNET_SYSERR otherwise |
827 | */ | 828 | */ |
828 | int | 829 | int |
829 | GNUNET_DISK_file_unmap (struct GNUNET_DISK_MapHandle *h); | 830 | GNUNET_DISK_file_unmap (struct GNUNET_DISK_MapHandle *h); |
diff --git a/src/util/disk.c b/src/util/disk.c index e815afb2b..066b0b99b 100644 --- a/src/util/disk.c +++ b/src/util/disk.c | |||
@@ -653,6 +653,7 @@ GNUNET_DISK_file_test (const char *fil) | |||
653 | 653 | ||
654 | /** | 654 | /** |
655 | * Implementation of "mkdir -p" | 655 | * Implementation of "mkdir -p" |
656 | * | ||
656 | * @param dir the directory to create | 657 | * @param dir the directory to create |
657 | * @returns GNUNET_OK on success, GNUNET_SYSERR on failure | 658 | * @returns GNUNET_OK on success, GNUNET_SYSERR on failure |
658 | */ | 659 | */ |