开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
sql_manager.cpp
资源名称：mysql-4.1.16-win-src.zip　[点击查看]
上传用户：romrleung
上传日期：2022-05-23
资源大小：18897k
文件大小：3k
源码类别：

MySQL数据库

开发平台：

Visual C++

sql_manager.cpp：源码内容
  1. /* Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult 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 */
  17. /* 
  18.  * sql_manager.cc
  19.  * This thread manages various maintenance tasks.
  20.  *
  21.  *   o Flushing the tables every flush_time seconds.
  22.  *   o Berkeley DB: removing unneeded log files.
  23.  */
  25. #include "mysql_priv.h"
  26. #include "sql_manager.h"
  28. ulong volatile manager_status;
  29. bool volatile manager_thread_in_use;
  31. pthread_t manager_thread;
  32. pthread_mutex_t LOCK_manager;
  33. pthread_cond_t COND_manager;
  35. extern "C" pthread_handler_decl(handle_manager,arg __attribute__((unused)))
  36. {
  37.   int error = 0;
  38.   ulong status;
  39.   struct timespec abstime;
  40.   bool reset_flush_time = TRUE;
  41.   my_thread_init();
  42.   DBUG_ENTER("handle_manager");
  44.   pthread_detach_this_thread();
  45.   manager_thread = pthread_self();
  46.   manager_status = 0;
  47.   manager_thread_in_use = 1;
  49.   for (;;)
  50.   {
  51.     pthread_mutex_lock(&LOCK_manager);
  52.     /* XXX: This will need to be made more general to handle different
  53.      * polling needs. */
  54.     if (flush_time)
  55.     {
  56.       if (reset_flush_time)
  57.       {
  58. set_timespec(abstime, flush_time);
  59.         reset_flush_time = FALSE;
  60.       }
  61.       while (!manager_status && !error && !abort_loop)
  62.         error = pthread_cond_timedwait(&COND_manager, &LOCK_manager, &abstime);
  63.     }
  64.     else
  65.       while (!manager_status && !error && !abort_loop)
  66.         error = pthread_cond_wait(&COND_manager, &LOCK_manager);
  67.     status = manager_status;
  68.     manager_status = 0;
  69.     pthread_mutex_unlock(&LOCK_manager);
  71.     if (abort_loop)
  72.       break;
  74.     if (error)  /* == ETIMEDOUT */
  75.     {
  76.       flush_tables();
  77.       error = 0;
  78.       reset_flush_time = TRUE;
  79.     }
  81. #ifdef HAVE_BERKELEY_DB
  82.     if (status & MANAGER_BERKELEY_LOG_CLEANUP)
  83.     {
  84.       berkeley_cleanup_log_files();
  85.       status &= ~MANAGER_BERKELEY_LOG_CLEANUP;
  86.     }
  87. #endif
  89.     if (status)
  90.       DBUG_PRINT("error", ("manager did not handle something: %lx", status));
  91.   }
  92.   manager_thread_in_use = 0;
  93.   my_thread_end();
  94.   DBUG_RETURN(NULL);
  95. }