File Manager

003 File Manager

Current Path: /usr/src/contrib/llvm-project/libcxx/src

usr / src / contrib / llvm-project / libcxx / src /

📁 ..
📄 algorithm.cpp(3.73 KB)
📄 any.cpp(933 B)
📄 atomic.cpp(7.67 KB)
📄 barrier.cpp(3.77 KB)
📄 bind.cpp(715 B)
📄 charconv.cpp(4.51 KB)
📄 chrono.cpp(4.94 KB)
📄 condition_variable.cpp(2.73 KB)
📄 condition_variable_destructor.cpp(1.26 KB)
📄 debug.cpp(13.37 KB)
📄 exception.cpp(1.25 KB)
📁 experimental
📁 filesystem
📄 functional.cpp(656 B)
📄 future.cpp(6.21 KB)
📄 hash.cpp(13.04 KB)
📁 include
📄 ios.cpp(12.62 KB)
📄 iostream.cpp(5.66 KB)
📄 locale.cpp(189.52 KB)
📄 memory.cpp(6.15 KB)
📄 mutex.cpp(5.77 KB)
📄 mutex_destructor.cpp(1.44 KB)
📄 new.cpp(5.98 KB)
📄 optional.cpp(1.16 KB)
📄 random.cpp(3.98 KB)
📄 random_shuffle.cpp(1.26 KB)
📄 regex.cpp(8.22 KB)
📄 shared_mutex.cpp(2.86 KB)
📄 stdexcept.cpp(592 B)
📄 string.cpp(11.54 KB)
📄 strstream.cpp(8.46 KB)
📁 support
📄 system_error.cpp(6.88 KB)
📄 thread.cpp(5.42 KB)
📄 typeinfo.cpp(1.79 KB)
📄 utility.cpp(497 B)
📄 valarray.cpp(1.67 KB)
📄 variant.cpp(517 B)
📄 vector.cpp(529 B)

Editing: condition_variable.cpp

//===-------------------- condition_variable.cpp --------------------------===//
//
// Part of the LLVM Project, under the Apache License v2.0 with LLVM Exceptions.
// See https://llvm.org/LICENSE.txt for license information.
// SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception
//
//===----------------------------------------------------------------------===//

#include "__config"

#ifndef _LIBCPP_HAS_NO_THREADS

#include "condition_variable"
#include "thread"
#include "system_error"
#include "__undef_macros"

#if defined(__ELF__) && defined(_LIBCPP_LINK_PTHREAD_LIB)
#pragma comment(lib, "pthread")
#endif

_LIBCPP_BEGIN_NAMESPACE_STD

// ~condition_variable is defined elsewhere.

void
condition_variable::notify_one() _NOEXCEPT
{
    __libcpp_condvar_signal(&__cv_);
}

void
condition_variable::notify_all() _NOEXCEPT
{
    __libcpp_condvar_broadcast(&__cv_);
}

void
condition_variable::wait(unique_lock<mutex>& lk) _NOEXCEPT
{
    if (!lk.owns_lock())
        __throw_system_error(EPERM,
                                  "condition_variable::wait: mutex not locked");
    int ec = __libcpp_condvar_wait(&__cv_, lk.mutex()->native_handle());
    if (ec)
        __throw_system_error(ec, "condition_variable wait failed");
}

void
condition_variable::__do_timed_wait(unique_lock<mutex>& lk,
     chrono::time_point<chrono::system_clock, chrono::nanoseconds> tp) _NOEXCEPT
{
    using namespace chrono;
    if (!lk.owns_lock())
        __throw_system_error(EPERM,
                            "condition_variable::timed wait: mutex not locked");
    nanoseconds d = tp.time_since_epoch();
    if (d > nanoseconds(0x59682F000000E941))
        d = nanoseconds(0x59682F000000E941);
    __libcpp_timespec_t ts;
    seconds s = duration_cast<seconds>(d);
    typedef decltype(ts.tv_sec) ts_sec;
    _LIBCPP_CONSTEXPR ts_sec ts_sec_max = numeric_limits<ts_sec>::max();
    if (s.count() < ts_sec_max)
    {
        ts.tv_sec = static_cast<ts_sec>(s.count());
        ts.tv_nsec = static_cast<decltype(ts.tv_nsec)>((d - s).count());
    }
    else
    {
        ts.tv_sec = ts_sec_max;
        ts.tv_nsec = giga::num - 1;
    }
    int ec = __libcpp_condvar_timedwait(&__cv_, lk.mutex()->native_handle(), &ts);
    if (ec != 0 && ec != ETIMEDOUT)
        __throw_system_error(ec, "condition_variable timed_wait failed");
}

void
notify_all_at_thread_exit(condition_variable& cond, unique_lock<mutex> lk)
{
    auto& tl_ptr = __thread_local_data();
    // If this thread was not created using std::thread then it will not have
    // previously allocated.
    if (tl_ptr.get() == nullptr) {
        tl_ptr.set_pointer(new __thread_struct);
    }
    __thread_local_data()->notify_all_at_thread_exit(&cond, lk.release());
}

_LIBCPP_END_NAMESPACE_STD

#endif // !_LIBCPP_HAS_NO_THREADS

003 File Manager

Editing: condition_variable.cpp

Upload File

Create Folder