Changeset 1275 for trunk/MagicSoft/Cosy/base

Timestamp:

04/12/02 16:59:23 (23 years ago)

Author:

tbretz

Message:

*** empty log message ***

Location:

trunk/MagicSoft/Cosy/base

Files:

• MThread.cc (modified) (6 diffs)
• msgqueue.cc (modified) (7 diffs)

trunk/MagicSoft/Cosy/base/MThread.cc

@@ -1 +1 @@
 #include <MThread.h>
+
+#include <iostream.h>
 
 #include <pthread.h>
@@ -12 +14 @@
 MThread::MThread(bool start, int prio) : fIsRunning(false), fIsDetached(false), fThread(NULL), fReturn(NULL)
 {
-    if (start)
-    {
-        SetPriority(prio);
-        Start();
-    }
+    if (!start)
+        return;
+
+    SetPriority(prio);
+    Start();
 }
 
@@ -27 +29 @@
 MThread::~MThread()
 {
-    if (fIsRunning)
-        Stop();
+    cout << "~MThread::MThread" << endl;
+    Stop();
 }
 
@@ -120 +122 @@
 void MThread::Stop()
 {
+    cout << "MThread::Stop: fThread=" << fThread << ", fIsRunning=" << (int)fIsRunning << endl;
     if (!fThread || !fIsRunning)
         return;
@@ -125 +128 @@
     if (fIsDetached)
     {
+        cout << "Stopping detached thread..." << flush;
         pthread_cancel(*fThread);
         fIsRunning = false;
@@ -130 +134 @@
     else
     {
+        cout << "Stopping thread..." << flush;
         fStop = true;
         pthread_join(*fThread, &fReturn);
     }
+    cout << "done." << endl;
 
     delete fThread;
     fThread = NULL;
+
+    cout << "MThread::Stop() done." << endl;
 }

trunk/MagicSoft/Cosy/base/msgqueue.cc

@@ -6 +6 @@
 #include <sys/resource.h>  // PRIO_PROCESS
 
+// --------------------------------------------------------------------------
+//
+// This creates the Message queue thread,
+//
 MsgQueue::MsgQueue() : fBreak(0)
 {
@@ -12 +16 @@
 }
 
+// --------------------------------------------------------------------------
+//
+// The destructor terminates the thread.
+//
 MsgQueue::~MsgQueue()
 {
+    cout << "~MsgQueue::MsgQueue" << endl;
     pthread_cancel(fThread);
     delete (unsigned char*)fMp;
 }
 
+// --------------------------------------------------------------------------
+//
+// This is the function which must be overloaded.
+// Here you process the messages. mp is a pointer which you can
+// specify when posting the message.
+//
+// If a new messages is posted while the old one is not yet
+// finished the fBreak flag is set. Please test this flag with
+// Break() and try to finish (or stop) the current action as soon
+// as possible. This makes sure, that before a new action is started
+// the old action can be finished correctly by the user.
+//
 void *MsgQueue::Proc(int msg, void *mp)
 {
@@ -23 +44 @@
 }
 
+// --------------------------------------------------------------------------
+//
+// This is the thread mapper.
+//
 void *MsgQueue::MapThread(void *arg)
 {
@@ -34 +59 @@
 }
 
+// --------------------------------------------------------------------------
+//
+// This is the thread which handles the processing.
+// As soon as a message is posted the fBreak flag is set (see PostMsg)
+// And as soon as the current action is finished the new action is executed
+// in this thread. This makes sure, that the calling program is not stalled.
+//
 void MsgQueue::Thread()
 {
@@ -56 +88 @@
         pthread_mutex_unlock(&fMuxMsg);
 
+        cout << "Processing Msg 0x" << hex << fMsg << endl;
+        // --- bool quit = fMsg==WM_QUIT;
         fRc=Proc(fMsg, fMp);
+        cout << "Msg 0x" << hex << fMsg << " processed." << endl;
 
-        if (fMsg==WM_QUIT)
-            break;
+        // --- if (quit)
+        // ---    break;
+    }
 
-    }
+    // --- fStart = 0;
+    // --- cout << "WM_QUIT posted... leaving msg queue." << endl;
 }
 
+// --------------------------------------------------------------------------
+//
+// Use this function to post a message.
+// mp can be a pointer to a data structure. size should be the size of it.
+// size bytes of this structure are copied and a pointer to the copy
+// is forwarded to the Proc function.
+//
 void *MsgQueue::PostMsg(int msg, void *mp, int size)
 {
@@ -74 +118 @@
     // stopped and the messages are processed serialized
     //
+    cout << "Locking MsgQueue mutex..." << flush;
     pthread_mutex_lock(&fMuxMsg);
+    cout << "done." << endl;
 
     //
@@ -101 +147 @@
     //
     fStart = 1;
+    cout << "Releasing MsgQueue mutex..." << flush;
     pthread_mutex_unlock(&fMuxMsg);
-    while (fStart) usleep(1);
+    cout << "done." << endl;
+    while (fStart)
+        usleep(1);
 
+    cout << "Returning rc = 0x" << hex << rc << endl;
     return rc;
 }