epics::pvAccess::TransportRegistry Class Reference

#include "transportRegistry.h"

Classes
class	Reservation

Public Types
typedef std::vector< Transport::shared_pointer >	transportVector_t

Public Member Functions
	POINTER_DEFINITIONS (TransportRegistry)
	TransportRegistry ()
	~TransportRegistry ()
Transport::shared_pointer	get (const osiSockAddr &address, epics::pvData::int16 prio)
void	install (const Transport::shared_pointer &ptr)
Transport::shared_pointer	remove (Transport::shared_pointer const &transport)
void	clear ()
size_t	size ()
void	toArray (transportVector_t &transportArray, const osiSockAddr *dest=0)

Detailed Description

Definition at line 38 of file transportRegistry.h.

Member Typedef Documentation

typedef std::vector<Transport::shared_pointer> epics::pvAccess::TransportRegistry::transportVector_t

Definition at line 55 of file transportRegistry.h.

Constructor & Destructor Documentation

epics::pvAccess::TransportRegistry::TransportRegistry ( )

inline

Definition at line 68 of file transportRegistry.h.

{}

epics::pvAccess::TransportRegistry::~TransportRegistry

(

)

Definition at line 71 of file transportRegistry.cpp.

{
    pvd::Lock G(_mutex);
    if(!transports.empty())
        LOG(logLevelWarn, "TransportRegistry destroyed while not empty");
}

Member Function Documentation

void epics::pvAccess::TransportRegistry::clear

(

)

Definition at line 119 of file transportRegistry.cpp.

{
    transports_t temp;
    {
        pvd::Lock guard(_mutex);
        transports.swap(temp);
    }

    if(temp.empty())
        return;

    LOG(logLevelDebug, "Context still has %zu transport(s) active and closing...", temp.size());

    for(transports_t::iterator it(temp.begin()), end(temp.end());
        it != end; ++it)
    {
        it->second->close();
    }

    for(transports_t::iterator it(temp.begin()), end(temp.end());
        it != end; ++it)
    {
        const Transport::shared_pointer& transport = it->second;
        transport->waitJoin();
        LEAK_CHECK(transport, "tcp transport")
        if(!transport.unique()) {
            LOG(logLevelError, "Closed transport %s still has use_count=%u",
                transport->getRemoteName().c_str(),
                (unsigned)transport.use_count());
        }
    }
}

Transport::shared_pointer epics::pvAccess::TransportRegistry::get	(	const osiSockAddr &	address,
		epics::pvData::int16	prio
	)

Definition at line 78 of file transportRegistry.cpp.

{
    const Key key(address, prio);

    pvd::Lock G(_mutex);

    transports_t::iterator it(transports.find(key));
    if(it!=transports.end()) {
        return it->second;
    }
    return Transport::shared_pointer();
}

void epics::pvAccess::TransportRegistry::install

(

const Transport::shared_pointer &

ptr

)

Definition at line 91 of file transportRegistry.cpp.

{
    const Key key(ptr->getRemoteAddress(), ptr->getPriority());

    pvd::Lock G(_mutex);

    std::pair<transports_t::iterator, bool> itpair(transports.insert(std::make_pair(key, ptr)));
    if(!itpair.second)
        THROW_EXCEPTION2(std::logic_error, "Refuse to insert dup");
}

epics::pvAccess::TransportRegistry::POINTER_DEFINITIONS

(

TransportRegistry

)

Transport::shared_pointer epics::pvAccess::TransportRegistry::remove

(

Transport::shared_pointer const &

transport

)

Definition at line 102 of file transportRegistry.cpp.

{
    assert(!!transport);
    const Key key(transport->getRemoteAddress(), transport->getPriority());
    Transport::shared_pointer ret;

    pvd::Lock guard(_mutex);
    transports_t::iterator it(transports.find(key));
    if(it!=transports.end()) {
        ret.swap(it->second);
        transports.erase(it);
    }
    return ret;
}

size_t epics::pvAccess::TransportRegistry::size

(

)

Definition at line 152 of file transportRegistry.cpp.

{
    pvd::Lock guard(_mutex);
    return transports.size();
}

void epics::pvAccess::TransportRegistry::toArray	(	transportVector_t &	transportArray,
		const osiSockAddr *	dest = 0
	)

Definition at line 158 of file transportRegistry.cpp.

{
    pvd::Lock guard(_mutex);

    transportArray.reserve(transportArray.size() + transports.size());

    for(transports_t::const_iterator it(transports.begin()), end(transports.end());
        it != end; ++it)
    {
        const Key& key = it->first;
        const Transport::shared_pointer& tr = it->second;

        if(!dest || sockAddrAreIdentical(dest, &key.addr))
            transportArray.push_back(tr);
    }
}

---

The documentation for this class was generated from the following files:

• modules/pvAccess/src/remote/pv/transportRegistry.h
• modules/pvAccess/src/remote/transportRegistry.cpp