diff options
author | Christian Grothoff <christian@grothoff.org> | 2015-10-26 00:01:25 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2015-10-26 00:01:25 +0000 |
commit | 0cd7408a37d1daefc6394027247b10d0efaae1a3 (patch) | |
tree | a8e8381050972d5b512d06ab220b600b74c8fdc4 | |
parent | 7c55f94e78c72d3b78a5c6007e3658ae30e1f64b (diff) | |
download | gnunet-0cd7408a37d1daefc6394027247b10d0efaae1a3.tar.gz gnunet-0cd7408a37d1daefc6394027247b10d0efaae1a3.zip |
-doxygen, simplify
-rw-r--r-- | src/fs/gnunet-service-fs_cp.c | 57 | ||||
-rw-r--r-- | src/fs/gnunet-service-fs_lc.c | 10 |
2 files changed, 40 insertions, 27 deletions
diff --git a/src/fs/gnunet-service-fs_cp.c b/src/fs/gnunet-service-fs_cp.c index 1d52f28f9..363a372cf 100644 --- a/src/fs/gnunet-service-fs_cp.c +++ b/src/fs/gnunet-service-fs_cp.c | |||
@@ -171,12 +171,12 @@ struct PeerRequest | |||
171 | { | 171 | { |
172 | 172 | ||
173 | /** | 173 | /** |
174 | * Handle to generic request. | 174 | * Handle to generic request (generic: from peer or local client). |
175 | */ | 175 | */ |
176 | struct GSF_PendingRequest *pr; | 176 | struct GSF_PendingRequest *pr; |
177 | 177 | ||
178 | /** | 178 | /** |
179 | * Handle to specific peer. | 179 | * Which specific peer issued this request? |
180 | */ | 180 | */ |
181 | struct GSF_ConnectedPeer *cp; | 181 | struct GSF_ConnectedPeer *cp; |
182 | 182 | ||
@@ -644,7 +644,9 @@ GSF_peer_connect_handler_ (const struct GNUNET_PeerIdentity *peer, | |||
644 | cp->ppd.pid = GNUNET_PEER_intern (peer); | 644 | cp->ppd.pid = GNUNET_PEER_intern (peer); |
645 | cp->ppd.transmission_delay = GNUNET_LOAD_value_init (GNUNET_TIME_UNIT_ZERO); | 645 | cp->ppd.transmission_delay = GNUNET_LOAD_value_init (GNUNET_TIME_UNIT_ZERO); |
646 | cp->rc = | 646 | cp->rc = |
647 | GNUNET_ATS_reserve_bandwidth (GSF_ats, peer, DBLOCK_SIZE, | 647 | GNUNET_ATS_reserve_bandwidth (GSF_ats, |
648 | peer, | ||
649 | DBLOCK_SIZE, | ||
648 | &ats_reserve_callback, cp); | 650 | &ats_reserve_callback, cp); |
649 | cp->request_map = GNUNET_CONTAINER_multihashmap_create (128, | 651 | cp->request_map = GNUNET_CONTAINER_multihashmap_create (128, |
650 | GNUNET_YES); | 652 | GNUNET_YES); |
@@ -653,7 +655,8 @@ GSF_peer_connect_handler_ (const struct GNUNET_PeerIdentity *peer, | |||
653 | GSF_connected_peer_get_identity2_ (cp), | 655 | GSF_connected_peer_get_identity2_ (cp), |
654 | cp, | 656 | cp, |
655 | GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY)); | 657 | GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY)); |
656 | GNUNET_STATISTICS_set (GSF_stats, gettext_noop ("# peers connected"), | 658 | GNUNET_STATISTICS_set (GSF_stats, |
659 | gettext_noop ("# peers connected"), | ||
657 | GNUNET_CONTAINER_multipeermap_size (cp_map), | 660 | GNUNET_CONTAINER_multipeermap_size (cp_map), |
658 | GNUNET_NO); | 661 | GNUNET_NO); |
659 | cp->creation_cb = creation_cb; | 662 | cp->creation_cb = creation_cb; |
@@ -799,14 +802,14 @@ copy_reply (void *cls, | |||
799 | * Free resources associated with the given peer request. | 802 | * Free resources associated with the given peer request. |
800 | * | 803 | * |
801 | * @param peerreq request to free | 804 | * @param peerreq request to free |
802 | * @param query associated key for the request | ||
803 | */ | 805 | */ |
804 | static void | 806 | static void |
805 | free_pending_request (struct PeerRequest *peerreq, | 807 | free_pending_request (struct PeerRequest *peerreq) |
806 | const struct GNUNET_HashCode *query) | ||
807 | { | 808 | { |
808 | struct GSF_ConnectedPeer *cp = peerreq->cp; | 809 | struct GSF_ConnectedPeer *cp = peerreq->cp; |
810 | struct GSF_PendingRequestData *prd; | ||
809 | 811 | ||
812 | prd = GSF_pending_request_get_data_ (peerreq->pr); | ||
810 | if (NULL != peerreq->kill_task) | 813 | if (NULL != peerreq->kill_task) |
811 | { | 814 | { |
812 | GNUNET_SCHEDULER_cancel (peerreq->kill_task); | 815 | GNUNET_SCHEDULER_cancel (peerreq->kill_task); |
@@ -818,7 +821,7 @@ free_pending_request (struct PeerRequest *peerreq, | |||
818 | GNUNET_NO); | 821 | GNUNET_NO); |
819 | GNUNET_break (GNUNET_YES == | 822 | GNUNET_break (GNUNET_YES == |
820 | GNUNET_CONTAINER_multihashmap_remove (cp->request_map, | 823 | GNUNET_CONTAINER_multihashmap_remove (cp->request_map, |
821 | query, | 824 | &prd->query, |
822 | peerreq)); | 825 | peerreq)); |
823 | GNUNET_free (peerreq); | 826 | GNUNET_free (peerreq); |
824 | } | 827 | } |
@@ -839,11 +842,10 @@ cancel_pending_request (void *cls, | |||
839 | { | 842 | { |
840 | struct PeerRequest *peerreq = value; | 843 | struct PeerRequest *peerreq = value; |
841 | struct GSF_PendingRequest *pr = peerreq->pr; | 844 | struct GSF_PendingRequest *pr = peerreq->pr; |
842 | struct GSF_PendingRequestData *prd; | ||
843 | 845 | ||
844 | prd = GSF_pending_request_get_data_ (pr); | 846 | free_pending_request (peerreq); |
845 | GSF_pending_request_cancel_ (pr, GNUNET_NO); | 847 | GSF_pending_request_cancel_ (pr, |
846 | free_pending_request (peerreq, &prd->query); | 848 | GNUNET_NO); |
847 | return GNUNET_OK; | 849 | return GNUNET_OK; |
848 | } | 850 | } |
849 | 851 | ||
@@ -864,7 +866,9 @@ peer_request_destroy (void *cls, | |||
864 | 866 | ||
865 | peerreq->kill_task = NULL; | 867 | peerreq->kill_task = NULL; |
866 | prd = GSF_pending_request_get_data_ (pr); | 868 | prd = GSF_pending_request_get_data_ (pr); |
867 | cancel_pending_request (NULL, &prd->query, peerreq); | 869 | cancel_pending_request (NULL, |
870 | &prd->query, | ||
871 | peerreq); | ||
868 | } | 872 | } |
869 | 873 | ||
870 | 874 | ||
@@ -968,7 +972,7 @@ handle_p2p_reply (void *cls, | |||
968 | prd = GSF_pending_request_get_data_ (pr); | 972 | prd = GSF_pending_request_get_data_ (pr); |
969 | if (NULL == data) | 973 | if (NULL == data) |
970 | { | 974 | { |
971 | free_pending_request (peerreq, &prd->query); | 975 | free_pending_request (peerreq); |
972 | return; | 976 | return; |
973 | } | 977 | } |
974 | GNUNET_break (GNUNET_BLOCK_TYPE_ANY != type); | 978 | GNUNET_break (GNUNET_BLOCK_TYPE_ANY != type); |
@@ -1047,9 +1051,11 @@ handle_p2p_reply (void *cls, | |||
1047 | GNUNET_STATISTICS_update (GSF_stats, | 1051 | GNUNET_STATISTICS_update (GSF_stats, |
1048 | gettext_noop | 1052 | gettext_noop |
1049 | ("# P2P searches destroyed due to ultimate reply"), | 1053 | ("# P2P searches destroyed due to ultimate reply"), |
1050 | 1, GNUNET_NO); | 1054 | 1, |
1055 | GNUNET_NO); | ||
1051 | peerreq->kill_task = | 1056 | peerreq->kill_task = |
1052 | GNUNET_SCHEDULER_add_now (&peer_request_destroy, peerreq); | 1057 | GNUNET_SCHEDULER_add_now (&peer_request_destroy, |
1058 | peerreq); | ||
1053 | } | 1059 | } |
1054 | } | 1060 | } |
1055 | 1061 | ||
@@ -1101,7 +1107,8 @@ change_peer_respect (struct GSF_ConnectedPeer *cp, int value) | |||
1101 | * @return effective priority | 1107 | * @return effective priority |
1102 | */ | 1108 | */ |
1103 | static int32_t | 1109 | static int32_t |
1104 | bound_priority (uint32_t prio_in, struct GSF_ConnectedPeer *cp) | 1110 | bound_priority (uint32_t prio_in, |
1111 | struct GSF_ConnectedPeer *cp) | ||
1105 | { | 1112 | { |
1106 | #define N ((double)128.0) | 1113 | #define N ((double)128.0) |
1107 | uint32_t ret; | 1114 | uint32_t ret; |
@@ -1254,9 +1261,9 @@ test_exist_cb (void *cls, | |||
1254 | } | 1261 | } |
1255 | /* existing request has lower TTL, drop old one! */ | 1262 | /* existing request has lower TTL, drop old one! */ |
1256 | tec->priority += prd->priority; | 1263 | tec->priority += prd->priority; |
1257 | GSF_pending_request_cancel_ (pr, GNUNET_YES); | 1264 | free_pending_request (peerreq); |
1258 | free_pending_request (peerreq, | 1265 | GSF_pending_request_cancel_ (pr, |
1259 | hc); | 1266 | GNUNET_YES); |
1260 | return GNUNET_NO; | 1267 | return GNUNET_NO; |
1261 | } | 1268 | } |
1262 | 1269 | ||
@@ -1467,8 +1474,7 @@ GSF_handle_p2p_query_ (const struct GNUNET_PeerIdentity *other, | |||
1467 | peerreq, | 1474 | peerreq, |
1468 | GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE)); | 1475 | GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE)); |
1469 | GNUNET_STATISTICS_update (GSF_stats, | 1476 | GNUNET_STATISTICS_update (GSF_stats, |
1470 | gettext_noop | 1477 | gettext_noop ("# P2P query messages received and processed"), |
1471 | ("# P2P query messages received and processed"), | ||
1472 | 1, | 1478 | 1, |
1473 | GNUNET_NO); | 1479 | GNUNET_NO); |
1474 | GNUNET_STATISTICS_update (GSF_stats, | 1480 | GNUNET_STATISTICS_update (GSF_stats, |
@@ -1747,8 +1753,11 @@ GSF_peer_disconnect_handler_ (void *cls, | |||
1747 | cp->request_map = NULL; | 1753 | cp->request_map = NULL; |
1748 | GSF_plan_notify_peer_disconnect_ (cp); | 1754 | GSF_plan_notify_peer_disconnect_ (cp); |
1749 | GNUNET_LOAD_value_free (cp->ppd.transmission_delay); | 1755 | GNUNET_LOAD_value_free (cp->ppd.transmission_delay); |
1750 | GNUNET_PEER_decrement_rcs (cp->ppd.last_p2p_replies, P2P_SUCCESS_LIST_SIZE); | 1756 | GNUNET_PEER_decrement_rcs (cp->ppd.last_p2p_replies, |
1751 | memset (cp->ppd.last_p2p_replies, 0, sizeof (cp->ppd.last_p2p_replies)); | 1757 | P2P_SUCCESS_LIST_SIZE); |
1758 | memset (cp->ppd.last_p2p_replies, | ||
1759 | 0, | ||
1760 | sizeof (cp->ppd.last_p2p_replies)); | ||
1752 | GSF_push_stop_ (cp); | 1761 | GSF_push_stop_ (cp); |
1753 | if (NULL != cp->cth) | 1762 | if (NULL != cp->cth) |
1754 | { | 1763 | { |
diff --git a/src/fs/gnunet-service-fs_lc.c b/src/fs/gnunet-service-fs_lc.c index 62e4274a9..b3d308bf4 100644 --- a/src/fs/gnunet-service-fs_lc.c +++ b/src/fs/gnunet-service-fs_lc.c | |||
@@ -195,10 +195,14 @@ client_request_destroy (void *cls, | |||
195 | 195 | ||
196 | cr->kill_task = NULL; | 196 | cr->kill_task = NULL; |
197 | lc = cr->lc; | 197 | lc = cr->lc; |
198 | GNUNET_CONTAINER_DLL_remove (lc->cr_head, lc->cr_tail, cr); | 198 | GNUNET_CONTAINER_DLL_remove (lc->cr_head, |
199 | GSF_pending_request_cancel_ (cr->pr, GNUNET_YES); | 199 | lc->cr_tail, |
200 | cr); | ||
201 | GSF_pending_request_cancel_ (cr->pr, | ||
202 | GNUNET_YES); | ||
200 | GNUNET_STATISTICS_update (GSF_stats, | 203 | GNUNET_STATISTICS_update (GSF_stats, |
201 | gettext_noop ("# client searches active"), -1, | 204 | gettext_noop ("# client searches active"), |
205 | -1, | ||
202 | GNUNET_NO); | 206 | GNUNET_NO); |
203 | GNUNET_free (cr); | 207 | GNUNET_free (cr); |
204 | } | 208 | } |