stasis_system.h File Reference

#include "asterisk/stasis.h"

Include dependency graph for stasis_system.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions
struct stasis_message_type *	ast_cc_available_type (void)
	A stasis_message_type for CCSS Available messages. More...
struct stasis_message_type *	ast_cc_callerrecalling_type (void)
	A stasis_message_type for CCSS Caller Recalling messages. More...
struct stasis_message_type *	ast_cc_callerstartmonitoring_type (void)
	A stasis_message_type for CCSS Caller Start Monitoring messages. More...
struct stasis_message_type *	ast_cc_callerstopmonitoring_type (void)
	A stasis_message_type for CCSS Caller Stop Monitoring messages. More...
struct stasis_message_type *	ast_cc_failure_type (void)
	A stasis_message_type for CCSS Failure messages. More...
struct stasis_message_type *	ast_cc_monitorfailed_type (void)
	A stasis_message_type for CCSS Monitor Failed messages. More...
struct stasis_message_type *	ast_cc_offertimerstart_type (void)
	A stasis_message_type for CCSS Offer Timer Start messages. More...
struct stasis_message_type *	ast_cc_recallcomplete_type (void)
	A stasis_message_type for CCSS Recall Complete messages. More...
struct stasis_message_type *	ast_cc_requestacknowledged_type (void)
	A stasis_message_type for CCSS Request Acknowledged messages. More...
struct stasis_message_type *	ast_cc_requested_type (void)
	A stasis_message_type for CCSS Requested messages. More...
struct stasis_message_type *	ast_cluster_discovery_type (void)
	A stasis_message_type for Cluster discovery. More...
struct stasis_message_type *	ast_network_change_type (void)
	A stasis_message_type for network changes. More...
int	ast_stasis_system_init (void)
	Initialize the stasis system topic and message types. More...
void	ast_system_publish_registry (const char *channeltype, const char *username, const char *domain, const char *status, const char *cause)
	Publish a channel driver outgoing registration message. More...
struct stasis_message_type *	ast_system_registry_type (void)
	A stasis_message_type for outbound registration. More...
struct stasis_topic *	ast_system_topic (void)
	A Stasis Message Bus API topic which publishes messages regarding system changes. More...

Function Documentation

ast_cc_available_type()

struct stasis_message_type * ast_cc_available_type

(

void

)

A stasis_message_type for CCSS Available messages.

Since

12

Referenced by ast_stasis_system_init(), cc_publish_available(), and stasis_system_cleanup().

ast_cc_callerrecalling_type()

struct stasis_message_type * ast_cc_callerrecalling_type

(

void

)

A stasis_message_type for CCSS Caller Recalling messages.

Since

12

Referenced by ast_stasis_system_init(), cc_publish_callerrecalling(), and stasis_system_cleanup().

ast_cc_callerstartmonitoring_type()

struct stasis_message_type * ast_cc_callerstartmonitoring_type

(

void

)

A stasis_message_type for CCSS Caller Start Monitoring messages.

Since

12

Referenced by ast_stasis_system_init(), cc_publish_callerstartmonitoring(), and stasis_system_cleanup().

ast_cc_callerstopmonitoring_type()

struct stasis_message_type * ast_cc_callerstopmonitoring_type

(

void

)

A stasis_message_type for CCSS Caller Stop Monitoring messages.

Since

12

Referenced by ast_stasis_system_init(), cc_publish_callerstopmonitoring(), and stasis_system_cleanup().

ast_cc_failure_type()

struct stasis_message_type * ast_cc_failure_type

(

void

)

A stasis_message_type for CCSS Failure messages.

Since

12

Referenced by ast_stasis_system_init(), cc_publish_failure(), and stasis_system_cleanup().

ast_cc_monitorfailed_type()

struct stasis_message_type * ast_cc_monitorfailed_type

(

void

)

A stasis_message_type for CCSS Monitor Failed messages.

Since

12

Referenced by ast_stasis_system_init(), cc_publish_monitorfailed(), and stasis_system_cleanup().

ast_cc_offertimerstart_type()

struct stasis_message_type * ast_cc_offertimerstart_type

(

void

)

A stasis_message_type for CCSS Offer Timer Start messages.

Since

12

Referenced by ast_stasis_system_init(), cc_publish_offertimerstart(), and stasis_system_cleanup().

ast_cc_recallcomplete_type()

struct stasis_message_type * ast_cc_recallcomplete_type

(

void

)

A stasis_message_type for CCSS Recall Complete messages.

Since

12

Referenced by ast_stasis_system_init(), cc_publish_recallcomplete(), and stasis_system_cleanup().

ast_cc_requestacknowledged_type()

struct stasis_message_type * ast_cc_requestacknowledged_type

(

void

)

A stasis_message_type for CCSS Request Acknowledged messages.

Since

12

Referenced by ast_stasis_system_init(), cc_publish_requestacknowledged(), and stasis_system_cleanup().

ast_cc_requested_type()

struct stasis_message_type * ast_cc_requested_type

(

void

)

A stasis_message_type for CCSS Requested messages.

Since

12

Referenced by ast_stasis_system_init(), cc_publish_requested(), and stasis_system_cleanup().

ast_cluster_discovery_type()

struct stasis_message_type * ast_cluster_discovery_type

(

void

)

A stasis_message_type for Cluster discovery.

Since

13.11.0

Referenced by ast_stasis_system_init(), publish_cluster_discovery_to_stasis_full(), and stasis_system_cleanup().

ast_network_change_type()

struct stasis_message_type * ast_network_change_type

(

void

)

A stasis_message_type for network changes.

Since

12

Return values

NULL

on error

Returns

stasis_message_type for network changes

Note

Messages of this type should always be issued on and expected from the ast_system_topic Stasis Message Bus API topic

Referenced by ast_stasis_system_init(), load_module(), network_change_stasis_cb(), network_change_stasis_subscribe(), stasis_system_cleanup(), and stun_monitor_request().

ast_stasis_system_init()

int ast_stasis_system_init

(

void

)

Initialize the stasis system topic and message types.

Return values

0	on success
-1	on failure

Initialize the stasis system topic and message types.

Definition at line 376 of file stasis_system.c.

{
    ast_register_cleanup(stasis_system_cleanup);
 
    system_topic = stasis_topic_create("system:all");
    if (!system_topic) {
        return 1;
    }
 
    if (STASIS_MESSAGE_TYPE_INIT(ast_network_change_type) != 0) {
        return -1;
    }
 
    if (STASIS_MESSAGE_TYPE_INIT(ast_system_registry_type) != 0) {
        return -1;
    }
 
    if (STASIS_MESSAGE_TYPE_INIT(ast_cc_available_type) != 0) {
        return -1;
    }
 
    if (STASIS_MESSAGE_TYPE_INIT(ast_cc_offertimerstart_type) != 0) {
        return -1;
    }
 
    if (STASIS_MESSAGE_TYPE_INIT(ast_cc_requested_type) != 0) {
        return -1;
    }
 
    if (STASIS_MESSAGE_TYPE_INIT(ast_cc_requestacknowledged_type) != 0) {
        return -1;
    }
 
    if (STASIS_MESSAGE_TYPE_INIT(ast_cc_callerstopmonitoring_type) != 0) {
        return -1;
    }
 
    if (STASIS_MESSAGE_TYPE_INIT(ast_cc_callerstartmonitoring_type) != 0) {
        return -1;
    }
 
    if (STASIS_MESSAGE_TYPE_INIT(ast_cc_callerrecalling_type) != 0) {
        return -1;
    }
 
    if (STASIS_MESSAGE_TYPE_INIT(ast_cc_recallcomplete_type) != 0) {
        return -1;
    }
 
    if (STASIS_MESSAGE_TYPE_INIT(ast_cc_failure_type) != 0) {
        return -1;
    }
 
    if (STASIS_MESSAGE_TYPE_INIT(ast_cc_monitorfailed_type) != 0) {
        return -1;
    }
 
    if (STASIS_MESSAGE_TYPE_INIT(ast_cluster_discovery_type) != 0) {
        return -1;
    }
 
    return 0;
}

References ast_cc_available_type(), ast_cc_callerrecalling_type(), ast_cc_callerstartmonitoring_type(), ast_cc_callerstopmonitoring_type(), ast_cc_failure_type(), ast_cc_monitorfailed_type(), ast_cc_offertimerstart_type(), ast_cc_recallcomplete_type(), ast_cc_requestacknowledged_type(), ast_cc_requested_type(), ast_cluster_discovery_type(), ast_network_change_type(), ast_register_cleanup(), ast_system_registry_type(), STASIS_MESSAGE_TYPE_INIT, stasis_system_cleanup(), stasis_topic_create(), and system_topic.

Referenced by asterisk_daemon().

ast_system_publish_registry()

void ast_system_publish_registry	(	const char *	channeltype,
		const char *	username,
		const char *	domain,
		const char *	status,
		const char *	cause
	)

Publish a channel driver outgoing registration message.

Since

12

Parameters

channeltype	The channel driver that published the message
username	The username that was used to register
domain	The domain that was used to register
status	The result of the registration
cause	The reason for the result

Definition at line 121 of file stasis_system.c.

{
    struct ast_json *registry;
    struct ast_json_payload *payload;
    struct stasis_message *message;
 
    if (!ast_system_registry_type()) {
        return;
    }
 
    registry = ast_json_pack("{s: s, s: s, s: s, s: s, s: s, s: s}",
        "type", "registry",
        "channeltype", channeltype,
        "username", username,
        "domain", domain,
        "status", status,
        "cause", S_OR(cause, ""));
 
    payload = ast_json_payload_create(registry);
    ast_json_unref(registry);
    if (!payload) {
        return;
    }
 
    message = stasis_message_create(ast_system_registry_type(), payload);
    ao2_ref(payload, -1);
    if (!message) {
        return;
    }
 
    stasis_publish(ast_system_topic(), message);
    ao2_ref(message, -1);
}

References ao2_ref, ast_json_pack(), ast_json_payload_create(), ast_json_unref(), ast_system_registry_type(), ast_system_topic(), S_OR, stasis_message_create(), stasis_publish(), and status.

Referenced by handle_registration_response(), and iax2_publish_registry().

ast_system_registry_type()

struct stasis_message_type * ast_system_registry_type

(

void

)

A stasis_message_type for outbound registration.

Since

12

Referenced by ast_stasis_system_init(), ast_system_publish_registry(), pjsip_outbound_registration_metrics_init(), and stasis_system_cleanup().

ast_system_topic()

struct stasis_topic * ast_system_topic

(

void

)

A Stasis Message Bus API topic which publishes messages regarding system changes.

Since

12

Returns

stasis_topic for system level changes

Return values

NULL

on error

Definition at line 350 of file stasis_system.c.

{
    return system_topic;
}

References system_topic.

Referenced by ast_system_publish_registry(), cc_publish(), load_module(), manager_system_init(), network_change_stasis_subscribe(), pjsip_outbound_registration_metrics_init(), publish_cluster_discovery_to_stasis_full(), publish_format_update(), and stun_monitor_request().