Seastar
High performance C++ framework for concurrent servers
|
Public Types | |
using | speculation = pollable_fd_state::speculation |
using | shutdown_kernel_only = bool_class< struct shutdown_kernel_only_tag > |
Public Member Functions | |
pollable_fd (file_desc fd, speculation speculate=speculation()) | |
future< size_t > | read_some (char *buffer, size_t size) |
future< size_t > | read_some (uint8_t *buffer, size_t size) |
future< size_t > | read_some (const std::vector< iovec > &iov) |
future< temporary_buffer< char > > | read_some (internal::buffer_allocator *ba) |
future | write_all (const char *buffer, size_t size) |
future | write_all (const uint8_t *buffer, size_t size) |
future< size_t > | write_some (net::packet &p) |
future | write_all (net::packet &p) |
future | readable () |
future | writeable () |
future | readable_or_writeable () |
future< std::tuple< pollable_fd, socket_address > > | accept () |
future | connect (socket_address &sa) |
future< temporary_buffer< char > > | recv_some (internal::buffer_allocator *ba) |
future< size_t > | sendmsg (struct msghdr *msg) |
future< size_t > | recvmsg (struct msghdr *msg) |
future< size_t > | sendto (socket_address addr, const void *buf, size_t len) |
file_desc & | get_file_desc () const |
void | shutdown (int how, shutdown_kernel_only kernel_only=shutdown_kernel_only::yes) |
void | close () |
operator bool () const noexcept | |
future | poll_rdhup () |
Protected Member Functions | |
int | get_fd () const |
void | maybe_no_more_recv () |
void | maybe_no_more_send () |