Why does Aerospike not follow msgpack?

1

Aerospike mostly follows msgpack format, but for certain specific cases, it does not.

When writing a string to aerospike, on subsequent reads from the server, the buffer will correctly be prefiexed with the correct type and size according to msgpack, but seems to contain extra data. See msgpack/spec.md at master · msgpack/msgpack · GitHub

Let’s say we have a string whose length is 32. We would expect, based on msgpack, for the serialized version of this string to look like [0xd9, 32, data]

When reading this string from Aerospike, we will see the buffer look like [0xd9, 32, 3, data] We can see this clearly when calling the UnpackString() method in the Unpacker class.

→

→

where ParticleType.STRING == 3 according to aerospike-client-csharp/AerospikeClient/Command/ParticleType.cs at master · aerospike/aerospike-client-csharp · GitHub

Can someone explain the purpose of this, as well as if it’s documented anywhere where Aerospike buffer format diverges from msgpack?

The Unpacker class claims to be following msgpack aerospike-client-csharp/AerospikeClient/Util/Unpacker.cs at master · aerospike/aerospike-client-csharp · GitHub

2
3

When the client and server implemented msgpack 10+ years ago, the msgpack specification at the time was used (See msgpack/spec-old.md at master · msgpack/msgpack · GitHub). This older specification did not have a string type and recommended to serialize strings using the raw (byte) type. Therefore, it was necessary to add an Aerospike particle type to the raw type to distinguish between a string and a byte.

When the new msgpack specification was created later that added a string type, the string type identifier was used, but the extra particle type was left for legacy reasons. Note that new functionality (like expressions) pack expression argument strings without the particle type because that functionality is not bound by legacy code. That’s why there are two low-level methods for packing strings:

// java client code
public void packString(String val) {
	int size = Buffer.estimateSizeUtf8(val);
	packStringBegin(size);

	if (buffer == null) {
		offset += size;
		return;
	}
	offset += Buffer.stringToUtf8(val, buffer, offset);
}

public void packParticleString(String val) {
	int size = Buffer.estimateSizeUtf8(val) + 1;
	packStringBegin(size);

	if (buffer == null) {
		offset += size;
		return;
	}
	buffer[offset++] = (byte)ParticleType.STRING;
	offset += Buffer.stringToUtf8(val, buffer, offset);
}
4

This topic was automatically closed 84 days after the last reply. New replies are no longer allowed.