Index: runtime/vm/thread_interrupter_win.cc |
diff --git a/runtime/vm/thread_interrupter_win.cc b/runtime/vm/thread_interrupter_win.cc |
index c933cbb73c98c866a59e8c0dc75fce17417811cb..4058da30d25d94c791265c7061b60af4cd69e553 100644 |
--- a/runtime/vm/thread_interrupter_win.cc |
+++ b/runtime/vm/thread_interrupter_win.cc |
@@ -38,7 +38,7 @@ class ThreadInterrupterWin : public AllStatic { |
} |
- static void Interrupt(ThreadInterrupter::ThreadState* state) { |
+ static void Interrupt(InterruptableThreadState* state) { |
ASSERT(GetCurrentThread() != state->id); |
DWORD result = SuspendThread(state->id); |
if (result == kThreadError) { |
@@ -70,19 +70,15 @@ class ThreadInterrupterWin : public AllStatic { |
}; |
-void ThreadInterrupter::InterruptThreads(int64_t current_time) { |
- for (intptr_t i = 0; i < threads_size_; i++) { |
- ThreadState* state = threads_[i]; |
- ASSERT(state->id != Thread::kInvalidThreadId); |
- if (FLAG_trace_thread_interrupter) { |
- OS::Print("ThreadInterrupter suspending %p\n", |
- reinterpret_cast<void*>(state->id)); |
- } |
- ThreadInterrupterWin::Interrupt(state); |
- if (FLAG_trace_thread_interrupter) { |
- OS::Print("ThreadInterrupter resuming %p\n", |
- reinterpret_cast<void*>(state->id)); |
- } |
+void ThreadInterrupter::InterruptThread(InterruptableThreadState* state) { |
+ if (FLAG_trace_thread_interrupter) { |
+ OS::Print("ThreadInterrupter suspending %p\n", |
+ reinterpret_cast<void*>(state->id)); |
+ } |
+ ThreadInterrupterWin::Interrupt(state); |
+ if (FLAG_trace_thread_interrupter) { |
+ OS::Print("ThreadInterrupter resuming %p\n", |
+ reinterpret_cast<void*>(state->id)); |
} |
} |