Commit 43be37b7 authored by Jakob Otto's avatar Jakob Otto

Run clang-format to fix formatting

parent 2185903c
...@@ -2,16 +2,12 @@ ...@@ -2,16 +2,12 @@
using namespace std; using namespace std;
int main() { int main() {
# ifdef __clang__ #ifdef __clang__
cout << __clang_major__ cout << __clang_major__ << "." << __clang_minor__;
<< "." #elif defined(__GNUC__)
<< __clang_minor__; cout << __GNUC__ << "." << __GNUC_MINOR__;
# elif defined(__GNUC__) #else
cout << __GNUC__ cout << "0.0";
<< "." #endif
<< __GNUC_MINOR__; return 0;
# else
cout << "0.0";
# endif
return 0;
} }
...@@ -97,4 +97,4 @@ behavior container_source(container_source_type<Container>* self, Container xs, ...@@ -97,4 +97,4 @@ behavior container_source(container_source_type<Container>* self, Container xs,
/// Convenience function for spawning container sources. /// Convenience function for spawning container sources.
} // namespace caf } // namespace caf::bb
...@@ -98,4 +98,4 @@ void stream_reader(stream_source_type<InputStream>* self, ...@@ -98,4 +98,4 @@ void stream_reader(stream_source_type<InputStream>* self,
unit(src.ptr()->add_outbound_path(sinks)...); unit(src.ptr()->add_outbound_path(sinks)...);
} }
} // namespace caf } // namespace caf::bb
...@@ -71,4 +71,4 @@ public: ...@@ -71,4 +71,4 @@ public:
} }
}; };
} // namespace caf } // namespace caf::policy
...@@ -102,9 +102,9 @@ CAF_TEST(stream_to_sinks) { ...@@ -102,9 +102,9 @@ CAF_TEST(stream_to_sinks) {
auto snk1 = sys.spawn(container_sink); auto snk1 = sys.spawn(container_sink);
auto snk2 = sys.spawn(container_sink); auto snk2 = sys.spawn(container_sink);
auto snk3 = sys.spawn(container_sink); auto snk3 = sys.spawn(container_sink);
auto src auto src = sys
= sys.spawn(bb::container_source<container_type, actor, actor, actor>, .spawn(bb::container_source<container_type, actor, actor, actor>,
test_container, snk1, snk2, snk3); test_container, snk1, snk2, snk3);
auto mon = sys.spawn(container_monitor); auto mon = sys.spawn(container_monitor);
self->send(mon, join_atom::value, src); self->send(mon, join_atom::value, src);
run(); run();
......
...@@ -104,10 +104,10 @@ CAF_TEST(stream_to_sink) { ...@@ -104,10 +104,10 @@ CAF_TEST(stream_to_sink) {
std::vector<value_type> test_container{1, 2, 3, 4, 5, 6, 7, 78, std::vector<value_type> test_container{1, 2, 3, 4, 5, 6, 7, 78,
1254, 1, 20, 4, 56, 78, 95}; 1254, 1, 20, 4, 56, 78, 95};
auto sink = sys.spawn(stream_reader_sink); auto sink = sys.spawn(stream_reader_sink);
auto src auto src = sys.spawn(bb::stream_reader<
= sys.spawn(bb::stream_reader<policy::tokenized_integer_reader<value_type>, policy::tokenized_integer_reader<value_type>,
stream_type, actor>, stream_type, actor>,
std::move(ptr_test_stream), sink); std::move(ptr_test_stream), sink);
auto mon = sys.spawn(stream_monitor); auto mon = sys.spawn(stream_monitor);
self->send(mon, join_atom::value, src); self->send(mon, join_atom::value, src);
run(); run();
...@@ -125,10 +125,10 @@ CAF_TEST(stream_to_sinks) { ...@@ -125,10 +125,10 @@ CAF_TEST(stream_to_sinks) {
auto snk1 = sys.spawn(stream_reader_sink); auto snk1 = sys.spawn(stream_reader_sink);
auto snk2 = sys.spawn(stream_reader_sink); auto snk2 = sys.spawn(stream_reader_sink);
auto snk3 = sys.spawn(stream_reader_sink); auto snk3 = sys.spawn(stream_reader_sink);
auto src auto src = sys.spawn(bb::stream_reader<
= sys.spawn(bb::stream_reader<policy::tokenized_integer_reader<value_type>, policy::tokenized_integer_reader<value_type>,
stream_type, actor, actor, actor>, stream_type, actor, actor, actor>,
std::move(ptr_test_stream), snk1, snk2, snk3); std::move(ptr_test_stream), snk1, snk2, snk3);
auto mon = sys.spawn(stream_monitor); auto mon = sys.spawn(stream_monitor);
self->send(mon, join_atom::value, src); self->send(mon, join_atom::value, src);
run(); run();
...@@ -146,10 +146,10 @@ CAF_TEST(error_stream_to_sink) { ...@@ -146,10 +146,10 @@ CAF_TEST(error_stream_to_sink) {
std::unique_ptr<stream_type> ptr_test_stream{ std::unique_ptr<stream_type> ptr_test_stream{
new stream_type(test_stringvalues)}; new stream_type(test_stringvalues)};
auto sink = sys.spawn(stream_reader_sink); auto sink = sys.spawn(stream_reader_sink);
auto src auto src = sys.spawn(bb::stream_reader<
= sys.spawn(bb::stream_reader<policy::tokenized_integer_reader<value_type>, policy::tokenized_integer_reader<value_type>,
stream_type, actor>, stream_type, actor>,
std::move(ptr_test_stream), sink); std::move(ptr_test_stream), sink);
auto mon = sys.spawn(stream_monitor); auto mon = sys.spawn(stream_monitor);
self->send(mon, join_atom::value, src); self->send(mon, join_atom::value, src);
run(); run();
......
...@@ -27,4 +27,4 @@ void convert(const ip_endpoint& src, sockaddr_storage& dst); ...@@ -27,4 +27,4 @@ void convert(const ip_endpoint& src, sockaddr_storage& dst);
error convert(const sockaddr_storage& src, ip_endpoint& dst); error convert(const sockaddr_storage& src, ip_endpoint& dst);
} // namespace caf } // namespace caf::detail
...@@ -46,4 +46,4 @@ inline auto port_of(sockaddr_in6& what) -> decltype(what.sin6_port)& { ...@@ -46,4 +46,4 @@ inline auto port_of(sockaddr_in6& what) -> decltype(what.sin6_port)& {
return what.sin6_port; return what.sin6_port;
} }
} // namespace caf } // namespace caf::detail
...@@ -40,4 +40,4 @@ using socket_size_type = unsigned; ...@@ -40,4 +40,4 @@ using socket_size_type = unsigned;
#endif // CAF_WINDOWS #endif // CAF_WINDOWS
} // namespace caf } // namespace caf::net
...@@ -41,4 +41,4 @@ private: ...@@ -41,4 +41,4 @@ private:
endpoint_manager_ptr dst_; endpoint_manager_ptr dst_;
}; };
} // namespace caf } // namespace caf::net
...@@ -73,4 +73,4 @@ private: ...@@ -73,4 +73,4 @@ private:
proxy_registry proxies_; proxy_registry proxies_;
}; };
} // namespace caf } // namespace caf::net::backend
...@@ -209,4 +209,4 @@ private: ...@@ -209,4 +209,4 @@ private:
std::unique_ptr<hub_type> hub_; std::unique_ptr<hub_type> hub_;
}; };
} // namespace caf } // namespace caf::net::basp
...@@ -46,4 +46,4 @@ std::string to_string(connection_state x); ...@@ -46,4 +46,4 @@ std::string to_string(connection_state x);
/// @} /// @}
} // namespace caf } // namespace caf::net::basp
...@@ -34,4 +34,4 @@ constexpr size_t header_size = 13; ...@@ -34,4 +34,4 @@ constexpr size_t header_size = 13;
/// @} /// @}
} // namespace caf } // namespace caf::net::basp
...@@ -49,4 +49,4 @@ std::string to_string(ec x); ...@@ -49,4 +49,4 @@ std::string to_string(ec x);
/// @relates ec /// @relates ec
error make_error(ec x); error make_error(ec x);
} // namespace caf } // namespace caf::net::basp
...@@ -89,4 +89,4 @@ typename Inspector::result_type inspect(Inspector& f, header& x) { ...@@ -89,4 +89,4 @@ typename Inspector::result_type inspect(Inspector& f, header& x) {
/// @} /// @}
} // namespace caf } // namespace caf::net::basp
...@@ -74,4 +74,4 @@ public: ...@@ -74,4 +74,4 @@ public:
std::vector<actor_msg> pending; std::vector<actor_msg> pending;
}; };
} // namespace caf } // namespace caf::net::basp
...@@ -73,4 +73,4 @@ std::string to_string(message_type); ...@@ -73,4 +73,4 @@ std::string to_string(message_type);
/// @} /// @}
} // namespace caf } // namespace caf::net::basp
...@@ -78,4 +78,4 @@ public: ...@@ -78,4 +78,4 @@ public:
} }
}; };
} // namespace caf } // namespace caf::net::basp
...@@ -111,4 +111,4 @@ private: ...@@ -111,4 +111,4 @@ private:
buffer_type payload_; buffer_type payload_;
}; };
} // namespace caf } // namespace caf::net::basp
...@@ -40,4 +40,4 @@ error allow_connreset(datagram_socket x, bool new_value); ...@@ -40,4 +40,4 @@ error allow_connreset(datagram_socket x, bool new_value);
variant<size_t, sec> variant<size_t, sec>
check_datagram_socket_io_res(std::make_signed<size_t>::type res); check_datagram_socket_io_res(std::make_signed<size_t>::type res);
} // namespace caf } // namespace caf::net
...@@ -30,4 +30,4 @@ extern const size_t max_payload_buffers; ...@@ -30,4 +30,4 @@ extern const size_t max_payload_buffers;
/// Maximum number of cached buffers for sending headers. /// Maximum number of cached buffers for sending headers.
extern const size_t max_header_buffers; extern const size_t max_header_buffers;
} // namespace caf } // namespace caf::defaults::middleman
...@@ -103,4 +103,4 @@ protected: ...@@ -103,4 +103,4 @@ protected:
using endpoint_manager_ptr = intrusive_ptr<endpoint_manager>; using endpoint_manager_ptr = intrusive_ptr<endpoint_manager>;
} // namespace caf } // namespace caf::net
...@@ -131,4 +131,4 @@ private: ...@@ -131,4 +131,4 @@ private:
uint64_t next_timeout_id_; uint64_t next_timeout_id_;
}; };
} // namespace caf } // namespace caf::net
...@@ -200,4 +200,4 @@ public: ...@@ -200,4 +200,4 @@ public:
using type = intrusive::fifo_inbox<policy>; using type = intrusive::fifo_inbox<policy>;
}; };
} // namespace caf } // namespace caf::net
...@@ -30,4 +30,4 @@ struct this_host { ...@@ -30,4 +30,4 @@ struct this_host {
static void cleanup(); static void cleanup();
}; };
} // namespace caf } // namespace caf::net
...@@ -41,4 +41,4 @@ std::vector<ip_address> local_addresses(ip_address host); ...@@ -41,4 +41,4 @@ std::vector<ip_address> local_addresses(ip_address host);
/// Returns the hostname of this device. /// Returns the hostname of this device.
std::string hostname(); std::string hostname();
} // namespace caf } // namespace caf::net::ip
...@@ -31,4 +31,4 @@ endpoint_manager_ptr make_endpoint_manager(const multiplexer_ptr& mpx, ...@@ -31,4 +31,4 @@ endpoint_manager_ptr make_endpoint_manager(const multiplexer_ptr& mpx,
return make_counted<impl>(mpx, sys, std::move(trans)); return make_counted<impl>(mpx, sys, std::move(trans));
} }
} // namespace caf } // namespace caf::net
...@@ -118,4 +118,4 @@ private: ...@@ -118,4 +118,4 @@ private:
std::thread mpx_thread_; std::thread mpx_thread_;
}; };
} // namespace caf } // namespace caf::net
...@@ -62,4 +62,4 @@ private: ...@@ -62,4 +62,4 @@ private:
/// @relates middleman_backend /// @relates middleman_backend
using middleman_backend_ptr = std::unique_ptr<middleman_backend>; using middleman_backend_ptr = std::unique_ptr<middleman_backend>;
} // namespace caf } // namespace caf::net
...@@ -127,4 +127,4 @@ using multiplexer_ptr = std::shared_ptr<multiplexer>; ...@@ -127,4 +127,4 @@ using multiplexer_ptr = std::shared_ptr<multiplexer>;
/// @relates multiplexer /// @relates multiplexer
using weak_multiplexer_ptr = std::weak_ptr<multiplexer>; using weak_multiplexer_ptr = std::weak_ptr<multiplexer>;
} // namespace caf } // namespace caf::net
...@@ -82,4 +82,4 @@ void shutdown_write(network_socket x); ...@@ -82,4 +82,4 @@ void shutdown_write(network_socket x);
/// @relates network_socket /// @relates network_socket
void shutdown(network_socket x); void shutdown(network_socket x);
} // namespace caf } // namespace caf::net
...@@ -48,4 +48,4 @@ constexpr operation operator~(operation x) { ...@@ -48,4 +48,4 @@ constexpr operation operator~(operation x) {
std::string to_string(operation x); std::string to_string(operation x);
} // namespace caf } // namespace caf::net
...@@ -55,4 +55,4 @@ protected: ...@@ -55,4 +55,4 @@ protected:
virtual void write_impl(span<buffer_type*> buffers) = 0; virtual void write_impl(span<buffer_type*> buffers) = 0;
}; };
} // namespace caf } // namespace caf::net
...@@ -92,4 +92,4 @@ make_packet_writer_decorator(Object& object, Parent& parent) { ...@@ -92,4 +92,4 @@ make_packet_writer_decorator(Object& object, Parent& parent) {
return {object, parent}; return {object, parent};
} }
} // namespace caf } // namespace caf::net
...@@ -62,4 +62,4 @@ variant<size_t, sec> read(pipe_socket x, span<byte>); ...@@ -62,4 +62,4 @@ variant<size_t, sec> read(pipe_socket x, span<byte>);
variant<size_t, sec> variant<size_t, sec>
check_pipe_socket_io_res(std::make_signed<size_t>::type res); check_pipe_socket_io_res(std::make_signed<size_t>::type res);
} // namespace caf } // namespace caf::net
...@@ -62,4 +62,4 @@ private: ...@@ -62,4 +62,4 @@ private:
size_t buf_size_; size_t buf_size_;
}; };
} // namespace caf } // namespace caf::net
...@@ -56,4 +56,4 @@ public: ...@@ -56,4 +56,4 @@ public:
} }
}; };
} // namespace caf } // namespace caf::net
...@@ -88,4 +88,4 @@ error child_process_inherit(socket x, bool new_value); ...@@ -88,4 +88,4 @@ error child_process_inherit(socket x, bool new_value);
/// @relates socket /// @relates socket
error nonblocking(socket x, bool new_value); error nonblocking(socket x, bool new_value);
} // namespace caf } // namespace caf::net
...@@ -77,4 +77,4 @@ socket_guard<Socket> make_socket_guard(Socket sock) { ...@@ -77,4 +77,4 @@ socket_guard<Socket> make_socket_guard(Socket sock) {
return socket_guard<Socket>{sock}; return socket_guard<Socket>{sock};
} }
} // namespace caf } // namespace caf::net
...@@ -50,4 +50,4 @@ constexpr socket_id invalid_socket_id = -1; ...@@ -50,4 +50,4 @@ constexpr socket_id invalid_socket_id = -1;
/// @relates socket /// @relates socket
using signed_socket_id = std::make_signed<socket_id>::type; using signed_socket_id = std::make_signed<socket_id>::type;
} // namespace caf } // namespace caf::net
...@@ -94,4 +94,4 @@ protected: ...@@ -94,4 +94,4 @@ protected:
using socket_manager_ptr = intrusive_ptr<socket_manager>; using socket_manager_ptr = intrusive_ptr<socket_manager>;
} // namespace caf } // namespace caf::net
...@@ -77,4 +77,4 @@ variant<size_t, sec> write(stream_socket x, ...@@ -77,4 +77,4 @@ variant<size_t, sec> write(stream_socket x,
variant<size_t, sec> variant<size_t, sec>
check_stream_socket_io_res(std::make_signed<size_t>::type res); check_stream_socket_io_res(std::make_signed<size_t>::type res);
} // namespace caf } // namespace caf::net
...@@ -57,4 +57,4 @@ make_tcp_accept_socket(const uri::authority_type& node, ...@@ -57,4 +57,4 @@ make_tcp_accept_socket(const uri::authority_type& node,
/// @relates tcp_accept_socket /// @relates tcp_accept_socket
expected<tcp_stream_socket> accept(tcp_accept_socket x); expected<tcp_stream_socket> accept(tcp_accept_socket x);
} // namespace caf } // namespace caf::net
...@@ -45,4 +45,4 @@ expected<tcp_stream_socket> make_connected_tcp_stream_socket(ip_endpoint node); ...@@ -45,4 +45,4 @@ expected<tcp_stream_socket> make_connected_tcp_stream_socket(ip_endpoint node);
expected<tcp_stream_socket> expected<tcp_stream_socket>
make_connected_tcp_stream_socket(const uri::authority_type& node); make_connected_tcp_stream_socket(const uri::authority_type& node);
} // namespace caf } // namespace caf::net
...@@ -82,4 +82,4 @@ variant<size_t, sec> write(udp_datagram_socket x, span<const byte> buf, ...@@ -82,4 +82,4 @@ variant<size_t, sec> write(udp_datagram_socket x, span<const byte> buf,
variant<size_t, sec> variant<size_t, sec>
check_udp_datagram_socket_io_res(std::make_signed<size_t>::type res); check_udp_datagram_socket_io_res(std::make_signed<size_t>::type res);
} // namespace caf } // namespace caf::net
...@@ -49,4 +49,4 @@ void actor_proxy_impl::kill_proxy(execution_unit* ctx, error rsn) { ...@@ -49,4 +49,4 @@ void actor_proxy_impl::kill_proxy(execution_unit* ctx, error rsn) {
cleanup(std::move(rsn), ctx); cleanup(std::move(rsn), ctx);
} }
} // namespace caf } // namespace caf::net
...@@ -395,4 +395,4 @@ error application::generate_handshake(std::vector<byte>& buf) { ...@@ -395,4 +395,4 @@ error application::generate_handshake(std::vector<byte>& buf) {
defaults::middleman::app_identifiers)); defaults::middleman::app_identifiers));
} }
} // namespace caf } // namespace caf::net::basp
...@@ -59,4 +59,4 @@ error convert(const sockaddr_storage& src, ip_endpoint& dst) { ...@@ -59,4 +59,4 @@ error convert(const sockaddr_storage& src, ip_endpoint& dst) {
return none; return none;
} }
} // namespace caf } // namespace caf::detail
...@@ -59,4 +59,4 @@ check_datagram_socket_io_res(std::make_signed<size_t>::type res) { ...@@ -59,4 +59,4 @@ check_datagram_socket_io_res(std::make_signed<size_t>::type res) {
return static_cast<size_t>(res); return static_cast<size_t>(res);
} }
} // namespace caf } // namespace caf::net
...@@ -24,4 +24,4 @@ const size_t max_payload_buffers = 100; ...@@ -24,4 +24,4 @@ const size_t max_payload_buffers = 100;
const size_t max_header_buffers = 10; const size_t max_header_buffers = 10;
} // namespace caf } // namespace caf::defaults::middleman
...@@ -28,4 +28,4 @@ error make_error(ec x) { ...@@ -28,4 +28,4 @@ error make_error(ec x) {
return {static_cast<uint8_t>(x), atom("basp")}; return {static_cast<uint8_t>(x), atom("basp")};
} }
} // namespace caf } // namespace caf::net::basp
...@@ -86,4 +86,4 @@ bool endpoint_manager::enqueue(endpoint_manager_queue::element* ptr) { ...@@ -86,4 +86,4 @@ bool endpoint_manager::enqueue(endpoint_manager_queue::element* ptr) {
} }
} }
} // namespace caf } // namespace caf::net
...@@ -67,4 +67,4 @@ void to_bytes(header x, std::vector<byte>& buf) { ...@@ -67,4 +67,4 @@ void to_bytes(header x, std::vector<byte>& buf) {
to_bytes_impl(x, buf.data()); to_bytes_impl(x, buf.data());
} }
} // namespace caf } // namespace caf::net::basp
...@@ -52,4 +52,4 @@ void this_host::cleanup() { ...@@ -52,4 +52,4 @@ void this_host::cleanup() {
#endif // CAF_WINDOWS #endif // CAF_WINDOWS
} // namespace caf } // namespace caf::net
...@@ -249,4 +249,4 @@ std::string hostname() { ...@@ -249,4 +249,4 @@ std::string hostname() {
return buf; return buf;
} }
} // namespace caf } // namespace caf::net::ip
...@@ -70,4 +70,4 @@ uint64_t message_queue::new_id() { ...@@ -70,4 +70,4 @@ uint64_t message_queue::new_id() {
return next_id++; return next_id++;
} }
} // namespace caf } // namespace caf::net::basp
...@@ -282,4 +282,4 @@ void multiplexer::write_to_pipe(uint8_t opcode, const socket_manager_ptr& mgr) { ...@@ -282,4 +282,4 @@ void multiplexer::write_to_pipe(uint8_t opcode, const socket_manager_ptr& mgr) {
mgr->deref(); mgr->deref();
} }
} // namespace caf } // namespace caf::net
...@@ -99,4 +99,4 @@ test::peer_entry& test::get_peer(const node_id& id) { ...@@ -99,4 +99,4 @@ test::peer_entry& test::get_peer(const node_id& id) {
return emplace(id, sockets->first, sockets->second); return emplace(id, sockets->first, sockets->second);
} }
} // namespace caf } // namespace caf::net::backend
...@@ -73,4 +73,4 @@ endpoint_manager_queue::message::~message() { ...@@ -73,4 +73,4 @@ endpoint_manager_queue::message::~message() {
// nop // nop
} }
} // namespace caf } // namespace caf::net
...@@ -102,4 +102,4 @@ middleman_backend* middleman::backend(string_view scheme) const noexcept { ...@@ -102,4 +102,4 @@ middleman_backend* middleman::backend(string_view scheme) const noexcept {
return nullptr; return nullptr;
} }
} // namespace caf } // namespace caf::net
...@@ -28,4 +28,4 @@ middleman_backend::~middleman_backend() { ...@@ -28,4 +28,4 @@ middleman_backend::~middleman_backend() {
// nop // nop
} }
} // namespace caf } // namespace caf::net
...@@ -24,4 +24,4 @@ packet_writer::~packet_writer() { ...@@ -24,4 +24,4 @@ packet_writer::~packet_writer() {
// nop // nop
} }
} // namespace caf } // namespace caf::net
...@@ -80,7 +80,6 @@ error allow_udp_connreset(network_socket x, bool new_value) { ...@@ -80,7 +80,6 @@ error allow_udp_connreset(network_socket x, bool new_value) {
} }
#else // CAF_WINDOWS #else // CAF_WINDOWS
error allow_sigpipe(network_socket x, bool new_value) { error allow_sigpipe(network_socket x, bool new_value) {
# ifdef CAF_HAS_NOSIGPIPE_SOCKET_FLAG # ifdef CAF_HAS_NOSIGPIPE_SOCKET_FLAG
int value = new_value ? 0 : 1; int value = new_value ? 0 : 1;
...@@ -192,4 +191,4 @@ void shutdown(network_socket x) { ...@@ -192,4 +191,4 @@ void shutdown(network_socket x) {
::shutdown(x.id, 2); ::shutdown(x.id, 2);
} }
} // namespace caf } // namespace caf::net
...@@ -101,4 +101,4 @@ check_pipe_socket_io_res(std::make_signed<size_t>::type res) { ...@@ -101,4 +101,4 @@ check_pipe_socket_io_res(std::make_signed<size_t>::type res) {
return check_stream_socket_io_res(res); return check_stream_socket_io_res(res);
} }
} // namespace caf } // namespace caf::net
...@@ -71,4 +71,4 @@ void pollset_updater::handle_error(sec) { ...@@ -71,4 +71,4 @@ void pollset_updater::handle_error(sec) {
// nop // nop
} }
} // namespace caf } // namespace caf::net
...@@ -179,4 +179,4 @@ error nonblocking(socket x, bool new_value) { ...@@ -179,4 +179,4 @@ error nonblocking(socket x, bool new_value) {
#endif // CAF_WINDOWS #endif // CAF_WINDOWS
} // namespace caf } // namespace caf::net
...@@ -67,4 +67,4 @@ void socket_manager::register_writing() { ...@@ -67,4 +67,4 @@ void socket_manager::register_writing() {
ptr->register_writing(this); ptr->register_writing(this);
} }
} // namespace caf } // namespace caf::net
...@@ -233,4 +233,4 @@ check_stream_socket_io_res(std::make_signed<size_t>::type res) { ...@@ -233,4 +233,4 @@ check_stream_socket_io_res(std::make_signed<size_t>::type res) {
return static_cast<size_t>(res); return static_cast<size_t>(res);
} }
} // namespace caf } // namespace caf::net
...@@ -144,4 +144,4 @@ expected<tcp_stream_socket> accept(tcp_accept_socket x) { ...@@ -144,4 +144,4 @@ expected<tcp_stream_socket> accept(tcp_accept_socket x) {
return tcp_stream_socket{sock}; return tcp_stream_socket{sock};
} }
} // namespace caf } // namespace caf::net
...@@ -95,4 +95,4 @@ make_connected_tcp_stream_socket(const uri::authority_type& node) { ...@@ -95,4 +95,4 @@ make_connected_tcp_stream_socket(const uri::authority_type& node) {
return make_error(sec::cannot_connect_to_node, to_string(node)); return make_error(sec::cannot_connect_to_node, to_string(node));
} }
} // namespace caf } // namespace caf::net
...@@ -190,4 +190,4 @@ check_udp_datagram_socket_io_res(std::make_signed<size_t>::type res) { ...@@ -190,4 +190,4 @@ check_udp_datagram_socket_io_res(std::make_signed<size_t>::type res) {
return static_cast<size_t>(res); return static_cast<size_t>(res);
} }
} // namespace caf } // namespace caf::net
...@@ -58,4 +58,4 @@ resumable::resume_result worker::resume(execution_unit* ctx, size_t) { ...@@ -58,4 +58,4 @@ resumable::resume_result worker::resume(execution_unit* ctx, size_t) {
return resumable::awaiting_message; return resumable::awaiting_message;
} }
} // namespace caf } // namespace caf::net::basp
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment