SemaphoreNotifiableBlock.hxx

Go to the documentation of this file.

 
#ifndef _EXECUTOR_SEMAPHORENOTIFIABLEBLOCK_HXX_
#define _EXECUTOR_SEMAPHORENOTIFIABLEBLOCK_HXX_
 
class SemaphoreNotifiableBlock : private Notifiable, private Atomic
{
public:
    SemaphoreNotifiableBlock(unsigned num_parallelism)
        : count_(num_parallelism)
        , sem_(num_parallelism)
        , barriers_(new BarrierNotifiable[num_parallelism])
    {
    }
 
    ~SemaphoreNotifiableBlock()
    {
        delete[] barriers_;
    }
 
    BarrierNotifiable* acquire() {
        sem_.wait();
        AtomicHolder h(this);
        for (unsigned i = 0; i < count_; ++i) {
            if (barriers_[i].is_done()) {
                return barriers_[i].reset(this);
            }
        }
        DIE("SempahoreNotifiableBlock: could not find a free barrier.");
    }
 
    void notify() override
    {
        sem_.post();
    }
 
#if OPENMRN_FEATURE_RTOS_FROM_ISR
    void notify_from_isr() OVERRIDE
    {
        int woken = 0;
        sem_.post_from_isr(&woken);
    }
#endif // OPENMRN_FEATURE_RTOS_FROM_ISR
 
private:
    unsigned count_;
    OSSem sem_;
    BarrierNotifiable *barriers_;
 
    DISALLOW_COPY_AND_ASSIGN(SemaphoreNotifiableBlock);
};
 
#endif // _EXECUTOR_SEMAPHORENOTIFIABLEBLOCK_HXX_