#include "utilities.h"

Inheritance diagram for TestProvider:

Collaboration diagram for TestProvider:

Public Types
typedef weak_value_map< std::string, TestPV >	pvs_t

Public Member Functions
	POINTER_DEFINITIONS (TestProvider)

virtual std::string	getProviderName ()

virtual void	destroy ()

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

virtual epics::pvAccess::ChannelFind::shared_pointer	channelList (epics::pvAccess::ChannelListRequester::shared_pointer const &channelListRequester)

virtual epics::pvAccess::Channel::shared_pointer	createChannel (std::string const &channelName, epics::pvAccess::ChannelRequester::shared_pointer const &channelRequester, short priority=PRIORITY_DEFAULT)

virtual epics::pvAccess::Channel::shared_pointer	createChannel (std::string const &channelName, epics::pvAccess::ChannelRequester::shared_pointer const &channelRequester, short priority, std::string const &address)

	TestProvider ()

virtual	~TestProvider ()

TestPV::shared_pointer	addPV (const std::string &name, const epics::pvData::StructureConstPtr &tdef)

void	dispatch ()

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)

Static Public Member Functions
static void	testCounts ()

Public Attributes
epicsMutex	lock

pvs_t	pvs

Additional Inherited Members
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 269 of file utilities.h.

Member Typedef Documentation

typedef weak_value_map<std::string, TestPV> TestProvider::pvs_t

Definition at line 293 of file utilities.h.

Constructor & Destructor Documentation

TestProvider::TestProvider ( )

Definition at line 500 of file utilities.cpp.

 {
     epicsAtomicIncrSizeT(&countTestProvider);
 }

TestProvider::~TestProvider ( )

virtual

Definition at line 505 of file utilities.cpp.

 {
     epicsAtomicDecrSizeT(&countTestProvider);
 }

Member Function Documentation

TestPV::shared_pointer TestProvider::addPV	(	const std::string &	name,
		const epics::pvData::StructureConstPtr &	tdef
	)

Definition at line 573 of file utilities.cpp.

 {
     Guard G(lock);
     TestPV::shared_pointer ret(new TestPV(name, shared_from_this(), tdef));
     pvs.insert(name, ret);
     return ret;
 }

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

virtual

Definition at line 528 of file utilities.cpp.

 {
     pva::ChannelFind::shared_pointer ret;
     requester->channelFindResult(pvd::Status(pvd::Status::STATUSTYPE_FATAL, "Not implemented"),
                                  ret, false);
     return ret;
 }

pva::ChannelFind::shared_pointer TestProvider::channelList ( epics::pvAccess::ChannelListRequester::shared_pointer const & channelListRequester )

virtual

Definition at line 516 of file utilities.cpp.

 {
     pva::ChannelFind::shared_pointer ret;
     pvd::PVStringArray::const_svector names;
     requester->channelListResult(pvd::Status(pvd::Status::STATUSTYPE_FATAL, "Not implemented"),
                                  ret,
                                  names,
                                  true);
     return ret;
 }

virtual epics::pvAccess::Channel::shared_pointer TestProvider::createChannel	(	std::string const &	channelName,
		epics::pvAccess::ChannelRequester::shared_pointer const &	channelRequester,
		short	priority = `PRIORITY_DEFAULT`
	)

virtual

virtual epics::pvAccess::Channel::shared_pointer TestProvider::createChannel	(	std::string const &	channelName,
		epics::pvAccess::ChannelRequester::shared_pointer const &	channelRequester,
		short	priority,
		std::string const &	address
	)

virtual

void TestProvider::destroy ( )

virtual

Destroy this instance.

Implements epics::pvAccess::Destroyable.

Definition at line 510 of file utilities.cpp.

 {
     // TODO: disconnect all?
 }

void TestProvider::dispatch ( )

Definition at line 581 of file utilities.cpp.

 {
     Guard G(lock);
     testDiag("TestProvider::dispatch");
 
     pvs_t::lock_vector_type allpvs(pvs.lock_vector());
     FOREACH(pvs_t::lock_vector_type::const_iterator, pvit, pvend, allpvs)
     {
         TestPV *pv = pvit->second.get();
         TestPV::channels_t::vector_type channels(pv->channels.lock_vector());
 
         FOREACH(TestPV::channels_t::vector_type::const_iterator, chit, chend, channels)
         {
             TestPVChannel *chan = chit->get();
             TestPVChannel::monitors_t::vector_type monitors(chan->monitors.lock_vector());
 
             if(!chan->isConnected())
                 continue;
 
             FOREACH(TestPVChannel::monitors_t::vector_type::const_iterator, monit, monend, monitors)
             {
                 TestPVMonitor *mon = monit->get();
 
                 if(mon->finalize || !mon->running)
                     continue;
 
                 if(mon->needWakeup) {
                     testDiag("  wakeup monitor %p", mon);
                     mon->needWakeup = false;
                     pva::MonitorRequester::shared_pointer req(mon->requester.lock());
                     UnGuard U(G);
                     if(req)
                         req->monitorEvent(*monit);
                 }
             }
         }
     }
 }

virtual std::string TestProvider::getProviderName ( )

inlinevirtual

Get the provider name.

Returns: The name.

Implements epics::pvAccess::ChannelProvider.

Definition at line 273 of file utilities.h.

273 { return "TestProvider"; }

TestProvider::POINTER_DEFINITIONS ( TestProvider )

void TestProvider::testCounts ( )

static

Definition at line 620 of file utilities.cpp.

 {
     int ok = 1;
     size_t temp;
 #define TESTC(name) temp=epicsAtomicGetSizeT(&count##name); ok &= temp==0; testDiag("num. live "  #name " %u", (unsigned)temp)
     TESTC(TestChannelMonitorRequester);
     TESTC(TestChannelRequester);
     TESTC(TestProvider);
     TESTC(TestPV);
     TESTC(TestPVChannel);
     TESTC(TestPVMonitor);
 #undef TESTC
     testOk(ok, "All instances free'd");
 }

Member Data Documentation

epicsMutex TestProvider::lock

mutable

Definition at line 292 of file utilities.h.

pvs_t TestProvider::pvs

Definition at line 294 of file utilities.h.

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

modules/pva2pva/common/utilities.h
modules/pva2pva/common/utilities.cpp

Public Types

Public Member Functions

Static Public Member Functions

Public Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation