OLD | NEW |
---|---|
(Empty) | |
1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. | |
2 // Use of this source code is governed by a BSD-style license that can be | |
3 // found in the LICENSE file. | |
4 | |
5 #include "components/rappor/log_uploader.h" | |
6 | |
7 //#include "chrome/browser/metrics/compression_utils.h" | |
Ilya Sherman
2014/01/10 11:00:32
nit: ?
Steven Holte
2014/01/14 00:47:54
Done.
| |
8 #include "net/base/load_flags.h" | |
9 #include "url/gurl.h" | |
10 | |
11 using base::TimeDelta; | |
12 | |
13 namespace { | |
14 | |
15 // The delay, in seconds, between uploading when there are queued logs to send. | |
16 const int kUnsentLogsIntervalSeconds = 3; | |
17 | |
18 // When uploading metrics to the server fails, we progressively wait longer and | |
19 // longer before sending the next log. This backoff process helps reduce load | |
20 // on a server that is having issues. | |
21 // The following is the multiplier we use to expand that inter-log duration. | |
22 const double kBackoffMultiplier = 1.1; | |
23 | |
24 // The maximum backoff multiplier. | |
25 const int kMaxBackoffMultiplier = 10; | |
26 | |
27 // If an upload fails, and the transmission was over this byte count, then we | |
28 // will discard the log, and not try to retransmit it. We also don't persist | |
29 // the log to the prefs for transmission during the next chrome session if this | |
Ilya Sherman
2014/01/10 11:00:32
nit: "chrome" -> "Chrome"
Steven Holte
2014/01/14 00:47:54
Removed the sentence because it doesn't actually a
| |
30 // limit is exceeded. | |
31 const size_t kUploadLogAvoidRetransmitSize = 50000; | |
32 | |
33 // The maximum number of unsent logs we will keep. | |
34 const size_t kMaxQueuedLogs = 10; | |
Ilya Sherman
2014/01/10 11:00:32
nit: It's generally better to limit based on size,
Steven Holte
2014/01/14 00:47:54
Added TODO
| |
35 | |
36 } // anonymous namespace | |
Ilya Sherman
2014/01/10 11:00:32
nit: "anonymous namespace" -> "namespace" (for con
Steven Holte
2014/01/14 00:47:54
Done.
| |
37 | |
38 namespace rappor { | |
39 | |
40 LogUploader::LogUploader(const char* server_url, const char* mime_type, | |
41 net::URLRequestContextGetter* request_context) | |
Ilya Sherman
2014/01/10 11:00:32
Who owns the request context?
Steven Holte
2014/01/14 00:47:54
Used scoped_refptr
| |
42 : server_url_(server_url), mime_type_(mime_type), | |
43 request_context_(request_context), callback_pending_(false), | |
Ilya Sherman
2014/01/10 11:00:32
nit: One field per line, please.
Steven Holte
2014/01/14 00:47:54
Done.
| |
44 upload_interval_(TimeDelta::FromSeconds(kUnsentLogsIntervalSeconds)) { | |
45 } | |
46 | |
47 LogUploader::~LogUploader() {} | |
48 | |
49 void LogUploader::QueueLog(const std::string& log) { | |
50 queued_logs_.push(log); | |
51 if (!upload_timer_.IsRunning() && !callback_pending_) | |
52 StartScheduledUpload(); | |
53 } | |
54 | |
55 void LogUploader::ScheduleNextUpload() { | |
56 if (upload_timer_.IsRunning() || callback_pending_) | |
57 return; | |
58 | |
59 upload_timer_.Start( | |
60 FROM_HERE, upload_interval_, this, &LogUploader::StartScheduledUpload); | |
61 } | |
62 | |
63 void LogUploader::StartScheduledUpload() { | |
64 callback_pending_ = true; | |
65 current_fetch_.reset( | |
66 net::URLFetcher::Create(GURL(server_url_), net::URLFetcher::POST, this)); | |
67 current_fetch_->SetRequestContext(request_context_); | |
68 current_fetch_->SetUploadData(mime_type_, queued_logs_.front()); | |
69 | |
70 // We already drop cookies server-side, but we might as well strip them out | |
71 // client-side as well. | |
72 current_fetch_->SetLoadFlags(net::LOAD_DO_NOT_SAVE_COOKIES | | |
73 net::LOAD_DO_NOT_SEND_COOKIES); | |
74 current_fetch_->Start(); | |
75 } | |
76 | |
77 void LogUploader::OnURLFetchComplete(const net::URLFetcher* source) { | |
78 // We're not allowed to re-use the existing |URLFetcher|s, so free them here. | |
79 // Note however that |source| is aliased to the fetcher, so we should be | |
80 // careful not to delete it too early. | |
81 DCHECK_EQ(current_fetch_.get(), source); | |
82 scoped_ptr<net::URLFetcher> s(current_fetch_.Pass()); | |
83 | |
84 int response_code = source->GetResponseCode(); | |
85 | |
86 bool upload_succeeded = response_code == 200; | |
87 | |
88 // Provide boolean for error recovery (allow us to ignore response_code). | |
89 bool discard_log = false; | |
90 const size_t log_size = queued_logs_.front().length(); | |
91 if (!upload_succeeded && log_size > kUploadLogAvoidRetransmitSize) { | |
92 discard_log = true; | |
93 } else if (queued_logs_.size() > kMaxQueuedLogs) { | |
94 discard_log = true; | |
95 } else if (response_code == 400) { | |
96 // Bad syntax. Retransmission won't work. | |
97 discard_log = true; | |
98 } | |
99 | |
100 if (upload_succeeded || discard_log) | |
101 queued_logs_.pop(); | |
102 | |
103 // Error 400 indicates a problem with the log, not with the server, so | |
104 // don't consider that a sign that the server is in trouble. | |
105 bool server_is_healthy = upload_succeeded || response_code == 400; | |
106 UploadFinished(server_is_healthy, !queued_logs_.empty()); | |
107 } | |
108 | |
109 void LogUploader::UploadFinished(bool server_is_healthy, | |
110 bool more_logs_remaining) { | |
111 DCHECK(callback_pending_); | |
112 callback_pending_ = false; | |
113 // If the server is having issues, back off. Otherwise, reset to default. | |
114 if (!server_is_healthy) { | |
115 BackOffUploadInterval(); | |
116 } else { | |
Ilya Sherman
2014/01/10 11:00:32
nit: No need for curlies.
Steven Holte
2014/01/14 00:47:54
Done.
| |
117 upload_interval_ = TimeDelta::FromSeconds(kUnsentLogsIntervalSeconds); | |
118 } | |
119 | |
120 if (more_logs_remaining) { | |
121 ScheduleNextUpload(); | |
122 } | |
Ilya Sherman
2014/01/10 11:00:32
nit: No need for curlies.
Steven Holte
2014/01/14 00:47:54
Done.
| |
123 } | |
124 | |
125 void LogUploader::BackOffUploadInterval() { | |
126 DCHECK_GT(kBackoffMultiplier, 1.0); | |
127 upload_interval_ = TimeDelta::FromMicroseconds(static_cast<int64>( | |
128 kBackoffMultiplier * upload_interval_.InMicroseconds())); | |
129 | |
130 TimeDelta max_interval = kMaxBackoffMultiplier * | |
131 TimeDelta::FromSeconds(kUnsentLogsIntervalSeconds); | |
132 if (upload_interval_ > max_interval || upload_interval_.InSeconds() < 0) { | |
133 upload_interval_ = max_interval; | |
134 } | |
Ilya Sherman
2014/01/10 11:00:32
nit: No need for curlies.
Steven Holte
2014/01/14 00:47:54
Done.
| |
135 } | |
136 | |
137 } // namespace rappor | |
OLD | NEW |