Added power fail save test; added more DLT INFO logs; rename wrong spelled define PCL_SHUTDOWN_CANEL to PCL_SHUTDOWN_CANCEL

3 files changed, 505 insertions, 3 deletions

diff --git a/test/Makefile.am b/test/Makefile.am
index 627b149..08e47e8 100644
--- a/test/Makefile.am
+++ b/test/Makefile.am
@@ -12,7 +12,8 @@ noinst_PROGRAMS = persistence_client_library_test \
                   persistence_client_library_dbus_test \
                   persistence_client_library_benchmark \
                   persistence_admin_service_mockup \
-                  persistence_lifeCycle_mockup
+                  persistence_lifeCycle_mockup \
+                  persistence_pfs_test
 
 persistence_client_library_dbus_test_SOURCES = persistence_client_library_dbus_test.c
 persistence_client_library_dbus_test_LDADD = $(DEPS_LIBS) \
@@ -30,8 +31,12 @@ persistence_admin_service_mockup_SOURCES = persistence_admin_service_mockup.c
 persistence_admin_service_mockup_LDADD = $(DEPS_LIBS) 
 
 persistence_lifeCycle_mockup_SOURCES = persistence_lifeCycle_mockup.c
-persistence_lifeCycle_mockup_LDADD = $(DEPS_LIBS)     
-  
+persistence_lifeCycle_mockup_LDADD = $(DEPS_LIBS)
+
+persistence_pfs_test_SOURCES = persistence_pfs_test.c
+persistence_pfs_test_LDADD = $(DEPS_LIBS) \
+   $(top_srcdir)/src/libpersistence_client_library.la
+
 TESTS=persistence_client_library_test
 
 
diff --git a/test/data/PAS_data.tar.gz b/test/data/PAS_data.tar.gz
index f88bce1..969f276 100644
--- a/test/data/PAS_data.tar.gz
+++ b/test/data/PAS_data.tar.gz
diff --git a/test/persistence_pfs_test.c b/test/persistence_pfs_test.c
new file mode 100644
index 0000000..2f14370
--- /dev/null
+++ b/test/persistence_pfs_test.c
@@ -0,0 +1,497 @@
+/******************************************************************************
+ * Project         Persistency
+ * (c) copyright   2012
+ * Company         XS Embedded GmbH
+ *****************************************************************************/
+/******************************************************************************
+ * This Source Code Form is subject to the terms of the
+ * Mozilla Public License, v. 2.0. If a  copy of the MPL was not distributed
+ * with this file, You can obtain one at http://mozilla.org/MPL/2.0/.
+******************************************************************************/
+ /**
+ * @file           persistence_pfs_test.c
+ * @ingroup        Persistence client library test
+ * @author         Ingo Huerner
+ * @brief          Persistence Power Fail Safe Test
+ * @see
+ */
+
+#include <stdio.h>
+#include <string.h>
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <fcntl.h>
+#include <unistd.h>
+#include <errno.h>
+#include <stdlib.h>
+
+#include <dlt/dlt.h>
+#include <dlt/dlt_common.h>
+
+#include <sys/mount.h>
+
+#include <persistence_client_library.h>
+#include <persistence_client_library_key.h>
+#include <persistence_client_library_file.h>
+
+
+#define LC_CNT_START 28
+#define WR_CNT_START 35
+
+
+DLT_DECLARE_CONTEXT(gPFSDLTContext);
+
+static int gLifecycleCounter = 0;
+
+static const char* gTestInProgressFlag = "/Data/mnt-c/persistence_pfst_test_in_progress";
+
+
+
+static const char* gDefaultKeyValueResName[] =
+{
+	"keyValue_Resource_01",
+	"keyValue_Resource_02",
+	"keyValue_Resource_03",
+	"keyValue_Resource_04",
+	"keyValue_Resource_05",
+	"keyValue_Resource_06",
+	"keyValue_Resource_07",
+	"keyValue_Resource_08",
+	"keyValue_Resource_09"
+};
+
+static const char* gDefaultKeyValueTestData[] =
+{
+	"keyValue pair cache One   : 000000 000000",
+	"keyValue pair cache Two   : 000000 000000",
+	"keyValue pair cache Three : 000000 000000",
+	"keyValue pair cache Four  : 000000 000000",
+	"keyValue pair wt One      : 000000 000000",
+	"keyValue pair wt Two      : 000000 000000",
+	"keyValue pair wt Three    : 000000 000000",
+	"keyValue pair wt Four     : 000000 000000",
+	"keyValue pair wt Six      : 000000 000000"
+};
+
+
+
+static const char* gDefaultFileAPITestData[] =
+{
+	"file API cache One   : 000000 000000",
+	"file API cache Two   : 000000 000000",
+	"file API cache Three : 000000 000000",
+	"file API cache Four  : 000000 000000",
+	"file API wt One      : 000000 000000",
+	"file API wt Two      : 000000 000000",
+	"file API wt Three    : 000000 000000",
+	"file API wt Four     : 000000 000000"
+};
+
+static const char* gDefaultFileResNames[] =
+{
+	"file API_Resource_01",
+	"file API_Resource_02",
+	"file API_Resource_03",
+	"file API_Resource_04",
+	"file API_Resource_05",
+	"file API_Resource_06",
+	"file API_Resource_07",
+	"file API_Resource_08"
+};
+
+
+
+// forward declaration
+
+/// verify written data form previous lifefycle
+void verify_data_key_value();
+void verify_data_file();
+
+
+/// write data until power off occurs
+void write_data_key_value(int numLoops);
+void write_data_file(int numLoops);
+int mount_persistence(const char* deviceName);
+void unmount_persistence();
+
+
+/// setup initial test data
+int setup_test_data()
+{
+	int i = 0;
+
+	// key/value data
+	for(i=0; i<sizeof(gDefaultKeyValueTestData) / sizeof(char*); i++)
+	{
+		printf(" key/val - data[%d] => %s\n", i, gDefaultKeyValueTestData[i]);
+	}
+
+	// file data
+	for(i=0; i<sizeof(gDefaultFileAPITestData) / sizeof(char*); i++)
+	{
+		printf(" file - data[%d] => %s\n", i, gDefaultFileAPITestData[i]);
+	}
+
+	return 1;
+}
+
+
+
+int update_test_progress_flag(const char* filename, int *counter)
+{
+   int fd = -1, rval = 0;
+
+   if(access(filename, F_OK) == 0)
+   {
+   	fd = open(filename, O_RDWR);		// file exists, update content
+   	if(fd != -1)
+   	{
+   		int size = 0;
+   		char buffer[12] = {0};
+   		if((size = read(fd, buffer, 12)) != -1)
+			{
+   			rval = atoi(buffer);
+   			*counter = rval;
+				snprintf(buffer, 3, "%d", *counter + 1);
+
+				lseek(fd, 0, SEEK_SET);
+				if((size = write(fd, buffer, strlen(buffer))) == -1)
+				{
+					printf("   Failed to write to file: %s » %s\n", filename, strerror(errno));
+				}
+			}
+   		else
+   		{
+			  printf("   Failed to write to file: %s » %s\n", filename, strerror(errno));
+			  rval = -1;
+			}
+   	}
+   	else
+   	{
+   		rval = -1;
+   	}
+   }
+   else
+   {
+   	fd = open(filename, O_CREAT|O_RDWR|O_TRUNC, S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP | S_IROTH);
+   	if(fd != -1)
+   	{
+   		int size = 0;
+   		char buffer[3] = {0};
+   		snprintf(buffer, 3, "%d", 1);
+			if((size = write(fd, buffer, strlen(buffer))) == -1)
+			{
+			  printf("   Failed to write to file: %s » %s\n", filename, strerror(errno));
+			  rval = -1;
+			}
+			*counter = 1;
+   	}
+   	else
+   	{
+   		rval = -1;
+   	}
+   }
+   close(fd);
+   return rval;
+}
+
+
+
+void update_test_data(char* buffer, int lc_counter, int write_counter)
+{
+	int i = 0;
+	char lc_cnt_buff[7] = {0};
+	char wr_cnt_buff[7] = {0};
+
+	snprintf(lc_cnt_buff, 7, "%.6d", lc_counter);
+	snprintf(wr_cnt_buff, 7, "%.6d", write_counter);
+
+	for(i=0; i<6; i++)
+	{
+		buffer[LC_CNT_START+i] = lc_cnt_buff[i];
+		buffer[WR_CNT_START+i] = wr_cnt_buff[i];
+	}
+}
+
+
+
+int get_lifecycle_count(char* buf)
+{
+	return atoi(&buf[LC_CNT_START]);
+}
+
+int get_write_count(char* buf)
+{
+	return atoi(&buf[WR_CNT_START]);
+}
+
+
+int main(int argc, char *argv[])
+{
+	int rVal = EXIT_SUCCESS;
+	unsigned int shutdownReg = PCL_SHUTDOWN_TYPE_FAST | PCL_SHUTDOWN_TYPE_NORMAL;
+
+   /// debug log and trace (DLT) setup
+   DLT_REGISTER_APP("PFS","power fail safe test");
+
+   DLT_REGISTER_CONTEXT(gPFSDLTContext,"PFS","Context for PCL PFS test logging");
+
+	if(-1 != mount_persistence("/dev/sdb") )
+	{
+		int numLoops = 10000000, opt = 0;
+
+		while ((opt = getopt(argc, argv, "l:")) != -1)
+		{
+			switch (opt)
+			{
+				case 'l':
+					numLoops = atoi(optarg);
+					break;
+			  }
+		 }
+
+		if(update_test_progress_flag(gTestInProgressFlag, &gLifecycleCounter) == 0)
+		{
+			printf("PFS test - first lifecycle, setup test data\n");
+			DLT_LOG(gPFSDLTContext, DLT_LOG_INFO, DLT_STRING("PFS test - first lifecycle, setup test data"));
+			setup_test_data();
+		}
+
+		printf("PFS test - Lifecycle counter: %d - number of test loops: %d\n", gLifecycleCounter, numLoops);
+		DLT_LOG(gPFSDLTContext, DLT_LOG_INFO, DLT_STRING("PFS test - Lifecycle counter:"), DLT_INT(gLifecycleCounter),
+				                                DLT_STRING("- number of write loops:"), DLT_INT(numLoops));
+
+		pclInitLibrary("pfs_test", shutdownReg);		// register to persistence client library
+
+		// verify the data form previous lifecycle
+		verify_data_key_value();
+		//verify_data_file();
+
+		// write data
+		write_data_key_value(numLoops);
+		//write_data_file(numLoops);
+
+
+		pclDeinitLibrary();									// unregister from persistence client library
+
+		unmount_persistence();
+	}
+	else
+	{
+		DLT_LOG(gPFSDLTContext, DLT_LOG_ERROR, DLT_STRING("PFS test - failed to mount pers partition:"), DLT_INT(gLifecycleCounter) );
+		printf("Mount Failed\n");
+		rVal = EXIT_FAILURE;
+	}
+
+   // unregister debug log and trace
+   DLT_UNREGISTER_APP();
+
+   dlt_free();
+
+	return rVal;
+}
+
+
+
+void verify_data_key_value()
+{
+	int i=0, ret = 0;
+	char buffer[64] = {0};
+
+	// read data from previous lifecycle - key/value
+	for(i=0; i<sizeof(gDefaultKeyValueTestData) / sizeof(char*); i++)
+	{
+		memset(buffer, 0, 64);
+		ret = pclKeyReadData(0xFF, gDefaultKeyValueResName[i], 1, 1, (unsigned char*)buffer, 64);
+		if(ret < 0)
+		{
+			DLT_LOG(gPFSDLTContext, DLT_LOG_WARN, DLT_STRING("verify - key/value - => failed to read data"), DLT_INT(ret), DLT_STRING(buffer));
+			printf("verify - key/value - pclKeyReadData FAILED: %s => \"%s\"\n", gDefaultKeyValueResName[i], buffer);
+		}
+		else
+		{
+			int lc_count = get_lifecycle_count(buffer);
+
+			// first verify buffer
+			if(0 == strncmp(gDefaultKeyValueTestData[i], buffer, LC_CNT_START) )
+			{
+				if(lc_count != (gLifecycleCounter-1) )
+				{
+					printf("   Failure - LC count - current: %d - previous: %d - \"%s\"\n", gLifecycleCounter, lc_count, buffer);
+					DLT_LOG(gPFSDLTContext, DLT_LOG_ERROR, DLT_STRING("Failure - LC count - current:"), DLT_INT(gLifecycleCounter),
+							                                 DLT_STRING("- previous:"), DLT_INT(lc_count),
+							                                 DLT_STRING("- buf:"), DLT_STRING(buffer));
+				}
+			}
+			else
+			{
+				printf("   Failure - base string does not match - actual: \"%s\" - desired: \"%s\"\n", buffer, gDefaultKeyValueTestData[i]);
+				DLT_LOG(gPFSDLTContext, DLT_LOG_ERROR, DLT_STRING("Failure - base string does not match - actual: "), DLT_STRING(buffer),
+						                                 DLT_STRING("- desired:"), DLT_STRING(gDefaultKeyValueTestData[i]));
+			}
+
+		}
+	}
+	printf("Persistence pfs test - verification ended!!!!\n");
+}
+
+
+void write_data_key_value(int numLoops)
+{
+	int i=0, k=0, ret = 0;
+
+	for(k=0; k<numLoops; k++)
+	{
+		// write key/value data
+
+		for(i=0; i<sizeof(gDefaultKeyValueTestData) / sizeof(char*); i++)
+		{
+			char buffer[64] = {0};
+
+			strncpy(buffer, gDefaultKeyValueTestData[i], 64);
+			update_test_data(buffer, gLifecycleCounter, k);
+
+			ret = pclKeyWriteData(0xFF, gDefaultKeyValueResName[i], 1, 1, (unsigned char*)buffer, strlen(buffer));
+			if(ret < 0)
+			{
+				printf("  failed to write data: %d\n", ret );
+				DLT_LOG(gPFSDLTContext, DLT_LOG_ERROR, DLT_STRING("write key/value - failed to write data"), DLT_INT(ret));
+			}
+
+			//printf("write data - key/value - \"%s\"\n", buffer);
+		}
+	}	//num writes per lifecycle
+}
+
+
+
+void verify_data_file()
+{
+	int i=0, ret = 0;
+	int handles[128] = {0};
+	char buffer[64] = {0};
+
+	// open files
+	for(i=0; i<sizeof(gDefaultFileAPITestData) / sizeof(char*); i++)
+	{
+		handles[i] = pclFileOpen(0xFF, gDefaultFileResNames[i], 1, 0);
+	}
+
+	// read data from previous lifecycle - file
+	for(i=0; i<sizeof(gDefaultFileAPITestData) / sizeof(char*); i++)
+	{
+		memset(buffer, 0, 64);
+		ret = pclFileReadData(handles[i], buffer, 64);
+		if(ret < 0)
+		{
+			DLT_LOG(gPFSDLTContext, DLT_LOG_ERROR, DLT_STRING("verify data - file - failed to read data"), DLT_INT(ret));
+		}
+		else
+		{
+			printf("verify file - file - \"%s\"\n", buffer);
+			DLT_LOG(gPFSDLTContext, DLT_LOG_INFO, DLT_STRING("verify file: "), DLT_STRING(buffer));
+		}
+	}
+
+	// close fd's
+	for(i=0; i<sizeof(gDefaultFileAPITestData) / sizeof(char*); i++)
+	{
+		ret = pclFileClose(handles[i]);
+		if(ret != 0)
+		{
+			DLT_LOG(gPFSDLTContext, DLT_LOG_ERROR, DLT_STRING("close file - failed to close"), DLT_INT(ret));
+		}
+	}
+}
+
+
+void write_data_file(int numLoops)
+{
+	int i=0, k=0, ret = 0;
+	int handles[128] = {0};
+
+	// open files
+	for(i=0; i<sizeof(gDefaultFileAPITestData) / sizeof(char*); i++)
+	{
+		handles[i] = pclFileOpen(0xFF, gDefaultFileResNames[i], 1, 1);
+	}
+
+	for(k=0; k<numLoops; k++)
+	{
+		// write file data
+
+		for(i=0; i<sizeof(gDefaultFileAPITestData) / sizeof(char*); i++)
+		{
+			char buffer[64] = {0};
+
+			strncpy(buffer, gDefaultFileAPITestData[i], 64);
+			update_test_data(buffer, gLifecycleCounter, k);
+
+			DLT_LOG(gPFSDLTContext, DLT_LOG_INFO, DLT_STRING("- write file:"), DLT_STRING(buffer));
+			printf("write data - file - \"%s\"\n", buffer);
+
+			ret = pclFileWriteData(handles[i], buffer, strlen(buffer));
+			if(ret < 0)
+			{
+				DLT_LOG(gPFSDLTContext, DLT_LOG_ERROR, DLT_STRING("write file - failed to write data"), DLT_INT(ret));
+			}
+			usleep((int)(rand()/100000));	// sleep a time random period
+			pclFileSeek(handles[i], 0, SEEK_SET);
+		}
+
+	}	// writes per lifecycle
+
+	// close fd's
+	for(i=0; i<sizeof(gDefaultFileAPITestData) / sizeof(char*); i++)
+	{
+		ret = pclFileClose(handles[i]);
+		if(ret != 0)
+		{
+			DLT_LOG(gPFSDLTContext, DLT_LOG_ERROR, DLT_STRING("close file - failed to close"), DLT_INT(ret));
+		}
+	}
+}
+
+
+
+void unmount_persistence()
+{
+	if(umount2("/Data/mnt-c", MNT_DETACH) == -1)
+	{
+		printf("unmount /Data/mnt-c - FAILED: %s\n", strerror(errno));
+	}
+
+	if(umount2("/Data/mnt-wt", MNT_DETACH) == -1)
+	{
+		printf("unmount /Data/mnt-wt - FAILED: %s\n", strerror(errno));
+	}
+
+}
+
+int mount_persistence(const char* deviceName)
+{
+	int rval = 0;
+
+	printf("Mount - /Data/mnt-c\n");
+	if(-1 != mount(deviceName, "/Data/mnt-c",  "ext4", 0, ""))
+	{
+		printf("Mount - /Data/mnt-wt\n");
+		if(-1 == mount(deviceName, "/Data/mnt-wt", "ext4", 0, ""))
+		{
+			printf("Mount - FAILED - mnt-wt: %s\n", strerror(errno));
+			rval = -1;
+		}
+		else
+		{
+			printf("Mount - SUCCESS\n");
+		}
+	}
+	else
+	{
+		printf("Mount - FAILED - mnt-c: %s\n", strerror(errno));
+		rval = -1;
+	}
+
+	return rval;
+}
+