Method log_op

fdbserver/KeyValueStoreMemory.actor.cpp:468–501

Data format for normal operation: +-------------+-------------+-------------+--------+--------+ | opType | len1 | len2 | param2 | param2 | | sizeof(int) | sizeof(int) | sizeof(int) | len1 | len2 | +-------------+-------------+-------------+--------+--------+ However, if the operation is encrypted: +-------------+-------------+-------------+---------------------------------+

	// +-----------------------------------------------------------------------------------------------------------+
	//
	IDiskQueue::location log_op(OpType op, StringRef v1, StringRef v2) {
		// Metadata op types to be excluded from encryption.
		static std::unordered_set<OpType> metaOps = { OpSnapshotEnd, OpSnapshotAbort, OpCommit, OpRollback };
		if (!enableEncryption || metaOps.count(op) > 0) {
			OpHeader h = { (int)op, v1.size(), v2.size() };
			log->push(StringRef((const uint8_t*)&h, sizeof(h)));
			log->push(v1);
			log->push(v2);
		} else {
			OpHeader h = { (int)OpEncrypted, v1.size(), v2.size() };
			log->push(StringRef((const uint8_t*)&h, sizeof(h)));

			uint8_t* plaintext = new uint8_t[sizeof(int) + v1.size() + v2.size()];
			*(int*)plaintext = op;
			if (v1.size()) {
				memcpy(plaintext + sizeof(int), v1.begin(), v1.size());
			}
			if (v2.size()) {
				memcpy(plaintext + sizeof(int) + v1.size(), v2.begin(), v2.size());
			}

			ASSERT(cipherKeys.cipherTextKey.isValid());
			ASSERT(cipherKeys.cipherHeaderKey.isValid());
			EncryptBlobCipherAes265Ctr cipher(
			    cipherKeys.cipherTextKey, cipherKeys.cipherHeaderKey, ENCRYPT_HEADER_AUTH_TOKEN_MODE_SINGLE);
			BlobCipherEncryptHeader cipherHeader;
			Arena arena;
			StringRef ciphertext =
			    cipher.encrypt(plaintext, sizeof(int) + v1.size() + v2.size(), &cipherHeader, arena)->toStringRef();
			log->push(StringRef((const uint8_t*)&cipherHeader, BlobCipherEncryptHeader::headerSize));
			log->push(ciphertext);
		}
		return log->push(LiteralStringRef("\x01")); // Changes here should be reflected in OP_DISK_OVERHEAD
	}

	// In case the op data is not encrypted, simply read the operands and the zero fill flag.
	// Otherwise, decrypt the op type and data.