plugin_transport_udp.h File Reference

Implementation of the UDP transport protocol. More...

#include "platform.h"
#include "gnunet_hello_lib.h"
#include "gnunet_util_lib.h"
#include "gnunet_fragmentation_lib.h"
#include "gnunet_protocols.h"
#include "gnunet_resolver_service.h"
#include "gnunet_signatures.h"
#include "gnunet_constants.h"
#include "gnunet_statistics_service.h"
#include "gnunet_transport_service.h"
#include "gnunet_transport_plugin.h"
#include "transport.h"

Include dependency graph for plugin_transport_udp.h:

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

Go to the source code of this file.

Data Structures
struct	IPv4UdpAddress
	Network format for IPv4 addresses. More...
struct	IPv6UdpAddress
	Network format for IPv6 addresses. More...
union	UdpAddress
	Either an IPv4 or IPv6 UDP address. More...
struct	Plugin
	Handle for a plugin. More...

Macros
#define	LOG(kind, ...)   GNUNET_log_from (kind, "transport-udp", __VA_ARGS__)
#define	PLUGIN_NAME   "udp"
#define	DEBUG_UDP   GNUNET_NO
#define	DEBUG_UDP_BROADCASTING   GNUNET_NO
#define	UDP_MTU   1400
	MTU for fragmentation subsystem. More...

Functions
const char *	udp_address_to_string (void *cls, const void *addr, size_t addrlen)
	Function called for a quick conversion of the binary address to a numeric address. More...
void	udp_broadcast_receive (struct Plugin *plugin, const char *buf, ssize_t size, const union UdpAddress *udp_addr, size_t udp_addr_len, enum GNUNET_NetworkType network_type)
	We received a broadcast message. More...
void	setup_broadcast (struct Plugin *plugin, struct sockaddr_in6 *server_addrv6, struct sockaddr_in *server_addrv4)
	Setup broadcasting subsystem. More...
void	stop_broadcast (struct Plugin *plugin)
	Stop broadcasting subsystem. More...

Detailed Description

Implementation of the UDP transport protocol.

Author

Christian Grothoff

Nathan Evans

Matthias Wachs

Definition in file plugin_transport_udp.h.

Macro Definition Documentation

LOG

#define LOG	(		kind,
			...
	)		GNUNET_log_from (kind, "transport-udp", __VA_ARGS__)

Definition at line 44 of file plugin_transport_udp.h.

PLUGIN_NAME

#define PLUGIN_NAME   "udp"

Definition at line 46 of file plugin_transport_udp.h.

DEBUG_UDP

#define DEBUG_UDP   GNUNET_NO

Definition at line 48 of file plugin_transport_udp.h.

DEBUG_UDP_BROADCASTING

#define DEBUG_UDP_BROADCASTING   GNUNET_NO

Definition at line 50 of file plugin_transport_udp.h.

UDP_MTU

#define UDP_MTU   1400

MTU for fragmentation subsystem.

Should be conservative since all communicating peers MUST work with this MTU.

Definition at line 56 of file plugin_transport_udp.h.

Function Documentation

udp_address_to_string()

const char* udp_address_to_string	(	void *	cls,
		const void *	addr,
		size_t	addrlen
	)

Function called for a quick conversion of the binary address to a numeric address.

Note that the caller must not free the address and that the next call to this function is allowed to override the address again.

Parameters

cls	closure
addr	binary address (a union UdpAddress)
addrlen	length of the addr

Returns

string representing the same address

Definition at line 864 of file plugin_transport_udp.c.

{
  static char rbuf[INET6_ADDRSTRLEN + 10];
  char buf[INET6_ADDRSTRLEN];
  const void *sb;
  struct in_addr a4;
  struct in6_addr a6;
  const struct IPv4UdpAddress *t4;
  const struct IPv6UdpAddress *t6;
  int af;
  uint16_t port;
  uint32_t options;
 
  if (NULL == addr)
  {
    GNUNET_break_op (0);
    return NULL;
  }
 
  if (addrlen == sizeof(struct IPv6UdpAddress))
  {
    t6 = addr;
    af = AF_INET6;
    options = ntohl (t6->options);
    port = ntohs (t6->u6_port);
    a6 = t6->ipv6_addr;
    sb = &a6;
  }
  else if (addrlen == sizeof(struct IPv4UdpAddress))
  {
    t4 = addr;
    af = AF_INET;
    options = ntohl (t4->options);
    port = ntohs (t4->u4_port);
    a4.s_addr = t4->ipv4_addr;
    sb = &a4;
  }
  else
  {
    GNUNET_break_op (0);
    return NULL;
  }
  inet_ntop (af, sb, buf, INET6_ADDRSTRLEN);
  GNUNET_snprintf (rbuf,
                   sizeof(rbuf),
                   (af == AF_INET6) ? "%s.%u.[%s]:%u" : "%s.%u.%s:%u",
                   PLUGIN_NAME,
                   options,
                   buf,
                   port);
  return rbuf;
}

References buf, GNUNET_break_op, GNUNET_snprintf(), options, PLUGIN_NAME, port, t4, and t6.

Referenced by ack_proc(), broadcast_mst_cb(), libgnunet_plugin_transport_udp_init(), read_process_ack(), read_process_fragment(), udp_disconnect_session(), udp_plugin_create_session(), udp_plugin_lookup_session(), and udp_plugin_send().

Here is the call graph for this function:

Here is the caller graph for this function:

udp_broadcast_receive()

void udp_broadcast_receive	(	struct Plugin *	plugin,
		const char *	buf,
		ssize_t	size,
		const union UdpAddress *	udp_addr,
		size_t	udp_addr_len,
		enum GNUNET_NetworkType	network_type
	)

We received a broadcast message.

Process it and all subsequent messages in the same packet.

Parameters

plugin	the UDP plugin
buf	the buffer with the message(s)
size	number of bytes in buf
udp_addr	address of the sender
udp_addr_len	number of bytes in udp_addr
network_type	network type of the sender's address

Definition at line 187 of file plugin_transport_udp_broadcasting.c.

{
  struct GNUNET_MessageStreamTokenizer *broadcast_mst;
  struct MstContext mc;
 
  broadcast_mst = GNUNET_MST_create (&broadcast_mst_cb,
                                     &mc);
  mc.plugin = plugin;
  mc.udp_addr = udp_addr;
  mc.udp_addr_len = udp_addr_len;
  mc.ats_address_network_type = network_type;
  GNUNET_MST_from_buffer (broadcast_mst,
                          buf, size,
                          GNUNET_NO,
                          GNUNET_NO);
  GNUNET_MST_destroy (broadcast_mst);
}

References broadcast_mst_cb(), buf, GNUNET_MST_create(), GNUNET_MST_destroy(), GNUNET_MST_from_buffer(), GNUNET_NO, mc, plugin, size, MstContext::udp_addr, and MstContext::udp_addr_len.

Referenced by udp_select_read().

Here is the call graph for this function:

Here is the caller graph for this function:

setup_broadcast()

void setup_broadcast	(	struct Plugin *	plugin,
		struct sockaddr_in6 *	server_addrv6,
		struct sockaddr_in *	server_addrv4
	)

Setup broadcasting subsystem.

Parameters

plugin
server_addrv6
server_addrv4

Definition at line 542 of file plugin_transport_udp_broadcasting.c.

{
  if (GNUNET_YES ==
      GNUNET_CONFIGURATION_get_value_yesno (plugin->env->cfg,
                                            "topology",
                                            "FRIENDS-ONLY"))
  {
    LOG (GNUNET_ERROR_TYPE_WARNING,
         _ (
           "Disabling HELLO broadcasting due to friend-to-friend only configuration!\n"));
    return;
  }
 
  if (GNUNET_YES != plugin->enable_broadcasting)
    return; /* We do not send, just receive */
 
  /* create IPv4 broadcast socket */
  if ((GNUNET_YES == plugin->enable_ipv4) && (NULL != plugin->sockv4))
  {
    static int yes = 1;
 
    if (GNUNET_NETWORK_socket_setsockopt
          (plugin->sockv4, SOL_SOCKET, SO_BROADCAST, &yes,
          sizeof(int)) != GNUNET_OK)
    {
      LOG (GNUNET_ERROR_TYPE_WARNING,
           _ (
             "Failed to set IPv4 broadcast option for broadcast socket on port %d\n"),
           ntohs (server_addrv4->sin_port));
    }
  }
  /* create IPv6 multicast socket */
  if ((GNUNET_YES == plugin->enable_ipv6) && (plugin->sockv6 != NULL))
  {
    memset (&plugin->ipv6_multicast_address, 0, sizeof(struct sockaddr_in6));
    GNUNET_assert (1 ==
                   inet_pton (AF_INET6, "FF05::13B",
                              &plugin->ipv6_multicast_address.sin6_addr));
    plugin->ipv6_multicast_address.sin6_family = AF_INET6;
    plugin->ipv6_multicast_address.sin6_port = htons (plugin->port);
  }
  GNUNET_OS_network_interfaces_list (&iface_proc, plugin);
}

References _, GNUNET_assert, GNUNET_CONFIGURATION_get_value_yesno(), GNUNET_ERROR_TYPE_WARNING, GNUNET_NETWORK_socket_setsockopt(), GNUNET_OK, GNUNET_OS_network_interfaces_list(), GNUNET_YES, iface_proc(), LOG, and plugin.

Referenced by libgnunet_plugin_transport_udp_init().

Here is the call graph for this function:

Here is the caller graph for this function:

stop_broadcast()

void stop_broadcast

(

struct Plugin *

plugin

)

Stop broadcasting subsystem.

Parameters

plugin

Definition at line 595 of file plugin_transport_udp_broadcasting.c.

{
  if (GNUNET_YES == plugin->enable_broadcasting)
  {
    /* Disable broadcasting */
    while (plugin->broadcast_head != NULL)
    {
      struct BroadcastAddress *p = plugin->broadcast_head;
 
      if (p->broadcast_task != NULL)
      {
        GNUNET_SCHEDULER_cancel (p->broadcast_task);
        p->broadcast_task = NULL;
      }
      if ((GNUNET_YES == plugin->enable_ipv6) &&
          (NULL != plugin->sockv6) &&
          (p->addrlen == sizeof(struct sockaddr_in6)))
      {
        /* Create IPv6 multicast request */
        struct ipv6_mreq multicastRequest;
        const struct sockaddr_in6 *s6 = (const struct sockaddr_in6 *) p->addr;
 
        multicastRequest.ipv6mr_multiaddr =
          plugin->ipv6_multicast_address.sin6_addr;
        multicastRequest.ipv6mr_interface = s6->sin6_scope_id;
 
        /* Leave the multicast group */
        if (GNUNET_OK ==
            GNUNET_NETWORK_socket_setsockopt
              (plugin->sockv6, IPPROTO_IPV6, IPV6_LEAVE_GROUP,
              &multicastRequest, sizeof(multicastRequest)))
        {
          GNUNET_log_strerror (GNUNET_ERROR_TYPE_ERROR, "setsockopt");
        }
        else
        {
          LOG (GNUNET_ERROR_TYPE_DEBUG, "IPv6 multicasting stopped\n");
        }
      }
 
#ifdef __linux__
      GNUNET_DISK_file_close (p->cryogenic_fd);
#endif
      GNUNET_CONTAINER_DLL_remove (plugin->broadcast_head,
                                   plugin->broadcast_tail, p);
      GNUNET_free (p->addr);
      GNUNET_free (p);
    }
  }
}