src/network.c File Reference

#include "copyright.h"
#include "config.h"
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <sys/file.h>
#include <sys/ioctl.h>
#include <sys/wait.h>
#include <signal.h>
#include <errno.h>
#include <netdb.h>
#include <arpa/inet.h>
#include "externs.h"

Include dependency graph for network.c:

Go to the source code of this file.

Data Structures
struct	listening_socket_t
Functions
int	network_init (int port)
static void	network_accept_client (int fd, short event, void *arg)
static int	network_bind_port (struct sockaddr *addr, int salen)
static void	network_make_nonblocking (int socket)
static void	network_make_blocking (int socket)
DESC *	network_initialize_socket (int socket, struct sockaddr *saddr, int addrlen)
void	network_choke_socket (DESC *desc)
void	network_release_socket (DESC *desc)
static void	network_client_input (int fd, short event, void *arg)
void	network_write (DESC *client, char *buffer, int length)
Variables
listening_socket_t *	listening_sockets
DESC *	descriptor_list = NULL

---

Function Documentation

static void network_accept_client	(	int	fd,
		short	event,
		void *	arg
	)			[static]

Definition at line 207 of file network.c.

References desc, log_printf(), and network_initialize_socket().

Referenced by network_bind_port().

{
        int newfd;
        struct sockaddr_storage addr;
        unsigned int addrlen = sizeof(struct sockaddr_storage);
        struct descriptor_data *desc;

        newfd = accept(fd, (struct sockaddr *) addr, &addrlen);
        if(newfd < 0) {
                log_printf("network] accept on %d failed with '%s'", fd,
                                   strerror(errno));
                return;
        }
        desc = network_initialize_socket(newfd, addr, addrlen);
        log_printf("network] connection from %s %d", desc->ip, desc->port);
}

static int network_bind_port	(	struct sockaddr *	addr,
		int	salen
	)			[static]

Definition at line 39 of file network.c.

References listening_socket_t::addr, listening_socket_t::ev, listening_socket_t::fd, listening_sockets, log_perror(), network_accept_client(), network_make_nonblocking(), listening_socket_t::next, and listening_socket_t::salen.

Referenced by network_init().

{
        int one = 1;
        struct listening_socket_t *lst = NULL;

        lst = malloc(sizeof(struct listening_socket_t));
        memset(lst, 0, sizeof(struct listening_socket_t));

        lst->fd = socket(addr->sa_family, SOCK_STREAM, 0);
        if(lst->fd < 0) {
                log_perror("NET", "FAIL", "network_bind_port", "socket");
                goto error;
        }

        if(setsockopt(lst->fd, SOL_SOCKET, SO_REUSEADDR, &one, sizeof(one)) < 0) {
                log_perror("NET", "WARN", "network_bind_port", "setsockopt");
        }

        memcpy(&lst->addr, addr, salen);
        lst->salen = salen;

        if(bind(lst->fd, (struct sockaddr *) &lst->addr, lst->salen) < 0) {
                log_perror("NET", "FAIL", "network_bind_port", "bind");
                goto error;
        }

        if(listen(lst->fd, 0) < 0) {
                log_perror("NET", "FAIL", "network_bind_port", "listen");
                goto error;
        }

        network_make_nonblocking(lst->fd);

        event_set(&lst->ev, lst->fd, EV_READ | EV_PERSIST, network_accept_client,
                          lst);
        event_add(&lst->ev, NULL);

        lst->next = listening_sockets;
        listening_sockets = lst;
        return 1;

  error:
        if(lst->fd >= 0) {
                close(lst->fd);
        }
        memset(lst, 0, sizeof(struct listening_socket_t));
        return 0;
}

void network_choke_socket

(

DESC *

desc

)

Definition at line 172 of file network.c.

References desc.

{
        int eins = 1;

        if(desc->chokes == 0) {
#if defined(TCP_CORK)                   // Linux 2.4, 2.6
                setsockopt(d->fd, IPPROTO_TCP, TCP_CORK, &eins, sizeof(eins));
#elif defined(TCP_NOPUSH)               // *BSD, Mac OS X
                setsockopt(d->fd, IPPROTO_TCP, TCP_NOPUSH, &eins, sizeof(eins));
#else // else
                /* Nothing! */
#endif
        }
        desc->chokes++;
}

static void network_client_input	(	int	fd,
		short	event,
		void *	arg
	)			[static]

Definition at line 281 of file network.c.

References dprintk, descriptor_data::fd, handle_errno, and telnet_read_ring().

{
        struct DESC *client = (DESC *) arg;
        int avail, net_length;

        dprintk("fd = %d, head = %d, tail = %d", client->fd, client->ringhead,
                        client->ringtail);
        if(client->ringtail < client->ringhead) {
                avail = client->ringhead - client->ringtail;
                handle_errno(net_length = read(client->fd,
                                                                           client->ringbuffer + client->ringtail,
                                                                           avail));
        } else {
                if(client->ringhead == 0) {
                        avail = RING_LENGTH - client->ringtail;
                        handle_errno(net_length = read(client->fd,
                                                                                   client->ringbuffer +
                                                                                   client->ringtail, avail));
                        client->ringtail = (client->ringtail + net_length) % RING_LENGTH;
                } else {
                        avail = RING_LENGTH - client->ringtail;
                        handle_errno(net_length = read(client->fd,
                                                                                   client->ringbuffer +
                                                                                   client->ringtail, avail));
                        client->ringtail = (client->ringtail + net_length) % RING_LENGTH;
                        if(net_length && net_length == avail) {
                                handle_errno(net_length += read(client->fd,
                                                                                                client->ringbuffer,
                                                                                                client->ringhead - 1));
                                client->ringtail += net_length - avail;
                        }
                }
        }

        dprintk("net_length = %d", net_length);

        if(net_length == 0) {
                printf(" client disconnected.\n");
                client_disconnect(client);
                return;
        }

        telnet_read_ring(client);
}

int network_init

(

int

port

)

Definition at line 88 of file network.c.

References log_printf(), and network_bind_port().

{
        struct addrinfo hints;
        struct addrinfo *res, *walk;
        char myservice[128];
        char hostname[1025];
        int error;

        snprintf(myservice, 32, "%d", port + 10);

        signal(SIGPIPE, SIG_IGN);

        memset(&hints, 0, sizeof(hints));
        hints.ai_family = AF_UNSPEC;
        hints.ai_flags =
                AI_PASSIVE | AI_NUMERICSERV | AI_ADDRCONFIG | AI_ALL | AI_V4MAPPED;
        hints.ai_socktype = SOCK_STREAM;
        error = getaddrinfo(NULL, myservice, &hints, &res);
        walk = res;
        if(error)
                perror(gai_strerror(error));
        else {
                /*
                 * "res" has a chain of addrinfo structure filled with
                 * 0.0.0.0 (for IPv4), 0:0:0:0:0:0:0:0 (for IPv6) and alike,
                 * with port filled for "myservice".
                 */
                while (walk) {
                        if(getnameinfo(walk->ai_addr, walk->ai_addrlen, hostname, 1025,
                                                   myservice, 128, NI_NUMERICSERV)) {
                                log_printf("network] serious problem in getnameinfo().");
                        }
                        if(network_bind_port(walk->ai_addr, walk->ai_addrlen) == 0) {
                                log_printf("network] binding to %s %s %s failed.",
                                                   (walk->ai_family == AF_INET6 ? "IPv6" : "IPv4"),
                                                   hostname, myservice);
                        } else {
                                log_printf("network] bound to %s %s %s. ",
                                                   (walk->ai_family == AF_INET6 ? "IPv6" : "IPv4"),
                                                   hostname, myservice);
                        }

                        walk = walk->ai_next;
                }
        }
        freeaddrinfo(res);
        return 1;
}

DESC * network_initialize_socket	(	int	socket,
		struct sockaddr *	saddr,
		int	addrlen
	)

Definition at line 224 of file network.c.

References desc, descriptor_data::descriptor, descriptor_list, confdata::idle_timeout, log_printf(), mudconf, mudstate, NETWORK_HOSTNAME_MAX, network_make_nonblocking(), NETWORK_PORTNAME_MAX, statedata::now, descriptor_data::remoteport, confdata::retry_limit, telnet_init(), and welcome_user().

Referenced by network_accept_client().

{
        char remotehost[NETWORK_HOSTNAME_MAX];
        char remoteport[NETWORK_PORTNAME_MAX];
        DESC *desc;

        desc = malloc(sizeof(DESC));
        memset(desc, 0, sizeof(DESC));

        desc->fd = socket;

        memcpy(desc->saddr, addr, addrlen);

        if(getnameinfo(addr, addrlen, remotehost, NETWORK_HOSTNAME_MAX,
                                   remoteport, NETWORK_PORTNAME_MAX,
                                   NI_NUMERICSERV | NI_NUMERICHOST)) {
                log_printf("network] getnameinfo failed!");
                desc->ip = strdup("unspec");
                desc->port = -1;
        } else {
                desc->ip = strdup(remotehost);
                desc->port = itoa(remoteport);
        }

        network_make_nonblocking(socket);

        desc->connected_at = mudstate.now;
        desc->retries_left = mudconf.retry_limit;
        desc->timeout = mudconf.idle_timeout;
        desc->host_info = 1;
        desc->next = descriptor_list;
        descriptor->list = desc;

        desc->sock_buff = bufferevent_new(desc->fd, network_write_callback,
                                                                          network_read_callback,
                                                                          network_error_callback, NULL);
        bufferevent_disable(desc->sock_buff, EV_READ);
        bufferevent_enable(desc->sock_buff, EV_WRITE);
        event_set(&desc->sock_ev, desc->fd, EV_READ | EV_PERSIST,
                          network_accept_input, d);
        event_add(&desc->sock_ev, NULL);
        telnet_init(desc);

        welcome_user(desc);

        return desc;
}

static void network_make_blocking

(

int

socket

)

[static]

Definition at line 154 of file network.c.

References log_perror().

{
        long flags = 0;

        if(fcntl(s, F_GETFL, &flags) < 0) {
                log_perror("NET", "FAIL", "make_blocking", "fcntl F_GETFL");
        }
        flags &= ~O_NONBLOCK;
        if(fcntl(s, F_SETFL, flags) < 0) {
                log_perror("NET", "FAIL", "make_blocking", "fcntl F_SETFL");
        }
        flags = 0;
        if(setsockopt(s, IPPROTO_TCP, TCP_NODELAY, &flags, sizeof(flags)) < 0) {
                log_perror("NET", "FAIL", "make_blocking", "setsockopt NDELAY");
        }
}

static void network_make_nonblocking

(

int

socket

)

[static]

Definition at line 137 of file network.c.

References log_perror().

Referenced by network_bind_port(), and network_initialize_socket().

{
        long flags = 0;

        if(fcntl(s, F_GETFL, &flags) < 0) {
                log_perror("NET", "FAIL", "make_nonblocking", "fcntl F_GETFL");
        }
        flags |= O_NONBLOCK;
        if(fcntl(s, F_SETFL, flags) < 0) {
                log_perror("NET", "FAIL", "make_nonblocking", "fcntl F_SETFL");
        }
        flags = 1;
        if(setsockopt(s, IPPROTO_TCP, TCP_NODELAY, &flags, sizeof(flags)) < 0) {
                log_perror("NET", "FAIL", "make_nonblocking", "setsockopt NDELAY");
        }
}

void network_release_socket

(

DESC *

desc

)

Definition at line 188 of file network.c.

References desc.

{
        int null = 0;

        desc->chokes--;
        if(desc->chokes < 0)
                desc->chokes = 0;

        if(desc->chokes == 0) {
#if defined(TCP_CORK)                   // Linux 2.4, 2.6
                setsockopt(d->fd, IPPROTO_TCP, TCP_CORK, &null, sizeof(null));
#elif defined(TCP_NOPUSH)               // *BSD, Mac OS X
                setsockopt(d->fd, IPPROTO_TCP, TCP_NOPUSH, &null, sizeof(null));
#else // else
                /* Nothing! */
#endif
        }
}

void network_write	(	DESC *	client,
		char *	buffer,
		int	length
	)

Definition at line 326 of file network.c.

References descriptor_data::output_tot.

Referenced by telnet_send_req(), telnet_send_subop(), and telnet_write().

{
        bufferevent_write(d->sock_buff, buffer, length);
        client->output_tot += length;
}

---

Variable Documentation

DESC* descriptor_list = NULL

Definition at line 28 of file network.c.

struct listening_socket_t * listening_sockets

Referenced by network_bind_port().

---