Function enqueue_sql_query

db/sqlinterfaces.c:4902–5006

    } while (0)

static int enqueue_sql_query(struct sqlclntstate *clnt)
{
    char msg[1024];
    int rc;
    int fail_dispatch = 0;
    int q_depth_tag_and_sql;

    struct thr_handle *self = thrman_self();
    if (self) {
        if (clnt->exec_lua_thread)
            thrman_set_subtype(self, THRSUBTYPE_LUA_SQL);
        else
            thrman_set_subtype(self, THRSUBTYPE_TOPLEVEL_SQL);
    }

    bzero(&clnt->osql.timings, sizeof(osqltimings_t));
    bzero(&clnt->osql.fdbtimes, sizeof(fdbtimings_t));
    clnt->osql.timings.query_received = osql_log_time();

    Pthread_mutex_lock(&clnt->wait_mutex);
    clnt->deadlock_recovered = 0;

    Pthread_mutex_lock(&clnt_lk);
    /* Reset clnt->thd: there's no guarantee that this clnt is going to be
       dispatched to the same sql thread it previously ran under; Also, that
       thread may not even exist any more (eg aged out), causing
       reqlog_long_running_clnt() to segfault when reading clnt->thd, which is
       alloca'd on the stack by the sql thread */
    clnt->thd = NULL;
    clnt->done = 0;
    if (clnt->statement_timedout)
        fail_dispatch = 1;
    Pthread_mutex_unlock(&clnt_lk);

    clnt->total_sql++;
    clnt->sql_since_reset++;

    /* keep track so we can display it in stat thr */
    clnt->appsock_id = getarchtid();
    if (!clnt->sql_ref && clnt->sql) {
        clnt->sql_ref = create_string_ref(clnt->sql);
    }

    Pthread_mutex_unlock(&clnt->wait_mutex);

    if (fail_dispatch)
        return -1;

    struct thdpool *pool = get_sql_pool(clnt);
    clnt->enque_timeus = comdb2_time_epochus();

    if (gbl_verbose_normalized_queries) {
        snprintf(msg, sizeof(msg), "%s {%s} ==> pool {%s} at %llu",
                 clnt->origin, clnt->sql, (pool != NULL) ? thdpool_get_name(pool) :
                 "<null>", (long long unsigned int)clnt->enque_timeus);

        logmsg(LOGMSG_DEBUG, "%s: %s\n", __func__, msg);
    }