dlr.h File Reference

Go to the source code of this file.

Macros
#define	DLR_UNDEFINED   -1
#define	DLR_NOTHING   0x00
#define	DLR_SUCCESS   0x01
#define	DLR_FAIL   0x02
#define	DLR_BUFFERED   0x04
#define	DLR_SMSC_SUCCESS   0x08
#define	DLR_SMSC_FAIL   0x10
#define	DLR_EXPIRED   0x20|DLR_FAIL
#define	DLR_UNKNOWN   0x40|DLR_FAIL
#define	DLR_IS_DEFINED(dlr)   (dlr != DLR_UNDEFINED)
#define	DLR_IS_ENABLED(dlr)   (DLR_IS_DEFINED(dlr) && (dlr & (DLR_SUCCESS | DLR_FAIL | DLR_BUFFERED | DLR_SMSC_SUCCESS | DLR_SMSC_FAIL | DLR_EXPIRED | DLR_UNKNOWN)))
#define	DLR_IS_ENABLED_DEVICE(dlr)   (DLR_IS_DEFINED(dlr) && (dlr & (DLR_SUCCESS | DLR_FAIL | DLR_BUFFERED | DLR_EXPIRED | DLR_UNKNOWN)))
#define	DLR_IS_ENABLED_SMSC(dlr)   (DLR_IS_DEFINED(dlr) && (dlr & (DLR_SMSC_SUCCESS | DLR_SMSC_FAIL)))
#define	DLR_IS_NOT_FINAL(dlr)   (DLR_IS_DEFINED(dlr) && (dlr & (DLR_BUFFERED | DLR_SMSC_SUCCESS)))
#define	DLR_IS_SUCCESS_OR_FAIL(dlr)   (DLR_IS_DEFINED(dlr) && (dlr & (DLR_SUCCESS | DLR_FAIL | DLR_EXPIRED | DLR_UNKNOWN)))
#define	DLR_IS_SUCCESS(dlr)   (DLR_IS_DEFINED(dlr) && (dlr & DLR_SUCCESS))
#define	DLR_IS_FAIL(dlr)   (DLR_IS_DEFINED(dlr) && (dlr & (DLR_FAIL|DLR_EXPIRED|DLR_UNKNOWN)))
#define	DLR_IS_BUFFERED(dlr)   (DLR_IS_DEFINED(dlr) && (dlr & DLR_BUFFERED))
#define	DLR_IS_SMSC_SUCCESS(dlr)   (DLR_IS_DEFINED(dlr) && (dlr & DLR_SMSC_SUCCESS))
#define	DLR_IS_SMSC_FAIL(dlr)   (DLR_IS_DEFINED(dlr) && (dlr & DLR_SMSC_FAIL))

Functions
void	dlr_init (Cfg *cfg)
void	dlr_shutdown (void)
void	dlr_add (const Octstr *smsc, const Octstr *ts, Msg *msg, int use_dst)
Msg *	dlr_find (const Octstr *smsc, const Octstr *ts, const Octstr *dst, int type, int use_dst)
long	dlr_messages (void)
void	dlr_flush (void)
const char *	dlr_type (void)
Msg *	create_dlr_from_msg (const Octstr *smsc, const Msg *msg, const Octstr *reply, long stat)
void	dlr_save (const char *filename)
void	dlr_load (const char *filename)

Macro Definition Documentation

DLR_BUFFERED

#define DLR_BUFFERED   0x04

Definition at line 74 of file dlr.h.

Referenced by at2_pdu_decode_report_sm(), cgw_handle_op(), clickatell_receive_sms(), clickatell_send_sms(), handle_dlr(), handle_operation(), msg_to_pdu(), soap_parse_dlr(), and xidris_receive_sms().

DLR_EXPIRED

#define DLR_EXPIRED   0x20|DLR_FAIL

Definition at line 77 of file dlr.h.

Referenced by cimd2_accept_delivery_report_message(), clickatell_receive_sms(), clickatell_send_sms(), handle_dlr(), and msg_to_pdu().

DLR_FAIL

#define DLR_FAIL   0x02

Definition at line 73 of file dlr.h.

Referenced by at2_pdu_decode_report_sm(), cgw_handle_op(), cimd2_accept_delivery_report_message(), clickatell_receive_sms(), clickatell_send_sms(), handle_dlr(), handle_operation(), msg_to_pdu(), oisd_accept_delivery_report_message(), pdu_to_msg(), soap_parse_dlr(), and xidris_receive_sms().

DLR_IS_BUFFERED

#define DLR_IS_BUFFERED

(

dlr

)

(DLR_IS_DEFINED(dlr) && (dlr & DLR_BUFFERED))

Definition at line 88 of file dlr.h.

Referenced by msg_to_emimsg(), and msg_to_pdu().

DLR_IS_DEFINED

#define DLR_IS_DEFINED

(

dlr

)

(dlr != DLR_UNDEFINED)

Definition at line 80 of file dlr.h.

DLR_IS_ENABLED

#define DLR_IS_ENABLED

(

dlr

)

(DLR_IS_DEFINED(dlr) && (dlr & (DLR_SUCCESS | DLR_FAIL | DLR_BUFFERED | DLR_SMSC_SUCCESS | DLR_SMSC_FAIL | DLR_EXPIRED | DLR_UNKNOWN)))

Definition at line 81 of file dlr.h.

Referenced by create_dlr_from_msg(), dlr_add(), handle_pdu(), main(), send_message(), and sms_split().

DLR_IS_ENABLED_DEVICE

#define DLR_IS_ENABLED_DEVICE

(

dlr

)

(DLR_IS_DEFINED(dlr) && (dlr & (DLR_SUCCESS | DLR_FAIL | DLR_BUFFERED | DLR_EXPIRED | DLR_UNKNOWN)))

Definition at line 82 of file dlr.h.

Referenced by add_msg_cb(), at2_pdu_encode(), at2_send_one_message(), cgw_handle_op(), clickatell_parse_reply(), clickatell_send_sms(), emi2_handle_smscreq(), generic_parse_reply(), handle_pdu(), kannel_parse_reply(), msg_cb(), msg_to_cgwop(), msg_to_emimsg(), and xidris_parse_reply().

DLR_IS_ENABLED_SMSC

#define DLR_IS_ENABLED_SMSC

(

dlr

)

(DLR_IS_DEFINED(dlr) && (dlr & (DLR_SMSC_SUCCESS | DLR_SMSC_FAIL)))

Definition at line 83 of file dlr.h.

Referenced by soap_o2o_dlrmask_smsc_yn_attribute().

DLR_IS_FAIL

#define DLR_IS_FAIL

(

dlr

)

(DLR_IS_DEFINED(dlr) && (dlr & (DLR_FAIL|DLR_EXPIRED|DLR_UNKNOWN)))

Definition at line 87 of file dlr.h.

Referenced by bb_smscconn_send_failed(), and msg_to_pdu().

DLR_IS_NOT_FINAL

#define DLR_IS_NOT_FINAL

(

dlr

)

(DLR_IS_DEFINED(dlr) && (dlr & (DLR_BUFFERED | DLR_SMSC_SUCCESS)))

Definition at line 84 of file dlr.h.

Referenced by dlr_find().

DLR_IS_SMSC_FAIL

#define DLR_IS_SMSC_FAIL

(

dlr

)

(DLR_IS_DEFINED(dlr) && (dlr & DLR_SMSC_FAIL))

Definition at line 90 of file dlr.h.

Referenced by bb_smscconn_send_failed().

DLR_IS_SMSC_SUCCESS

#define DLR_IS_SMSC_SUCCESS

(

dlr

)

(DLR_IS_DEFINED(dlr) && (dlr & DLR_SMSC_SUCCESS))

Definition at line 89 of file dlr.h.

Referenced by bb_smscconn_sent().

DLR_IS_SUCCESS

#define DLR_IS_SUCCESS

(

dlr

)

(DLR_IS_DEFINED(dlr) && (dlr & DLR_SUCCESS))

Definition at line 86 of file dlr.h.

Referenced by msg_to_pdu(), and soap_o2o_dlrmask_success_01_attribute().

DLR_IS_SUCCESS_OR_FAIL

#define DLR_IS_SUCCESS_OR_FAIL

(

dlr

)

(DLR_IS_DEFINED(dlr) && (dlr & (DLR_SUCCESS | DLR_FAIL | DLR_EXPIRED | DLR_UNKNOWN)))

Definition at line 85 of file dlr.h.

Referenced by cimd2_submit_msg(), dlr_find(), main_connection_loop(), msg_to_pdu(), oisd_submit_msg(), and packet_encode_message().

DLR_NOTHING

#define DLR_NOTHING   0x00

Definition at line 71 of file dlr.h.

Referenced by kannel_send_sms(), and msg_to_pdu().

DLR_SMSC_FAIL

#define DLR_SMSC_FAIL   0x10

Definition at line 76 of file dlr.h.

Referenced by bb_smscconn_send_failed(), msg_to_pdu(), and pdu_to_msg().

DLR_SMSC_SUCCESS

#define DLR_SMSC_SUCCESS   0x08

Definition at line 75 of file dlr.h.

Referenced by bb_smscconn_sent(), and msg_to_pdu().

DLR_SUCCESS

#define DLR_SUCCESS   0x01

Definition at line 72 of file dlr.h.

Referenced by at2_pdu_decode_report_sm(), cgw_handle_op(), cimd2_accept_delivery_report_message(), clickatell_receive_sms(), clickatell_send_sms(), handle_dlr(), handle_operation(), main_connection_loop(), msg_to_pdu(), oisd_accept_delivery_report_message(), pdu_to_msg(), soap_parse_dlr(), and xidris_receive_sms().

DLR_UNDEFINED

#define DLR_UNDEFINED   -1

Definition at line 70 of file dlr.h.

Referenced by create_onetrans(), generic_receive_sms(), kannel_send_sms(), and msg_to_pdu().

DLR_UNKNOWN

#define DLR_UNKNOWN   0x40|DLR_FAIL

Definition at line 78 of file dlr.h.

Referenced by clickatell_receive_sms().

Function Documentation

create_dlr_from_msg()

Msg* create_dlr_from_msg	(	const Octstr *	smsc,
		const Msg *	msg,
		const Octstr *	reply,
		long	stat
	)

Definition at line 501 of file dlr.c.

References debug(), DLR_IS_ENABLED, dlr_mask, gw_assert(), meta_data_set_value(), METADATA_ORIG_MSG_GROUP, METADATA_ORIG_MSG_GROUP_DLR_MASK, msg, msg_create, octstr_create, octstr_destroy(), octstr_duplicate, octstr_format(), octstr_get_cstr, octstr_imm(), reply(), report_mo, and dlr_entry::smsc.

Referenced by bb_smscconn_send_failed(), and bb_smscconn_sent().

{
    Msg *dlrmsg;

    if (msg == NULL)
        return NULL;

    /* generate DLR */
    debug("dlr.dlr", 0,"SMSC[%s]: creating DLR message",
                (smsc ? octstr_get_cstr(smsc) : "UNKNOWN"));

    dlrmsg = msg_create(sms);
    gw_assert(dlrmsg != NULL);

    dlrmsg->sms.service = octstr_duplicate(msg->sms.service);
    dlrmsg->sms.dlr_mask = stat;
    dlrmsg->sms.sms_type = report_mo;
    dlrmsg->sms.smsc_id = octstr_duplicate(smsc ? smsc : msg->sms.smsc_id);
    dlrmsg->sms.sender = octstr_duplicate(msg->sms.sender);
    dlrmsg->sms.receiver = octstr_duplicate(msg->sms.receiver);
    dlrmsg->sms.dlr_url = octstr_duplicate(msg->sms.dlr_url);
    dlrmsg->sms.msgdata = octstr_duplicate(reply);
    dlrmsg->sms.boxc_id = octstr_duplicate(msg->sms.boxc_id);
    dlrmsg->sms.foreign_id = octstr_duplicate(msg->sms.foreign_id);
    time(&dlrmsg->sms.time);
    dlrmsg->sms.meta_data = octstr_duplicate(msg->sms.meta_data);

    /* add original DLR bit-mask, as we do in dlr_find() */
    if (DLR_IS_ENABLED(msg->sms.dlr_mask)) {
        Octstr *dlr_mask = octstr_format("%ld", msg->sms.dlr_mask);
        if (dlrmsg->sms.meta_data == NULL)
            dlrmsg->sms.meta_data = octstr_create("");
        meta_data_set_value(dlrmsg->sms.meta_data, METADATA_ORIG_MSG_GROUP,
                            octstr_imm(METADATA_ORIG_MSG_GROUP_DLR_MASK), dlr_mask, 1);
        octstr_destroy(dlr_mask);
    }

    debug("dlr.dlr", 0,"SMSC[%s]: DLR = %s",
                (smsc ? octstr_get_cstr(smsc) : "UNKNOWN"),
                (dlrmsg->sms.dlr_url ? octstr_get_cstr(dlrmsg->sms.dlr_url) : ""));

    return dlrmsg;
}

dlr_add()

void dlr_add	(	const Octstr *	smsc,
		const Octstr *	ts,
		Msg *	msg,
		int	use_dst
	)

Definition at line 330 of file dlr.c.

References dlr_entry::boxc_id, debug(), dlr_entry::destination, dlr_storage::dlr_add, dlr_entry_create(), DLR_IS_ENABLED, dlr_type(), gw_assert(), handles, dlr_entry::mask, msg, octstr_create, octstr_destroy(), octstr_duplicate, octstr_get_cstr, octstr_len(), dlr_entry::service, dlr_entry::smsc, dlr_entry::source, split, dlr_entry::timestamp, dlr_entry::url, dlr_entry::use_dst, and warning().

Referenced by add_msg_cb(), at2_send_one_message(), cgw_handle_op(), cimd2_submit_msg(), clickatell_parse_reply(), emi2_handle_smscreq(), generic_parse_reply(), handle_pdu(), kannel_parse_reply(), msg_cb(), oisd_submit_msg(), soap_read_response(), and xidris_parse_reply().

{
    struct dlr_entry *dlr = NULL;

    /* Add the foreign_id so all SMSC modules can use it.
     * Obey also the original message in the split_parts list. */
    if (msg->sms.foreign_id != NULL)
        octstr_destroy(msg->sms.foreign_id);
    msg->sms.foreign_id = octstr_duplicate(ts);
    if (msg->sms.split_parts != NULL) {
        struct split_parts *split = msg->sms.split_parts;
        if (split->orig->sms.foreign_id != NULL)
            octstr_destroy(split->orig->sms.foreign_id);
        split->orig->sms.foreign_id = octstr_duplicate(ts);
    }

    if (octstr_len(smsc) == 0) {
        warning(0, "DLR[%s]: Can't add a dlr without smsc-id", dlr_type());
        return;
    }

    /* sanity check */
    if (handles == NULL || handles->dlr_add == NULL || msg == NULL)
        return;

    /* check if delivery receipt requested */
    if (!DLR_IS_ENABLED(msg->sms.dlr_mask))
        return;

     /* allocate new struct dlr_entry struct */
    dlr = dlr_entry_create();
    gw_assert(dlr != NULL);

    /* now copy all values, we are interested in */
    dlr->smsc = (smsc ? octstr_duplicate(smsc) : octstr_create(""));
    dlr->timestamp = (ts ? octstr_duplicate(ts) : octstr_create(""));
    dlr->source = (msg->sms.sender ? octstr_duplicate(msg->sms.sender) : octstr_create(""));
    dlr->destination = (msg->sms.receiver ? octstr_duplicate(msg->sms.receiver) : octstr_create(""));
    dlr->service = (msg->sms.service ? octstr_duplicate(msg->sms.service) : octstr_create(""));
    dlr->url = (msg->sms.dlr_url ? octstr_duplicate(msg->sms.dlr_url) : octstr_create(""));
    dlr->boxc_id = (msg->sms.boxc_id ? octstr_duplicate(msg->sms.boxc_id) : octstr_create(""));
    dlr->mask = msg->sms.dlr_mask;
    dlr->use_dst = use_dst;

    debug("dlr.dlr", 0, "DLR[%s]: Adding DLR smsc=%s, ts=%s, src=%s, dst=%s, mask=%d, boxc=%s",
          dlr_type(), octstr_get_cstr(dlr->smsc), octstr_get_cstr(dlr->timestamp),
          octstr_get_cstr(dlr->source), octstr_get_cstr(dlr->destination), dlr->mask, octstr_get_cstr(dlr->boxc_id));
    
    /* call registered function */
    handles->dlr_add(dlr);
}

dlr_find()

Msg* dlr_find	(	const Octstr *	smsc,
		const Octstr *	ts,
		const Octstr *	dst,
		int	type,
		int	use_dst
	)

Definition at line 387 of file dlr.c.

References dlr_entry::boxc_id, debug(), dlr_entry::destination, dlr_entry_destroy(), dlr_storage::dlr_get, DLR_IS_NOT_FINAL, DLR_IS_SUCCESS_OR_FAIL, dlr_mask, dlr_storage::dlr_remove, dlr_type(), dlr_storage::dlr_update, handles, dlr_entry::mask, meta_data_set_value(), METADATA_ORIG_MSG_GROUP, METADATA_ORIG_MSG_GROUP_DLR_MASK, MIN_DST_LEN, msg, msg_create, O_SET, octstr_create, octstr_delete(), octstr_destroy(), octstr_duplicate, octstr_format(), octstr_get_cstr, octstr_imm(), octstr_len(), report_mo, dlr_entry::service, dlr_entry::smsc, dlr_entry::source, dlr_entry::url, dlr_entry::use_dst, and warning().

Referenced by at2_pdu_decode_report_sm(), cgw_handle_op(), cimd2_accept_delivery_report_message(), clickatell_receive_sms(), generic_receive_sms(), handle_dlr(), handle_operation(), kannel_receive_sms(), main_connection_loop(), msg_to_pdu(), oisd_accept_delivery_report_message(), soap_parse_dlr(), and xidris_receive_sms().

{
    Msg *msg = NULL;
    struct dlr_entry *dlr = NULL;
    Octstr *dst_min = NULL;
    Octstr *dlr_mask;
    
    if(octstr_len(smsc) == 0) {
    warning(0, "DLR[%s]: Can't find a dlr without smsc-id", dlr_type());
        return NULL;
    }

    /* check if we have handler registered */
    if (handles == NULL || handles->dlr_get == NULL)
        return NULL;

    if (use_dst && dst) {
        dst_min = octstr_duplicate(dst);
        int len = octstr_len(dst);

        if (len > MIN_DST_LEN)
            octstr_delete(dst_min, 0, len - MIN_DST_LEN);
    }
    debug("dlr.dlr", 0, "DLR[%s]: Looking for DLR smsc=%s, ts=%s, dst=%s, type=%d",
                                 dlr_type(), octstr_get_cstr(smsc), octstr_get_cstr(ts), octstr_get_cstr(dst), typ);

    dlr = handles->dlr_get(smsc, ts, dst_min);
    if (dlr == NULL)  {
        warning(0, "DLR[%s]: DLR from SMSC<%s> for DST<%s> not found.",
                dlr_type(), octstr_get_cstr(smsc), octstr_get_cstr(dst));         
        return NULL;
    }

#define O_SET(x, val) if (octstr_len(val) > 0) { x = val; val = NULL; }

    if ((typ & dlr->mask) > 0) {
        /* its an entry we are interested in */
        msg = msg_create(sms);
        msg->sms.sms_type = report_mo;
        msg->sms.dlr_mask = typ;
        O_SET(msg->sms.service, dlr->service);
        O_SET(msg->sms.smsc_id, dlr->smsc);
        O_SET(msg->sms.receiver, dlr->destination);
        O_SET(msg->sms.sender, dlr->source);
        /* if dlr_url was present, recode it here again */
        O_SET(msg->sms.dlr_url, dlr->url);
        /* add the foreign_id */
        msg->sms.foreign_id = octstr_duplicate(ts);
        /* 
         * insert original message to the data segment 
         * later in the smsc module 
         */
        msg->sms.msgdata = NULL;
        /* 
         * If a boxc_id is available, then instruct bearerbox to 
         * route this msg back to originating smsbox
         */
        O_SET(msg->sms.boxc_id, dlr->boxc_id);
        /*
         * We will provide the DLR request bitmask in the DLR going back
         * to the smsbox connection for processing. This allows smsbox
         * connection type applications to avoid temporary storing and
         * resolving data to pull up this information.
         */
        dlr_mask = octstr_format("%ld", dlr->mask);
        msg->sms.meta_data = octstr_create("");
        meta_data_set_value(msg->sms.meta_data, METADATA_ORIG_MSG_GROUP,
                            octstr_imm(METADATA_ORIG_MSG_GROUP_DLR_MASK), dlr_mask, 1);
        octstr_destroy(dlr_mask);

        time(&msg->sms.time);
        debug("dlr.dlr", 0, "DLR[%s]: created DLR message for URL <%s>",
                      dlr_type(), (msg->sms.dlr_url?octstr_get_cstr(msg->sms.dlr_url):""));
    } else {
        debug("dlr.dlr", 0, "DLR[%s]: Ignoring DLR message because of mask type=%d dlr->mask=%d", dlr_type(), typ, dlr->mask);
        /* ok that was a status report but we where not interested in having it */
        msg = NULL;
    }

#undef O_SET
 
    /* check for end status and if so remove from storage */
    if (DLR_IS_NOT_FINAL(typ) && DLR_IS_SUCCESS_OR_FAIL(dlr->mask)) {
        debug("dlr.dlr", 0, "DLR[%s]: DLR not destroyed, still waiting for other delivery report", dlr_type());
        /* update dlr entry status if function defined */
        if (handles != NULL && handles->dlr_update != NULL){
            handles->dlr_update(smsc, ts, dst_min, typ);
        }
    } else {
        if (handles != NULL && handles->dlr_remove != NULL){
            /* it's not good for internal storage, but better for all others */
            handles->dlr_remove(smsc, ts, dst_min);
        } else {
            warning(0, "DLR[%s]: Storage don't have remove operation defined", dlr_type());
        }
    }

    /* destroy struct dlr_entry */
    dlr_entry_destroy(dlr);
    octstr_destroy(dst_min);

    return msg;
}

dlr_flush()

void dlr_flush

(

void

)

Definition at line 491 of file dlr.c.

References dlr_storage::dlr_flush, dlr_messages(), dlr_type(), handles, and info().

Referenced by bb_flush_dlr().

{
    info(0, "Flushing all %ld queued DLR messages in %s storage", dlr_messages(), 
            dlr_type());
 
    if (handles != NULL && handles->dlr_flush != NULL)
        handles->dlr_flush();
}

dlr_init()

void dlr_init

(

Cfg *

cfg

)

Definition at line 233 of file dlr.c.

References cfg, cfg_get, cfg_get_single_group(), dlr_storage::dlr_add, dlr_storage::dlr_get, dlr_init_cass(), dlr_init_mem(), dlr_init_mssql(), dlr_init_mysql(), dlr_init_oracle(), dlr_init_pgsql(), dlr_init_redis(), dlr_init_sdb(), dlr_init_spool(), dlr_init_sqlite3(), dlr_storage::dlr_remove, dlr_type(), handles, info(), octstr_compare(), octstr_destroy(), octstr_get_cstr, octstr_imm(), panic, dlr_storage::type, and warning().

Referenced by init_smppbox(), and main().

{
    CfgGroup *grp;
    Octstr *dlr_type;

    /* check which DLR storage type we are using */
    grp = cfg_get_single_group(cfg, octstr_imm("core"));
    if(grp == NULL)
    panic(0, "DLR: can't find group core");

    dlr_type = cfg_get(grp, octstr_imm("dlr-storage"));

    /* 
     * assume we are using internal memory in case no directive
     * has been specified, warn the user anyway
     */
    if (dlr_type == NULL) {
        dlr_type = octstr_imm("internal");
        warning(0, "DLR: using default 'internal' for storage type.");
    }

    /* call the sub-init routine */
    if (octstr_compare(dlr_type, octstr_imm("spool")) == 0) {
        handles = dlr_init_spool(cfg);
    } else if (octstr_compare(dlr_type, octstr_imm("mysql")) == 0) {
        handles = dlr_init_mysql(cfg);
    } else if (octstr_compare(dlr_type, octstr_imm("sdb")) == 0) {
        handles = dlr_init_sdb(cfg);
    } else if (octstr_compare(dlr_type, octstr_imm("oracle")) == 0) {
        handles = dlr_init_oracle(cfg);
    } else if (octstr_compare(dlr_type, octstr_imm("internal")) == 0) {
        handles = dlr_init_mem(cfg);
    } else if (octstr_compare(dlr_type, octstr_imm("pgsql")) == 0) {
        handles = dlr_init_pgsql(cfg);
    } else if (octstr_compare(dlr_type, octstr_imm("mssql")) == 0) {
        handles = dlr_init_mssql(cfg);
    } else if (octstr_compare(dlr_type, octstr_imm("sqlite3")) == 0) {
        handles = dlr_init_sqlite3(cfg);
    } else if (octstr_compare(dlr_type, octstr_imm("redis")) == 0) {
        handles = dlr_init_redis(cfg);
    } else if (octstr_compare(dlr_type, octstr_imm("cassandra")) == 0) {
        handles = dlr_init_cass(cfg);
    }

    /*
     * add aditional types here
     */

     if (handles == NULL) {
        panic(0, "DLR: storage type '%s' is not supported!", octstr_get_cstr(dlr_type));
    }

    /* check needed function pointers */
    if (handles->dlr_add == NULL || handles->dlr_get == NULL || handles->dlr_remove == NULL)
        panic(0, "DLR: storage type '%s' don't implement needed functions", octstr_get_cstr(dlr_type));

    /* get info from storage */
    info(0, "DLR using storage type: %s", handles->type);

    /* cleanup */
    octstr_destroy(dlr_type);
}

dlr_load()

void dlr_load

(

const char *

filename

)

dlr_messages()

long dlr_messages

(

void

)

Definition at line 308 of file dlr.c.

References dlr_storage::dlr_messages, and handles.

Referenced by bb_print_status(), and dlr_flush().

{
    if (handles != NULL && handles->dlr_messages != NULL)
        return handles->dlr_messages();

    return -1;
}

dlr_save()

void dlr_save

(

const char *

filename

)

dlr_shutdown()

void dlr_shutdown

(

void

)

Definition at line 299 of file dlr.c.

References dlr_storage::dlr_shutdown, and handles.

Referenced by main().

{
    if (handles != NULL && handles->dlr_shutdown != NULL)
        handles->dlr_shutdown();
}

dlr_type()

const char* dlr_type

(

void

)

Definition at line 319 of file dlr.c.

References handles, and dlr_storage::type.

Referenced by bb_print_status(), dlr_add(), dlr_find(), dlr_flush(), and dlr_init().

{
    if (handles != NULL && handles->type != NULL)
        return handles->type;

    return "unknown";
}