Tor
0.4.7.0-alpha-dev
|
Compatibility and utility functions for working with network sockets. More...
#include "lib/net/socket.h"
#include "lib/net/socketpair.h"
#include "lib/net/address.h"
#include "lib/cc/compat_compiler.h"
#include "lib/err/torerr.h"
#include "lib/lock/compat_mutex.h"
#include "lib/log/log.h"
#include "lib/log/util_bug.h"
#include <stddef.h>
#include <string.h>
Go to the source code of this file.
Macros | |
#define | mark_socket_open(s) ((void) (s)) |
#define | mark_socket_closed(s) ((void) (s)) |
Functions | |
int | network_init (void) |
void | check_network_configuration (bool server_mode) |
int | get_max_sockets (void) |
void | set_max_sockets (int n) |
static void | socket_accounting_lock (void) |
static void | socket_accounting_unlock (void) |
int | tor_close_socket_simple (tor_socket_t s) |
int | tor_close_socket (tor_socket_t s) |
tor_socket_t | tor_open_socket (int domain, int type, int protocol) |
tor_socket_t | tor_connect_socket (tor_socket_t sock, const struct sockaddr *address, socklen_t address_len) |
tor_socket_t | tor_open_socket_nonblocking (int domain, int type, int protocol) |
tor_socket_t | tor_open_socket_with_extensions (int domain, int type, int protocol, int cloexec, int nonblock) |
void | tor_take_socket_ownership (tor_socket_t s) |
void | tor_release_socket_ownership (tor_socket_t s) |
tor_socket_t | tor_accept_socket (tor_socket_t sockfd, struct sockaddr *addr, socklen_t *len) |
tor_socket_t | tor_accept_socket_nonblocking (tor_socket_t sockfd, struct sockaddr *addr, socklen_t *len) |
tor_socket_t | tor_accept_socket_with_extensions (tor_socket_t sockfd, struct sockaddr *addr, socklen_t *len, int cloexec, int nonblock) |
int | get_n_open_sockets (void) |
int | tor_socketpair (int family, int type, int protocol, tor_socket_t fd[2]) |
int | tor_getsockname (tor_socket_t sock, struct sockaddr *address, socklen_t *address_len) |
int | tor_addr_from_getsockname (struct tor_addr_t *addr_out, tor_socket_t sock) |
int | set_socket_nonblocking (tor_socket_t sock) |
ssize_t | read_all_from_socket (tor_socket_t sock, char *buf, size_t count) |
ssize_t | write_all_to_socket (tor_socket_t fd, const char *buf, size_t count) |
Variables | |
static int | max_sockets = 1024 |
static int | n_sockets_open = 0 |
static tor_mutex_t * | socket_accounting_mutex = NULL |
Compatibility and utility functions for working with network sockets.
Definition in file socket.c.
void check_network_configuration | ( | bool | server_mode | ) |
int get_max_sockets | ( | void | ) |
Return the maximum number of allowed sockets.
Definition at line 98 of file socket.c.
Referenced by fill_socket_values(), and socket_failed_from_resource_exhaustion().
int get_n_open_sockets | ( | void | ) |
Return the number of sockets we currently have opened.
Definition at line 440 of file socket.c.
Referenced by fill_socket_values(), and tor_accept_socket_with_extensions().
int network_init | ( | void | ) |
ssize_t read_all_from_socket | ( | tor_socket_t | sock, |
char * | buf, | ||
size_t | count | ||
) |
void set_max_sockets | ( | int | n | ) |
int set_socket_nonblocking | ( | tor_socket_t | sock | ) |
|
inlinestatic |
Helper: acquire the socket accounting lock.
Definition at line 130 of file socket.c.
Referenced by get_n_open_sockets(), tor_close_socket(), tor_release_socket_ownership(), and tor_take_socket_ownership().
|
inlinestatic |
Helper: release the socket accounting lock.
Definition at line 139 of file socket.c.
Referenced by get_n_open_sockets().
tor_socket_t tor_accept_socket | ( | tor_socket_t | sockfd, |
struct sockaddr * | addr, | ||
socklen_t * | len | ||
) |
tor_socket_t tor_accept_socket_nonblocking | ( | tor_socket_t | sockfd, |
struct sockaddr * | addr, | ||
socklen_t * | len | ||
) |
tor_socket_t tor_accept_socket_with_extensions | ( | tor_socket_t | sockfd, |
struct sockaddr * | addr, | ||
socklen_t * | len, | ||
int | cloexec, | ||
int | nonblock | ||
) |
As accept(), but counts the number of open sockets and handles socket creation with either of SOCK_CLOEXEC and SOCK_NONBLOCK specified. cloexec and nonblock should be either 0 or 1 to indicate if the corresponding extension should be used.
Definition at line 377 of file socket.c.
Referenced by tor_accept_socket(), and tor_accept_socket_nonblocking().
int tor_addr_from_getsockname | ( | struct tor_addr_t * | addr_out, |
tor_socket_t | sock | ||
) |
Find the local address associated with the socket sock, and place it in *addr_out. Return 0 on success, -1 on failure.
(As tor_getsockname, but instead places the result in a tor_addr_t.)
Definition at line 544 of file socket.c.
Referenced by client_check_address_changed().
int tor_close_socket | ( | tor_socket_t | s | ) |
As tor_close_socket_simple(), but keeps track of the number of open sockets. Returns 0 on success, -1 on failure.
Definition at line 217 of file socket.c.
Referenced by alert_sockets_close().
int tor_close_socket_simple | ( | tor_socket_t | s | ) |
As close(), but guaranteed to work for sockets across platforms (including Windows, where close()ing a socket doesn't work. Returns 0 on success and the socket error code on failure.
Definition at line 148 of file socket.c.
Referenced by tor_close_socket().
tor_socket_t tor_connect_socket | ( | tor_socket_t | sock, |
const struct sockaddr * | address, | ||
socklen_t | address_len | ||
) |
int tor_getsockname | ( | tor_socket_t | sock, |
struct sockaddr * | address, | ||
socklen_t * | address_len | ||
) |
Mockable wrapper for getsockname().
Definition at line 533 of file socket.c.
Referenced by tor_addr_from_getsockname().
tor_socket_t tor_open_socket | ( | int | domain, |
int | type, | ||
int | protocol | ||
) |
As socket(), but counts the number of open sockets.
Definition at line 243 of file socket.c.
Referenced by get_interface_address6_via_udp_socket_hack().
tor_socket_t tor_open_socket_nonblocking | ( | int | domain, |
int | type, | ||
int | protocol | ||
) |
As socket(), but creates a nonblocking socket and counts the number of open sockets.
Definition at line 259 of file socket.c.
Referenced by tor_tls_release_socket().
tor_socket_t tor_open_socket_with_extensions | ( | int | domain, |
int | type, | ||
int | protocol, | ||
int | cloexec, | ||
int | nonblock | ||
) |
void tor_release_socket_ownership | ( | tor_socket_t | s | ) |
int tor_socketpair | ( | int | family, |
int | type, | ||
int | protocol, | ||
tor_socket_t | fd[2] | ||
) |
Allocate a pair of connected sockets. (Like socketpair(family, type,protocol,fd), but works on systems that don't have socketpair.)
Currently, only (AF_UNIX, SOCK_STREAM, 0) sockets are supported.
Note that on systems without socketpair, this call will fail if localhost is inaccessible (for example, if the networking stack is down). And even if it succeeds, the socket pair will not be able to read while localhost is down later (the socket pair may even close, depending on OS-specific timeouts). The socket pair should work on IPv4-only, IPv6-only, and dual-stack systems, as long as they have the standard localhost addresses.
Returns 0 on success and -errno on failure; do not rely on the value of errno or WSAGetLastError().
void tor_take_socket_ownership | ( | tor_socket_t | s | ) |
ssize_t write_all_to_socket | ( | tor_socket_t | fd, |
const char * | buf, | ||
size_t | count | ||
) |
|
static |
Count of number of sockets currently open. (Undercounts sockets opened by eventdns and libevent.)
Definition at line 123 of file socket.c.
Referenced by get_n_open_sockets(), tor_release_socket_ownership(), and tor_take_socket_ownership().
|
static |
Mutex to protect open_sockets, max_socket, and n_sockets_open.
Definition at line 126 of file socket.c.
Referenced by socket_accounting_unlock().