Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 /* | 1 /* |
| 2 * Copyright (C) 2013 Google Inc. All rights reserved. | 2 * Copyright (C) 2013 Google Inc. All rights reserved. |
| 3 * | 3 * |
| 4 * Redistribution and use in source and binary forms, with or without | 4 * Redistribution and use in source and binary forms, with or without |
| 5 * modification, are permitted provided that the following conditions are | 5 * modification, are permitted provided that the following conditions are |
| 6 * met: | 6 * met: |
| 7 * | 7 * |
| 8 * * Redistributions of source code must retain the above copyright | 8 * * Redistributions of source code must retain the above copyright |
| 9 * notice, this list of conditions and the following disclaimer. | 9 * notice, this list of conditions and the following disclaimer. |
| 10 * * Redistributions in binary form must reproduce the above | 10 * * Redistributions in binary form must reproduce the above |
| (...skipping 16 matching lines...) Expand all Loading... | |
| 27 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE | 27 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
| 28 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | 28 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
| 29 */ | 29 */ |
| 30 | 30 |
| 31 #ifndef ThreadState_h | 31 #ifndef ThreadState_h |
| 32 #define ThreadState_h | 32 #define ThreadState_h |
| 33 | 33 |
| 34 #include "platform/PlatformExport.h" | 34 #include "platform/PlatformExport.h" |
| 35 #include "platform/heap/AddressSanitizer.h" | 35 #include "platform/heap/AddressSanitizer.h" |
| 36 #include "public/platform/WebThread.h" | 36 #include "public/platform/WebThread.h" |
| 37 #include "wtf/HashMap.h" | |
| 37 #include "wtf/HashSet.h" | 38 #include "wtf/HashSet.h" |
| 38 #include "wtf/OwnPtr.h" | 39 #include "wtf/OwnPtr.h" |
| 39 #include "wtf/PassOwnPtr.h" | 40 #include "wtf/PassOwnPtr.h" |
| 40 #include "wtf/ThreadSpecific.h" | 41 #include "wtf/ThreadSpecific.h" |
| 41 #include "wtf/Threading.h" | 42 #include "wtf/Threading.h" |
| 42 #include "wtf/ThreadingPrimitives.h" | 43 #include "wtf/ThreadingPrimitives.h" |
| 43 #include "wtf/Vector.h" | 44 #include "wtf/Vector.h" |
| 44 | 45 |
| 45 #if ENABLE(GC_PROFILE_HEAP) | |
| 46 #include "wtf/HashMap.h" | |
| 47 #endif | |
| 48 | |
| 49 namespace blink { | 46 namespace blink { |
| 50 | 47 |
| 51 class BaseHeap; | 48 class BaseHeap; |
| 52 class BaseHeapPage; | 49 class BaseHeapPage; |
| 53 class FinalizedHeapObjectHeader; | 50 class FinalizedHeapObjectHeader; |
| 54 struct GCInfo; | 51 struct GCInfo; |
| 55 class HeapContainsCache; | 52 class HeapContainsCache; |
| 56 class HeapObjectHeader; | 53 class HeapObjectHeader; |
| 57 class PageMemory; | 54 class PageMemory; |
| 58 class PersistentNode; | 55 class PersistentNode; |
| (...skipping 65 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 124 class Class; \ | 121 class Class; \ |
| 125 } \ | 122 } \ |
| 126 namespace blink { \ | 123 namespace blink { \ |
| 127 template<> struct ThreadingTrait<Namespace::Class> { \ | 124 template<> struct ThreadingTrait<Namespace::Class> { \ |
| 128 static const ThreadAffinity Affinity = AnyThread; \ | 125 static const ThreadAffinity Affinity = AnyThread; \ |
| 129 }; \ | 126 }; \ |
| 130 } | 127 } |
| 131 | 128 |
| 132 template<typename U> class ThreadingTrait<const U> : public ThreadingTrait<U> { }; | 129 template<typename U> class ThreadingTrait<const U> : public ThreadingTrait<U> { }; |
| 133 | 130 |
| 131 // Declare that a class has a pre-finalizer function. The function is called in | |
| 132 // the object's owner thread, and can access Member<>s to other | |
| 133 // garbarge-collected objects allocated in the thread. However we must not | |
| 134 // allocate new garbage-collected objects, and must not update Member<> and | |
|
haraken
2014/10/06 01:55:27
, and => nor
tkent
2014/10/06 05:01:43
Done.
| |
| 135 // Persistent<> pointers. | |
| 136 // | |
| 137 // See ThreadState::registerPreFinalizer. | |
| 138 // | |
| 139 // Usage: | |
| 140 // | |
| 141 // class Foo : GarbageCollected<Foo> { | |
| 142 // USING_PRE_FINALIZER(Foo, dispose); | |
| 143 // public: | |
| 144 // Foo() .... | |
| 145 // private: | |
| 146 // void dispose(); | |
| 147 // Member<Bar> m_bar; | |
| 148 // }; | |
| 149 // | |
| 150 // void Foo::dispose() | |
| 151 // { | |
| 152 // m_bar->... | |
| 153 // } | |
| 154 #define USING_PRE_FINALIZER(Class, method) \ | |
| 155 public: \ | |
| 156 static bool invokePreFinalier(void* object, Visitor& visitor) \ | |
|
haraken
2014/10/06 01:55:27
invokePreFinalier => invokePreFinalizer
tkent
2014/10/06 05:01:43
Done.
| |
| 157 { \ | |
| 158 Class* self = reinterpret_cast<Class*>(object); \ | |
| 159 if (visitor.isAlive(self)) \ | |
| 160 return false; \ | |
| 161 self->method(); \ | |
| 162 return true; \ | |
| 163 } \ | |
| 164 typedef char UsingPreFinazlizerMacroNeedsTrailingSemiColon | |
|
haraken
2014/10/06 01:55:27
What's this?
tkent
2014/10/06 05:01:43
This is an idiom to make ';' after USING_PRE_FINAL
| |
| 165 | |
| 134 // List of typed heaps. The list is used to generate the implementation | 166 // List of typed heaps. The list is used to generate the implementation |
| 135 // of typed heap related methods. | 167 // of typed heap related methods. |
| 136 // | 168 // |
| 137 // To create a new typed heap add a H(<ClassName>) to the | 169 // To create a new typed heap add a H(<ClassName>) to the |
| 138 // FOR_EACH_TYPED_HEAP macro below. | 170 // FOR_EACH_TYPED_HEAP macro below. |
| 139 #define FOR_EACH_TYPED_HEAP(H) \ | 171 #define FOR_EACH_TYPED_HEAP(H) \ |
| 140 H(Node) | 172 H(Node) |
| 141 | 173 |
| 142 #define TypedHeapEnumName(Type) Type##Heap, | 174 #define TypedHeapEnumName(Type) Type##Heap, |
| 143 #define TypedHeapEnumNameNonFinalized(Type) Type##HeapNonFinalized, | 175 #define TypedHeapEnumNameNonFinalized(Type) Type##HeapNonFinalized, |
| (...skipping 478 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 622 | 654 |
| 623 void getStats(HeapStats&); | 655 void getStats(HeapStats&); |
| 624 HeapStats& stats() { return m_stats; } | 656 HeapStats& stats() { return m_stats; } |
| 625 HeapStats& statsAfterLastGC() { return m_statsAfterLastGC; } | 657 HeapStats& statsAfterLastGC() { return m_statsAfterLastGC; } |
| 626 | 658 |
| 627 void setupHeapsForTermination(); | 659 void setupHeapsForTermination(); |
| 628 | 660 |
| 629 void registerSweepingTask(); | 661 void registerSweepingTask(); |
| 630 void unregisterSweepingTask(); | 662 void unregisterSweepingTask(); |
| 631 | 663 |
| 664 // Request to call a pref-finalizer function of the target object before the | |
|
haraken
2014/10/06 01:55:27
a pref-finalizer function => a pre-finalizer
tkent
2014/10/06 05:01:43
Done.
| |
| 665 // object is destructed. The class T must have USING_PRE_FINALIZER(). The | |
| 666 // argument should be |*this|. Registering a lot of objects affects GC | |
|
haraken
2014/10/06 01:55:27
Would it be possible to define registerPreFinalize
tkent
2014/10/06 05:01:43
It's not impossible, however I think it's not an i
haraken
2014/10/06 05:26:42
Makes sense.
| |
| 667 // performance. We should register an object only if the object really | |
| 668 // requires pre-finalizer, and we should unregister the object if | |
| 669 // pre-finalizer is unnecessary. | |
| 670 template<typename T> | |
| 671 void registerPreFinalizer(T& target) | |
| 672 { | |
| 673 ASSERT(!m_preFinalizers.contains(&target)); | |
| 674 ASSERT(!isSweepInProgress()); | |
| 675 m_preFinalizers.add(&target, &T::invokePreFinalier); | |
| 676 } | |
| 677 // Cancel above requests. The argument should be |*this|. This function is | |
| 678 // ignored if it is called in pre-finalizer functions. | |
| 679 template<typename T> | |
| 680 void unregisterPreFinalizer(T& target) | |
| 681 { | |
| 682 ASSERT(&T::invokePreFinalier); | |
| 683 unregisterPreFinalizerInternal(&target); | |
| 684 } | |
| 685 | |
| 632 Mutex& sweepMutex() { return m_sweepMutex; } | 686 Mutex& sweepMutex() { return m_sweepMutex; } |
| 633 | 687 |
| 634 private: | 688 private: |
| 635 explicit ThreadState(); | 689 explicit ThreadState(); |
| 636 ~ThreadState(); | 690 ~ThreadState(); |
| 637 | 691 |
| 638 friend class SafePointBarrier; | 692 friend class SafePointBarrier; |
| 639 friend class SafePointAwareMutexLocker; | 693 friend class SafePointAwareMutexLocker; |
| 640 | 694 |
| 641 void enterSafePoint(StackState, void*); | 695 void enterSafePoint(StackState, void*); |
| (...skipping 18 matching lines...) Expand all Loading... | |
| 660 // to sweep away any objects that are left on this heap. | 714 // to sweep away any objects that are left on this heap. |
| 661 // We assert that nothing must remain after this cleanup. | 715 // We assert that nothing must remain after this cleanup. |
| 662 // If assertion does not hold we crash as we are potentially | 716 // If assertion does not hold we crash as we are potentially |
| 663 // in the dangling pointer situation. | 717 // in the dangling pointer situation. |
| 664 void cleanup(); | 718 void cleanup(); |
| 665 void cleanupPages(); | 719 void cleanupPages(); |
| 666 | 720 |
| 667 void setLowCollectionRate(bool value) { m_lowCollectionRate = value; } | 721 void setLowCollectionRate(bool value) { m_lowCollectionRate = value; } |
| 668 | 722 |
| 669 void waitUntilSweepersDone(); | 723 void waitUntilSweepersDone(); |
| 724 void unregisterPreFinalizerInternal(void*); | |
| 725 void invokePreFinalizers(Visitor&); | |
| 670 | 726 |
| 671 static WTF::ThreadSpecific<ThreadState*>* s_threadSpecific; | 727 static WTF::ThreadSpecific<ThreadState*>* s_threadSpecific; |
| 672 static SafePointBarrier* s_safePointBarrier; | 728 static SafePointBarrier* s_safePointBarrier; |
| 673 | 729 |
| 674 // This variable is flipped to true after all threads are stoped | 730 // This variable is flipped to true after all threads are stoped |
| 675 // and outermost GC has started. | 731 // and outermost GC has started. |
| 676 static bool s_inGC; | 732 static bool s_inGC; |
| 677 | 733 |
| 678 // We can't create a static member of type ThreadState here | 734 // We can't create a static member of type ThreadState here |
| 679 // because it will introduce global constructor and destructor. | 735 // because it will introduce global constructor and destructor. |
| (...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 711 bool m_isTerminating; | 767 bool m_isTerminating; |
| 712 | 768 |
| 713 bool m_lowCollectionRate; | 769 bool m_lowCollectionRate; |
| 714 | 770 |
| 715 OwnPtr<blink::WebThread> m_sweeperThread; | 771 OwnPtr<blink::WebThread> m_sweeperThread; |
| 716 int m_numberOfSweeperTasks; | 772 int m_numberOfSweeperTasks; |
| 717 Mutex m_sweepMutex; | 773 Mutex m_sweepMutex; |
| 718 ThreadCondition m_sweepThreadCondition; | 774 ThreadCondition m_sweepThreadCondition; |
| 719 | 775 |
| 720 CallbackStack* m_weakCallbackStack; | 776 CallbackStack* m_weakCallbackStack; |
| 777 HashMap<void*, bool (*)(void*, Visitor&)> m_preFinalizers; | |
|
haraken
2014/10/06 01:55:28
Can we add an assertion to verify that m_preFinali
tkent
2014/10/06 05:01:43
Done.
| |
| 721 | 778 |
| 722 #if defined(ADDRESS_SANITIZER) | 779 #if defined(ADDRESS_SANITIZER) |
| 723 void* m_asanFakeStack; | 780 void* m_asanFakeStack; |
| 724 #endif | 781 #endif |
| 725 }; | 782 }; |
| 726 | 783 |
| 727 template<ThreadAffinity affinity> class ThreadStateFor; | 784 template<ThreadAffinity affinity> class ThreadStateFor; |
| 728 | 785 |
| 729 template<> class ThreadStateFor<MainThreadOnly> { | 786 template<> class ThreadStateFor<MainThreadOnly> { |
| 730 public: | 787 public: |
| (...skipping 116 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 847 // whether the page is part of a terminting thread or | 904 // whether the page is part of a terminting thread or |
| 848 // if the page is traced after being terminated (orphaned). | 905 // if the page is traced after being terminated (orphaned). |
| 849 uintptr_t m_terminating : 1; | 906 uintptr_t m_terminating : 1; |
| 850 uintptr_t m_tracedAfterOrphaned : 1; | 907 uintptr_t m_tracedAfterOrphaned : 1; |
| 851 uintptr_t m_promptlyFreedSize : 17; // == blinkPageSizeLog2 | 908 uintptr_t m_promptlyFreedSize : 17; // == blinkPageSizeLog2 |
| 852 }; | 909 }; |
| 853 | 910 |
| 854 } | 911 } |
| 855 | 912 |
| 856 #endif // ThreadState_h | 913 #endif // ThreadState_h |
| OLD | NEW |