epics::pvAccess::ServerChannel Class Reference

#include "serverChannelImpl.h"

Collaboration diagram for epics::pvAccess::ServerChannel:

Public Member Functions
	POINTER_DEFINITIONS (ServerChannel)
	ServerChannel (Channel::shared_pointer const &channel, const ChannelRequester::shared_pointer &requester, pvAccessID cid, pvAccessID sid)
	~ServerChannel ()
const Channel::shared_pointer &	getChannel () const
pvAccessID	getCID () const
pvAccessID	getSID () const
void	registerRequest (pvAccessID id, const std::tr1::shared_ptr< BaseChannelRequester > &request)
void	unregisterRequest (pvAccessID id)
void	installGetField (const GetFieldRequester::shared_pointer &gf)
void	completeGetField (GetFieldRequester *req)
std::tr1::shared_ptr< BaseChannelRequester >	getRequest (pvAccessID id)
	may return NULL More...
void	destroy ()
void	printInfo () const
void	printInfo (FILE *fd) const

Static Public Attributes
static size_t	num_instances

Detailed Description

Definition at line 20 of file serverChannelImpl.h.

Constructor & Destructor Documentation

epics::pvAccess::ServerChannel::ServerChannel	(	Channel::shared_pointer const &	channel,
		const ChannelRequester::shared_pointer &	requester,
		pvAccessID	cid,
		pvAccessID	sid
	)

Create server channel for given process variable.

Parameters

channel	local channel.
cid	channel CID.
sid	channel SID.
css	channel security session.

Definition at line 19 of file serverChannelImpl.cpp.

                                                            :
    _channel(channel),
    _requester(requester),
    _cid(cid),
    _sid(sid),
    _destroyed(false)
{
    REFTRACE_INCREMENT(num_instances);
    if (!channel.get())
    {
        THROW_BASE_EXCEPTION("non-null channel required");
    }
}

epics::pvAccess::ServerChannel::~ServerChannel

(

)

Definition at line 93 of file serverChannelImpl.cpp.

{
    destroy();
    REFTRACE_DECREMENT(num_instances);
}

Member Function Documentation

void epics::pvAccess::ServerChannel::completeGetField

(

GetFieldRequester *

req

)

Definition at line 123 of file serverChannelImpl.cpp.

{
    GetFieldRequester::shared_pointer prev;
    {
        epicsGuard<epicsMutex> G(_mutex);
        if(_active_requester.get()==req)
            prev.swap(_active_requester);
    }
}

void epics::pvAccess::ServerChannel::destroy

(

)

Definition at line 63 of file serverChannelImpl.cpp.

{
    _requests_t reqs;
    {
        Lock guard(_mutex);

        if (_destroyed) return;
        _destroyed = true;

        // destroy all requests
        // take ownership of _requests locally to prevent
        // removal via unregisterRequest() during iteration
        _requests.swap(reqs);

        // ... and the channel
        // TODO try catch
        _channel->destroy();
    }
    // unlock our before destroy.
    // our mutex is subordinate to operation mutex

    for(_requests_t::const_iterator it=reqs.begin(), end=reqs.end(); it!=end; ++it)
    {
        const _requests_t::mapped_type& req = it->second;
        // will call unregisterRequest() which is now a no-op
        req->destroy();
        // May still be in the send queue
    }
}

const Channel::shared_pointer& epics::pvAccess::ServerChannel::getChannel ( ) const

inline

Definition at line 39 of file serverChannelImpl.h.

{ return _channel; }

pvAccessID epics::pvAccess::ServerChannel::getCID ( ) const

inline

Definition at line 41 of file serverChannelImpl.h.

{ return _cid; }

std::tr1::shared_ptr< BaseChannelRequester > epics::pvAccess::ServerChannel::getRequest

(

pvAccessID

id

)

may return NULL

Definition at line 52 of file serverChannelImpl.cpp.

{
    Lock guard(_mutex);
    _requests_t::iterator iter = _requests.find(id);
    if(iter != _requests.end())
    {
        return iter->second;
    }
    return BaseChannelRequester::shared_pointer();
}

pvAccessID epics::pvAccess::ServerChannel::getSID ( ) const

inline

Definition at line 43 of file serverChannelImpl.h.

{ return _sid; }

void epics::pvAccess::ServerChannel::installGetField

(

const GetFieldRequester::shared_pointer &

gf

)

Definition at line 110 of file serverChannelImpl.cpp.

{
    GetFieldRequester::shared_pointer prev;
    {
        epicsGuard<epicsMutex> G(_mutex);
        prev.swap(_active_requester);
        _active_requester = gf;
    }
    if(prev) {
        prev->getDone(Status::error("Aborted"), FieldConstPtr());
    }
}

epics::pvAccess::ServerChannel::POINTER_DEFINITIONS

(

ServerChannel

)

void epics::pvAccess::ServerChannel::printInfo

(

)

const

Definition at line 99 of file serverChannelImpl.cpp.

{
    printInfo(stdout);
}

void epics::pvAccess::ServerChannel::printInfo

(

FILE *

fd

)

const

Definition at line 104 of file serverChannelImpl.cpp.

{
    fprintf(fd,"CLASS        : %s\n", typeid(*this).name());
    fprintf(fd,"CHANNEL      : %s\n", typeid(*_channel).name());
}

void epics::pvAccess::ServerChannel::registerRequest	(	pvAccessID	id,
		const std::tr1::shared_ptr< BaseChannelRequester > &	request
	)

Definition at line 35 of file serverChannelImpl.cpp.

{
    Lock guard(_mutex);
    if(_destroyed) throw std::logic_error("Can't registerRequest() for destory'd server channel");
    _requests[id] = request;
}

void epics::pvAccess::ServerChannel::unregisterRequest

(

pvAccessID

id

)

Definition at line 42 of file serverChannelImpl.cpp.

{
    Lock guard(_mutex);
    _requests_t::iterator iter = _requests.find(id);
    if(iter != _requests.end())
    {
        _requests.erase(iter);
    }
}

Member Data Documentation

size_t epics::pvAccess::ServerChannel::num_instances

static

Definition at line 25 of file serverChannelImpl.h.

---

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

• modules/pvAccess/src/server/pv/serverChannelImpl.h
• modules/pvAccess/src/server/serverChannelImpl.cpp