cmsclient_types.h

在LINUX下实现HA的源代码

/*
 * cmsclient_types.h: cms daemon and client library types header
 *
 * Copyright (c) 2004 Intel Corp.
 *
 * Author: Zou Yixiong ([e-mail])
 * Author: Zhu Yi ([e-mail])
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
 *
 */
#ifndef __CMSCLIENT_TYPES_H__
#define __CMSCLIENT_TYPES_H__

#ifdef HAVE_CONFIG_H
#include <config.h>
#endif

/*
 * Note: modify together with cmsrequest_type_str
 * at the same time.
 */
#define	CMS_TYPE_TOTAL			19

#define	CMS_QUEUE_STATUS		(1 << 0)
#define	CMS_QUEUE_OPEN 			(1 << 1)
#define	CMS_QUEUE_OPEN_ASYNC		(1 << 2)
#define	CMS_QUEUE_CLOSE			(1 << 3)
#define	CMS_QUEUE_UNLINK		(1 << 4)
#define	CMS_MSG_SEND			(1 << 5)
#define	CMS_MSG_SEND_ASYNC		(1 << 6)
#define	CMS_MSG_ACK			(1 << 7)
#define	CMS_MSG_GET			(1 << 8)
#define	CMS_MSG_RECEIVED_GET		(1 << 9)
#define	CMS_QUEUEGROUP_CREATE		(1 << 10)
#define	CMS_QUEUEGROUP_DELETE		(1 << 11)
#define	CMS_QUEUEGROUP_INSERT		(1 << 12)
#define	CMS_QUEUEGROUP_REMOVE		(1 << 13)
#define	CMS_QUEUEGROUP_TRACK_START	(1 << 14)
#define	CMS_QUEUEGROUP_TRACK_STOP	(1 << 15)
#define	CMS_QUEUEGROUP_NOTIFY		(1 << 16)
#define	CMS_MSG_NOTIFY			(1 << 17)
#define	CMS_MSG_REQUEST			(1 << 18)


#define CMS_DOMAIN_SOCKET	HA_VARLIBDIR "/heartbeat/cms/cms"

typedef struct {

	GList * opened_mqueue_list;
			/* mqueue or mqgroup list opened by this client */
	int channel_count;
	 		/* channel count for this farside_pid */
} cms_client_t ;


typedef struct {
	size_t	 	type;
	size_t		len;
	SaErrorT	flag; /* used for msg reply */
	SaNameT		name; /* mqueue or mqgroup name for this request */

} client_header_t;


typedef struct {
	client_header_t		header;
	SaMsgQueueStatusT	qstatus;

} client_mqueue_status_t;


typedef struct {
	client_header_t 		header;
	SaMsgQueueCreationAttributesT	attr;
	SaMsgQueueOpenFlagsT		openflag;
	SaMsgQueueHandleT		handle;
	SaTimeT				timeout;
	SaInvocationT			invocation;/* only used by open_async */
	SaMsgQueueGroupPolicyT		policy;

} client_mqueue_open_t;


typedef struct {
	client_header_t		header;
	SaMsgQueueHandleT	handle;
	gboolean		silent;

} client_mqueue_close_t;

typedef struct {
	client_header_t		header;
	SaMsgQueueHandleT	handle;

} client_mqueue_handle_t;


typedef client_mqueue_handle_t client_mqueue_notify_t;
typedef client_mqueue_handle_t client_mqueue_unlink_t;


typedef struct {
	client_header_t 	header;
	SaNameT			qgname;

} client_mqgroup_ops_t;


typedef struct {
	client_header_t 	header;
	SaNameT			group_name;
	SaUint8T		flag;

} client_mqgroup_mem_t;


typedef struct {
	client_header_t 	header;
	SaNameT			group_name;
	SaMsgQueueGroupPolicyT	policy;
	SaUint32T		number;
	void *			data;

} client_mqgroup_notify_t;


typedef struct {
	client_header_t		header;
	SaMsgQueueHandleT       handle;
	SaMsgMessageT		msg;
	SaInvocationT		invocation; /* only used by send_async */
	SaMsgAckFlagsT		ack;
	void * 			data;

} client_message_t;


typedef struct {
	client_header_t		header;
	SaMsgQueueHandleT	handle;
	SaInvocationT		invocation; /* only used by send_async */
	size_t			send_type;

} client_message_ack_t;


typedef struct {
	IPC_Channel *ch;
	SaUint8T flag;

} client_mqgroup_track_t;


#endif	/* __CMSCLIENT_TYPES_H__ */