Commit cccaaa9d authored by Jakob Otto's avatar Jakob Otto

Run clang-format to fix formatting

parent 102c3dfa
......@@ -27,4 +27,4 @@ void convert(const ip_endpoint& src, sockaddr_storage& 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)& {
return what.sin6_port;
}
} // namespace caf
} // namespace caf::detail
......@@ -40,4 +40,4 @@ using socket_size_type = unsigned;
#endif // CAF_WINDOWS
} // namespace caf
} // namespace caf::net
......@@ -41,4 +41,4 @@ private:
endpoint_manager_ptr dst_;
};
} // namespace caf
} // namespace caf::net
......@@ -73,4 +73,4 @@ private:
proxy_registry proxies_;
};
} // namespace caf
} // namespace caf::net::backend
......@@ -209,4 +209,4 @@ private:
std::unique_ptr<hub_type> hub_;
};
} // namespace caf
} // namespace caf::net::basp
......@@ -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;
/// @}
} // namespace caf
} // namespace caf::net::basp
......@@ -49,4 +49,4 @@ std::string to_string(ec x);
/// @relates ec
error make_error(ec x);
} // namespace caf
} // namespace caf::net::basp
......@@ -89,4 +89,4 @@ typename Inspector::result_type inspect(Inspector& f, header& x) {
/// @}
} // namespace caf
} // namespace caf::net::basp
......@@ -74,4 +74,4 @@ public:
std::vector<actor_msg> pending;
};
} // namespace caf
} // namespace caf::net::basp
......@@ -73,4 +73,4 @@ std::string to_string(message_type);
/// @}
} // namespace caf
} // namespace caf::net::basp
......@@ -78,4 +78,4 @@ public:
}
};
} // namespace caf
} // namespace caf::net::basp
......@@ -111,4 +111,4 @@ private:
buffer_type payload_;
};
} // namespace caf
} // namespace caf::net::basp
......@@ -40,4 +40,4 @@ error allow_connreset(datagram_socket x, bool new_value);
variant<size_t, sec>
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;
/// Maximum number of cached buffers for sending headers.
extern const size_t max_header_buffers;
} // namespace caf
} // namespace caf::defaults::middleman
......@@ -103,4 +103,4 @@ protected:
using endpoint_manager_ptr = intrusive_ptr<endpoint_manager>;
} // namespace caf
} // namespace caf::net
......@@ -131,4 +131,4 @@ private:
uint64_t next_timeout_id_;
};
} // namespace caf
} // namespace caf::net
......@@ -200,4 +200,4 @@ public:
using type = intrusive::fifo_inbox<policy>;
};
} // namespace caf
} // namespace caf::net
......@@ -30,4 +30,4 @@ struct this_host {
static void cleanup();
};
} // namespace caf
} // namespace caf::net
......@@ -41,4 +41,4 @@ std::vector<ip_address> local_addresses(ip_address host);
/// Returns the hostname of this device.
std::string hostname();
} // namespace caf
} // namespace caf::net::ip
......@@ -31,4 +31,4 @@ endpoint_manager_ptr make_endpoint_manager(const multiplexer_ptr& mpx,
return make_counted<impl>(mpx, sys, std::move(trans));
}
} // namespace caf
} // namespace caf::net
......@@ -118,4 +118,4 @@ private:
std::thread mpx_thread_;
};
} // namespace caf
} // namespace caf::net
......@@ -62,4 +62,4 @@ private:
/// @relates 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>;
/// @relates multiplexer
using weak_multiplexer_ptr = std::weak_ptr<multiplexer>;
} // namespace caf
} // namespace caf::net
......@@ -82,4 +82,4 @@ void shutdown_write(network_socket x);
/// @relates network_socket
void shutdown(network_socket x);
} // namespace caf
} // namespace caf::net
......@@ -48,4 +48,4 @@ constexpr operation operator~(operation x) {
std::string to_string(operation x);
} // namespace caf
} // namespace caf::net
......@@ -55,4 +55,4 @@ protected:
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) {
return {object, parent};
}
} // namespace caf
} // namespace caf::net
......@@ -62,4 +62,4 @@ variant<size_t, sec> read(pipe_socket x, span<byte>);
variant<size_t, sec>
check_pipe_socket_io_res(std::make_signed<size_t>::type res);
} // namespace caf
} // namespace caf::net
......@@ -62,4 +62,4 @@ private:
size_t buf_size_;
};
} // namespace caf
} // namespace caf::net
......@@ -56,4 +56,4 @@ public:
}
};
} // namespace caf
} // namespace caf::net
......@@ -88,4 +88,4 @@ error child_process_inherit(socket x, bool new_value);
/// @relates socket
error nonblocking(socket x, bool new_value);
} // namespace caf
} // namespace caf::net
......@@ -77,4 +77,4 @@ socket_guard<Socket> make_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;
/// @relates socket
using signed_socket_id = std::make_signed<socket_id>::type;
} // namespace caf
} // namespace caf::net
......@@ -94,4 +94,4 @@ protected:
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,
variant<size_t, sec>
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,
/// @relates tcp_accept_socket
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);
expected<tcp_stream_socket>
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,
variant<size_t, sec>
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) {
cleanup(std::move(rsn), ctx);
}
} // namespace caf
} // namespace caf::net
......@@ -395,4 +395,4 @@ error application::generate_handshake(std::vector<byte>& buf) {
defaults::middleman::app_identifiers));
}
} // namespace caf
} // namespace caf::net::basp
......@@ -59,4 +59,4 @@ error convert(const sockaddr_storage& src, ip_endpoint& dst) {
return none;
}
} // namespace caf
} // namespace caf::detail
......@@ -59,4 +59,4 @@ check_datagram_socket_io_res(std::make_signed<size_t>::type res) {
return static_cast<size_t>(res);
}
} // namespace caf
} // namespace caf::net
......@@ -24,4 +24,4 @@ const size_t max_payload_buffers = 100;
const size_t max_header_buffers = 10;
} // namespace caf
} // namespace caf::defaults::middleman
......@@ -28,4 +28,4 @@ error make_error(ec x) {
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) {
}
}
} // namespace caf
} // namespace caf::net
......@@ -67,4 +67,4 @@ void to_bytes(header x, std::vector<byte>& buf) {
to_bytes_impl(x, buf.data());
}
} // namespace caf
} // namespace caf::net::basp
......@@ -52,4 +52,4 @@ void this_host::cleanup() {
#endif // CAF_WINDOWS
} // namespace caf
} // namespace caf::net
......@@ -249,4 +249,4 @@ std::string hostname() {
return buf;
}
} // namespace caf
} // namespace caf::net::ip
......@@ -70,4 +70,4 @@ uint64_t message_queue::new_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) {
mgr->deref();
}
} // namespace caf
} // namespace caf::net
......@@ -99,4 +99,4 @@ test::peer_entry& test::get_peer(const node_id& id) {
return emplace(id, sockets->first, sockets->second);
}
} // namespace caf
} // namespace caf::net::backend
......@@ -73,4 +73,4 @@ endpoint_manager_queue::message::~message() {
// nop
}
} // namespace caf
} // namespace caf::net
......@@ -102,4 +102,4 @@ middleman_backend* middleman::backend(string_view scheme) const noexcept {
return nullptr;
}
} // namespace caf
} // namespace caf::net
......@@ -28,4 +28,4 @@ middleman_backend::~middleman_backend() {
// nop
}
} // namespace caf
} // namespace caf::net
......@@ -24,4 +24,4 @@ packet_writer::~packet_writer() {
// nop
}
} // namespace caf
} // namespace caf::net
......@@ -80,7 +80,6 @@ error allow_udp_connreset(network_socket x, bool new_value) {
}
#else // CAF_WINDOWS
error allow_sigpipe(network_socket x, bool new_value) {
# ifdef CAF_HAS_NOSIGPIPE_SOCKET_FLAG
int value = new_value ? 0 : 1;
......@@ -192,4 +191,4 @@ void shutdown(network_socket x) {
::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) {
return check_stream_socket_io_res(res);
}
} // namespace caf
} // namespace caf::net
......@@ -71,4 +71,4 @@ void pollset_updater::handle_error(sec) {
// nop
}
} // namespace caf
} // namespace caf::net
......@@ -179,4 +179,4 @@ error nonblocking(socket x, bool new_value) {
#endif // CAF_WINDOWS
} // namespace caf
} // namespace caf::net
......@@ -67,4 +67,4 @@ void socket_manager::register_writing() {
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) {
return static_cast<size_t>(res);
}
} // namespace caf
} // namespace caf::net
......@@ -144,4 +144,4 @@ expected<tcp_stream_socket> accept(tcp_accept_socket x) {
return tcp_stream_socket{sock};
}
} // namespace caf
} // namespace caf::net
......@@ -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));
}
} // namespace caf
} // namespace caf::net
......@@ -190,4 +190,4 @@ check_udp_datagram_socket_io_res(std::make_signed<size_t>::type 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) {
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