corosync 3.1.9
|
#include <config.h>
#include <assert.h>
#include <sys/mman.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/socket.h>
#include <netdb.h>
#include <sys/un.h>
#include <sys/ioctl.h>
#include <sys/param.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <fcntl.h>
#include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <sched.h>
#include <time.h>
#include <sys/time.h>
#include <sys/poll.h>
#include <sys/uio.h>
#include <limits.h>
#include <qb/qblist.h>
#include <qb/qbdefs.h>
#include <qb/qbloop.h>
#include <corosync/sq.h>
#include <corosync/swab.h>
#include <corosync/logsys.h>
#include "totemudpu.h"
#include "util.h"
Go to the source code of this file.
Data Structures | |
struct | totemudpu_member |
struct | totemudpu_instance |
struct | work_item |
Macros | |
#define | LOGSYS_UTILS_ONLY 1 |
#define | MSG_NOSIGNAL 0 |
#define | MCAST_SOCKET_BUFFER_SIZE (TRANSMITS_ALLOWED * UDP_RECEIVE_FRAME_SIZE_MAX) |
#define | NETIF_STATE_REPORT_UP 1 |
#define | NETIF_STATE_REPORT_DOWN 2 |
#define | BIND_STATE_UNBOUND 0 |
#define | BIND_STATE_REGULAR 1 |
#define | BIND_STATE_LOOPBACK 2 |
#define | log_printf(level, format, args...) |
#define | LOGSYS_PERROR(err_num, level, fmt, args...) |
#define BIND_STATE_LOOPBACK 2 |
Definition at line 83 of file totemudpu.c.
#define BIND_STATE_REGULAR 1 |
Definition at line 82 of file totemudpu.c.
#define BIND_STATE_UNBOUND 0 |
Definition at line 81 of file totemudpu.c.
Definition at line 227 of file totemudpu.c.
Definition at line 234 of file totemudpu.c.
#define LOGSYS_UTILS_ONLY 1 |
Definition at line 67 of file totemudpu.c.
#define MCAST_SOCKET_BUFFER_SIZE (TRANSMITS_ALLOWED * UDP_RECEIVE_FRAME_SIZE_MAX) |
Definition at line 77 of file totemudpu.c.
#define MSG_NOSIGNAL 0 |
Definition at line 74 of file totemudpu.c.
#define NETIF_STATE_REPORT_DOWN 2 |
Definition at line 79 of file totemudpu.c.
#define NETIF_STATE_REPORT_UP 1 |
Definition at line 78 of file totemudpu.c.
Definition at line 1049 of file totemudpu.c.
References FRAME_SIZE_MAX, and nodeid.
Definition at line 1054 of file totemudpu.c.
References nodeid.
Definition at line 244 of file totemudpu.c.
Definition at line 423 of file totemudpu.c.
References totemudpu_instance::local_loop_sock, nodeid, totemudpu_instance::token_socket, totemudpu_instance::totemudpu_poll_handle, and totemudpu_instance::udpu_context.
Definition at line 1133 of file totemudpu.c.
References nodeid, and totemudpu_instance::udpu_context.
int totemudpu_iface_set | ( | void * | net_context, |
const struct totem_ip_address * | local_addr, | ||
unsigned short | ip_port, | ||
unsigned int | iface_no | ||
) |
Definition at line 1301 of file totemudpu.c.
Definition at line 825 of file totemudpu.c.
References INTERFACE_MAX, and nodeid.
int totemudpu_initialize | ( | qb_loop_t * | poll_handle, |
void ** | udpu_context, | ||
struct totem_config * | totem_config, | ||
totemsrp_stats_t * | stats, | ||
void * | context, | ||
int(*)(void *context, const void *msg, unsigned int msg_len, const struct sockaddr_storage *system_from) | deliver_fn, | ||
int(*)(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.
Definition at line 953 of file totemudpu.c.
References totem_interface::bindnet, totemudpu_instance::context, totem_config::interfaces, totemudpu_instance::iov_buffer, totemudpu_instance::local_loop_sock, totem_logging_configuration::log_level_debug, totem_logging_configuration::log_level_error, totem_logging_configuration::log_level_notice, totem_logging_configuration::log_level_warning, totem_logging_configuration::log_printf, totem_logging_configuration::log_subsys_id, totem_config::node_id, nodeid, totem_ip_address::nodeid, totemudpu_instance::stats, totemudpu_instance::timer_netif_check_timeout, totemudpu_instance::totem_config, totemudpu_instance::totem_interface, totem_config::totem_logging_configuration, totemudpu_instance::totemudpu_deliver_fn, totemudpu_instance::totemudpu_iface_change_fn, totemudpu_instance::totemudpu_log_level_debug, totemudpu_instance::totemudpu_log_level_error, totemudpu_instance::totemudpu_log_level_notice, totemudpu_instance::totemudpu_log_level_security, totemudpu_instance::totemudpu_log_level_warning, totemudpu_instance::totemudpu_log_printf, totemudpu_instance::totemudpu_poll_handle, totemudpu_instance::totemudpu_subsys_id, totemudpu_instance::totemudpu_target_set_completed, UDP_RECEIVE_FRAME_SIZE_MAX, and totemudpu_instance::udpu_context.
Definition at line 1107 of file totemudpu.c.
References nodeid, and totemudpu_instance::udpu_context.
Definition at line 1120 of file totemudpu.c.
References nodeid, and totemudpu_instance::udpu_context.
int totemudpu_member_add | ( | void * | udpu_context, |
const struct totem_ip_address * | local, | ||
const struct totem_ip_address * | member, | ||
int | ring_no | ||
) |
Definition at line 1310 of file totemudpu.c.
References log_printf, LOGSYS_LEVEL_NOTICE, totemudpu_member::member, totemudpu_instance::member_list, nodeid, totemip_print(), and totemudpu_instance::udpu_context.
Definition at line 1386 of file totemudpu.c.
References totemudpu_member::fd, totemudpu_member::member, totemudpu_instance::member_list, nodeid, and totemudpu_instance::udpu_context.
int totemudpu_member_remove | ( | void * | udpu_context, |
const struct totem_ip_address * | token_target, | ||
int | ring_no | ||
) |
Definition at line 1338 of file totemudpu.c.
References totemudpu_member::fd, log_printf, LOGSYS_LEVEL_DEBUG, LOGSYS_LEVEL_NOTICE, totemudpu_member::member, totemudpu_instance::member_list, nodeid, totemudpu_instance::token_target, totemip_compare(), totemip_print(), totemudpu_instance::totemudpu_poll_handle, and totemudpu_instance::udpu_context.
|
extern |
Definition at line 1143 of file totemudpu.c.
References totem_interface::bindnet, totem_ip_address::family, totem_config::interfaces, totem_config::net_mtu, and totemip_udpip_header_size().
int totemudpu_nodestatus_get | ( | void * | udpu_context, |
unsigned int | nodeid, | ||
struct totem_node_status * | node_status | ||
) |
Definition at line 797 of file totemudpu.c.
References BIND_STATE_REGULAR, totemudpu_member::list, totemudpu_member::member, totemudpu_instance::member_list, totem_config::net_mtu, totemudpu_instance::netif_bind_state, nodeid, totem_ip_address::nodeid, totemudpu_instance::totem_config, totemip_print(), and totemudpu_instance::udpu_context.
int totemudpu_reconfigure | ( | void * | udpu_context, |
struct totem_config * | totem_config | ||
) |
Definition at line 1447 of file totemudpu.c.
Definition at line 1081 of file totemudpu.c.
References nodeid.
Definition at line 1175 of file totemudpu.c.
References BIND_STATE_REGULAR, totemudpu_instance::local_loop_sock, MSG_NOSIGNAL, totemudpu_instance::netif_bind_state, nodeid, system_from, totemudpu_instance::token_socket, totemudpu_instance::totemudpu_iov_recv, and totemudpu_instance::udpu_context.
Definition at line 1088 of file totemudpu.c.
References nodeid.
Definition at line 1095 of file totemudpu.c.
References nodeid, totemudpu_instance::token_target, and totemudpu_instance::udpu_context.
Definition at line 1149 of file totemudpu.c.
References totemudpu_instance::context, totemudpu_member::list, totemudpu_member::member, totemudpu_instance::member_list, nodeid, totem_ip_address::nodeid, totemudpu_instance::token_target, totemudpu_instance::totemudpu_target_set_completed, and totemudpu_instance::udpu_context.