SRS-control 0.1.4
 
Loading...
Searching...
No Matches
srs::connection::Stopper Member List

This is the complete list of members for srs::connection::Stopper, including all inherited members.

acq_off()srs::connection::Stopper
app_srs::connection::Base< buffer_size >private
Base(const Info &info, std::string name)srs::connection::Base< buffer_size >inlineexplicit
close()srs::connection::Base< buffer_size >inline
close_socket()srs::connection::Base< buffer_size >protected
communicate(this auto &&self, const std::vector< CommunicateEntryType > &data, uint16_t address)srs::connection::Base< buffer_size >
continuous_send_msg_srs::connection::Base< buffer_size >private
counter_srs::connection::Base< buffer_size >private
encode_write_msg(const std::vector< CommunicateEntryType > &data, uint16_t address)srs::connection::Base< buffer_size >private
get_app() -> App &srs::connection::Base< buffer_size >inline
get_executor()srs::connection::Base< buffer_size >inline
get_local_port_number() const -> intsrs::connection::Base< buffer_size >inline
get_name() const -> const std::string &srs::connection::Base< buffer_size >inline
get_read_msg_buffer() const -> const ReadBufferType< buffer_size > &srs::connection::Base< buffer_size >inline
get_remote_endpoint() -> const udp::endpoint &srs::connection::Base< buffer_size >inline
get_socket() -> const udp::socket &srs::connection::Base< buffer_size >inline
is_continuous() const -> boolsrs::connection::Base< buffer_size >inline
is_continuous_srs::connection::Base< buffer_size >private
is_socket_closed_srs::connection::Base< buffer_size >private
listen(this auto &&self, bool is_non_stop=false)srs::connection::Base< buffer_size >
listen_message(SharedConnectionPtr auto connection, bool is_non_stop=false) -> asio::awaitable< void >srs::connection::Base< buffer_size >privatestatic
local_port_number_srs::connection::Base< buffer_size >private
name_srs::connection::Base< buffer_size >private
new_shared_socket(int port_number) -> std::unique_ptr< udp::socket >srs::connection::Base< buffer_size >protected
on_fail()srs::connection::Stopperinlinestatic
operator=(const Stopper &)=deletesrs::connection::Stopper
operator=(Stopper &&)=deletesrs::connection::Stopper
read_data_handle(std::span< BufferElementType > read_data)srs::connection::Base< buffer_size >inline
read_msg_buffer_srs::connection::Base< buffer_size >private
remote_endpoint_srs::connection::Base< buffer_size >private
reset_read_msg_buffer()srs::connection::Base< buffer_size >inlineprivate
send_continuous_message() -> asio::experimental::coro< int(std::optional< std::string_view >)>srs::connection::Base< buffer_size >
send_message(std::shared_ptr< Base > connection) -> asio::awaitable< void >srs::connection::Base< buffer_size >privatestatic
set_continuous(bool is_continuous=true)srs::connection::Base< buffer_size >inlineprotected
set_remote_endpoint(asio::ip::udp::endpoint endpoint)srs::connection::Base< buffer_size >inline
set_send_message(const RangedData auto &msg)srs::connection::Base< buffer_size >inline
set_socket(std::unique_ptr< asio::ip::udp::socket > socket)srs::connection::Base< buffer_size >inline
set_timeout_seconds(int val)srs::connection::Base< buffer_size >inline
signal_handling(SharedConnectionPtr auto connection) -> asio::awaitable< void >srs::connection::Base< buffer_size >privatestatic
signal_set_srs::connection::Base< buffer_size >private
socket_srs::connection::Base< buffer_size >private
Stopper(const Stopper &)=deletesrs::connection::Stopper
Stopper(Stopper &&)=deletesrs::connection::Stopper
Stopper(const Info &info)srs::connection::Stopperinlineexplicit
timeout_seconds_srs::connection::Base< buffer_size >private
timer_countdown(auto *connection) -> asio::awaitable< void >srs::connection::Base< buffer_size >privatestatic
write_msg_buffer_srs::connection::Base< buffer_size >private
~Stopper()srs::connection::Stopperinline