diff data/fileio/FileReadThread.h @ 148:1a42221a1522

* Reorganising code base.  This revision will not compile.

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/data/fileio/FileReadThread.h	Mon Jul 31 11:49:58 2006 +0000
@@ -0,0 +1,73 @@
+/* -*- 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 "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