Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1766)

Unified Diff: runtime/vm/thread_interrupter.cc

Issue 796063006: Rename Thread -> OSThread. (Closed) Base URL: http://dart.googlecode.com/svn/branches/bleeding_edge/dart/
Patch Set: Created 5 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « runtime/vm/thread_interrupter.h ('k') | runtime/vm/thread_interrupter_android.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: runtime/vm/thread_interrupter.cc
===================================================================
--- runtime/vm/thread_interrupter.cc (revision 42893)
+++ runtime/vm/thread_interrupter.cc (working copy)
@@ -51,19 +51,20 @@
bool ThreadInterrupter::initialized_ = false;
bool ThreadInterrupter::shutdown_ = false;
bool ThreadInterrupter::thread_running_ = false;
-ThreadId ThreadInterrupter::interrupter_thread_id_ = Thread::kInvalidThreadId;
+ThreadId ThreadInterrupter::interrupter_thread_id_ =
+ OSThread::kInvalidThreadId;
Monitor* ThreadInterrupter::monitor_ = NULL;
intptr_t ThreadInterrupter::interrupt_period_ = 1000;
intptr_t ThreadInterrupter::current_wait_time_ = Monitor::kNoTimeout;
ThreadLocalKey ThreadInterrupter::thread_state_key_ =
- Thread::kUnsetThreadLocalKey;
+ OSThread::kUnsetThreadLocalKey;
void ThreadInterrupter::InitOnce() {
ASSERT(!initialized_);
- ASSERT(thread_state_key_ == Thread::kUnsetThreadLocalKey);
- thread_state_key_ = Thread::CreateThreadLocal();
- ASSERT(thread_state_key_ != Thread::kUnsetThreadLocalKey);
+ ASSERT(thread_state_key_ == OSThread::kUnsetThreadLocalKey);
+ thread_state_key_ = OSThread::CreateThreadLocal();
+ ASSERT(thread_state_key_ != OSThread::kUnsetThreadLocalKey);
monitor_ = new Monitor();
ASSERT(monitor_ != NULL);
initialized_ = true;
@@ -75,15 +76,15 @@
if (FLAG_trace_thread_interrupter) {
OS::Print("ThreadInterrupter starting up.\n");
}
- ASSERT(interrupter_thread_id_ == Thread::kInvalidThreadId);
+ ASSERT(interrupter_thread_id_ == OSThread::kInvalidThreadId);
{
MonitorLocker startup_ml(monitor_);
- Thread::Start(ThreadMain, 0);
+ OSThread::Start(ThreadMain, 0);
while (!thread_running_) {
startup_ml.Wait();
}
}
- ASSERT(interrupter_thread_id_ != Thread::kInvalidThreadId);
+ ASSERT(interrupter_thread_id_ != OSThread::kInvalidThreadId);
if (FLAG_trace_thread_interrupter) {
OS::Print("ThreadInterrupter running.\n");
}
@@ -109,9 +110,9 @@
// On Windows, a thread's exit-code can leak into the process's exit-code,
// if exiting 'at same time' as the process ends. By joining with the thread
// here, we avoid this race condition.
- ASSERT(interrupter_thread_id_ != Thread::kInvalidThreadId);
- Thread::Join(interrupter_thread_id_);
- interrupter_thread_id_ = Thread::kInvalidThreadId;
+ ASSERT(interrupter_thread_id_ != OSThread::kInvalidThreadId);
+ OSThread::Join(interrupter_thread_id_);
+ interrupter_thread_id_ = OSThread::kInvalidThreadId;
#else
// On non-Windows platforms, just wait for the thread interrupter to signal
// that it has exited the loop.
@@ -183,9 +184,9 @@
InterruptableThreadState* state = CurrentThreadState();
if (state == NULL) {
// Create thread state object lazily.
- ThreadId current_thread = Thread::GetCurrentThreadId();
+ ThreadId current_thread = OSThread::GetCurrentThreadId();
if (FLAG_trace_thread_interrupter) {
- intptr_t tid = Thread::ThreadIdToIntPtr(current_thread);
+ intptr_t tid = OSThread::ThreadIdToIntPtr(current_thread);
OS::Print("ThreadInterrupter Tracking %p\n",
reinterpret_cast<void*>(tid));
}
@@ -204,9 +205,9 @@
void ThreadInterrupter::UpdateStateObject(ThreadInterruptCallback callback,
void* data) {
InterruptableThreadState* state = CurrentThreadState();
- ThreadId current_thread = Thread::GetCurrentThreadId();
+ ThreadId current_thread = OSThread::GetCurrentThreadId();
ASSERT(state != NULL);
- ASSERT(Thread::Compare(state->id, Thread::GetCurrentThreadId()));
+ ASSERT(OSThread::Compare(state->id, OSThread::GetCurrentThreadId()));
SetCurrentThreadState(NULL);
// It is now safe to modify the state object. If an interrupt occurs,
// the current thread state will be NULL.
@@ -214,7 +215,7 @@
state->data = data;
SetCurrentThreadState(state);
if (FLAG_trace_thread_interrupter) {
- intptr_t tid = Thread::ThreadIdToIntPtr(current_thread);
+ intptr_t tid = OSThread::ThreadIdToIntPtr(current_thread);
if (callback == NULL) {
OS::Print("ThreadInterrupter Cleared %p\n", reinterpret_cast<void*>(tid));
} else {
@@ -231,13 +232,14 @@
InterruptableThreadState* ThreadInterrupter::CurrentThreadState() {
InterruptableThreadState* state = reinterpret_cast<InterruptableThreadState*>(
- Thread::GetThreadLocal(thread_state_key_));
+ OSThread::GetThreadLocal(thread_state_key_));
return state;
}
void ThreadInterrupter::SetCurrentThreadState(InterruptableThreadState* state) {
- Thread::SetThreadLocal(thread_state_key_, reinterpret_cast<uword>(state));
+ OSThread::SetThreadLocal(thread_state_key_,
+ reinterpret_cast<uword>(state));
}
@@ -279,7 +281,7 @@
{
// Signal to main thread we are ready.
MonitorLocker startup_ml(monitor_);
- interrupter_thread_id_ = Thread::GetCurrentThreadId();
+ interrupter_thread_id_ = OSThread::GetCurrentThreadId();
thread_running_ = true;
startup_ml.Notify();
}
« no previous file with comments | « runtime/vm/thread_interrupter.h ('k') | runtime/vm/thread_interrupter_android.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698