| OLD | NEW |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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/ui/webui/chrome_url_data_manager.h" | 5 #include "chrome/browser/ui/webui/chrome_url_data_manager.h" |
| 6 | 6 |
| 7 #include <vector> | 7 #include <vector> |
| 8 | 8 |
| 9 #include "base/i18n/rtl.h" | 9 #include "base/i18n/rtl.h" |
| 10 #include "base/memory/ref_counted_memory.h" | 10 #include "base/memory/ref_counted_memory.h" |
| (...skipping 101 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 112 : source_name_(source_name), | 112 : source_name_(source_name), |
| 113 message_loop_(message_loop), | 113 message_loop_(message_loop), |
| 114 backend_(NULL) { | 114 backend_(NULL) { |
| 115 } | 115 } |
| 116 | 116 |
| 117 ChromeURLDataManager::DataSource::~DataSource() { | 117 ChromeURLDataManager::DataSource::~DataSource() { |
| 118 } | 118 } |
| 119 | 119 |
| 120 void ChromeURLDataManager::DataSource::SendResponse(int request_id, | 120 void ChromeURLDataManager::DataSource::SendResponse(int request_id, |
| 121 RefCountedMemory* bytes) { | 121 RefCountedMemory* bytes) { |
| 122 // Take a ref-pointer on entry so byte->Release() will always get called. |
| 123 scoped_refptr<RefCountedMemory> bytes_ptr(bytes); |
| 122 if (IsScheduledForDeletion(this)) { | 124 if (IsScheduledForDeletion(this)) { |
| 123 // We're scheduled for deletion. Servicing the request would result in | 125 // We're scheduled for deletion. Servicing the request would result in |
| 124 // this->AddRef being invoked, even though the ref count is 0 and 'this' is | 126 // this->AddRef being invoked, even though the ref count is 0 and 'this' is |
| 125 // about to be deleted. If the AddRef were allowed through, when 'this' is | 127 // about to be deleted. If the AddRef were allowed through, when 'this' is |
| 126 // released it would be deleted again. | 128 // released it would be deleted again. |
| 127 // | 129 // |
| 128 // This scenario occurs with DataSources that make history requests. Such | 130 // This scenario occurs with DataSources that make history requests. Such |
| 129 // DataSources do a history query in |StartDataRequest| and the request is | 131 // DataSources do a history query in |StartDataRequest| and the request is |
| 130 // live until the object is deleted (history requests don't up the ref | 132 // live until the object is deleted (history requests don't up the ref |
| 131 // count). This means it's entirely possible for the DataSource to invoke | 133 // count). This means it's entirely possible for the DataSource to invoke |
| 132 // |SendResponse| between the time when there are no more refs and the time | 134 // |SendResponse| between the time when there are no more refs and the time |
| 133 // when the object is deleted. | 135 // when the object is deleted. |
| 134 return; | 136 return; |
| 135 } | 137 } |
| 136 BrowserThread::PostTask( | 138 BrowserThread::PostTask( |
| 137 BrowserThread::IO, FROM_HERE, | 139 BrowserThread::IO, FROM_HERE, |
| 138 NewRunnableMethod(this, &DataSource::SendResponseOnIOThread, | 140 NewRunnableMethod(this, &DataSource::SendResponseOnIOThread, |
| 139 request_id, make_scoped_refptr(bytes))); | 141 request_id, bytes_ptr)); |
| 140 } | 142 } |
| 141 | 143 |
| 142 MessageLoop* ChromeURLDataManager::DataSource::MessageLoopForRequestPath( | 144 MessageLoop* ChromeURLDataManager::DataSource::MessageLoopForRequestPath( |
| 143 const std::string& path) const { | 145 const std::string& path) const { |
| 144 return message_loop_; | 146 return message_loop_; |
| 145 } | 147 } |
| 146 | 148 |
| 147 bool ChromeURLDataManager::DataSource::ShouldReplaceExistingSource() const { | 149 bool ChromeURLDataManager::DataSource::ShouldReplaceExistingSource() const { |
| 148 return true; | 150 return true; |
| 149 } | 151 } |
| (...skipping 18 matching lines...) Expand all Loading... |
| 168 base::i18n::IsRTL() ? "rtl" : "ltr"); | 170 base::i18n::IsRTL() ? "rtl" : "ltr"); |
| 169 } | 171 } |
| 170 | 172 |
| 171 void ChromeURLDataManager::DataSource::SendResponseOnIOThread( | 173 void ChromeURLDataManager::DataSource::SendResponseOnIOThread( |
| 172 int request_id, | 174 int request_id, |
| 173 scoped_refptr<RefCountedMemory> bytes) { | 175 scoped_refptr<RefCountedMemory> bytes) { |
| 174 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 176 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
| 175 if (backend_) | 177 if (backend_) |
| 176 backend_->DataAvailable(request_id, bytes); | 178 backend_->DataAvailable(request_id, bytes); |
| 177 } | 179 } |
| OLD | NEW |