tests/logsv/Makefile.am | 4 +-
tests/logsv/logtest.c | 132 +--
tests/logsv/tet_LogOiOps.c | 2 +-
tests/logsv/tet_Log_recov.c | 17 +-
tests/logsv/tet_log_longDN.c | 1226 ++++++++++++++++++++++++++++++++++
tests/logsv/tet_log_runtime_cfgobj.c | 9 +-
tests/logsv/tet_saLogStreamOpen_2.c | 53 +-
tests/logsv/tet_saLogWriteLogAsync.c | 8 +-
8 files changed, 1318 insertions(+), 133 deletions(-)
Major changes:
1) Add new test suite #13 for long DN test (tet_log_longDN.c file)
2) Do re-processing for old SaNameT
3) Disable test cases that checked DN limited to 256 bytes
diff --git a/tests/logsv/Makefile.am b/tests/logsv/Makefile.am
--- a/tests/logsv/Makefile.am
+++ b/tests/logsv/Makefile.am
@@ -24,6 +24,7 @@ noinst_HEADERS = \
logtest.h
logtest_CPPFLAGS = \
+ -DSA_EXTENDED_NAME_SOURCE \
$(AM_CPPFLAGS) \
-I$(top_srcdir)/tests/unit_test_fw/inc \
-I$(top_srcdir)/osaf/libs/common/immsv/include
@@ -46,7 +47,8 @@ logtest_SOURCES = \
tet_LogOiOps.c \
tet_Log_misc.c \
tet_Log_recov.c \
- tet_log_runtime_cfgobj.c
+ tet_log_runtime_cfgobj.c \
+ tet_log_longDN.c
logtest_LDADD = \
$(top_builddir)/tests/unit_test_fw/src/libutest.la \
diff --git a/tests/logsv/logtest.c b/tests/logsv/logtest.c
--- a/tests/logsv/logtest.c
+++ b/tests/logsv/logtest.c
@@ -29,79 +29,37 @@
#include <saf_error.h>
#include "logtest.h"
+#include "osaf_extended_name.h"
+#include <saAis.h>
#define LLDTEST
-SaNameT systemStreamName =
-{
- .value = SA_LOG_STREAM_SYSTEM,
- .length = sizeof(SA_LOG_STREAM_SYSTEM)
-};
+SaNameT systemStreamName;
+SaNameT alarmStreamName;
+SaNameT globalConfig;
+SaNameT notificationStreamName;
+SaNameT app1StreamName;
+SaNameT notifyingObject;
+SaNameT notificationObject;
+SaNameT configurationObject;
-SaNameT alarmStreamName =
-{
- .value = SA_LOG_STREAM_ALARM,
- .length = sizeof(SA_LOG_STREAM_ALARM)
-};
+SaConstStringT obj256 = "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
+ "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
+ "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
+ "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
+ "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
+ "bbbbb";
+SaNameT saNameT_Object_256;
-SaNameT globalConfig =
-{
- .value = LOGTST_IMM_LOG_GCFG,
- .length = sizeof(LOGTST_IMM_LOG_GCFG)
-};
+SaConstStringT name256 = "safLgStr=aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
+ "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
+ "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
+ "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
+ "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
+ "bbbbb";
-SaNameT notificationStreamName =
-{
- .value = SA_LOG_STREAM_NOTIFICATION,
- .length = sizeof(SA_LOG_STREAM_NOTIFICATION)
-};
-
-SaNameT app1StreamName =
-{
- .value = SA_LOG_STREAM_APPLICATION1,
- .length = sizeof(SA_LOG_STREAM_APPLICATION1)
-};
-
-SaNameT notifyingObject =
-{
- .value = DEFAULT_NOTIFYING_OBJECT,
- .length = sizeof(DEFAULT_NOTIFYING_OBJECT)
-};
-
-SaNameT notificationObject =
-{
- .value = DEFAULT_NOTIFICATION_OBJECT,
- .length = sizeof(DEFAULT_NOTIFICATION_OBJECT)
-};
-
-SaNameT configurationObject =
-{
- .value = SA_LOG_CONFIGURATION_OBJECT,
- .length = sizeof(SA_LOG_CONFIGURATION_OBJECT)
-};
-
-SaNameT saNameT_Object_256 =
-{
- .value = "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
- "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
- "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
- "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
- "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
- "bbbbb",
- .length = 256
-};
-
-SaNameT saNameT_appstream_name_256 =
-{
- .value = "safLgStr=aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
- "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
- "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
- "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
- "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
- "bbbbb",
- .length = 256
-};
+SaNameT saNameT_appstream_name_256;
static char buf[2048];
@@ -123,11 +81,7 @@ static SaLogBufferT genLogBuffer =
.logBufSize = 0,
};
-SaNameT logSvcUsrName =
-{
- .value = SA_LOG_STREAM_APPLICATION1,
- .length = sizeof(SA_LOG_STREAM_APPLICATION1)
-};
+SaNameT logSvcUsrName;
SaLogRecordT genLogRecord =
{
@@ -169,10 +123,8 @@ int tet_system(const char *command) {
void init_logrootpath(void)
{
SaImmHandleT omHandle;
- SaNameT objectName = {
- .value = "logConfig=1,safApp=safLogService",
- .length = strlen("logConfig=1,safApp=safLogService")
- };
+ SaConstStringT config = "logConfig=1,safApp=safLogService";
+ SaNameT objectName;
SaImmAccessorHandleT accessorHandle;
SaImmAttrValuesT_2 *attribute;
SaImmAttrValuesT_2 **attributes;
@@ -180,7 +132,8 @@ void init_logrootpath(void)
const char logRootDirectory_name[] = "logRootDirectory";
SaImmAttrNameT attributeNames[2] = {(char *) logRootDirectory_name,
NULL};
void *value;
-
+
+ saAisNameLend(config, &objectName);
/* NOTE: immutil init osaf_assert if error */
(void) immutil_saImmOmInitialize(&omHandle, NULL, &immVersion);
(void) immutil_saImmOmAccessorInitialize(omHandle, &accessorHandle);
@@ -352,16 +305,15 @@ int get_active_sc(void)
{
int active_sc = 0;
SaImmHandleT omHandle;
- SaNameT objectName1 = { /* Read object for SC-1 */
- .value = "safSu=SC-1,safSg=2N,safApp=OpenSAF",
- .length = strlen("safSu=SC-1,safSg=2N,safApp=OpenSAF") + 1
- };
+ SaConstStringT objname = "safSu=SC-1,safSg=2N,safApp=OpenSAF";
+ SaNameT objectName1;
SaImmAccessorHandleT accessorHandle;
SaImmAttrValuesT_2 **attributes;
const char saAmfSUNumCurrActiveSIs[] = "saAmfSUNumCurrActiveSIs";
SaImmAttrNameT attributeNames[2] = {(char *) saAmfSUNumCurrActiveSIs,
NULL};
SaUint32T curr_act_sis = 0;
-
+
+ saAisNameLend(objname, &objectName1);
/* NOTE: immutil init osaf_assert if error
*/
(void) immutil_saImmOmInitialize(&omHandle, NULL, &immVersion);
@@ -486,6 +438,24 @@ int main(int argc, char **argv)
char *opt_str_ptr;
char *tok_str_ptr = NULL;
+ if (setenv("SA_ENABLE_EXTENDED_NAMES", "1", 1) != 0 ) {
+ fprintf(stderr, "Failed to set SA_ENABLE_EXTENDED_NAMES (%s)",
+ strerror(errno));
+ exit(0);
+ }
+
+ saAisNameLend(SA_LOG_STREAM_SYSTEM, &systemStreamName);
+ saAisNameLend(SA_LOG_STREAM_ALARM, &alarmStreamName);
+ saAisNameLend(LOGTST_IMM_LOG_GCFG, &globalConfig);
+ saAisNameLend(SA_LOG_STREAM_NOTIFICATION, ¬ificationStreamName);
+ saAisNameLend(SA_LOG_STREAM_APPLICATION1, &app1StreamName);
+ saAisNameLend(DEFAULT_NOTIFYING_OBJECT, ¬ifyingObject);
+ saAisNameLend(DEFAULT_NOTIFICATION_OBJECT, ¬ificationObject);
+ saAisNameLend(SA_LOG_CONFIGURATION_OBJECT, &configurationObject);
+ saAisNameLend(obj256, &saNameT_Object_256);
+ saAisNameLend(name256, &saNameT_appstream_name_256);
+ saAisNameLend(SA_LOG_STREAM_APPLICATION1, &logSvcUsrName);
+
init_logrootpath();
srandom(getpid());
silent_flg = false;
diff --git a/tests/logsv/tet_LogOiOps.c b/tests/logsv/tet_LogOiOps.c
--- a/tests/logsv/tet_LogOiOps.c
+++ b/tests/logsv/tet_LogOiOps.c
@@ -3331,7 +3331,7 @@ void verLogFileName(void)
/* Invalid filename with forward slash in */
sprintf(command, "immcfg -a saLogStreamFileName='invalidFile/Name' %s
2> /dev/null",
- alarmStreamName.value);
+ SA_LOG_STREAM_ALARM);
rc = system(command);
rc_validate(WEXITSTATUS(rc), 1);
diff --git a/tests/logsv/tet_Log_recov.c b/tests/logsv/tet_Log_recov.c
--- a/tests/logsv/tet_Log_recov.c
+++ b/tests/logsv/tet_Log_recov.c
@@ -242,6 +242,10 @@ static int clear_file(char *filename)
* - extension .log
* - two timestamps (other log files has four)
*/
+#ifndef SA_MAX_NAME_LENGTH
+#define SA_MAX_NAME_LENGTH 255
+#endif
+
static char file_name_find[SA_MAX_NAME_LENGTH];
static int filter_logfile_name(const struct dirent *finfo)
{
@@ -389,20 +393,21 @@ static int tst_StreamOpen_app_logtest_sc
int rc = 0;
int n;
int i;
+ char data[255];
/* Open num_streams */
for (i = 0; i < num_streams; i++) {
/* Prepare stream name and attributes for the stream to be
opened */
SaNameT stream_name;
- n = sprintf((char *) stream_name.value, "safLgStr=%s_%d",
+ n = sprintf(data, "safLgStr=%s_%d",
STREAM_NAME_9, i+1);
+ saAisNameLend(data, &stream_name);
if (n < 0) {
fprintf(stderr, "\t%s [%d] sprintf Fail\n",
__FUNCTION__, __LINE__);
rc = -1;
break;
}
- stream_name.length = n;
/* Create log file name */
char logfile_name[256];
@@ -1790,13 +1795,11 @@ static SaLogHandleT logHandleRecv;
void saLogRecov_openRtStream(void)
{
SaAisErrorT rc = SA_AIS_OK;
- SaNameT logStreamName = {.length = 0 };
+ SaNameT logStreamName;
char command[300];
int sysRc;
-
- strcpy((char *)logStreamName.value, "safLgStr=rtCleanup");
- logStreamName.length = strlen((char *)logStreamName.value);
-
+ SaConstStringT data = "safLgStr=rtCleanup";
+ saAisNameLend(data, &logStreamName);
SaLogFileCreateAttributesT_2 appLogFileCreateAttributes;
/* Cleanup the test directory */
diff --git a/tests/logsv/tet_log_longDN.c b/tests/logsv/tet_log_longDN.c
new file mode 100644
--- /dev/null
+++ b/tests/logsv/tet_log_longDN.c
@@ -0,0 +1,1226 @@
+/* -*- OpenSAF -*-
+ *
+ * (C) Copyright 2016 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 <unistd.h>
+#include <saf_error.h>
+#include <poll.h>
+#include <stdbool.h>
+#include "logtest.h"
+
+#include "osaf_extended_name.h"
+#include <saLog.h>
+#include "saf_error.h"
+
+/* Default format expression for alm/not streams */
+static const char *fmt_alarm_default="@Cr @Ct @Nt @Ne6 @No30 @Ng30 \"@Cb\"";
+/* Default format expression for sys/app streams */
+static const char *fmt_sys_default="@Cr @Ch:@Cn:@Cs @Cm/@Cd/@CY @Sv @Sl
\"@Cb\"";
+/* Format expression for testing Long DN at @No */
+static const char *test_alarm_fmt="@Cr @Ct @Nt @Ne6 START_@No_END \"@Cb\"";
+/* Format expression for testing Long DN at @Ng */
+static const char *test_notif_fmt="@Cr @Ct @Nt @Ne6 START_@Ng_END \"@Cb\"";
+/* Format expression for testing Long DN at @Sl */
+static const char *test_sys_fmt="@Cr @Ch:@Cn:@Cs @Cm/@Cd/@CY @Sv START_@Sl_END
\"@Cb\"";
+// @NOTE:
+// The purpose for adding START_*_END in fmt expression
+// is for searching/test verifying using regular expression.
+
+#define ALM_LOG_FILE "saLogAlarmLongDN"
+#define NTF_LOG_FILE "saLogNotificationLongDN"
+#define SYS_LOG_FILE "saLogSystemLongDN"
+#define MAX_DATA 3000
+
+//>>
+// Steps to test Long DN in each test case
+// 1) Change global `logMaxLogrecsize` to max number `SA_LOG_MAX_RECORD_SIZE`
+// 2) Change the `saLogStreamLogFileFormat`
+// 3) Set up the logBuf containing long DN data/or `logSvcUsrName` with long
DN (> 255 bytes)
+// 4) Sending the record to log stream
+// 5) Read the log file and verify the content
+// 6) Restore to default settings
+//<<
+
+/* Vars holding default values - they have to change to test Long DN */
+static uint32_t v_logMaxLogrecsize = 1024;
+static char v_saLogStreamLogFileFormat[1024] = {0};
+static uint32_t v_saLogStreamFixedLogRecordSize = 200;
+static char v_saLogStreamFileName[256] = {0};
+static uint32_t v_longDnsAllowed = 0;
+
+typedef enum {
+ E_ALARM,
+ E_NOTIF,
+ E_SYSTE,
+ E_APPLI
+} stream_type_t;
+
+SaConstStringT s_opensafImm = "opensafImm=opensafImm,safApp=safImmService";
+SaNameT sa_opensafImm;
+
+//>>
+// Global data for handling LOG API
+//<<
+static SaLogHandleT logHandleLd = -1;
+static SaLogStreamHandleT logStreamHandleLd = -1;
+static SaLogRecordT logRecordLd;
+static SaSelectionObjectT selectionObjectLd = -1;
+static SaLogFileCreateAttributesT_2 *logFileCreateAttributesLd = NULL;
+
+static SaNameT logSvcUsrNameLd;
+static SaNameT notificationObjLd;
+static SaNameT notifyingObjLd;
+static SaNameT logStreamNameLd;
+static SaLogBufferT logBufferLd;
+static SaNtfClassIdT notificationClassIdLd = { 1, 2, 3 };
+static SaVersionT logVersionLd = { 'A', 2, 1 };
+static SaInvocationT invocationLd;
+static SaAisErrorT errorLd;
+
+
+/* Try for 10 seconds before giving up on an API */
+#define TEN_SECONDS 10*1000*1000
+/* Sleep for 100 ms before retrying an API */
+#define HUNDRED_MS 100*1000
+
+SaConstStringT logSvcUsrNameDf = "SvcUserName_Test_LongDN";
+SaConstStringT notifyingObjDf = "NotifyingObj_Test_LongDN";
+SaConstStringT notificationObjDf = "NotificationObj_Test_LongDN";
+
+static void logWriteLogCallbackT(SaInvocationT invocation, SaAisErrorT error);
+static SaLogCallbacksT logCallbacksLd = { 0, 0, logWriteLogCallbackT };
+
+//>
+// Following attributes are backup before performing testing
+// logMaxLogrecsize;
+// saLogStreamLogFileFormat
+// saLogStreamFixedLogRecordSize;
+// saLogStreamFileName;
+// longDnsAllowed
+//<
+static int backupData(stream_type_t type)
+{
+ int rc;
+
+ saAisNameLend(s_opensafImm, &sa_opensafImm);
+ rc = get_attr_value(&sa_opensafImm, "longDnsAllowed",
&v_longDnsAllowed);
+ if (rc == -1) {
+ /* Failed, use default one */
+ fprintf(stderr, "Failed to get attribute longDnsAllowed value
from IMM\n");
+ }
+ rc = get_attr_value(&configurationObject, "logMaxLogrecsize",
&v_logMaxLogrecsize);
+ if (rc == -1) {
+ /* Failed, use default one */
+ fprintf(stderr, "Failed to get attribute logMaxLogrecsize value
from IMM\n");
+ }
+
+ switch (type) {
+ case E_ALARM:
+ /* Get and save saLogStreamLogFileFormat */
+ rc = get_attr_value(&alarmStreamName,
"saLogStreamLogFileFormat", v_saLogStreamLogFileFormat);
+ if (rc == -1) {
+ /* Failed, use default one */
+ fprintf(stderr, "Failed to get saLogStreamLogFileFormat
attribute value from IMM\n");
+ strncpy(v_saLogStreamLogFileFormat, fmt_alarm_default,
500);
+ }
+ /* Get and save salogStreamFileName */
+ rc = get_attr_value(&alarmStreamName, "saLogStreamFileName",
v_saLogStreamFileName);
+ if (rc == -1) {
+ /* Failed, use default one */
+ fprintf(stderr, "Failed to get saLogStreamFileName
attribute value from IMM\n");
+ strncpy(v_saLogStreamFileName, "saLogAlarm", 256);
+ }
+ /* Get and save saLogStreamFixedLogRecordSize */
+ rc = get_attr_value(&alarmStreamName,
"saLogStreamFixedLogRecordSize",
+ &v_saLogStreamFixedLogRecordSize);
+ if (rc == -1) {
+ /* Failed, use default one */
+ fprintf(stderr, "Failed to get
saLogStreamFixedLogRecordSize attribute value from IMM\n");
+ }
+ break;
+
+ case E_NOTIF:
+ /* Get and save saLogStreamLogFileFormat */
+ rc = get_attr_value(¬ificationStreamName,
"saLogStreamLogFileFormat",
+ v_saLogStreamLogFileFormat);
+ if (rc == -1) {
+ /* Failed, use default one */
+ fprintf(stderr, "Failed to get attribute value from
IMM\n");
+ strncpy(v_saLogStreamLogFileFormat, fmt_alarm_default,
256);
+ }
+ /* Get and save salogStreamFileName */
+ rc = get_attr_value(¬ificationStreamName,
"saLogStreamFileName", v_saLogStreamFileName);
+ if (rc == -1) {
+ /* Failed, use default one */
+ fprintf(stderr, "Failed to get saLogStreamFileName
attribute value from IMM\n");
+ strncpy(v_saLogStreamFileName, "saLogNotification",
256);
+ }
+ /* Get and save saLogStreamFixedLogRecordSize */
+ rc = get_attr_value(¬ificationStreamName,
"saLogStreamFixedLogRecordSize",
+ &v_saLogStreamFixedLogRecordSize);
+ if (rc == -1) {
+ /* Failed, use default one */
+ fprintf(stderr, "Failed to get
saLogStreamFixedLogRecordSize attribute value from IMM\n");
+ }
+ break;
+
+ case E_SYSTE:
+ /* Get and save saLogStreamLogFileFormat */
+ rc = get_attr_value(&systemStreamName,
"saLogStreamLogFileFormat",
+ v_saLogStreamLogFileFormat);
+ if (rc == -1) {
+ /* Failed, use default one */
+ fprintf(stderr, "Failed to get attribute value from
IMM\n");
+ strncpy(v_saLogStreamLogFileFormat, fmt_sys_default,
256);
+ }
+ /* Get and save salogStreamFileName */
+ rc = get_attr_value(&systemStreamName, "saLogStreamFileName",
v_saLogStreamFileName);
+ if (rc == -1) {
+ /* Failed, use default one */
+ fprintf(stderr, "Failed to get saLogStreamFileName
attribute value from IMM\n");
+ strncpy(v_saLogStreamFileName, "saLogSystem", 256);
+ }
+ /* Get and save saLogStreamFixedLogRecordSize */
+ rc = get_attr_value(&systemStreamName,
"saLogStreamFixedLogRecordSize",
+ &v_saLogStreamFixedLogRecordSize);
+ if (rc == -1) {
+ /* Failed, use default one */
+ fprintf(stderr, "Failed to get
saLogStreamFixedLogRecordSize attribute value from IMM\n");
+ }
+ break;
+
+ case E_APPLI:
+ /* Do nothing here */
+ break;
+
+ default:
+ fprintf(stderr, "Not supported!\n");
+ rc = -1;
+ break;
+ }
+
+ return rc;
+}
+
+//>
+// Set up environments before performing testing
+// 1) Tell IMM to enable long DN feature
+// 2) Change max log record size (record contains long DN data could be huge)
+// 3) Change log file format, so long DN can be saved fully in log record
+// 4) Change log record size to variable record (not fix one)
+//
+// Return value must be 0, report test failed otherwise.
+//<
+static int setUpTestEnv(stream_type_t type)
+{
+ int rc;
+ char command[MAX_DATA];
+
+ /* Enable long DN feature */
+ rc = system("immcfg -m -a longDnsAllowed=1
opensafImm=opensafImm,safApp=safImmService");
+ if (WEXITSTATUS(rc) != 0) {
+ fprintf(stderr, "Failed to enable long DN \n");
+ return -1;
+ }
+ sprintf(command, "immcfg -a logMaxLogrecsize=%d "
+ "logConfig=1,safApp=safLogService 2> /dev/null",
SA_LOG_MAX_RECORD_SIZE);
+ rc = system(command);
+ if (WEXITSTATUS(rc) != 0) {
+ fprintf(stderr, "Failed to execute command %s\n", command);
+ return -1;
+ }
+
+ switch (type) {
+ case E_ALARM:
+ sprintf(command, "immcfg -a saLogStreamLogFileFormat=\"%s\" "
+ " -a saLogStreamFixedLogRecordSize=0 %s",
+ test_alarm_fmt, SA_LOG_STREAM_ALARM);
+ break;
+
+ case E_NOTIF:
+ sprintf(command, "immcfg -a saLogStreamLogFileFormat=\"%s\" "
+ " -a saLogStreamFixedLogRecordSize=0 %s",
+ test_notif_fmt, SA_LOG_STREAM_NOTIFICATION);
+ break;
+
+ case E_SYSTE:
+ sprintf(command, "immcfg -a saLogStreamLogFileFormat=\"%s\" "
+ " -a saLogStreamFixedLogRecordSize=0 %s",
+ test_sys_fmt, SA_LOG_STREAM_SYSTEM);
+ break;
+
+ case E_APPLI:
+ /* Do nothing here */
+ break;
+
+ default:
+ fprintf(stderr, "Not supported\n");
+ return -1;
+ }
+
+ rc = system(command);
+ if (WEXITSTATUS(rc) != 0) {
+ fprintf(stderr, "Failed to perform cmd = %s\n", command);
+ return -1;
+ }
+
+ return 0;
+}
+
+void restoreData(stream_type_t type)
+{
+ int rc;
+ char command[MAX_DATA];
+
+ sprintf(command, "immcfg -a longDnsAllowed=%d %s", v_longDnsAllowed,
s_opensafImm);
+ rc = system(command);
+ if (WEXITSTATUS(rc) != 0) {
+ fprintf(stderr, "Failed to perform cmd = %s\n", command);
+ }
+
+ sprintf(command, "immcfg -a logMaxLogrecsize=%d "
+ "logConfig=1,safApp=safLogService 2> /dev/null",
v_logMaxLogrecsize);
+ rc = system(command);
+ if (WEXITSTATUS(rc) != 0) {
+ fprintf(stderr, "Failed to perform cmd = %s\n", command);
+ }
+
+ switch (type) {
+ case E_ALARM:
+ sprintf(command, "immcfg -a saLogStreamLogFileFormat=\"%s\" "
+ " -a saLogStreamFixedLogRecordSize=%d %s",
v_saLogStreamLogFileFormat,
+ v_saLogStreamFixedLogRecordSize, SA_LOG_STREAM_ALARM);
+ break;
+
+ case E_NOTIF:
+ sprintf(command, "immcfg -a saLogStreamLogFileFormat=\"%s\" "
+ " -a saLogStreamFixedLogRecordSize=%d %s",
v_saLogStreamLogFileFormat,
+ v_saLogStreamFixedLogRecordSize,
SA_LOG_STREAM_NOTIFICATION);
+ break;
+
+ case E_SYSTE:
+ sprintf(command, "immcfg -a saLogStreamLogFileFormat=\"%s\" "
+ " -a saLogStreamFixedLogRecordSize=%d %s",
v_saLogStreamLogFileFormat,
+ v_saLogStreamFixedLogRecordSize, SA_LOG_STREAM_SYSTEM);
+ break;
+
+ case E_APPLI:
+ /* Do nothing here */
+ break;
+
+ default:
+ fprintf(stderr, "Not supported\n");
+ break;
+ }
+
+ rc = system(command);
+ if (WEXITSTATUS(rc) != 0) {
+ fprintf(stderr, "failed to perform cmd = %s\n", command);
+ }
+
+}
+
+//
+// Functions
+//
+
+static void logWriteLogCallbackT(SaInvocationT invocation, SaAisErrorT error)
+{
+ invocationLd = invocation;
+ errorLd = error;
+}
+
+static SaTimeT currentTime(void)
+{
+ struct timeval tv;
+ SaTimeT ntfTime;
+ gettimeofday(&tv, 0);
+ ntfTime = ((unsigned)tv.tv_sec * 1000000000ULL) +
+ ((unsigned)tv.tv_usec * 1000ULL);
+ return ntfTime;
+}
+
+static SaAisErrorT initLog(void)
+{
+ SaAisErrorT error;
+ unsigned int wait_time = 0;
+
+ error = saLogInitialize(&logHandleLd, &logCallbacksLd, &logVersionLd);
+ while (error == SA_AIS_ERR_TRY_AGAIN && wait_time < TEN_SECONDS) {
+ usleep(HUNDRED_MS);
+ wait_time += HUNDRED_MS;
+ error = saLogInitialize(&logHandleLd, &logCallbacksLd,
&logVersionLd);
+ }
+
+ return error;
+}
+
+static SaAisErrorT openLog(stream_type_t type)
+{
+ SaAisErrorT error;
+ unsigned int wait_time = 0;
+ SaLogStreamOpenFlagsT logStreamOpenFlagsIn = 0;
+ SaLogFileCreateAttributesT_2 appLogFileCreateAttributesIn;
+
+ // Set up default data
+ saAisNameLend(logSvcUsrNameDf, &logSvcUsrNameLd);
+ saAisNameLend(notifyingObjDf, ¬ifyingObjLd);
+ saAisNameLend(notificationObjDf, ¬ificationObjLd);
+
+
+ saAisNameLend(SA_LOG_STREAM_SYSTEM, &logStreamNameLd);
+ logRecordLd.logTimeStamp = SA_TIME_UNKNOWN; /* LOG service should
supply timestamp */
+ logRecordLd.logHdrType = SA_LOG_GENERIC_HEADER;
+ logRecordLd.logHeader.genericHdr.notificationClassId = NULL;
+ logRecordLd.logHeader.genericHdr.logSeverity = SA_LOG_SEV_INFO;
+ logRecordLd.logHeader.genericHdr.logSvcUsrName = &logSvcUsrNameLd;
+ logRecordLd.logBuffer = NULL;
+
+ /* Initial data for E_APPLI stream type */
+ char appStreamDN[1000] = {0};
+
+ switch (type) {
+ case E_ALARM:
+ saAisNameLend(SA_LOG_STREAM_ALARM, &logStreamNameLd);
+ logRecordLd.logHdrType = SA_LOG_NTF_HEADER;
+ break;
+
+ case E_NOTIF:
+ saAisNameLend(SA_LOG_STREAM_NOTIFICATION, &logStreamNameLd);
+ logRecordLd.logHdrType = SA_LOG_NTF_HEADER;
+ break;
+
+ case E_SYSTE:
+ /* Do nothing here */
+ break;
+
+ case E_APPLI:
+ appLogFileCreateAttributesIn.logFilePathName = "testLongDN";
+ appLogFileCreateAttributesIn.maxLogFileSize =
DEFAULT_APP_LOG_FILE_SIZE;
+ appLogFileCreateAttributesIn.maxLogRecordSize =
DEFAULT_APP_LOG_REC_SIZE;
+ appLogFileCreateAttributesIn.haProperty = SA_TRUE;
+ appLogFileCreateAttributesIn.logFileFullAction =
SA_LOG_FILE_FULL_ACTION_ROTATE;
+ appLogFileCreateAttributesIn.maxFilesRotated = 4;
+
+ char tmp [1000] = {0};
+ memset(tmp, 'L', sizeof(tmp) - 1);
+ snprintf(appStreamDN, sizeof(appStreamDN) - 2, "safLgStr=%s",
tmp);
+
+ /* Use built-in log file format in log server for app stream */
+ appLogFileCreateAttributesIn.logFileFmt = NULL;
+ appLogFileCreateAttributesIn.logFileName = "longDNAppStream";
+
+ logFileCreateAttributesLd = &appLogFileCreateAttributesIn;
+ logStreamOpenFlagsIn = SA_LOG_STREAM_CREATE;
+ saAisNameLend(appStreamDN, &logStreamNameLd);
+
+ break;
+
+ default:
+ fprintf(stderr, "Not supported \n");
+ return SA_AIS_ERR_INVALID_PARAM;
+ }
+
+ if (logRecordLd.logHdrType == SA_LOG_NTF_HEADER) {
+ /* Setup some valid values */
+ logRecordLd.logHeader.ntfHdr.notificationId =
SA_NTF_IDENTIFIER_UNUSED;
+ logRecordLd.logHeader.ntfHdr.eventType =
SA_NTF_ALARM_PROCESSING;
+ logRecordLd.logHeader.ntfHdr.notificationObject =
¬ificationObjLd;
+ logRecordLd.logHeader.ntfHdr.notifyingObject = ¬ifyingObjLd;
+ logRecordLd.logHeader.ntfHdr.notificationClassId =
¬ificationClassIdLd;
+ logRecordLd.logHeader.ntfHdr.eventTime = currentTime();
+ }
+
+ error = saLogStreamOpen_2(logHandleLd, &logStreamNameLd, NULL, 0,
+ SA_TIME_ONE_SECOND, &logStreamHandleLd);
+ while (error == SA_AIS_ERR_TRY_AGAIN && wait_time < TEN_SECONDS) {
+ usleep(HUNDRED_MS);
+ wait_time += HUNDRED_MS;
+ error = saLogStreamOpen_2(logHandleLd, &logStreamNameLd, NULL,
0,
+ SA_TIME_ONE_SECOND,
&logStreamHandleLd);
+ }
+
+ if (error == SA_AIS_ERR_NOT_EXIST && type == E_APPLI) {
+ wait_time = 0;
+ error = saLogStreamOpen_2(logHandleLd, &logStreamNameLd,
logFileCreateAttributesLd,
+ logStreamOpenFlagsIn,
SA_TIME_ONE_SECOND, &logStreamHandleLd);
+ while (error == SA_AIS_ERR_TRY_AGAIN && wait_time <
TEN_SECONDS) {
+ usleep(HUNDRED_MS);
+ wait_time += HUNDRED_MS;
+ error = saLogStreamOpen_2(logHandleLd,
&logStreamNameLd, logFileCreateAttributesLd,
+ logStreamOpenFlagsIn,
SA_TIME_ONE_SECOND, &logStreamHandleLd);
+ }
+ }
+
+ return error;
+}
+
+static SaAisErrorT endLog(void)
+{
+ SaAisErrorT error;
+ unsigned int wait_time = 0;
+
+ wait_time = 0;
+ error = saLogStreamClose(logStreamHandleLd);
+ while (error == SA_AIS_ERR_TRY_AGAIN && wait_time < TEN_SECONDS) {
+ usleep(HUNDRED_MS);
+ wait_time += HUNDRED_MS;
+ error = saLogStreamClose(logStreamHandleLd);
+ }
+ if (SA_AIS_OK != error) {
+ fprintf(stderr, "saLogStreamClose FAILED: %s\n",
saf_error(error));
+ }
+
+ wait_time = 0;
+ error = saLogFinalize(logHandleLd);
+ while (error == SA_AIS_ERR_TRY_AGAIN && wait_time < TEN_SECONDS) {
+ usleep(HUNDRED_MS);
+ wait_time += HUNDRED_MS;
+ error = saLogFinalize(logHandleLd);
+ }
+ if (SA_AIS_OK != error) {
+ fprintf(stderr, "saLogFinalize FAILED: %s\n", saf_error(error));
+ }
+
+ /* Reset data */
+ logStreamHandleLd = -1;
+ logHandleLd = -1;
+ selectionObjectLd = -1;
+
+ return error;
+
+}
+
+static SaAisErrorT writeLog(void)
+{
+ SaAisErrorT error;
+ unsigned int wait_time = 0;
+ SaInvocationT invocation;
+ int sz;
+ struct pollfd fds[1];
+ const char *logBuf = "test long DN";
+ int ret;
+
+ sz = strlen(logBuf);
+ logBufferLd.logBufSize = sz;
+ logBufferLd.logBuf = (SaUint8T *)logBuf;
+ logRecordLd.logBuffer = &logBufferLd;
+ invocation = random();
+
+retry:
+ error = saLogWriteLogAsync(logStreamHandleLd, invocation,
SA_LOG_RECORD_WRITE_ACK, &logRecordLd);
+ while (error == SA_AIS_ERR_TRY_AGAIN && wait_time < TEN_SECONDS) {
+ usleep(HUNDRED_MS);
+ wait_time += HUNDRED_MS;
+ goto retry;
+ }
+
+ if (error != SA_AIS_OK) {
+ return error;
+ }
+
+ fds[0].fd = (int)selectionObjectLd;
+ fds[0].events = POLLIN;
+
+poll_retry:
+ ret = poll(fds, 1, 20000);
+
+ if (ret == EINTR)
+ goto poll_retry;
+ if (ret == -1) {
+ fprintf(stderr, "poll FAILED: %u\n", ret);
+ return SA_AIS_ERR_BAD_OPERATION;
+ }
+ if (ret == 0) {
+ fprintf(stderr, "poll timeout\n");
+ return SA_AIS_ERR_BAD_OPERATION;
+ }
+
+ error = saLogDispatch(logHandleLd, SA_DISPATCH_ONE);
+ if (error != SA_AIS_OK) {
+ fprintf(stderr, "saLogDispatch FAILED: %s\n", saf_error(error));
+ return error;
+ }
+
+ if (invocationLd != invocation) {
+ fprintf(stderr, "logWriteLogCallbackT FAILED: wrong
invocation\n");
+ return SA_AIS_ERR_BAD_OPERATION;
+ }
+ if (errorLd == SA_AIS_ERR_TRY_AGAIN && wait_time < TEN_SECONDS) {
+ usleep(HUNDRED_MS);
+ wait_time += HUNDRED_MS;
+ goto retry;
+ }
+ if (errorLd == SA_AIS_ERR_TIMEOUT) {
+ usleep(HUNDRED_MS);
+ fprintf(stderr, "got SA_AIS_ERR_TIMEOUT, retry\n");
+ goto retry;
+ }
+ if (errorLd != SA_AIS_OK) {
+ fprintf(stderr, "logWriteLogCallbackT FAILED: %s\n",
saf_error(errorLd));
+ return errorLd;
+ }
+
+ return error;
+}
+
+//>
+// Verify the log file content to see if the long DN exists at specific token
or not
+//
+// 1) Find all log files that have changes within last 1 minute
+// 2) Take all log files which match the pattern
+// 3) Search in file to see the long DN exist
+// 4) Return 0 if found, otherwise -1
+//
+// @param type stream type
+// @ret 0 if found long DN in log record, 1 otherwise
+//
+// NOTES:
+// 1) If environment variable `LOGTEST_ENABLE_STDOUT` set, user will set
+// the log record that contains the long DN.
+// 2) In step #1, if the timer is different b/w active and other nodes,
+// running test on other node might get failed at verifyData step.
+//<
+static int verifyData(void)
+{
+ int rc = 0;
+ char command[500];
+ bool disable_stdout = true;
+ SaConstStringT s_stdout = "1> /dev/null";
+
+ if (getenv("LOGTEST_ENABLE_STDOUT")) disable_stdout = false;
+
+ sprintf(command, "find %s -type f -mmin -1 | egrep
\"%s_[0-9]{8}_[0-9]{6}\\.log$\" "
+ " | xargs egrep \" START.*END \" %s ",
+ log_root_path, v_saLogStreamFileName, disable_stdout ? s_stdout
: " ");
+ rc = system(command);
+ if (WEXITSTATUS(rc) != 0) {
+ fprintf(stderr, "failed to perform cmd = %s\n", command);
+ rc = 1;
+ }
+
+ return rc;
+}
+
+//>>
+// UC1: Write an log records using the long DN in @No tokens using Log API.
+//<<
+void longDNAt_No_token(void)
+{
+ int rc;
+ SaAisErrorT ais;
+
+ rc = backupData(E_ALARM);
+ if (rc != 0) {
+ fprintf(stderr, "Backup data failed\n");
+ // Not report test failed as can use default data to restore.
+ // rc_validate(WEXITSTATUS(rc), 0);
+ // return;
+ }
+
+ rc = setUpTestEnv(E_ALARM);
+ if (rc != 0) {
+ fprintf(stderr, "set up env failed\n");
+ rc_validate(WEXITSTATUS(rc), 0);
+ goto done;
+ }
+
+ ais = initLog();
+ if (ais != SA_AIS_OK) {
+ fprintf(stderr, "initLog FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done;
+ }
+
+ ais = openLog(E_ALARM);
+ if (ais != SA_AIS_OK) {
+ fprintf(stderr, "openLog FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done_init;
+ }
+
+ ais = saLogSelectionObjectGet(logHandleLd, &selectionObjectLd);
+ if (ais != SA_AIS_OK) {
+ printf("saLogSelectionObjectGet FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done_init;
+ }
+
+ // Long DN in @No token
+ char notificationObj[1000] = {0};
+ memset(notificationObj, 'A', sizeof(notificationObj) - 1);
+ saAisNameLend(notificationObj, ¬ificationObjLd);
+
+ ais = writeLog();
+ if (ais != SA_AIS_OK) {
+ fprintf(stderr, "saLogOpen FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done_init;
+ }
+
+ // Verify if log file contains long DN record or not
+ rc = verifyData();
+ rc_validate(rc, 0);
+
+ // End testing. Close handles and restore data
+done_init:
+ endLog();
+done:
+ restoreData(E_ALARM);
+}
+
+//>>
+// UC2: Write an log records using the long DN in @Ng tokens using Log API.
+//<<
+void longDNAt_Ng_token(void)
+{
+ int rc;
+ SaAisErrorT ais;
+
+ rc = backupData(E_NOTIF);
+ if (rc != 0) {
+ fprintf(stderr, "Backup data failed\n");
+ // Not report test failed as can use default data to restore.
+ // rc_validate(WEXITSTATUS(rc), 0);
+ // return;
+ }
+
+ rc = setUpTestEnv(E_NOTIF);
+ if (rc != 0) {
+ fprintf(stderr, "set up env failed\n");
+ rc_validate(WEXITSTATUS(rc), 0);
+ goto done;
+ }
+
+ ais = initLog();
+ if (ais != SA_AIS_OK) {
+ fprintf(stderr, "saLogInitialize FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done;
+ }
+
+ ais = openLog(E_NOTIF);
+ if (ais != SA_AIS_OK) {
+ fprintf(stderr, "saLogOpen FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done_init;
+ }
+
+ ais = saLogSelectionObjectGet(logHandleLd, &selectionObjectLd);
+ if (ais != SA_AIS_OK) {
+ printf("saLogSelectionObjectGet FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done_init;
+ }
+
+ // Long DN in @No token
+ char notifyingObj[1000] = {0};
+ memset(notifyingObj, 'B', sizeof(notifyingObj) - 1);
+ saAisNameLend(notifyingObj, ¬ifyingObjLd);
+
+ ais = writeLog();
+ if (ais != SA_AIS_OK) {
+ fprintf(stderr, "saLogOpen FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done_init;
+ }
+
+ // Verify if log file contains long DN record or not
+ rc = verifyData();
+ rc_validate(rc, 0);
+
+ // End testing. Close handles and restore data
+done_init:
+ endLog();
+done:
+ restoreData(E_NOTIF);
+}
+
+//>>
+// UC3: Write an log records using the long DN in @Sl tokens using Log API.
+//<<
+void longDNAt_Sl_token(void)
+{
+ int rc;
+ SaAisErrorT ais;
+
+ rc = backupData(E_SYSTE);
+ if (rc != 0) {
+ fprintf(stderr, "Backup data failed\n");
+ // Not report test failed as can use default data to restore.
+ // rc_validate(WEXITSTATUS(rc), 0);
+ // return;
+ }
+
+ rc = setUpTestEnv(E_SYSTE);
+ if (rc != 0) {
+ fprintf(stderr, "set up env failed\n");
+ rc_validate(WEXITSTATUS(rc), 0);
+ goto done;
+ }
+
+ ais = initLog();
+ if (ais != SA_AIS_OK) {
+ fprintf(stderr, "saLogInitialize FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done;
+ }
+
+ ais = openLog(E_SYSTE);
+ if (ais != SA_AIS_OK) {
+ fprintf(stderr, "saLogOpen FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done_init;
+ }
+
+ ais = saLogSelectionObjectGet(logHandleLd, &selectionObjectLd);
+ if (ais != SA_AIS_OK) {
+ printf("saLogSelectionObjectGet FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done_init;
+ }
+
+ // Long DN in @Sl token
+ char serviceName[1000] = {0};
+ memset(serviceName, 'C', sizeof(serviceName) - 1);
+ saAisNameLend(serviceName, &logSvcUsrNameLd);
+
+ ais = writeLog();
+ if (ais != SA_AIS_OK) {
+ fprintf(stderr, "saLogOpen FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done_init;
+ }
+
+ // Verify if log file contains long DN record or not
+ rc = verifyData();
+ rc_validate(rc, 0);
+
+ // End testing. Close handles and restore data
+done_init:
+ endLog();
+done:
+ restoreData(E_SYSTE);
+}
+
+//>>
+// UC4: Write an log records to long DN app stream using Log API.
+//<<
+void longDN_AppStream(void)
+{
+ int rc;
+ SaAisErrorT ais;
+
+ rc = backupData(E_APPLI);
+ if (rc != 0) {
+ fprintf(stderr, "Backup data failed\n");
+ // Not report test failed as can use default data to restore.
+ // rc_validate(WEXITSTATUS(rc), 0);
+ // return;
+ }
+
+ rc = setUpTestEnv(E_APPLI);
+ if (rc != 0) {
+ fprintf(stderr, "set up env failed\n");
+ rc_validate(WEXITSTATUS(rc), 0);
+ goto done;
+ }
+
+ ais = initLog();
+ if (ais != SA_AIS_OK) {
+ fprintf(stderr, "saLogInitialize FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done;
+ }
+
+ ais = openLog(E_APPLI);
+ if (ais != SA_AIS_OK) {
+ fprintf(stderr, "saLogOpen FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done_init;
+ }
+
+ ais = saLogSelectionObjectGet(logHandleLd, &selectionObjectLd);
+ if (ais != SA_AIS_OK) {
+ printf("saLogSelectionObjectGet FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done_init;
+ }
+
+ ais = writeLog();
+ if (ais != SA_AIS_OK) {
+ fprintf(stderr, "saLogOpen FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done_init;
+ }
+
+ rc_validate(rc, 0);
+
+ // End testing. Close handles and restore data
+done_init:
+ endLog();
+done:
+ restoreData(E_APPLI);
+}
+
+//>>
+// UC5: Write a log record to long DN runtime app stream using saflogger
+//<<
+void longDNIn_AppStreamDN(void)
+{
+ int rc;
+ char command[3000];
+
+ // Backup default setting
+ saAisNameLend(s_opensafImm, &sa_opensafImm);
+ rc = get_attr_value(&sa_opensafImm, "longDnsAllowed",
&v_longDnsAllowed);
+ if (rc == -1) {
+ /* Failed, use default one */
+ fprintf(stderr, "Failed to get attribute longDnsAllowed value
from IMM\n");
+ }
+
+ /* Enable long DN feature */
+ rc = system("immcfg -m -a longDnsAllowed=1
opensafImm=opensafImm,safApp=safImmService");
+ if (WEXITSTATUS(rc) != 0) {
+ fprintf(stderr, "Failed to enable long DN \n");
+ rc_validate(WEXITSTATUS(rc), 0);
+ return;
+ }
+
+ // Preparing data
+ char appStreamDN[1000] = {0};
+ memset(appStreamDN, 'D', sizeof(appStreamDN) - 1);
+
+ // Perform testing
+ sprintf(command, "saflogger -a safLgStrCfg=%s -f longDN longDN_test",
appStreamDN);
+ rc = system(command);
+ if (WEXITSTATUS(rc) != 0) {
+ fprintf(stderr, "Failed to perform cmd = %s\n", command);
+ rc_validate(WEXITSTATUS(rc), 0);
+ goto done;
+ }
+
+ rc_validate(WEXITSTATUS(rc), 0);
+done:
+ // Restore data
+ sprintf(command, "immcfg -a longDnsAllowed=%d %s", v_longDnsAllowed,
s_opensafImm);
+ rc = system(command);
+ if (WEXITSTATUS(rc) != 0) {
+ fprintf(stderr, "Failed to perform cmd = %s\n", command);
+ }
+
+}
+
+//>
+// ABNORMAL USE CASES
+//<
+
+//>>
+// A-UC1: Write an log records with `notificationObject` over kOsafMaxDnLength
(2048)
+// using Log API.
+//<<
+void longDN_No_Over_MaxDn(void)
+{
+ int rc;
+ SaAisErrorT ais;
+
+ rc = backupData(E_ALARM);
+ if (rc != 0) {
+ fprintf(stderr, "Backup data failed\n");
+ // Not report test failed as can use default data to restore.
+ // rc_validate(WEXITSTATUS(rc), 0);
+ // return;
+ }
+
+ rc = setUpTestEnv(E_ALARM);
+ if (rc != 0) {
+ fprintf(stderr, "set up env failed\n");
+ rc_validate(WEXITSTATUS(rc), 0);
+ goto done;
+ }
+
+ ais = initLog();
+ if (ais != SA_AIS_OK) {
+ fprintf(stderr, "initLog FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done;
+ }
+
+ ais = openLog(E_ALARM);
+ if (ais != SA_AIS_OK) {
+ fprintf(stderr, "openLog FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done_init;
+ }
+
+ ais = saLogSelectionObjectGet(logHandleLd, &selectionObjectLd);
+ if (ais != SA_AIS_OK) {
+ printf("saLogSelectionObjectGet FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done_init;
+ }
+
+ // Long DN in @No token
+ char notificationObj[kOsafMaxDnLength + 1] = {0};
+ memset(notificationObj, 'X', sizeof(notificationObj) - 1);
+ saAisNameLend(notificationObj, ¬ificationObjLd);
+
+ ais = writeLog();
+ rc_validate(ais, SA_AIS_ERR_INVALID_PARAM);
+
+ // End testing. Close handles and restore data
+done_init:
+ endLog();
+done:
+ restoreData(E_ALARM);
+}
+
+//>>
+// A-UC3: Write an log records with `notifyingObject` over kOsafMaxDnLength
(2048)
+// using Log API.
+//<<
+void longDN_Ng_Over_MaxDn(void)
+{
+ int rc;
+ SaAisErrorT ais;
+
+ rc = backupData(E_NOTIF);
+ if (rc != 0) {
+ fprintf(stderr, "Backup data failed\n");
+ // Not report test failed as can use default data to restore.
+ // rc_validate(WEXITSTATUS(rc), 0);
+ // return;
+ }
+
+ rc = setUpTestEnv(E_NOTIF);
+ if (rc != 0) {
+ fprintf(stderr, "set up env failed\n");
+ rc_validate(WEXITSTATUS(rc), 0);
+ goto done;
+ }
+
+ ais = initLog();
+ if (ais != SA_AIS_OK) {
+ fprintf(stderr, "saLogInitialize FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done;
+ }
+
+ ais = openLog(E_NOTIF);
+ if (ais != SA_AIS_OK) {
+ fprintf(stderr, "saLogOpen FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done_init;
+ }
+
+ ais = saLogSelectionObjectGet(logHandleLd, &selectionObjectLd);
+ if (ais != SA_AIS_OK) {
+ printf("saLogSelectionObjectGet FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done_init;
+ }
+
+ // Long DN in @No token
+ char notifyingObj[kOsafMaxDnLength + 1] = {0};
+ memset(notifyingObj, 'Y', sizeof(notifyingObj) - 1);
+ saAisNameLend(notifyingObj, ¬ifyingObjLd);
+
+ ais = writeLog();
+ rc_validate(ais, SA_AIS_ERR_INVALID_PARAM);
+
+ // End testing. Close handles and restore data
+done_init:
+ endLog();
+done:
+ restoreData(E_NOTIF);
+}
+
+//>>
+// A-UC3: Write an log records with `logSvcUsrName` over kOsafMaxDnLength
(2048)
+// using Log API.
+//<<
+void longDN_Sl_Over_MaxDn(void)
+{
+ int rc;
+ SaAisErrorT ais;
+
+ rc = backupData(E_SYSTE);
+ if (rc != 0) {
+ fprintf(stderr, "Backup data failed\n");
+ // Not report test failed as can use default data to restore.
+ // rc_validate(WEXITSTATUS(rc), 0);
+ // return;
+ }
+
+ rc = setUpTestEnv(E_SYSTE);
+ if (rc != 0) {
+ fprintf(stderr, "set up env failed\n");
+ rc_validate(WEXITSTATUS(rc), 0);
+ goto done;
+ }
+
+ ais = initLog();
+ if (ais != SA_AIS_OK) {
+ fprintf(stderr, "saLogInitialize FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done;
+ }
+
+ ais = openLog(E_SYSTE);
+ if (ais != SA_AIS_OK) {
+ fprintf(stderr, "saLogOpen FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done_init;
+ }
+
+ ais = saLogSelectionObjectGet(logHandleLd, &selectionObjectLd);
+ if (ais != SA_AIS_OK) {
+ printf("saLogSelectionObjectGet FAILED: %s\n", saf_error(ais));
+ rc_validate(ais, SA_AIS_OK);
+ goto done_init;
+ }
+
+ // Long DN in @Sl token
+ char serviceName[kOsafMaxDnLength + 1] = {0};
+ memset(serviceName, 'Z', sizeof(serviceName) - 1);
+ saAisNameLend(serviceName, &logSvcUsrNameLd);
+
+ ais = writeLog();
+ rc_validate(ais, SA_AIS_ERR_INVALID_PARAM);
+
+ // End testing. Close handles and restore data
+done_init:
+ endLog();
+done:
+ restoreData(E_SYSTE);
+}
+
+//>>
+// UC4: Write a log record to long DN runtime app stream using saflogger
+//<<
+void longDN_AppStrDN_Over_MaxDn(void)
+{
+ int rc;
+ char command[kOsafMaxDnLength + 100];
+
+ // Backup default setting
+ saAisNameLend(s_opensafImm, &sa_opensafImm);
+ rc = get_attr_value(&sa_opensafImm, "longDnsAllowed",
&v_longDnsAllowed);
+ if (rc == -1) {
+ /* Failed, use default one */
+ fprintf(stderr, "Failed to get attribute longDnsAllowed value
from IMM\n");
+ }
+
+ /* Enable long DN feature */
+ rc = system("immcfg -m -a longDnsAllowed=1
opensafImm=opensafImm,safApp=safImmService");
+ if (WEXITSTATUS(rc) != 0) {
+ fprintf(stderr, "Failed to enable long DN \n");
+ rc_validate(WEXITSTATUS(rc), 0);
+ return;
+ }
+
+ // Preparing data
+ char appStreamDN[kOsafMaxDnLength + 1] = {0};
+ memset(appStreamDN, 'x', sizeof(appStreamDN) - 1);
+
+ // Perform testing
+ sprintf(command, "saflogger -a safLgStrCfg=%s -f longDN_overMax
longDN_test 2> /dev/null", appStreamDN);
+ rc = system(command);
+ if (WEXITSTATUS(rc) != 0) {
+ rc_validate(0, 0);
+ goto done;
+ }
+
+ rc_validate(1, 0);
+done:
+ // Restore data
+ sprintf(command, "immcfg -a longDnsAllowed=%d %s", v_longDnsAllowed,
s_opensafImm);
+ rc = system(command);
+ if (WEXITSTATUS(rc) != 0) {
+ fprintf(stderr, "Failed to perform cmd = %s\n", command);
+ }
+
+}
+
+//>>
+// A-UC4: Write a log record to long DN runtime app stream using saflogger,
+// but not using f option (ER)
+//<<
+void longDNIn_AppStreamDN_ButNoF(void)
+{
+ int rc;
+ char command[3000];
+
+ // Backup default setting
+ saAisNameLend(s_opensafImm, &sa_opensafImm);
+ rc = get_attr_value(&sa_opensafImm, "longDnsAllowed",
&v_longDnsAllowed);
+ if (rc == -1) {
+ /* Failed, use default one */
+ fprintf(stderr, "Failed to get attribute longDnsAllowed value
from IMM\n");
+ }
+
+ /* Enable long DN feature */
+ rc = system("immcfg -m -a longDnsAllowed=1
opensafImm=opensafImm,safApp=safImmService");
+ if (WEXITSTATUS(rc) != 0) {
+ fprintf(stderr, "Failed to enable long DN \n");
+ rc_validate(WEXITSTATUS(rc), 0);
+ return;
+ }
+
+ // Preparing data
+ char appStreamDN[1000] = {0};
+ memset(appStreamDN, 'E', sizeof(appStreamDN) - 1);
+
+ // Perform testing
+ sprintf(command, "saflogger -a safLgStrCfg=%s longDN_test_no_f 2>
/dev/null", appStreamDN);
+ rc = system(command);
+ if (WEXITSTATUS(rc) != 0) {
+ rc_validate(0, 0);
+ goto done;
+ }
+
+ rc_validate(WEXITSTATUS(rc), 0);
+done:
+ // Restore data
+ sprintf(command, "immcfg -a longDnsAllowed=%d %s", v_longDnsAllowed,
s_opensafImm);
+ rc = system(command);
+ if (WEXITSTATUS(rc) != 0) {
+ fprintf(stderr, "Failed to perform cmd = %s\n", command);
+ }
+
+}
+
+/*
+ * Suite #13
+ */
+__attribute__ ((constructor)) static void longDN_constructor(void)
+{
+ test_suite_add(13, "Test Long DN support");
+ // Normal test cases
+ test_case_add(13, longDNAt_No_token, "Write a log record using the long
DN in @No");
+ test_case_add(13, longDNAt_Ng_token, "Write a log record using the long
DN in @Ng");
+ test_case_add(13, longDNAt_Sl_token, "Write a log record using the long
DN in @Sl");
+ test_case_add(13, longDN_AppStream, "Write a log record to long DN app
stream");
+ test_case_add(13, longDNIn_AppStreamDN, "Write a log record to long DN
runtime app stream using saflogger tool");
+ // Abnormal test cases
+ test_case_add(13, longDN_No_Over_MaxDn, "Write a log record with
notificationObj (@No) over max length");
+ test_case_add(13, longDN_Ng_Over_MaxDn, "Write a log record with
notifyingObj (@Ng) over max length");
+ test_case_add(13, longDN_Sl_Over_MaxDn, "Write a log record with
logSvcUsrName (@Sl) over max length");
+ test_case_add(13, longDN_AppStrDN_Over_MaxDn, "Write a log record to
app stream with DN over max using saflogger tool");
+ test_case_add(13, longDNIn_AppStreamDN_ButNoF, "Write a log record to
long DN runtime app using saflogger, but no f option");
+
+
+}
diff --git a/tests/logsv/tet_log_runtime_cfgobj.c
b/tests/logsv/tet_log_runtime_cfgobj.c
--- a/tests/logsv/tet_log_runtime_cfgobj.c
+++ b/tests/logsv/tet_log_runtime_cfgobj.c
@@ -46,10 +46,7 @@ void log_rt_cf_obj_compare(void)
/* Count attributes in configuration object
*/
- sprintf((char *) object_name.value, "%s",
- LOGTST_IMM_LOG_CONFIGURATION);
- object_name.length = strlen((char *) object_name.value);
-
+ saAisNameLend(LOGTST_IMM_LOG_CONFIGURATION, &object_name);
ais_rc = immutil_saImmOmAccessorGet_2(accessorHandle, &object_name,
NULL,
&attributes);
if (ais_rc != SA_AIS_OK) {
@@ -64,9 +61,7 @@ void log_rt_cf_obj_compare(void)
/* Count attributes in runtime object
*/
- sprintf((char *) object_name.value, "%s",
- LOGTST_IMM_LOG_RUNTIME);
- object_name.length = strlen((char *) object_name.value);
+ saAisNameLend(LOGTST_IMM_LOG_RUNTIME, &object_name);
ais_rc = immutil_saImmOmAccessorGet_2(accessorHandle, &object_name,
NULL,
&attributes);
diff --git a/tests/logsv/tet_saLogStreamOpen_2.c
b/tests/logsv/tet_saLogStreamOpen_2.c
--- a/tests/logsv/tet_saLogStreamOpen_2.c
+++ b/tests/logsv/tet_saLogStreamOpen_2.c
@@ -205,8 +205,8 @@ void saLogStreamOpen_2_15(void)
void saLogStreamOpen_2_16(void)
{
SaNameT streamName;
- streamName.length = sizeof("safLgStr=")+sizeof(__FUNCTION__)-1;
- sprintf((char*)streamName.value, "safLgStr=%s", __FUNCTION__);
+ SaConstStringT data = "safLgStr=saLogStreamOpen_2_16";
+ saAisNameLend(data, &streamName);
init_file_create_attributes();
safassert(saLogInitialize(&logHandle, &logCallbacks, &logVersion),
SA_AIS_OK);
@@ -222,8 +222,8 @@ void saLogStreamOpen_2_16(void)
void saLogStreamOpen_2_17(void)
{
SaNameT streamName;
- streamName.length = sizeof("safLgStr=")+sizeof(__FUNCTION__)-1;
- sprintf((char*)streamName.value, "safLgStr=%s", __FUNCTION__);
+ SaConstStringT data = "safLgStr=saLogStreamOpen_2_17";
+ saAisNameLend(data, &streamName);
init_file_create_attributes();
safassert(saLogInitialize(&logHandle, &logCallbacks, &logVersion),
SA_AIS_OK);
@@ -338,10 +338,9 @@ void saLogStreamOpen_2_23(void)
void saLogStreamOpen_2_46(void)
{
SaAisErrorT rc = SA_AIS_OK;
- SaNameT logStreamName = {.length = 0 };
+ SaNameT logStreamName;
- strcpy((char *)logStreamName.value, SA_LOG_STREAM_APPLICATION1);
- logStreamName.length = strlen((char *)logStreamName.value);
+ saAisNameLend(SA_LOG_STREAM_APPLICATION1, &logStreamName);
SaLogFileCreateAttributesT_2 appLogFileCreateAttributes;
@@ -387,10 +386,8 @@ done:
void saLogStreamOpen_2_47(void)
{
SaAisErrorT rc = SA_AIS_OK;
- SaNameT logStreamName = {.length = 0 };
-
- strcpy((char *)logStreamName.value, SA_LOG_STREAM_APPLICATION1);
- logStreamName.length = strlen((char *)logStreamName.value);
+ SaNameT logStreamName;
+ saAisNameLend(SA_LOG_STREAM_APPLICATION1, &logStreamName);
SaLogFileCreateAttributesT_2 appLogFileCreateAttributes;
@@ -440,10 +437,8 @@ done:
void verFixLogRec_Max_Err(void)
{
SaAisErrorT rc = SA_AIS_OK;
- SaNameT logStreamName = {.length = 0 };
-
- strcpy((char *)logStreamName.value, SA_LOG_STREAM_APPLICATION1);
- logStreamName.length = strlen((char *)logStreamName.value);
+ SaNameT logStreamName;
+ saAisNameLend(SA_LOG_STREAM_APPLICATION1, &logStreamName);
SaLogFileCreateAttributesT_2 appLogFileCreateAttributes;
@@ -489,10 +484,8 @@ done:
void verFixLogRec_Min_Err(void)
{
SaAisErrorT rc = SA_AIS_OK;
- SaNameT logStreamName = {.length = 0 };
-
- strcpy((char *)logStreamName.value, SA_LOG_STREAM_APPLICATION1);
- logStreamName.length = strlen((char *)logStreamName.value);
+ SaNameT logStreamName;
+ saAisNameLend(SA_LOG_STREAM_APPLICATION1, &logStreamName);
SaLogFileCreateAttributesT_2 appLogFileCreateAttributes;
@@ -537,14 +530,12 @@ done:
void saLogStreamOpen_2_48(void)
{
SaAisErrorT rc = SA_AIS_OK;
- SaNameT logStreamName = {.length = 0 };
+ SaNameT logStreamName;
char fileName[220];
memset(fileName, 'A', 218);
fileName[219] = '\0';
-
- strcpy((char *)logStreamName.value, SA_LOG_STREAM_APPLICATION1);
- logStreamName.length = strlen((char *)logStreamName.value);
+ saAisNameLend(SA_LOG_STREAM_APPLICATION1, &logStreamName);
SaLogFileCreateAttributesT_2 appLogFileCreateAttributes;
@@ -591,10 +582,8 @@ done:
void saLogStreamOpen_2_49(void)
{
SaAisErrorT rc = SA_AIS_OK;
- SaNameT logStreamName = {.length = 0 };
-
- strcpy((char *)logStreamName.value, SA_LOG_STREAM_APPLICATION1);
- logStreamName.length = strlen((char *)logStreamName.value);
+ SaNameT logStreamName;
+ saAisNameLend(SA_LOG_STREAM_APPLICATION1, &logStreamName);
SaLogFileCreateAttributesT_2 appLogFileCreateAttributes;
@@ -756,7 +745,8 @@ extern void saLogStreamClose_01(void);
test_case_add(2, saLogStreamOpen_2_20, "Open app stream with invalid
logFileFmt");
test_case_add(2, saLogStreamOpen_2_21, "Open app stream with unsupported
logFullAction");
test_case_add(2, saLogStreamOpen_2_22, "Open non exist app stream with
NULL create attrs");
- test_case_add(2, saLogStreamOpen_2_23, "Open with stream name length ==
256");
+ //This test case is no longer valid when Long DN is supported
+ //test_case_add(2, saLogStreamOpen_2_23, "Open with stream name length ==
256");
test_case_add(2, saLogStreamOpenAsync_2_01, "saLogStreamOpenAsync_2(), Not
supported");
test_case_add(2, saLogStreamOpenCallbackT_01, "saLogStreamOpenCallbackT()
OK");
test_case_add(2, saLogWriteLog_01, "saLogWriteLog(), Not supported");
@@ -773,9 +763,10 @@ extern void saLogStreamClose_01(void);
test_case_add(2, saLogWriteLogAsync_12, "saLogWriteAsyncLog() without
logTimeStamp set");
test_case_add(2, saLogWriteLogAsync_13, "saLogWriteAsyncLog() 1800 bytes
logrecord (ticket #203)");
test_case_add(2, saLogWriteLogAsync_14, "saLogWriteAsyncLog() invalid
severity");
- test_case_add(2, saLogWriteLogAsync_15, "saLogWriteAsyncLog() NTF
notificationObject length == 256");
- test_case_add(2, saLogWriteLogAsync_16, "saLogWriteAsyncLog() NTF
notifyingObject length == 256");
- test_case_add(2, saLogWriteLogAsync_17, "saLogWriteLogAsync() Generic
logSvcUsrName length == 256");
+ //These test cases are no longer valid when Long DN is supported
+ //test_case_add(2, saLogWriteLogAsync_15, "saLogWriteAsyncLog() NTF
notificationObject length == 256");
+ //test_case_add(2, saLogWriteLogAsync_16, "saLogWriteAsyncLog() NTF
notifyingObject length == 256");
+ //test_case_add(2, saLogWriteLogAsync_17, "saLogWriteLogAsync() Generic
logSvcUsrName length == 256");
test_case_add(2, saLogWriteLogAsync_18, "saLogWriteLogAsync() logBufSize >
strlen(logBuf) + 1");
test_case_add(2, saLogWriteLogAsync_19, "saLogWriteLogAsync() logBufSize >
SA_LOG_MAX_RECORD_SIZE");
test_case_add(2, saLogWriteLogCallbackT_01, "saLogWriteLogCallbackT()
SA_DISPATCH_ONE");
diff --git a/tests/logsv/tet_saLogWriteLogAsync.c
b/tests/logsv/tet_saLogWriteLogAsync.c
--- a/tests/logsv/tet_saLogWriteLogAsync.c
+++ b/tests/logsv/tet_saLogWriteLogAsync.c
@@ -321,11 +321,9 @@ void saLogWriteLogAsync_13(void)
.logFileFmt = DEFAULT_FORMAT_EXPRESSION
};
SaInvocationT invocation = 0;
- SaNameT appStreamName = {
- .value = "safLgStr=ticket203",
- .length = 0
- };
- appStreamName.length = strlen((char *) appStreamName.value);
+ SaNameT appStreamName;
+ SaConstStringT data = "safLgStr=ticket203";
+ saAisNameLend(data, &appStreamName);
memset(genLogRecord.logBuffer->logBuf, 'X', 1000);
genLogRecord.logBuffer->logBufSize = 1000;
------------------------------------------------------------------------------
Attend Shape: An AT&T Tech Expo July 15-16. Meet us at AT&T Park in San
Francisco, CA to explore cutting-edge tech and listen to tech luminaries
present their vision of the future. This family event has something for
everyone, including kids. Get more information and register today.
http://sdm.link/attshape
_______________________________________________
Opensaf-devel mailing list
Opensaf-devel@lists.sourceforge.net
https://lists.sourceforge.net/lists/listinfo/opensaf-devel
