Function dbconsumer_emit

lua/sp.c:943–952

static int db_emit_int(Lua);
static int dbconsumer_emit(Lua L)
{
    dbconsumer_t *q = luaL_checkudata(L, 1, dbtypes.dbconsumer);
    lua_remove(L, 1);

    ping(L);
    int rc = db_emit_int(L);
    pong(L, q);
    return rc;
}

static int dbconsumer_emit_timeout(Lua L)
{