shared.h File Reference

#include "gwlib/gwlib.h"
#include "msg.h"

Go to the source code of this file.

Macros
#define	INFINITE_TIME   -1

Enumerations
enum	program_status { starting_up, running, shutting_down }

Functions
Connection *	connect_to_bearerbox_real (Octstr *host, int port, int ssl, Octstr *our_host)
void	connect_to_bearerbox (Octstr *host, int port, int ssl, Octstr *our_host)
void	close_connection_to_bearerbox_real (Connection *conn)
void	close_connection_to_bearerbox (void)
int	read_from_bearerbox_real (Connection *conn, Msg **msg, double seconds)
int	read_from_bearerbox (Msg **msg, double seconds)
void	write_to_bearerbox_real (Connection *conn, Msg *pmsg)
void	write_to_bearerbox (Msg *msg)
int	deliver_to_bearerbox_real (Connection *conn, Msg *msg)
int	deliver_to_bearerbox (Msg *msg)
Octstr *	parse_date (Octstr *date)
int	restart_box (char **argv)

Variables
enum program_status	program_status

Macro Definition Documentation

INFINITE_TIME

#define INFINITE_TIME   -1

Definition at line 73 of file shared.h.

Referenced by main(), and read_messages_from_bearerbox().

Enumeration Type Documentation

program_status

enum program_status

Enumerator
starting_up
running
shutting_down

Definition at line 79 of file shared.h.

                                    {
    starting_up,
    running,
    shutting_down
} program_status;

Function Documentation

close_connection_to_bearerbox()

void close_connection_to_bearerbox

(

void

)

Definition at line 122 of file shared.c.

References bb_conn, and close_connection_to_bearerbox_real().

Referenced by main(), and run_connects().

{
    close_connection_to_bearerbox_real(bb_conn);
    bb_conn = NULL;
}

close_connection_to_bearerbox_real()

void close_connection_to_bearerbox_real

(

Connection *

conn

)

Definition at line 116 of file shared.c.

References conn_destroy().

Referenced by close_connection_to_bearerbox().

{
    conn_destroy(conn);
}

connect_to_bearerbox()

void connect_to_bearerbox	(	Octstr *	host,
		int	port,
		int	ssl,
		Octstr *	our_host
	)

Definition at line 108 of file shared.c.

References bb_conn, connect_to_bearerbox_real(), host, our_host, panic, and ssl.

Referenced by main(), and run_connects().

{
    bb_conn = connect_to_bearerbox_real(host, port, ssl, our_host);
    if (bb_conn == NULL)
        panic(0, "Couldn't connect to the bearerbox.");
}

connect_to_bearerbox_real()

Connection* connect_to_bearerbox_real	(	Octstr *	host,
		int	port,
		int	ssl,
		Octstr *	our_host
	)

Definition at line 83 of file shared.c.

References conn_open_tcp(), host, info(), octstr_get_cstr, our_host, and ssl.

Referenced by connect_to_bearerbox(), run_smppbox(), run_sqlbox(), and sql_to_bearerbox().

{
    Connection *conn;

#ifdef HAVE_LIBSSL
    if (ssl) 
        conn = conn_open_ssl(host, port, NULL, our_host);
        /* XXX add certkeyfile to be given to conn_open_ssl */
    else
#endif /* HAVE_LIBSSL */
    conn = conn_open_tcp(host, port, our_host);
    if (conn == NULL)
        return NULL;

    if (ssl)
        info(0, "Connected to bearerbox at %s port %d using SSL.",
             octstr_get_cstr(host), port);
    else
        info(0, "Connected to bearerbox at %s port %d.",
             octstr_get_cstr(host), port);

    return conn;
}

deliver_to_bearerbox()

int deliver_to_bearerbox

(

Msg *

msg

)

Definition at line 166 of file shared.c.

References bb_conn, deliver_to_bearerbox_real(), and msg.

Referenced by send_message().

{
    return deliver_to_bearerbox_real(bb_conn, msg);
}

deliver_to_bearerbox_real()

int deliver_to_bearerbox_real	(	Connection *	conn,
		Msg *	msg
	)

Definition at line 148 of file shared.c.

References conn_write_withlen(), error(), msg, msg_destroy(), msg_pack(), and octstr_destroy().

Referenced by deliver_to_bearerbox().

{
     
    Octstr *pack;
    
    pack = msg_pack(msg);
    if (conn_write_withlen(conn, pack) == -1) {
        error(0, "Couldn't deliver Msg to bearerbox.");
        octstr_destroy(pack);
        return -1;
    }
                                   
    octstr_destroy(pack);
    msg_destroy(msg);
    return 0;
}

parse_date()

Octstr* parse_date

(

Octstr *

date

)

Definition at line 232 of file shared.c.

References date(), error(), octstr_get_char(), octstr_parse_long(), and warning().

Referenced by parse_progress_note_value(), parse_push_message_value(), parse_push_response_value(), and tokenize_date().

{
    long date_value;

    if (octstr_get_char(date, 4) != '-')
        goto error;
    if (octstr_get_char(date, 7) != '-')
        goto error;
    if (octstr_get_char(date, 10) != 'T')
        goto error;
    if (octstr_get_char(date, 13) != ':')
        goto error;
    if (octstr_get_char(date, 16) != ':')
        goto error;
    if (octstr_get_char(date, 19) != 'Z')
        goto error;

    if (octstr_parse_long(&date_value, date, 0, 10) < 0)
        goto error;
    if (octstr_parse_long(&date_value, date, 5, 10) < 0)
        goto error;
    if (date_value < 1 || date_value > 12)
        goto error;
    if (octstr_parse_long(&date_value, date, 8, 10) < 0)
        goto error;
    if (date_value < 1 || date_value > 31)
        goto error;
    if (octstr_parse_long(&date_value, date, 11, 10) < 0)
        goto error;
    if (date_value < 0 || date_value > 23)
        goto error;
    if (octstr_parse_long(&date_value, date, 14, 10) < 0)
        goto error;
    if (date_value < 0 || date_value > 59)
        goto error;
    if (date_value < 0 || date_value > 59)
        goto error;
    if (octstr_parse_long(&date_value, date, 17, 10) < 0)
        goto error;

    return date;

error:
    warning(0, "parse_date: not an ISO date");
    return NULL;
}

read_from_bearerbox()

int read_from_bearerbox	(	Msg **	msg,
		double	seconds
	)

Definition at line 220 of file shared.c.

References bb_conn, msg, and read_from_bearerbox_real().

Referenced by main(), and read_messages_from_bearerbox().

{
    return read_from_bearerbox_real(bb_conn, msg, seconds);
}

read_from_bearerbox_real()

int read_from_bearerbox_real	(	Connection *	conn,
		Msg **	msg,
		double	seconds
	)

Definition at line 172 of file shared.c.

References conn_eof(), conn_error(), conn_read_withlen(), conn_wait(), error(), msg, msg_unpack, octstr_destroy(), and shutting_down.

Referenced by read_from_bearerbox(), and read_from_box().

{
    int ret;
    Octstr *pack;

    pack = NULL;
    *msg = NULL;
    while (program_status != shutting_down) {
        pack = conn_read_withlen(conn);
        gw_claim_area(pack);
        if (pack != NULL)
            break;

        if (conn_error(conn)) {
            error(0, "Error reading from bearerbox, disconnecting.");
            return -1;
        }
        if (conn_eof(conn)) {
            error(0, "Connection closed by the bearerbox.");
            return -1;
        }

        ret = conn_wait(conn, seconds);
        if (ret < 0) {
            error(0, "Connection to bearerbox broke.");
            return -1;
        }
        else if (ret == 1) {
            /* debug("gwlib.gwlib", 0, "Connection to bearerbox timed out after %.2f seconds.", seconds); */
            return 1;
        }
    }

    if (pack == NULL)
        return -1;

    *msg = msg_unpack(pack);
    octstr_destroy(pack);

    if (*msg == NULL) {
        error(0, "Failed to unpack data!");
        return -1;
    }

    return 0;
}

restart_box()

int restart_box

(

char **

argv

)

Definition at line 279 of file shared.c.

References error(), and gwthread_sleep().

Referenced by main().

{
    int rc;

    if (!(rc = fork())) {
        /*
         * Sleep a while in order to get father
         * process time to cleanup things
         */
        gwthread_sleep(1.0);
        if (execvp(argv[0],argv) == -1)
            error(errno, "Unable to start new process.");
    } else if (rc == -1)
        error(errno, "Could not restart, exiting...");

    return rc == -1 ? -1 : 0;
}

write_to_bearerbox()

void write_to_bearerbox

(

Msg *

msg

)

Definition at line 142 of file shared.c.

References bb_conn, and write_to_bearerbox_real().

Referenced by dispatch_datagram(), identify_to_bearerbox(), main(), obey_request_thread(), run_connects(), and send_message().

{
    write_to_bearerbox_real(bb_conn, pmsg);
}

write_to_bearerbox_real()

void write_to_bearerbox_real	(	Connection *	conn,
		Msg *	pmsg
	)

Definition at line 129 of file shared.c.

References conn_write_withlen(), error(), msg_destroy(), msg_pack(), and octstr_destroy().

Referenced by send_msg(), and write_to_bearerbox().

{
    Octstr *pack;

    pack = msg_pack(pmsg);
    if (conn_write_withlen(conn, pack) == -1)
        error(0, "Couldn't write Msg to bearerbox.");

    msg_destroy(pmsg);
    octstr_destroy(pack);
}

Variable Documentation

program_status

enum program_status program_status