aboutsummaryrefslogtreecommitdiff
path: root/src/dv/gnunet-service-dv.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/dv/gnunet-service-dv.c')
-rw-r--r--src/dv/gnunet-service-dv.c40
1 files changed, 19 insertions, 21 deletions
diff --git a/src/dv/gnunet-service-dv.c b/src/dv/gnunet-service-dv.c
index 876d056ac..6699fef11 100644
--- a/src/dv/gnunet-service-dv.c
+++ b/src/dv/gnunet-service-dv.c
@@ -761,8 +761,8 @@ transmit_to_plugin (void *cls, size_t size, void *buf)
761 if (plugin_pending_head != NULL) 761 if (plugin_pending_head != NULL)
762 plugin_transmit_handle = 762 plugin_transmit_handle =
763 GNUNET_SERVER_notify_transmit_ready (client_handle, 763 GNUNET_SERVER_notify_transmit_ready (client_handle,
764 ntohs (plugin_pending_head-> 764 ntohs (plugin_pending_head->msg->
765 msg->size), 765 size),
766 GNUNET_TIME_UNIT_FOREVER_REL, 766 GNUNET_TIME_UNIT_FOREVER_REL,
767 &transmit_to_plugin, NULL); 767 &transmit_to_plugin, NULL);
768 768
@@ -858,7 +858,8 @@ send_to_plugin (const struct GNUNET_PeerIdentity *sender,
858} 858}
859 859
860/* Declare here so retry_core_send is aware of it */ 860/* Declare here so retry_core_send is aware of it */
861size_t core_transmit_notify (void *cls, size_t size, void *buf); 861size_t
862core_transmit_notify (void *cls, size_t size, void *buf);
862 863
863/** 864/**
864 * Try to send another message from our core sending list 865 * Try to send another message from our core sending list
@@ -999,9 +1000,9 @@ send_message_via (const struct GNUNET_PeerIdentity *sender,
999 find_context.via = recipient; 1000 find_context.via = recipient;
1000 find_context.tid = 0; 1001 find_context.tid = 0;
1001 GNUNET_CONTAINER_multihashmap_get_multiple (extended_neighbors, 1002 GNUNET_CONTAINER_multihashmap_get_multiple (extended_neighbors,
1002 &send_context->distant_peer-> 1003 &send_context->
1003 hashPubKey, &find_specific_id, 1004 distant_peer->hashPubKey,
1004 &find_context); 1005 &find_specific_id, &find_context);
1005 1006
1006 if (find_context.tid == 0) 1007 if (find_context.tid == 0)
1007 { 1008 {
@@ -2071,19 +2072,16 @@ handle_dv_send_message (void *cls, struct GNUNET_SERVER_Client *client,
2071} 2072}
2072 2073
2073/** Forward declarations **/ 2074/** Forward declarations **/
2074static int handle_dv_gossip_message (void *cls, 2075static int
2075 const struct GNUNET_PeerIdentity *peer, 2076handle_dv_gossip_message (void *cls, const struct GNUNET_PeerIdentity *peer,
2076 const struct GNUNET_MessageHeader *message, 2077 const struct GNUNET_MessageHeader *message,
2077 const struct 2078 const struct GNUNET_TRANSPORT_ATS_Information *atsi);
2078 GNUNET_TRANSPORT_ATS_Information *atsi); 2079
2079 2080static int
2080static int handle_dv_disconnect_message (void *cls, 2081handle_dv_disconnect_message (void *cls, const struct GNUNET_PeerIdentity *peer,
2081 const struct GNUNET_PeerIdentity *peer, 2082 const struct GNUNET_MessageHeader *message,
2082 const struct GNUNET_MessageHeader 2083 const struct GNUNET_TRANSPORT_ATS_Information
2083 *message, 2084 *atsi);
2084 const struct
2085 GNUNET_TRANSPORT_ATS_Information
2086 *atsi);
2087/** End forward declarations **/ 2085/** End forward declarations **/
2088 2086
2089 2087
@@ -2658,8 +2656,8 @@ addUpdateNeighbor (const struct GNUNET_PeerIdentity *peer,
2658 atsi[0].value = htonl (referrer->pending_messages[i].distance); 2656 atsi[0].value = htonl (referrer->pending_messages[i].distance);
2659 atsi[1].type = htonl (GNUNET_TRANSPORT_ATS_QUALITY_NET_DELAY); 2657 atsi[1].type = htonl (GNUNET_TRANSPORT_ATS_QUALITY_NET_DELAY);
2660 atsi[1].value = 2658 atsi[1].value =
2661 htonl ((uint32_t) referrer->pending_messages[i].latency. 2659 htonl ((uint32_t) referrer->pending_messages[i].
2662 rel_value); 2660 latency.rel_value);
2663 atsi[2].type = htonl (GNUNET_TRANSPORT_ATS_ARRAY_TERMINATOR); 2661 atsi[2].type = htonl (GNUNET_TRANSPORT_ATS_ARRAY_TERMINATOR);
2664 atsi[2].value = htonl (0); 2662 atsi[2].value = htonl (0);
2665 handle_dv_data_message (NULL, &referrer->pending_messages[i].sender, 2663 handle_dv_data_message (NULL, &referrer->pending_messages[i].sender,