From 55ac5ee8e9cbf1b0e5f7fee1c46fc67714e9c36f Mon Sep 17 00:00:00 2001 From: Steven Dake Date: Fri, 10 Jul 2009 12:54:56 +0000 Subject: [PATCH] add stress_cpgcontext. git-svn-id: http://svn.fedorahosted.org/svn/corosync/trunk@2359 fd59a12c-fef9-0310-b244-a6a79926bd2f --- test/Makefile.am | 4 +- test/stress_cpgcontext.c | 135 +++++++++++++++++++++++++++++++++++++++ 2 files changed, 138 insertions(+), 1 deletion(-) create mode 100644 test/stress_cpgcontext.c diff --git a/test/Makefile.am b/test/Makefile.am index 720f73f7..ae744a6b 100644 --- a/test/Makefile.am +++ b/test/Makefile.am @@ -36,7 +36,7 @@ INCLUDES = -I$(top_builddir)/include -I$(top_srcdir)/include noinst_PROGRAMS = testevs evsbench evsverify cpgverify testcpg testcpg2 cpgbench testconfdb \ logsysbench logsysrec testquorum testvotequorum1 testvotequorum2 \ logsys_s logsys_t1 logsys_t2 testcpgzc cpgbenchzc testzcgc \ - stress_cpgzc stress_cpgfdget + stress_cpgzc stress_cpgfdget stress_cpgcontext testevs_LDADD = -levs -lcoroipcc testevs_LDFLAGS = -L../lib @@ -52,6 +52,8 @@ stress_cpgzc_LDADD = -lcpg -lcoroipcc stress_cpgzc_LDFLAGS = -L../lib stress_cpgfdget_LDADD = -lcpg -lcoroipcc stress_cpgfdget_LDFLAGS = -L../lib +stress_cpgcontext_LDADD = -lcpg +stress_cpgcontext_LDFLAGS = -L../lib testconfdb_LDADD = -lconfdb ../lcr/liblcr.a -lcoroipcc testconfdb_LDFLAGS = -L../lib testquorum_LDADD = -lquorum -lcoroipcc diff --git a/test/stress_cpgcontext.c b/test/stress_cpgcontext.c new file mode 100644 index 00000000..0e03f40d --- /dev/null +++ b/test/stress_cpgcontext.c @@ -0,0 +1,135 @@ +/* + * Copyright (c) 2009 Red Hat, Inc. + * + * All rights reserved. + * + * Author: Steven Dake (sdake@redhat.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 + +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include "../exec/crypto.h" + +struct my_msg { + unsigned int msg_size; + unsigned char sha1[20]; + unsigned char buffer[0]; +}; + +static void cpg_deliver_fn ( + cpg_handle_t handle, + const struct cpg_name *group_name, + uint32_t nodeid, + uint32_t pid, + void *m, + size_t msg_len) +{ +} + +static void cpg_confchg_fn ( + cpg_handle_t handle, + const struct cpg_name *group_name, + const struct cpg_address *member_list, size_t member_list_entries, + const struct cpg_address *left_list, size_t left_list_entries, + const struct cpg_address *joined_list, size_t joined_list_entries) +{ +} + +static cpg_callbacks_t callbacks = { + cpg_deliver_fn, + cpg_confchg_fn +}; + +static void sigintr_handler (int num) +{ + exit (1); +} + +#define ITERATIONS (1000000) + +#define INSTANCES 100 + +int main (void) +{ + cpg_handle_t handle[INSTANCES]; + cs_error_t res; + void *context[INSTANCES]; + int i, j; + void *ctx; + + signal (SIGINT, sigintr_handler); + for (i = 0; i < INSTANCES; i++) { + res = cpg_initialize (&handle[i], &callbacks); + if (res != CS_OK) { + printf ("FAIL %d\n", res); + exit (-1); + } + } + + for (j = 0; j < ITERATIONS; j++) { + for (i = 0; i < INSTANCES; i++) { + context[i] = malloc (20); + res = cpg_context_set (handle[i], context[i]); + if (res != CS_OK) { + printf ("FAIL %d\n", res); + exit (-1); + } + } + + for (i = 0; i < INSTANCES; i++) { + res = cpg_context_get (handle[i], &ctx); + if (res != CS_OK) { + printf ("FAIL %d\n", res); + exit (-1); + } + if (ctx != context[i]) { + printf ("FAIL\n"); + exit (-1); + } + free (ctx); + } + } + + for (i = 0; i < INSTANCES; i++) { + cpg_finalize (handle[i]); + } + + printf ("PASS\n"); + return (0); +}