X-Git-Url: https://git.librecmc.org/?a=blobdiff_plain;f=src%2Ftransport%2Fgnunet-service-transport.h;h=2807afd793a634ac2fec619bc233a6d574ec922e;hb=5a7cef0202631204485cbcb1e36671e4321a936f;hp=36469df0672b9e97ba0c166721147969bc970046;hpb=57aa3363dc8203686c8c73148dc9df2315edf8b0;p=oweals%2Fgnunet.git diff --git a/src/transport/gnunet-service-transport.h b/src/transport/gnunet-service-transport.h index 36469df06..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 @@ -53,19 +54,175 @@ extern struct GNUNET_PeerIdentity GST_my_identity; extern struct GNUNET_PEERINFO_Handle *GST_peerinfo; /** - * Our public key. + * Our private key. */ -extern struct GNUNET_CRYPTO_RsaPublicKeyBinaryEncoded GST_my_public_key; +extern struct GNUNET_CRYPTO_EddsaPrivateKey *GST_my_private_key; /** - * Our private key. + * ATS handle. */ -extern struct GNUNET_CRYPTO_RsaPrivateKey *GST_my_private_key; +extern struct GNUNET_ATS_SchedulingHandle *GST_ats; /** - * ATS handle. + * 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. + * + * @param cls closure, const char* with the name of the plugin we received the message from + * @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 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) */ -extern struct GNUNET_ATS_Handle *GST_ats; +struct GNUNET_TIME_Relative +GST_receive_callback (void *cls, + 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_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