#include "asterisk.h"
#include "asterisk/_private.h"
#include "asterisk/pbx.h"
#include "asterisk/stasis.h"
#include "asterisk/vector.h"
#include "pbx_private.h"

Include dependency graph for extension_state_autohints.c:

Macros
#define	AUTOHINT_CMP_CONTEXT_NAME(elem, name) (!strcmp(ast_get_context_name(elem), name))

Functions
int	ast_extension_state_autohints_init (void)

static void	extension_state_autohints_cleanup (void)

static void	extension_state_autohints_device_state_cb (void userdata, struct stasis_subscription sub, struct stasis_message *msg)

void	pbx_extension_state_autohint_remove (struct ast_context *context, unsigned int forced)

void	pbx_extension_state_autohint_set (struct ast_context *context)

Variables
static struct stasis_subscription *	autohints_subscription
	Subscription to receive updates so we can create hints as needed on autohint enabled contexts.

struct {

size_t current

struct ast_context ** elems

size_t max

}	extension_state_autohints
	Contexts which have autohints enabled.

static ast_mutex_t	extension_state_autohints_lock = AST_MUTEX_INIT_VALUE
	Lock to protect the autohints vector.

static const char	registrar [] = "autohints"
	The static registrar for the added dialplan hints.

Macro Definition Documentation

◆ AUTOHINT_CMP_CONTEXT_NAME

#define AUTOHINT_CMP_CONTEXT_NAME	(	elem,
		name
	)	(!strcmp(ast_get_context_name(elem), name))

Definition at line 111 of file extension_state_autohints.c.

Function Documentation

◆ ast_extension_state_autohints_init()

int ast_extension_state_autohints_init ( void )

Provided by extension_state_autohints.c

Definition at line 174 of file extension_state_autohints.c.

{
    /* Most likely there will be at most one context configured for autohints, or zero */
    if (AST_VECTOR_INIT(&extension_state_autohints, 1)) {
        return -1;
    }
 
    ast_register_cleanup(extension_state_autohints_cleanup);
    return 0;
}

References ast_register_cleanup(), AST_VECTOR_INIT, extension_state_autohints, and extension_state_autohints_cleanup().

Referenced by asterisk_daemon().

◆ extension_state_autohints_cleanup()

static void extension_state_autohints_cleanup ( void )

static

Definition at line 163 of file extension_state_autohints.c.

{
    ast_mutex_lock(&extension_state_autohints_lock);
    if (autohints_subscription) {
        autohints_subscription = stasis_unsubscribe(autohints_subscription);
    }
    /* The vector just contains pointers so no need to free the individual items */
    AST_VECTOR_FREE(&extension_state_autohints);
    ast_mutex_unlock(&extension_state_autohints_lock);
}

References ast_mutex_lock, ast_mutex_unlock, AST_VECTOR_FREE, autohints_subscription, extension_state_autohints, extension_state_autohints_lock, and stasis_unsubscribe().

Referenced by ast_extension_state_autohints_init().

◆ extension_state_autohints_device_state_cb()

static void extension_state_autohints_device_state_cb	(	void *	userdata,
		struct stasis_subscription *	sub,
		struct stasis_message *	msg
	)

static

Definition at line 50 of file extension_state_autohints.c.

{
    struct ast_device_state_message *device_state;
    char *virtual_device, *type, *device_name;
    int i;
 
    if (stasis_message_type(msg) != ast_device_state_message_type()) {
        return;
    }
 
    device_state = stasis_message_data(msg);
 
    /* We only care about the aggregate state */
    if (device_state->eid) {
        return;
    }
 
    type = ast_strdupa(device_state->device);
    if (ast_strlen_zero(type)) {
        return;
    }
 
    /* Determine if this is a virtual/custom device or a real device */
    virtual_device = strchr(type, ':');
    device_name = strchr(type, '/');
    if (virtual_device && (!device_name || (virtual_device < device_name))) {
        device_name = virtual_device;
    }
 
    /* Invalid device state name - not a virtual/custom device and not a real device */
    if (ast_strlen_zero(device_name)) {
        return;
    }
    *device_name++ = '\0';
 
    ast_wrlock_contexts();
 
    ast_mutex_lock(&extension_state_autohints_lock);
    for (i = 0; i < AST_VECTOR_SIZE(&extension_state_autohints); i++) {
        struct ast_context *context = AST_VECTOR_GET(&extension_state_autohints, i);
        struct pbx_find_info q = { .stacklen = 0 };
 
        if (pbx_find_extension(NULL, NULL, &q, ast_get_context_name(context), device_name,
            PRIORITY_HINT, NULL, "", E_MATCH)) {
            continue;
        }
 
        /* The device has no hint in the context referenced by this autohint so create one */
        ast_add_extension(ast_get_context_name(context), 0, device_name, PRIORITY_HINT, NULL, NULL,
            device_state->device, ast_strdup(device_state->device), ast_free_ptr, registrar);
    }
    ast_mutex_unlock(&extension_state_autohints_lock);
 
    ast_unlock_contexts();
}

References ast_add_extension(), ast_device_state_message_type(), ast_free_ptr(), ast_get_context_name(), ast_mutex_lock, ast_mutex_unlock, ast_strdup, ast_strdupa, ast_strlen_zero(), ast_unlock_contexts(), AST_VECTOR_GET, AST_VECTOR_SIZE, ast_wrlock_contexts(), ast_device_state_message::device, E_MATCH, ast_device_state_message::eid, extension_state_autohints, extension_state_autohints_lock, NULL, pbx_find_extension(), PRIORITY_HINT, registrar, pbx_find_info::stacklen, stasis_message_data(), and type.

Referenced by pbx_extension_state_autohint_set().

◆ pbx_extension_state_autohint_remove()

void pbx_extension_state_autohint_remove	(	struct ast_context *	context,
		unsigned int	forced
	)

Definition at line 133 of file extension_state_autohints.c.

{
    int removed;
 
    ast_wrlock_contexts();
 
    ast_mutex_lock(&extension_state_autohints_lock);
    if (!forced) {
        removed = AST_VECTOR_REMOVE_CMP_UNORDERED(&extension_state_autohints, context, AST_VECTOR_ELEM_DEFAULT_CMP,
            AST_VECTOR_ELEM_CLEANUP_NOOP);
    } else {
        removed = AST_VECTOR_REMOVE_CMP_UNORDERED(&extension_state_autohints, ast_get_context_name(context), AUTOHINT_CMP_CONTEXT_NAME,
            AST_VECTOR_ELEM_CLEANUP_NOOP);
    }
    if (removed) {
        ast_context_destroy_by_name(ast_get_context_name(context), registrar);
    }
    if (!AST_VECTOR_SIZE(&extension_state_autohints) && autohints_subscription) {
        /* There's no more autohint enabled contexts, so unsubscribe */
        autohints_subscription = stasis_unsubscribe(autohints_subscription);
    }
    ast_mutex_unlock(&extension_state_autohints_lock);
 
    ast_unlock_contexts();
}

References ast_context_destroy_by_name(), ast_get_context_name(), ast_mutex_lock, ast_mutex_unlock, ast_unlock_contexts(), AST_VECTOR_ELEM_CLEANUP_NOOP, AST_VECTOR_ELEM_DEFAULT_CMP, AST_VECTOR_REMOVE_CMP_UNORDERED, AST_VECTOR_SIZE, ast_wrlock_contexts(), AUTOHINT_CMP_CONTEXT_NAME, autohints_subscription, extension_state_autohints, extension_state_autohints_lock, registrar, and stasis_unsubscribe().

Referenced by __ast_internal_context_destroy(), ast_context_set_autohints(), and context_promote().

◆ pbx_extension_state_autohint_set()

void pbx_extension_state_autohint_set ( struct ast_context * context )

extension_state_autohints.c functions needed by pbx.c

Definition at line 113 of file extension_state_autohints.c.

{
    ast_rdlock_contexts();
 
    ast_mutex_lock(&extension_state_autohints_lock);
 
    /* Since we store a pointer to the context we remove the old one by name and append the new one, easy */
    AST_VECTOR_REMOVE_CMP_UNORDERED(&extension_state_autohints, ast_get_context_name(context), AUTOHINT_CMP_CONTEXT_NAME,
        AST_VECTOR_ELEM_CLEANUP_NOOP);
    AST_VECTOR_APPEND(&extension_state_autohints, context);
 
    if (AST_VECTOR_SIZE(&extension_state_autohints) && !autohints_subscription) {
        /* We have at least one context enabled with autohints and no subscription, so subscribe */
        autohints_subscription = stasis_subscribe(ast_device_state_topic_all(), extension_state_autohints_device_state_cb, NULL);
    }
    ast_mutex_unlock(&extension_state_autohints_lock);
 
    ast_unlock_contexts();
}