Function dohsql_wait_for_master

db/dohsql.c:1348–1401

    (clnt->plugin.state && clnt->plugin.write_response == dohsql_write_response)

void dohsql_wait_for_master(sqlite3_stmt *stmt, struct sqlclntstate *clnt)
{
    int rc;
    dohsql_connector_t *conn;

    if (!stmt || !DOHSQL_CLIENT)
        return;

    if (gbl_dohsql_verbose)
        logmsg(LOGMSG_USER, "%p %s waiting for master\n",
               (void *)pthread_self(), __func__);

    conn = clnt->plugin.state;

    Pthread_mutex_lock(&conn->mtx);

    /* wait if run ended ok, master is not done, and there are cached rows */
    if (!clnt->query_rc) {
        while (conn->status == DOH_RUNNING &&
               (conn->selected || (queue_count(conn->que) > 0))) {
            Pthread_mutex_unlock(&conn->mtx);
            poll(NULL, 0, 10);
            if (bdb_lock_desired(thedb->bdb_env)) {
                rc = recover_deadlock_simple(thedb->bdb_env);
                if (rc) {
                    logmsg(LOGMSG_ERROR,
                           "%s failed recover_deadlock "
                           "rc=%d\n",
                           __func__, rc);
                    return;
                }
            }
            Pthread_mutex_lock(&conn->mtx);
        }
    }

    if (gbl_dohsql_verbose)
        logmsg(LOGMSG_USER,
               "%p %s done waiting que %p count %d que_free %p count %d\n",
               (void *)pthread_self(), __func__, conn->que,
               queue_count(conn->que), conn->que_free,
               queue_count(conn->que_free));

    _track_que_free(conn);
    trimQue(conn, stmt, conn->que, 0);
    trimQue(conn, stmt, conn->que_free, 0);

    /*
        This has to be done after the sql thread has done touching clnt
    structure conn->status = DOH_CLIENT_DONE;
    */

    Pthread_mutex_unlock(&conn->mtx);
}

const char *dohsql_get_sql(struct sqlclntstate *clnt, int index)
{