Function dbq_poll_int

lua/sp.c:669–694

Call with q->lock held. Unlocks q->lock on return. Returns -2:stopped -1:error 0:IX_NOTFND 1:IX_FND If IX_FND will push Lua table on stack.

// Returns  -2:stopped -1:error  0:IX_NOTFND  1:IX_FND
// If IX_FND will push Lua table on stack.
static int dbq_poll_int(Lua L, dbconsumer_t *q)
{
    SP sp = getsp(L);
    struct sqlclntstate *clnt = sp->clnt;
    struct qfound f = {0};
    int rc = dbq_get(&q->iq, 0, &q->last, &f.item, NULL, NULL, &q->fnd, &f.seq,
                     bdb_get_lid_from_cursortran(clnt->dbtran.cursor_tran));
    Pthread_mutex_unlock(q->lock);
    comdb2_sql_tick_no_recover_deadlock();
    sp->num_instructions = 0;
    if (rc == 0) {
        char *err;
        rc = push_trigger_args_int(L, q, &f, &err);
        free(f.item);
        if (rc != 1) {
            SP sp = getsp(L);
            luabb_error(L, sp, err);
            free(err);
        }
        return rc;
    }
    if (rc == IX_NOTFND) {
        return 0;
    }
    return -1;
}

static int dbq_poll(Lua L, dbconsumer_t *q, int delay_ms)
{