dlr_p.h File Reference

Go to the source code of this file.

Data Structures
struct	dlr_entry
struct	dlr_storage
struct	dlr_db_fields

Macros
#define	DLR_TRACE   1
#define	MIN_DST_LEN   7

Functions
struct dlr_entry *	dlr_entry_create (void)
void	dlr_entry_destroy (struct dlr_entry *dlr)
struct dlr_entry *	dlr_entry_duplicate (const struct dlr_entry *dlr)
struct dlr_db_fields *	dlr_db_fields_create (CfgGroup *grp)
void	dlr_db_fields_destroy (struct dlr_db_fields *fields)
struct dlr_storage *	dlr_init_mem (Cfg *cfg)
struct dlr_storage *	dlr_init_spool (Cfg *cfg)
struct dlr_storage *	dlr_init_mysql (Cfg *cfg)
struct dlr_storage *	dlr_init_sdb (Cfg *cfg)
struct dlr_storage *	dlr_init_oracle (Cfg *cfg)
struct dlr_storage *	dlr_init_pgsql (Cfg *cfg)
struct dlr_storage *	dlr_init_mssql (Cfg *cfg)
struct dlr_storage *	dlr_init_sqlite3 (Cfg *cfg)
struct dlr_storage *	dlr_init_redis (Cfg *cfg)
struct dlr_storage *	dlr_init_cass (Cfg *cfg)

Macro Definition Documentation

DLR_TRACE

#define DLR_TRACE   1

Definition at line 71 of file dlr_p.h.

MIN_DST_LEN

#define MIN_DST_LEN   7

Definition at line 74 of file dlr_p.h.

Referenced by dlr_find().

Function Documentation

dlr_db_fields_create()

struct dlr_db_fields* dlr_db_fields_create

(

CfgGroup *

grp

)

Definition at line 169 of file dlr.c.

References cfg_get, cfg_get_integer(), dlr_db_fields::field_boxc, dlr_db_fields::field_dst, dlr_db_fields::field_mask, dlr_db_fields::field_serv, dlr_db_fields::field_smsc, dlr_db_fields::field_src, dlr_db_fields::field_status, dlr_db_fields::field_ts, dlr_db_fields::field_url, gw_assert(), octstr_imm(), panic, dlr_db_fields::table, and dlr_db_fields::ttl.

{
    struct dlr_db_fields *ret = NULL;

    ret = gw_malloc(sizeof(*ret));
    gw_assert(ret != NULL);
    memset(ret, 0, sizeof(*ret));

    if (!(ret->table = cfg_get(grp, octstr_imm("table"))))
        panic(0, "DLR: DB: directive 'table' is not specified!");
    ret->ttl = 0;
    if (cfg_get_integer(&ret->ttl, grp, octstr_imm("ttl")) == -1 || ret->ttl < 0)
        ret->ttl = 0;
    if (!(ret->field_smsc = cfg_get(grp, octstr_imm("field-smsc"))))
        panic(0, "DLR: DB: directive 'field-smsc' is not specified!");
    if (!(ret->field_ts = cfg_get(grp, octstr_imm("field-timestamp"))))
        panic(0, "DLR: DB: directive 'field-timestamp' is not specified!");
    if (!(ret->field_src = cfg_get(grp, octstr_imm("field-source"))))
        panic(0, "DLR: DB: directive 'field-source' is not specified!");
    if (!(ret->field_dst = cfg_get(grp, octstr_imm("field-destination"))))
        panic(0, "DLR: DB: directive 'field-destination' is not specified!");
    if (!(ret->field_serv = cfg_get(grp, octstr_imm("field-service"))))
        panic(0, "DLR: DB: directive 'field-service' is not specified!");
    if (!(ret->field_url = cfg_get(grp, octstr_imm("field-url"))))
        panic(0, "DLR: DB: directive 'field-url' is not specified!");
    if (!(ret->field_mask = cfg_get(grp, octstr_imm("field-mask"))))
        panic(0, "DLR: DB: directive 'field-mask' is not specified!");
    if (!(ret->field_status = cfg_get(grp, octstr_imm("field-status"))))
        panic(0, "DLR: DB: directive 'field-status' is not specified!");
    if (!(ret->field_boxc = cfg_get(grp, octstr_imm("field-boxc-id"))))
        panic(0, "DLR: DB: directive 'field-boxc-id' is not specified!");

    return ret;
}

dlr_db_fields_destroy()

void dlr_db_fields_destroy

(

struct dlr_db_fields *

fields

)

Definition at line 204 of file dlr.c.

References dlr_db_fields::field_boxc, dlr_db_fields::field_dst, dlr_db_fields::field_mask, dlr_db_fields::field_serv, dlr_db_fields::field_smsc, dlr_db_fields::field_src, dlr_db_fields::field_status, dlr_db_fields::field_ts, dlr_db_fields::field_url, O_DELETE, and dlr_db_fields::table.

{
    /* sanity check */
    if (fields == NULL)
        return;

#define O_DELETE(a)  { if (a) octstr_destroy(a); a = NULL; }

    O_DELETE(fields->table);
    O_DELETE(fields->field_smsc);
    O_DELETE(fields->field_ts);
    O_DELETE(fields->field_src);
    O_DELETE(fields->field_dst);
    O_DELETE(fields->field_serv);
    O_DELETE(fields->field_url);
    O_DELETE(fields->field_mask);
    O_DELETE(fields->field_status);
    O_DELETE(fields->field_boxc);

#undef O_DELETE

    gw_free(fields);
}

dlr_entry_create()

struct dlr_entry* dlr_entry_create

(

void

)

Definition at line 103 of file dlr.c.

References gw_assert().

Referenced by dlr_add(), dlr_entry_duplicate(), and dlr_spool_get().

{
    struct dlr_entry *dlr;

    dlr = gw_malloc(sizeof(*dlr));
    gw_assert(dlr != NULL);

    /* set all values to NULL */
    memset(dlr, 0, sizeof(*dlr));

    return dlr;
}

dlr_entry_destroy()

void dlr_entry_destroy

(

struct dlr_entry *

dlr

)

Definition at line 142 of file dlr.c.

References dlr_entry::boxc_id, dlr_entry::destination, dlr_entry::mask, O_DELETE, dlr_entry::service, dlr_entry::smsc, dlr_entry::source, dlr_entry::timestamp, and dlr_entry::url.

Referenced by dlr_find(), dlr_mem_flush(), dlr_mem_remove(), dlr_mem_shutdown(), and dlr_spool_add().

{
    /* sanity check */
    if (dlr == NULL)
        return;

#define O_DELETE(a)  { if (a) octstr_destroy(a); a = NULL; }

    O_DELETE(dlr->smsc);
    O_DELETE(dlr->timestamp);
    O_DELETE(dlr->source);
    O_DELETE(dlr->destination);
    O_DELETE(dlr->service);
    O_DELETE(dlr->url);
    O_DELETE(dlr->boxc_id);

#undef O_DELETE

    dlr->mask = 0;
    gw_free(dlr);
}

dlr_entry_duplicate()

struct dlr_entry* dlr_entry_duplicate

(

const struct dlr_entry *

dlr

)

Definition at line 119 of file dlr.c.

References dlr_entry::boxc_id, dlr_entry::destination, dlr_entry_create(), dlr_entry::mask, octstr_duplicate, dlr_entry::service, dlr_entry::smsc, dlr_entry::source, dlr_entry::timestamp, and dlr_entry::url.

Referenced by dlr_mem_get().

{
    struct dlr_entry *ret;

    if (dlr == NULL)
        return NULL;

    ret = dlr_entry_create();
    ret->smsc = octstr_duplicate(dlr->smsc);
    ret->timestamp = octstr_duplicate(dlr->timestamp);
    ret->source = octstr_duplicate(dlr->source);
    ret->destination = octstr_duplicate(dlr->destination);
    ret->service = octstr_duplicate(dlr->service);
    ret->url = octstr_duplicate(dlr->url);
    ret->boxc_id = octstr_duplicate(dlr->boxc_id);
    ret->mask = dlr->mask;

    return ret;
}

dlr_init_cass()

struct dlr_storage* dlr_init_cass

(

Cfg *

cfg

)

Definition at line 427 of file dlr_cass.c.

Referenced by dlr_init().

{
    return NULL;
}

dlr_init_mem()

struct dlr_storage* dlr_init_mem

(

Cfg *

cfg

)

Definition at line 206 of file dlr_mem.c.

References dlr_waiting_list, gw_rwlock_init_static(), gwlist_create, handles, and rwlock.

Referenced by dlr_init().

{
    dlr_waiting_list = gwlist_create();
    gw_rwlock_init_static(&rwlock);

    return &handles;
}

dlr_init_mssql()

struct dlr_storage* dlr_init_mssql

(

Cfg *

cfg

)

Definition at line 394 of file dlr_mssql.c.

Referenced by dlr_init().

{
    return NULL;
}

dlr_init_mysql()

struct dlr_storage* dlr_init_mysql

(

Cfg *

cfg

)

Definition at line 470 of file dlr_mysql.c.

Referenced by dlr_init().

{
    return NULL;
}

dlr_init_oracle()

struct dlr_storage* dlr_init_oracle

(

Cfg *

cfg

)

Definition at line 428 of file dlr_oracle.c.

Referenced by dlr_init().

{
    return NULL;
}

dlr_init_pgsql()

struct dlr_storage* dlr_init_pgsql

(

Cfg *

cfg

)

Definition at line 420 of file dlr_pgsql.c.

Referenced by dlr_init().

{
    return NULL;
}

dlr_init_redis()

struct dlr_storage* dlr_init_redis

(

Cfg *

cfg

)

Definition at line 576 of file dlr_redis.c.

Referenced by dlr_init().

{
    return NULL;
}

dlr_init_sdb()

struct dlr_storage* dlr_init_sdb

(

Cfg *

cfg

)

Definition at line 477 of file dlr_sdb.c.

Referenced by dlr_init().

{
    return NULL;
}

dlr_init_spool()

struct dlr_storage* dlr_init_spool

(

Cfg *

cfg

)

Definition at line 606 of file dlr_spool.c.

References cfg, cfg_get, cfg_get_single_group(), counter, counter_create(), for_each_file(), handles, non_verified_file(), octstr_imm(), panic, and spool_dir.

Referenced by dlr_init().

{
    CfgGroup *grp;

    if (!(grp = cfg_get_single_group(cfg, octstr_imm("core"))))
        panic(0, "DLR: spool: group 'core' is not specified!");

    if (!(spool_dir = cfg_get(grp, octstr_imm("dlr-spool"))))
        panic(0, "DLR: spool: directive 'dlr-spool' is not specified!");

#ifdef HAVE_LIBSSL
    OpenSSL_add_all_digests();
#endif

    counter = counter_create();

    /* we need to traverse the DLR spool to determine how
     * many entries we have. */
#ifdef VERIFIED
    for_each_file(spool_dir, 1, verified_file);
#else
    for_each_file(spool_dir, 1, non_verified_file);
#endif

    return &handles;
}

dlr_init_sqlite3()

struct dlr_storage* dlr_init_sqlite3

(

Cfg *

cfg

)

Definition at line 421 of file dlr_sqlite3.c.

Referenced by dlr_init().

{
    return NULL;
}