#include <sys/types.h>#include <sys/socket.h>#include <qb/qbloop.h>#include <corosync/totem/totem.h>
Go to the source code of this file.
Functions | |
| int | totemknet_initialize (qb_loop_t *poll_handle, void **knet_context, struct totem_config *totem_config, totemsrp_stats_t *stats, void *context, void(*deliver_fn)(void *context, const void *msg, unsigned int msg_len, const struct sockaddr_storage *system_from), void(*iface_change_fn)(void *context, const struct totem_ip_address *iface_address, unsigned int ring_no), void(*mtu_changed)(void *context, int net_mtu), void(*target_set_completed)(void *context)) |
| Create an instance. More... | |
| void * | totemknet_buffer_alloc (void) |
| void | totemknet_buffer_release (void *ptr) |
| int | totemknet_processor_count_set (void *knet_context, int processor_count) |
| int | totemknet_token_send (void *knet_context, const void *msg, unsigned int msg_len) |
| int | totemknet_mcast_flush_send (void *knet_context, const void *msg, unsigned int msg_len) |
| int | totemknet_mcast_noflush_send (void *knet_context, const void *msg, unsigned int msg_len) |
| int | totemknet_recv_flush (void *knet_context) |
| int | totemknet_send_flush (void *knet_context) |
| int | totemknet_iface_check (void *knet_context) |
| int | totemknet_finalize (void *knet_context) |
| void | totemknet_net_mtu_adjust (void *knet_context, struct totem_config *totem_config) |
| int | totemknet_nodestatus_get (void *knet_context, unsigned int nodeid, struct totem_node_status *node_status) |
| int | totemknet_ifaces_get (void *net_context, char ***status, unsigned int *iface_count) |
| int | totemknet_iface_set (void *net_context, const struct totem_ip_address *local_addr, unsigned short ip_port, unsigned int iface_no) |
| int | totemknet_token_target_set (void *knet_context, unsigned int nodeid) |
| int | totemknet_crypto_set (void *knet_context, const char *cipher_type, const char *hash_type) |
| int | totemknet_recv_mcast_empty (void *knet_context) |
| int | totemknet_member_add (void *knet_context, const struct totem_ip_address *local, const struct totem_ip_address *member, int ring_no) |
| int | totemknet_member_remove (void *knet_context, const struct totem_ip_address *member, int ring_no) |
| int | totemknet_member_set_active (void *knet_context, const struct totem_ip_address *member_ip, int active) |
| int | totemknet_reconfigure (void *knet_context, struct totem_config *totem_config) |
| int | totemknet_crypto_reconfigure_phase (void *knet_context, struct totem_config *totem_config, cfg_message_crypto_reconfig_phase_t phase) |
| void | totemknet_stats_clear (void *knet_context) |
| void | totemknet_configure_log_level (void) |
Function Documentation
◆ totemknet_buffer_alloc()
| void * totemknet_buffer_alloc | ( | void | ) |
Definition at line 1358 of file totemknet.c.
◆ totemknet_buffer_release()
| void totemknet_buffer_release | ( | void * | ptr | ) |
Definition at line 1364 of file totemknet.c.
◆ totemknet_configure_log_level()
| void totemknet_configure_log_level | ( | void | ) |
Definition at line 888 of file totemknet.c.
References global_instance, totemknet_instance::knet_handle, log_printf, logsys_config_debug_get(), LOGSYS_DEBUG_OFF, LOGSYS_DEBUG_ON, LOGSYS_DEBUG_TRACE, and LOGSYS_LEVEL_DEBUG.
◆ totemknet_crypto_reconfigure_phase()
| int totemknet_crypto_reconfigure_phase | ( | void * | knet_context, |
| struct totem_config * | totem_config, | ||
| cfg_message_crypto_reconfig_phase_t | phase | ||
| ) |
Definition at line 1750 of file totemknet.c.
References totem_config::crypto_index, CRYPTO_RECONFIG_PHASE_ACTIVATE, totemknet_instance::knet_context, knet_log_printf, and LOGSYS_LEVEL_DEBUG.
◆ totemknet_crypto_set()
| int totemknet_crypto_set | ( | void * | knet_context, |
| const char * | cipher_type, | ||
| const char * | hash_type | ||
| ) |
Definition at line 363 of file totemknet.c.
◆ totemknet_finalize()
| int totemknet_finalize | ( | void * | knet_context | ) |
Definition at line 664 of file totemknet.c.
References CS_PRI_NODE_ID, totemknet_instance::knet_context, totemknet_instance::knet_fd, totemknet_instance::knet_handle, knet_log_printf, totemknet_instance::logpipes, LOGSYS_LEVEL_CRIT, LOGSYS_LEVEL_ERROR, and totemknet_instance::poll_handle.
◆ totemknet_iface_check()
| int totemknet_iface_check | ( | void * | knet_context | ) |
Definition at line 1425 of file totemknet.c.
References totemknet_instance::knet_context, and knet_log_printf.
◆ totemknet_iface_set()
| int totemknet_iface_set | ( | void * | net_context, |
| const struct totem_ip_address * | local_addr, | ||
| unsigned short | ip_port, | ||
| unsigned int | iface_no | ||
| ) |
Definition at line 1508 of file totemknet.c.
References totemknet_instance::ip_port, totemknet_instance::knet_context, knet_log_printf, totemknet_instance::my_ids, totemip_copy(), and totemip_print().
◆ totemknet_ifaces_get()
| int totemknet_ifaces_get | ( | void * | net_context, |
| char *** | status, | ||
| unsigned int * | iface_count | ||
| ) |
Definition at line 569 of file totemknet.c.
References totemknet_instance::knet_context, totemknet_instance::knet_handle, and OWN_INDEX_NONE.
◆ totemknet_initialize()
| int totemknet_initialize | ( | qb_loop_t * | poll_handle, |
| void ** | knet_context, | ||
| struct totem_config * | totem_config, | ||
| totemsrp_stats_t * | stats, | ||
| void * | context, | ||
| void(*)(void *context, const void *msg, unsigned int msg_len, const struct sockaddr_storage *system_from) | deliver_fn, | ||
| void(*)(void *context, const struct totem_ip_address *iface_address, unsigned int ring_no) | iface_change_fn, | ||
| void(*)(void *context, int net_mtu) | mtu_changed, | ||
| void(*)(void *context) | target_set_completed | ||
| ) |
Create an instance.
◆ totemknet_mcast_flush_send()
| int totemknet_mcast_flush_send | ( | void * | knet_context, |
| const void * | msg, | ||
| unsigned int | msg_len | ||
| ) |
Definition at line 1398 of file totemknet.c.
References totemknet_instance::knet_context.
◆ totemknet_mcast_noflush_send()
| int totemknet_mcast_noflush_send | ( | void * | knet_context, |
| const void * | msg, | ||
| unsigned int | msg_len | ||
| ) |
Definition at line 1411 of file totemknet.c.
References totemknet_instance::knet_context.
◆ totemknet_member_add()
| int totemknet_member_add | ( | void * | knet_context, |
| const struct totem_ip_address * | local, | ||
| const struct totem_ip_address * | member, | ||
| int | ring_no | ||
| ) |
Definition at line 1525 of file totemknet.c.
References CS_PRI_NODE_ID, totem_config::interfaces, totemknet_instance::ip_port, totemknet_instance::knet_context, totemknet_instance::knet_handle, totem_interface::knet_link_priority, knet_log_printf, KNET_LOGSYS_PERROR, totem_interface::knet_ping_interval, totem_interface::knet_ping_precision, totem_interface::knet_ping_timeout, totem_interface::knet_pong_count, totem_interface::knet_transport, totemknet_instance::link_mode, LOGSYS_LEVEL_DEBUG, LOGSYS_LEVEL_ERROR, totemknet_instance::loopback_link, totem_ip_address::nodeid, totemknet_instance::our_nodeid, stats_knet_add_member(), totemknet_instance::totem_config, totemip_print(), and totemip_totemip_to_sockaddr_convert().
◆ totemknet_member_remove()
| int totemknet_member_remove | ( | void * | knet_context, |
| const struct totem_ip_address * | member, | ||
| int | ring_no | ||
| ) |
Definition at line 1647 of file totemknet.c.
References CS_PRI_NODE_ID, totemknet_instance::knet_context, totemknet_instance::knet_handle, knet_log_printf, KNET_LOGSYS_PERROR, LOGSYS_LEVEL_DEBUG, LOGSYS_LEVEL_ERROR, totem_ip_address::nodeid, totemknet_instance::our_nodeid, stats_knet_del_member(), and totemknet_instance::token_target.
◆ totemknet_member_set_active()
| int totemknet_member_set_active | ( | void * | knet_context, |
| const struct totem_ip_address * | member_ip, | ||
| int | active | ||
| ) |
◆ totemknet_net_mtu_adjust()
| void totemknet_net_mtu_adjust | ( | void * | knet_context, |
| struct totem_config * | totem_config | ||
| ) |
Definition at line 1435 of file totemknet.c.
References totemknet_instance::knet_context, knet_log_printf, and totem_config::net_mtu.
◆ totemknet_nodestatus_get()
| int totemknet_nodestatus_get | ( | void * | knet_context, |
| unsigned int | nodeid, | ||
| struct totem_node_status * | node_status | ||
| ) |
Definition at line 491 of file totemknet.c.
References totem_interface::configured, CS_ERR_INVALID_PARAM, CS_ERR_NOT_EXIST, totem_node_status::external, totem_config::interfaces, totemknet_instance::knet_context, totemknet_instance::knet_handle, knet_log_printf, totem_node_status::link_status, LOGSYS_LEVEL_WARNING, nodeid, totem_node_status::nodeid, totem_node_status::onwire_max, totem_node_status::onwire_min, totem_node_status::onwire_ver, totem_node_status::reachable, totem_node_status::remote, and totemknet_instance::totem_config.
◆ totemknet_processor_count_set()
| int totemknet_processor_count_set | ( | void * | knet_context, |
| int | processor_count | ||
| ) |
Definition at line 1369 of file totemknet.c.
◆ totemknet_reconfigure()
| int totemknet_reconfigure | ( | void * | knet_context, |
| struct totem_config * | totem_config | ||
| ) |
Definition at line 1720 of file totemknet.c.
References totemknet_instance::knet_context.
◆ totemknet_recv_flush()
| int totemknet_recv_flush | ( | void * | knet_context | ) |
Definition at line 1376 of file totemknet.c.
◆ totemknet_recv_mcast_empty()
| int totemknet_recv_mcast_empty | ( | void * | knet_context | ) |
Definition at line 1456 of file totemknet.c.
References totemknet_instance::iov_buffer, totemknet_instance::knet_context, totemknet_instance::knet_fd, MSG_NOSIGNAL, and system_from.
◆ totemknet_send_flush()
| int totemknet_send_flush | ( | void * | knet_context | ) |
Definition at line 1381 of file totemknet.c.
◆ totemknet_stats_clear()
| void totemknet_stats_clear | ( | void * | knet_context | ) |
Definition at line 1809 of file totemknet.c.
References totemknet_instance::knet_context, and totemknet_instance::knet_handle.
◆ totemknet_token_send()
| int totemknet_token_send | ( | void * | knet_context, |
| const void * | msg, | ||
| unsigned int | msg_len | ||
| ) |
Definition at line 1386 of file totemknet.c.
References totemknet_instance::knet_context.
◆ totemknet_token_target_set()
| int totemknet_token_target_set | ( | void * | knet_context, |
| unsigned int | nodeid | ||
| ) |
Definition at line 1442 of file totemknet.c.
References totemknet_instance::context, totemknet_instance::knet_context, nodeid, totem_ip_address::nodeid, totemknet_instance::token_target, and totemknet_instance::totemknet_target_set_completed.
