Function push_trigger_args_int

lua/sp.c:6667–6761

}

static int push_trigger_args_int(Lua L, dbconsumer_t *q, struct qfound *f, char **err)
{
    uint8_t *payload = ((uint8_t *)f->item) + f->item->data_offset;
    size_t len = f->item->data_len;
    memcpy(&q->genid, &q->fnd.genid, sizeof(genid_t));
    /*
    char header[] = "CDB2_UPD";
    if (memcmp(payload, header, sizeof(header)) != 0) {
        *err = strdup("bad payload header");
        return -1;
    }
    */
    uint8_t zeros[4] = {0};
    if (memcmp(payload + len - 4, zeros, sizeof(zeros)) != 0) {
        *err = strdup("bad payload tail");
        return -1;
    }

    len -= 4; // 4 bytes of zeroes
    uint8_t *end = payload + len;
    payload += 40; // 8 + 32

    int32_t flags = ntohl(*(int *)(payload));
    payload += 4;

    int sztbl = ntohs(*(short *)(payload)) + 1;
    payload += 2;

    char tbl[sztbl];
    strcpy(tbl, (char *)payload);
    payload += sztbl;

    lua_newtable(L);
    lua_pushstring(L, tbl);
    lua_setfield(L, -2, "name");

    blob_t id = {.length = sizeof(genid_t), .data = &q->genid};
    luabb_pushblob(L, &id);
    lua_setfield(L, -2, "id");

    if (q->push_tid) {
        luabb_pushinteger(L, f->item->trans.tid);
        lua_setfield (L, -2, "tid");
    }
    if (q->push_seq) {
        luabb_pushinteger(L, f->seq);
        lua_setfield (L, -2, "sequence");
    }
    if (q->push_epoch) {
        luabb_pushinteger(L, f->item->epoch);
        lua_setfield (L, -2, "epoch");
    }
    if (flags & TYPE_TAGGED_ADD) {
        lua_newtable(L);
        lua_setfield(L, -2, "new");
        lua_pushstring(L, "add");
        lua_setfield(L, -2, "type");
    } else if (flags & TYPE_TAGGED_DEL) {