asio_local_stream_socket_fwd.hpp File Reference

#include "ipc/transport/asio_local_stream_socket_fwd.hpp"
#include "ipc/util/shared_name_fwd.hpp"
#include <flow/util/util.hpp>

Go to the source code of this file.

Namespaces
namespace	ipc
	Catch-all namespace for the Flow-IPC project: A library/API in modern C++17 providing high-performance communication between processes.
namespace	ipc::transport
	Flow-IPC module providing transmission of structured messages and/or low-level blobs (and more) between pairs of processes.
namespace	ipc::transport::asio_local_stream_socket
	Additional (versus boost.asio) APIs for advanced work with local stream (Unix domain) sockets including transmission of native handles through such streams; and peer process credentials acquisition.

Functions
Endpoint	ipc::transport::asio_local_stream_socket::endpoint_at_shared_name (flow::log::Logger *logger_ptr, const Shared_name &absolute_name, Error_code *err_code=0)
	Returns an Endpoint corresponding to the given absolute Shared_name, so that an Acceptor or Peer_socket could be bound to it. More...
template<typename Task_err >
void	ipc::transport::asio_local_stream_socket::on_wait_writable_or_error (flow::log::Logger *logger_ptr, const Error_code &sys_err_code, Native_handle payload_hndl, const util::Blob_const &payload_blob, Peer_socket *peer_socket, Task_err &&on_sent_or_error)
	Helper of async_write_with_native_handle() used as the callback executed when waiting for writability of the given connected local peer socket, with the idea to execute a native sendmsg() call and all further parts of the async send op started by async_write_with_native_handle(). More...
template<bool TARGET_TBD, typename Task_err_blob , typename Target_payload_blob_func , typename Should_interrupt_func >
void	ipc::transport::asio_local_stream_socket::on_wait_readable_or_error (flow::log::Logger *logger_ptr, const Error_code &sys_err_code, Peer_socket *peer_socket, Should_interrupt_func &&should_interrupt_func, Task_err_blob &&on_rcvd_or_error, Target_payload_blob_func &&target_payload_blob_func, util::Blob_mutable target_payload_blob, size_t n_rcvd_so_far)
	Helper of async_read_with_target_func() containing its core (asynchronously) recursive implementation. More...