Flow-IPC 1.0.2
Flow-IPC project: Full implementation 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... | |