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
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
|
// Copyright (c) 2012 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.
#ifndef CHROME_BROWSER_NET_LOAD_TIMING_OBSERVER_H_
#define CHROME_BROWSER_NET_LOAD_TIMING_OBSERVER_H_
#pragma once
#include "base/gtest_prod_util.h"
#include "base/hash_tables.h"
#include "base/time.h"
#include "net/base/net_log.h"
#include "webkit/glue/resource_loader_bridge.h"
namespace content {
struct ResourceResponse;
}
namespace net {
class URLRequest;
} // namespace net
// LoadTimingObserver watches the NetLog event stream and collects the network
// timing information.
//
// LoadTimingObserver lives completely on the IOThread and ignores events from
// other threads. It is not safe to use from other threads.
class LoadTimingObserver : public net::NetLog::ThreadSafeObserver {
public:
struct URLRequestRecord {
URLRequestRecord();
webkit_glue::ResourceLoadTimingInfo timing;
uint32 connect_job_id;
uint32 socket_log_id;
bool socket_reused;
base::TimeTicks base_ticks;
};
struct HTTPStreamJobRecord {
HTTPStreamJobRecord();
uint32 socket_log_id;
bool socket_reused;
base::TimeTicks connect_start;
base::TimeTicks connect_end;
base::TimeTicks dns_start;
base::TimeTicks dns_end;
base::TimeTicks ssl_start;
base::TimeTicks ssl_end;
};
struct ConnectJobRecord {
base::TimeTicks dns_start;
base::TimeTicks dns_end;
};
struct SocketRecord {
base::TimeTicks ssl_start;
base::TimeTicks ssl_end;
};
LoadTimingObserver();
virtual ~LoadTimingObserver();
// Starts observing specified NetLog. Must not already be watching a NetLog.
// Separate from constructor to enforce thread safety.
void StartObserving(net::NetLog* net_log);
URLRequestRecord* GetURLRequestRecord(uint32 source_id);
// net::NetLog::ThreadSafeObserver implementation:
virtual void OnAddEntry(net::NetLog::EventType type,
const base::TimeTicks& time,
const net::NetLog::Source& source,
net::NetLog::EventPhase phase,
net::NetLog::EventParameters* params) OVERRIDE;
static void PopulateTimingInfo(net::URLRequest* request,
content::ResourceResponse* response);
private:
FRIEND_TEST_ALL_PREFIXES(LoadTimingObserverTest,
HTTPStreamJobRecord);
FRIEND_TEST_ALL_PREFIXES(LoadTimingObserverTest,
ConnectJobRecord);
FRIEND_TEST_ALL_PREFIXES(LoadTimingObserverTest,
SocketRecord);
void OnAddURLRequestEntry(net::NetLog::EventType type,
const base::TimeTicks& time,
const net::NetLog::Source& source,
net::NetLog::EventPhase phase,
net::NetLog::EventParameters* params);
void OnAddHTTPStreamJobEntry(net::NetLog::EventType type,
const base::TimeTicks& time,
const net::NetLog::Source& source,
net::NetLog::EventPhase phase,
net::NetLog::EventParameters* params);
void OnAddConnectJobEntry(net::NetLog::EventType type,
const base::TimeTicks& time,
const net::NetLog::Source& source,
net::NetLog::EventPhase phase,
net::NetLog::EventParameters* params);
void OnAddSocketEntry(net::NetLog::EventType type,
const base::TimeTicks& time,
const net::NetLog::Source& source,
net::NetLog::EventPhase phase,
net::NetLog::EventParameters* params);
URLRequestRecord* CreateURLRequestRecord(uint32 source_id);
void DeleteURLRequestRecord(uint32 source_id);
typedef base::hash_map<uint32, URLRequestRecord> URLRequestToRecordMap;
typedef base::hash_map<uint32, HTTPStreamJobRecord> HTTPStreamJobToRecordMap;
typedef base::hash_map<uint32, ConnectJobRecord> ConnectJobToRecordMap;
typedef base::hash_map<uint32, SocketRecord> SocketToRecordMap;
URLRequestToRecordMap url_request_to_record_;
HTTPStreamJobToRecordMap http_stream_job_to_record_;
ConnectJobToRecordMap connect_job_to_record_;
SocketToRecordMap socket_to_record_;
uint32 last_connect_job_id_;
ConnectJobRecord last_connect_job_record_;
DISALLOW_COPY_AND_ASSIGN(LoadTimingObserver);
};
#endif // CHROME_BROWSER_NET_LOAD_TIMING_OBSERVER_H_
|
