| /external/chromium_org/net/quic/test_tools/ |
| quic_sent_packet_manager_peer.cc | 25 QuicPacketSequenceNumber sequence_number) {
27 sequence_number)->second->nack_count();
33 QuicPacketSequenceNumber sequence_number) {
34 DCHECK(ContainsKey(sent_packet_manager->unacked_packets_, sequence_number));
37 .find(sequence_number)->second.sent_time;
49 QuicPacketSequenceNumber sequence_number) {
50 DCHECK(sent_packet_manager->HasRetransmittableFrames(sequence_number));
51 return sent_packet_manager->HasRetransmittableFrames(sequence_number) &&
53 unacked_packets_[sequence_number].previous_transmissions != NULL;
59 QuicPacketSequenceNumber sequence_number,
[all...] |
| quic_sent_packet_manager_peer.h | 24 QuicPacketSequenceNumber sequence_number);
27 QuicPacketSequenceNumber sequence_number);
31 // Returns true if |sequence_number| is a retransmission of a packet.
33 QuicPacketSequenceNumber sequence_number);
36 QuicPacketSequenceNumber sequence_number,
|
| quic_connection_peer.cc | 72 QuicPacketSequenceNumber sequence_number) {
73 return connection->sent_packet_manager_.IsUnacked(sequence_number) &&
75 sequence_number);
81 QuicPacketSequenceNumber sequence_number) {
83 &connection->sent_packet_manager_, sequence_number);
90 QuicPacketSequenceNumber sequence_number) {
91 return connection->sent_entropy_manager_.EntropyHash(sequence_number);
107 QuicPacketSequenceNumber sequence_number) {
109 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 | 48 QuicPacketSequenceNumber sequence_number = header.packet_sequence_number; local
49 DCHECK(IsAwaitingPacket(sequence_number));
59 DVLOG(1) << "Removing " << sequence_number << " from missing list";
60 received_info_.missing_packets.erase(sequence_number);
66 RecordPacketEntropyHash(sequence_number, header.entropy_hash);
71 bytes, sequence_number, receipt_time, revived);
76 QuicPacketSequenceNumber sequence_number) {
77 return ContainsKey(received_info_.missing_packets, sequence_number);
81 QuicPacketSequenceNumber sequence_number) {
82 return ::net::IsAwaitingPacket(received_info_, sequence_number);
[all...] |
| quic_ack_notifier.cc | 26 const QuicPacketSequenceNumber& sequence_number) {
27 sequence_numbers_.insert(sequence_number);
38 bool QuicAckNotifier::OnAck(QuicPacketSequenceNumber sequence_number) {
39 DCHECK(ContainsKey(sequence_numbers_, sequence_number));
40 sequence_numbers_.erase(sequence_number);
|
| quic_sent_packet_manager.cc | 118 unacked_packets_.rbegin()->first < serialized_packet.sequence_number);
119 unacked_packets_[serialized_packet.sequence_number] =
194 QuicPacketSequenceNumber sequence_number) {
195 MarkPacketReceivedByPeer(sequence_number);
204 QuicPacketSequenceNumber sequence_number = it->first; local
205 if (sequence_number > received_info.largest_observed) {
210 if (IsAwaitingPacket(received_info, sequence_number)) {
216 DVLOG(1) << ENDPOINT <<"Got an ack for packet " << sequence_number; local
219 it = MarkPacketReceivedByPeer(sequence_number);
222 ack_notifier_manager_.OnPacketAcked(sequence_number);
236 QuicPacketSequenceNumber sequence_number = it->first; local
322 QuicPacketSequenceNumber sequence_number = local
437 QuicPacketSequenceNumber sequence_number = it->first; local
497 QuicPacketSequenceNumber sequence_number = *it; local
571 QuicPacketSequenceNumber sequence_number = *it; local
[all...] |
| quic_sent_packet_manager.h | 45 PendingRetransmission(QuicPacketSequenceNumber sequence_number,
49 : sequence_number(sequence_number),
55 QuicPacketSequenceNumber sequence_number; member in struct:net::QuicSentPacketManager::PendingRetransmission
95 // Discards any information for the packet corresponding to |sequence_number|.
98 void DiscardUnackedPacket(QuicPacketSequenceNumber sequence_number);
100 // Returns true if the non-FEC packet |sequence_number| is unacked.
101 bool IsUnacked(QuicPacketSequenceNumber sequence_number) const;
106 // Returns true if the unacked packet |sequence_number| has retransmittable
110 bool HasRetransmittableFrames(QuicPacketSequenceNumber sequence_number) const
[all...] |
| /external/chromium_org/content/browser/ |
| 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...] |
| 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_synchronizer.cc | 44 RequestContext(const base::Closure& callback, int sequence_number)
46 sequence_number_(sequence_number),
80 // |sequence_number|.
81 static void Register(const base::Closure& callback, int sequence_number) {
84 RequestContext* request = new RequestContext(callback, sequence_number);
85 outstanding_requests_.Get()[sequence_number] = request;
89 // |sequence_number|.
90 static RequestContext* GetRequestContext(int sequence_number) {
94 outstanding_requests_.Get().find(sequence_number);
99 DCHECK_EQ(sequence_number, request->sequence_number_)
234 int sequence_number = GetNextAvailableSequenceNumber(requester); local
[all...] |
| histogram_subscriber.h | 20 virtual void OnPendingProcesses(int sequence_number,
27 int sequence_number,
|
| /external/chromium_org/content/child/ |
| child_histogram_message_filter.cc | 44 void ChildHistogramMessageFilter::SendHistograms(int sequence_number) {
47 this, sequence_number));
50 void ChildHistogramMessageFilter::OnGetChildHistogramData(int sequence_number) {
51 UploadAllHistograms(sequence_number);
54 void ChildHistogramMessageFilter::UploadAllHistograms(int sequence_number) {
63 new ChildProcessHostMsg_ChildHistogramData(sequence_number, deltas));
|
| /external/chromium_org/content/browser/renderer_host/media/ |
| webrtc_identity_service_host.cc | 40 int sequence_number,
47 SendErrorMessage(sequence_number, net::ERR_INSUFFICIENT_RESOURCES);
55 SendErrorMessage(sequence_number, net::ERR_ACCESS_DENIED);
65 sequence_number));
67 SendErrorMessage(sequence_number, net::ERR_UNEXPECTED);
78 void WebRTCIdentityServiceHost::OnComplete(int sequence_number,
85 sequence_number, certificate, private_key));
87 SendErrorMessage(sequence_number, status);
91 void WebRTCIdentityServiceHost::SendErrorMessage(int sequence_number,
93 Send(new WebRTCIdentityHostMsg_RequestFailed(sequence_number, error))
[all...] |
| webrtc_identity_service_host.h | 40 // |sequence_number| is the same as in the OnRequestIdentity call.
42 void OnComplete(int sequence_number,
47 // |sequence_number| is a renderer wide unique number for each request and
52 void OnRequestIdentity(int sequence_number,
59 void SendErrorMessage(int sequence_number, int error);
|
| /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...] |
| 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);
|
| /external/chromium_org/chrome/browser/metrics/ |
| 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/common/media/ |
| webrtc_identity_messages.h | 19 int /* sequence_number */,
29 int /* sequence_number */,
34 int /* sequence_number */,
|
| /external/chromium_org/ppapi/proxy/ |
| resource_reply_thread_registrar.cc | 25 int32_t sequence_number,
42 map_[resource][sequence_number] = reply_thread;
54 int32_t sequence_number) {
61 resource_iter->second.find(sequence_number);
|
| /external/chromium/chrome/browser/metrics/ |
| histogram_synchronizer.cc | 95 int sequence_number = local
106 sequence_number),
112 int sequence_number,
126 current_synchronizer->DecrementPendingRenderers(sequence_number);
140 int sequence_number = GetNextAvailableSequenceNumber(requester, local
145 new ViewMsg_GetRendererHistograms(sequence_number)))
146 DecrementPendingRenderers(sequence_number);
149 return sequence_number;
152 void HistogramSynchronizer::DecrementPendingRenderers(int sequence_number) {
158 if (sequence_number == async_sequence_number_)
[all...] |
| /external/chromium_org/content/public/browser/ |
| profiler_subscriber.h | 21 virtual void OnPendingProcesses(int sequence_number,
28 int sequence_number,
|
