Chris@148: /* -*- c-basic-offset: 4 indent-tabs-mode: nil -*-  vi:set ts=8 sts=4 sw=4: */
Chris@148: 
Chris@148: /*
Chris@148:     Sonic Visualiser
Chris@148:     An audio file viewer and annotation editor.
Chris@148:     Centre for Digital Music, Queen Mary, University of London.
Chris@148:     This file copyright 2006 Chris Cannam.
Chris@148:     
Chris@148:     This program is free software; you can redistribute it and/or
Chris@148:     modify it under the terms of the GNU General Public License as
Chris@148:     published by the Free Software Foundation; either version 2 of the
Chris@148:     License, or (at your option) any later version.  See the file
Chris@148:     COPYING included with this distribution for more information.
Chris@148: */
Chris@148: 
Chris@1581: #ifndef SV_FILE_READ_THREAD_H
Chris@1581: #define SV_FILE_READ_THREAD_H
Chris@148: 
Chris@150: #include "base/Thread.h"
Chris@148: 
Chris@148: #include <QMutex>
Chris@148: #include <QWaitCondition>
Chris@148: 
Chris@148: #include <map>
Chris@148: #include <set>
Chris@148: 
Chris@148: #include <stdint.h>
Chris@148: 
Chris@148: class FileReadThread : public Thread
Chris@148: {
Chris@148:     Q_OBJECT
Chris@148: 
Chris@148: public:
Chris@148:     FileReadThread();
Chris@148: 
Chris@1580:     void run() override;
Chris@148:     virtual void finish();
Chris@148: 
Chris@148:     struct Request {
Chris@148:         int fd;
Chris@148:         QMutex *mutex; // used to synchronise access to fd; may be null
Chris@148:         off_t start;
Chris@148:         size_t size;
Chris@148:         char *data; // caller is responsible for allocating and deallocating
Chris@148:         bool successful; // set by FileReadThread after processing request
Chris@148:     };
Chris@148:     
Chris@148:     virtual int request(const Request &request);
Chris@148:     virtual void cancel(int token);
Chris@148: 
Chris@148:     virtual bool isReady(int token);
Chris@148:     virtual bool isCancelled(int token); // and safe to delete
Chris@455:     virtual bool haveRequest(int token);
Chris@148:     virtual bool getRequest(int token, Request &request);
Chris@148:     virtual void done(int token);
Chris@148:     
Chris@148: protected:
Chris@148:     int m_nextToken;
Chris@148:     bool m_exiting;
Chris@148:     
Chris@148:     typedef std::map<int, Request> RequestQueue;
Chris@148:     RequestQueue m_queue;
Chris@148:     RequestQueue m_cancelledRequests;
Chris@148:     RequestQueue m_readyRequests;
Chris@148:     std::set<int> m_newlyCancelled;
Chris@148: 
Chris@148:     QMutex m_mutex;
Chris@148:     QWaitCondition m_condition;
Chris@148: 
Chris@148:     void process();
Chris@148:     void notifyCancelled();
Chris@148: };
Chris@148: 
Chris@148: #endif