remove whitespace at eol

[goodguy/history.git] / cinelerra-5.1 / guicast / thread.C

diff --git a/cinelerra-5.1/guicast/thread.C b/cinelerra-5.1/guicast/thread.C
index c3d068e0b3c867bfadd06572433bfa27b63c2d49..6cde612dfdfbb853902f02e423bc39699817bf18 100644 (file)
--- a/cinelerra-5.1/guicast/thread.C
+++ b/cinelerra-5.1/guicast/thread.C
@@ -2,107 +2,33 @@
 /*
  * CINELERRA
  * Copyright (C) 2008 Adam Williams <broadcast at earthling dot net>
- * 
+ *
  * 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.
- * 
+ *
  * This program is distributed in the hope that it will be useful,
  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  * GNU General Public License for more details.
- * 
+ *
  * You should have received a copy of the GNU General Public License
  * along with this program; if not, write to the Free Software
  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
- * 
+ *
  */
 
-#ifndef NO_GUICAST
 #include "bcsignals.h"
-#endif
 #include <sys/wait.h>
 #include <sched.h>
 #include <signal.h>
 #include <stdio.h>
 #include <unistd.h>
 #include <string.h>
-#include "thread.h"
-
-// track unjoined threads at termination
-#ifndef NO_GUICAST
-#include "arraylist.h"
-#include "mutex.h"
 #include <typeinfo>
+#include "thread.h"
 
-class MLocker {
-       static Mutex the_lock;
-public:
-       MLocker() { the_lock.lock(); }
-       ~MLocker() { the_lock.unlock(); }
-};
-Mutex MLocker::the_lock;
-
-class the_dbg {
-public:
-       pthread_t tid;  const char *name;
-       the_dbg(pthread_t t, const char *nm) { tid = t; name = nm; }
-       ~the_dbg() {}
-};
-
-
-static class the_list : public ArrayList<the_dbg*> {
-public:
-       static void dump_threads(FILE *fp);
-        the_list() {}
-       ~the_list() {
-               MLocker mlkr;
-               remove_all_objects();
-       }
-} thread_list;
-
-static void dbg_add(pthread_t tid, const char *nm)
-{
-       MLocker mlkr;
-       int i = thread_list.size();
-       while( --i >= 0 && thread_list[i]->tid != tid );
-       if( i >= 0 ) {
-               printf("dbg_add, dup %016lx %s %s\n",
-                       (unsigned long)tid, nm, thread_list[i]->name);
-               return;
-       }
-       thread_list.append(new the_dbg(tid, nm));
-}
-
-static void dbg_del(pthread_t tid)
-{
-       MLocker mlkr;
-       int i = thread_list.size();
-       while( --i >= 0 && thread_list[i]->tid != tid );
-       if( i < 0 ) {
-               printf("dbg_del, mis %016lx\n",(unsigned long)tid);
-               return;
-       }
-       thread_list.remove_object_number(i);
-}
-
-static class the_chkr {
-public:
-       the_chkr() {}
-       ~the_chkr() {
-               int i = thread_list.size();
-               if( !i ) return;
-               printf("unjoined tids %d\n", i);
-               while( --i >= 0 ) printf("  %016lx %s\n",
-                       (unsigned long)thread_list[i]->tid,
-                       thread_list[i]->name);
-       }
-} the_chk;
-#else
-#define dbg_add(t, nm) do {} while(0)
-#define dbg_del(t) do {} while(0)
-#endif
 
 Thread::Thread(int synchronous, int realtime, int autodelete)
 {
@@ -139,7 +65,7 @@ void* Thread::entrypoint(void *parameters)
        thread->run();
        thread->finished = true;
        if( !thread->synchronous ) {
-               if( !thread->cancelled ) dbg_del(thread->tid);
+               if( !thread->cancelled ) TheList::dbg_del(thread->tid);
                if( thread->autodelete ) delete thread;
                else thread->tid = ((pthread_t)-1);
        }
@@ -182,7 +108,7 @@ void Thread::start()
 
        pthread_create(&tid, &attr, Thread::entrypoint, this);
 
-       dbg_add(tid, typeid(*this).name());
+       TheList::dbg_add(tid, owner, typeid(*this).name());
 }
 
 int Thread::cancel()
@@ -191,7 +117,7 @@ int Thread::cancel()
                LOCK_LOCKS("Thread::cancel");
                pthread_cancel(tid);
                cancelled = true;
-               if( !synchronous ) dbg_del(tid);
+               if( !synchronous ) TheList::dbg_del(tid);
                UNLOCK_LOCKS;
        }
        return 0;
@@ -205,7 +131,7 @@ int Thread::join()   // join this thread
                int ret = pthread_join(tid, 0);
                if( ret ) strerror(ret);
                CLEAR_LOCKS_TID(tid);
-               dbg_del(tid);
+               TheList::dbg_del(tid);
                tid = ((pthread_t)-1);
 // Don't execute anything after this.
                if( autodelete ) delete this;
@@ -311,13 +237,3 @@ unsigned long Thread::get_tid()
        return tid;
 }
 
-void Thread::dump_threads(FILE *fp)
-{
-       int i = thread_list.size();
-       while( --i >= 0 ) {
-               fprintf(fp, "thread %016lx, %s\n",
-                       (unsigned long)thread_list[i]->tid,
-                       thread_list[i]->name);
-       }
-}
-