#include <SocketContextUpgradeFactorySelector.h>

Collaboration diagram for web::http::SocketContextUpgradeFactorySelector< SocketContextUpgradeFactoryT >:

Classes
struct	SocketContextPlugin

Public Types
using	SocketContextUpgradeFactory = SocketContextUpgradeFactoryT

using	Request = typename SocketContextUpgradeFactory::Request

using	Response = typename SocketContextUpgradeFactory::Response

Public Member Functions
virtual SocketContextUpgradeFactory *	select (Request &req, Response &res)=0

bool	add (SocketContextUpgradeFactory *socketContextUpgradeFactory)

void	link (const std::string &socketContextUpgradeName, SocketContextUpgradeFactory (linkedPlugin)())

void	allowDlOpen ()

void	unload (SocketContextUpgradeFactory *socketContextUpgradeFactory)

Protected Member Functions
	SocketContextUpgradeFactorySelector ()=default

virtual	~SocketContextUpgradeFactorySelector ()=default

SocketContextUpgradeFactory *	select (const std::string &socketContextUpgradeName)

virtual SocketContextUpgradeFactory *	load (const std::string &socketContextUpgradeName)=0

SocketContextUpgradeFactory *	load (const std::string &socketContextUpgradeName, const std::string &socketContextUpgradeFactoryLibraryFile, const std::string &socketContextUpgradeFactoryFunctionName)

bool	add (SocketContextUpgradeFactory socketContextUpgradeFactory, void handler)

Private Attributes
std::map< std::string, SocketContextPlugin >	socketContextUpgradePlugins

std::map< std::string, SocketContextUpgradeFactory ()()>	linkedSocketContextUpgradePlugins

bool	onlyLinked = false

Detailed Description

template<typename SocketContextUpgradeFactoryT>
class web::http::SocketContextUpgradeFactorySelector< SocketContextUpgradeFactoryT >

Definition at line 57 of file SocketContextUpgradeFactorySelector.h.

Member Typedef Documentation

◆ Request

template<typename SocketContextUpgradeFactoryT >

using web::http::SocketContextUpgradeFactorySelector< SocketContextUpgradeFactoryT >::Request = typename SocketContextUpgradeFactory::Request

Definition at line 60 of file SocketContextUpgradeFactorySelector.h.

◆ Response

template<typename SocketContextUpgradeFactoryT >

using web::http::SocketContextUpgradeFactorySelector< SocketContextUpgradeFactoryT >::Response = typename SocketContextUpgradeFactory::Response

Definition at line 61 of file SocketContextUpgradeFactorySelector.h.

◆ SocketContextUpgradeFactory

template<typename SocketContextUpgradeFactoryT >

using web::http::SocketContextUpgradeFactorySelector< SocketContextUpgradeFactoryT >::SocketContextUpgradeFactory = SocketContextUpgradeFactoryT

Definition at line 59 of file SocketContextUpgradeFactorySelector.h.

Constructor & Destructor Documentation

◆ SocketContextUpgradeFactorySelector()

template<typename SocketContextUpgradeFactoryT >

web::http::SocketContextUpgradeFactorySelector< SocketContextUpgradeFactoryT >::SocketContextUpgradeFactorySelector ( )

protecteddefault

◆ ~SocketContextUpgradeFactorySelector()

template<typename SocketContextUpgradeFactoryT >

virtual web::http::SocketContextUpgradeFactorySelector< SocketContextUpgradeFactoryT >::~SocketContextUpgradeFactorySelector ( )

protectedvirtualdefault

Member Function Documentation

◆ add() [1/2]

template<typename SocketContextUpgradeFactory >

bool web::http::SocketContextUpgradeFactorySelector< SocketContextUpgradeFactory >::add ( SocketContextUpgradeFactory * socketContextUpgradeFactory )

Definition at line 73 of file SocketContextUpgradeFactorySelector.hpp.

                                                                                                                                       {
        return add(socketContextUpgradeFactory, nullptr);
    }

◆ add() [2/2]

template<typename SocketContextUpgradeFactory >

bool web::http::SocketContextUpgradeFactorySelector< SocketContextUpgradeFactory >::add	(	SocketContextUpgradeFactory *	socketContextUpgradeFactory,
		void *	handler
	)

protected

Definition at line 60 of file SocketContextUpgradeFactorySelector.hpp.

                                                                                             {
        bool success = false;
 
        if (socketContextUpgradeFactory != nullptr) {
            SocketContextPlugin socketContextPlugin = {.socketContextUpgradeFactory = socketContextUpgradeFactory, .handle = handle};
            std::tie(std::ignore, success) = socketContextUpgradePlugins.insert({socketContextUpgradeFactory->name(), socketContextPlugin});
        }
 
        return success;
    }

References web::http::SocketContextUpgradeFactorySelector< SocketContextUpgradeFactoryT >::socketContextUpgradePlugins.

◆ allowDlOpen()

template<typename SocketContextUpgradeFactory >

void web::http::SocketContextUpgradeFactorySelector< SocketContextUpgradeFactory >::allowDlOpen ( )

Definition at line 78 of file SocketContextUpgradeFactorySelector.hpp.

                                                                                       {
        onlyLinked = false;
    }

References web::http::SocketContextUpgradeFactorySelector< SocketContextUpgradeFactoryT >::onlyLinked.

◆ link()

template<typename SocketContextUpgradeFactory >

void web::http::SocketContextUpgradeFactorySelector< SocketContextUpgradeFactory >::link	(	const std::string &	socketContextUpgradeName,
		SocketContextUpgradeFactory ()()	linkedPlugin
	)

Definition at line 139 of file SocketContextUpgradeFactorySelector.hpp.

                                                                                                                                {
        if (!linkedSocketContextUpgradePlugins.contains(socketContextUpgradeName)) {
            linkedSocketContextUpgradePlugins[socketContextUpgradeName] = linkedPlugin;
        }
 
        onlyLinked = true;
    }

References web::http::SocketContextUpgradeFactorySelector< SocketContextUpgradeFactoryT >::linkedSocketContextUpgradePlugins, and web::http::SocketContextUpgradeFactorySelector< SocketContextUpgradeFactoryT >::onlyLinked.

Referenced by web::http::client::SocketContextUpgradeFactory::link(), and web::http::server::SocketContextUpgradeFactory::link().

Here is the caller graph for this function:

◆ load() [1/2]

template<typename SocketContextUpgradeFactoryT >

virtual SocketContextUpgradeFactory * web::http::SocketContextUpgradeFactorySelector< SocketContextUpgradeFactoryT >::load ( const std::string & socketContextUpgradeName )

protectedpure virtual

Implemented in web::http::client::SocketContextUpgradeFactorySelector, and web::http::server::SocketContextUpgradeFactorySelector.

◆ load() [2/2]

template<typename SocketContextUpgradeFactory >

SocketContextUpgradeFactory * web::http::SocketContextUpgradeFactorySelector< SocketContextUpgradeFactory >::load	(	const std::string &	socketContextUpgradeName,
		const std::string &	socketContextUpgradeFactoryLibraryFile,
		const std::string &	socketContextUpgradeFactoryFunctionName
	)

protected

Definition at line 84 of file SocketContextUpgradeFactorySelector.hpp.

                                                                                                                                     {
        SocketContextUpgradeFactory* socketContextUpgradeFactory = nullptr;
 
        void* handle = core::DynamicLoader::dlOpen(socketContextUpgradeFactoryLibraryFile);
 
        if (handle != nullptr) {
            SocketContextUpgradeFactory* (*getSocketContextUpgradeFactory)() = reinterpret_cast<SocketContextUpgradeFactory* (*) ()>(
                core::DynamicLoader::dlSym(handle, socketContextUpgradeFactoryFunctionName));
 
            if (getSocketContextUpgradeFactory != nullptr) {
                socketContextUpgradeFactory = getSocketContextUpgradeFactory();
 
                if (socketContextUpgradeFactory != nullptr) {
                    if (add(socketContextUpgradeFactory, handle)) {
                        LOG(TRACE) << "HTTP: SocketContextUpgradeFactory create success: " << socketContextUpgradeName;
                    } else {
                        LOG(TRACE) << "HTTP: SocketContextUpgradeFactory already existing: " << socketContextUpgradeName;
                        delete socketContextUpgradeFactory;
                        socketContextUpgradeFactory = nullptr;
                        core::DynamicLoader::dlClose(handle);
                    }
                } else {
                    LOG(ERROR) << "HTTP: SocketContextUpgradeFactory create failed: " << socketContextUpgradeName;
                    core::DynamicLoader::dlClose(handle);
                }
            } else {
                LOG(ERROR) << "HTTP: Optaining function \"" << socketContextUpgradeFactoryFunctionName
                           << "\" in plugin failed: " << core::DynamicLoader::dlError();
                core::DynamicLoader::dlClose(handle);
            }
        }
 
        return socketContextUpgradeFactory;
    }

◆ select() [1/2]

template<typename SocketContextUpgradeFactory >

SocketContextUpgradeFactory * web::http::SocketContextUpgradeFactorySelector< SocketContextUpgradeFactory >::select ( const std::string & socketContextUpgradeName )

protected

Definition at line 123 of file SocketContextUpgradeFactorySelector.hpp.

                                                                                                                      {
        SocketContextUpgradeFactory* socketContextUpgradeFactory = nullptr;
 
        if (socketContextUpgradePlugins.contains(socketContextUpgradeName)) {
            socketContextUpgradeFactory = socketContextUpgradePlugins[socketContextUpgradeName].socketContextUpgradeFactory;
        } else if (linkedSocketContextUpgradePlugins.contains(socketContextUpgradeName)) {
            socketContextUpgradeFactory = linkedSocketContextUpgradePlugins[socketContextUpgradeName]();
            add(socketContextUpgradeFactory);
        } else if (!onlyLinked) {
            socketContextUpgradeFactory = load(socketContextUpgradeName);
        }
 
        return socketContextUpgradeFactory;
    }

References web::http::SocketContextUpgradeFactorySelector< SocketContextUpgradeFactoryT >::linkedSocketContextUpgradePlugins, web::http::SocketContextUpgradeFactorySelector< SocketContextUpgradeFactoryT >::onlyLinked, and web::http::SocketContextUpgradeFactorySelector< SocketContextUpgradeFactoryT >::socketContextUpgradePlugins.

Referenced by web::http::client::SocketContextUpgradeFactorySelector::select(), web::http::client::SocketContextUpgradeFactorySelector::select(), and web::http::server::SocketContextUpgradeFactorySelector::select().

Here is the caller graph for this function:

◆ select() [2/2]

template<typename SocketContextUpgradeFactoryT >

virtual SocketContextUpgradeFactory * web::http::SocketContextUpgradeFactorySelector< SocketContextUpgradeFactoryT >::select	(	Request &	req,
		Response &	res
	)

pure virtual

Implemented in web::http::client::SocketContextUpgradeFactorySelector, and web::http::server::SocketContextUpgradeFactorySelector.

◆ unload()

template<typename SocketContextUpgradeFactory >

void web::http::SocketContextUpgradeFactorySelector< SocketContextUpgradeFactory >::unload ( SocketContextUpgradeFactory * socketContextUpgradeFactory )

Definition at line 150 of file SocketContextUpgradeFactorySelector.hpp.

                                                                                                                                     {
        std::string upgradeContextNames = socketContextUpgradeFactory->name();
 
        if (socketContextUpgradePlugins.contains(upgradeContextNames)) {
            SocketContextPlugin socketContextPlugin = socketContextUpgradePlugins[upgradeContextNames];
            socketContextUpgradePlugins.erase(upgradeContextNames);
 
            delete socketContextUpgradeFactory;
 
            if (socketContextPlugin.handle != nullptr) {
                core::DynamicLoader::dlCloseDelayed(socketContextPlugin.handle);
            }
        }
    }