Advanced example: Managing accepted connections. More...

Collaboration diagram for ConnectionManager:

Public Member Functions
void	start (std::unique_ptr< unified::i_listener > listener)

void	broadcast (std::span< const std::byte > data)

Private Member Functions
void	handle_new_connection (std::unique_ptr< unified::i_connection > conn)

Private Attributes
std::unique_ptr< unified::i_listener >	listener_

std::map< std::string, std::unique_ptr< unified::i_connection > >	connections_

Detailed Description

Advanced example: Managing accepted connections.

Shows how to get ownership of accepted connections for custom management.

Definition at line 109 of file unified_server_example.cpp.

Member Function Documentation

◆ broadcast()

void ConnectionManager::broadcast ( std::span< const std::byte > data )

inline

Definition at line 123 of file unified_server_example.cpp.

                                                {
        for (auto& [id, conn] : connections_) {
            conn->send(data);
        }
    }

References connections_.

◆ handle_new_connection()

void ConnectionManager::handle_new_connection ( std::unique_ptr< unified::i_connection > conn )

inlineprivate

Definition at line 130 of file unified_server_example.cpp.

                                                                        {
        // Get connection ID from endpoint info
        auto endpoint = conn->remote_endpoint();
        std::string id = std::string(endpoint.host) + ":" +
                         std::to_string(endpoint.port);
 
        std::cout << "Managing connection: " << id << "\n";
 
        // Set up connection-specific callbacks
        conn->set_callbacks({
            .on_data = [id](std::span<const std::byte> data) {
                std::cout << "Data from " << id << "\n";
            },
            .on_disconnected = [this, id]() {
                connections_.erase(id);
                std::cout << "Removed connection: " << id << "\n";
            }
        });
 
        // Store connection
        connections_[id] = std::move(conn);
    }

References connections_.

Referenced by start().

Here is the caller graph for this function:

◆ start()

void ConnectionManager::start ( std::unique_ptr< unified::i_listener > listener )

inline

Definition at line 111 of file unified_server_example.cpp.

                                                          {
        listener_ = std::move(listener);
 
        // Use accept callback to get connection ownership
        listener_->set_accept_callback(
            [this](std::unique_ptr<unified::i_connection> conn) {
                handle_new_connection(std::move(conn));
            });
 
        listener_->start(8080);
    }