res_mwi_external.c File Reference

Core external MWI support. More...

#include "asterisk.h"
#include "asterisk/app.h"
#include "asterisk/mwi.h"
#include "asterisk/module.h"
#include "asterisk/res_mwi_external.h"
#include "asterisk/sorcery.h"
#include "asterisk/cli.h"

Include dependency graph for res_mwi_external.c:

Go to the source code of this file.

Data Structures
struct	ast_mwi_mailbox_object

Macros
#define	FORMAT_MAILBOX_HDR   "%6s %6s %s\n"
#define	FORMAT_MAILBOX_ROW   "%6u %6u %s\n"
#define	MWI_ASTDB_PREFIX   "mwi_external"
#define	MWI_MAILBOX_TYPE   "mailboxes"

Enumerations
enum	folder_map { FOLDER_INVALID = 0 , FOLDER_INBOX = 1 , FOLDER_OLD = 2 }

Functions
static void	__reg_module (void)
static void	__unreg_module (void)
struct ast_module *	AST_MODULE_SELF_SYM (void)
struct ast_mwi_mailbox_object *	ast_mwi_mailbox_alloc (const char *mailbox_id)
	Allocate an external MWI object.
struct ast_mwi_mailbox_object *	ast_mwi_mailbox_copy (const struct ast_mwi_mailbox_object *mailbox)
	Copy the external MWI counts object.
int	ast_mwi_mailbox_delete (const char *mailbox_id)
	Delete matching external MWI object.
int	ast_mwi_mailbox_delete_all (void)
	Delete all external MWI objects.
int	ast_mwi_mailbox_delete_by_regex (const char *regex)
	Delete all external MWI objects selected by the regular expression.
const struct ast_mwi_mailbox_object *	ast_mwi_mailbox_get (const char *mailbox_id)
	Get matching external MWI object.
struct ao2_container *	ast_mwi_mailbox_get_all (void)
	Get all external MWI objects.
struct ao2_container *	ast_mwi_mailbox_get_by_regex (const char *regex)
	Get all external MWI objects selected by the regular expression.
const char *	ast_mwi_mailbox_get_id (const struct ast_mwi_mailbox_object *mailbox)
	Get mailbox id.
unsigned int	ast_mwi_mailbox_get_msgs_new (const struct ast_mwi_mailbox_object *mailbox)
	Get the number of new messages.
unsigned int	ast_mwi_mailbox_get_msgs_old (const struct ast_mwi_mailbox_object *mailbox)
	Get the number of old messages.
void	ast_mwi_mailbox_set_msgs_new (struct ast_mwi_mailbox_object *mailbox, unsigned int num_msgs)
	Set the number of new messages.
void	ast_mwi_mailbox_set_msgs_old (struct ast_mwi_mailbox_object *mailbox, unsigned int num_msgs)
	Set the number of old messages.
int	ast_mwi_mailbox_update (struct ast_mwi_mailbox_object *mailbox)
	Update the external MWI counts with the given object.
static int	load_module (void)
static enum folder_map	mwi_folder_map (const char *folder)
static int	mwi_has_voicemail (const char *mailboxes, const char *folder)
static int	mwi_inboxcount (const char *mailboxes, int *newmsgs, int *oldmsgs)
static int	mwi_inboxcount2 (const char *mailboxes, int *urgentmsgs, int *newmsgs, int *oldmsgs)
static void	mwi_initial_events (void)
static void	mwi_mailbox_delete (struct ast_mwi_mailbox_object *mailbox)
static void	mwi_mailbox_delete_all (struct ao2_container *mailboxes)
static int	mwi_messagecount (const char *mailbox_id, const char *folder)
static void	mwi_observe_delete (const void *obj)
static void	mwi_observe_update (const void *obj)
static void	mwi_post_event (const struct ast_mwi_mailbox_object *mailbox)
static int	mwi_sorcery_init (void)
static void *	mwi_sorcery_object_alloc (const char *id)
	Internal function to allocate a mwi object.
static int	unload_module (void)

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_GLOBAL_SYMBOLS | AST_MODFLAG_LOAD_ORDER , .description = "Core external MWI resource" , .key = ASTERISK_GPL_KEY , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .unload = unload_module, .load_pri = AST_MODPRI_CHANNEL_DEPEND - 5, }
static const struct ast_module_info *	ast_module_info = &__mod_info
static const struct ast_sorcery_observer	mwi_observers
static struct ast_sorcery *	mwi_sorcery
static const struct ast_vm_functions	vm_table

Detailed Description

Core external MWI support.

The module manages the persistent message counts cache and supplies an API to allow the protocol specific modules to control the counts or a subset.

Author

Richard Mudgett rmudg.nosp@m.ett@.nosp@m.digiu.nosp@m.m.co.nosp@m.m

See Also:

• CREDITS

Definition in file res_mwi_external.c.

Macro Definition Documentation

FORMAT_MAILBOX_HDR

#define FORMAT_MAILBOX_HDR   "%6s %6s %s\n"

Definition at line 642 of file res_mwi_external.c.

FORMAT_MAILBOX_ROW

#define FORMAT_MAILBOX_ROW   "%6u %6u %s\n"

Definition at line 643 of file res_mwi_external.c.

MWI_ASTDB_PREFIX

#define MWI_ASTDB_PREFIX   "mwi_external"

Define to include CLI commands to manipulate the external MWI mailboxes. Useful for testing the module functionality.

Definition at line 72 of file res_mwi_external.c.

MWI_MAILBOX_TYPE

#define MWI_MAILBOX_TYPE   "mailboxes"

Definition at line 73 of file res_mwi_external.c.

Enumeration Type Documentation

folder_map

enum folder_map

Enumerator
FOLDER_INVALID
FOLDER_INBOX
FOLDER_OLD

Definition at line 318 of file res_mwi_external.c.

                {
    FOLDER_INVALID = 0,
    FOLDER_INBOX = 1,
    FOLDER_OLD = 2,
};

Function Documentation

__reg_module()

static void __reg_module ( void  )

static

Definition at line 943 of file res_mwi_external.c.

__unreg_module()

static void __unreg_module ( void  )

static

Definition at line 943 of file res_mwi_external.c.

AST_MODULE_SELF_SYM()

struct ast_module * AST_MODULE_SELF_SYM

(

void

)

Definition at line 943 of file res_mwi_external.c.

ast_mwi_mailbox_alloc()

struct ast_mwi_mailbox_object * ast_mwi_mailbox_alloc

(

const char *

mailbox_id

)

Allocate an external MWI object.

Since

12.1.0

Parameters

mailbox_id

Name of mailbox.

Returns

object on success. The object is an ao2 object.

Return values

NULL

on error.

Definition at line 192 of file res_mwi_external.c.

{
    if (ast_strlen_zero(mailbox_id)) {
        return NULL;
    }
 
    return ast_sorcery_alloc(mwi_sorcery, MWI_MAILBOX_TYPE, mailbox_id);
}

References ast_sorcery_alloc(), ast_strlen_zero(), MWI_MAILBOX_TYPE, mwi_sorcery, and NULL.

Referenced by mwi_mailbox_update(), and stasis_app_mailbox_update().

ast_mwi_mailbox_copy()

struct ast_mwi_mailbox_object * ast_mwi_mailbox_copy

(

const struct ast_mwi_mailbox_object *

mailbox

)

Copy the external MWI counts object.

Since

12.1.0

Parameters

mailbox

What to copy.

Returns

copy on success. The object is an ao2 object.

Return values

NULL

on error.

Definition at line 201 of file res_mwi_external.c.

{
    return ast_sorcery_copy(mwi_sorcery, mailbox);
}

References ast_sorcery_copy(), and mwi_sorcery.

ast_mwi_mailbox_delete()

int ast_mwi_mailbox_delete

(

const char *

mailbox_id

)

Delete matching external MWI object.

Since

12.1.0

Parameters

mailbox_id

Name of mailbox to delete.

Return values

0	on success.
-1	on error.

Definition at line 302 of file res_mwi_external.c.

{
    const struct ast_mwi_mailbox_object *mailbox;
 
    if (ast_strlen_zero(mailbox_id)) {
        return -1;
    }
 
    mailbox = ast_mwi_mailbox_get(mailbox_id);
    if (mailbox) {
        mwi_mailbox_delete((struct ast_mwi_mailbox_object *) mailbox);
        ast_mwi_mailbox_unref(mailbox);
    }
    return 0;
}

References ast_mwi_mailbox_get(), ast_mwi_mailbox_unref, ast_strlen_zero(), and mwi_mailbox_delete().

Referenced by mwi_mailbox_delete(), and stasis_app_mailbox_delete().

ast_mwi_mailbox_delete_all()

int ast_mwi_mailbox_delete_all

(

void

)

Delete all external MWI objects.

Since

12.1.0

Return values

0	on success.
-1	on error.

Definition at line 278 of file res_mwi_external.c.

{
    struct ao2_container *mailboxes;
 
    mailboxes = ast_mwi_mailbox_get_all();
    if (mailboxes) {
        mwi_mailbox_delete_all(mailboxes);
        ao2_ref(mailboxes, -1);
    }
    return 0;
}

References ao2_ref, ast_mwi_mailbox_get_all(), mailboxes, and mwi_mailbox_delete_all().

ast_mwi_mailbox_delete_by_regex()

int ast_mwi_mailbox_delete_by_regex

(

const char *

regex

)

Delete all external MWI objects selected by the regular expression.

Since

12.1.0

Parameters

regex

Regular expression in extended syntax. (NULL is same as "")

Note

The provided regex is treated as extended case sensitive.

Return values

0	on success.
-1	on error.

Definition at line 290 of file res_mwi_external.c.

{
    struct ao2_container *mailboxes;
 
    mailboxes = ast_mwi_mailbox_get_by_regex(regex);
    if (mailboxes) {
        mwi_mailbox_delete_all(mailboxes);
        ao2_ref(mailboxes, -1);
    }
    return 0;
}

References ao2_ref, ast_mwi_mailbox_get_by_regex(), mailboxes, mwi_mailbox_delete_all(), and regex().

Referenced by mwi_mailbox_delete().

ast_mwi_mailbox_get()

const struct ast_mwi_mailbox_object * ast_mwi_mailbox_get

(

const char *

mailbox_id

)

Get matching external MWI object.

Since

12.1.0

Parameters

mailbox_id

Name of mailbox to retrieve.

Returns

requested mailbox on success. The object is an ao2 object.

Return values

NULL	on error or no mailbox.

Note

The object must be treated as read-only.

Definition at line 183 of file res_mwi_external.c.

{
    if (ast_strlen_zero(mailbox_id)) {
        return NULL;
    }
 
    return ast_sorcery_retrieve_by_id(mwi_sorcery, MWI_MAILBOX_TYPE, mailbox_id);
}

References ast_sorcery_retrieve_by_id(), ast_strlen_zero(), MWI_MAILBOX_TYPE, mwi_sorcery, and NULL.

Referenced by ast_mwi_mailbox_delete(), mwi_has_voicemail(), mwi_inboxcount(), mwi_mailbox_get(), mwi_messagecount(), stasis_app_mailbox_delete(), and stasis_app_mailbox_to_json().

ast_mwi_mailbox_get_all()

struct ao2_container * ast_mwi_mailbox_get_all

(

void

)

Get all external MWI objects.

Since

12.1.0

Returns

container of struct ast_mwi_mailbox_object on success.

Return values

NULL

on error.

Note

The objects in the container must be treated as read-only.

Definition at line 172 of file res_mwi_external.c.

{
    return ast_sorcery_retrieve_by_fields(mwi_sorcery, MWI_MAILBOX_TYPE,
        AST_RETRIEVE_FLAG_MULTIPLE | AST_RETRIEVE_FLAG_ALL, NULL);
}

References AST_RETRIEVE_FLAG_ALL, AST_RETRIEVE_FLAG_MULTIPLE, ast_sorcery_retrieve_by_fields(), MWI_MAILBOX_TYPE, mwi_sorcery, and NULL.

Referenced by ast_mwi_mailbox_delete_all(), mwi_initial_events(), and stasis_app_mailboxes_to_json().

ast_mwi_mailbox_get_by_regex()

struct ao2_container * ast_mwi_mailbox_get_by_regex

(

const char *

regex

)

Get all external MWI objects selected by the regular expression.

Since

12.1.0

Parameters

regex

Regular expression in extended syntax. (NULL is same as "")

Note

The provided regex is treated as extended case sensitive.

Returns

container of struct ast_mwi_mailbox_object on success.

Return values

NULL

on error.

Note

The objects in the container must be treated as read-only.

Definition at line 178 of file res_mwi_external.c.

{
    return ast_sorcery_retrieve_by_regex(mwi_sorcery, MWI_MAILBOX_TYPE, regex ?: "");
}

References ast_sorcery_retrieve_by_regex(), MWI_MAILBOX_TYPE, mwi_sorcery, and regex().

Referenced by ast_mwi_mailbox_delete_by_regex(), and mwi_mailbox_get().

ast_mwi_mailbox_get_id()

const char * ast_mwi_mailbox_get_id

(

const struct ast_mwi_mailbox_object *

mailbox

)

Get mailbox id.

Since

12.1.0

Parameters

mailbox

Object to get id.

Returns

mailbox_id of the object.

Note

This should never return NULL unless there is a bug in sorcery.

Definition at line 206 of file res_mwi_external.c.

{
    return ast_sorcery_object_get_id(mailbox);
}

References ast_sorcery_object_get_id().

Referenced by mailbox_to_json(), and mwi_mailbox_get().

ast_mwi_mailbox_get_msgs_new()

unsigned int ast_mwi_mailbox_get_msgs_new

(

const struct ast_mwi_mailbox_object *

mailbox

)

Get the number of new messages.

Since

12.1.0

Parameters

mailbox

Object to get number of new messages.

Returns

Number of new messages.

Definition at line 211 of file res_mwi_external.c.

{
    return mailbox->msgs_new;
}

Referenced by mailbox_to_json(), and mwi_mailbox_get().

ast_mwi_mailbox_get_msgs_old()

unsigned int ast_mwi_mailbox_get_msgs_old

(

const struct ast_mwi_mailbox_object *

mailbox

)

Get the number of old messages.

Since

12.1.0

Parameters

mailbox

Object to get number of old messages.

Returns

Number of old messages.

Definition at line 216 of file res_mwi_external.c.

{
    return mailbox->msgs_old;
}

Referenced by mailbox_to_json(), and mwi_mailbox_get().

ast_mwi_mailbox_set_msgs_new()

void ast_mwi_mailbox_set_msgs_new	(	struct ast_mwi_mailbox_object *	mailbox,
		unsigned int	num_msgs
	)

Set the number of new messages.

Since

12.1.0

Parameters

mailbox	Object to set number of new messages.
num_msgs	Number of messages to set.

Definition at line 221 of file res_mwi_external.c.

{
    mailbox->msgs_new = num_msgs;
}

Referenced by mwi_mailbox_update(), and stasis_app_mailbox_update().

ast_mwi_mailbox_set_msgs_old()

void ast_mwi_mailbox_set_msgs_old	(	struct ast_mwi_mailbox_object *	mailbox,
		unsigned int	num_msgs
	)

Set the number of old messages.

Since

12.1.0

Parameters

mailbox	Object to set number of old messages.
num_msgs	Number of messages to set.

Definition at line 226 of file res_mwi_external.c.

{
    mailbox->msgs_old = num_msgs;
}

Referenced by mwi_mailbox_update(), and stasis_app_mailbox_update().

ast_mwi_mailbox_update()

int ast_mwi_mailbox_update

(

struct ast_mwi_mailbox_object *

mailbox

)

Update the external MWI counts with the given object.

Since

12.1.0

Parameters

mailbox

What to update.

Return values

0	on success.
-1	on error.

Definition at line 231 of file res_mwi_external.c.

{
    const struct ast_mwi_mailbox_object *exists;
    int res;
 
    exists = ast_sorcery_retrieve_by_id(mwi_sorcery, MWI_MAILBOX_TYPE,
        ast_sorcery_object_get_id(mailbox));
    if (exists) {
        res = ast_sorcery_update(mwi_sorcery, mailbox);
        ast_mwi_mailbox_unref(exists);
    } else {
        res = ast_sorcery_create(mwi_sorcery, mailbox);
    }
    return res;
}

References ast_mwi_mailbox_unref, ast_sorcery_create(), ast_sorcery_object_get_id(), ast_sorcery_retrieve_by_id(), ast_sorcery_update(), exists(), MWI_MAILBOX_TYPE, and mwi_sorcery.

Referenced by mwi_mailbox_update(), and stasis_app_mailbox_update().

load_module()

static int load_module ( void  )

static

Definition at line 910 of file res_mwi_external.c.

{
    int res;
 
    if (mwi_sorcery_init()
        || ast_sorcery_observer_add(mwi_sorcery, MWI_MAILBOX_TYPE, &mwi_observers)
#if defined(MWI_DEBUG_CLI)
        || ast_cli_register_multiple(mwi_cli, ARRAY_LEN(mwi_cli))
#endif  /* defined(MWI_DEBUG_CLI) */
        ) {
        unload_module();
        return AST_MODULE_LOAD_DECLINE;
    }
 
    /* ast_vm_register may return DECLINE if another module registered for vm */
    res = ast_vm_register(&vm_table);
    if (res) {
        ast_log(LOG_ERROR, "Failure registering as a voicemail provider\n");
        unload_module();
        return AST_MODULE_LOAD_DECLINE;
    }
 
    /* Post initial MWI count events. */
    mwi_initial_events();
 
    return AST_MODULE_LOAD_SUCCESS;
}

References ARRAY_LEN, ast_cli_register_multiple, ast_log, AST_MODULE_LOAD_DECLINE, AST_MODULE_LOAD_SUCCESS, ast_sorcery_observer_add(), ast_vm_register, LOG_ERROR, mwi_initial_events(), MWI_MAILBOX_TYPE, mwi_observers, mwi_sorcery, mwi_sorcery_init(), unload_module(), and vm_table.

mwi_folder_map()

static enum folder_map mwi_folder_map ( const char *  folder )

static

Definition at line 333 of file res_mwi_external.c.

{
    enum folder_map which_folder;
 
    if (ast_strlen_zero(folder) || !strcasecmp(folder, "INBOX")) {
        which_folder = FOLDER_INBOX;
    } else if (!strcasecmp(folder, "Old")) {
        which_folder = FOLDER_OLD;
    } else {
        which_folder = FOLDER_INVALID;
    }
    return which_folder;
}

References ast_strlen_zero(), FOLDER_INBOX, FOLDER_INVALID, and FOLDER_OLD.

Referenced by mwi_has_voicemail(), and mwi_messagecount().

mwi_has_voicemail()

static int mwi_has_voicemail ( const char *  mailboxes, const char *  folder  )

static

Definition at line 399 of file res_mwi_external.c.

{
    char *parse;
    char *mailbox_id;
    enum folder_map which_folder;
 
    which_folder = mwi_folder_map(folder);
    if (which_folder == FOLDER_INVALID) {
        return 0;
    }
 
    /* For each mailbox in the list. */
    parse = ast_strdupa(mailboxes);
    while ((mailbox_id = strsep(&parse, ",&"))) {
        const struct ast_mwi_mailbox_object *mailbox;
        int num_msgs;
 
        /* Get the specified mailbox. */
        mailbox = ast_mwi_mailbox_get(mailbox_id);
        if (!mailbox) {
            continue;
        }
 
        /* Done if the found mailbox has any messages. */
        num_msgs = 0;
        switch (which_folder) {
        case FOLDER_INVALID:
            break;
        case FOLDER_INBOX:
            num_msgs = mailbox->msgs_new;
            break;
        case FOLDER_OLD:
            num_msgs = mailbox->msgs_old;
            break;
        }
        ast_mwi_mailbox_unref(mailbox);
        if (num_msgs) {
            return 1;
        }
    }
 
    return 0;
}

References ast_mwi_mailbox_get(), ast_mwi_mailbox_unref, ast_strdupa, FOLDER_INBOX, FOLDER_INVALID, FOLDER_OLD, mailboxes, mwi_folder_map(), and strsep().

mwi_inboxcount()

static int mwi_inboxcount ( const char *  mailboxes, int *  newmsgs, int *  oldmsgs  )

static

Definition at line 459 of file res_mwi_external.c.

{
    char *parse;
    char *mailbox_id;
 
    if (!newmsgs && !oldmsgs) {
        /* Nowhere to accumulate counts */
        return 0;
    }
 
    /* For each mailbox in the list. */
    parse = ast_strdupa(mailboxes);
    while ((mailbox_id = strsep(&parse, ", "))) {
        const struct ast_mwi_mailbox_object *mailbox;
 
        /* Get the specified mailbox. */
        mailbox = ast_mwi_mailbox_get(mailbox_id);
        if (!mailbox) {
            continue;
        }
 
        /* Accumulate the counts. */
        if (newmsgs) {
            *newmsgs += mailbox->msgs_new;
        }
        if (oldmsgs) {
            *oldmsgs += mailbox->msgs_old;
        }
 
        ast_mwi_mailbox_unref(mailbox);
    }
 
    return 0;
}

References ast_mwi_mailbox_get(), ast_mwi_mailbox_unref, ast_strdupa, mailboxes, and strsep().

Referenced by mwi_inboxcount2().

mwi_inboxcount2()

static int mwi_inboxcount2 ( const char *  mailboxes, int *  urgentmsgs, int *  newmsgs, int *  oldmsgs  )

static

Definition at line 512 of file res_mwi_external.c.

{
    /*
     * This module does not support urgentmsgs.  Just ignore them.
     * The global API call has already set the count to zero.
     */
    return mwi_inboxcount(mailboxes, newmsgs, oldmsgs);
}

References mailboxes, and mwi_inboxcount().

mwi_initial_events()

static void mwi_initial_events ( void  )

static

Definition at line 874 of file res_mwi_external.c.

{
    struct ao2_container *mailboxes;
    const struct ast_mwi_mailbox_object *mailbox;
    struct ao2_iterator iter;
 
    /* Get all mailbox counts. */
    mailboxes = ast_mwi_mailbox_get_all();
    if (!mailboxes) {
        return;
    }
 
    /* Post all mailbox counts. */
    iter = ao2_iterator_init(mailboxes, AO2_ITERATOR_UNLINK);
    for (; (mailbox = ao2_iterator_next(&iter)); ast_mwi_mailbox_unref(mailbox)) {
        mwi_post_event(mailbox);
    }
    ao2_iterator_destroy(&iter);
 
    ao2_ref(mailboxes, -1);
}

References ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, AO2_ITERATOR_UNLINK, ao2_ref, ast_mwi_mailbox_get_all(), ast_mwi_mailbox_unref, mailboxes, and mwi_post_event().

Referenced by load_module().

mwi_mailbox_delete()

static void mwi_mailbox_delete ( struct ast_mwi_mailbox_object *  mailbox )

static

Definition at line 254 of file res_mwi_external.c.

{
    ast_sorcery_delete(mwi_sorcery, mailbox);
}

References ast_sorcery_delete(), and mwi_sorcery.

Referenced by ast_mwi_mailbox_delete(), and mwi_mailbox_delete_all().

mwi_mailbox_delete_all()

static void mwi_mailbox_delete_all ( struct ao2_container *  mailboxes )

static

Definition at line 266 of file res_mwi_external.c.

{
    struct ast_mwi_mailbox_object *mailbox;
    struct ao2_iterator iter;
 
    iter = ao2_iterator_init(mailboxes, AO2_ITERATOR_UNLINK);
    for (; (mailbox = ao2_iterator_next(&iter)); ast_mwi_mailbox_unref(mailbox)) {
        mwi_mailbox_delete(mailbox);
    }
    ao2_iterator_destroy(&iter);
}

References ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, AO2_ITERATOR_UNLINK, ast_mwi_mailbox_unref, mailboxes, and mwi_mailbox_delete().

Referenced by ast_mwi_mailbox_delete_all(), and ast_mwi_mailbox_delete_by_regex().

mwi_messagecount()

static int mwi_messagecount ( const char *  mailbox_id, const char *  folder  )

static

Definition at line 357 of file res_mwi_external.c.

{
    const struct ast_mwi_mailbox_object *mailbox;
    int num_msgs;
    enum folder_map which_folder;
 
    which_folder = mwi_folder_map(folder);
    if (which_folder == FOLDER_INVALID) {
        return 0;
    }
 
    mailbox = ast_mwi_mailbox_get(mailbox_id);
    if (!mailbox) {
        return 0;
    }
    num_msgs = 0;
    switch (which_folder) {
    case FOLDER_INVALID:
        break;
    case FOLDER_INBOX:
        num_msgs = mailbox->msgs_new;
        break;
    case FOLDER_OLD:
        num_msgs = mailbox->msgs_old;
        break;
    }
    ast_mwi_mailbox_unref(mailbox);
 
    return num_msgs;
}

References ast_mwi_mailbox_get(), ast_mwi_mailbox_unref, FOLDER_INBOX, FOLDER_INVALID, FOLDER_OLD, and mwi_folder_map().

mwi_observe_delete()

static void mwi_observe_delete ( const void *  obj )

static

Definition at line 106 of file res_mwi_external.c.

{
    const struct ast_mwi_mailbox_object *mailbox = obj;
 
    if (mailbox->msgs_new || mailbox->msgs_old) {
        /* Post a count clearing event. */
        ast_publish_mwi_state(ast_sorcery_object_get_id(mailbox), NULL, 0, 0);
    }
 
    /* Post a cache remove event. */
    ast_delete_mwi_state(ast_sorcery_object_get_id(mailbox), NULL);
}

References ast_delete_mwi_state, ast_publish_mwi_state, ast_sorcery_object_get_id(), and NULL.

mwi_observe_update()

static void mwi_observe_update ( const void *  obj )

static

Definition at line 96 of file res_mwi_external.c.

{
    mwi_post_event(obj);
}

References mwi_post_event().

mwi_post_event()

static void mwi_post_event ( const struct ast_mwi_mailbox_object *  mailbox )

static

Definition at line 90 of file res_mwi_external.c.

{
    ast_publish_mwi_state(ast_sorcery_object_get_id(mailbox), NULL,
        mailbox->msgs_new, mailbox->msgs_old);
}

References ast_publish_mwi_state, ast_sorcery_object_get_id(), and NULL.

Referenced by mwi_initial_events(), and mwi_observe_update().

mwi_sorcery_init()

static int mwi_sorcery_init ( void  )

static

Definition at line 139 of file res_mwi_external.c.

{
    int res;
 
    mwi_sorcery = ast_sorcery_open();
    if (!mwi_sorcery) {
        ast_log(LOG_ERROR, "MWI external: Sorcery failed to open.\n");
        return -1;
    }
 
    /* Map the external MWI wizards. */
    if (ast_sorcery_apply_default(mwi_sorcery, MWI_MAILBOX_TYPE, "astdb",
            MWI_ASTDB_PREFIX) == AST_SORCERY_APPLY_FAIL) {
        ast_log(LOG_ERROR, "MWI external: Sorcery could not setup wizards.\n");
        return -1;
    }
 
    res = ast_sorcery_object_register(mwi_sorcery, MWI_MAILBOX_TYPE,
        mwi_sorcery_object_alloc, NULL, NULL);
    if (res) {
        ast_log(LOG_ERROR, "MWI external: Sorcery could not register object type '%s'.\n",
            MWI_MAILBOX_TYPE);
        return -1;
    }
 
    /* Define the MWI_MAILBOX_TYPE object fields. */
    res |= ast_sorcery_object_field_register_nodoc(mwi_sorcery, MWI_MAILBOX_TYPE,
        "msgs_new", "0", OPT_UINT_T, 0, FLDSET(struct ast_mwi_mailbox_object, msgs_new));
    res |= ast_sorcery_object_field_register_nodoc(mwi_sorcery, MWI_MAILBOX_TYPE,
        "msgs_old", "0", OPT_UINT_T, 0, FLDSET(struct ast_mwi_mailbox_object, msgs_old));
    return res ? -1 : 0;
}

References ast_log, ast_sorcery_apply_default, AST_SORCERY_APPLY_FAIL, ast_sorcery_object_field_register_nodoc, ast_sorcery_object_register, ast_sorcery_open, FLDSET, LOG_ERROR, MWI_ASTDB_PREFIX, MWI_MAILBOX_TYPE, mwi_sorcery, mwi_sorcery_object_alloc(), NULL, and OPT_UINT_T.

Referenced by load_module().

mwi_sorcery_object_alloc()

static void * mwi_sorcery_object_alloc ( const char *  id )

static

Internal function to allocate a mwi object.

Definition at line 126 of file res_mwi_external.c.

{
    return ast_sorcery_generic_alloc(sizeof(struct ast_mwi_mailbox_object), NULL);
}

References ast_sorcery_generic_alloc(), and NULL.

Referenced by mwi_sorcery_init().

unload_module()

static int unload_module ( void  )

static

Definition at line 896 of file res_mwi_external.c.

{
    ast_vm_unregister(vm_table.module_name);
#if defined(MWI_DEBUG_CLI)
    ast_cli_unregister_multiple(mwi_cli, ARRAY_LEN(mwi_cli));
#endif  /* defined(MWI_DEBUG_CLI) */
    ast_sorcery_observer_remove(mwi_sorcery, MWI_MAILBOX_TYPE, &mwi_observers);
 
    ast_sorcery_unref(mwi_sorcery);
    mwi_sorcery = NULL;
 
    return 0;
}

References ARRAY_LEN, ast_cli_unregister_multiple(), ast_sorcery_observer_remove(), ast_sorcery_unref, ast_vm_unregister(), ast_vm_functions::module_name, MWI_MAILBOX_TYPE, mwi_observers, mwi_sorcery, NULL, and vm_table.

Referenced by load_module().

Variable Documentation

__mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_GLOBAL_SYMBOLS | AST_MODFLAG_LOAD_ORDER , .description = "Core external MWI resource" , .key = ASTERISK_GPL_KEY , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .unload = unload_module, .load_pri = AST_MODPRI_CHANNEL_DEPEND - 5, }

static

Definition at line 943 of file res_mwi_external.c.

ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 943 of file res_mwi_external.c.

mwi_observers

const struct ast_sorcery_observer mwi_observers

static

Initial value:

= {
    .created = mwi_observe_update,
    .updated = mwi_observe_update,
    .deleted = mwi_observe_delete,
}

Definition at line 119 of file res_mwi_external.c.

                                                         {
    .created = mwi_observe_update,
    .updated = mwi_observe_update,
    .deleted = mwi_observe_delete,
};

Referenced by load_module(), and unload_module().

mwi_sorcery

struct ast_sorcery* mwi_sorcery

static

Definition at line 83 of file res_mwi_external.c.

Referenced by ast_mwi_mailbox_alloc(), ast_mwi_mailbox_copy(), ast_mwi_mailbox_get(), ast_mwi_mailbox_get_all(), ast_mwi_mailbox_get_by_regex(), ast_mwi_mailbox_update(), load_module(), mwi_mailbox_delete(), mwi_sorcery_init(), and unload_module().

vm_table

const struct ast_vm_functions vm_table

static

Definition at line 521 of file res_mwi_external.c.

                                                {
    .module_version = VM_MODULE_VERSION,
    .module_name = AST_MODULE,
 
    .has_voicemail = mwi_has_voicemail,
    .inboxcount = mwi_inboxcount,
    .inboxcount2 = mwi_inboxcount2,
    .messagecount = mwi_messagecount,
};

Referenced by load_module(), and unload_module().