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

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

MySQL数据库

开发平台：

Visual C++

Services.hpp：源码内容
  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 */
  17. #ifndef MGMAPI_SERVICE_HPP
  18. #define MGMAPI_SERVICE_HPP
  20. #include <SocketServer.hpp>
  21. #include <NdbSleep.h>
  22. #include <Parser.hpp>
  23. #include <OutputStream.hpp>
  24. #include <InputStream.hpp>
  26. #include "MgmtSrvr.hpp"
  28. /** Undefine this to remove backwards compatibility for "GET CONFIG". */
  29. #define MGM_GET_CONFIG_BACKWARDS_COMPAT
  31. class MgmApiSession : public SocketServer::Session
  32. {
  33.   static void stop_session_if_not_connected(SocketServer::Session *_s, void *data);
  34. private:
  35.   typedef Parser<MgmApiSession> Parser_t;
  37.   class MgmtSrvr & m_mgmsrv;
  38.   InputStream *m_input;
  39.   OutputStream *m_output;
  40.   Parser_t *m_parser;
  41.   MgmtSrvr::Allocated_resources *m_allocated_resources;
  42.   char m_err_str[1024];
  44.   void getConfig_common(Parser_t::Context &ctx,
  45. const class Properties &args,
  46. bool compat = false);
  47.   const char *get_error_text(int err_no)
  48.   { return m_mgmsrv.getErrorText(err_no, m_err_str, sizeof(m_err_str)); }
  50. public:
  51.   MgmApiSession(class MgmtSrvr & mgm, NDB_SOCKET_TYPE sock);  
  52.   virtual ~MgmApiSession();
  53.   void runSession();
  55.   void getStatPort(Parser_t::Context &ctx, const class Properties &args);
  56.   void getConfig(Parser_t::Context &ctx, const class Properties &args);
  57. #ifdef MGM_GET_CONFIG_BACKWARDS_COMPAT
  58.   void getConfig_old(Parser_t::Context &ctx);
  59. #endif /* MGM_GET_CONFIG_BACKWARDS_COMPAT */
  61.   void get_nodeid(Parser_t::Context &ctx, const class Properties &args);
  62.   void getVersion(Parser_t::Context &ctx, const class Properties &args);
  63.   void getStatus(Parser_t::Context &ctx, const class Properties &args);
  64.   void getInfoClusterLog(Parser_t::Context &ctx, const class Properties &args);
  65.   void restart(Parser_t::Context &ctx, const class Properties &args);
  66.   void restartAll(Parser_t::Context &ctx, const class Properties &args);
  67.   void insertError(Parser_t::Context &ctx, const class Properties &args);
  68.   void setTrace(Parser_t::Context &ctx, const class Properties &args);
  69.   void logSignals(Parser_t::Context &ctx, const class Properties &args);
  70.   void startSignalLog(Parser_t::Context &ctx, const class Properties &args);
  71.   void stopSignalLog(Parser_t::Context &ctx, const class Properties &args);
  72.   void dumpState(Parser_t::Context &ctx, const class Properties &args);
  73.   void startBackup(Parser_t::Context &ctx, const class Properties &args);
  74.   void abortBackup(Parser_t::Context &ctx, const class Properties &args);
  75.   void enterSingleUser(Parser_t::Context &ctx, const class Properties &args);
  76.   void exitSingleUser(Parser_t::Context &ctx, const class Properties &args);
  77.   void stop(Parser_t::Context &ctx, const class Properties &args);
  78.   void stopAll(Parser_t::Context &ctx, const class Properties &args);
  79.   void start(Parser_t::Context &ctx, const class Properties &args);
  80.   void startAll(Parser_t::Context &ctx, const class Properties &args);
  81.   void bye(Parser_t::Context &ctx, const class Properties &args);
  82.   void setLogLevel(Parser_t::Context &ctx, const class Properties &args);
  83.   void setClusterLogLevel(Parser_t::Context &ctx, 
  84.   const class Properties &args);
  85.   void setLogFilter(Parser_t::Context &ctx, const class Properties &args);
  87.   void setParameter(Parser_t::Context &ctx, const class Properties &args);
  88.   void listen_event(Parser_t::Context &ctx, const class Properties &args);
  90.   void purge_stale_sessions(Parser_t::Context &ctx, const class Properties &args);
  91.   void check_connection(Parser_t::Context &ctx, const class Properties &args);
  92.   
  93.   void repCommand(Parser_t::Context &ctx, const class Properties &args);
  94. };
  96. class MgmApiService : public SocketServer::Service {
  97.   class MgmtSrvr * m_mgmsrv;
  98. public:
  99.   MgmApiService(){
  100.     m_mgmsrv = 0;
  101.   }
  102.   
  103.   void setMgm(class MgmtSrvr * mgmsrv){
  104.     m_mgmsrv = mgmsrv;
  105.   }
  106.   
  107.   SocketServer::Session * newSession(NDB_SOCKET_TYPE socket){
  108.     return new MgmApiSession(* m_mgmsrv, socket);
  109.   }
  110. };
  112. #endif