url_request_job_manager.cc revision 2a99a7e74a7f215066514fe81d2bfa6639d9eddd
15821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Copyright (c) 2012 The Chromium Authors. All rights reserved. 25821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Use of this source code is governed by a BSD-style license that can be 35821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// found in the LICENSE file. 45821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 55821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/url_request/url_request_job_manager.h" 65821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 75821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include <algorithm> 85821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 95821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/memory/singleton.h" 105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "build/build_config.h" 115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/string_util.h" 125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/base/load_flags.h" 135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/base/net_errors.h" 145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/base/network_delegate.h" 155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/url_request/url_request_about_job.h" 165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/url_request/url_request_context.h" 175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/url_request/url_request_data_job.h" 185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/url_request/url_request_error_job.h" 195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/url_request/url_request_file_job.h" 205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/url_request/url_request_ftp_job.h" 215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/url_request/url_request_http_job.h" 225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/url_request/url_request_job_factory.h" 235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)namespace net { 255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// The built-in set of protocol factories 275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)namespace { 285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)struct SchemeToFactory { 305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const char* scheme; 315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) URLRequest::ProtocolFactory* factory; 325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)}; 335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace 355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)static const SchemeToFactory kBuiltinFactories[] = { 375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) { "http", URLRequestHttpJob::Factory }, 385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) { "https", URLRequestHttpJob::Factory }, 395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) { "file", URLRequestFileJob::Factory }, 405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#if !defined(DISABLE_FTP_SUPPORT) 415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) { "ftp", URLRequestFtpJob::Factory }, 425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#endif 435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) { "about", URLRequestAboutJob::Factory }, 445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) { "data", URLRequestDataJob::Factory }, 455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)}; 465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// static 485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)URLRequestJobManager* URLRequestJobManager::GetInstance() { 495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return Singleton<URLRequestJobManager>::get(); 505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)URLRequestJob* URLRequestJobManager::CreateJob( 535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) URLRequest* request, NetworkDelegate* network_delegate) const { 545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(IsAllowedThread()); 555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // If we are given an invalid URL, then don't even try to inspect the scheme. 575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!request->url().is_valid()) 585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return new URLRequestErrorJob(request, network_delegate, ERR_INVALID_URL); 595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // We do this here to avoid asking interceptors about unsupported schemes. 615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const URLRequestJobFactory* job_factory = NULL; 625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) job_factory = request->context()->job_factory(); 635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& scheme = request->url().scheme(); // already lowercase 655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (job_factory) { 665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!job_factory->IsHandledProtocol(scheme)) { 675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return new URLRequestErrorJob( 685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request, network_delegate, ERR_UNKNOWN_URL_SCHEME); 695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else if (!SupportsScheme(scheme)) { 715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return new URLRequestErrorJob( 725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request, network_delegate, ERR_UNKNOWN_URL_SCHEME); 735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // THREAD-SAFETY NOTICE: 765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // We do not need to acquire the lock here since we are only reading our 775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // data structures. They should only be modified on the current thread. 785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // See if the request should be intercepted. 805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // 815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 822a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // TODO(pauljensen): Remove this when AppCacheInterceptor is a 832a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // ProtocolHandler, see crbug.com/161547. 845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!(request->load_flags() & LOAD_DISABLE_INTERCEPT)) { 855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) InterceptorList::const_iterator i; 865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) for (i = interceptors_.begin(); i != interceptors_.end(); ++i) { 875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) URLRequestJob* job = (*i)->MaybeIntercept(request, network_delegate); 885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (job) 895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return job; 905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (job_factory) { 945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) URLRequestJob* job = job_factory->MaybeCreateJobWithProtocolHandler( 955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) scheme, request, network_delegate); 965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (job) 975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return job; 985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // TODO(willchan): Remove this in favor of 1015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // URLRequestJobFactory::ProtocolHandler. 1025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // See if the request should be handled by a registered protocol factory. 1035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // If the registered factory returns null, then we want to fall-back to the 1045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // built-in protocol factory. 1055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FactoryMap::const_iterator i = factories_.find(scheme); 1065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (i != factories_.end()) { 1075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) URLRequestJob* job = i->second(request, network_delegate, scheme); 1085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (job) 1095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return job; 1105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // See if the request should be handled by a built-in protocol factory. 1135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) for (size_t i = 0; i < arraysize(kBuiltinFactories); ++i) { 1145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (scheme == kBuiltinFactories[i].scheme) { 1155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) URLRequestJob* job = (kBuiltinFactories[i].factory)( 1165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request, network_delegate, scheme); 1175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(job); // The built-in factories are not expected to fail! 1185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return job; 1195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // If we reached here, then it means that a registered protocol factory 1235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // wasn't interested in handling the URL. That is fairly unexpected, and we 1245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // don't have a specific error to report here :-( 1255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) LOG(WARNING) << "Failed to map: " << request->url().spec(); 1265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return new URLRequestErrorJob(request, network_delegate, ERR_FAILED); 1275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)URLRequestJob* URLRequestJobManager::MaybeInterceptRedirect( 1305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) URLRequest* request, 1315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) NetworkDelegate* network_delegate, 1325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const GURL& location) const { 1335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(IsAllowedThread()); 1345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!request->url().is_valid() || 1355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request->load_flags() & LOAD_DISABLE_INTERCEPT || 1365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request->status().status() == URLRequestStatus::CANCELED) { 1375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return NULL; 1385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const URLRequestJobFactory* job_factory = NULL; 1415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) job_factory = request->context()->job_factory(); 1425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& scheme = request->url().scheme(); // already lowercase 1445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (job_factory) { 1455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!job_factory->IsHandledProtocol(scheme)) { 1465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return NULL; 1475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else if (!SupportsScheme(scheme)) { 1495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return NULL; 1505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) InterceptorList::const_iterator i; 1535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) for (i = interceptors_.begin(); i != interceptors_.end(); ++i) { 1542a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) URLRequestJob* job = (*i)->MaybeInterceptRedirect(request, 1552a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) network_delegate, 1562a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) location); 1575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (job) 1585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return job; 1595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return NULL; 1615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)URLRequestJob* URLRequestJobManager::MaybeInterceptResponse( 1645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) URLRequest* request, NetworkDelegate* network_delegate) const { 1655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(IsAllowedThread()); 1665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!request->url().is_valid() || 1675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request->load_flags() & LOAD_DISABLE_INTERCEPT || 1685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) request->status().status() == URLRequestStatus::CANCELED) { 1695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return NULL; 1705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const URLRequestJobFactory* job_factory = NULL; 1735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) job_factory = request->context()->job_factory(); 1745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& scheme = request->url().scheme(); // already lowercase 1765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (job_factory) { 1775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!job_factory->IsHandledProtocol(scheme)) { 1785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return NULL; 1795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else if (!SupportsScheme(scheme)) { 1815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return NULL; 1825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) InterceptorList::const_iterator i; 1855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) for (i = interceptors_.begin(); i != interceptors_.end(); ++i) { 1862a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) URLRequestJob* job = (*i)->MaybeInterceptResponse(request, 1872a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) network_delegate); 1885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (job) 1895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return job; 1905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return NULL; 1925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool URLRequestJobManager::SupportsScheme(const std::string& scheme) const { 1955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // The set of registered factories may change on another thread. 1965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) { 1975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::AutoLock locked(lock_); 1985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (factories_.find(scheme) != factories_.end()) 1995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return true; 2005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) for (size_t i = 0; i < arraysize(kBuiltinFactories); ++i) 2035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (LowerCaseEqualsASCII(scheme, kBuiltinFactories[i].scheme)) 2045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return true; 2055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return false; 2075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)URLRequest::ProtocolFactory* URLRequestJobManager::RegisterProtocolFactory( 2105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& scheme, 2115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) URLRequest::ProtocolFactory* factory) { 2125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(IsAllowedThread()); 2135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::AutoLock locked(lock_); 2155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) URLRequest::ProtocolFactory* old_factory; 2175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FactoryMap::iterator i = factories_.find(scheme); 2185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (i != factories_.end()) { 2195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) old_factory = i->second; 2205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 2215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) old_factory = NULL; 2225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (factory) { 2245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) factories_[scheme] = factory; 2255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else if (i != factories_.end()) { // uninstall any old one 2265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) factories_.erase(i); 2275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return old_factory; 2295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void URLRequestJobManager::RegisterRequestInterceptor( 2325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) URLRequest::Interceptor* interceptor) { 2335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(IsAllowedThread()); 2345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::AutoLock locked(lock_); 2365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(std::find(interceptors_.begin(), interceptors_.end(), interceptor) == 2385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) interceptors_.end()); 2395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) interceptors_.push_back(interceptor); 2405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void URLRequestJobManager::UnregisterRequestInterceptor( 2435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) URLRequest::Interceptor* interceptor) { 2445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(IsAllowedThread()); 2455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::AutoLock locked(lock_); 2475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) InterceptorList::iterator i = 2495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) std::find(interceptors_.begin(), interceptors_.end(), interceptor); 2505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(i != interceptors_.end()); 2515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) interceptors_.erase(i); 2525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)URLRequestJobManager::URLRequestJobManager() 2555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) : allowed_thread_(0), 2565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) allowed_thread_initialized_(false) { 2575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)URLRequestJobManager::~URLRequestJobManager() {} 2605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace net 262