This test program generates a random length message from 100 bytes to
100100 bytes and fills it with a string with an incrementing number and
random values. It then generates an sha1 hash which is later calculated
and compared by the delivery function.
It is used to verify that the messages delivered to evs are not
corrupted.
Regards
-steve
Index: test/evsverify.c
===================================================================
--- test/evsverify.c (revision 0)
+++ test/evsverify.c (revision 0)
@@ -0,0 +1,183 @@
+/*
+ * Copyright (c) 2004 MontaVista Software, Inc.
+ * Copyright (c) 2006-2007 Red Hat, Inc.
+ *
+ * All rights reserved.
+ *
+ * Author: Steven Dake ([EMAIL PROTECTED])
+ *
+ * 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 <sys/socket.h>
+#include <netinet/in.h>
+#include <arpa/inet.h>
+#include <errno.h>
+#include <string.h>
+#include <corosync/evs.h>
+#include "../exec/crypto.h"
+
+char *delivery_string;
+struct msg {
+ unsigned int msg_size;
+ unsigned char sha1[20];
+ unsigned char buffer[0];
+};
+
+int deliveries = 0;
+void evs_deliver_fn (
+ unsigned int nodeid,
+ void *m,
+ int msg_len)
+{
+ struct msg *msg2 = (struct msg *)m;
+ unsigned char sha1_compare[20];
+ hash_state sha1_hash;
+ unsigned int i;
+
+ printf ("API '%s' msg '%s'\n", delivery_string, msg2->buffer);
+ sha1_init (&sha1_hash);
+ sha1_process (&sha1_hash, msg2->buffer, msg2->msg_size);
+ sha1_done (&sha1_hash, sha1_compare);
+printf ("SIZE %d HASH: ", msg2->msg_size);
+for (i = 0; i < 20; i++) {
+printf ("%x", sha1_compare[i]);
+}
+printf ("\n");
+ if (memcmp (sha1_compare, msg2->sha1, 20) != 0) {
+ printf ("incorrect hash\n");
+ exit (1);
+ }
+ deliveries++;
+}
+
+void evs_confchg_fn (
+ unsigned int *member_list, int member_list_entries,
+ unsigned int *left_list, int left_list_entries,
+ unsigned int *joined_list, int joined_list_entries)
+{
+ int i;
+
+ printf ("CONFIGURATION CHANGE\n");
+ printf ("--------------------\n");
+ printf ("New configuration\n");
+ for (i = 0; i < member_list_entries; i++) {
+ printf ("%x\n", member_list[i]);
+ }
+ printf ("Members Left:\n");
+ for (i = 0; i < left_list_entries; i++) {
+ printf ("%x\n", left_list[i]);
+ }
+ printf ("Members Joined:\n");
+ for (i = 0; i < joined_list_entries; i++) {
+ printf ("%x\n", joined_list[i]);
+ }
+}
+
+evs_callbacks_t callbacks = {
+ evs_deliver_fn,
+ evs_confchg_fn
+};
+
+struct evs_group groups[3] = {
+ { "key1" },
+ { "key2" },
+ { "key3" }
+};
+
+struct msg msg;
+
+char buffer[200000];
+int main (void)
+{
+ evs_handle_t handle;
+ evs_error_t result;
+ unsigned int i = 0, j;
+ int fd;
+ unsigned int member_list[32];
+ unsigned int local_nodeid;
+ int member_list_entries = 32;
+ struct msg msg;
+ hash_state sha1_hash;
+ struct iovec iov[2];
+
+ result = evs_initialize (&handle, &callbacks);
+ if (result != EVS_OK) {
+ printf ("Couldn't initialize EVS service %d\n", result);
+ exit (0);
+ }
+
+ result = evs_membership_get (handle, &local_nodeid,
+ member_list, &member_list_entries);
+ printf ("Current membership from evs_membership_get entries %d\n",
+ member_list_entries);
+ for (i = 0; i < member_list_entries; i++) {
+ printf ("member [%d] is %x\n", i, member_list[i]);
+ }
+ printf ("local processor from evs_membership_get %x\n", local_nodeid);
+
+ printf ("Init result %d\n", result);
+ result = evs_join (handle, groups, 3);
+ printf ("Join result %d\n", result);
+ result = evs_leave (handle, &groups[0], 1);
+ printf ("Leave result %d\n", result);
+ delivery_string = "evs_mcast_joined";
+
+ iov[0].iov_base = &msg;
+ iov[0].iov_len = sizeof (struct msg);
+ iov[1].iov_base = buffer;
+
+ /*
+ * Demonstrate evs_mcast_joined
+ */
+ for (i = 0; i < 1000000000; i++) {
+ msg.msg_size = 100 + rand() % 100000;
+ iov[1].iov_len = msg.msg_size;
+ for (j = 0; j < msg.msg_size; j++) {
+ buffer[j] = j;
+ }
+ sprintf ((char *)buffer,
+ "evs_mcast_joined: This is message %12d", i);
+ sha1_init (&sha1_hash);
+ sha1_process (&sha1_hash, buffer, msg.msg_size);
+ sha1_done (&sha1_hash, msg.sha1);
+try_again_one:
+ result = evs_mcast_joined (handle, EVS_TYPE_AGREED,
+ iov, 2);
+ if (result == EVS_ERR_TRY_AGAIN) {
+ goto try_again_one;
+ }
+ result = evs_dispatch (handle, EVS_DISPATCH_ALL);
+ }
+
+ evs_fd_get (handle, &fd);
+
+ evs_finalize (handle);
+
+ return (0);
+}
Index: test/Makefile
===================================================================
--- test/Makefile (revision 1667)
+++ test/Makefile (working copy)
@@ -31,17 +31,22 @@
# Include configuration
#
-include ../Makefile.inc
+srcdir ?= $(CURDIR)/../
+subdir ?= exec/
+include $(srcdir)Makefile.inc
+
+override LDFLAGS += -L./ ${DYFLAGS}
+
ifeq (${COROSYNC_COMPAT}, SOLARIS)
override LDFLAGS += -lnsl -lsocket -lrt
endif
LIBRARIES= ../lib/libevs.a ../lib/libcpg.a ../lib/libcfg.a ../lib/libconfdb.a
LIBS = $(LIBRARIES)
-BINARIES= testevs evsbench testcpg testcpg2 cpgbench testconfdb
+BINARIES= testevs evsbench evsverify testcpg testcpg2 cpgbench testconfdb
-#override CFLAGS += -I../include
+override CFLAGS += -I../include
override LDFLAGS += -L../lib
EXTRA_CFLAGS = -I$(srcdir)include
@@ -61,6 +66,9 @@
evsbench: evsbench.o $(LIBS)
$(CC) $(LDFLAGS) -o evsbench evsbench.o $(LIBS)
+evsverify: evsverify.o $(LIBS) ../exec/crypto.o
+ $(CC) $(LDFLAGS) -o evsverify evsverify.o $(LIBS) ../exec/crypto.o
+
testcpg: testcpg.o $(LIBRARIES)
$(CC) $(LDFLAGS) -o testcpg testcpg.o $(LIBS)
_______________________________________________
Openais mailing list
[email protected]
https://lists.linux-foundation.org/mailman/listinfo/openais
