X-Git-Url: https://git.librecmc.org/?a=blobdiff_plain;f=src%2Ftransport%2Fgnunet-service-transport_neighbours.h;h=5b37ccb6aacbfa3a6f484c7e1964f45dda9cbed1;hb=f181f6eaf8cdb1fdb47dc98cf171ad1be842b441;hp=72ced636d3b6a2edd4f5ed2105ba02fb94cc11bc;hpb=a983a0267109b1b6a8e16e476e2f2956a8771b94;p=oweals%2Fgnunet.git diff --git a/src/transport/gnunet-service-transport_neighbours.h b/src/transport/gnunet-service-transport_neighbours.h index 72ced636d..5b37ccb6a 100644 --- a/src/transport/gnunet-service-transport_neighbours.h +++ b/src/transport/gnunet-service-transport_neighbours.h @@ -124,6 +124,19 @@ GST_neighbours_calculate_receive_delay (const struct GNUNET_PeerIdentity void GST_neighbours_keepalive (const struct GNUNET_PeerIdentity *neighbour); +/** + * We received a KEEP_ALIVE_RESPONSE message and use this to calculate latency + * to this peer + * + * @param neighbour neighbour to keep alive + * @param ats performance data + * @param ats_count number of entries in ats + */ +void +GST_neighbours_keepalive_response (const struct GNUNET_PeerIdentity *neighbour, + const struct GNUNET_ATS_Information *ats, + uint32_t ats_count); + /** * Change the incoming quota for the given peer. @@ -159,7 +172,8 @@ typedef void (*GST_NeighbourIterator) (void *cls, neighbour, const struct GNUNET_ATS_Information * ats, uint32_t ats_count, - const struct GNUNET_HELLO_Address *address); + const struct GNUNET_HELLO_Address * + address); /** @@ -200,10 +214,10 @@ GST_neighbours_session_terminated (const struct GNUNET_PeerIdentity *peer, */ int GST_neighbours_switch_to_address_3way (const struct GNUNET_PeerIdentity *peer, - const struct GNUNET_HELLO_Address *address, - struct Session *session, - const struct GNUNET_ATS_Information *ats, - uint32_t ats_count, + const struct GNUNET_HELLO_Address + *address, struct Session *session, + const struct GNUNET_ATS_Information *ats, + uint32_t ats_count, struct GNUNET_BANDWIDTH_Value32NBO bandwidth_in, struct GNUNET_BANDWIDTH_Value32NBO @@ -246,7 +260,7 @@ GST_neighbours_handle_connect (const struct GNUNET_MessageHeader *message, void GST_neighbours_handle_connect_ack (const struct GNUNET_MessageHeader *message, const struct GNUNET_PeerIdentity *peer, - const struct GNUNET_HELLO_Address *address, + const struct GNUNET_HELLO_Address *address, struct Session *session, const struct GNUNET_ATS_Information *ats, uint32_t ats_count); @@ -255,7 +269,7 @@ void GST_neighbours_handle_ack (const struct GNUNET_MessageHeader *message, const struct GNUNET_PeerIdentity *peer, const struct GNUNET_HELLO_Address *address, - struct Session *session, + struct Session *session, const struct GNUNET_ATS_Information *ats, uint32_t ats_count); @@ -263,7 +277,7 @@ GST_neighbours_handle_ack (const struct GNUNET_MessageHeader *message, /** * Obtain current latency information for the given neighbour. * - * @param peer + * @param peer * @return observed latency of the address, FOREVER if the address was * never successfully validated */ @@ -271,6 +285,16 @@ struct GNUNET_TIME_Relative GST_neighbour_get_latency (const struct GNUNET_PeerIdentity *peer); +/** + * Obtain current address information for the given neighbour. + * + * @param peer + * @return address currently used + */ +struct GNUNET_HELLO_Address * +GST_neighbour_get_current_address (const struct GNUNET_PeerIdentity *peer); + + /** * We received a disconnect message from the given peer, * validate and process.