ais_event.h

linux集群服务器软件代码包

#ifndef _AIS_EVENT_H_
#define _AIS_EVENT_H_ 

#include "ais_base.h"


/* Chapter 8 */
#ifdef __CPLUSPLUS
extern "C"{
#endif

typedef SaUint32T SaEvtHandleT;
typedef SaUint32T SaEvtEventHandleT;
typedef SaUint32T SaEvtChannelHandleT;
typedef SaUint32T SaEvtSubscriptionIdT;


typedef void
(*SaEvtEventDeliverCallbackT)(SaEvtSubscriptionIdT subscriptionId,
                              const SaEvtEventHandleT eventHandle,
                              const SaSizeT eventDataSize);

typedef void (*SaEvtChannelOpenCallbackT)(SaInvocationT invocation,
		SaEvtChannelHandleT channelHandle,
		SaErrorT error);

typedef struct{
    SaEvtEventDeliverCallbackT saEvtEventDeliverCallback;
	SaEvtChannelOpenCallbackT saEvtChannelOpenCallback;
} SaEvtCallbacksT;

#define SA_EVT_CHANNEL_PUBLISHER  0X1
#define SA_EVT_CHANNEL_SUBSCRIBER 0X2
#define SA_EVT_CHANNEL_CREATE     0X4
typedef SaUint8T SaEvtChannelOpenFlagsT;

typedef struct {
    SaUint8T *pattern;
    SaSizeT patternSize;
} SaEvtEventPatternT;


#define SA_EVT_HIGHEST_PRIORITY 0
#define SA_EVT_LOWEST_PRIORITY  3

#define SA_EVT_LOST_EVENT "SA_EVT_LOST_EVENT_PATTERN"

typedef struct {
    SaEvtEventPatternT *patterns;
    SaSizeT patternsNumber;
} SaEvtEventPatternArrayT;

typedef SaUint8T SaEvtEventPriorityT;
typedef SaUint64T SaEvtEventIdT;

typedef enum {
    SA_EVT_PREFIX_FILTER = 1,
    SA_EVT_SUFFIX_FILTER = 2,
    SA_EVT_EXACT_FILTER = 3,
    SA_EVT_PASS_ALL_FILTER = 4
} SaEvtEventFilterTypeT;

typedef struct {
    SaEvtEventFilterTypeT filterType;
    SaEvtEventPatternT filter;
} SaEvtEventFilterT;

typedef struct {
    SaEvtEventFilterT *filters;
    SaSizeT filtersNumber;
} SaEvtEventFilterArrayT;

    SaErrorT 
saEvtInitialize(SaEvtHandleT *evtHandle, const SaEvtCallbacksT *callbacks,
                SaVersionT *version);

    SaErrorT 
saEvtSelectionObjectGet(SaEvtHandleT evtHandle,
                        SaSelectionObjectT *selectionObject);

    SaErrorT 
saEvtDispatch(const SaEvtHandleT evtHandle, SaDispatchFlagsT dispatchFlags);

    SaErrorT 
saEvtFinalize(SaEvtHandleT evtHandle);

    SaErrorT 
saEvtChannelOpen(const SaEvtHandleT evtHandle, const SaNameT *channelName,
         SaEvtChannelOpenFlagsT channelOpenFlags,
		 SaTimeT timeout,
		 SaEvtChannelHandleT *channelHandle);

	SaErrorT
saEvtChannelOpenAsync(
		SaEvtHandleT evtHandle,
		SaInvocationT invocation,
		const SaNameT *channelName,
		SaEvtChannelOpenFlagsT channelOpenFlags);


    SaErrorT 
saEvtChannelClose(SaEvtChannelHandleT channelHandle);

    SaErrorT 
saEvtEventAllocate(const SaEvtChannelHandleT channelHandle,
                   SaEvtEventHandleT *eventHandle);

    SaErrorT 
saEvtEventFree(SaEvtEventHandleT eventHandle);

    SaErrorT 
saEvtEventAttributesSet(const SaEvtEventHandleT eventHandle,
                        const SaEvtEventPatternArrayT *patternArray,
                        SaUint8T priority,
                        SaTimeT retentionTime,
                        const SaNameT *publisherName);

    SaErrorT 
saEvtEventAttributesGet(const SaEvtEventHandleT eventHandle,
                        SaEvtEventPatternArrayT *patternArray,
                        SaUint8T *priority,
                        SaTimeT *retentionTime,
                        SaNameT *publisherName,
                        SaTimeT *publishTime,
                        SaEvtEventIdT *eventId);

    SaErrorT 
saEvtEventDataGet(const SaEvtEventHandleT eventHandle,
                  void *eventData,
                  SaSizeT *eventDataSize);

    SaErrorT 
saEvtEventPublish(const SaEvtEventHandleT eventHandle,
                  const void *eventData,
                  SaSizeT eventDataSize,
				  SaEvtEventIdT *eventId);

    SaErrorT 
saEvtEventSubscribe(const SaEvtChannelHandleT channelHandle,
                    const SaEvtEventFilterArrayT *filters,
                    SaEvtSubscriptionIdT subscriptionId);

    SaErrorT 
saEvtEventUnsubscribe(const SaEvtChannelHandleT channelHandle,
                      SaEvtSubscriptionIdT subscriptionId);

SaErrorT saEvtChannelUnlink(SaEvtHandleT evtHandle,
				const SaNameT *channelName);

    SaErrorT 
saEvtEventRetentionTimeClear(SaEvtChannelHandleT channelHandle,
                             const SaEvtEventIdT eventHandle);
#ifdef __CPLUSPLUS
}
#endif

#endif /* _AIS_EVENT_H_ */