(Logical change 1.16)

git-svn-id: http://svn.fedorahosted.org/svn/corosync/trunk@36 fd59a12c-fef9-0310-b244-a6a79926bd2f

test/ckptbench.c

@@ -0,0 +1,218 @@
+#define _BSD_SOURCE
+/*
+ * Copyright (c) 2002-2004 MontaVista Software, Inc.
+ *
+ * All rights reserved.
+ *
+ * Author: Steven Dake (sdake@mvista.com)
+ *
+ * This software licensed under BSD license, the text of which follows:
+ * 
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * - Redistributions of source code must retain the above copyright notice,
+ *   this list of conditions and the following disclaimer.
+ * - Redistributions in binary form must reproduce the above copyright notice,
+ *   this list of conditions and the following disclaimer in the documentation
+ *   and/or other materials provided with the distribution.
+ * - Neither the name of the MontaVista Software, Inc. nor the names of its
+ *   contributors may be used to endorse or promote products derived from this
+ *   software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+ * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+ * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
+ * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
+ * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
+ * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
+ * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
+ * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
+ * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
+ * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
+ * THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <errno.h>
+#include <unistd.h>
+#include <time.h>
+#include <sys/time.h>
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <sys/select.h>
+#include <sys/un.h>
+
+#include "ais_types.h"
+#include "ais_ckpt.h"
+
+int ckptinv;
+void printSaNameT (SaNameT *name)
+{
+	int i;
+
+	for (i = 0; i < name->length; i++) {
+		printf ("%c", name->value[i]);
+	}
+}
+
+SaVersionT version = { 'A', 1, 1 };
+
+SaNameT checkpointName = { 5, "abra\0" };
+
+SaCkptCheckpointCreationAttributesT checkpointCreationAttributes = {
+	SA_CKPT_WR_ALL_REPLICAS,
+	100000,
+	0,
+	5,
+	20000,
+	10
+};
+
+SaCkptSectionIdT sectionId1 = {
+	"section ID #1",
+	14
+};
+
+SaCkptSectionIdT sectionId2 = {
+	"section ID #2",
+	14
+};
+SaCkptSectionCreationAttributesT sectionCreationAttributes1 = {
+	&sectionId1,
+	0xFFFFFFFF
+};
+
+SaCkptSectionCreationAttributesT sectionCreationAttributes2 = {
+	&sectionId2,
+	0xFFFFFFFF
+};
+
+char readBuffer1[1025];
+
+char readBuffer2[1025];
+
+SaCkptIOVectorElementT ReadVectorElements[] = {
+	{
+		{
+			"section ID #1",
+			14
+		},
+		readBuffer1,
+		sizeof (readBuffer1),
+		0, 
+		0
+	},
+	{
+		{
+			"section ID #2",
+			14
+		},
+		readBuffer2,
+		sizeof (readBuffer2),
+		0, 
+		0
+	}
+};
+
+#define DATASIZE 1000
+#define LOOPS 5000
+
+char data[500000];
+SaCkptIOVectorElementT WriteVectorElements[] = {
+	{
+		{
+			"section ID #1",
+			14
+		},
+		data, /*"written data #1, this should extend past end of old section data", */
+		DATASIZE, /*sizeof ("data #1, this should extend past end of old section data") + 1, */
+		0, //5, 
+		0
+	}
+#ifdef COMPILE_OUT
+	{
+		{
+			"section ID #2",
+			14
+		},
+		data, /*"written data #2, this should extend past end of old section data" */
+		DATASIZE, /*sizeof ("written data #2, this should extend past end of old section data") + 1, */
+		0, //3, 
+		0
+	}
+#endif
+};
+
+void ckpt_benchmark (SaCkptCheckpointHandleT checkpointHandle,
+	int write_count, int write_size)
+{
+	struct timeval tv1, tv2, tv_elapsed;
+	SaUint32T erroroneousVectorIndex = 0;
+	SaErrorT error;
+
+	WriteVectorElements[0].dataSize = write_size;
+
+	gettimeofday (&tv1, NULL);
+	for (ckptinv = 0; ckptinv < write_count; ckptinv++) {
+		/*
+		 * Test checkpoint write
+		 */
+		error = saCkptCheckpointWrite (&checkpointHandle,
+			WriteVectorElements,
+			1,
+			&erroroneousVectorIndex);
+		if (error != SA_OK) {
+			printf ("saCkptCheckpointWrite result %d (should be 1)\n", error);
+			exit (1);
+		}
+	}
+	gettimeofday (&tv2, NULL);
+	timersub (&tv2, &tv1, &tv_elapsed);
+
+	printf ("%5d Writes ", write_count);
+	printf ("%5d bytes per write ", write_size);
+	printf ("%7.3f Seconds runtime ", 
+		(tv_elapsed.tv_sec + (tv_elapsed.tv_usec / 1000000.0)));
+	printf ("%9.3f TP/s ",
+		((float)write_count) /  (tv_elapsed.tv_sec + (tv_elapsed.tv_usec / 1000000.0)));
+	printf ("%7.3f MB/s.\n", 
+		((float)write_count) * ((float)write_size) /  ((tv_elapsed.tv_sec + (tv_elapsed.tv_usec / 1000000.0)) * 1000000.0));
+}
+
+int main (void) {
+	SaCkptCheckpointHandleT checkpointHandle;
+	SaErrorT error;
+	int size;
+	int count;
+	int i;
+	
+	error = saCkptCheckpointOpen (&checkpointName,
+		&checkpointCreationAttributes,
+		SA_CKPT_CHECKPOINT_READ|SA_CKPT_CHECKPOINT_WRITE,
+		0,
+		&checkpointHandle);
+	error = saCkptSectionCreate (&checkpointHandle,
+		&sectionCreationAttributes1,
+		"Initial Data #0",
+		strlen ("Initial Data #0") + 1);
+	error = saCkptSectionCreate (&checkpointHandle,
+		&sectionCreationAttributes2,
+		"Initial Data #0",
+		strlen ("Initial Data #0") + 1);
+
+	count = 50000;
+	size = 1000;
+
+	for (i = 0; i < 35; i++) { /* number of repetitions */
+		ckpt_benchmark (checkpointHandle, count, size);
+		/*
+		 * Adjust count to 95% of previous count
+		 * Adjust bytes to write per checkpoint up by 1500
+		 */
+		count = (((float)count) * 0.95);
+		size += 1500;
+	}
+	return (0);
+}

test/ckptbenchth.c

@@ -0,0 +1,270 @@
+#define _BSD_SOURCE
+/*
+ * Copyright (c) 2002-2004 MontaVista Software, Inc.
+ *
+ * All rights reserved.
+ *
+ * Author: Steven Dake (sdake@mvista.com)
+ *
+ * This software licensed under BSD license, the text of which follows:
+ * 
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * - Redistributions of source code must retain the above copyright notice,
+ *   this list of conditions and the following disclaimer.
+ * - Redistributions in binary form must reproduce the above copyright notice,
+ *   this list of conditions and the following disclaimer in the documentation
+ *   and/or other materials provided with the distribution.
+ * - Neither the name of the MontaVista Software, Inc. nor the names of its
+ *   contributors may be used to endorse or promote products derived from this
+ *   software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+ * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+ * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
+ * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
+ * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
+ * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
+ * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
+ * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
+ * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
+ * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
+ * THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <errno.h>
+#include <unistd.h>
+#include <time.h>
+#include <sys/time.h>
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <sys/select.h>
+#include <sys/un.h>
+#include <pthread.h>
+
+#include "ais_types.h"
+#include "ais_ckpt.h"
+
+void printSaNameT (SaNameT *name)
+{
+	int i;
+
+	for (i = 0; i < name->length; i++) {
+		printf ("%c", name->value[i]);
+	}
+}
+
+SaVersionT version = { 'A', 1, 1 };
+
+SaCkptCheckpointCreationAttributesT checkpointCreationAttributes = {
+	SA_CKPT_WR_ALL_REPLICAS,
+	100000,
+	0,
+	5,
+	20000,
+	10
+};
+
+SaCkptSectionIdT sectionId1 = {
+	"section ID #1",
+	14
+};
+
+SaCkptSectionIdT sectionId2 = {
+	"section ID #2",
+	14
+};
+SaCkptSectionCreationAttributesT sectionCreationAttributes1 = {
+	&sectionId1,
+	0xFFFFFFFF
+};
+
+SaCkptSectionCreationAttributesT sectionCreationAttributes2 = {
+	&sectionId2,
+	0xFFFFFFFF
+};
+
+char readBuffer1[1025];
+
+char readBuffer2[1025];
+
+SaCkptIOVectorElementT ReadVectorElements[] = {
+	{
+		{
+			"section ID #1",
+			14
+		},
+		readBuffer1,
+		sizeof (readBuffer1),
+		0, 
+		0
+	},
+	{
+		{
+			"section ID #2",
+			14
+		},
+		readBuffer2,
+		sizeof (readBuffer2),
+		0, 
+		0
+	}
+};
+
+#define DATASIZE 1000
+#define LOOPS 5000
+
+char data[500000];
+SaCkptIOVectorElementT WriteVectorElements[] = {
+	{
+		{
+			"section ID #1",
+			14
+		},
+		data, /*"written data #1, this should extend past end of old section data", */
+		DATASIZE, /*sizeof ("data #1, this should extend past end of old section data") + 1, */
+		0, //5, 
+		0
+	}
+#ifdef COMPILE_OUT
+	{
+		{
+			"section ID #2",
+			14
+		},
+		data, /*"written data #2, this should extend past end of old section data" */
+		DATASIZE, /*sizeof ("written data #2, this should extend past end of old section data") + 1, */
+		0, //3, 
+		0
+	}
+#endif
+};
+
+int runs = 0;
+
+struct threaddata {
+	SaCkptCheckpointHandleT checkpointHandle;
+	int write_count;
+	int write_size;
+};
+
+void *benchmark_thread (void *arg) 
+{
+	
+	SaCkptCheckpointHandleT checkpointHandle;
+	int write_count;
+	int write_size;
+	SaErrorT error;
+	SaUint32T erroroneousVectorIndex = 0;
+	struct threaddata *td = (struct threaddata *)arg;
+	int ckptinv;
+
+	checkpointHandle = td->checkpointHandle;
+	write_count = td->write_count;
+	write_size = td->write_size;
+
+	WriteVectorElements[0].dataSize = write_size;
+
+	for (ckptinv = 0; ckptinv < write_count; ckptinv++) {
+		/*
+		 * Test checkpoint write
+		 */
+		error = saCkptCheckpointWrite (&checkpointHandle,
+			WriteVectorElements,
+			1,
+			&erroroneousVectorIndex);
+		if (error != SA_OK) {
+			printf ("saCkptCheckpointWrite result %d (should be 1)\n", error);
+			exit (1);
+		}
+	}
+	pthread_exit (0);
+}
+
+
+void threaded_bench (SaCkptCheckpointHandleT *checkpointHandles, int threads, int write_count,
+	int write_size)
+{
+	struct timeval tv1, tv2, tv_elapsed;
+	struct threaddata td[100];
+	int i;
+	pthread_t threadt[100];
+	int res;
+
+	runs = threads;
+	gettimeofday (&tv1, NULL);
+
+	for (i = 0; i < threads; i++) {
+		td[i].checkpointHandle = checkpointHandles[i];
+		td[i].write_count = write_count;
+		td[i].write_size = write_size;
+
+		res = pthread_create (&threadt[i], NULL, benchmark_thread, (void *)&td[i]);
+	}
+
+	for (i = 0; i < threads; i++) {
+		pthread_join (threadt[i], NULL);
+	}
+
+	gettimeofday (&tv2, NULL);
+	timersub (&tv2, &tv1, &tv_elapsed);
+
+	printf ("%5d Writes ", write_count * threads);
+	printf ("%5d bytes per write ", write_size);
+	printf ("%7.3f Seconds runtime ", 
+		(tv_elapsed.tv_sec + (tv_elapsed.tv_usec / 1000000.0)));
+	printf ("%9.3f TP/s ",
+		((float)write_count * (float)threads) /  (tv_elapsed.tv_sec + (tv_elapsed.tv_usec / 1000000.0)));
+	printf ("%7.3f MB/s.\n", 
+		((float)write_count * (float)threads) * ((float)write_size) /  ((tv_elapsed.tv_sec + (tv_elapsed.tv_usec / 1000000.0)) * 1000000.0));
+}
+
+SaNameT checkpointName = { 12, "abra\0" };
+
+int main (void) {
+	SaCkptCheckpointHandleT checkpointHandles[50];
+	SaErrorT error;
+	int size;
+	int count;
+	int i, j;
+	
+	/*
+	 * Create 50 checkpoints
+	 */
+	for (i  = 0; i < 50; i++) {
+		sprintf (checkpointName.value, "checkpoint%d \n", i);
+		error = saCkptCheckpointOpen (&checkpointName,
+			&checkpointCreationAttributes,
+			SA_CKPT_CHECKPOINT_READ|SA_CKPT_CHECKPOINT_WRITE,
+			0,
+			&checkpointHandles[i]);
+		error = saCkptSectionCreate (&checkpointHandles[i],
+			&sectionCreationAttributes1,
+			"Initial Data #0",
+			strlen ("Initial Data #0") + 1);
+		error = saCkptSectionCreate (&checkpointHandles[i],
+			&sectionCreationAttributes2,
+			"Initial Data #0",
+			strlen ("Initial Data #0") + 1);
+	}
+
+	for (i = 1; i < 50; i++) {	/* i threads */
+		count = 3000; /* initial count */
+		size = 1000; /* initial size */
+		printf ("THREADS %d\n", i);
+		for (j = 0; j < 5; j++) { /* number of runs with i threads */
+			threaded_bench (checkpointHandles, i, count, size);
+			/*
+			 * Adjust count to 95% of previous count
+			 * adjust size upwards by 1500
+			 * This keeps the run times similiar
+			 */
+			count = (((float)count) * 0.95);
+			size += 1500;
+		}
+	}
+	return (0);
+}