Function writeMutation

fdbserver/CommitProxyServer.actor.cpp:1160–1174

}

void writeMutation(CommitBatchContext* self, int64_t tenantId, const MutationRef& mutation) {
	static_assert(TenantInfo::INVALID_TENANT == ENCRYPT_INVALID_DOMAIN_ID);
	if (!self->pProxyCommitData->isEncryptionEnabled || tenantId == TenantInfo::INVALID_TENANT) {
		// TODO(yiwu): In raw access mode, use tenant prefix to figure out tenant id for user data
		bool isRawAccess = tenantId == TenantInfo::INVALID_TENANT && !isSystemKey(mutation.param1) &&
		                   !(mutation.type == MutationRef::ClearRange && isSystemKey(mutation.param2)) &&
		                   self->pProxyCommitData->db->get().client.tenantMode == TenantMode::REQUIRED;
		CODE_PROBE(isRawAccess, "Raw access to tenant key space");
		self->toCommit.writeTypedMessage(mutation);
	} else {
		Arena arena;
		self->toCommit.writeTypedMessage(
		    EncryptedMutationMessage::encrypt(arena, self->cipherKeys, tenantId /*domainId*/, mutation));
	}
}

/// This second pass through committed transactions assigns the actual mutations to the appropriate storage servers'
/// tags