| 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/policy/device_management_service.h" | 5 #include "chrome/browser/policy/device_management_service.h" |
| 6 | 6 |
| 7 #include <utility> | 7 #include <utility> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/compiler_specific.h" | 10 #include "base/compiler_specific.h" |
| (...skipping 264 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 275 // Handles the URL request response. | 275 // Handles the URL request response. |
| 276 void HandleResponse(const net::URLRequestStatus& status, | 276 void HandleResponse(const net::URLRequestStatus& status, |
| 277 int response_code, | 277 int response_code, |
| 278 const net::ResponseCookies& cookies, | 278 const net::ResponseCookies& cookies, |
| 279 const std::string& data); | 279 const std::string& data); |
| 280 | 280 |
| 281 // Gets the URL to contact. | 281 // Gets the URL to contact. |
| 282 GURL GetURL(const std::string& server_url); | 282 GURL GetURL(const std::string& server_url); |
| 283 | 283 |
| 284 // Configures the fetcher, setting up payload and headers. | 284 // Configures the fetcher, setting up payload and headers. |
| 285 void ConfigureRequest(content::URLFetcher* fetcher); | 285 void ConfigureRequest(net::URLFetcher* fetcher); |
| 286 | 286 |
| 287 protected: | 287 protected: |
| 288 // DeviceManagementRequestJob: | 288 // DeviceManagementRequestJob: |
| 289 virtual void Run() OVERRIDE; | 289 virtual void Run() OVERRIDE; |
| 290 | 290 |
| 291 private: | 291 private: |
| 292 // Invokes the callback with the given error code. | 292 // Invokes the callback with the given error code. |
| 293 void ReportError(DeviceManagementStatus code); | 293 void ReportError(DeviceManagementStatus code); |
| 294 | 294 |
| 295 // Pointer to the service this job is associated with. | 295 // Pointer to the service this job is associated with. |
| (...skipping 90 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 386 if (entry != query_params_.begin()) | 386 if (entry != query_params_.begin()) |
| 387 result += '&'; | 387 result += '&'; |
| 388 result += net::EscapeQueryParamValue(entry->first, true); | 388 result += net::EscapeQueryParamValue(entry->first, true); |
| 389 result += '='; | 389 result += '='; |
| 390 result += net::EscapeQueryParamValue(entry->second, true); | 390 result += net::EscapeQueryParamValue(entry->second, true); |
| 391 } | 391 } |
| 392 return GURL(result); | 392 return GURL(result); |
| 393 } | 393 } |
| 394 | 394 |
| 395 void DeviceManagementRequestJobImpl::ConfigureRequest( | 395 void DeviceManagementRequestJobImpl::ConfigureRequest( |
| 396 content::URLFetcher* fetcher) { | 396 net::URLFetcher* fetcher) { |
| 397 std::string payload; | 397 std::string payload; |
| 398 CHECK(request_.SerializeToString(&payload)); | 398 CHECK(request_.SerializeToString(&payload)); |
| 399 fetcher->SetUploadData(kPostContentType, payload); | 399 fetcher->SetUploadData(kPostContentType, payload); |
| 400 std::string extra_headers; | 400 std::string extra_headers; |
| 401 if (!gaia_token_.empty()) | 401 if (!gaia_token_.empty()) |
| 402 extra_headers += kServiceTokenAuthHeader + gaia_token_ + "\n"; | 402 extra_headers += kServiceTokenAuthHeader + gaia_token_ + "\n"; |
| 403 if (!dm_token_.empty()) | 403 if (!dm_token_.empty()) |
| 404 extra_headers += kDMTokenAuthHeader + dm_token_ + "\n"; | 404 extra_headers += kDMTokenAuthHeader + dm_token_ + "\n"; |
| 405 fetcher->SetExtraRequestHeaders(extra_headers); | 405 fetcher->SetExtraRequestHeaders(extra_headers); |
| 406 } | 406 } |
| (...skipping 96 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 503 | 503 |
| 504 DeviceManagementService::DeviceManagementService( | 504 DeviceManagementService::DeviceManagementService( |
| 505 const std::string& server_url) | 505 const std::string& server_url) |
| 506 : server_url_(server_url), | 506 : server_url_(server_url), |
| 507 initialized_(false), | 507 initialized_(false), |
| 508 ALLOW_THIS_IN_INITIALIZER_LIST(weak_ptr_factory_(this)) { | 508 ALLOW_THIS_IN_INITIALIZER_LIST(weak_ptr_factory_(this)) { |
| 509 } | 509 } |
| 510 | 510 |
| 511 void DeviceManagementService::StartJob(DeviceManagementRequestJobImpl* job, | 511 void DeviceManagementService::StartJob(DeviceManagementRequestJobImpl* job, |
| 512 bool bypass_proxy) { | 512 bool bypass_proxy) { |
| 513 content::URLFetcher* fetcher = content::URLFetcher::Create( | 513 net::URLFetcher* fetcher = content::URLFetcher::Create( |
| 514 0, job->GetURL(server_url_), content::URLFetcher::POST, this); | 514 0, job->GetURL(server_url_), net::URLFetcher::POST, this); |
| 515 fetcher->SetLoadFlags(net::LOAD_DO_NOT_SEND_COOKIES | | 515 fetcher->SetLoadFlags(net::LOAD_DO_NOT_SEND_COOKIES | |
| 516 net::LOAD_DO_NOT_SAVE_COOKIES | | 516 net::LOAD_DO_NOT_SAVE_COOKIES | |
| 517 net::LOAD_DISABLE_CACHE | | 517 net::LOAD_DISABLE_CACHE | |
| 518 (bypass_proxy ? net::LOAD_BYPASS_PROXY : 0)); | 518 (bypass_proxy ? net::LOAD_BYPASS_PROXY : 0)); |
| 519 fetcher->SetRequestContext(request_context_getter_.get()); | 519 fetcher->SetRequestContext(request_context_getter_.get()); |
| 520 job->ConfigureRequest(fetcher); | 520 job->ConfigureRequest(fetcher); |
| 521 pending_jobs_[fetcher] = job; | 521 pending_jobs_[fetcher] = job; |
| 522 fetcher->Start(); | 522 fetcher->Start(); |
| 523 } | 523 } |
| 524 | 524 |
| (...skipping 60 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 585 } | 585 } |
| 586 } | 586 } |
| 587 | 587 |
| 588 const JobQueue::iterator elem = | 588 const JobQueue::iterator elem = |
| 589 std::find(queued_jobs_.begin(), queued_jobs_.end(), job); | 589 std::find(queued_jobs_.begin(), queued_jobs_.end(), job); |
| 590 if (elem != queued_jobs_.end()) | 590 if (elem != queued_jobs_.end()) |
| 591 queued_jobs_.erase(elem); | 591 queued_jobs_.erase(elem); |
| 592 } | 592 } |
| 593 | 593 |
| 594 } // namespace policy | 594 } // namespace policy |
| OLD | NEW |