test/testclm.c

   1 /*
   2  * Copyright (c) 2002-2003 MontaVista Software, Inc.
   3  * Copyright (c) 2006 Sun Microsystems, Inc.
   4  *
   5  * All rights reserved.
   6  *
   7  * Author: Steven Dake (sdake@mvista.com)
   8  *
   9  * This software licensed under BSD license, the text of which follows:
  10  *
  11  * Redistribution and use in source and binary forms, with or without
  12  * modification, are permitted provided that the following conditions are met:
  13  *
  14  * - Redistributions of source code must retain the above copyright notice,
  15  *   this list of conditions and the following disclaimer.
  16  * - Redistributions in binary form must reproduce the above copyright notice,
  17  *   this list of conditions and the following disclaimer in the documentation
  18  *   and/or other materials provided with the distribution.
  19  * - Neither the name of the MontaVista Software, Inc. nor the names of its
  20  *   contributors may be used to endorse or promote products derived from this
  21  *   software without specific prior written permission.
  22  *
  23  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
  24  * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  25  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  26  * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
  27  * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
  28  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
  29  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
  30  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
  31  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
  32  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
  33  * THE POSSIBILITY OF SUCH DAMAGE.
  34  */
  35
  36 #include <string.h>
  37 #include <stdio.h>
  38 #include <stdlib.h>
  39 #include <errno.h>
  40 #include <signal.h>
  41 #include <unistd.h>
  42 #include <sys/types.h>
  43 #include <sys/socket.h>
  44 #include <sys/select.h>
  45 #include <sys/un.h>
  46
  47 #include "saAis.h"
  48 #include "saClm.h"
  49
  50 void printSaClmNodeAddressT (SaClmNodeAddressT *nodeAddress) {
  51         int i;
  52
  53         printf ("family=%d - address=", nodeAddress->family);
  54         for (i = 0; i < nodeAddress->length; i++) {
  55                 printf ("%c", nodeAddress->value[i]);
  56         }
  57 }
  58
  59 void printSaNameT (SaNameT *name)
  60 {
  61         int i;
  62
  63         for (i = 0; i < name->length; i++) {
  64                 printf ("%c", name->value[i]);
  65         }
  66 }
  67
  68 void printSaClmClusterNodeT (char *description, SaClmClusterNodeT *clusterNode) {
  69         printf ("Node Information for %s\n", description);
  70
  71         printf ("\tnode id is %x\n", (int)clusterNode->nodeId);
  72
  73         printf ("\tnode address is ");
  74         printSaClmNodeAddressT (&clusterNode->nodeAddress);
  75         printf ("\n");
  76
  77         printf ("\tNode name is ");
  78         printSaNameT (&clusterNode->nodeName);
  79         printf ("\n");
  80
  81         printf ("\tMember is %d\n", clusterNode->member);
  82
  83         printf ("\tTimestamp is %llx nanoseconds\n", (unsigned long long)clusterNode->bootTimestamp);
  84 }
  85
  86 void NodeGetCallback (
  87         SaInvocationT invocation,
  88         const SaClmClusterNodeT *clusterNode,
  89         SaAisErrorT error)
  90 {
  91         char buf[128];
  92
  93         if (error != SA_AIS_OK) {
  94                 printf ("Node for invocation %llu not found (%d)\n",
  95                         (unsigned long long)invocation, error);
  96         } else {
  97                 sprintf (buf, "NODEGETCALLBACK %llu\n", (unsigned long long)invocation);
  98                 printSaClmClusterNodeT (buf, (SaClmClusterNodeT *)clusterNode);
  99         }
 100 }
 101
 102 void TrackCallback (
 103         const SaClmClusterNotificationBufferT *notificationBuffer,
 104         SaUint32T numberOfMembers,
 105         SaAisErrorT error)
 106 {
 107         int i;
 108
 109 printf ("Track callback\n");
 110         printf ("Calling track callback %p\n", notificationBuffer);
 111         for (i = 0; i < numberOfMembers; i++) {
 112                 switch (notificationBuffer->notification[i].clusterChange) {
 113                 case SA_CLM_NODE_NO_CHANGE:
 114                         printf ("NODE STATE NO CHANGE.\n");
 115                         break;
 116                 case SA_CLM_NODE_JOINED:
 117                         printf ("NODE STATE JOINED.\n");
 118                         break;
 119                 case SA_CLM_NODE_LEFT:
 120                         printf ("NODE STATE LEFT.\n");
 121                         break;
 122                 case SA_CLM_NODE_RECONFIGURED:
 123                         printf ("NODE STATE RECONFIGURED.\n");
 124                         break;
 125                 }
 126                 printSaClmClusterNodeT ("TRACKING",
 127                         &notificationBuffer->notification[i].clusterNode);
 128         }
 129         printf ("Done calling trackCallback\n");
 130 }
 131
 132 SaClmCallbacksT callbacks = {
 133         .saClmClusterNodeGetCallback    = NodeGetCallback,
 134         .saClmClusterTrackCallback              = TrackCallback
 135 };
 136
 137 SaVersionT version = { 'B', 1, 1 };
 138
 139 void sigintr_handler (int signum) {
 140         exit (0);
 141 }
 142
 143 int main (void) {
 144         SaClmHandleT handle;
 145         fd_set read_fds;
 146         SaSelectionObjectT select_fd;
 147         int result;
 148         SaClmClusterNotificationT clusterNotification[64];
 149         SaClmClusterNotificationBufferT clusterNotificationBuffer;
 150         SaClmClusterNodeT clusterNode;
 151         int i;
 152
 153         clusterNotificationBuffer.notification = clusterNotification;
 154         clusterNotificationBuffer.numberOfItems = 64;
 155
 156         signal (SIGINT, sigintr_handler);
 157
 158         result = saClmInitialize (&handle, &callbacks, &version);
 159         if (result != SA_AIS_OK) {
 160                 printf ("Could not initialize Cluster Membership API instance error %d\n", result);
 161                 exit (1);
 162         }
 163
 164         result = saClmClusterNodeGet (handle, SA_CLM_LOCAL_NODE_ID, SA_TIME_END, &clusterNode);
 165
 166         printf ("Result of saClmClusterNodeGet %d\n", result);
 167
 168         printSaClmClusterNodeT ("saClmClusterNodeGet SA_CLM_LOCAL_NODE_ID result %d", &clusterNode);
 169
 170         result = saClmClusterNodeGetAsync (handle, 55, SA_CLM_LOCAL_NODE_ID);
 171         printf ("result is %d\n", result);
 172
 173         result = saClmClusterNodeGetAsync (handle, 60, 0x6201a8c0);
 174         printf ("result is %d\n", result);
 175
 176         result = saClmClusterNodeGetAsync (handle, 61, 0x6a01a8f0);
 177         printf ("result is %d\n", result);
 178
 179         result = saClmClusterNodeGetAsync (handle, 59, SA_CLM_LOCAL_NODE_ID);
 180         printf ("result is %d\n", result);
 181
 182         result = saClmClusterNodeGetAsync (handle, 57, SA_CLM_LOCAL_NODE_ID);
 183         printf ("result is %d\n", result);
 184
 185         result = saClmClusterTrack (handle, SA_TRACK_CURRENT | SA_TRACK_CHANGES,
 186                 &clusterNotificationBuffer);
 187         printf ("track result is %d\n", result);
 188         for (i = 0; i < clusterNotificationBuffer.numberOfItems; i++) {
 189                 printSaClmClusterNodeT ("Results from SA_TRACK_CURRENT:",
 190                         &clusterNotificationBuffer.notification[i].clusterNode);
 191         }
 192
 193         saClmSelectionObjectGet (handle, &select_fd);
 194
 195 printf ("select fd is %llu\n", (unsigned long long)select_fd);
 196         FD_ZERO (&read_fds);
 197 printf ("press the enter key to exit with track stop and finalize.\n");
 198         do {
 199                 FD_SET (select_fd, &read_fds);
 200                 FD_SET (STDIN_FILENO, &read_fds);
 201                 result = select (select_fd + 1, &read_fds, 0, 0, 0);
 202                 if (result == -1) {
 203                         perror ("select\n");
 204                 }
 205                 if (FD_ISSET (STDIN_FILENO, &read_fds)) {
 206                         break;
 207                 }
 208 printf ("done with select\n");
 209                 saClmDispatch (handle, SA_DISPATCH_ALL);
 210         } while (result);
 211
 212         result = saClmClusterTrackStop (handle);
 213         printf ("TrackStop result is %d (should be 1)\n", result);
 214
 215         result = saClmFinalize (handle);
 216         printf ("Finalize  result is %d (should be 1)\n", result);
 217         return (0);
 218 }