Function luabb_trigger_register

lua/sp.c:400–444

static pthread_mutex_t consumer_sqlthds_mutex = PTHREAD_MUTEX_INITIALIZER;

static int luabb_trigger_register(Lua L, trigger_reg_t *reg, int register_timeoutms)
{
    int rc;
    SP sp = getsp(L);
    sp->num_instructions = 0;
    int retry = round(register_timeoutms / 1000.0);
    if (retry <= 0) {
        retry = 1;
    }

    struct thdpool *pool = get_sql_pool(sp->clnt);
    Pthread_mutex_lock(&consumer_sqlthds_mutex);
    thdpool_add_waitthd(pool);
    Pthread_mutex_unlock(&consumer_sqlthds_mutex);

    while ((rc = trigger_register_req(reg)) != CDB2_TRIG_REQ_SUCCESS) {
        /* trigger_register_req() can take up to 1 second. Tick up immediately
           after this so that it's guaranteed that the appsock thread observes
           a good query state for the next heartbeat. */
        comdb2_sql_tick_no_recover_deadlock();
        if (register_timeoutms) {
            if (retry == 0) {
                luabb_error(L, sp, "trigger:%s registration timeout %dms", reg->spname, register_timeoutms);
                rc = -2;
                goto out;
            }
            --retry;
        }
        if (check_retry_conditions(L, reg, 1) != 0) {
            rc = luabb_error(L, sp, sp->error);
            goto out;
        }
        if (rc != NET_SEND_FAIL_TIMEOUT) {
            sleep(1);
            comdb2_sql_tick_no_recover_deadlock();
        }
    }

out:
    Pthread_mutex_lock(&consumer_sqlthds_mutex);
    thdpool_remove_waitthd(pool);
    Pthread_mutex_unlock(&consumer_sqlthds_mutex);

    return rc;
}

static void luabb_trigger_unregister(Lua L, dbconsumer_t *q)
{