svcore  1.9
Classes | Public Types | Public Slots | Public Member Functions | Protected Types | Protected Member Functions | Protected Attributes
FileReadThread Class Reference

#include <FileReadThread.h>

Inheritance diagram for FileReadThread:
Inheritance graph
[legend]
Collaboration diagram for FileReadThread:
Collaboration graph
[legend]

List of all members.

Classes

struct  Request

Public Types

enum  Type { RTThread, NonRTThread }

Public Slots

void start ()

Public Member Functions

 FileReadThread ()
virtual void run ()
virtual void finish ()
virtual int request (const Request &request)
virtual void cancel (int token)
virtual bool isReady (int token)
virtual bool isCancelled (int token)
virtual bool haveRequest (int token)
virtual bool getRequest (int token, Request &request)
virtual void done (int token)

Protected Types

typedef std::map< int, Request > RequestQueue

Protected Member Functions

void process ()
void notifyCancelled ()

Protected Attributes

int m_nextToken
bool m_exiting
RequestQueue m_queue
RequestQueue m_cancelledRequests
RequestQueue m_readyRequests
std::set< int > m_newlyCancelled
QMutex m_mutex
QWaitCondition m_condition

Detailed Description

Definition at line 29 of file FileReadThread.h.

Member Typedef Documentation

typedef std::map<int, Request> FileReadThread::RequestQueue [protected]

Definition at line 61 of file FileReadThread.h.

Member Enumeration Documentation

enum Thread::Type [inherited]
Enumerator:
RTThread 
NonRTThread 

Definition at line 29 of file Thread.h.

Constructor & Destructor Documentation

FileReadThread::FileReadThread ( )

Definition at line 27 of file FileReadThread.cpp.

Member Function Documentation

void FileReadThread::run ( ) [virtual]

Implements Thread.

Definition at line 34 of file FileReadThread.cpp.

References m_condition, m_exiting, m_mutex, m_queue, notifyCancelled(), process(), and SVDEBUG.

void FileReadThread::finish ( ) [virtual]

Definition at line 55 of file FileReadThread.cpp.

References m_cancelledRequests, m_condition, m_exiting, m_mutex, m_newlyCancelled, m_queue, and SVDEBUG.

int FileReadThread::request ( const Request &  request) [virtual]

Definition at line 81 of file FileReadThread.cpp.

References m_condition, m_mutex, m_nextToken, and m_queue.

Referenced by process().

void FileReadThread::cancel ( int  token) [virtual]

Definition at line 98 of file FileReadThread.cpp.

References m_cancelledRequests, m_condition, m_mutex, m_newlyCancelled, m_queue, m_readyRequests, and SVDEBUG.

bool FileReadThread::isReady ( int  token) [virtual]

Definition at line 123 of file FileReadThread.cpp.

References m_mutex, and m_readyRequests.

bool FileReadThread::isCancelled ( int  token) [virtual]

Definition at line 133 of file FileReadThread.cpp.

References m_cancelledRequests, m_mutex, and m_newlyCancelled.

bool FileReadThread::haveRequest ( int  token) [virtual]

Definition at line 145 of file FileReadThread.cpp.

References m_cancelledRequests, m_mutex, m_queue, and m_readyRequests.

bool FileReadThread::getRequest ( int  token,
Request &  request 
) [virtual]

Definition at line 163 of file FileReadThread.cpp.

References m_cancelledRequests, m_mutex, m_queue, and m_readyRequests.

void FileReadThread::done ( int  token) [virtual]

Definition at line 184 of file FileReadThread.cpp.

References m_cancelledRequests, m_mutex, m_newlyCancelled, m_queue, and m_readyRequests.

void FileReadThread::process ( ) [protected]

Definition at line 207 of file FileReadThread.cpp.

References FileReadThread::Request::data, FileReadThread::Request::fd, m_exiting, m_mutex, m_queue, m_readyRequests, FileReadThread::Request::mutex, request(), FileReadThread::Request::size, FileReadThread::Request::start, FileReadThread::Request::successful, and SVDEBUG.

Referenced by run().

void FileReadThread::notifyCancelled ( ) [protected]

Definition at line 306 of file FileReadThread.cpp.

References m_newlyCancelled, and SVDEBUG.

Referenced by run().

void Thread::start ( ) [slot, inherited]

Definition at line 34 of file Thread.cpp.

References Thread::m_type, and Thread::RTThread.

Referenced by DecodingWavFileReader::DecodingWavFileReader(), WaveFileModel::fillCache(), MP3FileReader::MP3FileReader(), OggVorbisFileReader::OggVorbisFileReader(), DSSIPluginInstance::requestNonRTThread(), FFTDataServer::resume(), FFTDataServer::FillThread::run(), and ModelTransformerFactory::transformMultiple().

Member Data Documentation

int FileReadThread::m_nextToken [protected]

Definition at line 58 of file FileReadThread.h.

Referenced by request().

bool FileReadThread::m_exiting [protected]

Definition at line 59 of file FileReadThread.h.

Referenced by finish(), process(), and run().

RequestQueue FileReadThread::m_queue [protected]

Definition at line 62 of file FileReadThread.h.

Referenced by cancel(), done(), finish(), getRequest(), haveRequest(), process(), request(), and run().

RequestQueue FileReadThread::m_cancelledRequests [protected]

Definition at line 63 of file FileReadThread.h.

Referenced by cancel(), done(), finish(), getRequest(), haveRequest(), and isCancelled().

RequestQueue FileReadThread::m_readyRequests [protected]

Definition at line 64 of file FileReadThread.h.

Referenced by cancel(), done(), getRequest(), haveRequest(), isReady(), and process().

std::set<int> FileReadThread::m_newlyCancelled [protected]

Definition at line 65 of file FileReadThread.h.

Referenced by cancel(), done(), finish(), isCancelled(), and notifyCancelled().

QMutex FileReadThread::m_mutex [protected]

Definition at line 67 of file FileReadThread.h.

Referenced by cancel(), done(), finish(), getRequest(), haveRequest(), isCancelled(), isReady(), process(), request(), and run().

QWaitCondition FileReadThread::m_condition [protected]

Definition at line 68 of file FileReadThread.h.

Referenced by cancel(), finish(), request(), and run().

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