ipc_binary.h File Reference

#include "di/bit/endian/little_endian.h"
#include "di/container/allocator/allocator.h"
#include "di/container/intrusive/list.h"
#include "di/container/intrusive/list_node.h"
#include "di/container/vector/vector.h"
#include "di/execution/algorithm/just.h"
#include "di/execution/algorithm/just_from.h"
#include "di/execution/algorithm/let.h"
#include "di/execution/algorithm/let_value_with.h"
#include "di/execution/algorithm/read.h"
#include "di/execution/algorithm/when_all.h"
#include "di/execution/algorithm/with_env.h"
#include "di/execution/concepts/single_sender.h"
#include "di/execution/interface/connect.h"
#include "di/execution/interface/get_env.h"
#include "di/execution/interface/run.h"
#include "di/execution/io/async_read_exactly.h"
#include "di/execution/io/async_read_some.h"
#include "di/execution/io/async_write_exactly.h"
#include "di/execution/io/async_write_some.h"
#include "di/execution/io/ipc_protocol.h"
#include "di/execution/query/get_allocator.h"
#include "di/execution/query/get_sequence_cardinality.h"
#include "di/execution/query/get_stop_token.h"
#include "di/execution/query/make_env.h"
#include "di/execution/receiver/set_error.h"
#include "di/execution/receiver/set_stopped.h"
#include "di/execution/receiver/set_value.h"
#include "di/execution/scope/scope.h"
#include "di/execution/sequence/filter.h"
#include "di/execution/sequence/ignore_all.h"
#include "di/execution/sequence/let_each.h"
#include "di/execution/sequence/repeat.h"
#include "di/execution/sequence/sequence_sender.h"
#include "di/execution/sequence/then_each.h"
#include "di/execution/types/completion_signuatures.h"
#include "di/execution/types/empty_env.h"
#include "di/function/index_dispatch.h"
#include "di/function/invoke.h"
#include "di/function/make_deferred.h"
#include "di/function/monad/monad_try.h"
#include "di/function/tag_invoke.h"
#include "di/io/vector_reader.h"
#include "di/io/vector_writer.h"
#include "di/io/write_exactly.h"
#include "di/math/intcmp/representable_as.h"
#include "di/meta/algorithm.h"
#include "di/meta/core.h"
#include "di/meta/function.h"
#include "di/meta/language.h"
#include "di/meta/list.h"
#include "di/meta/operations.h"
#include "di/meta/util.h"
#include "di/platform/compiler.h"
#include "di/platform/prelude.h"
#include "di/serialization/binary_deserializer.h"
#include "di/serialization/binary_serializer.h"
#include "di/serialization/deserialize.h"
#include "di/serialization/serialize.h"
#include "di/sync/stop_token/forward_declaration.h"
#include "di/sync/stop_token/in_place_stop_source.h"
#include "di/sync/stop_token/in_place_stop_token.h"
#include "di/types/byte.h"
#include "di/util/addressof.h"
#include "di/util/bit_cast.h"
#include "di/util/defer_construct.h"
#include "di/util/immovable.h"
#include "di/util/named_arguments.h"
#include "di/util/noncopyable.h"
#include "di/util/reference_wrapper.h"
#include "di/vocab/array/array.h"
#include "di/vocab/error/error.h"
#include "di/vocab/error/result.h"
#include "di/vocab/span/span_forward_declaration.h"
#include "di/vocab/variant/holds_alternative.h"

Go to the source code of this file.

Classes
struct	di::execution::ipc_binary_ns::Client
struct	di::execution::ipc_binary_ns::Server
struct	di::execution::ipc_binary_ns::MessageAtIndexHelper< Proto, ClientOrServer, message_index >
struct	di::execution::ipc_binary_ns::MessageHeader
struct	di::execution::ipc_binary_ns::ReplyWaiterBase
struct	di::execution::ipc_binary_ns::ConnectionDataT< Proto, Read, Write, Alloc >
struct	di::execution::ipc_binary_ns::ConnectionDataT< Proto, Read, Write, Alloc >::Type
struct	di::execution::ipc_binary_ns::MessageDecode< Proto, ClientOrServer >
struct	di::execution::ipc_binary_ns::MessageDecode< Proto, ClientOrServer >::Sender
struct	di::execution::ipc_binary_ns::MessageDecode< Proto, ClientOrServer >::Sender::OperationStateT< Rec >
struct	di::execution::ipc_binary_ns::MessageDecode< Proto, ClientOrServer >::Sender::OperationStateT< Rec >::Type
struct	di::execution::ipc_binary_ns::MessageSequence< Proto, Read, Write, Alloc, ClientOrServer >
struct	di::execution::ipc_binary_ns::WaitForReplyOperationT< Proto, Read, Write, Alloc, ClientOrServer, message_index_, Rec >
struct	di::execution::ipc_binary_ns::WaitForReplyOperationT< Proto, Read, Write, Alloc, ClientOrServer, message_index_, Rec >::Type
struct	di::execution::ipc_binary_ns::WaitForReplySenderT< Proto, Read, Write, Alloc, ClientOrServer, message_index >
struct	di::execution::ipc_binary_ns::WaitForReplySenderT< Proto, Read, Write, Alloc, ClientOrServer, message_index >::Type
struct	di::execution::ipc_binary_ns::ConnectionTokenT< Proto, Read, Write, Alloc, ClientOrServer >
struct	di::execution::ipc_binary_ns::ConnectionTokenT< Proto, Read, Write, Alloc, ClientOrServer >::Type
struct	di::execution::ipc_binary_ns::FilterMessagesFunction< Proto, Read, Write, TxFun, RxFun, Alloc, ClientOrServer >
struct	di::execution::ipc_binary_ns::MakeJoinedSender< Proto, Read, Write, TxFun, RxFun, Alloc, ClientOrServer >
struct	di::execution::ipc_binary_ns::OperationStateT< Proto, Read, Write, TxFun, RxFun, Alloc, ClientOrServer, Rec >
struct	di::execution::ipc_binary_ns::OperationStateT< Proto, Read, Write, TxFun, RxFun, Alloc, ClientOrServer, Rec >::Type
struct	di::execution::ipc_binary_ns::SenderT< Proto, Read, Write, TxFun, RxFun, Alloc, ClientOrServer >
struct	di::execution::ipc_binary_ns::SenderT< Proto, Read, Write, TxFun, RxFun, Alloc, ClientOrServer >::Type
struct	di::execution::ipc_binary_ns::DefaultTransmit
struct	di::execution::ipc_binary_ns::DefaultReceive
struct	di::execution::ipc_binary_ns::ConnectToClientFunction< Proto >
struct	di::execution::ipc_binary_ns::ConnectToServerFunction< Proto >

Namespaces
namespace	di
namespace	di::execution
namespace	di::execution::ipc_binary_ns

Typedefs
template<typename T>
using	di::execution::ipc_binary_ns::Peer = meta::Conditional<is_client<T>, Server, Client>
template<typename Proto, typename ClientOrServer, usize message_index>
using	di::execution::ipc_binary_ns::MessageAtIndex = meta::Type<MessageAtIndexHelper<Proto, ClientOrServer, message_index>>
template<typename Proto, typename Read, typename Write, typename Alloc>
using	di::execution::ipc_binary_ns::ConnectionData = meta::Type<ConnectionDataT<Proto, Read, Write, Alloc>>
template<typename Proto, typename Read, typename Write, typename Alloc, typename ClientOrServer, usize message_index, typename Rec>
using	di::execution::ipc_binary_ns::WaitForReplyOperation
template<typename Proto, typename Read, typename Write, typename Alloc, typename ClientOrServer, usize message_index>
using	di::execution::ipc_binary_ns::WaitForReplySender
template<typename Proto, typename Read, typename Write, typename Alloc, typename ClientOrServer>
using	di::execution::ipc_binary_ns::ConnectionToken = meta::Type<ConnectionTokenT<Proto, Read, Write, Alloc, ClientOrServer>>
template<typename Proto, typename Read, typename Write, typename TxFun, typename RxFun, typename Alloc, typename ClientOrServer, typename Rec>
using	di::execution::ipc_binary_ns::OperationState = meta::Type<OperationStateT<Proto, Read, Write, TxFun, RxFun, Alloc, ClientOrServer, Rec>>
template<typename Proto, typename Read, typename Write, typename TxFun, typename RxFun, typename Alloc, typename ClientOrServer>
using	di::execution::ipc_binary_ns::Sender = meta::Type<SenderT<Proto, Read, Write, TxFun, RxFun, Alloc, ClientOrServer>>
template<typename Proto, typename Read, typename Write, typename TxFun, typename RxFun, typename Alloc>
using	di::execution::ipc_binary_ns::ClientSender
template<typename Proto, typename Read, typename Write, typename TxFun, typename RxFun, typename Alloc>
using	di::execution::ipc_binary_ns::ServerSender

Variables
template<typename Proto, typename ClientOrServer>
constexpr auto	di::execution::ipc_binary_ns::message_decode = MessageDecode<Proto, ClientOrServer> {}
template<typename Proto, typename Read, typename Write, typename Alloc, typename ClientOrServer>
constexpr auto	di::execution::ipc_binary_ns::message_sequence = MessageSequence<Proto, Read, Write, Alloc, ClientOrServer> {}
template<typename Proto, typename Read, typename Write, typename TxFun, typename RxFun, typename Alloc, typename ClientOrServer>
constexpr auto	di::execution::ipc_binary_ns::filter_messages
template<typename Proto, typename Read, typename Write, typename TxFun, typename RxFun, typename Alloc, typename ClientOrServer>
constexpr auto	di::execution::ipc_binary_ns::make_joined_sender
constexpr auto	di::execution::ipc_binary_ns::default_transmit = DefaultTransmit {}
constexpr auto	di::execution::ipc_binary_ns::default_receive = DefaultReceive {}
template<concepts::InstanceOf< Protocol > Proto>
constexpr auto	di::execution::ipc_binary_connect_to_client = ipc_binary_ns::ConnectToClientFunction<Proto> {}
template<concepts::InstanceOf< Protocol > Proto>
constexpr auto	di::execution::ipc_binary_connect_to_server = ipc_binary_ns::ConnectToServerFunction<Proto> {}
template<concepts::InstanceOf< Protocol > Proto>
constexpr auto	di::ipc_binary_connect_to_client
template<concepts::InstanceOf< Protocol > Proto>
constexpr auto	di::ipc_binary_connect_to_server