|
| | DECLARE_HDB_DATABASE (cpg_handle_t_db, cpg_inst_free) |
| |
| | DECLARE_HDB_DATABASE (cpg_iteration_handle_t_db, NULL) |
| |
| cs_error_t | cpg_initialize (cpg_handle_t *handle, cpg_callbacks_t *callbacks) |
| | Create a new cpg connection.
|
| |
| cs_error_t | cpg_model_initialize (cpg_handle_t *handle, cpg_model_t model, cpg_model_data_t *model_data, void *context) |
| | Create a new cpg connection, initialize with model.
|
| |
| cs_error_t | cpg_finalize (cpg_handle_t handle) |
| | Close the cpg handle.
|
| |
| cs_error_t | cpg_fd_get (cpg_handle_t handle, int *fd) |
| | Get a file descriptor on which to poll.
|
| |
| cs_error_t | cpg_max_atomic_msgsize_get (cpg_handle_t handle, uint32_t *size) |
| | Get maximum size of a message that will not be fragmented.
|
| |
| cs_error_t | cpg_context_get (cpg_handle_t handle, void **context) |
| | Get contexts for a CPG handle.
|
| |
| cs_error_t | cpg_context_set (cpg_handle_t handle, void *context) |
| | Set contexts for a CPG handle.
|
| |
| cs_error_t | cpg_dispatch (cpg_handle_t handle, cs_dispatch_flags_t dispatch_types) |
| | Dispatch messages and configuration changes.
|
| |
| cs_error_t | cpg_join (cpg_handle_t handle, const struct cpg_name *group) |
| | Join one or more groups.
|
| |
| cs_error_t | cpg_leave (cpg_handle_t handle, const struct cpg_name *group) |
| | Leave one or more groups.
|
| |
| cs_error_t | cpg_membership_get (cpg_handle_t handle, struct cpg_name *group_name, struct cpg_address *member_list, int *member_list_entries) |
| | Get membership information from cpg.
|
| |
| cs_error_t | cpg_local_get (cpg_handle_t handle, unsigned int *local_nodeid) |
| | cpg_local_get
|
| |
| cs_error_t | cpg_flow_control_state_get (cpg_handle_t handle, cpg_flow_control_state_t *flow_control_state) |
| | cpg_flow_control_state_get
|
| |
| cs_error_t | cpg_zcb_alloc (cpg_handle_t handle, size_t size, void **buffer) |
| | cpg_zcb_alloc
|
| |
| cs_error_t | cpg_zcb_free (cpg_handle_t handle, void *buffer) |
| | cpg_zcb_free
|
| |
| cs_error_t | cpg_zcb_mcast_joined (cpg_handle_t handle, cpg_guarantee_t guarantee, void *msg, size_t msg_len) |
| | cpg_zcb_mcast_joined
|
| |
| cs_error_t | cpg_mcast_joined (cpg_handle_t handle, cpg_guarantee_t guarantee, const struct iovec *iovec, unsigned int iov_len) |
| | Multicast to groups joined with cpg_join.
|
| |
| cs_error_t | cpg_iteration_initialize (cpg_handle_t handle, cpg_iteration_type_t iteration_type, const struct cpg_name *group, cpg_iteration_handle_t *cpg_iteration_handle) |
| | cpg_iteration_initialize
|
| |
| cs_error_t | cpg_iteration_next (cpg_iteration_handle_t handle, struct cpg_iteration_description_t *description) |
| | cpg_iteration_next
|
| |
| cs_error_t | cpg_iteration_finalize (cpg_iteration_handle_t handle) |
| | cpg_iteration_finalize
|
| |
