X-Git-Url: https://git.librecmc.org/?a=blobdiff_plain;f=src%2Ftransport%2Fgnunet-service-transport.h;h=2807afd793a634ac2fec619bc233a6d574ec922e;hb=5a7cef0202631204485cbcb1e36671e4321a936f;hp=5e3a250315c1d604570990bbab56f87edf9851f0;hpb=ea69f50952d863c6e7250bc92559a3dca27ce97b;p=oweals%2Fgnunet.git diff --git a/src/transport/gnunet-service-transport.h b/src/transport/gnunet-service-transport.h index 5e3a25031..2807afd79 100644 --- a/src/transport/gnunet-service-transport.h +++ b/src/transport/gnunet-service-transport.h @@ -1,6 +1,6 @@ /* This file is part of GNUnet. - (C) 2010,2011 Christian Grothoff (and other contributing authors) + Copyright (C) 2010,2011 GNUnet e.V. GNUnet is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published @@ -14,8 +14,8 @@ You should have received a copy of the GNU General Public License along with GNUnet; see the file COPYING. If not, write to the - Free Software Foundation, Inc., 59 Temple Place - Suite 330, - Boston, MA 02111-1307, USA. + Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, + Boston, MA 02110-1301, USA. */ /** @@ -26,9 +26,10 @@ #ifndef GNUNET_SERVICE_TRANSPORT_H #define GNUNET_SERVICE_TRANSPORT_H +#include "gnunet_util_lib.h" #include "gnunet_statistics_service.h" +#include "gnunet_ats_service.h" #include "gnunet_transport_service.h" -#include "gnunet_util_lib.h" #define VERBOSE_VALIDATION GNUNET_YES @@ -52,57 +53,177 @@ extern struct GNUNET_PeerIdentity GST_my_identity; */ extern struct GNUNET_PEERINFO_Handle *GST_peerinfo; -/** - * Our public key. - */ -extern struct GNUNET_CRYPTO_EccPublicKeyBinaryEncoded GST_my_public_key; - /** * Our private key. */ -extern struct GNUNET_CRYPTO_EccPrivateKey *GST_my_private_key; +extern struct GNUNET_CRYPTO_EddsaPrivateKey *GST_my_private_key; /** * ATS handle. */ extern struct GNUNET_ATS_SchedulingHandle *GST_ats; +/** + * ATS connectivity handle. + */ +extern struct GNUNET_ATS_ConnectivityHandle *GST_ats_connect; + +/** + * Interface scanner determines our LAN address range(s). + */ +extern struct GNUNET_ATS_InterfaceScanner *GST_is; + + +/** + * Function to call when a peer's address has changed + * + * @param cls closure + * @param peer peer this update is about, + * @param address address, NULL for disconnect notification + */ +typedef void +(*GNUNET_TRANSPORT_NeighbourChangeCallback) (void *cls, + const struct GNUNET_PeerIdentity *peer, + const struct GNUNET_HELLO_Address *address, + enum GNUNET_TRANSPORT_PeerState state, + struct GNUNET_TIME_Absolute state_timeout, + struct GNUNET_BANDWIDTH_Value32NBO bandwidth_in, + struct GNUNET_BANDWIDTH_Value32NBO bandwidth_out); + + +/** + * Continuation called from a blacklist test. + * + * @param cls closure + * @param peer identity of peer that was tested + * @param address address associated with the request + * @param session session associated with the request + * @param result #GNUNET_OK if the connection is allowed, + * #GNUNET_NO if not, + * #GNUNET_SYSERR if operation was aborted + */ +typedef void +(*GST_BlacklistTestContinuation) (void *cls, + const struct GNUNET_PeerIdentity *peer, + const struct GNUNET_HELLO_Address *address, + struct GNUNET_ATS_Session *session, + int result); + + +/** + * Add the given peer to the blacklist (for the given transport). + * + * @param peer peer to blacklist + * @param transport_name transport to blacklist for this peer, NULL for all + */ +void +GST_blacklist_add_peer (const struct GNUNET_PeerIdentity *peer, + const char *transport_name); + + +/** + * Handle to an active blacklist check. + */ +struct GST_BlacklistCheck; + + + +/** + * Test if a peer/transport combination is blacklisted. + * + * @param peer the identity of the peer to test + * @param transport_name name of the transport to test, never NULL + * @param cont function to call with result + * @param cont_cls closure for @a cont + * @param address address to pass back to @a cont, can be NULL + * @param session session to pass back to @a cont, can be NULL + * @return handle to the blacklist check, NULL if the decision + * was made instantly and @a cont was already called + */ +struct GST_BlacklistCheck * +GST_blacklist_test_allowed (const struct GNUNET_PeerIdentity *peer, + const char *transport_name, + GST_BlacklistTestContinuation cont, + void *cont_cls, + const struct GNUNET_HELLO_Address *address, + struct GNUNET_ATS_Session *session); + + +/** + * Abort blacklist if @a address and @a session match. + * + * @param address address used to abort matching checks + * @param session session used to abort matching checks + */ +void +GST_blacklist_abort_matching (const struct GNUNET_HELLO_Address *address, + struct GNUNET_ATS_Session *session); + +/** + * Cancel a blacklist check. + * + * @param bc check to cancel + */ +void +GST_blacklist_test_cancel (struct GST_BlacklistCheck *bc); + + /** * Function called by the transport for each received message. - * This function should also be called with "NULL" for the - * message to signal that the other peer disconnected. * * @param cls closure, const char* with the name of the plugin we received the message from - * @param peer (claimed) identity of the other peer - * @param message the message, NULL if we only care about - * learning about the delay until we should receive again -- FIXME! + * @param address address and (claimed) identity of the other peer * @param session identifier used for this session (NULL for plugins * that do not offer bi-directional communication to the sender * using the same "connection") - * @param sender_address binary address of the sender (if we established the - * connection or are otherwise sure of it; should be NULL - * for inbound TCP/UDP connections since it it not clear - * that we could establish ourselves a connection to that - * IP address and get the same system) - * @param sender_address_len number of bytes in sender_address + * @param message the message, NULL if we only care about + * learning about the delay until we should receive again * @return how long the plugin should wait until receiving more data * (plugins that do not support this, can ignore the return value) */ struct GNUNET_TIME_Relative GST_receive_callback (void *cls, - const struct GNUNET_PeerIdentity *peer, - const struct GNUNET_MessageHeader *message, - struct Session *session, - const char *sender_address, - uint16_t sender_address_len); + const struct GNUNET_HELLO_Address *address, + struct GNUNET_ATS_Session *session, + const struct GNUNET_MessageHeader *message); + +/** + * Broadcast the given message to all of our clients. + * + * @param msg message to broadcast + * @param may_drop #GNUNET_YES if the message can be dropped / is payload + */ +void +GST_clients_broadcast (const struct GNUNET_MessageHeader *msg, + int may_drop); +/** + * Broadcast the new active address to all clients monitoring the peer. + * + * @param peer peer this update is about (never NULL) + * @param address address, NULL on disconnect + * @param state the current state of the peer + * @param state_timeout the time out for the state + */ void -GST_update_ats_metrics (const struct GNUNET_PeerIdentity *peer, - const struct GNUNET_HELLO_Address *address, - struct Session *session, - const struct GNUNET_ATS_Information *ats, - uint32_t ats_count); +GST_clients_broadcast_peer_notification (const struct GNUNET_PeerIdentity *peer, + const struct GNUNET_HELLO_Address *address, + enum GNUNET_TRANSPORT_PeerState state, + struct GNUNET_TIME_Absolute state_timeout); + + +/** + * Notify all clients about a disconnect, and cancel + * pending SEND_OK messages for this peer. + * + * @param peer peer that disconnected + */ +void +GST_clients_broadcast_disconnect (const struct GNUNET_PeerIdentity *peer); + + + #endif /* end of file gnunet-service-transport_plugins.h */