res_mwi_devstate.c File Reference

#include "asterisk.h"
#include "asterisk/mwi.h"
#include "asterisk/devicestate.h"
#include "asterisk/module.h"
#include "asterisk/stasis_message_router.h"
#include "asterisk/stasis.h"

Include dependency graph for res_mwi_devstate.c:

Go to the source code of this file.

Functions
static void	__reg_module (void)
static void	__unreg_module (void)
struct ast_module *	AST_MODULE_SELF_SYM (void)
static int	load_module (void)
static int	mwi_cached_cb (void *obj, void *arg, int flags)
static void	mwi_update_cb (void *data, struct stasis_subscription *sub, struct stasis_message *msg)
static int	unload_module (void)

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "MWI Device State Subscriptions" , .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_DEVSTATE_PROVIDER, }
static const struct ast_module_info *	ast_module_info = &__mod_info
static struct stasis_subscription *	mwi_sub

Function Documentation

__reg_module()

static void __reg_module ( void  )

static

Definition at line 105 of file res_mwi_devstate.c.

__unreg_module()

static void __unreg_module ( void  )

static

Definition at line 105 of file res_mwi_devstate.c.

AST_MODULE_SELF_SYM()

struct ast_module * AST_MODULE_SELF_SYM

(

void

)

Definition at line 105 of file res_mwi_devstate.c.

load_module()

static int load_module ( void  )

static

Definition at line 71 of file res_mwi_devstate.c.

{
    struct ao2_container *cached;
 
    if (!(mwi_sub = stasis_subscribe(ast_mwi_topic_all(), mwi_update_cb, NULL))) {
        return AST_MODULE_LOAD_DECLINE;
    }
 
    if (stasis_subscription_accept_message_type(mwi_sub, ast_mwi_state_type())) {
        unload_module();
        return AST_MODULE_LOAD_DECLINE;
    }
 
    if (stasis_subscription_set_filter(mwi_sub, STASIS_SUBSCRIPTION_FILTER_SELECTIVE)) {
        unload_module();
        return AST_MODULE_LOAD_DECLINE;
    }
 
    cached = stasis_cache_dump(ast_mwi_state_cache(), NULL);
    if (!cached) {
        unload_module();
        return AST_MODULE_LOAD_DECLINE;
    }
    ao2_callback(cached, OBJ_NODATA, mwi_cached_cb, NULL);
    ao2_ref(cached, -1);
 
    return AST_MODULE_LOAD_SUCCESS;
}

References ao2_callback, ao2_ref, AST_MODULE_LOAD_DECLINE, AST_MODULE_LOAD_SUCCESS, ast_mwi_state_cache(), ast_mwi_state_type(), ast_mwi_topic_all(), mwi_cached_cb(), mwi_sub, mwi_update_cb(), NULL, OBJ_NODATA, stasis_cache_dump(), stasis_subscribe, stasis_subscription_accept_message_type(), STASIS_SUBSCRIPTION_FILTER_SELECTIVE, stasis_subscription_set_filter(), and unload_module().

mwi_cached_cb()

static int mwi_cached_cb ( void *  obj, void *  arg, int  flags  )

static

Definition at line 56 of file res_mwi_devstate.c.

{
    struct stasis_message *msg = obj;
    mwi_update_cb(NULL, mwi_sub, msg);
 
    return 0;
}

References mwi_sub, mwi_update_cb(), and NULL.

Referenced by load_module().

mwi_update_cb()

static void mwi_update_cb ( void *  data, struct stasis_subscription *  sub, struct stasis_message *  msg  )

static

Definition at line 33 of file res_mwi_devstate.c.

{
    struct ast_mwi_state *mwi_state;
 
    if (ast_mwi_state_type() != stasis_message_type(msg)) {
        return;
    }
 
    mwi_state = stasis_message_data(msg);
    if (!mwi_state) {
        return;
    }
 
    if (mwi_state->new_msgs > 0) {
        ast_debug(1, "Sending inuse devstate change for MWI:%s\n", mwi_state->uniqueid);
        ast_devstate_changed(AST_DEVICE_INUSE, AST_DEVSTATE_CACHABLE, "MWI:%s", mwi_state->uniqueid);
    } else {
        ast_debug(1, "Sending not inuse devstate change for MWI:%s\n", mwi_state->uniqueid);
        ast_devstate_changed(AST_DEVICE_NOT_INUSE, AST_DEVSTATE_CACHABLE, "MWI:%s", mwi_state->uniqueid);
    }
}

References ast_debug, AST_DEVICE_INUSE, AST_DEVICE_NOT_INUSE, AST_DEVSTATE_CACHABLE, ast_devstate_changed(), ast_mwi_state_type(), ast_mwi_state::new_msgs, stasis_message_data(), and ast_mwi_state::uniqueid.

Referenced by load_module(), and mwi_cached_cb().

unload_module()

static int unload_module ( void  )

static

Definition at line 64 of file res_mwi_devstate.c.

{
    mwi_sub = stasis_unsubscribe(mwi_sub);
 
    return 0;
}

References mwi_sub, and stasis_unsubscribe().

Referenced by load_module().

Variable Documentation

__mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "MWI Device State Subscriptions" , .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_DEVSTATE_PROVIDER, }

static

Definition at line 105 of file res_mwi_devstate.c.

ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 105 of file res_mwi_devstate.c.

mwi_sub

struct stasis_subscription* mwi_sub

static

Definition at line 31 of file res_mwi_devstate.c.

Referenced by allow_and_or_replace_unsolicited(), has_mwi_subscription(), is_unsolicited_allowed(), load_module(), mwi_cached_cb(), mwi_contact_deleted(), mwi_get_notify_data(), mwi_stasis_cb(), mwi_stasis_subscription_alloc(), mwi_subscription_shutdown(), mwi_to_ami(), send_contact_notify(), send_notify(), serialized_cleanup(), serialized_notify(), unload_module(), and unsubscribe().