Anders, The changes for Makefile.common and configure.ac are pushed in default branch, but not pushed in the opensaf-5.0.x branch. Because of this, the compilation failed. I shall push those changes now.
-- Srikanth On 04/11/2016 04:55 PM, Anders Widell wrote: > Hi! > > I get a build error on the opensaf-5.0.x branch, when I enable python > e.g. like this: > > hg update opensaf-5.0.x > ./bootstrap.sh > ./configure --enable-python > make > > regards, > Anders Widell > > On 04/07/2016 02:06 PM, Johan Mårtensson O wrote: >> Hi Srikanth, >> >> Thanks for coming back to these patches. There are some limitations >> in these that need improvement but I think it's good to push them as >> a base. >> >> / Johan >> >> -----Original Message----- >> From: Srikanth Revanuru [mailto:srikanth.revan...@oracle.com] >> Sent: den 7 april 2016 13:56 >> To: Johan Mårtensson O; Hans Nordebäck; mathi.naic...@oracle.com; >> Hung Duc Nguyen >> Cc: opensaf-devel@lists.sourceforge.net >> Subject: Re: [PATCH 1 of 1] pyosaf: Add NTF high-level bindings and >> sample applications [#1586] >> >> Johan, >> >> Ack. Tested the sample applications. >> >> Couple of comments. "ntf" entry to Makefile.common and configure.ac >> is to be done. The file saNtf.py is using SaAnyT, which is not imported. >> >> I shall make those changes and push today. >> >> Thanks, >> Srikanth >> >> >> On 11/06/2015 08:28 PM, Johan Mårtensson wrote: >>> opensaf.spec.in | 3 + >>> python/pyosaf/saNtf.py | 27 + >>> python/pyosaf/utils/Makefile.am | 3 +- >>> python/pyosaf/utils/ntf/Makefile.am | 22 + >>> python/pyosaf/utils/ntf/__init__.py | 657 >>> ++++++++++++++++++++++++++++++++++++ >>> python/samples/README | 11 + >>> python/samples/ntfsend | 251 +++++++++++++ >>> python/samples/ntfsubscribe | 307 ++++++++++++++++ >>> 8 files changed, 1280 insertions(+), 1 deletions(-) >>> >>> >>> Add high-level bindings and sample applications for NTF. A known issue >>> is that the assignment of additionalText is not working. >>> >>> Verify by using the ntfsend and ntfsubscribe sample applications. >>> >>> diff --git a/opensaf.spec.in b/opensaf.spec.in >>> --- a/opensaf.spec.in >>> +++ b/opensaf.spec.in >>> @@ -1524,6 +1524,9 @@ fi >>> %{python_sitelib}/pyosaf/utils/log/*.py >>> %{python_sitelib}/pyosaf/utils/log/*.pyc >>> %{python_sitelib}/pyosaf/utils/log/*.pyo >>> +%{python_sitelib}/pyosaf/utils/ntf/*.py >>> +%{python_sitelib}/pyosaf/utils/ntf/*.pyc >>> +%{python_sitelib}/pyosaf/utils/ntf/*.pyo >>> %{python_sitelib}/pyosaf/utils/immoi/*.py >>> %{python_sitelib}/pyosaf/utils/immoi/*.pyc >>> %{python_sitelib}/pyosaf/utils/immoi/*.pyo >>> diff --git a/python/pyosaf/saNtf.py b/python/pyosaf/saNtf.py >>> --- a/python/pyosaf/saNtf.py >>> +++ b/python/pyosaf/saNtf.py >>> @@ -176,6 +176,33 @@ eSaNtfValueTypeT = Enumeration(( >>> 'SA_NTF_VALUE_ARRAY', >>> )) >>> +SaNtfValueTypeMap = { >>> + eSaNtfValueTypeT.SA_NTF_VALUE_UINT8: SaUint8T, >>> + eSaNtfValueTypeT.SA_NTF_VALUE_INT8: SaInt8T, >>> + eSaNtfValueTypeT.SA_NTF_VALUE_UINT16: SaUint16T, >>> + eSaNtfValueTypeT.SA_NTF_VALUE_INT16: SaInt16T, >>> + eSaNtfValueTypeT.SA_NTF_VALUE_UINT32: SaUint32T, >>> + eSaNtfValueTypeT.SA_NTF_VALUE_INT32: SaInt32T, >>> + eSaNtfValueTypeT.SA_NTF_VALUE_FLOAT: SaFloatT, >>> + eSaNtfValueTypeT.SA_NTF_VALUE_UINT64: SaUint64T, >>> + eSaNtfValueTypeT.SA_NTF_VALUE_INT64: SaInt64T, >>> + eSaNtfValueTypeT.SA_NTF_VALUE_DOUBLE: SaDoubleT, >>> + eSaNtfValueTypeT.SA_NTF_VALUE_LDAP_NAME: SaStringT, >>> + eSaNtfValueTypeT.SA_NTF_VALUE_STRING: SaStringT, >>> + eSaNtfValueTypeT.SA_NTF_VALUE_IPADDRESS: SaStringT, >>> + eSaNtfValueTypeT.SA_NTF_VALUE_BINARY: SaAnyT, >>> + eSaNtfValueTypeT.SA_NTF_VALUE_ARRAY: SaAnyT >>> +} >>> + >>> +def unmarshalSaNtfValue(void_ptr, value_type): >>> + """Convert void pointer to an instance of value type. >>> + """ >>> + val_ptr = SaNtfValueTypeMap.get(value_type) >>> + if val_ptr and void_ptr: >>> + if val_ptr == SaNameT: >>> + return cast(void_ptr, POINTER(val_ptr))[0].value >>> + return cast(void_ptr, POINTER(val_ptr))[0] >>> + return None >>> class _ptrVal(Structure): >>> _fields_ = [('dataOffset', SaUint16T), >>> ('dataSize', SaUint16T)] >>> diff --git a/python/pyosaf/utils/Makefile.am >>> b/python/pyosaf/utils/Makefile.am >>> --- a/python/pyosaf/utils/Makefile.am >>> +++ b/python/pyosaf/utils/Makefile.am >>> @@ -25,4 +25,5 @@ SUBDIRS = \ >>> immom \ >>> clm \ >>> log \ >>> - immoi >>> + immoi \ >>> + ntf >>> diff --git a/python/pyosaf/utils/ntf/Makefile.am >>> b/python/pyosaf/utils/ntf/Makefile.am >>> new file mode 100644 >>> --- /dev/null >>> +++ b/python/pyosaf/utils/ntf/Makefile.am >>> @@ -0,0 +1,22 @@ >>> +# -*- OpenSAF -*- >>> +# >>> +# (C) Copyright 2011 The OpenSAF Foundation >>> +# >>> +# 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. This file and program are >>> licensed >>> +# under the GNU Lesser General Public License Version 2.1, February >>> 1999. >>> +# The complete license can be accessed from the following location: >>> +# http://opensource.org/licenses/lgpl-license.php >>> +# See the Copying file included with the OpenSAF distribution for full >>> +# licensing terms. >>> +# >>> +# Author(s): Oracle >>> +# >>> + >>> +include $(top_srcdir)/Makefile.common >>> + >>> +MAINTAINERCLEANFILES = Makefile.in >>> + >>> +pkgpyosafutilsntf_PYTHON = \ >>> + __init__.py >>> diff --git a/python/pyosaf/utils/ntf/__init__.py >>> b/python/pyosaf/utils/ntf/__init__.py >>> new file mode 100644 >>> --- /dev/null >>> +++ b/python/pyosaf/utils/ntf/__init__.py >>> @@ -0,0 +1,657 @@ >>> +############################################################################ >>> >>> >>> +# >>> +# (C) Copyright 2015 The OpenSAF Foundation >>> +# >>> +# 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. This file and program are >>> licensed >>> +# under the GNU Lesser General Public License Version 2.1, February >>> 1999. >>> +# The complete license can be accessed from the following location: >>> +# http://opensource.org/licenses/lgpl-license.php >>> +# See the Copying file included with the OpenSAF distribution for full >>> +# licensing terms. >>> +# >>> +# Author(s): Ericsson >>> +# >>> +############################################################################ >>> >>> >>> + >>> +''' >>> + NTF common utilities >>> +''' >>> + >>> +from pyosaf import saNtf, saAis >>> +import ctypes >>> + >>> +from pyosaf.utils import decorate >>> + >>> +saNtfInitialize = decorate(saNtf.saNtfInitialize) >>> +saNtfLocalizedMessageFree = >>> decorate(saNtf.saNtfLocalizedMessageFree) >>> +saNtfStateChangeNotificationFilterAllocate = >>> decorate(saNtf.saNtfStateChangeNotificationFilterAllocate) >>> +saNtfNotificationUnsubscribe = >>> decorate(saNtf.saNtfNotificationUnsubscribe) >>> +saNtfNotificationReadInitialize = >>> decorate(saNtf.saNtfNotificationReadInitialize) >>> +saNtfInitialize_2 = decorate(saNtf.saNtfInitialize_2) >>> +saNtfNotificationReadInitialize_2 = >>> decorate(saNtf.saNtfNotificationReadInitialize_2) >>> +saNtfNotificationSubscribe = >>> decorate(saNtf.saNtfNotificationSubscribe) >>> +saNtfInitialize_3 = decorate(saNtf.saNtfInitialize_3) >>> +saNtfSelectionObjectGet = >>> decorate(saNtf.saNtfSelectionObjectGet) >>> +saNtfDispatch = decorate(saNtf.saNtfDispatch) >>> +saNtfFinalize = decorate(saNtf.saNtfFinalize) >>> +saNtfObjectCreateDeleteNotificationAllocate = >>> decorate(saNtf.saNtfObjectCreateDeleteNotificationAllocate) >>> +saNtfAttributeChangeNotificationAllocate = >>> decorate(saNtf.saNtfAttributeChangeNotificationAllocate) >>> +saNtfStateChangeNotificationAllocate = >>> decorate(saNtf.saNtfStateChangeNotificationAllocate) >>> +saNtfStateChangeNotificationAllocate_3 = >>> decorate(saNtf.saNtfStateChangeNotificationAllocate_3) >>> +saNtfAlarmNotificationAllocate = >>> decorate(saNtf.saNtfAlarmNotificationAllocate) >>> +saNtfSecurityAlarmNotificationAllocate = >>> decorate(saNtf.saNtfSecurityAlarmNotificationAllocate) >>> +saNtfMiscellaneousNotificationAllocate = >>> decorate(saNtf.saNtfMiscellaneousNotificationAllocate) >>> +saNtfPtrValAllocate = decorate(saNtf.saNtfPtrValAllocate) >>> +saNtfArrayValAllocate = >>> decorate(saNtf.saNtfArrayValAllocate) >>> +saNtfIdentifierAllocate = >>> decorate(saNtf.saNtfIdentifierAllocate) >>> +saNtfNotificationSend = >>> decorate(saNtf.saNtfNotificationSend) >>> +saNtfNotificationSendWithId = >>> decorate(saNtf.saNtfNotificationSendWithId) >>> +saNtfNotificationFree = >>> decorate(saNtf.saNtfNotificationFree) >>> +saNtfVariableDataSizeGet = >>> decorate(saNtf.saNtfVariableDataSizeGet) >>> +saNtfLocalizedMessageGet = >>> decorate(saNtf.saNtfLocalizedMessageGet) >>> +saNtfLocalizedMessageFree_2 = >>> decorate(saNtf.saNtfLocalizedMessageFree_2) >>> +saNtfPtrValGet = decorate(saNtf.saNtfPtrValGet) >>> +saNtfArrayValGet = decorate(saNtf.saNtfArrayValGet) >>> +saNtfObjectCreateDeleteNotificationFilterAllocate = >>> decorate(saNtf.saNtfObjectCreateDeleteNotificationFilterAllocate) >>> +saNtfAttributeChangeNotificationFilterAllocate = >>> decorate(saNtf.saNtfAttributeChangeNotificationFilterAllocate) >>> +saNtfStateChangeNotificationFilterAllocate_2 = >>> decorate(saNtf.saNtfStateChangeNotificationFilterAllocate_2) >>> +saNtfAlarmNotificationFilterAllocate = >>> decorate(saNtf.saNtfAlarmNotificationFilterAllocate) >>> +saNtfSecurityAlarmNotificationFilterAllocate = >>> decorate(saNtf.saNtfSecurityAlarmNotificationFilterAllocate) >>> +saNtfNotificationFilterFree = >>> decorate(saNtf.saNtfNotificationFilterFree) >>> +saNtfNotificationSubscribe_3 = >>> decorate(saNtf.saNtfNotificationSubscribe_3) >>> +saNtfNotificationReadInitialize_3 = >>> decorate(saNtf.saNtfNotificationReadInitialize_3) >>> +saNtfNotificationUnsubscribe_2 = >>> decorate(saNtf.saNtfNotificationUnsubscribe_2) >>> +saNtfNotificationReadNext = >>> decorate(saNtf.saNtfNotificationReadNext) >>> +saNtfNotificationReadNext_3 = >>> decorate(saNtf.saNtfNotificationReadNext_3) >>> +saNtfNotificationReadFinalize = >>> decorate(saNtf.saNtfNotificationReadFinalize) >>> + >>> + >>> +HANDLE = saNtf.SaNtfHandleT() >>> +SELECTION_OBJECT = saAis.SaSelectionObjectT() >>> +CALLBACKS = saNtf.SaNtfCallbacksT() >>> + >>> + >>> +class AdditionalInfo(object): >>> + ''' Represents a piece of additional info to be included in a >>> + notification >>> + ''' >>> + >>> + def __init__(self, info_id, info_type, info_value): >>> + self.info_id = info_id >>> + self.info_type = info_type >>> + self.info_value = info_value >>> + >>> + >>> +class StateChange(object): >>> + ''' Contains information about a state change event''' >>> + >>> + def __init__(self): >>> + pass >>> + >>> + >>> +class AttributeChange(object): >>> + ''' Contains information about a change in an attribute''' >>> + >>> + def __init__(self): >>> + pass >>> + >>> + >>> +class Attribute(object): >>> + ''' Contains information about the value and value type of an >>> attribute''' >>> + >>> + def __init__(self): >>> + pass >>> + >>> + >>> +class SecurityAlarmDetector(object): >>> + ''' Represents an instance of a security alarm detector''' >>> + >>> + def __init__(self, value=None, value_type=None): >>> + self.value = value >>> + self.value_type = value_type >>> + >>> + >>> +class ServiceUser(object): >>> + ''' Represents a service user''' >>> + >>> + def __init__(self, value=None, value_type=None): >>> + self.value = value >>> + self.value_type = value_type >>> + >>> + >>> +class ServiceProvider(object): >>> + ''' Represents a service provider''' >>> + >>> + def __init__(self, value=None, value_type=None): >>> + self.value = value >>> + self.value_type = value_type >>> + >>> + >>> +def dummy_func(*args): >>> + ''' Dummy function used as a callback when no proper callbacks >>> are set''' >>> + pass >>> + >>> +def initialize(notification_callback=None): >>> + ''' Initializes the NTF library''' >>> + >>> + # Initialize the NTF API >>> + version = saAis.SaVersionT('A', 1, 1) >>> + >>> + # Assign default values for callbacks >>> + CALLBACKS.saNtfNotificationCallback = \ >>> + saNtf.SaNtfNotificationCallbackT(dummy_func) >>> + CALLBACKS.saNtfNotificationDiscardedCallback = \ >>> + saNtf.SaNtfNotificationDiscardedCallbackT(dummy_func) >>> + >>> + # Override the notification subscribe callback if it's passed >>> + if notification_callback: >>> + CALLBACKS.saNtfNotificationCallback = \ >>> + saNtf.SaNtfNotificationCallbackT(notification_callback) >>> + >>> + # Initialize the API >>> + saNtfInitialize(HANDLE, CALLBACKS, version) >>> + >>> + # Get the selection object >>> + saNtfSelectionObjectGet(HANDLE, SELECTION_OBJECT) >>> + >>> + >>> +def assign_ntf_value_to_attribute(attr_value_field, value, >>> value_type): >>> + ''' Assigns the correct sub-field in the given attribute >>> + >>> + e.g. attr_value_field.uint8Val = ... >>> + >>> + ''' >>> + >>> + if value_type == saNtf.eSaNtfValueTypeT.SA_NTF_VALUE_UINT8: >>> + attr_value_field.uint8Val = value >>> + >>> + elif value_type == saNtf.eSaNtfValueTypeT.SA_NTF_VALUE_INT8: >>> + attr_value_field.int8Val = value >>> + >>> + elif value_type == saNtf.eSaNtfValueTypeT.SA_NTF_VALUE_UINT16: >>> + attr_value_field.uint16Val = value >>> + >>> + elif value_type == saNtf.eSaNtfValueTypeT.SA_NTF_VALUE_INT16: >>> + attr_value_field.int16Val = value >>> + >>> + elif value_type == saNtf.eSaNtfValueTypeT.SA_NTF_VALUE_UINT32: >>> + attr_value_field.uint32Val = value >>> + >>> + elif value_type == saNtf.eSaNtfValueTypeT.SA_NTF_VALUE_INT32: >>> + attr_value_field.int32Val = value >>> + >>> + elif value_type == saNtf.eSaNtfValueTypeT.SA_NTF_VALUE_FLOAT: >>> + attr_value_field.floatVal = value >>> + >>> + elif value_type == saNtf.eSaNtfValueTypeT.SA_NTF_VALUE_UINT64: >>> + attr_value_field.uint64Val = value >>> + >>> + elif value_type == saNtf.eSaNtfValueTypeT.SA_NTF_VALUE_INT64: >>> + attr_value_field.int64Val = value >>> + >>> + elif value_type == saNtf.eSaNtfValueTypeT.SA_NTF_VALUE_DOUBLE: >>> + attr_value_field.doubleVal = value >>> + >>> + >>> +def fill_in_header(notification_handle, >>> + header, notification_object, notifying_object, >>> vendor_id, >>> + major_id, minor_id, additional_text, event_type, >>> event_time, >>> + additional_info): >>> + ''' Fills in the given notification header with the provided >>> values''' >>> + >>> + header.eventType.contents.value = event_type >>> + header.notificationObject.contents.value = notification_object >>> + header.notificationObject.contents.length = >>> len(notification_object) >>> + header.notifyingObject.contents.value = notifying_object >>> + header.notifyingObject.contents.length = len(notifying_object) >>> + header.notificationClassId.contents.vendorId = vendor_id >>> + header.notificationClassId.contents.majorId = major_id >>> + header.notificationClassId.contents.minorId = minor_id >>> + header.eventTime.contents.value = event_time >>> + header.numCorrelatedNotifications = 0 >>> + header.lengthAdditionalText = len(additional_text) >>> + >>> + ## >>> + ## FIXME: this fails to copy the value of the additional_text >>> variable into >>> + ## header.additionalText. >>> + >>> + ctypes.memmove(header.additionalText, >>> + additional_text, >>> + len(additional_text)) >>> + >>> + header.numAdditionalInfo = len(additional_info) >>> + header.thresholdInformation = None >>> + >>> + # Fill in additional info >>> + if additional_info != []: >>> + for i in range(0, len(additional_info)): >>> + >>> + header.additionalInfo[i].infoId = >>> additional_info[i].info_id >>> + header.additionalInfo[i].infoType = >>> additional_info[i].info_type >>> + >>> + dest_ptr = (ctypes.c_char * >>> len(additional_info[i].info_value))() >>> + >>> + saNtf.saNtfPtrValAllocate(notification_handle, >>> + len(additional_info[i].info_value) + 1, >>> + dest_ptr, >>> + header.additionalInfo[i].infoValue) >>> + >>> + ctypes.memmove(ctypes.addressof(dest_ptr), >>> + additional_info[i].info_value, >>> + len(additional_info[i].info_value) + 1) >>> + >>> + else: >>> + header.additionalInfo = None >>> + >>> + >>> +def send_object_create_notification(vendor_id, major_id, minor_id, >>> + additional_text="", >>> + notification_object="", >>> + notifying_object="", >>> + attributes=[], >>> + event_time=saAis.saAis.SA_TIME_UNKNOWN, >>> + additional_info=[]): >>> + ''' Sends a notification for a created object''' >>> + >>> + _send_object_create_delete_notification( >>> + saNtf.eSaNtfEventTypeT.SA_NTF_OBJECT_CREATION, >>> + vendor_id, major_id, minor_id, >>> + additional_text=additional_text, >>> + notification_object=notification_object, >>> + notifying_object=notifying_object, >>> + attributes=attributes, >>> + event_time=event_time, >>> + additional_info=additional_info) >>> + >>> + >>> +def send_object_delete_notification(vendor_id, >>> + major_id, >>> + minor_id, >>> + additional_text="", >>> + notification_object="", >>> + notifying_object="", >>> + attributes=[], >>> + event_time=saAis.saAis.SA_TIME_UNKNOWN, >>> + additional_info=[]): >>> + ''' Sends a notification for a deleted object''' >>> + >>> + _send_object_create_delete_notification( >>> + saNtf.eSaNtfEventTypeT.SA_NTF_OBJECT_DELETION, >>> + vendor_id, major_id, minor_id, >>> + additional_text=additional_text, >>> + notification_object=notification_object, >>> + notifying_object=notifying_object, >>> + attributes=attributes, >>> + event_time=event_time, >>> + additional_info=additional_info) >>> + >>> + >>> +def _send_object_create_delete_notification( >>> + event_type, >>> + vendor_id, >>> + major_id, >>> + minor_id, >>> + additional_text="", >>> + notification_object="", >>> + notifying_object="", >>> + attributes=[], >>> + event_time=saAis.saAis.SA_TIME_UNKNOWN, >>> + additional_info=[]): >>> + ''' Sends an object create delete notification''' >>> + >>> + # Create the notification >>> + notification = saNtf.SaNtfObjectCreateDeleteNotificationT() >>> + >>> + saNtfObjectCreateDeleteNotificationAllocate( >>> + HANDLE, >>> + notification, >>> + 0, >>> + len(additional_text) + 1, >>> + len(additional_info), >>> + len(attributes), >>> + 0) >>> + >>> + # Fill in the header >>> + fill_in_header(notification.notificationHandle, >>> + notification.notificationHeader, >>> + notification_object, notifying_object, vendor_id, >>> + major_id, minor_id, additional_text, >>> + event_type, event_time, additional_info) >>> + >>> + # Fill in attributes >>> + for i in range(0, notification.numAttributes): >>> + >>> + ptr = notification.objectAttributes[i] >>> + >>> + ptr.attributeId = attributes[i].attribute_id >>> + ptr.attributeType = attributes[i].attribute_type >>> + >>> + assign_ntf_value_to_attribute(ptr.attributeValue, >>> + attributes[i].attribute_value, >>> + attributes[i].attribute_type) >>> + >>> + >>> + # Send the notification >>> + saNtfNotificationSend(notification.notificationHandle) >>> + >>> + # Free the notification >>> + saNtfNotificationFree(notification.notificationHandle) >>> + >>> + >>> +def send_state_change_notification(vendor_id, >>> + major_id, >>> + minor_id, >>> + additional_text="", >>> + notification_object="", >>> + notifying_object="", >>> + event_time=saAis.saAis.SA_TIME_UNKNOWN, >>> + additional_info=[], >>> + state_changes=[]): >>> + ''' Sends a state change notification''' >>> + >>> + event_type = saNtf.eSaNtfEventTypeT.SA_NTF_OBJECT_STATE_CHANGE >>> + >>> + # Create the notification >>> + notification = saNtf.SaNtfStateChangeNotificationT() >>> + >>> + saNtfStateChangeNotificationAllocate( >>> + HANDLE, >>> + notification, >>> + 0, >>> + len(additional_text) + 1, >>> + len(additional_info), >>> + len(state_changes), >>> + 0) >>> + >>> + # Fill in the header >>> + fill_in_header(notification.notificationHandle, >>> + notification.notificationHeader, >>> + notification_object, notifying_object, vendor_id, >>> + major_id, minor_id, additional_text, event_type, >>> + event_time, additional_info) >>> + >>> + # Fill in state changes >>> + >>> + for i in range(0, len(state_changes)): >>> + >>> + notification.changedStates[i].stateId = >>> state_changes[i].state_id >>> + >>> + if state_changes[i].old_state_present: >>> + notification.changedStates[i].oldStatePresent = >>> saAis.eSaBoolT.SA_TRUE >>> + notification.changedStates[i].oldState = >>> state_changes[i].old_state >>> + >>> + else: >>> + notification.changedStates[i].oldStatePresent = >>> saAis.eSaBoolT.SA_FALSE >>> + >>> + notification.changedStates[i].newState = >>> state_changes[i].new_state >>> + >>> + # Send the alarm notification >>> + saNtfNotificationSend(notification.notificationHandle) >>> + >>> + # Free the alarm notification >>> + saNtfNotificationFree(notification.notificationHandle) >>> + >>> + >>> +def send_attribute_change_notification(vendor_id, >>> + major_id, >>> + minor_id, >>> + additional_text="", >>> + notification_object="", >>> + notifying_object="", >>> + event_type=saNtf.eSaNtfEventTypeT.SA_NTF_ATTRIBUTE_ADDED, >>> + event_time=saAis.saAis.SA_TIME_UNKNOWN, >>> + additional_info=[], >>> + changed_attributes=[]): >>> + ''' Sends an attribute_change notification''' >>> + >>> + # Create the notification >>> + notification = saNtf.SaNtfAttributeChangeNotificationT() >>> + >>> + saNtfAttributeChangeNotificationAllocate( >>> + HANDLE, >>> + notification, >>> + 0, >>> + len(additional_text) + 1, >>> + len(additional_info), >>> + len(changed_attributes), >>> + 0) >>> + >>> + # Fill in the header >>> + fill_in_header(notification.notificationHandle, >>> + notification.notificationHeader, >>> + notification_object, notifying_object, vendor_id, >>> + major_id, minor_id, additional_text, event_type, >>> + event_time, additional_info) >>> + >>> + >>> + # Fill in attributes >>> + for i in range(0, len(changed_attributes)): >>> + >>> + ptr = notification.changedAttributes[i] >>> + >>> + ptr.attributeId = changed_attributes[i].attribute_id >>> + ptr.attributeType = changed_attributes[i].attribute_type >>> + >>> + if changed_attributes[i].old_attribute_present: >>> + ptr.oldAttributePresent = saAis.eSaBoolT.SA_TRUE >>> + >>> + assign_ntf_value_to_attribute(ptr.oldAttributeValue, >>> + changed_attributes[i].old_attribute_value, >>> + changed_attributes[i].attribute_type) >>> + >>> + else: >>> + ptr.oldAttributePresent = saAis.eSaBoolT.SA_FALSE >>> + >>> + assign_ntf_value_to_attribute(ptr.newAttributeValue, >>> + changed_attributes[i].new_attribute_value, >>> + changed_attributes[i].attribute_type) >>> + >>> + # Send the alarm notification >>> + saNtfNotificationSend(notification.notificationHandle) >>> + >>> + # Free the alarm notification >>> + saNtfNotificationFree(notification.notificationHandle) >>> + >>> + >>> +def send_security_alarm_notification(vendor_id, major_id, minor_id, >>> severity, >>> + alarm_detector, >>> + user, >>> + provider, >>> + additional_text="", >>> + notification_object="", >>> + notifying_object="", >>> + event_type=saNtf.eSaNtfEventTypeT.SA_NTF_INTEGRITY_VIOLATION, >>> + event_time=saAis.saAis.SA_TIME_UNKNOWN, >>> + additional_info=[], >>> + probable_cause=saNtf.eSaNtfProbableCauseT.SA_NTF_SOFTWARE_ERROR): >>> + >>> + ''' Sends a security alarm notification''' >>> + >>> + # Create the notification >>> + notification = saNtf.SaNtfSecurityAlarmNotificationT() >>> + >>> + saNtfSecurityAlarmNotificationAllocate( >>> + HANDLE, >>> + notification, >>> + 0, >>> + len(additional_text) + 1, >>> + len(additional_info), >>> + 0) >>> + >>> + # Fill in the header >>> + fill_in_header(notification.notificationHandle, >>> + notification.notificationHeader, >>> + notification_object, notifying_object, vendor_id, >>> + major_id, minor_id, additional_text, event_type, >>> + event_time, additional_info) >>> + >>> + # Fill in security alarm-specific fields >>> + notification.probableCause.contents.value = probable_cause >>> + notification.severity.contents.value = severity >>> + >>> + assign_ntf_value_to_attribute(notification.securityAlarmDetector, >>> + alarm_detector.value, >>> + alarm_detector.value_type) >>> + >>> + assign_ntf_value_to_attribute(notification.serviceUser, >>> + user.value, >>> + user.value_type) >>> + >>> + assign_ntf_value_to_attribute(notification.serviceProvider, >>> + provider.value, >>> + provider.value_type) >>> + >>> + # Send the alarm notification >>> + saNtfNotificationSend(notification.notificationHandle) >>> + >>> + # Free the alarm notification >>> + saNtfNotificationFree(notification.notificationHandle) >>> + >>> + >>> +def send_alarm_notification(vendor_id, major_id, minor_id, severity, >>> + additional_text="", >>> + notification_object="", >>> + notifying_object="", >>> + event_type=saNtf.eSaNtfEventTypeT.SA_NTF_ALARM_PROCESSING, >>> + event_time=saAis.saAis.SA_TIME_UNKNOWN, >>> + additional_info=[]): >>> + ''' Sends an alarm notification''' >>> + >>> + # Create the notification >>> + notification = saNtf.SaNtfAlarmNotificationT() >>> + >>> + saNtfAlarmNotificationAllocate( >>> + HANDLE, >>> + notification, >>> + 0, >>> + len(additional_text) + 1, >>> + len(additional_info), >>> + 0, >>> + 0, >>> + 0, >>> + 0) >>> + >>> + # Fill in the header >>> + fill_in_header(notification.notificationHandle, >>> + notification.notificationHeader, >>> + notification_object, notifying_object, vendor_id, >>> + major_id, minor_id, additional_text, event_type, >>> + event_time, additional_info) >>> + >>> + notification.numMonitoredAttributes = 0 >>> + notification.numSpecificProblems = 0 >>> + notification.numProposedRepairActions = 0 >>> + notification.perceivedSeverity.contents.value = severity >>> + notification.probableCause.contents.value = \ >>> + saNtf.eSaNtfProbableCauseT.SA_NTF_DEGRADED_SIGNAL >>> + >>> + # Send the alarm notification >>> + saNtfNotificationSend(notification.notificationHandle) >>> + >>> + # Free the alarm notification >>> + saNtfNotificationFree(notification.notificationHandle) >>> + >>> + >>> +def subscribe_for_notifications(notification_types=None): >>> + ''' Subscribes for notifications from NTF. The types of >>> notifications to >>> + subscribe to are passed in the notification_types list and >>> + subscriptions are set up for all types if the list is empty >>> + ''' >>> + >>> + filters = [] >>> + >>> + filter_handles = saNtf.SaNtfNotificationTypeFilterHandlesT() >>> + >>> + filter_handles.objectCreateDeleteFilterHandle = >>> saNtf.SaNtfNotificationFilterHandleT(0) >>> + filter_handles.attributeChangeFilterHandle = >>> saNtf.SaNtfNotificationFilterHandleT(0) >>> + filter_handles.stateChangeFilterHandle = >>> saNtf.SaNtfNotificationFilterHandleT(0) >>> + filter_handles.alarmFilterHandle = >>> saNtf.SaNtfNotificationFilterHandleT(0) >>> + filter_handles.securityFilterHandle = >>> saNtf.SaNtfNotificationFilterHandleT(0) >>> + >>> + >>> + # Create and allocate the alarm filter >>> + if not notification_types or \ >>> + saNtf.eSaNtfNotificationTypeT.SA_NTF_TYPE_ALARM in >>> notification_types: >>> + notification_filter = saNtf.SaNtfAlarmNotificationFilterT() >>> + >>> + saNtfAlarmNotificationFilterAllocate(HANDLE, >>> notification_filter, >>> + 0, 0, 0, 0, 0, 0, 0) >>> + >>> + filter_handles.alarmFilterHandle = >>> notification_filter.notificationFilterHandle >>> + >>> + filters.append(notification_filter.notificationFilterHandle) >>> + >>> + # Create and allocate the object create delete filter >>> + if not notification_types or \ >>> + saNtf.eSaNtfNotificationTypeT.SA_NTF_TYPE_OBJECT_CREATE_DELETE in >>> notification_types: >>> + notification_filter = >>> saNtf.SaNtfObjectCreateDeleteNotificationFilterT() >>> + >>> + saNtfObjectCreateDeleteNotificationFilterAllocate(HANDLE, >>> + notification_filter, >>> + 0, 0, 0, >>> 0, 0) >>> + >>> + filter_handles.objectCreateDeleteFilterHandle = >>> notification_filter.notificationFilterHandle >>> + filters.append(notification_filter.notificationFilterHandle) >>> + >>> + # Create and allocate the attribute change filter >>> + if not notification_types or \ >>> + saNtf.eSaNtfNotificationTypeT.SA_NTF_TYPE_ATTRIBUTE_CHANGE in >>> notification_types: >>> + >>> + notification_filter = >>> saNtf.SaNtfAttributeChangeNotificationFilterT() >>> + >>> + saNtfAttributeChangeNotificationFilterAllocate(HANDLE, >>> + notification_filter, >>> + 0, 0, 0, 0, 0) >>> + >>> + filter_handles.attributeChangeFilterHandle = >>> notification_filter.notificationFilterHandle >>> + >>> + filters.append(notification_filter.notificationFilterHandle) >>> + >>> + # Create and allocate the state change filter >>> + if not notification_types or \ >>> + saNtf.eSaNtfNotificationTypeT.SA_NTF_TYPE_STATE_CHANGE in >>> notification_types: >>> + >>> + notification_filter = >>> saNtf.SaNtfStateChangeNotificationFilterT() >>> + >>> + saNtfStateChangeNotificationFilterAllocate(HANDLE, >>> + notification_filter, >>> + 0, 0, 0, 0, 0, 0) >>> + >>> + filter_handles.stateChangeFilterHandle = >>> notification_filter.notificationFilterHandle >>> + >>> + filters.append(notification_filter.notificationFilterHandle) >>> + >>> + # Create and allocate the security alarm filter >>> + if not notification_types or \ >>> + saNtf.eSaNtfNotificationTypeT.SA_NTF_TYPE_SECURITY_ALARM in >>> notification_types: >>> + >>> + notification_filter = >>> saNtf.SaNtfSecurityAlarmNotificationFilterT() >>> + >>> + saNtfSecurityAlarmNotificationFilterAllocate(HANDLE, >>> + notification_filter, >>> + 0, 0, 0, 0, 0, >>> 0, 0, 0, 0) >>> + >>> + filter_handles.securityAlarmFilterHandle = >>> notification_filter.notificationFilterHandle >>> + >>> + filters.append(notification_filter.notificationFilterHandle) >>> + >>> + # Create a unique subscription id >>> + sub_id = saNtf.SaNtfSubscriptionIdT(1) >>> + >>> + # Start subscription >>> + saNtfNotificationSubscribe(filter_handles, sub_id) >>> + >>> + # Free up the filters >>> + for filter_handle in filters: >>> + saNtfNotificationFilterFree(filter_handle) >>> + >>> + >>> +def dispatch(mode=saAis.eSaDispatchFlagsT.SA_DISPATCH_ALL): >>> + ''' Invokes NTF callbacks for queued events. The default is to >>> dispatch all >>> + available events >>> + ''' >>> + >>> + saNtfDispatch(HANDLE, mode) >>> + >>> diff --git a/python/samples/README b/python/samples/README >>> --- a/python/samples/README >>> +++ b/python/samples/README >>> @@ -74,6 +74,17 @@ interface-handler: >>> netifaces library to do so. Run 'interface-handler >>> --help' for >>> specific options and arguments. >>> +ntfsend: >>> + The ntfsend sample application is a copy of the ntfsend tool, >>> + implemented in Python. It sends notifications through NTF. Run >>> + 'ntfsend --help' for specific options and arguments. >>> + >>> +ntfsubscribe: >>> + The ntfsubscribe sample application is a copy of the >>> + ntfsubscribe tool, implemented in Python. It listens for >>> + notifications and logs received notifications in the >>> + terminal. Run 'ntfsubscribe --help'. >>> + >>> Logging for all apps/utils goes to >>> /var/log/opensaf/saflog/saLogSystem*.log >>> The IMM OI samples use the classes defined in the classes.xml >>> file. Load it with immcfg -f classes.xml before trying them. >>> diff --git a/python/samples/ntfsend b/python/samples/ntfsend >>> new file mode 100755 >>> --- /dev/null >>> +++ b/python/samples/ntfsend >>> @@ -0,0 +1,251 @@ >>> +#! /usr/bin/env python >>> + >>> +import argparse >>> +import time >>> + >>> +from pyosaf import saNtf, saAis >>> +from pyosaf.utils import ntf >>> + >>> + >>> +def construct_additional_info(additional_info_string): >>> + ''' Constructs an AdditionalInfo instance from the given string. >>> + >>> + The string must be of the format ID,TYPE,VALUE >>> + ''' >>> + >>> + info_id = int(additional_info_string.split(',')[0]) >>> + info_type = int(additional_info_string.split(',')[1]) >>> + info_value = ','.join(additional_info_string.split(',')[2:]) >>> + >>> + return ntf.AdditionalInfo(info_id, info_type, info_value) >>> + >>> + >>> +if __name__ == '__main__': >>> + >>> + # Parse command line arguments >>> + parser = argparse.ArgumentParser( >>> + description='ntfsend is a SAF NTF client used to send a >>> notificaiton.') >>> + >>> + parser.add_argument('--notificationType', '-T', >>> metavar='0x1000...0x5000', >>> + default='0x4000', >>> + help='numeric value of SaNtfNotificationTypeT' >>> + '(obj_create_del=0x1000,attr_ch,state_ch,al,sec_al=0x5000)') >>> + parser.add_argument('--eventType', '-e', metavar='4096...24589', >>> + help='numeric value of SaNtfEventTypeT' >>> + '(SA_NTF_OBJECT_NOTIFICATIONS_START...SA_NTF_HPI_EVENT_OTHER)') >>> + parser.add_argument('--eventTime', '-E', metavar='TIME', >>> + default=saAis.saAis.SA_TIME_UNKNOWN, >>> + help='numeric value of SaTimeT') >>> + parser.add_argument('--notificationClassId', '-c', >>> metavar='VE,MA,MI', >>> + default='162,1,1', >>> + help='vendorid, majorid, minorid') >>> + parser.add_argument('--notificationObject', '-n', >>> metavar='NOT_OBJ', >>> + default="", >>> + help='notification object (string value)') >>> + parser.add_argument('--notifyingObject', '-N', >>> metavar='NOTIFY_OBJ', >>> + default="", >>> + help='notififying object (string value)') >>> + parser.add_argument('--additionalText', '-a', metavar='TEXT', >>> + default="", >>> + help='additional text (string value)') >>> + parser.add_argument('--probableCause', '-p', metavar='0..74', >>> + help='numeric value SaNtfProbableCauseT' >>> + 'SA_NTF_ADAPTER_ERROR to >>> SA_NTF_UNSPECIFIED_REASON') >>> + parser.add_argument('--perceivedSeverity', '-s', metavar='0...5', >>> + type=int, default='4', >>> + help='severity numeric value' >>> + '(clear=0,ind,warn,min,maj,crit=5)') >>> + parser.add_argument('--repeatSends', '-r', metavar='NUM', >>> + default=1, type=int, >>> + help='send the same notifification NUM times') >>> + parser.add_argument('--burstTimeout', '-b', metavar='TIME', >>> + default=0, type=int, >>> + help='send burst of NUM repeatSends ' >>> + '[default: 1] and sleep TIME (usec)' >>> + 'between each burst, will continue for ever') >>> + parser.add_argument('--additionalInfo', '-i', >>> metavar='ID,TYPE,VALUE', >>> + help='additional information' >>> + 'ID: SaNtfElementIdT integer value' >>> + 'TYPE: numeric value SaNtfValueTypeT, only ' >>> + 'SA_NTF_VALUE_STRING=11 is supported') >>> + >>> + args = parser.parse_args() >>> + >>> + # Fill in arguments >>> + vendor_id = int(args.notificationClassId.split(',')[0]) >>> + major_id = int(args.notificationClassId.split(',')[1]) >>> + minor_id = int(args.notificationClassId.split(',')[2]) >>> + >>> + event_time = int(args.eventTime) >>> + >>> + severity = int(args.perceivedSeverity) >>> + >>> + additional_text = args.additionalText >>> + notification_object = args.notificationObject >>> + notifying_object = args.notifyingObject >>> + >>> + # Initialize the NTF library >>> + ntf.initialize() >>> + >>> + # Send the notification >>> + ntf_type = int(args.notificationType, 0) >>> + >>> + if ntf_type == >>> saNtf.eSaNtfNotificationTypeT.SA_NTF_TYPE_OBJECT_CREATE_DELETE: >>> + >>> + # Create sample attributes >>> + attributes = [] >>> + >>> + attr1 = ntf.Attribute() >>> + >>> + attr1.attribute_id = 1 >>> + attr1.attribute_type = >>> saNtf.eSaNtfValueTypeT.SA_NTF_VALUE_INT16 >>> + attr1.attribute_value = 23 >>> + >>> + attributes.append(attr1) >>> + >>> + attr2 = ntf.Attribute() >>> + >>> + attr2.attribute_id = 2 >>> + attr2.attribute_type = >>> saNtf.eSaNtfValueTypeT.SA_NTF_VALUE_INT32 >>> + attr2.attribute_value = -3 >>> + >>> + attributes.append(attr2) >>> + >>> + # Create sample additional info >>> + additional_info = [] >>> + if args.additionalInfo: >>> + >>> additional_info.append(construct_additional_info(args.additionalInfo)) >>> + >>> + # Send the notification >>> + for i in range(0, args.repeatSends): >>> + ntf.send_object_create_notification(vendor_id, >>> + major_id, >>> + minor_id, >>> + additional_text=additional_text, >>> + notification_object=notification_object, >>> + notifying_object=notifying_object, >>> + attributes=attributes, >>> + event_time=event_time, >>> + additional_info=additional_info) >>> + >>> + time.sleep(args.burstTimeout) >>> + >>> + elif ntf_type == >>> saNtf.eSaNtfNotificationTypeT.SA_NTF_TYPE_SECURITY_ALARM: >>> + >>> + # Create security alarm sample fields >>> + >>> + detector = ntf.SecurityAlarmDetector( >>> + value=15, >>> + value_type=saNtf.eSaNtfValueTypeT.SA_NTF_VALUE_INT32 >>> + ) >>> + >>> + user = ntf.ServiceUser( >>> + value=-2, >>> + value_type=saNtf.eSaNtfValueTypeT.SA_NTF_VALUE_INT16 >>> + ) >>> + >>> + provider = ntf.ServiceProvider( >>> + value=128, >>> + value_type=saNtf.eSaNtfValueTypeT.SA_NTF_VALUE_UINT32 >>> + ) >>> + >>> + # Send the notification >>> + for i in range(0, args.repeatSends): >>> + ntf.send_security_alarm_notification(vendor_id, >>> major_id, minor_id, severity, >>> + detector, user, >>> provider, >>> + additional_text=additional_text, >>> + notification_object=notification_object, >>> + notifying_object=notifying_object, >>> + event_time=event_time) >>> + >>> + time.sleep(args.burstTimeout) >>> + >>> + elif ntf_type == saNtf.eSaNtfNotificationTypeT.SA_NTF_TYPE_ALARM: >>> + >>> + for i in range(0, args.repeatSends): >>> + ntf.send_alarm_notification(vendor_id, major_id, >>> minor_id, severity, >>> + additional_text=additional_text, >>> + notification_object=notification_object, >>> + notifying_object=notifying_object, >>> + event_time=event_time) >>> + >>> + time.sleep(args.burstTimeout) >>> + >>> + elif ntf_type == >>> saNtf.eSaNtfNotificationTypeT.SA_NTF_TYPE_ATTRIBUTE_CHANGE: >>> + >>> + # Fill in sample attribute changes >>> + >>> + attr0 = ntf.AttributeChange() >>> + >>> + attr0.attribute_id = 0 >>> + attr0.attribute_type = >>> saNtf.eSaNtfValueTypeT.SA_NTF_VALUE_INT32 >>> + attr0.old_attribute_present = saAis.eSaBoolT.SA_FALSE >>> + attr0.new_attribute_value = 1 >>> + >>> + attr1 = ntf.AttributeChange() >>> + >>> + attr1.attribute_id = 1 >>> + attr1.attribute_type = >>> saNtf.eSaNtfValueTypeT.SA_NTF_VALUE_INT32 >>> + attr1.old_attribute_present = saAis.eSaBoolT.SA_TRUE >>> + attr1.old_attribute_value = 8 >>> + attr1.new_attribute_value = -4 >>> + >>> + changed_attributes = [attr0, attr1] >>> + >>> + # Send the notification >>> + for i in range(0, args.repeatSends): >>> + ntf.send_attribute_change_notification(vendor_id, >>> major_id, minor_id, >>> + additional_text=additional_text, >>> + notification_object=notification_object, >>> + notifying_object=notifying_object, >>> + event_time=event_time, >>> + changed_attributes=changed_attributes) >>> + >>> + time.sleep(args.burstTimeout) >>> + >>> + elif ntf_type == >>> saNtf.eSaNtfNotificationTypeT.SA_NTF_TYPE_STATE_CHANGE: >>> + >>> + # Fill in sample state changes >>> + changes = [] >>> + >>> + change0 = ntf.StateChange() >>> + >>> + change0.state_id = 1 >>> + change0.old_state_present = False >>> + change0.new_state = 0 >>> + >>> + change1 = ntf.StateChange() >>> + >>> + change1.state_id = 2 >>> + change1.old_state_present = False >>> + change1.new_state = 5 >>> + >>> + change2 = ntf.StateChange() >>> + >>> + change2.state_id = 1 >>> + change2.old_state_present = True >>> + change2.old_state = 0 >>> + change2.new_state = 1 >>> + >>> + change3 = ntf.StateChange() >>> + >>> + change3.state_id = 2 >>> + change3.old_state_present = True >>> + change3.old_state = 5 >>> + change3.new_state = 10 >>> + >>> + changes.append(change0) >>> + changes.append(change1) >>> + changes.append(change2) >>> + changes.append(change3) >>> + >>> + # Send the notification >>> + for i in range(0, args.repeatSends): >>> + ntf.send_state_change_notification(vendor_id, major_id, >>> minor_id, >>> + additional_text=additional_text, >>> + notification_object=notification_object, >>> + notifying_object=notifying_object, >>> + event_time=event_time, >>> + state_changes=changes) >>> + >>> + time.sleep(args.burstTimeout) >>> diff --git a/python/samples/ntfsubscribe b/python/samples/ntfsubscribe >>> new file mode 100755 >>> --- /dev/null >>> +++ b/python/samples/ntfsubscribe >>> @@ -0,0 +1,307 @@ >>> +#! /usr/bin/env python >>> + >>> +import select >>> +import ctypes >>> +import datetime >>> +import argparse >>> + >>> +from pyosaf import saNtf, saAis >>> +from pyosaf.utils import ntf >>> + >>> +def SaNameT_to_string(name): >>> + ''' Converts an instance of SaNameT to a Python string''' >>> + >>> + return ctypes.create_string_buffer(name.value, name.length).value >>> + >>> +def p_char_to_string(p_char, length): >>> + ''' Converts a char pointer with a missing NULL pointer to a >>> string with the >>> + given length''' >>> + >>> + return ctypes.create_string_buffer(p_char, length).value >>> + >>> +def SaTimeT_to_date_string(sa_time): >>> + ''' Returns a string representation for the given SaTimeT >>> instance''' >>> + >>> + milli_seconds = sa_time / 1000000 >>> + >>> + return >>> datetime.datetime.fromtimestamp(milli_seconds/1000).isoformat() >>> + >>> +def print_notification_header(header): >>> + ''' Prints the given notification header''' >>> + >>> + class_id = header.notificationClassId.contents >>> + >>> + print '''eventType = %s >>> +notificationObject = "%s" >>> +notifyingObject = "%s" >>> +notificationClassId = %d.%d.%d (0x0) >>> +additionalText = "%s"''' % ( >>> + saNtf.eSaNtfEventTypeT.whatis(header.eventType.contents.value), >>> + SaNameT_to_string(header.notificationObject.contents), >>> + SaNameT_to_string(header.notifyingObject.contents), >>> + class_id.vendorId, >>> + class_id.majorId, >>> + class_id.minorId, >>> + p_char_to_string(header.additionalText, >>> header.lengthAdditionalText) >>> +) >>> + >>> + >>> +def print_alarm_notification(notification): >>> + ''' Prints the given alarm notification''' >>> + >>> + header = notification.notificationHeader >>> + >>> + print '=== %s - Alarm ===' % >>> SaTimeT_to_date_string(header.eventTime.contents.value) >>> + >>> + print_notification_header(header) >>> + >>> + print 'probableCause = %s' % \ >>> + >>> saNtf.eSaNtfProbableCauseT.whatis(notification.probableCause.contents.value) >>> + print 'perceivedSeverity = %s' % \ >>> + >>> saNtf.eSaNtfSeverityT.whatis(notification.perceivedSeverity.contents.value) >>> + >>> + >>> +def print_object_create_delete_notification(notification): >>> + ''' Prints the given object create delete notification''' >>> + >>> + header = notification.notificationHeader >>> + >>> + print '=== %s - Object Create/Delete ===' % >>> SaTimeT_to_date_string(header.eventTime.contents.value) >>> + >>> + print_notification_header(header) >>> + >>> + print 'sourceIndicator = %s' % \ >>> + >>> saNtf.eSaNtfSourceIndicatorT.whatis(notification.sourceIndicator.contents.value) >>> + >>> + print >>> + >>> + print 'numAttributes: %d' % notification.numAttributes >>> + >>> + for i in range(0, notification.numAttributes): >>> + >>> + c_attribute = notification.objectAttributes[i] >>> + >>> + print '- Attribute ID: %d -' % c_attribute.attributeId >>> + print ' Attribute Type: (%d) %s' % ( >>> + c_attribute.attributeType, >>> + saNtf.eSaNtfValueTypeT.whatis(c_attribute.attributeType) >>> + ) >>> + >>> + print ' Attribute Value: %d' % \ >>> + saNtf.unmarshalSaNtfValue(saAis.BYREF(c_attribute.attributeValue), >>> + c_attribute.attributeType) >>> + >>> + >>> +def print_attribute_change_notification(notification): >>> + ''' Prints the given attribute change notification''' >>> + >>> + header = notification.notificationHeader >>> + >>> + print '=== %s - Attribute Change ===' % >>> SaTimeT_to_date_string(header.eventTime.contents.value) >>> + >>> + print_notification_header(header) >>> + >>> + print 'sourceIndicator = %s' % \ >>> + >>> saNtf.eSaNtfSourceIndicatorT.whatis(notification.sourceIndicator.contents.value) >>> + >>> + print >>> + >>> + print 'numAttributes: %d' % notification.numAttributes >>> + >>> + for i in range(0, notification.numAttributes): >>> + >>> + c_attribute = notification.changedAttributes[i] >>> + >>> + print '''- Attribute ID: %d - >>> + Attribute Type: (%d) %s''' % ( >>> + c_attribute.attributeId, >>> + c_attribute.attributeType, >>> + saNtf.eSaNtfValueTypeT.whatis(c_attribute.attributeType) >>> +) >>> + >>> + if c_attribute.oldAttributePresent: >>> + print ''' Old Attribute Present: Yes >>> + Old Attribute Value: %s''' % \ >>> + saNtf.unmarshalSaNtfValue(saAis.BYREF(c_attribute.oldAttributeValue), >>> + c_attribute.attributeType) >>> + else: >>> + print ' Old Attribute Present: No' >>> + >>> + print ' Attribute Value: %s' % \ >>> + saNtf.unmarshalSaNtfValue(saAis.BYREF(c_attribute.newAttributeValue), >>> + c_attribute.attributeType) >>> + >>> + >>> +def print_state_change_notification(notification): >>> + ''' Prints the given state change notification''' >>> + >>> + header = notification.notificationHeader >>> + >>> + print '=== %s - State Change ===' % >>> SaTimeT_to_date_string(header.eventTime.contents.value) >>> + >>> + print_notification_header(header) >>> + >>> + print 'sourceIndicator = %s' % \ >>> + >>> saNtf.eSaNtfSourceIndicatorT.whatis(notification.sourceIndicator.contents.value) >>> + >>> + print >>> + >>> + i = 0 >>> + for c_state in notification.changedStates: >>> + >>> + if i == notification.numStateChanges: >>> + break >>> + >>> + i = i + 1 >>> + >>> + print '- State ID: %d -' % c_state.stateId >>> + >>> + if c_state.oldStatePresent: >>> + print ' Old State Present: Yes' >>> + print ' Old State: %s' % c_state.oldState >>> + else: >>> + print ' Old State Present: No' >>> + >>> + print ' New State: %s' % c_state.newState >>> + >>> + >>> +def print_security_alarm_notification(notification): >>> + ''' Prints the given security alarm notification''' >>> + >>> + header = notification.notificationHeader >>> + >>> + print '=== %s - Security Alarm ===' % >>> SaTimeT_to_date_string(header.eventTime.contents.value) >>> + >>> + print_notification_header(header) >>> + >>> + print'''probableCause = %s >>> +severity = %s >>> +Security Alarm Detector Type: %d >>> +Security Alarm Detector Value: %d >>> +Service User Type: %d >>> +Service User Value: %d >>> +Service Provider Type: %d >>> +Service Provider Value: %d >>> +''' % ( >>> + >>> saNtf.eSaNtfProbableCauseT.whatis(notification.probableCause.contents.value), >>> + saNtf.eSaNtfSeverityT.whatis(notification.severity.contents.value), >>> + notification.securityAlarmDetector.contents.valueType, >>> + >>> saNtf.unmarshalSaNtfValue(saAis.BYREF(notification.securityAlarmDetector.contents.value), >>> + notification.securityAlarmDetector.contents.valueType), >>> + notification.serviceUser.contents.valueType, >>> + >>> saNtf.unmarshalSaNtfValue(saAis.BYREF(notification.serviceUser.contents.value), >>> + notification.serviceUser.contents.valueType), >>> + notification.serviceProvider.contents.valueType, >>> + >>> saNtf.unmarshalSaNtfValue(saAis.BYREF(notification.serviceProvider.contents.value), >>> + notification.serviceProvider.contents.valueType) >>> +) >>> + >>> + >>> +def notification_received(subscription_id, c_p_notification): >>> + ''' Handle received notifications''' >>> + >>> + notification_type = c_p_notification.contents.notificationType >>> + >>> + print >>> + >>> + if notification_type == >>> saNtf.eSaNtfNotificationTypeT.SA_NTF_TYPE_ALARM: >>> + notification = >>> c_p_notification.contents.notification.alarmNotification >>> + >>> + print_alarm_notification(notification) >>> + >>> + elif notification_type == >>> saNtf.eSaNtfNotificationTypeT.SA_NTF_TYPE_OBJECT_CREATE_DELETE: >>> + notification = >>> c_p_notification.contents.notification.objectCreateDeleteNotification >>> + >>> + print_object_create_delete_notification(notification) >>> + >>> + elif notification_type == >>> saNtf.eSaNtfNotificationTypeT.SA_NTF_TYPE_ATTRIBUTE_CHANGE: >>> + notification = >>> c_p_notification.contents.notification.attributeChangeNotification >>> + >>> + print_attribute_change_notification(notification) >>> + >>> + elif notification_type == >>> saNtf.eSaNtfNotificationTypeT.SA_NTF_TYPE_STATE_CHANGE: >>> + notification = >>> c_p_notification.contents.notification.stateChangeNotification >>> + >>> + print_state_change_notification(notification) >>> + >>> + elif notification_type == >>> saNtf.eSaNtfNotificationTypeT.SA_NTF_TYPE_SECURITY_ALARM: >>> + notification = >>> c_p_notification.contents.notification.securityAlarmNotification >>> + >>> + print_security_alarm_notification(notification) >>> + >>> + >>> +if __name__ == '__main__': >>> + >>> + # Parse the parameters >>> + parser = argparse.ArgumentParser( >>> + description='ntfsubscribe is a SAF NTF client used to >>> subscribe for all incoming notifications.') >>> + >>> + parser.add_argument('--timeout', '-t', metavar='TIME', >>> + default=1, >>> + help='timeout (sec) waiting for notification') >>> + >>> + parser.add_argument('--alarm', '-a', >>> + dest='alarm', action='store_true', >>> + help='subscribe for only alarm notifications') >>> + >>> + parser.add_argument('--objectCreateDelete', '-o', >>> + dest='object_create_delete', >>> action='store_true', >>> + help='subscribe for only objectCreateDelete >>> notifications') >>> + >>> + parser.add_argument('--attributeChange', '-c', >>> + dest='attribute_change', action='store_true', >>> + help='subscribe for only attributeChange >>> notifications') >>> + >>> + parser.add_argument('--stateChange', '-s', >>> + dest='state_change', action='store_true', >>> + help='subscribe for only stateChange >>> notifications') >>> + >>> + parser.add_argument('--securityAlarm', '-y', >>> + dest='security_alarm', action='store_true', >>> + help='subscribe for only securityAlarm >>> notifications') >>> + >>> + args = parser.parse_args() >>> + >>> + print args.timeout >>> + >>> + # Initialize the NTF library >>> + ntf.initialize(notification_callback=notification_received) >>> + >>> + # Subscribe for notifications >>> + subscriptions = [] >>> + >>> + if args.object_create_delete: >>> + >>> subscriptions.append(saNtf.eSaNtfNotificationTypeT.SA_NTF_TYPE_OBJECT_CREATE_DELETE) >>> + >>> + if args.alarm: >>> + subscriptions.append(saNtf.eSaNtfNotificationTypeT.SA_NTF_TYPE_ALARM) >>> + >>> + if args.attribute_change: >>> + >>> subscriptions.append(saNtf.eSaNtfNotificationTypeT.SA_NTF_TYPE_ATTRIBUTE_CHANGE) >>> + >>> + if args.state_change: >>> + >>> subscriptions.append(saNtf.eSaNtfNotificationTypeT.SA_NTF_TYPE_STATE_CHANGE) >>> + >>> + if args.security_alarm: >>> + >>> subscriptions.append(saNtf.eSaNtfNotificationTypeT.SA_NTF_TYPE_SECURITY_ALARM) >>> + >>> + if subscriptions == []: >>> + ntf.subscribe_for_notifications() >>> + else: >>> + ntf.subscribe_for_notifications(notification_types=subscriptions) >>> + >>> + # Get selection object for the implementer >>> + selection_object = ntf.SELECTION_OBJECT.value >>> + >>> + # Wait for next OI event or one second timeout >>> + inputs = [selection_object] >>> + outputs = [] >>> + >>> + # Loop and wait for notifications >>> + while True: >>> + >>> + readable, writable, exceptional = \ >>> + select.select(inputs, outputs, inputs, args.timeout) >>> + >>> + if selection_object in readable: >>> + ntf.dispatch(saAis.eSaDispatchFlagsT.SA_DISPATCH_ALL) >> >> ------------------------------------------------------------------------------ >> >> >> _______________________________________________ >> Opensaf-devel mailing list >> Opensaf-devel@lists.sourceforge.net >> https://lists.sourceforge.net/lists/listinfo/opensaf-devel >> > > ------------------------------------------------------------------------------ Find and fix application performance issues faster with Applications Manager Applications Manager provides deep performance insights into multiple tiers of your business applications. It resolves application problems quickly and reduces your MTTR. Get your free trial! http://pubads.g.doubleclick.net/ gampad/clk?id=1444514301&iu=/ca-pub-7940484522588532 _______________________________________________ Opensaf-devel mailing list Opensaf-devel@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/opensaf-devel
