Backport WL#4085: Merge revno:2476.1105.1 from 6.0.

server-tools/CMakeLists.txt

-# Copyright (C) 2006 MySQL AB
-# 
-# This program is free software; you can redistribute it and/or modify
-# it under the terms of the GNU General Public License as published by
-# the Free Software Foundation; version 2 of the License.
-# 
-# This program is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-# GNU General Public License for more details.
-# 
-# You should have received a copy of the GNU General Public License
-# along with this program; if not, write to the Free Software
-# Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
-
-SET(CMAKE_CXX_FLAGS_DEBUG "${CMAKE_CXX_FLAGS_DEBUG} -DSAFEMALLOC -DSAFE_MUTEX")
-SET(CMAKE_C_FLAGS_DEBUG "${CMAKE_C_FLAGS_DEBUG} -DSAFEMALLOC -DSAFE_MUTEX")
-
-ADD_DEFINITIONS(-DMYSQL_SERVER -DMYSQL_INSTANCE_MANAGER)
-INCLUDE_DIRECTORIES(${PROJECT_SOURCE_DIR}/include ${PROJECT_SOURCE_DIR}/sql
-                    ${PROJECT_SOURCE_DIR}/extra/yassl/include)
- 
-ADD_EXECUTABLE(mysqlmanager buffer.cc command.cc commands.cc guardian.cc instance.cc instance_map.cc
-                            instance_options.cc listener.cc log.cc manager.cc messages.cc mysql_connection.cc
-                            mysqlmanager.cc options.cc parse.cc parse_output.cc priv.cc protocol.cc
-                            thread_registry.cc user_map.cc imservice.cpp windowsservice.cpp
-                            user_management_commands.cc
-                            ../../sql/net_serv.cc ../../sql-common/pack.c ../../sql/password.c
-                            ../../sql/sql_state.c ../../sql-common/client.c ../../libmysql/get_password.c
-                            ../../libmysql/errmsg.c)
-
-ADD_DEPENDENCIES(mysqlmanager GenError)
-TARGET_LINK_LIBRARIES(mysqlmanager dbug mysys strings taocrypt vio yassl zlib wsock32)

server-tools/Makefile.am

-# Copyright (C) 2003, 2006 MySQL AB
-# 
-# This program is free software; you can redistribute it and/or modify
-# it under the terms of the GNU General Public License as published by
-# the Free Software Foundation; version 2 of the License.
-# 
-# This program is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-# GNU General Public License for more details.
-# 
-# You should have received a copy of the GNU General Public License
-# along with this program; if not, write to the Free Software
-# Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
-
-SUBDIRS = . instance-manager
-DIST_SUBDIRS = . instance-manager
-
-# Don't update the files from bitkeeper
-%::SCCS/s.%

server-tools/instance-manager/CMakeLists.txt

-# Copyright (C) 2006 MySQL AB
-# 
-# This program is free software; you can redistribute it and/or modify
-# it under the terms of the GNU General Public License as published by
-# the Free Software Foundation; version 2 of the License.
-# 
-# This program is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-# GNU General Public License for more details.
-# 
-# You should have received a copy of the GNU General Public License
-# along with this program; if not, write to the Free Software
-# Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
-INCLUDE("${PROJECT_SOURCE_DIR}/win/mysql_manifest.cmake")
-
-SET(CMAKE_CXX_FLAGS_DEBUG "${CMAKE_CXX_FLAGS_DEBUG} -DSAFEMALLOC -DSAFE_MUTEX")
-SET(CMAKE_C_FLAGS_DEBUG "${CMAKE_C_FLAGS_DEBUG} -DSAFEMALLOC -DSAFE_MUTEX")
-
-ADD_DEFINITIONS(-DMYSQL_SERVER -DMYSQL_INSTANCE_MANAGER)
-INCLUDE_DIRECTORIES(${PROJECT_SOURCE_DIR}/include ${PROJECT_SOURCE_DIR}/sql
-                    ${PROJECT_SOURCE_DIR}/extra/yassl/include)
- 
-ADD_EXECUTABLE(mysqlmanager buffer.cc command.cc commands.cc guardian.cc instance.cc instance_map.cc
-                            instance_options.cc listener.cc log.cc manager.cc messages.cc mysql_connection.cc
-                            mysqlmanager.cc options.cc parse.cc parse_output.cc priv.cc protocol.cc
-                            thread_registry.cc user_map.cc IMService.cpp WindowsService.cpp
-                            user_management_commands.cc
-                            ../../sql/net_serv.cc ../../sql-common/pack.c ../../sql/password.c
-                            ../../sql/sql_state.c ../../sql-common/client.c ../../libmysql/get_password.c
-                            ../../libmysql/errmsg.c)
-
-ADD_DEPENDENCIES(mysqlmanager GenError)
-TARGET_LINK_LIBRARIES(mysqlmanager debug dbug mysys strings taocrypt vio yassl zlib wsock32)
-
-IF(EMBED_MANIFESTS)
-  MYSQL_EMBED_MANIFEST("mysqlmanager" "asInvoker")
-ENDIF(EMBED_MANIFESTS)

server-tools/instance-manager/IMService.cpp

-/* Copyright (C) 2005 MySQL AB
-
-   This program is free software; you can redistribute it and/or modify
-   it under the terms of the GNU General Public License as published by
-   the Free Software Foundation; version 2 of the License.
-
-   This program is distributed in the hope that it will be useful,
-   but WITHOUT ANY WARRANTY; without even the implied warranty of
-   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-   GNU General Public License for more details.
-
-   You should have received a copy of the GNU General Public License
-   along with this program; if not, write to the Free Software
-   Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA */
-
-#include <winsock2.h>
-#include <signal.h>
-
-#include "IMService.h"
-
-#include "log.h"
-#include "manager.h"
-#include "options.h"
-
-static const char * const IM_SVC_USERNAME= NULL;
-static const char * const IM_SVC_PASSWORD= NULL;
-
-IMService::IMService(void)
-  :WindowsService("MySqlManager", "MySQL Manager")
-{
-}
-
-IMService::~IMService(void)
-{
-}
-
-void IMService::Stop()
-{
-  ReportStatus(SERVICE_STOP_PENDING);
-
-  /* stop the IM work */
-  raise(SIGTERM);
-}
-
-void IMService::Run(DWORD argc, LPTSTR *argv)
-{
-  /* report to the SCM that we're about to start */
-  ReportStatus((DWORD)SERVICE_START_PENDING);
-
-  Options::load(argc, argv);
-
-  /* init goes here */
-  ReportStatus((DWORD)SERVICE_RUNNING);
-
-  /* wait for main loop to terminate */
-  (void) Manager::main();
-  Options::cleanup();
-}
-
-void IMService::Log(const char *msg)
-{
-  log_info(msg);
-}
-
-int IMService::main()
-{
-  IMService winService;
-
-  if (Options::Service::install_as_service)
-  {
-    if (winService.IsInstalled())
-    {
-      log_info("Service is already installed.");
-      return 1;
-    }
-
-    if (winService.Install(IM_SVC_USERNAME, IM_SVC_PASSWORD))
-    {
-      log_info("Service installed successfully.");
-      return 0;
-    }
-    else
-    {
-      log_error("Service failed to install.");
-      return 1;
-    }
-  }
-
-  if (Options::Service::remove_service)
-  {
-    if (!winService.IsInstalled())
-    {
-      log_info("Service is not installed.");
-      return 1;
-    }
-
-    if (winService.Remove())
-    {
-      log_info("Service removed successfully.");
-      return 0;
-    }
-    else
-    {
-      log_error("Service failed to remove.");
-      return 1;
-    }
-  }
-
-  log_info("Initializing Instance Manager service...");
-
-  if (!winService.Init())
-  {
-    log_error("Service failed to initialize.");
-
-    fprintf(stderr,
-      "The service should be started by Windows Service Manager.\n"
-      "The MySQL Manager should be started with '--standalone'\n"
-      "to run from command line.");
-
-    return 1;
-  }
-
-  return 0;
-}

server-tools/instance-manager/IMService.h

-/* Copyright (C) 2005 MySQL AB
-
-   This program is free software; you can redistribute it and/or modify
-   it under the terms of the GNU General Public License as published by
-   the Free Software Foundation; version 2 of the License.
-
-   This program is distributed in the hope that it will be useful,
-   but WITHOUT ANY WARRANTY; without even the implied warranty of
-   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-   GNU General Public License for more details.
-
-   You should have received a copy of the GNU General Public License
-   along with this program; if not, write to the Free Software
-   Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA */
-
-#pragma once
-#include "WindowsService.h"
-
-class IMService: public WindowsService
-{
-public:
-  static int main();
-
-private:
-  IMService(void);
-  ~IMService(void);
-
-protected:
-  void Log(const char *msg);
-  void Stop();
-  void Run(DWORD argc, LPTSTR *argv);
-};

server-tools/instance-manager/Makefile.am

-# Copyright (C) 2004 MySQL AB
-#
-# This program is free software; you can redistribute it and/or modify
-# it under the terms of the GNU General Public License as published by
-# the Free Software Foundation; version 2 of the License.
-#
-# This program is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-# GNU General Public License for more details.
-#
-# You should have received a copy of the GNU General Public License
-# along with this program; if not, write to the Free Software
-# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
-
-INCLUDES= @ZLIB_INCLUDES@ -I$(top_srcdir)/include \
-	@openssl_includes@ -I$(top_builddir)/include
-
-DEFS= -DMYSQL_INSTANCE_MANAGER -DMYSQL_SERVER
-
-# As all autoconf variables depend from ${prefix} and being resolved only when
-# make is run, we can not put these defines to a header file (e.g. to
-# default_options.h, generated from default_options.h.in)
-# See automake/autoconf docs for details
-
-noinst_LTLIBRARIES= liboptions.la
-noinst_LIBRARIES=   libnet.a
-
-liboptions_la_CXXFLAGS= $(CXXFLAGS) \
-	-DDEFAULT_PID_FILE_NAME="$(localstatedir)/mysqlmanager.pid" \
-	-DDEFAULT_LOG_FILE_NAME="$(localstatedir)/mysqlmanager.log" \
-	-DDEFAULT_SOCKET_FILE_NAME="/tmp/mysqlmanager.sock" \
-	-DDEFAULT_PASSWORD_FILE_NAME="/etc/mysqlmanager.passwd" \
-	-DDEFAULT_MYSQLD_PATH="$(libexecdir)/mysqld$(EXEEXT)" \
-	-DDEFAULT_CONFIG_FILE="my.cnf" \
-	-DPROTOCOL_VERSION=@PROTOCOL_VERSION@
-
-liboptions_la_SOURCES= options.h options.cc priv.h priv.cc
-liboptions_la_LIBADD= $(top_builddir)/libmysql/get_password.lo
-
-# MySQL sometimes uses symlinks to reuse code 
-# All symlinked files are grouped in libnet.a
-
-nodist_libnet_a_SOURCES= net_serv.cc client_settings.h
-libnet_a_LIBADD= $(top_builddir)/sql/password.$(OBJEXT) \
-	$(top_builddir)/sql/pack.$(OBJEXT) \
-	$(top_builddir)/sql/sql_state.$(OBJEXT) \
-	$(top_builddir)/sql/mini_client_errors.$(OBJEXT)\
-	$(top_builddir)/sql/client.$(OBJEXT)
-
-CLEANFILES= net_serv.cc client_settings.h
-
-net_serv.cc:
-	rm -f net_serv.cc
-	@LN_CP_F@ $(top_srcdir)/sql/net_serv.cc net_serv.cc
-
-client_settings.h:
-	rm -f client_settings.h
-	@LN_CP_F@ $(top_srcdir)/sql/client_settings.h client_settings.h
-
-libexec_PROGRAMS= mysqlmanager
-
-mysqlmanager_CXXFLAGS=  
-
-mysqlmanager_SOURCES=	command.cc command.h mysqlmanager.cc \
-			manager.h manager.cc log.h log.cc \
-			thread_registry.h thread_registry.cc \
-			listener.h listener.cc protocol.h protocol.cc \
-			mysql_connection.h mysql_connection.cc \
-			user_map.h user_map.cc \
-			messages.h messages.cc \
-			commands.h commands.cc \
-			instance.h instance.cc \
-			instance_map.h instance_map.cc\
-			instance_options.h instance_options.cc \
-			buffer.h buffer.cc parse.cc parse.h \
-			guardian.cc guardian.h \
-			parse_output.cc parse_output.h \
-                        mysql_manager_error.h \
-                        portability.h \
-			exit_codes.h \
-			user_management_commands.h \
-			user_management_commands.cc \
-			angel.h \
-			angel.cc
-
-mysqlmanager_LDADD=	@CLIENT_EXTRA_LDFLAGS@ \
-			liboptions.la \
-			libnet.a \
-			$(top_builddir)/vio/libvio.a \
-			$(top_builddir)/mysys/libmysys.a \
-			$(top_builddir)/strings/libmystrings.a \
-			$(top_builddir)/dbug/libdbug.a \
-			@openssl_libs@ @yassl_libs@ @ZLIB_LIBS@
-
-EXTRA_DIST =		WindowsService.cpp WindowsService.h IMService.cpp \
-			IMService.h CMakeLists.txt
-
-tags:
-	ctags -R *.h *.cc
-
-# Don't update the files from bitkeeper
-%::SCCS/s.%

server-tools/instance-manager/README

-Instance Manager - manage MySQL instances locally and remotely.
-
-File description:
- mysqlmanager.cc - entry point to the manager, main, 
- options.{h,cc} - handle startup options
- manager.{h,cc} - manager process
- mysql_connection.{h,cc} - handle one connection with mysql client.
-
-See also instance manager architecture description in mysqlmanager.cc.
-
-

server-tools/instance-manager/WindowsService.cpp

-/* Copyright (C) 2005 MySQL AB
-
-   This program is free software; you can redistribute it and/or modify
-   it under the terms of the GNU General Public License as published by
-   the Free Software Foundation; version 2 of the License.
-
-   This program is distributed in the hope that it will be useful,
-   but WITHOUT ANY WARRANTY; without even the implied warranty of
-   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-   GNU General Public License for more details.
-
-   You should have received a copy of the GNU General Public License
-   along with this program; if not, write to the Free Software
-   Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA */
-
-#include "my_global.h"
-#include <windows.h>
-#include "WindowsService.h"
-
-static WindowsService *gService;
-
-WindowsService::WindowsService(const char *p_serviceName,
-                               const char *p_displayName) :
-  statusCheckpoint(0),
-  serviceName(p_serviceName),
-  displayName(p_displayName),
-  inited(FALSE),
-  dwAcceptedControls(SERVICE_ACCEPT_STOP),
-  debugging(FALSE)
-{
-  DBUG_ASSERT(serviceName != NULL);
-
-  /* TODO: shouldn't we check displayName too (can it really be NULL)? */
-
-  /* WindowsService is assumed to be singleton. Let's assure this. */
-  DBUG_ASSERT(gService == NULL);
-
-  gService= this;
-
-  status.dwServiceType= SERVICE_WIN32_OWN_PROCESS;
-  status.dwServiceSpecificExitCode= 0;
-}
-
-WindowsService::~WindowsService(void)
-{
-}
-
-BOOL WindowsService::Install(const char *username, const char *password)
-{
-  bool ret_val= FALSE;
-  SC_HANDLE newService;
-  SC_HANDLE scm;
-
-  if (IsInstalled())
-    return TRUE;
-
-  // determine the name of the currently executing file
-  char szFilePath[_MAX_PATH];
-  GetModuleFileName(NULL, szFilePath, sizeof(szFilePath));
-
-  // open a connection to the SCM
-  if (!(scm= OpenSCManager(0, 0,SC_MANAGER_CREATE_SERVICE)))
-    return FALSE;
-
-  newService= CreateService(scm, serviceName, displayName,
-                            SERVICE_ALL_ACCESS, SERVICE_WIN32_OWN_PROCESS,
-                            SERVICE_AUTO_START, SERVICE_ERROR_NORMAL,
-                            szFilePath, NULL, NULL, NULL, username,
-                            password);
-
-  if (newService)
-  {
-    CloseServiceHandle(newService);
-    ret_val= TRUE;
-  }
-
-  CloseServiceHandle(scm);
-  return ret_val;
-}
-
-BOOL WindowsService::Init()
-{
-  DBUG_ASSERT(serviceName != NULL);
-
-  if (inited)
-    return TRUE;
-
-  SERVICE_TABLE_ENTRY stb[] =
-  {
-    { (LPSTR)serviceName, (LPSERVICE_MAIN_FUNCTION) ServiceMain},
-    { NULL, NULL }
-  };
-  inited= TRUE;
-  return StartServiceCtrlDispatcher(stb); //register with the Service Manager
-}
-
-BOOL WindowsService::Remove()
-{
-  bool ret_val= FALSE;
-
-  if (!IsInstalled())
-    return TRUE;
-
-  // open a connection to the SCM
-  SC_HANDLE scm= OpenSCManager(0, 0,SC_MANAGER_CREATE_SERVICE);
-  if (!scm)
-    return FALSE;
-
-  SC_HANDLE service= OpenService(scm, serviceName, DELETE);
-  if (service)
-  {
-    if (DeleteService(service))
-      ret_val= TRUE;
-    DWORD dw= ::GetLastError();
-    CloseServiceHandle(service);
-  }
-
-  CloseServiceHandle(scm);
-  return ret_val;
-}
-
-BOOL WindowsService::IsInstalled()
-{
-  BOOL ret_val= FALSE;
-
-  SC_HANDLE scm= ::OpenSCManager(NULL, NULL, SC_MANAGER_CONNECT);
-  SC_HANDLE serv_handle= ::OpenService(scm, serviceName, SERVICE_QUERY_STATUS);
-
-  ret_val= serv_handle != NULL;
-
-  ::CloseServiceHandle(serv_handle);
-  ::CloseServiceHandle(scm);
-
-  return ret_val;
-}
-
-void WindowsService::SetAcceptedControls(DWORD acceptedControls)
-{
-  dwAcceptedControls= acceptedControls;
-}
-
-
-BOOL WindowsService::ReportStatus(DWORD currentState, DWORD waitHint,
-                                  DWORD dwError)
-{
-  if (debugging)
-    return TRUE;
-
-  if(currentState == SERVICE_START_PENDING)
-    status.dwControlsAccepted= 0;
-  else
-    status.dwControlsAccepted= dwAcceptedControls;
-
-  status.dwCurrentState= currentState;
-  status.dwWin32ExitCode= dwError != 0 ?
-    ERROR_SERVICE_SPECIFIC_ERROR : NO_ERROR;
-  status.dwWaitHint= waitHint;
-  status.dwServiceSpecificExitCode= dwError;
-
-  if(currentState == SERVICE_RUNNING || currentState == SERVICE_STOPPED)
-  {
-    status.dwCheckPoint= 0;
-    statusCheckpoint= 0;
-  }
-  else
-    status.dwCheckPoint= ++statusCheckpoint;
-
-  // Report the status of the service to the service control manager.
-  BOOL result= SetServiceStatus(statusHandle, &status);
-  if (!result)
-    Log("ReportStatus failed");
-
-  return result;
-}
-
-void WindowsService::RegisterAndRun(DWORD argc, LPTSTR *argv)
-{
-  statusHandle= ::RegisterServiceCtrlHandler(serviceName, ControlHandler);
-  if (statusHandle && ReportStatus(SERVICE_START_PENDING))
-    Run(argc, argv);
-  ReportStatus(SERVICE_STOPPED);
-}
-
-void WindowsService::HandleControlCode(DWORD opcode)
-{
-  // Handle the requested control code.
-  switch(opcode) {
-  case SERVICE_CONTROL_STOP:
-    // Stop the service.
-    status.dwCurrentState= SERVICE_STOP_PENDING;
-    Stop();
-    break;
-
-  case SERVICE_CONTROL_PAUSE:
-    status.dwCurrentState= SERVICE_PAUSE_PENDING;
-    Pause();
-    break;
-
-  case SERVICE_CONTROL_CONTINUE:
-    status.dwCurrentState= SERVICE_CONTINUE_PENDING;
-    Continue();
-    break;
-
-  case SERVICE_CONTROL_SHUTDOWN:
-    Shutdown();
-    break;
-
-  case SERVICE_CONTROL_INTERROGATE:
-    ReportStatus(status.dwCurrentState);
-    break;
-
-  default:
-    // invalid control code
-    break;
-  }
-}
-
-void WINAPI WindowsService::ServiceMain(DWORD argc, LPTSTR *argv)
-{
-  DBUG_ASSERT(gService != NULL);
-
-  // register our service control handler:
-  gService->RegisterAndRun(argc, argv);
-}
-
-void WINAPI WindowsService::ControlHandler(DWORD opcode)
-{
-  DBUG_ASSERT(gService != NULL);
-
-  return gService->HandleControlCode(opcode);
-}

server-tools/instance-manager/WindowsService.h

-/* Copyright (C) 2005 MySQL AB
-
-   This program is free software; you can redistribute it and/or modify
-   it under the terms of the GNU General Public License as published by
-   the Free Software Foundation; version 2 of the License.
-
-   This program is distributed in the hope that it will be useful,
-   but WITHOUT ANY WARRANTY; without even the implied warranty of
-   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-   GNU General Public License for more details.
-
-   You should have received a copy of the GNU General Public License
-   along with this program; if not, write to the Free Software
-   Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA */
-
-#pragma once
-
-class WindowsService
-{
-protected:
-  bool                  inited;
-  const char            *serviceName;
-  const char            *displayName;
-  SERVICE_STATUS_HANDLE statusHandle;
-  DWORD                 statusCheckpoint;
-  SERVICE_STATUS        status;
-  DWORD                 dwAcceptedControls;
-  bool                  debugging;
-
-public:
-  WindowsService(const char *p_serviceName, const char *p_displayName);
-  ~WindowsService(void);
-
-  BOOL  Install(const char *username, const char *password);
-  BOOL  Remove();
-  BOOL  Init();
-  BOOL  IsInstalled();
-  void  SetAcceptedControls(DWORD acceptedControls);
-  void  Debug(bool debugFlag) { debugging= debugFlag; }
-
-public:
-  static void WINAPI    ServiceMain(DWORD argc, LPTSTR *argv);
-  static void WINAPI    ControlHandler(DWORD CtrlType);
-
-protected:
-  virtual void Run(DWORD argc, LPTSTR *argv)= 0;
-  virtual void Stop()                 {}
-  virtual void Shutdown()             {}
-  virtual void Pause()                {}
-  virtual void Continue()             {}
-  virtual void Log(const char *msg)   {}
-
-  BOOL ReportStatus(DWORD currentStatus, DWORD waitHint= 3000, DWORD dwError=0);
-  void HandleControlCode(DWORD opcode);
-  void RegisterAndRun(DWORD argc, LPTSTR *argv);
-};

server-tools/instance-manager/angel.h

-/* Copyright (C) 2003-2006 MySQL AB
-
-   This program is free software; you can redistribute it and/or modify
-   it under the terms of the GNU General Public License as published by
-   the Free Software Foundation; version 2 of the License.
-
-   This program is distributed in the hope that it will be useful,
-   but WITHOUT ANY WARRANTY; without even the implied warranty of
-   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-   GNU General Public License for more details.
-
-   You should have received a copy of the GNU General Public License
-   along with this program; if not, write to the Free Software
-   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
-
-#ifndef INCLUDES_MYSQL_ANGEL_H
-#define INCLUDES_MYSQL_ANGEL_H
-
-#ifndef __WIN__
-
-#if defined(__GNUC__) && defined(USE_PRAGMA_INTERFACE)
-#pragma interface
-#endif
-
-#include <my_global.h>
-
-class Angel
-{
-public:
-  static int main();
-};
-
-#endif // INCLUDES_MYSQL_ANGEL_H
-#endif // __WIN__

server-tools/instance-manager/buffer.cc

-/* Copyright (C) 2004 MySQL AB
-
-   This program is free software; you can redistribute it and/or modify
-   it under the terms of the GNU General Public License as published by
-   the Free Software Foundation; version 2 of the License.
-
-   This program is distributed in the hope that it will be useful,
-   but WITHOUT ANY WARRANTY; without even the implied warranty of
-   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-   GNU General Public License for more details.
-
-   You should have received a copy of the GNU General Public License
-   along with this program; if not, write to the Free Software
-   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
-
-#if defined(__GNUC__) && defined(USE_PRAGMA_IMPLEMENTATION)
-#pragma implementation
-#endif
-
-#include "buffer.h"
-#include <m_string.h>
-
-const uint Buffer::BUFFER_INITIAL_SIZE= 4096;
-const uint Buffer::MAX_BUFFER_SIZE= 16777216;
-
-/*
-  Puts the given string to the buffer.
-
-  SYNOPSIS
-    append()
-    position          start position in the buffer
-    string            string to be put in the buffer
-    len_arg           the length of the string. This way we can avoid some
-                      strlens.
-
-  DESCRIPTION
-
-    The method puts a string into the buffer, starting from position .
-    In the case when the buffer is too small it reallocs the buffer. The
-    total size of the buffer is restricted with 16.
-
-  RETURN
-    0 - ok
-    1 - got an error in reserve()
-*/
-
-int Buffer::append(size_t position, const char *string, size_t len_arg)
-{
-  if (reserve(position, len_arg))
-    return 1;
-
-  strnmov((char*) buffer + position, string, len_arg);
-  return 0;
-}
-
-
-/*
-  Checks whether the current buffer size is ok to put a string of the length
-  "len_arg" starting from "position" and reallocs it if no.
-
-  SYNOPSIS
-    reserve()
-    position          the number starting byte on the buffer to store a buffer
-    len_arg           the length of the string.
-
-  DESCRIPTION
-
-    The method checks whether it is possible to put a string of the "len_arg"
-    length into the buffer, starting from "position" byte. In the case when the
-    buffer is too small it reallocs the buffer. The total size of the buffer is
-    restricted with 16 Mb.
-
-  RETURN
-    0 - ok
-    1 - realloc error or we have come to the 16Mb barrier
-*/
-
-int Buffer::reserve(size_t position, size_t len_arg)
-{
-  if (position + len_arg >= MAX_BUFFER_SIZE)
-    goto err;
-
-  if (position + len_arg >= buffer_size)
-  {
-    buffer= (uchar*) my_realloc(buffer,
-                                min(MAX_BUFFER_SIZE,
-                                    max((uint) (buffer_size*1.5),
-                                        position + len_arg)), MYF(0));
-    if (!(buffer))
-      goto err;
-    buffer_size= (size_t) (buffer_size*1.5);
-  }
-  return 0;
-
-err:
-  error= 1;
-  return 1;
-}
-
-
-int Buffer::get_size()
-{
-  return (uint) buffer_size;
-}
-
-
-int Buffer::is_error()
-{
-  return error;
-}

server-tools/instance-manager/buffer.h

-#ifndef INCLUDES_MYSQL_INSTANCE_MANAGER_BUFFER_H
-#define INCLUDES_MYSQL_INSTANCE_MANAGER_BUFFER_H
-/* Copyright (C) 2004 MySQL AB
-
-   This program is free software; you can redistribute it and/or modify
-   it under the terms of the GNU General Public License as published by
-   the Free Software Foundation; version 2 of the License.
-
-   This program is distributed in the hope that it will be useful,
-   but WITHOUT ANY WARRANTY; without even the implied warranty of
-   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-   GNU General Public License for more details.
-
-   You should have received a copy of the GNU General Public License
-   along with this program; if not, write to the Free Software
-   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
-
-#include <my_global.h>
-#include <my_sys.h>
-
-#if defined(__GNUC__) && defined(USE_PRAGMA_INTERFACE)
-#pragma interface
-#endif
-
-/*
-  This class is a simple implementation of the buffer of varying size.
-  It is used to store MySQL client-server protocol packets. This is why
-  the maximum buffer size if 16Mb. (See internals manual section
-  7. MySQL Client/Server Protocol)
-*/
-
-class Buffer
-{
-private:
-  static const uint BUFFER_INITIAL_SIZE;
-  /* maximum buffer size is 16Mb */
-  static const uint MAX_BUFFER_SIZE;
-  size_t buffer_size;
-  /* Error flag. Triggered if we get an error of some kind */
-  int error;
-public:
-  Buffer(size_t buffer_size_arg= BUFFER_INITIAL_SIZE)
-    :buffer_size(buffer_size_arg), error(0)
-  {
-    /*
-      As append() will invokes realloc() anyway, it's ok if malloc returns 0
-    */
-    if (!(buffer= (uchar*) my_malloc(buffer_size, MYF(0))))
-        buffer_size= 0;
-  }
-
-  ~Buffer()
-  {
-    my_free(buffer, MYF(0));
-  }
-
-public:
-  uchar *buffer;
-  int get_size();
-  int is_error();
-  int append(size_t position, const char *string, size_t len_arg);
-  int reserve(size_t position, size_t len_arg);
-};
-
-#endif /* INCLUDES_MYSQL_INSTANCE_MANAGER_BUFFER_H */

server-tools/instance-manager/command.cc

-/* Copyright (C) 2004 MySQL AB
-
-   This program is free software; you can redistribute it and/or modify
-   it under the terms of the GNU General Public License as published by
-   the Free Software Foundation; version 2 of the License.
-
-   This program is distributed in the hope that it will be useful,
-   but WITHOUT ANY WARRANTY; without even the implied warranty of
-   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-   GNU General Public License for more details.
-
-   You should have received a copy of the GNU General Public License
-   along with this program; if not, write to the Free Software
-   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
-
-#if defined(__GNUC__) && defined(USE_PRAGMA_IMPLEMENTATION)
-#pragma implementation
-#endif
-
-#include "manager.h"
-#include "command.h"
-
-Command::Command()
-  :guardian(Manager::get_guardian()),
-  instance_map(Manager::get_instance_map())
-{}
-
-Command::~Command()
-{}
-

server-tools/instance-manager/command.h

-#ifndef INCLUDES_MYSQL_INSTANCE_MANAGER_COMMAND_H
-#define INCLUDES_MYSQL_INSTANCE_MANAGER_COMMAND_H
-/* Copyright (C) 2004 MySQL AB
-
-   This program is free software; you can redistribute it and/or modify
-   it under the terms of the GNU General Public License as published by
-   the Free Software Foundation; version 2 of the License.
-
-   This program is distributed in the hope that it will be useful,
-   but WITHOUT ANY WARRANTY; without even the implied warranty of
-   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-   GNU General Public License for more details.
-
-   You should have received a copy of the GNU General Public License
-   along with this program; if not, write to the Free Software
-   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
-
-#include <my_global.h>
-
-#if defined(__GNUC__) && defined(USE_PRAGMA_INTERFACE)
-#pragma interface
-#endif
-
-/* Class responsible for allocation of IM commands. */
-
-class Guardian;
-class Instance_map;
-
-struct st_net;
-
-/*
-  Command - entry point for any command.
-  GangOf4: 'Command' design pattern
-*/
-
-class Command
-{
-public:
-  Command();
-  virtual ~Command();
-
-  /*
-    This operation incapsulates behaviour of the command.
-
-    SYNOPSIS
-      net             The network connection to the client.
-      connection_id   Client connection ID
-
-    RETURN
-      0               On success
-      non 0           On error. Client error code is returned.
-  */
-  virtual int execute(st_net *net, ulong connection_id) = 0;
-
-protected:
-  Guardian *guardian;
-  Instance_map *instance_map;
-};
-
-#endif /* INCLUDES_MYSQL_INSTANCE_MANAGER_COMMAND_H */

server-tools/instance-manager/commands.h

-#ifndef INCLUDES_MYSQL_INSTANCE_MANAGER_COMMANDS_H
-#define INCLUDES_MYSQL_INSTANCE_MANAGER_COMMANDS_H
-/* Copyright (C) 2004 MySQL AB
-
-   This program is free software; you can redistribute it and/or modify
-   it under the terms of the GNU General Public License as published by
-   the Free Software Foundation; version 2 of the License.
-
-   This program is distributed in the hope that it will be useful,
-   but WITHOUT ANY WARRANTY; without even the implied warranty of
-   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-   GNU General Public License for more details.
-
-   You should have received a copy of the GNU General Public License
-   along with this program; if not, write to the Free Software
-   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
-
-#include <my_global.h>
-#include <my_sys.h>
-#include <m_string.h>
-#include <hash.h>
-
-#include "command.h"
-#include "instance.h"
-#include "parse.h"
-
-#if defined(__GNUC__) && defined(USE_PRAGMA_INTERFACE)
-#pragma interface
-#endif
-
-
-/**
-  Print all instances of this instance manager.
-  Grammar: SHOW INSTANCES
-*/
-
-class Show_instances: public Command
-{
-public:
-  Show_instances()
-  { }
-
-public:
-  int execute(st_net *net, ulong connection_id);
-
-private:
-  int write_header(st_net *net);
-  int write_data(st_net *net);
-};
-
-
-/**
-  Reread configuration file and refresh internal cache.
-  Grammar: FLUSH INSTANCES
-*/
-
-class Flush_instances: public Command
-{
-public:
-  Flush_instances()
-  { }
-
-public:
-  int execute(st_net *net, ulong connection_id);
-};
-
-
-/**
-  Base class for Instance-specific commands
-  (commands that operate on one instance).
-
-  Instance_cmd extends Command class by:
-    - an attribute for storing instance name;
-    - code to initialize instance name in constructor;
-    - an accessor to get instance name.
-*/
-
-class Instance_cmd : public Command
-{
-public:
-  Instance_cmd(const LEX_STRING *instance_name_arg);
-
-protected:
-  inline const LEX_STRING *get_instance_name() const
-  {
-    return instance_name.get_str();
-  }
-
-private:
-  Instance_name instance_name;
-};
-
-
-/**
-  Abstract class for Instance-specific commands.
-
-  Abstract_instance_cmd extends Instance_cmd by providing a common
-  framework for writing command-implementations. Basically, the class
-  implements Command::execute() pure virtual function in the following
-  way:
-    - Lock Instance_map;
-    - Get an instance by name. Return an error, if there is no such
-      instance;
-    - Lock the instance;
-    - Unlock Instance_map;
-    - Call execute_impl(), which should be implemented in derived class;
-    - Unlock the instance;
-    - Send response to the client and return error status.
-*/
-
-class Abstract_instance_cmd: public Instance_cmd
-{
-public:
-  Abstract_instance_cmd(const LEX_STRING *instance_name_arg);
-
-public:
-  virtual int execute(st_net *net, ulong connection_id);
-
-protected:
-  /**
-    This operation is intended to contain command-specific implementation.
-
-    MT-NOTE: this operation is called under acquired Instance's lock.
-  */
-  virtual int execute_impl(st_net *net, Instance *instance) = 0;
-
-  /**
-    This operation is invoked on successful return of execute_impl() and is
-    intended to send closing data.
-
-    MT-NOTE: this operation is called under released Instance's lock.
-  */
-  virtual int send_ok_response(st_net *net, ulong connection_id) = 0;
-};
-
-
-/**
-  Print status of an instance.
-  Grammar: SHOW INSTANCE STATUS <instance_name>
-*/
-
-class Show_instance_status: public Abstract_instance_cmd
-{
-public:
-  Show_instance_status(const LEX_STRING *instance_name_arg);
-
-protected:
-  virtual int execute_impl(st_net *net, Instance *instance);
-  virtual int send_ok_response(st_net *net, ulong connection_id);
-
-private:
-  int write_header(st_net *net);
-  int write_data(st_net *net, Instance *instance);
-};
-
-
-/**
-  Print options of chosen instance.
-  Grammar: SHOW INSTANCE OPTIONS <instance_name>
-*/
-
-class Show_instance_options: public Abstract_instance_cmd
-{
-public:
-  Show_instance_options(const LEX_STRING *instance_name_arg);
-
-protected:
-  virtual int execute_impl(st_net *net, Instance *instance);
-  virtual int send_ok_response(st_net *net, ulong connection_id);
-
-private:
-  int write_header(st_net *net);
-  int write_data(st_net *net, Instance *instance);
-};
-
-
-/**
-  Start an instance.
-  Grammar: START INSTANCE <instance_name>
-*/
-
-class Start_instance: public Abstract_instance_cmd
-{
-public:
-  Start_instance(const LEX_STRING *instance_name_arg);
-
-protected:
-  virtual int execute_impl(st_net *net, Instance *instance);
-  virtual int send_ok_response(st_net *net, ulong connection_id);
-};
-
-
-/**
-  Stop an instance.
-  Grammar: STOP INSTANCE <instance_name>
-*/
-
-class Stop_instance: public Abstract_instance_cmd
-{
-public:
-  Stop_instance(const LEX_STRING *instance_name_arg);
-
-protected:
-  virtual int execute_impl(st_net *net, Instance *instance);
-  virtual int send_ok_response(st_net *net, ulong connection_id);
-};
-
-
-/**
-  Create an instance.
-  Grammar: CREATE INSTANCE <instance_name> [<options>]
-*/
-
-class Create_instance: public Instance_cmd
-{
-public:
-  Create_instance(const LEX_STRING *instance_name_arg);
-
-public:
-  bool init(const char **text);
-
-protected:
-  virtual int execute(st_net *net, ulong connection_id);
-
-private:
-  bool parse_args(const char **text);
-
-private:
-  Named_value_arr options;
-};
-
-
-/**
-  Drop an instance.
-  Grammar: DROP INSTANCE <instance_name>
-
-  Operation is permitted only if the instance is stopped. On successful
-  completion the instance section is removed from config file and the instance
-  is removed from the instance map.
-*/
-
-class Drop_instance: public Instance_cmd
-{
-public:
-  Drop_instance(const LEX_STRING *instance_name_arg);
-
-protected:
-  virtual int execute(st_net *net, ulong connection_id);
-};
-
-
-/**
-  Print requested part of the log.
-  Grammar:
-    SHOW <instance_name> LOG {ERROR | SLOW | GENERAL} size[, offset_from_end]
-*/
-
-class Show_instance_log: public Abstract_instance_cmd
-{
-public:
-  Show_instance_log(const LEX_STRING *instance_name_arg,
-                    Log_type log_type_arg, uint size_arg, uint offset_arg);
-
-protected:
-  virtual int execute_impl(st_net *net, Instance *instance);
-  virtual int send_ok_response(st_net *net, ulong connection_id);
-
-private:
-  int check_params(Instance *instance);
-  int write_header(st_net *net);
-  int write_data(st_net *net, Instance *instance);
-
-private:
-  Log_type log_type;
-  uint size;
-  uint offset;
-};
-
-
-/**
-  Shows the list of the log files, used by an instance.
-  Grammar: SHOW <instance_name> LOG FILES
-*/
-
-class Show_instance_log_files: public Abstract_instance_cmd
-{
-public:
-  Show_instance_log_files(const LEX_STRING *instance_name_arg);
-
-protected:
-  virtual int execute_impl(st_net *net, Instance *instance);
-  virtual int send_ok_response(st_net *net, ulong connection_id);
-
-private:
-  int write_header(st_net *net);
-  int write_data(st_net *net, Instance *instance);
-};
-
-
-/**
-  Abstract class for option-management commands.
-*/
-
-class Instance_options_list;
-
-class Abstract_option_cmd: public Command
-{
-public:
-  ~Abstract_option_cmd();
-
-public:
-  bool add_option(const LEX_STRING *instance_name, Named_value *option);
-
-public:
-  bool init(const char **text);
-
-  virtual int execute(st_net *net, ulong connection_id);
-
-protected:
-  Abstract_option_cmd();
-
-  int correct_file(Instance *instance, Named_value *option, bool skip);
-
-protected:
-  virtual bool parse_args(const char **text) = 0;
-  virtual int process_option(Instance *instance, Named_value *option) = 0;
-
-private:
-  Instance_options_list *
-  get_instance_options_list(const LEX_STRING *instance_name);
-
-  int execute_impl(st_net *net, ulong connection_id);
-
-private:
-  HASH instance_options_map;
-  bool initialized;
-};
-
-
-/**
-  Set an option for the instance.
-  Grammar: SET instance_name.option[=option_value][, ...]
-*/
-
-class Set_option: public Abstract_option_cmd
-{
-public:
-  Set_option()
-  { }
-
-protected:
-  virtual bool parse_args(const char **text);
-  virtual int process_option(Instance *instance, Named_value *option);
-};
-
-
-/**
-  Remove option of the instance.
-  Grammar: UNSET instance_name.option[, ...]
-*/
-
-class Unset_option: public Abstract_option_cmd
-{
-public:
-  Unset_option()
-  { }
-
-protected:
-  virtual bool parse_args(const char **text);
-  virtual int process_option(Instance *instance, Named_value *option);
-};
-
-
-/**
-  Syntax error command.
-
-  This command is issued if parser reported a syntax error. We need it to
-  distinguish between syntax error and internal parser error.  E.g. parsing
-  failed because we hadn't had enought memory. In the latter case the parser
-  just returns NULL.
-*/
-
-class Syntax_error: public Command
-{
-public:
-  Syntax_error()
-  { }
-
-public:
-  int execute(st_net *net, ulong connection_id);
-};
-
-#endif /* INCLUDES_MYSQL_INSTANCE_MANAGER_COMMANDS_H */

server-tools/instance-manager/exit_codes.h

-#ifndef INCLUDES_MYSQL_INSTANCE_MANAGER_EXIT_CODES_H
-#define INCLUDES_MYSQL_INSTANCE_MANAGER_EXIT_CODES_H
-
-/*
-   Copyright (C) 2006 MySQL AB
-
-   This program is free software; you can redistribute it and/or modify
-   it under the terms of the GNU General Public License as published by
-   the Free Software Foundation; version 2 of the License.
-
-   This program is distributed in the hope that it will be useful,
-   but WITHOUT ANY WARRANTY; without even the implied warranty of
-   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-   GNU General Public License for more details.
-
-   You should have received a copy of the GNU General Public License
-   along with this program; if not, write to the Free Software
-   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
-*/
-
-/*
-  This file contains a list of exit codes, which are used when Instance
-  Manager is working in user-management mode.
-*/
-
-const int ERR_OK = 0;
-
-const int ERR_OUT_OF_MEMORY = 1;
-const int ERR_INVALID_USAGE = 2;
-const int ERR_INTERNAL_ERROR = 3;
-const int ERR_IO_ERROR = 4;
-const int ERR_PASSWORD_FILE_CORRUPTED = 5;
-const int ERR_PASSWORD_FILE_DOES_NOT_EXIST = 6;
-
-const int ERR_CAN_NOT_READ_USER_NAME = 10;
-const int ERR_CAN_NOT_READ_PASSWORD = 11;
-const int ERR_USER_ALREADY_EXISTS = 12;
-const int ERR_USER_NOT_FOUND = 13;
-
-#endif // INCLUDES_MYSQL_INSTANCE_MANAGER_EXIT_CODES_H

server-tools/instance-manager/guardian.h

-#ifndef INCLUDES_MYSQL_INSTANCE_MANAGER_GUARDIAN_H
-#define INCLUDES_MYSQL_INSTANCE_MANAGER_GUARDIAN_H
-/* Copyright (C) 2004 MySQL AB
-
-   This program is free software; you can redistribute it and/or modify
-   it under the terms of the GNU General Public License as published by
-   the Free Software Foundation; version 2 of the License.
-
-   This program is distributed in the hope that it will be useful,
-   but WITHOUT ANY WARRANTY; without even the implied warranty of
-   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-   GNU General Public License for more details.
-
-   You should have received a copy of the GNU General Public License
-   along with this program; if not, write to the Free Software
-   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
-
-
-#include <my_global.h>
-#include <my_sys.h>
-#include <my_list.h>
-
-#include "thread_registry.h"
-
-#if defined(__GNUC__) && defined(USE_PRAGMA_INTERFACE)
-#pragma interface
-#endif
-
-class Instance;
-class Instance_map;
-class Thread_registry;
-
-/**
-  The guardian thread is responsible for monitoring and restarting of guarded
-  instances.
-*/
-
-class Guardian: public Thread
-{
-public:
-  Guardian(Thread_registry *thread_registry_arg,
-           Instance_map *instance_map_arg);
-  ~Guardian();
-
-  void init();
-
-public:
-  void request_shutdown();
-
-  bool is_stopped();
-
-  void lock();
-  void unlock();
-
-  void ping();
-
-protected:
-  virtual void run();
-
-private:
-  void stop_instances();
-
-  void process_instance(Instance *instance);
-
-private:
-  /*
-    LOCK_guardian protectes the members in this section:
-      - shutdown_requested;
-      - stopped;
-
-    Also, it is used for COND_guardian.
-  */
-  pthread_mutex_t LOCK_guardian;
-
-  /*
-    Guardian's main loop waits on this condition. So, it should be signalled
-    each time, when instance state has been changed and we want Guardian to
-    wake up.
-
-    TODO: Change this to having data-scoped conditions, i.e. conditions,
-    which indicate that some data has been changed.
-  */
-  pthread_cond_t COND_guardian;
-
-  /*
-    This variable is set to TRUE, when Manager thread is shutting down.
-    The flag is used by Guardian thread to understand that it's time to
-    finish.
-  */
-  bool shutdown_requested;
-
-  /*
-    This flag is set to TRUE on shutdown by Guardian thread, when all guarded
-    mysqlds are stopped.
-
-    The flag is used in the Manager thread to wait for Guardian to stop all
-    mysqlds.
-  */
-  bool stopped;
-
-  Thread_info thread_info;
-  Thread_registry *thread_registry;
-  Instance_map *instance_map;
-
-private:
-  Guardian(const Guardian &);
-  Guardian&operator =(const Guardian &);
-};
-
-#endif /* INCLUDES_MYSQL_INSTANCE_MANAGER_GUARDIAN_H */

server-tools/instance-manager/instance.h

-#ifndef INCLUDES_MYSQL_INSTANCE_MANAGER_INSTANCE_H
-#define INCLUDES_MYSQL_INSTANCE_MANAGER_INSTANCE_H
-/* Copyright (C) 2004 MySQL AB
-
-   This program is free software; you can redistribute it and/or modify
-   it under the terms of the GNU General Public License as published by
-   the Free Software Foundation; version 2 of the License.
-
-   This program is distributed in the hope that it will be useful,
-   but WITHOUT ANY WARRANTY; without even the implied warranty of
-   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-   GNU General Public License for more details.
-
-   You should have received a copy of the GNU General Public License
-   along with this program; if not, write to the Free Software
-   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
-
-#include <my_global.h>
-#include <m_string.h>
-
-#include "instance_options.h"
-#include "priv.h"
-
-#if defined(__GNUC__) && defined(USE_PRAGMA_INTERFACE)
-#pragma interface
-#endif
-
-class Instance_map;
-class Thread_registry;
-
-
-/**
-  Instance_name -- the class represents instance name -- a string of length
-  less than MAX_INSTANCE_NAME_SIZE.
-
-  Generally, this is just a string with self-memory-management and should be
-  eliminated in the future.
-*/
-
-class Instance_name
-{
-public:
-  Instance_name(const LEX_STRING *name);
-
-public:
-  inline const LEX_STRING *get_str() const
-  {
-    return &str;
-  }
-
-  inline const char *get_c_str() const
-  {
-    return str.str;
-  }
-
-  inline uint get_length() const
-  {
-    return str.length;
-  }
-
-private:
-  LEX_STRING str;
-  char str_buffer[MAX_INSTANCE_NAME_SIZE];
-};
-
-
-class Instance
-{
-public:
-  /* States of an instance. */
-  enum enum_instance_state
-  {
-    STOPPED,
-    NOT_STARTED,
-    STARTING,
-    STARTED,
-    JUST_CRASHED,
-    CRASHED,
-    CRASHED_AND_ABANDONED,
-    STOPPING
-  };
-
-public:
-  /**
-    The constant defines name of the default mysqld-instance ("mysqld").
-  */
-  static const LEX_STRING DFLT_INSTANCE_NAME;
-
-public:
-  static bool is_name_valid(const LEX_STRING *name);
-  static bool is_mysqld_compatible_name(const LEX_STRING *name);
-
-public:
-  Instance();
-  ~Instance();
-
-  bool init(const LEX_STRING *name_arg);
-  bool complete_initialization();
-
-public:
-  bool is_active();
-
-  bool is_mysqld_running();
-
-  bool start_mysqld();
-  bool stop_mysqld();
-  bool kill_mysqld(int signo);
-
-  void lock();
-  void unlock();
-
-  const char *get_state_name();
-
-  void reset_stat();
-
-public:
-  /**
-    The operation is intended to check if the instance is mysqld-compatible
-    or not.
-  */
-  inline bool is_mysqld_compatible() const;
-
-  /**
-    The operation is intended to check if the instance is configured properly
-    or not. Misconfigured instances are not managed.
-  */
-  inline bool is_configured() const;
-
-  /**
-    The operation returns TRUE if the instance is guarded and FALSE otherwise.
-  */
-  inline bool is_guarded() const;
-
-  /**
-    The operation returns name of the instance.
-  */
-  inline const LEX_STRING *get_name() const;
-
-  /**
-    The operation returns the current state of the instance.
-
-    NOTE: At the moment should be used only for guarded instances.
-  */
-  inline enum_instance_state get_state() const;
-
-  /**
-    The operation changes the state of the instance.
-
-    NOTE: At the moment should be used only for guarded instances.
-    TODO: Make private.
-  */
-  inline void set_state(enum_instance_state new_state);
-
-  /**
-    The operation returns crashed flag.
-  */
-  inline bool is_crashed();
-
-public:
-  /**
-    This attributes contains instance options.
-
-    TODO: Make private.
-  */
-  Instance_options options;
-
-private:
-  /**
-    monitoring_thread_active is TRUE if there is a thread that monitors the
-    corresponding mysqld-process.
-  */
-  bool monitoring_thread_active;
-
-  /**
-    crashed is TRUE when corresponding mysqld-process has been died after
-    start.
-  */
-  bool crashed;
-
-  /**
-    configured is TRUE when the instance is configured and FALSE otherwise.
-    Misconfigured instances are not managed.
-  */
-  bool configured;
-
-  /*
-    mysqld_compatible specifies whether the instance is mysqld-compatible
-    or not. Mysqld-compatible instances can contain only mysqld-specific
-    options. At the moment an instance is mysqld-compatible if its name is
-    "mysqld".
-
-    The idea is that [mysqld] section should contain only mysqld-specific
-    options (no Instance Manager-specific options) to be readable by mysqld
-    program.
-  */
-  bool mysqld_compatible;
-
-  /*
-    Mutex protecting the instance.
-  */
-  pthread_mutex_t LOCK_instance;
-
-private:
-  /* Guarded-instance attributes. */
-
-  /* state of an instance (i.e. STARTED, CRASHED, etc.) */
-  enum_instance_state state;
-
-public:
-  /* the amount of attemts to restart instance (cleaned up at success) */
-  int restart_counter;
-
-  /* triggered at a crash */
-  time_t crash_moment;
-
-  /* General time field. Used to provide timeouts (at shutdown and restart) */
-  time_t last_checked;
-
-private:
-  static const char *get_instance_state_name(enum_instance_state state);
-
-private:
-  void remove_pid();
-
-  bool wait_for_stop();
-
-private:
-  friend class Instance_monitor;
-};
-
-
-inline bool Instance::is_mysqld_compatible() const
-{
-  return mysqld_compatible;
-}
-
-
-inline bool Instance::is_configured() const
-{
-  return configured;
-}
-
-
-inline bool Instance::is_guarded() const
-{
-  return !options.nonguarded;
-}
-
-
-inline const LEX_STRING *Instance::get_name() const
-{
-  return &options.instance_name;
-}
-
-
-inline Instance::enum_instance_state Instance::get_state() const
-{
-  return state;
-}
-
-
-inline void Instance::set_state(enum_instance_state new_state)
-{
-  state= new_state;
-}
-
-
-inline bool Instance::is_crashed()
-{
-  return crashed;
-}
-
-#endif /* INCLUDES_MYSQL_INSTANCE_MANAGER_INSTANCE_H */

server-tools/instance-manager/instance_map.h

-#ifndef INCLUDES_MYSQL_INSTANCE_MANAGER_INSTANCE_MAP_H
-#define INCLUDES_MYSQL_INSTANCE_MANAGER_INSTANCE_MAP_H
-/* Copyright (C) 2004 MySQL AB
-
-   This program is free software; you can redistribute it and/or modify
-   it under the terms of the GNU General Public License as published by
-   the Free Software Foundation; version 2 of the License.
-
-   This program is distributed in the hope that it will be useful,
-   but WITHOUT ANY WARRANTY; without even the implied warranty of
-   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-   GNU General Public License for more details.
-
-   You should have received a copy of the GNU General Public License
-   along with this program; if not, write to the Free Software
-   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
-
-#include <my_global.h>
-#include <my_sys.h>
-#include <m_string.h>
-#include <hash.h>
-
-#if defined(__GNUC__) && defined(USE_PRAGMA_INTERFACE)
-#pragma interface
-#endif
-
-class Guardian;
-class Instance;
-class Named_value_arr;
-class Thread_registry;
-
-extern int load_all_groups(char ***groups, const char *filename);
-extern void free_groups(char **groups);
-
-extern int create_instance_in_file(const LEX_STRING *instance_name,
-                                   const Named_value_arr *options);
-
-
-/**
-  Instance_map - stores all existing instances
-*/
-
-class Instance_map
-{
-public:
-  /**
-    Instance_map iterator
-  */
-
-  class Iterator
-  {
-  private:
-    uint current_instance;
-    Instance_map *instance_map;
-  public:
-    Iterator(Instance_map *instance_map_arg) :
-     current_instance(0), instance_map(instance_map_arg)
-    {}
-
-    void go_to_first();
-    Instance *next();
-  };
-
-public:
-  Instance *find(const LEX_STRING *name);
-
-  bool is_there_active_instance();
-
-  void lock();
-  void unlock();
-
-  bool init();
-  bool reset();
-
-  int load();
-
-  int process_one_option(const LEX_STRING *group, const char *option);
-
-  int add_instance(Instance *instance);
-
-  int remove_instance(Instance *instance);
-
-  int create_instance(const LEX_STRING *instance_name,
-                      const Named_value_arr *options);
-
-public:
-  Instance_map();
-  ~Instance_map();
-
-private:
-  bool complete_initialization();
-
-private:
-  enum { START_HASH_SIZE = 16 };
-  pthread_mutex_t LOCK_instance_map;
-  HASH hash;
-
-private:
-  friend class Iterator;
-};
-
-#endif /* INCLUDES_MYSQL_INSTANCE_MANAGER_INSTANCE_MAP_H */

server-tools/instance-manager/instance_options.h

-#ifndef INCLUDES_MYSQL_INSTANCE_MANAGER_INSTANCE_OPTIONS_H
-#define INCLUDES_MYSQL_INSTANCE_MANAGER_INSTANCE_OPTIONS_H
-/* Copyright (C) 2004 MySQL AB
-
-   This program is free software; you can redistribute it and/or modify
-   it under the terms of the GNU General Public License as published by
-   the Free Software Foundation; version 2 of the License.
-
-   This program is distributed in the hope that it will be useful,
-   but WITHOUT ANY WARRANTY; without even the implied warranty of
-   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-   GNU General Public License for more details.
-
-   You should have received a copy of the GNU General Public License
-   along with this program; if not, write to the Free Software
-   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
-
-#include <my_global.h>
-#include <my_sys.h>
-
-#include "parse.h"
-#include "portability.h" /* for pid_t on Win32 */
-
-#if defined(__GNUC__) && defined(USE_PRAGMA_INTERFACE)
-#pragma interface
-#endif
-
-
-/*
-  This class contains options of an instance and methods to operate them.
-
-  We do not provide this class with the means of synchronization as it is
-  supposed that options for instances are all loaded at once during the
-  instance_map initilization and we do not change them later. This way we
-  don't have to synchronize between threads.
-*/
-
-class Instance_options
-{
-public:
-  /* The operation is used to check if the option is IM-specific or not. */
-   static bool is_option_im_specific(const char *option_name);
-
-public:
-  Instance_options();
-  ~Instance_options();
-
-  bool complete_initialization();
-
-  bool set_option(Named_value *option);
-  void unset_option(const char *option_name);
-
-  inline int get_num_options() const;
-  inline Named_value get_option(int idx) const;
-
-public:
-  bool init(const LEX_STRING *instance_name_arg);
-  pid_t load_pid();
-  int get_pid_filename(char *result);
-  int unlink_pidfile();
-  void print_argv();
-
-  uint get_shutdown_delay() const;
-  int get_mysqld_port() const;
-
-public:
-  /*
-    We need this value to be greater or equal then FN_REFLEN found in
-    my_global.h to use my_load_path()
-  */
-  enum { MAX_PATH_LEN= 512 };
-  enum { MAX_NUMBER_OF_DEFAULT_OPTIONS= 2 };
-  char pid_file_with_path[MAX_PATH_LEN];
-  char **argv;
-  /*
-    Here we cache the version string, obtained from mysqld --version.
-    In the case when mysqld binary is not found we get NULL here.
-  */
-  const char *mysqld_version;
-  /* We need the some options, so we store them as a separate pointers */
-  const char *mysqld_socket;
-  const char *mysqld_datadir;
-  const char *mysqld_pid_file;
-  LEX_STRING instance_name;
-  LEX_STRING mysqld_path;
-  LEX_STRING mysqld_real_path;
-  const char *nonguarded;
-  /* log enums are defined in parse.h */
-  char *logs[3];
-
-private:
-  bool fill_log_options();
-  bool fill_instance_version();
-  bool fill_mysqld_real_path();
-  int add_to_argv(const char *option);
-  int get_default_option(char *result, size_t result_len,
-                         const char *option_name);
-
-  void update_var(const char *option_name, const char *option_value);
-  int find_option(const char *option_name);
-
-private:
-  const char *mysqld_port;
-  uint mysqld_port_val;
-  const char *shutdown_delay;
-  uint shutdown_delay_val;
-
-  uint filled_default_options;
-  MEM_ROOT alloc;
-
-  Named_value_arr options;
-};
-
-
-inline int Instance_options::get_num_options() const
-{
-  return options.get_size();
-}
-
-
-inline Named_value Instance_options::get_option(int idx) const
-{
-  return options.get_element(idx);
-}
-
-#endif /* INCLUDES_MYSQL_INSTANCE_MANAGER_INSTANCE_OPTIONS_H */

server-tools/instance-manager/listener.cc

-/* Copyright (C) 2003-2006 MySQL AB
-
-   This program is free software; you can redistribute it and/or modify
-   it under the terms of the GNU General Public License as published by
-   the Free Software Foundation; version 2 of the License.
-
-   This program is distributed in the hope that it will be useful,
-   but WITHOUT ANY WARRANTY; without even the implied warranty of
-   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-   GNU General Public License for more details.
-
-   You should have received a copy of the GNU General Public License
-   along with this program; if not, write to the Free Software
-   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
-
-#if defined(__GNUC__) && defined(USE_PRAGMA_IMPLEMENTATION)
-#pragma implementation
-#endif
-
-#include "listener.h"
-
-#include <my_global.h>
-#include <mysql.h>
-#include <violite.h>
-
-#include <sys/stat.h>
-#ifndef __WIN__
-#include <sys/un.h>
-#endif
-
-#include "log.h"
-#include "mysql_connection.h"
-#include "options.h"
-#include "portability.h"
-#include "priv.h"
-#include "thread_registry.h"
-
-
-static void set_non_blocking(int socket)
-{
-#ifndef __WIN__
-  int flags= fcntl(socket, F_GETFL, 0);
-  fcntl(socket, F_SETFL, flags | O_NONBLOCK);
-#else
-  u_long arg= 1;
-  ioctlsocket(socket, FIONBIO, &arg);
-#endif
-}
-
-
-static void set_no_inherit(int socket)
-{
-#ifndef __WIN__
-  int flags= fcntl(socket, F_GETFD, 0);
-  fcntl(socket, F_SETFD, flags | FD_CLOEXEC);
-#endif
-}
-
-const int Listener::LISTEN_BACK_LOG_SIZE= 5;     /* standard backlog size */
-
-Listener::Listener(Thread_registry *thread_registry_arg,
-                   User_map *user_map_arg)
-  :thread_registry(thread_registry_arg),
-  user_map(user_map_arg),
-  total_connection_count(0),
-  num_sockets(0)
-{
-}
-
-
-/*
-  Listener::run() - listen all supported sockets and spawn a thread
-  to handle incoming connection.
-  Using 'die' in case of syscall failure is OK now - we don't hold any
-  resources and 'die' kills the signal thread automatically. To be rewritten
-  one day.
-  See also comments in mysqlmanager.cc to picture general Instance Manager
-  architecture.
-*/
-
-void Listener::run()
-{
-  int i, n= 0;
-
-#ifndef __WIN__
-  struct sockaddr_un unix_socket_address;
-#endif
-
-  log_info("Listener: started.");
-
-  thread_registry->register_thread(&thread_info);
-
-  FD_ZERO(&read_fds);
-
-  /* I. prepare 'listen' sockets */
-  if (create_tcp_socket())
-    goto err;
-
-#ifndef __WIN__
-  if (create_unix_socket(unix_socket_address))
-    goto err;
-#endif
-
-  /* II. Listen sockets and spawn childs */
-  for (i= 0; i < num_sockets; i++)
-    n= max(n, sockets[i]);
-  n++;
-
-  timeval tv;
-  while (!thread_registry->is_shutdown())
-  {
-    fd_set read_fds_arg= read_fds;
-    /*
-      We should reintialize timer as on linux it is modified
-      to reflect amount of time not slept.
-    */
-    tv.tv_sec= 0;
-    tv.tv_usec= 100000;
-
-    /*
-      When using valgrind 2.0 this syscall doesn't get kicked off by a
-      signal during shutdown. This results in failing assert
-      (Thread_registry::~Thread_registry). Valgrind 2.2 works fine.
-    */
-    int rc= select(n, &read_fds_arg, 0, 0, &tv);
-
-    if (rc == 0 || rc == -1)
-    {
-      if (rc == -1 && errno != EINTR)
-        log_error("Listener: select() failed: %s.",
-                  (const char *) strerror(errno));
-      continue;
-    }
-
-
-    for (int socket_index= 0; socket_index < num_sockets; socket_index++)
-    {
-      /* Assuming that rc > 0 as we asked to wait forever */
-      if (FD_ISSET(sockets[socket_index], &read_fds_arg))
-      {
-        int client_fd= accept(sockets[socket_index], 0, 0);
-        /* accept may return -1 (failure or spurious wakeup) */
-        if (client_fd >= 0)                    // connection established
-        {
-          set_no_inherit(client_fd);
-
-          struct st_vio *vio=
-            vio_new(client_fd,
-                    socket_index == 0 ?  VIO_TYPE_SOCKET : VIO_TYPE_TCPIP,
-                    socket_index == 0 ? 1 : 0);
-
-          if (vio != NULL)
-            handle_new_mysql_connection(vio);
-          else
-          {
-            shutdown(client_fd, SHUT_RDWR);
-            closesocket(client_fd);
-          }
-        }
-      }
-    }
-  }
-
-  /* III. Release all resources and exit */
-
-  log_info("Listener: shutdown requested, exiting...");
-
-  for (i= 0; i < num_sockets; i++)
-    closesocket(sockets[i]);
-
-#ifndef __WIN__
-  unlink(unix_socket_address.sun_path);
-#endif
-
-  thread_registry->unregister_thread(&thread_info);
-
-  log_info("Listener: finished.");
-  return;
-
-err:
-  log_error("Listener: failed to initialize. Initiate shutdown...");
-
-  // we have to close the ip sockets in case of error
-  for (i= 0; i < num_sockets; i++)
-    closesocket(sockets[i]);
-
-  thread_registry->set_error_status();
-  thread_registry->unregister_thread(&thread_info);
-  thread_registry->request_shutdown();
-  return;
-}
-
-int Listener::create_tcp_socket()
-{
-  /* value to be set by setsockopt */
-  int arg= 1;
-
-  int ip_socket= socket(AF_INET, SOCK_STREAM, 0);
-  if (ip_socket == INVALID_SOCKET)
-  {
-    log_error("Listener: socket(AF_INET) failed: %s.",
-              (const char *) strerror(errno));
-    return -1;
-  }
-
-  struct sockaddr_in ip_socket_address;
-  bzero(&ip_socket_address, sizeof(ip_socket_address));
-
-  ulong im_bind_addr;
-  if (Options::Main::bind_address != 0)
-  {
-    im_bind_addr= (ulong) inet_addr(Options::Main::bind_address);
-
-    if (im_bind_addr == (ulong) INADDR_NONE)
-      im_bind_addr= htonl(INADDR_ANY);
-  }
-  else
-    im_bind_addr= htonl(INADDR_ANY);
-  uint im_port= Options::Main::port_number;
-
-  ip_socket_address.sin_family= AF_INET;
-  ip_socket_address.sin_addr.s_addr= im_bind_addr;
-
-
-  ip_socket_address.sin_port= (unsigned short)
-    htons((unsigned short) im_port);
-
-  setsockopt(ip_socket, SOL_SOCKET, SO_REUSEADDR, (char*) &arg, sizeof(arg));
-  if (bind(ip_socket, (struct sockaddr *) &ip_socket_address,
-           sizeof(ip_socket_address)))
-  {
-    log_error("Listener: bind(ip socket) failed: %s.",
-              (const char *) strerror(errno));
-    closesocket(ip_socket);
-    return -1;
-  }
-
-  if (listen(ip_socket, LISTEN_BACK_LOG_SIZE))
-  {
-    log_error("Listener: listen(ip socket) failed: %s.",
-              (const char *) strerror(errno));
-    closesocket(ip_socket);
-    return -1;
-  }
-
-  /* set the socket nonblocking */
-  set_non_blocking(ip_socket);
-
-  /* make sure that instances won't be listening our sockets */
-  set_no_inherit(ip_socket);
-
-  FD_SET(ip_socket, &read_fds);
-  sockets[num_sockets++]= ip_socket;
-  log_info("Listener: accepting connections on ip socket (port: %d)...",
-           (int) im_port);
-  return 0;
-}
-
-#ifndef __WIN__
-int Listener::
-create_unix_socket(struct sockaddr_un &unix_socket_address)
-{
-  int unix_socket= socket(AF_UNIX, SOCK_STREAM, 0);
-  if (unix_socket == INVALID_SOCKET)
-  {
-    log_error("Listener: socket(AF_UNIX) failed: %s.",
-              (const char *) strerror(errno));
-    return -1;
-  }
-
-  bzero(&unix_socket_address, sizeof(unix_socket_address));
-
-  unix_socket_address.sun_family= AF_UNIX;
-  strmake(unix_socket_address.sun_path, Options::Main::socket_file_name,
-          sizeof(unix_socket_address.sun_path));
-  unlink(unix_socket_address.sun_path); // in case we have stale socket file
-
-  /*
-    POSIX specifies default permissions for a pathname created by bind
-    to be 0777. We need everybody to have access to the socket.
-  */
-  mode_t old_mask= umask(0);
-  if (bind(unix_socket, (struct sockaddr *) &unix_socket_address,
-           sizeof(unix_socket_address)))
-  {
-    log_error("Listener: bind(unix socket) failed for '%s': %s.",
-              (const char *) unix_socket_address.sun_path,
-              (const char *) strerror(errno));
-    close(unix_socket);
-    return -1;
-  }
-
-  umask(old_mask);
-
-  if (listen(unix_socket, LISTEN_BACK_LOG_SIZE))
-  {
-    log_error("Listener: listen(unix socket) failed: %s.",
-              (const char *) strerror(errno));
-    close(unix_socket);
-    return -1;
-  }
-
-  /* set the socket nonblocking */
-  set_non_blocking(unix_socket);
-
-  /* make sure that instances won't be listening our sockets */
-  set_no_inherit(unix_socket);
-
-  log_info("Listener: accepting connections on unix socket '%s'...",
-           (const char *) unix_socket_address.sun_path);
-  sockets[num_sockets++]= unix_socket;
-  FD_SET(unix_socket, &read_fds);
-  return 0;
-}
-#endif
-
-
-/*
-  Create new mysql connection. Created thread is responsible for deletion of
-  the Mysql_connection and Vio instances passed to it.
-  SYNOPSIS
-    handle_new_mysql_connection()
-*/
-
-void Listener::handle_new_mysql_connection(struct st_vio *vio)
-{
-  Mysql_connection *mysql_connection=
-    new Mysql_connection(thread_registry, user_map,
-                         vio, ++total_connection_count);
-  if (mysql_connection == NULL || mysql_connection->start(Thread::DETACHED))
-  {
-    log_error("Listener: can not start connection handler.");
-    delete mysql_connection;
-    vio_delete(vio);
-  }
-  /* The connection will delete itself when the thread is finished */
-}