| Index: base/threading/platform_thread_posix.cc
|
| diff --git a/base/threading/platform_thread_posix.cc b/base/threading/platform_thread_posix.cc
|
| deleted file mode 100644
|
| index f3a835e54f0b2c56cc02827ee85749a8fb25f214..0000000000000000000000000000000000000000
|
| --- a/base/threading/platform_thread_posix.cc
|
| +++ /dev/null
|
| @@ -1,286 +0,0 @@
|
| -// Copyright (c) 2012 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -#include "base/threading/platform_thread.h"
|
| -
|
| -#include <errno.h>
|
| -#include <pthread.h>
|
| -#include <sched.h>
|
| -#include <sys/resource.h>
|
| -#include <sys/time.h>
|
| -
|
| -#include "base/lazy_instance.h"
|
| -#include "base/logging.h"
|
| -#include "base/memory/scoped_ptr.h"
|
| -#include "base/synchronization/waitable_event.h"
|
| -#include "base/threading/platform_thread_internal_posix.h"
|
| -#include "base/threading/thread_id_name_manager.h"
|
| -#include "base/threading/thread_restrictions.h"
|
| -#include "base/tracked_objects.h"
|
| -
|
| -#if defined(OS_LINUX)
|
| -#include <sys/syscall.h>
|
| -#elif defined(OS_ANDROID)
|
| -#include <sys/types.h>
|
| -#endif
|
| -
|
| -namespace base {
|
| -
|
| -void InitThreading();
|
| -void InitOnThread();
|
| -void TerminateOnThread();
|
| -size_t GetDefaultThreadStackSize(const pthread_attr_t& attributes);
|
| -
|
| -namespace {
|
| -
|
| -struct ThreadParams {
|
| - ThreadParams()
|
| - : delegate(NULL),
|
| - joinable(false),
|
| - priority(ThreadPriority::NORMAL),
|
| - handle(NULL),
|
| - handle_set(false, false) {
|
| - }
|
| -
|
| - PlatformThread::Delegate* delegate;
|
| - bool joinable;
|
| - ThreadPriority priority;
|
| - PlatformThreadHandle* handle;
|
| - WaitableEvent handle_set;
|
| -};
|
| -
|
| -void* ThreadFunc(void* params) {
|
| - base::InitOnThread();
|
| - ThreadParams* thread_params = static_cast<ThreadParams*>(params);
|
| -
|
| - PlatformThread::Delegate* delegate = thread_params->delegate;
|
| - if (!thread_params->joinable)
|
| - base::ThreadRestrictions::SetSingletonAllowed(false);
|
| -
|
| - if (thread_params->priority != ThreadPriority::NORMAL)
|
| - PlatformThread::SetCurrentThreadPriority(thread_params->priority);
|
| -
|
| - // Stash the id in the handle so the calling thread has a complete
|
| - // handle, and unblock the parent thread.
|
| - *(thread_params->handle) = PlatformThreadHandle(pthread_self(),
|
| - PlatformThread::CurrentId());
|
| - thread_params->handle_set.Signal();
|
| -
|
| - ThreadIdNameManager::GetInstance()->RegisterThread(
|
| - PlatformThread::CurrentHandle().platform_handle(),
|
| - PlatformThread::CurrentId());
|
| -
|
| - delegate->ThreadMain();
|
| -
|
| - ThreadIdNameManager::GetInstance()->RemoveName(
|
| - PlatformThread::CurrentHandle().platform_handle(),
|
| - PlatformThread::CurrentId());
|
| -
|
| - base::TerminateOnThread();
|
| - return NULL;
|
| -}
|
| -
|
| -bool CreateThread(size_t stack_size, bool joinable,
|
| - PlatformThread::Delegate* delegate,
|
| - PlatformThreadHandle* thread_handle,
|
| - ThreadPriority priority) {
|
| - base::InitThreading();
|
| -
|
| - bool success = false;
|
| - pthread_attr_t attributes;
|
| - pthread_attr_init(&attributes);
|
| -
|
| - // Pthreads are joinable by default, so only specify the detached
|
| - // attribute if the thread should be non-joinable.
|
| - if (!joinable) {
|
| - pthread_attr_setdetachstate(&attributes, PTHREAD_CREATE_DETACHED);
|
| - }
|
| -
|
| - // Get a better default if available.
|
| - if (stack_size == 0)
|
| - stack_size = base::GetDefaultThreadStackSize(attributes);
|
| -
|
| - if (stack_size > 0)
|
| - pthread_attr_setstacksize(&attributes, stack_size);
|
| -
|
| - ThreadParams params;
|
| - params.delegate = delegate;
|
| - params.joinable = joinable;
|
| - params.priority = priority;
|
| - params.handle = thread_handle;
|
| -
|
| - pthread_t handle;
|
| - int err = pthread_create(&handle,
|
| - &attributes,
|
| - ThreadFunc,
|
| - ¶ms);
|
| - success = !err;
|
| - if (!success) {
|
| - // Value of |handle| is undefined if pthread_create fails.
|
| - handle = 0;
|
| - errno = err;
|
| - PLOG(ERROR) << "pthread_create";
|
| - }
|
| -
|
| - pthread_attr_destroy(&attributes);
|
| -
|
| - // Don't let this call complete until the thread id
|
| - // is set in the handle.
|
| - if (success)
|
| - params.handle_set.Wait();
|
| - CHECK_EQ(handle, thread_handle->platform_handle());
|
| -
|
| - return success;
|
| -}
|
| -
|
| -} // namespace
|
| -
|
| -// static
|
| -PlatformThreadId PlatformThread::CurrentId() {
|
| - // Pthreads doesn't have the concept of a thread ID, so we have to reach down
|
| - // into the kernel.
|
| -#if defined(OS_MACOSX)
|
| - return pthread_mach_thread_np(pthread_self());
|
| -#elif defined(OS_LINUX)
|
| - return syscall(__NR_gettid);
|
| -#elif defined(OS_ANDROID)
|
| - return gettid();
|
| -#elif defined(OS_SOLARIS) || defined(OS_QNX)
|
| - return pthread_self();
|
| -#elif defined(OS_NACL) && defined(__GLIBC__)
|
| - return pthread_self();
|
| -#elif defined(OS_NACL) && !defined(__GLIBC__)
|
| - // Pointers are 32-bits in NaCl.
|
| - return reinterpret_cast<int32>(pthread_self());
|
| -#elif defined(OS_POSIX)
|
| - return reinterpret_cast<int64>(pthread_self());
|
| -#endif
|
| -}
|
| -
|
| -// static
|
| -PlatformThreadRef PlatformThread::CurrentRef() {
|
| - return PlatformThreadRef(pthread_self());
|
| -}
|
| -
|
| -// static
|
| -PlatformThreadHandle PlatformThread::CurrentHandle() {
|
| - return PlatformThreadHandle(pthread_self(), CurrentId());
|
| -}
|
| -
|
| -// static
|
| -void PlatformThread::YieldCurrentThread() {
|
| - sched_yield();
|
| -}
|
| -
|
| -// static
|
| -void PlatformThread::Sleep(TimeDelta duration) {
|
| - struct timespec sleep_time, remaining;
|
| -
|
| - // Break the duration into seconds and nanoseconds.
|
| - // NOTE: TimeDelta's microseconds are int64s while timespec's
|
| - // nanoseconds are longs, so this unpacking must prevent overflow.
|
| - sleep_time.tv_sec = duration.InSeconds();
|
| - duration -= TimeDelta::FromSeconds(sleep_time.tv_sec);
|
| - sleep_time.tv_nsec = duration.InMicroseconds() * 1000; // nanoseconds
|
| -
|
| - while (nanosleep(&sleep_time, &remaining) == -1 && errno == EINTR)
|
| - sleep_time = remaining;
|
| -}
|
| -
|
| -// static
|
| -const char* PlatformThread::GetName() {
|
| - return ThreadIdNameManager::GetInstance()->GetName(CurrentId());
|
| -}
|
| -
|
| -// static
|
| -bool PlatformThread::Create(size_t stack_size, Delegate* delegate,
|
| - PlatformThreadHandle* thread_handle) {
|
| - base::ThreadRestrictions::ScopedAllowWait allow_wait;
|
| - return CreateThread(stack_size, true /* joinable thread */,
|
| - delegate, thread_handle, ThreadPriority::NORMAL);
|
| -}
|
| -
|
| -// static
|
| -bool PlatformThread::CreateWithPriority(size_t stack_size, Delegate* delegate,
|
| - PlatformThreadHandle* thread_handle,
|
| - ThreadPriority priority) {
|
| - base::ThreadRestrictions::ScopedAllowWait allow_wait;
|
| - return CreateThread(stack_size, true, // joinable thread
|
| - delegate, thread_handle, priority);
|
| -}
|
| -
|
| -// static
|
| -bool PlatformThread::CreateNonJoinable(size_t stack_size, Delegate* delegate) {
|
| - PlatformThreadHandle unused;
|
| -
|
| - base::ThreadRestrictions::ScopedAllowWait allow_wait;
|
| - bool result = CreateThread(stack_size, false /* non-joinable thread */,
|
| - delegate, &unused, ThreadPriority::NORMAL);
|
| - return result;
|
| -}
|
| -
|
| -// static
|
| -void PlatformThread::Join(PlatformThreadHandle thread_handle) {
|
| - // Joining another thread may block the current thread for a long time, since
|
| - // the thread referred to by |thread_handle| may still be running long-lived /
|
| - // blocking tasks.
|
| - base::ThreadRestrictions::AssertIOAllowed();
|
| - CHECK_EQ(0, pthread_join(thread_handle.platform_handle(), NULL));
|
| -}
|
| -
|
| -// Mac has its own Set/GetCurrentThreadPriority() implementations.
|
| -#if !defined(OS_MACOSX)
|
| -
|
| -// static
|
| -void PlatformThread::SetCurrentThreadPriority(ThreadPriority priority) {
|
| -#if defined(OS_NACL)
|
| - NOTIMPLEMENTED();
|
| -#else
|
| - if (internal::SetCurrentThreadPriorityForPlatform(priority))
|
| - return;
|
| -
|
| - // setpriority(2) should change the whole thread group's (i.e. process)
|
| - // priority. However, as stated in the bugs section of
|
| - // http://man7.org/linux/man-pages/man2/getpriority.2.html: "under the current
|
| - // Linux/NPTL implementation of POSIX threads, the nice value is a per-thread
|
| - // attribute". Also, 0 is prefered to the current thread id since it is
|
| - // equivalent but makes sandboxing easier (https://crbug.com/399473).
|
| - const int nice_setting = internal::ThreadPriorityToNiceValue(priority);
|
| - if (setpriority(PRIO_PROCESS, 0, nice_setting)) {
|
| - DVPLOG(1) << "Failed to set nice value of thread ("
|
| - << PlatformThread::CurrentId() << ") to " << nice_setting;
|
| - }
|
| -#endif // defined(OS_NACL)
|
| -}
|
| -
|
| -// static
|
| -ThreadPriority PlatformThread::GetCurrentThreadPriority() {
|
| -#if defined(OS_NACL)
|
| - NOTIMPLEMENTED();
|
| - return ThreadPriority::NORMAL;
|
| -#else
|
| - // Mirrors SetCurrentThreadPriority()'s implementation.
|
| - ThreadPriority platform_specific_priority;
|
| - if (internal::GetCurrentThreadPriorityForPlatform(
|
| - &platform_specific_priority)) {
|
| - return platform_specific_priority;
|
| - }
|
| -
|
| - // Need to clear errno before calling getpriority():
|
| - // http://man7.org/linux/man-pages/man2/getpriority.2.html
|
| - errno = 0;
|
| - int nice_value = getpriority(PRIO_PROCESS, 0);
|
| - if (errno != 0) {
|
| - DVPLOG(1) << "Failed to get nice value of thread ("
|
| - << PlatformThread::CurrentId() << ")";
|
| - return ThreadPriority::NORMAL;
|
| - }
|
| -
|
| - return internal::NiceValueToThreadPriority(nice_value);
|
| -#endif // !defined(OS_NACL)
|
| -}
|
| -
|
| -#endif // !defined(OS_MACOSX)
|
| -
|
| -} // namespace base
|
|
|