pvac::ClientChannel::Impl Struct Reference

Inheritance diagram for pvac::ClientChannel::Impl:

Collaboration diagram for pvac::ClientChannel::Impl:

Public Types
typedef std::vector< ClientChannel::ConnectCallback * >	listeners_t
Public Types inherited from epics::pvAccess::ChannelRequester
typedef Channel	operation_type

Public Member Functions
	Impl ()
virtual	~Impl ()
void	cancel ()
virtual std::string	getRequesterName () OVERRIDE FINAL
virtual void	channelCreated (const pvd::Status &status, pva::Channel::shared_pointer const &channel) OVERRIDE FINAL
virtual void	channelStateChange (pva::Channel::shared_pointer const &channel, pva::Channel::ConnectionState connectionState) OVERRIDE FINAL
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 Member Functions inherited from pvac::detail::wrapped_shared_from_this< ClientChannel::Impl >
std::tr1::shared_ptr< ClientChannel::Impl >	internal_shared_from_this ()

Public Attributes
epicsMutex	mutex
pva::Channel::shared_pointer	channel
listeners_t	listeners
bool	listeners_inprogress
epicsEvent	listeners_done

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

Additional Inherited Members
Static Public Member Functions inherited from pvac::detail::wrapped_shared_from_this< ClientChannel::Impl >
static std::tr1::shared_ptr< ClientChannel::Impl >	build ()
static std::tr1::shared_ptr< ClientChannel::Impl >	build (A a)
static std::tr1::shared_ptr< ClientChannel::Impl >	build (A a, B b)

Detailed Description

Definition at line 36 of file client.cpp.

Member Typedef Documentation

typedef std::vector<ClientChannel::ConnectCallback*> pvac::ClientChannel::Impl::listeners_t

Definition at line 42 of file client.cpp.

Constructor & Destructor Documentation

pvac::ClientChannel::Impl::Impl ( )

inline

Definition at line 49 of file client.cpp.

:listeners_inprogress(false) {REFTRACE_INCREMENT(num_instances);}

virtual pvac::ClientChannel::Impl::~Impl ( )

inlinevirtual

Definition at line 50 of file client.cpp.

{REFTRACE_DECREMENT(num_instances);}

Member Function Documentation

void pvac::ClientChannel::Impl::cancel ( )

inline

Definition at line 53 of file client.cpp.

    {
        // ClientChannel destroy implicitly removes all callbacks,
        // but doesn't destroy the Channel or cancel Operations
        Guard G(mutex);
        while(listeners_inprogress) {
            UnGuard U(G);
            listeners_done.wait();
        }
        listeners.clear();
    }

virtual void pvac::ClientChannel::Impl::channelCreated ( const pvd::Status &  status, pva::Channel::shared_pointer const &  channel  )

inlinevirtual

Definition at line 67 of file client.cpp.

{}

virtual void pvac::ClientChannel::Impl::channelStateChange ( pva::Channel::shared_pointer const &  channel, pva::Channel::ConnectionState  connectionState  )

inlinevirtual

Definition at line 69 of file client.cpp.

    {
        listeners_t notify;
        {
            Guard G(mutex);
            notify = listeners; // copy vector
            listeners_inprogress = true;
        }
        try {
            ConnectEvent evt;
            evt.connected = connectionState==pva::Channel::CONNECTED;
            if(evt.connected)
                evt.peerName = channel->getRemoteAddress();
            for(listeners_t::const_iterator it=notify.begin(), end=notify.end(); it!=end; ++it)
            {
                try {
                    (*it)->connectEvent(evt);
                }catch(std::exception& e){
                    LOG(pva::logLevelError, "Unhandled exception in connection state listener: %s\n", e.what());

                    Guard G(mutex);
                    for(listeners_t::iterator it2=listeners.begin(), end2=listeners.end(); it2!=end2; ++it2) {
                        if(*it==*it2) {
                            listeners.erase(it2);
                            break;
                        }
                    }
                }
            }
        }catch(...){
            {
                Guard G(mutex);
                listeners_inprogress = false;
            }
            listeners_done.signal();
        }
        {
            Guard G(mutex);
            listeners_inprogress = false;
        }
        listeners_done.signal();
    }

virtual std::string pvac::ClientChannel::Impl::getRequesterName ( )

inlinevirtual

The requester must have a name.

Returns

The requester's name.

Implements epics::pvAccess::Requester.

Definition at line 65 of file client.cpp.

{ return "ClientChannel::Impl"; }

Member Data Documentation

pva::Channel::shared_pointer pvac::ClientChannel::Impl::channel

Definition at line 40 of file client.cpp.

listeners_t pvac::ClientChannel::Impl::listeners

Definition at line 43 of file client.cpp.

epicsEvent pvac::ClientChannel::Impl::listeners_done

Definition at line 45 of file client.cpp.

bool pvac::ClientChannel::Impl::listeners_inprogress

Definition at line 44 of file client.cpp.

epicsMutex pvac::ClientChannel::Impl::mutex

Definition at line 39 of file client.cpp.

size_t pvac::ClientChannel::Impl::num_instances

static

Definition at line 47 of file client.cpp.

---

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

• modules/pvAccess/src/client/client.cpp