diff options
author | unknown <anozdrin/alik@booka.site> | 2006-11-20 15:37:12 +0300 |
---|---|---|
committer | unknown <anozdrin/alik@booka.site> | 2006-11-20 15:37:12 +0300 |
commit | 4da807726b3f1ea6d495a33178e51c16b52b3dd4 (patch) | |
tree | 9ee1eab65ab5cc4dd88dc2c8078cb3495906f56a /server-tools | |
parent | bc06af9d69fcc5b90b81a1d2e9b9d0e0be3b996e (diff) | |
download | mariadb-git-4da807726b3f1ea6d495a33178e51c16b52b3dd4.tar.gz |
Polishing + make the code compiled on Windows.
server-tools/instance-manager/listener.cc:
Polishing: declare variable prior to the first statement in block.
server-tools/instance-manager/listener.h:
Polishing.
server-tools/instance-manager/manager.cc:
Make Manager::manager_pid local variable.
server-tools/instance-manager/manager.h:
Make Manager::manager_pid local variable.
server-tools/instance-manager/thread_registry.cc:
Polsihing.
Diffstat (limited to 'server-tools')
-rw-r--r-- | server-tools/instance-manager/listener.cc | 4 | ||||
-rw-r--r-- | server-tools/instance-manager/listener.h | 19 | ||||
-rw-r--r-- | server-tools/instance-manager/manager.cc | 3 | ||||
-rw-r--r-- | server-tools/instance-manager/manager.h | 3 | ||||
-rw-r--r-- | server-tools/instance-manager/thread_registry.cc | 2 |
5 files changed, 18 insertions, 13 deletions
diff --git a/server-tools/instance-manager/listener.cc b/server-tools/instance-manager/listener.cc index d77bd687acf..b66dbab8eae 100644 --- a/server-tools/instance-manager/listener.cc +++ b/server-tools/instance-manager/listener.cc @@ -82,12 +82,12 @@ void Listener::run() { int i, n= 0; - log_info("Listener: started."); - #ifndef __WIN__ struct sockaddr_un unix_socket_address; #endif + log_info("Listener: started."); + thread_registry->register_thread(&thread_info); FD_ZERO(&read_fds); diff --git a/server-tools/instance-manager/listener.h b/server-tools/instance-manager/listener.h index 7758c2dc13d..811744f8ea6 100644 --- a/server-tools/instance-manager/listener.h +++ b/server-tools/instance-manager/listener.h @@ -34,21 +34,28 @@ class Listener: public Thread { public: Listener(Thread_registry *thread_registry_arg, User_map *user_map_arg); + protected: virtual void run(); + +private: + static const int LISTEN_BACK_LOG_SIZE= 5; /* standard backlog size */ + private: Thread_info thread_info; Thread_registry *thread_registry; User_map *user_map; - static const int LISTEN_BACK_LOG_SIZE= 5; /* standard backlog size */ + ulong total_connection_count; - int sockets[2]; - int num_sockets; - fd_set read_fds; + int sockets[2]; + int num_sockets; + fd_set read_fds; + +private: void handle_new_mysql_connection(struct st_vio *vio); - int create_tcp_socket(); - int create_unix_socket(struct sockaddr_un &unix_socket_address); + int create_tcp_socket(); + int create_unix_socket(struct sockaddr_un &unix_socket_address); }; #endif // INCLUDES_MYSQL_INSTANCE_MANAGER_LISTENER_H diff --git a/server-tools/instance-manager/manager.cc b/server-tools/instance-manager/manager.cc index 4fb4efef87e..a55adbed950 100644 --- a/server-tools/instance-manager/manager.cc +++ b/server-tools/instance-manager/manager.cc @@ -114,7 +114,6 @@ Guardian *Manager::p_guardian; Instance_map *Manager::p_instance_map; Thread_registry *Manager::p_thread_registry; User_map *Manager::p_user_map; -pid_t Manager::manager_pid; /* manager - entry point to the main instance manager process: start @@ -131,6 +130,7 @@ int Manager::main() int rc= 1; const char *err_msg; bool shutdown_complete= FALSE; + pid_t manager_pid= getpid(); Thread_registry thread_registry; /* @@ -146,7 +146,6 @@ int Manager::main() Listener listener(&thread_registry, &user_map); - manager_pid= getpid(); p_instance_map= &instance_map; p_guardian= instance_map.guardian= &guardian; p_thread_registry= &thread_registry; diff --git a/server-tools/instance-manager/manager.h b/server-tools/instance-manager/manager.h index 1f2b2cf6926..8f3dbfefb7b 100644 --- a/server-tools/instance-manager/manager.h +++ b/server-tools/instance-manager/manager.h @@ -38,12 +38,11 @@ public: static Guardian *get_guardian() { return p_guardian; } static Thread_registry *get_thread_registry() { return p_thread_registry; } static User_map *get_user_map() { return p_user_map; } - static pid_t get_manager_pid() { return manager_pid; } private: static void stop_all_threads(); + private: - static pid_t manager_pid; static Guardian *p_guardian; static Instance_map *p_instance_map; static Thread_registry *p_thread_registry; diff --git a/server-tools/instance-manager/thread_registry.cc b/server-tools/instance-manager/thread_registry.cc index 037f104f7bd..b913cb718b5 100644 --- a/server-tools/instance-manager/thread_registry.cc +++ b/server-tools/instance-manager/thread_registry.cc @@ -371,7 +371,7 @@ bool Thread::start_detached() pthread_attr_init(&attr); pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED); rc= set_stacksize_and_create_thread(&thd_id, &attr, - Thread::thread_func, this); + Thread::thread_func, this); pthread_attr_destroy(&attr); return rc != 0; |