| Index: chrome_frame/urlmon_url_request.cc
|
| ===================================================================
|
| --- chrome_frame/urlmon_url_request.cc (revision 70328)
|
| +++ chrome_frame/urlmon_url_request.cc (working copy)
|
| @@ -12,6 +12,7 @@
|
| #include "base/scoped_ptr.h"
|
| #include "base/string_number_conversions.h"
|
| #include "base/stringprintf.h"
|
| +#include "base/threading/platform_thread.h"
|
| #include "base/utf_string_conversions.h"
|
| #include "chrome_frame/bind_context_info.h"
|
| #include "chrome_frame/chrome_frame_activex_base.h"
|
| @@ -47,8 +48,8 @@
|
|
|
| bool UrlmonUrlRequest::Start() {
|
| DVLOG(1) << __FUNCTION__ << me() << url();
|
| - DCHECK(thread_ == 0 || thread_ == PlatformThread::CurrentId());
|
| - thread_ = PlatformThread::CurrentId();
|
| + DCHECK(thread_ == 0 || thread_ == base::PlatformThread::CurrentId());
|
| + thread_ = base::PlatformThread::CurrentId();
|
| status_.Start();
|
| // The UrlmonUrlRequest instance can get destroyed in the context of
|
| // StartAsyncDownload if BindToStorage finishes synchronously with an error.
|
| @@ -64,7 +65,7 @@
|
| }
|
|
|
| void UrlmonUrlRequest::Stop() {
|
| - DCHECK_EQ(thread_, PlatformThread::CurrentId());
|
| + DCHECK_EQ(thread_, base::PlatformThread::CurrentId());
|
| DCHECK((status_.get_state() != Status::DONE) == (binding_ != NULL));
|
| Status::State state = status_.get_state();
|
| delegate_ = NULL;
|
| @@ -92,7 +93,7 @@
|
| }
|
|
|
| bool UrlmonUrlRequest::Read(int bytes_to_read) {
|
| - DCHECK_EQ(thread_, PlatformThread::CurrentId());
|
| + DCHECK_EQ(thread_, base::PlatformThread::CurrentId());
|
| DCHECK_GE(bytes_to_read, 0);
|
| DCHECK_EQ(0, calling_delegate_);
|
| DVLOG(1) << __FUNCTION__ << me();
|
| @@ -136,8 +137,8 @@
|
| DCHECK(bind_context_ == NULL);
|
| DCHECK(moniker_ == NULL);
|
| DCHECK(cache_ == NULL);
|
| - DCHECK(thread_ == 0 || thread_ == PlatformThread::CurrentId());
|
| - thread_ = PlatformThread::CurrentId();
|
| + DCHECK(thread_ == 0 || thread_ == base::PlatformThread::CurrentId());
|
| + thread_ = base::PlatformThread::CurrentId();
|
| bind_context_ = bind_context;
|
| moniker_ = moniker;
|
| enable_frame_busting_ = enable_frame_busting;
|
| @@ -156,7 +157,7 @@
|
| }
|
|
|
| void UrlmonUrlRequest::TerminateBind(TerminateBindCallback* callback) {
|
| - DCHECK_EQ(thread_, PlatformThread::CurrentId());
|
| + DCHECK_EQ(thread_, base::PlatformThread::CurrentId());
|
| DVLOG(1) << __FUNCTION__ << me();
|
| cleanup_transaction_ = false;
|
| if (status_.get_state() == Status::DONE) {
|
| @@ -190,7 +191,7 @@
|
| }
|
|
|
| size_t UrlmonUrlRequest::SendDataToDelegate(size_t bytes_to_read) {
|
| - DCHECK_EQ(thread_, PlatformThread::CurrentId());
|
| + DCHECK_EQ(thread_, base::PlatformThread::CurrentId());
|
| DCHECK_NE(id(), -1);
|
| DCHECK_GT(bytes_to_read, 0U);
|
| size_t bytes_copied = 0;
|
| @@ -242,7 +243,7 @@
|
|
|
| STDMETHODIMP UrlmonUrlRequest::OnStartBinding(DWORD reserved,
|
| IBinding* binding) {
|
| - DCHECK_EQ(thread_, PlatformThread::CurrentId());
|
| + DCHECK_EQ(thread_, base::PlatformThread::CurrentId());
|
| binding_ = binding;
|
| if (pending_) {
|
| response_headers_ = GetHttpHeadersFromBinding(binding_);
|
| @@ -264,7 +265,7 @@
|
|
|
| STDMETHODIMP UrlmonUrlRequest::OnProgress(ULONG progress, ULONG max_progress,
|
| ULONG status_code, LPCWSTR status_text) {
|
| - DCHECK_EQ(thread_, PlatformThread::CurrentId());
|
| + DCHECK_EQ(thread_, base::PlatformThread::CurrentId());
|
|
|
| if (status_.get_state() != Status::WORKING)
|
| return S_OK;
|
| @@ -341,7 +342,7 @@
|
| }
|
|
|
| STDMETHODIMP UrlmonUrlRequest::OnStopBinding(HRESULT result, LPCWSTR error) {
|
| - DCHECK_EQ(thread_, PlatformThread::CurrentId());
|
| + DCHECK_EQ(thread_, base::PlatformThread::CurrentId());
|
| DVLOG(1) << __FUNCTION__ << me()
|
| << "- Request stopped, Result: " << std::hex << result;
|
| DCHECK(status_.get_state() == Status::WORKING ||
|
| @@ -485,7 +486,7 @@
|
| STDMETHODIMP UrlmonUrlRequest::OnDataAvailable(DWORD flags, DWORD size,
|
| FORMATETC* formatetc,
|
| STGMEDIUM* storage) {
|
| - DCHECK_EQ(thread_, PlatformThread::CurrentId());
|
| + DCHECK_EQ(thread_, base::PlatformThread::CurrentId());
|
| DVLOG(1) << __FUNCTION__ << me() << "bytes available: " << size;
|
|
|
| if (terminate_requested()) {
|
| @@ -538,7 +539,7 @@
|
| STDMETHODIMP UrlmonUrlRequest::BeginningTransaction(const wchar_t* url,
|
| const wchar_t* current_headers, DWORD reserved,
|
| wchar_t** additional_headers) {
|
| - DCHECK_EQ(thread_, PlatformThread::CurrentId());
|
| + DCHECK_EQ(thread_, base::PlatformThread::CurrentId());
|
| if (!additional_headers) {
|
| NOTREACHED();
|
| return E_POINTER;
|
| @@ -614,7 +615,7 @@
|
| STDMETHODIMP UrlmonUrlRequest::OnResponse(DWORD dwResponseCode,
|
| const wchar_t* response_headers, const wchar_t* request_headers,
|
| wchar_t** additional_headers) {
|
| - DCHECK_EQ(thread_, PlatformThread::CurrentId());
|
| + DCHECK_EQ(thread_, base::PlatformThread::CurrentId());
|
| DVLOG(1) << __FUNCTION__ << me() << "headers: \n" << response_headers;
|
|
|
| if (!delegate_) {
|
| @@ -829,7 +830,7 @@
|
| }
|
|
|
| void UrlmonUrlRequest::NotifyDelegateAndDie() {
|
| - DCHECK_EQ(thread_, PlatformThread::CurrentId());
|
| + DCHECK_EQ(thread_, base::PlatformThread::CurrentId());
|
| DVLOG(1) << __FUNCTION__ << me();
|
|
|
| PluginUrlRequestDelegate* delegate = delegate_;
|
|
|