Category

Development Platform
Home > SourceCode/Document > Database system > MySQL > View Code
WatchDog.cpp
Package: mysql-4.1.16-win-src.zip　[view]
Upload User: romrleung
Upload Date: 2022-05-23
Package Size: 18897k
Code Size: 3k
Category:

MySQL

Development Platform:

Visual C++

WatchDog.cpp：Code Content
  1. /* Copyright (C) 2003 MySQL AB
  3.    This program is free software; you can redistribute it and/or modify
  4.    it under the terms of the GNU General Public License as published by
  5.    the Free Software Foundation; either version 2 of the License, or
  6.    (at your option) any later version.
  8.    This program is distributed in the hope that it will be useful,
  9.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  10.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  11.    GNU General Public License for more details.
  13.    You should have received a copy of the GNU General Public License
  14.    along with this program; if not, write to the Free Software
  15.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  18. #include <ndb_global.h>
  19. #include <my_pthread.h>
  21. #include "WatchDog.hpp"
  22. #include "GlobalData.hpp"
  23. #include <NdbOut.hpp>
  24. #include <NdbSleep.h>
  25. #include <ErrorHandlingMacros.hpp>
  26.    
  27. extern "C" 
  28. void* 
  29. runWatchDog(void* w){
  30.   ((WatchDog*)w)->run();
  31.   return NULL;
  32. }
  34. WatchDog::WatchDog(Uint32 interval) : 
  35.   theIPValue(globalData.getWatchDogPtr())
  36. {
  37.   setCheckInterval(interval);
  38.   theStop = false;
  39.   theThreadPtr = 0;
  40. }
  42. WatchDog::~WatchDog(){
  43.   doStop();
  44. }
  46. Uint32
  47. WatchDog::setCheckInterval(Uint32 interval){
  48.   // An interval of less than 70ms is not acceptable
  49.   return theInterval = (interval < 70 ? 70 : interval);
  50. }
  52. void
  53. WatchDog::doStart(){
  54.   theStop = false;
  55.   theThreadPtr = NdbThread_Create(runWatchDog, 
  56.   (void**)this, 
  57.   32768,
  58.   "ndb_watchdog",
  59.                                   NDB_THREAD_PRIO_HIGH);
  60. }
  62. void
  63. WatchDog::doStop(){
  64.   void *status;
  65.   theStop = true;
  66.   if(theThreadPtr){
  67.     NdbThread_WaitFor(theThreadPtr, &status);
  68.     NdbThread_Destroy(&theThreadPtr);
  69.   }
  70. }
  72. void 
  73. WatchDog::run(){
  74.   unsigned int anIPValue;
  75.   unsigned int alerts = 0;
  76.   unsigned int oldIPValue = 0;
  77.   
  78.   // WatchDog for the single threaded NDB
  79.   while(!theStop){
  80.     Uint32 tmp  = theInterval / 500;
  81.     tmp= (tmp ? tmp : 1);
  82.     
  83.     while(!theStop && tmp > 0){
  84.       NdbSleep_MilliSleep(500);
  85.       tmp--;
  86.     }
  87.     
  88.     if(theStop)
  89.       break;
  91.     // Verify that the IP thread is not stuck in a loop
  92.     anIPValue = *theIPValue;
  93.     if(anIPValue != 0) {
  94.       oldIPValue = anIPValue;
  95.       globalData.incrementWatchDogCounter(0);
  96.       alerts = 0;
  97.     } else {
  98.       alerts++;
  99.       ndbout << "Ndb kernel is stuck in: ";
  100.       switch (oldIPValue) {
  101.       case 1:
  102.         ndbout << "Job Handling" << endl;
  103.         break;
  104.       case 2:
  105.         ndbout << "Scanning Timers" << endl;
  106.         break;
  107.       case 3:
  108.         ndbout << "External I/O" << endl;
  109.         break;
  110.       case 4:
  111.         ndbout << "Print Job Buffers at crash" << endl;
  112.         break;
  113.       case 5:
  114.         ndbout << "Checking connections" << endl;
  115.         break;
  116.       case 6:
  117.         ndbout << "Performing Send" << endl;
  118.         break;
  119.       case 7:
  120.         ndbout << "Polling for Receive" << endl;
  121.         break;
  122.       case 8:
  123.         ndbout << "Performing Receive" << endl;
  124.         break;
  125.       default:
  126.         ndbout << "Unknown place" << endl;
  127.         break;
  128.       }//switch
  129.       if(alerts == 3){
  130. shutdownSystem();
  131.       }
  132.     }
  133.   }
  134.   return;
  135. }
  137. void
  138. WatchDog::shutdownSystem(){
  139.   
  140.   ErrorReporter::handleError(ecError,
  141.      ERR_PROGRAMERROR,
  142.      "WatchDog terminate",
  143.      __FILE__,
  144.      NST_Watchdog);
  145. }