| Index: net/url_request/certificate_report_sender.cc
|
| diff --git a/net/url_request/certificate_report_sender.cc b/net/url_request/certificate_report_sender.cc
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..0361a328c242241ca762bd1a1a6c1e2b4e748ebf
|
| --- /dev/null
|
| +++ b/net/url_request/certificate_report_sender.cc
|
| @@ -0,0 +1,76 @@
|
| +// Copyright 2015 The Chromium Authors. All rights reserved.
|
| +// Use of this source code is governed by a BSD-style license that can be
|
| +// found in the LICENSE file.
|
| +
|
| +#include "net/url_request/certificate_report_sender.h"
|
| +
|
| +#include "base/stl_util.h"
|
| +#include "net/base/elements_upload_data_stream.h"
|
| +#include "net/base/load_flags.h"
|
| +#include "net/base/request_priority.h"
|
| +#include "net/base/upload_bytes_element_reader.h"
|
| +#include "net/url_request/url_request_context.h"
|
| +#include "net/url_request/url_request_status.h"
|
| +
|
| +namespace net {
|
| +
|
| +CertificateReportSender::CertificateReportSender(
|
| + URLRequestContext* request_context,
|
| + CookiesPreference cookies_preference)
|
| + : request_context_(request_context),
|
| + cookies_preference_(cookies_preference) {}
|
| +
|
| +CertificateReportSender::~CertificateReportSender() {
|
| + STLDeleteElements(&inflight_requests_);
|
| +}
|
| +
|
| +void CertificateReportSender::Send(const GURL& report_uri,
|
| + const std::string& report) {
|
| + scoped_ptr<URLRequest> url_request =
|
| + CreateURLRequest(request_context_, report_uri);
|
| + url_request->set_method("POST");
|
| +
|
| + scoped_ptr<UploadElementReader> reader(
|
| + UploadOwnedBytesElementReader::CreateWithString(report));
|
| + url_request->set_upload(
|
| + ElementsUploadDataStream::CreateWithReader(reader.Pass(), 0));
|
| +
|
| + URLRequest* raw_url_request = url_request.get();
|
| + inflight_requests_.insert(url_request.release());
|
| + raw_url_request->Start();
|
| +}
|
| +
|
| +void CertificateReportSender::OnResponseStarted(URLRequest* request) {
|
| + // TODO(estark): call a callback so that the caller can print a
|
| + // warning on failure.
|
| + RequestComplete(request);
|
| +}
|
| +
|
| +void CertificateReportSender::OnReadCompleted(URLRequest* request,
|
| + int bytes_read) {
|
| + NOTREACHED();
|
| +}
|
| +
|
| +scoped_ptr<URLRequest> CertificateReportSender::CreateURLRequest(
|
| + URLRequestContext* context,
|
| + const GURL& report_uri) {
|
| + scoped_ptr<URLRequest> request =
|
| + context->CreateRequest(report_uri, DEFAULT_PRIORITY, this);
|
| + int load_flags =
|
| + LOAD_BYPASS_CACHE | LOAD_DISABLE_CACHE | LOAD_DO_NOT_SEND_AUTH_DATA;
|
| + if (cookies_preference_ != SEND_COOKIES) {
|
| + load_flags =
|
| + load_flags | LOAD_DO_NOT_SEND_COOKIES | LOAD_DO_NOT_SAVE_COOKIES;
|
| + }
|
| + request->SetLoadFlags(load_flags);
|
| + return request.Pass();
|
| +}
|
| +
|
| +void CertificateReportSender::RequestComplete(URLRequest* request) {
|
| + std::set<URLRequest*>::iterator i = inflight_requests_.find(request);
|
| + CHECK(i != inflight_requests_.end());
|
| + scoped_ptr<URLRequest> url_request(*i);
|
| + inflight_requests_.erase(i);
|
| +}
|
| +
|
| +} // namespace net
|
|
|