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

Side by Side Diff: src/isolate.cc

Issue 9959093: Merged r11194, r11198, r11201, r11214 into trunk branch. (Closed) Base URL: https://v8.googlecode.com/svn/trunk
Patch Set: Created 8 years, 8 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 unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « src/isolate.h ('k') | src/lazy-instance.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright 2012 the V8 project authors. All rights reserved. 1 // Copyright 2012 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 20 matching lines...) Expand all
31 31
32 #include "ast.h" 32 #include "ast.h"
33 #include "bootstrapper.h" 33 #include "bootstrapper.h"
34 #include "codegen.h" 34 #include "codegen.h"
35 #include "compilation-cache.h" 35 #include "compilation-cache.h"
36 #include "debug.h" 36 #include "debug.h"
37 #include "deoptimizer.h" 37 #include "deoptimizer.h"
38 #include "heap-profiler.h" 38 #include "heap-profiler.h"
39 #include "hydrogen.h" 39 #include "hydrogen.h"
40 #include "isolate.h" 40 #include "isolate.h"
41 #include "lazy-instance.h"
42 #include "lithium-allocator.h" 41 #include "lithium-allocator.h"
43 #include "log.h" 42 #include "log.h"
44 #include "messages.h" 43 #include "messages.h"
45 #include "platform.h" 44 #include "platform.h"
46 #include "regexp-stack.h" 45 #include "regexp-stack.h"
47 #include "runtime-profiler.h" 46 #include "runtime-profiler.h"
48 #include "scopeinfo.h" 47 #include "scopeinfo.h"
49 #include "serialize.h" 48 #include "serialize.h"
50 #include "simulator.h" 49 #include "simulator.h"
51 #include "spaces.h" 50 #include "spaces.h"
52 #include "stub-cache.h" 51 #include "stub-cache.h"
53 #include "version.h" 52 #include "version.h"
54 #include "vm-state-inl.h" 53 #include "vm-state-inl.h"
55 54
56 55
57 namespace v8 { 56 namespace v8 {
58 namespace internal { 57 namespace internal {
59 58
60 struct GlobalState {
61 Thread::LocalStorageKey per_isolate_thread_data_key;
62 Thread::LocalStorageKey isolate_key;
63 Thread::LocalStorageKey thread_id_key;
64 Isolate* default_isolate;
65 Isolate::ThreadDataTable* thread_data_table;
66 Mutex* mutex;
67 };
68
69 struct InitializeGlobalState {
70 static void Construct(GlobalState* state) {
71 state->isolate_key = Thread::CreateThreadLocalKey();
72 state->thread_id_key = Thread::CreateThreadLocalKey();
73 state->per_isolate_thread_data_key = Thread::CreateThreadLocalKey();
74 state->thread_data_table = new Isolate::ThreadDataTable();
75 state->default_isolate = new Isolate();
76 state->mutex = OS::CreateMutex();
77 // Can't use SetIsolateThreadLocals(default_isolate_, NULL) here
78 // because a non-null thread data may be already set.
79 Thread::SetThreadLocal(state->isolate_key, state->default_isolate);
80 }
81 };
82
83 static LazyInstance<GlobalState, InitializeGlobalState>::type global_state;
84
85 Atomic32 ThreadId::highest_thread_id_ = 0; 59 Atomic32 ThreadId::highest_thread_id_ = 0;
86 60
87 int ThreadId::AllocateThreadId() { 61 int ThreadId::AllocateThreadId() {
88 int new_id = NoBarrier_AtomicIncrement(&highest_thread_id_, 1); 62 int new_id = NoBarrier_AtomicIncrement(&highest_thread_id_, 1);
89 return new_id; 63 return new_id;
90 } 64 }
91 65
92 66
93 int ThreadId::GetCurrentThreadId() { 67 int ThreadId::GetCurrentThreadId() {
94 const GlobalState& global = global_state.Get(); 68 int thread_id = Thread::GetThreadLocalInt(Isolate::thread_id_key_);
95 int thread_id = Thread::GetThreadLocalInt(global.thread_id_key);
96 if (thread_id == 0) { 69 if (thread_id == 0) {
97 thread_id = AllocateThreadId(); 70 thread_id = AllocateThreadId();
98 Thread::SetThreadLocalInt(global.thread_id_key, thread_id); 71 Thread::SetThreadLocalInt(Isolate::thread_id_key_, thread_id);
99 } 72 }
100 return thread_id; 73 return thread_id;
101 } 74 }
102 75
103 76
104 ThreadLocalTop::ThreadLocalTop() { 77 ThreadLocalTop::ThreadLocalTop() {
105 InitializeInternal(); 78 InitializeInternal();
106 // This flag may be set using v8::V8::IgnoreOutOfMemoryException() 79 // This flag may be set using v8::V8::IgnoreOutOfMemoryException()
107 // before an isolate is initialized. The initialize methods below do 80 // before an isolate is initialized. The initialize methods below do
108 // not touch it to preserve its value. 81 // not touch it to preserve its value.
(...skipping 223 matching lines...) Expand 10 before | Expand all | Expand 10 after
332 FreeStoreAllocationPolicy::Delete(p); 305 FreeStoreAllocationPolicy::Delete(p);
333 return; 306 return;
334 } 307 }
335 PreallocatedStorage* storage = reinterpret_cast<PreallocatedStorage*>(p) - 1; 308 PreallocatedStorage* storage = reinterpret_cast<PreallocatedStorage*>(p) - 1;
336 ASSERT(storage->next_->previous_ == storage); 309 ASSERT(storage->next_->previous_ == storage);
337 ASSERT(storage->previous_->next_ == storage); 310 ASSERT(storage->previous_->next_ == storage);
338 storage->Unlink(); 311 storage->Unlink();
339 storage->LinkTo(&free_list_); 312 storage->LinkTo(&free_list_);
340 } 313 }
341 314
315 Isolate* Isolate::default_isolate_ = NULL;
316 Thread::LocalStorageKey Isolate::isolate_key_;
317 Thread::LocalStorageKey Isolate::thread_id_key_;
318 Thread::LocalStorageKey Isolate::per_isolate_thread_data_key_;
319 Mutex* Isolate::process_wide_mutex_ = OS::CreateMutex();
320 Isolate::ThreadDataTable* Isolate::thread_data_table_ = NULL;
321
322
342 Isolate::PerIsolateThreadData* Isolate::AllocatePerIsolateThreadData( 323 Isolate::PerIsolateThreadData* Isolate::AllocatePerIsolateThreadData(
343 ThreadId thread_id) { 324 ThreadId thread_id) {
344 ASSERT(!thread_id.Equals(ThreadId::Invalid())); 325 ASSERT(!thread_id.Equals(ThreadId::Invalid()));
345 PerIsolateThreadData* per_thread = new PerIsolateThreadData(this, thread_id); 326 PerIsolateThreadData* per_thread = new PerIsolateThreadData(this, thread_id);
346 { 327 {
347 GlobalState* const global = global_state.Pointer(); 328 ScopedLock lock(process_wide_mutex_);
348 ScopedLock lock(global->mutex); 329 ASSERT(thread_data_table_->Lookup(this, thread_id) == NULL);
349 ASSERT(global->thread_data_table->Lookup(this, thread_id) == NULL); 330 thread_data_table_->Insert(per_thread);
350 global->thread_data_table->Insert(per_thread); 331 ASSERT(thread_data_table_->Lookup(this, thread_id) == per_thread);
351 ASSERT(global->thread_data_table->Lookup(this, thread_id) == per_thread);
352 } 332 }
353 return per_thread; 333 return per_thread;
354 } 334 }
355 335
356 336
357 Isolate::PerIsolateThreadData* 337 Isolate::PerIsolateThreadData*
358 Isolate::FindOrAllocatePerThreadDataForThisThread() { 338 Isolate::FindOrAllocatePerThreadDataForThisThread() {
359 ThreadId thread_id = ThreadId::Current(); 339 ThreadId thread_id = ThreadId::Current();
360 PerIsolateThreadData* per_thread = NULL; 340 PerIsolateThreadData* per_thread = NULL;
361 { 341 {
362 GlobalState* const global = global_state.Pointer(); 342 ScopedLock lock(process_wide_mutex_);
363 ScopedLock lock(global->mutex); 343 per_thread = thread_data_table_->Lookup(this, thread_id);
364 per_thread = global->thread_data_table->Lookup(this, thread_id);
365 if (per_thread == NULL) { 344 if (per_thread == NULL) {
366 per_thread = AllocatePerIsolateThreadData(thread_id); 345 per_thread = AllocatePerIsolateThreadData(thread_id);
367 } 346 }
368 } 347 }
369 return per_thread; 348 return per_thread;
370 } 349 }
371 350
372 351
373 Isolate::PerIsolateThreadData* Isolate::FindPerThreadDataForThisThread() { 352 Isolate::PerIsolateThreadData* Isolate::FindPerThreadDataForThisThread() {
374 ThreadId thread_id = ThreadId::Current(); 353 ThreadId thread_id = ThreadId::Current();
375 PerIsolateThreadData* per_thread = NULL; 354 PerIsolateThreadData* per_thread = NULL;
376 { 355 {
377 GlobalState* const global = global_state.Pointer(); 356 ScopedLock lock(process_wide_mutex_);
378 ScopedLock lock(global->mutex); 357 per_thread = thread_data_table_->Lookup(this, thread_id);
379 per_thread = global->thread_data_table->Lookup(this, thread_id);
380 } 358 }
381 return per_thread; 359 return per_thread;
382 } 360 }
383 361
384 362
385 bool Isolate::IsDefaultIsolate() const {
386 return this == global_state.Get().default_isolate;
387 }
388
389
390 void Isolate::EnsureDefaultIsolate() { 363 void Isolate::EnsureDefaultIsolate() {
391 GlobalState* const global = global_state.Pointer(); 364 ScopedLock lock(process_wide_mutex_);
365 if (default_isolate_ == NULL) {
366 isolate_key_ = Thread::CreateThreadLocalKey();
367 thread_id_key_ = Thread::CreateThreadLocalKey();
368 per_isolate_thread_data_key_ = Thread::CreateThreadLocalKey();
369 thread_data_table_ = new Isolate::ThreadDataTable();
370 default_isolate_ = new Isolate();
371 }
392 // Can't use SetIsolateThreadLocals(default_isolate_, NULL) here 372 // Can't use SetIsolateThreadLocals(default_isolate_, NULL) here
393 // because a non-null thread data may be already set. 373 // because a non-null thread data may be already set.
394 if (Thread::GetThreadLocal(global->isolate_key) == NULL) { 374 if (Thread::GetThreadLocal(isolate_key_) == NULL) {
395 Thread::SetThreadLocal(global->isolate_key, global->default_isolate); 375 Thread::SetThreadLocal(isolate_key_, default_isolate_);
396 } 376 }
397 } 377 }
398 378
379 struct StaticInitializer {
380 StaticInitializer() {
381 Isolate::EnsureDefaultIsolate();
382 }
383 } static_initializer;
399 384
400 #ifdef ENABLE_DEBUGGER_SUPPORT 385 #ifdef ENABLE_DEBUGGER_SUPPORT
401 Debugger* Isolate::GetDefaultIsolateDebugger() { 386 Debugger* Isolate::GetDefaultIsolateDebugger() {
402 EnsureDefaultIsolate(); 387 EnsureDefaultIsolate();
403 return global_state.Pointer()->default_isolate->debugger(); 388 return default_isolate_->debugger();
404 } 389 }
405 #endif 390 #endif
406 391
407 392
408 StackGuard* Isolate::GetDefaultIsolateStackGuard() { 393 StackGuard* Isolate::GetDefaultIsolateStackGuard() {
409 EnsureDefaultIsolate(); 394 EnsureDefaultIsolate();
410 return global_state.Pointer()->default_isolate->stack_guard(); 395 return default_isolate_->stack_guard();
411 }
412
413
414 Thread::LocalStorageKey Isolate::isolate_key() {
415 return global_state.Get().isolate_key;
416 }
417
418
419 Thread::LocalStorageKey Isolate::thread_id_key() {
420 return global_state.Get().thread_id_key;
421 }
422
423
424 Thread::LocalStorageKey Isolate::per_isolate_thread_data_key() {
425 return global_state.Get().per_isolate_thread_data_key;
426 } 396 }
427 397
428 398
429 void Isolate::EnterDefaultIsolate() { 399 void Isolate::EnterDefaultIsolate() {
430 EnsureDefaultIsolate(); 400 EnsureDefaultIsolate();
431 Isolate* const default_isolate = global_state.Pointer()->default_isolate; 401 ASSERT(default_isolate_ != NULL);
432 ASSERT(default_isolate != NULL);
433 402
434 PerIsolateThreadData* data = CurrentPerIsolateThreadData(); 403 PerIsolateThreadData* data = CurrentPerIsolateThreadData();
435 // If not yet in default isolate - enter it. 404 // If not yet in default isolate - enter it.
436 if (data == NULL || data->isolate() != default_isolate) { 405 if (data == NULL || data->isolate() != default_isolate_) {
437 default_isolate->Enter(); 406 default_isolate_->Enter();
438 } 407 }
439 } 408 }
440 409
441 410
442 Isolate* Isolate::GetDefaultIsolateForLocking() { 411 Isolate* Isolate::GetDefaultIsolateForLocking() {
443 EnsureDefaultIsolate(); 412 EnsureDefaultIsolate();
444 return global_state.Pointer()->default_isolate; 413 return default_isolate_;
445 } 414 }
446 415
447 416
448 Address Isolate::get_address_from_id(Isolate::AddressId id) { 417 Address Isolate::get_address_from_id(Isolate::AddressId id) {
449 return isolate_addresses_[id]; 418 return isolate_addresses_[id];
450 } 419 }
451 420
452 421
453 char* Isolate::Iterate(ObjectVisitor* v, char* thread_storage) { 422 char* Isolate::Iterate(ObjectVisitor* v, char* thread_storage) {
454 ThreadLocalTop* thread = reinterpret_cast<ThreadLocalTop*>(thread_storage); 423 ThreadLocalTop* thread = reinterpret_cast<ThreadLocalTop*>(thread_storage);
(...skipping 1102 matching lines...) Expand 10 before | Expand all | Expand 10 after
1557 // Temporarily set this isolate as current so that various parts of 1526 // Temporarily set this isolate as current so that various parts of
1558 // the isolate can access it in their destructors without having a 1527 // the isolate can access it in their destructors without having a
1559 // direct pointer. We don't use Enter/Exit here to avoid 1528 // direct pointer. We don't use Enter/Exit here to avoid
1560 // initializing the thread data. 1529 // initializing the thread data.
1561 PerIsolateThreadData* saved_data = CurrentPerIsolateThreadData(); 1530 PerIsolateThreadData* saved_data = CurrentPerIsolateThreadData();
1562 Isolate* saved_isolate = UncheckedCurrent(); 1531 Isolate* saved_isolate = UncheckedCurrent();
1563 SetIsolateThreadLocals(this, NULL); 1532 SetIsolateThreadLocals(this, NULL);
1564 1533
1565 Deinit(); 1534 Deinit();
1566 1535
1567 { ScopedLock lock(global_state.Pointer()->mutex); 1536 { ScopedLock lock(process_wide_mutex_);
1568 global_state.Pointer()->thread_data_table->RemoveAllThreads(this); 1537 thread_data_table_->RemoveAllThreads(this);
1569 } 1538 }
1570 1539
1571 if (!IsDefaultIsolate()) { 1540 if (!IsDefaultIsolate()) {
1572 delete this; 1541 delete this;
1573 } 1542 }
1574 1543
1575 // Restore the previous current isolate. 1544 // Restore the previous current isolate.
1576 SetIsolateThreadLocals(saved_isolate, saved_data); 1545 SetIsolateThreadLocals(saved_isolate, saved_data);
1577 } 1546 }
1578 1547
(...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after
1611 logger_->TearDown(); 1580 logger_->TearDown();
1612 1581
1613 // The default isolate is re-initializable due to legacy API. 1582 // The default isolate is re-initializable due to legacy API.
1614 state_ = UNINITIALIZED; 1583 state_ = UNINITIALIZED;
1615 } 1584 }
1616 } 1585 }
1617 1586
1618 1587
1619 void Isolate::SetIsolateThreadLocals(Isolate* isolate, 1588 void Isolate::SetIsolateThreadLocals(Isolate* isolate,
1620 PerIsolateThreadData* data) { 1589 PerIsolateThreadData* data) {
1621 const GlobalState& global = global_state.Get(); 1590 Thread::SetThreadLocal(isolate_key_, isolate);
1622 Thread::SetThreadLocal(global.isolate_key, isolate); 1591 Thread::SetThreadLocal(per_isolate_thread_data_key_, data);
1623 Thread::SetThreadLocal(global.per_isolate_thread_data_key, data);
1624 } 1592 }
1625 1593
1626 1594
1627 Isolate::~Isolate() { 1595 Isolate::~Isolate() {
1628 TRACE_ISOLATE(destructor); 1596 TRACE_ISOLATE(destructor);
1629 1597
1630 // Has to be called while counters_ are still alive. 1598 // Has to be called while counters_ are still alive.
1631 zone_.DeleteKeptSegment(); 1599 zone_.DeleteKeptSegment();
1632 1600
1633 delete[] assembler_spare_buffer_; 1601 delete[] assembler_spare_buffer_;
(...skipping 339 matching lines...) Expand 10 before | Expand all | Expand 10 after
1973 1941
1974 #ifdef DEBUG 1942 #ifdef DEBUG
1975 #define ISOLATE_FIELD_OFFSET(type, name, ignored) \ 1943 #define ISOLATE_FIELD_OFFSET(type, name, ignored) \
1976 const intptr_t Isolate::name##_debug_offset_ = OFFSET_OF(Isolate, name##_); 1944 const intptr_t Isolate::name##_debug_offset_ = OFFSET_OF(Isolate, name##_);
1977 ISOLATE_INIT_LIST(ISOLATE_FIELD_OFFSET) 1945 ISOLATE_INIT_LIST(ISOLATE_FIELD_OFFSET)
1978 ISOLATE_INIT_ARRAY_LIST(ISOLATE_FIELD_OFFSET) 1946 ISOLATE_INIT_ARRAY_LIST(ISOLATE_FIELD_OFFSET)
1979 #undef ISOLATE_FIELD_OFFSET 1947 #undef ISOLATE_FIELD_OFFSET
1980 #endif 1948 #endif
1981 1949
1982 } } // namespace v8::internal 1950 } } // namespace v8::internal
OLDNEW
« no previous file with comments | « src/isolate.h ('k') | src/lazy-instance.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698