From e1d4a8c7ea9fda9bf8e203450d2996adb0153684 Mon Sep 17 00:00:00 2001 From: Edouard DUPIN Date: Mon, 9 Oct 2017 10:25:41 +0200 Subject: [PATCH] [DEV] update new ETK --- audio/blockEngine/Thread.cpp | 12 +++---- audio/blockEngine/Thread.hpp | 12 +++---- audio/blockEngine/base/GeneratorFile.cpp | 2 +- audio/blockEngine/base/GeneratorRiver.cpp | 2 +- audio/blockEngine/base/ReceiverFile.cpp | 2 +- audio/blockEngine/base/ReceiverRiver.cpp | 10 +++--- audio/blockEngine/base/ReceiverRiver.hpp | 4 +-- audio/blockEngine/core/Block.cpp | 2 +- audio/blockEngine/core/Block.hpp | 10 +++--- audio/blockEngine/core/BlockMeta.cpp | 22 ++++++------- audio/blockEngine/core/BlockMeta.hpp | 24 +++++++------- audio/blockEngine/core/BufferAudio.cpp | 4 +-- audio/blockEngine/core/BufferAudio.hpp | 8 ++--- audio/blockEngine/core/Processing.hpp | 2 +- audio/blockEngine/flow/Base.cpp | 14 ++++----- audio/blockEngine/flow/Base.hpp | 26 ++++++++-------- audio/blockEngine/flow/Flow.hpp | 38 +++++++++++------------ audio/blockEngine/flow/Interface.cpp | 20 ++++++------ audio/blockEngine/flow/Interface.hpp | 20 ++++++------ test/Main.cpp | 2 +- test/Windows.cpp | 2 +- 21 files changed, 119 insertions(+), 119 deletions(-) diff --git a/audio/blockEngine/Thread.cpp b/audio/blockEngine/Thread.cpp index 35a5d5b..f782edd 100644 --- a/audio/blockEngine/Thread.cpp +++ b/audio/blockEngine/Thread.cpp @@ -42,7 +42,7 @@ static const char* threadGetCharState(enum audio::blockEngine::status state) { */ void audio::blockEngine::Thread::threadChangeState(enum audio::blockEngine::status _newState) { int ret; - std::unique_lock lock(m_interfaceMutex); + ethread::UniqueLock lock(m_interfaceMutex); // debug display : ABE_DEBUG("[" << m_id << "] '" << m_name << "' Change state : " << threadGetCharState(m_state) << " ==> " << threadGetCharState(_newState)); // set the New state @@ -51,7 +51,7 @@ void audio::blockEngine::Thread::threadChangeState(enum audio::blockEngine::stat } -audio::blockEngine::Thread::Thread(const std::string& _chainName) { +audio::blockEngine::Thread::Thread(const etk::String& _chainName) { if (_chainName != "") { m_name = _chainName; } else { @@ -84,7 +84,7 @@ int32_t audio::blockEngine::Thread::start() { return audio::blockEngine::ERR_FAIL; } m_state = audio::blockEngine::statusCreating; - m_thread = std::make_shared(audio::blockEngine::Thread::genericThreadCall, reinterpret_cast(this)); + m_thread = std::make_shared(audio::blockEngine::Thread::genericThreadCall, reinterpret_cast(this)); // no else ==> the thread is started corectly... (we think) return audio::blockEngine::ERR_NONE; } @@ -92,7 +92,7 @@ int32_t audio::blockEngine::Thread::start() { int32_t audio::blockEngine::Thread::stop() { ABE_INFO(" Stop [" << m_id << "] name='" << m_name << "'"); // Set the stop flag for the thread : - std::unique_lock lock(m_interfaceMutex); + ethread::UniqueLock lock(m_interfaceMutex); m_flags |= 1; return audio::blockEngine::ERR_NONE; } @@ -113,7 +113,7 @@ int32_t audio::blockEngine::Thread::stopAtEnd() { if (audio::blockEngine::statusNotStarted != m_state) { m_thread.reset(); } - std::unique_lock lock(m_interfaceMutex); + ethread::UniqueLock lock(m_interfaceMutex); m_flags = 0; m_state = audio::blockEngine::statusNotStarted; @@ -157,7 +157,7 @@ void audio::blockEngine::Thread::threadCall() { while(audio::blockEngine::statusDie != m_state) { int32_t flags = 0; { - std::unique_lock lock(m_interfaceMutex); + ethread::UniqueLock lock(m_interfaceMutex); flags = m_flags; m_flags = 0; } diff --git a/audio/blockEngine/Thread.hpp b/audio/blockEngine/Thread.hpp index 79241a6..ecf6654 100644 --- a/audio/blockEngine/Thread.hpp +++ b/audio/blockEngine/Thread.hpp @@ -5,8 +5,8 @@ */ #pragma once -#include -#include +#include +#include #include #include