CpcClient.hpp
上传用户:romrleung
上传日期:2022-05-23
资源大小:18897k
文件大小:3k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. /* Copyright (C) 2003 MySQL AB
  2.    This program is free software; you can redistribute it and/or modify
  3.    it under the terms of the GNU General Public License as published by
  4.    the Free Software Foundation; either version 2 of the License, or
  5.    (at your option) any later version.
  6.    This program is distributed in the hope that it will be useful,
  7.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  8.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  9.    GNU General Public License for more details.
  10.    You should have received a copy of the GNU General Public License
  11.    along with this program; if not, write to the Free Software
  12.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  13. #ifndef __CPCCLIENT_HPP_INCLUDED__
  14. #define __CPCCLIENT_HPP_INCLUDED__
  15. #include <Parser.hpp>
  16. #include <SocketServer.hpp>
  17. #include <util/InputStream.hpp>
  18. #include <util/OutputStream.hpp>
  19. /**
  20.  * Simple CPC client class. The whole management client should be replaced
  21.  * something smarter and more worked through.
  22.  */
  23. class SimpleCpcClient {
  24. public:
  25.   SimpleCpcClient(const char *host, int port);
  26.   ~SimpleCpcClient();
  27.   static void run(SimpleCpcClient &);
  28.   int getPort() const { return port;}
  29.   const char * getHost() const { return host;}
  30.   
  31.   struct Process {
  32.     int m_id;
  33.     BaseString m_name;
  34.     BaseString m_owner;
  35.     BaseString m_group;
  36.     BaseString m_runas;
  37.     BaseString m_cwd;
  38.     BaseString m_env;
  39.     BaseString m_path;
  40.     BaseString m_args;
  41.     BaseString m_type;
  42.     BaseString m_status;
  43.     
  44.     BaseString m_stdin;
  45.     BaseString m_stdout;
  46.     BaseString m_stderr;
  47.     BaseString m_ulimit;
  48.     BaseString m_shutdown_options;
  49.   };
  50. private:
  51.   class ParserDummy : SocketServer::Session {
  52.   public:
  53.     ParserDummy(NDB_SOCKET_TYPE sock);
  54.   };
  55.   
  56.   typedef Parser<ParserDummy> Parser_t;
  57.   typedef ParserRow<ParserDummy> ParserRow_t;
  58.   
  59.   char *host;
  60.   int port;
  61.   NDB_SOCKET_TYPE cpc_sock;
  62.   InputStream *cpc_in;
  63.   OutputStream *cpc_out;
  64. public:  
  65.   int connect();
  66.   void cmd_list(char *arg);
  67.   void cmd_start(char *arg);
  68.   void cmd_stop(char *arg);
  69.   void cmd_help(char *arg);
  70.   int list_processes(Vector<Process>&, Properties &reply);
  71.   int start_process(Uint32 id, Properties& reply);
  72.   int stop_process(Uint32 id, Properties& reply);
  73.   int undefine_process(Uint32 id, Properties& reply);
  74.   int define_process(Process & p, Properties& reply);
  75.   
  76. private:
  77.   int cpc_send(const char *cmd,
  78.        const Properties &args);
  79.   Parser_t::ParserStatus cpc_recv(const ParserRow_t *syntax,
  80.   const Properties **reply,
  81.   void **user_data = NULL);
  82.   const Properties *cpc_call(const char *cmd,
  83.      const Properties &args,
  84.      const ParserRow_t *reply_syntax);
  85. };
  86. #endif /* !__CPCCLIENT_HPP_INCLUDED__ */