Function start_sql_thread

db/sqlglue.c:766–785

}

struct sql_thread *start_sql_thread(void)
{
    struct sql_thread *thd = calloc(1, sizeof(struct sql_thread));
    if (!thd) {
        logmsg(LOGMSG_ERROR, "%s: calloc failed\n", __func__);
        return NULL;
    }
    listc_init(&thd->query_stats, offsetof(struct query_path_component, lnk));
    thd->query_hash = hash_init_user(query_path_component_hash,
                                     query_path_component_cmp, 0, 0);
    Pthread_mutex_init(&thd->lk, NULL);
    Pthread_setspecific(query_info_key, thd);
    Pthread_mutex_lock(&gbl_sql_lock);
    listc_abl(&thedb->sql_threads, thd);
    Pthread_mutex_unlock(&gbl_sql_lock);

    thd->crtshard = 0;

    return thd;
}

static int free_queryhash(void *obj, void *arg)
{