Network library

Basic low-level networking interface. More...

Collaboration diagram for Network library:

Data Structures
struct	GNUNET_NETWORK_FDSet
	collection of IO descriptors More...

Functions
enum GNUNET_GenericReturnValue	GNUNET_NETWORK_test_pf (int pf)
	Test if the given protocol family is supported by this system. More...
char *	GNUNET_NETWORK_shorten_unixpath (char *unixpath)
	Given a unixpath that is too long (larger than UNIX_PATH_MAX), shorten it to an acceptable length while keeping it unique and making sure it remains a valid filename (if possible). More...
void	GNUNET_NETWORK_unix_precheck (const struct sockaddr_un *un)
	If services crash, they can leave a unix domain socket file on the disk. More...
struct GNUNET_NETWORK_Handle *	GNUNET_NETWORK_socket_accept (const struct GNUNET_NETWORK_Handle *desc, struct sockaddr *address, socklen_t *address_len)
	Accept a new connection on a socket. More...
struct GNUNET_NETWORK_Handle *	GNUNET_NETWORK_socket_box_native (int fd)
	Box a native socket (and check that it is a socket). More...
enum GNUNET_GenericReturnValue	GNUNET_NETWORK_socket_set_blocking (struct GNUNET_NETWORK_Handle *fd, int doBlock)
	Set if a socket should use blocking or non-blocking IO. More...
enum GNUNET_GenericReturnValue	GNUNET_NETWORK_socket_bind (struct GNUNET_NETWORK_Handle *desc, const struct sockaddr *address, socklen_t address_len)
	Bind a socket to a particular address. More...
enum GNUNET_GenericReturnValue	GNUNET_NETWORK_socket_close (struct GNUNET_NETWORK_Handle *desc)
	Close a socket. More...
void	GNUNET_NETWORK_socket_free_memory_only_ (struct GNUNET_NETWORK_Handle *desc)
	Only free memory of a socket, keep the file descriptor untouched. More...
enum GNUNET_GenericReturnValue	GNUNET_NETWORK_socket_connect (const struct GNUNET_NETWORK_Handle *desc, const struct sockaddr *address, socklen_t address_len)
	Connect a socket to some remote address. More...
enum GNUNET_GenericReturnValue	GNUNET_NETWORK_socket_getsockopt (const struct GNUNET_NETWORK_Handle *desc, int level, int optname, void *optval, socklen_t *optlen)
	Get socket options. More...
enum GNUNET_GenericReturnValue	GNUNET_NETWORK_socket_listen (const struct GNUNET_NETWORK_Handle *desc, int backlog)
	Listen on a socket. More...
ssize_t	GNUNET_NETWORK_socket_recvfrom_amount (const struct GNUNET_NETWORK_Handle *desc)
	How much data is available to be read on this descriptor? More...
ssize_t	GNUNET_NETWORK_socket_recvfrom (const struct GNUNET_NETWORK_Handle *desc, void *buffer, size_t length, struct sockaddr *src_addr, socklen_t *addrlen)
	Read data from a socket (always non-blocking). More...
ssize_t	GNUNET_NETWORK_socket_recv (const struct GNUNET_NETWORK_Handle *desc, void *buffer, size_t length)
	Read data from a connected socket (always non-blocking). More...
int	GNUNET_NETWORK_socket_select (struct GNUNET_NETWORK_FDSet *rfds, struct GNUNET_NETWORK_FDSet *wfds, struct GNUNET_NETWORK_FDSet *efds, struct GNUNET_TIME_Relative timeout)
	Check if sockets meet certain conditions. More...
ssize_t	GNUNET_NETWORK_socket_send (const struct GNUNET_NETWORK_Handle *desc, const void *buffer, size_t length)
	Send data (always non-blocking). More...
ssize_t	GNUNET_NETWORK_socket_sendto (const struct GNUNET_NETWORK_Handle *desc, const void *message, size_t length, const struct sockaddr *dest_addr, socklen_t dest_len)
	Send data to a particular destination (always non-blocking). More...
int	GNUNET_NETWORK_socket_setsockopt (struct GNUNET_NETWORK_Handle *fd, int level, int option_name, const void *option_value, socklen_t option_len)
	Set socket option. More...
enum GNUNET_GenericReturnValue	GNUNET_NETWORK_socket_shutdown (struct GNUNET_NETWORK_Handle *desc, int how)
	Shut down socket operations. More...
enum GNUNET_GenericReturnValue	GNUNET_NETWORK_socket_disable_corking (struct GNUNET_NETWORK_Handle *desc)
	Disable the "CORK" feature for communication with the given socket, forcing the OS to immediately flush the buffer on transmission instead of potentially buffering multiple messages. More...
struct GNUNET_NETWORK_Handle *	GNUNET_NETWORK_socket_create (int domain, int type, int protocol)
	Create a new socket. More...
void	GNUNET_NETWORK_fdset_zero (struct GNUNET_NETWORK_FDSet *fds)
	Reset FD set (clears all file descriptors). More...
void	GNUNET_NETWORK_fdset_set (struct GNUNET_NETWORK_FDSet *fds, const struct GNUNET_NETWORK_Handle *desc)
	Add a socket to the FD set. More...
int	GNUNET_NETWORK_fdset_isset (const struct GNUNET_NETWORK_FDSet *fds, const struct GNUNET_NETWORK_Handle *desc)
	Check whether a socket is part of the fd set. More...
void	GNUNET_NETWORK_fdset_add (struct GNUNET_NETWORK_FDSet *dst, const struct GNUNET_NETWORK_FDSet *src)
	Add one fd set to another (computes the union). More...
void	GNUNET_NETWORK_fdset_copy (struct GNUNET_NETWORK_FDSet *to, const struct GNUNET_NETWORK_FDSet *from)
	Copy one fd set to another. More...
int	GNUNET_NETWORK_get_fd (const struct GNUNET_NETWORK_Handle *desc)
	Return file descriptor for this network handle. More...
struct sockaddr *	GNUNET_NETWORK_get_addr (const struct GNUNET_NETWORK_Handle *desc)
	Return the sockaddr for this network handle. More...
socklen_t	GNUNET_NETWORK_get_addrlen (const struct GNUNET_NETWORK_Handle *desc)
	Return sockaddr length for this network handle. More...
void	GNUNET_NETWORK_fdset_copy_native (struct GNUNET_NETWORK_FDSet *to, const fd_set *from, int nfds)
	Copy a native fd set into the GNUnet representation. More...
void	GNUNET_NETWORK_fdset_set_native (struct GNUNET_NETWORK_FDSet *to, int nfd)
	Set a native fd in a set. More...
int	GNUNET_NETWORK_fdset_test_native (const struct GNUNET_NETWORK_FDSet *to, int nfd)
	Test native fd in a set. More...
void	GNUNET_NETWORK_fdset_handle_set (struct GNUNET_NETWORK_FDSet *fds, const struct GNUNET_DISK_FileHandle *h)
	Add a file handle to the fd set. More...
void	GNUNET_NETWORK_fdset_handle_set_first (struct GNUNET_NETWORK_FDSet *fds, const struct GNUNET_DISK_FileHandle *h)
	Add a file handle to the fd set On W32: ensure that the handle is first in the array. More...
int	GNUNET_NETWORK_fdset_handle_isset (const struct GNUNET_NETWORK_FDSet *fds, const struct GNUNET_DISK_FileHandle *h)
	Check if a file handle is part of an fd set. More...
int	GNUNET_NETWORK_fdset_overlap (const struct GNUNET_NETWORK_FDSet *fds1, const struct GNUNET_NETWORK_FDSet *fds2)
	Checks if two fd sets overlap. More...
struct GNUNET_NETWORK_FDSet *	GNUNET_NETWORK_fdset_create (void)
	Creates an fd set. More...
void	GNUNET_NETWORK_fdset_destroy (struct GNUNET_NETWORK_FDSet *fds)
	Releases the associated memory of an fd set. More...
int	GNUNET_NETWORK_test_port_free (int ipproto, uint16_t port)
	Test if the given port is available. More...

Detailed Description

Basic low-level networking interface.

Function Documentation

GNUNET_NETWORK_test_pf()

enum GNUNET_GenericReturnValue GNUNET_NETWORK_test_pf

(

int

pf

)

Test if the given protocol family is supported by this system.

Parameters

pf	protocol family to test (PF_INET, PF_INET6, PF_UNIX)

Returns

GNUNET_OK if the PF is supported

Definition at line 1 of file network.c.

{
  static int cache_v4 = -1;
  static int cache_v6 = -1;
  static int cache_un = -1;
  int s;
  int ret;
 
  switch (pf)
  {
  case PF_INET:
    if (-1 != cache_v4)
      return cache_v4;
    break;
 
  case PF_INET6:
    if (-1 != cache_v6)
      return cache_v6;
    break;
 
#ifdef PF_UNIX
  case PF_UNIX:
    if (-1 != cache_un)
      return cache_un;
    break;
#endif
  }
  s = socket (pf, SOCK_STREAM, 0);
  if (-1 == s)
  {
    if (EAFNOSUPPORT != errno)
    {
      GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING,
                           "socket");
      return GNUNET_SYSERR;
    }
    ret = GNUNET_NO;
  }
  else
  {
    GNUNET_break (0 == close (s));
    ret = GNUNET_OK;
  }
  switch (pf)
  {
  case PF_INET:
    cache_v4 = ret;
    break;
 
  case PF_INET6:
    cache_v6 = ret;
    break;
 
#ifdef PF_UNIX
  case PF_UNIX:
    cache_un = ret;
    break;
#endif
  }
  return ret;
}

Referenced by get_server_addresses(), handle_gns_result(), parse_ip_options(), run(), tcp_address_to_sockaddr_port_only(), and udp_address_to_sockaddr().

Here is the caller graph for this function:

GNUNET_NETWORK_shorten_unixpath()

char* GNUNET_NETWORK_shorten_unixpath

(

char *

unixpath

)

Given a unixpath that is too long (larger than UNIX_PATH_MAX), shorten it to an acceptable length while keeping it unique and making sure it remains a valid filename (if possible).

Parameters

unixpath

long path, will be freed (or same pointer returned with moved 0-termination).

Returns

shortened unixpath, NULL on error

Definition at line 144 of file network.c.

{
  struct sockaddr_un dummy;
  size_t slen;
  char *end;
  struct GNUNET_HashCode sh;
  struct GNUNET_CRYPTO_HashAsciiEncoded ae;
  size_t upm;
 
  upm = sizeof(dummy.sun_path);
  slen = strlen (unixpath);
  if (slen < upm)
    return unixpath; /* no shortening required */
  GNUNET_CRYPTO_hash (unixpath, slen, &sh);
  while (16 + strlen (unixpath) >= upm)
  {
    if (NULL == (end = strrchr (unixpath, '/')))
    {
      GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                  _ (
                    "Unable to shorten unix path `%s' while keeping name unique\n"),
                  unixpath);
      GNUNET_free (unixpath);
      return NULL;
    }
    *end = '\0';
  }
  GNUNET_CRYPTO_hash_to_enc (&sh, &ae);
  ae.encoding[16] = '\0';
  strcat (unixpath, (char *) ae.encoding);
  return unixpath;
}

References _, dummy, GNUNET_CRYPTO_HashAsciiEncoded::encoding, end, GNUNET_CRYPTO_hash(), GNUNET_CRYPTO_hash_to_enc(), GNUNET_ERROR_TYPE_ERROR, GNUNET_free, GNUNET_log, and sh.

Referenced by get_server_addresses(), LEGACY_SERVICE_get_server_addresses(), and try_unixpath().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_NETWORK_unix_precheck()

void GNUNET_NETWORK_unix_precheck

(

const struct sockaddr_un *

un

)

If services crash, they can leave a unix domain socket file on the disk.

This needs to be manually removed, because otherwise both bind() and connect() for the respective address will fail. In this function, we test if such a left-over file exists, and if so, remove it (unless there is a listening service at the address).

Parameters

un	unix domain socket address to check

Definition at line 179 of file network.c.

{
  int s;
  int eno;
  struct stat sbuf;
  int ret;
 
  s = socket (AF_UNIX, SOCK_STREAM, 0);
  if (-1 == s)
  {
    GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING,
                         "Failed to open AF_UNIX socket");
    return;
  }
  ret = connect (s,
                 (struct sockaddr *) un,
                 sizeof(struct sockaddr_un));
  eno = errno;
  GNUNET_break (0 == close (s));
  if (0 == ret)
    return; /* another process is listening, do not remove! */
  if (ECONNREFUSED != eno)
    return; /* some other error, likely "no such file or directory" -- all well */
  /* should unlink, but sanity checks first */
  if (0 != stat (un->sun_path,
                 &sbuf))
    return; /* failed to 'stat', likely does not exist after all */
  if (S_IFSOCK != (S_IFMT & sbuf.st_mode))
    return; /* refuse to unlink anything except sockets */
  /* finally, really unlink */
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Removing left-over `%s' from previous exeuction\n",
              un->sun_path);
  if (0 != unlink (un->sun_path))
    GNUNET_log_strerror_file (GNUNET_ERROR_TYPE_WARNING,
                              "unlink",
                              un->sun_path);
}

Referenced by create_listen_socket().

Here is the caller graph for this function:

GNUNET_NETWORK_socket_accept()

struct GNUNET_NETWORK_Handle* GNUNET_NETWORK_socket_accept	(	const struct GNUNET_NETWORK_Handle *	desc,
		struct sockaddr *	address,
		socklen_t *	address_len
	)

Accept a new connection on a socket.

Configure it for non-blocking IO and mark it as non-inheritable to child processes (set the close-on-exec flag).

Parameters

desc	bound socket
address	address of the connecting peer, may be NULL
address_len	length of address

Returns

client socket

Definition at line 393 of file network.c.

{
  struct GNUNET_NETWORK_Handle *ret;
  int eno;
 
  ret = GNUNET_new (struct GNUNET_NETWORK_Handle);
#if DEBUG_NETWORK
  {
    struct sockaddr_storage name;
    socklen_t namelen = sizeof(name);
 
    int gsn = getsockname (desc->fd,
                           (struct sockaddr *) &name,
                           &namelen);
 
    if (0 == gsn)
      LOG (GNUNET_ERROR_TYPE_DEBUG,
           "Accepting connection on `%s'\n",
           GNUNET_a2s ((const struct sockaddr *) &name,
                       namelen));
  }
#endif
  ret->fd = accept (desc->fd,
                    address,
                    address_len);
  if (-1 == ret->fd)
  {
    eno = errno;
    GNUNET_free (ret);
    errno = eno;
    return NULL;
  }
  if (GNUNET_OK !=
      initialize_network_handle (ret,
                                 (NULL != address) ? address->sa_family :
                                 desc->af,
                                 SOCK_STREAM))
  {
    return NULL;
  }
  return ret;
}

References address, GNUNET_NETWORK_Handle::af, GNUNET_NETWORK_Handle::fd, GNUNET_a2s(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_new, GNUNET_OK, initialize_network_handle(), LOG, name, and ret.

Referenced by accept_client(), do_accept(), GNUNET_CONNECTION_create_from_accept(), listen_cb(), and main().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_NETWORK_socket_box_native()

struct GNUNET_NETWORK_Handle* GNUNET_NETWORK_socket_box_native

(

int

fd

)

Box a native socket (and check that it is a socket).

Parameters

fd	socket to box

Returns

NULL on error (including not supported on target platform)

Definition at line 580 of file network.c.

{
  struct GNUNET_NETWORK_Handle *ret;
 
  if (fcntl (fd, F_GETFD) < 0)
    return NULL;                /* invalid FD */
  ret = GNUNET_new (struct GNUNET_NETWORK_Handle);
  ret->fd = fd;
  ret->af = AF_UNSPEC;
  return ret;
}

References GNUNET_NETWORK_Handle::fd, GNUNET_new, and ret.

Referenced by extract_handles(), libgnunet_plugin_dhtu_ip_init(), scheduler_fd_cb(), and setup_service().

Here is the caller graph for this function:

GNUNET_NETWORK_socket_set_blocking()

enum GNUNET_GenericReturnValue GNUNET_NETWORK_socket_set_blocking	(	struct GNUNET_NETWORK_Handle *	fd,
		int	doBlock
	)

Set if a socket should use blocking or non-blocking IO.

Parameters

fd	socket
doBlock	blocking mode

Returns

GNUNET_OK on success, GNUNET_SYSERR on error

Definition at line 179 of file network.c.

{
  int flags = fcntl (fd->fd, F_GETFL);
 
  if (flags == -1)
  {
    LOG_STRERROR (GNUNET_ERROR_TYPE_WARNING,
                  "fcntl");
    return GNUNET_SYSERR;
  }
  if (doBlock)
    flags &= ~O_NONBLOCK;
 
  else
    flags |= O_NONBLOCK;
  if (0 != fcntl (fd->fd,
                  F_SETFL,
                  flags))
 
  {
    LOG_STRERROR (GNUNET_ERROR_TYPE_WARNING,
                  "fcntl");
    return GNUNET_SYSERR;
  }
  return GNUNET_OK;
}

References GNUNET_break, GNUNET_ERROR_TYPE_INFO, GNUNET_ERROR_TYPE_WARNING, GNUNET_log, GNUNET_log_strerror, GNUNET_log_strerror_file, and ret.

Referenced by initialize_network_handle(), and main().

Here is the caller graph for this function:

GNUNET_NETWORK_socket_bind()

enum GNUNET_GenericReturnValue GNUNET_NETWORK_socket_bind	(	struct GNUNET_NETWORK_Handle *	desc,
		const struct sockaddr *	address,
		socklen_t	address_len
	)

Bind a socket to a particular address.

Parameters

desc	socket to bind
address	address to be bound
address_len	length of address

Returns

GNUNET_OK on success, GNUNET_SYSERR otherwise

Definition at line 393 of file network.c.

{
  int ret;
 
#ifdef IPV6_V6ONLY
#ifdef IPPROTO_IPV6
  {
    const int on = 1;
 
    if (AF_INET6 == desc->af)
      if (setsockopt (desc->fd,
                      IPPROTO_IPV6,
                      IPV6_V6ONLY,
                      (const void *) &on,
                      sizeof(on)))
        LOG_STRERROR (GNUNET_ERROR_TYPE_DEBUG,
                      "setsockopt");
  }
#endif
#endif
  if (AF_UNIX == address->sa_family)
    GNUNET_NETWORK_unix_precheck ((const struct sockaddr_un *) address);
 
  {
    const int on = 1;
 
    if ( (SOCK_STREAM == desc->type) &&
         (0 != setsockopt (desc->fd,
                           SOL_SOCKET,
                           SO_REUSEADDR,
                           &on, sizeof(on))) )
      LOG_STRERROR (GNUNET_ERROR_TYPE_DEBUG,
                    "setsockopt");
  }
  {
    /* set permissions of newly created non-abstract UNIX domain socket to
       "user-only"; applications can choose to relax this later */
    mode_t old_mask = 0; /* assigned to make compiler happy */
    const struct sockaddr_un *un = (const struct sockaddr_un *) address;
    int not_abstract = 0;
 
    if ((AF_UNIX == address->sa_family)
        && ('\0' != un->sun_path[0]))  /* Not an abstract socket */
      not_abstract = 1;
    if (not_abstract)
      old_mask = umask (S_IWGRP | S_IRGRP | S_IXGRP | S_IWOTH | S_IROTH
                        | S_IXOTH);
 
    ret = bind (desc->fd,
                address,
                address_len);
 
    if (not_abstract)
      (void) umask (old_mask);
  }
  if (0 != ret)
    return GNUNET_SYSERR;
 
  desc->addr = GNUNET_malloc (address_len);
  GNUNET_memcpy (desc->addr, address, address_len);
  desc->addrlen = address_len;
 
  return GNUNET_OK;
}

Referenced by bind_v4(), bind_v6(), create_listen_socket(), GNUNET_NAT_AUTO_test_start(), GNUNET_NAT_test_start(), GNUNET_NETWORK_test_port_free(), GNUNET_TESTING_reserve_port(), init_socket(), open_listen_socket(), open_socket(), run(), setup_sockets(), and unix_transport_server_start().

Here is the caller graph for this function:

GNUNET_NETWORK_socket_close()

enum GNUNET_GenericReturnValue GNUNET_NETWORK_socket_close

(

struct GNUNET_NETWORK_Handle *

desc

)

Close a socket.

Parameters

desc	socket to close

Returns

GNUNET_OK on success, GNUNET_SYSERR otherwise

Definition at line 393 of file network.c.

{
  int ret;
 
  ret = close (desc->fd);
 
  const struct sockaddr_un *un = (const struct sockaddr_un *) desc->addr;
 
  /* Cleanup the UNIX domain socket and its parent directories in case of non
     abstract sockets */
  if ((AF_UNIX == desc->af) &&
      (NULL != desc->addr) &&
      ('\0' != un->sun_path[0]))
  {
    char *dirname = GNUNET_strndup (un->sun_path,
                                    sizeof(un->sun_path));
 
    if (0 != unlink (dirname))
    {
      LOG_STRERROR_FILE (GNUNET_ERROR_TYPE_WARNING,
                         "unlink",
                         dirname);
    }
    else
    {
      size_t len;
 
      len = strlen (dirname);
      while ((len > 0) && (dirname[len] != DIR_SEPARATOR))
        len--;
      dirname[len] = '\0';
      if ((0 != len) && (0 != rmdir (dirname)))
      {
        switch (errno)
        {
        case EACCES:
        case ENOTEMPTY:
        case EPERM:
          /* these are normal and can just be ignored */
          break;
 
        default:
          GNUNET_log_strerror_file (GNUNET_ERROR_TYPE_WARNING,
                                    "rmdir",
                                    dirname);
          break;
        }
      }
    }
    GNUNET_free (dirname);
  }
  GNUNET_NETWORK_socket_free_memory_only_ (desc);
  return (ret == 0) ? GNUNET_OK : GNUNET_SYSERR;
}

Referenced by accept_client(), bind_v4(), bind_v6(), cancel_aps(), cleanup_ar(), cleanup_rs(), cleanup_s5r(), connect_probe_continuation(), connection_client_destroy_impl(), create_listen_socket(), create_proto_queue(), do_accept(), do_dns_read(), do_read(), do_shutdown(), do_udp_read(), finish_client_drop(), free_proto_queue(), get_lt_delete_it(), get_server_addresses(), GNUNET_CONNECTION_connect_socket(), GNUNET_CONNECTION_create_from_accept(), GNUNET_CONNECTION_create_from_connect_to_unixpath(), GNUNET_CONNECTION_destroy(), GNUNET_NAT_AUTO_test_start(), GNUNET_NAT_AUTO_test_stop(), GNUNET_NAT_test_start(), GNUNET_NAT_test_stop(), GNUNET_NETWORK_test_port_free(), GNUNET_SERVER_destroy(), GNUNET_SERVER_stop_listening(), GNUNET_TESTING_reserve_port(), init_socket(), initialize_network_handle(), kill_httpd(), LEGACY_SERVICE_get_server_addresses(), libgnunet_plugin_dhtu_ip_done(), libgnunet_plugin_transport_unix_done(), main(), mq_init(), open_listen_socket(), open_socket(), queue_destroy(), run(), server_check_ipv6_support(), setup_service(), setup_sockets(), shutdown_task(), signal_transmit_error(), stop_stun(), tcp_plugin_get_session(), tcp_send(), teardown_service(), try_connect_using_address(), try_send_tcp(), try_send_udp(), try_unixpath(), and unix_transport_server_start().

GNUNET_NETWORK_socket_free_memory_only_()

void GNUNET_NETWORK_socket_free_memory_only_

(

struct GNUNET_NETWORK_Handle *

desc

)

Only free memory of a socket, keep the file descriptor untouched.

Parameters

desc

socket

Definition at line 566 of file network.c.

{
  GNUNET_free (desc->addr);
  GNUNET_free (desc);
}

References GNUNET_NETWORK_Handle::addr, and GNUNET_free.

Referenced by cleanup_ar(), cleanup_s5r(), destroy_task(), finish_client_drop(), and GNUNET_CONNECTION_destroy().

Here is the caller graph for this function:

GNUNET_NETWORK_socket_connect()

enum GNUNET_GenericReturnValue GNUNET_NETWORK_socket_connect	(	const struct GNUNET_NETWORK_Handle *	desc,
		const struct sockaddr *	address,
		socklen_t	address_len
	)

Connect a socket to some remote address.

Parameters

desc	socket to connect
address	peer address
address_len	of address

Returns

GNUNET_OK on success, GNUNET_SYSERR otherwise

Parameters

desc	socket
address	peer address
address_len	length of address

Returns

GNUNET_OK on success, GNUNET_SYSERR otherwise

Definition at line 580 of file network.c.

{
  int ret;
 
  ret = connect (desc->fd,
                 address,
                 address_len);
 
  return ret == 0 ? GNUNET_OK : GNUNET_SYSERR;
}

Referenced by create_proto_queue(), GNUNET_CONNECTION_connect_socket(), GNUNET_CONNECTION_create_from_connect_to_unixpath(), main(), mq_init(), try_connect_using_address(), try_send_tcp(), and try_unixpath().

Here is the caller graph for this function:

GNUNET_NETWORK_socket_getsockopt()

enum GNUNET_GenericReturnValue GNUNET_NETWORK_socket_getsockopt	(	const struct GNUNET_NETWORK_Handle *	desc,
		int	level,
		int	optname,
		void *	optval,
		socklen_t *	optlen
	)

Get socket options.

Parameters

desc	socket to inspect
level	protocol level of the option
optname	identifier of the option
optval	options
optlen	length of optval

Returns

GNUNET_OK on success, GNUNET_SYSERR otherwise

Parameters

desc	socket
level	protocol level of the option
optname	identifier of the option
optval	options
optlen	length of optval

Returns

GNUNET_OK on success, GNUNET_SYSERR otherwise

Definition at line 580 of file network.c.

{
  int ret;
 
  ret = getsockopt (desc->fd,
                    level,
                    optname,
                    optval, optlen);
 
  return ret == 0 ? GNUNET_OK : GNUNET_SYSERR;
}

Referenced by connect_probe_continuation(), select_write_cb(), and unix_plugin_get_network().

Here is the caller graph for this function:

GNUNET_NETWORK_socket_listen()

enum GNUNET_GenericReturnValue GNUNET_NETWORK_socket_listen	(	const struct GNUNET_NETWORK_Handle *	desc,
		int	backlog
	)

Listen on a socket.

Parameters

desc	socket to start listening on
backlog	length of the listen queue

Returns

GNUNET_OK on success, GNUNET_SYSERR otherwise

Parameters

desc	socket
backlog	length of the listen queue

Returns

GNUNET_OK on success, GNUNET_SYSERR otherwise

Definition at line 580 of file network.c.

{
  int ret;
 
  ret = listen (desc->fd,
                backlog);
 
  return ret == 0 ? GNUNET_OK : GNUNET_SYSERR;
}

Referenced by create_listen_socket(), GNUNET_NAT_AUTO_test_start(), GNUNET_NAT_test_start(), init_socket(), open_listen_socket(), and run().

Here is the caller graph for this function:

GNUNET_NETWORK_socket_recvfrom_amount()

ssize_t GNUNET_NETWORK_socket_recvfrom_amount

(

const struct GNUNET_NETWORK_Handle *

desc

)

How much data is available to be read on this descriptor?

Parameters

desc

socket

Returns

GNUNET_SYSERR if no data is available, or on error!

Definition at line 671 of file network.c.

{
  int error;
 
  /* How much is there to be read? */
  int pending;
 
  error = ioctl (desc->fd,
                 FIONREAD,
                 &pending);
  if (0 == error)
    return (ssize_t) pending;
  return GNUNET_SYSERR;
}

References GNUNET_NETWORK_Handle::fd, GNUNET_SYSERR, and pending.

Referenced by read_dns4(), read_dns6(), and stun_read_task().

Here is the caller graph for this function:

GNUNET_NETWORK_socket_recvfrom()

ssize_t GNUNET_NETWORK_socket_recvfrom	(	const struct GNUNET_NETWORK_Handle *	desc,
		void *	buffer,
		size_t	length,
		struct sockaddr *	src_addr,
		socklen_t *	addrlen
	)

Read data from a socket (always non-blocking).

Parameters

desc	socket
buffer	buffer
length	length of buffer
src_addr	either the source to recv from, or all zeroes to be filled in by recvfrom
addrlen	length of the addr

Definition at line 688 of file network.c.

{
  int flags = 0;
 
#ifdef MSG_DONTWAIT
  flags |= MSG_DONTWAIT;
#endif
  return recvfrom (desc->fd,
                   buffer,
                   length,
                   flags,
                   src_addr,
                   addrlen);
}

References GNUNET_NETWORK_Handle::addrlen, and GNUNET_NETWORK_Handle::fd.

Referenced by do_dns_read(), read_dns4(), read_dns6(), select_read_cb(), sock_read(), stun_read_task(), udp_select_read(), and unix_plugin_do_read().

Here is the caller graph for this function:

GNUNET_NETWORK_socket_recv()

ssize_t GNUNET_NETWORK_socket_recv	(	const struct GNUNET_NETWORK_Handle *	desc,
		void *	buffer,
		size_t	length
	)

Read data from a connected socket (always non-blocking).

Parameters

desc	socket
buffer	buffer
length	length of buffer

Returns

number of bytes read

Parameters

desc	socket
buffer	buffer
length	length of buffer

Returns

number of bytes received, -1 on error

Definition at line 717 of file network.c.

{
  int ret;
  int flags;
 
  flags = 0;
 
#ifdef MSG_DONTWAIT
  flags |= MSG_DONTWAIT;
#endif
  ret = recv (desc->fd,
              buffer,
              length,
              flags);
  return ret;
}

References GNUNET_NETWORK_Handle::fd, and ret.

Referenced by do_read(), do_s5r_read(), do_udp_read(), proto_read_kx(), queue_read(), queue_read_kx(), and receive_ready().

Here is the caller graph for this function:

GNUNET_NETWORK_socket_select()

int GNUNET_NETWORK_socket_select	(	struct GNUNET_NETWORK_FDSet *	rfds,
		struct GNUNET_NETWORK_FDSet *	wfds,
		struct GNUNET_NETWORK_FDSet *	efds,
		const struct GNUNET_TIME_Relative	timeout
	)

Check if sockets meet certain conditions.

Parameters

rfds	set of sockets to be checked for readability
wfds	set of sockets to be checked for writability
efds	set of sockets to be checked for exceptions
timeout	relative value when to return

Returns

number of selected sockets, GNUNET_SYSERR on error

Check if sockets meet certain conditions.

Parameters

rfds	set of sockets or pipes to be checked for readability
wfds	set of sockets or pipes to be checked for writability
efds	set of sockets or pipes to be checked for exceptions
timeout	relative value when to return

Returns

number of selected sockets or pipes, GNUNET_SYSERR on error

Definition at line 1261 of file network.c.

{
  int nfds;
  struct timeval tv;
 
  if (NULL != rfds)
    nfds = rfds->nsds;
  else
    nfds = 0;
  if (NULL != wfds)
    nfds = GNUNET_MAX (nfds,
                       wfds->nsds);
  if (NULL != efds)
    nfds = GNUNET_MAX (nfds,
                       efds->nsds);
  if ((0 == nfds) &&
      (timeout.rel_value_us == GNUNET_TIME_UNIT_FOREVER_REL.rel_value_us))
  {
    GNUNET_break (0);
    LOG (GNUNET_ERROR_TYPE_ERROR,
         _ (
           "Fatal internal logic error, process hangs in `%s' (abort with CTRL-C)!\n"),
         "select");
  }
  if (timeout.rel_value_us / GNUNET_TIME_UNIT_SECONDS.rel_value_us > (unsigned
                                                                      long long)
      LONG_MAX)
  {
    tv.tv_sec = LONG_MAX;
    tv.tv_usec = 999999L;
  }
  else
  {
    tv.tv_sec = (long) (timeout.rel_value_us
                        / GNUNET_TIME_UNIT_SECONDS.rel_value_us);
    tv.tv_usec =
      (timeout.rel_value_us
       - (tv.tv_sec * GNUNET_TIME_UNIT_SECONDS.rel_value_us));
  }
  return select (nfds,
                 (NULL != rfds) ? &rfds->sds : NULL,
                 (NULL != wfds) ? &wfds->sds : NULL,
                 (NULL != efds) ? &efds->sds : NULL,
                 (timeout.rel_value_us ==
                  GNUNET_TIME_UNIT_FOREVER_REL.rel_value_us) ? NULL : &tv);
}

References _, GNUNET_break, GNUNET_ERROR_TYPE_ERROR, GNUNET_MAX, GNUNET_TIME_UNIT_FOREVER_REL, GNUNET_TIME_UNIT_SECONDS, LOG, GNUNET_NETWORK_FDSet::nsds, GNUNET_TIME_Relative::rel_value_us, GNUNET_NETWORK_FDSet::sds, and timeout.

Referenced by main(), and select_loop().

Here is the caller graph for this function:

GNUNET_NETWORK_socket_send()

ssize_t GNUNET_NETWORK_socket_send	(	const struct GNUNET_NETWORK_Handle *	desc,
		const void *	buffer,
		size_t	length
	)

Send data (always non-blocking).

Parameters

desc	socket
buffer	data to send
length	size of the buffer

Returns

number of bytes sent, GNUNET_SYSERR on error

Definition at line 738 of file network.c.

{
  int ret;
  int flags;
 
  flags = 0;
#ifdef MSG_DONTWAIT
  flags |= MSG_DONTWAIT;
#endif
#ifdef MSG_NOSIGNAL
  flags |= MSG_NOSIGNAL;
#endif
  ret = send (desc->fd,
              buffer,
              length,
              flags);
  return ret;
}

References GNUNET_NETWORK_Handle::fd, and ret.

Referenced by do_send(), do_write(), main(), proto_queue_write(), queue_write(), recv_message(), tcp_send(), and transmit_ready().

Here is the caller graph for this function:

GNUNET_NETWORK_socket_sendto()

ssize_t GNUNET_NETWORK_socket_sendto	(	const struct GNUNET_NETWORK_Handle *	desc,
		const void *	message,
		size_t	length,
		const struct sockaddr *	dest_addr,
		socklen_t	dest_len
	)

Send data to a particular destination (always non-blocking).

This function only works for UDP sockets.

Parameters

desc	socket
message	data to send
length	size of the data in message
dest_addr	destination address
dest_len	length of dest_addr

Returns

number of bytes sent, GNUNET_SYSERR on error

This function only works for UDP sockets.

Parameters

desc	socket
message	data to send
length	size of the message
dest_addr	destination address
dest_len	length of address

Returns

number of bytes sent, GNUNET_SYSERR on error

Definition at line 772 of file network.c.

{
  int flags = 0;
 
#ifdef MSG_DONTWAIT
  flags |= MSG_DONTWAIT;
#endif
#ifdef MSG_NOSIGNAL
  flags |= MSG_NOSIGNAL;
#endif
  return sendto (desc->fd,
                 message,
                 length,
                 flags,
                 dest_addr,
                 dest_len);
}

References GNUNET_NETWORK_Handle::fd.

Referenced by flush_egress(), ifc_broadcast(), ip_send(), mq_send_d(), select_write_cb(), send_msg_with_kx(), send_response(), sock_read(), stun_dns_callback(), transmit_query(), try_send_udp(), udp_ipv4_broadcast_send(), udp_ipv6_broadcast_send(), udp_select_send(), and unix_plugin_get_network().

Here is the caller graph for this function:

GNUNET_NETWORK_socket_setsockopt()

int GNUNET_NETWORK_socket_setsockopt	(	struct GNUNET_NETWORK_Handle *	fd,
		int	level,
		int	option_name,
		const void *	option_value,
		socklen_t	option_len
	)

Set socket option.

Parameters

fd	socket
level	protocol level of the option
option_name	option identifier
option_value	value to set
option_len	size of option_value

Returns

GNUNET_OK on success, GNUNET_SYSERR otherwise

Definition at line 806 of file network.c.

{
  return (0 == setsockopt (fd->fd,
                           level,
                           option_name,
                           option_value,
                           option_len))
    ? GNUNET_OK
    : GNUNET_SYSERR;
}

References GNUNET_NETWORK_Handle::fd, GNUNET_OK, and GNUNET_SYSERR.

Referenced by bi_destroy(), create_listen_socket(), iface_proc(), ifc_broadcast(), libgnunet_plugin_transport_tcp_init(), select_write_cb(), setup_broadcast(), tcp_plugin_get_session(), and unix_plugin_get_network().

Here is the caller graph for this function:

GNUNET_NETWORK_socket_shutdown()

enum GNUNET_GenericReturnValue GNUNET_NETWORK_socket_shutdown	(	struct GNUNET_NETWORK_Handle *	desc,
		int	how
	)

Shut down socket operations.

Parameters

desc	socket
how	type of shutdown

Returns

GNUNET_OK on success, GNUNET_SYSERR otherwise

Definition at line 833 of file network.c.

{
  int ret;
 
  ret = shutdown (desc->fd, how);
 
  return (0 == ret) ? GNUNET_OK : GNUNET_SYSERR;
}

Referenced by GNUNET_CONNECTION_create_from_accept(), GNUNET_CONNECTION_destroy(), signal_transmit_error(), and tcp_send().

Here is the caller graph for this function:

GNUNET_NETWORK_socket_disable_corking()

enum GNUNET_GenericReturnValue GNUNET_NETWORK_socket_disable_corking

(

struct GNUNET_NETWORK_Handle *

desc

)

Disable the "CORK" feature for communication with the given socket, forcing the OS to immediately flush the buffer on transmission instead of potentially buffering multiple messages.

Essentially reduces the OS send buffers to zero.

Parameters

desc

socket

Returns

GNUNET_OK on success, GNUNET_SYSERR otherwise

Definition at line 833 of file network.c.

{
  int ret = 0;
 
#ifdef __linux__
  int value = 0;
 
  if (0 !=
      (ret =
         setsockopt (desc->fd,
                     SOL_SOCKET,
                     SO_SNDBUF,
                     &value,
                     sizeof(value))))
    LOG_STRERROR (GNUNET_ERROR_TYPE_WARNING,
                  "setsockopt");
  if (0 !=
      (ret =
         setsockopt (desc->fd,
                     SOL_SOCKET,
                     SO_RCVBUF,
                     &value,
                     sizeof(value))))
    LOG_STRERROR (GNUNET_ERROR_TYPE_WARNING,
                  "setsockopt");
#endif
  return ret == 0 ? GNUNET_OK : GNUNET_SYSERR;
}

Referenced by GNUNET_CONNECTION_disable_corking().

Here is the caller graph for this function:

GNUNET_NETWORK_socket_create()

struct GNUNET_NETWORK_Handle* GNUNET_NETWORK_socket_create	(	int	domain,
		int	type,
		int	protocol
	)

Create a new socket.

Configure it for non-blocking IO and mark it as non-inheritable to child processes (set the close-on-exec flag).

Parameters

domain	domain of the socket
type	socket type
protocol	network protocol

Returns

new socket, NULL on error

Definition at line 833 of file network.c.

{
  struct GNUNET_NETWORK_Handle *ret;
  int fd;
 
  fd = socket (domain, type, protocol);
  if (-1 == fd)
    return NULL;
  ret = GNUNET_new (struct GNUNET_NETWORK_Handle);
  ret->fd = fd;
  if (GNUNET_OK !=
      initialize_network_handle (ret,
                                 domain,
                                 type))
    return NULL;
  return ret;
}

References GNUNET_NETWORK_Handle::fd, GNUNET_new, GNUNET_OK, initialize_network_handle(), ret, and type.

Referenced by bind_v4(), bind_v6(), create_listen_socket(), create_proto_queue(), get_server_addresses(), GNUNET_CONNECTION_create_from_connect_to_unixpath(), GNUNET_CONNECTION_create_from_sockaddr(), GNUNET_NAT_AUTO_test_start(), GNUNET_NAT_test_start(), GNUNET_NETWORK_test_port_free(), GNUNET_TESTING_reserve_port(), init_socket(), LEGACY_SERVICE_get_server_addresses(), main(), mq_init(), open_listen_socket(), open_socket(), run(), server_check_ipv6_support(), setup_sockets(), tcp_plugin_get_session(), try_connect_using_address(), try_send_tcp(), try_send_udp(), try_unixpath(), and unix_transport_server_start().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_NETWORK_fdset_zero()

void GNUNET_NETWORK_fdset_zero

(

struct GNUNET_NETWORK_FDSet *

fds

)

Reset FD set (clears all file descriptors).

Parameters

fds	fd set to clear

Reset FD set (clears all file descriptors).

Parameters

fds

fd set

Definition at line 918 of file network.c.

{
  FD_ZERO (&fds->sds);
  fds->nsds = 0;
}

References GNUNET_NETWORK_FDSet::nsds, and GNUNET_NETWORK_FDSet::sds.

Referenced by GNUNET_NETWORK_fdset_create(), GNUNET_SCHEDULER_do_work(), main(), and select_loop().

Here is the caller graph for this function:

GNUNET_NETWORK_fdset_set()

void GNUNET_NETWORK_fdset_set	(	struct GNUNET_NETWORK_FDSet *	fds,
		const struct GNUNET_NETWORK_Handle *	desc
	)

Add a socket to the FD set.

Parameters

fds	fd set
desc	socket to add

Definition at line 932 of file network.c.

{
  FD_SET (desc->fd,
          &fds->sds);
  fds->nsds = GNUNET_MAX (fds->nsds,
                          desc->fd + 1);
}

References GNUNET_NETWORK_Handle::fd, GNUNET_MAX, GNUNET_NETWORK_FDSet::nsds, and GNUNET_NETWORK_FDSet::sds.

Referenced by GNUNET_SERVER_resume(), main(), and schedule_read().

Here is the caller graph for this function:

GNUNET_NETWORK_fdset_isset()

int GNUNET_NETWORK_fdset_isset	(	const struct GNUNET_NETWORK_FDSet *	fds,
		const struct GNUNET_NETWORK_Handle *	desc
	)

Check whether a socket is part of the fd set.

Parameters

fds	fd set
desc	socket

Returns

GNUNET_YES if the socket is in the set

Parameters

fds	fd set
desc	socket

Returns

0 if the FD is not set

Definition at line 950 of file network.c.

{
  return FD_ISSET (desc->fd,
                   &fds->sds);
}

References GNUNET_NETWORK_Handle::fd, and GNUNET_NETWORK_FDSet::sds.

Referenced by do_read(), do_s5r_read(), do_udp_read(), main(), process_listen_socket(), read_response(), receive_ready(), tcp_send(), transmit_ready(), udp_plugin_select_v4(), and udp_plugin_select_v6().

Here is the caller graph for this function:

GNUNET_NETWORK_fdset_add()

void GNUNET_NETWORK_fdset_add	(	struct GNUNET_NETWORK_FDSet *	dst,
		const struct GNUNET_NETWORK_FDSet *	src
	)

Add one fd set to another (computes the union).

Parameters

dst	the fd set to add to
src	the fd set to add from

Add one fd set to another (computes the union).

Parameters

dst	the fd set to add to
src	the fd set to add from

Definition at line 965 of file network.c.

{
  int nfds;
 
  for (nfds = src->nsds; nfds >= 0; nfds--)
    if (FD_ISSET (nfds, &src->sds))
      FD_SET (nfds, &dst->sds);
  dst->nsds = GNUNET_MAX (dst->nsds,
                          src->nsds);
}

References GNUNET_MAX, GNUNET_NETWORK_FDSet::nsds, and GNUNET_NETWORK_FDSet::sds.

GNUNET_NETWORK_fdset_copy()

void GNUNET_NETWORK_fdset_copy	(	struct GNUNET_NETWORK_FDSet *	to,
		const struct GNUNET_NETWORK_FDSet *	from
	)

Copy one fd set to another.

Parameters

to	destination
from	source

Definition at line 985 of file network.c.

{
  FD_COPY (&from->sds,
           &to->sds);
  to->nsds = from->nsds;
}

References FD_COPY, GNUNET_NETWORK_FDSet::nsds, and GNUNET_NETWORK_FDSet::sds.

GNUNET_NETWORK_get_fd()

int GNUNET_NETWORK_get_fd

(

const struct GNUNET_NETWORK_Handle *

desc

)

Return file descriptor for this network handle.

Parameters

desc	wrapper to process

Returns

POSIX file descriptor

Definition at line 1001 of file network.c.

{
  return desc->fd;
}

References GNUNET_NETWORK_Handle::fd.

Referenced by add_without_sets(), do_accept(), do_dns_read(), GNUNET_CONNECTION_create_from_accept(), GNUNET_SCHEDULER_add_net_with_priority(), init_fd_info(), init_socket(), mhd_connection_cb(), queue_destroy(), read_cb(), run(), setup_data_transfer(), and start_process().

Here is the caller graph for this function:

GNUNET_NETWORK_get_addr()

struct sockaddr* GNUNET_NETWORK_get_addr

(

const struct GNUNET_NETWORK_Handle *

desc

)

Return the sockaddr for this network handle.

Parameters

desc	wrapper to process

Returns

POSIX file descriptor

Return the sockaddr for this network handle.

Parameters

desc	wrapper to process

Returns

sockaddr

Definition at line 1014 of file network.c.

{
  return desc->addr;
}

References GNUNET_NETWORK_Handle::addr.

Referenced by do_accept(), and setup_data_transfer().

Here is the caller graph for this function:

GNUNET_NETWORK_get_addrlen()

socklen_t GNUNET_NETWORK_get_addrlen

(

const struct GNUNET_NETWORK_Handle *

desc

)

Return sockaddr length for this network handle.

Parameters

desc	wrapper to process

Returns

socklen_t for sockaddr

Definition at line 1027 of file network.c.

{
  return desc->addrlen;
}

References GNUNET_NETWORK_Handle::addrlen.

Referenced by do_accept(), and setup_data_transfer().

Here is the caller graph for this function:

GNUNET_NETWORK_fdset_copy_native()

void GNUNET_NETWORK_fdset_copy_native	(	struct GNUNET_NETWORK_FDSet *	to,
		const fd_set *	from,
		int	nfds
	)

Copy a native fd set into the GNUnet representation.

Parameters

to	destination
from	native source set
nfds	the biggest socket number in from + 1

Copy a native fd set into the GNUnet representation.

Parameters

to	destination
from	native source set
nfds	the biggest socket number in from + 1

Definition at line 1041 of file network.c.

{
  FD_COPY (from,
           &to->sds);
  to->nsds = nfds;
}

References FD_COPY, GNUNET_NETWORK_FDSet::nsds, and GNUNET_NETWORK_FDSet::sds.

Referenced by client_schedule(), context_task(), curl_download_prepare(), download_prepare(), prepare_daemon(), run_httpd(), schedule_httpd(), and server_schedule().

Here is the caller graph for this function:

GNUNET_NETWORK_fdset_set_native()

void GNUNET_NETWORK_fdset_set_native	(	struct GNUNET_NETWORK_FDSet *	to,
		int	nfd
	)

Set a native fd in a set.

Parameters

to	destination
nfd	native FD to set

Definition at line 1058 of file network.c.

{
  GNUNET_assert ((nfd >= 0) && (nfd < FD_SETSIZE));
  FD_SET (nfd, &to->sds);
  to->nsds = GNUNET_MAX (nfd + 1,
                         to->nsds);
}

References GNUNET_assert, GNUNET_MAX, GNUNET_NETWORK_FDSet::nsds, and GNUNET_NETWORK_FDSet::sds.

Referenced by GNUNET_SCHEDULER_do_work(), listen_stdio(), and select_loop().

Here is the caller graph for this function:

GNUNET_NETWORK_fdset_test_native()

int GNUNET_NETWORK_fdset_test_native	(	const struct GNUNET_NETWORK_FDSet *	to,
		int	nfd
	)

Test native fd in a set.

Parameters

to	set to test, NULL for empty set
nfd	native FD to test, -1 for none

Returns

GNUNET_YES if to contains nfd

Parameters

to	set to test, NULL for empty set
nfd	native FD to test, or -1 for none

Returns

GNUNET_YES if FD is set in the set

Definition at line 1076 of file network.c.

{
  if ((-1 == nfd) ||
      (NULL == to))
    return GNUNET_NO;
  return FD_ISSET (nfd, &to->sds) ? GNUNET_YES : GNUNET_NO;
}

References GNUNET_NO, GNUNET_YES, and GNUNET_NETWORK_FDSet::sds.

Referenced by extract_handles(), and select_loop().

Here is the caller graph for this function:

GNUNET_NETWORK_fdset_handle_set()

void GNUNET_NETWORK_fdset_handle_set	(	struct GNUNET_NETWORK_FDSet *	fds,
		const struct GNUNET_DISK_FileHandle *	h
	)

Add a file handle to the fd set.

Parameters

fds	fd set
h	the file handle to add

Definition at line 1092 of file network.c.

{
  int fd;
 
  GNUNET_assert (GNUNET_OK ==
                 GNUNET_DISK_internal_file_handle_ (h,
                                                    &fd,
                                                    sizeof(int)));
  FD_SET (fd,
          &fds->sds);
  fds->nsds = GNUNET_MAX (fd + 1,
                          fds->nsds);
}

References GNUNET_assert, GNUNET_DISK_internal_file_handle_(), GNUNET_MAX, GNUNET_OK, h, GNUNET_NETWORK_FDSet::nsds, and GNUNET_NETWORK_FDSet::sds.

Referenced by GNUNET_NETWORK_fdset_handle_set_first(), GNUNET_SCHEDULER_driver_init(), and main().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_NETWORK_fdset_handle_set_first()

void GNUNET_NETWORK_fdset_handle_set_first	(	struct GNUNET_NETWORK_FDSet *	fds,
		const struct GNUNET_DISK_FileHandle *	h
	)

Add a file handle to the fd set On W32: ensure that the handle is first in the array.

Parameters

fds	fd set
h	the file handle to add

Add a file handle to the fd set On W32: ensure that the handle is first in the array.

Parameters

fds	fd set
h	the file handle to add

Definition at line 1114 of file network.c.

{
  GNUNET_NETWORK_fdset_handle_set (fds, h);
}

References GNUNET_NETWORK_fdset_handle_set(), and h.

Here is the call graph for this function:

GNUNET_NETWORK_fdset_handle_isset()

int GNUNET_NETWORK_fdset_handle_isset	(	const struct GNUNET_NETWORK_FDSet *	fds,
		const struct GNUNET_DISK_FileHandle *	h
	)

Check if a file handle is part of an fd set.

Parameters

fds	fd set
h	file handle

Returns

GNUNET_YES if the file handle is part of the set

Definition at line 1129 of file network.c.

{
  return FD_ISSET (h->fd,
                   &fds->sds);
}

References h, and GNUNET_NETWORK_FDSet::sds.

Referenced by cmd_read().

Here is the caller graph for this function:

GNUNET_NETWORK_fdset_overlap()

int GNUNET_NETWORK_fdset_overlap	(	const struct GNUNET_NETWORK_FDSet *	fds1,
		const struct GNUNET_NETWORK_FDSet *	fds2
	)

Checks if two fd sets overlap.

Parameters

fds1	first fd set
fds2	second fd set

Returns

GNUNET_YES if they do overlap, GNUNET_NO otherwise

Definition at line 1145 of file network.c.

{
  int nfds;
 
  nfds = GNUNET_MIN (fds1->nsds,
                     fds2->nsds);
  while (nfds > 0)
  {
    nfds--;
    if ((FD_ISSET (nfds,
                   &fds1->sds)) &&
        (FD_ISSET (nfds,
                   &fds2->sds)))
      return GNUNET_YES;
  }
  return GNUNET_NO;
}

References GNUNET_MIN, GNUNET_NO, GNUNET_YES, GNUNET_NETWORK_FDSet::nsds, and GNUNET_NETWORK_FDSet::sds.

GNUNET_NETWORK_fdset_create()

struct GNUNET_NETWORK_FDSet* GNUNET_NETWORK_fdset_create

(

void

)

Creates an fd set.

Returns

a new fd set

Definition at line 1171 of file network.c.

{
  struct GNUNET_NETWORK_FDSet *fds;
 
  fds = GNUNET_new (struct GNUNET_NETWORK_FDSet);
  GNUNET_NETWORK_fdset_zero (fds);
  return fds;
}

References GNUNET_NETWORK_fdset_zero(), and GNUNET_new.

Referenced by client_schedule(), context_task(), curl_download_prepare(), download_prepare(), GNUNET_SCHEDULER_driver_init(), GNUNET_SERVER_resume(), listen_stdio(), main(), prepare_daemon(), run_httpd(), schedule_httpd(), schedule_read(), select_loop(), and server_schedule().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_NETWORK_fdset_destroy()

void GNUNET_NETWORK_fdset_destroy

(

struct GNUNET_NETWORK_FDSet *

fds

)

Releases the associated memory of an fd set.

Parameters

fds

fd set

Definition at line 1187 of file network.c.

{
  GNUNET_free (fds);
}

References GNUNET_free.

Referenced by client_schedule(), context_task(), curl_download_prepare(), download_prepare(), GNUNET_SCHEDULER_driver_done(), GNUNET_SERVER_resume(), listen_stdio(), prepare_daemon(), run_httpd(), schedule_httpd(), schedule_read(), select_loop(), and server_schedule().

Here is the caller graph for this function:

GNUNET_NETWORK_test_port_free()

int GNUNET_NETWORK_test_port_free	(	int	ipproto,
		uint16_t	port
	)

Test if the given port is available.

Parameters

ipproto	transport protocol to test (e.g. IPPROTO_TCP)
port	port number to test

Returns

GNUNET_OK if the port is available, GNUNET_NO if not

Definition at line 1201 of file network.c.

{
  struct GNUNET_NETWORK_Handle *socket;
  int bind_status;
  int socktype;
  char open_port_str[6];
  struct addrinfo hint;
  struct addrinfo *ret;
  struct addrinfo *ai;
 
  GNUNET_snprintf (open_port_str,
                   sizeof(open_port_str),
                   "%u",
                   (unsigned int) port);
  socktype = (IPPROTO_TCP == ipproto) ? SOCK_STREAM : SOCK_DGRAM;
  ret = NULL;
  memset (&hint, 0, sizeof(hint));
  hint.ai_family = AF_UNSPEC; /* IPv4 and IPv6 */
  hint.ai_socktype = socktype;
  hint.ai_protocol = ipproto;
  hint.ai_addrlen = 0;
  hint.ai_addr = NULL;
  hint.ai_canonname = NULL;
  hint.ai_next = NULL;
  hint.ai_flags = AI_PASSIVE | AI_NUMERICSERV; /* Wild card address */
  GNUNET_assert (0 == getaddrinfo (NULL,
                                   open_port_str,
                                   &hint,
                                   &ret));
  bind_status = GNUNET_NO;
  for (ai = ret; NULL != ai; ai = ai->ai_next)
  {
    socket = GNUNET_NETWORK_socket_create (ai->ai_family,
                                           ai->ai_socktype,
                                           ai->ai_protocol);
    if (NULL == socket)
      continue;
    bind_status = GNUNET_NETWORK_socket_bind (socket,
                                              ai->ai_addr,
                                              ai->ai_addrlen);
    GNUNET_NETWORK_socket_close (socket);
    if (GNUNET_OK != bind_status)
      break;
  }
  freeaddrinfo (ret);
  return bind_status;
}

References ai, AI_NUMERICSERV, GNUNET_assert, GNUNET_NETWORK_socket_bind(), GNUNET_NETWORK_socket_close(), GNUNET_NETWORK_socket_create(), GNUNET_NO, GNUNET_OK, GNUNET_snprintf(), port, and ret.

Here is the call graph for this function: