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

Side by Side Diff: components/discardable_memory/service/discardable_shared_memory_manager.h

Issue 2485623002: discardable_memory: Using mojo IPC to replace Chrome IPC (Closed)
Patch Set: Rebase Created 4 years, 1 month 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
OLDNEW
1 // Copyright 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 The Chromium 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 COMPONENTS_DISCARDABLE_MEMORY_SERVICE_DISCARDABLE_SHARED_MEMORY_MANAGER_ H_ 5 #ifndef COMPONENTS_DISCARDABLE_MEMORY_SERVICE_DISCARDABLE_SHARED_MEMORY_MANAGER_ H_
6 #define COMPONENTS_DISCARDABLE_MEMORY_SERVICE_DISCARDABLE_SHARED_MEMORY_MANAGER_ H_ 6 #define COMPONENTS_DISCARDABLE_MEMORY_SERVICE_DISCARDABLE_SHARED_MEMORY_MANAGER_ H_
7 7
8 #include <stddef.h> 8 #include <stddef.h>
9 #include <stdint.h> 9 #include <stdint.h>
10 10
11 #include <memory> 11 #include <memory>
12 #include <vector> 12 #include <vector>
13 13
14 #include "base/callback.h" 14 #include "base/callback.h"
15 #include "base/containers/hash_tables.h" 15 #include "base/containers/hash_tables.h"
16 #include "base/format_macros.h" 16 #include "base/format_macros.h"
17 #include "base/macros.h" 17 #include "base/macros.h"
18 #include "base/memory/discardable_memory_allocator.h" 18 #include "base/memory/discardable_memory_allocator.h"
19 #include "base/memory/discardable_shared_memory.h" 19 #include "base/memory/discardable_shared_memory.h"
20 #include "base/memory/memory_coordinator_client.h" 20 #include "base/memory/memory_coordinator_client.h"
21 #include "base/memory/memory_pressure_listener.h" 21 #include "base/memory/memory_pressure_listener.h"
22 #include "base/memory/ref_counted.h" 22 #include "base/memory/ref_counted.h"
23 #include "base/memory/shared_memory.h" 23 #include "base/memory/shared_memory.h"
24 #include "base/memory/weak_ptr.h" 24 #include "base/memory/weak_ptr.h"
25 #include "base/process/process_handle.h" 25 #include "base/process/process_handle.h"
26 #include "base/synchronization/lock.h" 26 #include "base/synchronization/lock.h"
27 #include "base/threading/thread_task_runner_handle.h" 27 #include "base/threading/thread_task_runner_handle.h"
28 #include "base/trace_event/memory_dump_provider.h" 28 #include "base/trace_event/memory_dump_provider.h"
29 #include "components/discardable_memory/common/discardable_memory_export.h" 29 #include "components/discardable_memory/common/discardable_memory_export.h"
30 #include "components/discardable_memory/common/discardable_shared_memory_id.h" 30 #include "components/discardable_memory/public/interfaces/discardable_shared_mem ory_manager.mojom.h"
31 31
32 namespace discardable_memory { 32 namespace discardable_memory {
33 33
34 // Implementation of DiscardableMemoryAllocator that allocates and manages 34 // Implementation of DiscardableMemoryAllocator that allocates and manages
35 // discardable memory segments for the process which hosts this class, and 35 // discardable memory segments for the process which hosts this class, and
36 // for remote processes which request discardable memory from this class via 36 // for remote processes which request discardable memory from this class via
37 // IPC. 37 // IPC.
38 // This class is thread-safe and instances can safely be used on any thread. 38 // This class is thread-safe and instances can safely be used on any thread.
39 class DISCARDABLE_MEMORY_EXPORT DiscardableSharedMemoryManager 39 class DISCARDABLE_MEMORY_EXPORT DiscardableSharedMemoryManager
40 : public base::DiscardableMemoryAllocator, 40 : public base::DiscardableMemoryAllocator,
41 public base::trace_event::MemoryDumpProvider, 41 public base::trace_event::MemoryDumpProvider,
42 public base::MemoryCoordinatorClient { 42 public base::MemoryCoordinatorClient {
43 public: 43 public:
44 DiscardableSharedMemoryManager(); 44 DiscardableSharedMemoryManager();
45 ~DiscardableSharedMemoryManager() override; 45 ~DiscardableSharedMemoryManager() override;
46 46
47 // Returns a singleton instance. 47 // Returns a singleton instance.
48 static DiscardableSharedMemoryManager* current(); 48 static DiscardableSharedMemoryManager* current();
49 49
50 // Bind the current manager to a mojo interface request.
51 static void Bind(mojom::DiscardableSharedMemoryManagerRequest request);
52
50 // Overridden from base::DiscardableMemoryAllocator: 53 // Overridden from base::DiscardableMemoryAllocator:
51 std::unique_ptr<base::DiscardableMemory> AllocateLockedDiscardableMemory( 54 std::unique_ptr<base::DiscardableMemory> AllocateLockedDiscardableMemory(
52 size_t size) override; 55 size_t size) override;
53 56
54 // Overridden from base::trace_event::MemoryDumpProvider: 57 // Overridden from base::trace_event::MemoryDumpProvider:
55 bool OnMemoryDump(const base::trace_event::MemoryDumpArgs& args, 58 bool OnMemoryDump(const base::trace_event::MemoryDumpArgs& args,
56 base::trace_event::ProcessMemoryDump* pmd) override; 59 base::trace_event::ProcessMemoryDump* pmd) override;
57 60
58 // TODO(penghuang): Get ride of the |process_handle| when we switch to mojo.
59 // This allocates a discardable memory segment for |process_handle|. 61 // This allocates a discardable memory segment for |process_handle|.
60 // A valid shared memory handle is returned on success. 62 // A valid shared memory handle is returned on success.
61 void AllocateLockedDiscardableSharedMemoryForClient( 63 void AllocateLockedDiscardableSharedMemoryForClient(
62 base::ProcessHandle process_handle,
63 int client_id, 64 int client_id,
64 size_t size, 65 size_t size,
65 DiscardableSharedMemoryId id, 66 int32_t id,
66 base::SharedMemoryHandle* shared_memory_handle); 67 base::SharedMemoryHandle* shared_memory_handle);
67 68
68 // Call this to notify the manager that client process associated with 69 // Call this to notify the manager that client process associated with
69 // |client_id| has deleted discardable memory segment with |id|. 70 // |client_id| has deleted discardable memory segment with |id|.
70 void ClientDeletedDiscardableSharedMemory(DiscardableSharedMemoryId id, 71 void ClientDeletedDiscardableSharedMemory(int32_t id, int client_id);
71 int client_id);
72 72
73 // Call this to notify the manager that client associated with |client_id| 73 // Call this to notify the manager that client associated with |client_id|
74 // has been removed. The manager will use this to release memory segments 74 // has been removed. The manager will use this to release memory segments
75 // allocated for client to the OS. 75 // allocated for client to the OS.
76 void ClientRemoved(int client_id); 76 void ClientRemoved(int client_id);
77 77
78 // The maximum number of bytes of memory that may be allocated. This will 78 // The maximum number of bytes of memory that may be allocated. This will
79 // cause memory usage to be reduced if currently above |limit|. 79 // cause memory usage to be reduced if currently above |limit|.
80 void SetMemoryLimit(size_t limit); 80 void SetMemoryLimit(size_t limit);
81 81
(...skipping 22 matching lines...) Expand all
104 104
105 static bool CompareMemoryUsageTime(const scoped_refptr<MemorySegment>& a, 105 static bool CompareMemoryUsageTime(const scoped_refptr<MemorySegment>& a,
106 const scoped_refptr<MemorySegment>& b) { 106 const scoped_refptr<MemorySegment>& b) {
107 // In this system, LRU memory segment is evicted first. 107 // In this system, LRU memory segment is evicted first.
108 return a->memory()->last_known_usage() > b->memory()->last_known_usage(); 108 return a->memory()->last_known_usage() > b->memory()->last_known_usage();
109 } 109 }
110 110
111 // base::MemoryCoordinatorClient implementation: 111 // base::MemoryCoordinatorClient implementation:
112 void OnMemoryStateChange(base::MemoryState state) override; 112 void OnMemoryStateChange(base::MemoryState state) override;
113 113
114 // TODO(penghuang): Get ride of the |process_handle| when we switch to mojo.
115 void AllocateLockedDiscardableSharedMemory( 114 void AllocateLockedDiscardableSharedMemory(
116 base::ProcessHandle process_handle,
117 int client_id, 115 int client_id,
118 size_t size, 116 size_t size,
119 DiscardableSharedMemoryId id, 117 int32_t id,
120 base::SharedMemoryHandle* shared_memory_handle); 118 base::SharedMemoryHandle* shared_memory_handle);
121 void DeletedDiscardableSharedMemory(DiscardableSharedMemoryId id, 119 void DeletedDiscardableSharedMemory(int32_t id, int client_id);
122 int client_id);
123 void OnMemoryPressure( 120 void OnMemoryPressure(
124 base::MemoryPressureListener::MemoryPressureLevel memory_pressure_level); 121 base::MemoryPressureListener::MemoryPressureLevel memory_pressure_level);
125 void ReduceMemoryUsageUntilWithinMemoryLimit(); 122 void ReduceMemoryUsageUntilWithinMemoryLimit();
126 void ReduceMemoryUsageUntilWithinLimit(size_t limit); 123 void ReduceMemoryUsageUntilWithinLimit(size_t limit);
127 void ReleaseMemory(base::DiscardableSharedMemory* memory); 124 void ReleaseMemory(base::DiscardableSharedMemory* memory);
128 void BytesAllocatedChanged(size_t new_bytes_allocated) const; 125 void BytesAllocatedChanged(size_t new_bytes_allocated) const;
129 126
130 // Virtual for tests. 127 // Virtual for tests.
131 virtual base::Time Now() const; 128 virtual base::Time Now() const;
132 virtual void ScheduleEnforceMemoryPolicy(); 129 virtual void ScheduleEnforceMemoryPolicy();
133 130
131 int32_t last_client_id_;
132
134 base::Lock lock_; 133 base::Lock lock_;
135 typedef base::hash_map<DiscardableSharedMemoryId, 134 typedef base::hash_map<int32_t, scoped_refptr<MemorySegment>>
136 scoped_refptr<MemorySegment>>
137 MemorySegmentMap; 135 MemorySegmentMap;
138 typedef base::hash_map<int, MemorySegmentMap> ClientMap; 136 typedef base::hash_map<int, MemorySegmentMap> ClientMap;
139 ClientMap clients_; 137 ClientMap clients_;
140 // Note: The elements in |segments_| are arranged in such a way that they form 138 // Note: The elements in |segments_| are arranged in such a way that they form
141 // a heap. The LRU memory segment always first. 139 // a heap. The LRU memory segment always first.
142 typedef std::vector<scoped_refptr<MemorySegment>> MemorySegmentVector; 140 typedef std::vector<scoped_refptr<MemorySegment>> MemorySegmentVector;
143 MemorySegmentVector segments_; 141 MemorySegmentVector segments_;
144 size_t default_memory_limit_; 142 size_t default_memory_limit_;
145 size_t memory_limit_; 143 size_t memory_limit_;
146 size_t bytes_allocated_; 144 size_t bytes_allocated_;
147 std::unique_ptr<base::MemoryPressureListener> memory_pressure_listener_; 145 std::unique_ptr<base::MemoryPressureListener> memory_pressure_listener_;
148 scoped_refptr<base::SingleThreadTaskRunner> 146 scoped_refptr<base::SingleThreadTaskRunner>
149 enforce_memory_policy_task_runner_; 147 enforce_memory_policy_task_runner_;
150 base::Closure enforce_memory_policy_callback_; 148 base::Closure enforce_memory_policy_callback_;
151 bool enforce_memory_policy_pending_; 149 bool enforce_memory_policy_pending_;
152 base::WeakPtrFactory<DiscardableSharedMemoryManager> weak_ptr_factory_; 150 base::WeakPtrFactory<DiscardableSharedMemoryManager> weak_ptr_factory_;
153 151
154 DISALLOW_COPY_AND_ASSIGN(DiscardableSharedMemoryManager); 152 DISALLOW_COPY_AND_ASSIGN(DiscardableSharedMemoryManager);
155 }; 153 };
156 154
157 } // namespace discardable_memory 155 } // namespace discardable_memory
158 156
159 #endif // COMPONENTS_DISCARDABLE_MEMORY_SERVICE_DISCARDABLE_SHARED_MEMORY_MANAG ER_H_ 157 #endif // COMPONENTS_DISCARDABLE_MEMORY_SERVICE_DISCARDABLE_SHARED_MEMORY_MANAG ER_H_
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698