#include "asterisk.h"#include <corosync/cpg.h>#include <corosync/cfg.h>#include "asterisk/module.h"#include "asterisk/logger.h"#include "asterisk/poll-compat.h"#include "asterisk/config.h"#include "asterisk/event.h"#include "asterisk/cli.h"#include "asterisk/devicestate.h"
Go to the source code of this file.
Enumerations | |
| enum | { PUBLISH, SUBSCRIBE } |
Functions | |
| static void | __reg_module (void) |
| static void | __unreg_module (void) |
| static void | ast_event_cb (const struct ast_event *event, void *data) |
| ASTERISK_FILE_VERSION (__FILE__,"$Revision: 370535 $") | |
| static void | cfg_shutdown_cb (corosync_cfg_handle_t cfg_handle, corosync_cfg_shutdown_flags_t flags) |
| static void | cleanup_module (void) |
| static char * | corosync_ping (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a) |
| 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 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 | load_config (unsigned int reload) |
| static int | load_general_config (struct ast_config *cfg) |
| static int | load_module (void) |
| static int | set_event (const char *event_type, int pubsub) |
| static int | unload_module (void) |
Variables | |
| static struct ast_module_info | __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "Corosync" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = AST_BUILDOPT_SUM, .load = load_module, .unload = unload_module, .load_pri = AST_MODPRI_DEFAULT, } |
| static struct ast_module_info * | ast_module_info = &__mod_info |
| static corosync_cfg_callbacks_t | cfg_callbacks |
| static corosync_cfg_handle_t | cfg_handle |
| static struct ast_cli_entry | corosync_cli [] |
| static cpg_callbacks_t | cpg_callbacks |
| static cpg_handle_t | cpg_handle |
| struct { | |
| int alert_pipe [2] | |
| pthread_t id | |
| unsigned int stop:1 | |
| } | dispatch_thread |
| struct { | |
| const char * name | |
| unsigned char publish | |
| unsigned char publish_default | |
| struct ast_event_sub * sub | |
| unsigned char subscribe | |
| unsigned char subscribe_default | |
| } | event_types [] |
| static ast_rwlock_t | event_types_lock = { PTHREAD_RWLOCK_INITIALIZER , NULL, 1 } |
Detailed Description
This module is based on and replaces the previous res_ais module.
Definition in file res_corosync.c.
Enumeration Type Documentation
| anonymous enum |
Definition at line 480 of file res_corosync.c.
Function Documentation
| static void __reg_module | ( | void | ) | [static] |
Definition at line 682 of file res_corosync.c.
| static void __unreg_module | ( | void | ) | [static] |
Definition at line 682 of file res_corosync.c.
| static void ast_event_cb | ( | const struct ast_event * | event, |
| void * | data | ||
| ) | [static] |
Definition at line 289 of file res_corosync.c.
References ast_eid_cmp(), ast_eid_default, ast_eid_to_str(), ast_event_get_ie_raw(), ast_event_get_size(), ast_event_get_type(), AST_EVENT_IE_EID, AST_EVENT_PING, ast_log(), cpg_handle, ast_eid::eid, LOG_NOTICE, and LOG_WARNING.
Referenced by cpg_confchg_cb(), and load_general_config().
{
cs_error_t cs_err;
struct iovec iov = {
.iov_base = (void *) event,
.iov_len = ast_event_get_size(event),
};
if (ast_event_get_type(event) == AST_EVENT_PING) {
const struct ast_eid *eid;
char buf[128] = "";
eid = ast_event_get_ie_raw(event, AST_EVENT_IE_EID);
ast_eid_to_str(buf, sizeof(buf), (struct ast_eid *) eid);
ast_log(LOG_NOTICE, "(ast_event_cb) Got event PING from server with EID: '%s'\n", buf);
}
if (ast_eid_cmp(&ast_eid_default,
ast_event_get_ie_raw(event, AST_EVENT_IE_EID))) {
/* If the event didn't originate from this server, don't send it back out. */
return;
}
/* The ast_event subscription will only exist if we are configured to publish
* these events, so just send away. */
if ((cs_err = cpg_mcast_joined(cpg_handle, CPG_TYPE_FIFO, &iov, 1)) != CS_OK) {
ast_log(LOG_WARNING, "CPG mcast failed (%d)\n", cs_err);
}
}
| ASTERISK_FILE_VERSION | ( | __FILE__ | , |
| "$Revision: 370535 $" | |||
| ) |
| static void cfg_shutdown_cb | ( | corosync_cfg_handle_t | cfg_handle, |
| corosync_cfg_shutdown_flags_t | flags | ||
| ) | [static] |
Definition at line 113 of file res_corosync.c.
{
}
| static void cleanup_module | ( | void | ) | [static] |
Definition at line 574 of file res_corosync.c.
References ARRAY_LEN, ast_carefulwrite(), ast_event_unsubscribe(), ast_log(), AST_PTHREADT_NULL, cfg_handle, cpg_handle, dispatch_thread, errno, event_types, LOG_ERROR, and sub.
Referenced by load_module(), and unload_module().
{
cs_error_t cs_err;
unsigned int i;
for (i = 0; i < ARRAY_LEN(event_types); i++) {
if (event_types[i].sub) {
event_types[i].sub = ast_event_unsubscribe(event_types[i].sub);
}
event_types[i].publish = 0;
event_types[i].subscribe = 0;
}
if (dispatch_thread.id != AST_PTHREADT_NULL) {
char meepmeep = 'x';
dispatch_thread.stop = 1;
if (ast_carefulwrite(dispatch_thread.alert_pipe[1], &meepmeep, 1,
5000) == -1) {
ast_log(LOG_ERROR, "Failed to write to pipe: %s (%d)\n",
strerror(errno), errno);
}
pthread_join(dispatch_thread.id, NULL);
}
if (dispatch_thread.alert_pipe[0] != -1) {
close(dispatch_thread.alert_pipe[0]);
dispatch_thread.alert_pipe[0] = -1;
}
if (dispatch_thread.alert_pipe[1] != -1) {
close(dispatch_thread.alert_pipe[1]);
dispatch_thread.alert_pipe[1] = -1;
}
if (cpg_handle && (cs_err = cpg_finalize(cpg_handle)) != CS_OK) {
ast_log(LOG_ERROR, "Failed to finalize cpg (%d)\n", (int) cs_err);
}
cpg_handle = 0;
if (cfg_handle && (cs_err = corosync_cfg_finalize(cfg_handle)) != CS_OK) {
ast_log(LOG_ERROR, "Failed to finalize cfg (%d)\n", (int) cs_err);
}
cfg_handle = 0;
}
| static char* corosync_ping | ( | struct ast_cli_entry * | e, |
| int | cmd, | ||
| struct ast_cli_args * | a | ||
| ) | [static] |
Definition at line 394 of file res_corosync.c.
References ast_cli_args::argc, ast_cli_entry::args, AST_EVENT_IE_END, ast_event_new(), AST_EVENT_PING, ast_event_queue(), CLI_FAILURE, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, and ast_cli_entry::usage.
{
struct ast_event *event;
switch (cmd) {
case CLI_INIT:
e->command = "corosync ping";
e->usage =
"Usage: corosync ping\n"
" Send a test ping to the cluster.\n"
"A NOTICE will be in the log for every ping received\n"
"on a server.\n If you send a ping, you should see a NOTICE\n"
"in the log for every server in the cluster.\n";
return NULL;
case CLI_GENERATE:
return NULL; /* no completion */
}
if (a->argc != e->args) {
return CLI_SHOWUSAGE;
}
event = ast_event_new(AST_EVENT_PING, AST_EVENT_IE_END);
if (!event) {
return CLI_FAILURE;
}
ast_event_queue(event);
return CLI_SUCCESS;
}
| static char* corosync_show_config | ( | struct ast_cli_entry * | e, |
| int | cmd, | ||
| struct ast_cli_args * | a | ||
| ) | [static] |
Definition at line 428 of file res_corosync.c.
References ast_cli_args::argc, ast_cli_entry::args, ARRAY_LEN, ast_cli(), ast_rwlock_rdlock, ast_rwlock_unlock, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, event_types, event_types_lock, ast_cli_args::fd, publish, subscribe, and ast_cli_entry::usage.
{
unsigned int i;
switch (cmd) {
case CLI_INIT:
e->command = "corosync show config";
e->usage =
"Usage: corosync show config\n"
" Show configuration loaded from res_corosync.conf\n";
return NULL;
case CLI_GENERATE:
return NULL; /* no completion */
}
if (a->argc != e->args) {
return CLI_SHOWUSAGE;
}
ast_cli(a->fd, "\n"
"=============================================================\n"
"=== res_corosync config =====================================\n"
"=============================================================\n"
"===\n");
ast_rwlock_rdlock(&event_types_lock);
for (i = 0; i < ARRAY_LEN(event_types); i++) {
if (event_types[i].publish) {
ast_cli(a->fd, "=== ==> Publishing Event Type: %s\n",
event_types[i].name);
}
if (event_types[i].subscribe) {
ast_cli(a->fd, "=== ==> Subscribing to Event Type: %s\n",
event_types[i].name);
}
}
ast_rwlock_unlock(&event_types_lock);
ast_cli(a->fd, "===\n"
"=============================================================\n"
"\n");
return CLI_SUCCESS;
}
| static char* corosync_show_members | ( | struct ast_cli_entry * | e, |
| int | cmd, | ||
| struct ast_cli_args * | a | ||
| ) | [static] |
Definition at line 320 of file res_corosync.c.
References ast_cli_args::argc, ast_cli_entry::args, ARRAY_LEN, ast_cli(), ast_log(), cfg_handle, CLI_FAILURE, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, cpg_handle, ast_cli_args::fd, LOG_WARNING, and ast_cli_entry::usage.
{
cs_error_t cs_err;
cpg_iteration_handle_t cpg_iter;
struct cpg_iteration_description_t cpg_desc;
unsigned int i;
switch (cmd) {
case CLI_INIT:
e->command = "corosync show members";
e->usage =
"Usage: corosync show members\n"
" Show corosync cluster members\n";
return NULL;
case CLI_GENERATE:
return NULL; /* no completion */
}
if (a->argc != e->args) {
return CLI_SHOWUSAGE;
}
cs_err = cpg_iteration_initialize(cpg_handle, CPG_ITERATION_ALL, NULL, &cpg_iter);
if (cs_err != CS_OK) {
ast_cli(a->fd, "Failed to initialize CPG iterator.\n");
return CLI_FAILURE;
}
ast_cli(a->fd, "\n"
"=============================================================\n"
"=== Cluster members =========================================\n"
"=============================================================\n"
"===\n");
for (i = 1, cs_err = cpg_iteration_next(cpg_iter, &cpg_desc);
cs_err == CS_OK;
cs_err = cpg_iteration_next(cpg_iter, &cpg_desc), i++) {
corosync_cfg_node_address_t addrs[8];
int num_addrs = 0;
unsigned int j;
cs_err = corosync_cfg_get_node_addrs(cfg_handle, cpg_desc.nodeid,
ARRAY_LEN(addrs), &num_addrs, addrs);
if (cs_err != CS_OK) {
ast_log(LOG_WARNING, "Failed to get node addresses\n");
continue;
}
ast_cli(a->fd, "=== Node %d\n", i);
ast_cli(a->fd, "=== --> Group: %s\n", cpg_desc.group.value);
for (j = 0; j < num_addrs; j++) {
struct sockaddr *sa = (struct sockaddr *) addrs[j].address;
size_t sa_len = (size_t) addrs[j].address_length;
char buf[128];
getnameinfo(sa, sa_len, buf, sizeof(buf), NULL, 0, NI_NUMERICHOST);
ast_cli(a->fd, "=== --> Address %d: %s\n", j + 1, buf);
}
}
ast_cli(a->fd, "===\n"
"=============================================================\n"
"\n");
cpg_iteration_finalize(cpg_iter);
return CLI_SUCCESS;
}
| 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] |
Definition at line 163 of file res_corosync.c.
References ARRAY_LEN, ast_eid_default, ast_event_cb(), ast_event_dump_cache(), AST_EVENT_IE_EID, ast_event_sub_append_ie_raw(), ast_event_sub_destroy(), ast_event_subscribe_new(), ast_rwlock_rdlock, ast_rwlock_unlock, event_sub, event_types, event_types_lock, and publish.
{
unsigned int i;
/* If any new nodes have joined, dump our cache of events we are publishing
* that originated from this server. */
if (!joined_list_entries) {
return;
}
for (i = 0; i < ARRAY_LEN(event_types); i++) {
struct ast_event_sub *event_sub;
ast_rwlock_rdlock(&event_types_lock);
if (!event_types[i].publish) {
ast_rwlock_unlock(&event_types_lock);
continue;
}
ast_rwlock_unlock(&event_types_lock);
event_sub = ast_event_subscribe_new(i, ast_event_cb, NULL);
ast_event_sub_append_ie_raw(event_sub, AST_EVENT_IE_EID,
&ast_eid_default, sizeof(ast_eid_default));
ast_event_dump_cache(event_sub);
ast_event_sub_destroy(event_sub);
}
}
| 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] |
Definition at line 118 of file res_corosync.c.
References ast_debug, ast_eid_cmp(), ast_eid_default, ast_eid_to_str(), ast_event_get_ie_raw(), ast_event_get_type(), AST_EVENT_IE_EID, ast_event_minimum_length(), AST_EVENT_PING, ast_event_queue(), ast_event_queue_and_cache(), ast_log(), ast_malloc, ast_rwlock_rdlock, ast_rwlock_unlock, ast_eid::eid, event_types, event_types_lock, LOG_NOTICE, and subscribe.
{
struct ast_event *event;
if (msg_len < ast_event_minimum_length()) {
ast_debug(1, "Ignoring event that's too small. %u < %u\n",
(unsigned int) msg_len,
(unsigned int) ast_event_minimum_length());
return;
}
if (!ast_eid_cmp(&ast_eid_default, ast_event_get_ie_raw(msg, AST_EVENT_IE_EID))) {
/* Don't feed events back in that originated locally. */
return;
}
ast_rwlock_rdlock(&event_types_lock);
if (!event_types[ast_event_get_type(msg)].subscribe) {
/* We are not configured to subscribe to these events. */
ast_rwlock_unlock(&event_types_lock);
return;
}
ast_rwlock_unlock(&event_types_lock);
if (!(event = ast_malloc(msg_len))) {
return;
}
memcpy(event, msg, msg_len);
if (ast_event_get_type(event) == AST_EVENT_PING) {
const struct ast_eid *eid;
char buf[128] = "";
eid = ast_event_get_ie_raw(event, AST_EVENT_IE_EID);
ast_eid_to_str(buf, sizeof(buf), (struct ast_eid *) eid);
ast_log(LOG_NOTICE, "(cpg_deliver_cb) Got event PING from server with EID: '%s'\n", buf);
ast_event_queue(event);
} else {
ast_event_queue_and_cache(event);
}
}
| static void* dispatch_thread_handler | ( | void * | data | ) | [static] |
Definition at line 195 of file res_corosync.c.
References ARRAY_LEN, ast_copy_string(), ast_log(), ast_poll, cfg_callbacks, cfg_handle, cpg_callbacks, cpg_handle, dispatch_thread, errno, LOG_ERROR, LOG_NOTICE, and LOG_WARNING.
Referenced by load_module().
{
cs_error_t cs_err;
struct pollfd pfd[3] = {
{ .events = POLLIN, },
{ .events = POLLIN, },
{ .events = POLLIN, },
};
if ((cs_err = cpg_fd_get(cpg_handle, &pfd[0].fd)) != CS_OK) {
ast_log(LOG_ERROR, "Failed to get CPG fd. This module is now broken.\n");
return NULL;
}
if ((cs_err = corosync_cfg_fd_get(cfg_handle, &pfd[1].fd)) != CS_OK) {
ast_log(LOG_ERROR, "Failed to get CFG fd. This module is now broken.\n");
return NULL;
}
pfd[2].fd = dispatch_thread.alert_pipe[0];
while (!dispatch_thread.stop) {
int res;
cs_err = CS_OK;
pfd[0].revents = 0;
pfd[1].revents = 0;
pfd[2].revents = 0;
res = ast_poll(pfd, ARRAY_LEN(pfd), -1);
if (res == -1 && errno != EINTR && errno != EAGAIN) {
ast_log(LOG_ERROR, "poll() error: %s (%d)\n", strerror(errno), errno);
continue;
}
if (pfd[0].revents & POLLIN) {
if ((cs_err = cpg_dispatch(cpg_handle, CS_DISPATCH_ALL)) != CS_OK) {
ast_log(LOG_WARNING, "Failed CPG dispatch: %d\n", cs_err);
}
}
if (pfd[1].revents & POLLIN) {
if ((cs_err = corosync_cfg_dispatch(cfg_handle, CS_DISPATCH_ALL)) != CS_OK) {
ast_log(LOG_WARNING, "Failed CFG dispatch: %d\n", cs_err);
}
}
if (cs_err == CS_ERR_LIBRARY || cs_err == CS_ERR_BAD_HANDLE) {
struct cpg_name name;
/* If corosync gets restarted out from under Asterisk, try to recover. */
ast_log(LOG_NOTICE, "Attempting to recover from corosync failure.\n");
if ((cs_err = corosync_cfg_initialize(&cfg_handle, &cfg_callbacks)) != CS_OK) {
ast_log(LOG_ERROR, "Failed to initialize cfg (%d)\n", (int) cs_err);
sleep(5);
continue;
}
if ((cs_err = cpg_initialize(&cpg_handle, &cpg_callbacks) != CS_OK)) {
ast_log(LOG_ERROR, "Failed to initialize cpg (%d)\n", (int) cs_err);
sleep(5);
continue;
}
if ((cs_err = cpg_fd_get(cpg_handle, &pfd[0].fd)) != CS_OK) {
ast_log(LOG_ERROR, "Failed to get CPG fd.\n");
sleep(5);
continue;
}
if ((cs_err = corosync_cfg_fd_get(cfg_handle, &pfd[1].fd)) != CS_OK) {
ast_log(LOG_ERROR, "Failed to get CFG fd.\n");
sleep(5);
continue;
}
ast_copy_string(name.value, "asterisk", sizeof(name.value));
name.length = strlen(name.value);
if ((cs_err = cpg_join(cpg_handle, &name)) != CS_OK) {
ast_log(LOG_ERROR, "Failed to join cpg (%d)\n", (int) cs_err);
sleep(5);
continue;
}
ast_log(LOG_NOTICE, "Corosync recovery complete.\n");
}
}
return NULL;
}
| static int load_config | ( | unsigned int | reload | ) | [static] |
Definition at line 547 of file res_corosync.c.
References ast_category_browse(), ast_config_destroy(), ast_config_load, ast_log(), CONFIG_STATUS_FILEINVALID, CONFIG_STATUS_FILEMISSING, load_general_config(), and LOG_WARNING.
Referenced by load_module().
{
static const char filename[] = "res_corosync.conf";
struct ast_config *cfg;
const char *cat = NULL;
struct ast_flags config_flags = { 0 };
int res = 0;
cfg = ast_config_load(filename, config_flags);
if (cfg == CONFIG_STATUS_FILEMISSING || cfg == CONFIG_STATUS_FILEINVALID) {
return -1;
}
while ((cat = ast_category_browse(cfg, cat))) {
if (!strcasecmp(cat, "general")) {
res = load_general_config(cfg);
} else {
ast_log(LOG_WARNING, "Unknown configuration section '%s'\n", cat);
}
}
ast_config_destroy(cfg);
return res;
}
| static int load_general_config | ( | struct ast_config * | cfg | ) | [static] |
Definition at line 509 of file res_corosync.c.
References ARRAY_LEN, ast_event_cb(), AST_EVENT_IE_END, ast_event_subscribe(), ast_event_unsubscribe(), ast_log(), ast_rwlock_unlock, ast_rwlock_wrlock, ast_variable_browse(), event_types, event_types_lock, LOG_WARNING, ast_variable::name, ast_variable::next, publish, PUBLISH, set_event(), sub, SUBSCRIBE, and ast_variable::value.
Referenced by load_config().
{
struct ast_variable *v;
int res = 0;
unsigned int i;
ast_rwlock_wrlock(&event_types_lock);
for (i = 0; i < ARRAY_LEN(event_types); i++) {
event_types[i].publish = event_types[i].publish_default;
event_types[i].subscribe = event_types[i].subscribe_default;
}
for (v = ast_variable_browse(cfg, "general"); v && !res; v = v->next) {
if (!strcasecmp(v->name, "publish_event")) {
res = set_event(v->value, PUBLISH);
} else if (!strcasecmp(v->name, "subscribe_event")) {
res = set_event(v->value, SUBSCRIBE);
} else {
ast_log(LOG_WARNING, "Unknown option '%s'\n", v->name);
}
}
for (i = 0; i < ARRAY_LEN(event_types); i++) {
if (event_types[i].publish && !event_types[i].sub) {
event_types[i].sub = ast_event_subscribe(i,
ast_event_cb, "Corosync", NULL,
AST_EVENT_IE_END);
} else if (!event_types[i].publish && event_types[i].sub) {
event_types[i].sub = ast_event_unsubscribe(event_types[i].sub);
}
}
ast_rwlock_unlock(&event_types_lock);
return res;
}
| static int load_module | ( | void | ) | [static] |
Definition at line 619 of file res_corosync.c.
References ARRAY_LEN, ast_cli_register_multiple(), ast_copy_string(), ast_enable_distributed_devstate(), ast_log(), AST_MODULE_LOAD_DECLINE, AST_MODULE_LOAD_FAILURE, AST_MODULE_LOAD_SUCCESS, ast_pthread_create_background, cfg_callbacks, cfg_handle, cleanup_module(), cpg_callbacks, cpg_handle, dispatch_thread, dispatch_thread_handler(), errno, load_config(), and LOG_ERROR.
{
cs_error_t cs_err;
enum ast_module_load_result res = AST_MODULE_LOAD_FAILURE;
struct cpg_name name;
if ((cs_err = corosync_cfg_initialize(&cfg_handle, &cfg_callbacks)) != CS_OK) {
ast_log(LOG_ERROR, "Failed to initialize cfg (%d)\n", (int) cs_err);
return AST_MODULE_LOAD_DECLINE;
}
if ((cs_err = cpg_initialize(&cpg_handle, &cpg_callbacks)) != CS_OK) {
ast_log(LOG_ERROR, "Failed to initialize cpg (%d)\n", (int) cs_err);
goto failed;
}
ast_copy_string(name.value, "asterisk", sizeof(name.value));
name.length = strlen(name.value);
if ((cs_err = cpg_join(cpg_handle, &name)) != CS_OK) {
ast_log(LOG_ERROR, "Failed to join (%d)\n", (int) cs_err);
goto failed;
}
if (pipe(dispatch_thread.alert_pipe) == -1) {
ast_log(LOG_ERROR, "Failed to create alert pipe: %s (%d)\n",
strerror(errno), errno);
goto failed;
}
if (ast_pthread_create_background(&dispatch_thread.id, NULL,
dispatch_thread_handler, NULL)) {
ast_log(LOG_ERROR, "Error starting CPG dispatch thread.\n");
goto failed;
}
if (load_config(0)) {
/* simply not configured is not a fatal error */
res = AST_MODULE_LOAD_DECLINE;
goto failed;
}
ast_cli_register_multiple(corosync_cli, ARRAY_LEN(corosync_cli));
ast_enable_distributed_devstate();
return AST_MODULE_LOAD_SUCCESS;
failed:
cleanup_module();
return res;
}
| static int set_event | ( | const char * | event_type, |
| int | pubsub | ||
| ) | [static] |
Definition at line 485 of file res_corosync.c.
References ARRAY_LEN, event_types, name, PUBLISH, and SUBSCRIBE.
Referenced by load_general_config().
{
unsigned int i;
for (i = 0; i < ARRAY_LEN(event_types); i++) {
if (!event_types[i].name || strcasecmp(event_type, event_types[i].name)) {
continue;
}
switch (pubsub) {
case PUBLISH:
event_types[i].publish = 1;
break;
case SUBSCRIBE:
event_types[i].subscribe = 1;
break;
}
break;
}
return (i == ARRAY_LEN(event_types)) ? -1 : 0;
}
| static int unload_module | ( | void | ) | [static] |
Definition at line 673 of file res_corosync.c.
References ARRAY_LEN, ast_cli_unregister_multiple(), and cleanup_module().
{
ast_cli_unregister_multiple(corosync_cli, ARRAY_LEN(corosync_cli));
cleanup_module();
return 0;
}
Variable Documentation
struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "Corosync" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = AST_BUILDOPT_SUM, .load = load_module, .unload = unload_module, .load_pri = AST_MODPRI_DEFAULT, } [static] |
Definition at line 682 of file res_corosync.c.
| int alert_pipe[2] |
Definition at line 64 of file res_corosync.c.
struct ast_module_info* ast_module_info = &__mod_info [static] |
Definition at line 682 of file res_corosync.c.
corosync_cfg_callbacks_t cfg_callbacks [static] |
Definition at line 83 of file res_corosync.c.
Referenced by dispatch_thread_handler(), and load_module().
corosync_cfg_handle_t cfg_handle [static] |
Definition at line 72 of file res_corosync.c.
Referenced by cleanup_module(), corosync_show_members(), dispatch_thread_handler(), and load_module().
struct ast_cli_entry corosync_cli[] [static] |
{
AST_CLI_DEFINE(corosync_show_config, "Show configuration"),
AST_CLI_DEFINE(corosync_show_members, "Show cluster members"),
AST_CLI_DEFINE(corosync_ping, "Send a test ping to the cluster"),
}
Definition at line 474 of file res_corosync.c.
cpg_callbacks_t cpg_callbacks [static] |
{
.cpg_deliver_fn = cpg_deliver_cb,
.cpg_confchg_fn = cpg_confchg_cb,
}
Definition at line 98 of file res_corosync.c.
Referenced by dispatch_thread_handler(), and load_module().
cpg_handle_t cpg_handle [static] |
Definition at line 71 of file res_corosync.c.
Referenced by ast_event_cb(), cleanup_module(), corosync_show_members(), dispatch_thread_handler(), and load_module().
struct { ... } dispatch_thread [static] |
Referenced by cleanup_module(), dispatch_thread_handler(), and load_module().
struct { ... } event_types[] [static] |
ast_rwlock_t event_types_lock = { PTHREAD_RWLOCK_INITIALIZER , NULL, 1 } [static] |
Definition at line 47 of file res_corosync.c.
Referenced by corosync_show_config(), cpg_confchg_cb(), cpg_deliver_cb(), and load_general_config().
| pthread_t id |
Definition at line 63 of file res_corosync.c.
| const char* name |
Definition at line 50 of file res_corosync.c.
| unsigned char publish |
Definition at line 52 of file res_corosync.c.
Referenced by aji_build_publish_skeleton(), corosync_show_config(), cpg_confchg_cb(), load_general_config(), and xmpp_pubsub_build_publish_skeleton().
| unsigned char publish_default |
Definition at line 53 of file res_corosync.c.
| unsigned int stop |
Definition at line 65 of file res_corosync.c.
| struct ast_event_sub* sub |
Definition at line 51 of file res_corosync.c.
Referenced by _skinny_show_lines(), acf_channel_read(), activatesub(), analog_new_ast_channel(), analog_set_inthreeway(), ast_channel_connected_line_sub(), ast_channel_redirecting_sub(), ast_event_check_subscriber(), ast_event_report_subs(), ast_event_subscribe(), ast_event_subscribe_new(), build_gateway(), channel_to_session(), cleanup_module(), close_call(), close_client(), config_device(), destroy_endpoint(), discard_call(), event_shutdown(), find_rtp_port(), find_subchannel_and_lock(), find_subchannel_by_instance_reference(), find_subchannel_by_name(), find_subchannel_by_reference(), get_devicestate(), get_sub(), handle_call_incoming(), handle_call_outgoing(), handle_cli_status(), handle_enbloc_call_message(), handle_event(), handle_key_fav(), handle_keypad_button_message(), handle_offhook_message(), handle_onhook_message(), handle_open_receive_channel_ack_message(), handle_request(), handle_soft_key_event_message(), handle_stimulus_message(), handle_transfer_button(), key_call(), key_dial_page(), load_general_config(), mgcp_alloc_pktcgate(), mgcp_answer(), mgcp_call(), mgcp_fixup(), mgcp_get_codec(), mgcp_get_rtp_peer(), mgcp_hangup(), mgcp_indicate(), mgcp_pktcgate_open(), mgcp_pktcgate_remove(), mgcp_postrequest(), mgcp_prune_realtime_gateway(), mgcp_read(), mgcp_request(), mgcp_senddigit_begin(), mgcp_senddigit_end(), mgcp_set_rtp_peer(), mgcp_ss(), mgcp_write(), mgcpsock_read(), onevent(), rcv_mac_addr(), reload_config(), setsubstate(), skinny_answer(), skinny_autoanswer_cb(), skinny_call(), skinny_dialer_cb(), skinny_fixup(), skinny_get_rtp_peer(), skinny_get_vrtp_peer(), skinny_hangup(), skinny_indicate(), skinny_new(), skinny_newcall(), skinny_read(), skinny_request(), skinny_senddigit_end(), skinny_set_rtp_peer(), skinny_transfer(), skinny_write(), subscript(), transfer_call_step1(), transfer_cancel_step2(), unistim_alloc_sub(), unistim_answer(), unistim_call(), unistim_do_senddigit(), unistim_get_rtp_peer(), unistim_hangup(), unistim_indicate(), unistim_read(), unistim_request(), unistim_senddigit_end(), unistim_set_rtp_peer(), unistim_show_info(), unistim_sp(), unistim_ss(), unistim_write(), and unload_module().
| unsigned char subscribe |
Definition at line 54 of file res_corosync.c.
Referenced by aji_pubsub_subscribe(), corosync_show_config(), cpg_deliver_cb(), and xmpp_pubsub_subscribe().
| unsigned char subscribe_default |
Definition at line 55 of file res_corosync.c.
