sqlbox.c File Reference

#include <errno.h>
#include <unistd.h>
#include <signal.h>
#include <string.h>
#include "gwlib/gwlib.h"
#include "gwlib/dbpool.h"
#include "gw/msg.h"
#include "gw/sms.h"
#include "gw/shared.h"
#include "gw/bb.h"
#include "sqlbox_sql.h"
#include "sqlbox-cfg.def"

Go to the source code of this file.

Data Structures
struct	_boxc

Macros
#define	SQL_DEAD   0
#define	SQL_SHUTDOWN   1
#define	SQL_RUNNING   2
#define	SLEEP_BETWEEN_EMPTY_SELECTS   1.0
#define	DEFAULT_LIMIT_PER_CYCLE   10
#define	OCTSTR(name)
#define	SINGLE_GROUP(name, fields)
#define	MULTI_GROUP(name, fields)
#define	OCTSTR(name)
#define	SINGLE_GROUP(name, fields)
#define	MULTI_GROUP(name, fields)

Typedefs
typedef struct _boxc	Boxc

Functions
static int	sqlbox_is_allowed_in_group (Octstr *group, Octstr *variable)
static int	sqlbox_is_single_group (Octstr *query)
static int	charset_processing (Msg *msg)
static Msg *	read_from_box (Connection *conn, Boxc *boxconn)
static int	send_msg (Connection *conn, Boxc *boxconn, Msg *pmsg)
static void	smsbox_to_bearerbox (void *arg)
static Boxc *	boxc_create (int fd, Octstr *ip, int ssl)
static void	boxc_destroy (Boxc *boxc)
static Boxc *	accept_boxc (int fd, int ssl)
static void	bearerbox_to_smsbox (void *arg)
static void	run_sqlbox (void *arg)
static void	wait_for_connections (int fd, void(*function)(void *arg), List *waited)
static void	identify_to_bearerbox (Boxc *conn)
static void	bearerbox_to_sql (void *arg)
static void	sql_single (Boxc *boxc)
static void	sql_list (Boxc *boxc)
static void	sql_to_bearerbox (void *arg)
static void	sqlboxc_run (void *arg)
static void	signal_handler (int signum)
static void	setup_signal_handlers (void)
static void	init_sqlbox (Cfg *cfg)
static int	check_args (int i, int argc, char **argv)
int	main (int argc, char **argv)

Variables
static Cfg *	cfg
static volatile sig_atomic_t	restart_sqlbox = 0
static volatile sig_atomic_t	sqlbox_status
static long	sqlbox_port
static int	sqlbox_port_ssl = 0
static long	bearerbox_port
static Octstr *	bearerbox_host
static int	bearerbox_port_ssl = 0
static Octstr *	global_sender
static long	limit_per_cycle
static int	save_mo
static int	save_mt
static int	save_dlr
Octstr *	sqlbox_id

Macro Definition Documentation

DEFAULT_LIMIT_PER_CYCLE

#define DEFAULT_LIMIT_PER_CYCLE   10

Definition at line 98 of file sqlbox.c.

Referenced by init_sqlbox().

MULTI_GROUP [1/2]

#define MULTI_GROUP	(		name,
			fields
	)

Value:

if (octstr_compare(octstr_imm(#name), group) == 0) { \
        if (octstr_compare(groupstr, variable) == 0) \
        return 1; \
        fields \
        return 0; \
    }

MULTI_GROUP [2/2]

#define MULTI_GROUP	(		name,
			fields
	)

Value:

if (octstr_compare(octstr_imm(#name), query) == 0) \
        return 0;

OCTSTR [1/2]

#define OCTSTR

(

name

)

Value:

if (octstr_compare(octstr_imm(#name), variable) == 0) \
        return 1;

OCTSTR [2/2]

#define OCTSTR

(

name

)

SINGLE_GROUP [1/2]

#define SINGLE_GROUP	(		name,
			fields
	)

Value:

if (octstr_compare(octstr_imm(#name), group) == 0) { \
        if (octstr_compare(groupstr, variable) == 0) \
        return 1; \
        fields \
        return 0; \
    }

SINGLE_GROUP [2/2]

#define SINGLE_GROUP	(		name,
			fields
	)

Value:

if (octstr_compare(octstr_imm(#name), query) == 0) \
        return 1;

SLEEP_BETWEEN_EMPTY_SELECTS

#define SLEEP_BETWEEN_EMPTY_SELECTS   1.0

Definition at line 97 of file sqlbox.c.

Referenced by sql_list(), and sql_single().

SQL_DEAD

#define SQL_DEAD   0

Definition at line 79 of file sqlbox.c.

SQL_RUNNING

#define SQL_RUNNING   2

Definition at line 81 of file sqlbox.c.

Referenced by bearerbox_to_smsbox(), bearerbox_to_sql(), init_sqlbox(), signal_handler(), smsbox_to_bearerbox(), sql_list(), sql_single(), and wait_for_connections().

SQL_SHUTDOWN

#define SQL_SHUTDOWN   1

Definition at line 80 of file sqlbox.c.

Referenced by bearerbox_to_sql(), signal_handler(), and wait_for_connections().

Typedef Documentation

Boxc

typedef struct _boxc Boxc

Function Documentation

accept_boxc()

static Boxc* accept_boxc ( int  fd, int  ssl  )

static

Definition at line 347 of file sqlbox.c.

References boxc_create(), host_ip(), info(), octstr_get_cstr, _boxc::smsbox_connection, and ssl.

Referenced by run_sqlbox().

{
    Boxc *newconn;
    Octstr *ip;

    int newfd;
    struct sockaddr_in client_addr;
    socklen_t client_addr_len;

    client_addr_len = sizeof(client_addr);

    newfd = accept(fd, (struct sockaddr *)&client_addr, &client_addr_len);
    if (newfd < 0)
        return NULL;

    ip = host_ip(client_addr);

    // if (is_allowed_ip(box_allow_ip, box_deny_ip, ip) == 0) {
        // info(0, "Box connection tried from denied host <%s>, disconnected",
                // octstr_get_cstr(ip));
        // octstr_destroy(ip);
        // close(newfd);
        // return NULL;
    // }
    newconn = boxc_create(newfd, ip, ssl);

    /*
     * check if the SSL handshake was successfull, otherwise
     * this is no valid box connection any more
     */
#ifdef HAVE_LIBSSL
     if (ssl && !conn_get_ssl(newconn->smsbox_connection))
        return NULL;
#endif

    if (ssl)
        info(0, "Client connected from <%s> using SSL", octstr_get_cstr(ip));
    else
        info(0, "Client connected from <%s>", octstr_get_cstr(ip));


    /* XXX TODO: do the hand-shake, baby, yeah-yeah! */

    return newconn;
}

bearerbox_to_smsbox()

static void bearerbox_to_smsbox ( void *  arg )

static

Definition at line 394 of file sqlbox.c.

References _boxc::alive, _boxc::bearerbox_connection, cmd_restart, cmd_shutdown, debug(), gw_sql_save_msg, msg, msg_destroy(), msg_duplicate(), octstr_imm(), read_from_box(), report_mo, save_dlr, save_mo, send_msg(), _boxc::smsbox_connection, SQL_RUNNING, and sqlbox_status.

Referenced by run_sqlbox().

{
    Msg *msg, *msg_escaped;
    Boxc *conn = arg;

    while (sqlbox_status == SQL_RUNNING && conn->alive) {

        msg = read_from_box(conn->bearerbox_connection, conn);

        if (msg == NULL) {
            /* tell sqlbox to die */
            conn->alive = 0;
            debug("sqlbox", 0, "bearerbox_to_smsbox: connection to bearerbox died.");
            break;
        }
        if (msg_type(msg) == admin) {
            if (msg->admin.command == cmd_shutdown || msg->admin.command == cmd_restart) {
                /* tell sqlbox to die */
                conn->alive = 0;
                debug("sqlbox", 0, "bearerbox_to_smsbox: Bearerbox told us to shutdown.");
                break;
            }
        }

        if (msg_type(msg) == heartbeat) {
        // todo
            debug("sqlbox", 0, "bearerbox_to_smsbox: catch an heartbeat - we are alive");
            msg_destroy(msg);
            continue;
        }
        if (!conn->alive) {
            msg_destroy(msg);
            break;
        }
        if (msg_type(msg) == sms) {
            msg_escaped = msg_duplicate(msg);
            if (msg->sms.sms_type != report_mo) {
                if (save_mo) {
                    gw_sql_save_msg(msg_escaped, octstr_imm("MO"));
                }
            }
            else {
                if (save_dlr) {
                    gw_sql_save_msg(msg_escaped, octstr_imm("DLR"));
                }
            }
            msg_destroy(msg_escaped);
        }
        send_msg(conn->smsbox_connection, conn, msg);
        msg_destroy(msg);
    }
    /* the client closes the connection, after that die in receiver */
    conn->alive = 0;
}

bearerbox_to_sql()

static void bearerbox_to_sql ( void *  arg )

static

Definition at line 521 of file sqlbox.c.

References ack_success, _boxc::alive, _boxc::bearerbox_connection, cmd_shutdown, debug(), gw_sql_save_msg, msg, msg_create, msg_destroy(), octstr_imm(), read_from_box(), report_mo, save_dlr, save_mo, send_msg(), SQL_RUNNING, SQL_SHUTDOWN, sqlbox_status, and uuid_copy().

Referenced by sql_to_bearerbox().

{
    Boxc *conn = (Boxc *)arg;
    Msg *msg, *mack;

    while (sqlbox_status == SQL_RUNNING && conn->alive) {
        msg = read_from_box(conn->bearerbox_connection, conn);

        if (msg == NULL) {    /* garbage/connection lost */
                    /* tell sqlbox to die */
            conn->alive = 0;
            sqlbox_status = SQL_SHUTDOWN;
            debug("sqlbox", 0, "bearerbox_to_sql: connection to bearerbox died.");
            break;
        }
            if (msg_type(msg) == heartbeat) {
                // todo
                    debug("sqlbox", 0, "bearerbox_to_sql: catch an heartbeat - we are alive");
                    msg_destroy(msg);
                    continue;
            }
        /* if this is an identification message from an smsbox instance */
        if (msg_type(msg) == admin && msg->admin.command == cmd_shutdown) {
                    /* tell sqlbox to die */
            conn->alive = 0;
            sqlbox_status = SQL_SHUTDOWN;
            debug("sqlbox", 0, "bearerbox_to_sql: Bearerbox told us to shutdown.");
            break;
        }
        if (msg_type(msg) == sms) {
            if (msg->sms.sms_type != report_mo) {
                if (save_mo) {
                    gw_sql_save_msg(msg, octstr_imm("MO"));
                }
            }
            else {
                if (save_dlr) {
                    gw_sql_save_msg(msg, octstr_imm("DLR"));
                }
            }

        /* create ack message */
        mack = msg_create(ack);
        mack->ack.nack = ack_success;
        mack->ack.time = msg->sms.time;
        uuid_copy(mack->ack.id, msg->sms.id);
        send_msg(conn->bearerbox_connection, conn, mack);
        msg_destroy(mack);

        }

        msg_destroy(msg);
    }
}

boxc_create()

static Boxc* boxc_create ( int  fd, Octstr *  ip, int  ssl  )

static

Definition at line 316 of file sqlbox.c.

References _boxc::alive, _boxc::bearerbox_connection, _boxc::boxc_id, _boxc::client_ip, conn_wrap_fd(), _boxc::connect_time, _boxc::smsbox_connection, and ssl.

Referenced by accept_boxc().

{
    Boxc *boxc;

    boxc = gw_malloc(sizeof(Boxc));
    boxc->smsbox_connection = conn_wrap_fd(fd, ssl);
    boxc->bearerbox_connection = NULL;
    boxc->client_ip = ip;
    boxc->alive = 1;
    boxc->connect_time = time(NULL);
    boxc->boxc_id = NULL;
    return boxc;
}

boxc_destroy()

static void boxc_destroy ( Boxc *  boxc )

static

Definition at line 330 of file sqlbox.c.

References _boxc::bearerbox_connection, _boxc::boxc_id, _boxc::client_ip, conn_destroy(), octstr_destroy(), and _boxc::smsbox_connection.

Referenced by run_sqlbox(), and sql_to_bearerbox().

{
    if (boxc == NULL)
        return;

    /* do nothing to the lists, as they are only references */

    if (boxc->smsbox_connection)
        conn_destroy(boxc->smsbox_connection);
    if (boxc->bearerbox_connection)
        conn_destroy(boxc->bearerbox_connection);
    octstr_destroy(boxc->client_ip);
    octstr_destroy(boxc->boxc_id);
    gw_free(boxc);
}

charset_processing()

static int charset_processing ( Msg *  msg )

static

Definition at line 171 of file sqlbox.c.

References charset_convert(), DC_7BIT, DC_UCS2, gw_assert(), msg, octstr_get_cstr, octstr_len(), and octstr_url_decode().

Referenced by sql_list(), and sql_single().

{
    gw_assert(msg->type == sms);

    /* URL-decode first */
    if (octstr_url_decode(msg->sms.msgdata) == -1)
        return -1;
    if (octstr_url_decode(msg->sms.udhdata) == -1)
        return -1;
        
    /* If a specific character encoding has been indicated by the
     * user, then make sure we convert to our internal representations. */
    if (octstr_len(msg->sms.charset)) {
    
        if (msg->sms.coding == DC_7BIT) {
            /* For 7 bit, convert to UTF-8 */
            if (charset_convert(msg->sms.msgdata, octstr_get_cstr(msg->sms.charset), "UTF-8") < 0)
                return -1;
        } 
        else if (msg->sms.coding == DC_UCS2) {
            /* For UCS-2, convert to UTF-16BE */
            if (charset_convert(msg->sms.msgdata, octstr_get_cstr(msg->sms.charset), "UTF-16BE") < 0) 
                return -1;
        }
    }
    
    return 0;
}

check_args()

static int check_args ( int  i, int  argc, char **  argv  )

static

Definition at line 852 of file sqlbox.c.

Referenced by main().

                                                    {
    if (strcmp(argv[i], "-H")==0 || strcmp(argv[i], "--tryhttp")==0) {
    //only_try_http = 1;
    } else {
        return -1;
    }

    return 0;
}

identify_to_bearerbox()

static void identify_to_bearerbox ( Boxc *  conn )

static

Definition at line 510 of file sqlbox.c.

References _boxc::bearerbox_connection, _boxc::boxc_id, cmd_identify, msg, msg_create, msg_destroy(), octstr_duplicate, and send_msg().

Referenced by sql_to_bearerbox().

{
    Msg *msg;

    msg = msg_create(admin);
    msg->admin.command = cmd_identify;
    msg->admin.boxc_id = octstr_duplicate(conn->boxc_id);
    send_msg(conn->bearerbox_connection, conn, msg);
    msg_destroy(msg);
}

init_sqlbox()

static void init_sqlbox ( Cfg *  cfg )

static

Definition at line 776 of file sqlbox.c.

References BB_DEFAULT_HOST, BB_DEFAULT_SMSBOX_PORT, bearerbox_host, bearerbox_port, bearerbox_port_ssl, cfg, cfg_get, cfg_get_bool(), cfg_get_integer(), cfg_get_single_group(), conn_config_ssl(), DEFAULT_LIMIT_PER_CYCLE, global_sender, GW_NON_EXCL, gw_sql_enter, info(), limit_per_cycle, log_open(), octstr_create, octstr_destroy(), octstr_get_cstr, octstr_imm(), panic, save_dlr, save_mo, save_mt, SQL_RUNNING, sql_type, sqlbox_id, sqlbox_init_sql(), sqlbox_port, sqlbox_port_ssl, and sqlbox_status.

Referenced by main().

{
    CfgGroup *grp;
    Octstr *logfile;
    long lvl;

    /* some default values */
    sqlbox_port_ssl = 0;
    bearerbox_port = BB_DEFAULT_SMSBOX_PORT;
    bearerbox_port_ssl = 0;
    logfile = NULL;
    lvl = 0;

    /*
     * first we take the port number in bearerbox and other values from the
     * core group in configuration file
    */

    grp = cfg_get_single_group(cfg, octstr_imm("sqlbox"));
    if (cfg_get_integer(&bearerbox_port, grp, octstr_imm("bearerbox-port")) == -1)
        panic(0, "Missing or bad 'bearerbox-port' in sqlbox group");
#ifdef HAVE_LIBSSL
    cfg_get_bool(&bearerbox_port_ssl, grp, octstr_imm("smsbox-port-ssl"));
    conn_config_ssl(grp);
#endif

    grp = cfg_get_single_group(cfg, octstr_imm("sqlbox"));
    if (grp == NULL)
        panic(0, "No 'sqlbox' group in configuration");

    bearerbox_host = cfg_get( grp, octstr_imm("bearerbox-host"));
    if (bearerbox_host == NULL)
        bearerbox_host = octstr_create(BB_DEFAULT_HOST);

    sqlbox_id = cfg_get(grp, octstr_imm("smsbox-id"));
    global_sender = cfg_get(grp, octstr_imm("global-sender"));

    if (cfg_get_integer(&sqlbox_port, grp, octstr_imm("smsbox-port")) == -1)
        sqlbox_port = 13005;

    /* setup limit per cycle */
    if (cfg_get_integer(&limit_per_cycle, grp, octstr_imm("limit-per-cycle")) == -1)
        limit_per_cycle = DEFAULT_LIMIT_PER_CYCLE;

    /* set up save parameters */
    if (cfg_get_bool(&save_mo, grp, octstr_imm("save-mo")) == -1)
        save_mo = 1;

    if (cfg_get_bool(&save_mt, grp, octstr_imm("save-mt")) == -1)
        save_mt = 1;

    if (cfg_get_bool(&save_dlr, grp, octstr_imm("save-dlr")) == -1)
        save_dlr = 1;

    /* setup logfile stuff */
    logfile = cfg_get(grp, octstr_imm("log-file"));

    cfg_get_integer(&lvl, grp, octstr_imm("log-level"));

    if (logfile != NULL) {
        info(0, "Starting to log to file %s level %ld",
            octstr_get_cstr(logfile), lvl);
        log_open(octstr_get_cstr(logfile), lvl, GW_NON_EXCL);
        octstr_destroy(logfile);
    }

    sql_type = sqlbox_init_sql(cfg);
    if (sql_type == NULL) {
        panic(0, "No proper SQL server defined.");
    }

    gw_sql_enter(cfg);

    sqlbox_status = SQL_RUNNING;
}

main()

int main	(	int	argc,
		char **	argv
	)

Definition at line 862 of file sqlbox.c.

References cfg, cfg_add_hooks(), cfg_create(), cfg_destroy(), cfg_read(), check_args(), filename, get_and_set_debugs(), gw_sql_leave, gwlib_init(), gwlib_shutdown(), gwthread_sleep(), init_sqlbox(), octstr_create, octstr_destroy(), octstr_get_cstr, panic, report_versions(), restart_sqlbox, setup_signal_handlers(), sqlbox_is_allowed_in_group(), sqlbox_is_single_group(), sqlbox_port, and sqlboxc_run().

{
    int cf_index;
    Octstr *filename;

    gwlib_init();

    cf_index = get_and_set_debugs(argc, argv, check_args);
    setup_signal_handlers();

    if (argv[cf_index] == NULL) {
        filename = octstr_create("sqlbox.conf");
    } else {
        filename = octstr_create(argv[cf_index]);
    }

    cfg = cfg_create(filename);

    /* Adding cfg-checks to core */

    cfg_add_hooks(sqlbox_is_allowed_in_group, sqlbox_is_single_group);

    if (cfg_read(cfg) == -1)
        panic(0, "Couldn't read configuration from `%s'.", octstr_get_cstr(filename));

    octstr_destroy(filename);

    report_versions("sqlbox");

    init_sqlbox(cfg);

    sqlboxc_run((void *)sqlbox_port);

    cfg_destroy(cfg);
    if (restart_sqlbox) {
        gwthread_sleep(1.0);
    }

    gw_sql_leave();
    gwlib_shutdown();

    if (restart_sqlbox)
        execvp(argv[0], argv);
    return 0;
}

read_from_box()

static Msg* read_from_box ( Connection *  conn, Boxc *  boxconn  )

static

Definition at line 210 of file sqlbox.c.

References _boxc::alive, msg, and read_from_bearerbox_real().

Referenced by bearerbox_to_smsbox(), bearerbox_to_sql(), and smsbox_to_bearerbox().

{
    Msg *msg;

    while (boxconn->alive) {
    switch (read_from_bearerbox_real(conn, &msg, 1.0)) {
    case -1:
        /* connection to bearerbox lost */
        return NULL;
        break;
    case  0:
        /* all is well */
        return msg;
        break;
    case  1:
        /* timeout */
        break;
    }
    }

    return NULL;
}

run_sqlbox()

static void run_sqlbox ( void *  arg )

static

Definition at line 449 of file sqlbox.c.

References accept_boxc(), _boxc::bearerbox_connection, bearerbox_host, bearerbox_port, bearerbox_port_ssl, bearerbox_to_smsbox(), boxc_destroy(), _boxc::client_ip, connect_to_bearerbox_real(), error(), gwthread_create, gwthread_join(), octstr_get_cstr, panic, smsbox_to_bearerbox(), and sqlbox_port_ssl.

Referenced by sqlboxc_run().

{
    int fd;
    Boxc *newconn;
    long sender;

    fd = (int)arg;
    newconn = accept_boxc(fd, sqlbox_port_ssl);
    if (newconn == NULL) {
        panic(0, "Socket accept failed");
        return;
    }
    newconn->bearerbox_connection = connect_to_bearerbox_real(bearerbox_host, bearerbox_port, bearerbox_port_ssl, NULL /* bb_our_host */);
    /* XXX add our_host if required */


    sender = gwthread_create(bearerbox_to_smsbox, newconn);
    if (sender == -1) {
        error(0, "Failed to start a new thread, disconnecting client <%s>",
              octstr_get_cstr(newconn->client_ip));
        //goto cleanup;
    }
    smsbox_to_bearerbox(newconn);
    gwthread_join(sender);
    boxc_destroy(newconn);
}

send_msg()

static int send_msg ( Connection *  conn, Boxc *  boxconn, Msg *  pmsg  )

static

Definition at line 242 of file sqlbox.c.

References _boxc::client_ip, conn_write_withlen(), error(), msg_pack(), octstr_destroy(), and octstr_get_cstr.

Referenced by bearerbox_to_smsbox(), bearerbox_to_sql(), identify_to_bearerbox(), smsbox_to_bearerbox(), sql_list(), and sql_single().

{
    Octstr *pack;

    pack = msg_pack(pmsg);

    if (pack == NULL)
        return -1;

    if (conn_write_withlen(conn, pack) == -1) {
        error(0, "Couldn't write Msg to box <%s>, disconnecting",
          octstr_get_cstr(boxconn->client_ip));
        octstr_destroy(pack);
        return -1;
    }
    octstr_destroy(pack);
    return 0;
}

setup_signal_handlers()

static void setup_signal_handlers ( void  )

static

Definition at line 762 of file sqlbox.c.

References signal_handler().

Referenced by main().

                                        {
    struct sigaction act;

    act.sa_handler = signal_handler;
    sigemptyset(&act.sa_mask);
    act.sa_flags = 0;
    sigaction(SIGINT, &act, NULL);
    sigaction(SIGQUIT, &act, NULL);
    sigaction(SIGHUP, &act, NULL);
    sigaction(SIGPIPE, &act, NULL);
}

signal_handler()

static void signal_handler ( int  signum )

static

Definition at line 728 of file sqlbox.c.

References alog_reopen(), error(), gwthread_shouldhandlesignal(), log_reopen(), SQL_RUNNING, SQL_SHUTDOWN, sqlbox_status, and warning().

Referenced by setup_signal_handlers().

                                       {
    /* On some implementations (i.e. linuxthreads), signals are delivered
     * to all threads.  We only want to handle each signal once for the
     * entire box, and we let the gwthread wrapper take care of choosing
     * one.
     */
    if (!gwthread_shouldhandlesignal(signum))
        return;

    switch (signum) {
        case SIGINT:
            if (sqlbox_status == SQL_RUNNING) {
                error(0, "SIGINT received, aborting program...");
                sqlbox_status = SQL_SHUTDOWN;
            }
            break;

        case SIGHUP:
            warning(0, "SIGHUP received, catching and re-opening logs");
            log_reopen();
            alog_reopen();
            break;
        /*
         * It would be more proper to use SIGUSR1 for this, but on some
         * platforms that's reserved by the pthread support.
         */
        case SIGQUIT:
           warning(0, "SIGQUIT received, reporting memory usage.");
           gw_check_leaks();
           break;
    }
}

smsbox_to_bearerbox()

static void smsbox_to_bearerbox ( void *  arg )

static

Definition at line 261 of file sqlbox.c.

References _boxc::alive, _boxc::bearerbox_connection, _boxc::boxc_id, _boxc::client_ip, cmd_identify, debug(), gw_sql_save_msg, msg, msg_destroy(), msg_duplicate(), octstr_get_cstr, octstr_imm(), read_from_box(), save_mt, send_msg(), SMS_PARAM_UNDEFINED, _boxc::smsbox_connection, SQL_RUNNING, and sqlbox_status.

Referenced by run_sqlbox().

{
    Boxc *conn = arg;
    Msg *msg, *msg_escaped;

    /* remove messages from socket until it is closed */
    while (sqlbox_status == SQL_RUNNING && conn->alive) {

        //list_consume(suspended);    /* block here if suspended */

        msg = read_from_box(conn->smsbox_connection, conn);

        if (msg == NULL) {    /* garbage/connection lost */
            conn->alive = 0;
            break;
        }

        if (msg_type(msg) == sms) {
            debug("sqlbox", 0, "smsbox_to_bearerbox: sms received");
            if (save_mt) {
                msg_escaped = msg_duplicate(msg);
                /* convert validity & deferred to minutes */
                if (msg_escaped->sms.validity != SMS_PARAM_UNDEFINED)
                    msg_escaped->sms.validity = (msg_escaped->sms.validity - time(NULL))/60;
                if (msg_escaped->sms.deferred != SMS_PARAM_UNDEFINED)
                    msg_escaped->sms.deferred = (msg_escaped->sms.deferred - time(NULL))/60;
                gw_sql_save_msg(msg_escaped, octstr_imm("MT"));
                msg_destroy(msg_escaped);
            }
        }

        send_msg(conn->bearerbox_connection, conn, msg);

        /* if this is an identification message from an smsbox instance */
        if (msg_type(msg) == admin && msg->admin.command == cmd_identify) {
            /*
             * any smsbox sends this command even if boxc_id is NULL,
             * but we will only consider real identified boxes
             */
            if (msg->admin.boxc_id != NULL) {

                /* and add the boxc_id into conn for boxc_status() output */
                conn->boxc_id = msg->admin.boxc_id;
                msg->admin.boxc_id = NULL;

                debug("sqlbox", 0, "smsbox_to_bearerbox: got boxc_id <%s> from <%s>",
                      octstr_get_cstr(conn->boxc_id),
                      octstr_get_cstr(conn->client_ip));
            }
        }
        msg_destroy(msg);
    }
    conn->alive = 0;
}

sql_list()

static void sql_list ( Boxc *  boxc )

static

Definition at line 615 of file sqlbox.c.

References _boxc::alive, _boxc::bearerbox_connection, charset_processing(), error(), global_sender, gw_sql_fetch_msg_list, gw_sql_save_list, gwlist_add_producer(), gwlist_consume(), gwlist_create, gwlist_destroy(), gwlist_len(), gwlist_produce(), gwlist_remove_producer(), gwthread_sleep(), limit_per_cycle, msg, msg_destroy(), msg_destroy_item(), octstr_duplicate, octstr_imm(), octstr_len(), save_mt, send_msg(), SLEEP_BETWEEN_EMPTY_SELECTS, SMS_PARAM_UNDEFINED, SQL_RUNNING, and sqlbox_status.

Referenced by sql_to_bearerbox().

{
    Msg *msg;
    List *qlist, *save_list;

    qlist = gwlist_create();
    gwlist_add_producer(qlist);
    save_list = gwlist_create();
    gwlist_add_producer(save_list);

    while (sqlbox_status == SQL_RUNNING && boxc->alive) {
    if ( gw_sql_fetch_msg_list(qlist, limit_per_cycle) > 0 ) {
        while((gwlist_len(qlist)>0) && ((msg = gwlist_consume(qlist)) != NULL )) {
                if (charset_processing(msg) == -1) {
                    error(0, "Could not charset process message, dropping it!");
                    msg_destroy(msg);
                    continue;
                }
                if (global_sender != NULL && (msg->sms.sender == NULL || octstr_len(msg->sms.sender) == 0)) {
                    msg->sms.sender = octstr_duplicate(global_sender);
                }
                /* convert validity and deferred to unix timestamp */
                if (msg->sms.validity != SMS_PARAM_UNDEFINED)
                    msg->sms.validity = time(NULL) + msg->sms.validity * 60;
                if (msg->sms.deferred != SMS_PARAM_UNDEFINED)
                    msg->sms.deferred = time(NULL) + msg->sms.deferred * 60;
                send_msg(boxc->bearerbox_connection, boxc, msg);
    
                /* convert validity & deferred back to minutes */
                if (save_mt && msg->sms.validity != SMS_PARAM_UNDEFINED)
                    msg->sms.validity = (msg->sms.validity - time(NULL))/60;
                if (save_mt && msg->sms.deferred != SMS_PARAM_UNDEFINED)
                    msg->sms.deferred = (msg->sms.deferred - time(NULL))/60;
        gwlist_produce(save_list, msg);
            }
            /* save_list also deletes and destroys messages */
        gw_sql_save_list(save_list, octstr_imm("MT"), save_mt);
        }
        else {
            gwthread_sleep(SLEEP_BETWEEN_EMPTY_SELECTS);
        }
    }

    gwlist_remove_producer(qlist);
    gwlist_remove_producer(save_list);
    gwlist_destroy(qlist, msg_destroy_item);
    gwlist_destroy(save_list, msg_destroy_item);
}

sql_single()

static void sql_single ( Boxc *  boxc )

static

Definition at line 576 of file sqlbox.c.

References _boxc::alive, _boxc::bearerbox_connection, charset_processing(), error(), global_sender, gw_sql_fetch_msg, gw_sql_save_msg, gwthread_sleep(), msg, msg_destroy(), octstr_duplicate, octstr_imm(), octstr_len(), save_mt, send_msg(), SLEEP_BETWEEN_EMPTY_SELECTS, SMS_PARAM_UNDEFINED, SQL_RUNNING, and sqlbox_status.

Referenced by sql_to_bearerbox().

{
    Msg *msg;

    while (sqlbox_status == SQL_RUNNING && boxc->alive) {
        if ((msg = gw_sql_fetch_msg()) != NULL) {
            if (charset_processing(msg) == -1) {
                error(0, "Could not charset process message, dropping it!");
                msg_destroy(msg);
                continue;
            }
            if (global_sender != NULL && (msg->sms.sender == NULL || octstr_len(msg->sms.sender) == 0)) {
                msg->sms.sender = octstr_duplicate(global_sender);
            }
            /* convert validity and deferred to unix timestamp */
            if (msg->sms.validity != SMS_PARAM_UNDEFINED)
                msg->sms.validity = time(NULL) + msg->sms.validity * 60;
            if (msg->sms.deferred != SMS_PARAM_UNDEFINED)
                msg->sms.deferred = time(NULL) + msg->sms.deferred * 60;
            send_msg(boxc->bearerbox_connection, boxc, msg);

            if (save_mt) {
                /* convert validity & deferred back to minutes
                 * TODO clarify why we fetched message from DB and then insert it back here???
                 */
                if (msg->sms.validity != SMS_PARAM_UNDEFINED)
                    msg->sms.validity = (msg->sms.validity - time(NULL))/60;
                if (msg->sms.deferred != SMS_PARAM_UNDEFINED)
                    msg->sms.deferred = (msg->sms.deferred - time(NULL))/60;
                gw_sql_save_msg(msg, octstr_imm("MT"));
            }
        }
        else {
            gwthread_sleep(SLEEP_BETWEEN_EMPTY_SELECTS);
        }
        msg_destroy(msg);
    }
}

sql_to_bearerbox()

static void sql_to_bearerbox ( void *  arg )

static

Definition at line 664 of file sqlbox.c.

References _boxc::alive, _boxc::bearerbox_connection, bearerbox_host, bearerbox_port, bearerbox_port_ssl, bearerbox_to_sql(), boxc_destroy(), _boxc::boxc_id, _boxc::client_ip, _boxc::connect_time, connect_to_bearerbox_real(), gw_sql_fetch_msg_list, gw_sql_save_list, gwthread_create, identify_to_bearerbox(), limit_per_cycle, octstr_duplicate, _boxc::smsbox_connection, sql_list(), sql_single(), and sqlbox_id.

Referenced by sqlboxc_run().

{
    Boxc *boxc;

    boxc = gw_malloc(sizeof(Boxc));
    boxc->bearerbox_connection = connect_to_bearerbox_real(bearerbox_host, bearerbox_port, bearerbox_port_ssl, NULL /* bb_our_host */);
    boxc->smsbox_connection = NULL;
    boxc->client_ip = NULL;
    boxc->alive = 1;
    boxc->connect_time = time(NULL);
    boxc->boxc_id = octstr_duplicate(sqlbox_id);
    if (boxc->bearerbox_connection == NULL) {
        boxc_destroy(boxc);
        return;
    }

    gwthread_create(bearerbox_to_sql, boxc);
    identify_to_bearerbox(boxc);

    if (gw_sql_fetch_msg_list == NULL || gw_sql_save_list == NULL || limit_per_cycle <= 1) {
        sql_single(boxc);
    }
    else {
        sql_list(boxc);
    }

    boxc_destroy(boxc);
}

sqlbox_is_allowed_in_group()

static int sqlbox_is_allowed_in_group ( Octstr *  group, Octstr *  variable  )

static

Definition at line 115 of file sqlbox.c.

References octstr_imm().

Referenced by main().

{
    Octstr *groupstr;

    groupstr = octstr_imm("group");

    #define OCTSTR(name) \
        if (octstr_compare(octstr_imm(#name), variable) == 0) \
        return 1;
    #define SINGLE_GROUP(name, fields) \
        if (octstr_compare(octstr_imm(#name), group) == 0) { \
        if (octstr_compare(groupstr, variable) == 0) \
        return 1; \
        fields \
        return 0; \
    }
    #define MULTI_GROUP(name, fields) \
        if (octstr_compare(octstr_imm(#name), group) == 0) { \
        if (octstr_compare(groupstr, variable) == 0) \
        return 1; \
        fields \
        return 0; \
    }
    #include "sqlbox-cfg.def"

    return 0;
}

sqlbox_is_single_group()

static int sqlbox_is_single_group ( Octstr *  query )

static

Definition at line 147 of file sqlbox.c.

Referenced by main().

{
    #define OCTSTR(name)
    #define SINGLE_GROUP(name, fields) \
        if (octstr_compare(octstr_imm(#name), query) == 0) \
        return 1;
    #define MULTI_GROUP(name, fields) \
        if (octstr_compare(octstr_imm(#name), query) == 0) \
        return 0;
    #include "sqlbox-cfg.def"
    return 0;
}

sqlboxc_run()

static void sqlboxc_run ( void *  arg )

static

Definition at line 693 of file sqlbox.c.

References gwthread_create, make_server_socket(), panic, port, run_sqlbox(), sql_to_bearerbox(), and wait_for_connections().

Referenced by main().

{
    int fd;
    int port;

    /* we will use one thread for SQL sms injections */
    gwthread_create(sql_to_bearerbox, NULL);

    port = (int)arg;

    fd = make_server_socket(port, NULL);
        /* XXX add interface_name if required */

    if (fd < 0) {
        panic(0, "Could not open sqlbox port %d", port);
    }

    /*
     * infinitely wait for new connections;
     * to shut down the system, SIGTERM is send and then
     * select drops with error, so we can check the status
     */

    wait_for_connections(fd, run_sqlbox, NULL);

    /* close listen socket */
    close(fd);
}

wait_for_connections()

static void wait_for_connections ( int  fd, void(*)(void *arg)  function, List *  waited  )

static

Definition at line 476 of file sqlbox.c.

References error(), gw_assert(), gwthread_create, gwthread_pollfd(), gwthread_sleep(), POLLIN, SQL_RUNNING, SQL_SHUTDOWN, and sqlbox_status.

Referenced by sqlboxc_run().

{
    int ret;
    int timeout = 10; /* 10 sec. */

    gw_assert(function != NULL);

    while(sqlbox_status == SQL_RUNNING) {

        ret = gwthread_pollfd(fd, POLLIN, 1.0);
        if (sqlbox_status == SQL_SHUTDOWN) {
            if (ret == -1 || !timeout)
                    break;
                else
                    timeout--;
        }

        if (ret > 0) {
            gwthread_create(function, (void *)fd);
            gwthread_sleep(1.0);
        } else if (ret < 0) {
            if(errno==EINTR) continue;
            if(errno==EAGAIN) continue;
            error(errno, "wait_for_connections failed");
        }
    }
}

Variable Documentation

bearerbox_host

Octstr* bearerbox_host

static

Definition at line 85 of file sqlbox.c.

Referenced by init_sqlbox(), run_sqlbox(), and sql_to_bearerbox().

bearerbox_port

long bearerbox_port

static

Definition at line 84 of file sqlbox.c.

Referenced by init_sqlbox(), run_sqlbox(), and sql_to_bearerbox().

bearerbox_port_ssl

int bearerbox_port_ssl = 0

static

Definition at line 86 of file sqlbox.c.

Referenced by init_sqlbox(), run_sqlbox(), and sql_to_bearerbox().

cfg

Cfg* cfg

static

Definition at line 75 of file sqlbox.c.

Referenced by init_sqlbox(), and main().

global_sender

Octstr* global_sender

static

Definition at line 87 of file sqlbox.c.

Referenced by init_sqlbox(), sql_list(), and sql_single().

limit_per_cycle

long limit_per_cycle

static

Definition at line 88 of file sqlbox.c.

Referenced by init_sqlbox(), sql_list(), and sql_to_bearerbox().

restart_sqlbox

volatile sig_atomic_t restart_sqlbox = 0

static

Definition at line 77 of file sqlbox.c.

Referenced by main().

save_dlr

int save_dlr

static

Definition at line 89 of file sqlbox.c.

Referenced by bearerbox_to_smsbox(), bearerbox_to_sql(), and init_sqlbox().

save_mo

int save_mo

static

Definition at line 89 of file sqlbox.c.

Referenced by bearerbox_to_smsbox(), bearerbox_to_sql(), and init_sqlbox().

save_mt

int save_mt

static

Definition at line 89 of file sqlbox.c.

Referenced by init_sqlbox(), smsbox_to_bearerbox(), sql_list(), and sql_single().

sqlbox_id

Octstr* sqlbox_id

Definition at line 95 of file sqlbox.c.

Referenced by init_sqlbox(), and sql_to_bearerbox().

sqlbox_port

long sqlbox_port

static

Definition at line 82 of file sqlbox.c.

Referenced by init_sqlbox(), and main().

sqlbox_port_ssl

int sqlbox_port_ssl = 0

static

Definition at line 83 of file sqlbox.c.

Referenced by init_sqlbox(), and run_sqlbox().

sqlbox_status

volatile sig_atomic_t sqlbox_status

static

Definition at line 78 of file sqlbox.c.

Referenced by bearerbox_to_smsbox(), bearerbox_to_sql(), init_sqlbox(), signal_handler(), smsbox_to_bearerbox(), sql_list(), sql_single(), and wait_for_connections().