netwerk/protocol/http/ConnectionDiagnostics.cpp@6474c204b198
netwerk/protocol/http/ConnectionDiagnostics.cpp
Wed, 31 Dec 2014 06:09:35 +0100
- author
- Michael Schloh von Bennewitz <michael@schloh.com>
- date
- Wed, 31 Dec 2014 06:09:35 +0100
- changeset 0
- 6474c204b198
- permissions
- -rw-r--r--
Cloned upstream origin tor-browser at tor-browser-31.3.0esr-4.5-1-build1
revision ID fc1c9ff7c1b2defdbc039f12214767608f46423f for hacking purpose.
1 /* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
2 /* vim: set sw=2 ts=8 et tw=80 : */
3 /* This Source Code Form is subject to the terms of the Mozilla Public
4 * License, v. 2.0. If a copy of the MPL was not distributed with this
5 * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
7 // HttpLog.h should generally be included first
8 #include "HttpLog.h"
10 #include "nsHttpConnectionMgr.h"
11 #include "nsHttpConnection.h"
12 #include "SpdySession3.h"
13 #include "SpdySession31.h"
14 #include "Http2Session.h"
15 #include "nsHttpHandler.h"
16 #include "nsIConsoleService.h"
17 #include "nsHttpRequestHead.h"
19 extern PRThread *gSocketThread;
21 namespace mozilla {
22 namespace net {
24 void
25 nsHttpConnectionMgr::PrintDiagnostics()
26 {
27 PostEvent(&nsHttpConnectionMgr::OnMsgPrintDiagnostics, 0, nullptr);
28 }
30 void
31 nsHttpConnectionMgr::OnMsgPrintDiagnostics(int32_t, void *)
32 {
33 MOZ_ASSERT(PR_GetCurrentThread() == gSocketThread);
35 nsCOMPtr<nsIConsoleService> consoleService =
36 do_GetService(NS_CONSOLESERVICE_CONTRACTID);
37 if (!consoleService)
38 return;
40 mLogData.AppendPrintf("HTTP Connection Diagnostics\n---------------------\n");
41 mLogData.AppendPrintf("IsSpdyEnabled() = %d\n", gHttpHandler->IsSpdyEnabled());
42 mLogData.AppendPrintf("MaxSocketCount() = %d\n", gHttpHandler->MaxSocketCount());
43 mLogData.AppendPrintf("mNumActiveConns = %d\n", mNumActiveConns);
44 mLogData.AppendPrintf("mNumIdleConns = %d\n", mNumIdleConns);
46 mCT.Enumerate(PrintDiagnosticsCB, this);
48 consoleService->LogStringMessage(NS_ConvertUTF8toUTF16(mLogData).Data());
49 mLogData.Truncate();
50 }
52 PLDHashOperator
53 nsHttpConnectionMgr::PrintDiagnosticsCB(const nsACString &key,
54 nsAutoPtr<nsConnectionEntry> &ent,
55 void *closure)
56 {
57 nsHttpConnectionMgr *self = static_cast<nsHttpConnectionMgr *>(closure);
58 uint32_t i;
60 self->mLogData.AppendPrintf(" ent host = %s hashkey = %s\n",
61 ent->mConnInfo->Host(), ent->mConnInfo->HashKey().get());
62 self->mLogData.AppendPrintf(" AtActiveConnectionLimit = %d\n",
63 self->AtActiveConnectionLimit(ent, NS_HTTP_ALLOW_KEEPALIVE));
64 self->mLogData.AppendPrintf(" RestrictConnections = %d\n",
65 self->RestrictConnections(ent));
66 self->mLogData.AppendPrintf(" Pending Q Length = %u\n",
67 ent->mPendingQ.Length());
68 self->mLogData.AppendPrintf(" Active Conns Length = %u\n",
69 ent->mActiveConns.Length());
70 self->mLogData.AppendPrintf(" Idle Conns Length = %u\n",
71 ent->mIdleConns.Length());
72 self->mLogData.AppendPrintf(" Half Opens Length = %u\n",
73 ent->mHalfOpens.Length());
74 self->mLogData.AppendPrintf(" Coalescing Key = %s\n",
75 ent->mCoalescingKey.get());
76 self->mLogData.AppendPrintf(" Spdy using = %d, tested = %d, preferred = %d\n",
77 ent->mUsingSpdy, ent->mTestedSpdy, ent->mSpdyPreferred);
78 self->mLogData.AppendPrintf(" pipelinestate = %d penalty = %d\n",
79 ent->mPipelineState, ent->mPipeliningPenalty);
80 for (i = 0; i < nsAHttpTransaction::CLASS_MAX; ++i) {
81 self->mLogData.AppendPrintf(" pipeline per class penalty 0x%x %d\n",
82 i, ent->mPipeliningClassPenalty[i]);
83 }
84 for (i = 0; i < ent->mActiveConns.Length(); ++i) {
85 self->mLogData.AppendPrintf(" :: Active Connection #%u\n", i);
86 ent->mActiveConns[i]->PrintDiagnostics(self->mLogData);
87 }
88 for (i = 0; i < ent->mIdleConns.Length(); ++i) {
89 self->mLogData.AppendPrintf(" :: Idle Connection #%u\n", i);
90 ent->mIdleConns[i]->PrintDiagnostics(self->mLogData);
91 }
92 for (i = 0; i < ent->mHalfOpens.Length(); ++i) {
93 self->mLogData.AppendPrintf(" :: Half Open #%u\n", i);
94 ent->mHalfOpens[i]->PrintDiagnostics(self->mLogData);
95 }
96 for (i = 0; i < ent->mPendingQ.Length(); ++i) {
97 self->mLogData.AppendPrintf(" :: Pending Transaction #%u\n", i);
98 ent->mPendingQ[i]->PrintDiagnostics(self->mLogData);
99 }
101 return PL_DHASH_NEXT;
102 }
104 void
105 nsHttpConnectionMgr::nsHalfOpenSocket::PrintDiagnostics(nsCString &log)
106 {
107 log.AppendPrintf(" has connected = %d, isSpeculative = %d\n",
108 HasConnected(), IsSpeculative());
110 TimeStamp now = TimeStamp::Now();
112 if (mPrimarySynStarted.IsNull())
113 log.AppendPrintf(" primary not started\n");
114 else
115 log.AppendPrintf(" primary started %.2fms ago\n",
116 (now - mPrimarySynStarted).ToMilliseconds());
118 if (mBackupSynStarted.IsNull())
119 log.AppendPrintf(" backup not started\n");
120 else
121 log.AppendPrintf(" backup started %.2f ago\n",
122 (now - mBackupSynStarted).ToMilliseconds());
124 log.AppendPrintf(" primary transport %d, backup transport %d\n",
125 !!mSocketTransport.get(), !!mBackupTransport.get());
126 }
128 void
129 nsHttpConnection::PrintDiagnostics(nsCString &log)
130 {
131 log.AppendPrintf(" CanDirectlyActivate = %d\n", CanDirectlyActivate());
133 log.AppendPrintf(" npncomplete = %d setupSSLCalled = %d\n",
134 mNPNComplete, mSetupSSLCalled);
136 log.AppendPrintf(" spdyVersion = %d reportedSpdy = %d everspdy = %d\n",
137 mUsingSpdyVersion, mReportedSpdy, mEverUsedSpdy);
139 log.AppendPrintf(" iskeepalive = %d dontReuse = %d isReused = %d\n",
140 IsKeepAlive(), mDontReuse, mIsReused);
142 log.AppendPrintf(" mTransaction = %d mSpdySession = %d\n",
143 !!mTransaction.get(), !!mSpdySession.get());
145 PRIntervalTime now = PR_IntervalNow();
146 log.AppendPrintf(" time since last read = %ums\n",
147 PR_IntervalToMilliseconds(now - mLastReadTime));
149 log.AppendPrintf(" max-read/read/written %lld/%lld/%lld\n",
150 mMaxBytesRead, mTotalBytesRead, mTotalBytesWritten);
152 log.AppendPrintf(" rtt = %ums\n", PR_IntervalToMilliseconds(mRtt));
154 log.AppendPrintf(" idlemonitoring = %d transactionCount=%d\n",
155 mIdleMonitoring, mHttp1xTransactionCount);
157 log.AppendPrintf(" supports pipeline = %d classification = 0x%x\n",
158 mSupportsPipelining, mClassification);
160 if (mSpdySession)
161 mSpdySession->PrintDiagnostics(log);
162 }
165 void
166 SpdySession3::PrintDiagnostics(nsCString &log)
167 {
168 log.AppendPrintf(" ::: SPDY VERSION 3\n");
169 log.AppendPrintf(" shouldgoaway = %d mClosed = %d CanReuse = %d nextID=0x%X\n",
170 mShouldGoAway, mClosed, CanReuse(), mNextStreamID);
172 log.AppendPrintf(" concurrent = %d maxconcurrent = %d\n",
173 mConcurrent, mMaxConcurrent);
175 log.AppendPrintf(" roomformorestreams = %d roomformoreconcurrent = %d\n",
176 RoomForMoreStreams(), RoomForMoreConcurrent());
178 log.AppendPrintf(" transactionHashCount = %d streamIDHashCount = %d\n",
179 mStreamTransactionHash.Count(),
180 mStreamIDHash.Count());
182 log.AppendPrintf(" Queued Stream Size = %d\n", mQueuedStreams.GetSize());
184 PRIntervalTime now = PR_IntervalNow();
185 log.AppendPrintf(" Ping Threshold = %ums next ping id = 0x%X\n",
186 PR_IntervalToMilliseconds(mPingThreshold),
187 mNextPingID);
188 log.AppendPrintf(" Ping Timeout = %ums\n",
189 PR_IntervalToMilliseconds(gHttpHandler->SpdyPingTimeout()));
190 log.AppendPrintf(" Idle for Any Activity (ping) = %ums\n",
191 PR_IntervalToMilliseconds(now - mLastReadEpoch));
192 log.AppendPrintf(" Idle for Data Activity = %ums\n",
193 PR_IntervalToMilliseconds(now - mLastDataReadEpoch));
194 if (mPingSentEpoch)
195 log.AppendPrintf(" Ping Outstanding (ping) = %ums, expired = %d\n",
196 PR_IntervalToMilliseconds(now - mPingSentEpoch),
197 now - mPingSentEpoch >= gHttpHandler->SpdyPingTimeout());
198 else
199 log.AppendPrintf(" No Ping Outstanding\n");
200 }
202 void
203 SpdySession31::PrintDiagnostics(nsCString &log)
204 {
205 log.AppendPrintf(" ::: SPDY VERSION 3.1\n");
206 log.AppendPrintf(" shouldgoaway = %d mClosed = %d CanReuse = %d nextID=0x%X\n",
207 mShouldGoAway, mClosed, CanReuse(), mNextStreamID);
209 log.AppendPrintf(" concurrent = %d maxconcurrent = %d\n",
210 mConcurrent, mMaxConcurrent);
212 log.AppendPrintf(" roomformorestreams = %d roomformoreconcurrent = %d\n",
213 RoomForMoreStreams(), RoomForMoreConcurrent());
215 log.AppendPrintf(" transactionHashCount = %d streamIDHashCount = %d\n",
216 mStreamTransactionHash.Count(),
217 mStreamIDHash.Count());
219 log.AppendPrintf(" Queued Stream Size = %d\n", mQueuedStreams.GetSize());
221 PRIntervalTime now = PR_IntervalNow();
222 log.AppendPrintf(" Ping Threshold = %ums next ping id = 0x%X\n",
223 PR_IntervalToMilliseconds(mPingThreshold),
224 mNextPingID);
225 log.AppendPrintf(" Ping Timeout = %ums\n",
226 PR_IntervalToMilliseconds(gHttpHandler->SpdyPingTimeout()));
227 log.AppendPrintf(" Idle for Any Activity (ping) = %ums\n",
228 PR_IntervalToMilliseconds(now - mLastReadEpoch));
229 log.AppendPrintf(" Idle for Data Activity = %ums\n",
230 PR_IntervalToMilliseconds(now - mLastDataReadEpoch));
231 if (mPingSentEpoch)
232 log.AppendPrintf(" Ping Outstanding (ping) = %ums, expired = %d\n",
233 PR_IntervalToMilliseconds(now - mPingSentEpoch),
234 now - mPingSentEpoch >= gHttpHandler->SpdyPingTimeout());
235 else
236 log.AppendPrintf(" No Ping Outstanding\n");
237 }
239 void
240 Http2Session::PrintDiagnostics(nsCString &log)
241 {
242 log.AppendPrintf(" ::: HTTP2\n");
243 log.AppendPrintf(" shouldgoaway = %d mClosed = %d CanReuse = %d nextID=0x%X\n",
244 mShouldGoAway, mClosed, CanReuse(), mNextStreamID);
246 log.AppendPrintf(" concurrent = %d maxconcurrent = %d\n",
247 mConcurrent, mMaxConcurrent);
249 log.AppendPrintf(" roomformorestreams = %d roomformoreconcurrent = %d\n",
250 RoomForMoreStreams(), RoomForMoreConcurrent());
252 log.AppendPrintf(" transactionHashCount = %d streamIDHashCount = %d\n",
253 mStreamTransactionHash.Count(),
254 mStreamIDHash.Count());
256 log.AppendPrintf(" Queued Stream Size = %d\n", mQueuedStreams.GetSize());
258 PRIntervalTime now = PR_IntervalNow();
259 log.AppendPrintf(" Ping Threshold = %ums\n",
260 PR_IntervalToMilliseconds(mPingThreshold));
261 log.AppendPrintf(" Ping Timeout = %ums\n",
262 PR_IntervalToMilliseconds(gHttpHandler->SpdyPingTimeout()));
263 log.AppendPrintf(" Idle for Any Activity (ping) = %ums\n",
264 PR_IntervalToMilliseconds(now - mLastReadEpoch));
265 log.AppendPrintf(" Idle for Data Activity = %ums\n",
266 PR_IntervalToMilliseconds(now - mLastDataReadEpoch));
267 if (mPingSentEpoch)
268 log.AppendPrintf(" Ping Outstanding (ping) = %ums, expired = %d\n",
269 PR_IntervalToMilliseconds(now - mPingSentEpoch),
270 now - mPingSentEpoch >= gHttpHandler->SpdyPingTimeout());
271 else
272 log.AppendPrintf(" No Ping Outstanding\n");
273 }
275 void
276 nsHttpTransaction::PrintDiagnostics(nsCString &log)
277 {
278 if (!mRequestHead)
279 return;
281 log.AppendPrintf(" ::: uri = %s\n",
282 nsAutoCString(mRequestHead->RequestURI()).get());
283 log.AppendPrintf(" caps = 0x%x\n", mCaps);
284 log.AppendPrintf(" priority = %d\n", mPriority);
285 log.AppendPrintf(" restart count = %u\n", mRestartCount);
286 log.AppendPrintf(" classification = 0x%x\n", mClassification);
287 }
289 } // namespace mozilla::net
290 } // namespace mozilla
