Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright 2008 the V8 project authors. All rights reserved. | 1 // Copyright 2008 the V8 project authors. All rights reserved. |
| 2 // Redistribution and use in source and binary forms, with or without | 2 // Redistribution and use in source and binary forms, with or without |
| 3 // modification, are permitted provided that the following conditions are | 3 // modification, are permitted provided that the following conditions are |
| 4 // met: | 4 // met: |
| 5 // | 5 // |
| 6 // * Redistributions of source code must retain the above copyright | 6 // * Redistributions of source code must retain the above copyright |
| 7 // notice, this list of conditions and the following disclaimer. | 7 // notice, this list of conditions and the following disclaimer. |
| 8 // * Redistributions in binary form must reproduce the above | 8 // * Redistributions in binary form must reproduce the above |
| 9 // copyright notice, this list of conditions and the following | 9 // copyright notice, this list of conditions and the following |
| 10 // disclaimer in the documentation and/or other materials provided | 10 // disclaimer in the documentation and/or other materials provided |
| (...skipping 223 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 234 return in_use_anchor_->Next(); | 234 return in_use_anchor_->Next(); |
| 235 } | 235 } |
| 236 | 236 |
| 237 | 237 |
| 238 ThreadState* ThreadState::Next() { | 238 ThreadState* ThreadState::Next() { |
| 239 if (next_ == in_use_anchor_) return NULL; | 239 if (next_ == in_use_anchor_) return NULL; |
| 240 return next_; | 240 return next_; |
| 241 } | 241 } |
| 242 | 242 |
| 243 | 243 |
| 244 int ThreadManager::next_id_ = 0; | 244 int ThreadManager::last_id_ = 0; |
|
Søren Thygesen Gjesse
2009/09/04 09:29:57
Please add a comment about that a thread cannot ha
Mikhail Naganov
2009/09/04 11:09:22
Done.
| |
| 245 Mutex* ThreadManager::mutex_ = OS::CreateMutex(); | 245 Mutex* ThreadManager::mutex_ = OS::CreateMutex(); |
| 246 ThreadHandle ThreadManager::mutex_owner_(ThreadHandle::INVALID); | 246 ThreadHandle ThreadManager::mutex_owner_(ThreadHandle::INVALID); |
| 247 ThreadHandle ThreadManager::lazily_archived_thread_(ThreadHandle::INVALID); | 247 ThreadHandle ThreadManager::lazily_archived_thread_(ThreadHandle::INVALID); |
| 248 ThreadState* ThreadManager::lazily_archived_thread_state_ = NULL; | 248 ThreadState* ThreadManager::lazily_archived_thread_state_ = NULL; |
| 249 | 249 |
| 250 | 250 |
| 251 void ThreadManager::ArchiveThread() { | 251 void ThreadManager::ArchiveThread() { |
| 252 ASSERT(!lazily_archived_thread_.IsValid()); | 252 ASSERT(!lazily_archived_thread_.IsValid()); |
| 253 ASSERT(Thread::GetThreadLocal(thread_state_key) == NULL); | 253 ASSERT(!IsArchived()); |
| 254 ThreadState* state = ThreadState::GetFree(); | 254 ThreadState* state = ThreadState::GetFree(); |
| 255 state->Unlink(); | 255 state->Unlink(); |
| 256 Thread::SetThreadLocal(thread_state_key, reinterpret_cast<void*>(state)); | 256 Thread::SetThreadLocal(thread_state_key, reinterpret_cast<void*>(state)); |
| 257 lazily_archived_thread_.Initialize(ThreadHandle::SELF); | 257 lazily_archived_thread_.Initialize(ThreadHandle::SELF); |
| 258 lazily_archived_thread_state_ = state; | 258 lazily_archived_thread_state_ = state; |
| 259 ASSERT(state->id() == kInvalidId); | 259 ASSERT(state->id() == kInvalidId); |
| 260 state->set_id(CurrentId()); | 260 state->set_id(CurrentId()); |
| 261 ASSERT(state->id() != kInvalidId); | 261 ASSERT(state->id() != kInvalidId); |
| 262 } | 262 } |
| 263 | 263 |
| (...skipping 10 matching lines...) Expand all Loading... | |
| 274 to = Debug::ArchiveDebug(to); | 274 to = Debug::ArchiveDebug(to); |
| 275 #endif | 275 #endif |
| 276 to = StackGuard::ArchiveStackGuard(to); | 276 to = StackGuard::ArchiveStackGuard(to); |
| 277 to = RegExpStack::ArchiveStack(to); | 277 to = RegExpStack::ArchiveStack(to); |
| 278 to = Bootstrapper::ArchiveState(to); | 278 to = Bootstrapper::ArchiveState(to); |
| 279 lazily_archived_thread_.Initialize(ThreadHandle::INVALID); | 279 lazily_archived_thread_.Initialize(ThreadHandle::INVALID); |
| 280 lazily_archived_thread_state_ = NULL; | 280 lazily_archived_thread_state_ = NULL; |
| 281 } | 281 } |
| 282 | 282 |
| 283 | 283 |
| 284 bool ThreadManager::IsArchived() { | |
| 285 return Thread::HasThreadLocal(thread_state_key); | |
| 286 } | |
| 287 | |
| 288 | |
| 284 void ThreadManager::Iterate(ObjectVisitor* v) { | 289 void ThreadManager::Iterate(ObjectVisitor* v) { |
| 285 // Expecting no threads during serialization/deserialization | 290 // Expecting no threads during serialization/deserialization |
| 286 for (ThreadState* state = ThreadState::FirstInUse(); | 291 for (ThreadState* state = ThreadState::FirstInUse(); |
| 287 state != NULL; | 292 state != NULL; |
| 288 state = state->Next()) { | 293 state = state->Next()) { |
| 289 char* data = state->data(); | 294 char* data = state->data(); |
| 290 data = HandleScopeImplementer::Iterate(v, data); | 295 data = HandleScopeImplementer::Iterate(v, data); |
| 291 data = Top::Iterate(v, data); | 296 data = Top::Iterate(v, data); |
| 292 } | 297 } |
| 293 } | 298 } |
| (...skipping 20 matching lines...) Expand all Loading... | |
| 314 } | 319 } |
| 315 } | 320 } |
| 316 | 321 |
| 317 | 322 |
| 318 int ThreadManager::CurrentId() { | 323 int ThreadManager::CurrentId() { |
| 319 return Thread::GetThreadLocalInt(thread_id_key); | 324 return Thread::GetThreadLocalInt(thread_id_key); |
| 320 } | 325 } |
| 321 | 326 |
| 322 | 327 |
| 323 void ThreadManager::AssignId() { | 328 void ThreadManager::AssignId() { |
| 324 if (!Thread::HasThreadLocal(thread_id_key)) { | 329 if (!HasId()) { |
| 325 ASSERT(Locker::IsLocked()); | 330 ASSERT(Locker::IsLocked()); |
| 326 int thread_id = next_id_++; | 331 int thread_id = ++last_id_; |
|
Søren Thygesen Gjesse
2009/09/04 09:29:57
Maybe assert thread_id > 0.
Mikhail Naganov
2009/09/04 11:09:22
Done.
| |
| 327 Thread::SetThreadLocalInt(thread_id_key, thread_id); | 332 Thread::SetThreadLocalInt(thread_id_key, thread_id); |
| 328 Top::set_thread_id(thread_id); | 333 Top::set_thread_id(thread_id); |
| 329 } | 334 } |
| 330 } | 335 } |
| 331 | 336 |
| 332 | 337 |
| 338 bool ThreadManager::HasId() { | |
| 339 return Thread::HasThreadLocal(thread_id_key); | |
| 340 } | |
| 341 | |
| 342 | |
| 333 void ThreadManager::TerminateExecution(int thread_id) { | 343 void ThreadManager::TerminateExecution(int thread_id) { |
| 334 for (ThreadState* state = ThreadState::FirstInUse(); | 344 for (ThreadState* state = ThreadState::FirstInUse(); |
| 335 state != NULL; | 345 state != NULL; |
| 336 state = state->Next()) { | 346 state = state->Next()) { |
| 337 if (thread_id == state->id()) { | 347 if (thread_id == state->id()) { |
| 338 state->set_terminate_on_restore(true); | 348 state->set_terminate_on_restore(true); |
| 339 } | 349 } |
| 340 } | 350 } |
| 341 } | 351 } |
| 342 | 352 |
| (...skipping 54 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 397 // Acknowledge the preemption by the receiving thread. | 407 // Acknowledge the preemption by the receiving thread. |
| 398 void ContextSwitcher::PreemptionReceived() { | 408 void ContextSwitcher::PreemptionReceived() { |
| 399 ASSERT(Locker::IsLocked()); | 409 ASSERT(Locker::IsLocked()); |
| 400 // There is currently no accounting being done for this. But could be in the | 410 // There is currently no accounting being done for this. But could be in the |
| 401 // future, which is why we leave this in. | 411 // future, which is why we leave this in. |
| 402 } | 412 } |
| 403 | 413 |
| 404 | 414 |
| 405 } // namespace internal | 415 } // namespace internal |
| 406 } // namespace v8 | 416 } // namespace v8 |
| OLD | NEW |