smsc_loopback.c File Reference

#include "gwlib/gwlib.h"
#include "smscconn.h"
#include "smscconn_p.h"
#include "bb_smscconn_cb.h"
#include "dlr.h"

Go to the source code of this file.

Macros
#define	O_DESTROY(a)   { octstr_destroy(a); a = NULL; }

Functions
static int	msg_cb (SMSCConn *conn, Msg *msg)
static int	shutdown_cb (SMSCConn *conn, int finish_sending)
static void	start_cb (SMSCConn *conn)
static long	queued_cb (SMSCConn *conn)
int	smsc_loopback_create (SMSCConn *conn, CfgGroup *cfg)

Macro Definition Documentation

O_DESTROY

#define O_DESTROY

(

a

)

{ octstr_destroy(a); a = NULL; }

Definition at line 73 of file smsc_loopback.c.

Referenced by msg_cb().

Function Documentation

msg_cb()

static int msg_cb ( SMSCConn *  conn, Msg *  msg  )

static

Definition at line 76 of file smsc_loopback.c.

References bb_smscconn_receive(), bb_smscconn_sent(), dlr_add(), DLR_IS_ENABLED_DEVICE, smscconn::id, mo, msg, msg_duplicate(), MSG_PARAM_UNDEFINED, O_DESTROY, octstr_create, octstr_destroy(), octstr_duplicate, smscconn::reroute_to_smsc, uuid_clear(), uuid_generate(), uuid_is_null(), UUID_STR_LEN, and uuid_unparse().

Referenced by smsc_loopback_create().

{
    Msg *sms;
    
    /* create duplicates first */
    sms = msg_duplicate(msg);
    
    /* store temporary DLR data for SMSC ACK */
    if (DLR_IS_ENABLED_DEVICE(msg->sms.dlr_mask) && !uuid_is_null(sms->sms.id)) {
        Octstr *mid;
        char id[UUID_STR_LEN + 1];

        uuid_unparse(sms->sms.id, id);
        mid = octstr_create(id);

        dlr_add(conn->id, mid, sms, 0);
        
        octstr_destroy(mid);
    }

    /* 
     * Inform abstraction layer of sent event,
     * it will also take care of DLR SMSC events.
     */
    bb_smscconn_sent(conn, sms, NULL);

    /* now change msg type to reflect flow type */
    sms = msg_duplicate(msg);
    sms->sms.sms_type = mo;
    
    /* Since this is a new MO now, make sure that the
     * values we have still from the MT are cleaned. */
    uuid_clear(sms->sms.id); 
    uuid_generate(sms->sms.id);
    O_DESTROY(sms->sms.boxc_id);
    sms->sms.dlr_mask = MSG_PARAM_UNDEFINED;
    O_DESTROY(sms->sms.dlr_url);
    
    /* 
     * If there is a reroute-smsc-id in the config group,
     * then let's use that value, otherwise assign the
     * smsc-id canonical name for the MO. 
     * This re-assignment of the smsc-id provides some
     * MO routing capabilities, i.e. via smsbox-route group.
     */
    octstr_destroy(sms->sms.smsc_id);
    
    if (conn->reroute_to_smsc) {
        sms->sms.smsc_id = octstr_duplicate(conn->reroute_to_smsc);
    } else {
        sms->sms.smsc_id = octstr_duplicate(conn->id);
    }
    
    /* now pass back again as MO to the abstraction layer */
    bb_smscconn_receive(conn, sms);

    return 0;
}

queued_cb()

static long queued_cb ( SMSCConn *  conn )

static

Definition at line 156 of file smsc_loopback.c.

References smscconn::load.

Referenced by smsc_loopback_create().

{
    long ret = 0;

    conn->load = ret;
    return ret;
}

shutdown_cb()

static int shutdown_cb ( SMSCConn *  conn, int  finish_sending  )

static

Definition at line 136 of file smsc_loopback.c.

References bb_smscconn_killed(), debug(), smscconn::name, octstr_get_cstr, SMSCCONN_DEAD, SMSCCONN_KILLED_SHUTDOWN, smscconn::status, and smscconn::why_killed.

Referenced by smsc_loopback_create().

{
    debug("smsc.loopback", 0, "Shutting down SMSCConn %s", 
          octstr_get_cstr(conn->name));

    conn->why_killed = SMSCCONN_KILLED_SHUTDOWN;
    conn->status = SMSCCONN_DEAD;
    bb_smscconn_killed();
        
    return 0;
}

smsc_loopback_create()

int smsc_loopback_create	(	SMSCConn *	conn,
		CfgGroup *	cfg
	)

Definition at line 165 of file smsc_loopback.c.

References smscconn::connect_time, smscconn::data, smscconn::id, msg_cb(), smscconn::name, octstr_format(), smscconn::queued, queued_cb(), smscconn::send_msg, smscconn::shutdown, shutdown_cb(), SMSCCONN_CONNECTING, start_cb(), smscconn::start_conn, and smscconn::status.

Referenced by smscconn_create().

{
    conn->data = NULL;
    conn->name = octstr_format("LOOPBACK:%S", conn->id);
  
    conn->status = SMSCCONN_CONNECTING;
    conn->connect_time = time(NULL);

    conn->shutdown = shutdown_cb;
    conn->queued = queued_cb;
    conn->start_conn = start_cb;
    conn->send_msg = msg_cb;

    return 0;
}

start_cb()

static void start_cb ( SMSCConn *  conn )

static

Definition at line 149 of file smsc_loopback.c.

References smscconn::connect_time, SMSCCONN_ACTIVE, and smscconn::status.

Referenced by smsc_loopback_create().

{
    conn->status = SMSCCONN_ACTIVE;
    conn->connect_time = time(NULL);
}