Adding 5 new test case into a testsuite 6
---
src/imm/Makefile.am | 1 +
.../test_saImmConfigSyncrTimeoutImma.c | 259 ++++++++++++++++++
.../management/test_saImmOmCcbInitialize.c | 22 ++
3 files changed, 282 insertions(+)
create mode 100644
src/imm/apitest/management/test_saImmConfigSyncrTimeoutImma.c
diff --git a/src/imm/Makefile.am b/src/imm/Makefile.am
index e83ba3a31..d3042b86f 100644
--- a/src/imm/Makefile.am
+++ b/src/imm/Makefile.am
@@ -477,6 +477,7 @@ bin_immomtest_SOURCES = \
src/imm/apitest/management/test_saImmOmThreadInterference.c \
src/imm/apitest/management/test_saImmOmLongDn.c \
src/imm/apitest/management/test_saImmOmSaStringT.c \
+ src/imm/apitest/management/test_saImmConfigSyncrTimeoutImma.c \
src/imm/apitest/management/test_cleanup.c
bin_immomtest_LDADD = \
diff --git a/src/imm/apitest/management/test_saImmConfigSyncrTimeoutImma.c
b/src/imm/apitest/management/test_saImmConfigSyncrTimeoutImma.c
new file mode 100644
index 000000000..a4b470b8d
--- /dev/null
+++ b/src/imm/apitest/management/test_saImmConfigSyncrTimeoutImma.c
@@ -0,0 +1,259 @@
+/* -*- OpenSAF -*-
+ *
+ * (C) Copyright 2021 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 "base/os_defs.h"
+#include "imm/agent/imma_def.h"
+#include "imm/apitest/immtest.h"
+#include "osaf/configmake.h"
+
+#include <stdio.h>
+#include <string.h>
+#include <unistd.h>
+
+static int get_pid_immnd()
+{
+ FILE *f;
+ int pid;
+ const char *osafimmnd_pid_file = PKGPIDDIR "/osafimmnd.pid";
+ if ((f = fopen(osafimmnd_pid_file, "r")) == NULL) {
+ fprintf(stderr, "Failed to open %s", osafimmnd_pid_file);
+ return -1;
+ }
+
+ if (fscanf(f, "%d", &pid) == 0) {
+ fprintf(stderr, "Could not read PID from file %s",
+ osafimmnd_pid_file);
+ return -1;
+ }
+
+ if (fclose(f) != 0) {
+ fprintf(stderr, "Could not close file");
+ return -1;
+ }
+ return pid;
+}
+
+static bool suppend_immnd(int pid)
+{
+ char command[255] = {0};
+ sprintf(command, "kill -STOP %d", pid);
+ if (system(command) != EXIT_SUCCESS) {
+ fprintf(stderr, "suppend osafimmnd failed\n");
+ return false;
+ }
+ return true;
+}
+
+static bool resume_immnd(int pid)
+{
+ char command[255] = {0};
+ sprintf(command, "kill -CONT %d", pid);
+ if (system(command) != EXIT_SUCCESS) {
+ fprintf(stderr, "resume osafimmnd failed\n");
+ return false;
+ }
+ return true;
+}
+
+static bool is_non_root()
+{
+ if (getuid() == 0 || geteuid() == 0)
+ return false;
+ fprintf(stdout,
+ "The test case need to run under root user. Skip test\n");
+ test_validate(true, true);
+ return true;
+}
+
+static int64_t estimate_timeout()
+{
+ const SaImmClassNameT className = (SaImmClassNameT) __FUNCTION__;
+ SaImmAttrDefinitionT_2 attr1 = {
+ "rdn", SA_IMM_ATTR_SANAMET,
+ SA_IMM_ATTR_RUNTIME | SA_IMM_ATTR_RDN | SA_IMM_ATTR_CACHED, NULL};
+ const SaImmAttrDefinitionT_2 *attrDefinitions[] = {&attr1, NULL};
+ int64_t diff_time = -1;
+ safassert(immutil_saImmOmInitialize(&immOmHandle, NULL, &immVersion),
+ SA_AIS_OK);
+
+ int pid = get_pid_immnd();
+ if (pid == -1) {
+ goto fail_handle;
+ }
+ if (!suppend_immnd(pid)) {
+ goto fail_handle;
+ }
+
+ int64_t start_time = ncs_os_time_ms();
+ safassert(saImmOmClassCreate_2(immOmHandle, className,
+ SA_IMM_CLASS_RUNTIME, attrDefinitions),
+ SA_AIS_ERR_TIMEOUT);
+ diff_time = ncs_os_time_ms() - start_time;
+ safassert(resume_immnd(pid), true);
+
+fail_handle:
+ safassert(immutil_saImmOmFinalize(immOmHandle), SA_AIS_OK);
+ return diff_time;
+}
+
+static SaAisErrorT update_syncr_timeout(SaTimeT timeout, bool estimate_timeout)
+{
+ const char mgmt_object[] = "safRdn=immManagement,safApp=safImmService";
+ const SaImmAdminOwnerNameT adminOwnerName =
+ (SaImmAdminOwnerNameT) __FUNCTION__;
+ SaImmAdminOwnerHandleT ownerHandle;
+ SaImmCcbHandleT ccbHandle;
+ SaNameT objectName;
+ const SaNameT *objectNames[] = {&objectName, NULL};
+ SaTimeT *saTimeValues[] = {&timeout};
+ SaImmAttrValuesT_2 v1 = {"saImmSyncrTimeout", SA_IMM_ATTR_SATIMET, 1,
+ (void **)saTimeValues};
+ SaImmAttrModificationT_2 attrMod = {SA_IMM_ATTR_VALUES_REPLACE, v1};
+ const SaImmAttrModificationT_2 *attrMods[] = {&attrMod, NULL};
+ SaAisErrorT rc = SA_AIS_OK;
+
+ objectName.length = sizeof(mgmt_object);
+ strncpy((char *)objectName.value, mgmt_object, objectName.length + 1);
+
+ safassert(immutil_saImmOmInitialize(&immOmHandle, NULL, &immVersion),
+ SA_AIS_OK);
+ safassert(immutil_saImmOmAdminOwnerInitialize(
+ immOmHandle, adminOwnerName, SA_TRUE, &ownerHandle),
+ SA_AIS_OK);
+ safassert(
+ immutil_saImmOmAdminOwnerSet(ownerHandle, objectNames, SA_IMM_ONE),
+ SA_AIS_OK);
+
+ safassert(immutil_saImmOmCcbInitialize(ownerHandle, 0, &ccbHandle),
+ SA_AIS_OK);
+
+ rc = immutil_saImmOmCcbObjectModify_2(ccbHandle, objectNames[0],
+ attrMods);
+ if (rc == SA_AIS_OK)
+ safassert(immutil_saImmOmCcbApply(ccbHandle), SA_AIS_OK);
+
+ if (estimate_timeout) {
+ int pid = get_pid_immnd();
+ if (pid == -1) {
+ goto fail_handle;
+ }
+ if (!suppend_immnd(pid)) {
+ goto fail_handle;
+ }
+ int64_t start_time = ncs_os_time_ms();
+ safassert(immutil_saImmOmCcbObjectModify_2(
+ ccbHandle, objectNames[0], attrMods),
+ SA_AIS_ERR_TIMEOUT);
+ int64_t diff_time = ncs_os_time_ms() - start_time;
+ rc_validate(diff_time / 1000, timeout / 100);
+ safassert(resume_immnd(pid), true);
+ }
+
+fail_handle:
+ safassert(immutil_saImmOmCcbFinalize(ccbHandle), SA_AIS_OK);
+ safassert(immutil_saImmOmAdminOwnerFinalize(ownerHandle), SA_AIS_OK);
+ safassert(immutil_saImmOmFinalize(immOmHandle), SA_AIS_OK);
+ return rc;
+}
+
+static void restore_syncr_timeout()
+{
+ safassert(update_syncr_timeout(0, false), SA_AIS_OK);
+}
+
+void test_modify_syncr_timeout_success(void)
+{
+ if (is_non_root())
+ return;
+ if (unsetenv("IMMA_SYNCR_TIMEOUT") != 0) {
+ fprintf(stderr,
+ "Deletes a variable IMMA_SYNCR_TIMEOUT failed\n");
+ test_validate(false, true);
+ return;
+ }
+
+ safassert(update_syncr_timeout(300, true), SA_AIS_OK);
+ restore_syncr_timeout();
+}
+
+void test_modify_syncr_timeout_failure(void)
+{
+ if (is_non_root())
+ return;
+ test_validate(update_syncr_timeout(5, false),
+ SA_AIS_ERR_BAD_OPERATION);
+}
+
+void test_modify_syncr_timeout_with_imm_client_restart(void)
+{
+ const int expected_timeout_second = 3;
+
+ if (is_non_root())
+ return;
+ if (unsetenv("IMMA_SYNCR_TIMEOUT") != 0) {
+ fprintf(stderr,
+ "Deletes a variable IMMA_SYNCR_TIMEOUT failed\n");
+ test_validate(false, true);
+ return;
+ }
+
+ safassert(update_syncr_timeout(expected_timeout_second * 100, false),
+ SA_AIS_OK);
+ int64_t timeout = estimate_timeout();
+ rc_validate(timeout / 1000, expected_timeout_second);
+ restore_syncr_timeout();
+}
+
+void test_restore_syncr_timeout_with_setenv(void)
+{
+ const char *expected_timeout = "600"; // in 10ms units => 6sec
+
+ if (is_non_root())
+ return;
+ if (setenv("IMMA_SYNCR_TIMEOUT", expected_timeout, 1) != 0) {
+ fprintf(stderr,
+ "Add a variable IMMA_SYNCR_TIMEOUT=%s failed\n",
+ expected_timeout);
+ test_validate(false, true);
+ return;
+ }
+
+ safassert(update_syncr_timeout(300, false), SA_AIS_OK);
+ restore_syncr_timeout();
+
+ int64_t timeout = estimate_timeout();
+ unsetenv("IMMA_SYNCR_TIMEOUT");
+ rc_validate(timeout / 1000, atoi(expected_timeout) / 100);
+}
+
+void test_restore_syncr_timeout_without_setenv(void)
+{
+ if (is_non_root())
+ return;
+ if (unsetenv("IMMA_SYNCR_TIMEOUT") != 0) {
+ fprintf(stderr,
+ "Deletes a variable IMMA_SYNCR_TIMEOUT failed\n");
+ test_validate(false, true);
+ return;
+ }
+
+ safassert(update_syncr_timeout(300, false), SA_AIS_OK);
+ restore_syncr_timeout();
+
+ int64_t timeout = estimate_timeout();
+ rc_validate(timeout / 1000, IMMSV_WAIT_TIME / 100);
+}
diff --git a/src/imm/apitest/management/test_saImmOmCcbInitialize.c
b/src/imm/apitest/management/test_saImmOmCcbInitialize.c
index 71d1c1703..5e93059f6 100644
--- a/src/imm/apitest/management/test_saImmOmCcbInitialize.c
+++ b/src/imm/apitest/management/test_saImmOmCcbInitialize.c
@@ -197,6 +197,11 @@ extern void saImmOmCcbValidate_02(void);
extern void saImmOmCcbObjectRead_01(void);
extern void saImmOmCcbObjectRead_02(void);
extern void saImmOmCcbObjectRead_03(void);
+extern void test_modify_syncr_timeout_success(void);
+extern void test_modify_syncr_timeout_failure(void);
+extern void test_modify_syncr_timeout_with_imm_client_restart(void);
+extern void test_restore_syncr_timeout_with_setenv(void);
+extern void test_restore_syncr_timeout_without_setenv(void);
__attribute__((constructor)) static void saImmOmInitialize_constructor(void)
{
@@ -400,4 +405,21 @@ __attribute__((constructor)) static void
saImmOmInitialize_constructor(void)
"saImmOmCcbObjectRead escalated to modify - SA_AIS_OK");
test_case_add(6, saImmOmCcbObjectRead_03,
"saImmOmCcbObjectRead escalated to delete - SA_AIS_OK");
+ test_case_add(6, test_modify_syncr_timeout_success,
+ "saImmOmCcbObjectModify_2 - SA_AIS_OK, Set a valid "
+ "value to saImmSyncrTimeout");
+ test_case_add(6, test_modify_syncr_timeout_failure,
+ "saImmOmCcbObjectModify_2 - SA_AIS_ERR_BAD_OPERATION, "
+ "Set a invalid value to saImmSyncrTimeout");
+ test_case_add(6, test_modify_syncr_timeout_with_imm_client_restart,
+ "saImmOmCcbObjectModify_2 - SA_AIS_OK, Set a valid "
+ "value to saImmSyncrTimeout then verify syncr timeout "
+ "after imm client restart");
+ test_case_add(6, test_restore_syncr_timeout_with_setenv,
+ "saImmOmCcbObjectModify_2 - SA_AIS_OK, set variable "
+ "IMMA_SYNCR_TIMEOUT=600 and saImmSyncrTimeout=0 then "
+ "verify syncr timeout");
+ test_case_add(6, test_restore_syncr_timeout_without_setenv,
+ "saImmOmCcbObjectModify_2 - SA_AIS_OK, set attribute "
+ "saImmSyncrTimeout=0 then verify syncr timeout");
}
--
2.25.1
_______________________________________________
Opensaf-devel mailing list
[email protected]
https://lists.sourceforge.net/lists/listinfo/opensaf-devel
