anonymous_namespace{HeavyDB.cpp} Namespace Reference

Functions
void	register_signal_handler (int signum, void(*handler)(int))
void	heavydb_signal_handler (int signum)
void	register_signal_handlers ()

Variables
std::atomic< int >	g_saw_signal {-1}
std::shared_ptr< TThreadedServer >	g_thrift_http_server
std::shared_ptr< TThreadedServer >	g_thrift_http_binary_server
std::shared_ptr< TThreadedServer >	g_thrift_tcp_server
std::shared_ptr< DBHandler >	g_warmup_handler
std::shared_ptr< DBHandler >	g_db_handler

Function Documentation

void anonymous_namespace{HeavyDB.cpp}::heavydb_signal_handler

(

int

signum

)

Definition at line 117 of file HeavyDB.cpp.

References g_running, g_saw_signal, and register_signal_handler().

Referenced by register_signal_handlers().

                                        {
  // Record the signal number for logging during shutdown.
  // Only records the first signal if called more than once.
  int expected_signal{-1};
  if (!g_saw_signal.compare_exchange_strong(expected_signal, signum)) {
    return;  // this wasn't the first signal
  }

  // This point should never be reached more than once.

  // Tell heartbeat() to shutdown by unsetting the 'g_running' flag.
  // If 'g_running' is already false, this has no effect and the
  // shutdown is already in progress.
  g_running = false;

  // Handle core dumps specially by pausing inside this signal handler
  // because on some systems, some signals will execute their default
  // action immediately when and if the signal handler returns.
  // We would like to do some emergency cleanup before core dump.
  if (signum == SIGABRT || signum == SIGSEGV || signum == SIGFPE
#ifndef _WIN32
      || signum == SIGQUIT
#endif
  ) {
    // Wait briefly to give heartbeat() a chance to flush the logs and
    // do any other emergency shutdown tasks.
    std::this_thread::sleep_for(std::chrono::seconds(2));

    // Explicitly trigger whatever default action this signal would
    // have done, such as terminate the process or dump core.
    // Signals are currently blocked so this new signal will be queued
    // until this signal handler returns.
    register_signal_handler(signum, SIG_DFL);
#ifdef _WIN32
    raise(signum);
#else
    kill(getpid(), signum);
#endif
    std::this_thread::sleep_for(std::chrono::seconds(5));

#ifndef __APPLE__
    // as a last resort, abort
    // primary used in Docker environments, where we can end up with PID 1 and fail to
    // catch unix signals
    quick_exit(signum);
#endif
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

void anonymous_namespace{HeavyDB.cpp}::register_signal_handler	(	int	signum,
		void(*)(int)	handler
	)

Definition at line 96 of file HeavyDB.cpp.

Referenced by heavydb_signal_handler(), and register_signal_handlers().

                                                               {
#ifdef _WIN32
  signal(signum, handler);
#else
  struct sigaction act;
  memset(&act, 0, sizeof(act));
  if (handler != SIG_DFL && handler != SIG_IGN) {
    // block all signal deliveries while inside the signal handler
    sigfillset(&act.sa_mask);
  }
  act.sa_handler = handler;
  sigaction(signum, &act, NULL);
#endif
}

Here is the caller graph for this function:

void anonymous_namespace{HeavyDB.cpp}::register_signal_handlers

(

)

Definition at line 166 of file HeavyDB.cpp.

References heavydb_signal_handler(), and register_signal_handler().

Referenced by startHeavyDBServer().

                                {
  register_signal_handler(SIGINT, heavydb_signal_handler);
#ifndef _WIN32
  register_signal_handler(SIGQUIT, heavydb_signal_handler);
  register_signal_handler(SIGHUP, heavydb_signal_handler);
#endif
  register_signal_handler(SIGTERM, heavydb_signal_handler);
  register_signal_handler(SIGSEGV, heavydb_signal_handler);
  register_signal_handler(SIGABRT, heavydb_signal_handler);
#ifndef _WIN32
  // Thrift secure socket can cause problems with SIGPIPE
  register_signal_handler(SIGPIPE, SIG_IGN);
#endif
}

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

std::shared_ptr<DBHandler> anonymous_namespace{HeavyDB.cpp}::g_db_handler

Definition at line 94 of file HeavyDB.cpp.

Referenced by startHeavyDBServer().

std::atomic<int> anonymous_namespace{HeavyDB.cpp}::g_saw_signal {-1}

Definition at line 84 of file HeavyDB.cpp.

Referenced by heartbeat(), heavydb_signal_handler(), and startHeavyDBServer().

std::shared_ptr<TThreadedServer> anonymous_namespace{HeavyDB.cpp}::g_thrift_http_binary_server

Definition at line 87 of file HeavyDB.cpp.

std::shared_ptr<TThreadedServer> anonymous_namespace{HeavyDB.cpp}::g_thrift_http_server

Definition at line 86 of file HeavyDB.cpp.

std::shared_ptr<TThreadedServer> anonymous_namespace{HeavyDB.cpp}::g_thrift_tcp_server

Definition at line 88 of file HeavyDB.cpp.

std::shared_ptr<DBHandler> anonymous_namespace{HeavyDB.cpp}::g_warmup_handler

Definition at line 90 of file HeavyDB.cpp.