1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
|
/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
/* vim:set ts=4 sw=2 sts=2 et cin: */
/* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/. */
// HttpLog.h should generally be included first
#include "HttpLog.h"
// Log on level :5, instead of default :4.
#undef LOG
#define LOG(args) LOG5(args)
#undef LOG_ENABLED
#define LOG_ENABLED() LOG5_ENABLED()
#define TLS_EARLY_DATA_NOT_AVAILABLE 0
#define TLS_EARLY_DATA_AVAILABLE_BUT_NOT_USED 1
#define TLS_EARLY_DATA_AVAILABLE_AND_USED 2
#include "mozilla/Telemetry.h"
#include "HttpConnectionBase.h"
#include "nsHttpHandler.h"
#include "nsIClassOfService.h"
#include "nsIOService.h"
#include "nsISocketTransport.h"
namespace mozilla {
namespace net {
//-----------------------------------------------------------------------------
// nsHttpConnection <public>
//-----------------------------------------------------------------------------
HttpConnectionBase::HttpConnectionBase() {
LOG(("Creating HttpConnectionBase @%p\n", this));
}
void HttpConnectionBase::BootstrapTimings(TimingStruct times) {
mBootstrappedTimingsSet = true;
mBootstrappedTimings = times;
}
void HttpConnectionBase::SetSecurityCallbacks(
nsIInterfaceRequestor* aCallbacks) {
MutexAutoLock lock(mCallbacksLock);
// This is called both on and off the main thread. For JS-implemented
// callbacks, we requires that the call happen on the main thread, but
// for C++-implemented callbacks we don't care. Use a pointer holder with
// strict checking disabled.
mCallbacks = new nsMainThreadPtrHolder<nsIInterfaceRequestor>(
"nsHttpConnection::mCallbacks", aCallbacks, false);
}
void HttpConnectionBase::SetTrafficCategory(HttpTrafficCategory aCategory) {
MOZ_ASSERT(OnSocketThread(), "not on socket thread");
if (aCategory == HttpTrafficCategory::eInvalid ||
mTrafficCategory.Contains(aCategory)) {
return;
}
Unused << mTrafficCategory.AppendElement(aCategory);
}
void HttpConnectionBase::ChangeConnectionState(ConnectionState aState) {
LOG(("HttpConnectionBase::ChangeConnectionState this=%p (%d->%d)", this,
static_cast<uint32_t>(mConnectionState), static_cast<uint32_t>(aState)));
// The state can't move backward.
if (aState <= mConnectionState) {
return;
}
mConnectionState = aState;
}
void HttpConnectionBase::RecordConnectionCloseTelemetry(nsresult aReason) {
/**
*
* The returned telemetry key has the format:
* "Version_EndToEndSSL_IsTrrServiceChannel_ExperienceState_ConnectionState"
*
* - Version: The HTTP version of the connection.
* - EndToEndSSL: Indicates whether SSL encryption is end-to-end.
* - IsTrrServiceChannel: Specifies if the connection is used to send TRR
* requests.
* - ExperienceState: ConnectionExperienceState
* - ConnectionState: The connection state before closing.
*/
auto key = nsPrintfCString("%d_%d_%d_%d_%d", static_cast<uint32_t>(Version()),
mConnInfo->EndToEndSSL(),
mConnInfo->GetIsTrrServiceChannel(),
static_cast<uint32_t>(mExperienceState),
static_cast<uint32_t>(mConnectionState));
SetCloseReason(ToCloseReason(aReason));
LOG(("RecordConnectionCloseTelemetry key=%s reason=%d\n", key.get(),
static_cast<uint32_t>(mCloseReason)));
Telemetry::Accumulate(Telemetry::HTTP_CONNECTION_CLOSE_REASON, key,
static_cast<uint32_t>(mCloseReason));
}
} // namespace net
} // namespace mozilla
|
