.. _program_listing_file_components_Util_src_Sema.cpp:

Program Listing for File Sema.cpp
=================================

|exhale_lsh| :ref:`Return to documentation for file <file_components_Util_src_Sema.cpp>` (``components/Util/src/Sema.cpp``)

.. |exhale_lsh| unicode:: U+021B0 .. UPWARDS ARROW WITH TIP LEFTWARDS

.. code-block:: cpp

   
   #include "Sema.h"
   
   #include "esp_log.h"
   
   namespace util {
   
   static const char* TAG = "Semaphore";
   
   Semaphore::Semaphore(const char* dbg_name)
       : m_handle(),
         m_dbg_name(dbg_name)
   {
       ESP_LOGD(TAG, "new semaphore \"%s\"", m_dbg_name);
       m_handle = xSemaphoreCreateBinary();
       xSemaphoreGive(m_handle);
   }
   
   Semaphore::Semaphore(Semaphore&& other)
       : m_handle(other.m_handle),
         m_dbg_name(other.m_dbg_name)
   {
       other.m_handle = 0;
   }
   
   Semaphore::~Semaphore()
   {
       if (m_handle != 0) vSemaphoreDelete(m_handle);
   }
   
   void Semaphore::take()
   {
       ESP_LOGD(TAG, "take \"%s\"", m_dbg_name);
       xSemaphoreTake(m_handle, portMAX_DELAY);
   }
   
   bool Semaphore::take(std::uint32_t timeout_ms)
   {
       ESP_LOGD(TAG, "take: %s for %d ms", m_dbg_name, timeout_ms);
   
       TickType_t timeout_ticks = timeout_ms / portTICK_PERIOD_MS;
       bool taken = xSemaphoreTake(m_handle, timeout_ticks) == pdTRUE;
   
       if (taken) {
           ESP_LOGD(TAG, "Semaphore taken:  %s", m_dbg_name);
       } else {
           ESP_LOGE(TAG, "Semaphore NOT taken:  %s", m_dbg_name);
       }
       return taken;
   }
   
   void Semaphore::give()
   {
       ESP_LOGD(TAG, "give \"%s\"", m_dbg_name);
       xSemaphoreGive(m_handle);
   }
   
   void Semaphore::wait()
   {
       ESP_LOGD(TAG, "wait on \"%s\"", m_dbg_name);
   
       xSemaphoreTake(m_handle, portMAX_DELAY);
       xSemaphoreGive(m_handle);
   }
   
   } // namespace util