ResourceThread Class Reference

Inheritance diagram for ResourceThread:

List of all members.

Public Member Functions
	ResourceThread (std::string desc, boost::barrier &barrier, int count)
virtual	~ResourceThread ()
int	getCompleted ()
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
boost::barrier &	barrier
int	count
int	completed
std::vector< std::string >	variants

---

Detailed Description

Definition at line 59 of file ResourceTest.cpp.

---

Constructor & Destructor Documentation

ResourceThread::ResourceThread	(	std::string	desc,
		boost::barrier &	barrier,
		int	count
	)			[inline, explicit]

Definition at line 70 of file ResourceTest.cpp.

References variants.

        : Thread(desc), barrier(barrier), count(count), completed(0)
    {
        for (int i = 0; i < count; i++) {
            std::stringstream ss;
            ss << "var_" << (i + 1);
            variants.push_back(ss.str());
        }
    }

virtual ResourceThread::~ResourceThread

(

)

[inline, virtual]

Definition at line 81 of file ResourceTest.cpp.

    {
    }

---

Member Function Documentation

int ResourceThread::getCompleted

(

)

[inline]

Definition at line 85 of file ResourceTest.cpp.

References completed.

Referenced by ResourceTest::testConcurrency().

    {
        return completed;
    }

virtual void ResourceThread::run

(

)

[inline, virtual]

Implements Thread.

Definition at line 90 of file ResourceTest.cpp.

References barrier, completed, count, and variants.

    {
        try {
            barrier.wait();

            for (int i = 0; i < count; i++) {
                std::string &variant = variants[i];

                Locale locale("en", "US", variant);

                FennelResource::instance(locale).sysCallFailed(variant);

                completed++;
            }
        } catch (...) {
            completed = -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

boost::barrier& ResourceThread::barrier [private]

Definition at line 62 of file ResourceTest.cpp.

Referenced by run().

int ResourceThread::count [private]

Definition at line 64 of file ResourceTest.cpp.

Referenced by run().

int ResourceThread::completed [private]

Definition at line 65 of file ResourceTest.cpp.

Referenced by getCompleted(), and run().

std::vector<std::string> ResourceThread::variants [private]

Definition at line 67 of file ResourceTest.cpp.

Referenced by ResourceThread(), and 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/test/ResourceTest.cpp

---