Hi Praveen,
The suite 35 requires IMM enables EXTENDED_NAME, so you need:
- Enable SA_ENABLE_EXTENDED_NAMES=1 in immnd.conf
- immcfg -m -a longDnsAllowed=1 opensafImm=opensafImm,safApp=safImmService
Thanks,
Minh
On 8/8/2014 7:49 PM, praveen malviya wrote:
>
> Hi Minh,
>
> Some how test cases of new suite 35 fails with
> SA_AIS_ERR_FAILED_OPERATION.
> Any prerequisite for executing them?
>
> -Praveen
>
>
> On 08-Aug-14 12:28 PM, Minh Hon Chau wrote:
>> tests/ntfsv/Makefile.am | 3 +-
>> tests/ntfsv/test_ntf_imcn.c | 508 ++++++++++++++-
>> tests/ntfsv/tet_longDnObject_notification.c | 972
>> ++++++++++++++++++++++++++++
>> tests/unit_test_fw/inc/util.h | 5 +-
>> tests/unit_test_fw/src/Makefile.am | 1 +
>> tests/unit_test_fw/src/util.c | 14 +-
>> 6 files changed, 1483 insertions(+), 20 deletions(-)
>>
>>
>> (1) Add testcase for AdditionInfo with extended name
>>
>> (2) Add testcase for create/modify/delete runtime&config object with
>> extended name attribute
>>
>> diff --git a/tests/ntfsv/Makefile.am b/tests/ntfsv/Makefile.am
>> --- a/tests/ntfsv/Makefile.am
>> +++ b/tests/ntfsv/Makefile.am
>> @@ -64,7 +64,8 @@ ntftest_SOURCES = \
>> tet_saNtfPtrValAllocate.c \
>> tet_saNtfArrayValGet.c \
>> tet_saNtfPtrValGet.c \
>> - test_ntfFilterVerification.c
>> + test_ntfFilterVerification.c \
>> + tet_longDnObject_notification.c
>>
>> ntftest_LDADD = \
>> $(top_builddir)/tests/unit_test_fw/src/libutest.la
>> diff --git a/tests/ntfsv/test_ntf_imcn.c b/tests/ntfsv/test_ntf_imcn.c
>> --- a/tests/ntfsv/test_ntf_imcn.c
>> +++ b/tests/ntfsv/test_ntf_imcn.c
>> @@ -39,6 +39,12 @@
>> static SaNtfHandleT ntfHandle;
>> static NotifData rec_notif_data;
>> static SaImmOiHandleT immOiHnd = 0;
>> +#define DEFAULT_EXT_NAME_LENGTH 300
>> +static char extended_name_string_01[DEFAULT_EXT_NAME_LENGTH];
>> +static char extended_name_string_02[DEFAULT_EXT_NAME_LENGTH];
>> +
>> +extern void saAisNameLend(SaConstStringT value, SaNameT* name);
>> +extern SaConstStringT saAisNameBorrow(const SaNameT* name);
>>
>> /**
>> * Callback routine, called when subscribed notification arrives.
>> @@ -976,6 +982,31 @@ static SaAisErrorT set_attr_buf(NotifDat
>> return error;
>> }
>>
>> +static SaAisErrorT set_attr_extended_name(NotifData* n_exp,
>> SaUint16T idx,
>> + SaNtfElementIdT attrId, SaNtfValueTypeT valType, void*
>> attrValue)
>> +{
>> + safassert(valType == SA_NTF_VALUE_LDAP_NAME, true);
>> + SaAisErrorT error = SA_AIS_OK;
>> + SaUint16T numAlloc = strlen(saAisNameBorrow((SaNameT*)attrValue));
>> + SaUint8T* temp = NULL;
>> + SaUint8T* srcPtr = (SaUint8T*)saAisNameBorrow((SaNameT*)attrValue);
>> +
>> + if (n_exp->c_d_notif_ptr != NULL) {
>> + error = saNtfPtrValAllocate(n_exp->nHandle,
>> + numAlloc,
>> + (void**) &temp,
>> + &n_exp->c_d_notif_ptr->objectAttributes[idx].attributeValue);
>> + if (error == SA_AIS_OK) {
>> + memcpy(temp, srcPtr, numAlloc);
>> + n_exp->c_d_notif_ptr->objectAttributes[idx].attributeId = attrId;
>> + n_exp->c_d_notif_ptr->objectAttributes[idx].attributeType = valType;
>> + }
>> + } else {
>> + error = SA_AIS_ERR_FAILED_OPERATION;
>> + }
>> + return error;
>> +}
>> +
>> /**
>> * Set an expected attribute value, type is string.
>> */
>> @@ -1038,6 +1069,34 @@ static SaAisErrorT set_attr_change_buf(N
>> return error;
>> }
>>
>> +static SaAisErrorT set_attr_change_extended_name(NotifData* n_exp,
>> SaUint16T idx,
>> + SaNtfElementIdT attrId, SaNtfValueTypeT valType, const void*
>> newValue)
>> +{
>> + safassert(valType == SA_NTF_VALUE_LDAP_NAME, true);
>> + SaAisErrorT error = SA_AIS_OK;
>> + SaUint16T numAlloc = strlen(saAisNameBorrow((SaNameT*)newValue));
>> + SaUint8T* temp = NULL;
>> + SaUint8T* srcPtr = (SaUint8T*)saAisNameBorrow((SaNameT*)newValue);
>> +
>> + if (n_exp->a_c_notif_ptr != NULL) {
>> + n_exp->a_c_notif_ptr->changedAttributes[idx].oldAttributePresent =
>> SA_FALSE;
>> + error = saNtfPtrValAllocate(n_exp->nHandle,
>> + numAlloc,
>> + (void**) &temp,
>> + &n_exp->a_c_notif_ptr->changedAttributes[idx].newAttributeValue);
>> + if (error == SA_AIS_OK) {
>> + memcpy(temp, srcPtr, numAlloc);
>> + n_exp->a_c_notif_ptr->changedAttributes[idx].attributeId = attrId;
>> + n_exp->a_c_notif_ptr->changedAttributes[idx].attributeType = valType;
>> + } else {
>> + error = SA_AIS_ERR_FAILED_OPERATION;
>> + }
>> + } else {
>> + error = SA_AIS_ERR_FAILED_OPERATION;
>> + }
>> + return error;
>> +}
>> +
>> /**
>> * Set expected attribute change value, type is
>> UINT32/INT32/UINT64/INT64/FLOAT/DOUBLE.
>> */
>> @@ -4256,6 +4315,432 @@ void objectDeleteTest_3404(void)
>> test_validate(error, SA_AIS_OK);
>> }
>>
>> +/**
>> + * Create a runtime test object with extended name attribute and
>> verify correctness
>> + * of generated notification.
>> + */
>> +void objectCreateTest_3501(void)
>> +{
>> + SaAisErrorT error = SA_AIS_OK;
>> + safassert(init_ntf(), SA_AIS_OK);
>> + safassert(subscribe_notifications(), SA_AIS_OK);
>> + rec_notif_data.populated = SA_FALSE;
>> +
>> + /* create the runtime object */
>> + SaInt32T int32Var = INT32VAR1;
>> + SaUint32T uint32Var = UINT32VAR1;
>> + SaInt64T int64Var = INT64VAR1;
>> + SaUint64T uint64Var = UINT64VAR1;
>> + SaTimeT timeVar = TIMEVAR1;
>> + SaNameT nameVar;
>> + saAisNameLend((SaConstStringT)&extended_name_string_01, &nameVar);
>> + SaFloatT floatVar = FLOATVAR1;
>> + SaDoubleT doubleVar = DOUBLEVAR1;
>> + SaStringT stringVar = STRINGVAR1;
>> + SaAnyT anyVar = {.bufferSize = sizeof (BUF1), .bufferAddr =
>> (SaUint8T*) BUF1};
>> +
>> + /*
>> + * Create the object in IMM.
>> + */
>> + create_rt_test_object("OsafNtfCmTestRT", DNTESTRT, int32Var,
>> uint32Var, int64Var, uint64Var,
>> + &timeVar, &nameVar, floatVar, doubleVar, &stringVar,
>> &anyVar);
>> +
>> + /*
>> + * Wait for notification reception.
>> + */
>> + int dwCnt = 0;
>> + while (dwCnt++ < POLLWAIT && !rec_notif_data.populated) {
>> + saNtfDispatch(ntfHandle, SA_DISPATCH_ALL);
>> + if (!rec_notif_data.populated) usleep(100);
>> + }
>> +
>> + if (rec_notif_data.populated) {
>> + NotifData n_exp;
>> + safassert(set_ntf(&n_exp, SA_NTF_OBJECT_CREATION, DNTESTRT,
>> 12, 12), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 0, 0,
>> "SaImmAttrImplementerName"), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 1, 1, "SaImmAttrClassName"),
>> SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 2, 2, "testUint32"), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 3, 3, "testInt32"), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 4, 4, "testUint64"), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 5, 5, "testInt64"), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 6, 6, "testString"), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 7, 7, "testFloat"), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 8, 8, "testDouble"), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 9, 9, "testName"), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 10, 10, "testTime"), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 11, 11, "testAny"), SA_AIS_OK);
>> + safassert(set_attr_str(&n_exp, 0, 0, IMPLEMENTERNAME_RT),
>> SA_AIS_OK);
>> + safassert(set_attr_str(&n_exp, 1, 1, "OsafNtfCmTestRT"),
>> SA_AIS_OK);
>> + safassert(set_attr_scalar(&n_exp, 2, 2, SA_NTF_VALUE_UINT32,
>> &uint32Var), SA_AIS_OK);
>> + safassert(set_attr_scalar(&n_exp, 3, 3, SA_NTF_VALUE_INT32,
>> &int32Var), SA_AIS_OK);
>> + safassert(set_attr_scalar(&n_exp, 4, 4, SA_NTF_VALUE_UINT64,
>> &uint64Var), SA_AIS_OK);
>> + safassert(set_attr_scalar(&n_exp, 5, 5, SA_NTF_VALUE_INT64,
>> &int64Var), SA_AIS_OK);
>> + safassert(set_attr_str(&n_exp, 6, 6, stringVar), SA_AIS_OK);
>> + safassert(set_attr_scalar(&n_exp, 7, 7, SA_NTF_VALUE_FLOAT,
>> &floatVar), SA_AIS_OK);
>> + safassert(set_attr_scalar(&n_exp, 8, 8, SA_NTF_VALUE_DOUBLE,
>> &doubleVar), SA_AIS_OK);
>> + safassert(set_attr_extended_name(&n_exp, 9, 9,
>> SA_NTF_VALUE_LDAP_NAME, &nameVar), SA_AIS_OK);
>> + safassert(set_attr_scalar(&n_exp, 10, 10,
>> SA_NTF_VALUE_INT64, &timeVar), SA_AIS_OK);
>> + safassert(set_attr_buf(&n_exp, 11, 11, SA_NTF_VALUE_BINARY,
>> &anyVar), SA_AIS_OK);
>> +
>> + if (!compare_notifs(&n_exp, &rec_notif_data)) {
>> + print_notif(&n_exp);
>> + print_notif(&rec_notif_data);
>> + error = SA_AIS_ERR_FAILED_OPERATION;
>> + }
>> +
>> + safassert(saNtfNotificationFree(rec_notif_data.nHandle), SA_AIS_OK);
>> + safassert(saNtfNotificationFree(n_exp.nHandle), SA_AIS_OK);
>> + } else {
>> + error = SA_AIS_ERR_FAILED_OPERATION;
>> + }
>> + safassert(unsub_notifications(), SA_AIS_OK);
>> + safassert(saNtfFinalize(ntfHandle), SA_AIS_OK);
>> + test_validate(error, SA_AIS_OK);
>> +}
>> +
>> +/**
>> + * Modify a runtime test object with extended name attribute and
>> verify correctness
>> + * of generated notification.
>> + */
>> +void objectModifyTest_3502(void)
>> +{
>> + SaAisErrorT error = SA_AIS_OK;
>> + safassert(init_ntf(), SA_AIS_OK);
>> + safassert(subscribe_notifications(), SA_AIS_OK);
>> + rec_notif_data.populated = SA_FALSE;
>> +
>> + SaNameT var1;
>> + saAisNameLend((SaConstStringT)&extended_name_string_02, &var1);
>> +
>> + SaAnyT var2 = {.bufferSize = sizeof (BUF2), .bufferAddr =
>> (SaUint8T*) BUF2};
>> + void* v1[] = {&var1};
>> + void* v2[] = {&var2};
>> + TestAttributeValue att1 = {
>> + .attrName = "testName", .attrType = SA_IMM_ATTR_SANAMET,
>> .attrValues = v1
>> + };
>> + TestAttributeValue att2 = {
>> + .attrName = "testAny", .attrType = SA_IMM_ATTR_SAANYT,
>> .attrValues = v2
>> + };
>> + TestAttributeValue * attrs[] = {&att1, &att2, NULL};
>> +
>> + /*
>> + * Modify (REPLACE) the object in IMM.
>> + */
>> + modify_rt_test_object(DNTESTRT, SA_IMM_ATTR_VALUES_REPLACE, attrs);
>> +
>> + /*
>> + * Wait for notification reception.
>> + */
>> + int dwCnt = 0;
>> + while (dwCnt++ < POLLWAIT && !rec_notif_data.populated) {
>> + saNtfDispatch(ntfHandle, SA_DISPATCH_ALL);
>> + if (!rec_notif_data.populated) usleep(100);
>> + }
>> +
>> + if (rec_notif_data.populated) {
>> + NotifData n_exp;
>> + safassert(set_ntf(&n_exp, SA_NTF_ATTRIBUTE_CHANGED,
>> DNTESTRT, 4, 4), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 0, 0,
>> "SaImmAttrImplementerName"), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 1, 1, "SaImmAttrClassName"),
>> SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 2, 2, "testName"), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 3, 3, "testAny"), SA_AIS_OK);
>> + safassert(set_attr_change_str(&n_exp, 0, 0,
>> IMPLEMENTERNAME_RT), SA_AIS_OK);
>> + safassert(set_attr_change_str(&n_exp, 1, 1,
>> "OsafNtfCmTestRT"), SA_AIS_OK);
>> + safassert(set_attr_change_extended_name(&n_exp, 2, 2,
>> SA_NTF_VALUE_LDAP_NAME, &var1), SA_AIS_OK);
>> + safassert(set_attr_change_buf(&n_exp, 3, 3,
>> SA_NTF_VALUE_BINARY, &var2), SA_AIS_OK);
>> +
>> + if (!compare_notifs(&n_exp, &rec_notif_data)) {
>> + print_notif(&n_exp);
>> + print_notif(&rec_notif_data);
>> + error = SA_AIS_ERR_FAILED_OPERATION;
>> + }
>> + safassert(saNtfNotificationFree(rec_notif_data.nHandle), SA_AIS_OK);
>> + safassert(saNtfNotificationFree(n_exp.nHandle), SA_AIS_OK);
>> + } else {
>> + error = SA_AIS_ERR_FAILED_OPERATION;
>> + }
>> + safassert(unsub_notifications(), SA_AIS_OK);
>> + safassert(saNtfFinalize(ntfHandle), SA_AIS_OK);
>> + test_validate(error, SA_AIS_OK);
>> +}
>> +
>> +
>> +/**
>> + * Modify a runtime test object with extended name attribute and
>> verify correctness
>> + * of generated notification.
>> + */
>> +void objectModifyTest_3503(void)
>> +{
>> + SaAisErrorT error = SA_AIS_OK;
>> + safassert(init_ntf(), SA_AIS_OK);
>> + safassert(subscribe_notifications(), SA_AIS_OK);
>> + rec_notif_data.populated = SA_FALSE;
>> +
>> + /* modify the runtime object */
>> +
>> + SaNameT oldvar;
>> + saAisNameLend((SaConstStringT)&extended_name_string_02, &oldvar);
>> + SaNameT addvar;
>> + saAisNameLend((SaConstStringT)&extended_name_string_01, &addvar);
>> + void* v[] = {&addvar};
>> + TestAttributeValue att = {
>> + .attrName = "testName", .attrType = SA_IMM_ATTR_SANAMET,
>> .attrValues = v
>> + };
>> + TestAttributeValue * attrs[] = {&att, NULL};
>> +
>> + /*
>> + * Modify (ADD) the object in IMM.
>> + */
>> + modify_rt_test_object(DNTESTRT, SA_IMM_ATTR_VALUES_ADD, attrs);
>> +
>> + /*
>> + * Wait for notification reception.
>> + */
>> + int dwCnt = 0;
>> + while (dwCnt++ < POLLWAIT && !rec_notif_data.populated) {
>> + saNtfDispatch(ntfHandle, SA_DISPATCH_ALL);
>> + if (!rec_notif_data.populated) usleep(100);
>> + }
>> +
>> + if (rec_notif_data.populated) {
>> + NotifData n_exp;
>> + safassert(set_ntf(&n_exp, SA_NTF_ATTRIBUTE_CHANGED,
>> DNTESTRT, 3, 4), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 0, 0,
>> "SaImmAttrImplementerName"), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 1, 1, "SaImmAttrClassName"),
>> SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 2, 2, "testName"), SA_AIS_OK);
>> + safassert(set_attr_change_str(&n_exp, 0, 0,
>> IMPLEMENTERNAME_RT), SA_AIS_OK);
>> + safassert(set_attr_change_str(&n_exp, 1, 1,
>> "OsafNtfCmTestRT"), SA_AIS_OK);
>> + safassert(set_attr_change_extended_name(&n_exp, 2, 2,
>> SA_NTF_VALUE_LDAP_NAME, &oldvar), SA_AIS_OK);
>> + safassert(set_attr_change_extended_name(&n_exp, 3, 2,
>> SA_NTF_VALUE_LDAP_NAME, &addvar), SA_AIS_OK);
>> +
>> + if (!compare_notifs(&n_exp, &rec_notif_data)) {
>> + print_notif(&n_exp);
>> + print_notif(&rec_notif_data);
>> + error = SA_AIS_ERR_FAILED_OPERATION;
>> + }
>> + safassert(saNtfNotificationFree(rec_notif_data.nHandle), SA_AIS_OK);
>> + safassert(saNtfNotificationFree(n_exp.nHandle), SA_AIS_OK);
>> + } else {
>> + error = SA_AIS_ERR_FAILED_OPERATION;
>> + }
>> + safassert(unsub_notifications(), SA_AIS_OK);
>> + safassert(saNtfFinalize(ntfHandle), SA_AIS_OK);
>> + test_validate(error, SA_AIS_OK);
>> +}
>> +
>> +
>> +/**
>> + * Create a config object with extended name attribute and verify
>> correctness of
>> + * generated notification.
>> + */
>> +void objectCreateTest_3505(void)
>> +{
>> + char command[1024];
>> + SaAisErrorT error = SA_AIS_OK;
>> + safassert(init_ntf(), SA_AIS_OK);
>> + safassert(subscribe_notifications(), SA_AIS_OK);
>> + rec_notif_data.populated = SA_FALSE;
>> +
>> + /* create an object */
>> + sprintf(command, "immcfg -t 20 -c OsafNtfCmTestCFG %s -a
>> testNameCfg=%s -a testStringCfg=%s -a testAnyCfg=%s",
>> + DNTESTCFG, extended_name_string_01, STRINGVAR1, BUF1);
>> + assert(system(command) != -1);
>> +
>> + /*
>> + * Wait for notification reception.
>> + */
>> + int dwCnt = 0;
>> + while (dwCnt++ < POLLWAIT && !rec_notif_data.populated) {
>> + saNtfDispatch(ntfHandle, SA_DISPATCH_ALL);
>> + if (!rec_notif_data.populated) usleep(100);
>> + }
>> +
>> + if (rec_notif_data.populated) {
>> + NotifData n_exp;
>> + SaInt32T int32Var = INT32VAR1;
>> + SaUint32T uint32Var = UINT32VAR1;
>> + SaInt64T int64Var = INT64VAR1;
>> + SaUint64T uint64Var = UINT64VAR1;
>> + SaTimeT timeVar = TIMEVAR1;
>> + SaNameT nameVar;
>> + saAisNameLend((SaConstStringT)&extended_name_string_01, &nameVar);
>> + SaFloatT floatVar = FLOATVAR1;
>> + SaDoubleT doubleVar = DOUBLEVAR1;
>> + SaStringT stringVar = STRINGVAR1;
>> + SaAnyT anyVar = {.bufferSize = sizeof (BUF1), .bufferAddr =
>> (SaUint8T*) BUF1};
>> +
>> + safassert(set_ntf(&n_exp, SA_NTF_OBJECT_CREATION, DNTESTCFG,
>> 14, 14), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 0, 0,
>> "SaImmAttrAdminOwnerName"), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 1, 1, "SaImmAttrClassName"),
>> SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 2, 2, "SaImmOiCcbIdT"),
>> SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 3, 3, "ccbLast"), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 4, 4, "testUint32Cfg"),
>> SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 5, 5, "testInt32Cfg"),
>> SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 6, 6, "testUint64Cfg"),
>> SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 7, 7, "testInt64Cfg"),
>> SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 8, 8, "testStringCfg"),
>> SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 9, 9, "testFloatCfg"),
>> SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 10, 10, "testDoubleCfg"),
>> SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 11, 11, "testNameCfg"),
>> SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 12, 12, "testTimeCfg"),
>> SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 13, 13, "testAnyCfg"),
>> SA_AIS_OK);
>> + safassert(set_attr_str(&n_exp, 0, 0, "immcfg_xxx"), SA_AIS_OK);
>> + safassert(set_attr_str(&n_exp, 1, 1, "OsafNtfCmTestCFG"),
>> SA_AIS_OK);
>> + SaUint64T ccidVar = 2;
>> + safassert(set_attr_scalar(&n_exp, 2, 2, SA_NTF_VALUE_UINT64,
>> &ccidVar), SA_AIS_OK);
>> + SaUint32T ccbLast = 1;
>> + safassert(set_attr_scalar(&n_exp, 3, 3, SA_NTF_VALUE_UINT32,
>> &ccbLast), SA_AIS_OK);
>> + safassert(set_attr_scalar(&n_exp, 4, 4, SA_NTF_VALUE_UINT32,
>> &uint32Var), SA_AIS_OK);
>> + safassert(set_attr_scalar(&n_exp, 5, 5, SA_NTF_VALUE_INT32,
>> &int32Var), SA_AIS_OK);
>> + safassert(set_attr_scalar(&n_exp, 6, 6, SA_NTF_VALUE_UINT64,
>> &uint64Var), SA_AIS_OK);
>> + safassert(set_attr_scalar(&n_exp, 7, 7, SA_NTF_VALUE_INT64,
>> &int64Var), SA_AIS_OK);
>> + safassert(set_attr_str(&n_exp, 8, 8, stringVar), SA_AIS_OK);
>> + safassert(set_attr_scalar(&n_exp, 9, 9, SA_NTF_VALUE_FLOAT,
>> &floatVar), SA_AIS_OK);
>> + safassert(set_attr_scalar(&n_exp, 10, 10,
>> SA_NTF_VALUE_DOUBLE, &doubleVar), SA_AIS_OK);
>> + safassert(set_attr_extended_name(&n_exp, 11, 11,
>> SA_NTF_VALUE_LDAP_NAME, &nameVar), SA_AIS_OK);
>> + safassert(set_attr_scalar(&n_exp, 12, 12,
>> SA_NTF_VALUE_INT64, &timeVar), SA_AIS_OK);
>> + safassert(set_attr_buf(&n_exp, 13, 13, SA_NTF_VALUE_BINARY,
>> &anyVar), SA_AIS_OK);
>> +
>> + if (!compare_notifs(&n_exp, &rec_notif_data)) {
>> + print_notif(&n_exp);
>> + print_notif(&rec_notif_data);
>> + error = SA_AIS_ERR_FAILED_OPERATION;
>> + }
>> + safassert(saNtfNotificationFree(rec_notif_data.nHandle), SA_AIS_OK);
>> + safassert(saNtfNotificationFree(n_exp.nHandle), SA_AIS_OK);
>> + } else {
>> + error = SA_AIS_ERR_FAILED_OPERATION;
>> + }
>> + safassert(unsub_notifications(), SA_AIS_OK);
>> + safassert(saNtfFinalize(ntfHandle), SA_AIS_OK);
>> + test_validate(error, SA_AIS_OK);
>> +}
>> +
>> +
>> +/**
>> + * Modify a config object with extended name and verify correctness
>> + * of generated notification.
>> + */
>> +void objectModifyTest_3506(void)
>> +{
>> + char command[1024];
>> + SaAisErrorT error = SA_AIS_OK;
>> + safassert(init_ntf(), SA_AIS_OK);
>> + safassert(subscribe_notifications(), SA_AIS_OK);
>> + rec_notif_data.populated = SA_FALSE;
>> +
>> + SaNameT var1;
>> + saAisNameLend((SaConstStringT)&extended_name_string_02, &var1);
>> +
>> + SaAnyT var2 = {.bufferSize = sizeof (BUF2), .bufferAddr =
>> (SaUint8T*) BUF2};
>> +
>> + /* modify an object */
>> + sprintf(command, "immcfg -t 20 -a testNameCfg=%s -a
>> testAnyCfg=%s %s",
>> + extended_name_string_02, BUF2, DNTESTCFG);
>> + assert(system(command) != -1);
>> +
>> + /*
>> + * Wait for notification reception.
>> + */
>> + int dwCnt = 0;
>> + while (dwCnt++ < POLLWAIT && !rec_notif_data.populated) {
>> + saNtfDispatch(ntfHandle, SA_DISPATCH_ALL);
>> + if (!rec_notif_data.populated) usleep(100);
>> + }
>> +
>> + if (rec_notif_data.populated) {
>> + NotifData n_exp;
>> + safassert(set_ntf(&n_exp, SA_NTF_ATTRIBUTE_CHANGED,
>> DNTESTCFG, 6, 6), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 0, 0,
>> "SaImmAttrAdminOwnerName"), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 1, 1, "SaImmAttrClassName"),
>> SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 2, 2, "SaImmOiCcbIdT"),
>> SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 3, 3, "ccbLast"), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 4, 4, "testNameCfg"),
>> SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 5, 5, "testAnyCfg"), SA_AIS_OK);
>> + safassert(set_attr_change_str(&n_exp, 0, 0, "immcfg_xxx"),
>> SA_AIS_OK);
>> + safassert(set_attr_change_str(&n_exp, 1, 1,
>> "OsafNtfCmTestCFG"), SA_AIS_OK);
>> + SaUint64T ccidVar = 3;
>> + safassert(set_attr_change_scalar(&n_exp, 2, 2,
>> SA_NTF_VALUE_UINT64, &ccidVar), SA_AIS_OK);
>> + SaUint32T ccbLast = 1;
>> + safassert(set_attr_change_scalar(&n_exp, 3, 3,
>> SA_NTF_VALUE_UINT32, &ccbLast), SA_AIS_OK);
>> + safassert(set_attr_change_extended_name(&n_exp, 4, 4,
>> SA_NTF_VALUE_LDAP_NAME, &var1), SA_AIS_OK);
>> + safassert(set_attr_change_buf(&n_exp, 5, 5,
>> SA_NTF_VALUE_BINARY, &var2), SA_AIS_OK);
>> +
>> + if (!compare_notifs(&n_exp, &rec_notif_data)) {
>> + print_notif(&n_exp);
>> + print_notif(&rec_notif_data);
>> + error = SA_AIS_ERR_FAILED_OPERATION;
>> + }
>> + safassert(saNtfNotificationFree(rec_notif_data.nHandle), SA_AIS_OK);
>> + safassert(saNtfNotificationFree(n_exp.nHandle), SA_AIS_OK);
>> + } else {
>> + error = SA_AIS_ERR_FAILED_OPERATION;
>> + }
>> + safassert(unsub_notifications(), SA_AIS_OK);
>> + safassert(saNtfFinalize(ntfHandle), SA_AIS_OK);
>> + test_validate(error, SA_AIS_OK);
>> +}
>> +
>> +/**
>> + * Modify a config object with extended name attribute and verify
>> correctness
>> + * of generated notification.
>> + */
>> +void objectModifyTest_3507(void)
>> +{
>> + char command[1024];
>> + SaAisErrorT error = SA_AIS_OK;
>> + safassert(init_ntf(), SA_AIS_OK);
>> + safassert(subscribe_notifications(), SA_AIS_OK);
>> + rec_notif_data.populated = SA_FALSE;
>> +
>> + /* modify an object */
>> + SaNameT oldvar;
>> + saAisNameLend((SaConstStringT)&extended_name_string_02, &oldvar);
>> + SaNameT addvar;
>> + saAisNameLend((SaConstStringT)&extended_name_string_01, &addvar);
>> + sprintf(command, "immcfg -a testNameCfg+=%s %s",
>> extended_name_string_01, DNTESTCFG);
>> + assert(system(command) != -1);
>> +
>> + /*
>> + * Wait for notification reception.
>> + */
>> + int dwCnt = 0;
>> + while (dwCnt++ < POLLWAIT && !rec_notif_data.populated) {
>> + saNtfDispatch(ntfHandle, SA_DISPATCH_ALL);
>> + if (!rec_notif_data.populated) usleep(100);
>> + }
>> +
>> + if (rec_notif_data.populated) {
>> + NotifData n_exp;
>> + safassert(set_ntf(&n_exp, SA_NTF_ATTRIBUTE_CHANGED,
>> DNTESTCFG, 5, 6), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 0, 0,
>> "SaImmAttrAdminOwnerName"), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 1, 1, "SaImmAttrClassName"),
>> SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 2, 2, "SaImmOiCcbIdT"),
>> SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 3, 3, "ccbLast"), SA_AIS_OK);
>> + safassert(set_add_info(&n_exp, 4, 4, "testNameCfg"),
>> SA_AIS_OK);
>> + safassert(set_attr_change_str(&n_exp, 0, 0, "immcfg_xxx"),
>> SA_AIS_OK);
>> + safassert(set_attr_change_str(&n_exp, 1, 1,
>> "OsafNtfCmTestCFG"), SA_AIS_OK);
>> + SaUint64T ccidVar = 3;
>> + safassert(set_attr_change_scalar(&n_exp, 2, 2,
>> SA_NTF_VALUE_UINT64, &ccidVar), SA_AIS_OK);
>> + SaUint32T ccbLast = 1;
>> + safassert(set_attr_change_scalar(&n_exp, 3, 3,
>> SA_NTF_VALUE_UINT32, &ccbLast), SA_AIS_OK);
>> + safassert(set_attr_change_extended_name(&n_exp, 4, 4,
>> SA_NTF_VALUE_LDAP_NAME, &oldvar), SA_AIS_OK);
>> + safassert(set_attr_change_extended_name(&n_exp, 5, 4,
>> SA_NTF_VALUE_LDAP_NAME, &addvar), SA_AIS_OK);
>> +
>> + if (!compare_notifs(&n_exp, &rec_notif_data)) {
>> + print_notif(&n_exp);
>> + print_notif(&rec_notif_data);
>> + error = SA_AIS_ERR_FAILED_OPERATION;
>> + }
>> + safassert(saNtfNotificationFree(rec_notif_data.nHandle), SA_AIS_OK);
>> + safassert(saNtfNotificationFree(n_exp.nHandle), SA_AIS_OK);
>> + } else {
>> + error = SA_AIS_ERR_FAILED_OPERATION;
>> + }
>> + safassert(unsub_notifications(), SA_AIS_OK);
>> + safassert(saNtfFinalize(ntfHandle), SA_AIS_OK);
>> + test_validate(error, SA_AIS_OK);
>> +}
>>
>> __attribute__((constructor)) static void ntf_imcn_constructor(void)
>> {
>> @@ -4290,9 +4775,15 @@ void objectDeleteTest_3404(void)
>> rc = system("immcfg -f //tmp//ntfsv_test_classes.xml");
>> }
>> if (rc != 0) {
>> - printf("ntfsv_test_classes.xml file not installed (see
>> README)");
>> - return;
>> - }
>> + printf("ntfsv_test_classes.xml file not installed (see
>> README)");
>> + return;
>> + }
>> + memset(&extended_name_string_01, 'C', DEFAULT_EXT_NAME_LENGTH - 1);
>> + extended_name_string_01[DEFAULT_EXT_NAME_LENGTH - 1] = '\0';
>> +
>> + memset(&extended_name_string_02, 'D', DEFAULT_EXT_NAME_LENGTH - 1);
>> + extended_name_string_02[DEFAULT_EXT_NAME_LENGTH - 1] = '\0';
>> +
>> test_suite_add(32, "CM notifications test");
>> test_case_add(32, objectCreateTest_01, "CREATE, runtime
>> (OsafNtfCmTestRT) object");
>> test_case_add(32, objectModifyTest_02, "runtime, attr ch,
>> REPLACE (UINT32, FLOAT)");
>> @@ -4334,10 +4825,21 @@ void objectDeleteTest_3404(void)
>> test_case_add(32, objectMultiCcbTest_38, "config, multiple op
>> in ccb, 2 REPLACE");
>> test_case_add(32, objectMultiCcbTest_39, "config, multiple op
>> in ccb, ADD, REPLACE, DELETE");
>> test_case_add(32, objectDeleteTest_40, "DELETE, config
>> (OsafNtfCmTestCFG) object");
>> +
>> test_suite_add(34, "CM notifications test, persistent runtime");
>> test_case_add(34, objectCreateTest_3401, "CREATE, runtime
>> (OsafNtfCmTestRT1) object");
>> test_case_add(34, objectModifyTest_3402, "runtime, attr ch,
>> REPLACE (UINT32, FLOAT)");
>> test_case_add(34, objectModifyTest_3403, "runtime, attr ch, ADD
>> (INT32)");
>> test_case_add(34, objectDeleteTest_3404, "DELETE, runtime
>> (OsafNtfCmTestRT1) object");
>> +
>> + test_suite_add(35, "CM notification test for extended name
>> attribute");
>> + test_case_add(35, objectCreateTest_3501, "CREATE, runtime
>> (OsafNtfCmTestRT) object, extended name attribute");
>> + test_case_add(35, objectModifyTest_3502, "runtime, attr ch,
>> REPLACE (EXTENDED NAME, ANY)");
>> + test_case_add(35, objectModifyTest_3503, "runtime, attr ch, ADD
>> (EXTENDED NAME)");
>> + test_case_add(35, objectDeleteTest_19, "DELETE, runtime
>> (OsafNtfCmTestRT) object");
>> + test_case_add(35, objectCreateTest_3505, "CREATE, config
>> (OsafNtfCmTestCFG) object, extended name attribute");
>> + test_case_add(35, objectModifyTest_3506, "config, attr ch,
>> REPLACE (EXTENDED NAME, ANY)");
>> + test_case_add(35, objectModifyTest_3507, "config, attr ch, ADD
>> (EXTENDED NAME)");
>> + test_case_add(35, objectDeleteTest_40, "DELETE, config
>> (OsafNtfCmTestCFG) object");
>> }
>>
>> diff --git a/tests/ntfsv/tet_longDnObject_notification.c
>> b/tests/ntfsv/tet_longDnObject_notification.c
>> new file mode 100644
>> --- /dev/null
>> +++ b/tests/ntfsv/tet_longDnObject_notification.c
>> @@ -0,0 +1,972 @@
>> +/* -*- OpenSAF -*-
>> + *
>> + * (C) Copyright 2009 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 AB
>> + *
>> + */
>> +/**
>> +
>> + */
>> +#include <utest.h>
>> +#include <util.h>
>> +#include "tet_ntf.h"
>> +#include "tet_ntf_common.h"
>> +//#include "util.h"
>> +#define NOTIFYING_OBJECT_TEST "AVND"
>> +#define NTF_REST_MAX_IDS 30
>> +
>> +#define DEFAULT_EXT_NAME_LENGTH 300
>> +#define DEFAULT_UNEXT_NAME_STRING "This is unextended SaNameT string
>> (<256)"
>> +struct not_idsT {
>> + int length;
>> + SaNtfIdentifierT ids[NTF_REST_MAX_IDS];
>> +};
>> +
>> +static struct not_idsT received_ids = {0,};
>> +static struct not_idsT ok_ids = {0,};
>> +
>> +static char default_ext_notification_object[DEFAULT_EXT_NAME_LENGTH];
>> +static char default_ext_notifying_object[DEFAULT_EXT_NAME_LENGTH];
>> +static char test_longdn_object_1[DEFAULT_EXT_NAME_LENGTH];
>> +static char test_longdn_object_2[DEFAULT_EXT_NAME_LENGTH];
>> +static char test_longdn_object_3[DEFAULT_EXT_NAME_LENGTH];
>> +
>> +static SaNtfNotificationTypeFilterHandlesT myNotificationFilterHandles;
>> +
>> +/* Used to keep track of which ntf we got */
>> +static SaNtfNotificationTypeFilterHandlesT ntfRecieved;
>> +
>> +static int errors;
>> +static SaNtfSubscriptionIdT subscriptionId;
>> +static SaNtfAlarmNotificationT myAlarmNotification;
>> +static SaNtfObjectCreateDeleteNotificationT myObjCrDelNotification;
>> +static SaNtfAttributeChangeNotificationT myAttrChangeNotification;
>> +static SaNtfStateChangeNotificationT myStateChangeNotification;
>> +static SaNtfSecurityAlarmNotificationT mySecAlarmNotification;
>> +
>> +extern void saAisNameLend(SaConstStringT value, SaNameT* name);
>> +extern SaConstStringT saAisNameBorrow(const SaNameT* name);
>> +
>> +/**
>> + * Init default long dn objects
>> + */
>> +static void init_ext_object()
>> +{
>> + safassert(setenv("SA_ENABLE_EXTENDED_NAMES", "1", 1), 0);
>> +
>> + memset(&default_ext_notification_object, 'A',
>> DEFAULT_EXT_NAME_LENGTH - 1);
>> + default_ext_notification_object[DEFAULT_EXT_NAME_LENGTH - 1] =
>> '\0';
>> +
>> + memset(&default_ext_notifying_object, 'B',
>> DEFAULT_EXT_NAME_LENGTH - 1);
>> + default_ext_notifying_object[DEFAULT_EXT_NAME_LENGTH - 1] = '\0';
>> +
>> + memset(&test_longdn_object_1, 'C', DEFAULT_EXT_NAME_LENGTH - 1);
>> + test_longdn_object_1[DEFAULT_EXT_NAME_LENGTH - 1] = '\0';
>> +
>> + memset(&test_longdn_object_2, 'D', DEFAULT_EXT_NAME_LENGTH - 1);
>> + test_longdn_object_2[DEFAULT_EXT_NAME_LENGTH - 1] = '\0';
>> +
>> + memset(&test_longdn_object_3, 'E', DEFAULT_EXT_NAME_LENGTH - 1);
>> + test_longdn_object_3[DEFAULT_EXT_NAME_LENGTH - 1] = '\0';
>> +
>> +}
>> +
>> +/**
>> + * Store all recieved notificationIds
>> + */
>> +static void ntf_id_store(SaNtfIdentifierT n_id)
>> +{
>> + assert(NTF_REST_MAX_IDS > received_ids.length);
>> + received_ids.ids[received_ids.length++] = n_id;
>> +}
>> +
>> +/**
>> + * Post process all recived notificationIds towards the ids that
>> + * are expected to be received.
>> + */
>> +static SaAisErrorT check_errors()
>> +{
>> + int i, j, found;
>> + SaAisErrorT rc = SA_AIS_OK;
>> +
>> + for (i = 0; i< received_ids.length; i++) {
>> + found=0;
>> + for (j= 0; j< ok_ids.length; j++) {
>> + if (received_ids.ids[i] == ok_ids.ids[j]){
>> + found = 1;
>> + break;
>> + }
>> + }
>> + if(!found)
>> + errors++;
>> + }
>> + if(errors)
>> + {
>> + rc = SA_AIS_ERR_FAILED_OPERATION;
>> + printf("num of failed notifications: %d\n", errors);
>> + }
>> + return rc;
>> +}
>> +
>> +static void resetCounters()
>> +{
>> + errors = 0;
>> + received_ids.length = 0;
>> + ok_ids.length = 0;
>> + ntfRecieved.alarmFilterHandle = 0;
>> + ntfRecieved.attributeChangeFilterHandle = 0;
>> + ntfRecieved.objectCreateDeleteFilterHandle = 0;
>> + ntfRecieved.securityAlarmFilterHandle = 0;
>> + ntfRecieved.stateChangeFilterHandle = 0;
>> +}
>> +
>> +/**
>> + * Creates an ObjectCreateDeleteNotification with default values.
>> + *
>> + * @param ntfHandle
>> + * @param myObjCreDelNotification
>> + */
>> +void extCreateObjectCreateDeleteNotification(SaNtfHandleT ntfHandle,
>> + SaNtfObjectCreateDeleteNotificationT *myObjCrDelNotification)
>> +{
>> + SaNtfNotificationHeaderT *head;
>> +
>> + createObjectCreateDeleteNotification(ntfHandle,
>> myObjCrDelNotification);
>> + head = &myObjCrDelNotification->notificationHeader;
>> + /* Overwrite with long dn object */
>> + saAisNameLend((SaConstStringT)&default_ext_notification_object,
>> head->notificationObject);
>> + saAisNameLend((SaConstStringT)&default_ext_notifying_object,
>> head->notifyingObject);
>> +}
>> +
>> +/**
>> + * Creates an AttributeChangeNotification with default values.
>> + *
>> + * @param ntfhandle
>> + * @param myAttrChangeNotification
>> + */
>> +void extCreateAttributeChangeNotification(SaNtfHandleT ntfHandle,
>> + SaNtfAttributeChangeNotificationT *myAttrChangeNotification)
>> +{
>> + SaNtfNotificationHeaderT *head;
>> +
>> + createAttributeChangeNotification(ntfHandle,
>> myAttrChangeNotification);
>> + head = &myAttrChangeNotification->notificationHeader;
>> + /* Overwrite with long dn object */
>> + saAisNameLend((SaConstStringT)&default_ext_notification_object,
>> head->notificationObject);
>> + saAisNameLend((SaConstStringT)&default_ext_notifying_object,
>> head->notifyingObject);
>> +}
>> +
>> +/**
>> + * Create a StateChangeNotification with default values.
>> + *
>> + * @param ntfHandle
>> + * @param myStateChangeNotification
>> + */
>> +void extCreateStateChangeNotification(SaNtfHandleT ntfHandle,
>> + SaNtfStateChangeNotificationT *myStateChangeNotification)
>> +{
>> + SaNtfNotificationHeaderT *head;
>> +
>> + createStateChangeNotification(ntfHandle,
>> myStateChangeNotification);
>> + head = &myStateChangeNotification->notificationHeader;
>> + /* Overwrite with long dn object */
>> + saAisNameLend((SaConstStringT)&default_ext_notification_object,
>> head->notificationObject);
>> + saAisNameLend((SaConstStringT)&default_ext_notifying_object,
>> head->notifyingObject);
>> +}
>> +
>> +/**
>> + * Create a SecurityAlarmNotification with default values.
>> + *
>> + * @param ntfHandle
>> + * @param mySecAlarmNotification
>> + */
>> +void extCreateSecurityAlarmNotification(SaNtfHandleT ntfHandle,
>> + SaNtfSecurityAlarmNotificationT *mySecAlarmNotification)
>> +{
>> + SaNtfNotificationHeaderT *head;
>> +
>> + createSecurityAlarmNotification(ntfHandle, mySecAlarmNotification);
>> + head = &mySecAlarmNotification->notificationHeader;
>> + /* Overwrite with long dn object */
>> + saAisNameLend((SaConstStringT)&default_ext_notification_object,
>> head->notificationObject);
>> + saAisNameLend((SaConstStringT)&default_ext_notifying_object,
>> head->notifyingObject);
>> +}
>> +
>> +/**
>> + * Verify the contents in the notification.
>> + * We use the myNotificationFilterHandles to know which
>> notifications to expect.
>> + */
>> +static void saNtfNotificationCallbackT(
>> + SaNtfSubscriptionIdT subscriptionId,
>> + const SaNtfNotificationsT *notification)
>> +{
>> + SaNtfNotificationHandleT notificationHandle = 0;
>> + switch(notification->notificationType)
>> + {
>> + case SA_NTF_TYPE_OBJECT_CREATE_DELETE:
>> + notificationHandle =
>> notification->notification.objectCreateDeleteNotification.notificationHandle;
>> + ntfRecieved.objectCreateDeleteFilterHandle += 1;
>> + if(myNotificationFilterHandles.objectCreateDeleteFilterHandle == 0)
>> + errors +=1;
>> + else
>> +
>> ntf_id_store(*notification->notification.objectCreateDeleteNotification.notificationHeader.notificationId);
>> + break;
>> +
>> + case SA_NTF_TYPE_ATTRIBUTE_CHANGE:
>> + notificationHandle =
>> notification->notification.attributeChangeNotification.notificationHandle;
>> + ntfRecieved.attributeChangeFilterHandle += 1;
>> + if(myNotificationFilterHandles.attributeChangeFilterHandle == 0)
>> + errors += 1;
>> + else
>> +
>> ntf_id_store(*notification->notification.attributeChangeNotification.notificationHeader.notificationId);
>> + break;
>> +
>> + case SA_NTF_TYPE_STATE_CHANGE:
>> + notificationHandle =
>> notification->notification.stateChangeNotification.notificationHandle;
>> + ntfRecieved.stateChangeFilterHandle += 1;
>> + if(myNotificationFilterHandles.stateChangeFilterHandle == 0)
>> + errors += 1;
>> + else
>> +
>> ntf_id_store(*notification->notification.stateChangeNotification.notificationHeader.notificationId);
>> + break;
>> +
>> + case SA_NTF_TYPE_ALARM:
>> + notificationHandle =
>> notification->notification.alarmNotification.notificationHandle;
>> + ntfRecieved.alarmFilterHandle += 1;
>> + if(myNotificationFilterHandles.alarmFilterHandle == 0) {
>> + printf("alarmFilterHandle == 0\n");
>> + errors +=1;
>> + } else
>> +
>> ntf_id_store(*notification->notification.alarmNotification.notificationHeader.notificationId);
>> + break;
>> +
>> + case SA_NTF_TYPE_SECURITY_ALARM:
>> + notificationHandle =
>> notification->notification.securityAlarmNotification.notificationHandle;
>> + ntfRecieved.securityAlarmFilterHandle += 1;
>> + if(myNotificationFilterHandles.securityAlarmFilterHandle == 0)
>> + errors += 1;
>> + else
>> +
>> ntf_id_store(*notification->notification.securityAlarmNotification.notificationHeader.notificationId);
>> + break;
>> +
>> + default:
>> + errors +=1;
>> + assert(0);
>> + break;
>> + }
>> + last_not_id = get_ntf_id(notification);
>> + if (notificationHandle != 0)
>> + safassert(saNtfNotificationFree(notificationHandle),
>> SA_AIS_OK);
>> +}
>> +
>> +
>> +static SaNtfCallbacksT ntfCbTest = {
>> + saNtfNotificationCallbackT,
>> + NULL
>> +};
>> +
>> +/**
>> + * Fill the filter header with long dn objects
>> + */
>> +void extFillFilterHeader(SaNtfNotificationFilterHeaderT *head)
>> +{
>> + fillFilterHeader(head);
>> + /* Overwrite the objects with long dn */
>> + saAisNameLend((SaConstStringT)&default_ext_notification_object,
>> &head->notificationObjects[0]);
>> + saAisNameLend((SaConstStringT)&default_ext_notifying_object,
>> &head->notifyingObjects[0]);
>> +}
>> +
>> +/**
>> + * Fill the header with long dn objects
>> + */
>> +void extFillHeader(SaNtfNotificationHeaderT *head)
>> +{
>> + fillHeader(head);
>> + /* Overwrite the objects with long dn */
>> + saAisNameLend((SaConstStringT)&default_ext_notification_object,
>> head->notificationObject);
>> + saAisNameLend((SaConstStringT)&default_ext_notifying_object,
>> head->notifyingObject);
>> +}
>> +
>> +
>> +/**
>> + * Fill header with extended SaNameT in additionalInfo
>> + */
>> + void extFillHeaderAddInfo(SaNtfNotificationHeaderT *head,
>> SaNtfNotificationHandleT notHandle)
>> + {
>> + int i;
>> + SaStringT dest_ptr;
>> + SaNameT name1, name2, name3, name4, name5;
>> + *(head->eventType) = SA_NTF_ALARM_COMMUNICATION;
>> + *(head->eventTime) = SA_TIME_UNKNOWN;
>> +
>> + saAisNameLend((SaConstStringT)&default_ext_notification_object,
>> head->notificationObject);
>> + saAisNameLend((SaConstStringT)&default_ext_notifying_object,
>> head->notifyingObject);
>> +
>> + head->notificationClassId->vendorId = ERICSSON_VENDOR_ID;
>> + head->notificationClassId->majorId = 92;
>> + head->notificationClassId->minorId = 12;
>> +
>> + /* set additional text */
>> + (void)strncpy(head->additionalText,
>> + DEFAULT_ADDITIONAL_TEXT,
>> + (SaUint16T)(strlen(DEFAULT_ADDITIONAL_TEXT) + 1));
>> +
>> + for (i = 0; i < head->numCorrelatedNotifications; i++)
>> + head->correlatedNotifications[i] = (SaNtfIdentifierT) (i +
>> 400);
>> +
>> + // Fill first additionalInfo as extended SaNameT including NULL
>> character
>> + head->additionalInfo[0].infoType = SA_NTF_VALUE_LDAP_NAME;
>> + head->additionalInfo[0].infoId = 1;
>> + saAisNameLend((SaConstStringT)&test_longdn_object_1, &name1);
>> +
>> + safassert(saNtfPtrValAllocate(notHandle,
>> + strlen(saAisNameBorrow(&name1)) + 3,
>> + (void**)&dest_ptr,
>> + &(head->additionalInfo[0].infoValue)), SA_AIS_OK);
>> +
>> + saAisNameLend(saAisNameBorrow(&name1), (SaNameT*) dest_ptr);
>> +
>> + // Fill sencond additionalInfo as extended SaNameT excluding
>> NULL character
>> + head->additionalInfo[1].infoType = SA_NTF_VALUE_LDAP_NAME;
>> + head->additionalInfo[1].infoId = 1;
>> + saAisNameLend((SaConstStringT)&test_longdn_object_2, &name2);
>> +
>> + safassert(saNtfPtrValAllocate(notHandle,
>> + strlen(saAisNameBorrow(&name2)) + 2,
>> + (void**)&dest_ptr,
>> + &(head->additionalInfo[1].infoValue)), SA_AIS_OK);
>> +
>> + saAisNameLend(saAisNameBorrow(&name2), (SaNameT*) dest_ptr);
>> +
>> +
>> + //Fill third additionalInfo as extended SaNameT as legacy code
>> -> object is truncated
>> + head->additionalInfo[2].infoType = SA_NTF_VALUE_LDAP_NAME;
>> + head->additionalInfo[2].infoId = 1;
>> + saAisNameLend((SaConstStringT)&test_longdn_object_3, &name3);
>> + safassert(saNtfPtrValAllocate(notHandle,
>> + sizeof(name3) + 1,
>> + (void**)&dest_ptr,
>> + &(head->additionalInfo[2].infoValue)), SA_AIS_OK);
>> +
>> + memcpy(dest_ptr, &name3, sizeof(name3));
>> +
>> + // Fill fourth additionalInfo as unextended SaNameT as legacy code
>> + head->additionalInfo[3].infoType = SA_NTF_VALUE_LDAP_NAME;
>> + head->additionalInfo[3].infoId = 1;
>> + saAisNameLend(DEFAULT_UNEXT_NAME_STRING, &name4);
>> +
>> + safassert(saNtfPtrValAllocate(notHandle,
>> + sizeof(name4) + 1,
>> + (void**)&dest_ptr,
>> + &(head->additionalInfo[3].infoValue)), SA_AIS_OK);
>> +
>> + memcpy(dest_ptr, &name4, sizeof(name4));
>> +
>> + //Fill the fifth additionalInfo as unextended SaNameT as modern
>> code
>> + head->additionalInfo[4].infoType = SA_NTF_VALUE_LDAP_NAME;
>> + head->additionalInfo[4].infoId = 1;
>> + saAisNameLend(DEFAULT_UNEXT_NAME_STRING, &name5);
>> +
>> + safassert(saNtfPtrValAllocate(notHandle,
>> + strlen(saAisNameBorrow(&name5)) + 3,
>> + (void**)&dest_ptr,
>> + &(head->additionalInfo[4].infoValue)), SA_AIS_OK);
>> +
>> + saAisNameLend(saAisNameBorrow(&name5), (SaNameT*) dest_ptr);
>> + }
>> +
>> + /**
>> + * Test AdditionalInfo with extended SaNameT type
>> + */
>> + void extAdditionalInfoTest(void)
>> + {
>> + SaNtfAlarmNotificationFilterT myAlarmFilter;
>> + subscriptionId = 1;
>> + SaNtfNotificationHeaderT *head;
>> +
>> + rc = SA_AIS_OK;
>> +
>> + resetCounters();
>> +
>> + safassert(saNtfInitialize(&ntfHandle, &ntfCbTest, &ntfVersion) ,
>> SA_AIS_OK);
>> + safassert(saNtfSelectionObjectGet(ntfHandle, &selectionObject) ,
>> SA_AIS_OK);
>> +
>> + /* specify complex filter */
>> + safassert(saNtfAlarmNotificationFilterAllocate(
>> + ntfHandle,
>> + &myAlarmFilter,
>> + 1,
>> + 1,
>> + 1,
>> + 1,
>> + 0,
>> + 0,
>> + 0), SA_AIS_OK);
>> + /* set header filter specific fields */
>> + extFillFilterHeader(&myAlarmFilter.notificationFilterHeader);
>> +
>> + /* Initialize filter handles */
>> + myNotificationFilterHandles.alarmFilterHandle =
>> + myAlarmFilter.notificationFilterHandle;
>> + myNotificationFilterHandles.attributeChangeFilterHandle = 0;
>> + myNotificationFilterHandles.objectCreateDeleteFilterHandle = 0;
>> + myNotificationFilterHandles.securityAlarmFilterHandle = 0;
>> + myNotificationFilterHandles.stateChangeFilterHandle = 0;
>> +
>> + safassert(saNtfNotificationSubscribe(&myNotificationFilterHandles,
>> + subscriptionId), SA_AIS_OK);
>> +
>> + /* Create a notification and send it */
>> + safassert(saNtfAlarmNotificationAllocate(
>> + ntfHandle,
>> + &myAlarmNotification,
>> + 0,
>> + (SaUint16T)(strlen(DEFAULT_ADDITIONAL_TEXT) + 1),
>> + 5,
>> + 0,
>> + 0,
>> + 0,
>> + SA_NTF_ALLOC_SYSTEM_LIMIT), SA_AIS_OK);
>> +
>> + head = &myAlarmNotification.notificationHeader;
>> + extFillHeaderAddInfo(head, myAlarmNotification.notificationHandle);
>> + /* These 3 fields is alarm filter items */
>> + *(myAlarmNotification.perceivedSeverity) = SA_NTF_SEVERITY_WARNING;
>> + *(myAlarmNotification.probableCause) = SA_NTF_BANDWIDTH_REDUCED;
>> + *myAlarmNotification.trend = SA_NTF_TREND_MORE_SEVERE;
>> +
>> + myAlarmNotification.thresholdInformation->thresholdValueType =
>> SA_NTF_VALUE_UINT32;
>> + myAlarmNotification.thresholdInformation->thresholdValue.uint32Val
>> = 600;
>> +
>> myAlarmNotification.thresholdInformation->thresholdHysteresis.uint32Val
>> = 100;
>> + myAlarmNotification.thresholdInformation->observedValue.uint32Val =
>> 567;
>> + myAlarmNotification.thresholdInformation->armTime =
>> SA_TIME_UNKNOWN;
>> +
>> +
>> safassert(saNtfNotificationSend(myAlarmNotification.notificationHandle),
>> SA_AIS_OK);
>> +
>> + /* only this notification should be caught */
>> + ok_ids.ids[ok_ids.length++] =
>> *myAlarmNotification.notificationHeader.notificationId;
>> + poll_until_received(ntfHandle,
>> *myAlarmNotification.notificationHeader.notificationId);
>> +
>> + if(ntfRecieved.alarmFilterHandle != 1 ||
>> + ntfRecieved.attributeChangeFilterHandle != 0 ||
>> + ntfRecieved.objectCreateDeleteFilterHandle !=0 ||
>> + ntfRecieved.securityAlarmFilterHandle != 0 ||
>> + ntfRecieved.stateChangeFilterHandle != 0)
>> safassert(SA_AIS_ERR_BAD_FLAGS, SA_AIS_OK);
>> +
>> +
>> safassert(saNtfNotificationFree(myAlarmNotification.notificationHandle)
>> , SA_AIS_OK);
>> +
>> safassert(saNtfNotificationFilterFree(myAlarmFilter.notificationFilterHandle),
>>
>> SA_AIS_OK);
>> + safassert(saNtfNotificationUnsubscribe(subscriptionId), SA_AIS_OK);
>> +
>> + safassert(saNtfFinalize(ntfHandle), SA_AIS_OK);
>> + rc = check_errors();
>> + test_validate(rc, SA_AIS_OK);
>> + }
>> +
>> +/**
>> + * Test all filter header fields
>> + */
>> +void extFilterNotificationTest(void)
>> +{
>> + SaNtfAlarmNotificationFilterT myAlarmFilter;
>> + subscriptionId = 1;
>> + SaNtfNotificationHeaderT *head;
>> +
>> + rc = SA_AIS_OK;
>> +
>> + resetCounters();
>> +
>> + safassert(saNtfInitialize(&ntfHandle, &ntfCbTest, &ntfVersion) ,
>> SA_AIS_OK);
>> + safassert(saNtfSelectionObjectGet(ntfHandle, &selectionObject) ,
>> SA_AIS_OK);
>> +
>> + /* specify complex filter */
>> + safassert(saNtfAlarmNotificationFilterAllocate(
>> + ntfHandle,
>> + &myAlarmFilter,
>> + 1,
>> + 1,
>> + 1,
>> + 1,
>> + 0,
>> + 0,
>> + 0), SA_AIS_OK);
>> + /* set header filter specific fields */
>> + extFillFilterHeader(&myAlarmFilter.notificationFilterHeader);
>> +
>> + /* Initialize filter handles */
>> + myNotificationFilterHandles.alarmFilterHandle =
>> + myAlarmFilter.notificationFilterHandle;
>> + myNotificationFilterHandles.attributeChangeFilterHandle = 0;
>> + myNotificationFilterHandles.objectCreateDeleteFilterHandle = 0;
>> + myNotificationFilterHandles.securityAlarmFilterHandle = 0;
>> + myNotificationFilterHandles.stateChangeFilterHandle = 0;
>> +
>> + safassert(saNtfNotificationSubscribe(&myNotificationFilterHandles,
>> + subscriptionId), SA_AIS_OK);
>> +
>> + /* Create a notification and send it */
>> + safassert(saNtfAlarmNotificationAllocate(
>> + ntfHandle,
>> + &myAlarmNotification,
>> + 0,
>> + (SaUint16T)(strlen(DEFAULT_ADDITIONAL_TEXT) + 1),
>> + 0,
>> + 0,
>> + 0,
>> + 0,
>> + SA_NTF_ALLOC_SYSTEM_LIMIT), SA_AIS_OK);
>> +
>> + head = &myAlarmNotification.notificationHeader;
>> + extFillHeader(head);
>> +
>> + /* These 3 fields is alarm filter items */
>> + *(myAlarmNotification.perceivedSeverity) = SA_NTF_SEVERITY_WARNING;
>> + *(myAlarmNotification.probableCause) = SA_NTF_BANDWIDTH_REDUCED;
>> + *myAlarmNotification.trend = SA_NTF_TREND_MORE_SEVERE;
>> +
>> + myAlarmNotification.thresholdInformation->thresholdValueType =
>> SA_NTF_VALUE_UINT32;
>> + myAlarmNotification.thresholdInformation->thresholdValue.uint32Val
>> = 600;
>> +
>> myAlarmNotification.thresholdInformation->thresholdHysteresis.uint32Val
>> = 100;
>> + myAlarmNotification.thresholdInformation->observedValue.uint32Val =
>> 567;
>> + myAlarmNotification.thresholdInformation->armTime =
>> SA_TIME_UNKNOWN;
>> +
>> + *(head->eventType) = SA_NTF_ALARM_EQUIPMENT;
>> +
>> safassert(saNtfNotificationSend(myAlarmNotification.notificationHandle),
>> SA_AIS_OK);
>> +
>> + saAisNameLend((SaConstStringT)&test_longdn_object_1,
>> head->notificationObject);
>> +
>> safassert(saNtfNotificationSend(myAlarmNotification.notificationHandle),
>> SA_AIS_OK);
>> +
>> + extFillHeader(head);
>> + saAisNameLend(NOTIFYING_OBJECT_TEST, head->notifyingObject);
>> +
>> safassert(saNtfNotificationSend(myAlarmNotification.notificationHandle),
>> SA_AIS_OK);
>> +
>> + extFillHeader(head);
>> + head->notificationClassId->vendorId = 199;
>> +
>> safassert(saNtfNotificationSend(myAlarmNotification.notificationHandle),
>> SA_AIS_OK);
>> +
>> + extFillHeader(head);
>> + head->notificationClassId->majorId = 89;
>> +
>> safassert(saNtfNotificationSend(myAlarmNotification.notificationHandle),
>> SA_AIS_OK);
>> +
>> + extFillHeader(head);
>> + head->notificationClassId->minorId = 24;
>> +
>> safassert(saNtfNotificationSend(myAlarmNotification.notificationHandle),
>> SA_AIS_OK);
>> +
>> + extFillHeader(head);
>> +
>> safassert(saNtfNotificationSend(myAlarmNotification.notificationHandle),
>> SA_AIS_OK);
>> +
>> + /* only this notification should be caught */
>> + ok_ids.ids[ok_ids.length++] =
>> *myAlarmNotification.notificationHeader.notificationId;
>> + poll_until_received(ntfHandle,
>> *myAlarmNotification.notificationHeader.notificationId);
>> +
>> + if(ntfRecieved.alarmFilterHandle != 1 ||
>> + ntfRecieved.attributeChangeFilterHandle != 0 ||
>> + ntfRecieved.objectCreateDeleteFilterHandle !=0 ||
>> + ntfRecieved.securityAlarmFilterHandle != 0 ||
>> + ntfRecieved.stateChangeFilterHandle != 0)
>> safassert(SA_AIS_ERR_BAD_FLAGS, SA_AIS_OK);
>> +
>> +
>> safassert(saNtfNotificationFree(myAlarmNotification.notificationHandle)
>> , SA_AIS_OK);
>> +
>> safassert(saNtfNotificationFilterFree(myAlarmFilter.notificationFilterHandle),
>>
>> SA_AIS_OK);
>> + safassert(saNtfNotificationUnsubscribe(subscriptionId), SA_AIS_OK);
>> +
>> + safassert(saNtfFinalize(ntfHandle), SA_AIS_OK);
>> + rc = check_errors();
>> + test_validate(rc, SA_AIS_OK);
>> +}
>> +
>> +/**
>> + * Test Alarm notification with long dn objects
>> + */
>> +void extAlarmNotificationTest(void)
>> +{
>> + SaNtfAlarmNotificationFilterT myAlarmFilter;
>> + subscriptionId = 1;
>> +
>> + rc = SA_AIS_OK;
>> +
>> + resetCounters();
>> +
>> + safassert(saNtfInitialize(&ntfHandle, &ntfCbTest, &ntfVersion) ,
>> SA_AIS_OK);
>> + safassert(saNtfSelectionObjectGet(ntfHandle, &selectionObject) ,
>> SA_AIS_OK);
>> +
>> + safassert(saNtfAlarmNotificationFilterAllocate(
>> + ntfHandle,
>> + &myAlarmFilter,
>> + 0,
>> + 0,
>> + 0,
>> + 0,
>> + 1,
>> + 1,
>> + 1), SA_AIS_OK);
>> + /* Set perceived severities */
>> + myAlarmFilter.perceivedSeverities[0] = SA_NTF_SEVERITY_WARNING;
>> + myAlarmFilter.probableCauses[0] = SA_NTF_BANDWIDTH_REDUCED;
>> + myAlarmFilter.trends[0] = SA_NTF_TREND_MORE_SEVERE;
>> +
>> + /* Initialize filter handles */
>> + myNotificationFilterHandles.alarmFilterHandle =
>> + myAlarmFilter.notificationFilterHandle;
>> + myNotificationFilterHandles.attributeChangeFilterHandle = 0;
>> + myNotificationFilterHandles.objectCreateDeleteFilterHandle = 0;
>> + myNotificationFilterHandles.securityAlarmFilterHandle = 0;
>> + myNotificationFilterHandles.stateChangeFilterHandle = 0;
>> +
>> + safassert(saNtfNotificationSubscribe(&myNotificationFilterHandles,
>> + subscriptionId), SA_AIS_OK);
>> +
>> + /* Create a notification and send it */
>> + safassert(saNtfAlarmNotificationAllocate(
>> + ntfHandle,
>> + &myAlarmNotification,
>> + 0,
>> + (SaUint16T)(strlen(DEFAULT_ADDITIONAL_TEXT) + 1),
>> + 0,
>> + 0,
>> + 0,
>> + 0,
>> + SA_NTF_ALLOC_SYSTEM_LIMIT), SA_AIS_OK);
>> + extFillHeader(&myAlarmNotification.notificationHeader);
>> +
>> + *(myAlarmNotification.perceivedSeverity) =
>> SA_NTF_SEVERITY_CRITICAL;
>> + *(myAlarmNotification.probableCause) =
>> SA_NTF_CALL_ESTABLISHMENT_ERROR;
>> + *myAlarmNotification.trend = SA_NTF_TREND_NO_CHANGE;
>> +
>> safassert(saNtfNotificationSend(myAlarmNotification.notificationHandle),
>> SA_AIS_OK);
>> +
>> + *(myAlarmNotification.perceivedSeverity) = SA_NTF_SEVERITY_WARNING;
>> + *(myAlarmNotification.probableCause) =
>> SA_NTF_PRESSURE_UNACCEPTABLE;
>> +
>> safassert(saNtfNotificationSend(myAlarmNotification.notificationHandle),
>> SA_AIS_OK);
>> +
>> + *(myAlarmNotification.perceivedSeverity) = SA_NTF_SEVERITY_WARNING;
>> + *(myAlarmNotification.probableCause) = SA_NTF_BANDWIDTH_REDUCED;
>> + *myAlarmNotification.trend = SA_NTF_TREND_NO_CHANGE;
>> +
>> safassert(saNtfNotificationSend(myAlarmNotification.notificationHandle),
>> SA_AIS_OK);
>> +
>> + extFillHeader(&myAlarmNotification.notificationHeader);
>> + /* These 3 fields is filter items */
>> + *(myAlarmNotification.perceivedSeverity) = SA_NTF_SEVERITY_WARNING;
>> + *(myAlarmNotification.probableCause) = SA_NTF_BANDWIDTH_REDUCED;
>> + *myAlarmNotification.trend = SA_NTF_TREND_MORE_SEVERE;
>> + myAlarmNotification.thresholdInformation->thresholdValueType =
>> SA_NTF_VALUE_UINT32;
>> + myAlarmNotification.thresholdInformation->thresholdValue.uint32Val
>> = 600;
>> +
>> myAlarmNotification.thresholdInformation->thresholdHysteresis.uint32Val
>> = 100;
>> + myAlarmNotification.thresholdInformation->observedValue.uint32Val =
>> 567;
>> + myAlarmNotification.thresholdInformation->armTime =
>> SA_TIME_UNKNOWN;
>> +
>> safassert(saNtfNotificationSend(myAlarmNotification.notificationHandle),
>> SA_AIS_OK);
>> + /* only this notification should be caught*/
>> + ok_ids.ids[ok_ids.length++] =
>> *myAlarmNotification.notificationHeader.notificationId;
>> + poll_until_received(ntfHandle,
>> *myAlarmNotification.notificationHeader.notificationId);
>> + if(ntfRecieved.alarmFilterHandle != 1 ||
>> + ntfRecieved.attributeChangeFilterHandle != 0 ||
>> + ntfRecieved.objectCreateDeleteFilterHandle !=0 ||
>> + ntfRecieved.securityAlarmFilterHandle != 0 ||
>> + ntfRecieved.stateChangeFilterHandle != 0)
>> safassert(SA_AIS_ERR_BAD_FLAGS, SA_AIS_OK);
>> +
>> +
>> safassert(saNtfNotificationFree(myAlarmNotification.notificationHandle)
>> , SA_AIS_OK);
>> +
>> safassert(saNtfNotificationFilterFree(myAlarmFilter.notificationFilterHandle),
>>
>> SA_AIS_OK);
>> +
>> + safassert(saNtfNotificationUnsubscribe(subscriptionId), SA_AIS_OK);
>> + safassert(saNtfFinalize(ntfHandle), SA_AIS_OK);
>> + rc = check_errors();
>> + test_validate(rc, SA_AIS_OK);
>> +}
>> +
>> +/**
>> + * Test Object Create/Delete notification with long dn objects
>> + */
>> +void extObjectCreateDeleteNotificationTest(void)
>> +{
>> + SaNtfObjectCreateDeleteNotificationFilterT myFilter;
>> +
>> + subscriptionId = 2;
>> +
>> + resetCounters();
>> +
>> + safassert(saNtfInitialize(&ntfHandle, &ntfCbTest, &ntfVersion) ,
>> SA_AIS_OK);
>> + safassert(saNtfSelectionObjectGet(ntfHandle, &selectionObject) ,
>> SA_AIS_OK);
>> +
>> + safassert(saNtfObjectCreateDeleteNotificationFilterAllocate(
>> + ntfHandle,
>> + &myFilter,
>> + 1,
>> + 1,
>> + 1,
>> + 1,
>> + 2), SA_AIS_OK);
>> + myFilter.sourceIndicators[0] = SA_NTF_OBJECT_OPERATION;
>> + myFilter.sourceIndicators[1] = SA_NTF_MANAGEMENT_OPERATION;
>> + extFillFilterHeader(&myFilter.notificationFilterHeader);
>> + myFilter.notificationFilterHeader.eventTypes[0] =
>> SA_NTF_OBJECT_CREATION;
>> + /* Initialize filter handles */
>> + myNotificationFilterHandles.alarmFilterHandle = 0;
>> + myNotificationFilterHandles.attributeChangeFilterHandle = 0;
>> + myNotificationFilterHandles.objectCreateDeleteFilterHandle =
>> + myFilter.notificationFilterHandle;
>> + myNotificationFilterHandles.securityAlarmFilterHandle = 0;
>> + myNotificationFilterHandles.stateChangeFilterHandle = 0;
>> + safassert(saNtfNotificationSubscribe(&myNotificationFilterHandles,
>> + subscriptionId), SA_AIS_OK);
>> + extCreateObjectCreateDeleteNotification(ntfHandle,
>> &myObjCrDelNotification);
>> + *(myObjCrDelNotification.sourceIndicator) =
>> SA_NTF_OBJECT_OPERATION;
>> +
>> safassert(saNtfNotificationSend(myObjCrDelNotification.notificationHandle),
>> SA_AIS_OK);
>> + /* this notification should be caught*/
>> + ok_ids.ids[ok_ids.length++] =
>> *myObjCrDelNotification.notificationHeader.notificationId;
>> +
>> + *(myObjCrDelNotification.sourceIndicator) =
>> SA_NTF_UNKNOWN_OPERATION;
>> +
>> safassert(saNtfNotificationSend(myObjCrDelNotification.notificationHandle),
>> SA_AIS_OK);
>> +
>> + *(myObjCrDelNotification.sourceIndicator) =
>> SA_NTF_MANAGEMENT_OPERATION;
>> +
>> safassert(saNtfNotificationSend(myObjCrDelNotification.notificationHandle),
>> SA_AIS_OK);
>> + /* this notification should be caught*/
>> + ok_ids.ids[ok_ids.length++] =
>> *myObjCrDelNotification.notificationHeader.notificationId;
>> + poll_until_received(ntfHandle,
>> *myObjCrDelNotification.notificationHeader.notificationId);
>> + if(ntfRecieved.alarmFilterHandle != 0 ||
>> + ntfRecieved.attributeChangeFilterHandle != 0 ||
>> + ntfRecieved.objectCreateDeleteFilterHandle !=
>> ok_ids.length||
>> + ntfRecieved.securityAlarmFilterHandle != 0 ||
>> + ntfRecieved.stateChangeFilterHandle != 0)
>> safassert(SA_AIS_ERR_BAD_FLAGS, SA_AIS_OK);
>> +
>> safassert(saNtfNotificationFree(myObjCrDelNotification.notificationHandle),
>> SA_AIS_OK);
>> +
>> safassert(saNtfNotificationFilterFree(myFilter.notificationFilterHandle),
>> SA_AIS_OK);
>> +
>> + safassert(saNtfNotificationUnsubscribe(subscriptionId), SA_AIS_OK);
>> + safassert(saNtfFinalize(ntfHandle) , SA_AIS_OK);
>> + rc = check_errors();
>> + test_validate(rc, SA_AIS_OK);
>> +}
>> +
>> +/**
>> + * Test Attribute Change notification with long dn objects
>> + */
>> +void extAttributeChangeNotificationTest(void)
>> +{
>> + SaNtfAttributeChangeNotificationFilterT myFilter;
>> +
>> + subscriptionId = 2;
>> +
>> + resetCounters();
>> +
>> + safassert(saNtfInitialize(&ntfHandle, &ntfCbTest, &ntfVersion) ,
>> SA_AIS_OK);
>> + safassert(saNtfSelectionObjectGet(ntfHandle, &selectionObject) ,
>> SA_AIS_OK);
>> +
>> + safassert(saNtfAttributeChangeNotificationFilterAllocate(
>> + ntfHandle,
>> + &myFilter,
>> + 1,
>> + 1,
>> + 1,
>> + 1,
>> + 2), SA_AIS_OK);
>> +
>> + myFilter.sourceIndicators[0] = SA_NTF_OBJECT_OPERATION;
>> + myFilter.sourceIndicators[1] = SA_NTF_MANAGEMENT_OPERATION;
>> + extFillFilterHeader(&myFilter.notificationFilterHeader);
>> + myFilter.notificationFilterHeader.eventTypes[0] =
>> SA_NTF_ATTRIBUTE_CHANGED;
>> + /* Initialize filter handles */
>> + myNotificationFilterHandles.alarmFilterHandle = 0;
>> + myNotificationFilterHandles.attributeChangeFilterHandle =
>> + myFilter.notificationFilterHandle;
>> + myNotificationFilterHandles.objectCreateDeleteFilterHandle = 0;
>> + myNotificationFilterHandles.securityAlarmFilterHandle = 0;
>> + myNotificationFilterHandles.stateChangeFilterHandle = 0;
>> + safassert(saNtfNotificationSubscribe(&myNotificationFilterHandles,
>> + subscriptionId), SA_AIS_OK);
>> + extCreateAttributeChangeNotification(ntfHandle,
>> &myAttrChangeNotification);
>> + *(myAttrChangeNotification.sourceIndicator) =
>> SA_NTF_OBJECT_OPERATION;
>> +
>> safassert(saNtfNotificationSend(myAttrChangeNotification.notificationHandle),
>>
>> SA_AIS_OK);
>> + /* this notification should be caught*/
>> + ok_ids.ids[ok_ids.length++] =
>> *myAttrChangeNotification.notificationHeader.notificationId;
>> +
>> + *(myAttrChangeNotification.sourceIndicator) =
>> SA_NTF_UNKNOWN_OPERATION;
>> +
>> safassert(saNtfNotificationSend(myAttrChangeNotification.notificationHandle),
>>
>> SA_AIS_OK);
>> +
>> + *(myAttrChangeNotification.sourceIndicator) =
>> SA_NTF_MANAGEMENT_OPERATION;
>> +
>> safassert(saNtfNotificationSend(myAttrChangeNotification.notificationHandle),
>>
>> SA_AIS_OK);
>> + /* this notification should be caught*/
>> + ok_ids.ids[ok_ids.length++] =
>> *myAttrChangeNotification.notificationHeader.notificationId;
>> + poll_until_received(ntfHandle,
>> *myAttrChangeNotification.notificationHeader.notificationId);
>> + if(ntfRecieved.alarmFilterHandle != 0 ||
>> + ntfRecieved.attributeChangeFilterHandle != ok_ids.length ||
>> + ntfRecieved.objectCreateDeleteFilterHandle != 0||
>> + ntfRecieved.securityAlarmFilterHandle != 0 ||
>> + ntfRecieved.stateChangeFilterHandle != 0)
>> safassert(SA_AIS_ERR_BAD_FLAGS, SA_AIS_OK);
>> +
>> safassert(saNtfNotificationFree(myAttrChangeNotification.notificationHandle),
>>
>> SA_AIS_OK);
>> +
>> safassert(saNtfNotificationFilterFree(myFilter.notificationFilterHandle),
>> SA_AIS_OK);
>> +
>> +
>> + safassert(saNtfNotificationUnsubscribe(subscriptionId), SA_AIS_OK);
>> + safassert(saNtfFinalize(ntfHandle) , SA_AIS_OK);
>> + rc = check_errors();
>> + test_validate(rc, SA_AIS_OK);
>> +}
>> +
>> +/**
>> + * Test State Change notification with long dn objects
>> + */
>> +void extStateChangeNotificationTest(void)
>> +{
>> + SaNtfStateChangeNotificationFilterT myFilter;
>> +
>> + subscriptionId = 2;
>> +
>> + resetCounters();
>> +
>> + safassert(saNtfInitialize(&ntfHandle, &ntfCbTest, &ntfVersion) ,
>> SA_AIS_OK);
>> + safassert(saNtfSelectionObjectGet(ntfHandle, &selectionObject) ,
>> SA_AIS_OK);
>> +
>> + safassert(saNtfStateChangeNotificationFilterAllocate(
>> + ntfHandle,
>> + &myFilter,
>> + 1,
>> + 1,
>> + 1,
>> + 1,
>> + 2,
>> + 0), SA_AIS_OK);
>> +
>> + myFilter.sourceIndicators[0] = SA_NTF_OBJECT_OPERATION;
>> + myFilter.sourceIndicators[1] = SA_NTF_MANAGEMENT_OPERATION;
>> + extFillFilterHeader(&myFilter.notificationFilterHeader);
>> + myFilter.notificationFilterHeader.eventTypes[0] =
>> SA_NTF_OBJECT_STATE_CHANGE;
>> + /* Initialize filter handles */
>> + myNotificationFilterHandles.alarmFilterHandle = 0;
>> + myNotificationFilterHandles.attributeChangeFilterHandle = 0;
>> + myNotificationFilterHandles.objectCreateDeleteFilterHandle = 0;
>> + myNotificationFilterHandles.securityAlarmFilterHandle = 0;
>> + myNotificationFilterHandles.stateChangeFilterHandle =
>> myFilter.notificationFilterHandle;
>> + safassert(saNtfNotificationSubscribe(&myNotificationFilterHandles,
>> + subscriptionId), SA_AIS_OK);
>> +
>> + extCreateStateChangeNotification(ntfHandle,
>> &myStateChangeNotification);
>> + *(myStateChangeNotification.sourceIndicator) =
>> SA_NTF_OBJECT_OPERATION;
>> +
>> safassert(saNtfNotificationSend(myStateChangeNotification.notificationHandle),
>>
>> SA_AIS_OK);
>> + /* this notification should be caught*/
>> + ok_ids.ids[ok_ids.length++] =
>> *myStateChangeNotification.notificationHeader.notificationId;
>> +
>> + *(myStateChangeNotification.sourceIndicator) =
>> SA_NTF_UNKNOWN_OPERATION;
>> +
>> safassert(saNtfNotificationSend(myStateChangeNotification.notificationHandle),
>>
>> SA_AIS_OK);
>> +
>> + *(myStateChangeNotification.sourceIndicator) =
>> SA_NTF_MANAGEMENT_OPERATION;
>> +
>> safassert(saNtfNotificationSend(myStateChangeNotification.notificationHandle),
>>
>> SA_AIS_OK);
>> + /* this notification should be caught*/
>> + ok_ids.ids[ok_ids.length++] =
>> *myStateChangeNotification.notificationHeader.notificationId;
>> + poll_until_received(ntfHandle,
>> *myStateChangeNotification.notificationHeader.notificationId);
>> + if(ntfRecieved.alarmFilterHandle != 0 ||
>> + ntfRecieved.attributeChangeFilterHandle != 0 ||
>> + ntfRecieved.objectCreateDeleteFilterHandle != 0||
>> + ntfRecieved.securityAlarmFilterHandle != 0 ||
>> + ntfRecieved.stateChangeFilterHandle != ok_ids.length)
>> safassert(SA_AIS_ERR_BAD_FLAGS, SA_AIS_OK);
>> +
>> safassert(saNtfNotificationFree(myStateChangeNotification.notificationHandle),
>>
>> SA_AIS_OK);
>> +
>> safassert(saNtfNotificationFilterFree(myFilter.notificationFilterHandle),
>> SA_AIS_OK);
>> +
>> + safassert(saNtfNotificationUnsubscribe(subscriptionId), SA_AIS_OK);
>> + safassert(saNtfFinalize(ntfHandle), SA_AIS_OK);
>> + rc = check_errors();
>> + test_validate(rc, SA_AIS_OK);
>> +}
>> +
>> +/**
>> + * Test Security Alarm notification with long dn objects
>> + */
>> +void extSecurityAlarmNotificationTest(void)
>> +{
>> + SaNtfSecurityAlarmNotificationFilterT myFilter;
>> +
>> + subscriptionId = 5;
>> +
>> + resetCounters();
>> + safassert(saNtfInitialize(&ntfHandle, &ntfCbTest, &ntfVersion) ,
>> SA_AIS_OK);
>> + safassert(saNtfSelectionObjectGet(ntfHandle, &selectionObject) ,
>> SA_AIS_OK);
>> +
>> + safassert(saNtfSecurityAlarmNotificationFilterAllocate(
>> + ntfHandle,
>> + &myFilter,
>> + 0,
>> + 0,
>> + 0,
>> + 0,
>> + 3,
>> + 0,
>> + 0,
>> + 0,
>> + 0), SA_AIS_OK);
>> +
>> + /* Initialize filter handles */
>> + myNotificationFilterHandles.alarmFilterHandle = 0;
>> + myNotificationFilterHandles.attributeChangeFilterHandle = 0;
>> + myNotificationFilterHandles.objectCreateDeleteFilterHandle = 0;
>> + myNotificationFilterHandles.securityAlarmFilterHandle =
>> + myFilter.notificationFilterHandle;
>> + myNotificationFilterHandles.stateChangeFilterHandle = 0;
>> + myFilter.probableCauses[0] = SA_NTF_ADAPTER_ERROR;
>> + myFilter.probableCauses[1] = SA_NTF_EQUIPMENT_MALFUNCTION;
>> + myFilter.probableCauses[2] = SA_NTF_VERSION_MISMATCH;
>> +
>> + /* subscribe */
>> + safassert(saNtfNotificationSubscribe(&myNotificationFilterHandles,
>> + subscriptionId), SA_AIS_OK);
>> + extCreateSecurityAlarmNotification(ntfHandle,
>> &mySecAlarmNotification);
>> +
>> safassert(saNtfNotificationSend(mySecAlarmNotification.notificationHandle),
>> SA_AIS_OK);
>> +
>> + *mySecAlarmNotification.probableCause = SA_NTF_VERSION_MISMATCH;
>> +
>> safassert(saNtfNotificationSend(mySecAlarmNotification.notificationHandle),
>> SA_AIS_OK);
>> + ok_ids.ids[ok_ids.length++] =
>> *mySecAlarmNotification.notificationHeader.notificationId;
>> +
>> + *mySecAlarmNotification.probableCause =
>> SA_NTF_RESPONSE_TIME_EXCESSIVE;
>> +
>> safassert(saNtfNotificationSend(mySecAlarmNotification.notificationHandle),
>> SA_AIS_OK);
>> +
>> + *mySecAlarmNotification.probableCause =
>> SA_NTF_NON_REPUDIATION_FAILURE;
>> +
>> safassert(saNtfNotificationSend(mySecAlarmNotification.notificationHandle),
>> SA_AIS_OK);
>> +
>> + *mySecAlarmNotification.probableCause =
>> SA_NTF_EQUIPMENT_MALFUNCTION;
>> +
>> safassert(saNtfNotificationSend(mySecAlarmNotification.notificationHandle),
>> SA_AIS_OK);
>> + ok_ids.ids[ok_ids.length++] =
>> *mySecAlarmNotification.notificationHeader.notificationId;
>> + *mySecAlarmNotification.probableCause =
>> SA_NTF_STORAGE_CAPACITY_PROBLEM;
>> +
>> safassert(saNtfNotificationSend(mySecAlarmNotification.notificationHandle),
>> SA_AIS_OK);
>> + *mySecAlarmNotification.probableCause = SA_NTF_DENIAL_OF_SERVICE;
>> +
>> safassert(saNtfNotificationSend(mySecAlarmNotification.notificationHandle),
>> SA_AIS_OK);
>> + *mySecAlarmNotification.probableCause = SA_NTF_ADAPTER_ERROR;
>> +
>> safassert(saNtfNotificationSend(mySecAlarmNotification.notificationHandle),
>> SA_AIS_OK);
>> + ok_ids.ids[ok_ids.length++] =
>> *mySecAlarmNotification.notificationHeader.notificationId;
>> + poll_until_received(ntfHandle,
>> *mySecAlarmNotification.notificationHeader.notificationId);
>> + if(ntfRecieved.alarmFilterHandle != 0 ||
>> + ntfRecieved.attributeChangeFilterHandle != 0 ||
>> + ntfRecieved.objectCreateDeleteFilterHandle !=0 ||
>> + ntfRecieved.securityAlarmFilterHandle != ok_ids.length ||
>> + ntfRecieved.stateChangeFilterHandle != 0)
>> safassert(SA_AIS_ERR_BAD_FLAGS, SA_AIS_OK);
>> +
>> safassert(saNtfNotificationFree(mySecAlarmNotification.notificationHandle),
>> SA_AIS_OK);
>> +
>> safassert(saNtfNotificationFilterFree(myFilter.notificationFilterHandle),
>> SA_AIS_OK);
>> +
>> + safassert(saNtfNotificationUnsubscribe(subscriptionId), SA_AIS_OK);
>> + safassert(saNtfFinalize(ntfHandle) , SA_AIS_OK);
>> + rc = check_errors();
>> + test_validate(rc, SA_AIS_OK);
>> +}
>> +
>> +__attribute__ ((constructor)) static void
>> longDnObject_notification_constructor(void)
>> +{
>> + init_ext_object();
>> + test_suite_add(36, "Long DNs Test");
>> + test_case_add(36, extAdditionalInfoTest
>> + , "Test additional info with extended SaNameT
>> type");
>> + test_case_add(36, extFilterNotificationTest
>> + , "Test filter with longDn objects");
>> + test_case_add(36, extAlarmNotificationTest
>> + , "Test Alarm notification with longDn objects");
>> + test_case_add(36, extObjectCreateDeleteNotificationTest
>> + , "Test Object Create/Delete notification with
>> longDn objects");
>> + test_case_add(36, extAttributeChangeNotificationTest
>> + , "Test Attribute Change notification with
>> longDn objects");
>> + test_case_add(36, extStateChangeNotificationTest
>> + , "Test State Change notification with longDn
>> objects");
>> + test_case_add(36, extSecurityAlarmNotificationTest
>> + , "Test Security Alarm notification with longDn
>> objects");
>> +}
>> diff --git a/tests/unit_test_fw/inc/util.h
>> b/tests/unit_test_fw/inc/util.h
>> --- a/tests/unit_test_fw/inc/util.h
>> +++ b/tests/unit_test_fw/inc/util.h
>> @@ -19,11 +19,10 @@
>> #ifndef util_h
>> #define util_h
>>
>> +#include <saAis.h>
>> +
>> extern SaTimeT getSaTimeT(void);
>> -extern void create_dn(char *rdn, char *parent, SaNameT *dn);
>> -extern void sa_namet_init(char *value, SaNameT *namet);
>> extern const char *get_saf_error(SaAisErrorT rc);
>> -
>> extern void safassert_impl(const char* file, unsigned int line,
>> SaAisErrorT actual, SaAisErrorT expected);
>>
>> /**
>> diff --git a/tests/unit_test_fw/src/Makefile.am
>> b/tests/unit_test_fw/src/Makefile.am
>> --- a/tests/unit_test_fw/src/Makefile.am
>> +++ b/tests/unit_test_fw/src/Makefile.am
>> @@ -22,6 +22,7 @@ noinst_LTLIBRARIES = libutest.la
>>
>> libutest_la_CPPFLAGS = \
>> $(AM_CPPFLAGS) \
>> + -DSA_EXTENDED_NAME_SOURCE \
>> -I$(top_srcdir)/tests/unit_test_fw/inc \
>> -I$(top_srcdir)/osaf/libs/saf/include
>>
>> diff --git a/tests/unit_test_fw/src/util.c
>> b/tests/unit_test_fw/src/util.c
>> --- a/tests/unit_test_fw/src/util.c
>> +++ b/tests/unit_test_fw/src/util.c
>> @@ -21,8 +21,7 @@
>> #include <sys/time.h>
>> #include <unistd.h>
>> #include <assert.h>
>> -#include <saAis.h>
>> -
>> +#include "util.h"
>> static const char *saf_error[] =
>> {
>> "SA_AIS_NOT_VALID",
>> @@ -65,17 +64,6 @@ SaTimeT getSaTimeT(void)
>> (tp.tv_usec * SA_TIME_ONE_MICROSECOND);
>> }
>>
>> -void create_dn(char *rdn, char *parent, SaNameT *dn)
>> -{
>> - dn->length = sprintf((char*)dn->value, "%s,%s", rdn, parent);
>> - assert(dn->length < SA_MAX_NAME_LENGTH);
>> -}
>> -
>> -void sa_namet_init(char *value, SaNameT *namet)
>> -{
>> - namet->length = sprintf((char*)namet->value, "%s", value);
>> -}
>> -
>> const char *get_saf_error(SaAisErrorT rc)
>> {
>> if (rc <= SA_AIS_ERR_UNAVAILABLE)
>>
>
------------------------------------------------------------------------------
Want fast and easy access to all the code in your enterprise? Index and
search up to 200,000 lines of code with a free copy of Black Duck
Code Sight - the same software that powers the world's largest code
search on Ohloh, the Black Duck Open Hub! Try it now.
http://p.sf.net/sfu/bds
_______________________________________________
Opensaf-devel mailing list
Opensaf-devel@lists.sourceforge.net
https://lists.sourceforge.net/lists/listinfo/opensaf-devel
