socket.c File Reference

#include <ctype.h>
#include <errno.h>
#include <stdarg.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>
#include <unistd.h>
#include <fcntl.h>
#include <sys/time.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h>
#include <arpa/inet.h>
#include <sys/utsname.h>
#include "gwlib.h"

Go to the source code of this file.

Macros
#define	UDP_PACKET_MAX_SIZE   (64*1024)

Functions
int	make_server_socket (int port, const char *interface_name)
int	tcpip_connect_to_server (char *hostname, int port, const char *source_addr)
int	tcpip_connect_to_server_with_port (char *hostname, int port, int our_port, const char *source_addr)
int	tcpip_connect_nb_to_server (char *hostname, int port, const char *source_addr, int *done)
int	tcpip_connect_nb_to_server_with_port (char *hostname, int port, int our_port, const char *source_addr, int *done)
int	write_to_socket (int socket, char *str)
int	socket_set_blocking (int fd, int blocking)
int	socket_set_nodelay (int fd, int on)
int	read_available (int fd, long wait_usec)
int	udp_client_socket (void)
int	udp_bind (int port, const char *source_addr)
Octstr *	udp_create_address (Octstr *host_or_ip, int port)
int	udp_get_port (Octstr *addr)
Octstr *	udp_get_ip (Octstr *addr)
int	udp_sendto (int s, Octstr *datagram, Octstr *addr)
int	udp_recvfrom (int s, Octstr **datagram, Octstr **addr)
int	udp_recvfrom_flags (int s, Octstr **datagram, Octstr **addr, int sockrcvflags)
Octstr *	host_ip (struct sockaddr_in addr)
int	host_port (struct sockaddr_in addr)
Octstr *	get_official_name (void)
Octstr *	get_official_ip (void)
static void	setup_official_name (void)
void	socket_init (void)
void	socket_shutdown (void)
Octstr *	gw_netaddr_to_octstr (int af, void *src)
int	gw_accept (int fd, Octstr **client_addr)

Variables
static Octstr *	official_name = NULL
static Octstr *	official_ip = NULL
static const struct sockaddr_in	empty_sockaddr_in

Macro Definition Documentation

UDP_PACKET_MAX_SIZE

#define UDP_PACKET_MAX_SIZE   (64*1024)

Definition at line 89 of file socket.c.

Referenced by udp_recvfrom_flags().

Function Documentation

get_official_ip()

Octstr* get_official_ip

(

void

)

Definition at line 634 of file socket.c.

References gw_assert(), and official_ip.

Referenced by name(), and version_report_string().

{
    gw_assert(official_ip != NULL);
    return official_ip;
}

get_official_name()

Octstr* get_official_name

(

void

)

Definition at line 627 of file socket.c.

References gw_assert(), and official_name.

Referenced by add_via(), challenge(), tell_ppg_name(), and version_report_string().

{
    gw_assert(official_name != NULL);
    return official_name;
}

gw_accept()

int gw_accept	(	int	fd,
		Octstr **	client_addr
	)

Definition at line 700 of file socket.c.

References debug(), error(), gwthread_pollfd(), host_ip(), octstr_get_cstr, and POLLIN.

Referenced by smpp_emu().

{
    struct sockaddr_in addr;
    socklen_t addrlen;
    int new_fd;

    if (gwthread_pollfd(fd, POLLIN, -1.0) != POLLIN) {
    debug("gwlib.socket", 0, "gwthread_pollfd interrupted or failed");
    return -1;
    }
    addrlen = sizeof(addr);
    new_fd = accept(fd, (struct sockaddr *) &addr, &addrlen);
    if (new_fd == -1) {
    error(errno, "accept system call failed.");
    return -1;
    }
    *client_addr = host_ip(addr);
    debug("test_smsc", 0, "accept() succeeded, client from %s",
      octstr_get_cstr(*client_addr));
    return new_fd;
}

gw_netaddr_to_octstr()

Octstr* gw_netaddr_to_octstr	(	int	af,
		void *	src
	)

Definition at line 677 of file socket.c.

References octstr_create.

Referenced by host_ip(), ois_open_receiver(), setup_official_name(), tcpip_connect_nb_to_server_with_port(), tcpip_connect_to_server_with_port(), udp_get_ip(), and wait_for_client().

{
    switch (af) {
    case AF_INET: {
        char straddr[INET_ADDRSTRLEN];
        inet_ntop(AF_INET, src, straddr, sizeof(straddr));
        return octstr_create(straddr);
    }

#ifdef AF_INET6
    case AF_INET6: {
        char straddr[INET6_ADDRSTRLEN];
        inet_ntop(AF_INET6, src, straddr, sizeof(straddr));
        return octstr_create(straddr);
    }
#endif

    default:
        return NULL;
    }
}

host_ip()

Octstr* host_ip

(

struct sockaddr_in

addr

)

Definition at line 615 of file socket.c.

References gw_netaddr_to_octstr().

Referenced by accept_boxc(), accept_smpp(), cgw_listener(), emi2_listener(), fake_listener(), get_data(), gw_accept(), and server_thread().

{
    return gw_netaddr_to_octstr(AF_INET, &addr.sin_addr);
}

host_port()

int host_port

(

struct sockaddr_in

addr

)

Definition at line 621 of file socket.c.

{
    return ntohs(addr.sin_port);
}

make_server_socket()

int make_server_socket	(	int	port,
		const char *	interface_name
	)

Definition at line 93 of file socket.c.

References empty_sockaddr_in, error(), gw_gethostbyname(), and interface_name.

Referenced by accept_thread(), cgw_open_listening_socket(), emi2_open_listening_socket(), fake_open_connection(), http_open_port_if(), ois_open_listener(), smpp_emu(), smppboxc_run(), smsboxc_run(), sqlboxc_run(), start_wapbox(), wait_for_client(), and wapboxc_run().

{
    struct sockaddr_in addr;
    int s;
    int reuse;
    struct hostent hostinfo;
    char *buff = NULL;

    s = socket(PF_INET, SOCK_STREAM, 0);
    if (s == -1) {
        error(errno, "socket failed");
        goto error;
    }

    addr = empty_sockaddr_in;
    addr.sin_family = AF_INET;
    addr.sin_port = htons(port);
    if (interface_name == NULL || strcmp(interface_name, "*") == 0)
        addr.sin_addr.s_addr = htonl(INADDR_ANY);
    else {
        if (gw_gethostbyname(&hostinfo, interface_name, &buff) == -1) {
            error(errno, "gethostbyname failed");
            goto error;
        }
        addr.sin_addr = *(struct in_addr *) hostinfo.h_addr;
    }

    reuse = 1;
    if (setsockopt(s, SOL_SOCKET, SO_REUSEADDR, (char *) &reuse,
                   sizeof(reuse)) == -1) {
        error(errno, "setsockopt failed for server address");
        goto error;
    }

    if (bind(s, (struct sockaddr *) &addr, sizeof(addr)) == -1) {
        error(errno, "bind failed");
        goto error;
    }

    if (listen(s, 10) == -1) {
        error(errno, "listen failed");
        goto error;
    }

    gw_free(buff);

    return s;

error:
    if (s >= 0)
        (void) close(s);
    gw_free(buff);
    return -1;
}

read_available()

int read_available	(	int	fd,
		long	wait_usec
	)

Definition at line 406 of file socket.c.

References gw_assert(), and warning().

Referenced by cimd2_get_packet(), cimd2_receive_msg(), ois_read_into_buffer(), oisd_get_packet(), oisd_receive_msg(), proxy_thread(), udp_receiver(), and wap_msg_recv().

{
    fd_set rf;
    struct timeval to;
    int ret;
    div_t waits;

    gw_assert(fd >= 0);

    FD_ZERO(&rf);
    FD_SET(fd, &rf);
    waits = div(wait_usec, 1000000);
    to.tv_sec = waits.quot;
    to.tv_usec = waits.rem;
retry:
    ret = select(fd + 1, &rf, NULL, NULL, &to);
    if (ret > 0 && FD_ISSET(fd, &rf))
        return 1;
    if (ret < 0) {
        /* In most select() implementations, to will now contain the
         * remaining time rather than the original time.  That is exactly
         * what we want when retrying after an interrupt. */
        switch (errno) {
            /*The first two entries here are OK*/
        case EINTR:
            goto retry;
        case EAGAIN:
            return 1;
            /* We are now sucking mud, figure things out here
             * as much as possible before it gets lost under
             * layers of abstraction.  */
        case EBADF:
            if (!FD_ISSET(fd, &rf)) {
                warning(0, "Tried to select on fd %d, not in the set!\n", fd);
            } else {
                warning(0, "Tried to select on invalid fd %d!\n", fd);
            }
            break;
        case EINVAL:
            /* Solaris catchall "It didn't work" error, lets apply
             * some tests and see if we can catch it. */

            /* First up, try invalid timeout*/
            if (to.tv_sec > 10000000)
                warning(0, "Wait more than three years for a select?\n");
            if (to.tv_usec > 1000000)
                warning(0, "There are only 1000000 usec in a second...\n");
            break;


        }
        return -1;  /* some error */
    }
    return 0;
}

setup_official_name()

static void setup_official_name ( void  )

static

Definition at line 641 of file socket.c.

References error(), gw_assert(), gw_gethostbyname(), gw_netaddr_to_octstr(), octstr_create, official_ip, official_name, and panic.

Referenced by socket_init().

{
    struct utsname u;
    struct hostent h;
    char *buff = NULL;

    gw_assert(official_name == NULL);
    if (uname(&u) == -1)
        panic(0, "uname failed - can't happen, unless " GW_NAME " is buggy.");
    if (gw_gethostbyname(&h, u.nodename, &buff) == -1) {
        error(0, "Can't find out official hostname for this host, "
              "using `%s' instead.", u.nodename);
        official_name = octstr_create(u.nodename);
        official_ip = octstr_create("127.0.0.1");
    } else {
        official_name = octstr_create(h.h_name);
        official_ip = gw_netaddr_to_octstr(AF_INET, h.h_addr);
    }
    gw_free(buff);
}

socket_init()

void socket_init

(

void

)

Definition at line 663 of file socket.c.

References setup_official_name().

Referenced by gwlib_init().

{
    setup_official_name();
}

socket_set_blocking()

int socket_set_blocking	(	int	fd,
		int	blocking
	)

Definition at line 368 of file socket.c.

References error().

Referenced by cgw_open_listening_socket(), conn_wrap_fd(), emi2_open_listening_socket(), fake_open_connection(), fill_threadinfo(), ois_open_listener(), and wait_for_client().

{
    int flags, newflags;

    flags = fcntl(fd, F_GETFL);
    if (flags < 0) {
        error(errno, "cannot get flags for fd %d", fd);
        return -1;
    }

    if (blocking)
        newflags = flags & ~O_NONBLOCK;
    else
        newflags = flags | O_NONBLOCK;

    if (newflags != flags) {
        if (fcntl(fd, F_SETFL, newflags) < 0) {
            error(errno, "cannot set flags for fd %d", fd);
            return -1;
        }
    }

    return 0;
}

socket_set_nodelay()

int socket_set_nodelay	(	int	fd,
		int	on
	)

Definition at line 394 of file socket.c.

References error().

{
    int rc;

    rc = setsockopt(fd, IPPROTO_TCP, TCP_NODELAY, &on, sizeof (on));
    if (rc == -1)
        error(errno, "Unable set TCP_NODELAY(%d)", on);

    return rc;
}

socket_shutdown()

void socket_shutdown

(

void

)

Definition at line 668 of file socket.c.

References octstr_destroy(), official_ip, and official_name.

Referenced by gwlib_shutdown().

{
    octstr_destroy(official_name);
    official_name = NULL;
    octstr_destroy(official_ip);
    official_ip = NULL;
}

tcpip_connect_nb_to_server()

int tcpip_connect_nb_to_server	(	char *	hostname,
		int	port,
		const char *	source_addr,
		int *	done
	)

Definition at line 241 of file socket.c.

References hostname, and tcpip_connect_nb_to_server_with_port().

{
    return tcpip_connect_nb_to_server_with_port(hostname, port, 0, source_addr, done);
}

tcpip_connect_nb_to_server_with_port()

int tcpip_connect_nb_to_server_with_port	(	char *	hostname,
		int	port,
		int	our_port,
		const char *	source_addr,
		int *	done
	)

Definition at line 246 of file socket.c.

References debug(), empty_sockaddr_in, error(), gw_gethostbyname(), gw_netaddr_to_octstr(), hostname, octstr_destroy(), octstr_get_cstr, and our_port.

Referenced by conn_open_tcp_nb_with_port(), and tcpip_connect_nb_to_server().

{
    struct sockaddr_in addr;
    struct sockaddr_in o_addr;
    struct hostent hostinfo;
    struct hostent o_hostinfo;
    int s, flags, rc = -1, i;
    char *buff, *buff1;

    *done = 1;
    buff = buff1 = NULL;

    s = socket(PF_INET, SOCK_STREAM, 0);
    if (s == -1) {
        error(errno, "Couldn't create new socket.");
        goto error;
    }

    if (gw_gethostbyname(&hostinfo, hostname, &buff) == -1) {
        error(errno, "gethostbyname failed");
        goto error;
    }

    if (our_port > 0 || (source_addr != NULL && strcmp(source_addr, "*") != 0)) {
        int reuse;

        o_addr = empty_sockaddr_in;
        o_addr.sin_family = AF_INET;
        o_addr.sin_port = htons(our_port);
        if (source_addr == NULL || strcmp(source_addr, "*") == 0)
            o_addr.sin_addr.s_addr = htonl(INADDR_ANY);
        else {
            if (gw_gethostbyname(&o_hostinfo, source_addr, &buff1) == -1) {
                error(errno, "gethostbyname failed");
                goto error;
            }
            o_addr.sin_addr = *(struct in_addr *) o_hostinfo.h_addr;
        }

        reuse = 1;
        if (setsockopt(s, SOL_SOCKET, SO_REUSEADDR, (char *) &reuse, sizeof(reuse)) == -1) {
            error(errno, "setsockopt failed before bind");
            goto error;
        }
        if (bind(s, (struct sockaddr *) &o_addr, sizeof(o_addr)) == -1) {
            error(errno, "bind to local port %d failed", our_port);
            goto error;
        }
    }

    flags = fcntl(s, F_GETFL, 0);
    fcntl(s, F_SETFL, flags | O_NONBLOCK);

    i = 0;
    do {
        Octstr *ip2;

        addr = empty_sockaddr_in;
        addr.sin_family = AF_INET;
        addr.sin_port = htons(port);
        addr.sin_addr = *(struct in_addr *) hostinfo.h_addr_list[i];

        ip2 = gw_netaddr_to_octstr(AF_INET, &addr.sin_addr);

        debug("gwlib.socket", 0, "Connecting nonblocking to <%s>", octstr_get_cstr(ip2));

        if ((rc = connect(s, (struct sockaddr *) &addr, sizeof(addr))) < 0) {
            if (errno != EINPROGRESS) {
                error(errno, "nonblocking connect to <%s> failed", octstr_get_cstr(ip2));
            }
        }
        octstr_destroy(ip2);
    } while (rc == -1 && errno != EINPROGRESS && hostinfo.h_addr_list[++i] != NULL);

    if (rc == -1 && errno != EINPROGRESS)
        goto error;

    /* May be connected immediatly
     * (if we connecting to localhost for example)
     */
    if (rc == 0) {
        *done = 0;
    }

    gw_free(buff);
    gw_free(buff1);

    return s;

error:
    error(0, "error connecting to server `%s' at port `%d'", hostname, port);
    if (s >= 0)
        close(s);
    gw_free(buff);
    gw_free(buff1);
    return -1;
}

tcpip_connect_to_server()

int tcpip_connect_to_server	(	char *	hostname,
		int	port,
		const char *	source_addr
	)

Definition at line 149 of file socket.c.

References hostname, and tcpip_connect_to_server_with_port().

Referenced by at2_open_device1(), cimd_open_connection(), connect_tcpip(), ois_open_sender(), and oisd_login().

{

    return tcpip_connect_to_server_with_port(hostname, port, 0, source_addr);
}

tcpip_connect_to_server_with_port()

int tcpip_connect_to_server_with_port	(	char *	hostname,
		int	port,
		int	our_port,
		const char *	source_addr
	)

Definition at line 156 of file socket.c.

References debug(), empty_sockaddr_in, error(), gw_gethostbyname(), gw_netaddr_to_octstr(), hostname, octstr_destroy(), octstr_get_cstr, and our_port.

Referenced by cimd2_login(), conn_open_tcp_with_port(), emi_open_connection_ip(), and tcpip_connect_to_server().

{
    struct sockaddr_in addr;
    struct sockaddr_in o_addr;
    struct hostent hostinfo;
    struct hostent o_hostinfo;
    int s, rc = -1, i;
    char *buff, *buff1;

    buff = buff1 = NULL;

    s = socket(PF_INET, SOCK_STREAM, 0);
    if (s == -1) {
        error(errno, "Couldn't create new socket.");
        goto error;
    }

    if (gw_gethostbyname(&hostinfo, hostname, &buff) == -1) {
        error(errno, "gethostbyname failed");
        goto error;
    }

    if (our_port > 0 || (source_addr != NULL && strcmp(source_addr, "*") != 0))  {
        int reuse;

        o_addr = empty_sockaddr_in;
        o_addr.sin_family = AF_INET;
        o_addr.sin_port = htons(our_port);
        if (source_addr == NULL || strcmp(source_addr, "*") == 0)
            o_addr.sin_addr.s_addr = htonl(INADDR_ANY);
        else {
            if (gw_gethostbyname(&o_hostinfo, source_addr, &buff1) == -1) {
                error(errno, "gethostbyname failed");
                goto error;
            }
            o_addr.sin_addr = *(struct in_addr *) o_hostinfo.h_addr;
        }

        reuse = 1;
        if (setsockopt(s, SOL_SOCKET, SO_REUSEADDR, (char *) &reuse, sizeof(reuse)) == -1) {
            error(errno, "setsockopt failed before bind");
            goto error;
        }
        if (bind(s, (struct sockaddr *) &o_addr, sizeof(o_addr)) == -1) {
            error(errno, "bind to local port %d failed", our_port);
            goto error;
        }
    }

    i = 0;
    do {
        Octstr *ip2;

        addr = empty_sockaddr_in;
        addr.sin_family = AF_INET;
        addr.sin_port = htons(port);
        addr.sin_addr = *(struct in_addr *) hostinfo.h_addr_list[i];

        ip2 = gw_netaddr_to_octstr(AF_INET, &addr.sin_addr);

        debug("gwlib.socket", 0, "Connecting to <%s>", octstr_get_cstr(ip2));

        rc = connect(s, (struct sockaddr *) &addr, sizeof(addr));
        if (rc == -1) {
            error(errno, "connect to <%s> failed", octstr_get_cstr(ip2));
        }
        octstr_destroy(ip2);
    } while (rc == -1 && hostinfo.h_addr_list[++i] != NULL);

    if (rc == -1)
        goto error;

    gw_free(buff);
    gw_free(buff1);
    return s;

error:
    error(0, "error connecting to server `%s' at port `%d'", hostname, port);
    if (s >= 0)
        close(s);
    gw_free(buff);
    gw_free(buff1);
    return -1;
}

udp_bind()

int udp_bind	(	int	port,
		const char *	source_addr
	)

Definition at line 478 of file socket.c.

References empty_sockaddr_in, error(), and gw_gethostbyname().

Referenced by proxy_thread(), server(), and udpc_create().

{
    int s;
    struct sockaddr_in sa;
    struct hostent hostinfo;
    char *buff = NULL;

    s = socket(PF_INET, SOCK_DGRAM, 0);
    if (s == -1) {
        error(errno, "Couldn't create a UDP socket");
        return -1;
    }

    sa = empty_sockaddr_in;
    sa.sin_family = AF_INET;
    sa.sin_port = htons(port);
    if (strcmp(source_addr, "*") == 0)
        sa.sin_addr.s_addr = htonl(INADDR_ANY);
    else {
        if (gw_gethostbyname(&hostinfo, source_addr, &buff) == -1) {
            error(errno, "gethostbyname failed");
            gw_free(buff);
            return -1;
        }
        sa.sin_addr = *(struct in_addr *) hostinfo.h_addr;
    }

    if (bind(s, (struct sockaddr *) &sa, (int) sizeof(sa)) == -1) {
        error(errno, "Couldn't bind a UDP socket to port %d", port);
        (void) close(s);
        return -1;
    }

    gw_free(buff);

    return s;
}

udp_client_socket()

int udp_client_socket

(

void

)

Definition at line 464 of file socket.c.

References error().

Referenced by client(), client_session(), main(), proxy_thread(), and server().

{
    int s;

    s = socket(PF_INET, SOCK_DGRAM, 0);
    if (s == -1) {
        error(errno, "Couldn't create a UDP socket");
        return -1;
    }

    return s;
}

udp_create_address()

Octstr* udp_create_address	(	Octstr *	host_or_ip,
		int	port
	)

Definition at line 517 of file socket.c.

References empty_sockaddr_in, error(), gw_gethostbyname(), octstr_create_from_data, and octstr_get_cstr.

Referenced by client(), main(), proxy_thread(), send_udp(), server(), udp_addwdp_from_client(), udp_addwdp_from_server(), and udpc_create().

{
    struct sockaddr_in sa;
    struct hostent h;
    char *buff = NULL;
    Octstr *ret;

    sa = empty_sockaddr_in;
    sa.sin_family = AF_INET;
    sa.sin_port = htons(port);

    if (strcmp(octstr_get_cstr(host_or_ip), "*") == 0) {
        sa.sin_addr.s_addr = INADDR_ANY;
    } else {
        if (gw_gethostbyname(&h, octstr_get_cstr(host_or_ip), &buff) == -1) {
            error(0, "Couldn't find the IP number of `%s'",
                  octstr_get_cstr(host_or_ip));
            gw_free(buff);
            return NULL;
        }
        sa.sin_addr = *(struct in_addr *) h.h_addr;
    }

    ret = octstr_create_from_data((char *) &sa, sizeof(sa));
    gw_free(buff);

    return ret;
}

udp_get_ip()

Octstr* udp_get_ip

(

Octstr *

addr

)

Definition at line 557 of file socket.c.

References gw_assert(), gw_netaddr_to_octstr(), octstr_get_cstr, and octstr_len().

Referenced by client(), proxy_thread(), server(), udp_addwdp(), udp_addwdp_from_client(), udp_addwdp_from_server(), udp_receiver(), udpc_create(), and udpc_find_mapping().

{
    struct sockaddr_in sa;

    gw_assert(octstr_len(addr) == sizeof(sa));
    memcpy(&sa, octstr_get_cstr(addr), sizeof(sa));
    return gw_netaddr_to_octstr(AF_INET, &sa.sin_addr);
}

udp_get_port()

int udp_get_port

(

Octstr *

addr

)

Definition at line 547 of file socket.c.

References gw_assert(), octstr_get_cstr, and octstr_len().

Referenced by client(), proxy_thread(), server(), udp_addwdp(), udp_addwdp_from_client(), udp_addwdp_from_server(), udp_receiver(), udpc_create(), and udpc_find_mapping().

{
    struct sockaddr_in sa;

    gw_assert(octstr_len(addr) == sizeof(sa));
    memcpy(&sa, octstr_get_cstr(addr), sizeof(sa));
    return ntohs(sa.sin_port);
}

udp_recvfrom()

int udp_recvfrom	(	int	s,
		Octstr **	datagram,
		Octstr **	addr
	)

Definition at line 582 of file socket.c.

References udp_recvfrom_flags().

Referenced by client(), proxy_thread(), server(), and udp_receiver().

{
    return udp_recvfrom_flags(s, datagram, addr, 0);
}

udp_recvfrom_flags()

int udp_recvfrom_flags	(	int	s,
		Octstr **	datagram,
		Octstr **	addr,
		int	sockrcvflags
	)

Definition at line 588 of file socket.c.

References error(), octstr_create_from_data, and UDP_PACKET_MAX_SIZE.

Referenced by udp_recvfrom(), and wap_msg_recv().

{
    struct sockaddr_in sa;
    socklen_t salen;
    char *buf;
    int bytes;

    buf = gw_malloc(UDP_PACKET_MAX_SIZE);

    salen = sizeof(sa);
    bytes = recvfrom(s, buf, UDP_PACKET_MAX_SIZE, sockrcvflags, (struct sockaddr *) &sa, &salen);
    if (bytes == -1) {
        if (errno != EAGAIN)
            error(errno, "Couldn't receive UDP packet");
    gw_free(buf);
        return -1;
    }

    *datagram = octstr_create_from_data(buf, bytes);
    *addr = octstr_create_from_data((char *) &sa, salen);

    gw_free(buf);

    return 0;
}

udp_sendto()

int udp_sendto	(	int	s,
		Octstr *	datagram,
		Octstr *	addr
	)

Definition at line 567 of file socket.c.

References error(), gw_assert(), octstr_get_cstr, and octstr_len().

Referenced by client(), proxy_thread(), send_file(), send_udp(), server(), and wap_msg_send().

{
    struct sockaddr_in sa;

    gw_assert(octstr_len(addr) == sizeof(sa));
    memcpy(&sa, octstr_get_cstr(addr), sizeof(sa));
    if (sendto(s, octstr_get_cstr(datagram), octstr_len(datagram), 0,
               (struct sockaddr *) &sa, (int) sizeof(sa)) == -1) {
        error(errno, "Couldn't send UDP packet");
        return -1;
    }
    return 0;
}

write_to_socket()

int write_to_socket	(	int	socket,
		char *	str
	)

Definition at line 345 of file socket.c.

References error().

Referenced by cimd_close(), cimd_open_connection(), cimd_pending_smsmessage(), cimd_submit_msg(), connect_tcpip(), ois_deliver_sm_result(), ois_submit_sm_invoke(), and send_acknowledge().

{
    size_t len;
    int ret;

    len = strlen(str);
    while (len > 0) {
        ret = write(socket, str, len);
        if (ret == -1) {
            if (errno == EAGAIN) continue;
            if (errno == EINTR) continue;
            error(errno, "Writing to socket failed");
            return -1;
        }
        /* ret may be less than len, if the writing was interrupted
           by a signal. */
        len -= ret;
        str += ret;
    }
    return 0;
}

Variable Documentation

empty_sockaddr_in

const struct sockaddr_in empty_sockaddr_in

static

Definition at line 86 of file socket.c.

Referenced by make_server_socket(), tcpip_connect_nb_to_server_with_port(), tcpip_connect_to_server_with_port(), udp_bind(), and udp_create_address().

official_ip

Octstr* official_ip = NULL

static

Definition at line 79 of file socket.c.

Referenced by get_official_ip(), setup_official_name(), and socket_shutdown().

official_name

Octstr* official_name = NULL

static

Definition at line 78 of file socket.c.

Referenced by get_official_name(), setup_official_name(), and socket_shutdown().