| /external/chromium_org/net/quic/ |
| quic_sent_entropy_manager.cc | 21 QuicPacketSequenceNumber sequence_number) const {
22 return packets_entropy_[sequence_number - map_offset_];
36 QuicPacketSequenceNumber sequence_number,
38 while (cumulative->sequence_number < sequence_number) {
39 ++cumulative->sequence_number;
40 cumulative->entropy ^= GetPacketEntropy(cumulative->sequence_number);
45 QuicPacketSequenceNumber sequence_number,
51 DCHECK_EQ(GetLargestPacketWithEntropy() + 1, sequence_number);
54 DVLOG(2) << "Recorded sequence number " << sequence_number
61 DCHECK_GE(GetLargestPacketWithEntropy(), sequence_number); local
[all...] |
| quic_received_packet_manager.cc | 43 QuicPacketSequenceNumber sequence_number) const {
44 DCHECK_LE(sequence_number, largest_observed_);
45 if (sequence_number == largest_observed_) {
49 DCHECK_GE(sequence_number, first_gap_);
54 i < (largest_observed_ - sequence_number); ++i, ++it) {
61 QuicPacketSequenceNumber sequence_number,
63 if (sequence_number < first_gap_) {
64 DVLOG(1) << "Ignoring received packet entropy for sequence_number:"
65 << sequence_number << " less than largest_peer_sequence_number:"
70 DCHECK(sequence_number > largest_observed_ |
151 QuicPacketSequenceNumber sequence_number = header.packet_sequence_number; local
[all...] |
| quic_sent_entropy_manager.h | 32 // Record |entropy_hash| for sent packet corresponding to |sequence_number|.
33 void RecordPacketEntropyHash(QuicPacketSequenceNumber sequence_number,
36 // Retrieves the cumulative entropy up to |sequence_number|.
37 // Must always be called with a monotonically increasing |sequence_number|.
39 QuicPacketSequenceNumber sequence_number);
48 // Removes unnecessary entries before |sequence_number|.
49 void ClearEntropyBefore(QuicPacketSequenceNumber sequence_number);
57 CumulativeEntropy() : sequence_number(0), entropy(0) {}
59 QuicPacketSequenceNumber sequence_number; member in struct:net::QuicSentEntropyManager::CumulativeEntropy
66 // Convenience method to get the entropy hash for |sequence_number|
[all...] |
| quic_unacked_packet_map.h | 34 // Returns true if the packet |sequence_number| is unacked.
35 bool IsUnacked(QuicPacketSequenceNumber sequence_number) const;
38 void NackPacket(QuicPacketSequenceNumber sequence_number,
41 // Marks |sequence_number| as no longer in flight.
42 void RemoveFromInFlight(QuicPacketSequenceNumber sequence_number);
44 // Returns true if the unacked packet |sequence_number| has retransmittable
49 bool HasRetransmittableFrames(QuicPacketSequenceNumber sequence_number) const;
81 void SetSent(QuicPacketSequenceNumber sequence_number,
87 void RestoreInFlight(QuicPacketSequenceNumber sequence_number);
103 // Returns the TransmissionInfo associated with |sequence_number|, whic
[all...] |
| quic_received_packet_manager.h | 40 // and including sequence_number.
42 // sequence_number == largest_observed_
44 // sequence_number > first_gap_ &&
45 // sequence_number < largest_observed_ &&
46 // sequence_number in packets_entropy_
48 QuicPacketSequenceNumber sequence_number) const;
50 // Record the received entropy hash against |sequence_number|.
52 // sequence_number == first_gap_.
53 void RecordPacketEntropyHash(QuicPacketSequenceNumber sequence_number,
59 void SetCumulativeEntropyUpTo(QuicPacketSequenceNumber sequence_number,
[all...] |
| quic_sent_packet_manager.cc | 169 "pending_retransmissions_. sequence_number: " << old_sequence_number;
267 QuicPacketSequenceNumber sequence_number = unacked_packets_.GetLeastUnacked(); local
269 it != unacked_packets_.end(); ++it, ++sequence_number) {
270 if (sequence_number > ack_frame.largest_observed) {
275 if (ContainsKey(ack_frame.missing_packets, sequence_number)) {
285 size_t min_nacks = ack_frame.largest_observed - sequence_number;
290 unacked_packets_.NackPacket(sequence_number, min_nacks);
294 DVLOG(1) << ENDPOINT << "Got an ack for packet " << sequence_number; local
298 packets_acked_.push_back(make_pair(sequence_number, *it));
300 MarkPacketHandled(sequence_number, *it, delta_largest_observed)
320 QuicPacketSequenceNumber sequence_number = unacked_packets_.GetLeastUnacked(); local
332 QuicPacketSequenceNumber sequence_number = unacked_packets_.GetLeastUnacked(); local
408 QuicPacketSequenceNumber sequence_number = local
589 QuicPacketSequenceNumber sequence_number = unacked_packets_.GetLeastUnacked(); local
608 QuicPacketSequenceNumber sequence_number = unacked_packets_.GetLeastUnacked(); local
635 QuicPacketSequenceNumber sequence_number = unacked_packets_.GetLeastUnacked(); local
691 QuicPacketSequenceNumber sequence_number = *it; local
699 DVLOG(1) << ENDPOINT << "Lost packet " << sequence_number; local
[all...] |
| quic_unacked_packet_map.cc | 41 DCHECK_GE(serialized_packet.sequence_number,
44 serialized_packet.sequence_number) {
163 QuicPacketSequenceNumber sequence_number) const {
164 DCHECK_GE(sequence_number, least_unacked_);
165 DCHECK_LT(sequence_number, least_unacked_ + unacked_packets_.size());
167 sequence_number - least_unacked_].retransmittable_frames != NULL;
170 void QuicUnackedPacketMap::NackPacket(QuicPacketSequenceNumber sequence_number,
172 DCHECK_GE(sequence_number, least_unacked_);
173 DCHECK_LT(sequence_number, least_unacked_ + unacked_packets_.size());
174 unacked_packets_[sequence_number - least_unacked_].nack_count
319 QuicPacketSequenceNumber sequence_number = least_unacked_; local
[all...] |
| /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 | 30 void HistogramController::OnPendingProcesses(int sequence_number,
35 subscriber_->OnPendingProcesses(sequence_number, pending_processes, end);
39 int sequence_number,
46 sequence_number,
53 subscriber_->OnHistogramDataCollected(sequence_number,
71 int sequence_number) {
93 if (!iter.Send(new ChildProcessMsg_GetChildHistogramData(sequence_number)))
103 sequence_number,
108 void HistogramController::GetHistogramData(int sequence_number) {
116 new ChildProcessMsg_GetChildHistogramData(sequence_number))) {
[all...] |
| profiler_controller_impl.cc | 33 void ProfilerControllerImpl::OnPendingProcesses(int sequence_number,
38 subscriber_->OnPendingProcesses(sequence_number, pending_processes, end);
42 int sequence_number,
50 sequence_number,
58 subscriber_->OnProfilerDataCollected(sequence_number, profiler_data,
75 int sequence_number) {
88 if (!iter.Send(new ChildProcessMsg_GetChildProfilerData(sequence_number)))
98 sequence_number,
103 void ProfilerControllerImpl::GetProfilerData(int sequence_number) {
111 new ChildProcessMsg_GetChildProfilerData(sequence_number))) {
[all...] |
| /external/chromium_org/content/public/browser/ |
| profiler_subscriber.h | 21 virtual void OnPendingProcesses(int sequence_number,
28 int sequence_number,
|
| /external/chromium_org/content/child/ |
| child_histogram_message_filter.cc | 45 void ChildHistogramMessageFilter::SendHistograms(int sequence_number) {
48 this, sequence_number));
51 void ChildHistogramMessageFilter::OnGetChildHistogramData(int sequence_number) {
52 UploadAllHistograms(sequence_number);
55 void ChildHistogramMessageFilter::UploadAllHistograms(int sequence_number) {
64 new ChildProcessHostMsg_ChildHistogramData(sequence_number, deltas));
|
| child_histogram_message_filter.h | 31 void SendHistograms(int sequence_number);
39 virtual void OnGetChildHistogramData(int sequence_number);
43 void UploadAllHistograms(int sequence_number);
|
| /external/chromium_org/sync/internal_api/public/ |
| non_blocking_sync_common.cc | 16 : sequence_number(0),
25 : sequence_number(0),
|
| /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 | 39 // |sequence_number| is the same as in the OnRequestIdentity call.
41 void OnComplete(int sequence_number,
46 // |sequence_number| is a renderer wide unique number for each request and
51 void OnRequestIdentity(int sequence_number,
58 void SendErrorMessage(int sequence_number, int error);
|
| /external/chromium_org/third_party/webrtc/modules/pacing/ |
| paced_sender_unittest.cc | 29 bool(uint32_t ssrc, uint16_t sequence_number, int64_t capture_time_ms,
39 bool TimeToSendPacket(uint32_t ssrc, uint16_t sequence_number,
68 uint32_t ssrc, uint16_t sequence_number,
72 sequence_number, capture_time_ms, size, retransmission));
74 ssrc, sequence_number, capture_time_ms, false))
86 uint16_t sequence_number = 1234; local
88 SendAndExpectPacket(PacedSender::kNormalPriority, ssrc, sequence_number++,
90 SendAndExpectPacket(PacedSender::kNormalPriority, ssrc, sequence_number++,
92 SendAndExpectPacket(PacedSender::kNormalPriority, ssrc, sequence_number++,
96 sequence_number, queued_packet_timestamp, 250, false))
121 uint16_t sequence_number = 1234; local
161 uint16_t sequence_number = 1234; local
211 uint16_t sequence_number = 1234; local
234 uint16_t sequence_number = 1234; local
278 uint16_t sequence_number = 1234; local
296 uint16_t sequence_number = 1234; local
322 uint16_t sequence_number = 1234; local
371 uint16_t sequence_number = 1234; local
439 uint16_t sequence_number = 1234; local
499 uint16_t sequence_number = 1234; local
529 uint16_t sequence_number = 1234; local
[all...] |
| /external/chromium_org/components/metrics/profiler/ |
| 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/net/quic/congestion_control/ |
| hybrid_slow_start_test.cc | 30 QuicPacketSequenceNumber sequence_number = 1; local
34 EXPECT_FALSE(slow_start_->IsEndOfRound(sequence_number++));
37 EXPECT_FALSE(slow_start_->IsEndOfRound(sequence_number));
39 EXPECT_FALSE(slow_start_->IsEndOfRound(sequence_number++));
40 EXPECT_TRUE(slow_start_->IsEndOfRound(sequence_number++));
43 EXPECT_TRUE(slow_start_->IsEndOfRound(sequence_number++));
47 while (sequence_number < end_sequence_number) {
48 EXPECT_FALSE(slow_start_->IsEndOfRound(sequence_number++));
50 EXPECT_TRUE(slow_start_->IsEndOfRound(sequence_number++));
60 QuicPacketSequenceNumber sequence_number = 2 local
[all...] |
| receive_algorithm_interface.h | 31 // sequence_number: is the unique sequence number from the QUIC packet header.
34 QuicPacketSequenceNumber sequence_number,
|
| /external/chromium_org/media/cast/net/rtp/ |
| rtp_receiver_defines.cc | 13 sequence_number(0),
|
| /external/chromium_org/net/quic/test_tools/ |
| quic_sent_packet_manager_peer.cc | 58 QuicPacketSequenceNumber sequence_number) {
60 GetTransmissionInfo(sequence_number).nack_count;
78 QuicPacketSequenceNumber sequence_number) {
79 DCHECK(sent_packet_manager->unacked_packets_.IsUnacked(sequence_number));
82 sequence_number).sent_time;
88 QuicPacketSequenceNumber sequence_number) {
89 DCHECK(sent_packet_manager->HasRetransmittableFrames(sequence_number));
90 return sent_packet_manager->HasRetransmittableFrames(sequence_number) &&
92 sequence_number).all_transmissions != NULL;
98 QuicPacketSequenceNumber sequence_number,
[all...] |
