svcore
1.9
|
#include <FileReadThread.h>
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 |
Definition at line 29 of file FileReadThread.h.
typedef std::map<int, Request> FileReadThread::RequestQueue [protected] |
Definition at line 61 of file FileReadThread.h.
enum Thread::Type [inherited] |
Definition at line 27 of file FileReadThread.cpp.
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().
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.
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] |