Function streamGetEdgeID

src/t_stream.cpp:399–430

}

void streamGetEdgeID(stream *s, int first, streamID *edge_id)
{
    raxIterator ri;
    raxStart(&ri, s->rax);
    int empty;
    if (first) {
        raxSeek(&ri, "^", NULL, 0);
        empty = !raxNext(&ri);
    } else {
        raxSeek(&ri, "$", NULL, 0);
        empty = !raxPrev(&ri);
    }

    if (empty) {
        /* Stream is empty, mark edge ID as lowest/highest possible. */
        edge_id->ms = first ? UINT64_MAX : 0;
        edge_id->seq = first ? UINT64_MAX : 0;
        raxStop(&ri);
        return;
    }

    unsigned char *lp = (unsigned char*)ri.data;

    /* Read the master ID from the radix tree key. */
    streamID master_id;
    streamDecodeID(ri.key, &master_id);

    /* Construct edge ID. */
    lpGetEdgeStreamID(lp, first, &master_id, edge_id);

    raxStop(&ri);
}

/* Adds a new item into the stream 's' having the specified number of
 * field-value pairs as specified in 'numfields' and stored into 'argv'.