summaryrefslogtreecommitdiff
path: root/server-tools
diff options
context:
space:
mode:
authorunknown <anozdrin/alik@booka.site>2006-11-20 15:37:12 +0300
committerunknown <anozdrin/alik@booka.site>2006-11-20 15:37:12 +0300
commit4da807726b3f1ea6d495a33178e51c16b52b3dd4 (patch)
tree9ee1eab65ab5cc4dd88dc2c8078cb3495906f56a /server-tools
parentbc06af9d69fcc5b90b81a1d2e9b9d0e0be3b996e (diff)
downloadmariadb-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.cc4
-rw-r--r--server-tools/instance-manager/listener.h19
-rw-r--r--server-tools/instance-manager/manager.cc3
-rw-r--r--server-tools/instance-manager/manager.h3
-rw-r--r--server-tools/instance-manager/thread_registry.cc2
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;