Files
Li, Xun d10cabebb5 Linux 2.5 Open Source Gold Release
Added new APIs in sgx_uae_service.h and sgx_ukey_exchange.h to support ECDSA quote based remote attestation.
  The set of legacy APIs supports EPID only and the set of new APIs supports ECDSA quotes.
Enhanced Edger8r with structure deep-copy feature.
Fixed bugs.

Signed-off-by: Li, Xun <xun.li@intel.com>
2019-04-02 13:26:58 +08:00

124 lines
3.1 KiB
C++

/*=============================================================================
Library: CppMicroServices
Copyright (c) The CppMicroServices developers. See the COPYRIGHT
file at the top-level directory of this distribution and at
https://github.com/CppMicroServices/CppMicroServices/COPYRIGHT .
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
=============================================================================*/
#ifndef CPPMICROSERVICES_WAITCONDITION_H
#define CPPMICROSERVICES_WAITCONDITION_H
#include "cppmicroservices/GlobalConfig.h"
#include <chrono>
#include <condition_variable>
namespace cppmicroservices {
namespace detail {
template<class MutexHost>
class WaitCondition
{
public:
void Wait(typename MutexHost::UniqueLock& lock)
{
#ifdef US_ENABLE_THREADING_SUPPORT
m_CondVar.wait(lock.m_Lock);
#else
US_UNUSED(lock);
#endif
}
template<class Predicate>
void Wait(typename MutexHost::UniqueLock& lock, Predicate pred)
{
#ifdef US_ENABLE_THREADING_SUPPORT
m_CondVar.wait(lock.m_Lock, pred);
#else
US_UNUSED(lock);
US_UNUSED(pred);
#endif
}
template<class Rep, class Period>
std::cv_status WaitFor(typename MutexHost::UniqueLock& lock,
const std::chrono::duration<Rep, Period>& rel_time)
{
#ifdef US_ENABLE_THREADING_SUPPORT
if (rel_time == std::chrono::duration<Rep, Period>::zero()) {
Wait(lock);
return std::cv_status::no_timeout;
} else {
return m_CondVar.wait_for(lock.m_Lock, rel_time);
}
#else
US_UNUSED(lock);
US_UNUSED(rel_time);
return std::cv_status::no_timeout;
#endif
}
template<class Rep, class Period, class Predicate>
bool WaitFor(typename MutexHost::UniqueLock& lock,
const std::chrono::duration<Rep, Period>& rel_time,
Predicate pred)
{
#ifdef US_ENABLE_THREADING_SUPPORT
if (rel_time == std::chrono::duration<Rep, Period>::zero()) {
Wait(lock, pred);
return true;
} else {
return m_CondVar.wait_for(lock.m_Lock, rel_time, pred);
}
#else
US_UNUSED(lock);
US_UNUSED(rel_time);
US_UNUSED(pred);
return pred();
#endif
}
/** Notify that the condition is true and release one waiting thread */
void Notify()
{
#ifdef US_ENABLE_THREADING_SUPPORT
m_CondVar.notify_one();
#endif
}
/** Notify that the condition is true and release all waiting threads */
void NotifyAll()
{
#ifdef US_ENABLE_THREADING_SUPPORT
m_CondVar.notify_all();
#endif
}
private:
#ifdef US_ENABLE_THREADING_SUPPORT
std::condition_variable m_CondVar;
#endif
};
} // namespace detail
} // namespace cppmicroservices
#endif // CPPMICROSERVICES_WAITCONDITION_H