Mercurial > hg > svcore
view data/fileio/FileReadThread.h @ 408:115f60df1e4d
* Speed up spectrogram painting by releasing mutex in FFTDataServer
while calculating data prior to writing it, and by adding whole-column
value query methods to FFT objects
* Add paint cache to Thumbwheel -- repaints of this widget were slowing
down the whole spectrogram repaint
* More uses of MutexLocker (named and with debug) and more profile
points
* Make startup much quicker some of the time, with OSC server in place
author | Chris Cannam |
---|---|
date | Thu, 08 May 2008 14:46:22 +0000 |
parents | 4b2ea82fd0ed |
children | 3e0f1f7bec85 |
line wrap: on
line source
/* -*- c-basic-offset: 4 indent-tabs-mode: nil -*- vi:set ts=8 sts=4 sw=4: */ /* Sonic Visualiser An audio file viewer and annotation editor. Centre for Digital Music, Queen Mary, University of London. This file copyright 2006 Chris Cannam. This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 2 of the License, or (at your option) any later version. See the file COPYING included with this distribution for more information. */ #ifndef _FILE_READ_THREAD_H_ #define _FILE_READ_THREAD_H_ #include "base/Thread.h" #include <QMutex> #include <QWaitCondition> #include <map> #include <set> #include <stdint.h> class FileReadThread : public Thread { Q_OBJECT public: FileReadThread(); virtual void run(); virtual void finish(); struct Request { int fd; QMutex *mutex; // used to synchronise access to fd; may be null off_t start; size_t size; char *data; // caller is responsible for allocating and deallocating bool successful; // set by FileReadThread after processing request }; virtual int request(const Request &request); virtual void cancel(int token); virtual bool isReady(int token); virtual bool isCancelled(int token); // and safe to delete virtual bool getRequest(int token, Request &request); virtual void done(int token); protected: int m_nextToken; bool m_exiting; typedef std::map<int, Request> RequestQueue; RequestQueue m_queue; RequestQueue m_cancelledRequests; RequestQueue m_readyRequests; std::set<int> m_newlyCancelled; QMutex m_mutex; QWaitCondition m_condition; void process(); void notifyCancelled(); }; #endif