Notifiable.cxx

Go to the documentation of this file.

 
#include "executor/Notifiable.hxx"
 
#include "utils/macros.h"
 
static EmptyNotifiable default_empty_notifiable;
 
Notifiable* EmptyNotifiable::DefaultInstance() {
  return &default_empty_notifiable;
}
 
static CrashNotifiable default_crash_notifiable;
 
Notifiable* CrashNotifiable::DefaultInstance() {
  return &default_crash_notifiable;
}
 
void CrashNotifiable::notify() { DIE("Called CrashNotifiable."); }
 
BarrierNotifiable* BarrierNotifiable::new_child() {
  AtomicHolder h(this);
  count_++;
  return this;
}
 
void BarrierNotifiable::notify() {
  unsigned new_value;
  {
    AtomicHolder h(this);
    HASSERT(count_ && "barrier notifyable received too many notifys");
    new_value = --count_;
  }
  if (!new_value) {
    HASSERT(done_);
    done_->notify();
  }
}
 
BarrierNotifiable::~BarrierNotifiable() { HASSERT(!count_); }
 
BarrierNotifiable* BarrierNotifiable::reset(Notifiable* done) {
  AtomicHolder h(this);
  HASSERT(!count_);
  count_ = 1;
  done_ = done;
  return this;
}