Browse Source

ckdb - name the threads

master
kanoi 10 years ago
parent
commit
a12d67fdef
  1. 9
      src/ckdb.c

9
src/ckdb.c

@ -8043,6 +8043,8 @@ static void *summariser(__maybe_unused void *arg)
{ {
pthread_detach(pthread_self()); pthread_detach(pthread_self());
rename_proc("db_summariser");
while (!everyone_die && !db_load_complete) while (!everyone_die && !db_load_complete)
cksleep_ms(42); cksleep_ms(42);
@ -8067,6 +8069,8 @@ static void *logger(__maybe_unused void *arg)
pthread_detach(pthread_self()); pthread_detach(pthread_self());
rename_proc("db_logger");
setnow(&now); setnow(&now);
snprintf(buf, sizeof(buf), "logstart.%ld,%ld", snprintf(buf, sizeof(buf), "logstart.%ld,%ld",
now.tv_sec, now.tv_usec); now.tv_sec, now.tv_usec);
@ -8131,6 +8135,8 @@ static void *socketer(__maybe_unused void *arg)
pthread_detach(pthread_self()); pthread_detach(pthread_self());
rename_proc("db_socketer");
while (!everyone_die && !db_auths_complete) while (!everyone_die && !db_auths_complete)
cksem_mswait(&socketer_sem, 420); cksem_mswait(&socketer_sem, 420);
@ -8706,7 +8712,6 @@ static void process_queued(K_ITEM *wq_item)
// TODO: equivalent of api_allow // TODO: equivalent of api_allow
static void *listener(void *arg) static void *listener(void *arg)
{ {
proc_instance_t *pi = (proc_instance_t *)arg;
pthread_t log_pt; pthread_t log_pt;
pthread_t sock_pt; pthread_t sock_pt;
pthread_t summ_pt; pthread_t summ_pt;
@ -8723,7 +8728,7 @@ static void *listener(void *arg)
create_pthread(&summ_pt, summariser, NULL); create_pthread(&summ_pt, summariser, NULL);
rename_proc(pi->sockname); rename_proc("db_listener");
if (!setup_data()) { if (!setup_data()) {
if (!everyone_die) { if (!everyone_die) {

Loading…
Cancel
Save