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)
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 154 of file chancache.h.

Member Typedef Documentation

entries_t

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

Definition at line 156 of file chancache.h.

Constructor & Destructor Documentation

ChannelCache()

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::~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

lookup()

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

cacheLock

epicsMutex ChannelCache::cacheLock

Definition at line 159 of file chancache.h.

cleaner

cacheClean* ChannelCache::cleaner

Definition at line 168 of file chancache.h.

cleanerDust

size_t ChannelCache::cleanerDust

Definition at line 170 of file chancache.h.

cleanerRuns

size_t ChannelCache::cleanerRuns

Definition at line 169 of file chancache.h.

cleanTimer

epicsTimer* ChannelCache::cleanTimer

Definition at line 166 of file chancache.h.

entries

entries_t ChannelCache::entries

Definition at line 161 of file chancache.h.

provider

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

Definition at line 163 of file chancache.h.

timerQueue

epicsTimerQueueActive* ChannelCache::timerQueue

Definition at line 165 of file chancache.h.

---

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

• p2pApp/chancache.h
• p2pApp/chancache.cpp