new branch muse2, first checkin

1 files changed, 104 insertions, 0 deletions

diff --git a/muse2/muse/thread.h b/muse2/muse/thread.h
new file mode 100644
index 00000000..f9642301
--- /dev/null
+++ b/muse2/muse/thread.h
@@ -0,0 +1,104 @@
+//=========================================================
+//  MusE
+//  Linux Music Editor
+//  $Id: thread.h,v 1.1.1.1.2.2 2009/12/20 05:00:35 terminator356 Exp $
+//
+//  (C) Copyright 2001 Werner Schweer (ws@seh.de)
+//=========================================================
+
+#ifndef __THREAD_H__
+#define __THREAD_H__
+
+#include <pthread.h>
+#include <list>
+
+//---------------------------------------------------------
+//   Poll
+//---------------------------------------------------------
+
+struct Poll {
+      int fd;
+      int action;
+      void (*handler)(void*,void*);
+      void* param1;
+      void* param2;
+
+      Poll(int _fd, int _action, void(*_handler)(void*,void*), void* p, void* q) {
+            fd      = _fd;
+            action  = _action;
+            handler = _handler;
+            param1   = p;
+            param2   = q;
+            }
+      };
+
+typedef std::list<Poll> PollList;
+typedef std::list<Poll>::iterator iPoll;
+
+
+//---------------------------------------------------------
+//   ThreadMsg
+//---------------------------------------------------------
+
+struct ThreadMsg {
+      int id;
+      };
+
+//---------------------------------------------------------
+//   Thread
+//---------------------------------------------------------
+
+class Thread {
+      const char* _name;
+      volatile bool _running;
+      //int realTimePriority;
+      int _pollWait;    // poll timeout in msec (-1 = infinite)
+
+      pthread_t thread;
+
+      int toThreadFdw;     // message to thread (app write)
+
+      PollList plist;
+//      pthread_mutex_t lock;
+//      pthread_cond_t ready;
+      void* userPtr;
+
+   protected:
+      int _realTimePriority;
+      int fromThreadFdr;   // message from thread (seq read)
+      int fromThreadFdw;   // message from thread (app write)
+      int toThreadFdr;     // message to thread (seq read)
+      struct pollfd* pfd;  // poll file descriptors
+      int npfd;
+      int maxpfd;
+      virtual void processMsg(const ThreadMsg*) {}
+      virtual void processMsg1(const void *) {}
+      virtual void defaultTick() {}
+
+   public:
+      //Thread(int prio, const char* name);
+      Thread(const char* name);
+      
+      virtual ~Thread();
+      const char* name() const { return _name; }
+      
+      //virtual void start(void* ptr=0);
+      virtual void start(int priority, void* ptr=0);
+      
+      void stop(bool);
+      void clearPollFd() {    plist.clear(); npfd = 0; }
+      void addPollFd(int fd, int action, void (*handler)(void*,void*), void*, void*);
+      void removePollFd(int fd, int action);
+      void loop();
+      void readMsg();
+      void readMsg1(int size);
+      bool sendMsg1(const void* m, int n);
+      bool sendMsg(const ThreadMsg* m);
+      bool isRunning() const { return _running; }
+      void setPollWait(int val) { _pollWait = val; }
+      virtual void threadStart(void*){ }  // called from loop
+      virtual void threadStop() { }  // called from loop before leaving
+      };
+
+#endif
+