blob: 998e1bfb14462716e3d9419525eb0a291140ce16 [file] [log] [blame]
/*******************************************************************************
* Copyright (c) 2016, 2018 fortiss GmbH, TU Vienna/ACIN
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the Eclipse Public License v1.0
* which accompanies this distribution, and is available at
* http://www.eclipse.org/legal/epl-v10.html
*
* Contributors:
* Alois Zoitl - initial API and implementation and/or initial documentation
* Martin Melik-Merkumians - adds timed wait and try and no wait
* and documentation
*******************************************************************************/
#ifndef SRC_ARCH_RCX_SEMAPHORE_H_
#define SRC_ARCH_RCX_SEMAPHORE_H_
#include <rX_Includes.h>
namespace forte {
namespace arch {
/*!\ingroup rcX_hal
* \brief counting semaphore for syncing operation in FORTE
*
* The semaphore is initialized with the value given.
*/
class CrcXSemaphore{
public:
explicit CrcXSemaphore(unsigned int paInitialValue = 0);
~CrcXSemaphore();
/** @brief Unlocks (increments) the semaphore
*
*/
void inc();
/** @brief Waits until the semaphore can be locked
*
*/
void waitIndefinitely();
/** @brief Checks if the semaphore is locked, and waits the specified amount of time if it is locked
*
* @param paRelativeTimeout - The relative time span to wait in nanoseconds
* @return true - semaphore has become available before the timeout, false - semaphore was not available before timeout
*/
bool timedWait(const TForteUInt64 paRelativeTimeout);
/** @brief Tries to immediately get the semaphore, if it is available
*
* @return true - semaphore was available, false - semaphore was not available
*/
bool tryNoWait();
private:
RX_HANDLE mSemaphore;
};
typedef CrcXSemaphore CSemaphore;
} /* namespace arch */
} /* namespace forte */
#endif /* SRC_ARCH_RCX_SEMAPHORE_H_ */