dthread.h

Go to the documentation of this file.

/*
 * See the dyninst/COPYRIGHT file for copyright information.
 * 
 * We provide the Paradyn Tools (below described as "Paradyn")
 * on an AS IS basis, and do not warrant its validity or performance.
 * We reserve the right to update, modify, or discontinue this
 * software at any time.  We shall have no obligation to supply such
 * updates or modifications or any other form of support to you.
 * 
 * By your use of Paradyn, you understand and agree that we (or any
 * other person or entity with proprietary rights in Paradyn) are
 * under no obligation to provide either maintenance services,
 * update services, notices of latent defects, or correction of
 * defects for Paradyn.
 * 
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 * 
 * This library 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
 * Lesser General Public License for more details.
 * 
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
 */

#if !defined(DTHREAD_H_)
#define DTHREAD_H_

#include <stdlib.h>
#include "util.h"
#include <cassert>

#if !defined(os_windows)
#define cap_pthreads
#include <pthread.h>
#else
#include <common/h/ntheaders.h>
#endif

#if !defined(WINAPI)
#define WINAPI
#endif

class COMMON_EXPORT DThread {
#if defined(cap_pthreads)
   pthread_t thrd;
 public:
   typedef void (*initial_func_t)(void *);
   typedef void dthread_ret_t;
#define DTHREAD_RET_VAL
#else
    HANDLE thrd;
    DWORD tid;
 public:
    typedef LPTHREAD_START_ROUTINE initial_func_t;
    typedef int dthread_ret_t;
    #define DTHREAD_RET_VAL 0
#endif
   bool live;   
 public:
   DThread();
   ~DThread();

   static long self();
   bool spawn(initial_func_t func, void *param);
   bool join();
   long id();
};

class COMMON_EXPORT Mutex {
   friend class CondVar;
#if defined(cap_pthreads)
   pthread_mutex_t mutex;
#else
#if defined(os_windows)
   HANDLE mutex;
#endif
#endif
 public:
   Mutex(bool recursive=false);
   ~Mutex();

   bool trylock();
   bool lock();
   bool unlock();
};

class COMMON_EXPORT CondVar {
#if defined(cap_pthreads)
   pthread_cond_t cond;
#else
    int numWaiting;
    CRITICAL_SECTION numWaitingLock;
    HANDLE wait_sema;
    HANDLE wait_done;
    bool was_broadcast;
    Mutex sync_cv_ops;
#endif
   Mutex *mutex;
   bool created_mutex;
 public:
   CondVar(Mutex *m = NULL);
   ~CondVar();

   bool unlock();
   bool trylock();
   bool lock();
   bool signal();
   bool broadcast();
   bool wait();
};

/**
 * Construct a version of this class as a local variable, and it will hold
 * its lock as long as it's in scope.  Thus you can get auto-unlock upon 
 * return.
 **/
class ScopeLock {
  private:
   Mutex *m;
   CondVar *c;
  public:
   ScopeLock(Mutex &m_) :
     m(&m_),
     c(NULL)
   {
      bool result = m->lock();
      assert(result);
   }
      
   ScopeLock(CondVar &c_) :
     m(NULL),
     c(&c_)
   {
      bool result = c->lock();
      assert(result);
   }

   void unlock() {
      if (m) {
         m->unlock();
         m = NULL;
      }
      else if (c) {
         c->unlock();
         c = NULL;
      }
   }

   bool isLocked() {
      return m || c;
   }

   ~ScopeLock() {
      unlock();
   }
};

#endif