This file is part of GNUnet.
Copyright (C) 2010-2016 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
- by the Free Software Foundation; either version 3, or (at your
- option) any later version.
+ GNUnet is free software: you can redistribute it and/or modify it
+ under the terms of the GNU Affero General Public License as published
+ by the Free Software Foundation, either version 3 of the License,
+ or (at your option) any later version.
GNUnet is distributed in the hope that it will be useful, but
WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- General Public License for more details.
+ Affero General Public License for more details.
- 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., 51 Franklin Street, Fifth Floor,
- Boston, MA 02110-1301, USA.
+ You should have received a copy of the GNU Affero General Public License
+ along with this program. If not, see <http://www.gnu.org/licenses/>.
+
+ SPDX-License-Identifier: AGPL3.0-or-later
*/
/**
* @file transport/gnunet-service-transport.c
/**
* It is a blacklist, query about allowed connections.
*/
- CT_BLACKLIST = 3
+ CT_BLACKLIST = 3,
+
+ /**
+ * CORE client without any handlers.
+ */
+ CT_CORE_NO_HANDLERS = 4
};
/**
* What type of client is this?
- */
+ */
enum ClientType type;
union {
-
+
/**
* Peer identity to monitor the addresses of.
* Zero to monitor all neighbours. Valid if
* if we're performing one that has been cancelled).
*/
struct GST_BlacklistCheck *bc;
-
+
/**
* Set to #GNUNET_YES if we're currently waiting for a reply.
*/
int waiting_for_reply;
-
+
/**
* #GNUNET_YES if we have to call receive_done for this client
*/
int call_receive_done;
-
+
} blacklist;
-
+
} details;
-
+
};
*/
struct SendTransmitContinuationContext
{
-
+
/**
* Client that made the request.
*/
/**
* Interface scanner determines our LAN address range(s).
*/
-struct GNUNET_ATS_InterfaceScanner *GST_is;
+struct GNUNET_NT_InterfaceScanner *GST_is;
/**
GNUNET_MQ_get_length (tc->mq),
MAX_PENDING);
GNUNET_STATISTICS_update (GST_stats,
- gettext_noop
- ("# messages dropped due to slow client"), 1,
+ gettext_noop ("# messages dropped due to slow client"),
+ 1,
GNUNET_NO);
return;
}
GNUNET_CONTAINER_multipeermap_iterate (active_stccs,
&mark_match_down,
tc);
+ for (struct AddressToStringContext *cur = a2s_head;
+ NULL != cur;
+ cur = cur->next)
+ {
+ if (cur->tc == tc)
+ cur->tc = NULL;
+ }
GNUNET_CONTAINER_DLL_remove (clients_head,
clients_tail,
tc);
bc);
}
break;
- }
+ case CT_CORE_NO_HANDLERS:
+ break;
+ }
GNUNET_free (tc);
}
cim.header.size = htons (sizeof (struct ConnectInfoMessage));
cim.header.type = htons (GNUNET_MESSAGE_TYPE_TRANSPORT_CONNECT);
cim.id = *peer;
- cim.quota_in = bandwidth_in;
cim.quota_out = bandwidth_out;
unicast (tc,
&cim.header,
/**
* Initialize a normal client. We got a start message from this
- * client, add him to the list of clients for broadcasting of inbound
+ * client, add it to the list of clients for broadcasting of inbound
* messages.
*
* @param cls the client
}
if (0 != (2 & options))
tc->type = CT_CORE;
+ else
+ tc->type = CT_CORE_NO_HANDLERS;
hello = GST_hello_get ();
if (NULL != hello)
unicast (tc,
{
struct TransportClient *tc = cls;
+ GNUNET_log (GNUNET_ERROR_TYPE_INFO,
+ "Received HELLO message\n");
GST_validation_handle_hello (message);
GNUNET_SERVICE_client_continue (tc->client);
}
const struct OutboundMessage *obm)
{
static unsigned long long uuid_gen;
- struct TransportClient *tc = cls;
+ struct TransportClient *tc = cls;
const struct GNUNET_MessageHeader *obmm;
struct SendTransmitContinuationContext *stcc;
GNUNET_assert ( (GNUNET_OK == res) ||
(GNUNET_SYSERR == res) );
+ if (NULL == actx->tc)
+ return;
if (NULL == buf)
{
env = GNUNET_MQ_msg (atsm,
GNUNET_CONTAINER_DLL_remove (a2s_head,
a2s_tail,
actx);
+ GNUNET_free (actx);
return;
}
if (GNUNET_SYSERR == res)
return GNUNET_SYSERR;
}
return GNUNET_OK;
-}
+}
/**
handle_client_address_to_string (void *cls,
const struct AddressLookupMessage *alum)
{
- struct TransportClient *tc = cls;
+ struct TransportClient *tc = cls;
struct GNUNET_TRANSPORT_PluginFunctions *papi;
const char *plugin_name;
const char *address;
const struct GNUNET_MessageHeader *message)
{
struct TransportClient *tc = cls;
-
+
GNUNET_SERVICE_client_mark_monitor (tc->client);
GNUNET_SERVICE_client_disable_continue_warning (tc->client);
GNUNET_notification_context_add (plugin_nc,
GST_clients_broadcast (const struct GNUNET_MessageHeader *msg,
int may_drop)
{
- struct TransportClient *tc;
int done;
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
(unsigned int) ntohs (msg->type),
(unsigned int) ntohs (msg->size));
done = GNUNET_NO;
- for (tc = clients_head; NULL != tc; tc = tc->next)
+ for (struct TransportClient *tc = clients_head;
+ NULL != tc;
+ tc = tc->next)
{
+ if (CT_NONE == tc->type)
+ continue; /* client not yet ready */
if ( (GNUNET_YES == may_drop) &&
(CT_CORE != tc->type) )
continue; /* skip, this client does not care about payload */
{
struct GNUNET_MQ_Envelope *env;
struct PeerIterateResponseMessage *msg;
- struct TransportClient *tc;
msg = compose_address_iterate_response_message (peer,
address);
msg->state = htonl (state);
msg->state_timeout = GNUNET_TIME_absolute_hton (state_timeout);
- for (tc = clients_head; NULL != tc; tc = tc->next)
+ for (struct TransportClient *tc = clients_head;
+ NULL != tc;
+ tc = tc->next)
{
if (CT_MONITOR != tc->type)
continue;
goto end;
type = ntohs (message->type);
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
- "Received message with type %u from peer `%s'\n",
+ "Received message with type %u from peer `%s' at %s\n",
type,
- GNUNET_i2s (&address->peer));
+ GNUNET_i2s (&address->peer),
+ GST_plugins_a2s (address));
GNUNET_STATISTICS_update (GST_stats,
gettext_noop ("# bytes total received"),
plugin_env_session_start (void *cls,
const struct GNUNET_HELLO_Address *address,
struct GNUNET_ATS_Session *session,
- enum GNUNET_ATS_Network_Type scope)
+ enum GNUNET_NetworkType scope)
{
struct GNUNET_ATS_Properties prop;
memset (&prop,
0,
sizeof (prop));
- GNUNET_break (GNUNET_ATS_NET_UNSPECIFIED != scope);
+ GNUNET_break (GNUNET_NT_UNSPECIFIED != scope);
prop.scope = scope;
GST_ats_add_inbound_address (address,
session,
/**
* Initialize a blacklisting client. We got a blacklist-init
- * message from this client, add him to the list of clients
+ * message from this client, add it to the list of clients
* to query for blacklisting.
*
* @param cls the client
const struct TrafficMetricMessage *tm)
{
struct TransportClient *tc = cls;
-
+
GST_manipulation_set_metric (tm);
GNUNET_SERVICE_client_continue (tc->client);
}
GST_ats = NULL;
GNUNET_ATS_connectivity_done (GST_ats_connect);
GST_ats_connect = NULL;
- GNUNET_ATS_scanner_done (GST_is);
+ GNUNET_NT_scanner_done (GST_is);
GST_is = NULL;
while (NULL != (cur = a2s_head))
{
bc = tc->details.blacklist.bc;
tc->details.blacklist.bc = NULL;
tc->details.blacklist.waiting_for_reply = GNUNET_NO;
- tc->details.blacklist.call_receive_done = GNUNET_YES;
+ tc->details.blacklist.call_receive_done = GNUNET_YES;
if (NULL != bc)
{
/* only run this if the blacklist check has not been
GNUNET_assert (NULL != GST_my_private_key);
GNUNET_log(GNUNET_ERROR_TYPE_INFO,
- "My identity is `%4s'\n",
+ "My identity is `%s'\n",
GNUNET_i2s_full (&GST_my_identity));
GNUNET_SCHEDULER_add_shutdown (&shutdown_task,
#if HAVE_GETRLIMIT
{
struct rlimit r_file;
-
+
if (0 == getrlimit (RLIMIT_NOFILE,
&r_file))
{
/* start subsystems */
read_blacklist_configuration (GST_cfg,
&GST_my_identity);
- GST_is = GNUNET_ATS_scanner_init ();
+ GST_is = GNUNET_NT_scanner_init ();
GST_ats_connect = GNUNET_ATS_connectivity_init (GST_cfg);
GST_ats = GNUNET_ATS_scheduling_init (GST_cfg,
&ats_request_address_change,
GNUNET_MESSAGE_TYPE_TRANSPORT_SEND,
struct OutboundMessage,
NULL),
- GNUNET_MQ_hd_var_size (client_address_to_string,
+ GNUNET_MQ_hd_var_size (client_address_to_string,
GNUNET_MESSAGE_TYPE_TRANSPORT_ADDRESS_TO_STRING,
struct AddressLookupMessage,
NULL),
GNUNET_MESSAGE_TYPE_TRANSPORT_TRAFFIC_METRIC,
struct TrafficMetricMessage,
NULL),
- GNUNET_MQ_hd_fixed_size (client_monitor_plugins,
+ GNUNET_MQ_hd_fixed_size (client_monitor_plugins,
GNUNET_MESSAGE_TYPE_TRANSPORT_MONITOR_PLUGIN_START,
struct GNUNET_MessageHeader,
NULL),
projects / oweals / gnunet.git / blobdiff