| /external/chromium_org/content/browser/ |
| histogram_subscriber.h | 20 virtual void OnPendingProcesses(int sequence_number,
27 int sequence_number,
|
| histogram_controller.h | 42 void GetHistogramData(int sequence_number);
49 void OnPendingProcesses(int sequence_number, int pending_processes, bool end);
54 int sequence_number,
63 void GetHistogramDataFromChildProcesses(int sequence_number);
|
| profiler_controller_impl.h | 35 void OnPendingProcesses(int sequence_number, int pending_processes, bool end);
40 int sequence_number,
47 virtual void GetProfilerData(int sequence_number) OVERRIDE;
53 void GetProfilerDataFromChildProcesses(int sequence_number);
|
| histogram_controller.cc | 29 void HistogramController::OnPendingProcesses(int sequence_number,
34 subscriber_->OnPendingProcesses(sequence_number, pending_processes, end);
38 int sequence_number,
45 sequence_number,
52 subscriber_->OnHistogramDataCollected(sequence_number,
70 int sequence_number) {
84 if (!iter.Send(new ChildProcessMsg_GetChildHistogramData(sequence_number)))
94 sequence_number,
99 void HistogramController::GetHistogramData(int sequence_number) {
107 new ChildProcessMsg_GetChildHistogramData(sequence_number))) {
[all...] |
| profiler_controller_impl.cc | 34 void ProfilerControllerImpl::OnPendingProcesses(int sequence_number,
39 subscriber_->OnPendingProcesses(sequence_number, pending_processes, end);
43 int sequence_number,
51 sequence_number,
59 subscriber_->OnProfilerDataCollected(sequence_number, profiler_data,
76 int sequence_number) {
89 if (!iter.Send(new ChildProcessMsg_GetChildProfilerData(sequence_number)))
99 sequence_number,
104 void ProfilerControllerImpl::GetProfilerData(int sequence_number) {
112 new ChildProcessMsg_GetChildProfilerData(sequence_number))) {
[all...] |
| histogram_synchronizer.cc | 43 RequestContext(const base::Closure& callback, int sequence_number)
45 sequence_number_(sequence_number),
79 // |sequence_number|.
80 static void Register(const base::Closure& callback, int sequence_number) {
83 RequestContext* request = new RequestContext(callback, sequence_number);
84 outstanding_requests_.Get()[sequence_number] = request;
88 // |sequence_number|.
89 static RequestContext* GetRequestContext(int sequence_number) {
93 outstanding_requests_.Get().find(sequence_number);
98 DCHECK_EQ(sequence_number, request->sequence_number_)
233 int sequence_number = GetNextAvailableSequenceNumber(requester); local
[all...] |
| histogram_synchronizer.h | 96 // Update the number of pending processes for the given |sequence_number|.
98 virtual void OnPendingProcesses(int sequence_number,
106 int sequence_number,
117 void ForceHistogramSynchronizationDoneCallback(int sequence_number);
137 // give up on a "slow to respond" process. We use a sequence_number to be
|
| /external/chromium_org/content/public/browser/ |
| profiler_subscriber.h | 21 virtual void OnPendingProcesses(int sequence_number,
28 int sequence_number,
|
| /external/chromium_org/net/quic/ |
| quic_sent_entropy_manager.h | 26 // Record |entropy_hash| for sent packet corresponding to |sequence_number|.
27 void RecordPacketEntropyHash(QuicPacketSequenceNumber sequence_number,
31 QuicPacketSequenceNumber sequence_number) const;
34 // up to |sequence_number| removing sequence numbers from |missing_packets|.
35 bool IsValidEntropy(QuicPacketSequenceNumber sequence_number,
40 // |sequence_number|.
41 void ClearEntropyBefore(QuicPacketSequenceNumber sequence_number);
|
| quic_sent_entropy_manager.cc | 22 QuicPacketSequenceNumber sequence_number,
28 make_pair(sequence_number,
32 << " updated with sequence number " << sequence_number
37 QuicPacketSequenceNumber sequence_number) const {
39 packets_entropy_.find(sequence_number);
42 DCHECK_EQ(0u, sequence_number);
49 QuicPacketSequenceNumber sequence_number,
53 packets_entropy_.find(sequence_number);
55 DCHECK_EQ(0u, sequence_number);
57 return 0 == sequence_number;
[all...] |
| quic_received_packet_manager.cc | 31 QuicPacketSequenceNumber sequence_number = header.packet_sequence_number; local
32 DCHECK(IsAwaitingPacket(sequence_number));
42 DVLOG(1) << "Removing " << sequence_number << " from missing list";
43 received_info_.missing_packets.erase(sequence_number);
49 RecordPacketEntropyHash(sequence_number, header.entropy_hash);
53 QuicPacketSequenceNumber sequence_number) {
54 return ::net::IsAwaitingPacket(received_info_, sequence_number);
74 QuicPacketSequenceNumber sequence_number,
76 if (sequence_number < largest_sequence_number_) {
77 DLOG(INFO) << "Ignoring received packet entropy for sequence_number:
[all...] |
| quic_received_packet_manager.h | 33 // Checks if we're still waiting for the packet with |sequence_number|.
34 bool IsAwaitingPacket(QuicPacketSequenceNumber sequence_number);
44 QuicPacketSequenceNumber sequence_number) const OVERRIDE;
71 // Record the received entropy hash against |sequence_number|.
72 void RecordPacketEntropyHash(QuicPacketSequenceNumber sequence_number,
|
| quic_connection.cc | 473 packet_creator_.sequence_number()) {
476 << packet_creator_.sequence_number();
552 QuicPacketSequenceNumber sequence_number = it->first; local
553 if (sequence_number >
559 if (!IsAwaitingPacket(incoming_ack.received_info, sequence_number)) {
561 DVLOG(1) << ENDPOINT <<"Got an ack for packet " << sequence_number; local
562 acked_packets->insert(sequence_number);
565 retransmission_map_.erase(sequence_number);
570 DVLOG(1) << ENDPOINT << "still missing packet " << sequence_number; local
575 retransmission_map_.find(sequence_number);
582 << sequence_number local
595 QuicPacketSequenceNumber sequence_number = it->first; local
601 DVLOG(1) << ENDPOINT << "Got an ack for fec packet: " << sequence_number; local
606 << sequence_number; local
953 DVLOG(2) << ENDPOINT << "alarm fired for " << sequence_number local
1082 DVLOG(1) << ENDPOINT << "Will not retransmit packet " << sequence_number; local
1157 DLOG(INFO) << ENDPOINT << "Dropped packet: " << sequence_number local
1341 << sequence_number << "; it's already acked'"; local
[all...] |
| /external/chromium_org/net/quic/congestion_control/ |
| available_channel_estimator.cc | 12 QuicPacketSequenceNumber sequence_number,
15 : first_sequence_number_(sequence_number),
18 last_incorporated_sequence_number_(sequence_number),
26 QuicPacketSequenceNumber sequence_number,
30 if (sequence_number <= first_sequence_number_) {
34 if (sequence_number <= last_incorporated_sequence_number_) {
39 last_incorporated_sequence_number_ = sequence_number;
|
| hybrid_slow_start_test.cc | 30 QuicPacketSequenceNumber sequence_number = 1; local
34 EXPECT_FALSE(slowStart_->EndOfRound(sequence_number++));
37 EXPECT_FALSE(slowStart_->EndOfRound(sequence_number));
39 EXPECT_FALSE(slowStart_->EndOfRound(sequence_number++));
40 EXPECT_TRUE(slowStart_->EndOfRound(sequence_number++));
43 EXPECT_TRUE(slowStart_->EndOfRound(sequence_number++));
47 while (sequence_number < end_sequence_number) {
48 EXPECT_FALSE(slowStart_->EndOfRound(sequence_number++));
50 EXPECT_TRUE(slowStart_->EndOfRound(sequence_number++));
58 QuicPacketSequenceNumber sequence_number = 2 local
[all...] |
| inter_arrival_receiver.cc | 39 QuicPacketSequenceNumber sequence_number,
45 received_packet_times_.insert(std::make_pair(sequence_number, timestamp));
|
| channel_estimator.cc | 31 QuicPacketSequenceNumber sequence_number,
35 if (last_sequence_number_ > sequence_number) {
36 // Old packet. The sequence_number use the full 64 bits even though it's
40 if (last_sequence_number_ != sequence_number - 1) {
48 UpdateFilter(received_delta, packet_size, sequence_number);
51 last_sequence_number_ = sequence_number;
104 QuicPacketSequenceNumber sequence_number) {
107 sorted_bitrate_estimates_.Insert(estimate, sequence_number);
|
| inter_arrival_probe.cc | 57 QuicPacketSequenceNumber sequence_number,
70 first_sequence_number_ = sequence_number;
72 sequence_number, time_sent, time_received));
76 available_channel_estimator_->OnIncomingFeedback(sequence_number,
80 if (sequence_number < kProbeSizePackets - 1 + first_sequence_number_) {
|
| channel_estimator.h | 38 void OnAcknowledgedPacket(QuicPacketSequenceNumber sequence_number,
49 QuicPacketSequenceNumber sequence_number);
|
| quic_congestion_manager_test.cc | 90 for (QuicPacketSequenceNumber sequence_number = 1; sequence_number <= 100;
91 ++sequence_number) {
96 sequence_number, clock_.Now(), 1000, NOT_RETRANSMISSION);
98 ack.received_info.largest_observed = sequence_number;
141 QuicPacketSequenceNumber sequence_number = 1; local
146 OnIncomingAck(sequence_number, _, expected_rtt)).Times(1);
148 manager_->SentPacket(sequence_number, clock_.Now(), 1000, NOT_RETRANSMISSION);
152 ack.received_info.largest_observed = sequence_number;
167 QuicPacketSequenceNumber sequence_number = 1 local
193 QuicPacketSequenceNumber sequence_number = 1; local
218 QuicPacketSequenceNumber sequence_number = 1; local
[all...] |
| /external/chromium_org/chrome/browser/metrics/ |
| tracking_synchronizer.h | 58 // Update the number of pending processes for the given |sequence_number|.
60 virtual void OnPendingProcesses(int sequence_number,
76 int sequence_number,
87 // It finds the RequestContext for the given |sequence_number| and notifies
93 // the entry for sequence_number. This method is accessible on UI thread.
95 int sequence_number,
105 // give up on a "slow to respond" process. We use a sequence_number to be
|
| tracking_synchronizer.cc | 49 int sequence_number)
51 sequence_number_(sequence_number),
90 // |sequence_number|.
92 int sequence_number,
97 callback_object, sequence_number);
98 outstanding_requests_.Get()[sequence_number] = request;
104 // |sequence_number|.
105 static RequestContext* GetRequestContext(int sequence_number) {
109 outstanding_requests_.Get().find(sequence_number);
114 DCHECK_EQ(sequence_number, request->sequence_number_)
209 int sequence_number = g_tracking_synchronizer->RegisterAndNotifyAllProcesses( local
246 int sequence_number = GetNextAvailableSequenceNumber(); local
[all...] |
| /external/chromium_org/content/renderer/pepper/ |
| pepper_browser_connection.cc | 66 int32_t sequence_number = GetNextSequence(); local
67 pending_create_map_[sequence_number] = callback;
68 ppapi::proxy::ResourceMessageCallParams params(0, sequence_number);
81 int32_t sequence_number = GetNextSequence(); local
82 get_info_map_[sequence_number] = callback;
84 routing_id(), child_process_id, sequence_number, resources));
88 int32_t sequence_number,
93 pending_create_map_.find(sequence_number);
103 int32_t sequence_number,
111 get_info_map_.find(sequence_number);
[all...] |
| /external/chromium_org/content/child/ |
| child_histogram_message_filter.h | 34 void SendHistograms(int sequence_number);
51 virtual void OnGetChildHistogramData(int sequence_number);
55 void UploadAllHistograms(int sequence_number);
|
| child_histogram_message_filter.cc | 46 void ChildHistogramMessageFilter::SendHistograms(int sequence_number) {
49 this, sequence_number));
52 void ChildHistogramMessageFilter::OnGetChildHistogramData(int sequence_number) {
53 UploadAllHistograms(sequence_number);
56 void ChildHistogramMessageFilter::UploadAllHistograms(int sequence_number) {
67 sequence_number, pickled_histograms_));
|
