#include <config.h>#include <assert.h>#include <pthread.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 <limits.h>#include <string.h>#include <rdma/rdma_cma.h>#include <corosync/sq.h>#include <corosync/list.h>#include <corosync/hdb.h>#include <corosync/swab.h>#include <qb/qbdefs.h>#include <qb/qbloop.h>#include <corosync/logsys.h>#include "totemiba.h"
Go to the source code of this file.
Data Structures | |
| struct | totemiba_instance |
| union | u |
| struct | recv_buf |
| struct | send_buf |
Macros | |
| #define | LOGSYS_UTILS_ONLY 1 |
| #define | COMPLETION_QUEUE_ENTRIES 100 |
| #define | TOTAL_READ_POSTS 100 |
| #define | MAX_MTU_SIZE 4096 |
| #define | MCAST_REJOIN_MSEC 100 |
| #define | log_printf(level, format, args...) |
Functions | |
| int | totemiba_crypto_set (void *iba_context, const char *cipher_type, const char *hash_type) |
| int | totemiba_finalize (void *iba_context) |
| int | totemiba_initialize (qb_loop_t *qb_poll_handle, void **iba_context, struct totem_config *totem_config, totemsrp_stats_t *stats, int interface_no, void *context, void(*deliver_fn)(void *context, const void *msg, unsigned int msg_len), void(*iface_change_fn)(void *context, const struct totem_ip_address *iface_address), void(*target_set_completed)(void *context)) |
| Create an instance. More... | |
| void * | totemiba_buffer_alloc (void) |
| void | totemiba_buffer_release (void *ptr) |
| int | totemiba_processor_count_set (void *iba_context, int processor_count) |
| int | totemiba_recv_flush (void *iba_context) |
| int | totemiba_send_flush (void *iba_context) |
| int | totemiba_token_send (void *iba_context, const void *ms, unsigned int msg_len) |
| int | totemiba_mcast_flush_send (void *iba_context, const void *ms, unsigned int msg_len) |
| int | totemiba_mcast_noflush_send (void *iba_context, const void *ms, unsigned int msg_len) |
| int | totemiba_iface_check (void *iba_context) |
| void | totemiba_net_mtu_adjust (void *iba_context, struct totem_config *totem_config) |
| const char * | totemiba_iface_print (void *iba_context) |
| int | totemiba_iface_get (void *iba_context, struct totem_ip_address *addr) |
| int | totemiba_token_target_set (void *iba_context, const struct totem_ip_address *token_target) |
| int | totemiba_recv_mcast_empty (void *iba_context) |
Macro Definition Documentation
| #define COMPLETION_QUEUE_ENTRIES 100 |
Definition at line 80 of file totemiba.c.
| #define log_printf | ( | level, | |
| format, | |||
| args... | |||
| ) |
Definition at line 224 of file totemiba.c.
| #define LOGSYS_UTILS_ONLY 1 |
Definition at line 76 of file totemiba.c.
| #define MAX_MTU_SIZE 4096 |
Definition at line 84 of file totemiba.c.
Referenced by totemiba_buffer_alloc().
| #define MCAST_REJOIN_MSEC 100 |
Definition at line 86 of file totemiba.c.
| #define TOTAL_READ_POSTS 100 |
Definition at line 82 of file totemiba.c.
Function Documentation
| void* totemiba_buffer_alloc | ( | void | ) |
Definition at line 1411 of file totemiba.c.
References MAX_MTU_SIZE.
| void totemiba_buffer_release | ( | void * | ptr | ) |
Definition at line 1416 of file totemiba.c.
| int totemiba_crypto_set | ( | void * | iba_context, |
| const char * | cipher_type, | ||
| const char * | hash_type | ||
| ) |
Definition at line 1323 of file totemiba.c.
| int totemiba_finalize | ( | void * | iba_context | ) |
Definition at line 1336 of file totemiba.c.
| int totemiba_iface_check | ( | void * | iba_context | ) |
Definition at line 1575 of file totemiba.c.
| int totemiba_iface_get | ( | void * | iba_context, |
| struct totem_ip_address * | addr | ||
| ) |
Definition at line 1601 of file totemiba.c.
References totemiba_instance::my_id.
| const char* totemiba_iface_print | ( | void * | iba_context | ) |
Definition at line 1591 of file totemiba.c.
References totemiba_instance::my_id, and totemip_print().
| int totemiba_initialize | ( | qb_loop_t * | qb_poll_handle, |
| void ** | iba_context, | ||
| struct totem_config * | totem_config, | ||
| totemsrp_stats_t * | stats, | ||
| int | interface_no, | ||
| void * | context, | ||
| void(*)(void *context, const void *msg, unsigned int msg_len) | deliver_fn, | ||
| void(*)(void *context, const struct totem_ip_address *iface_address) | iface_change_fn, | ||
| void(*)(void *context) | target_set_completed | ||
| ) |
Create an instance.
Definition at line 1350 of file totemiba.c.
References totem_interface::bindnet, totem_config::interfaces, totem_logging_configuration::log_printf, totem_logging_configuration::log_subsys_id, totem_config::node_id, totem_ip_address::nodeid, totemiba_instance::rrp_context, totemiba_instance::stats, totemiba_instance::timer_netif_check_timeout, totemiba_instance::totem_config, totemiba_instance::totem_interface, totem_config::totem_logging_configuration, totemiba_instance::totemiba_deliver_fn, totemiba_instance::totemiba_iface_change_fn, totemiba_instance::totemiba_log_printf, totemiba_instance::totemiba_poll_handle, totemiba_instance::totemiba_subsys_id, and totemiba_instance::totemiba_target_set_completed.
| int totemiba_mcast_flush_send | ( | void * | iba_context, |
| const void * | ms, | ||
| unsigned int | msg_len | ||
| ) |
Definition at line 1493 of file totemiba.c.
References send_buf::buffer, totemiba_instance::mcast_ah, totemiba_instance::mcast_cma_id, totemiba_instance::mcast_qkey, totemiba_instance::mcast_qpn, and send_buf::mr.
| int totemiba_mcast_noflush_send | ( | void * | iba_context, |
| const void * | ms, | ||
| unsigned int | msg_len | ||
| ) |
Definition at line 1534 of file totemiba.c.
References send_buf::buffer, totemiba_instance::mcast_ah, totemiba_instance::mcast_cma_id, totemiba_instance::mcast_qkey, totemiba_instance::mcast_qpn, and send_buf::mr.
| void totemiba_net_mtu_adjust | ( | void * | iba_context, |
| struct totem_config * | totem_config | ||
| ) |
Definition at line 1585 of file totemiba.c.
| int totemiba_processor_count_set | ( | void * | iba_context, |
| int | processor_count | ||
| ) |
Definition at line 1421 of file totemiba.c.
| int totemiba_recv_flush | ( | void * | iba_context | ) |
Definition at line 1433 of file totemiba.c.
| int totemiba_recv_mcast_empty | ( | void * | iba_context | ) |
Definition at line 1632 of file totemiba.c.
| int totemiba_send_flush | ( | void * | iba_context | ) |
Definition at line 1443 of file totemiba.c.
| int totemiba_token_send | ( | void * | iba_context, |
| const void * | ms, | ||
| unsigned int | msg_len | ||
| ) |
Definition at line 1453 of file totemiba.c.
References send_buf::buffer, send_buf::mr, totemiba_instance::send_token_ah, totemiba_instance::send_token_bound, totemiba_instance::send_token_cma_id, totemiba_instance::send_token_qkey, and totemiba_instance::send_token_qpn.
| int totemiba_token_target_set | ( | void * | iba_context, |
| const struct totem_ip_address * | token_target | ||
| ) |
Definition at line 1613 of file totemiba.c.
References totem_interface::ip_port, totemiba_instance::token_addr, totemiba_instance::totem_interface, and totemip_totemip_to_sockaddr_convert().
