Skip navigation links

MySQL Newsletter - Subscribe Today!

The world's most popular open source database

MySQL 5.1: mysql/src/5.1-dbg/storage/ndb/ndbapi-examples/mgmapi_logevent/mgmapi_logevent.cpp File Reference

mysql/src/5.1-dbg/storage/ndb/ndbapi-examples/mgmapi_logevent/mgmapi_logevent.cpp File Reference

#include <mysql.h>
#include <ndbapi/NdbApi.hpp>
#include <mgmapi.h>
#include <stdio.h>

Include dependency graph for mgmapi_logevent.cpp:

Go to the source code of this file.


Defines

#define MGMERROR(h)
#define LOGEVENTERROR(h)

Functions

int main ()

Define Documentation

#define LOGEVENTERROR ( h   ) 

Value:

{ \
  fprintf(stderr, "code: %d msg: %s\n", \
          ndb_logevent_get_latest_error(h), \
          ndb_logevent_get_latest_error_msg(h)); \
  exit(-1); \
}

Definition at line 34 of file mgmapi_logevent.cpp.

Referenced by main().

#define MGMERROR ( h   ) 

Value:

{ \
  fprintf(stderr, "code: %d msg: %s\n", \
          ndb_mgm_get_latest_error(h), \
          ndb_mgm_get_latest_error_msg(h)); \
  exit(-1); \
}

Definition at line 26 of file mgmapi_logevent.cpp.

Referenced by main().

Function Documentation

int main ( void   ) 

Definition at line 42 of file mgmapi_logevent.cpp.

References ndb_logevent::ArbitResult, ndb_logevent::ArbitState, ndb_logevent::BackupStarted, ndb_logevent::Connected, ndb_logevent::DeadDueToHeartbeat, ndb_logevent::Disconnected, exit, h, LOGEVENTERROR, MGMERROR, ndb_end(), ndb_init(), NDB_LE_ArbitResult, NDB_LE_ArbitState, NDB_LE_BackupAborted, NDB_LE_BackupCompleted, NDB_LE_BackupFailedToStart, NDB_LE_BackupStarted, NDB_LE_Connected, NDB_LE_DeadDueToHeartbeat, NDB_LE_Disconnected, NDB_LE_NDBStartCompleted, NDB_LE_NodeFailCompleted, ndb_logevent_get_next(), ndb_mgm_connect(), ndb_mgm_create_handle(), ndb_mgm_create_logevent_handle(), ndb_mgm_destroy_handle(), ndb_mgm_destroy_logevent_handle(), NDB_MGM_EVENT_CATEGORY_BACKUP, NDB_MGM_EVENT_CATEGORY_CONNECTION, NDB_MGM_EVENT_CATEGORY_ERROR, NDB_MGM_EVENT_CATEGORY_NODE_RESTART, NDB_MGM_EVENT_CATEGORY_STARTUP, ndb_logevent::NDBStartCompleted, ndb_logevent::source_nodeid, and ndb_logevent::type.

00043 {
00044   NdbMgmHandle h;
00045   NdbLogEventHandle le;
00046   int filter[] = { 15, NDB_MGM_EVENT_CATEGORY_BACKUP,
00047                    15, NDB_MGM_EVENT_CATEGORY_CONNECTION,
00048                    15, NDB_MGM_EVENT_CATEGORY_NODE_RESTART,
00049                    15, NDB_MGM_EVENT_CATEGORY_STARTUP,
00050                    15, NDB_MGM_EVENT_CATEGORY_ERROR,
00051                    0 };
00052   struct ndb_logevent event;
00053 
00054   ndb_init();
00055 
00056   h= ndb_mgm_create_handle();
00057   if ( h == 0)
00058   {
00059     printf("Unable to create handle\n");
00060     exit(-1);
00061   }
00062   if (ndb_mgm_connect(h,0,0,0)) MGMERROR(h);
00063 
00064   le= ndb_mgm_create_logevent_handle(h, filter);
00065   if ( le == 0 )  MGMERROR(h);
00066 
00067   while (1)
00068   {
00069     int timeout= 5000;
00070     int r= ndb_logevent_get_next(le,&event,timeout);
00071     if (r == 0)
00072       printf("No event within %d milliseconds\n", timeout);
00073     else if (r < 0)
00074       LOGEVENTERROR(le)
00075     else
00076     {
00077       switch (event.type) {
00078       case NDB_LE_BackupStarted:
00079         printf("Node %d: BackupStarted\n", event.source_nodeid);
00080         printf("  Starting node ID: %d\n", event.BackupStarted.starting_node);
00081         printf("  Backup ID: %d\n", event.BackupStarted.backup_id);
00082         break;
00083       case NDB_LE_BackupCompleted:
00084         printf("Node %d: BackupCompleted\n", event.source_nodeid);
00085         printf("  Backup ID: %d\n", event.BackupStarted.backup_id);
00086         break;
00087       case NDB_LE_BackupAborted:
00088         printf("Node %d: BackupAborted\n", event.source_nodeid);
00089         break;
00090       case NDB_LE_BackupFailedToStart:
00091         printf("Node %d: BackupFailedToStart\n", event.source_nodeid);
00092         break;
00093 
00094       case NDB_LE_NodeFailCompleted:
00095         printf("Node %d: NodeFailCompleted\n", event.source_nodeid);
00096         break;
00097       case NDB_LE_ArbitResult:
00098         printf("Node %d: ArbitResult\n", event.source_nodeid);
00099         printf("  code %d, arbit_node %d\n",
00100                event.ArbitResult.code & 0xffff,
00101                event.ArbitResult.arbit_node);
00102         break;
00103       case NDB_LE_DeadDueToHeartbeat:
00104         printf("Node %d: DeadDueToHeartbeat\n", event.source_nodeid);
00105         printf("  node %d\n", event.DeadDueToHeartbeat.node);
00106         break;
00107 
00108       case NDB_LE_Connected:
00109         printf("Node %d: Connected\n", event.source_nodeid);
00110         printf("  node %d\n", event.Connected.node);
00111         break;
00112       case NDB_LE_Disconnected:
00113         printf("Node %d: Disconnected\n", event.source_nodeid);
00114         printf("  node %d\n", event.Disconnected.node);
00115         break;
00116       case NDB_LE_NDBStartCompleted:
00117         printf("Node %d: StartCompleted\n", event.source_nodeid);
00118         printf("  version %d.%d.%d\n",
00119                event.NDBStartCompleted.version >> 16 & 0xff,
00120                event.NDBStartCompleted.version >> 8 & 0xff,
00121                event.NDBStartCompleted.version >> 0 & 0xff);
00122         break;
00123       case NDB_LE_ArbitState:
00124         printf("Node %d: ArbitState\n", event.source_nodeid);
00125         printf("  code %d, arbit_node %d\n",
00126                event.ArbitState.code & 0xffff,
00127                event.ArbitResult.arbit_node);
00128         break;
00129 
00130       default:
00131         break;
00132       }
00133     }
00134   }
00135       
00136   ndb_mgm_destroy_logevent_handle(&le);
00137   ndb_mgm_destroy_handle(&h);
00138   ndb_end(0);
00139   return 0;
00140 }

Here is the call graph for this function:

Generated on Sat Sep 9 18:43:57 2006 for MySQL 5.1 by  doxygen 1.4.7