Get current VersionStamp

Using FoundationDB
3

I can think of two ways that might solve your problem.

Tail the last key in your log

This is the most direct way of solving your problem in that it gets you a for real version that someone has used to write a key into your log, which might be useful. You could do a snapshot read from the end of your log keyspace to get the last record and then parse the versionstamp out of it. Something like:

public CompletableFuture<Versionstamp> getCurVersionStamp(ReadTransaction tr) {
  AsyncIterator<KeyValue> iterator = tr.getRange(logSubspace.range(), /* reverse = */ true, /* limit = */ 1).iterator();
  return iterator.onHasNext(hasAny -> {
    if (hasAny) {
        // Get the last element from the log subspace and parse out the versionstamp
        KeyValue kv = iterator.next();
        return Tuple.fromBytes(kv.getKey()).getVersionstamp(0);
    } else {
        // Log subspace is empty
        return null; // or a versionstamp of all zeroes if you prefer
    }
  });
}

If you do this in it’s own transaction or a read only transaction, this is fine. If you do it in a transaction that also performs writes, then you will conflict if there are any concurrent writes to the log subspace unless you pass in a snapshot transaction to the function outlined above.

Construct a versionstamp from your transaction's read version

This makes use of the fact that the first 8 bytes of a versionstamp are the commit version of the data associated with a record. Therefore, if you know the read version of the transaction, you also know that all data in your log subspace at version v will be prefixed by a version less than or equal to v and all future data added later will be prefixed with a version greater than v. So you can do something like:

public CompletableFuture<Versionstamp> getCurVersionStamp(ReadTransaction tr) {
    return tr.getReadVersion().thenApply(readVersion ->
            Versionstamp.fromBytes(ByteBuffer.allocate(Versionstamp.LENGTH)
                .order(ByteOrder.BIG_ENDIAN)
                .putLong(readVersion)
                .putInt(0xffffffff)
                .array())
    );
}

This creates a new versionstamp prefixed by the current read version with all 0xff byte’s at the end. This guarantees that all versionstamps in the database will be less than or equal to (probably strictly less than) the constructed value, and all future versionstamps will be strictly greater than this value, which is I think what you want. Note that it doesn’t have to do any disk I/O and that it only depends on waiting for the read version (which is something that all FDB reads will have to do any way), though it somewhat depends on knowing the byte format used by FDB.

EDIT: I fixed some faulty method calls within the code snippets

2 Likes