#include <config.h>#include <stdlib.h>#include <string.h>#include <unistd.h>#include <sys/types.h>#include <sys/socket.h>#include <sys/uio.h>#include <errno.h>#include <qb/qbdefs.h>#include <qb/qbipcc.h>#include <corosync/corotypes.h>#include <corosync/corodefs.h>#include <corosync/hdb.h>#include <corosync/votequorum.h>#include <corosync/ipc_votequorum.h>#include "util.h"
Go to the source code of this file.
Data Structures | |
| struct | votequorum_inst |
Function Documentation
◆ DECLARE_HDB_DATABASE()
| DECLARE_HDB_DATABASE | ( | votequorum_handle_t_db | , |
| votequorum_inst_free | |||
| ) |
◆ votequorum_context_get()
| cs_error_t votequorum_context_get | ( | votequorum_handle_t | handle, |
| void ** | context | ||
| ) |
Save and retrieve private data/context.
- Parameters
-
handle context
- Returns
Definition at line 370 of file lib/votequorum.c.
References votequorum_inst::context, CS_OK, hdb_error_to_cs(), and nodeid.
◆ votequorum_context_set()
| cs_error_t votequorum_context_set | ( | votequorum_handle_t | handle, |
| void * | context | ||
| ) |
votequorum_context_set
- Parameters
-
handle context
- Returns
Definition at line 389 of file lib/votequorum.c.
References votequorum_inst::context, CS_OK, hdb_error_to_cs(), and nodeid.
◆ votequorum_dispatch()
| cs_error_t votequorum_dispatch | ( | votequorum_handle_t | handle, |
| cs_dispatch_flags_t | dispatch_types | ||
| ) |
Dispatch messages and configuration changes.
- Parameters
-
handle dispatch_types
- Returns
Definition at line 428 of file lib/votequorum.c.
References votequorum_inst::c, votequorum_inst::callbacks, CS_DISPATCH_ALL, CS_DISPATCH_BLOCKING, CS_DISPATCH_ONE, CS_DISPATCH_ONE_NONBLOCKING, CS_ERR_BAD_HANDLE, CS_ERR_INVALID_PARAM, CS_ERR_LIBRARY, CS_ERR_TRY_AGAIN, CS_OK, votequorum_inst::finalize, hdb_error_to_cs(), IPC_DISPATCH_SIZE, MESSAGE_RES_VOTEQUORUM_EXPECTEDVOTES_NOTIFICATION, MESSAGE_RES_VOTEQUORUM_NODELIST_NOTIFICATION, MESSAGE_RES_VOTEQUORUM_QUORUM_NOTIFICATION, nodeid, qb_to_cs_error(), ring_id, votequorum_callbacks_t::votequorum_expectedvotes_notify_fn, votequorum_callbacks_t::votequorum_nodelist_notify_fn, and votequorum_callbacks_t::votequorum_quorum_notify_fn.
◆ votequorum_fd_get()
| cs_error_t votequorum_fd_get | ( | votequorum_handle_t | handle, |
| int * | fd | ||
| ) |
Get a file descriptor on which to poll.
- Note
- votequorum_handle_t is NOT a file descriptor and may not be used directly.
- Parameters
-
handle fd
- Returns
Definition at line 409 of file lib/votequorum.c.
References votequorum_inst::c, CS_OK, hdb_error_to_cs(), nodeid, and qb_to_cs_error().
◆ votequorum_finalize()
| cs_error_t votequorum_finalize | ( | votequorum_handle_t | handle | ) |
Close the quorum handle.
- Parameters
-
handle
- Returns
Definition at line 119 of file lib/votequorum.c.
References CS_ERR_BAD_HANDLE, CS_OK, votequorum_inst::finalize, hdb_error_to_cs(), and nodeid.
◆ votequorum_getinfo()
| cs_error_t votequorum_getinfo | ( | votequorum_handle_t | handle, |
| unsigned int | nodeid, | ||
| struct votequorum_info * | info | ||
| ) |
Get quorum information.
- Parameters
-
handle nodeid info
- Returns
Definition at line 148 of file lib/votequorum.c.
References votequorum_inst::c, CS_IPC_TIMEOUT_MS, CS_OK, res_lib_votequorum_getinfo::expected_votes, res_lib_votequorum_getinfo::flags, hdb_error_to_cs(), res_lib_votequorum_getinfo::highest_expected, MESSAGE_REQ_VOTEQUORUM_GETINFO, nodeid, req_lib_votequorum_getinfo::nodeid, res_lib_votequorum_getinfo::nodeid, qb_to_cs_error(), res_lib_votequorum_getinfo::qdevice_name, res_lib_votequorum_getinfo::qdevice_votes, res_lib_votequorum_getinfo::quorum, res_lib_votequorum_getinfo::state, res_lib_votequorum_getinfo::total_votes, VOTEQUORUM_QDEVICE_MAX_NAME_LEN, and res_lib_votequorum_getinfo::votes.
◆ votequorum_initialize()
| cs_error_t votequorum_initialize | ( | votequorum_handle_t * | handle, |
| votequorum_callbacks_t * | callbacks | ||
| ) |
Create a new quorum connection.
- Parameters
-
handle callbacks
- Returns
Definition at line 72 of file lib/votequorum.c.
References votequorum_inst::c, votequorum_inst::callbacks, CS_OK, votequorum_inst::finalize, hdb_error_to_cs(), IPC_REQUEST_SIZE, nodeid, and qb_to_cs_error().
◆ votequorum_qdevice_master_wins()
| cs_error_t votequorum_qdevice_master_wins | ( | votequorum_handle_t | handle, |
| const char * | name, | ||
| unsigned int | allow | ||
| ) |
Allow qdevice to tell votequorum if master_wins can be enabled or not.
- Parameters
-
handle name allow
- Returns
Definition at line 669 of file lib/votequorum.c.
References req_lib_votequorum_qdevice_master_wins::allow, votequorum_inst::c, CS_ERR_INVALID_PARAM, CS_IPC_TIMEOUT_MS, CS_OK, hdb_error_to_cs(), MESSAGE_REQ_VOTEQUORUM_QDEVICE_MASTER_WINS, req_lib_votequorum_qdevice_master_wins::name, nodeid, qb_to_cs_error(), and VOTEQUORUM_QDEVICE_MAX_NAME_LEN.
◆ votequorum_qdevice_poll()
| cs_error_t votequorum_qdevice_poll | ( | votequorum_handle_t | handle, |
| const char * | name, | ||
| unsigned int | cast_vote, | ||
| votequorum_ring_id_t | ring_id | ||
| ) |
Poll a quorum device.
- Parameters
-
handle name cast_vote ring_id
- Returns
Definition at line 619 of file lib/votequorum.c.
References votequorum_inst::c, req_lib_votequorum_qdevice_poll::cast_vote, CS_ERR_INVALID_PARAM, CS_IPC_TIMEOUT_MS, CS_OK, hdb_error_to_cs(), MESSAGE_REQ_VOTEQUORUM_QDEVICE_POLL, req_lib_votequorum_qdevice_poll::name, nodeid, qb_to_cs_error(), ring_id, and VOTEQUORUM_QDEVICE_MAX_NAME_LEN.
◆ votequorum_qdevice_register()
| cs_error_t votequorum_qdevice_register | ( | votequorum_handle_t | handle, |
| const char * | name | ||
| ) |
Register a quorum device.
it will be DEAD until polled
- Parameters
-
handle name
- Returns
Definition at line 572 of file lib/votequorum.c.
References votequorum_inst::c, CS_ERR_INVALID_PARAM, CS_IPC_TIMEOUT_MS, CS_OK, hdb_error_to_cs(), MESSAGE_REQ_VOTEQUORUM_QDEVICE_REGISTER, req_lib_votequorum_qdevice_register::name, nodeid, qb_to_cs_error(), and VOTEQUORUM_QDEVICE_MAX_NAME_LEN.
◆ votequorum_qdevice_unregister()
| cs_error_t votequorum_qdevice_unregister | ( | votequorum_handle_t | handle, |
| const char * | name | ||
| ) |
Unregister a quorum device.
- Parameters
-
handle name
- Returns
Definition at line 767 of file lib/votequorum.c.
References votequorum_inst::c, CS_ERR_INVALID_PARAM, CS_IPC_TIMEOUT_MS, CS_OK, hdb_error_to_cs(), MESSAGE_REQ_VOTEQUORUM_QDEVICE_UNREGISTER, req_lib_votequorum_qdevice_unregister::name, nodeid, qb_to_cs_error(), and VOTEQUORUM_QDEVICE_MAX_NAME_LEN.
◆ votequorum_qdevice_update()
| cs_error_t votequorum_qdevice_update | ( | votequorum_handle_t | handle, |
| const char * | oldname, | ||
| const char * | newname | ||
| ) |
Update registered name of a quorum device.
- Parameters
-
handle oldname newname
- Returns
Definition at line 717 of file lib/votequorum.c.
References votequorum_inst::c, CS_ERR_INVALID_PARAM, CS_IPC_TIMEOUT_MS, CS_OK, hdb_error_to_cs(), MESSAGE_REQ_VOTEQUORUM_QDEVICE_UPDATE, newname, req_lib_votequorum_qdevice_update::newname, nodeid, oldname, req_lib_votequorum_qdevice_update::oldname, qb_to_cs_error(), and VOTEQUORUM_QDEVICE_MAX_NAME_LEN.
◆ votequorum_setexpected()
| cs_error_t votequorum_setexpected | ( | votequorum_handle_t | handle, |
| unsigned int | expected_votes | ||
| ) |
set expected_votes
- Parameters
-
handle expected_votes
- Returns
Definition at line 202 of file lib/votequorum.c.
References votequorum_inst::c, CS_IPC_TIMEOUT_MS, CS_OK, expected_votes, req_lib_votequorum_setexpected::expected_votes, hdb_error_to_cs(), MESSAGE_REQ_VOTEQUORUM_SETEXPECTED, nodeid, and qb_to_cs_error().
◆ votequorum_setvotes()
| cs_error_t votequorum_setvotes | ( | votequorum_handle_t | handle, |
| unsigned int | nodeid, | ||
| unsigned int | votes | ||
| ) |
set votes for a node
- Parameters
-
handle nodeid votes
- Returns
Definition at line 244 of file lib/votequorum.c.
References votequorum_inst::c, CS_IPC_TIMEOUT_MS, CS_OK, hdb_error_to_cs(), MESSAGE_REQ_VOTEQUORUM_SETVOTES, nodeid, req_lib_votequorum_setvotes::nodeid, qb_to_cs_error(), votes, and req_lib_votequorum_setvotes::votes.
◆ votequorum_trackstart()
| cs_error_t votequorum_trackstart | ( | votequorum_handle_t | handle, |
| uint64_t | context, | ||
| unsigned int | flags | ||
| ) |
Track node and quorum changes.
- Parameters
-
handle context flags
- Returns
Definition at line 287 of file lib/votequorum.c.
References votequorum_inst::c, req_lib_votequorum_trackstart::context, CS_IPC_TIMEOUT_MS, CS_OK, flags, hdb_error_to_cs(), MESSAGE_REQ_VOTEQUORUM_TRACKSTART, nodeid, qb_to_cs_error(), and req_lib_votequorum_trackstart::track_flags.
◆ votequorum_trackstop()
| cs_error_t votequorum_trackstop | ( | votequorum_handle_t | handle | ) |
votequorum_trackstop
- Parameters
-
handle
- Returns
Definition at line 330 of file lib/votequorum.c.
References votequorum_inst::c, CS_IPC_TIMEOUT_MS, CS_OK, hdb_error_to_cs(), MESSAGE_REQ_VOTEQUORUM_TRACKSTOP, nodeid, and qb_to_cs_error().
