res_pjsip_publish_asterisk.c File Reference

#include "asterisk.h"
#include <regex.h>
#include <pjsip.h>
#include <pjsip_simple.h>
#include "asterisk/res_pjsip.h"
#include "asterisk/res_pjsip_outbound_publish.h"
#include "asterisk/res_pjsip_pubsub.h"
#include "asterisk/module.h"
#include "asterisk/logger.h"
#include "asterisk/mwi.h"

Include dependency graph for res_pjsip_publish_asterisk.c:

Go to the source code of this file.

Data Structures
struct	asterisk_devicestate_publisher_state
	Structure which contains Asterisk device state publisher state information. More...
struct	asterisk_mwi_publisher_state
	Structure which contains Asterisk mailbox publisher state information. More...
struct	asterisk_publication_config
	Structure which contains Asterisk publication information. More...

Functions
static void	__reg_module (void)
static void	__unreg_module (void)
struct ast_module *	AST_MODULE_SELF_SYM (void)
static void	asterisk_devicestate_publisher_state_destroy (void *obj)
	Destroy callback for Asterisk devicestate publisher state information from datastore.
static void	asterisk_mwi_publisher_state_destroy (void *obj)
	Destroy callback for Asterisk mwi publisher state information from datastore.
static void *	asterisk_publication_config_alloc (const char *name)
	Allocator function for Asterisk publication configuration.
static void	asterisk_publication_config_destroy (void *obj)
	Destructor function for Asterisk publication configuration.
static int	asterisk_publication_devicestate (struct ast_sip_publication *pub, struct asterisk_publication_config *config, struct ast_eid *pubsub_eid, struct ast_json *json)
static int	asterisk_publication_devicestate_refresh (struct ast_sip_publication *pub, struct asterisk_publication_config *config, struct ast_eid *pubsub_eid, struct ast_json *json)
static int	asterisk_publication_devicestate_state_change (struct ast_sip_publication *pub, pjsip_msg_body *body, enum ast_sip_publish_state state)
static int	asterisk_publication_mailboxstate (struct ast_sip_publication *pub, struct asterisk_publication_config *config, struct ast_eid *pubsub_eid, struct ast_json *json)
static int	asterisk_publication_mwi_refresh (struct ast_sip_publication *pub, struct asterisk_publication_config *config, struct ast_eid *pubsub_eid, struct ast_json *json)
static int	asterisk_publication_mwi_state_change (struct ast_sip_publication *pub, pjsip_msg_body *body, enum ast_sip_publish_state state)
static int	asterisk_publication_new (struct ast_sip_endpoint *endpoint, const char *resource, const char *event_configuration)
static void	asterisk_publication_send_refresh (void)
	Internal function to send refresh requests to all publications.
static void	asterisk_publisher_devstate_cb (void *data, struct stasis_subscription *sub, struct stasis_message *msg)
	Callback function for device state events.
static void	asterisk_publisher_mwistate_cb (void *data, struct stasis_subscription *sub, struct stasis_message *msg)
	Callback function for mailbox state events.
static int	asterisk_start_devicestate_publishing (struct ast_sip_outbound_publish *configuration, struct ast_sip_outbound_publish_client *client)
static int	asterisk_start_mwi_publishing (struct ast_sip_outbound_publish *configuration, struct ast_sip_outbound_publish_client *client)
static int	asterisk_stop_devicestate_publishing (struct ast_sip_outbound_publish_client *client)
static int	asterisk_stop_mwi_publishing (struct ast_sip_outbound_publish_client *client)
static int	build_regex (regex_t *regex, const char *text)
static int	cached_devstate_cb (void *obj, void *arg, int flags)
static int	cached_mwistate_cb (void *obj, void *arg, int flags)
static int	load_module (void)
static int	regex_filter_handler (const struct aco_option *opt, struct ast_variable *var, void *obj)
static int	reload_module (void)
static int	send_refresh_cb (void *obj, void *arg, int flags)
static int	unload_module (void)

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "PJSIP Asterisk Event PUBLISH Support" , .key = ASTERISK_GPL_KEY , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .reload = reload_module, .unload = unload_module, .load_pri = AST_MODPRI_CHANNEL_DEPEND + 5, .requires = "res_pjsip,res_pjsip_outbound_publish,res_pjsip_pubsub", }
static const struct ast_module_info *	ast_module_info = &__mod_info
struct ast_sip_publish_handler	asterisk_devicestate_publication_handler
struct ast_sip_event_publisher_handler	asterisk_devicestate_publisher_handler
static const struct ast_datastore_info	asterisk_devicestate_publisher_state_datastore
	Datastore for attaching devicestate publisher state information.
struct ast_sip_publish_handler	asterisk_mwi_publication_handler
struct ast_sip_event_publisher_handler	asterisk_mwi_publisher_handler
static const struct ast_datastore_info	asterisk_mwi_publisher_state_datastore
	Datastore for attaching devicestate publisher state information.

Function Documentation

__reg_module()

static void __reg_module ( void  )

static

Definition at line 964 of file res_pjsip_publish_asterisk.c.

__unreg_module()

static void __unreg_module ( void  )

static

Definition at line 964 of file res_pjsip_publish_asterisk.c.

AST_MODULE_SELF_SYM()

struct ast_module * AST_MODULE_SELF_SYM

(

void

)

Definition at line 964 of file res_pjsip_publish_asterisk.c.

asterisk_devicestate_publisher_state_destroy()

static void asterisk_devicestate_publisher_state_destroy ( void *  obj )

static

Destroy callback for Asterisk devicestate publisher state information from datastore.

Definition at line 156 of file res_pjsip_publish_asterisk.c.

{
    struct asterisk_devicestate_publisher_state *publisher_state = obj;
 
    ao2_cleanup(publisher_state->client);
 
    if (publisher_state->device_state_filter) {
        regfree(&publisher_state->device_state_regex);
    }
}

References ao2_cleanup, asterisk_devicestate_publisher_state::client, asterisk_devicestate_publisher_state::device_state_filter, and asterisk_devicestate_publisher_state::device_state_regex.

asterisk_mwi_publisher_state_destroy()

static void asterisk_mwi_publisher_state_destroy ( void *  obj )

static

Destroy callback for Asterisk mwi publisher state information from datastore.

Definition at line 174 of file res_pjsip_publish_asterisk.c.

{
    struct asterisk_mwi_publisher_state *publisher_state = obj;
 
    ao2_cleanup(publisher_state->client);
 
    if (publisher_state->mailbox_state_filter) {
        regfree(&publisher_state->mailbox_state_regex);
    }
}

References ao2_cleanup, asterisk_mwi_publisher_state::client, asterisk_mwi_publisher_state::mailbox_state_filter, and asterisk_mwi_publisher_state::mailbox_state_regex.

asterisk_publication_config_alloc()

static void * asterisk_publication_config_alloc ( const char *  name )

static

Allocator function for Asterisk publication configuration.

Definition at line 849 of file res_pjsip_publish_asterisk.c.

{
    struct asterisk_publication_config *config = ast_sorcery_generic_alloc(sizeof(*config),
        asterisk_publication_config_destroy);
 
    if (!config || ast_string_field_init(config, 256)) {
        ao2_cleanup(config);
        return NULL;
    }
 
    return config;
}

References ao2_cleanup, ast_sorcery_generic_alloc(), ast_string_field_init, asterisk_publication_config_destroy(), config, and NULL.

Referenced by load_module().

asterisk_publication_config_destroy()

static void asterisk_publication_config_destroy ( void *  obj )

static

Destructor function for Asterisk publication configuration.

Definition at line 841 of file res_pjsip_publish_asterisk.c.

{
    struct asterisk_publication_config *config = obj;
 
    ast_string_field_free_memory(config);
}

References ast_string_field_free_memory, and config.

Referenced by asterisk_publication_config_alloc().

asterisk_publication_devicestate()

static int asterisk_publication_devicestate ( struct ast_sip_publication *  pub, struct asterisk_publication_config *  config, struct ast_eid *  pubsub_eid, struct ast_json *  json  )

static

Definition at line 514 of file res_pjsip_publish_asterisk.c.

{
    const char *device = ast_json_string_get(ast_json_object_get(json, "device"));
    const char *state = ast_json_string_get(ast_json_object_get(json, "state"));
    int cachable = ast_json_integer_get(ast_json_object_get(json, "cachable"));
 
    if (!config->device_state) {
        ast_debug(2, "Received device state event for resource '%s' but it is not configured to accept them\n",
            ast_sorcery_object_get_id(config));
        return 0;
    }
 
    if (ast_strlen_zero(device) || ast_strlen_zero(state)) {
        ast_debug(1, "Received incomplete device state event for resource '%s'\n",
            ast_sorcery_object_get_id(config));
        return -1;
    }
 
    if (config->device_state_filter && regexec(&config->device_state_regex, device, 0, NULL, 0)) {
        ast_debug(2, "Received device state on resource '%s' for device '%s' but it has been filtered out\n",
            ast_sorcery_object_get_id(config), device);
        return 0;
    }
 
    ast_publish_device_state_full(device, ast_devstate_val(state),
        cachable == AST_DEVSTATE_CACHABLE ? AST_DEVSTATE_CACHABLE : AST_DEVSTATE_NOT_CACHABLE,
        pubsub_eid);
 
    return 0;
}

References ast_debug, AST_DEVSTATE_CACHABLE, AST_DEVSTATE_NOT_CACHABLE, ast_devstate_val(), ast_json_integer_get(), ast_json_object_get(), ast_json_string_get(), ast_publish_device_state_full(), ast_sorcery_object_get_id(), ast_strlen_zero(), config, and NULL.

Referenced by asterisk_publication_devicestate_state_change().

asterisk_publication_devicestate_refresh()

static int asterisk_publication_devicestate_refresh ( struct ast_sip_publication *  pub, struct asterisk_publication_config *  config, struct ast_eid *  pubsub_eid, struct ast_json *  json  )

static

Definition at line 581 of file res_pjsip_publish_asterisk.c.

{
    struct ast_sip_outbound_publish_client *client;
    struct ast_datastore *datastore;
    struct ao2_container *cached;
 
    if (ast_strlen_zero(config->devicestate_publish)) {
        return 0;
    }
 
    client = ast_sip_publish_client_get(config->devicestate_publish);
    if (!client) {
        ast_log(LOG_ERROR, "Received refresh request for devicestate on publication '%s' but publish '%s' is not available\n",
            ast_sorcery_object_get_id(config), config->devicestate_publish);
        return 0;
    }
 
    datastore = ast_sip_publish_client_get_datastore(client, "asterisk-devicestate-publisher");
    if (!datastore) {
        ao2_ref(client, -1);
        return 0;
    }
 
    cached = stasis_cache_dump(ast_device_state_cache(), NULL);
    if (cached) {
        ao2_callback(cached, OBJ_NODATA, cached_devstate_cb, datastore);
        ao2_ref(cached, -1);
    }
    ao2_ref(client, -1);
    ao2_ref(datastore, -1);
 
    return 0;
}

References ao2_callback, ao2_ref, ast_device_state_cache(), ast_log, ast_sip_publish_client_get(), ast_sip_publish_client_get_datastore(), ast_sorcery_object_get_id(), ast_strlen_zero(), cached_devstate_cb(), config, LOG_ERROR, NULL, OBJ_NODATA, and stasis_cache_dump().

Referenced by asterisk_publication_devicestate_state_change().

asterisk_publication_devicestate_state_change()

static int asterisk_publication_devicestate_state_change ( struct ast_sip_publication *  pub, pjsip_msg_body *  body, enum ast_sip_publish_state  state  )

static

Definition at line 616 of file res_pjsip_publish_asterisk.c.

{
    RAII_VAR(struct asterisk_publication_config *, config, ast_sorcery_retrieve_by_id(ast_sip_get_sorcery(), "asterisk-publication",
        ast_sip_publication_get_event_configuration(pub)), ao2_cleanup);
    RAII_VAR(struct ast_json *, json, NULL, ast_json_unref);
    const char *eid, *type;
    struct ast_eid pubsub_eid;
    int res = -1;
 
    /* If no configuration exists for this publication it has most likely been removed, so drop this immediately */
    if (!config) {
        return -1;
    }
 
    /* If no body exists this is a refresh and can be ignored */
    if (!body) {
        return 0;
    }
 
    /* We only accept JSON for content */
    if (!ast_sip_is_content_type(&body->content_type, "application", "json")) {
        ast_debug(2, "Received unsupported content type for Asterisk event on resource '%s'\n",
            ast_sorcery_object_get_id(config));
        return -1;
    }
 
    json = ast_json_load_buf(body->data, body->len, NULL);
    if (!json) {
        ast_debug(1, "Received unparseable JSON event for resource '%s'\n",
            ast_sorcery_object_get_id(config));
        return -1;
    }
 
    eid = ast_json_string_get(ast_json_object_get(json, "eid"));
    if (!eid) {
        ast_debug(1, "Received event without eid for resource '%s'\n",
            ast_sorcery_object_get_id(config));
        return -1;
    }
    ast_str_to_eid(&pubsub_eid, eid);
 
    type = ast_json_string_get(ast_json_object_get(json, "type"));
    if (!type) {
        ast_debug(1, "Received event without type for resource '%s'\n",
            ast_sorcery_object_get_id(config));
        return -1;
    } else if (!strcmp(type, "devicestate")) {
        res = asterisk_publication_devicestate(pub, config, &pubsub_eid, json);
    } else if (!strcmp(type, "refresh")) {
        res = asterisk_publication_devicestate_refresh(pub, config, &pubsub_eid, json);
    }
 
    return res;
}

References ao2_cleanup, ast_debug, ast_json_load_buf(), ast_json_object_get(), ast_json_string_get(), ast_json_unref(), ast_sip_get_sorcery(), ast_sip_is_content_type(), ast_sip_publication_get_event_configuration(), ast_sorcery_object_get_id(), ast_sorcery_retrieve_by_id(), ast_str_to_eid(), asterisk_publication_devicestate(), asterisk_publication_devicestate_refresh(), config, ast_eid::eid, NULL, RAII_VAR, and type.

asterisk_publication_mailboxstate()

static int asterisk_publication_mailboxstate ( struct ast_sip_publication *  pub, struct asterisk_publication_config *  config, struct ast_eid *  pubsub_eid, struct ast_json *  json  )

static

Definition at line 546 of file res_pjsip_publish_asterisk.c.

{
    const char *uniqueid = ast_json_string_get(ast_json_object_get(json, "uniqueid"));
    int old_msgs = ast_json_integer_get(ast_json_object_get(json, "old"));
    int new_msgs = ast_json_integer_get(ast_json_object_get(json, "new"));
    char *item_id;
    const char *mailbox;
 
    if (!config->mailbox_state) {
        ast_debug(2, "Received mailbox state event for resource '%s' but it is not configured to accept them\n",
            ast_sorcery_object_get_id(config));
        return 0;
    }
 
    if (ast_strlen_zero(uniqueid)) {
        ast_debug(1, "Received incomplete mailbox state event for resource '%s'\n",
            ast_sorcery_object_get_id(config));
        return -1;
    }
 
    if (config->mailbox_state_filter && regexec(&config->mailbox_state_regex, uniqueid, 0, NULL, 0)) {
        ast_debug(2, "Received mailbox state on resource '%s' for uniqueid '%s' but it has been filtered out\n",
            ast_sorcery_object_get_id(config), uniqueid);
        return 0;
    }
 
    item_id = ast_strdupa(uniqueid);
    mailbox = strsep(&item_id, "@");
 
    ast_publish_mwi_state_full(mailbox, item_id, new_msgs, old_msgs, NULL, pubsub_eid);
 
    return 0;
}

References ast_debug, ast_json_integer_get(), ast_json_object_get(), ast_json_string_get(), ast_publish_mwi_state_full(), ast_sorcery_object_get_id(), ast_strdupa, ast_strlen_zero(), config, NULL, and strsep().

Referenced by asterisk_publication_mwi_state_change().

asterisk_publication_mwi_refresh()

static int asterisk_publication_mwi_refresh ( struct ast_sip_publication *  pub, struct asterisk_publication_config *  config, struct ast_eid *  pubsub_eid, struct ast_json *  json  )

static

Definition at line 672 of file res_pjsip_publish_asterisk.c.

{
    struct ast_sip_outbound_publish_client *client;
    struct ast_datastore *datastore;
    struct ao2_container *cached;
 
    if (ast_strlen_zero(config->mailboxstate_publish)) {
        return 0;
    }
 
    client = ast_sip_publish_client_get(config->mailboxstate_publish);
    if (!client) {
        ast_log(LOG_ERROR, "Received refresh request for mwi state on publication '%s' but publish '%s' is not available\n",
            ast_sorcery_object_get_id(config), config->mailboxstate_publish);
        return 0;
    }
 
    datastore = ast_sip_publish_client_get_datastore(client, "asterisk-mwi-publisher");
    if (!datastore) {
        ao2_ref(client, -1);
        return 0;
    }
 
    cached = stasis_cache_dump(ast_mwi_state_cache(), NULL);
    if (cached) {
        ao2_callback(cached, OBJ_NODATA, cached_mwistate_cb, datastore);
        ao2_ref(cached, -1);
    }
    ao2_ref(client, -1);
    ao2_ref(datastore, -1);
 
    return 0;
}

References ao2_callback, ao2_ref, ast_log, ast_mwi_state_cache(), ast_sip_publish_client_get(), ast_sip_publish_client_get_datastore(), ast_sorcery_object_get_id(), ast_strlen_zero(), cached_mwistate_cb(), config, LOG_ERROR, NULL, OBJ_NODATA, and stasis_cache_dump().

Referenced by asterisk_publication_mwi_state_change().

asterisk_publication_mwi_state_change()

static int asterisk_publication_mwi_state_change ( struct ast_sip_publication *  pub, pjsip_msg_body *  body, enum ast_sip_publish_state  state  )

static

Definition at line 707 of file res_pjsip_publish_asterisk.c.

{
    RAII_VAR(struct asterisk_publication_config *, config, ast_sorcery_retrieve_by_id(ast_sip_get_sorcery(), "asterisk-publication",
        ast_sip_publication_get_event_configuration(pub)), ao2_cleanup);
    RAII_VAR(struct ast_json *, json, NULL, ast_json_unref);
    const char *eid, *type;
    struct ast_eid pubsub_eid;
    int res = -1;
 
    /* If no configuration exists for this publication it has most likely been removed, so drop this immediately */
    if (!config) {
        return -1;
    }
 
    /* If no body exists this is a refresh and can be ignored */
    if (!body) {
        return 0;
    }
 
    /* We only accept JSON for content */
    if (!ast_sip_is_content_type(&body->content_type, "application", "json")) {
        ast_debug(2, "Received unsupported content type for Asterisk event on resource '%s'\n",
            ast_sorcery_object_get_id(config));
        return -1;
    }
 
    json = ast_json_load_buf(body->data, body->len, NULL);
    if (!json) {
        ast_debug(1, "Received unparseable JSON event for resource '%s'\n",
            ast_sorcery_object_get_id(config));
        return -1;
    }
 
    eid = ast_json_string_get(ast_json_object_get(json, "eid"));
    if (!eid) {
        ast_debug(1, "Received event without eid for resource '%s'\n",
            ast_sorcery_object_get_id(config));
        return -1;
    }
    ast_str_to_eid(&pubsub_eid, eid);
 
    type = ast_json_string_get(ast_json_object_get(json, "type"));
    if (!type) {
        ast_debug(1, "Received event without type for resource '%s'\n",
            ast_sorcery_object_get_id(config));
        return -1;
    } else if (!strcmp(type, "mailboxstate")) {
        res = asterisk_publication_mailboxstate(pub, config, &pubsub_eid, json);
    } else if (!strcmp(type, "refresh")) {
        res = asterisk_publication_mwi_refresh(pub, config, &pubsub_eid, json);
    }
 
    return res;
}

References ao2_cleanup, ast_debug, ast_json_load_buf(), ast_json_object_get(), ast_json_string_get(), ast_json_unref(), ast_sip_get_sorcery(), ast_sip_is_content_type(), ast_sip_publication_get_event_configuration(), ast_sorcery_object_get_id(), ast_sorcery_retrieve_by_id(), ast_str_to_eid(), asterisk_publication_mailboxstate(), asterisk_publication_mwi_refresh(), config, ast_eid::eid, NULL, RAII_VAR, and type.

asterisk_publication_new()

static int asterisk_publication_new ( struct ast_sip_endpoint *  endpoint, const char *  resource, const char *  event_configuration  )

static

Definition at line 501 of file res_pjsip_publish_asterisk.c.

{
    RAII_VAR(struct asterisk_publication_config *, config, ast_sorcery_retrieve_by_id(ast_sip_get_sorcery(), "asterisk-publication",
        event_configuration), ao2_cleanup);
 
    /* If no inbound Asterisk publication configuration exists reject the PUBLISH */
    if (!config) {
        return 404;
    }
 
    return 200;
}

References ao2_cleanup, ast_sip_get_sorcery(), ast_sorcery_retrieve_by_id(), config, and RAII_VAR.

asterisk_publication_send_refresh()

static void asterisk_publication_send_refresh ( void  )

static

Internal function to send refresh requests to all publications.

Definition at line 788 of file res_pjsip_publish_asterisk.c.

{
    struct ao2_container *publications = ast_sorcery_retrieve_by_fields(ast_sip_get_sorcery(), "asterisk-publication", AST_RETRIEVE_FLAG_MULTIPLE | AST_RETRIEVE_FLAG_ALL, NULL);
    char eid_str[20];
    struct ast_json *json;
    char *text;
    struct ast_sip_body body = {
        .type = "application",
        .subtype = "json",
    };
 
    if (!publications) {
        return;
    }
 
    ast_eid_to_str(eid_str, sizeof(eid_str), &ast_eid_default);
    json = ast_json_pack(
        "{ s: s, s: s }",
        "type", "refresh",
        "eid", eid_str);
    if (!json) {
        ao2_ref(publications, -1);
        return;
    }
 
    text = ast_json_dump_string(json);
    if (!text) {
        ast_json_unref(json);
        ao2_ref(publications, -1);
        return;
    }
    body.body_text = text;
 
    ao2_callback(publications, OBJ_NODATA, send_refresh_cb, &body);
 
    ast_json_free(text);
    ast_json_unref(json);
    ao2_ref(publications, -1);
}

References ao2_callback, ao2_ref, ast_eid_default, ast_eid_to_str(), ast_json_dump_string, ast_json_free(), ast_json_pack(), ast_json_unref(), AST_RETRIEVE_FLAG_ALL, AST_RETRIEVE_FLAG_MULTIPLE, ast_sip_get_sorcery(), ast_sorcery_retrieve_by_fields(), ast_sip_body::body_text, NULL, OBJ_NODATA, send_refresh_cb(), text, and ast_sip_body::type.

Referenced by load_module(), and reload_module().

asterisk_publisher_devstate_cb()

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

static

Callback function for device state events.

Parameters

data	void pointer to ast_client structure
sub,msg

Definition at line 196 of file res_pjsip_publish_asterisk.c.

{
    struct ast_datastore *datastore = data;
    struct asterisk_devicestate_publisher_state *publisher_state = datastore->data;
    struct ast_device_state_message *dev_state;
    char eid_str[20];
    struct ast_json *json;
    char *text;
    struct ast_sip_body body = {
        .type = "application",
        .subtype = "json",
    };
 
    if (!stasis_subscription_is_subscribed(sub) || ast_device_state_message_type() != stasis_message_type(msg)) {
        return;
    }
 
    dev_state = stasis_message_data(msg);
    if (!dev_state->eid || ast_eid_cmp(&ast_eid_default, dev_state->eid)) {
        /* If the event is aggregate or didn't originate from this server, don't send it out. */
        return;
    }
 
    if (publisher_state->device_state_filter && regexec(&publisher_state->device_state_regex, dev_state->device, 0, NULL, 0)) {
        /* Outgoing device state has been filtered and the device name does not match */
        return;
    }
 
    ast_eid_to_str(eid_str, sizeof(eid_str), &ast_eid_default);
    json = ast_json_pack(
        "{ s: s, s: s, s: s, s: i, s:s }",
        "type", "devicestate",
        "device", dev_state->device,
        "state", ast_devstate_str(dev_state->state),
        "cachable", dev_state->cachable,
        "eid", eid_str);
    if (!json) {
        return;
    }
 
    text = ast_json_dump_string(json);
    if (!text) {
        ast_json_unref(json);
        return;
    }
    body.body_text = text;
 
    ast_sip_publish_client_send(publisher_state->client, &body);
 
    ast_json_free(text);
    ast_json_unref(json);
}

References ast_device_state_message_type(), ast_devstate_str(), ast_eid_cmp(), ast_eid_default, ast_eid_to_str(), ast_json_dump_string, ast_json_free(), ast_json_pack(), ast_json_unref(), ast_sip_publish_client_send(), ast_sip_body::body_text, ast_device_state_message::cachable, asterisk_devicestate_publisher_state::client, ast_datastore::data, ast_device_state_message::device, asterisk_devicestate_publisher_state::device_state_filter, asterisk_devicestate_publisher_state::device_state_regex, ast_device_state_message::eid, NULL, stasis_message_data(), stasis_subscription_is_subscribed(), ast_device_state_message::state, sub, text, and ast_sip_body::type.

Referenced by asterisk_start_devicestate_publishing(), and cached_devstate_cb().

asterisk_publisher_mwistate_cb()

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

static

Callback function for mailbox state events.

Parameters

data	void pointer to ast_client structure
sub,msg

Definition at line 254 of file res_pjsip_publish_asterisk.c.

{
    struct ast_datastore *datastore = data;
    struct asterisk_mwi_publisher_state *publisher_state = datastore->data;
    struct ast_mwi_state *mwi_state;
    char eid_str[20];
    struct ast_json *json;
    char *text;
    struct ast_sip_body body = {
        .type = "application",
        .subtype = "json",
    };
 
    if (!stasis_subscription_is_subscribed(sub) || ast_mwi_state_type() != stasis_message_type(msg)) {
        return;
    }
 
    mwi_state = stasis_message_data(msg);
    if (ast_eid_cmp(&ast_eid_default, &mwi_state->eid)) {
        /* If the event is aggregate or didn't originate from this server, don't send it out. */
        return;
    }
 
    if (publisher_state->mailbox_state_filter && regexec(&publisher_state->mailbox_state_regex, mwi_state->uniqueid, 0, NULL, 0)) {
        /* Outgoing mailbox state has been filtered and the uniqueid does not match */
        return;
    }
 
    ast_eid_to_str(eid_str, sizeof(eid_str), &ast_eid_default);
    json = ast_json_pack(
        "{ s: s, s: s, s: i, s: i, s:s }",
        "type", "mailboxstate",
        "uniqueid", mwi_state->uniqueid,
        "old", mwi_state->old_msgs,
        "new", mwi_state->new_msgs,
        "eid", eid_str);
    if (!json) {
        return;
    }
 
    text = ast_json_dump_string(json);
    if (!text) {
        ast_json_unref(json);
        return;
    }
    body.body_text = text;
 
    ast_sip_publish_client_send(publisher_state->client, &body);
 
    ast_json_free(text);
    ast_json_unref(json);
}

References ast_eid_cmp(), ast_eid_default, ast_eid_to_str(), ast_json_dump_string, ast_json_free(), ast_json_pack(), ast_json_unref(), ast_mwi_state_type(), ast_sip_publish_client_send(), ast_sip_body::body_text, asterisk_mwi_publisher_state::client, ast_datastore::data, ast_mwi_state::eid, asterisk_mwi_publisher_state::mailbox_state_filter, asterisk_mwi_publisher_state::mailbox_state_regex, ast_mwi_state::new_msgs, NULL, ast_mwi_state::old_msgs, stasis_message_data(), stasis_subscription_is_subscribed(), sub, text, ast_sip_body::type, and ast_mwi_state::uniqueid.

Referenced by asterisk_start_mwi_publishing(), and cached_mwistate_cb().

asterisk_start_devicestate_publishing()

static int asterisk_start_devicestate_publishing ( struct ast_sip_outbound_publish *  configuration, struct ast_sip_outbound_publish_client *  client  )

static

Definition at line 344 of file res_pjsip_publish_asterisk.c.

{
    RAII_VAR(struct ast_datastore *, datastore, NULL, ao2_cleanup);
    struct asterisk_devicestate_publisher_state *publisher_state;
    const char *value;
    struct ao2_container *cached;
 
    datastore = ast_sip_publish_client_alloc_datastore(&asterisk_devicestate_publisher_state_datastore,
        "asterisk-devicestate-publisher");
    if (!datastore) {
        return -1;
    }
 
    publisher_state = ast_calloc(1, sizeof(struct asterisk_devicestate_publisher_state));
    if (!publisher_state) {
        return -1;
    }
    datastore->data = publisher_state;
 
    value = ast_sorcery_object_get_extended(configuration, "device_state_filter");
    if (!ast_strlen_zero(value)) {
        if (build_regex(&publisher_state->device_state_regex, value)) {
            return -1;
        }
        publisher_state->device_state_filter = 1;
    }
 
    publisher_state->client = ao2_bump(client);
 
    if (ast_sip_publish_client_add_datastore(client, datastore)) {
        return -1;
    }
 
    publisher_state->device_state_subscription = stasis_subscribe(ast_device_state_topic_all(),
        asterisk_publisher_devstate_cb, ao2_bump(datastore));
    if (!publisher_state->device_state_subscription) {
        ast_sip_publish_client_remove_datastore(client, "asterisk-devicestate-publisher");
        ao2_ref(datastore, -1);
        return -1;
    }
    stasis_subscription_accept_message_type(publisher_state->device_state_subscription, ast_device_state_message_type());
    stasis_subscription_accept_message_type(publisher_state->device_state_subscription, stasis_subscription_change_type());
    stasis_subscription_set_filter(publisher_state->device_state_subscription, STASIS_SUBSCRIPTION_FILTER_SELECTIVE);
 
    cached = stasis_cache_dump(ast_device_state_cache(), NULL);
    ao2_callback(cached, OBJ_NODATA, cached_devstate_cb, datastore);
    ao2_ref(cached, -1);
 
    return 0;
}

References ao2_bump, ao2_callback, ao2_cleanup, ao2_ref, ast_calloc, ast_device_state_cache(), ast_device_state_message_type(), ast_device_state_topic_all(), ast_sip_publish_client_add_datastore(), ast_sip_publish_client_alloc_datastore(), ast_sip_publish_client_remove_datastore(), ast_sorcery_object_get_extended(), ast_strlen_zero(), asterisk_devicestate_publisher_state_datastore, asterisk_publisher_devstate_cb(), build_regex(), cached_devstate_cb(), asterisk_devicestate_publisher_state::client, asterisk_devicestate_publisher_state::device_state_filter, asterisk_devicestate_publisher_state::device_state_regex, asterisk_devicestate_publisher_state::device_state_subscription, NULL, OBJ_NODATA, RAII_VAR, stasis_cache_dump(), stasis_subscribe, stasis_subscription_accept_message_type(), stasis_subscription_change_type(), STASIS_SUBSCRIPTION_FILTER_SELECTIVE, stasis_subscription_set_filter(), and value.

asterisk_start_mwi_publishing()

static int asterisk_start_mwi_publishing ( struct ast_sip_outbound_publish *  configuration, struct ast_sip_outbound_publish_client *  client  )

static

Definition at line 423 of file res_pjsip_publish_asterisk.c.

{
    RAII_VAR(struct ast_datastore *, datastore, NULL, ao2_cleanup);
    struct asterisk_mwi_publisher_state *publisher_state;
    const char *value;
    struct ao2_container *cached;
 
    datastore = ast_sip_publish_client_alloc_datastore(&asterisk_mwi_publisher_state_datastore, "asterisk-mwi-publisher");
    if (!datastore) {
        return -1;
    }
 
    publisher_state = ast_calloc(1, sizeof(struct asterisk_mwi_publisher_state));
    if (!publisher_state) {
        return -1;
    }
    datastore->data = publisher_state;
 
    value = ast_sorcery_object_get_extended(configuration, "mailbox_state_filter");
    if (!ast_strlen_zero(value)) {
        if (build_regex(&publisher_state->mailbox_state_regex, value)) {
            return -1;
        }
        publisher_state->mailbox_state_filter = 1;
    }
 
    publisher_state->client = ao2_bump(client);
 
    if (ast_sip_publish_client_add_datastore(client, datastore)) {
        return -1;
    }
 
    publisher_state->mailbox_state_subscription = stasis_subscribe(ast_mwi_topic_all(),
        asterisk_publisher_mwistate_cb, ao2_bump(datastore));
    if (!publisher_state->mailbox_state_subscription) {
        ast_sip_publish_client_remove_datastore(client, "asterisk-mwi-publisher");
        ao2_ref(datastore, -1);
        return -1;
    }
    stasis_subscription_accept_message_type(publisher_state->mailbox_state_subscription, ast_mwi_state_type());
    stasis_subscription_accept_message_type(publisher_state->mailbox_state_subscription, stasis_subscription_change_type());
    stasis_subscription_set_filter(publisher_state->mailbox_state_subscription, STASIS_SUBSCRIPTION_FILTER_SELECTIVE);
 
    cached = stasis_cache_dump(ast_mwi_state_cache(), NULL);
    ao2_callback(cached, OBJ_NODATA, cached_mwistate_cb, datastore);
    ao2_ref(cached, -1);
 
    return 0;
}

References ao2_bump, ao2_callback, ao2_cleanup, ao2_ref, ast_calloc, ast_mwi_state_cache(), ast_mwi_state_type(), ast_mwi_topic_all(), ast_sip_publish_client_add_datastore(), ast_sip_publish_client_alloc_datastore(), ast_sip_publish_client_remove_datastore(), ast_sorcery_object_get_extended(), ast_strlen_zero(), asterisk_mwi_publisher_state_datastore, asterisk_publisher_mwistate_cb(), build_regex(), cached_mwistate_cb(), asterisk_mwi_publisher_state::client, asterisk_mwi_publisher_state::mailbox_state_filter, asterisk_mwi_publisher_state::mailbox_state_regex, asterisk_mwi_publisher_state::mailbox_state_subscription, NULL, OBJ_NODATA, RAII_VAR, stasis_cache_dump(), stasis_subscribe, stasis_subscription_accept_message_type(), stasis_subscription_change_type(), STASIS_SUBSCRIPTION_FILTER_SELECTIVE, stasis_subscription_set_filter(), and value.

asterisk_stop_devicestate_publishing()

static int asterisk_stop_devicestate_publishing ( struct ast_sip_outbound_publish_client *  client )

static

Definition at line 396 of file res_pjsip_publish_asterisk.c.

{
    RAII_VAR(struct ast_datastore *, datastore, ast_sip_publish_client_get_datastore(client, "asterisk-devicestate-publisher"),
        ao2_cleanup);
    struct asterisk_devicestate_publisher_state *publisher_state;
 
    if (!datastore) {
        return 0;
    }
 
    publisher_state = datastore->data;
    if (publisher_state->device_state_subscription) {
        stasis_unsubscribe_and_join(publisher_state->device_state_subscription);
        ao2_ref(datastore, -1);
    }
 
    ast_sip_publish_client_remove_datastore(client, "asterisk-devicestate-publisher");
 
    return 0;
}

References ao2_cleanup, ao2_ref, ast_sip_publish_client_get_datastore(), ast_sip_publish_client_remove_datastore(), asterisk_devicestate_publisher_state::client, asterisk_devicestate_publisher_state::device_state_subscription, RAII_VAR, and stasis_unsubscribe_and_join().

asterisk_stop_mwi_publishing()

static int asterisk_stop_mwi_publishing ( struct ast_sip_outbound_publish_client *  client )

static

Definition at line 474 of file res_pjsip_publish_asterisk.c.

{
    RAII_VAR(struct ast_datastore *, datastore, ast_sip_publish_client_get_datastore(client, "asterisk-mwi-publisher"),
        ao2_cleanup);
    struct asterisk_mwi_publisher_state *publisher_state;
 
    if (!datastore) {
        return 0;
    }
 
    publisher_state = datastore->data;
    if (publisher_state->mailbox_state_subscription) {
        stasis_unsubscribe_and_join(publisher_state->mailbox_state_subscription);
        ao2_ref(datastore, -1);
    }
 
    ast_sip_publish_client_remove_datastore(client, "asterisk-mwi-publisher");
 
    return 0;
}

References ao2_cleanup, ao2_ref, ast_sip_publish_client_get_datastore(), ast_sip_publish_client_remove_datastore(), asterisk_mwi_publisher_state::client, asterisk_mwi_publisher_state::mailbox_state_subscription, RAII_VAR, and stasis_unsubscribe_and_join().

build_regex()

static int build_regex ( regex_t *  regex, const char *  text  )

static

Definition at line 329 of file res_pjsip_publish_asterisk.c.

{
    int res;
 
    if ((res = regcomp(regex, text, REG_EXTENDED | REG_ICASE | REG_NOSUB))) {
        size_t len = regerror(res, regex, NULL, 0);
        char buf[len];
        regerror(res, regex, buf, len);
        ast_log(LOG_ERROR, "Could not compile regex '%s': %s\n", text, buf);
        return -1;
    }
 
    return 0;
}

References ast_log, buf, len(), LOG_ERROR, NULL, regex(), and text.

Referenced by asterisk_start_devicestate_publishing(), asterisk_start_mwi_publishing(), and regex_filter_handler().

cached_devstate_cb()

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

static

Definition at line 307 of file res_pjsip_publish_asterisk.c.

{
    struct stasis_message *msg = obj;
    struct ast_datastore *datastore = arg;
    struct asterisk_devicestate_publisher_state *publisher_state = datastore->data;
 
    asterisk_publisher_devstate_cb(arg, publisher_state->device_state_subscription, msg);
 
    return 0;
}

References asterisk_publisher_devstate_cb(), ast_datastore::data, and asterisk_devicestate_publisher_state::device_state_subscription.

Referenced by asterisk_publication_devicestate_refresh(), and asterisk_start_devicestate_publishing().

cached_mwistate_cb()

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

static

Definition at line 318 of file res_pjsip_publish_asterisk.c.

{
    struct stasis_message *msg = obj;
    struct ast_datastore *datastore = arg;
    struct asterisk_mwi_publisher_state *publisher_state = datastore->data;
 
    asterisk_publisher_mwistate_cb(arg, publisher_state->mailbox_state_subscription, msg);
 
    return 0;
}

References asterisk_publisher_mwistate_cb(), ast_datastore::data, and asterisk_mwi_publisher_state::mailbox_state_subscription.

Referenced by asterisk_publication_mwi_refresh(), and asterisk_start_mwi_publishing().

load_module()

static int load_module ( void  )

static

Definition at line 884 of file res_pjsip_publish_asterisk.c.

{
    if (ast_eid_is_empty(&ast_eid_default)) {
        ast_log(LOG_ERROR, "Entity ID is not set.\n");
        return AST_MODULE_LOAD_DECLINE;
    }
 
    ast_sorcery_apply_config(ast_sip_get_sorcery(), "res_pjsip_publish_asterisk");
    ast_sorcery_apply_default(ast_sip_get_sorcery(), "asterisk-publication", "config", "pjsip.conf,criteria=type=asterisk-publication");
 
    if (ast_sorcery_object_register(ast_sip_get_sorcery(), "asterisk-publication", asterisk_publication_config_alloc, NULL, NULL)) {
        ast_log(LOG_ERROR, "Unable to register 'asterisk-publication' type with sorcery\n");
        return AST_MODULE_LOAD_DECLINE;
    }
 
    ast_sorcery_object_field_register(ast_sip_get_sorcery(), "asterisk-publication", "type", "", OPT_NOOP_T, 0, 0);
    ast_sorcery_object_field_register(ast_sip_get_sorcery(), "asterisk-publication", "devicestate_publish", "", OPT_STRINGFIELD_T, 0, STRFLDSET(struct asterisk_publication_config, devicestate_publish));
    ast_sorcery_object_field_register(ast_sip_get_sorcery(), "asterisk-publication", "mailboxstate_publish", "", OPT_STRINGFIELD_T, 0, STRFLDSET(struct asterisk_publication_config, mailboxstate_publish));
    ast_sorcery_object_field_register(ast_sip_get_sorcery(), "asterisk-publication", "device_state", "no", OPT_BOOL_T, 1, FLDSET(struct asterisk_publication_config, device_state));
    ast_sorcery_object_field_register_custom(ast_sip_get_sorcery(), "asterisk-publication", "device_state_filter", "", regex_filter_handler, NULL, NULL, 0, 0);
    ast_sorcery_object_field_register(ast_sip_get_sorcery(), "asterisk-publication", "mailbox_state", "no", OPT_BOOL_T, 1, FLDSET(struct asterisk_publication_config, mailbox_state));
    ast_sorcery_object_field_register_custom(ast_sip_get_sorcery(), "asterisk-publication", "mailbox_state_filter", "", regex_filter_handler, NULL, NULL, 0, 0);
    ast_sorcery_reload_object(ast_sip_get_sorcery(), "asterisk-publication");
 
    if (ast_sip_register_publish_handler(&asterisk_devicestate_publication_handler)) {
        ast_log(LOG_WARNING, "Unable to register event publication handler %s\n",
            asterisk_devicestate_publication_handler.event_name);
        return AST_MODULE_LOAD_DECLINE;
    }
    if (ast_sip_register_publish_handler(&asterisk_mwi_publication_handler)) {
        ast_log(LOG_WARNING, "Unable to register event publication handler %s\n",
            asterisk_mwi_publication_handler.event_name);
        ast_sip_unregister_publish_handler(&asterisk_devicestate_publication_handler);
        return AST_MODULE_LOAD_DECLINE;
    }
    if (ast_sip_register_event_publisher_handler(&asterisk_devicestate_publisher_handler)) {
        ast_log(LOG_WARNING, "Unable to register event publisher handler %s\n",
            asterisk_devicestate_publisher_handler.event_name);
        ast_sip_unregister_publish_handler(&asterisk_devicestate_publication_handler);
        ast_sip_unregister_publish_handler(&asterisk_mwi_publication_handler);
        return AST_MODULE_LOAD_DECLINE;
    }
    if (ast_sip_register_event_publisher_handler(&asterisk_mwi_publisher_handler)) {
        ast_log(LOG_WARNING, "Unable to register event publisher handler %s\n",
            asterisk_mwi_publisher_handler.event_name);
        ast_sip_unregister_event_publisher_handler(&asterisk_mwi_publisher_handler);
        ast_sip_unregister_publish_handler(&asterisk_devicestate_publication_handler);
        ast_sip_unregister_publish_handler(&asterisk_mwi_publication_handler);
        return AST_MODULE_LOAD_DECLINE;
    }
 
    asterisk_publication_send_refresh();
 
    return AST_MODULE_LOAD_SUCCESS;
}

References ast_eid_default, ast_eid_is_empty(), ast_log, AST_MODULE_LOAD_DECLINE, AST_MODULE_LOAD_SUCCESS, ast_sip_get_sorcery(), ast_sip_register_event_publisher_handler(), ast_sip_register_publish_handler(), ast_sip_unregister_event_publisher_handler(), ast_sip_unregister_publish_handler(), ast_sorcery_apply_config, ast_sorcery_apply_default, ast_sorcery_object_field_register, ast_sorcery_object_field_register_custom, ast_sorcery_object_register, ast_sorcery_reload_object(), asterisk_devicestate_publication_handler, asterisk_devicestate_publisher_handler, asterisk_mwi_publication_handler, asterisk_mwi_publisher_handler, asterisk_publication_config_alloc(), asterisk_publication_send_refresh(), asterisk_publication_config::device_state, asterisk_publication_config::devicestate_publish, ast_sip_event_publisher_handler::event_name, ast_sip_publish_handler::event_name, FLDSET, LOG_ERROR, LOG_WARNING, asterisk_publication_config::mailbox_state, asterisk_publication_config::mailboxstate_publish, NULL, OPT_BOOL_T, OPT_NOOP_T, OPT_STRINGFIELD_T, regex_filter_handler(), and STRFLDSET.

regex_filter_handler()

static int regex_filter_handler ( const struct aco_option *  opt, struct ast_variable *  var, void *  obj  )

static

Definition at line 862 of file res_pjsip_publish_asterisk.c.

{
    struct asterisk_publication_config *config = obj;
    int res = -1;
 
    if (ast_strlen_zero(var->value)) {
        return 0;
    }
 
    if (!strcmp(var->name, "device_state_filter")) {
        if (!(res = build_regex(&config->device_state_regex, var->value))) {
            config->device_state_filter = 1;
        }
    } else if (!strcmp(var->name, "mailbox_state_filter")) {
        if (!(res = build_regex(&config->mailbox_state_regex, var->value))) {
            config->mailbox_state_filter = 1;
        }
    }
 
    return res;
}

References ast_strlen_zero(), build_regex(), config, asterisk_publication_config::device_state_filter, and var.

Referenced by load_module().

reload_module()

static int reload_module ( void  )

static

Definition at line 940 of file res_pjsip_publish_asterisk.c.

{
    ast_sorcery_reload_object(ast_sip_get_sorcery(), "asterisk-publication");
    asterisk_publication_send_refresh();
    return 0;
}

References ast_sip_get_sorcery(), ast_sorcery_reload_object(), and asterisk_publication_send_refresh().

send_refresh_cb()

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

static

Definition at line 763 of file res_pjsip_publish_asterisk.c.

{
    struct asterisk_publication_config *config = obj;
    struct ast_sip_outbound_publish_client *client;
 
    if (!ast_strlen_zero(config->devicestate_publish)) {
        client = ast_sip_publish_client_get(config->devicestate_publish);
        if (client) {
            ast_sip_publish_client_send(client, arg);
            ao2_ref(client, -1);
        }
    }
 
    if (!ast_strlen_zero(config->mailboxstate_publish)) {
        client = ast_sip_publish_client_get(config->mailboxstate_publish);
        if (client) {
            ast_sip_publish_client_send(client, arg);
            ao2_ref(client, -1);
        }
    }
 
    return 0;
}

References ao2_ref, ast_sip_publish_client_get(), ast_sip_publish_client_send(), ast_strlen_zero(), and config.

Referenced by asterisk_publication_send_refresh().

unload_module()

static int unload_module ( void  )

static

Definition at line 947 of file res_pjsip_publish_asterisk.c.

{
    ast_sip_unregister_publish_handler(&asterisk_devicestate_publication_handler);
    ast_sip_unregister_publish_handler(&asterisk_mwi_publication_handler);
    ast_sip_unregister_event_publisher_handler(&asterisk_devicestate_publisher_handler);
    ast_sip_unregister_event_publisher_handler(&asterisk_mwi_publisher_handler);
    ast_sorcery_object_unregister(ast_sip_get_sorcery(), "asterisk-publication");
    return 0;
}

References ast_sip_get_sorcery(), ast_sip_unregister_event_publisher_handler(), ast_sip_unregister_publish_handler(), ast_sorcery_object_unregister(), asterisk_devicestate_publication_handler, asterisk_devicestate_publisher_handler, asterisk_mwi_publication_handler, and asterisk_mwi_publisher_handler.

Variable Documentation

__mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "PJSIP Asterisk Event PUBLISH Support" , .key = ASTERISK_GPL_KEY , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .reload = reload_module, .unload = unload_module, .load_pri = AST_MODPRI_CHANNEL_DEPEND + 5, .requires = "res_pjsip,res_pjsip_outbound_publish,res_pjsip_pubsub", }

static

Definition at line 964 of file res_pjsip_publish_asterisk.c.

ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 964 of file res_pjsip_publish_asterisk.c.

asterisk_devicestate_publication_handler

struct ast_sip_publish_handler asterisk_devicestate_publication_handler

Initial value:

= {
    .event_name = "asterisk-devicestate",
    .new_publication = asterisk_publication_new,
    .publication_state_change = asterisk_publication_devicestate_state_change,
}

Definition at line 828 of file res_pjsip_publish_asterisk.c.

                                                                          {
    .event_name = "asterisk-devicestate",
    .new_publication = asterisk_publication_new,
    .publication_state_change = asterisk_publication_devicestate_state_change,
};

Referenced by load_module(), and unload_module().

asterisk_devicestate_publisher_handler

struct ast_sip_event_publisher_handler asterisk_devicestate_publisher_handler

Initial value:

= {
    .event_name = "asterisk-devicestate",
    .start_publishing = asterisk_start_devicestate_publishing,
    .stop_publishing = asterisk_stop_devicestate_publishing,
}

Definition at line 417 of file res_pjsip_publish_asterisk.c.

                                                                                {
    .event_name = "asterisk-devicestate",
    .start_publishing = asterisk_start_devicestate_publishing,
    .stop_publishing = asterisk_stop_devicestate_publishing,
};

Referenced by load_module(), and unload_module().

asterisk_devicestate_publisher_state_datastore

const struct ast_datastore_info asterisk_devicestate_publisher_state_datastore

static

Initial value:

= {
    .type = "asterisk-devicestate-publisher",
    .destroy = asterisk_devicestate_publisher_state_destroy,
}

Datastore for attaching devicestate publisher state information.

Definition at line 168 of file res_pjsip_publish_asterisk.c.

                                                                                        {
    .type = "asterisk-devicestate-publisher",
    .destroy = asterisk_devicestate_publisher_state_destroy,
};

Referenced by asterisk_start_devicestate_publishing().

asterisk_mwi_publication_handler

struct ast_sip_publish_handler asterisk_mwi_publication_handler

Initial value:

= {
    .event_name = "asterisk-mwi",
    .new_publication = asterisk_publication_new,
    .publication_state_change = asterisk_publication_mwi_state_change,
}

Definition at line 834 of file res_pjsip_publish_asterisk.c.

                                                                  {
    .event_name = "asterisk-mwi",
    .new_publication = asterisk_publication_new,
    .publication_state_change = asterisk_publication_mwi_state_change,
};

Referenced by load_module(), and unload_module().

asterisk_mwi_publisher_handler

struct ast_sip_event_publisher_handler asterisk_mwi_publisher_handler

Initial value:

= {
    .event_name = "asterisk-mwi",
    .start_publishing = asterisk_start_mwi_publishing,
    .stop_publishing = asterisk_stop_mwi_publishing,
}

Definition at line 495 of file res_pjsip_publish_asterisk.c.

                                                                        {
    .event_name = "asterisk-mwi",
    .start_publishing = asterisk_start_mwi_publishing,
    .stop_publishing = asterisk_stop_mwi_publishing,
};

Referenced by load_module(), and unload_module().

asterisk_mwi_publisher_state_datastore

const struct ast_datastore_info asterisk_mwi_publisher_state_datastore

static

Initial value:

= {
    .type = "asterisk-mwi-publisher",
    .destroy = asterisk_mwi_publisher_state_destroy,
}

Datastore for attaching devicestate publisher state information.

Definition at line 186 of file res_pjsip_publish_asterisk.c.

                                                                                {
    .type = "asterisk-mwi-publisher",
    .destroy = asterisk_mwi_publisher_state_destroy,
};

Referenced by asterisk_start_mwi_publishing().