AioSignalHandlerThread Class Reference

Inheritance diagram for AioSignalHandlerThread:

List of all members.

Public Member Functions
	AioSignalHandlerThread (AioSignalScheduler &schedulerInit)
virtual void	run ()
virtual void	start ()
	Spawns the OS thread.
void	join ()
	Waits for the OS thread to terminate.
bool	isStarted () const
	Returns: true if start has been called (and subsequent join has not completed)
bool	isStopped () const
	Returns: opposite of isStarted()
boost::thread &	getBoostThread ()
	Accesses the underlying boost::thread, e.g.
std::string	getName ()
void	setName (std::string const &s)
Protected Member Functions
void	initAndRun ()
virtual void	beforeRun ()
virtual void	afterRun ()
Protected Attributes
boost::thread *	pBoostThread
bool	bRunning
std::string	name
Private Attributes
AioSignalScheduler &	scheduler

---

Detailed Description

Definition at line 38 of file AioSignalScheduler.cpp.

---

Constructor & Destructor Documentation

AioSignalHandlerThread::AioSignalHandlerThread

(

AioSignalScheduler &

schedulerInit

)

[inline]

Definition at line 42 of file AioSignalScheduler.cpp.

        : scheduler(schedulerInit)
    {
    }

---

Member Function Documentation

void AioSignalHandlerThread::run

(

)

[virtual]

Implements Thread.

Definition at line 156 of file AioSignalScheduler.cpp.

References AioSignalScheduler::quit, and scheduler.

{
    int rc;

    // unblock signal in this thread only
    sigset_t mask;
    sigemptyset(&mask);
    sigaddset(&mask,SIGRTMIN);
    rc = pthread_sigmask(SIG_UNBLOCK,&mask,NULL);
    assert(!rc);

    // NOTE: had to boost priority of this thread to get signal handler
    // to run frequently.
#ifdef sun
    int policy;
    sched_param param;
    rc = pthread_getschedparam(pthread_self(),&policy,&param);
    assert(!rc);
    param.sched_priority++;
    rc = pthread_setschedparam(pthread_self(),SCHED_RR,&param);
    assert(!rc);
#endif

    // NOTE: using a condition variable causes the signal handler
    // to run too infrequently.  Try again after switching threading models.
    while (!scheduler.quit) {
        sleep(1);
    }
}

void Thread::initAndRun

(

)

[protected, inherited]

Definition at line 66 of file Thread.cpp.

References Thread::afterRun(), Thread::beforeRun(), and Thread::run().

Referenced by Thread::start().

{
    beforeRun();
    run();
    afterRun();
}

void Thread::beforeRun

(

)

[protected, virtual, inherited]

Definition at line 73 of file Thread.cpp.

References Thread::bRunning.

Referenced by Thread::initAndRun().

{
    bRunning = true;
}

void Thread::afterRun

(

)

[protected, virtual, inherited]

Definition at line 78 of file Thread.cpp.

References Thread::bRunning.

Referenced by Thread::initAndRun().

{
    bRunning = false;
}

void Thread::start

(

)

[virtual, inherited]

Spawns the OS thread.

Definition at line 50 of file Thread.cpp.

References Thread::initAndRun(), and Thread::pBoostThread.

Referenced by AioLinuxScheduler::AioLinuxScheduler(), AioPollingScheduler::AioPollingScheduler(), StatsTimer::start(), ResourceTest::testConcurrency(), and LocalConditionTest::testNotifyAll().

{
    pBoostThread = new boost::thread(
        boost::bind(&Thread::initAndRun,this));
}

void Thread::join

(

)

[inherited]

Waits for the OS thread to terminate.

Definition at line 56 of file Thread.cpp.

References Thread::pBoostThread.

Referenced by CheckpointThread::closeImpl(), TimerThread::stop(), AioPollingScheduler::stop(), AioLinuxScheduler::stop(), ResourceTest::testConcurrency(), and LocalConditionTest::testNotifyAll().

{
    assert(pBoostThread);
    boost::thread t;
    assert(*pBoostThread != t);
    pBoostThread->join();
    delete pBoostThread;
    pBoostThread = NULL;
}

bool Thread::isStarted

(

)

const [inline, inherited]

Returns:

true if start has been called (and subsequent join has not completed)

Reimplemented in AioLinuxScheduler.

Definition at line 71 of file Thread.h.

Referenced by CheckpointThread::closeImpl(), CacheImpl< PageT, VictimPolicyT >::closeImpl(), AioLinuxScheduler::isStarted(), and TimerThread::stop().

    {
        return pBoostThread ? true : false;
    }

bool Thread::isStopped

(

)

const [inline, inherited]

Returns:

opposite of isStarted()

Definition at line 79 of file Thread.h.

    {
        return !isStarted();
    }

boost::thread& Thread::getBoostThread

(

)

[inline, inherited]

Accesses the underlying boost::thread, e.g.

for use in a boost::thread_group. This thread must already be started.

Returns:

the underlying boost::thread

Definition at line 90 of file Thread.h.

    {
        assert(isStarted());
        return *pBoostThread;
    }

std::string Thread::getName

(

)

[inline, inherited]

Definition at line 96 of file Thread.h.

    {
        return name;
    }

void Thread::setName

(

std::string const &

s

)

[inline, inherited]

Definition at line 101 of file Thread.h.

    {
        name = s;
    }

---

Member Data Documentation

AioSignalScheduler& AioSignalHandlerThread::scheduler [private]

Definition at line 40 of file AioSignalScheduler.cpp.

Referenced by run().

boost::thread* Thread::pBoostThread [protected, inherited]

Definition at line 44 of file Thread.h.

Referenced by Thread::join(), Thread::start(), Thread::Thread(), and Thread::~Thread().

bool Thread::bRunning [protected, inherited]

Definition at line 45 of file Thread.h.

Referenced by Thread::afterRun(), Thread::beforeRun(), Thread::Thread(), and Thread::~Thread().

std::string Thread::name [protected, inherited]

Definition at line 46 of file Thread.h.

Referenced by Thread::Thread().

---

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

• /home/pub/open/dev/fennel/device/AioSignalScheduler.cpp

---