condition.H

/*
 * This file is part of the "Archon" framework.
 * (http://files3d.sourceforge.net)
 *
 * Copyright © 2002 by Kristian Spangsege and Brian Kristiansen.
 *
 * Permission to use, copy, modify, and distribute this software and
 * its documentation under the terms of the GNU General Public License is
 * hereby granted. No representations are made about the suitability of
 * this software for any purpose. It is provided "as is" without express
 * or implied warranty. See the GNU General Public License
 * (http://www.gnu.org/copyleft/gpl.html) for more details.
 *
 * The characters in this file are ISO8859-1 encoded.
 *
 * The documentation in this file is in "Doxygen" style
 * (http://www.doxygen.org).
 */

#ifndef ARCHON_UTILITIES_CONDITION_H
#define ARCHON_UTILITIES_CONDITION_H

#include <list>

#include <sys/select.h> // fd_set

#include <archon/util/exception.H>
#include <archon/util/time.H>
#include <archon/util/mutex.H>

namespace Archon
{
  namespace Utilities
  {
    using namespace std;

    struct ThreadTerminatedException: UnexpectedException
    {
      ThreadTerminatedException(string l): UnexpectedException(l) {}
    };

    struct Condition
    {
      Condition(Mutex &m);
      ~Condition();

      void notifyOne()
      {
        const int e = pthread_cond_signal(&cond);
        if(e != 0)
          ARCHON_THROW1(InternalException,
                        "Attempt to signal on condition failed");
        Mutex::Lock l(sigThreadsMutex);
        if(sigThreads.size()) notifySigThreads();
      }

      void notifyAll()
      {
        const int e = pthread_cond_broadcast(&cond);
        if(e != 0)
          ARCHON_THROW1(InternalException,
                        "Attempt to broadcast on condition failed");
        Mutex::Lock l(sigThreadsMutex);
        if(sigThreads.size()) notifySigThreads();
      }

      void wait() throw(UnexpectedException);

      bool timedWait(Time timeout) throw(UnexpectedException);

      int select(int n, fd_set *readfds, fd_set *writefds,
                 fd_set *exceptfds, Time timeout)
        throw(UnexpectedException);

    private:
      friend struct Thread;

      pthread_cond_t cond;
      Mutex *mutex;

      Mutex sigThreadsMutex;
      list<pthread_t> sigThreads;

      Condition(const Condition &); // Hide
      Condition &operator=(const Condition &); // Hide

      void notifySigThreads();
    };
  }
}

#endif // ARCHON_UTILITIES_CONDITION_H

---