Skip navigation links

Recommended Servers for MySQL

The world's most popular open source database

Contact a MySQL Representative

Login | Register

• MySQL.com
• Downloads
• Developer Zone
• Partners & Solutions
• Customer Login

• DevZone
• Documentation
• Librarian
• Articles
• Forums
• Bugs
• Forge
• Planet MySQL
• Labs

 

 

 

• Get Started with MySQL
• Development with MySQL
• PHP
• Perl
• Python
• Ruby
• Java/JDBC
• C#/.NET

The world's most popular open source database

mysql/src/5.1-dbg/storage/ndb/src/kernel/main.cpp File Reference

#include <ndb_global.h>
#include <my_pthread.h>
#include <ndb_version.h>
#include "Configuration.hpp"
#include <ConfigRetriever.hpp>
#include <TransporterRegistry.hpp>
#include "vm/SimBlockList.hpp"
#include "ThreadConfig.hpp"
#include <SignalLoggerManager.hpp>
#include <NdbOut.hpp>
#include <NdbMain.h>
#include <NdbDaemon.h>
#include <NdbSleep.h>
#include <NdbConfig.h>
#include <WatchDog.hpp>
#include <LogLevel.hpp>
#include <EventLogger.hpp>
#include <NdbAutoPtr.hpp>
#include <Properties.hpp>
#include <mgmapi_debug.h>

Include dependency graph for main.cpp:

Go to the source code of this file.

Defines
#define	MAX_FAILED_STARTUPS   3
#define	handler_register(signum, handler, ignore)
Functions
void	catchsigs (bool ignore)
void	handler_shutdown (int signum)
void	handler_error (int signum)
void	handler_sigusr1 (int signum)
void	systemInfo (const Configuration &conf, const LogLevel &ll)
static void	writeChildInfo (const char *token, int val)
void	childReportSignal (int signum)
void	childReportError (int error)
void	childExit (int code, Uint32 currentStartPhase)
void	childAbort (int code, Uint32 currentStartPhase)
static int	insert (const char *pair, Properties &p)
static int	readChildInfo (Properties &info)
static bool	get_int_property (Properties &info, const char *token, Uint32 *int_val)
int	reportShutdown (class Configuration *config, int error_exit, int restart)
int	main (int argc, char **argv)
Variables
EventLogger	g_eventLogger
NdbMutex *	theShutdownMutex
static bool	failed_startup_flag = false
static Uint32	failed_startups = 0
static FILE *	child_info_file_r = stdin
static FILE *	child_info_file_w = stdout

---

Define Documentation

#define handler_register	(	signum,
		handler,
		ignore		)

Value:

{\
  if (ignore) {\
    if(signum != SIGCHLD)\
      signal(signum, SIG_IGN);\
  } else\
    signal(signum, handler);\
}

Definition at line 532 of file main.cpp.

Referenced by catchsigs().

#define MAX_FAILED_STARTUPS   3

Definition at line 53 of file main.cpp.

Referenced by main().

---

Function Documentation

void catchsigs

(

bool

ignore

)

Definition at line 542 of file main.cpp.

References Configuration::getForegroundMode(), globalEmulatorData, handler_error(), handler_register, handler_shutdown(), SIGPIPE, SIGQUIT, and EmulatorData::theConfiguration.

Referenced by main().

                      {
#if !defined NDB_WIN32 && !defined NDB_SOFTOSE && !defined NDB_OSE 

  static const int signals_shutdown[] = {
#ifdef SIGBREAK
    SIGBREAK,
#endif
    SIGHUP,
    SIGINT,
#if defined SIGPWR
    SIGPWR,
#elif defined SIGINFO
    SIGINFO,
#endif
    SIGQUIT,
    SIGTERM,
#ifdef SIGTSTP
    SIGTSTP,
#endif
    SIGTTIN,
    SIGTTOU
  };

  static const int signals_error[] = {
    SIGABRT,
    SIGALRM,
#ifdef SIGBUS
    SIGBUS,
#endif
    SIGCHLD,
    SIGFPE,
    SIGILL,
#ifdef SIGIO
    SIGIO,
#endif
#ifdef SIGPOLL
    SIGPOLL,
#endif
    SIGSEGV
  };

  static const int signals_ignore[] = {
    SIGPIPE
  };

  size_t i;
  for(i = 0; i < sizeof(signals_shutdown)/sizeof(signals_shutdown[0]); i++)
    handler_register(signals_shutdown[i], handler_shutdown, ignore);
  for(i = 0; i < sizeof(signals_error)/sizeof(signals_error[0]); i++)
    handler_register(signals_error[i], handler_error, ignore);
  for(i = 0; i < sizeof(signals_ignore)/sizeof(signals_ignore[0]); i++)
    handler_register(signals_ignore[i], SIG_IGN, ignore);
#ifdef SIGTRAP
  Configuration* theConfig = globalEmulatorData.theConfiguration;
  if (! theConfig->getForegroundMode())
    handler_register(SIGTRAP, handler_error, ignore);
#endif
#endif
}

Here is the call graph for this function:

Here is the caller graph for this function:

void childAbort	(	int	code,
		Uint32	currentStartPhase
	)

Definition at line 97 of file main.cpp.

Referenced by NdbShutdown().

{
  writeChildInfo("sphase", currentStartPhase);
  writeChildInfo("exit", code);
  fprintf(child_info_file_w, "\n");
  fclose(child_info_file_r);
  fclose(child_info_file_w);
  signal(6, SIG_DFL);
  abort();
}

Here is the caller graph for this function:

void childExit	(	int	code,
		Uint32	currentStartPhase
	)

Definition at line 87 of file main.cpp.

Referenced by NdbShutdown().

{
  writeChildInfo("sphase", currentStartPhase);
  writeChildInfo("exit", code);
  fprintf(child_info_file_w, "\n");
  fclose(child_info_file_r);
  fclose(child_info_file_w);
  exit(code);
}

Here is the caller graph for this function:

void childReportError

(

int

error

)

Definition at line 82 of file main.cpp.

References writeChildInfo().

{
  writeChildInfo("error", error);
}

Here is the call graph for this function:

void childReportSignal

(

int

signum

)

Definition at line 77 of file main.cpp.

References writeChildInfo().

Referenced by handler_error(), handler_shutdown(), and main().

{
  writeChildInfo("signal", signum);
}

Here is the call graph for this function:

Here is the caller graph for this function:

static bool get_int_property	(	Properties &	info,
		const char *	token,
		Uint32 *	int_val
	)			[static]

Definition at line 131 of file main.cpp.

References endptr, Properties::get(), and strtol().

Referenced by reportShutdown().

{
  const char *str_val= 0;
  if (!info.get(token, &str_val))
    return false;
  char *endptr;
  long int tmp= strtol(str_val, &endptr, 10);
  if (str_val == endptr)
    return false;
  *int_val = tmp;
  return true;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void handler_error

(

int

signum

)

Definition at line 613 of file main.cpp.

References childReportSignal(), ERROR_SET_SIGNAL, yaSSL::fatal, g_eventLogger, info, Logger::info(), my_thread_id(), NDBD_EXIT_OS_SIGNAL_RECEIVED, NdbMutex_Trylock(), NdbSleep_MilliSleep(), BaseString::snprintf(), theShutdownMutex, and thread_id.

Referenced by catchsigs().

                         {
  // only let one thread run shutdown
  static long thread_id= 0;

  if (thread_id != 0 && thread_id == my_thread_id())
  {
    // Shutdown thread received signal
#ifndef NDB_WIN32
        signal(signum, SIG_DFL);
    kill(getpid(), signum);
#endif
    while(true)
      NdbSleep_MilliSleep(10);
  }
  if(theShutdownMutex && NdbMutex_Trylock(theShutdownMutex) != 0)
    while(true)
      NdbSleep_MilliSleep(10);
  thread_id= my_thread_id();
  g_eventLogger.info("Received signal %d. Running error handler.", signum);
  childReportSignal(signum);
  // restart the system
  char errorData[64], *info= 0;
#ifdef HAVE_STRSIGNAL
  info= strsignal(signum);
#endif
  BaseString::snprintf(errorData, sizeof(errorData), "Signal %d received; %s", signum,
                       info ? info : "No text for signal available");
  ERROR_SET_SIGNAL(fatal, NDBD_EXIT_OS_SIGNAL_RECEIVED, errorData, __FILE__);
}

Here is the call graph for this function:

Here is the caller graph for this function:

void handler_shutdown

(

int

signum

)

Definition at line 604 of file main.cpp.

References childReportError(), childReportSignal(), g_eventLogger, globalData, Logger::info(), perform_stop, and GlobalData::theRestartFlag.

Referenced by catchsigs().

                            {
  g_eventLogger.info("Received signal %d. Performing stop.", signum);
  childReportError(0);
  childReportSignal(signum);
  globalData.theRestartFlag = perform_stop;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void handler_sigusr1

(

int

signum

)

Definition at line 645 of file main.cpp.

References failed_startup_flag, failed_startups, g_eventLogger, and Logger::info().

Referenced by main().

{
  if (!failed_startup_flag)
  {
    failed_startups++;
    failed_startup_flag = true;
  }
  g_eventLogger.info("Angel received ndbd startup failure count %u.", failed_startups);
}

Here is the call graph for this function:

Here is the caller graph for this function:

static int insert	(	const char *	pair,
		Properties &	p
	)			[static]

Definition at line 108 of file main.cpp.

References p, BaseString::split(), split(), trim(), and BaseString::trim().

{
  BaseString tmp(pair);
  
  tmp.trim(" \t\n\r");
  Vector<BaseString> split;
  tmp.split(split, ":=", 2);
  if(split.size() != 2)
    return -1;
  p.put(split[0].trim().c_str(), split[1].trim().c_str()); 
  return 0;
}

Here is the call graph for this function:

int main	(	int	argc,
		char **	argv
	)

Definition at line 230 of file main.cpp.

References Logger::alert(), assert, buf, catchsigs(), child_info_file_r, child_info_file_w, childReportSignal(), Configuration::closeConfiguration(), TransporterRegistry::connect_client(), EmulatorData::create(), Logger::createConsoleHandler(), WatchDog::doStart(), ThreadConfig::doStart(), Logger::enable(), errno, Logger::error(), ERROR_SET, exit, failed_startup_flag, failed_startups, yaSSL::fatal, Configuration::fetch_configuration(), g_eventLogger, Configuration::get_config_retriever(), ConfigRetriever::get_mgmHandlePtr(), Configuration::getDaemonMode(), Configuration::getForegroundMode(), globalData, globalEmulatorData, globalTransporterRegistry, handler_sigusr1(), Logger::info(), Configuration::init(), initial_state, ThreadConfig::ipControlLoop(), Logger::LL_CRITICAL, Logger::LL_ERROR, Logger::LL_INFO, Logger::LL_ON, Logger::LL_WARNING, LogLevel::llStartUp, SimBlockList::load(), logfile, SignalLoggerManager::LogInOut, Configuration::m_logLevel, EventLoggerBase::m_logLevel, EmulatorData::m_socket_server, MAX_FAILED_STARTUPS, my_setwd(), MYF, NDB_INIT, NdbConfig_get_path(), NdbConfig_PidFileName(), NdbConfig_SignalLogFileName(), NdbConfig_StdoutFileName(), NDBD_EXIT_INVALID_CONFIG, NdbDaemon_ErrorText, NdbDaemon_Make(), ndbout(), ndbout_c(), NdbShutdown(), NdbThread_SetConcurrencyLevel(), NRT_Default, NRT_DoStart_InitialStart, NRT_DoStart_Restart, NRT_NoStart_InitialStart, NRT_NoStart_Restart, NST_ErrorHandlerStartup, NST_Normal, GlobalData::ownId, perform_start, reportShutdown(), Logger::setCategory(), ErrorReporter::setErrorHandlerShutdownType(), Configuration::setInitialStart(), LogLevel::setLogLevel(), Configuration::setupConfiguration(), SIGPIPE, NodeState::SL_CMVMI, NodeState::SL_STARTING, TransporterRegistry::start_clients(), TransporterRegistry::start_service(), TransporterRegistry::startReceiving(), TransporterRegistry::startSending(), SocketServer::startServer(), status, Configuration::stopOnError(), systemInfo(), GlobalData::testOn, EmulatorData::theConfiguration, GlobalData::theRestartFlag, EmulatorData::theSimBlockList, EmulatorData::theThreadConfig, EmulatorData::theWatchDog, WEXITSTATUS, and WIFEXITED.

{
  NDB_INIT(argv[0]);
  // Print to stdout/console
  g_eventLogger.createConsoleHandler();
  g_eventLogger.setCategory("ndbd");
  g_eventLogger.enable(Logger::LL_ON, Logger::LL_INFO);
  g_eventLogger.enable(Logger::LL_ON, Logger::LL_CRITICAL);
  g_eventLogger.enable(Logger::LL_ON, Logger::LL_ERROR);
  g_eventLogger.enable(Logger::LL_ON, Logger::LL_WARNING);

  g_eventLogger.m_logLevel.setLogLevel(LogLevel::llStartUp, 15);

  globalEmulatorData.create();

  // Parse command line options
  Configuration* theConfig = globalEmulatorData.theConfiguration;
  if(!theConfig->init(argc, argv)){
    return NRT_Default;
  }
  
  { // Do configuration
#ifndef NDB_WIN32
        signal(SIGPIPE, SIG_IGN);
#endif
    theConfig->fetch_configuration();
  }

  my_setwd(NdbConfig_get_path(0), MYF(0));

  if (theConfig->getDaemonMode()) {
    // Become a daemon
    char *lockfile= NdbConfig_PidFileName(globalData.ownId);
    char *logfile=  NdbConfig_StdoutFileName(globalData.ownId);
    NdbAutoPtr<char> tmp_aptr1(lockfile), tmp_aptr2(logfile);

    if (NdbDaemon_Make(lockfile, logfile, 0) == -1) {
      ndbout << "Cannot become daemon: " << NdbDaemon_ErrorText << endl;
      return 1;
    }
  }

#ifndef NDB_WIN32
  signal(SIGUSR1, handler_sigusr1);

  pid_t child = -1;
  while (! theConfig->getForegroundMode()) // the cond is const
  {
    // setup reporting between child and parent
    int filedes[2];
    if (pipe(filedes))
    {
      g_eventLogger.error("pipe() failed with errno=%d (%s)",
                          errno, strerror(errno));
      return 1;
    }
    else
    {
      if (!(child_info_file_w= fdopen(filedes[1],"w")))
      {
        g_eventLogger.error("fdopen() failed with errno=%d (%s)",
                            errno, strerror(errno));
      }
      if (!(child_info_file_r= fdopen(filedes[0],"r")))
      {
        g_eventLogger.error("fdopen() failed with errno=%d (%s)",
                            errno, strerror(errno));
      }
    }

    if ((child = fork()) <= 0)
      break; // child or error

    catchsigs(true);

    theConfig->closeConfiguration(false);

    int status = 0, error_exit = 0, signum = 0;
    while(waitpid(child, &status, 0) != child);
    if(WIFEXITED(status)){
      switch(WEXITSTATUS(status)){
      case NRT_Default:
        g_eventLogger.info("Angel shutting down");
        reportShutdown(theConfig, 0, 0);
        exit(0);
        break;
      case NRT_NoStart_Restart:
        theConfig->setInitialStart(false);
        globalData.theRestartFlag = initial_state;
        break;
      case NRT_NoStart_InitialStart:
        theConfig->setInitialStart(true);
        globalData.theRestartFlag = initial_state;
        break;
      case NRT_DoStart_InitialStart:
        theConfig->setInitialStart(true);
        globalData.theRestartFlag = perform_start;
        break;
      default:
        error_exit = 1;
        if(theConfig->stopOnError()){
          reportShutdown(theConfig, error_exit, 0);
          exit(0);
        }
        // Fall-through
      case NRT_DoStart_Restart:
        theConfig->setInitialStart(false);
        globalData.theRestartFlag = perform_start;
        break;
      }
    } else {
      error_exit = 1;
      if (WIFSIGNALED(status))
      {
        signum = WTERMSIG(status);
        childReportSignal(signum);
      }
      else
      {
        signum = 127;
        g_eventLogger.info("Unknown exit reason. Stopped.");
      }
      if(theConfig->stopOnError()){
        reportShutdown(theConfig, error_exit, 0);
        exit(0);
      }
    }

    if (!failed_startup_flag)
    {
      // Reset the counter for consecutive failed startups
      failed_startups = 0;
    }
    else if (failed_startups >= MAX_FAILED_STARTUPS && !theConfig->stopOnError())
    {
      g_eventLogger.alert("Ndbd has failed %u consecutive startups. "
                          "Not restarting", failed_startups);
      reportShutdown(theConfig, error_exit, 0);
      exit(0);
    }
    failed_startup_flag = false;
    reportShutdown(theConfig, error_exit, 1);
    g_eventLogger.info("Ndb has terminated (pid %d) restarting", child);
    theConfig->fetch_configuration();
  }

  if (child >= 0)
    g_eventLogger.info("Angel pid: %d ndb pid: %d", getppid(), getpid());
  else if (child > 0)
    g_eventLogger.info("Ndb pid: %d", getpid());
  else
    g_eventLogger.info("Ndb started in foreground");
#else
  g_eventLogger.info("Ndb started");
#endif
  theConfig->setupConfiguration();
  systemInfo(* theConfig, * theConfig->m_logLevel); 
  
    // Load blocks
  globalEmulatorData.theSimBlockList->load(globalEmulatorData);
    
  // Set thread concurrency for Solaris' light weight processes
  int status;
  status = NdbThread_SetConcurrencyLevel(30);
  assert(status == 0);
  
#ifdef VM_TRACE
  // Create a signal logger
  char *buf= NdbConfig_SignalLogFileName(globalData.ownId);
  NdbAutoPtr<char> tmp_aptr(buf);
  FILE * signalLog = fopen(buf, "a");
  globalSignalLoggers.setOwnNodeId(globalData.ownId);
  globalSignalLoggers.setOutputStream(signalLog);
#if 0 // to log startup
  globalSignalLoggers.log(SignalLoggerManager::LogInOut, "BLOCK=DBDICT,DBDIH");
  globalData.testOn = 1;
#endif
#endif
  
  catchsigs(false);
   
  ErrorReporter::setErrorHandlerShutdownType(NST_ErrorHandlerStartup);

  switch(globalData.theRestartFlag){
  case initial_state:
    globalEmulatorData.theThreadConfig->doStart(NodeState::SL_CMVMI);
    break;
  case perform_start:
    globalEmulatorData.theThreadConfig->doStart(NodeState::SL_CMVMI);
    globalEmulatorData.theThreadConfig->doStart(NodeState::SL_STARTING);
    break;
  default:
    assert("Illegal state globalData.theRestartFlag" == 0);
  }

  globalTransporterRegistry.startSending();
  globalTransporterRegistry.startReceiving();
  if (!globalTransporterRegistry.start_service(*globalEmulatorData.m_socket_server)){
    ndbout_c("globalTransporterRegistry.start_service() failed");
    exit(-1);
  }

  // Re-use the mgm handle as a transporter
  if(!globalTransporterRegistry.connect_client(
                 theConfig->get_config_retriever()->get_mgmHandlePtr()))
      ERROR_SET(fatal, NDBD_EXIT_INVALID_CONFIG,
                "Connection to mgmd terminated before setup was complete", 
                "StopOnError missing");

  if (!globalTransporterRegistry.start_clients()){
    ndbout_c("globalTransporterRegistry.start_clients() failed");
    exit(-1);
  }

  globalEmulatorData.theWatchDog->doStart();
  
  globalEmulatorData.m_socket_server->startServer();

  //  theConfig->closeConfiguration();

  globalEmulatorData.theThreadConfig->ipControlLoop();
  
  NdbShutdown(NST_Normal);

  return NRT_Default;
}

Here is the call graph for this function:

static int readChildInfo

(

Properties &

info

)

[static]

Definition at line 121 of file main.cpp.

References buf, child_info_file_r, child_info_file_w, and insert().

Referenced by reportShutdown().

{
  fclose(child_info_file_w);
  char buf[128];
  while (fgets(buf,sizeof(buf),child_info_file_r))
    insert(buf,info);
  fclose(child_info_file_r);
  return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function:

int reportShutdown	(	class Configuration *	config,
		int	error_exit,
		int	restart
	)

Definition at line 145 of file main.cpp.

References BaseString::append(), BaseString::c_str(), Logger::error(), error, g_eventLogger, get_int_property(), EventReport::getEventType(), EventReport::getNodeId(), globalData, h, handle_error(), info, initial_state, EventLogger::log(), n, NDB_LE_NDBStopCompleted, NDB_LE_NDBStopForced, ndb_mgm_connect(), ndb_mgm_create_handle(), ndb_mgm_destroy_handle(), ndb_mgm_disconnect(), ndb_mgm_get_latest_error_desc(), ndb_mgm_get_latest_error_msg(), ndb_mgm_report_event(), ndb_mgm_set_connectstring(), GlobalData::ownId, readChildInfo(), EventReport::setEventType(), EventReport::setNodeId(), GlobalData::theRestartFlag, and Logger::warning().

Referenced by main().

{
  Uint32 error= 0, signum= 0, sphase= 256;
  Properties info;
  readChildInfo(info);

  get_int_property(info, "signal", &signum);
  get_int_property(info, "error", &error);
  get_int_property(info, "sphase", &sphase);

  Uint32 length, theData[25];
  EventReport *rep = (EventReport *)theData;

  rep->setNodeId(globalData.ownId);
  if (restart)
    theData[1] =                                    1      |
      (globalData.theRestartFlag == initial_state ? 2 : 0) |
      (config->getInitialStart()                  ? 4 : 0);
  else
    theData[1] = 0;

  if (error_exit == 0)
  {
    rep->setEventType(NDB_LE_NDBStopCompleted);
    theData[2] = signum;
    length = 3;
  }
  else
  {
    rep->setEventType(NDB_LE_NDBStopForced);
    theData[2] = signum;
    theData[3] = error;
    theData[4] = sphase;
    theData[5] = 0; // extra
    length = 6;
  }

  { // Log event
    const EventReport * const eventReport = (EventReport *)&theData[0];
    g_eventLogger.log(eventReport->getEventType(), theData,
                      eventReport->getNodeId(), 0);
  }

  for (unsigned n = 0; n < config->m_mgmds.size(); n++)
  {
    NdbMgmHandle h = ndb_mgm_create_handle();
    if (h == 0 ||
        ndb_mgm_set_connectstring(h, config->m_mgmds[n].c_str()) ||
        ndb_mgm_connect(h,
                        1, //no_retries
                        0, //retry_delay_in_seconds
                        0  //verbose
                        ))
      goto handle_error;

    {
      if (ndb_mgm_report_event(h, theData, length))
        goto handle_error;
    }
    goto do_next;

handle_error:
    if (h)
    {
      BaseString tmp(ndb_mgm_get_latest_error_msg(h));
      tmp.append(" : ");
      tmp.append(ndb_mgm_get_latest_error_desc(h));
      g_eventLogger.warning("Unable to report shutdown reason to %s: %s",
                            config->m_mgmds[n].c_str(), tmp.c_str());
    }
    else
    {
      g_eventLogger.error("Unable to report shutdown reason to %s",
                          config->m_mgmds[n].c_str());
    }
do_next:
    if (h)
    {
      ndb_mgm_disconnect(h);
      ndb_mgm_destroy_handle(&h);
    }
  }
  return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void systemInfo	(	const Configuration &	conf,
		const LogLevel &	ll
	)

Definition at line 483 of file main.cpp.

References g_eventLogger, LogLevel::getLogLevel(), globalData, Logger::info(), int(), LogLevel::llStartUp, memset, NDB_VERSION_STRING, and GlobalData::ownId.

Referenced by main().

                                                                   {
#ifdef NDB_WIN32
  int processors = 0;
  int speed;
  SYSTEM_INFO sinfo;
  GetSystemInfo(&sinfo);
  processors = sinfo.dwNumberOfProcessors;
  HKEY hKey;
  if(ERROR_SUCCESS==RegOpenKeyEx
     (HKEY_LOCAL_MACHINE, 
      TEXT("HARDWARE\\DESCRIPTION\\System\\CentralProcessor\\0"), 
      0, KEY_READ, &hKey)) {
    DWORD dwMHz;
    DWORD cbData = sizeof(dwMHz);
    if(ERROR_SUCCESS==RegQueryValueEx(hKey, 
                                      "~MHz", 0, 0, (LPBYTE)&dwMHz, &cbData)) {
      speed = int(dwMHz);
    }
    RegCloseKey(hKey);
  }
#elif defined NDB_SOLARIS // ok
  // Search for at max 16 processors among the first 256 processor ids
  processor_info_t pinfo; memset(&pinfo, 0, sizeof(pinfo));
  int pid = 0;
  while(processors < 16 && pid < 256){
    if(!processor_info(pid++, &pinfo))
      processors++;
  }
  speed = pinfo.pi_clock;
#endif
  
  if(logLevel.getLogLevel(LogLevel::llStartUp) > 0){
    g_eventLogger.info("NDB Cluster -- DB node %d", globalData.ownId);
    g_eventLogger.info("%s --", NDB_VERSION_STRING);
    if (config.get_mgmd_host())
      g_eventLogger.info("Configuration fetched at %s port %d",
                         config.get_mgmd_host(), config.get_mgmd_port());
#ifdef NDB_SOLARIS // ok
    g_eventLogger.info("NDB is running on a machine with %d processor(s) at %d MHz",
                       processor, speed);
#endif
  }
  if(logLevel.getLogLevel(LogLevel::llStartUp) > 3){
    Uint32 t = config.timeBetweenWatchDogCheck();
    g_eventLogger.info("WatchDog timer is set to %d ms", t);
  }

}

Here is the call graph for this function:

Here is the caller graph for this function:

static void writeChildInfo	(	const char *	token,
		int	val
	)			[static]

Definition at line 71 of file main.cpp.

References child_info_file_w.

Referenced by childAbort(), childExit(), childReportError(), and childReportSignal().

{
  fprintf(child_info_file_w, "%s=%d\n", token, val);
  fflush(child_info_file_w);
}

Here is the caller graph for this function:

---

Variable Documentation

FILE* child_info_file_r = stdin [static]

Definition at line 68 of file main.cpp.

Referenced by childAbort(), childExit(), main(), and readChildInfo().

FILE* child_info_file_w = stdout [static]

Definition at line 69 of file main.cpp.

Referenced by childAbort(), childExit(), main(), readChildInfo(), and writeChildInfo().

bool failed_startup_flag = false [static]

Definition at line 55 of file main.cpp.

Referenced by handler_sigusr1(), and main().

Uint32 failed_startups = 0 [static]

Definition at line 57 of file main.cpp.

Referenced by handler_sigusr1(), and main().

EventLogger g_eventLogger

Definition at line 47 of file Cmvmi.cpp.

NdbMutex* theShutdownMutex

Definition at line 71 of file Emulator.cpp.

Referenced by EmulatorData::create(), EmulatorData::destroy(), EmulatorData::EmulatorData(), handler_error(), and NdbShutdown().

---

• Products
• MySQL Enterprise
• MySQL Cluster
• MySQL Embedded (OEM/ISV)
• MySQL Data Warehouse
• MySQL Backup & Recovery
• MySQL Workbench
• MySQL Connectors
• Online Shop

• Downloads
• MySQL Community Server
• MySQL Enterprise
• MySQL Proxy
• MySQL Cluster
• MySQL Workbench
• GUI Tools
• Connectors
• Archives
• Snapshots
• Mirrors

• Developer Zone
• Documentation
• Librarian
• Developer Articles
• Forums
• Bugs
• Forge
• Planet MySQL
• Labs
• MySQL Meetups
• Guilds
• Lists

• About
• About MySQL
• Contact Us
• Legal
• Privacy Policy
• Job Opportunities
• Site Map

© 1995-2008 MySQL AB, 2008- Sun Microsystems, Inc.