From: "Fabio M. Di Nitto" <fdinitto@xxxxxxxxxx>
there are several reasons for this:
1) evs is only partially implemented with no plans to complete it
typedef enum {
EVS_TYPE_UNORDERED, /* not implemented */
EVS_TYPE_FIFO, /* same as agreed */
EVS_TYPE_AGREED,
EVS_TYPE_SAFE /* not implemented */
} evs_guarantee_t;
2) evs has no users in any upstream distribution and no search
engine can find any other upstream using it.
3) the only reason (I was told) to carry around evs was that evs
receives the full ring_id struct from totem. This is only
partially correct because while the structures are prepared
to carry around those data, they are never transmitted from
corosync engine down the IPC line to the user.
CPG ring_id contains the exact same information and it's
actually less buggy (due to prototying of the info).
worst case scenario where a user really absolutely need libevs,
it can be easily reimplemented as libcpg wrapper and avoid
lots of code duplication.
Signed-off-by: Fabio M. Di Nitto <fdinitto@xxxxxxxxxx>
---
AUTHORS | 2 +-
conf/corosync.conf.example | 2 +-
conf/corosync.conf.example.udpu | 2 +-
conf/corosync.xml.example | 2 +-
configure.ac | 1 -
corosync.spec.in | 5 -
exec/Makefile.am | 2 +-
exec/evs.c | 490 ---------------------------------
exec/ipc_glue.c | 3 -
exec/service.c | 9 +-
exec/service.h | 1 -
exec/util.c | 1 -
include/Makefile.am | 4 +-
include/corosync/corodefs.h | 3 +-
include/corosync/evs.h | 202 --------------
include/corosync/ipc_evs.h | 140 ----------
lib/Makefile.am | 4 +-
lib/evs.c | 569 ---------------------------------------
lib/libevs.versions | 14 -
lib/libevs.verso | 1 -
man/Makefile.am | 12 -
man/corosync.conf.5 | 4 -
man/corosync_overview.8 | 8 +-
man/evs_context_get.3.in | 64 -----
man/evs_context_set.3.in | 66 -----
man/evs_dispatch.3.in | 107 --------
man/evs_fd_get.3.in | 70 -----
man/evs_finalize.3.in | 66 -----
man/evs_initialize.3.in | 121 ---------
man/evs_join.3.in | 105 -------
man/evs_leave.3.in | 100 -------
man/evs_mcast_groups.3.in | 164 -----------
man/evs_mcast_joined.3.in | 137 ----------
man/evs_membership_get.3.in | 74 -----
man/evs_overview.8 | 185 -------------
man/index.html | 43 ---
pkgconfig/Makefile.am | 2 +-
test/.gitignore | 3 -
test/Makefile.am | 11 +-
test/evsbench.c | 197 --------------
test/evsverify.c | 188 -------------
test/testevs.c | 193 -------------
test/testevsth.c | 186 -------------
43 files changed, 17 insertions(+), 3546 deletions(-)
delete mode 100644 exec/evs.c
delete mode 100644 include/corosync/evs.h
delete mode 100644 include/corosync/ipc_evs.h
delete mode 100644 lib/evs.c
delete mode 100644 lib/libevs.versions
delete mode 100644 lib/libevs.verso
delete mode 100644 man/evs_context_get.3.in
delete mode 100644 man/evs_context_set.3.in
delete mode 100644 man/evs_dispatch.3.in
delete mode 100644 man/evs_fd_get.3.in
delete mode 100644 man/evs_finalize.3.in
delete mode 100644 man/evs_initialize.3.in
delete mode 100644 man/evs_join.3.in
delete mode 100644 man/evs_leave.3.in
delete mode 100644 man/evs_mcast_groups.3.in
delete mode 100644 man/evs_mcast_joined.3.in
delete mode 100644 man/evs_membership_get.3.in
delete mode 100644 man/evs_overview.8
delete mode 100644 test/evsbench.c
delete mode 100644 test/evsverify.c
delete mode 100644 test/testevs.c
delete mode 100644 test/testevsth.c
diff --git a/AUTHORS b/AUTHORS
index fb540f2..7ce2b46 100644
--- a/AUTHORS
+++ b/AUTHORS
@@ -2,7 +2,7 @@ Last Updated Dec 2009
Main Developers
---------------
-Steven Dake Maintainer, totem implementation, evs, cfg,
+Steven Dake Maintainer, totem implementation, cfg,
logsys, service engine architecture, ipc system
poll, timers, objdb, hdb, sync, coroapi
Christine Caulfield cpg, cfg, quorum, confdb, totem ipv6 support, totem NSS
diff --git a/conf/corosync.conf.example b/conf/corosync.conf.example
index 46be2eb..f856902 100644
--- a/conf/corosync.conf.example
+++ b/conf/corosync.conf.example
@@ -67,7 +67,7 @@ logging {
# timestamps can be annoying).
timestamp: on
logger_subsys {
- subsys: EVS
+ subsys: QUORUM
debug: off
}
}
diff --git a/conf/corosync.conf.example.udpu b/conf/corosync.conf.example.udpu
index 3730813..72613a1 100644
--- a/conf/corosync.conf.example.udpu
+++ b/conf/corosync.conf.example.udpu
@@ -68,7 +68,7 @@ logging {
debug: off
timestamp: on
logger_subsys {
- subsys: EVS
+ subsys: QUORUM
debug: off
}
}
diff --git a/conf/corosync.xml.example b/conf/corosync.xml.example
index c7e5a29..58d28ed 100644
--- a/conf/corosync.xml.example
+++ b/conf/corosync.xml.example
@@ -103,7 +103,7 @@
subsys if needed.
-->
- <logger_subsys subsys="EVS" debug="off" />
+ <logger_subsys subsys="QUORUM" debug="off" />
</logging>
</corosync>
diff --git a/configure.ac b/configure.ac
index 721eb2d..b426db9 100644
--- a/configure.ac
+++ b/configure.ac
@@ -216,7 +216,6 @@ SONAME="${SOMAJOR}.${SOMINOR}.${SOMICRO}"
# specific libraries SONAME
LIB_SONAME_IMPORT([cfg])
LIB_SONAME_IMPORT([cpg])
-LIB_SONAME_IMPORT([evs])
LIB_SONAME_IMPORT([quorum])
LIB_SONAME_IMPORT([sam])
LIB_SONAME_IMPORT([votequorum])
diff --git a/corosync.spec.in b/corosync.spec.in
index 51fb7ad..f73e39e 100644
--- a/corosync.spec.in
+++ b/corosync.spec.in
@@ -235,7 +235,6 @@ This package contains corosync libraries.
%{_libdir}/libcfg.so.*
%{_libdir}/libcpg.so.*
%{_libdir}/libcmap.so.*
-%{_libdir}/libevs.so.*
%{_libdir}/libtotem_pg.so.*
%{_libdir}/libquorum.so.*
%{_libdir}/libvotequorum.so.*
@@ -267,7 +266,6 @@ The Corosync Cluster Engine APIs.
%{_includedir}/corosync/cmap.h
%{_includedir}/corosync/corotypes.h
%{_includedir}/corosync/cpg.h
-%{_includedir}/corosync/evs.h
%{_includedir}/corosync/hdb.h
%{_includedir}/corosync/sam.h
%{_includedir}/corosync/quorum.h
@@ -279,7 +277,6 @@ The Corosync Cluster Engine APIs.
%{_libdir}/libcfg.so
%{_libdir}/libcpg.so
%{_libdir}/libcmap.so
-%{_libdir}/libevs.so
%{_libdir}/libtotem_pg.so
%{_libdir}/libquorum.so
%{_libdir}/libvotequorum.so
@@ -287,12 +284,10 @@ The Corosync Cluster Engine APIs.
%{_libdir}/libcorosync_common.so
%{_libdir}/pkgconfig/*.pc
%{_mandir}/man3/cpg_*3*
-%{_mandir}/man3/evs_*3*
%{_mandir}/man3/quorum_*3*
%{_mandir}/man3/votequorum_*3*
%{_mandir}/man3/sam_*3*
%{_mandir}/man8/cpg_overview.8*
-%{_mandir}/man8/evs_overview.8*
%{_mandir}/man8/votequorum_overview.8*
%{_mandir}/man8/sam_overview.8*
%{_mandir}/man3/cmap_*3*
diff --git a/exec/Makefile.am b/exec/Makefile.am
index 2e33033..6f739f4 100644
--- a/exec/Makefile.am
+++ b/exec/Makefile.am
@@ -48,7 +48,7 @@ sbin_PROGRAMS = corosync
libtotem_pg_a_SOURCES = $(TOTEM_SRC)
corosync_SOURCES = vsf_ykd.c coroparse.c vsf_quorum.c sync.c \
- logsys.c cfg.c cmap.c cpg.c evs.c mon.c pload.c \
+ logsys.c cfg.c cmap.c cpg.c mon.c pload.c \
votequorum.c wd.c util.c schedwrk.c main.c \
apidef.c quorum.c icmap.c timer.c \
ipc_glue.c service.c mainconfig.c totemconfig.c
diff --git a/exec/evs.c b/exec/evs.c
deleted file mode 100644
index 6667341..0000000
--- a/exec/evs.c
+++ /dev/null
@@ -1,490 +0,0 @@
-/*
- * Copyright (c) 2004-2006 MontaVista Software, Inc.
- * Copyright (c) 2006-2012 Red Hat, Inc.
- *
- * All rights reserved.
- *
- * Author: Steven Dake (sdake@xxxxxxxxxx)
- *
- * 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 <config.h>
-
-#include <sys/types.h>
-#include <sys/socket.h>
-#include <sys/un.h>
-#include <sys/ioctl.h>
-#include <netinet/in.h>
-#include <sys/uio.h>
-#include <unistd.h>
-#include <fcntl.h>
-#include <stdlib.h>
-#include <stdio.h>
-#include <errno.h>
-#include <assert.h>
-#include <time.h>
-#include <netinet/in.h>
-#include <arpa/inet.h>
-
-#include <corosync/swab.h>
-#include <corosync/corotypes.h>
-#include <qb/qbipc_common.h>
-#include <corosync/corodefs.h>
-#include <corosync/mar_gen.h>
-#include <corosync/coroapi.h>
-#include <corosync/logsys.h>
-#include <corosync/list.h>
-
-#include <corosync/evs.h>
-#include <corosync/ipc_evs.h>
-
-#include "service.h"
-
-LOGSYS_DECLARE_SUBSYS ("EVS");
-
-enum evs_exec_message_req_types {
- MESSAGE_REQ_EXEC_EVS_MCAST = 0
-};
-
-/*
- * Service Interfaces required by service_message_handler struct
- */
-static char *evs_exec_init_fn (
- struct corosync_api_v1 *corosync_api);
-
-static void evs_confchg_fn (
- enum totem_configuration_type configuration_type,
- const unsigned int *member_list, size_t member_list_entries,
- const unsigned int *left_list, size_t left_list_entries,
- const unsigned int *joined_list, size_t joined_list_entries,
- const struct memb_ring_id *ring_id);
-
-static void message_handler_req_exec_mcast (const void *msg, unsigned int nodeid);
-
-static void req_exec_mcast_endian_convert (void *msg);
-
-static void message_handler_req_evs_join (void *conn, const void *msg);
-static void message_handler_req_evs_leave (void *conn, const void *msg);
-static void message_handler_req_evs_mcast_joined (void *conn, const void *msg);
-static void message_handler_req_evs_mcast_groups (void *conn, const void *msg);
-static void message_handler_req_evs_membership_get (void *conn, const void *msg);
-
-static int evs_lib_init_fn (void *conn);
-static int evs_lib_exit_fn (void *conn);
-
-struct evs_pd {
- struct evs_group *groups;
- int group_entries;
- struct list_head list;
- void *conn;
-};
-
-static struct corosync_api_v1 *api;
-
-static struct corosync_lib_handler evs_lib_engine[] =
-{
- { /* 0 */
- .lib_handler_fn = message_handler_req_evs_join,
- .flow_control = CS_LIB_FLOW_CONTROL_NOT_REQUIRED
- },
- { /* 1 */
- .lib_handler_fn = message_handler_req_evs_leave,
- .flow_control = CS_LIB_FLOW_CONTROL_NOT_REQUIRED
- },
- { /* 2 */
- .lib_handler_fn = message_handler_req_evs_mcast_joined,
- .flow_control = CS_LIB_FLOW_CONTROL_REQUIRED
- },
- { /* 3 */
- .lib_handler_fn = message_handler_req_evs_mcast_groups,
- .flow_control = CS_LIB_FLOW_CONTROL_REQUIRED
- },
- { /* 4 */
- .lib_handler_fn = message_handler_req_evs_membership_get,
- .flow_control = CS_LIB_FLOW_CONTROL_NOT_REQUIRED
- }
-};
-
-static struct corosync_exec_handler evs_exec_engine[] =
-{
- {
- .exec_handler_fn = message_handler_req_exec_mcast,
- .exec_endian_convert_fn = req_exec_mcast_endian_convert
- }
-};
-
-struct corosync_service_engine evs_service_engine = {
- .name = "corosync extended virtual synchrony service",
- .id = EVS_SERVICE,
- .priority = 1,
- .private_data_size = sizeof (struct evs_pd),
- .flow_control = CS_LIB_FLOW_CONTROL_REQUIRED,
- .lib_init_fn = evs_lib_init_fn,
- .lib_exit_fn = evs_lib_exit_fn,
- .lib_engine = evs_lib_engine,
- .lib_engine_count = sizeof (evs_lib_engine) / sizeof (struct corosync_lib_handler),
- .exec_engine = evs_exec_engine,
- .exec_engine_count = sizeof (evs_exec_engine) / sizeof (struct corosync_exec_handler),
- .confchg_fn = evs_confchg_fn,
- .exec_init_fn = evs_exec_init_fn,
- .exec_dump_fn = NULL
-};
-
-static DECLARE_LIST_INIT (confchg_notify);
-
-struct corosync_service_engine *evs_get_service_engine_ver0 (void)
-{
- return (&evs_service_engine);
-}
-
-static char *evs_exec_init_fn (
- struct corosync_api_v1 *corosync_api)
-{
-#ifdef COROSYNC_SOLARIS
- logsys_subsys_init();
-#endif
-
- api = corosync_api;
-
- return NULL;
-}
-
-struct res_evs_confchg_callback res_evs_confchg_callback;
-
-static void evs_confchg_fn (
- enum totem_configuration_type configuration_type,
- const unsigned int *member_list, size_t member_list_entries,
- const unsigned int *left_list, size_t left_list_entries,
- const unsigned int *joined_list, size_t joined_list_entries,
- const struct memb_ring_id *ring_id)
-{
- struct list_head *list;
- struct evs_pd *evs_pd;
-
- /*
- * Build configuration change message
- */
- res_evs_confchg_callback.header.size = sizeof (struct res_evs_confchg_callback);
- res_evs_confchg_callback.header.id = MESSAGE_RES_EVS_CONFCHG_CALLBACK;
- res_evs_confchg_callback.header.error = CS_OK;
-
- memcpy (res_evs_confchg_callback.member_list,
- member_list, member_list_entries * sizeof(*member_list));
- res_evs_confchg_callback.member_list_entries = member_list_entries;
-
- memcpy (res_evs_confchg_callback.left_list,
- left_list, left_list_entries * sizeof(*left_list));
- res_evs_confchg_callback.left_list_entries = left_list_entries;
-
- memcpy (res_evs_confchg_callback.joined_list,
- joined_list, joined_list_entries * sizeof(*joined_list));
- res_evs_confchg_callback.joined_list_entries = joined_list_entries;
-
- /*
- * Send configuration change message to every EVS library user
- */
- for (list = confchg_notify.next; list != &confchg_notify; list = list->next) {
- evs_pd = list_entry (list, struct evs_pd, list);
- api->ipc_dispatch_send (evs_pd->conn,
- &res_evs_confchg_callback,
- sizeof (res_evs_confchg_callback));
- }
-}
-
-static int evs_lib_init_fn (void *conn)
-{
- struct evs_pd *evs_pd = (struct evs_pd *)api->ipc_private_data_get (conn);
-
- log_printf (LOGSYS_LEVEL_DEBUG, "Got request to initalize evs service.");
-
- evs_pd->groups = NULL;
- evs_pd->group_entries = 0;
- evs_pd->conn = conn;
- list_init (&evs_pd->list);
- list_add (&evs_pd->list, &confchg_notify);
-
- api->ipc_dispatch_send (conn, &res_evs_confchg_callback,
- sizeof (res_evs_confchg_callback));
-
- return (0);
-}
-
-static int evs_lib_exit_fn (void *conn)
-{
- struct evs_pd *evs_pd = (struct evs_pd *)api->ipc_private_data_get (conn);
-
- list_del (&evs_pd->list);
- return (0);
-}
-
-static void message_handler_req_evs_join (void *conn, const void *msg)
-{
- cs_error_t error = CS_OK;
- const struct req_lib_evs_join *req_lib_evs_join = msg;
- struct res_lib_evs_join res_lib_evs_join;
- void *addr;
- struct evs_pd *evs_pd = (struct evs_pd *)api->ipc_private_data_get (conn);
-
- if (req_lib_evs_join->group_entries > 50) {
- error = CS_ERR_TOO_MANY_GROUPS;
- goto exit_error;
- }
-
- addr = realloc (evs_pd->groups, sizeof (struct evs_group) *
- (evs_pd->group_entries + req_lib_evs_join->group_entries));
- if (addr == NULL) {
- error = CS_ERR_NO_MEMORY;
- goto exit_error;
- }
- evs_pd->groups = addr;
-
- memcpy (&evs_pd->groups[evs_pd->group_entries],
- req_lib_evs_join->groups,
- sizeof (struct evs_group) * req_lib_evs_join->group_entries);
-
- evs_pd->group_entries += req_lib_evs_join->group_entries;
-
-exit_error:
- res_lib_evs_join.header.size = sizeof (struct res_lib_evs_join);
- res_lib_evs_join.header.id = MESSAGE_RES_EVS_JOIN;
- res_lib_evs_join.header.error = error;
-
- api->ipc_response_send (conn, &res_lib_evs_join,
- sizeof (struct res_lib_evs_join));
-}
-
-static void message_handler_req_evs_leave (void *conn, const void *msg)
-{
- const struct req_lib_evs_leave *req_lib_evs_leave = msg;
- struct res_lib_evs_leave res_lib_evs_leave;
- cs_error_t error = CS_OK;
- int i, j;
- int found;
- struct evs_pd *evs_pd = (struct evs_pd *)api->ipc_private_data_get (conn);
-
- for (i = 0; i < req_lib_evs_leave->group_entries; i++) {
- found = 0;
- for (j = 0; j < evs_pd->group_entries;) {
-
- if (memcmp (&req_lib_evs_leave->groups[i],
- &evs_pd->groups[j], sizeof (struct evs_group)) == 0) {
-
- /*
- * Delete entry
- */
- memmove (&evs_pd->groups[j], &evs_pd->groups[j + 1],
- (evs_pd->group_entries - j - 1) * sizeof (struct evs_group));
-
- evs_pd->group_entries -= 1;
-
- found = 1;
- break;
- } else {
- j++;
- }
- }
- if (found == 0) {
- error = CS_ERR_NOT_EXIST;
- break;
- }
- }
-
- res_lib_evs_leave.header.size = sizeof (struct res_lib_evs_leave);
- res_lib_evs_leave.header.id = MESSAGE_RES_EVS_LEAVE;
- res_lib_evs_leave.header.error = error;
-
- api->ipc_response_send (conn, &res_lib_evs_leave,
- sizeof (struct res_lib_evs_leave));
-}
-
-static void message_handler_req_evs_mcast_joined (void *conn, const void *msg)
-{
- cs_error_t error = CS_ERR_TRY_AGAIN;
- const struct req_lib_evs_mcast_joined *req_lib_evs_mcast_joined = msg;
- struct res_lib_evs_mcast_joined res_lib_evs_mcast_joined;
- struct iovec req_exec_evs_mcast_iovec[3];
- struct req_exec_evs_mcast req_exec_evs_mcast;
- int res;
- struct evs_pd *evs_pd = (struct evs_pd *)api->ipc_private_data_get (conn);
-
- req_exec_evs_mcast.header.size = sizeof (struct req_exec_evs_mcast) +
- evs_pd->group_entries * sizeof (struct evs_group) +
- req_lib_evs_mcast_joined->msg_len;
-
- req_exec_evs_mcast.header.id =
- SERVICE_ID_MAKE (EVS_SERVICE, MESSAGE_REQ_EXEC_EVS_MCAST);
- req_exec_evs_mcast.msg_len = req_lib_evs_mcast_joined->msg_len;
- req_exec_evs_mcast.group_entries = evs_pd->group_entries;
-
- req_exec_evs_mcast_iovec[0].iov_base = (char *)&req_exec_evs_mcast;
- req_exec_evs_mcast_iovec[0].iov_len = sizeof (req_exec_evs_mcast);
- req_exec_evs_mcast_iovec[1].iov_base = (char *)evs_pd->groups;
- req_exec_evs_mcast_iovec[1].iov_len = evs_pd->group_entries * sizeof (struct evs_group);
- req_exec_evs_mcast_iovec[2].iov_base = (char *)&req_lib_evs_mcast_joined->msg;
- req_exec_evs_mcast_iovec[2].iov_len = req_lib_evs_mcast_joined->msg_len;
-
- res = api->totem_mcast (req_exec_evs_mcast_iovec, 3, TOTEM_AGREED);
- // TODO
- if (res == 0) {
- error = CS_OK;
- }
-
- res_lib_evs_mcast_joined.header.size = sizeof (struct res_lib_evs_mcast_joined);
- res_lib_evs_mcast_joined.header.id = MESSAGE_RES_EVS_MCAST_JOINED;
- res_lib_evs_mcast_joined.header.error = error;
-
- api->ipc_response_send (conn, &res_lib_evs_mcast_joined,
- sizeof (struct res_lib_evs_mcast_joined));
-}
-
-static void message_handler_req_evs_mcast_groups (void *conn, const void *msg)
-{
- cs_error_t error = CS_ERR_TRY_AGAIN;
- const struct req_lib_evs_mcast_groups *req_lib_evs_mcast_groups = msg;
- struct res_lib_evs_mcast_groups res_lib_evs_mcast_groups;
- struct iovec req_exec_evs_mcast_iovec[3];
- struct req_exec_evs_mcast req_exec_evs_mcast;
- const char *msg_addr;
- int res;
-
- req_exec_evs_mcast.header.size = sizeof (struct req_exec_evs_mcast) +
- sizeof (struct evs_group) * req_lib_evs_mcast_groups->group_entries +
- req_lib_evs_mcast_groups->msg_len;
-
- req_exec_evs_mcast.header.id =
- SERVICE_ID_MAKE (EVS_SERVICE, MESSAGE_REQ_EXEC_EVS_MCAST);
- req_exec_evs_mcast.msg_len = req_lib_evs_mcast_groups->msg_len;
- req_exec_evs_mcast.group_entries = req_lib_evs_mcast_groups->group_entries;
-
- msg_addr = (const char *)req_lib_evs_mcast_groups +
- sizeof (struct req_lib_evs_mcast_groups) +
- (sizeof (struct evs_group) * req_lib_evs_mcast_groups->group_entries);
-
- req_exec_evs_mcast_iovec[0].iov_base = (char *)&req_exec_evs_mcast;
- req_exec_evs_mcast_iovec[0].iov_len = sizeof (req_exec_evs_mcast);
- req_exec_evs_mcast_iovec[1].iov_base = (char *)&req_lib_evs_mcast_groups->groups;
- req_exec_evs_mcast_iovec[1].iov_len = sizeof (struct evs_group) * req_lib_evs_mcast_groups->group_entries;
- req_exec_evs_mcast_iovec[2].iov_base = (void *) msg_addr; /* discard const */
- req_exec_evs_mcast_iovec[2].iov_len = req_lib_evs_mcast_groups->msg_len;
-
- res = api->totem_mcast (req_exec_evs_mcast_iovec, 3, TOTEM_AGREED);
- if (res == 0) {
- error = CS_OK;
- }
-
- res_lib_evs_mcast_groups.header.size = sizeof (struct res_lib_evs_mcast_groups);
- res_lib_evs_mcast_groups.header.id = MESSAGE_RES_EVS_MCAST_GROUPS;
- res_lib_evs_mcast_groups.header.error = error;
-
- api->ipc_response_send (conn, &res_lib_evs_mcast_groups,
- sizeof (struct res_lib_evs_mcast_groups));
-}
-
-static void message_handler_req_evs_membership_get (void *conn, const void *msg)
-{
- struct res_lib_evs_membership_get res_lib_evs_membership_get;
-
- res_lib_evs_membership_get.header.size = sizeof (struct res_lib_evs_membership_get);
- res_lib_evs_membership_get.header.id = MESSAGE_RES_EVS_MEMBERSHIP_GET;
- res_lib_evs_membership_get.header.error = CS_OK;
- res_lib_evs_membership_get.local_nodeid = api->totem_nodeid_get ();
- memcpy (&res_lib_evs_membership_get.member_list,
- &res_evs_confchg_callback.member_list,
- sizeof (res_lib_evs_membership_get.member_list));
-
- res_lib_evs_membership_get.member_list_entries =
- res_evs_confchg_callback.member_list_entries;
-
- api->ipc_response_send (conn, &res_lib_evs_membership_get,
- sizeof (struct res_lib_evs_membership_get));
-}
-
-static void req_exec_mcast_endian_convert (void *msg)
-{
- struct req_exec_evs_mcast *req_exec_evs_mcast =
- (struct req_exec_evs_mcast *)msg;
- req_exec_evs_mcast->group_entries =
- swab32 (req_exec_evs_mcast->group_entries);
- req_exec_evs_mcast->msg_len = swab32 (req_exec_evs_mcast->msg_len);
-}
-
-static void message_handler_req_exec_mcast (
- const void *msg,
- unsigned int nodeid)
-{
- const struct req_exec_evs_mcast *req_exec_evs_mcast = msg;
- struct res_evs_deliver_callback res_evs_deliver_callback;
- const char *msg_addr;
- struct list_head *list;
- int found = 0;
- int i, j;
- struct evs_pd *evs_pd;
- struct iovec iov[2];
-
- res_evs_deliver_callback.header.size = sizeof (struct res_evs_deliver_callback) +
- req_exec_evs_mcast->msg_len;
- res_evs_deliver_callback.header.id = MESSAGE_RES_EVS_DELIVER_CALLBACK;
- res_evs_deliver_callback.header.error = CS_OK;
- res_evs_deliver_callback.msglen = req_exec_evs_mcast->msg_len;
-
- msg_addr = (const char *)req_exec_evs_mcast + sizeof (struct req_exec_evs_mcast) +
- (sizeof (struct evs_group) * req_exec_evs_mcast->group_entries);
-
- for (list = confchg_notify.next; list != &confchg_notify; list = list->next) {
- found = 0;
- evs_pd = list_entry (list, struct evs_pd, list);
-
- for (i = 0; i < evs_pd->group_entries; i++) {
- for (j = 0; j < req_exec_evs_mcast->group_entries; j++) {
-
- if (memcmp (&evs_pd->groups[i], &req_exec_evs_mcast->groups[j],
- sizeof (struct evs_group)) == 0) {
-
- found = 1;
- break;
- }
- }
- if (found) {
- break;
- }
- }
-
- if (found) {
- res_evs_deliver_callback.local_nodeid = nodeid;
- iov[0].iov_base = (void *)&res_evs_deliver_callback;
- iov[0].iov_len = sizeof (struct res_evs_deliver_callback);
- iov[1].iov_base = (void *) msg_addr; /* discard const */
- iov[1].iov_len = req_exec_evs_mcast->msg_len;
-
- api->ipc_dispatch_iov_send (
- evs_pd->conn,
- iov,
- 2);
- }
- }
-}
diff --git a/exec/ipc_glue.c b/exec/ipc_glue.c
index 9d00d7b..2aca988 100644
--- a/exec/ipc_glue.c
+++ b/exec/ipc_glue.c
@@ -118,9 +118,6 @@ static const char* cs_ipcs_serv_short_name(int32_t service_id)
{
const char *name;
switch (service_id) {
- case EVS_SERVICE:
- name = "evs";
- break;
case CFG_SERVICE:
name = "cfg";
break;
diff --git a/exec/service.c b/exec/service.c
index fed75c3..c8adae7 100644
--- a/exec/service.c
+++ b/exec/service.c
@@ -60,9 +60,9 @@ LOGSYS_DECLARE_SUBSYS ("SERV");
static struct default_service default_services[] = {
{
- .name = "corosync_evs",
+ .name = "corosync_cmap",
.ver = 0,
- .loader = evs_get_service_engine_ver0
+ .loader = cmap_get_service_engine_ver0
},
{
.name = "corosync_cfg",
@@ -98,11 +98,6 @@ static struct default_service default_services[] = {
.ver = 0,
.loader = vsf_quorum_get_service_engine_ver0
},
- {
- .name = "corosync_cmap",
- .ver = 0,
- .loader = cmap_get_service_engine_ver0
- },
};
/*
diff --git a/exec/service.h b/exec/service.h
index 1d255f3..647d0e0 100644
--- a/exec/service.h
+++ b/exec/service.h
@@ -85,7 +85,6 @@ struct corosync_service_engine *vsf_quorum_get_service_engine_ver0 (void);
struct corosync_service_engine *quorum_get_service_handler_ver0 (void);
struct corosync_service_engine *pload_get_service_engine_ver0 (void);
struct corosync_service_engine *cfg_get_service_engine_ver0 (void);
-struct corosync_service_engine *evs_get_service_engine_ver0 (void);
struct corosync_service_engine *cpg_get_service_engine_ver0 (void);
struct corosync_service_engine *mon_get_service_engine_ver0 (void);
struct corosync_service_engine *wd_get_service_engine_ver0 (void);
diff --git a/exec/util.c b/exec/util.c
index c0d5c8b..343759d 100644
--- a/exec/util.c
+++ b/exec/util.c
@@ -58,7 +58,6 @@ struct service_names {
static struct service_names servicenames[] =
{
- { "EVS", EVS_SERVICE },
{ "CFG", CFG_SERVICE },
{ "CPG", CPG_SERVICE },
{ "QUORUM", QUORUM_SERVICE },
diff --git a/include/Makefile.am b/include/Makefile.am
index e15d36c..780d012 100644
--- a/include/Makefile.am
+++ b/include/Makefile.am
@@ -31,10 +31,10 @@
MAINTAINERCLEANFILES = Makefile.in corosync/config.h.in
-CS_H = hdb.h cpg.h cfg.h evs.h corodefs.h \
+CS_H = hdb.h cpg.h cfg.h corodefs.h \
corotypes.h quorum.h votequorum.h sam.h cmap.h
-CS_INTERNAL_H = ipc_cfg.h ipc_cpg.h ipc_evs.h ipc_quorum.h \
+CS_INTERNAL_H = ipc_cfg.h ipc_cpg.h ipc_quorum.h \
quorum.h sq.h ipc_votequorum.h ipc_cmap.h \
logsys.h coroapi.h icmap.h mar_gen.h list.h swab.h cs_config.h
diff --git a/include/corosync/corodefs.h b/include/corosync/corodefs.h
index c391c57..93904f5 100644
--- a/include/corosync/corodefs.h
+++ b/include/corosync/corodefs.h
@@ -38,7 +38,7 @@
#include <netinet/in.h>
enum corosync_service_types {
- EVS_SERVICE = 0,
+ CMAP_SERVICE = 0,
CFG_SERVICE = 1,
CPG_SERVICE = 2,
QUORUM_SERVICE = 3,
@@ -46,7 +46,6 @@ enum corosync_service_types {
VOTEQUORUM_SERVICE = 5,
MON_SERVICE = 6,
WD_SERVICE = 7,
- CMAP_SERVICE = 8,
};
#ifdef HAVE_SMALL_MEMORY_FOOTPRINT
diff --git a/include/corosync/evs.h b/include/corosync/evs.h
deleted file mode 100644
index 881414c..0000000
--- a/include/corosync/evs.h
+++ /dev/null
@@ -1,202 +0,0 @@
-/*
- * Copyright (c) 2004 MontaVista Software, Inc.
- * Copyright (c) 2006-2011 Red Hat, Inc.
- *
- * All rights reserved.
- *
- * Author: Steven Dake (sdake@xxxxxxxxxx)
- *
- * 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.
- */
-#ifndef COROSYNC_EVS_H_DEFINED
-#define COROSYNC_EVS_H_DEFINED
-
-#include <inttypes.h>
-#include <netinet/in.h>
-#include <corosync/corotypes.h>
-#include <corosync/hdb.h>
-
-#ifdef __cplusplus
-extern "C" {
-#endif
-
-/**
- * @defgroup corosync Other API services provided by corosync
- */
-/**
- * @addtogroup evs_corosync
- *
- * @{
- */
-
-typedef uint64_t evs_handle_t;
-
-typedef enum {
- EVS_TYPE_UNORDERED, /* not implemented */
- EVS_TYPE_FIFO, /* same as agreed */
- EVS_TYPE_AGREED,
- EVS_TYPE_SAFE /* not implemented */
-} evs_guarantee_t;
-
-#define TOTEMIP_ADDRLEN (sizeof(struct in6_addr))
-
-/** These are the things that get passed around */
-struct evs_group {
- char key[32];
-};
-
-struct evs_ring_id {
- unsigned int nodeid;
- unsigned long long seq;
-};
-
-typedef void (*evs_deliver_fn_t) (
- hdb_handle_t handle,
- unsigned int nodeid,
- const void *msg,
- size_t msg_len);
-
-typedef void (*evs_confchg_fn_t) (
- hdb_handle_t handle,
- const unsigned int *member_list, size_t member_list_entries,
- const unsigned int *left_list, size_t left_list_entries,
- const unsigned int *joined_list, size_t joined_list_entries,
- const struct evs_ring_id *ring_id);
-
-typedef struct {
- evs_deliver_fn_t evs_deliver_fn;
- evs_confchg_fn_t evs_confchg_fn;
-} evs_callbacks_t;
-
-/** @} */
-
-/**
- * Create a new evs connection
- */
-cs_error_t evs_initialize (
- evs_handle_t *handle,
- evs_callbacks_t *callbacks);
-
-/**
- * Close the evs handle
- */
-cs_error_t evs_finalize (
- evs_handle_t handle);
-
-/**
- * Get a file descriptor on which to poll.
- *
- * evs_handle_t is NOT a file descriptor and may not be used directly.
- */
-cs_error_t evs_fd_get (
- evs_handle_t handle,
- int *fd);
-
-/**
- * Get contexts for a EVS handle
- */
-cs_error_t evs_context_get (
- evs_handle_t handle,
- void **context);
-
-/**
- * Set contexts for a EVS handle
- */
-cs_error_t evs_context_set (
- evs_handle_t handle,
- void *context);
-
-/**
- * Dispatch messages and configuration changes
- */
-cs_error_t evs_dispatch (
- evs_handle_t handle,
- cs_dispatch_flags_t dispatch_types);
-
-/**
- * Join one or more groups.
- *
- * messages multicasted with evs_mcast_joined will be sent to every
- * group that has been joined on handle handle. Any message multicasted
- * to a group that has been previously joined will be delivered in evs_dispatch
- */
-cs_error_t evs_join (
- evs_handle_t handle,
- const struct evs_group *groups,
- size_t group_cnt);
-
-/**
- * Leave one or more groups
- */
-cs_error_t evs_leave (
- evs_handle_t handle,
- const struct evs_group *groups,
- size_t group_cnt);
-
-/**
- * Multicast to groups joined with evs_join.
- *
- * @param handle
- * @param guarantee
- * @param iovec This iovec will be multicasted to all groups joined with
- * the evs_join interface for handle.
- * @param iov_len
- */
-cs_error_t evs_mcast_joined (
- evs_handle_t handle,
- evs_guarantee_t guarantee,
- const struct iovec *iovec,
- unsigned int iov_len);
-
-/**
- * Multicast to specified groups.
- *
- * Messages will be multicast to groups specified in the api call and not those
- * that have been joined (unless they are in the groups parameter).
- */
-cs_error_t evs_mcast_groups (
- evs_handle_t handle,
- evs_guarantee_t guarantee,
- const struct evs_group *groups,
- size_t group_cnt,
- const struct iovec *iovec,
- unsigned int iov_len);
-
-/**
- * Get membership information from evs
- */
-cs_error_t evs_membership_get (
- evs_handle_t handle,
- unsigned int *local_nodeid,
- unsigned int *member_list,
- size_t *member_list_entries);
-
-#ifdef __cplusplus
-}
-#endif
-
-#endif /* COROSYNC_EVS_H_DEFINED */
diff --git a/include/corosync/ipc_evs.h b/include/corosync/ipc_evs.h
deleted file mode 100644
index 9df5e5b..0000000
--- a/include/corosync/ipc_evs.h
+++ /dev/null
@@ -1,140 +0,0 @@
-/*
- * Copyright (c) 2002-2004 MontaVista Software, Inc.
- * Copyright (c) 2006-2012 Red Hat, Inc.
- *
- * All rights reserved.
- *
- * Author: Steven Dake (sdake@xxxxxxxxxx)
- *
- * 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.
- */
-#ifndef IPC_EVS_H_DEFINED
-#define IPC_EVS_H_DEFINED
-
-#include <inttypes.h>
-#include <corosync/corotypes.h>
-#include <qb/qbipc_common.h>
-#include <corosync/mar_gen.h>
-
-enum req_lib_evs_types {
- MESSAGE_REQ_EVS_JOIN = 0,
- MESSAGE_REQ_EVS_LEAVE = 1,
- MESSAGE_REQ_EVS_MCAST_JOINED = 2,
- MESSAGE_REQ_EVS_MCAST_GROUPS = 3,
- MESSAGE_REQ_EVS_MEMBERSHIP_GET = 4
-};
-
-enum res_lib_evs_types {
- MESSAGE_RES_EVS_DELIVER_CALLBACK = 0,
- MESSAGE_RES_EVS_CONFCHG_CALLBACK = 1,
- MESSAGE_RES_EVS_JOIN = 2,
- MESSAGE_RES_EVS_LEAVE = 3,
- MESSAGE_RES_EVS_MCAST_JOINED = 4,
- MESSAGE_RES_EVS_MCAST_GROUPS = 5,
- MESSAGE_RES_EVS_MEMBERSHIP_GET = 6
-};
-
-struct res_evs_deliver_callback {
- struct qb_ipc_response_header header;
- unsigned int local_nodeid;
- size_t msglen;
- char msg[0];
-};
-
-struct res_evs_confchg_callback {
- struct qb_ipc_response_header header;
- size_t member_list_entries;
- size_t left_list_entries;
- size_t joined_list_entries;
- unsigned int member_list[PROCESSOR_COUNT_MAX];
- unsigned int left_list[PROCESSOR_COUNT_MAX];
- unsigned int joined_list[PROCESSOR_COUNT_MAX];
-};
-
-struct req_lib_evs_join {
- struct qb_ipc_response_header header;
- size_t group_entries;
- struct evs_group groups[0];
-};
-
-struct res_lib_evs_join {
- struct qb_ipc_response_header header;
-};
-
-struct req_lib_evs_leave {
- struct qb_ipc_response_header header;
- size_t group_entries;
- struct evs_group groups[0];
-};
-
-struct res_lib_evs_leave {
- struct qb_ipc_response_header header;
-};
-
-struct req_lib_evs_mcast_joined {
- struct qb_ipc_response_header header;
- evs_guarantee_t guarantee;
- size_t msg_len;
- char msg[0];
-};
-
-struct res_lib_evs_mcast_joined {
- struct qb_ipc_response_header header;
-};
-
-struct req_lib_evs_mcast_groups {
- struct qb_ipc_response_header header;
- evs_guarantee_t guarantee;
- size_t msg_len;
- size_t group_entries;
- struct evs_group groups[0];
-};
-
-struct res_lib_evs_mcast_groups {
- struct qb_ipc_response_header header;
-};
-
-
-struct req_exec_evs_mcast {
- struct qb_ipc_request_header header;
- size_t group_entries;
- size_t msg_len;
- struct evs_group groups[0];
- /* data goes here */
-};
-
-struct req_lib_evs_membership_get {
- struct qb_ipc_request_header header;
-};
-
-struct res_lib_evs_membership_get {
- struct qb_ipc_response_header header;
- unsigned int local_nodeid;
- unsigned int member_list[PROCESSOR_COUNT_MAX];
- size_t member_list_entries;
-};
-#endif /* IPC_EVS_H_DEFINED */
diff --git a/lib/Makefile.am b/lib/Makefile.am
index 58c7b78..5883fe6 100644
--- a/lib/Makefile.am
+++ b/lib/Makefile.am
@@ -46,13 +46,12 @@ AM_LDFLAGS = -lpthread -L../common_lib -lcorosync_common
INCLUDES = -I$(top_builddir)/include -I$(top_srcdir)/include
-lib_LIBRARIES = libcpg.a libquorum.a libevs.a libcfg.a \
+lib_LIBRARIES = libcpg.a libquorum.a libcfg.a \
libvotequorum.a libsam.a libcmap.a
SHARED_LIBS_SO = $(lib_LIBRARIES:%.a=%.so)
libcpg_a_SOURCES = cpg.c
libcfg_a_SOURCES = cfg.c
-libevs_a_SOURCES = evs.c
libquorum_a_SOURCES = quorum.c
libvotequorum_a_SOURCES = votequorum.c
libcmap_a_SOURCES = cmap.c
@@ -62,7 +61,6 @@ libsam_a_SOURCES = sam.c
noinst_HEADERS = util.h \
libcfg.versions \
libcpg.versions \
- libevs.versions \
libquorum.versions libvotequorum.versions \
libsam.versions libcmap.versions
diff --git a/lib/evs.c b/lib/evs.c
deleted file mode 100644
index a5d0b3a..0000000
--- a/lib/evs.c
+++ /dev/null
@@ -1,569 +0,0 @@
-/*
- * vi: set autoindent tabstop=4 shiftwidth=4 :
-
- * Copyright (c) 2004-2005 MontaVista Software, Inc.
- * Copyright (c) 2006-2012 Red Hat, Inc.
- *
- * All rights reserved.
- *
- * Author: Steven Dake (sdake@xxxxxxxxxx)
- *
- * 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.
- */
-/*
- * Provides an extended virtual synchrony API using the corosync executive
- */
-
-#include <config.h>
-
-#include <stdlib.h>
-#include <string.h>
-#include <unistd.h>
-#include <sys/types.h>
-#include <sys/socket.h>
-#include <errno.h>
-
-#include <qb/qbipcc.h>
-
-#include <corosync/corotypes.h>
-#include <corosync/corodefs.h>
-#include <corosync/hdb.h>
-
-#include <corosync/evs.h>
-#include <corosync/ipc_evs.h>
-
-#include "util.h"
-
-struct evs_inst {
- qb_ipcc_connection_t *c;
- int finalize;
- evs_callbacks_t callbacks;
- void *context;
-};
-
-DECLARE_HDB_DATABASE (evs_handle_t_db,NULL);
-
-/*
- * Clean up function for an evt instance (saEvtInitialize) handle
- */
-
-
-/**
- * @defgroup evs_coroipcc The extended virtual synchrony passthrough API
- * @ingroup coroipcc
- *
- * @{
- */
-/**
- * test
- * @param handle The handle of evs initialize
- * @param callbacks The callbacks for evs_initialize
- * @returns CS_OK
- */
-cs_error_t evs_initialize (
- evs_handle_t *handle,
- evs_callbacks_t *callbacks)
-{
- cs_error_t error;
- struct evs_inst *evs_inst;
-
- error = hdb_error_to_cs(hdb_handle_create (&evs_handle_t_db, sizeof (struct evs_inst), handle));
- if (error != CS_OK) {
- goto error_no_destroy;
- }
-
- error = hdb_error_to_cs(hdb_handle_get (&evs_handle_t_db, *handle, (void *)&evs_inst));
- if (error != CS_OK) {
- goto error_destroy;
- }
-
- evs_inst->c = qb_ipcc_connect ("evs", IPC_REQUEST_SIZE);
- if (evs_inst->c == NULL) {
- error = qb_to_cs_error(-errno);
- goto error_put_destroy;
- }
-
- if (callbacks) {
- memcpy (&evs_inst->callbacks, callbacks, sizeof (evs_callbacks_t));
- }
-
- hdb_handle_put (&evs_handle_t_db, *handle);
-
- return (CS_OK);
-
-error_put_destroy:
- hdb_handle_put (&evs_handle_t_db, *handle);
-error_destroy:
- hdb_handle_destroy (&evs_handle_t_db, *handle);
-error_no_destroy:
- return (error);
-}
-
-cs_error_t evs_finalize (
- evs_handle_t handle)
-{
- struct evs_inst *evs_inst;
- cs_error_t error;
-
- error = hdb_error_to_cs(hdb_handle_get (&evs_handle_t_db, handle, (void *)&evs_inst));
- if (error != CS_OK) {
- return (error);
- }
-
- /*
- * Another thread has already started finalizing
- */
- if (evs_inst->finalize) {
- hdb_handle_put (&evs_handle_t_db, handle);
- return (CS_ERR_BAD_HANDLE);
- }
-
- evs_inst->finalize = 1;
-
- qb_ipcc_disconnect (evs_inst->c);
-
- hdb_handle_destroy (&evs_handle_t_db, handle);
-
- hdb_handle_put (&evs_handle_t_db, handle);
-
- return (CS_OK);
-}
-
-cs_error_t evs_fd_get (
- evs_handle_t handle,
- int *fd)
-{
- cs_error_t error;
- struct evs_inst *evs_inst;
-
- error = hdb_error_to_cs(hdb_handle_get (&evs_handle_t_db, handle, (void *)&evs_inst));
- if (error != CS_OK) {
- return (error);
- }
-
- qb_ipcc_fd_get (evs_inst->c, fd);
-
- hdb_handle_put (&evs_handle_t_db, handle);
-
- return (CS_OK);
-}
-
-cs_error_t evs_context_get (
- evs_handle_t handle,
- void **context)
-{
- cs_error_t error;
- struct evs_inst *evs_inst;
-
- error = hdb_error_to_cs (hdb_handle_get (&evs_handle_t_db, handle, (void *)&evs_inst));
- if (error != CS_OK) {
- return (error);
- }
-
- *context = evs_inst->context;
-
- hdb_handle_put (&evs_handle_t_db, handle);
-
- return (CS_OK);
-}
-
-cs_error_t evs_context_set (
- evs_handle_t handle,
- void *context)
-{
- cs_error_t error;
- struct evs_inst *evs_inst;
-
- error = hdb_error_to_cs (hdb_handle_get (&evs_handle_t_db, handle, (void *)&evs_inst));
- if (error != CS_OK) {
- return (error);
- }
-
- evs_inst->context = context;
-
- hdb_handle_put (&evs_handle_t_db, handle);
-
- return (CS_OK);
-}
-
-cs_error_t evs_dispatch (
- evs_handle_t handle,
- cs_dispatch_flags_t dispatch_types)
-{
- int timeout = -1;
- cs_error_t error;
- int cont = 1; /* always continue do loop except when set to 0 */
- struct evs_inst *evs_inst;
- struct res_evs_confchg_callback *res_evs_confchg_callback;
- struct res_evs_deliver_callback *res_evs_deliver_callback;
- evs_callbacks_t callbacks;
- struct qb_ipc_response_header *dispatch_data;
- char dispatch_buf[IPC_DISPATCH_SIZE];
-
- error = hdb_error_to_cs(hdb_handle_get (&evs_handle_t_db, handle, (void *)&evs_inst));
- if (error != CS_OK) {
- return (error);
- }
-
- /*
- * Timeout instantly for CS_DISPATCH_ONE_NONBLOCKING or CS_DISPATCH_ALL and
- * wait indefinately for CS_DISPATCH_ONE or CS_DISPATCH_BLOCKING
- */
- if (dispatch_types == CS_DISPATCH_ALL || dispatch_types == CS_DISPATCH_ONE_NONBLOCKING) {
- timeout = 0;
- }
-
- dispatch_data = (struct qb_ipc_response_header *)dispatch_buf;
- do {
- error = qb_to_cs_error(qb_ipcc_event_recv (
- evs_inst->c,
- dispatch_buf,
- IPC_DISPATCH_SIZE,
- timeout));
- if (error == CS_ERR_BAD_HANDLE) {
- error = CS_OK;
- goto error_put;
- }
- if (error == CS_ERR_TRY_AGAIN) {
- if (dispatch_types == CS_DISPATCH_ONE_NONBLOCKING) {
- /*
- * Don't mask error
- */
- goto error_put;
- }
- error = CS_OK;
- if (dispatch_types == CS_DISPATCH_ALL) {
- break; /* exit do while cont is 1 loop */
- } else {
- continue; /* next poll */
- }
- }
- if (error != CS_OK) {
- goto error_put;
- }
-
- /*
- * Make copy of callbacks, message data, unlock instance, and call callback
- * A risk of this dispatch method is that the callback routines may
- * operate at the same time that evsFinalize has been called.
- */
- memcpy (&callbacks, &evs_inst->callbacks, sizeof (evs_callbacks_t));
-
- /*
- * Dispatch incoming message
- */
- switch (dispatch_data->id) {
- case MESSAGE_RES_EVS_DELIVER_CALLBACK:
- if (callbacks.evs_deliver_fn == NULL) {
- break;
- }
-
- res_evs_deliver_callback = (struct res_evs_deliver_callback *)dispatch_data;
- callbacks.evs_deliver_fn (
- handle,
- res_evs_deliver_callback->local_nodeid,
- &res_evs_deliver_callback->msg,
- res_evs_deliver_callback->msglen);
- break;
-
- case MESSAGE_RES_EVS_CONFCHG_CALLBACK:
- if (callbacks.evs_confchg_fn == NULL) {
- break;
- }
-
- res_evs_confchg_callback = (struct res_evs_confchg_callback *)dispatch_data;
- callbacks.evs_confchg_fn (
- handle,
- res_evs_confchg_callback->member_list,
- res_evs_confchg_callback->member_list_entries,
- res_evs_confchg_callback->left_list,
- res_evs_confchg_callback->left_list_entries,
- res_evs_confchg_callback->joined_list,
- res_evs_confchg_callback->joined_list_entries,
- NULL);
- break;
-
- default:
- error = CS_ERR_LIBRARY;
- goto error_put;
- break;
- }
-
- /*
- * Determine if more messages should be processed
- */
- if (dispatch_types == CS_DISPATCH_ONE || dispatch_types == CS_DISPATCH_ONE_NONBLOCKING) {
- cont = 0;
- }
- } while (cont);
-
-error_put:
- hdb_handle_put (&evs_handle_t_db, handle);
- return (error);
-}
-
-cs_error_t evs_join (
- evs_handle_t handle,
- const struct evs_group *groups,
- size_t group_entries)
-{
- cs_error_t error;
- struct evs_inst *evs_inst;
- struct iovec iov[2];
- struct req_lib_evs_join req_lib_evs_join;
- struct res_lib_evs_join res_lib_evs_join;
-
- error = hdb_error_to_cs(hdb_handle_get (&evs_handle_t_db, handle, (void *)&evs_inst));
- if (error != CS_OK) {
- return (error);
- }
-
- req_lib_evs_join.header.size = sizeof (struct req_lib_evs_join) +
- (group_entries * sizeof (struct evs_group));
- req_lib_evs_join.header.id = MESSAGE_REQ_EVS_JOIN;
- req_lib_evs_join.group_entries = group_entries;
-
- iov[0].iov_base = (void *)&req_lib_evs_join;
- iov[0].iov_len = sizeof (struct req_lib_evs_join);
- iov[1].iov_base = (void*) groups; /* cast away const */
- iov[1].iov_len = (group_entries * sizeof (struct evs_group));
-
- error = qb_to_cs_error(qb_ipcc_sendv_recv (evs_inst->c, iov, 2,
- &res_lib_evs_join, sizeof (struct res_lib_evs_join), CS_IPC_TIMEOUT_MS));
-
- if (error != CS_OK) {
- goto error_exit;
- }
-
- error = res_lib_evs_join.header.error;
-
-error_exit:
- hdb_handle_put (&evs_handle_t_db, handle);
-
- return (error);
-}
-
-cs_error_t evs_leave (
- evs_handle_t handle,
- const struct evs_group *groups,
- size_t group_entries)
-{
- cs_error_t error;
- struct evs_inst *evs_inst;
- struct iovec iov[2];
- struct req_lib_evs_leave req_lib_evs_leave;
- struct res_lib_evs_leave res_lib_evs_leave;
-
- error = hdb_error_to_cs(hdb_handle_get (&evs_handle_t_db, handle, (void *)&evs_inst));
- if (error != CS_OK) {
- return (error);
- }
-
- req_lib_evs_leave.header.size = sizeof (struct req_lib_evs_leave) +
- (group_entries * sizeof (struct evs_group));
- req_lib_evs_leave.header.id = MESSAGE_REQ_EVS_LEAVE;
- req_lib_evs_leave.group_entries = group_entries;
-
- iov[0].iov_base = (void *)&req_lib_evs_leave;
- iov[0].iov_len = sizeof (struct req_lib_evs_leave);
- iov[1].iov_base = (void *) groups; /* cast away const */
- iov[1].iov_len = (group_entries * sizeof (struct evs_group));
-
- error = qb_to_cs_error(qb_ipcc_sendv_recv (evs_inst->c, iov, 2,
- &res_lib_evs_leave, sizeof (struct res_lib_evs_leave), CS_IPC_TIMEOUT_MS));
-
- if (error != CS_OK) {
- goto error_exit;
- }
-
- error = res_lib_evs_leave.header.error;
-
-error_exit:
- hdb_handle_put (&evs_handle_t_db, handle);
-
- return (error);
-}
-
-cs_error_t evs_mcast_joined (
- evs_handle_t handle,
- evs_guarantee_t guarantee,
- const struct iovec *iovec,
- unsigned int iov_len)
-{
- int i;
- cs_error_t error;
- struct evs_inst *evs_inst;
- struct iovec iov[64];
- struct req_lib_evs_mcast_joined req_lib_evs_mcast_joined;
- struct res_lib_evs_mcast_joined res_lib_evs_mcast_joined;
- size_t msg_len = 0;
-
- error = hdb_error_to_cs(hdb_handle_get (&evs_handle_t_db, handle, (void *)&evs_inst));
- if (error != CS_OK) {
- return (error);
- }
-
- for (i = 0; i < iov_len; i++ ) {
- msg_len += iovec[i].iov_len;
- }
-
- req_lib_evs_mcast_joined.header.size = sizeof (struct req_lib_evs_mcast_joined) +
- msg_len;
-
- req_lib_evs_mcast_joined.header.id = MESSAGE_REQ_EVS_MCAST_JOINED;
- req_lib_evs_mcast_joined.guarantee = guarantee;
- req_lib_evs_mcast_joined.msg_len = msg_len;
-
- iov[0].iov_base = (void *)&req_lib_evs_mcast_joined;
- iov[0].iov_len = sizeof (struct req_lib_evs_mcast_joined);
- memcpy (&iov[1], iovec, iov_len * sizeof (struct iovec));
-
- error = qb_to_cs_error(qb_ipcc_sendv_recv (evs_inst->c, iov,
- iov_len + 1,
- &res_lib_evs_mcast_joined,
- sizeof (struct res_lib_evs_mcast_joined), CS_IPC_TIMEOUT_MS));
-
- if (error != CS_OK) {
- goto error_exit;
- }
-
- error = res_lib_evs_mcast_joined.header.error;
-
-error_exit:
- hdb_handle_put (&evs_handle_t_db, handle);
-
- return (error);
-}
-
-cs_error_t evs_mcast_groups (
- evs_handle_t handle,
- evs_guarantee_t guarantee,
- const struct evs_group *groups,
- size_t group_entries,
- const struct iovec *iovec,
- unsigned int iov_len)
-{
- int i;
- cs_error_t error;
- struct evs_inst *evs_inst;
- struct iovec iov[64]; /* FIXME: what if iov_len > 62 ? use malloc */
- struct req_lib_evs_mcast_groups req_lib_evs_mcast_groups;
- struct res_lib_evs_mcast_groups res_lib_evs_mcast_groups;
- size_t msg_len = 0;
-
- error = hdb_error_to_cs(hdb_handle_get (&evs_handle_t_db, handle, (void *)&evs_inst));
- if (error != CS_OK) {
- return (error);
- }
- for (i = 0; i < iov_len; i++) {
- msg_len += iovec[i].iov_len;
- }
- req_lib_evs_mcast_groups.header.size = sizeof (struct req_lib_evs_mcast_groups) +
- (group_entries * sizeof (struct evs_group)) + msg_len;
- req_lib_evs_mcast_groups.header.id = MESSAGE_REQ_EVS_MCAST_GROUPS;
- req_lib_evs_mcast_groups.guarantee = guarantee;
- req_lib_evs_mcast_groups.msg_len = msg_len;
- req_lib_evs_mcast_groups.group_entries = group_entries;
-
- iov[0].iov_base = (void *)&req_lib_evs_mcast_groups;
- iov[0].iov_len = sizeof (struct req_lib_evs_mcast_groups);
- iov[1].iov_base = (void *) groups; /* cast away const */
- iov[1].iov_len = (group_entries * sizeof (struct evs_group));
- memcpy (&iov[2], iovec, iov_len * sizeof (struct iovec));
-
- error = qb_to_cs_error(qb_ipcc_sendv_recv (evs_inst->c, iov,
- iov_len + 2,
- &res_lib_evs_mcast_groups,
- sizeof (struct res_lib_evs_mcast_groups), CS_IPC_TIMEOUT_MS));
-
- if (error != CS_OK) {
- goto error_exit;
- }
-
- error = res_lib_evs_mcast_groups.header.error;
-
-error_exit:
- hdb_handle_put (&evs_handle_t_db, handle);
-
- return (error);
-}
-
-cs_error_t evs_membership_get (
- evs_handle_t handle,
- unsigned int *local_nodeid,
- unsigned int *member_list,
- size_t *member_list_entries)
-{
- cs_error_t error;
- struct evs_inst *evs_inst;
- struct iovec iov;
- struct req_lib_evs_membership_get req_lib_evs_membership_get;
- struct res_lib_evs_membership_get res_lib_evs_membership_get;
-
- error = hdb_error_to_cs(hdb_handle_get (&evs_handle_t_db, handle, (void *)&evs_inst));
- if (error != CS_OK) {
- return (error);
- }
-
- req_lib_evs_membership_get.header.size = sizeof (struct req_lib_evs_membership_get);
- req_lib_evs_membership_get.header.id = MESSAGE_REQ_EVS_MEMBERSHIP_GET;
-
- iov.iov_base = (void *)&req_lib_evs_membership_get;
- iov.iov_len = sizeof (struct req_lib_evs_membership_get);
-
- error = qb_to_cs_error(qb_ipcc_sendv_recv (evs_inst->c,
- &iov,
- 1,
- &res_lib_evs_membership_get,
- sizeof (struct res_lib_evs_membership_get), CS_IPC_TIMEOUT_MS));
-
- if (error != CS_OK) {
- goto error_exit;
- }
-
- error = res_lib_evs_membership_get.header.error;
-
- /*
- * Copy results to caller
- */
- if (local_nodeid) {
- *local_nodeid = res_lib_evs_membership_get.local_nodeid;
- }
- *member_list_entries = QB_MIN (*member_list_entries,
- res_lib_evs_membership_get.member_list_entries);
- if (member_list) {
- memcpy (member_list, &res_lib_evs_membership_get.member_list,
- *member_list_entries * sizeof (struct in_addr));
- }
-
-error_exit:
- hdb_handle_put (&evs_handle_t_db, handle);
-
- return (error);
-}
-
-/** @} */
diff --git a/lib/libevs.versions b/lib/libevs.versions
deleted file mode 100644
index abcaf50..0000000
--- a/lib/libevs.versions
+++ /dev/null
@@ -1,14 +0,0 @@
-# Version and symbol export for libSaClm.so
-
-COROSYNC_EVS_2.0 {
- global:
- evs_initialize;
- evs_finalize;
- evs_fd_get;
- evs_dispatch;
- evs_join;
- evs_leave;
- evs_mcast_joined;
- evs_mcast_groups;
- evs_membership_get;
-};
diff --git a/lib/libevs.verso b/lib/libevs.verso
deleted file mode 100644
index fcdb2e1..0000000
--- a/lib/libevs.verso
+++ /dev/null
@@ -1 +0,0 @@
-4.0.0
diff --git a/man/Makefile.am b/man/Makefile.am
index 54b1e19..b4be1c6 100644
--- a/man/Makefile.am
+++ b/man/Makefile.am
@@ -57,17 +57,6 @@ autogen_man = cpg_context_get.3 \
cpg_iteration_finalize.3 \
cpg_iteration_initialize.3 \
cpg_iteration_next.3 \
- evs_dispatch.3 \
- evs_fd_get.3 \
- evs_finalize.3 \
- evs_initialize.3 \
- evs_join.3 \
- evs_leave.3 \
- evs_mcast_groups.3 \
- evs_mcast_joined.3 \
- evs_membership_get.3 \
- evs_context_get.3 \
- evs_context_set.3 \
quorum_initialize.3 \
quorum_finalize.3 \
quorum_fd_get.3 \
@@ -139,7 +128,6 @@ dist_man_MANS = corosync.conf.5 \
corosync-quorumtool.8 \
corosync_overview.8 \
cpg_overview.8 \
- evs_overview.8 \
quorum_overview.8 \
votequorum_overview.8 \
sam_overview.8 \
diff --git a/man/corosync.conf.5 b/man/corosync.conf.5
index 3fe4da5..7cd1824 100644
--- a/man/corosync.conf.5
+++ b/man/corosync.conf.5
@@ -214,10 +214,6 @@ of 8982 seems to work for the few large frame devices that have been tested.
Some manufacturers claim large frame support when in fact they support frame
sizes of 4500 bytes.
-Increasing the MTU from 1500 to 8982 doubles throughput performance from 30MB/sec
-to 60MB/sec as measured with evsbench with 175000 byte messages with the secauth
-directive set to off.
-
When sending multicast traffic, if the network frequently reconfigures, chances are
that some device in the network doesn't support large frames.
diff --git a/man/corosync_overview.8 b/man/corosync_overview.8
index fb3766f..999ced9 100644
--- a/man/corosync_overview.8
+++ b/man/corosync_overview.8
@@ -56,9 +56,9 @@ Corosync. Corosync is designed for applications to replicate their state to
up to 16 processors. The processors all contain a replica of the application
state.
-The corosync project provides two group message APIs called CPG and EVS.
+The corosync project provides a group message API called CPG.
The project developers recommend CPG be used for most applications. The CPG
-service implmeents a closed group messaging model presenting extended virtual
+service implements a closed group messaging model presenting extended virtual
synchrony guarantees.
To manage conditions where the process executing the CPG application exchange
@@ -168,8 +168,7 @@ The default is /etc/corosync/authkey.
The corosync executive optionally encrypts all messages sent over the network
using the SOBER-128 stream cipher. The corosync executive uses HMAC and SHA1 to
authenticate all messages. The corosync executive library uses SOBER-128
-as a pseudo random number generator. The EVS library feeds the PRNG using
-the /dev/random Linux device.
+as a pseudo random number generator.
If membership messages can be captured by intruders, it is possible to execute
a denial of service attack on the cluster. In this scenario, the cluster is
@@ -191,7 +190,6 @@ None that are known.
.SH "SEE ALSO"
.BR corosync.conf (5),
.BR corosync-keygen (8),
-.BR evs_overview (8),
.BR cpg_overview (8),
.BR sam_overview (8)
.PP
diff --git a/man/evs_context_get.3.in b/man/evs_context_get.3.in
deleted file mode 100644
index 9ef4d3a..0000000
--- a/man/evs_context_get.3.in
+++ /dev/null
@@ -1,64 +0,0 @@
-.\"/*
-.\" * Copyright (c) 2007 Red Hat, Inc.
-.\" *
-.\" * All rights reserved.
-.\" *
-.\" * Author: Patrick Caulfield <pcaulfie@xxxxxxxxxx>
-.\" *
-.\" * 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.
-.\" */
-.TH EVS_CONTEXT_GET 3 2004-08-31 "corosync Man Page" "Corosync Cluster Engine Programmer's Manual"
-.SH NAME
-evs_context_get \- Gets the context variable for a EVS instance
-.SH SYNOPSIS
-.B #include <corosync/evs.h>
-.sp
-.BI "int evs_context_get(evs_handle_t " handle ", void **" context ");
-.SH DESCRIPTION
-The
-.B evs_context_get
-function is used to retrieve the context variable previously stored using
-.B evs_context_set(3)
-.SH RETURN VALUE
-This call returns the CS_OK value if successful, otherwise an error is returned.
-.PP
-.SH ERRORS
-The errors are undocumented.
-.SH "SEE ALSO"
-.BR evs_overview (8),
-.BR evs_initialize (3),
-.BR evs_finalize (3),
-.BR evs_fd_get (3),
-.BR evs_dispatch (3),
-.BR evs_join (3),
-.BR evs_leave (3),
-.BR evs_mcast_joined (3),
-.BR evs_mcast_groups (3),
-.BR evs_mmembership_get (3)
-.BR evs_context_get (3)
-.BR evs_context_set (3)
-.PP
diff --git a/man/evs_context_set.3.in b/man/evs_context_set.3.in
deleted file mode 100644
index 19d279f..0000000
--- a/man/evs_context_set.3.in
+++ /dev/null
@@ -1,66 +0,0 @@
-.\"/*
-.\" * Copyright (c) 2007 Red Hat, Inc.
-.\" *
-.\" * All rights reserved.
-.\" *
-.\" * Author: Patrick Caulfield <pcaulfie@xxxxxxxxxx>
-.\" *
-.\" * 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.
-.\" */
-.TH EVS_CONTEXT_SET 3 2004-08-31 "corosync Man Page" "Corosync Cluster Engine Programmer's Manual"
-.SH NAME
-evs_context_set \- Sets the context variable for a EVS instance
-.SH SYNOPSIS
-.B #include <corosync/evs.h>
-.sp
-.BI "int evs_context_set(evs_handle_t " handle ", void *" context ");
-.SH DESCRIPTION
-The
-.B evs_context_set
-function is used to set the context variable for a evs instance. It has no
-meaning insire libevs itself and will not be touched by the library. It can
-be retrieved using
-.B evs_context_get(3)
-.SH RETURN VALUE
-This call returns the CS_OK value if successful, otherwise an error is returned.
-.PP
-.SH ERRORS
-The errors are undocumented.
-.SH "SEE ALSO"
-.BR evs_overview (8),
-.BR evs_initialize (3),
-.BR evs_finalize (3),
-.BR evs_fd_get (3),
-.BR evs_dispatch (3),
-.BR evs_join (3),
-.BR evs_leave (3),
-.BR evs_mcast_joined (3),
-.BR evs_mcast_groups (3),
-.BR evs_mmembership_get (3)
-.BR evs_context_get (3)
-.BR evs_context_set (3)
-.PP
diff --git a/man/evs_dispatch.3.in b/man/evs_dispatch.3.in
deleted file mode 100644
index 2624a42..0000000
--- a/man/evs_dispatch.3.in
+++ /dev/null
@@ -1,107 +0,0 @@
-.\"/*
-.\" * Copyright (c) 2004 MontaVista Software, Inc.
-.\" *
-.\" * All rights reserved.
-.\" *
-.\" * Author: Steven Dake (sdake@xxxxxxxxxx)
-.\" *
-.\" * 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.
-.\" */
-.TH EVS_DISPATCH 3 2004-08-31 "corosync Man Page" "Corosync Cluster Engine Programmer's Manual"
-.SH NAME
-evs_dispatch \- Dispatches callbacks from the EVS service
-.SH SYNOPSIS
-.B #include <corosync/evs.h>
-.sp
-.BI "int evs_dispatch(evs_handle_t " handle ", evs_dispatch_t *" dispatch_types ");
-.SH DESCRIPTION
-The
-.B evs_dispatch
-function is used to dispatch configuration changes or messages from the
-extended virtual synchrony API.
-.PP
-Each application may have several connections to the EVS API. Each application
-uses the
-.I handle
-argument to uniquely identify the connection.
-.PP
-The
-.I dispatch_types
-argument is used to identify the type of dispatch to execute. The possible types are
-defined by the structure:
-
-.IP
-.RS
-.ne 18
-.nf
-.ta 4n 30n 33n
-typedef enum {
- CS_DISPATCH_ONE,
- CS_DISPATCH_ALL,
- CS_DISPATCH_BLOCKING
-} cs_dispatch_flags_t;
-.ta
-.fi
-.RE
-.IP
-.PP
-.PP
-The dispatch values have the following meanings:
-.TP
-.B CS_DISPATCH_ONE
-Dispatch atleast one callback, blocking until the callback is dispatched.
-.TP
-.B CS_DISPATCH_ALL
-Dispatch all waiting callbacks without blocking to wait for any callbacks.
-.TP
-.B CS_DISPATCH_BLOCKING
-Dispatch all callbacks blocking indefinately. This is used in a threaded
-program where a thread is created, and then evs_dispatch() is called immediately
-from the created thread to execute callbacks.
-.TP
-.B CS_DISPATCH_ONE_NONBLOCKING
-Dispatch at most one callback. If there is no pending callback,
-CS_ERR_TRY_AGAIN is returned.
-
-.SH RETURN VALUE
-This call returns the CS_OK value if successful, otherwise an error is returned.
-.PP
-.SH ERRORS
-The errors are undocumented.
-.SH "SEE ALSO"
-.BR evs_overview (8),
-.BR evs_initialize (3),
-.BR evs_finalize (3),
-.BR evs_fd_get (3),
-.BR evs_join (3),
-.BR evs_leave (3),
-.BR evs_mcast_joined (3),
-.BR evs_mcast_groups (3),
-.BR evs_mmembership_get (3)
-.BR evs_context_get (3)
-.BR evs_context_set (3)
-.PP
diff --git a/man/evs_fd_get.3.in b/man/evs_fd_get.3.in
deleted file mode 100644
index ece9036..0000000
--- a/man/evs_fd_get.3.in
+++ /dev/null
@@ -1,70 +0,0 @@
-.\"/*
-.\" * Copyright (c) 2004 MontaVista Software, Inc.
-.\" *
-.\" * All rights reserved.
-.\" *
-.\" * Author: Steven Dake (sdake@xxxxxxxxxx)
-.\" *
-.\" * 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.
-.\" */
-.TH EVS_FD_GET 3 2004-08-31 "corosync Man Page" "Corosync Cluster Engine Programmer's Manual"
-.SH NAME
-evs_fd_get \- Dispatches callbacks from the EVS service
-.SH SYNOPSIS
-.B #include <corosync/evs.h>
-.sp
-.BI "int evs_fd_get(evs_handle_t " handle ", int *" fd ");
-.SH DESCRIPTION
-The
-.B evs_fd_get
-function is used to retrieve the file descriptor that may be used with the poll
-system call to determine when
-.B evs_dispatch(3)
-won't block. The
-.I handle
-argument may not be used directly with
-.B poll
-because it is not the file descriptor, but instead an internal identifier used
-by the EVS library.
-.SH RETURN VALUE
-This call returns the CS_OK value if successful, otherwise an error is returned.
-.PP
-.SH ERRORS
-The errors are undocumented.
-.SH "SEE ALSO"
-.BR evs_overview (8),
-.BR evs_initialize (3),
-.BR evs_finalize (3),
-.BR evs_dispatch (3),
-.BR evs_join (3),
-.BR evs_leave (3),
-.BR evs_mcast_joined (3),
-.BR evs_mcast_groups (3),
-.BR evs_mmembership_get (3)
-.BR evs_context_get (3)
-.BR evs_context_set (3)
-.PP
diff --git a/man/evs_finalize.3.in b/man/evs_finalize.3.in
deleted file mode 100644
index cc2c697..0000000
--- a/man/evs_finalize.3.in
+++ /dev/null
@@ -1,66 +0,0 @@
-.\"/*
-.\" * Copyright (c) 2004 MontaVista Software, Inc.
-.\" *
-.\" * All rights reserved.
-.\" *
-.\" * Author: Steven Dake (sdake@xxxxxxxxxx)
-.\" *
-.\" * 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.
-.\" */
-.TH EVS_FINALIZE 3 2004-08-31 "corosync Man Page" "Corosync Cluster Engine Programmer's Manual"
-.SH NAME
-evs_finalize \- Terminate a connection to the EVS service
-.SH SYNOPSIS
-.B #include <corosync/evs.h>
-.sp
-.BI "int evs_finalize(evs_handle_t " handle ");
-.SH DESCRIPTION
-The
-.B evs_finalize
-function is used to close a connection to the extended virtual synchrony API.
-Once the connection is finalized, the handle may not be used again by applications.
-No more callbacks will be dispatched from the
-.B evs_dispatch function.
-.PP
-.SH RETURN VALUE
-This call returns the CS_OK value if successful, otherwise an error is returned.
-.PP
-.SH ERRORS
-The errors are undocumented.
-.SH "SEE ALSO"
-.BR evs_overview (8),
-.BR evs_initialize (3),
-.BR evs_fd_get (3),
-.BR evs_dispatch (3),
-.BR evs_join (3),
-.BR evs_leave (3),
-.BR evs_mcast_joined (3),
-.BR evs_mcast_groups (3),
-.BR evs_mmembership_get (3)
-.BR evs_context_get (3)
-.BR evs_context_set (3)
-.PP
diff --git a/man/evs_initialize.3.in b/man/evs_initialize.3.in
deleted file mode 100644
index c5bd4dd..0000000
--- a/man/evs_initialize.3.in
+++ /dev/null
@@ -1,121 +0,0 @@
-.\"/*
-.\" * Copyright (c) 2004 MontaVista Software, Inc.
-.\" *
-.\" * All rights reserved.
-.\" *
-.\" * Author: Steven Dake (sdake@xxxxxxxxxx)
-.\" *
-.\" * 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.
-.\" */
-.TH EVS_INITIALIZE 3 2004-08-31 "corosync Man Page" "Corosync Cluster Engine Programmer's Manual"
-.SH NAME
-evs_initialize \- Create a new connection to the EVS service
-.SH SYNOPSIS
-.B #include <corosync/evs.h>
-.sp
-.BI "int evs_initialize(evs_handle_t *" handle ", evs_callbacks_t *" callbacks ");
-.SH DESCRIPTION
-The
-.B evs_initialize
-function is used to initialize a connection to the extended virtual synchrony API.
-.PP
-Each application may have several connections to the EVS API. Each application
-uses the
-.I handle
-argument to uniquely identify the connection. The
-.I handle
-argument is then used in other function calls to identify the connection to be used
-for communication with the EVS service.
-.PP
-Every time an EVS event occurs, one of the callbacks specified by the argument
-.I callbacks
-is called. The callback functions are described by the following type definitions:
-.PP
-.IP
-.RS
-.ne 18
-.nf
-.ta 4n 20n 32n
-typedef void (*evs_deliver_fn_t) (
- unsigned int nodeid,
- const void *msg,
- size_t msg_len);
-
-typedef void (*evs_confchg_fn_t) (
- unsigned int *member_list, size_t member_list_entries,
- unsigned int *left_list, size_t left_list_entries,
- unsigned int *joined_list, size_t joined_list_entries);
-.ta
-.fi
-.RE
-.IP
-.PP
-.PP
-The
-.I callbacks
-argument is of the type:
-.IP
-.RS
-.ne 18
-.nf
-.PP
-typedef struct {
- evs_deliver_fn_t evs_deliver_fn;
- evs_confchg_fn_t evs_confchg_fn;
-} evs_callbacks_t;
-.ta
-.fi
-.RE
-.IP
-.PP
-When a configuration change occurs or a message is to be delivered one of the callbacks
-is called from the
-.B evs_dispatch()
-function. If a configuration change occurs,
-.I evs_confchg_fn
-is called. If a delivery of a message occurs,
-.I evs_deliver_fn
-is called.
-
-.SH RETURN VALUE
-This call returns the CS_OK value if successful, otherwise an error is returned.
-.PP
-.SH ERRORS
-The errors are undocumented.
-.SH "SEE ALSO"
-.BR evs_overview (8),
-.BR evs_finalize (3),
-.BR evs_fd_get (3),
-.BR evs_dispatch (3),
-.BR evs_join (3),
-.BR evs_leave (3),
-.BR evs_mcast_joined (3),
-.BR evs_mcast_groups (3),
-.BR evs_mmembership_get (3)
-.BR evs_context_get (3)
-.BR evs_context_set (3)
-.PP
diff --git a/man/evs_join.3.in b/man/evs_join.3.in
deleted file mode 100644
index e6338d4..0000000
--- a/man/evs_join.3.in
+++ /dev/null
@@ -1,105 +0,0 @@
-.\"/*
-.\" * Copyright (c) 2004 MontaVista Software, Inc.
-.\" *
-.\" * All rights reserved.
-.\" *
-.\" * Author: Steven Dake (sdake@xxxxxxxxxx)
-.\" *
-.\" * 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.
-.\" */
-.TH EVS_JOIN 3 2004-08-31 "corosync Man Page" "Corosync Cluster Engine Programmer's Manual"
-.SH NAME
-evs_join \- Joins one or more groups in the EVS library
-.SH SYNOPSIS
-.B #include <corosync/evs.h>
-.sp
-.BI "int evs_join(evs_handle_t " handle ", evs_group_t *" groups ", int " group_entries ");
-.SH DESCRIPTION
-The
-.B evs_join
-function is used to join one or more groups. When a group is joined, using the
-.B evs_mcast_joined(3)
-function will multicast to the groups joined in the argument
-.I handle.
-Messages that are sent to any of the groups joined to the parameter
-.I handle
-will be delivered by
-.B evs_dispatch(3).
-.PP
-This call may be used more then once on a handle, in which case the joined groups will
-be all of the groups passed to the
-.B evs_join(3)
-function during the lifecycle of the parameter
-.I handle.
-.PP
-
-The argument
-.I groups
-is used to specify the groups to join. A group is a 32 byte key. The key is
-not a string, hence, the entire key is used when joining the channel. For that reason
-the entire group should be initialized.
-.PP
-The argument
-.I group_entries
-specifies how many entries are located in the groups argument.
-
-The
-.I groups
-argument is of the type evs_group_t which is defined by the structure:
-
-.IP
-.RS
-.ne 18
-.nf
-.ta 4n 30n 33n
-typedef struct {
- char key[32];
-} evs_groups_t;
-.ta
-.fi
-.RE
-.IP
-.PP
-.PP
-.SH RETURN VALUE
-This call returns the CS_OK value if successful, otherwise an error is returned.
-.PP
-.SH ERRORS
-The errors are undocumented.
-.SH "SEE ALSO"
-.BR evs_overview (8),
-.BR evs_initialize (3),
-.BR evs_finalize (3),
-.BR evs_fd_get (3),
-.BR evs_dispatch (3),
-.BR evs_leave (3),
-.BR evs_mcast_joined (3),
-.BR evs_mcast_groups (3),
-.BR evs_mmembership_get (3)
-.BR evs_context_get (3)
-.BR evs_context_set (3)
-.PP
diff --git a/man/evs_leave.3.in b/man/evs_leave.3.in
deleted file mode 100644
index 09ffe8e..0000000
--- a/man/evs_leave.3.in
+++ /dev/null
@@ -1,100 +0,0 @@
-.\"/*
-.\" * Copyright (c) 2004 MontaVista Software, Inc.
-.\" *
-.\" * All rights reserved.
-.\" *
-.\" * Author: Steven Dake (sdake@xxxxxxxxxx)
-.\" *
-.\" * 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.
-.\" */
-.TH EVS_LEAVE 3 2004-08-31 "corosync Man Page" "Corosync Cluster Engine Programmer's Manual"
-.SH NAME
-evs_leave \- Leave one or more groups in the EVS library
-.SH SYNOPSIS
-.B #include <corosync/evs.h>
-.sp
-.BI "int evs_leave(evs_handle_t " handle ", evs_group_t *" groups ", int group_entries);
-.SH DESCRIPTION
-The
-.B evs_leave
-function is used to leave one or more groups. The joined groups are used with
-.B evs_mcast_joined(3)
-function to multicast to the groups joined in the argument
-.I handle.
-Messages that are sent to any of the joined groups to the parameter
-.I handle
-will be delivered by
-.B evs_dispatch(3).
-.PP
-This call may be used more then once on a handle.
-.PP
-
-The argument
-.I groups
-is used to specify the groups to leave. A group is a 32 byte key. The key is
-not a string, hence, the entire key is used when leaveing the channel. For that reason
-the entire group should be initialized.
-.PP
-The argument
-.I group_entries
-specifies how many entries are located in the groups argument.
-
-The
-.I groups
-argument is of the type evs_group_t which is defined by the structure:
-
-.IP
-.RS
-.ne 18
-.nf
-.ta 4n 30n 33n
-typedef struct {
- char key[32];
-} evs_groups_t;
-.ta
-.fi
-.RE
-.IP
-.PP
-.SH RETURN VALUE
-This call returns the CS_OK value if successful, otherwise an error is returned.
-.PP
-.SH ERRORS
-The errors are undocumented.
-.SH "SEE ALSO"
-.BR evs_overview (8),
-.BR evs_initialize (3),
-.BR evs_finalize (3),
-.BR evs_fd_get (3),
-.BR evs_dispatch (3),
-.BR evs_join (3),
-.BR evs_mcast_joined (3),
-.BR evs_mcast_groups (3),
-.BR evs_mmembership_get (3)
-.BR evs_context_get (3)
-.BR evs_context_set (3)
-.PP
diff --git a/man/evs_mcast_groups.3.in b/man/evs_mcast_groups.3.in
deleted file mode 100644
index 4bb5c00..0000000
--- a/man/evs_mcast_groups.3.in
+++ /dev/null
@@ -1,164 +0,0 @@
-.\"/*
-.\" * Copyright (c) 2004 MontaVista Software, Inc.
-.\" *
-.\" * All rights reserved.
-.\" *
-.\" * Author: Steven Dake (sdake@xxxxxxxxxx)
-.\" *
-.\" * 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.
-.\" */
-.TH EVS_MCAST_GROUPS 3 2004-08-31 "corosync Man Page" "Corosync Cluster Engine Programmer's Manual"
-.SH NAME
-evs_join \- Multicast a message to selected groups
-.SH SYNOPSIS
-.B #include <sys/uio.h>
-.B #include <corosync/evs.h>
-.sp
-.BI "int evs_mcast_groups(evs_handle_t " handle ", evs_guraantee_t " guarantee ", evs_group_t *" groups ", int group_entries, struct iovec *" iovec ", int " iov_len ");
-.SH DESCRIPTION
-The
-.B evs_mcast_groups(3)
-function multicasts a message to all the groups specified in the arguemnt
-.I groups.
-Messages are delivered to all processors in the system that are described by the current
-configuration.
-.PP
-The argument
-.I handle
-describes a handle created with
-.B evs_initialize(3).
-.PP
-The argument
-.I guarantee
-requests a delivery guarantee for the message to be sent. The evs_guarantee_t type is
-defined by:
-.IP
-.RS
-.ne 18
-.nf
-.ta 4n 30n 33n
-typedef enum {
- EVS_TYPE_UNORDERED, /* not implemented */
- EVS_TYPE_FIFO, /* same as agreed */
- EVS_TYPE_AGREED, /* implemented */
- EVS_TYPE_SAFE /* not implemented */
-} evs_guarantee_t;
-.ta
-.fi
-.RE
-.IP
-.PP
-.PP
-The meanings of the evs_guarantee_t typedef are:
-.TP
-.B EVS_GUARANTEE_UNORDERED
-Messages are guaranteed to be delivered, but with no particular order. This
-mode is unimplemented in the EVS library.
-.TP
-.B EVS_GUARANTEE_FIFO
-Messages are guaranteed to be delivered in first sent first delivery order
-from one one. In fact, this guarantee is actually the AGREED guarantee.
-.TP
-.B EVS_GUARANTEE_AGREED
-All processors must agree on the order of delivery. If a message is sent
-from two or more processors at about the same time, the delivery will occur
-in the same order to all processors.
-.TP
-.B EVS_GUARANTEE_SAFE
-All processors must agree on the order of delivery. Further all processors
-must have a copy of the message before any delivery takes place. This mode is
-unimplemented in the EVS library.
-.PP
-The
-.I groups
-argument is of the type evs_group_t which is defined by the structure:
-
-.IP
-.RS
-.ne 18
-.nf
-.ta 4n 30n 33n
-typedef struct {
- char key[32];
-} evs_groups_t;
-.ta
-.fi
-.RE
-.IP
-.PP
-.PP
-The
-.I group_entries
-argument describes the number of entries in the
-.I group
-argument.
-.PP
-
-The
-.I iovec
-argument describes the scatter/gather list which is used to transmit a message. This
-is a standard socket structure described by:
-.IP
-.RS
-.ne 18
-.nf
-.ta 4n 30n 33n
-struct iovec
-{
- void *iov_base; /* Pointer to data. */
- unsigned int iov_len; /* Length of data. */
-};
-.ta
-.fi
-.RE
-.IP
-.PP
-.PP
-The
-.I iovlen
-argument describes the number of entires in the
-.I iovec
-argument.
-
-.SH RETURN VALUE
-This call returns the CS_OK value if successful, otherwise an error is returned.
-.PP
-.SH ERRORS
-The errors are undocumented.
-.SH "SEE ALSO"
-.BR evs_overview (8),
-.BR evs_initialize (3),
-.BR evs_finalize (3),
-.BR evs_fd_get (3),
-.BR evs_dispatch (3),
-.BR evs_leave (3),
-.BR evs_join (3),
-.BR evs_mcast_joined (3),
-.BR evs_mmembership_get (3)
-.BR evs_context_get (3)
-.BR evs_context_set (3)
-.PP
diff --git a/man/evs_mcast_joined.3.in b/man/evs_mcast_joined.3.in
deleted file mode 100644
index 4d7d78e..0000000
--- a/man/evs_mcast_joined.3.in
+++ /dev/null
@@ -1,137 +0,0 @@
-.\"/*
-.\" * Copyright (c) 2004 MontaVista Software, Inc.
-.\" *
-.\" * All rights reserved.
-.\" *
-.\" * Author: Steven Dake (sdake@xxxxxxxxxx)
-.\" *
-.\" * 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.
-.\" */
-.TH EVS_MCAST_JOINED 3 3004-08-31 "corosync Man Page" "Corosync Cluster Engine Programmer's Manual"
-.SH NAME
-evs_join \- Multicasts to all groups joined to an handle
-.SH SYNOPSIS
-.B #include <sys/uio.h>
-.B #include <corosync/evs.h>
-.sp
-.BI "int evs_mcast_joined(evs_handle_t " handle ", evs_guraantee_t " guarantee ", struct iovec *" iovec ", int " iov_len ");
-.SH DESCRIPTION
-The
-.B evs_mcast_joined
-function is multicast a message to all the groups that have been joined with the
-.B evs_join(3)
-function for the argument
-.I handle.
-Messages that are sent to any of the groups joined to the parameter
-.I handle
-will be delivered to all processors in the system.
-.PP
-The argument
-.I guarantee
-requests a delivery guarantee for the message to be sent. The evs_guarantee_t type is
-defined by:
-.IP
-.RS
-.ne 18
-.nf
-.ta 4n 30n 33n
-typedef enum {
- EVS_TYPE_UNORDERED, /* not implemented */
- EVS_TYPE_FIFO, /* same as agreed */
- EVS_TYPE_AGREED, /* implemented */
- EVS_TYPE_SAFE /* not implemented */
-} evs_guarantee_t;
-.ta
-.fi
-.RE
-.IP
-.PP
-.PP
-The meanings of the evs_guarantee_t typedef are:
-.TP
-.B EVS_GUARANTEE_UNORDERED
-Messages are guaranteed to be delivered, but with no particular order. This
-mode is unimplemented in the EVS library.
-.TP
-.B EVS_GUARANTEE_FIFO
-Messages are guaranteed to be delivered in first sent first delivery order
-from one one. In fact, this guarantee is actually the AGREED guarantee.
-.TP
-.B EVS_GUARANTEE_AGREED
-All processors must agree on the order of delivery. If a message is sent
-from two or more processors at about the same time, the delivery will occur
-in the same order to all processors.
-.TP
-.B EVS_GUARANTEE_SAFE
-All processors must agree on the order of delivery. Further all processors
-must have a copy of the message before any delivery takes place. This mode is
-unimplemented in the EVS library.
-.PP
-The
-.I iovec
-argument describes the scatter/gather list which is used to transmit a message. This
-is a standard socket structure described by:
-.IP
-.RS
-.ne 18
-.nf
-.ta 4n 30n 33n
-struct iovec
-{
- void *iov_base; /* Pointer to data. */
- unsigned int iov_len; /* Length of data. */
-};
-.ta
-.fi
-.RE
-.IP
-.PP
-.PP
-The
-.I iovlen
-argument describes the number of entires in the
-.I iovec
-argument.
-
-.SH RETURN VALUE
-This call returns the CS_OK value if successful, otherwise an error is returned.
-.PP
-.SH ERRORS
-The errors are undocumented.
-.SH "SEE ALSO"
-.BR evs_overview (8),
-.BR evs_initialize (3),
-.BR evs_finalize (3),
-.BR evs_fd_get (3),
-.BR evs_dispatch (3),
-.BR evs_leave (3),
-.BR evs_join (3),
-.BR evs_mcast_groups (3),
-.BR evs_mmembership_get (3)
-.BR evs_context_get (3)
-.BR evs_context_set (3)
-.PP
diff --git a/man/evs_membership_get.3.in b/man/evs_membership_get.3.in
deleted file mode 100644
index 657b243..0000000
--- a/man/evs_membership_get.3.in
+++ /dev/null
@@ -1,74 +0,0 @@
-.\"/*
-.\" * Copyright (c) 2004 MontaVista Software, Inc.
-.\" *
-.\" * All rights reserved.
-.\" *
-.\" * Author: Steven Dake (sdake@xxxxxxxxxx)
-.\" *
-.\" * 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.
-.\" */
-.TH EVS_JOIN 3 2004-08-31 "corosync Man Page" "Corosync Cluster Engine Programmer's Manual"
-.SH NAME
-evs_join \- Joins one or more groups in the EVS library
-.SH SYNOPSIS
-.B #include <corosync/evs.h>
-.sp
-.BI "int evs_membership_get(evs_handle_t " handle ", unsigned int *" local_nodeid ", unsigned int *" member_list ", int *" member_list_entries ");
-.SH DESCRIPTION
-The
-.B evs_membership_get
-function is used to determine the current processors in the configuration and also
-the local processor identifier.
-The argument
-.I handle
-is used to reference the evs instantiation.
-The argument
-.I local_nodeid
-will return the local node id of the processor.
-The argument
-.I member_list
-will return the list of processors in the current membership.
-The argument
-.I member_list_entries
-should be set with the size of member_list and will return the size of the
-member_list after return from the function.
-.PP
-.SH ERRORS
-The errors are undocumented.
-.SH "SEE ALSO"
-.BR evs_overview (8),
-.BR evs_initialize (3),
-.BR evs_finalize (3),
-.BR evs_fd_get (3),
-.BR evs_dispatch (3),
-.BR evs_leave (3),
-.BR evs_mcast_joined (3),
-.BR evs_mcast_groups (3),
-.BR evs_mmembership_get (3)
-.BR evs_context_get (3)
-.BR evs_context_set (3)
-.PP
diff --git a/man/evs_overview.8 b/man/evs_overview.8
deleted file mode 100644
index d12c0c1..0000000
--- a/man/evs_overview.8
+++ /dev/null
@@ -1,185 +0,0 @@
-.\"/*
-.\" * Copyright (c) 2004 MontaVista Software, Inc.
-.\" *
-.\" * All rights reserved.
-.\" *
-.\" * Author: Steven Dake (sdake@xxxxxxxxxx)
-.\" *
-.\" * 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.
-.\" */
-.TH EVS_OVERVIEW 8 2004-08-31 "corosync Man Page" "Corosync Cluster Engine Programmer's Manual"
-.SH NAME
-evs_overview \- EvS Library Overview
-.SH OVERVIEW
-The EVS library is delivered with the corosync project. This library is used
-to create distributed applications that operate properly during partitions, merges,
-and faults.
-.PP
-The library provides a mechanism to:
-* handle abstraction for multiple instances of an EVS library in one application
-* Deliver messages
-* Deliver configuration changes
-* join one or more groups
-* leave one or more groups
-* send messages to one or more groups
-* send messages to currently joined groups
-.PP
-The EVS library implements a messaging model known as Extended Virtual Synchrony.
-This model allows one sender to transmit to many receivers using standard UDP/IP.
-UDP/IP is unreliable and unordered, so the EVS library applies ordering and reliability
-to messages. Hardware multicast is used to avoid duplicated packets with two or more
-receivers. Erroneous messages are corrected automatically by the library.
-.PP
-Certain guarantees are provided by the EVS library. These guarantees are related to
-message delivery and configuration change delivery.
-.SH DEFINITIONS
-.TP
-.B multicast
-A multicast occurs when a network interface card sends a UDP packet to multiple
-receivers simulatenously.
-.TP
-.B processor
-A processor is the entity that executes the extended virtual synchrony algorithms.
-.TP
-.B configuration
-A configuration is the current description of the processors executing the extended
-virtual syncrhony algorithm.
-.TP
-.B configuration change
-A configuration change occurs when a new configuration is delivered.
-.TP
-.B partition
-A partition occurs when a configuration splits into two or more configurations, or
-a processor fails or is stopped and leaves the configuration.
-.TP
-.B merge
-A merge occurs when two or more configurations join into a larger new configuration. When
-a new processor starts up, it is treated as a configuration with only one processor
-and a merge occurs.
-.TP
-.B fifo ordering
-A message is FIFO ordered when one sender and one receiver agree on the order of the
-messages sent.
-.TP
-.B agreed ordering
-A message is AGREED ordered when all processors agree on the order of the messages sent.
-.TP
-.B safe ordering
-A message is SAFE ordered when all processors agree on the order of messages sent and
-those messages are not delivered until all processors have a copy of the message to
-deliver.
-.TP
-.B virtual syncrhony
-Virtual syncrhony is obtained when all processors agree on the order of messages
-sent and configuration changes sent for each new configuration.
-.SH USING VIRTUAL SYNCHRONY
-The virtual synchrony messaging model has many benefits for developing distributed
-applications. Applications designed using replication have the most benefits. Applications
-that must be able to partition and merge also benefit from the virtual synchrony messaging
-model.
-.PP
-All applications receive a copy of transmitted messages even if there are errors on the
-transmission media. This allows optimiziations when every processor must receive a copy
-of the message for replication.
-.PP
-All messages are ordered according to agreed ordering. This mechanism allows the avoidance
-of race conditions. Consider a lock service implemented over several processors. Two
-requests occur at the same time on two seperate processors. The requests are ordered for
-every processor in the same order and delivered to the processors. Then all processors
-will get request A before request B and can reject request B. Any type of creation or
-deletion of a shared data structure can benefit from this mechanism.
-.PP
-Self delivery ensures that messages that are sent by a processor are also delivered back
-to that processor. This allows the processor sending the message to execute logic when
-the message is self delivered according to agreed ordering and the virtual synchrony rules.
-It also permits all logic to be placed in one message handler instead of two seperate places.
-.PP
-Virtual Synchrony allows the current configuration to be used to make decisions in partitions
-and merges. Since the configuration is sent in the stream of messages to the application,
-the application can alter its behavior based upon the configuration changes.
-.SH ARCHITECTURE AND ALGORITHM
-The EVS library is a thin IPC interface to the corosync executive. The corosync executive
-provides services for the SA Forum AIS libraries as well as the EVS library.
-.PP
-The corosync executive uses a ring protocol and membership protocol to send messages
-according to the semantics required by extended virtual synchrony. The ring protocol
-creates a virtual ring of processors. A token is rotated around the ring of processors.
-When the token is possessed by a processor, that processor may multicast messages to
-other processors in the system.
-.PP
-The token is called the ORF token (for ordering, reliability, flow control). The ORF
-token orders all messages by increasing a sequence number every time a message is
-multicasted. In this way, an ordering is placed on all messages that all processors
-agree to. The token also contains a retransmission list. If a token is received by
-a processor that has not yet received a message it should have, a message sequence
-number is added to the retransmission list. A processor that has a copy of the message
-then retransmits the message. The ORF token provides configuration-wide flow control
-by tracking the number of messages sent and limiting the number of messages that may
-be sent by one processor on each posession of the token.
-.PP
-The membership protocol is responsible for ring formation and detecting when a processor
-within a ring has failed. If the token fails to make a rotation within a timeout period
-known as the token rotation timeout, the membership protocol will form a new ring.
-If a new processor starts, it will also form a new ring. Two or more configurations
-may be used to form a new ring, allowing many partitions to merge together into one
-new configuration.
-.SH PERFORMANCE
-The EVS library obtains 8.5MB/sec throughput on 100 mbit network links with
-many processors. Larger messages obtain better throughput results because the
-time to access Ethernet is about the same for a small message as it is for a
-larger message. Smaller messages obtain better messages per second, because the
-time to send a message is not exactly the same.
-.PP
-80% of CPU utilization occurs because of encryption and authentication. The corosync
-can be built without encryption and authentication for those with no security
-requirements and low CPU utilization requirements. Even without encryption or
-authentication, under heavy load, processor utilization can reach 25% on 1.5 GHZ
-CPU processors.
-.PP
-The current corosync executive supports 16 processors, however, support for more processors is possible by changing defines in the corosync executive. This is untested, however.
-.SH SECURITY
-The EVS library encrypts all messages sent over the network using the SOBER-128
-stream cipher. The EVS library uses HMAC and SHA1 to authenticate all messages.
-The EVS library uses SOBER-128 as a pseudo random number generator. The EVS
-library feeds the PRNG using the /dev/random Linux device.
-.SH BUGS
-This software is not yet production, so there may still be some bugs. But it appears
-there are very few since nobody reports any unknown bugs at this point.
-.SH "SEE ALSO"
-.BR evs_initialize (3),
-.BR evs_finalize (3),
-.BR evs_fd_get (3),
-.BR evs_dispatch (3),
-.BR evs_join (3),
-.BR evs_leave (3),
-.BR evs_mcast_joined (3),
-.BR evs_mcast_groups (3),
-.BR evs_mmembership_get (3)
-.BR evs_context_get (3)
-.BR evs_context_set (3)
-
-.PP
diff --git a/man/index.html b/man/index.html
index 793d511..6ce0ac7 100644
--- a/man/index.html
+++ b/man/index.html
@@ -138,49 +138,6 @@
Description of the cpg_iteration_finalize interface.
<br>
- <h3>EVS service</h3>
-
- <a href="evs_overview.8.html">evs_overview(8)</a>:
- Overview of the evs extended virtual synchrony group
- communication toolkit.
- <br>
-
- <a href="evs_initialize.3.html">evs_initialize(3)</a>:
- Description of the evs_initialize interface.
- <br>
-
- <a href="evs_finalize.3.html">evs_finalize(3)</a>:
- Description of the evs_finalize interface.
- <br>
-
- <a href="evs_dispatch.3.html">evs_dispatch(3)</a>:
- Description of the evs_dispatch interface.
- <br>
-
- <a href="evs_fd_get.3.html">evs_fd_get(3)</a>:
- Description of the evs_fd_get interface.
- <br>
-
- <a href="evs_join.3.html">evs_join(3)</a>:
- Description of the evs_join interface.
- <br>
-
- <a href="evs_leave.3.html">evs_leave(3)</a>:
- Description of the evs_leave interface.
- <br>
-
- <a href="evs_mcast_groups.3.html">evs_mcast_groups(3)</a>:
- Description of the evs_mcast_groups interface.
- <br>
-
- <a href="evs_mcast_joined.3.html">evs_mcast_joined(3)</a>:
- Description of the evs_mcast_joined interface.
- <br>
-
- <a href="evs_membership_get.3.html">evs_membership_get(3)</a>:
- Description of the evs_membership_get interface.
- <br>
-
<h3>SAM service</h3>
<a href="sam_overview.8.html">sam_overview(8)</a>:
diff --git a/pkgconfig/Makefile.am b/pkgconfig/Makefile.am
index ac2f974..b3db16c 100644
--- a/pkgconfig/Makefile.am
+++ b/pkgconfig/Makefile.am
@@ -32,7 +32,7 @@ MAINTAINERCLEANFILES = Makefile.in
EXTRA_DIST = libtemplate.pc.in corosync.pc.in
-LIBS = cfg cpg evs quorum \
+LIBS = cfg cpg quorum \
totem_pg votequorum sam cmap corosync_common
target_LIBS = $(LIBS:%=lib%.pc)
diff --git a/test/.gitignore b/test/.gitignore
index d0b2f27..11771ff 100644
--- a/test/.gitignore
+++ b/test/.gitignore
@@ -1,8 +1,6 @@
cpgbench
cpgbound
cpgverify
-evsbench
-evsverify
logsys_s
logsys_t1
logsys_t2
@@ -12,7 +10,6 @@ stress_cpgcontext
stress_cpgfdget
testcpg
testcpg2
-testevs
testquorum
testsam
testvotequorum1
diff --git a/test/Makefile.am b/test/Makefile.am
index 647aad2..a7895f3 100644
--- a/test/Makefile.am
+++ b/test/Makefile.am
@@ -35,7 +35,7 @@ INCLUDES = -I$(top_builddir)/include/corosync -I$(top_srcdir)/include
EXTRA_DIST = ploadstart.sh
-noinst_PROGRAMS = testevs evsbench evsverify cpgverify testcpg testcpg2 cpgbench \
+noinst_PROGRAMS = cpgverify testcpg testcpg2 cpgbench \
testquorum testvotequorum1 testvotequorum2 \
stress_cpgfdget stress_cpgcontext cpgbound testsam \
testcpgzc cpgbenchzc testzcgc stress_cpgzc
@@ -44,8 +44,6 @@ noinst_SCRIPTS = ploadstart
COMMON_OPTS = -L../lib -L../common_lib -Wl,-rpath,../common_lib
-testevs_LDADD = -levs $(LIBQB_LIBS)
-testevs_LDFLAGS = $(COMMON_OPTS)
testcpg_LDADD = -lcpg $(LIBQB_LIBS)
testcpg_LDFLAGS = $(COMMON_OPTS)
testcpg2_LDADD = -lcpg $(LIBQB_LIBS)
@@ -66,14 +64,10 @@ testvotequorum1_LDADD = -lvotequorum $(LIBQB_LIBS)
testvotequorum1_LDFLAGS = $(COMMON_OPTS)
testvotequorum2_LDADD = -lvotequorum $(LIBQB_LIBS)
testvotequorum2_LDFLAGS = $(COMMON_OPTS)
-evsverify_LDADD = -levs -ltotem_pg $(LIBQB_LIBS)
-evsverify_LDFLAGS = $(COMMON_OPTS) -L../exec
cpgverify_LDADD = -lcpg -ltotem_pg $(LIBQB_LIBS)
cpgverify_LDFLAGS = $(COMMON_OPTS) -L../exec
cpgbound_LDADD = -lcpg $(LIBQB_LIBS)
cpgbound_LDFLAGS = $(COMMON_OPTS)
-evsbench_LDADD = -levs $(LIBQB_LIBS)
-evsbench_LDFLAGS = $(COMMON_OPTS)
cpgbench_LDADD = -lcpg $(LIBQB_LIBS)
cpgbench_LDFLAGS = $(COMMON_OPTS)
cpgbenchzc_LDADD = -lcpg -lcorosync_common $(LIBQB_LIBS)
@@ -86,8 +80,7 @@ ploadstart: ploadstart.sh
chmod 755 $@
LINT_FILES1:=$(filter-out sa_error.c, $(wildcard *.c))
-LINT_FILES2:=$(filter-out testevsth.c, $(LINT_FILES1))
-LINT_FILES:=$(filter-out testparse.c, $(LINT_FILES2))
+LINT_FILES:=$(filter-out testparse.c, $(LINT_FILES1))
lint:
-for f in $(LINT_FILES) ; do echo Splint $$f ; splint $(INCLUDES) $(LINT_FLAGS) $(CFLAGS) $$f ; done
diff --git a/test/evsbench.c b/test/evsbench.c
deleted file mode 100644
index 786e019..0000000
--- a/test/evsbench.c
+++ /dev/null
@@ -1,197 +0,0 @@
-#define _BSD_SOURCE
-/*
- * Copyright (c) 2004 MontaVista Software, Inc.
- *
- * All rights reserved.
- *
- * Author: Steven Dake (sdake@xxxxxxxxxx)
- *
- * 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 <config.h>
-
-#include <stdio.h>
-#include <stdlib.h>
-#include <signal.h>
-#include <unistd.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 <sys/socket.h>
-#include <netinet/in.h>
-#include <arpa/inet.h>
-
-#include <corosync/corotypes.h>
-#include <corosync/evs.h>
-
-#ifdef COROSYNC_SOLARIS
-#define timersub(a, b, result) \
- do { \
- (result)->tv_sec = (a)->tv_sec - (b)->tv_sec; \
- (result)->tv_usec = (a)->tv_usec - (b)->tv_usec; \
- if ((result)->tv_usec < 0) { \
- --(result)->tv_sec; \
- (result)->tv_usec += 1000000; \
- } \
- } while (0)
-#endif
-
-volatile static int alarm_notice = 0;
-
-static void evs_deliver_fn (
- hdb_handle_t handle,
- unsigned int nodeid,
- const void *msg,
- size_t msg_len)
-{
-}
-
-static void evs_confchg_fn (
- hdb_handle_t handle,
- const unsigned int *member_list, size_t member_list_entries,
- const unsigned int *left_list, size_t left_list_entries,
- const unsigned int *joined_list, size_t joined_list_entries,
- const struct evs_ring_id *ring_id)
-{
- 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]);
- }
-}
-
-static evs_callbacks_t callbacks = {
- evs_deliver_fn,
- evs_confchg_fn
-};
-
-struct evs_group groups[3] = {
- { "key1" },
- { "key2" },
- { "key3" }
-};
-
-static char buffer[200000];
-
-static struct iovec iov = {
- .iov_base = buffer,
- .iov_len = sizeof (buffer)
-};
-
-static void evs_benchmark (evs_handle_t handle,
- int write_size)
-{
- struct timeval tv1, tv2, tv_elapsed;
- cs_error_t result;
- int write_count = 0;
-
- /*
- * Run benchmark for 10 seconds
- */
- alarm (10);
- gettimeofday (&tv1, NULL);
-
- iov.iov_len = write_size;
- do {
- sprintf (buffer, "This is message %d\n", write_count);
- result = evs_mcast_joined (handle, EVS_TYPE_AGREED, &iov, 1);
-
- if (result != CS_ERR_TRY_AGAIN) {
- write_count += 1;
- }
- result = evs_dispatch (handle, CS_DISPATCH_ALL);
- } while (alarm_notice == 0);
- 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));
-
- alarm_notice = 0;
-}
-
-static void sigalrm_handler (int num)
-{
- alarm_notice = 1;
-}
-
-static void sigintr_handler (int num) __attribute__((__noreturn__));
-static void sigintr_handler (int num)
-{
- exit (1);
-}
-
-int main (void) {
- int size;
- int i;
- cs_error_t result;
- evs_handle_t handle;
-
- signal (SIGALRM, sigalrm_handler);
- signal (SIGINT, sigintr_handler);
-
-
- result = evs_initialize (&handle, &callbacks);
- printf ("Init result %d\n", result);
- result = evs_join (handle, groups, 3);
- printf ("Join result %d\n", result);
-
- size = 1;
-
- for (i = 0; i < 225; i++) { /* number of repetitions - up to 50k */
- evs_benchmark (handle, size);
- /*
- * Adjust count to 95% of previous count
- * Adjust bytes to write per checkpoint up by 1500
- */
- size += 1000;
- }
- return (0);
-}
diff --git a/test/evsverify.c b/test/evsverify.c
deleted file mode 100644
index 709bdd6..0000000
--- a/test/evsverify.c
+++ /dev/null
@@ -1,188 +0,0 @@
-/*
- * Copyright (c) 2004 MontaVista Software, Inc.
- * Copyright (c) 2006-2007, 2009 Red Hat, Inc.
- *
- * All rights reserved.
- *
- * Author: Steven Dake (sdake@xxxxxxxxxx)
- *
- * 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 <config.h>
-
-#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/corotypes.h>
-#include <corosync/evs.h>
-#include "../exec/crypto.h"
-
-const char *delivery_string;
-struct my_msg {
- unsigned int msg_size;
- unsigned char sha1[20];
- unsigned char buffer[0];
-};
-
-static int deliveries = 0;
-static void evs_deliver_fn (
- hdb_handle_t handle,
- unsigned int nodeid,
- const void *m,
- size_t msg_len)
-{
- const struct my_msg *msg2 = 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++;
-}
-
-static void evs_confchg_fn (
- hdb_handle_t handle,
- const unsigned int *member_list, size_t member_list_entries,
- const unsigned int *left_list, size_t left_list_entries,
- const unsigned int *joined_list, size_t joined_list_entries,
- const struct evs_ring_id *ring_id)
-{
- 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]);
- }
-}
-
-static evs_callbacks_t callbacks = {
- evs_deliver_fn,
- evs_confchg_fn
-};
-
-struct evs_group groups[3] = {
- { "key1" },
- { "key2" },
- { "key3" }
-};
-
-static unsigned char buffer[200000];
-int main (void)
-{
- evs_handle_t handle;
- cs_error_t result;
- unsigned int i = 0, j;
- int fd;
- unsigned int member_list[32];
- unsigned int local_nodeid;
- size_t member_list_entries = 32;
- struct my_msg msg;
- hash_state sha1_hash;
- struct iovec iov[2];
-
- result = evs_initialize (&handle, &callbacks);
- if (result != CS_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 %lu\n",
- (unsigned long int) 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 = (void *)&msg;
- iov[0].iov_len = sizeof (struct my_msg);
- iov[1].iov_base = (void *)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 == CS_ERR_TRY_AGAIN) {
- goto try_again_one;
- }
- result = evs_dispatch (handle, CS_DISPATCH_ALL);
- }
-
- evs_fd_get (handle, &fd);
-
- evs_finalize (handle);
-
- return (0);
-}
diff --git a/test/testevs.c b/test/testevs.c
deleted file mode 100644
index 0730ac6..0000000
--- a/test/testevs.c
+++ /dev/null
@@ -1,193 +0,0 @@
-/*
- * Copyright (c) 2004 MontaVista Software, Inc.
- * Copyright (c) 2006-2009 Red Hat, Inc.
- *
- * All rights reserved.
- *
- * Author: Steven Dake (sdake@xxxxxxxxxx)
- *
- * 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 <config.h>
-
-#include <stdio.h>
-#include <stdlib.h>
-#include <sys/socket.h>
-#include <netinet/in.h>
-#include <arpa/inet.h>
-#include <errno.h>
-#include <corosync/corotypes.h>
-#include <corosync/evs.h>
-
-#include <qb/qblog.h>
-
-static const char *delivery_string;
-
-static int deliveries = 0;
-static void evs_deliver_fn (
- hdb_handle_t handle,
- unsigned int nodeid,
- const void *msg,
- size_t msg_len)
-{
- const char *buf = msg;
-
- printf ("API '%s' msg '%s'\n", delivery_string, buf);
- deliveries++;
-}
-
-static void evs_confchg_fn (
- hdb_handle_t handle,
- const unsigned int *member_list, size_t member_list_entries,
- const unsigned int *left_list, size_t left_list_entries,
- const unsigned int *joined_list, size_t joined_list_entries,
- const struct evs_ring_id *ring_id)
-{
- 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]);
- }
-}
-
-static evs_callbacks_t callbacks = {
- evs_deliver_fn,
- evs_confchg_fn
-};
-
-static struct evs_group groups[3] = {
- { "key1" },
- { "key2" },
- { "key3" }
-};
-
-static char buffer[2000];
-struct iovec iov = {
- .iov_base = buffer,
- .iov_len = sizeof (buffer)
-};
-
-int main (void)
-{
- evs_handle_t handle;
- cs_error_t result;
- int i = 0;
- int fd;
- unsigned int member_list[32];
- unsigned int local_nodeid;
- size_t member_list_entries = 32;
-
- qb_log_init("testevs", LOG_USER, LOG_ERR);
- qb_log_ctl(QB_LOG_SYSLOG, QB_LOG_CONF_ENABLED, QB_FALSE);
- qb_log_filter_ctl(QB_LOG_STDERR, QB_LOG_FILTER_ADD,
- QB_LOG_FILTER_FILE, "*", LOG_TRACE);
- qb_log_ctl(QB_LOG_STDERR, QB_LOG_CONF_ENABLED, QB_TRUE);
- qb_log_format_set(QB_LOG_STDERR, "[%p] %f %b");
-
- result = evs_initialize (&handle, &callbacks);
- if (result != CS_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 %lu\n",
- (unsigned long int) 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);
- delivery_string = "evs_mcast_joined";
-
- /*
- * Demonstrate evs_mcast_joined
- */
- for (i = 0; i < 500; i++) {
- sprintf (buffer, "evs_mcast_joined: This is message %d", i);
-#ifdef COMPILE_OUT
- sprintf (buffer,
- "%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d%d",
- i, i, i, i, i, i, i, i, i, i, i, i, i, i, i, i, i, i, i, i, i, i, i, i, i,
- i, i, i, i, i, i, i, i, i, i, i, i, i, i, i, i, i, i, i, i, i, i, i, i, i);
-#endif
-try_again_one:
- result = evs_mcast_joined (handle, EVS_TYPE_AGREED,
- &iov, 1);
- if (result == CS_ERR_TRY_AGAIN) {
- goto try_again_one;
- }
- result = evs_dispatch (handle, CS_DISPATCH_ALL);
- }
-
- do {
- result = evs_dispatch (handle, CS_DISPATCH_ALL);
- } while (deliveries < 20);
- /*
- * Demonstrate evs_mcast_joined
- */
- delivery_string = "evs_mcast_groups";
- for (i = 0; i < 500; i++) {
- sprintf (buffer, "evs_mcast_groups: This is message %d", i);
-try_again_two:
- result = evs_mcast_groups (handle, EVS_TYPE_AGREED,
- &groups[1], 1, &iov, 1);
- if (result == CS_ERR_TRY_AGAIN) {
- goto try_again_two;
- }
-
- result = evs_dispatch (handle, CS_DISPATCH_ALL);
- }
- /*
- * Flush any pending callbacks
- */
- do {
- result = evs_dispatch (handle, CS_DISPATCH_ALL);
- } while (deliveries < 500);
-
- evs_fd_get (handle, &fd);
-
- evs_finalize (handle);
-
- return (0);
-}
diff --git a/test/testevsth.c b/test/testevsth.c
deleted file mode 100644
index 14da44f..0000000
--- a/test/testevsth.c
+++ /dev/null
@@ -1,186 +0,0 @@
-/*
- * Copyright (c) 2004 MontaVista Software, Inc.
- *
- * All rights reserved.
- *
- * Author: Steven Dake (sdake@xxxxxxxxxx)
- *
- * 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 <config.h>
-
-#include <stdio.h>
-#include <stdlib.h>
-#include <sys/socket.h>
-#include <netinet/in.h>
-#include <arpa/inet.h>
-#include <errno.h>
-#include <pthread.h>
-#include "../include/evs.h"
-
-char *delivery_string;
-
-#define CALLBACKS 200000
-int callback_count = 0;
-void evs_deliver_fn (struct in_addr source_addr, const void *msg, size_t msg_len)
-{
-#ifdef PRINT_OUTPUT
- char *buf;
- buf += 100000;
- printf ("Delivery callback\n");
- printf ("callback %d '%s' msg '%s'\n", callback_count, delivery_string, buf);
-#endif
- callback_count += 1;
- if (callback_count % 50 == 0) {
- printf ("Callback %d\n", callback_count);
- }
-}
-
-void evs_confchg_fn (
- const struct in_addr *member_list, size_t member_list_entries,
- const struct in_addr *left_list, size_t left_list_entries,
- const struct in_addr *joined_list, size_t joined_list_entries)
-{
- int i;
-
- printf ("CONFIGURATION CHANGE\n");
- printf ("--------------------\n");
- printf ("New configuration\n");
- for (i = 0; i < member_list_entries; i++) {
- printf ("%s\n", inet_ntoa (member_list[i]));
- }
- printf ("Members Left:\n");
- for (i = 0; i < left_list_entries; i++) {
- printf ("%s\n", inet_ntoa (left_list[i]));
- }
- printf ("Members Joined:\n");
- for (i = 0; i < joined_list_entries; i++) {
- printf ("%s\n", inet_ntoa (joined_list[i]));
- }
-}
-
-evs_callbacks_t callbacks = {
- evs_deliver_fn,
- evs_confchg_fn
-};
-
-struct evs_group groups[3] = {
- { "key1" },
- { "key2" },
- { "key3" }
-};
-
-char buffer[1000];
-struct iovec iov = {
- .iov_base = buffer,
- .iov_len = sizeof (buffer)
-};
-
-void *th_dispatch (void *arg)
-{
- cs_error_t result;
- evs_handle_t handle = *(evs_handle_t *)arg;
-
- printf ("THREAD DISPATCH starting.\n");
- result = evs_dispatch (handle, CS_DISPATCH_BLOCKING);
- printf ("THREAD DISPATCH return result is %d\n", result);
- return (0);
-}
-
-static struct sched_param sched_param = {
- sched_priority: 99
-};
-
-int main (void)
-{
- evs_handle_t handle;
- cs_error_t result;
- int i = 0;
- pthread_t dispatch_thread;
- pthread_attr_t dispatch_thread_attribute;
-
- result = evs_initialize (&handle, &callbacks);
- if (result != CS_OK) {
- printf ("Couldn't initialize EVS service %d\n", result);
- exit (0);
- }
-
- pthread_attr_init (&dispatch_thread_attribute);
- pthread_attr_setschedpolicy (&dispatch_thread_attribute, SCHED_FIFO);
- pthread_attr_setschedparam (&dispatch_thread_attribute, &sched_param);
-
- pthread_create (&dispatch_thread, NULL, th_dispatch, &handle);
-
- 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";
-
- /*
- * Demonstrate evs_mcast_joined
- */
- for (i = 0; i < CALLBACKS/2; i++) {
- sprintf (buffer, "evs_mcast_joined: This is message %d", i);
-try_again_one:
- result = evs_mcast_joined (handle, EVS_TYPE_AGREED, &iov, 1);
- if (result == CS_ERR_TRY_AGAIN) {
- goto try_again_one;
- } else
- if (result != CS_OK) {
- printf ("Got error result, exiting %d\n", result);
- exit (1);
- }
- }
-
- /*
- * Demonstrate evs_mcast_joined
- */
- delivery_string = "evs_mcast_groups";
- for (i = 0; i < CALLBACKS/2; i++) {
- sprintf (buffer, "evs_mcast_groups: This is message %d", i);
-try_again_two:
- result = evs_mcast_groups (handle, EVS_TYPE_AGREED,
- &groups[1], 1, &iov, 1);
- if (result == CS_ERR_TRY_AGAIN) {
- goto try_again_two;
- }
- }
-
- /*
- * Wait until all callbacks have been executed by dispatch thread
- */
- for (;;) {
- if (callback_count == CALLBACKS) {
- printf ("Test completed successfully\n");
- exit (0);
- }
- }
- return (0);
-}
--
1.7.7.6
_______________________________________________
discuss mailing list
discuss@xxxxxxxxxxxx
http://lists.corosync.org/mailman/listinfo/discuss
