| OLD | NEW |
| 1 // Copyright 2015 the V8 project authors. All rights reserved. | 1 // Copyright 2015 the V8 project authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #ifndef V8_HEAP_ARRAY_BUFFER_TRACKER_H_ | 5 #ifndef V8_HEAP_ARRAY_BUFFER_TRACKER_H_ |
| 6 #define V8_HEAP_ARRAY_BUFFER_TRACKER_H_ | 6 #define V8_HEAP_ARRAY_BUFFER_TRACKER_H_ |
| 7 | 7 |
| 8 #include <map> | 8 #include <map> |
| 9 | 9 |
| 10 #include "src/base/platform/mutex.h" | 10 #include "src/base/platform/mutex.h" |
| 11 #include "src/globals.h" | 11 #include "src/globals.h" |
| 12 | 12 |
| 13 namespace v8 { | 13 namespace v8 { |
| 14 namespace internal { | 14 namespace internal { |
| 15 | 15 |
| 16 // Forward declarations. | 16 // Forward declarations. |
| 17 class Heap; | 17 class Heap; |
| 18 class Page; | |
| 19 class JSArrayBuffer; | 18 class JSArrayBuffer; |
| 20 | 19 |
| 21 // LocalArrayBufferTracker is tracker for live and dead JSArrayBuffer objects. | |
| 22 // | |
| 23 // It consists of two sets, a live, and a not yet discovered set of buffers. | |
| 24 // Upon registration (in the ArrayBufferTracker) the buffers are added to both | |
| 25 // sets. When a buffer is encountered as live (or added is live) it is removed | |
| 26 // from the not yet discovered set. Finally, after each round (sometime during | |
| 27 // GC) the left over not yet discovered buffers are cleaned up. Upon starting | |
| 28 // a new round the not yet discovered buffers are initialized from the live set. | |
| 29 // | |
| 30 // Caveats: | |
| 31 // - Between cleaning up the buffers using |Free| we always need a |Reset| and | |
| 32 // thus another marking phase. | |
| 33 // - LocalArrayBufferTracker is completely unlocked. Calls need to ensure | |
| 34 // exclusive access. | |
| 35 class LocalArrayBufferTracker { | |
| 36 public: | |
| 37 typedef std::pair<void*, size_t> Value; | |
| 38 typedef JSArrayBuffer* Key; | |
| 39 | |
| 40 enum LivenessIndicator { kForwardingPointer, kMarkBit }; | |
| 41 enum CallbackResult { kKeepEntry, kKeepAndUpdateEntry, kRemoveEntry }; | |
| 42 | |
| 43 explicit LocalArrayBufferTracker(Heap* heap) : heap_(heap), started_(false) {} | |
| 44 ~LocalArrayBufferTracker(); | |
| 45 | |
| 46 void Add(Key key, const Value& value); | |
| 47 void AddLive(Key key, const Value& value); | |
| 48 Value Remove(Key key); | |
| 49 void MarkLive(Key key); | |
| 50 bool IsEmpty(); | |
| 51 | |
| 52 // Resets the tracking set, i.e., not yet discovered buffers are initialized | |
| 53 // from the remaining live set of buffers. | |
| 54 void Reset(); | |
| 55 | |
| 56 // Frees up any dead backing stores of not yet discovered array buffers. | |
| 57 // Requires that the buffers have been properly marked using MarkLive. | |
| 58 void FreeDead(); | |
| 59 | |
| 60 // Scans the whole tracker and decides based on liveness_indicator whether | |
| 61 // a JSArrayBuffer is still considered live. | |
| 62 template <LivenessIndicator liveness_indicator> | |
| 63 inline void ScanAndFreeDead(); | |
| 64 | |
| 65 bool IsTracked(Key key) { return live_.find(key) != live_.end(); } | |
| 66 | |
| 67 base::Mutex* mutex() { return &mutex_; } | |
| 68 | |
| 69 private: | |
| 70 // TODO(mlippautz): Switch to unordered_map once it is supported on all | |
| 71 // platforms. | |
| 72 typedef std::map<Key, Value> TrackingMap; | |
| 73 | |
| 74 // Processes buffers one by one. The CallbackResult decides whether the buffer | |
| 75 // will be dropped or not. | |
| 76 // | |
| 77 // Callback should be of type: | |
| 78 // CallbackResult fn(JSArrayBuffer*, JSArrayBuffer**); | |
| 79 template <typename Callback> | |
| 80 inline void Process(Callback callback); | |
| 81 | |
| 82 Heap* heap_; | |
| 83 base::Mutex mutex_; | |
| 84 | |
| 85 // |live_| maps tracked JSArrayBuffers to the internally allocated backing | |
| 86 // store and length. For each GC round |not_yet_discovered_| is initialized | |
| 87 // as a copy of |live_|. Upon finding a JSArrayBuffer during GC, the buffer | |
| 88 // is removed from |not_yet_discovered_|. At the end of a GC, we free up the | |
| 89 // remaining JSArrayBuffers in |not_yet_discovered_|. | |
| 90 TrackingMap live_; | |
| 91 TrackingMap not_yet_discovered_; | |
| 92 | |
| 93 bool started_; | |
| 94 }; | |
| 95 | |
| 96 class ArrayBufferTracker { | 20 class ArrayBufferTracker { |
| 97 public: | 21 public: |
| 98 explicit ArrayBufferTracker(Heap* heap) : heap_(heap) {} | 22 explicit ArrayBufferTracker(Heap* heap) : heap_(heap) {} |
| 99 ~ArrayBufferTracker(); | 23 ~ArrayBufferTracker(); |
| 100 | 24 |
| 25 inline Heap* heap() { return heap_; } |
| 26 |
| 101 // The following methods are used to track raw C++ pointers to externally | 27 // The following methods are used to track raw C++ pointers to externally |
| 102 // allocated memory used as backing store in live array buffers. | 28 // allocated memory used as backing store in live array buffers. |
| 103 | 29 |
| 104 // Register/unregister a new JSArrayBuffer |buffer| for tracking. | 30 // A new ArrayBuffer was created with |data| as backing store. |
| 105 void RegisterNew(JSArrayBuffer* buffer); | 31 void RegisterNew(JSArrayBuffer* buffer); |
| 32 |
| 33 // The backing store |data| is no longer owned by V8. |
| 106 void Unregister(JSArrayBuffer* buffer); | 34 void Unregister(JSArrayBuffer* buffer); |
| 107 | 35 |
| 108 // Frees all backing store pointers for dead JSArrayBuffers in new space. | 36 // A live ArrayBuffer was discovered during marking/scavenge. |
| 109 void FreeDeadInNewSpace(); | |
| 110 | |
| 111 void FreeDead(Page* page); | |
| 112 | |
| 113 template <LocalArrayBufferTracker::LivenessIndicator liveness_indicator> | |
| 114 void ScanAndFreeDeadArrayBuffers(Page* page); | |
| 115 | |
| 116 // A live JSArrayBuffer was discovered during marking. | |
| 117 void MarkLive(JSArrayBuffer* buffer); | 37 void MarkLive(JSArrayBuffer* buffer); |
| 118 | 38 |
| 119 // Resets all trackers in old space. Is required to be called from the main | 39 // Frees all backing store pointers that weren't discovered in the previous |
| 120 // thread. | 40 // marking or scavenge phase. |
| 121 void ResetTrackersInOldSpace(); | 41 void FreeDead(bool from_scavenge); |
| 42 |
| 43 // Prepare for a new scavenge phase. A new marking phase is implicitly |
| 44 // prepared by finishing the previous one. |
| 45 void PrepareDiscoveryInNewSpace(); |
| 46 |
| 47 // An ArrayBuffer moved from new space to old space. |
| 48 void Promote(JSArrayBuffer* buffer); |
| 122 | 49 |
| 123 private: | 50 private: |
| 51 base::Mutex mutex_; |
| 124 Heap* heap_; | 52 Heap* heap_; |
| 53 |
| 54 // |live_array_buffers_| maps externally allocated memory used as backing |
| 55 // store for ArrayBuffers to the length of the respective memory blocks. |
| 56 // |
| 57 // At the beginning of mark/compact, |not_yet_discovered_array_buffers_| is |
| 58 // a copy of |live_array_buffers_| and we remove pointers as we discover live |
| 59 // ArrayBuffer objects during marking. At the end of mark/compact, the |
| 60 // remaining memory blocks can be freed. |
| 61 std::map<void*, size_t> live_array_buffers_; |
| 62 std::map<void*, size_t> not_yet_discovered_array_buffers_; |
| 63 |
| 64 // To be able to free memory held by ArrayBuffers during scavenge as well, we |
| 65 // have a separate list of allocated memory held by ArrayBuffers in new space. |
| 66 // |
| 67 // Since mark/compact also evacuates the new space, all pointers in the |
| 68 // |live_array_buffers_for_scavenge_| list are also in the |
| 69 // |live_array_buffers_| list. |
| 70 std::map<void*, size_t> live_array_buffers_for_scavenge_; |
| 71 std::map<void*, size_t> not_yet_discovered_array_buffers_for_scavenge_; |
| 125 }; | 72 }; |
| 126 | |
| 127 } // namespace internal | 73 } // namespace internal |
| 128 } // namespace v8 | 74 } // namespace v8 |
| 129 #endif // V8_HEAP_ARRAY_BUFFER_TRACKER_H_ | 75 #endif // V8_HEAP_ARRAY_BUFFER_TRACKER_H_ |
| OLD | NEW |