Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 #include "chrome/browser/profiles/profile_destroyer.h" | 5 #include "chrome/browser/profiles/profile_destroyer.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/memory/scoped_ptr.h" | 8 #include "base/memory/scoped_ptr.h" |
| 9 #include "base/message_loop.h" | 9 #include "base/message_loop.h" |
| 10 #include "chrome/browser/profiles/profile.h" | 10 #include "chrome/browser/profiles/profile.h" |
| 11 #include "chrome/common/chrome_notification_types.h" | |
| 12 #include "content/public/browser/notification_service.h" | |
| 11 #include "content/public/browser/notification_source.h" | 13 #include "content/public/browser/notification_source.h" |
| 12 #include "content/public/browser/notification_types.h" | 14 #include "content/public/browser/notification_types.h" |
| 13 #include "content/public/browser/render_process_host.h" | 15 #include "content/public/browser/render_process_host.h" |
| 14 | 16 |
| 15 | 17 |
| 16 namespace { | 18 namespace { |
| 17 | 19 |
| 18 const int64 kTimerDelaySeconds = 1; | 20 const int64 kTimerDelaySeconds = 1; |
| 19 | 21 |
| 20 } // namespace | 22 } // namespace |
| 21 | 23 |
| 22 std::vector<ProfileDestroyer*>* ProfileDestroyer::pending_destroyers_ = NULL; | 24 std::vector<ProfileDestroyer*>* ProfileDestroyer::pending_destroyers_ = NULL; |
| 23 | 25 |
| 24 // static | 26 // static |
| 25 void ProfileDestroyer::DestroyProfileWhenAppropriate(Profile* const profile) { | 27 void ProfileDestroyer::DestroyProfileWhenAppropriate(Profile* const profile) { |
| 26 DCHECK(profile); | 28 DCHECK(profile); |
| 29 content::NotificationService::current()->Notify( | |
|
Yoyo Zhou
2012/07/25 18:13:00
I wanted to put this in the ProfileDestroyer initi
| |
| 30 chrome::NOTIFICATION_PROFILE_DESTROYED, | |
| 31 content::Source<Profile>(profile), | |
| 32 content::NotificationService::NoDetails()); | |
| 33 | |
| 27 std::vector<content::RenderProcessHost*> hosts; | 34 std::vector<content::RenderProcessHost*> hosts; |
| 28 // Testing profiles can simply be deleted directly. Some tests don't setup | 35 // Testing profiles can simply be deleted directly. Some tests don't setup |
| 29 // RenderProcessHost correctly and don't necessary run on the UI thread | 36 // RenderProcessHost correctly and don't necessary run on the UI thread |
| 30 // anyway, so we can't use the AllHostIterator. | 37 // anyway, so we can't use the AllHostIterator. |
| 31 if (profile->AsTestingProfile() == NULL) { | 38 if (profile->AsTestingProfile() == NULL) { |
| 32 GetHostsForProfile(profile, &hosts); | 39 GetHostsForProfile(profile, &hosts); |
| 33 if (!profile->IsOffTheRecord() && profile->HasOffTheRecordProfile()) | 40 if (!profile->IsOffTheRecord() && profile->HasOffTheRecordProfile()) |
| 34 GetHostsForProfile(profile->GetOffTheRecordProfile(), &hosts); | 41 GetHostsForProfile(profile->GetOffTheRecordProfile(), &hosts); |
| 35 } | 42 } |
| 36 // This should never happen for non Off the record profile, this means that | 43 // This should never happen for non Off the record profile, this means that |
| 37 // there is a leak in a render process host that MUST BE FIXED!!! | 44 // there is a leak in a render process host that MUST BE FIXED!!! |
| 38 DCHECK(hosts.empty() || profile->IsOffTheRecord()); | 45 DCHECK(hosts.empty() || profile->IsOffTheRecord()); |
|
Matt Perry
2012/07/25 19:32:08
you should change the DCHECK now that it works for
| |
| 39 // Note that we still test for !profile->IsOffTheRecord here even though we | 46 // Note that we still test for !profile->IsOffTheRecord here even though we |
| 40 // DCHECK'd above because we want to protect Release builds against this even | 47 // DCHECK'd above because we want to protect Release builds against this even |
| 41 // we need to identify if there are leaks when we run Debug builds. | 48 // we need to identify if there are leaks when we run Debug builds. |
| 42 if (hosts.empty() || !profile->IsOffTheRecord()) { | 49 if (hosts.empty() || !profile->IsOffTheRecord()) { |
| 43 if (profile->IsOffTheRecord()) | 50 if (profile->IsOffTheRecord()) |
| 44 profile->GetOriginalProfile()->DestroyOffTheRecordProfile(); | 51 profile->GetOriginalProfile()->DestroyOffTheRecordProfile(); |
| 45 else | 52 else |
| 46 delete profile; | 53 delete profile; |
| 47 } else { | 54 } else { |
| 48 // The instance will destroy itself once all render process hosts referring | 55 // The instance will destroy itself once all render process hosts referring |
| (...skipping 29 matching lines...) Expand all Loading... | |
| 78 Profile* const profile, | 85 Profile* const profile, |
| 79 const std::vector<content::RenderProcessHost*>& hosts) | 86 const std::vector<content::RenderProcessHost*>& hosts) |
| 80 : timer_(false, false), | 87 : timer_(false, false), |
| 81 num_hosts_(0), | 88 num_hosts_(0), |
| 82 profile_(profile) { | 89 profile_(profile) { |
| 83 if (pending_destroyers_ == NULL) | 90 if (pending_destroyers_ == NULL) |
| 84 pending_destroyers_ = new std::vector<ProfileDestroyer*>; | 91 pending_destroyers_ = new std::vector<ProfileDestroyer*>; |
| 85 pending_destroyers_->push_back(this); | 92 pending_destroyers_->push_back(this); |
| 86 for (size_t i = 0; i < hosts.size(); ++i) { | 93 for (size_t i = 0; i < hosts.size(); ++i) { |
| 87 registrar_.Add(this, content::NOTIFICATION_RENDERER_PROCESS_TERMINATED, | 94 registrar_.Add(this, content::NOTIFICATION_RENDERER_PROCESS_TERMINATED, |
| 88 content::Source<content::RenderProcessHost>(hosts[i])); | 95 content::Source<content::RenderProcessHost>(hosts[i])); |
| 89 // For each of the notifications, we bump up our reference count. | 96 // For each of the notifications, we bump up our reference count. |
| 90 // It will go back to 0 and free us when all hosts are terminated. | 97 // It will go back to 0 and free us when all hosts are terminated. |
| 91 ++num_hosts_; | 98 ++num_hosts_; |
| 92 } | 99 } |
| 93 // If we are going to wait for render process hosts, we don't want to do it | 100 // If we are going to wait for render process hosts, we don't want to do it |
| 94 // for longer than kTimerDelaySeconds. | 101 // for longer than kTimerDelaySeconds. |
| 95 if (num_hosts_) { | 102 if (num_hosts_) { |
| 96 timer_.Start(FROM_HERE, | 103 timer_.Start(FROM_HERE, |
| 97 base::TimeDelta::FromSeconds(kTimerDelaySeconds), | 104 base::TimeDelta::FromSeconds(kTimerDelaySeconds), |
| 98 base::Bind(&ProfileDestroyer::DestroyProfile, this)); | 105 base::Bind(&ProfileDestroyer::DestroyProfile, this)); |
| (...skipping 20 matching lines...) Expand all Loading... | |
| 119 if (pending_destroyers_->empty()) { | 126 if (pending_destroyers_->empty()) { |
| 120 delete pending_destroyers_; | 127 delete pending_destroyers_; |
| 121 pending_destroyers_ = NULL; | 128 pending_destroyers_ = NULL; |
| 122 } | 129 } |
| 123 } | 130 } |
| 124 | 131 |
| 125 void ProfileDestroyer::Observe(int type, | 132 void ProfileDestroyer::Observe(int type, |
| 126 const content::NotificationSource& source, | 133 const content::NotificationSource& source, |
| 127 const content::NotificationDetails& details) { | 134 const content::NotificationDetails& details) { |
| 128 DCHECK(type == content::NOTIFICATION_RENDERER_PROCESS_TERMINATED); | 135 DCHECK(type == content::NOTIFICATION_RENDERER_PROCESS_TERMINATED); |
| 136 registrar_.Remove(this, content::NOTIFICATION_RENDERER_PROCESS_TERMINATED, | |
|
Yoyo Zhou
2012/07/25 18:13:00
It turns out the current implementation doesn't re
| |
| 137 source); | |
| 129 DCHECK(num_hosts_ > 0); | 138 DCHECK(num_hosts_ > 0); |
| 130 --num_hosts_; | 139 --num_hosts_; |
| 131 if (num_hosts_ == 0) { | 140 if (num_hosts_ == 0) { |
| 132 // Delay the destruction one step further in case other observers of this | 141 // Delay the destruction one step further in case other observers of this |
| 133 // notification need to look at the profile attached to the host. | 142 // notification need to look at the profile attached to the host. |
| 134 MessageLoop::current()->PostTask( | 143 MessageLoop::current()->PostTask( |
| 135 FROM_HERE, base::Bind(&ProfileDestroyer::DestroyProfile, this)); | 144 FROM_HERE, base::Bind(&ProfileDestroyer::DestroyProfile, this)); |
| 136 } | 145 } |
| 137 } | 146 } |
| 138 | 147 |
| (...skipping 22 matching lines...) Expand all Loading... | |
| 161 content::RenderProcessHost::AllHostsIterator()); | 170 content::RenderProcessHost::AllHostsIterator()); |
| 162 !iter.IsAtEnd(); iter.Advance()) { | 171 !iter.IsAtEnd(); iter.Advance()) { |
| 163 content::RenderProcessHost* render_process_host = iter.GetCurrentValue(); | 172 content::RenderProcessHost* render_process_host = iter.GetCurrentValue(); |
| 164 if (render_process_host && Profile::FromBrowserContext( | 173 if (render_process_host && Profile::FromBrowserContext( |
| 165 render_process_host->GetBrowserContext()) == profile) { | 174 render_process_host->GetBrowserContext()) == profile) { |
| 166 hosts->push_back(render_process_host); | 175 hosts->push_back(render_process_host); |
| 167 } | 176 } |
| 168 } | 177 } |
| 169 return !hosts->empty(); | 178 return !hosts->empty(); |
| 170 } | 179 } |
| OLD | NEW |