fsfw/unittest/internal/osal/IntTestMutex.cpp

#include "IntTestMutex.h"

#include <fsfw/ipc/MutexFactory.h>
#include <fsfw/unittest/internal/UnittDefinitions.h>

#if defined(WIN32) || defined(UNIX)
#include <fsfw/osal/host/Mutex.h>
#include <thread>
#include <future>
#endif


void testmutex::testMutex() {
	std::string id = "[testMutex]";
	MutexIF* mutex = MutexFactory::instance()->createMutex();
	auto result = mutex->lockMutex(MutexIF::TimeoutType::POLLING);
	if(result != HasReturnvaluesIF::RETURN_OK) {
		unitt::put_error(id);
	}
	// timed_mutex from the C++ library specifies undefined behaviour if
	// the timed mutex is locked twice from the same thread.
    // TODO: we should pass a define like FSFW_OSAL_HOST to the build.
#if defined(WIN32) || defined(UNIX)
	// This calls the function from
	// another thread and stores the returnvalue in a future.
	auto future = std::async(&MutexIF::lockMutex, mutex, MutexIF::TimeoutType::WAITING, 1);
	result = future.get();
#else
	result = mutex->lockMutex(MutexIF::TimeoutType::WAITING, 1);
#endif
	if(result != MutexIF::MUTEX_TIMEOUT) {
		unitt::put_error(id);
	}

	result = mutex->unlockMutex();
	if(result != HasReturnvaluesIF::RETURN_OK) {
		unitt::put_error(id);
	}

	// TODO: we should pass a define like FSFW_OSAL_HOST to the build.
#if !defined(WIN32) && !defined(UNIX)
    result = mutex->unlockMutex();
	if(result != MutexIF::CURR_THREAD_DOES_NOT_OWN_MUTEX) {
		unitt::put_error(id);
	}
#endif
}