#include <RequestQueue.h>

Inheritance diagram for RequestQueue:

Collaboration diagram for RequestQueue:

Classes
class	Request

class	RequestQueueOverrunChecker

Public Types
enum	ActionOnDuplicate { Block, NewRequest, ReturnImmediately }

Public Member Functions
	RequestQueue (const String &name)

virtual void	initialise ()

virtual void	destroy ()

MUST_USE_RESULT uint64_t	addRequest (size_t priority, uint64_t p1=0, uint64_t p2=0, uint64_t p3=0, uint64_t p4=0, uint64_t p5=0, uint64_t p6=0, uint64_t p7=0, uint64_t p8=0)

MUST_USE_RESULT uint64_t	addRequest (size_t priority, ActionOnDuplicate action, uint64_t p1=0, uint64_t p2=0, uint64_t p3=0, uint64_t p4=0, uint64_t p5=0, uint64_t p6=0, uint64_t p7=0, uint64_t p8=0)

uint64_t	addAsyncRequest (size_t priority, uint64_t p1=0, uint64_t p2=0, uint64_t p3=0, uint64_t p4=0, uint64_t p5=0, uint64_t p6=0, uint64_t p7=0, uint64_t p8=0)

void	halt ()

void	resume ()

Protected Member Functions
virtual uint64_t	executeRequest (uint64_t p1, uint64_t p2, uint64_t p3, uint64_t p4, uint64_t p5, uint64_t p6, uint64_t p7, uint64_t p8)=0

	RequestQueue (const RequestQueue &)

void	operator= (const RequestQueue &)

virtual bool	compareRequests (const Request &a, const Request &b)

bool	isRequestValid (const Request *r)

int	work ()

Request *	getNextRequest ()

Static Protected Member Functions
static int	trampoline (void *p)

static int	doAsync (void *p)

Protected Attributes
Request *	m_pRequestQueue [REQUEST_QUEUE_NUM_PRIORITIES]

volatile bool	m_Stop

Mutex	m_RequestQueueMutex

ConditionVariable	m_RequestQueueCondition

ConditionVariable	m_AsyncRequestQueueCondition

Thread *	m_pThread

bool	m_Halted

Mutex	m_HaltAcknowledged

RequestQueueOverrunChecker	m_OverrunChecker

size_t	m_nMaxAsyncRequests

size_t	m_nAsyncRequests

size_t	m_nTotalRequests

String	m_Name

Friends
class	Thread

Detailed Description

Implements a request queue, with one worker thread performing all requests. All requests appear synchronous to the calling thread - calling threads are blocked on mutexes (so they can be put to sleep) until their request is complete.

Definition at line 41 of file RequestQueue.h.

Constructor & Destructor Documentation

RequestQueue::RequestQueue ( const String & name )

Creates a new RequestQueue.

Definition at line 35 of file RequestQueue.cc.

References destroy(), and m_pRequestQueue.

Member Function Documentation

uint64_t RequestQueue::addAsyncRequest	(	size_t	priority,
		uint64_t	p1 = `0`,
		uint64_t	p2 = `0`,
		uint64_t	p3 = `0`,
		uint64_t	p4 = `0`,
		uint64_t	p5 = `0`,
		uint64_t	p6 = `0`,
		uint64_t	p7 = `0`,
		uint64_t	p8 = `0`
	)

Adds an asynchronous request to the queue. Will not block.

Definition at line 282 of file RequestQueue.cc.

References addRequest(), Thread::detach(), doAsync(), ERROR, Hex, and Scheduler::instance().

Referenced by ScsiDisk::read(), Cache::release(), Cache::sync(), Cache::timer(), and ScsiDisk::write().

Here is the caller graph for this function:

uint64_t RequestQueue::addRequest	(	size_t	priority,
		uint64_t	p1 = `0`,
		uint64_t	p2 = `0`,
		uint64_t	p3 = `0`,
		uint64_t	p4 = `0`,
		uint64_t	p5 = `0`,
		uint64_t	p6 = `0`,
		uint64_t	p7 = `0`,
		uint64_t	p8 = `0`
	)

Adds a request to the queue. Blocks until it finishes and returns the result.

Parameters

priority The priority to attach to this request. Lower number is higher priority.

Definition at line 118 of file RequestQueue.cc.

Referenced by addAsyncRequest(), doAsync(), ScsiDisk::flush(), ScsiDisk::read(), and Cache::sync().

Here is the caller graph for this function:

uint64_t RequestQueue::addRequest	(	size_t	priority,
		ActionOnDuplicate	action,
		uint64_t	p1 = `0`,
		uint64_t	p2 = `0`,
		uint64_t	p3 = `0`,
		uint64_t	p4 = `0`,
		uint64_t	p5 = `0`,
		uint64_t	p6 = `0`,
		uint64_t	p7 = `0`,
		uint64_t	p8 = `0`
	)