dlr_mem.c File Reference

#include "gwlib/gwlib.h"
#include "dlr_p.h"

Go to the source code of this file.

Functions
static void	dlr_mem_shutdown ()
static long	dlr_mem_messages (void)
static void	dlr_mem_flush (void)
static void	dlr_mem_add (struct dlr_entry *dlr)
static int	dlr_mem_entry_match (struct dlr_entry *dlr, const Octstr *smsc, const Octstr *ts, const Octstr *dst)
static struct dlr_entry *	dlr_mem_get (const Octstr *smsc, const Octstr *ts, const Octstr *dst)
static void	dlr_mem_remove (const Octstr *smsc, const Octstr *ts, const Octstr *dst)
struct dlr_storage *	dlr_init_mem (Cfg *cfg)

Variables
static List *	dlr_waiting_list
static RWLock	rwlock
static struct dlr_storage	handles

Function Documentation

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_mem_add()

static void dlr_mem_add ( struct dlr_entry *  dlr )

static

Definition at line 115 of file dlr_mem.c.

References dlr_waiting_list, gw_rwlock_unlock(), gw_rwlock_wrlock(), gwlist_append(), and rwlock.

{
    gw_rwlock_wrlock(&rwlock);
    gwlist_append(dlr_waiting_list,dlr);
    gw_rwlock_unlock(&rwlock);
}

dlr_mem_entry_match()

static int dlr_mem_entry_match ( struct dlr_entry *  dlr, const Octstr *  smsc, const Octstr *  ts, const Octstr *  dst  )

static

Definition at line 126 of file dlr_mem.c.

References dlr_entry::destination, octstr_compare(), octstr_len(), octstr_search(), dlr_entry::smsc, and dlr_entry::timestamp.

Referenced by dlr_mem_get(), and dlr_mem_remove().

{
    /* XXX: check destination addr too, because e.g. for UCP is not enough to check only
     *          smsc and timestamp (timestamp is even without milliseconds)
     */
    if (dst){
        long pos = octstr_len(dlr->destination) - octstr_len(dst);

        if (pos < 0)
            return 1;

        if (octstr_compare(dlr->smsc, smsc) == 0 && octstr_compare(dlr->timestamp, ts) == 0 && octstr_search(dlr->destination, dst, pos) != -1)
            return 0;
    } else if (octstr_compare(dlr->smsc, smsc) == 0 && octstr_compare(dlr->timestamp, ts) == 0)
        return 0;

    return 1;
}

dlr_mem_flush()

static void dlr_mem_flush ( void  )

static

Definition at line 97 of file dlr_mem.c.

References dlr_entry_destroy(), dlr_waiting_list, gw_rwlock_unlock(), gw_rwlock_wrlock(), gwlist_delete(), gwlist_get(), gwlist_len(), and rwlock.

{
    long i;
    long len;

    gw_rwlock_wrlock(&rwlock);
    len = gwlist_len(dlr_waiting_list);
    for (i = 0; i < len; i++) {
        struct dlr_entry *dlr = gwlist_get(dlr_waiting_list, 0);
        gwlist_delete(dlr_waiting_list, 0, 1);
        dlr_entry_destroy(dlr);
    }
    gw_rwlock_unlock(&rwlock);
}

dlr_mem_get()

static struct dlr_entry* dlr_mem_get ( const Octstr *  smsc, const Octstr *  ts, const Octstr *  dst  )

static

Definition at line 148 of file dlr_mem.c.

References dlr_entry_duplicate(), dlr_mem_entry_match(), dlr_waiting_list, gw_rwlock_rdlock(), gw_rwlock_unlock(), gwlist_get(), gwlist_len(), rwlock, and dlr_entry::smsc.

{
    long i;
    long len;
    struct dlr_entry *dlr = NULL, *ret = NULL;

    gw_rwlock_rdlock(&rwlock);
    len = gwlist_len(dlr_waiting_list);
    for (i=0; i < len; i++) {
        dlr = gwlist_get(dlr_waiting_list, i);

        if (dlr_mem_entry_match(dlr, smsc, ts, dst) == 0) {
            ret = dlr_entry_duplicate(dlr);
            break;
        }
    }
    gw_rwlock_unlock(&rwlock);

    /* we couldnt find a matching entry */
    return ret;
}

dlr_mem_messages()

static long dlr_mem_messages ( void  )

static

Definition at line 92 of file dlr_mem.c.

References dlr_waiting_list, and gwlist_len().

{
    return gwlist_len(dlr_waiting_list);
}

dlr_mem_remove()

static void dlr_mem_remove ( const Octstr *  smsc, const Octstr *  ts, const Octstr *  dst  )

static

Definition at line 173 of file dlr_mem.c.

References dlr_entry_destroy(), dlr_mem_entry_match(), dlr_waiting_list, gw_rwlock_unlock(), gw_rwlock_wrlock(), gwlist_delete(), gwlist_get(), gwlist_len(), rwlock, and dlr_entry::smsc.

{
    long i;
    long len;
    struct dlr_entry *dlr = NULL;

    gw_rwlock_wrlock(&rwlock);
    len = gwlist_len(dlr_waiting_list);
    for (i=0; i < len; i++) {
        dlr = gwlist_get(dlr_waiting_list, i);

        if (dlr_mem_entry_match(dlr, smsc, ts, dst) == 0) {
            gwlist_delete(dlr_waiting_list, i, 1);
            dlr_entry_destroy(dlr);
            break;
        }
    }
    gw_rwlock_unlock(&rwlock);
}

dlr_mem_shutdown()

static void dlr_mem_shutdown ( )

static

Definition at line 81 of file dlr_mem.c.

References dlr_entry_destroy(), dlr_waiting_list, gw_rwlock_destroy(), gw_rwlock_unlock(), gw_rwlock_wrlock(), gwlist_destroy(), and rwlock.

{
    gw_rwlock_wrlock(&rwlock);
    gwlist_destroy(dlr_waiting_list, (gwlist_item_destructor_t *)dlr_entry_destroy);
    gw_rwlock_unlock(&rwlock);
    gw_rwlock_destroy(&rwlock);
}

Variable Documentation

dlr_waiting_list

List* dlr_waiting_list

static

Definition at line 75 of file dlr_mem.c.

Referenced by dlr_init_mem(), dlr_mem_add(), dlr_mem_flush(), dlr_mem_get(), dlr_mem_messages(), dlr_mem_remove(), and dlr_mem_shutdown().

handles

struct dlr_storage handles

static

Initial value:

= {
    .type = "internal",
    .dlr_add = dlr_mem_add,
    .dlr_get = dlr_mem_get,
    .dlr_remove = dlr_mem_remove,
    .dlr_shutdown = dlr_mem_shutdown,
    .dlr_messages = dlr_mem_messages,
    .dlr_flush = dlr_mem_flush
}

Definition at line 193 of file dlr_mem.c.

Referenced by dlr_init_mem().

rwlock

RWLock rwlock

static

Definition at line 76 of file dlr_mem.c.

Referenced by dlr_init_mem(), dlr_mem_add(), dlr_mem_flush(), dlr_mem_get(), dlr_mem_remove(), and dlr_mem_shutdown().