/home/andref/projetos/epos--/include/common/synchronizer.h

// EPOS-- Synchronizer Abstractions Common Package

// This work is licensed under the Creative Commons
// Attribution-NonCommercial-NoDerivs License. To view a copy of this license,
// visit http://creativecommons.org/licenses/by-nc-nd/2.0/ or send a letter to
// Creative Commons, 559 Nathan Abbott Way, Stanford, California 94305, USA.

#ifndef __synchronizer_h
#define __synchronizer_h

#include <system/config.h>
#include <cpu.h>
#include <thread.h>
#include "ep_cvec.h"
#include <scheduler_disabler.h>

__BEGIN_SYS

class Synchronizer_Common {
protected:
    Synchronizer_Common() {}

        void wakeup() {
          DISABLE_SCHED {
            if(!_waitingThreads.isEmpty()) removeWaintingThreadAndResume();
          }
        }

        void wakeupAll() {
          DISABLE_SCHED {
            while(!_waitingThreads.isEmpty()) removeWaintingThreadAndResume();
          }
        }

protected:
        inline bool tsl(volatile bool & lock) { return CPU::tsl(lock); }

        inline int inc(volatile int & number) { return CPU::finc(number); }

        inline int dec(volatile int & number) { return CPU::fdec(number); }

        void sleep() {
          DISABLE_SCHED {
            _waitingThreads.pushBack(&Scheduler::getInstance().getRunning());
            Scheduler::getInstance().suspend(&Scheduler::getInstance().getRunning());
          }
        }

private:
    typedef CircularVector<Thread *> ThreadVector;
    ThreadVector _waitingThreads;

    inline void removeWaintingThreadAndResume() {
                Thread *thread = _waitingThreads.front();
                _waitingThreads.popFront();
                Scheduler::getInstance().resume(thread);
        }
};

__END_SYS

#endif

---