ChannelCache Struct Reference

#include "chancache.h"

Collaboration diagram for ChannelCache:

Classes
struct	cacheClean

Public Types
typedef std::map< std::string, ChannelCacheEntry::shared_pointer >	entries_t

Public Member Functions
	ChannelCache (const epics::pvAccess::ChannelProvider::shared_pointer &prov)
	~ChannelCache ()
ChannelCacheEntry::shared_pointer	lookup (const std::string &name)

Public Attributes
epicsMutex	cacheLock
entries_t	entries
epics::pvAccess::ChannelProvider::shared_pointer	provider
epicsTimerQueueActive *	timerQueue
epicsTimer *	cleanTimer
cacheClean *	cleaner
size_t	cleanerRuns
size_t	cleanerDust

Detailed Description

Holds the set of channels the GW is searching for, or has found.

Definition at line 153 of file chancache.h.

Member Typedef Documentation

typedef std::map<std::string, ChannelCacheEntry::shared_pointer > ChannelCache::entries_t

Definition at line 155 of file chancache.h.

Constructor & Destructor Documentation

ChannelCache::ChannelCache

(

const epics::pvAccess::ChannelProvider::shared_pointer &

prov

)

Definition at line 136 of file chancache.cpp.

    :provider(prov)
    ,timerQueue(&epicsTimerQueueActive::allocate(1, epicsThreadPriorityCAServerLow-2))
    ,cleaner(new cacheClean(this))
    ,cleanerRuns(0)
    ,cleanerDust(0)
{
    if(!provider)
        throw std::logic_error("Missing 'pva' provider");
    assert(timerQueue);
    cleanTimer = &timerQueue->createTimer();
    cleanTimer->start(*cleaner, 30.0);
}

ChannelCache::~ChannelCache

(

)

Definition at line 150 of file chancache.cpp.

{
    entries_t E;
    {
        Guard G(cacheLock);

        cleanTimer->destroy();
        timerQueue->release();
        delete cleaner;

        entries_t E;
        E.swap(entries);
    }
}

Member Function Documentation

ChannelCacheEntry::shared_pointer ChannelCache::lookup

(

const std::string &

name

)

Definition at line 166 of file chancache.cpp.

{
    ChannelCacheEntry::shared_pointer ret;

    Guard G(cacheLock);

    entries_t::const_iterator it = entries.find(newName);

    if(it==entries.end()) {
        // first request, create ChannelCacheEntry
        //TODO: async lookup

        ChannelCacheEntry::shared_pointer ent(new ChannelCacheEntry(this, newName));
        ent->requester.reset(new ChannelCacheEntry::CRequester(ent));

        entries[newName] = ent;

        pva::Channel::shared_pointer M;
        {
            // unlock to call createChannel()
            epicsGuardRelease<epicsMutex> U(G);

            M = provider->createChannel(newName, ent->requester);
            if(!M)
                THROW_EXCEPTION2(std::runtime_error, "Failed to createChannel");
        }
        ent->channel = M;

        if(M->isConnected())
            ret = ent; // immediate connect, mostly for unit-tests (thus delayed connect not covered)

    } else if(it->second->channel && it->second->channel->isConnected()) {
        // another request, and hey we're connected this time

        ret = it->second;
        it->second->dropPoke = true;

    } else {
        // not connected yet, but a client is still interested
        it->second->dropPoke = true;
    }

    return ret;
}

Member Data Documentation

epicsMutex ChannelCache::cacheLock

Definition at line 158 of file chancache.h.

cacheClean* ChannelCache::cleaner

Definition at line 166 of file chancache.h.

size_t ChannelCache::cleanerDust

Definition at line 169 of file chancache.h.

size_t ChannelCache::cleanerRuns

Definition at line 168 of file chancache.h.

epicsTimer* ChannelCache::cleanTimer

Definition at line 165 of file chancache.h.

entries_t ChannelCache::entries

Definition at line 160 of file chancache.h.

epics::pvAccess::ChannelProvider::shared_pointer ChannelCache::provider

Definition at line 162 of file chancache.h.

epicsTimerQueueActive* ChannelCache::timerQueue

Definition at line 164 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