X-Git-Url: https://git.librecmc.org/?a=blobdiff_plain;f=src%2Ftransport%2Fgnunet-service-transport_neighbours.h;h=5b37ccb6aacbfa3a6f484c7e1964f45dda9cbed1;hb=f181f6eaf8cdb1fdb47dc98cf171ad1be842b441;hp=c263c33d9b09257f26f7295194d0e56a8725e359;hpb=502af2167f7c218366666ca4944bd7cc54b5b19a;p=oweals%2Fgnunet.git diff --git a/src/transport/gnunet-service-transport_neighbours.h b/src/transport/gnunet-service-transport_neighbours.h index c263c33d9..5b37ccb6a 100644 --- a/src/transport/gnunet-service-transport_neighbours.h +++ b/src/transport/gnunet-service-transport_neighbours.h @@ -44,15 +44,15 @@ * @param disconnect_cb function to call if we disconnect from a peer */ void -GST_neighbours_start (void *cls, - GNUNET_TRANSPORT_NotifyConnect connect_cb, +GST_neighbours_start (void *cls, GNUNET_TRANSPORT_NotifyConnect connect_cb, GNUNET_TRANSPORT_NotifyDisconnect disconnect_cb); /** * Cleanup the neighbours subsystem. */ -void GST_neighbours_stop (void); +void +GST_neighbours_stop (void); /** @@ -60,16 +60,18 @@ void GST_neighbours_stop (void); * * @param target peer to try to connect to */ -void GST_neighbours_try_connect (const struct GNUNET_PeerIdentity *target); +void +GST_neighbours_try_connect (const struct GNUNET_PeerIdentity *target); /** * Test if we're connected to the given peer. - * + * * @param target peer to test * @return GNUNET_YES if we are connected, GNUNET_NO if not */ -int GST_neighbours_test_connected (const struct GNUNET_PeerIdentity *target); +int +GST_neighbours_test_connected (const struct GNUNET_PeerIdentity *target); /** @@ -92,10 +94,8 @@ typedef void (*GST_NeighbourSendContinuation) (void *cls, int success); * @param cont_cls closure for 'cont' */ void -GST_neighbours_send (const struct GNUNET_PeerIdentity *target, - const void *msg, - size_t msg_size, - struct GNUNET_TIME_Relative timeout, +GST_neighbours_send (const struct GNUNET_PeerIdentity *target, const void *msg, + size_t msg_size, struct GNUNET_TIME_Relative timeout, GST_NeighbourSendContinuation cont, void *cont_cls); @@ -121,14 +121,28 @@ GST_neighbours_calculate_receive_delay (const struct GNUNET_PeerIdentity * * @param neighbour neighbour to keep alive */ -void GST_neighbours_keepalive (const struct GNUNET_PeerIdentity *neighbour); +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. * * @param neighbour identity of peer to change qutoa for - * @param quota new quota + * @param quota new quota */ void GST_neighbours_set_incoming_quota (const struct GNUNET_PeerIdentity *neighbour, @@ -140,7 +154,8 @@ GST_neighbours_set_incoming_quota (const struct GNUNET_PeerIdentity *neighbour, * * @param target peer to disconnect from */ -void GST_neighbours_force_disconnect (const struct GNUNET_PeerIdentity *target); +void +GST_neighbours_force_disconnect (const struct GNUNET_PeerIdentity *target); /** @@ -149,23 +164,26 @@ void GST_neighbours_force_disconnect (const struct GNUNET_PeerIdentity *target); * @param cls closure * @param neighbour identity of the neighbour * @param ats performance data - * @param ats_count number of entries in ats (excluding 0-termination) + * @param ats_count number of entries in ats (including 0-termination) + * @param address the address (or NULL) */ typedef void (*GST_NeighbourIterator) (void *cls, const struct GNUNET_PeerIdentity * neighbour, - const struct - GNUNET_TRANSPORT_ATS_Information * ats, - uint32_t ats_count); + const struct GNUNET_ATS_Information * + ats, uint32_t ats_count, + const struct GNUNET_HELLO_Address * + address); /** * Iterate over all connected neighbours. * - * @param cb function to call + * @param cb function to call * @param cb_cls closure for cb */ -void GST_neighbours_iterate (GST_NeighbourIterator cb, void *cb_cls); +void +GST_neighbours_iterate (GST_NeighbourIterator cb, void *cb_cls); /** @@ -184,22 +202,111 @@ GST_neighbours_session_terminated (const struct GNUNET_PeerIdentity *peer, * use the given address. * * @param peer identity of the peer to switch the address for - * @param plugin_name name of transport that delivered the PONG * @param address address of the other peer, NULL if other peer * connected to us - * @param address_len number of bytes in address + * @param session session to use (or NULL) + * @param ats performance data + * @param ats_count number of entries in ats + * @param bandwidth_in inbound quota to be used when connection is up + * @param bandwidth_out outbound quota to be used when connection is up + * @return GNUNET_YES if we are currently connected, GNUNET_NO if the + * connection is not up (yet) + */ +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, + struct GNUNET_BANDWIDTH_Value32NBO + bandwidth_in, + struct GNUNET_BANDWIDTH_Value32NBO + bandwidth_out); + + +/** + * We received a 'SESSION_CONNECT' message from the other peer. + * Consider switching to it. + * + * @param message possibly a 'struct SessionConnectMessage' (check format) + * @param peer identity of the peer to switch the address for + * @param address address of the other peer, NULL if other peer + * connected to us * @param session session to use (or NULL) * @param ats performance data * @param ats_count number of entries in ats (excluding 0-termination) + */ +void +GST_neighbours_handle_connect (const struct GNUNET_MessageHeader *message, + const struct GNUNET_PeerIdentity *peer, + const struct GNUNET_HELLO_Address *address, + struct Session *session, + const struct GNUNET_ATS_Information *ats, + uint32_t ats_count); + + +/** + * We received a 'SESSION_CONNECT_ACK' message from the other peer. + * Consider switching to it. + * + * @param message possibly a 'struct SessionConnectMessage' (check format) + * @param peer identity of the peer to switch the address for + * @param address address of the other peer, NULL if other peer + * connected to us + * @param session session to use (or NULL) + * @param ats performance data + * @param ats_count number of entries in ats + */ +void +GST_neighbours_handle_connect_ack (const struct GNUNET_MessageHeader *message, + const struct GNUNET_PeerIdentity *peer, + const struct GNUNET_HELLO_Address *address, + struct Session *session, + const struct GNUNET_ATS_Information *ats, + uint32_t ats_count); + +void +GST_neighbours_handle_ack (const struct GNUNET_MessageHeader *message, + const struct GNUNET_PeerIdentity *peer, + const struct GNUNET_HELLO_Address *address, + struct Session *session, + const struct GNUNET_ATS_Information *ats, + uint32_t ats_count); + + +/** + * Obtain current latency information for the given neighbour. + * + * @param peer + * @return observed latency of the address, FOREVER if the address was + * never successfully validated + */ +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. + * + * @param peer sender of the message + * @param msg the disconnect message */ void -GST_neighbours_switch_to_address (const struct GNUNET_PeerIdentity *peer, - const char *plugin_name, - const void *address, - size_t address_len, - struct Session *session, - const struct GNUNET_TRANSPORT_ATS_Information - *ats, uint32_t ats_count); +GST_neighbours_handle_disconnect_message (const struct GNUNET_PeerIdentity + *peer, + const struct GNUNET_MessageHeader + *msg); #endif