|
| AST_MODULE_INFO_STANDARD_EXTENDED (ASTERISK_GPL_KEY,"Corosync") |
|
static void | cfg_shutdown_cb (corosync_cfg_handle_t cfg_handle, corosync_cfg_shutdown_flags_t flags) |
|
static void | cleanup_module (void) |
|
static int | clear_node_cache (void *obj, void *arg, int flags) |
|
static struct corosync_node * | corosync_node_alloc (struct ast_event *event) |
|
static int | corosync_node_cmp_fn (void *obj, void *arg, int flags) |
|
static int | corosync_node_hash_fn (const void *obj, const int flags) |
|
static char * | corosync_ping (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a) |
|
static void | corosync_ping_payload_dtor (void *obj) |
| Destructor for the corosync_ping_payload wrapper object.
|
|
static struct ast_event * | corosync_ping_to_event (struct stasis_message *message) |
| Convert a Corosync PING to a ast_event.
|
|
static char * | corosync_show_config (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a) |
|
static char * | corosync_show_members (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a) |
|
static struct stasis_topic * | corosync_topic (void) |
| Internal accessor for our topic.
|
|
static void | cpg_confchg_cb (cpg_handle_t handle, const struct cpg_name *group_name, const struct cpg_address *member_list, size_t member_list_entries, const struct cpg_address *left_list, size_t left_list_entries, const struct cpg_address *joined_list, size_t joined_list_entries) |
|
static void | cpg_deliver_cb (cpg_handle_t handle, const struct cpg_name *group_name, uint32_t nodeid, uint32_t pid, void *msg, size_t msg_len) |
|
static void * | dispatch_thread_handler (void *data) |
|
static int | dump_cache_cb (void *obj, void *arg, int flags) |
|
static int | load_config (unsigned int reload) |
|
static int | load_general_config (struct ast_config *cfg) |
|
static int | load_module (void) |
|
static void | publish_cluster_discovery_to_stasis (struct ast_event *event) |
| Publish a received cluster discovery ast_event to Stasis Message Bus API.
|
|
static void | publish_cluster_discovery_to_stasis_full (struct corosync_node *node, int joined) |
| Publish cluster discovery to Stasis Message Bus API.
|
|
static void | publish_corosync_ping_to_stasis (struct ast_event *event) |
| Publish a Corosync ping to Stasis Message Bus API.
|
|
static void | publish_device_state_to_stasis (struct ast_event *event) |
| Publish a received device state ast_event to Stasis Message Bus API.
|
|
static void | publish_event_to_corosync (struct ast_event *event) |
|
static void | publish_mwi_to_stasis (struct ast_event *event) |
| Publish a received MWI ast_event to Stasis Message Bus API.
|
|
static void | publish_to_corosync (struct stasis_message *message) |
|
static void | send_cluster_notify (void) |
| Informs the cluster of our EID and our IP addresses.
|
|
static int | set_event (const char *event_type, int pubsub) |
|
static void | stasis_message_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message) |
|
| STASIS_MESSAGE_TYPE_DEFN_LOCAL (corosync_ping_message_type,.to_event=corosync_ping_to_event,) |
|
static int | unload_module (void) |
|
module publishes ast_event representations of information to other Asterisk instances in a cluster.
- Security event represent their event types and data using this system.
- Theoretically, any Stasis Message Bus API message can use this system to pass information around in a binary format.
Events have an associated event type, as well as information elements. The information elements are the meta data that go along with each event. For example, in the case of message waiting indication, the event type is MWI, and each MWI event contains at least three information elements: the mailbox, the number of new messages, and the number of old messages.
- Author
- Russell Bryant russe.nosp@m.ll@r.nosp@m.ussel.nosp@m.lbry.nosp@m.ant.n.nosp@m.et
This module is based on and replaces the previous res_ais module.
Definition in file res_corosync.c.