mirror of
https://git.proxmox.com/git/mirror_corosync
synced 2025-07-21 19:41:01 +00:00

git-svn-id: http://svn.fedorahosted.org/svn/corosync/trunk@2545 fd59a12c-fef9-0310-b244-a6a79926bd2f
919 lines
24 KiB
C
919 lines
24 KiB
C
/*
|
|
* vi: set autoindent tabstop=4 shiftwidth=4 :
|
|
*
|
|
* Copyright (c) 2006-2009 Red Hat, Inc.
|
|
*
|
|
* All rights reserved.
|
|
*
|
|
* Author: Christine Caulfield (ccaulfi@redhat.com)
|
|
* Author: Jan Friesse (jfriesse@redhat.com)
|
|
*
|
|
* This software licensed under BSD license, the text of which follows:
|
|
*
|
|
* Redistribution and use in source and binary forms, with or without
|
|
* modification, are permitted provided that the following conditions are met:
|
|
*
|
|
* - Redistributions of source code must retain the above copyright notice,
|
|
* this list of conditions and the following disclaimer.
|
|
* - Redistributions in binary form must reproduce the above copyright notice,
|
|
* this list of conditions and the following disclaimer in the documentation
|
|
* and/or other materials provided with the distribution.
|
|
* - Neither the name of the MontaVista Software, Inc. nor the names of its
|
|
* contributors may be used to endorse or promote products derived from this
|
|
* software without specific prior written permission.
|
|
*
|
|
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
|
|
* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
|
|
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
|
|
* ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
|
|
* LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
|
|
* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
|
|
* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
|
|
* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
|
|
* CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
|
|
* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
|
|
* THE POSSIBILITY OF SUCH DAMAGE.
|
|
*/
|
|
/*
|
|
* Provides a closed process group API using the coroipcc executive
|
|
*/
|
|
|
|
#include <config.h>
|
|
|
|
#include <stdlib.h>
|
|
#include <string.h>
|
|
#include <unistd.h>
|
|
#include <sys/types.h>
|
|
#include <sys/socket.h>
|
|
#include <errno.h>
|
|
|
|
#include <corosync/corotypes.h>
|
|
#include <corosync/coroipc_types.h>
|
|
#include <corosync/coroipcc.h>
|
|
#include <corosync/corodefs.h>
|
|
#include <corosync/hdb.h>
|
|
#include <corosync/list.h>
|
|
|
|
#include <corosync/cpg.h>
|
|
#include <corosync/ipc_cpg.h>
|
|
|
|
#include "util.h"
|
|
|
|
struct cpg_inst {
|
|
hdb_handle_t handle;
|
|
int finalize;
|
|
cpg_callbacks_t callbacks;
|
|
void *context;
|
|
struct list_head iteration_list_head;
|
|
};
|
|
|
|
DECLARE_HDB_DATABASE(cpg_handle_t_db,NULL);
|
|
|
|
struct cpg_iteration_instance_t {
|
|
cpg_iteration_handle_t cpg_iteration_handle;
|
|
hdb_handle_t conn_handle;
|
|
hdb_handle_t executive_iteration_handle;
|
|
struct list_head list;
|
|
};
|
|
|
|
DECLARE_HDB_DATABASE(cpg_iteration_handle_t_db,NULL);
|
|
|
|
|
|
/*
|
|
* Internal (not visible by API) functions
|
|
*/
|
|
|
|
static void cpg_iteration_instance_finalize (struct cpg_iteration_instance_t *cpg_iteration_instance)
|
|
{
|
|
list_del (&cpg_iteration_instance->list);
|
|
hdb_handle_destroy (&cpg_iteration_handle_t_db, cpg_iteration_instance->cpg_iteration_handle);
|
|
}
|
|
|
|
static void cpg_inst_finalize (struct cpg_inst *cpg_inst, hdb_handle_t handle)
|
|
{
|
|
struct list_head *iter, *iter_next;
|
|
struct cpg_iteration_instance_t *cpg_iteration_instance;
|
|
|
|
/*
|
|
* Traverse thru iteration instances and delete them
|
|
*/
|
|
for (iter = cpg_inst->iteration_list_head.next; iter != &cpg_inst->iteration_list_head;iter = iter_next) {
|
|
iter_next = iter->next;
|
|
|
|
cpg_iteration_instance = list_entry (iter, struct cpg_iteration_instance_t, list);
|
|
|
|
cpg_iteration_instance_finalize (cpg_iteration_instance);
|
|
}
|
|
hdb_handle_destroy (&cpg_handle_t_db, handle);
|
|
}
|
|
|
|
/**
|
|
* @defgroup cpg_coroipcc The closed process group API
|
|
* @ingroup coroipcc
|
|
*
|
|
* @{
|
|
*/
|
|
|
|
cs_error_t cpg_initialize (
|
|
cpg_handle_t *handle,
|
|
cpg_callbacks_t *callbacks)
|
|
{
|
|
cs_error_t error;
|
|
struct cpg_inst *cpg_inst;
|
|
|
|
error = hdb_error_to_cs (hdb_handle_create (&cpg_handle_t_db, sizeof (struct cpg_inst), handle));
|
|
if (error != CS_OK) {
|
|
goto error_no_destroy;
|
|
}
|
|
|
|
error = hdb_error_to_cs (hdb_handle_get (&cpg_handle_t_db, *handle, (void *)&cpg_inst));
|
|
if (error != CS_OK) {
|
|
goto error_destroy;
|
|
}
|
|
|
|
error = coroipcc_service_connect (
|
|
COROSYNC_SOCKET_NAME,
|
|
CPG_SERVICE,
|
|
IPC_REQUEST_SIZE,
|
|
IPC_RESPONSE_SIZE,
|
|
IPC_DISPATCH_SIZE,
|
|
&cpg_inst->handle);
|
|
if (error != CS_OK) {
|
|
goto error_put_destroy;
|
|
}
|
|
|
|
if (callbacks) {
|
|
memcpy (&cpg_inst->callbacks, callbacks, sizeof (cpg_callbacks_t));
|
|
}
|
|
|
|
list_init(&cpg_inst->iteration_list_head);
|
|
|
|
hdb_handle_put (&cpg_handle_t_db, *handle);
|
|
|
|
return (CS_OK);
|
|
|
|
error_put_destroy:
|
|
hdb_handle_put (&cpg_handle_t_db, *handle);
|
|
error_destroy:
|
|
hdb_handle_destroy (&cpg_handle_t_db, *handle);
|
|
error_no_destroy:
|
|
return (error);
|
|
}
|
|
|
|
cs_error_t cpg_finalize (
|
|
cpg_handle_t handle)
|
|
{
|
|
struct cpg_inst *cpg_inst;
|
|
cs_error_t error;
|
|
|
|
error = hdb_error_to_cs (hdb_handle_get (&cpg_handle_t_db, handle, (void *)&cpg_inst));
|
|
if (error != CS_OK) {
|
|
return (error);
|
|
}
|
|
|
|
/*
|
|
* Another thread has already started finalizing
|
|
*/
|
|
if (cpg_inst->finalize) {
|
|
hdb_handle_put (&cpg_handle_t_db, handle);
|
|
return (CPG_ERR_BAD_HANDLE);
|
|
}
|
|
|
|
cpg_inst->finalize = 1;
|
|
|
|
coroipcc_service_disconnect (cpg_inst->handle);
|
|
|
|
cpg_inst_finalize (cpg_inst, handle);
|
|
hdb_handle_put (&cpg_handle_t_db, handle);
|
|
|
|
return (CPG_OK);
|
|
}
|
|
|
|
cs_error_t cpg_fd_get (
|
|
cpg_handle_t handle,
|
|
int *fd)
|
|
{
|
|
cs_error_t error;
|
|
struct cpg_inst *cpg_inst;
|
|
|
|
error = hdb_error_to_cs (hdb_handle_get (&cpg_handle_t_db, handle, (void *)&cpg_inst));
|
|
if (error != CS_OK) {
|
|
return (error);
|
|
}
|
|
|
|
error = coroipcc_fd_get (cpg_inst->handle, fd);
|
|
|
|
hdb_handle_put (&cpg_handle_t_db, handle);
|
|
|
|
return (error);
|
|
}
|
|
|
|
cs_error_t cpg_context_get (
|
|
cpg_handle_t handle,
|
|
void **context)
|
|
{
|
|
cs_error_t error;
|
|
struct cpg_inst *cpg_inst;
|
|
|
|
error = hdb_error_to_cs (hdb_handle_get (&cpg_handle_t_db, handle, (void *)&cpg_inst));
|
|
if (error != CS_OK) {
|
|
return (error);
|
|
}
|
|
|
|
*context = cpg_inst->context;
|
|
|
|
hdb_handle_put (&cpg_handle_t_db, handle);
|
|
|
|
return (CS_OK);
|
|
}
|
|
|
|
cs_error_t cpg_context_set (
|
|
cpg_handle_t handle,
|
|
void *context)
|
|
{
|
|
cs_error_t error;
|
|
struct cpg_inst *cpg_inst;
|
|
|
|
error = hdb_error_to_cs (hdb_handle_get (&cpg_handle_t_db, handle, (void *)&cpg_inst));
|
|
if (error != CS_OK) {
|
|
return (error);
|
|
}
|
|
|
|
cpg_inst->context = context;
|
|
|
|
hdb_handle_put (&cpg_handle_t_db, handle);
|
|
|
|
return (CS_OK);
|
|
}
|
|
|
|
cs_error_t cpg_dispatch (
|
|
cpg_handle_t handle,
|
|
cs_dispatch_flags_t dispatch_types)
|
|
{
|
|
int timeout = -1;
|
|
cs_error_t error;
|
|
int cont = 1; /* always continue do loop except when set to 0 */
|
|
struct cpg_inst *cpg_inst;
|
|
struct res_lib_cpg_confchg_callback *res_cpg_confchg_callback;
|
|
struct res_lib_cpg_deliver_callback *res_cpg_deliver_callback;
|
|
cpg_callbacks_t callbacks;
|
|
coroipc_response_header_t *dispatch_data;
|
|
int ignore_dispatch = 0;
|
|
struct cpg_address member_list[CPG_MEMBERS_MAX];
|
|
struct cpg_address left_list[CPG_MEMBERS_MAX];
|
|
struct cpg_address joined_list[CPG_MEMBERS_MAX];
|
|
struct cpg_name group_name;
|
|
mar_cpg_address_t *left_list_start;
|
|
mar_cpg_address_t *joined_list_start;
|
|
unsigned int i;
|
|
|
|
error = hdb_error_to_cs (hdb_handle_get (&cpg_handle_t_db, handle, (void *)&cpg_inst));
|
|
if (error != CS_OK) {
|
|
return (error);
|
|
}
|
|
|
|
/*
|
|
* Timeout instantly for SA_DISPATCH_ONE or SA_DISPATCH_ALL and
|
|
* wait indefinately for SA_DISPATCH_BLOCKING
|
|
*/
|
|
if (dispatch_types == CPG_DISPATCH_ALL) {
|
|
timeout = 0;
|
|
}
|
|
|
|
do {
|
|
error = coroipcc_dispatch_get (
|
|
cpg_inst->handle,
|
|
(void **)&dispatch_data,
|
|
timeout);
|
|
if (error == CS_ERR_BAD_HANDLE) {
|
|
error = CS_OK;
|
|
goto error_put;
|
|
}
|
|
if (error == CS_ERR_TRY_AGAIN) {
|
|
error = CS_OK;
|
|
if (dispatch_types == CPG_DISPATCH_ALL) {
|
|
break; /* exit do while cont is 1 loop */
|
|
} else {
|
|
continue; /* next poll */
|
|
}
|
|
}
|
|
if (error != CS_OK) {
|
|
goto error_put;
|
|
}
|
|
|
|
/*
|
|
* Make copy of callbacks, message data, unlock instance, and call callback
|
|
* A risk of this dispatch method is that the callback routines may
|
|
* operate at the same time that cpgFinalize has been called.
|
|
*/
|
|
memcpy (&callbacks, &cpg_inst->callbacks, sizeof (cpg_callbacks_t));
|
|
/*
|
|
* Dispatch incoming message
|
|
*/
|
|
switch (dispatch_data->id) {
|
|
case MESSAGE_RES_CPG_DELIVER_CALLBACK:
|
|
if (callbacks.cpg_deliver_fn == NULL) {
|
|
continue;
|
|
}
|
|
|
|
res_cpg_deliver_callback = (struct res_lib_cpg_deliver_callback *)dispatch_data;
|
|
|
|
marshall_from_mar_cpg_name_t (
|
|
&group_name,
|
|
&res_cpg_deliver_callback->group_name);
|
|
|
|
callbacks.cpg_deliver_fn (handle,
|
|
&group_name,
|
|
res_cpg_deliver_callback->nodeid,
|
|
res_cpg_deliver_callback->pid,
|
|
&res_cpg_deliver_callback->message,
|
|
res_cpg_deliver_callback->msglen);
|
|
break;
|
|
|
|
case MESSAGE_RES_CPG_CONFCHG_CALLBACK:
|
|
if (callbacks.cpg_confchg_fn == NULL) {
|
|
continue;
|
|
}
|
|
|
|
res_cpg_confchg_callback = (struct res_lib_cpg_confchg_callback *)dispatch_data;
|
|
|
|
for (i = 0; i < res_cpg_confchg_callback->member_list_entries; i++) {
|
|
marshall_from_mar_cpg_address_t (&member_list[i],
|
|
&res_cpg_confchg_callback->member_list[i]);
|
|
}
|
|
left_list_start = res_cpg_confchg_callback->member_list +
|
|
res_cpg_confchg_callback->member_list_entries;
|
|
for (i = 0; i < res_cpg_confchg_callback->left_list_entries; i++) {
|
|
marshall_from_mar_cpg_address_t (&left_list[i],
|
|
&left_list_start[i]);
|
|
}
|
|
joined_list_start = res_cpg_confchg_callback->member_list +
|
|
res_cpg_confchg_callback->member_list_entries +
|
|
res_cpg_confchg_callback->left_list_entries;
|
|
for (i = 0; i < res_cpg_confchg_callback->joined_list_entries; i++) {
|
|
marshall_from_mar_cpg_address_t (&joined_list[i],
|
|
&joined_list_start[i]);
|
|
}
|
|
marshall_from_mar_cpg_name_t (
|
|
&group_name,
|
|
&res_cpg_confchg_callback->group_name);
|
|
|
|
callbacks.cpg_confchg_fn (handle,
|
|
&group_name,
|
|
member_list,
|
|
res_cpg_confchg_callback->member_list_entries,
|
|
left_list,
|
|
res_cpg_confchg_callback->left_list_entries,
|
|
joined_list,
|
|
res_cpg_confchg_callback->joined_list_entries);
|
|
break;
|
|
|
|
default:
|
|
coroipcc_dispatch_put (cpg_inst->handle);
|
|
error = CS_ERR_LIBRARY;
|
|
goto error_put;
|
|
break;
|
|
}
|
|
coroipcc_dispatch_put (cpg_inst->handle);
|
|
|
|
/*
|
|
* Determine if more messages should be processed
|
|
* */
|
|
switch (dispatch_types) {
|
|
case CPG_DISPATCH_ONE:
|
|
if (ignore_dispatch) {
|
|
ignore_dispatch = 0;
|
|
} else {
|
|
cont = 0;
|
|
}
|
|
break;
|
|
case CPG_DISPATCH_ALL:
|
|
if (ignore_dispatch) {
|
|
ignore_dispatch = 0;
|
|
}
|
|
break;
|
|
case CPG_DISPATCH_BLOCKING:
|
|
break;
|
|
}
|
|
} while (cont);
|
|
|
|
error_put:
|
|
hdb_handle_put (&cpg_handle_t_db, handle);
|
|
return (error);
|
|
}
|
|
|
|
cs_error_t cpg_join (
|
|
cpg_handle_t handle,
|
|
const struct cpg_name *group)
|
|
{
|
|
cs_error_t error;
|
|
struct cpg_inst *cpg_inst;
|
|
struct iovec iov[2];
|
|
struct req_lib_cpg_join req_lib_cpg_join;
|
|
struct res_lib_cpg_join res_lib_cpg_join;
|
|
|
|
error = hdb_error_to_cs (hdb_handle_get (&cpg_handle_t_db, handle, (void *)&cpg_inst));
|
|
if (error != CS_OK) {
|
|
return (error);
|
|
}
|
|
|
|
/* Now join */
|
|
req_lib_cpg_join.header.size = sizeof (struct req_lib_cpg_join);
|
|
req_lib_cpg_join.header.id = MESSAGE_REQ_CPG_JOIN;
|
|
req_lib_cpg_join.pid = getpid();
|
|
marshall_to_mar_cpg_name_t (&req_lib_cpg_join.group_name,
|
|
group);
|
|
|
|
iov[0].iov_base = (void *)&req_lib_cpg_join;
|
|
iov[0].iov_len = sizeof (struct req_lib_cpg_join);
|
|
|
|
do {
|
|
error = coroipcc_msg_send_reply_receive (cpg_inst->handle, iov, 1,
|
|
&res_lib_cpg_join, sizeof (struct res_lib_cpg_join));
|
|
|
|
if (error != CS_OK) {
|
|
goto error_exit;
|
|
}
|
|
} while (res_lib_cpg_join.header.error == CPG_ERR_BUSY);
|
|
|
|
error = res_lib_cpg_join.header.error;
|
|
|
|
error_exit:
|
|
hdb_handle_put (&cpg_handle_t_db, handle);
|
|
|
|
return (error);
|
|
}
|
|
|
|
cs_error_t cpg_leave (
|
|
cpg_handle_t handle,
|
|
const struct cpg_name *group)
|
|
{
|
|
cs_error_t error;
|
|
struct cpg_inst *cpg_inst;
|
|
struct iovec iov[2];
|
|
struct req_lib_cpg_leave req_lib_cpg_leave;
|
|
struct res_lib_cpg_leave res_lib_cpg_leave;
|
|
|
|
error = hdb_error_to_cs (hdb_handle_get (&cpg_handle_t_db, handle, (void *)&cpg_inst));
|
|
if (error != CS_OK) {
|
|
return (error);
|
|
}
|
|
|
|
req_lib_cpg_leave.header.size = sizeof (struct req_lib_cpg_leave);
|
|
req_lib_cpg_leave.header.id = MESSAGE_REQ_CPG_LEAVE;
|
|
req_lib_cpg_leave.pid = getpid();
|
|
marshall_to_mar_cpg_name_t (&req_lib_cpg_leave.group_name,
|
|
group);
|
|
|
|
iov[0].iov_base = (void *)&req_lib_cpg_leave;
|
|
iov[0].iov_len = sizeof (struct req_lib_cpg_leave);
|
|
|
|
do {
|
|
error = coroipcc_msg_send_reply_receive (cpg_inst->handle, iov, 1,
|
|
&res_lib_cpg_leave, sizeof (struct res_lib_cpg_leave));
|
|
|
|
if (error != CS_OK) {
|
|
goto error_exit;
|
|
}
|
|
} while (res_lib_cpg_leave.header.error == CPG_ERR_BUSY);
|
|
|
|
error = res_lib_cpg_leave.header.error;
|
|
|
|
error_exit:
|
|
hdb_handle_put (&cpg_handle_t_db, handle);
|
|
|
|
return (error);
|
|
}
|
|
|
|
cs_error_t cpg_membership_get (
|
|
cpg_handle_t handle,
|
|
struct cpg_name *group_name,
|
|
struct cpg_address *member_list,
|
|
int *member_list_entries)
|
|
{
|
|
cs_error_t error;
|
|
struct cpg_inst *cpg_inst;
|
|
struct iovec iov;
|
|
struct req_lib_cpg_membership req_lib_cpg_membership_get;
|
|
struct res_lib_cpg_confchg_callback res_lib_cpg_membership_get;
|
|
unsigned int i;
|
|
|
|
error = hdb_error_to_cs (hdb_handle_get (&cpg_handle_t_db, handle, (void *)&cpg_inst));
|
|
if (error != CS_OK) {
|
|
return (error);
|
|
}
|
|
|
|
req_lib_cpg_membership_get.header.size = sizeof (coroipc_request_header_t);
|
|
req_lib_cpg_membership_get.header.id = MESSAGE_REQ_CPG_MEMBERSHIP;
|
|
|
|
iov.iov_base = (void *)&req_lib_cpg_membership_get;
|
|
iov.iov_len = sizeof (coroipc_request_header_t);
|
|
|
|
do {
|
|
error = coroipcc_msg_send_reply_receive (cpg_inst->handle, &iov, 1,
|
|
&res_lib_cpg_membership_get, sizeof (coroipc_response_header_t));
|
|
|
|
if (error != CS_OK) {
|
|
goto error_exit;
|
|
}
|
|
} while (res_lib_cpg_membership_get.header.error == CPG_ERR_BUSY);
|
|
|
|
error = res_lib_cpg_membership_get.header.error;
|
|
|
|
/*
|
|
* Copy results to caller
|
|
*/
|
|
*member_list_entries = res_lib_cpg_membership_get.member_list_entries;
|
|
if (member_list) {
|
|
for (i = 0; i < res_lib_cpg_membership_get.member_list_entries; i++) {
|
|
marshall_from_mar_cpg_address_t (&member_list[i],
|
|
&res_lib_cpg_membership_get.member_list[i]);
|
|
}
|
|
}
|
|
|
|
error_exit:
|
|
hdb_handle_put (&cpg_handle_t_db, handle);
|
|
|
|
return (error);
|
|
}
|
|
|
|
cs_error_t cpg_local_get (
|
|
cpg_handle_t handle,
|
|
unsigned int *local_nodeid)
|
|
{
|
|
cs_error_t error;
|
|
struct cpg_inst *cpg_inst;
|
|
struct iovec iov;
|
|
struct req_lib_cpg_local_get req_lib_cpg_local_get;
|
|
struct res_lib_cpg_local_get res_lib_cpg_local_get;
|
|
|
|
error = hdb_error_to_cs (hdb_handle_get (&cpg_handle_t_db, handle, (void *)&cpg_inst));
|
|
if (error != CS_OK) {
|
|
return (error);
|
|
}
|
|
|
|
req_lib_cpg_local_get.header.size = sizeof (coroipc_request_header_t);
|
|
req_lib_cpg_local_get.header.id = MESSAGE_REQ_CPG_LOCAL_GET;
|
|
|
|
iov.iov_base = (void *)&req_lib_cpg_local_get;
|
|
iov.iov_len = sizeof (struct req_lib_cpg_local_get);
|
|
|
|
error = coroipcc_msg_send_reply_receive (cpg_inst->handle, &iov, 1,
|
|
&res_lib_cpg_local_get, sizeof (res_lib_cpg_local_get));
|
|
|
|
if (error != CS_OK) {
|
|
goto error_exit;
|
|
}
|
|
|
|
error = res_lib_cpg_local_get.header.error;
|
|
|
|
*local_nodeid = res_lib_cpg_local_get.local_nodeid;
|
|
|
|
error_exit:
|
|
hdb_handle_put (&cpg_handle_t_db, handle);
|
|
|
|
return (error);
|
|
}
|
|
|
|
cs_error_t cpg_flow_control_state_get (
|
|
cpg_handle_t handle,
|
|
cpg_flow_control_state_t *flow_control_state)
|
|
{
|
|
cs_error_t error;
|
|
struct cpg_inst *cpg_inst;
|
|
|
|
error = hdb_error_to_cs (hdb_handle_get (&cpg_handle_t_db, handle, (void *)&cpg_inst));
|
|
if (error != CS_OK) {
|
|
return (error);
|
|
}
|
|
|
|
error = coroipcc_dispatch_flow_control_get (cpg_inst->handle, (unsigned int *)flow_control_state);
|
|
|
|
hdb_handle_put (&cpg_handle_t_db, handle);
|
|
|
|
return (error);
|
|
}
|
|
|
|
cs_error_t cpg_zcb_alloc (
|
|
cpg_handle_t handle,
|
|
size_t size,
|
|
void **buffer)
|
|
{
|
|
cs_error_t error;
|
|
struct cpg_inst *cpg_inst;
|
|
|
|
error = hdb_error_to_cs (hdb_handle_get (&cpg_handle_t_db, handle, (void *)&cpg_inst));
|
|
if (error != CS_OK) {
|
|
return (error);
|
|
}
|
|
|
|
error = coroipcc_zcb_alloc (cpg_inst->handle,
|
|
buffer,
|
|
size,
|
|
sizeof (struct req_lib_cpg_mcast));
|
|
|
|
hdb_handle_put (&cpg_handle_t_db, handle);
|
|
*buffer = ((char *)*buffer) + sizeof (struct req_lib_cpg_mcast);
|
|
|
|
return (error);
|
|
}
|
|
|
|
cs_error_t cpg_zcb_free (
|
|
cpg_handle_t handle,
|
|
void *buffer)
|
|
{
|
|
cs_error_t error;
|
|
struct cpg_inst *cpg_inst;
|
|
|
|
error = hdb_error_to_cs (hdb_handle_get (&cpg_handle_t_db, handle, (void *)&cpg_inst));
|
|
if (error != CS_OK) {
|
|
return (error);
|
|
}
|
|
|
|
coroipcc_zcb_free (cpg_inst->handle, ((char *)buffer) - sizeof (struct req_lib_cpg_mcast));
|
|
|
|
hdb_handle_put (&cpg_handle_t_db, handle);
|
|
|
|
return (error);
|
|
}
|
|
|
|
cs_error_t cpg_zcb_mcast_joined (
|
|
cpg_handle_t handle,
|
|
cpg_guarantee_t guarantee,
|
|
void *msg,
|
|
size_t msg_len)
|
|
{
|
|
cs_error_t error;
|
|
struct cpg_inst *cpg_inst;
|
|
struct req_lib_cpg_mcast *req_lib_cpg_mcast;
|
|
struct res_lib_cpg_mcast res_lib_cpg_mcast;
|
|
|
|
error = hdb_error_to_cs (hdb_handle_get (&cpg_handle_t_db, handle, (void *)&cpg_inst));
|
|
if (error != CS_OK) {
|
|
return (error);
|
|
}
|
|
|
|
req_lib_cpg_mcast = (struct req_lib_cpg_mcast *)(((char *)msg) - sizeof (struct req_lib_cpg_mcast));
|
|
req_lib_cpg_mcast->header.size = sizeof (struct req_lib_cpg_mcast) +
|
|
msg_len;
|
|
|
|
req_lib_cpg_mcast->header.id = MESSAGE_REQ_CPG_MCAST;
|
|
req_lib_cpg_mcast->guarantee = guarantee;
|
|
req_lib_cpg_mcast->msglen = msg_len;
|
|
|
|
error = coroipcc_zcb_msg_send_reply_receive (
|
|
cpg_inst->handle,
|
|
req_lib_cpg_mcast,
|
|
&res_lib_cpg_mcast,
|
|
sizeof (res_lib_cpg_mcast));
|
|
|
|
if (error != CS_OK) {
|
|
goto error_exit;
|
|
}
|
|
|
|
error = res_lib_cpg_mcast.header.error;
|
|
|
|
error_exit:
|
|
hdb_handle_put (&cpg_handle_t_db, handle);
|
|
|
|
return (error);
|
|
}
|
|
|
|
cs_error_t cpg_mcast_joined (
|
|
cpg_handle_t handle,
|
|
cpg_guarantee_t guarantee,
|
|
const struct iovec *iovec,
|
|
unsigned int iov_len)
|
|
{
|
|
int i;
|
|
cs_error_t error;
|
|
struct cpg_inst *cpg_inst;
|
|
struct iovec iov[64];
|
|
struct req_lib_cpg_mcast req_lib_cpg_mcast;
|
|
struct res_lib_cpg_mcast res_lib_cpg_mcast;
|
|
size_t msg_len = 0;
|
|
|
|
error = hdb_error_to_cs (hdb_handle_get (&cpg_handle_t_db, handle, (void *)&cpg_inst));
|
|
if (error != CS_OK) {
|
|
return (error);
|
|
}
|
|
|
|
for (i = 0; i < iov_len; i++ ) {
|
|
msg_len += iovec[i].iov_len;
|
|
}
|
|
|
|
req_lib_cpg_mcast.header.size = sizeof (struct req_lib_cpg_mcast) +
|
|
msg_len;
|
|
|
|
req_lib_cpg_mcast.header.id = MESSAGE_REQ_CPG_MCAST;
|
|
req_lib_cpg_mcast.guarantee = guarantee;
|
|
req_lib_cpg_mcast.msglen = msg_len;
|
|
|
|
iov[0].iov_base = (void *)&req_lib_cpg_mcast;
|
|
iov[0].iov_len = sizeof (struct req_lib_cpg_mcast);
|
|
memcpy (&iov[1], iovec, iov_len * sizeof (struct iovec));
|
|
|
|
error = coroipcc_msg_send_reply_receive (cpg_inst->handle, iov,
|
|
iov_len + 1, &res_lib_cpg_mcast, sizeof (res_lib_cpg_mcast));
|
|
|
|
if (error != CS_OK) {
|
|
goto error_exit;
|
|
}
|
|
|
|
error = res_lib_cpg_mcast.header.error;
|
|
|
|
error_exit:
|
|
hdb_handle_put (&cpg_handle_t_db, handle);
|
|
|
|
return (error);
|
|
}
|
|
|
|
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)
|
|
{
|
|
cs_error_t error;
|
|
struct iovec iov;
|
|
struct cpg_inst *cpg_inst;
|
|
struct cpg_iteration_instance_t *cpg_iteration_instance;
|
|
struct req_lib_cpg_iterationinitialize req_lib_cpg_iterationinitialize;
|
|
struct res_lib_cpg_iterationinitialize res_lib_cpg_iterationinitialize;
|
|
|
|
if (cpg_iteration_handle == NULL) {
|
|
return (CS_ERR_INVALID_PARAM);
|
|
}
|
|
|
|
if ((iteration_type == CPG_ITERATION_ONE_GROUP && group == NULL) ||
|
|
(iteration_type != CPG_ITERATION_ONE_GROUP && group != NULL)) {
|
|
return (CS_ERR_INVALID_PARAM);
|
|
}
|
|
|
|
if (iteration_type != CPG_ITERATION_NAME_ONLY && iteration_type != CPG_ITERATION_ONE_GROUP &&
|
|
iteration_type != CPG_ITERATION_ALL) {
|
|
|
|
return (CS_ERR_INVALID_PARAM);
|
|
}
|
|
|
|
error = hdb_error_to_cs (hdb_handle_get (&cpg_handle_t_db, handle, (void *)&cpg_inst));
|
|
if (error != CS_OK) {
|
|
return (error);
|
|
}
|
|
|
|
error = hdb_error_to_cs (hdb_handle_create (&cpg_iteration_handle_t_db,
|
|
sizeof (struct cpg_iteration_instance_t), cpg_iteration_handle));
|
|
if (error != CS_OK) {
|
|
goto error_put_cpg_db;
|
|
}
|
|
|
|
error = hdb_error_to_cs (hdb_handle_get (&cpg_iteration_handle_t_db, *cpg_iteration_handle,
|
|
(void *)&cpg_iteration_instance));
|
|
if (error != CS_OK) {
|
|
goto error_destroy;
|
|
}
|
|
|
|
cpg_iteration_instance->conn_handle = cpg_inst->handle;
|
|
|
|
list_init (&cpg_iteration_instance->list);
|
|
|
|
req_lib_cpg_iterationinitialize.header.size = sizeof (struct req_lib_cpg_iterationinitialize);
|
|
req_lib_cpg_iterationinitialize.header.id = MESSAGE_REQ_CPG_ITERATIONINITIALIZE;
|
|
req_lib_cpg_iterationinitialize.iteration_type = iteration_type;
|
|
if (group) {
|
|
marshall_to_mar_cpg_name_t (&req_lib_cpg_iterationinitialize.group_name, group);
|
|
}
|
|
|
|
iov.iov_base = (void *)&req_lib_cpg_iterationinitialize;
|
|
iov.iov_len = sizeof (struct req_lib_cpg_iterationinitialize);
|
|
|
|
error = coroipcc_msg_send_reply_receive (cpg_inst->handle,
|
|
&iov,
|
|
1,
|
|
&res_lib_cpg_iterationinitialize,
|
|
sizeof (struct res_lib_cpg_iterationinitialize));
|
|
|
|
if (error != CS_OK) {
|
|
goto error_put_destroy;
|
|
}
|
|
|
|
cpg_iteration_instance->executive_iteration_handle =
|
|
res_lib_cpg_iterationinitialize.iteration_handle;
|
|
cpg_iteration_instance->cpg_iteration_handle = *cpg_iteration_handle;
|
|
|
|
list_add (&cpg_iteration_instance->list, &cpg_inst->iteration_list_head);
|
|
|
|
hdb_handle_put (&cpg_iteration_handle_t_db, *cpg_iteration_handle);
|
|
hdb_handle_put (&cpg_handle_t_db, handle);
|
|
|
|
return (res_lib_cpg_iterationinitialize.header.error);
|
|
|
|
error_put_destroy:
|
|
hdb_handle_put (&cpg_iteration_handle_t_db, *cpg_iteration_handle);
|
|
error_destroy:
|
|
hdb_handle_destroy (&cpg_iteration_handle_t_db, *cpg_iteration_handle);
|
|
error_put_cpg_db:
|
|
hdb_handle_put (&cpg_handle_t_db, handle);
|
|
|
|
return (error);
|
|
}
|
|
|
|
cs_error_t cpg_iteration_next(
|
|
cpg_iteration_handle_t handle,
|
|
struct cpg_iteration_description_t *description)
|
|
{
|
|
cs_error_t error;
|
|
struct cpg_iteration_instance_t *cpg_iteration_instance;
|
|
struct req_lib_cpg_iterationnext req_lib_cpg_iterationnext;
|
|
struct res_lib_cpg_iterationnext *res_lib_cpg_iterationnext;
|
|
struct iovec iov;
|
|
void *return_address;
|
|
|
|
if (description == NULL) {
|
|
return CS_ERR_INVALID_PARAM;
|
|
}
|
|
|
|
error = hdb_error_to_cs (hdb_handle_get (&cpg_iteration_handle_t_db, handle,
|
|
(void *)&cpg_iteration_instance));
|
|
if (error != CS_OK) {
|
|
goto error_exit;
|
|
}
|
|
|
|
req_lib_cpg_iterationnext.header.size = sizeof (struct req_lib_cpg_iterationnext);
|
|
req_lib_cpg_iterationnext.header.id = MESSAGE_REQ_CPG_ITERATIONNEXT;
|
|
req_lib_cpg_iterationnext.iteration_handle = cpg_iteration_instance->executive_iteration_handle;
|
|
|
|
iov.iov_base = (void *)&req_lib_cpg_iterationnext;
|
|
iov.iov_len = sizeof (struct req_lib_cpg_iterationnext);
|
|
|
|
error = coroipcc_msg_send_reply_receive_in_buf_get (cpg_iteration_instance->conn_handle,
|
|
&iov,
|
|
1,
|
|
&return_address);
|
|
res_lib_cpg_iterationnext = return_address;
|
|
|
|
if (error != CS_OK) {
|
|
goto error_put;
|
|
}
|
|
|
|
marshall_from_mar_cpg_iteration_description_t(
|
|
description,
|
|
&res_lib_cpg_iterationnext->description);
|
|
|
|
error = res_lib_cpg_iterationnext->header.error;
|
|
|
|
coroipcc_msg_send_reply_receive_in_buf_put(
|
|
cpg_iteration_instance->conn_handle);
|
|
|
|
error_put:
|
|
hdb_handle_put (&cpg_iteration_handle_t_db, handle);
|
|
|
|
error_exit:
|
|
return (error);
|
|
}
|
|
|
|
cs_error_t cpg_iteration_finalize (
|
|
cpg_iteration_handle_t handle)
|
|
{
|
|
cs_error_t error;
|
|
struct iovec iov;
|
|
struct cpg_iteration_instance_t *cpg_iteration_instance;
|
|
struct req_lib_cpg_iterationfinalize req_lib_cpg_iterationfinalize;
|
|
struct res_lib_cpg_iterationfinalize res_lib_cpg_iterationfinalize;
|
|
|
|
error = hdb_error_to_cs (hdb_handle_get (&cpg_iteration_handle_t_db, handle,
|
|
(void *)&cpg_iteration_instance));
|
|
if (error != CS_OK) {
|
|
goto error_exit;
|
|
}
|
|
|
|
req_lib_cpg_iterationfinalize.header.size = sizeof (struct req_lib_cpg_iterationfinalize);
|
|
req_lib_cpg_iterationfinalize.header.id = MESSAGE_REQ_CPG_ITERATIONFINALIZE;
|
|
req_lib_cpg_iterationfinalize.iteration_handle = cpg_iteration_instance->executive_iteration_handle;
|
|
|
|
iov.iov_base = (void *)&req_lib_cpg_iterationfinalize;
|
|
iov.iov_len = sizeof (struct req_lib_cpg_iterationfinalize);
|
|
|
|
error = coroipcc_msg_send_reply_receive (cpg_iteration_instance->conn_handle,
|
|
&iov,
|
|
1,
|
|
&res_lib_cpg_iterationfinalize,
|
|
sizeof (struct req_lib_cpg_iterationfinalize));
|
|
|
|
if (error != CS_OK) {
|
|
goto error_put;
|
|
}
|
|
|
|
cpg_iteration_instance_finalize (cpg_iteration_instance);
|
|
hdb_handle_put (&cpg_iteration_handle_t_db, cpg_iteration_instance->cpg_iteration_handle);
|
|
|
|
return (res_lib_cpg_iterationfinalize.header.error);
|
|
|
|
error_put:
|
|
hdb_handle_put (&cpg_iteration_handle_t_db, handle);
|
|
error_exit:
|
|
return (error);
|
|
}
|
|
|
|
/** @} */
|