Globals for gnunet-service-core. More...

#include "gnunet_statistics_service.h"
#include "gnunet_core_service.h"
#include "core.h"
#include "gnunet-service-core_typemap.h"

Include dependency graph for gnunet-service-core.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures
struct	GSC_ClientActiveRequest
	Record kept for each request for transmission issued by a client that is still pending. More...

Functions
void	GSC_CLIENTS_solicit_request (struct GSC_ClientActiveRequest *car)
	Tell a client that we are ready to receive the message. More...

void	GSC_CLIENTS_reject_request (struct GSC_ClientActiveRequest *car, int drop_client)
	We will never be ready to transmit the given message in (disconnect or invalid request). More...

void	GSC_CLIENTS_notify_client_about_neighbour (struct GSC_Client client, const struct GNUNET_PeerIdentity neighbour, const struct GSC_TypeMap tmap_old, const struct GSC_TypeMap tmap_new)
	Notify a particular client about a change to existing connection to one of our neighbours (check if the client is interested). More...

void	GSC_CLIENTS_deliver_message (const struct GNUNET_PeerIdentity sender, const struct GNUNET_MessageHeader msg, uint16_t msize, uint32_t options)
	Deliver P2P message to interested clients. More...

void	GSC_CLIENTS_notify_clients_about_neighbour (const struct GNUNET_PeerIdentity neighbour, const struct GSC_TypeMap tmap_old, const struct GSC_TypeMap *tmap_new)
	Notify all clients about a change to existing session. More...

Variables
const struct GNUNET_CONFIGURATION_Handle *	GSC_cfg
	Our configuration. More...

struct GNUNET_STATISTICS_Handle *	GSC_stats
	For creating statistics. More...

struct GNUNET_PeerIdentity	GSC_my_identity
	Our identity. More...

Detailed Description

Globals for gnunet-service-core.

Author: Christian Grothoff

Definition in file gnunet-service-core.h.

Function Documentation

◆ GSC_CLIENTS_solicit_request()

void GSC_CLIENTS_solicit_request ( struct GSC_ClientActiveRequest * car )

Tell a client that we are ready to receive the message.

Parameters

car	request that is now ready; the responsibility for the handle remains shared between CLIENTS and SESSIONS after this call.

Definition at line 261 of file gnunet-service-core.c.

 {
   struct GSC_Client *c;
   struct GNUNET_MQ_Envelope *env;
   struct SendMessageReady *smr;
   struct GNUNET_TIME_Relative delay;
   struct GNUNET_TIME_Relative left;
  
   c = car->client_handle;
   if (GNUNET_YES !=
       GNUNET_CONTAINER_multipeermap_contains (c->connectmap, &car->target))
   {
     /* connection has gone down since, drop request */
     GNUNET_assert (0 !=
                    GNUNET_memcmp (&car->target,
                                   &GSC_my_identity));
     GSC_SESSIONS_dequeue_request (car);
     GSC_CLIENTS_reject_request (car, GNUNET_NO);
     return;
   }
   delay = GNUNET_TIME_absolute_get_duration (car->received_time);
   left = GNUNET_TIME_absolute_get_duration (car->deadline);
   if (delay.rel_value_us > GNUNET_CONSTANTS_LATENCY_WARN.rel_value_us)
     GNUNET_log (
       GNUNET_ERROR_TYPE_WARNING,
       "Client waited %s for permission to transmit to `%s'%s (priority %u)\n",
       GNUNET_STRINGS_relative_time_to_string (delay, GNUNET_YES),
       GNUNET_i2s (&car->target),
       (0 == left.rel_value_us) ? " (past deadline)" : "",
       car->priority);
   env = GNUNET_MQ_msg (smr, GNUNET_MESSAGE_TYPE_CORE_SEND_READY);
   smr->size = htons (car->msize);
   smr->smr_id = car->smr_id;
   smr->peer = car->target;
   GNUNET_MQ_send (c->mq, env);
 }

References GSC_ClientActiveRequest::client_handle, GSC_Client::connectmap, GSC_ClientActiveRequest::deadline, delay, env, GNUNET_assert, GNUNET_CONSTANTS_LATENCY_WARN, GNUNET_CONTAINER_multipeermap_contains(), GNUNET_ERROR_TYPE_WARNING, GNUNET_i2s(), GNUNET_log, GNUNET_memcmp, GNUNET_MESSAGE_TYPE_CORE_SEND_READY, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_NO, GNUNET_STRINGS_relative_time_to_string(), GNUNET_TIME_absolute_get_duration(), GNUNET_YES, GSC_CLIENTS_reject_request(), GSC_my_identity, GSC_SESSIONS_dequeue_request(), GSC_Client::mq, GSC_ClientActiveRequest::msize, SendMessageReady::peer, GSC_ClientActiveRequest::priority, GSC_ClientActiveRequest::received_time, GNUNET_TIME_Relative::rel_value_us, SendMessageReady::size, SendMessageReady::smr_id, GSC_ClientActiveRequest::smr_id, and GSC_ClientActiveRequest::target.

Referenced by handle_client_send_request(), and solicit_messages().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GSC_CLIENTS_reject_request()

void GSC_CLIENTS_reject_request	(	struct GSC_ClientActiveRequest *	car,
		int	drop_client
	)

We will never be ready to transmit the given message in (disconnect or invalid request).

Frees resources associated with car. We don't explicitly tell the client, it'll learn with the disconnect (or violated the protocol).

Parameters

car	request that now permanently failed; the responsibility for the handle is now returned to CLIENTS (SESSIONS is done with it).
drop_client	GNUNET_YES if the client violated the protocol and we should thus drop the connection

Definition at line 239 of file gnunet-service-core.c.

 {
   GNUNET_assert (
     GNUNET_YES ==
     GNUNET_CONTAINER_multipeermap_remove (car->client_handle->requests,
                                           &car->target,
                                           car));
   if (GNUNET_YES == drop_client)
     GNUNET_SERVICE_client_drop (car->client_handle->client);
   GNUNET_free (car);
 }

References GSC_Client::client, GSC_ClientActiveRequest::client_handle, GNUNET_assert, GNUNET_CONTAINER_multipeermap_remove(), GNUNET_free, GNUNET_SERVICE_client_drop(), GNUNET_YES, GSC_Client::requests, and GSC_ClientActiveRequest::target.

Referenced by GSC_CLIENTS_solicit_request(), GSC_SESSIONS_end(), and GSC_SESSIONS_queue_request().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GSC_CLIENTS_notify_client_about_neighbour()

void GSC_CLIENTS_notify_client_about_neighbour	(	struct GSC_Client *	client,
		const struct GNUNET_PeerIdentity *	neighbour,
		const struct GSC_TypeMap *	tmap_old,
		const struct GSC_TypeMap *	tmap_new
	)

Notify a particular client about a change to existing connection to one of our neighbours (check if the client is interested).

Called from GSC_SESSIONS_notify_client_about_sessions().

Parameters

client	client to notify
neighbour	identity of the neighbour that changed status
tmap_old	previous type map for the neighbour, NULL for connect
tmap_new	updated type map for the neighbour, NULL for disconnect

Definition at line 643 of file gnunet-service-core.c.

 {
   struct GNUNET_MQ_Envelope *env;
   int old_match;
   int new_match;
  
   if (GNUNET_YES != client->got_init)
     return;
   old_match = GSC_TYPEMAP_test_match (tmap_old, client->types, client->tcnt);
   new_match = GSC_TYPEMAP_test_match (tmap_new, client->types, client->tcnt);
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
               "Notifying client about neighbour %s (%d/%d)\n",
               GNUNET_i2s (neighbour),
               old_match,
               new_match);
   if (old_match == new_match)
   {
     GNUNET_assert (
       old_match ==
       GNUNET_CONTAINER_multipeermap_contains (client->connectmap, neighbour));
     return;   /* no change */
   }
   if (GNUNET_NO == old_match)
   {
     struct ConnectNotifyMessage *cnm;
  
     /* send connect */
     GNUNET_assert (
       GNUNET_NO ==
       GNUNET_CONTAINER_multipeermap_contains (client->connectmap, neighbour));
     GNUNET_assert (GNUNET_YES ==
                    GNUNET_CONTAINER_multipeermap_put (
                      client->connectmap,
                      neighbour,
                      NULL,
                      GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY));
     env = GNUNET_MQ_msg (cnm, GNUNET_MESSAGE_TYPE_CORE_NOTIFY_CONNECT);
     cnm->reserved = htonl (0);
     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                 "Sending NOTIFY_CONNECT message about peer %s to client.\n",
                 GNUNET_i2s (neighbour));
     cnm->peer = *neighbour;
     GNUNET_MQ_send (client->mq, env);
   }
   else
   {
     struct DisconnectNotifyMessage *dcm;
  
     /* send disconnect */
     GNUNET_assert (
       GNUNET_YES ==
       GNUNET_CONTAINER_multipeermap_contains (client->connectmap, neighbour));
     GNUNET_assert (GNUNET_YES ==
                    GNUNET_CONTAINER_multipeermap_remove (client->connectmap,
                                                          neighbour,
                                                          NULL));
     env = GNUNET_MQ_msg (dcm, GNUNET_MESSAGE_TYPE_CORE_NOTIFY_DISCONNECT);
     dcm->reserved = htonl (0);
     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                 "Sending NOTIFY_DISCONNECT message about peer %s to client.\n",
                 GNUNET_i2s (neighbour));
     dcm->peer = *neighbour;
     GNUNET_MQ_send (client->mq, env);
   }
 }

References GSC_Client::connectmap, env, GNUNET_assert, GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY, GNUNET_CONTAINER_multipeermap_contains(), GNUNET_CONTAINER_multipeermap_put(), GNUNET_CONTAINER_multipeermap_remove(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_i2s(), GNUNET_log, GNUNET_MESSAGE_TYPE_CORE_NOTIFY_CONNECT, GNUNET_MESSAGE_TYPE_CORE_NOTIFY_DISCONNECT, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_NO, GNUNET_YES, GSC_Client::got_init, GSC_TYPEMAP_test_match(), GSC_Client::mq, ConnectNotifyMessage::peer, DisconnectNotifyMessage::peer, ConnectNotifyMessage::reserved, DisconnectNotifyMessage::reserved, GSC_Client::tcnt, and GSC_Client::types.

Referenced by GSC_CLIENTS_notify_clients_about_neighbour(), and notify_client_about_session().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GSC_CLIENTS_deliver_message()

void GSC_CLIENTS_deliver_message	(	const struct GNUNET_PeerIdentity *	sender,
		const struct GNUNET_MessageHeader *	msg,
		uint16_t	msize,
		uint32_t	options
	)

Deliver P2P message to interested clients.

Caller must have checked that the sending peer actually lists the given message type as one of its types.

Parameters

sender	peer who sent us the message
msg	the message
msize	number of bytes to transmit
options	options for checking which clients should receive the message

Definition at line 751 of file gnunet-service-core.c.

 {
   size_t size = msize + sizeof(struct NotifyTrafficMessage);
  
   if (size >= GNUNET_MAX_MESSAGE_SIZE)
   {
     GNUNET_break (0);
     return;
   }
   if (! ((0 != (all_client_options & options)) ||
          (0 != (options & GNUNET_CORE_OPTION_SEND_FULL_INBOUND))))
     return; /* no client cares about this message notification */
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
               "Core service passes message from `%s' of type %u to client.\n",
               GNUNET_i2s (sender),
               (unsigned int) ntohs (msg->type));
   GSC_SESSIONS_add_to_typemap (sender, ntohs (msg->type));
  
   for (struct GSC_Client *c = client_head; NULL != c; c = c->next)
   {
     struct GNUNET_MQ_Envelope *env;
     struct NotifyTrafficMessage *ntm;
     uint16_t mtype;
     unsigned int qlen;
     int tm;
  
     tm = type_match (ntohs (msg->type), c);
     if (! ((0 != (c->options & options)) ||
            ((0 != (options & GNUNET_CORE_OPTION_SEND_FULL_INBOUND)) &&
             (GNUNET_YES == tm))))
       continue;   /* neither options nor type match permit the message */
     if ((0 != (options & GNUNET_CORE_OPTION_SEND_HDR_INBOUND)) &&
         ((0 != (c->options & GNUNET_CORE_OPTION_SEND_FULL_INBOUND)) ||
          (GNUNET_YES == tm)))
       continue;
     if ((0 != (options & GNUNET_CORE_OPTION_SEND_HDR_OUTBOUND)) &&
         (0 != (c->options & GNUNET_CORE_OPTION_SEND_FULL_OUTBOUND)))
       continue;
  
     /* Drop messages if:
        1) We are above the hard limit, or
        2) We are above the soft limit, and a coin toss limited
           to the message size (giving larger messages a
           proportionally higher chance of being queued) falls
           below the threshold. The threshold is based on where
           we are between the soft and the hard limit, scaled
           to match the range of message sizes we usually encounter
           (i.e. up to 32k); so a 64k message has a 50% chance of
           being kept if we are just barely below the hard max,
           and a 99% chance of being kept if we are at the soft max.
        The reason is to make it more likely to drop control traffic
        (ACK, queries) which may be cumulative or highly redundant,
        and cheap to drop than data traffic.  */qlen = GNUNET_MQ_get_length (c->mq);
     if ((qlen >= HARD_MAX_QUEUE) ||
         ((qlen > SOFT_MAX_QUEUE) &&
          ((GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK,
                                      ntohs (msg->size))) <
           (qlen - SOFT_MAX_QUEUE) * 0x8000
           / (HARD_MAX_QUEUE - SOFT_MAX_QUEUE))))
     {
       char buf[1024];
  
       GNUNET_log (
         GNUNET_ERROR_TYPE_INFO | GNUNET_ERROR_TYPE_BULK,
         "Dropping decrypted message of type %u as client is too busy (queue full)\n",
         (unsigned int) ntohs (msg->type));
       GNUNET_snprintf (buf,
                        sizeof(buf),
                        gettext_noop (
                          "# messages of type %u discarded (client busy)"),
                        (unsigned int) ntohs (msg->type));
       GNUNET_STATISTICS_update (GSC_stats, buf, 1, GNUNET_NO);
       continue;
     }
  
     GNUNET_log (
       GNUNET_ERROR_TYPE_DEBUG,
       "Sending %u message with %u bytes to client interested in messages of type %u.\n",
       options,
       ntohs (msg->size),
       (unsigned int) ntohs (msg->type));
  
     if (0 != (options & (GNUNET_CORE_OPTION_SEND_FULL_INBOUND
                          | GNUNET_CORE_OPTION_SEND_HDR_INBOUND)))
       mtype = GNUNET_MESSAGE_TYPE_CORE_NOTIFY_INBOUND;
     else
       mtype = GNUNET_MESSAGE_TYPE_CORE_NOTIFY_OUTBOUND;
     env = GNUNET_MQ_msg_extra (ntm, msize, mtype);
     ntm->peer = *sender;
     GNUNET_memcpy (&ntm[1], msg, msize);
  
     GNUNET_assert (
       (0 == (c->options & GNUNET_CORE_OPTION_SEND_FULL_INBOUND)) ||
       (GNUNET_YES != tm) ||
       (GNUNET_YES ==
        GNUNET_CONTAINER_multipeermap_contains (c->connectmap, sender)));
     GNUNET_MQ_send (c->mq, env);
   }
 }

References all_client_options, buf, client_head, env, gettext_noop, GNUNET_assert, GNUNET_break, GNUNET_CONTAINER_multipeermap_contains(), GNUNET_CORE_OPTION_SEND_FULL_INBOUND, GNUNET_CORE_OPTION_SEND_FULL_OUTBOUND, GNUNET_CORE_OPTION_SEND_HDR_INBOUND, GNUNET_CORE_OPTION_SEND_HDR_OUTBOUND, GNUNET_CRYPTO_QUALITY_WEAK, GNUNET_CRYPTO_random_u32(), GNUNET_ERROR_TYPE_BULK, GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_INFO, GNUNET_i2s(), GNUNET_log, GNUNET_MAX_MESSAGE_SIZE, GNUNET_memcpy, GNUNET_MESSAGE_TYPE_CORE_NOTIFY_INBOUND, GNUNET_MESSAGE_TYPE_CORE_NOTIFY_OUTBOUND, GNUNET_MQ_get_length(), GNUNET_MQ_msg_extra, GNUNET_MQ_send(), GNUNET_NO, GNUNET_snprintf(), GNUNET_STATISTICS_update(), GNUNET_YES, GSC_SESSIONS_add_to_typemap(), GSC_stats, HARD_MAX_QUEUE, msg, GSC_Client::next, options, NotifyTrafficMessage::peer, GNUNET_MessageHeader::size, size, SOFT_MAX_QUEUE, GNUNET_MessageHeader::type, and type_match().

Referenced by deliver_message(), and tokenized_cb().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GSC_CLIENTS_notify_clients_about_neighbour()

void GSC_CLIENTS_notify_clients_about_neighbour	(	const struct GNUNET_PeerIdentity *	neighbour,
		const struct GSC_TypeMap *	tmap_old,
		const struct GSC_TypeMap *	tmap_new
	)

Notify all clients about a change to existing session.

Called from SESSIONS whenever there is a change in sessions or types processed by the respective peer.

Parameters

neighbour	identity of the neighbour that changed status
tmap_old	previous type map for the neighbour, NULL for connect
tmap_new	updated type map for the neighbour, NULL for disconnect

Definition at line 724 of file gnunet-service-core.c.

 {
   struct GSC_Client *c;
  
   for (c = client_head; NULL != c; c = c->next)
     GSC_CLIENTS_notify_client_about_neighbour (c,
                                                neighbour,
                                                tmap_old,
                                                tmap_new);
 }