#include <config.h>#include <stdlib.h>#include <stdio.h>#include <errno.h>#include <assert.h>#include <sys/uio.h>#include <string.h>#include <qb/qbdefs.h>#include <qb/qblist.h>#include <qb/qbutil.h>#include <qb/qbloop.h>#include <qb/qbipcs.h>#include <corosync/swab.h>#include <corosync/corotypes.h>#include <corosync/corodefs.h>#include <corosync/totem/totempg.h>#include <corosync/logsys.h>#include <corosync/icmap.h>#include "sync.h"#include "timer.h"#include "main.h"#include "util.h"#include "apidef.h"#include "service.h"
Go to the source code of this file.
Data Structures | |
| struct | cs_ipcs_mapper |
| struct | outq_item |
| struct | cs_ipcs_conn_context |
Macros | |
| #define | CS_IPCS_MAPPER_SERV_NAME 256 |
Functions | |
| LOGSYS_DECLARE_SUBSYS ("MAIN") | |
| void | cs_ipc_allow_connections (int32_t allow) |
| int32_t | cs_ipcs_service_destroy (int32_t service_id) |
| void | cs_ipc_refcnt_inc (void *conn) |
| void | cs_ipc_refcnt_dec (void *conn) |
| void * | cs_ipcs_private_data_get (void *conn) |
| int | cs_ipcs_response_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_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) |
| int32_t | cs_ipcs_q_level_get (void) |
| void | cs_ipcs_sync_state_changed (int32_t sync_in_process) |
| void | cs_ipcs_stats_update (void) |
| const char * | cs_ipcs_service_init (struct corosync_service_engine *service) |
| void | cs_ipcs_init (void) |
Macro Definition Documentation
| #define CS_IPCS_MAPPER_SERV_NAME 256 |
Definition at line 73 of file ipc_glue.c.
Referenced by cs_ipcs_service_init().
Function Documentation
| 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.
References corosync_sending_allowed(), corosync_sending_allowed_release(), corosync_service, CPG_SERVICE, CS_ERR_INVALID_PARAM, CS_ERR_TRY_AGAIN, cs_poll_handle_get(), cs_ipcs_conn_context::invalid_request, corosync_service_engine::lib_engine, corosync_lib_handler::lib_handler_fn, log_printf, LOGSYS_LEVEL_INFO, LOGSYS_LEVEL_NOTICE, LOGSYS_LEVEL_WARNING, and cs_ipcs_conn_context::overload.
| 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 corosync_service, cs_poll_handle_get(), cs_ipcs_conn_context::data, icmap_dec(), icmap_delete(), icmap_inc(), icmap_iter_finalize(), icmap_iter_init(), icmap_iter_next(), ICMAP_KEYNAME_MAXLEN, cs_ipcs_conn_context::icmap_path, corosync_service_engine::lib_exit_fn, list_entry, log_printf, outq_item::msg, list_head::next, and cs_ipcs_conn_context::outq_head.
| int32_t cs_ipcs_q_level_get | ( | void | ) |
Definition at line 682 of file ipc_glue.c.
References corosync_recheck_the_q_level(), corosync_service, CS_LIB_ALLOW_INQUORATE, cs_poll_handle_get(), cs_ipcs_mapper::inst, quorate, SERVICES_COUNT_MAX, TOTEM_Q_LEVEL_CRITICAL, TOTEM_Q_LEVEL_GOOD, TOTEM_Q_LEVEL_HIGH, TOTEM_Q_LEVEL_LOW, and VOTEQUORUM_SERVICE.
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.
References cs_poll_handle_get(), cs_ipcs_conn_context::data, outq_item::list, list_entry, log_printf, LOGSYS_LEVEL_ERROR, LOGSYS_LEVEL_INFO, outq_item::mlen, outq_item::msg, list_head::next, cs_ipcs_conn_context::outq_head, cs_ipcs_conn_context::queued, cs_ipcs_conn_context::queuing, and cs_ipcs_conn_context::sent.
| int32_t cs_ipcs_service_destroy | ( | int32_t | service_id | ) |
Definition at line 160 of file ipc_glue.c.
References corosync_service, CS_OK, icmap_get_uint8(), ICMAP_KEYNAME_MAXLEN, cs_ipcs_mapper::inst, log_printf, LOGSYS_LEVEL_DEBUG, LOGSYS_LEVEL_ERROR, and cs_ipcs_mapper::name.
Referenced by corosync_service_link_and_init().
| 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, CS_OK, icmap_get_string(), ICMAP_KEYNAME_MAXLEN, cs_ipcs_conn_context::icmap_path, icmap_set_uint32(), icmap_set_uint64(), cs_ipcs_mapper::inst, cs_ipcs_conn_context::invalid_request, log_printf, LOGSYS_LEVEL_DEBUG, 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.
| LOGSYS_DECLARE_SUBSYS | ( | "MAIN" | ) |
