transportRegistry.h

#ifndef TRANSPORTREGISTRY_H
#define TRANSPORTREGISTRY_H

#include <map>
#include <vector>
#include <list>
#include <iostream>

#ifdef epicsExportSharedSymbols
#   define transportRegistryEpicsExportSharedSymbols
#   undef epicsExportSharedSymbols
#endif

#include <osiSock.h>

#include <pv/lock.h>
#include <pv/pvType.h>
#include <pv/epicsException.h>
#include <pv/sharedPtr.h>

#ifdef transportRegistryEpicsExportSharedSymbols
#   define epicsExportSharedSymbols
#       undef transportRegistryEpicsExportSharedSymbols
#endif

#include <pv/remote.h>
#include <pv/inetAddressUtil.h>

namespace epics {
namespace pvAccess {

class TransportRegistry {
public:
    class Reservation;
private:
    struct Key {
        osiSockAddr addr;
        epics::pvData::int16 prio;
        Key(const osiSockAddr& a, epics::pvData::int16 p) :addr(a), prio(p) {}
        bool operator<(const Key& o) const;
    };

    typedef std::map<Key, Transport::shared_pointer> transports_t;
    typedef std::map<Key, std::tr1::shared_ptr<epics::pvData::Mutex> > locks_t;

public:
    POINTER_DEFINITIONS(TransportRegistry);

    typedef std::vector<Transport::shared_pointer> transportVector_t;

    class Reservation {
        TransportRegistry* const owner;
        const Key key;
        std::tr1::shared_ptr<epics::pvData::Mutex> mutex;
    public:

        // ctor blocks until no concurrent connect() in progress (success or failure)
        Reservation(TransportRegistry *owner, const osiSockAddr& address, epics::pvData::int16 prio);
        ~Reservation();
    };

    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();

    // optimized to avoid reallocation, adds to array
    void toArray(transportVector_t & transportArray, const osiSockAddr *dest=0);

private:
    transports_t transports;
    // per destination mutex to serialize concurrent connect() attempts
    locks_t locks;

    epics::pvData::Mutex _mutex;
};

}
}

#endif  /* INTROSPECTIONREGISTRY_H */