GWServerChannelProvider Struct Reference

#include "server.h"

Inheritance diagram for GWServerChannelProvider:

Collaboration diagram for GWServerChannelProvider:

Public Member Functions
	POINTER_DEFINITIONS (GWServerChannelProvider)
virtual std::tr1::shared_ptr< ChannelProvider >	getChannelProvider ()
virtual void	cancel ()
virtual std::string	getProviderName ()
virtual epics::pvAccess::ChannelFind::shared_pointer	channelFind (std::string const &channelName, epics::pvAccess::ChannelFindRequester::shared_pointer const &channelFindRequester)
virtual epics::pvAccess::Channel::shared_pointer	createChannel (std::string const &channelName, epics::pvAccess::ChannelRequester::shared_pointer const &channelRequester, short priority, std::string const &addressx)
virtual void	destroy ()
	GWServerChannelProvider (const epics::pvAccess::ChannelProvider::shared_pointer &prov)
virtual	~GWServerChannelProvider ()
Public Member Functions inherited from epics::pvAccess::ChannelProvider
	POINTER_DEFINITIONS (ChannelProvider)
	ChannelProvider ()
virtual	~ChannelProvider ()
virtual ChannelFind::shared_pointer	channelFind (std::string const &name, ChannelFindRequester::shared_pointer const &requester)=0
virtual ChannelFind::shared_pointer	channelList (ChannelListRequester::shared_pointer const &requester)
virtual Channel::shared_pointer	createChannel (std::string const &name, ChannelRequester::shared_pointer const &requester=DefaultChannelRequester::build(), short priority=PRIORITY_DEFAULT)
virtual Channel::shared_pointer	createChannel (std::string const &name, ChannelRequester::shared_pointer const &requester, short priority, std::string const &address)=0
Public Member Functions inherited from epics::pvAccess::Destroyable
	POINTER_DEFINITIONS (Destroyable)
Public Member Functions inherited from epics::pvAccess::ChannelFind
	POINTER_DEFINITIONS (ChannelFind)
	ChannelFind ()
virtual	~ChannelFind ()

Public Attributes
ChannelCache	cache

Additional Inherited Members
Public Types inherited from epics::pvAccess::ChannelFind
typedef ChannelFindRequester	requester_type
Static Public Member Functions inherited from epics::pvAccess::ChannelFind
static ChannelFind::shared_pointer	buildDummy (const std::tr1::shared_ptr< ChannelProvider > &provider)
Static Public Attributes inherited from epics::pvAccess::ChannelProvider
static const short	PRIORITY_MIN = 0
static const short	PRIORITY_MAX = 99
static const short	PRIORITY_DEFAULT = PRIORITY_MIN
static const short	PRIORITY_LINKS_DB = PRIORITY_MAX
static const short	PRIORITY_ARCHIVE = (PRIORITY_MAX + PRIORITY_MIN) / 2
static const short	PRIORITY_OPI = PRIORITY_MIN
static size_t	num_instances
Protected Member Functions inherited from epics::pvAccess::Destroyable
virtual	~Destroyable ()

Detailed Description

Definition at line 11 of file server.h.

Constructor & Destructor Documentation

GWServerChannelProvider::GWServerChannelProvider ( const epics::pvAccess::ChannelProvider::shared_pointer &  prov )

explicit

Definition at line 96 of file server.cpp.

    :cache(prov)
{}

GWServerChannelProvider::~GWServerChannelProvider ( )

virtual

Definition at line 100 of file server.cpp.

{}

Member Function Documentation

virtual void GWServerChannelProvider::cancel ( )

inlinevirtual

Implements epics::pvAccess::ChannelFind.

Definition at line 21 of file server.h.

{}

pva::ChannelFind::shared_pointer GWServerChannelProvider::channelFind ( std::string const &  channelName, epics::pvAccess::ChannelFindRequester::shared_pointer const &  channelFindRequester  )

virtual

Definition at line 36 of file server.cpp.

{
    pva::ChannelFind::shared_pointer ret;
    bool found = false;

    if(!channelName.empty())
    {
        LOG(pva::logLevelDebug, "Searching for '%s'", channelName.c_str());
        ChannelCacheEntry::shared_pointer ent(cache.lookup(channelName));
        if(ent) {
            found = true;
            ret = shared_from_this();
        }
    }

    // unlock for callback

    channelFindRequester->channelFindResult(pvd::Status::Ok, ret, found);

    return ret;
}

pva::Channel::shared_pointer GWServerChannelProvider::createChannel ( std::string const &  channelName, epics::pvAccess::ChannelRequester::shared_pointer const &  channelRequester, short  priority, std::string const &  addressx  )

virtual

Definition at line 62 of file server.cpp.

{
    GWChannel::shared_pointer ret;
    std::string address = channelRequester->getRequesterName();

    if(!channelName.empty())
    {
        Guard G(cache.cacheLock);

        ChannelCacheEntry::shared_pointer ent(cache.lookup(channelName)); // recursively locks cacheLock

        if(ent)
        {
            ret.reset(new GWChannel(ent, shared_from_this(), channelRequester, address));
            ent->interested.insert(ret);
            ret->weakref = ret;
        }
    }

    if(!ret) {
        pvd::Status S(pvd::Status::STATUSTYPE_ERROR, "Not found");
        channelRequester->channelCreated(S, ret);
    } else {
        channelRequester->channelCreated(pvd::Status::Ok, ret);
        channelRequester->channelStateChange(ret, pva::Channel::CONNECTED);
    }

    return ret; // ignored by caller
}

void GWServerChannelProvider::destroy ( )

virtual

Destroy this instance.

Implements epics::pvAccess::Destroyable.

Definition at line 94 of file server.cpp.

{}

std::tr1::shared_ptr< pva::ChannelProvider > GWServerChannelProvider::getChannelProvider ( )

virtual

Implements epics::pvAccess::ChannelFind.

Definition at line 28 of file server.cpp.

{
    return shared_from_this();
}

virtual std::string GWServerChannelProvider::getProviderName ( )

inlinevirtual

Get the provider name.

Returns

The name.

Implements epics::pvAccess::ChannelProvider.

Definition at line 23 of file server.h.

                                        {
        return "GWServer";
    }

GWServerChannelProvider::POINTER_DEFINITIONS

(

GWServerChannelProvider

)

Member Data Documentation

ChannelCache GWServerChannelProvider::cache

Definition at line 17 of file server.h.

---

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

• modules/pva2pva/p2pApp/server.h
• modules/pva2pva/p2pApp/server.cpp