Skip to content

Commit 037874e

Browse files
authored
Add mutex to request fifo for preventing concurrent calls to the process function
1 parent 09146f6 commit 037874e

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

src/chargepoint/requestfifo/RequestFifoManager.h

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,8 @@ along with OpenOCPP. If not, see <http://www.gnu.org/licenses/>.
1919
#ifndef OPENOCPP_REQUESTFIFOMANAGER_H
2020
#define OPENOCPP_REQUESTFIFOMANAGER_H
2121

22+
#include <mutex>
23+
2224
#include "IRequestFifo.h"
2325
#include "Timer.h"
2426

@@ -99,6 +101,9 @@ class RequestFifoManager : public ocpp::messages::IRequestFifo::IListener
99101
/** @brief Retry count for the current request */
100102
unsigned int m_request_retry_count;
101103

104+
/** @brief Mutex protectiing against concurrent processFifoRequest calls */
105+
std::mutex m_process_mutex;
106+
102107
/** @brief Process a FIFO request */
103108
void processFifoRequest();
104109
};

0 commit comments

Comments
 (0)