Go to the documentation of this file.
35 #ifndef IPC_CPG_H_DEFINED
36 #define IPC_CPG_H_DEFINED
38 #include <netinet/in.h>
39 #include <qb/qbipc_common.h>
43 #define CPG_ZC_PATH_LEN 128
123 swab_mar_uint32_t (&to_swab->length);
131 static inline void marshall_from_mar_cpg_name_t (
135 dest->
length = src->length;
144 static inline void marshall_to_mar_cpg_name_t (
148 dest->length = src->
length;
166 static inline void marshall_from_mar_cpg_address_t (
170 dest->
nodeid = src->nodeid;
171 dest->
pid = src->pid;
172 dest->
reason = src->reason;
180 static inline void marshall_to_mar_cpg_address_t (
184 dest->nodeid = src->
nodeid;
185 dest->pid = src->
pid;
186 dest->reason = src->
reason;
195 static inline int mar_name_compare (
199 return (g1->length == g2->length?
200 memcmp (g1->value, g2->value, g1->length):
201 g1->length - g2->length);
218 static inline void marshall_from_mar_cpg_iteration_description_t(
224 marshall_from_mar_cpg_name_t (&dest->
group, &src->
group);
240 static inline void marshall_from_mar_cpg_ring_id_t (
244 dest->
nodeid = src->nodeid;
245 dest->
seq = src->seq;
The req_lib_cpg_leave struct.
@ CONFCHG_CPG_REASON_NODEUP
@ MESSAGE_RES_CPG_FLOW_CONTROL_STATE_SET
@ MESSAGE_RES_CPG_ITERATIONINITIALIZE
@ MESSAGE_RES_CPG_ZC_EXECUTE
@ MESSAGE_RES_CPG_CONFCHG_CALLBACK
The res_lib_cpg_confchg_callback struct.
The cpg_iteration_description_t struct.
The req_lib_cpg_partial_mcast struct.
struct qb_ipc_response_header header __attribute__((aligned(8)))
@ MESSAGE_REQ_CPG_ZC_FREE
mar_uint32_t member_list[]
@ MESSAGE_RES_CPG_PARTIAL_SEND
The req_lib_cpg_membership_get struct.
mar_req_coroipcc_zc_execute_t struct
struct qb_ipc_request_header header __attribute__((aligned(8)))
@ CONFCHG_CPG_REASON_LEAVE
struct qb_ipc_response_header header __attribute__((aligned(8)))
struct qb_ipc_response_header header __attribute__((aligned(8)))
@ MESSAGE_REQ_CPG_ITERATIONFINALIZE
struct qb_ipc_response_header header __attribute__((aligned(8)))
The res_lib_cpg_iterationnext struct.
struct qb_ipc_response_header header __attribute__((aligned(8)))
@ LIBCPG_PARTIAL_CONTINUED
mar_cpg_address_t member_list[]
struct qb_ipc_request_header header __attribute__((aligned(8)))
@ CONFCHG_CPG_REASON_NODEDOWN
The req_lib_cpg_local_get struct.
The res_lib_cpg_leave struct.
res_cpg_types
The res_cpg_types enum.
@ MESSAGE_RES_CPG_PARTIAL_DELIVER_CALLBACK
struct qb_ipc_response_header header __attribute__((aligned(8)))
struct qb_ipc_request_header header __attribute__((aligned(8)))
mar_req_coroipcc_zc_free_t struct
@ MESSAGE_REQ_CPG_LOCAL_GET
@ MESSAGE_REQ_CPG_FINALIZE
struct qb_ipc_response_header header __attribute__((aligned(8)))
char value[CPG_MAX_NAME_LENGTH]
@ MESSAGE_RES_CPG_ITERATIONNEXT
struct qb_ipc_response_header header __attribute__((aligned(8)))
@ MESSAGE_RES_CPG_FLOWCONTROL_CALLBACK
struct totem_message_header header
The res_lib_cpg_membership_get struct.
@ MESSAGE_RES_CPG_ITERATIONFINALIZE
The res_lib_cpg_flowcontrol_callback struct.
#define CPG_MAX_NAME_LENGTH
lib_cpg_confchg_reason
The lib_cpg_confchg_reason enum.
struct qb_ipc_response_header header __attribute__((aligned(8)))
struct qb_ipc_response_header header __attribute__((aligned(8)))
struct qb_ipc_response_header header __attribute__((aligned(8)))
struct qb_ipc_response_header header __attribute__((aligned(8)))
struct qb_ipc_response_header header __attribute__((aligned(8)))
The req_lib_cpg_mcast struct.
The res_lib_cpg_finalize struct.
lib_cpg_partial_types
The lib_cpg_partial_types enum.
The req_lib_cpg_iterationfinalize struct.
struct qb_ipc_request_header header __attribute__((aligned(8)))
@ MESSAGE_RES_CPG_TOTEM_CONFCHG_CALLBACK
The req_lib_cpg_join struct.
The req_lib_cpg_finalize struct.
@ MESSAGE_REQ_CPG_ZC_ALLOC
@ MESSAGE_REQ_CPG_MEMBERSHIP
struct qb_ipc_request_header header __attribute__((aligned(8)))
The res_lib_cpg_local_get struct.
struct qb_ipc_response_header header __attribute__((aligned(8)))
@ MESSAGE_RES_CPG_FINALIZE
@ MESSAGE_REQ_CPG_ZC_EXECUTE
The res_lib_cpg_totem_confchg_callback struct.
struct qb_ipc_request_header header __attribute__((aligned(8)))
@ MESSAGE_RES_CPG_LOCAL_GET
@ MESSAGE_REQ_CPG_PARTIAL_MCAST
The res_lib_cpg_iterationfinalize struct.
@ MESSAGE_RES_CPG_ZC_ALLOC
The req_lib_cpg_iterationnext struct.
struct qb_ipc_response_header header __attribute__((aligned(8)))
@ MESSAGE_RES_CPG_ZC_FREE
@ MESSAGE_REQ_CPG_ITERATIONINITIALIZE
The res_lib_cpg_iterationinitialize struct.
The res_lib_cpg_mcast struct.
struct qb_ipc_request_header header __attribute__((aligned(8)))
@ MESSAGE_RES_CPG_DELIVER_CALLBACK
struct memb_ring_id ring_id
#define PROCESSOR_COUNT_MAX
struct qb_ipc_request_header header __attribute__((aligned(8)))
@ CONFCHG_CPG_REASON_JOIN
The res_lib_cpg_partial_send struct.
struct qb_ipc_response_header header __attribute__((aligned(8)))
@ MESSAGE_REQ_CPG_ITERATIONNEXT
req_cpg_types
The req_cpg_types enum.
The res_lib_cpg_join struct.
struct qb_ipc_response_header header __attribute__((aligned(8)))
The req_lib_cpg_iterationinitialize struct.
The res_lib_cpg_partial_deliver_callback struct.
Message from another node.
@ CONFCHG_CPG_REASON_PROCDOWN
mar_cpg_address_t member_list[PROCESSOR_COUNT_MAX]
mar_req_coroipcc_zc_alloc_t struct
@ MESSAGE_RES_CPG_MEMBERSHIP
mar_cpg_iteration_description_t struct