ChannelCacheEntry::CRequester Struct Reference

#include "chancache.h"

Inheritance diagram for ChannelCacheEntry::CRequester:

Collaboration diagram for ChannelCacheEntry::CRequester:

Public Member Functions
	CRequester (const ChannelCacheEntry::shared_pointer &p)
virtual	~CRequester ()
virtual std::string	getRequesterName ()
virtual void	channelCreated (const epics::pvData::Status &status, epics::pvAccess::Channel::shared_pointer const &channel)
virtual void	channelStateChange (epics::pvAccess::Channel::shared_pointer const &channel, epics::pvAccess::Channel::ConnectionState connectionState)
Public Member Functions inherited from epics::pvAccess::ChannelRequester
	POINTER_DEFINITIONS (ChannelRequester)
	ChannelRequester ()
virtual	~ChannelRequester ()
virtual void	channelCreated (const epics::pvData::Status &status, Channel::shared_pointer const &channel)=0
virtual void	channelStateChange (Channel::shared_pointer const &channel, Channel::ConnectionState connectionState)=0
virtual std::tr1::shared_ptr< const PeerInfo >	getPeerInfo ()
	Return information on connected peer if applicable. More...
Public Member Functions inherited from epics::pvAccess::Requester
	POINTER_DEFINITIONS (Requester)
virtual	~Requester ()
virtual void	message (std::string const &message, MessageType messageType=errorMessage)

Public Attributes
ChannelCacheEntry::weak_pointer	chan

Static Public Attributes
static size_t	num_instances
Static Public Attributes inherited from epics::pvAccess::ChannelRequester
static size_t	num_instances

Additional Inherited Members
Public Types inherited from epics::pvAccess::ChannelRequester
typedef Channel	operation_type

Detailed Description

Definition at line 134 of file chancache.h.

Constructor & Destructor Documentation

ChannelCacheEntry::CRequester::CRequester

(

const ChannelCacheEntry::shared_pointer &

p

)

Definition at line 46 of file chancache.cpp.

    :chan(p)
{
    epicsAtomicIncrSizeT(&num_instances);
}

ChannelCacheEntry::CRequester::~CRequester ( )

virtual

Definition at line 52 of file chancache.cpp.

{
    epicsAtomicDecrSizeT(&num_instances);
}

Member Function Documentation

void ChannelCacheEntry::CRequester::channelCreated ( const epics::pvData::Status &  status, epics::pvAccess::Channel::shared_pointer const &  channel  )

virtual

Definition at line 59 of file chancache.cpp.

{}

void ChannelCacheEntry::CRequester::channelStateChange ( epics::pvAccess::Channel::shared_pointer const &  channel, epics::pvAccess::Channel::ConnectionState  connectionState  )

virtual

Definition at line 64 of file chancache.cpp.

{
    ChannelCacheEntry::shared_pointer chan(this->chan.lock());
    if(!chan)
        return;

    {
        Guard G(chan->cache->cacheLock);

        assert(chan->channel.get()==channel.get());

        switch(connectionState)
        {
        case pva::Channel::DISCONNECTED:
        case pva::Channel::DESTROYED:
            // Drop from cache
            chan->cache->entries.erase(chan->channelName);
            // keep 'chan' as a reference so that actual destruction doesn't happen which cacheLock is held
            break;
        default:
            break;
        }
    }

    // fanout notification
    ChannelCacheEntry::interested_t::vector_type interested(chan->interested.lock_vector()); // Copy

    FOREACH(ChannelCacheEntry::interested_t::vector_type::const_iterator, it, end, interested)
    {
        GWChannel *chan = it->get();
        pva::ChannelRequester::shared_pointer req(chan->requester.lock());
        if(req)
            req->channelStateChange(*it, connectionState);
    }
}

std::string ChannelCacheEntry::CRequester::getRequesterName ( )

virtual

The requester must have a name.

Returns

The requester's name.

Implements epics::pvAccess::Requester.

Definition at line 39 of file chancache.cpp.

{
    return "GWClient";
}

Member Data Documentation

ChannelCacheEntry::weak_pointer ChannelCacheEntry::CRequester::chan

Definition at line 140 of file chancache.h.

size_t ChannelCacheEntry::CRequester::num_instances

static

Definition at line 136 of file chancache.h.

---

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

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