corosync
2.3.4
|
#include <corosync/corotypes.h>
#include <corosync/hdb.h>
#include <qb/qbloop.h>
#include <corosync/totem/totempg.h>
#include <corosync/icmap.h>
#include <corosync/coroapi.h>
Go to the source code of this file.
Macros | |
#define | TRUE 1 |
#define | FALSE 0 |
Functions | |
int | main_mcast (const struct iovec *iovec, unsigned int iov_len, unsigned int guarantee) |
void | message_source_set (mar_message_source_t *source, void *conn) |
int | message_source_is_local (const mar_message_source_t *source) |
void | corosync_shutdown_request (void) |
void | corosync_state_dump (void) |
qb_loop_t * | cs_poll_handle_get (void) |
int | cs_poll_dispatch_add (qb_loop_t *handle, int fd, int events, void *data, int(*dispatch_fn)(int fd, int revents, void *data)) |
int | cs_poll_dispatch_delete (qb_loop_t *handle, int fd) |
int | corosync_sending_allowed (unsigned int service, unsigned int id, const void *msg, void *sending_allowed_private_data) |
void | corosync_sending_allowed_release (void *sending_allowed_private_data) |
void | corosync_recheck_the_q_level (void *data) |
void | cs_ipcs_init (void) |
const char * | cs_ipcs_service_init (struct corosync_service_engine *service) |
void | cs_ipcs_stats_update (void) |
int32_t | cs_ipcs_service_destroy (int32_t service_id) |
int32_t | cs_ipcs_q_level_get (void) |
int | cs_ipcs_dispatch_send (void *conn, const void *msg, size_t mlen) |
int | cs_ipcs_dispatch_iov_send (void *conn, const struct iovec *iov, unsigned int iov_len) |
int | cs_ipcs_response_send (void *conn, const void *msg, size_t mlen) |
int | cs_ipcs_response_iov_send (void *conn, const struct iovec *iov, unsigned int iov_len) |
void | cs_ipcs_sync_state_changed (int32_t sync_in_process) |
void * | cs_ipcs_private_data_get (void *conn) |
void | cs_ipc_refcnt_inc (void *conn) |
void | cs_ipc_refcnt_dec (void *conn) |
void | cs_ipc_allow_connections (int32_t allow) |
int | coroparse_configparse (icmap_map_t config_map, const char **error_string) |
Variables | |
unsigned long long *(* | main_clm_get_by_nodeid )(unsigned int node_id) |
Definition in file main.h.
int coroparse_configparse | ( | icmap_map_t | config_map, |
const char ** | error_string | ||
) |
Definition at line 247 of file coroparse.c.
Referenced by main().
void corosync_recheck_the_q_level | ( | void * | data | ) |
Definition at line 810 of file main.c.
References corosync_recheck_the_q_level(), cs_ipcs_q_level_get(), cs_poll_handle_get(), TOTEM_Q_LEVEL_CRITICAL, and totempg_check_q_level().
Referenced by corosync_recheck_the_q_level().
int corosync_sending_allowed | ( | unsigned int | service, |
unsigned int | id, | ||
const void * | msg, | ||
void * | sending_allowed_private_data | ||
) |
Definition at line 824 of file main.c.
References corosync_quorum_is_quorate(), corosync_service, CS_LIB_ALLOW_INQUORATE, CS_LIB_FLOW_CONTROL_NOT_REQUIRED, sending_allowed_private_data_struct::reserved_msgs, and totempg_groups_joined_reserve().
void corosync_sending_allowed_release | ( | void * | sending_allowed_private_data | ) |
Definition at line 867 of file main.c.
References sending_allowed_private_data_struct::reserved_msgs, and totempg_groups_joined_release().
void corosync_shutdown_request | ( | void | ) |
Definition at line 229 of file main.c.
References corosync_service_unlink_all().
void corosync_state_dump | ( | void | ) |
Definition at line 182 of file main.c.
References corosync_service, corosync_service_engine::exec_dump_fn, and SERVICES_COUNT_MAX.
void cs_ipc_allow_connections | ( | int32_t | allow | ) |
Definition at line 155 of file ipc_glue.c.
void cs_ipc_refcnt_dec | ( | void * | conn | ) |
Definition at line 372 of file ipc_glue.c.
void cs_ipc_refcnt_inc | ( | void * | conn | ) |
Definition at line 367 of file ipc_glue.c.
int cs_ipcs_dispatch_iov_send | ( | void * | conn, |
const struct iovec * | iov, | ||
unsigned int | iov_len | ||
) |
Definition at line 564 of file ipc_glue.c.
int cs_ipcs_dispatch_send | ( | void * | conn, |
const void * | msg, | ||
size_t | mlen | ||
) |
Definition at line 555 of file ipc_glue.c.
void cs_ipcs_init | ( | void | ) |
Definition at line 888 of file ipc_glue.c.
References apidef_get(), cs_poll_handle_get(), icmap_set_uint64(), corosync_api_v1::quorum_register_callback, and totempg_queue_level_register_callback().
void* cs_ipcs_private_data_get | ( | void * | conn | ) |
Definition at line 377 of file ipc_glue.c.
References cs_ipcs_conn_context::data.
int32_t cs_ipcs_q_level_get | ( | void | ) |
Definition at line 682 of file ipc_glue.c.
Referenced by corosync_recheck_the_q_level().
int cs_ipcs_response_iov_send | ( | void * | conn, |
const struct iovec * | iov, | ||
unsigned int | iov_len | ||
) |
Definition at line 441 of file ipc_glue.c.
int cs_ipcs_response_send | ( | void * | conn, |
const void * | msg, | ||
size_t | mlen | ||
) |
Definition at line 452 of file ipc_glue.c.
int32_t cs_ipcs_service_destroy | ( | int32_t | service_id | ) |
Definition at line 160 of file ipc_glue.c.
References cs_ipcs_mapper::inst.
const char* cs_ipcs_service_init | ( | struct corosync_service_engine * | service | ) |
Definition at line 848 of file ipc_glue.c.
References CS_IPCS_MAPPER_SERV_NAME, cs_ipcs_mapper::id, corosync_service_engine::id, cs_ipcs_mapper::inst, corosync_service_engine::lib_engine_count, log_printf, LOGSYS_LEVEL_DEBUG, LOGSYS_LEVEL_ERROR, and cs_ipcs_mapper::name.
Referenced by corosync_service_link_and_init().
void cs_ipcs_stats_update | ( | void | ) |
Definition at line 751 of file ipc_glue.c.
References corosync_service, ICMAP_KEYNAME_MAXLEN, cs_ipcs_conn_context::icmap_path, icmap_set_uint32(), icmap_set_uint64(), cs_ipcs_conn_context::invalid_request, cs_ipcs_conn_context::overload, cs_ipcs_conn_context::queued, and SERVICES_COUNT_MAX.
void cs_ipcs_sync_state_changed | ( | int32_t | sync_in_process | ) |
Definition at line 745 of file ipc_glue.c.
int cs_poll_dispatch_add | ( | qb_loop_t * | handle, |
int | fd, | ||
int | events, | ||
void * | data, | ||
int(*)(int fd, int revents, void *data) | dispatch_fn | ||
) |
qb_loop_t* cs_poll_handle_get | ( | void | ) |
Definition at line 159 of file main.c.
Referenced by corosync_recheck_the_q_level(), corosync_service_unlink_all(), corosync_service_unlink_and_exit(), corosync_timer_add_absolute(), corosync_timer_add_duration(), corosync_timer_delete(), corosync_timer_expire_time_get(), and cs_ipcs_init().
int main_mcast | ( | const struct iovec * | iovec, |
unsigned int | iov_len, | ||
unsigned int | guarantee | ||
) |
Definition at line 709 of file main.c.
References corosync_service, icmap_fast_inc(), service_stats_tx, and totempg_groups_mcast_joined().
int message_source_is_local | ( | const mar_message_source_t * | source | ) |
Definition at line 878 of file main.c.
References totempg_my_nodeid_get().
void message_source_set | ( | mar_message_source_t * | source, |
void * | conn | ||
) |
Definition at line 889 of file main.c.
References totempg_my_nodeid_get().
unsigned long long*(* main_clm_get_by_nodeid)(unsigned int node_id) |