mirror of
https://github.com/privatevoid-net/nix-super.git
synced 2024-09-22 01:18:03 +03:00
be81764320
This introduces some shared infrastructure for our notion of protocols. We can then define multiple protocols in terms of that notion. We an also express how particular protocols depend on each other. For example, we can define a common protocol and a worker protocol, where the second depends on the first in terms of the data types it can read and write. The "serve" protocol can just use the common one for now, but will eventually need its own machinary just like the worker protocol for version-aware serialisers
60 lines
1.7 KiB
C++
60 lines
1.7 KiB
C++
#pragma once
|
|
/**
|
|
* @file
|
|
*
|
|
* Template implementations (as opposed to mere declarations).
|
|
*
|
|
* This file is an exmample of the "impl.hh" pattern. See the
|
|
* contributing guide.
|
|
*/
|
|
|
|
#include "worker-protocol.hh"
|
|
#include "length-prefixed-protocol-helper.hh"
|
|
|
|
namespace nix {
|
|
|
|
/* protocol-agnostic templates */
|
|
|
|
#define WORKER_USE_LENGTH_PREFIX_SERIALISER(TEMPLATE, T) \
|
|
TEMPLATE T WorkerProto::Serialise< T >::read(const Store & store, WorkerProto::ReadConn conn) \
|
|
{ \
|
|
return LengthPrefixedProtoHelper<WorkerProto, T >::read(store, conn); \
|
|
} \
|
|
TEMPLATE void WorkerProto::Serialise< T >::write(const Store & store, WorkerProto::WriteConn conn, const T & t) \
|
|
{ \
|
|
LengthPrefixedProtoHelper<WorkerProto, T >::write(store, conn, t); \
|
|
}
|
|
|
|
WORKER_USE_LENGTH_PREFIX_SERIALISER(template<typename T>, std::vector<T>)
|
|
WORKER_USE_LENGTH_PREFIX_SERIALISER(template<typename T>, std::set<T>)
|
|
WORKER_USE_LENGTH_PREFIX_SERIALISER(template<typename... Ts>, std::tuple<Ts...>)
|
|
|
|
#define COMMA_ ,
|
|
WORKER_USE_LENGTH_PREFIX_SERIALISER(
|
|
template<typename K COMMA_ typename V>,
|
|
std::map<K COMMA_ V>)
|
|
#undef COMMA_
|
|
|
|
/**
|
|
* Use `CommonProto` where possible.
|
|
*/
|
|
template<typename T>
|
|
struct WorkerProto::Serialise
|
|
{
|
|
static T read(const Store & store, WorkerProto::ReadConn conn)
|
|
{
|
|
return CommonProto::Serialise<T>::read(store,
|
|
CommonProto::ReadConn { .from = conn.from });
|
|
}
|
|
static void write(const Store & store, WorkerProto::WriteConn conn, const T & t)
|
|
{
|
|
CommonProto::Serialise<T>::write(store,
|
|
CommonProto::WriteConn { .to = conn.to },
|
|
t);
|
|
}
|
|
};
|
|
|
|
/* protocol-specific templates */
|
|
|
|
}
|