Doc:latest/evalguide/csa112 - Revision history

Prasad: /* How to Run csa212 and What to Observe */

2014-11-17T06:39:56Z

‎How to Run csa212 and What to Observe

Prasad: /* csa212 SA Forum Compliant Event Subscription */

2014-11-17T05:07:43Z

‎csa212 SA Forum Compliant Event Subscription

Prasad: /* Code */

2014-11-14T11:19:03Z

‎Code

Prasad: /* Code */

2014-11-14T11:09:10Z

‎Code

Show changes

Vnpraveendesu: /* Code */

2013-04-08T09:46:08Z

‎Code

Vnpraveendesu: /* Code */

2013-04-08T09:39:27Z

‎Code

Stone at 22:12, 21 January 2013

2013-01-21T22:12:54Z

Bot: 2 revisions

2011-10-24T19:02:15Z

2 revisions

Madhu at 08:05, 1 October 2010

2010-10-01T08:05:22Z

Show changes

Senthilk at 03:29, 27 August 2010

2010-08-27T03:29:16Z

New page

==csa112 Event Subscription==

===Objective===

The objective of csa112 is to learn how to use Clovis' event service to subscribe to events and to extract the relevant information from the events received by subscription.

===What you will learn===

You will learn
*how to initialize the event library
*how to subscribe to events
*how to receive events
*how to extract the event data

===Code===

One difference to note between this application and previous ones is that this application will not have a main loop in <code>clCompAppInitialize</code>. Instead we will do our work in callback code. This means that when we return from <code>clCompAppInitialize</code> we won't exit the application.

{| cellspacing="0" cellpadding = "0" border="0" align = "center" width="680"
! style="color:black;background-color:#ffccaa;" align="center"| clCompAppMain.c
|-
|<code><pre>
ClNameT evtChannelName = {
sizeof EVENT_CHANNEL_NAME - 1,
EVENT_CHANNEL_NAME
};

ClEventChannelHandleT evtChannelHandle = CL_HANDLE_INVALID_VALUE;
ClEventInitHandleT evtHandle = CL_HANDLE_INVALID_VALUE;

static void
csa112Comp_appEventCallback( ClEventSubscriptionIdT subscriptionId,
ClEventHandleT eventHandle,
ClSizeT eventDataSize);

</pre></code>
|}

Here we define variables to hold the payload of our event. Note the initialization of the <code>evtChannelName</code>. The length is set to the length of the <code>EVENT_CHANNEL_NAME</code> string WITHOUT including the <code>null</code> terminator.

{| cellspacing="0" cellpadding = "0" border="0" align = "center" width="680"
! style="color:black;background-color:#ffccaa;" align="center"| clCompAppMain.c
|-
|<code><pre>
ClRcT
clCompAppInitialize(ClUint32T argc,ClCharT *argv[])
{
....

ClEventCallbacksT evtCallbacks = {
NULL,
csa112Comp_appEventCallback
};

...

// publish our event callbacks
rc = clEventInitialize(&evtHandle, &evtCallbacks, &evtVersion);

...
</pre></code>
|}

We initialize the OpenClovis Event Manager with <code>clEventInitialize</code>. We pass the address of the variable where we want the event handle stored. We pass the address of our event callback functions structure. Note that the only event callback function that we specify is <code>csa112Comp_appEventCallback</code>. We do not specify the other callback which is the Asynchronous channel open callback. We specify <code>NULL</code> for that field of <code>evtCallbacks</code> because we don't open our event channel asynchronously.:

{| cellspacing="0" cellpadding = "0" border="0" align = "center" width="680"
! style="color:black;background-color:#ffccaa;" align="center"| clCompAppMain.c
|-
|<code><pre>
ClRcT
clCompAppInitialize(ClUint32T argc, ClCharT *argv[])
{

....

// Open an event chanel so that we can subscribe to events on that channel
rc = clEventChannelOpen(evtHandle,
&evtChannelName,
(CL_EVENT_CHANNEL_SUBSCRIBER |
CL_EVENT_GLOBAL_CHANNEL |
CL_EVENT_CHANNEL_CREATE),
(ClTimeT)CL_RMD_TIMEOUT_FOREVER,
&evtChannelHandle);
if (rc != CL_OK)
{
clprintf(CL_LOG_SEV_ERROR, "csa112\t:Failure opening event channel[0x%x]",
rc);
return rc;
}

rc = clEventExtSubscribe(evtChannelHandle, EVENT_TYPE, 1, (void*)0);
if (rc != CL_OK)
{
clprintf(CL_LOG_SEV_ERROR, "Failed to subscribe to event channel [0x%x]",
rc);
return rc;
}

</pre></code>
|}

Within the above code we open the channel synchronously. We pass the handle we got back from <code>clEventInitialize</code>, the channel name we defined previously, flags that indicate this process is subscribing to the channel and it's a global channel, and that the channel should be created if it's not already there, a timeout value of "forever", and the address of the location where the channel handle should be stored. Then, we subscribe to a specific event stream on the event channel. The <code>EVENT_TYPE</code> constant is defined in <code>common/common.h</code> as 5432. This value is used by the event publisher when it sends events. The constant 1 being passed simply identifies this specific subscription on this channel. This value will be passed to our event delivery callback function.

{| cellspacing="0" cellpadding = "0" border="0" align = "center" width="680"
! style="color:black;background-color:#ffccaa;" align="center"| clCompAppMain.c
|-
|<code><pre>
static void
csa112Comp_appEventCallback( ClEventSubscriptionIdT subscriptionId,
ClEventHandleT eventHandle,
ClSizeT eventDataSize)
{
ClRcT rc = CL_OK;
ClPtrT resTest = NULL;
ClSizeT resSize;
if (running == 0 || ha_state != CL_AMS_HA_STATE_ACTIVE)
{
goto cleanup;
}
clprintf(CL_LOG_SEV_NOTICE,"We've got an event to receive");

resTest = clHeapAllocate(eventDataSize + 1);
if (resTest == NULL)
{
clprintf(CL_LOG_SEV_ERROR, "Failed to allocate space for event");
goto cleanup;
}
*(((char *)resTest) + eventDataSize) = 0;
resSize = eventDataSize;
rc = clEventDataGet(eventHandle, resTest, &resSize);
if (rc != CL_OK)
{
clprintf(CL_LOG_SEV_ERROR, "Failed to get event data [0x%x]", rc);
clHeapFree(resTest);
goto cleanup;
}

clprintf(CL_LOG_SEV_NOTICE,"received event: %s", (char *)resTest);

cleanup:
//Free the memory associated with eventHandle
clEventFree(eventHandle);
}
</pre></code>
|}

The event delivery callback function is named <code>csa112Comp_appEventCallback</code>. First it checks that the running variable is not zero and that the High Availability State is <code>CL_AMS_HA_STATE_ACTIVE</code>, otherwise it returns, dropping the event in the bit bucket. Next it checks whether our incoming data buffer needs to be deallocated. If there is a buffer, it deallocates it and then allocates enough data to receive the incoming event data. Then, we extract the data from the event into the newly allocated buffer using <code>clEventDataGet</code>. Finally, we print the event data we received using <code>clprintf</code> which is another member of Clovis' OS Abstraction Layer. As its name and usage suggest, it is the OSAL replacement for printf.

===csa212 SA Forum Compliant Event Subscription===

csa212 demonstrates the usage of SA Forum's Event Service. This sample application does not deviate functionally from csa112. The differences in code are due to using SA Forum data types (structures) and APIs , as presented in the following two tables. (Note we have not repeated data types and APIs covered previously.)

{| cellspacing="0" border="1" align="center"
|+align="bottom"| '''SA Forum Data Types with the SAFplus Platform equivalent'''
|- style="color:black;background-color:#ffffaa;" align="center"
!SA Forum Data Types
!OpenClovis Data Types
|-
|SaEvtHandleT
|ClEventInitHandleT
|-
|SaEvtChannelHandleT
|ClEventChannelHandleT
|-
|SaEvtCallbacksT
|ClEventCallbacksT
|-
|SA_EVT_CHANNEL_SUBSCRIBER
|CL_EVENT_CHANNEL_SUBSCRIBER
|-
|SA_EVT_CHANNEL_CREATE
|CL_EVENT_CHANNEL_CREATE
|-
|SA_TIME_END
|CL_RMD_TIMEOUT_FOREVER
|}

{| cellspacing="0" border="1" align="center"
|+align="bottom"| '''SA Forum APIs with the SAFplus Platform equivalent'''
|- style="color:black;background-color:#ffffaa;" align="center"
!SA Forum APIs
!OpenClovis APIs
|-
|SaEvtInitialize
|ClEventInitialize
|-
|saEvtChannelOpen
|clEventChannelOpen
|-
|saEvtEventSubscribe
|clEventExtSubscribe
|-
|saEvtEventDataGet
|clEventDataGet
|-
|saEvtChannelClose
|clEventChannelClose
|-
|saEvtFinalize
|clEventFinalize
|}

===How to Run csa112 and What to Observe===

<ol>
<li>Start example csa112 in the same manner that we have started previous examples, with the SAFplus Platform Console.(Unlock csa212SGI0 instead of csa112SGI0 to run csa212).
<code><pre>
# cd /root/asp/bin
# ./asp_console

cli[Test]-> setc 1
cli[Test:SCNodeI0]-> setc cpm
cli[Test:SCNodeI0:CPM]-> amsLockAssignment sg csa112SGI0
</pre></code>

Looking at the log file for this example you should see the following.
{| cellspacing="0" cellpadding = "0" border="0" align = "center" width="680"
! style="color:black;background-color:#ffffaa;" align="center"| /root/asp/var/log/csa112CompI0Log.latest
|-
|<code><pre>
Mon Jul 14 21:59:49 2008 (SCNodeI0.24077 : csa112CompEO.---.---.00028 : INFO)
Component [csa112CompI0] : PID [24077]. Initializing
Mon Jul 14 21:59:49 2008 (SCNodeI0.24077 : csa112CompEO.---.---.00029 : INFO)
IOC Address : 0x1
Mon Jul 14 21:59:49 2008 (SCNodeI0.24077 : csa112CompEO.---.---.00030 : INFO)
IOC Port : 0x80
Mon Jul 14 21:59:49 2008 (SCNodeI0.24077 : csa112CompEO.---.---.00037 : INFO)
csa112: Instantiated as component instance csa112CompI0.
Mon Jul 14 21:59:49 2008 (SCNodeI0.24077 : csa112CompEO.---.---.00038 : INFO)
csa112CompI0: Waiting for CSI assignment...
</pre></code>
|}

<li>Now unlock the application with:
<code><pre>
cli[Test:SCNodeI0:CPM]-> amsUnlock sg csa112SGI0
</pre></code>

At this point you should see the following in the log.
{| cellspacing="0" cellpadding = "0" border="0" align = "center" width="680"
! style="color:black;background-color:#ffffaa;" align="center"| /root/asp/var/log/csa112CompI0Log.latest
|-
|<code><pre>
Mon Jul 14 22:01:29 2008 (SCNodeI0.24077 : csa112CompEO.---.---.00049 : INFO)
csa112: ACTIVE state requested; activating service
</pre></code>
|}

Thats all there is to this example. What you are looking at in the log is the output of our event listener. It doesn't appear very interesting because we have not yet written an event publisher that will give the program something to output. We'll do that in the next example (csa113).

<li>At this point we can shut down our example in the usual fashion.
<code><pre>
cli[Test:SCNodeI0:CPM]-> amsLockAssignment sg csa112SGI0
cli[Test:SCNodeI0:CPM]-> amsLockInstantiation sg csa112SGI0
cli[Test:SCNodeI0:CPM]-> end
cli[Test:SCNodeI0]-> end
cli[Test]-> bye
</pre></code>
</ol>
[[File:OpenClovis_Note.png]]When running model csa212 you will not see the output described for the the amsLockAssignment and amsUnlock commands.

===Summary and References===

We've seen how to create a basic event subscriber application using Clovis' event manager library. For further reading check the Clovis SAFplus Platform API reference guide, specifically the section on the event manager. Also, the header file: <code>clEventExtApi.h</code> should be helpful.

@@ Line 148: / Line 148: @@
   <code><pre># cp -r <eval_dir>/src/app/common  .</pre></code>
-===How to Run csa212 and What to Observe===
+===How to Run csa112 and What to Observe===
 <ol>

@@ Line 147: / Line 147: @@
 Before building the project,copy the common directory which can be found under            <code><eval_dir>/src/app</code> to the working area
   <code><pre># cp -r <eval_dir>/src/app/common  .</pre></code>
 ===How to Run csa212 and What to Observe===

@@ Line 141: / Line 141: @@
 |}
-The event delivery callback function is named <code>csa112Comp_appEventCallback</code>.  First it checks that the running variable is not zero and that the High Availability State is <code>CL_AMS_HA_STATE_ACTIVE</code>, otherwise it returns, dropping the event in the bit bucket.  Next it checks whether our incoming data buffer needs to be deallocated.  If there is a buffer, it deallocates it and then allocates enough data to receive the incoming event data.  Then, we extract the data from the event into the newly allocated buffer using <code>clEventDataGet</code>.  Finally, we print the event data we received using <code>clprintf</code> which is another member of Clovis' OS Abstraction Layer.  As its name and usage suggest, it is the OSAL replacement for printf.
+The event delivery callback function is named <code>csa112Comp_appEventCallback</code>. It checks whether our incoming data buffer needs to be deallocated.  If there is a buffer, it deallocates it and then allocates enough data to receive the incoming event data.  Then, we extract the data from the event into the newly allocated buffer using <code>clEventDataGet</code>.  Finally, we print the event data we received using <code>clprintf</code> which is another member of Clovis' OS Abstraction Layer.  As its name and usage suggest, it is the OSAL replacement for printf.
 '''Note:'''

@@ Line 158: / Line 158: @@
 '''Note:'''
-Before building the project,copy the common directory which can be found under <code><eval_dir>/src/app</code> to the project area
+Before building the project,copy the common directory which can be found under            <code><eval_dir>/src/app</code> to the working area
-  <code><pre># cp -r <eval_dir>/src/app/ev  .</pre></code>
+  <code><pre># cp -r <eval_dir>/src/app/common  .</pre></code>
 ===csa212 SA Forum Compliant Event Subscription===

← Older revision		Revision as of 09:39, 8 April 2013
Line 155:		Line 155:

	The event delivery callback function is named <code>csa112Comp_appEventCallback</code>. First it checks that the running variable is not zero and that the High Availability State is <code>CL_AMS_HA_STATE_ACTIVE</code>, otherwise it returns, dropping the event in the bit bucket. Next it checks whether our incoming data buffer needs to be deallocated. If there is a buffer, it deallocates it and then allocates enough data to receive the incoming event data. Then, we extract the data from the event into the newly allocated buffer using <code>clEventDataGet</code>. Finally, we print the event data we received using <code>clprintf</code> which is another member of Clovis' OS Abstraction Layer. As its name and usage suggest, it is the OSAL replacement for printf.		The event delivery callback function is named <code>csa112Comp_appEventCallback</code>. First it checks that the running variable is not zero and that the High Availability State is <code>CL_AMS_HA_STATE_ACTIVE</code>, otherwise it returns, dropping the event in the bit bucket. Next it checks whether our incoming data buffer needs to be deallocated. If there is a buffer, it deallocates it and then allocates enough data to receive the incoming event data. Then, we extract the data from the event into the newly allocated buffer using <code>clEventDataGet</code>. Finally, we print the event data we received using <code>clprintf</code> which is another member of Clovis' OS Abstraction Layer. As its name and usage suggest, it is the OSAL replacement for printf.
		+
		+	'''Note:'''
		+
		+	Before building the project,copy the common directory which can be found under <code><eval_dir>/src/app</code> to the project area
		+	<code><pre># cp -r <eval_dir>/src/app/ev .</pre></code>

	===csa212 SA Forum Compliant Event Subscription===		===csa212 SA Forum Compliant Event Subscription===

@@ Line 1: / Line 1: @@
-==csa212 Event Subscription==
+==csa112 Event Subscription==
 ===Objective===
-The objective of csa212 is to learn how to use Clovis' event service to subscribe to events and to extract the relevant information from the events received by subscription.
+The objective of csa112 is to learn how to use the SAFplus Platform event service to subscribe to events and to extract the relevant information from the events received by subscription.
 ===What you will learn===
-You will learn
+You will learn:
 *how to initialize the event library
 *how to subscribe to events
 *how to receive events
 *how to extract the event data
 ===Code===