Prasad: /* csa213 SA Forum Compliant Event Publication */

2014-11-17T06:39:15Z

‎csa213 SA Forum Compliant Event Publication

Prasad: /* Code */

2014-11-17T06:38:12Z

‎Code

Show changes

Vnpraveendesu: /* Code */

2013-04-08T09:57:20Z

‎Code

Bot: 1 revision

2011-10-24T19:02:17Z

1 revision

Senthilk at 03:30, 27 August 2010

2010-08-27T03:30:00Z

New page

==csa113 Event Publication==

===Objective===

The objective is to learn how to write an event publishing application using Clovis' Event Manager API.

===What You Will Learn===

*You will learn how to publish events using Clovis' Event Manager API.

===Code===

{| 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[])
{
ClNameT appName;
ClCpmCallbacksT callbacks;
ClVersionT version;
ClIocPortT iocPort;
ClRcT rc = CL_OK;

/*
* ---BEGIN_APPLICATION_CODE---
*/
ClVersionT evtVersion = CL_EVENT_VERSION;
ClEventCallbacksT evtCallbacks = { NULL, NULL };

/*
* ---END_APPLICATION_CODE---
*/
...

if ( (rc = clCpmClientInitialize(&cpmHandle, &callbacks, &version)) )
goto errorexit;

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

In the <code>clCompAppInitialize</code> function of this example we again see a call to <code>clEventInitialize</code>. Most everything else in the appInitialize function is the same as before in csa112, except that both callback function pointers are specified as <code>NULL</code>. This is because we neither open the event channel asynchronously, or subscribe to any events in this application. So there is no need to specify a callback to receive an event.

{| 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_PUBLISHER |
CL_EVENT_GLOBAL_CHANNEL |
CL_EVENT_CHANNEL_CREATE),
(ClTimeT)CL_RMD_TIMEOUT_FOREVER,
&evtChannelHandle);
</pre></code>
|}

Here we open the event channel. This is the same as in csa112 except that rather than opening as a SUBSCRIBER, we open as a <code>PUBLISHER</code> (by specifying <code>CL_EVENT_CHANNEL_PUBLISHER</code> flag)

{| 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[])
{

...

rc = clEventAllocate(evtChannelHandle, &eventHandle);
if (rc != CL_OK)
{
clprintf(CL_LOG_SEV_ERROR, "Failed to allocate event [0x%x]",
rc);
return rc;
}

rc = clEventExtAttributesSet(eventHandle,
EVENT_TYPE,
1,
0,
&publisherName);
if (rc != CL_OK)
{
clprintf(CL_LOG_SEV_ERROR, "Failed to set event attributes [0x%x]",
rc);
return rc;
}
</pre></code>
|}

The call to <code>clEventAllocate</code> allocates an event header. This header is identified by the event handle passed back to <code>gTestInfo.eventHandle</code>. The handle should be used any time the event header is to be used to manipulate the header, either by using <code>clEventExtAttributesSet</code> (right below), or to send an event using the header as in <code>clEventPublish</code>. The call to <code>clEventExtAttributesSet</code> defines the <code>EVENT_TYPE</code> which is defined as 5432 in <code>common/common.h</code> and is used in the event subscriber. It also defines the priority to be 1 which is just below the highest priority of <code>CL_EVENT_HIGHEST_PRIORITY</code> which is defined as 0 where <code>CL_EVENT_LOWEST_PRIORITY</code> is defined as 3. The retention time is specified as 0 since we don't want the event to be kept around if there is no subscriber to pick it up. Finally the <code>publisherName</code> is specified because it's required. Our subscriber doesn't care who publishes the events it receives.

{| 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[])
{

...

while (!exiting)
{
if (running && ha_state == CL_AMS_HA_STATE_ACTIVE)
{
csa113Comp_PublishEvent();
}
sleep(1);
}
</pre></code>
|}

Here is the main loop. As long as the application is running and active we make a call to <code>csa113Comp_PublishEvent</code>. The work of the application takes place in <code>csa113Comp_PublishEvent</code>, which is presented below.

{| cellspacing="0" cellpadding = "0" border="0" align = "center" width="680"
! style="color:black;background-color:#ffccaa;" align="center"| clCompAppMain.c
|-
|<code><pre>
static ClRcT
csa113Comp_PublishEvent()
{
ClRcT rc = CL_OK;
ClEventIdT eventId = 0;
static int index = 0;
ClSizeT data_len = 0;
char *data = 0;
typedef void (*Generator)(char **, ClSizeT*);

//
// Note: to add a new generator, just define it above and then include
// the new functions name in the generators list.
// Next, maybe something that gets disk free info by way of getfsent
// and statfs?
static Generator generators[] =
{
generate_time_of_day,
generate_load_average
};

//
// every time through increment index and then set index to
// it's value modulo the number of entries in the generators
// array. This will cause us to cycle through the list of
// generators as we're called to publish events.
(*generators[index++])(&data, &data_len);
index %= (int)(sizeof generators / sizeof generators[0]);
if (data == 0 || data_len == 0)
{
clprintf(CL_LOG_SEV_ERROR, "no event data generated");
return CL_ERR_NO_MEMORY;
}
clprintf(CL_LOG_SEV_NOTICE,"Publishing Event: %.*s", (int)data_len, data);
rc = clEventPublish(eventHandle, data, data_len, &eventId);
clHeapFree(data);

return CL_OK;
}
</pre></code>
|}

There's code to call one of a list of generator functions. The functions on the list, return a pointer and a length which are used to pass to <code>clEventPublish</code>. We pass the eventHandle prepared earlier with <code>clEventAllocate</code> and <code>clEventExtAttributesSet</code>. Pass the pointer and the length that we get back from the generator function. Those are used to package up the event data and send it to any subscribers. We also pass the address of the <code>eventId</code> local variable. This is required so that the <code>clEventPublish</code> function can return the event ID. We don't need it, so we promptly drop it in the bit bucket. Finally, we free the data that was allocated in the generator function and passed back as we no longer need it.

===csa213 SA Forum Compliant Event Publication===

This sample application demonstrates the usage of SA Forum Event Service. As mentioned previously, this sample application does not deviate functionally with csa113. The code differences 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
|ClEventHandleT
|}

{| 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
|-
|SaEvtEventAllocate
|ClEventAllocate
|-
|saEvtEventAttributesSet
|clEventExtAttributesSet
|-
|saEvtEventPublish
|clEventPublish
|}

===How to Run csa113 and What to Observe===

In csa113 you will be observing an event publishing application. This will be far more interesting if you observe an event subscription application at the same time. For this we will use the example from csa112.

<ol>
<li>First you should start up csa112 and put it in a LockAssignment state so that it can receive events.(Unlock csa212SGI0 instead of csa112SGI0 to run csa213).
<code><pre>
# cd /root/asp/bin
# ./asp_console

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

In the csa112 application log you should see:
{| 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:50:34 2008 (SCNodeI0.24830 : csa112CompEO.---.---.00037 : INFO)
csa112: Instantiated as component instance csa112CompI0.
Mon Jul 14 22:50:34 2008 (SCNodeI0.24830 : csa112CompEO.---.---.00038 : INFO)
csa112CompI0: Waiting for CSI assignment...
Mon Jul 14 22:51:20 2008 (SCNodeI0.24830 : csa112CompEO.---.---.00041 : INFO)
Component [csa112CompI0] : PID [24830]. CSI Set Received
Mon Jul 14 22:51:20 2008 (SCNodeI0.24830 : csa112CompEO.---.---.00042 : INFO)
CSI Flags : [Add One]
Mon Jul 14 22:51:20 2008 (SCNodeI0.24830 : csa112CompEO.---.---.00043 : INFO)
CSI Name : [csa112CSII0]
Mon Jul 14 22:51:20 2008 (SCNodeI0.24830 : csa112CompEO.---.---.00044 : INFO)
Name Value Pairs :
Mon Jul 14 22:51:20 2008 (SCNodeI0.24830 : csa112CompEO.---.---.00045 : INFO)
HA State : [Active]
Mon Jul 14 22:51:20 2008 (SCNodeI0.24830 : csa112CompEO.---.---.00046 : INFO)
Active Descriptor :
Mon Jul 14 22:51:20 2008 (SCNodeI0.24830 : csa112CompEO.---.---.00047 : INFO)
Transition Descriptor : [1]
Mon Jul 14 22:51:20 2008 (SCNodeI0.24830 : csa112CompEO.---.---.00048 : INFO)
Active Component : [csa112CompI0]
Mon Jul 14 22:51:20 2008 (SCNodeI0.24830 : csa112CompEO.---.---.00049 : INFO)
csa112: ACTIVE state requested; activating service
</pre></code>
|}
[[File:OpenClovis_Note.png]]When running model csa212 you will not see the output described above for the the amsLockAssignment and amsUnlock commands. Unlock csa212SGI0 instead of csa112SGI0.

<li>Now you can start up the event publishing application and put it in a LockAssignment state. (Unlock csa213SGI0 instead of csa113SGI0 to run csa213).
<code><pre>
cli[Test:SCNodeI0:CPM]-> amsLockAssignment sg csa113SGI0
cli[Test:SCNodeI0:CPM]-> amsUnlock sg csa113SGI0
</pre></code>

Putting csa113 into a LockAssignment state caused it to begin publishing events. Using <code>tail -f /root/asp/var/log/csa113CompI0Log.latest</code> on the csa113 application log you can see the events being published.(Unlock csa213SGI0 instead of csa113SGI0 to run SAF version).
{| cellspacing="0" cellpadding = "0" border="0" align = "center" width="680"
! style="color:black;background-color:#ffffaa;" align="center"| $ /root/asp/var/log/csa113CompI0Log.latest
|-
|<code><pre>
Mon Jul 14 22:53:54 2008 (SCNodeI0.24890 : csa113CompEO.---.---.00028 : INFO)
Component [csa113CompI0] : PID [24890]. Initializing
Mon Jul 14 22:53:54 2008 (SCNodeI0.24890 : csa113CompEO.---.---.00029 : INFO)
IOC Address : 0x1
Mon Jul 14 22:53:54 2008 (SCNodeI0.24890 : csa113CompEO.---.---.00030 : INFO)
IOC Port : 0x81
Mon Jul 14 22:53:54 2008 (SCNodeI0.24890 : csa113CompEO.---.---.00037 : INFO)
Instantiated as component instance csa113CompI0.
Mon Jul 14 22:53:54 2008 (SCNodeI0.24890 : csa113CompEO.---.---.00038 : INFO)
csa113CompI0: Waiting for CSI assignment...
Mon Jul 14 22:53:59 2008 (SCNodeI0.24890 : csa113CompEO.---.---.00041 : INFO)
Component [csa113CompI0] : PID [24890]. CSI Set Received
Mon Jul 14 22:53:59 2008 (SCNodeI0.24890 : csa113CompEO.---.---.00042 : INFO)
CSI Flags : [Add One]
Mon Jul 14 22:53:59 2008 (SCNodeI0.24890 : csa113CompEO.---.---.00043 : INFO)
CSI Name : [csa113CSII0]
Mon Jul 14 22:53:59 2008 (SCNodeI0.24890 : csa113CompEO.---.---.00044 : INFO)
Name Value Pairs :
Mon Jul 14 22:53:59 2008 (SCNodeI0.24890 : csa113CompEO.---.---.00045 : INFO)
HA State : [Active]
Mon Jul 14 22:53:59 2008 (SCNodeI0.24890 : csa113CompEO.---.---.00046 : INFO)
Active Descriptor :
Mon Jul 14 22:53:59 2008 (SCNodeI0.24890 : csa113CompEO.---.---.00047 : INFO)
Transition Descriptor : [1]
Mon Jul 14 22:53:59 2008 (SCNodeI0.24890 : csa113CompEO.---.---.00048 : INFO)
Active Component : [csa113CompI0]
Mon Jul 14 22:53:59 2008 (SCNodeI0.24890 : csa113CompEO.---.---.00049 : INFO)
csa113: ACTIVE state requested; activating service
Mon Jul 14 22:53:59 2008 (SCNodeI0.24890 : csa113CompEO.---.---.00050 : NOTICE)
Publishing Event: Mon Jul 14 22:53:59 2008
Mon Jul 14 22:54:00 2008 (SCNodeI0.24890 : csa113CompEO.---.---.00052 : NOTICE)
Publishing Event: 0.05 0.07 0.03
Mon Jul 14 22:54:01 2008 (SCNodeI0.24890 : csa113CompEO.---.---.00054 : NOTICE)
Publishing Event: Mon Jul 14 22:54:01 2008
Mon Jul 14 22:54:02 2008 (SCNodeI0.24890 : csa113CompEO.---.---.00056 : NOTICE)
Publishing Event: 0.05 0.07 0.03
Mon Jul 14 22:54:03 2008 (SCNodeI0.24890 : csa113CompEO.---.---.00058 : NOTICE)
Publishing Event: Mon Jul 14 22:54:03 2008
Mon Jul 14 22:54:04 2008 (SCNodeI0.24890 : csa113CompEO.---.---.00060 : NOTICE)
Publishing Event: 0.05 0.07 0.03
</pre></code>
|}

Since the event subscriber application is also running you can see the events that it is receiving in the csa112 application log file. Again using <code>tail -f /rootasp//var/log/csa112CompI0Log.latest</code> you can 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 22:53:59 2008 (SCNodeI0.24830 : csa112CompEO.---.---.00052 : NOTICE)
We've got an event to receive
Mon Jul 14 22:53:59 2008 (SCNodeI0.24830 : csa112CompEO.---.---.00054 : NOTICE)
received event: Mon Jul 14 22:53:59 2008
Mon Jul 14 22:54:00 2008 (SCNodeI0.24830 : csa112CompEO.---.---.00058 : NOTICE)
We've got an event to receive
Mon Jul 14 22:54:00 2008 (SCNodeI0.24830 : csa112CompEO.---.---.00060 : NOTICE)
received event: 0.05 0.07 0.03
Mon Jul 14 22:54:01 2008 (SCNodeI0.24830 : csa112CompEO.---.---.00064 : NOTICE)
We've got an event to receive
Mon Jul 14 22:54:01 2008 (SCNodeI0.24830 : csa112CompEO.---.---.00066 : NOTICE)
received event: Mon Jul 14 22:54:01 2008
Mon Jul 14 22:54:02 2008 (SCNodeI0.24830 : csa112CompEO.---.---.00070 : NOTICE)
We've got an event to receive
Mon Jul 14 22:54:02 2008 (SCNodeI0.24830 : csa112CompEO.---.---.00072 : NOTICE)
received event: 0.05 0.07 0.03
</pre></code>
|}

<li>Now you can shut everything down in the usual manner. Note that you will be shutting down two service groups.
<code><pre>
cli[Test:SCNodeI0:CPM]-> amsLockAssignment sg csa113SGI0
cli[Test:SCNodeI0:CPM]-> amsLockAssignment sg csa112SGI0
cli[Test:SCNodeI0:CPM]-> amsLockInstantiation sg csa113SGI0
cli[Test:SCNodeI0:CPM]-> amsLockInstantiation sg csa112SGI0
cli[Test:SCNodeI0:CPM]-> end
cli[Test:SCNodeI0]-> end
cli[Test]-> bye
</pre></code>

</ol>

===Summary and References===

We've seen how to initialize the event manager subsystem as an event publisher. We've seen:
*events flow from the event publisher to the subscriber.
*how to format events and send them through the event manager subsystem
*For further reading, check the same sources as listed under the csa112 section.

@@ Line 182: / Line 182: @@
 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 csa113 and What to Observe===

← Older revision		Revision as of 09:57, 8 April 2013
Line 179:		Line 179:

	There's code to call one of a list of generator functions. The functions on the list, return a pointer and a length which are used to pass to <code>clEventPublish</code>. We pass the eventHandle prepared earlier with <code>clEventAllocate</code> and <code>clEventExtAttributesSet</code>. Pass the pointer and the length that we get back from the generator function. Those are used to package up the event data and send it to any subscribers. We also pass the address of the <code>eventId</code> local variable. This is required so that the <code>clEventPublish</code> function can return the event ID. We don't need it, so we promptly drop it in the bit bucket. Finally, we free the data that was allocated in the generator function and passed back as we no longer need it.		There's code to call one of a list of generator functions. The functions on the list, return a pointer and a length which are used to pass to <code>clEventPublish</code>. We pass the eventHandle prepared earlier with <code>clEventAllocate</code> and <code>clEventExtAttributesSet</code>. Pass the pointer and the length that we get back from the generator function. Those are used to package up the event data and send it to any subscribers. We also pass the address of the <code>eventId</code> local variable. This is required so that the <code>clEventPublish</code> function can return the event ID. We don't need it, so we promptly drop it in the bit bucket. Finally, we free the data that was allocated in the generator function and passed back as we no longer need it.
		+
		+	'''Note:'''
		+
		+	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>

	===csa213 SA Forum Compliant Event Publication===		===csa213 SA Forum Compliant Event Publication===

Doc:latest/evalguide/csa113 - Revision history

Prasad: /* csa213 SA Forum Compliant Event Publication */

Prasad: /* Code */

Vnpraveendesu: /* Code */

Bot: 1 revision

Senthilk at 03:30, 27 August 2010