semaphore_value.h

Go to the documentation of this file.

#ifndef SENSESP_SRC_SENSESP_SYSTEM_SEMAPHORE_VALUE_H_
#define SENSESP_SRC_SENSESP_SYSTEM_SEMAPHORE_VALUE_H_
 
#include "sensesp.h"
 
#include <freertos/semphr.h>
 
namespace sensesp {
 
template <typename T>
class SemaphoreValue : public ValueConsumer<T> {
 public:
  SemaphoreValue() : ValueConsumer<T>() {
    semaphore_ = xSemaphoreCreateBinary();
  }
 
  bool wait(T& destination, unsigned int max_duration_ms) {
    if (xSemaphoreTake(semaphore_, max_duration_ms / portTICK_PERIOD_MS) ==
        pdTRUE) {
      destination = value_;
      return true;
    }
    return false;
  }
 
  bool take(unsigned int max_duration_ms) {
    return xSemaphoreTake(semaphore_, max_duration_ms / portTICK_PERIOD_MS) ==
           pdTRUE;
  }
 
  void set(const T& new_value) override {
    value_ = new_value;
    xSemaphoreGive(semaphore_);
  }
 
  void clear() { xSemaphoreTake(semaphore_, 0); }
 
 protected:
  T value_;
  SemaphoreHandle_t semaphore_;
};
 
}  // namespace sensesp
 
#endif  // SENSESP_SRC_SENSESP_SYSTEM_SEMAPHORE_VALUE_H_