Chromium Code Reviews| Index: net/http/certificate_report_sender_impl.cc |
| diff --git a/net/http/certificate_report_sender_impl.cc b/net/http/certificate_report_sender_impl.cc |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..57940fadc22a4400eb6bfc7064cec9ba0cb55530 |
| --- /dev/null |
| +++ b/net/http/certificate_report_sender_impl.cc |
| @@ -0,0 +1,71 @@ |
| +// 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/http/certificate_report_sender_impl.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 { |
| + |
| +CertificateReportSenderImpl::CertificateReportSenderImpl( |
| + URLRequestContext* request_context, |
| + CookiesPreference cookies_preference) |
| + : request_context_(request_context), |
| + cookies_preference_(cookies_preference) { |
| +} |
| + |
| +CertificateReportSenderImpl::~CertificateReportSenderImpl() { |
| + STLDeleteElements(&inflight_requests_); |
| +} |
| + |
| +void CertificateReportSenderImpl::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 CertificateReportSenderImpl::OnResponseStarted(URLRequest* request) { |
| + // TODO(estark): call a callback so that the caller can print a |
| + // warning on failure. |
|
Ryan Sleevi
2015/06/26 20:03:46
// warning
estark
2015/07/07 21:59:28
Done.
|
| + RequestComplete(request); |
| +} |
| + |
| +void CertificateReportSenderImpl::OnReadCompleted(URLRequest* request, |
| + int bytes_read) { |
| +} |
| + |
| +scoped_ptr<URLRequest> CertificateReportSenderImpl::CreateURLRequest( |
| + URLRequestContext* context, |
| + const GURL& report_uri) { |
| + scoped_ptr<URLRequest> request = |
| + context->CreateRequest(report_uri, DEFAULT_PRIORITY, this); |
| + if (cookies_preference_ != SEND_COOKIES) |
| + request->SetLoadFlags(LOAD_DO_NOT_SEND_COOKIES | LOAD_DO_NOT_SAVE_COOKIES); |
|
Ryan Sleevi
2015/06/26 20:03:46
DESIGN: Look through the other load flags to figur
estark
2015/07/07 21:59:28
I've changed it to be consistent with what other b
|
| + return request.Pass(); |
| +} |
| + |
| +void CertificateReportSenderImpl::RequestComplete(URLRequest* request) { |
| + std::set<URLRequest*>::iterator i = inflight_requests_.find(request); |
| + DCHECK(i != inflight_requests_.end()); |
|
Ryan Sleevi
2015/06/26 20:03:46
Should this be a CHECK()? I can't recall what evil
estark
2015/07/07 21:59:28
Dereferencing end() is undefined behavior, so I su
|
| + scoped_ptr<URLRequest> url_request(*i); |
| + inflight_requests_.erase(i); |
| +} |
| + |
| +} // namespace net |