epics::pvAccess::ca::ChannelConnectThread Class Reference

#include "channelConnectThread.h"

Inheritance diagram for epics::pvAccess::ca::ChannelConnectThread:

Collaboration diagram for epics::pvAccess::ca::ChannelConnectThread:

Public Member Functions
	~ChannelConnectThread ()
virtual void	run ()
void	start ()
void	stop ()
void	channelConnected (NotifyChannelRequesterPtr const &notifyChannelRequester)

Static Public Member Functions
static ChannelConnectThreadPtr	get ()

Detailed Description

Definition at line 47 of file channelConnectThread.h.

Constructor & Destructor Documentation

epics::pvAccess::ca::ChannelConnectThread::~ChannelConnectThread

(

)

Definition at line 40 of file channelConnectThread.cpp.

{
//std::cout << "ChannelConnectThread::~ChannelConnectThread()\n";
}

Member Function Documentation

void epics::pvAccess::ca::ChannelConnectThread::channelConnected

(

NotifyChannelRequesterPtr const &

notifyChannelRequester

)

Definition at line 67 of file channelConnectThread.cpp.

{
    {
        Lock lock(mutex);
        if(notifyChannelRequester->isOnQueue) return;
        notifyChannelRequester->isOnQueue = true;
        notifyChannelQueue.push(notifyChannelRequester);
    }
    waitForCommand.signal();
}

ChannelConnectThreadPtr epics::pvAccess::ca::ChannelConnectThread::get ( )

static

Definition at line 23 of file channelConnectThread.cpp.

{
    static  ChannelConnectThreadPtr master;
    static Mutex mutex;
    Lock xx(mutex);
    if(!master) {
        master = ChannelConnectThreadPtr(new ChannelConnectThread());
        master->start();
    }
    return master;
}

void epics::pvAccess::ca::ChannelConnectThread::run ( )

virtual

Definition at line 79 of file channelConnectThread.cpp.

{
    while(true)
    {
         waitForCommand.wait();
         while(true) {
             bool more = false;
             NotifyChannelRequester* notifyChannelRequester(NULL);
             {
                 Lock lock(mutex);
                 if(!notifyChannelQueue.empty())
                 {
                      more = true;
                      NotifyChannelRequesterWPtr req(notifyChannelQueue.front());
                      notifyChannelQueue.pop();
                      NotifyChannelRequesterPtr reqPtr(req.lock());
                      if(reqPtr) {
                         notifyChannelRequester = reqPtr.get();
                         reqPtr->isOnQueue = false;
                      }
                 }
             }
             if(!more) break;
             if(notifyChannelRequester!=NULL)
             {
                 CAChannelPtr channel(notifyChannelRequester->channel.lock());
                 if(channel) channel->notifyClient();
             }
         }
         if(isStop) {
             waitForStop.signal();
             break;
         }
    }
}

void epics::pvAccess::ca::ChannelConnectThread::start

(

)

Definition at line 46 of file channelConnectThread.cpp.

{
    thread =  std::tr1::shared_ptr<epicsThread>(new epicsThread(
        *this,
        "channelConnectThread",
        epicsThreadGetStackSize(epicsThreadStackSmall),
        epicsThreadPriorityLow));
    thread->start();
}

void epics::pvAccess::ca::ChannelConnectThread::stop

(

)

Definition at line 57 of file channelConnectThread.cpp.

{
    {
        Lock xx(mutex);
        isStop = true;
    }
    waitForCommand.signal();
    waitForStop.wait();
}

---

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

• modules/pvAccess/src/ca/channelConnectThread.h
• modules/pvAccess/src/ca/channelConnectThread.cpp