| /external/chromium_org/net/quic/ |
| D | quic_sent_entropy_manager.cc | 21 QuicPacketSequenceNumber sequence_number) const { in GetPacketEntropy()
22 return packets_entropy_[sequence_number - map_offset_]; in GetPacketEntropy()
36 QuicPacketSequenceNumber sequence_number, in UpdateCumulativeEntropy() argument
38 while (cumulative->sequence_number < sequence_number) { in UpdateCumulativeEntropy()
39 ++cumulative->sequence_number; in UpdateCumulativeEntropy()
40 cumulative->entropy ^= GetPacketEntropy(cumulative->sequence_number); in UpdateCumulativeEntropy()
45 QuicPacketSequenceNumber sequence_number, in RecordPacketEntropyHash() argument
51 DCHECK_EQ(GetLargestPacketWithEntropy() + 1, sequence_number); in RecordPacketEntropyHash()
54 DVLOG(2) << "Recorded sequence number " << sequence_number in RecordPacketEntropyHash()
59 QuicPacketSequenceNumber sequence_number) { in GetCumulativeEntropy() argument
[all …]
|
| D | quic_received_packet_manager.cc | 43 QuicPacketSequenceNumber sequence_number) const { in EntropyHash()
44 DCHECK_LE(sequence_number, largest_observed_); in EntropyHash()
45 if (sequence_number == largest_observed_) { in EntropyHash()
49 DCHECK_GE(sequence_number, first_gap_); in EntropyHash()
54 i < (largest_observed_ - sequence_number); ++i, ++it) { in EntropyHash()
61 QuicPacketSequenceNumber sequence_number, in RecordPacketEntropyHash() argument
63 if (sequence_number < first_gap_) { in RecordPacketEntropyHash()
65 << sequence_number << " less than largest_peer_sequence_number:" in RecordPacketEntropyHash()
70 DCHECK(sequence_number > largest_observed_ || in RecordPacketEntropyHash()
71 !packets_entropy_[sequence_number - first_gap_].second); in RecordPacketEntropyHash()
[all …]
|
| D | quic_unacked_packet_map.cc | 41 DCHECK_GE(serialized_packet.sequence_number, in AddPacket()
44 serialized_packet.sequence_number) { in AddPacket()
163 QuicPacketSequenceNumber sequence_number) const { in HasRetransmittableFrames()
164 DCHECK_GE(sequence_number, least_unacked_); in HasRetransmittableFrames()
165 DCHECK_LT(sequence_number, least_unacked_ + unacked_packets_.size()); in HasRetransmittableFrames()
167 sequence_number - least_unacked_].retransmittable_frames != NULL; in HasRetransmittableFrames()
170 void QuicUnackedPacketMap::NackPacket(QuicPacketSequenceNumber sequence_number, in NackPacket() argument
172 DCHECK_GE(sequence_number, least_unacked_); in NackPacket()
173 DCHECK_LT(sequence_number, least_unacked_ + unacked_packets_.size()); in NackPacket()
174 unacked_packets_[sequence_number - least_unacked_].nack_count = in NackPacket()
[all …]
|
| D | quic_sent_packet_manager.cc | 267 QuicPacketSequenceNumber sequence_number = unacked_packets_.GetLeastUnacked(); in HandleAckForSentPackets() local
269 it != unacked_packets_.end(); ++it, ++sequence_number) { in HandleAckForSentPackets()
270 if (sequence_number > ack_frame.largest_observed) { in HandleAckForSentPackets()
275 if (ContainsKey(ack_frame.missing_packets, sequence_number)) { in HandleAckForSentPackets()
285 size_t min_nacks = ack_frame.largest_observed - sequence_number; in HandleAckForSentPackets()
290 unacked_packets_.NackPacket(sequence_number, min_nacks); in HandleAckForSentPackets()
294 DVLOG(1) << ENDPOINT << "Got an ack for packet " << sequence_number; in HandleAckForSentPackets()
298 packets_acked_.push_back(make_pair(sequence_number, *it)); in HandleAckForSentPackets()
300 MarkPacketHandled(sequence_number, *it, delta_largest_observed); in HandleAckForSentPackets()
312 QuicPacketSequenceNumber sequence_number) const { in HasRetransmittableFrames()
[all …]
|
| D | quic_unacked_packet_map.h | 35 bool IsUnacked(QuicPacketSequenceNumber sequence_number) const;
38 void NackPacket(QuicPacketSequenceNumber sequence_number,
42 void RemoveFromInFlight(QuicPacketSequenceNumber sequence_number);
49 bool HasRetransmittableFrames(QuicPacketSequenceNumber sequence_number) const;
81 void SetSent(QuicPacketSequenceNumber sequence_number,
87 void RestoreInFlight(QuicPacketSequenceNumber sequence_number);
106 QuicPacketSequenceNumber sequence_number) const;
126 void RemoveRetransmittability(QuicPacketSequenceNumber sequence_number);
143 bool IsPacketUseless(QuicPacketSequenceNumber sequence_number,
147 bool IsPacketRemovable(QuicPacketSequenceNumber sequence_number,
|
| D | quic_sent_entropy_manager.h | 33 void RecordPacketEntropyHash(QuicPacketSequenceNumber sequence_number,
39 QuicPacketSequenceNumber sequence_number);
49 void ClearEntropyBefore(QuicPacketSequenceNumber sequence_number);
57 CumulativeEntropy() : sequence_number(0), entropy(0) {} in CumulativeEntropy()
59 QuicPacketSequenceNumber sequence_number; member
68 QuicPacketSequenceNumber sequence_number) const;
71 void UpdateCumulativeEntropy(QuicPacketSequenceNumber sequence_number,
|
| D | quic_received_packet_manager.h | 48 QuicPacketSequenceNumber sequence_number) const;
53 void RecordPacketEntropyHash(QuicPacketSequenceNumber sequence_number,
59 void SetCumulativeEntropyUpTo(QuicPacketSequenceNumber sequence_number,
109 void RecordPacketRevived(QuicPacketSequenceNumber sequence_number);
112 bool IsMissing(QuicPacketSequenceNumber sequence_number);
115 bool IsAwaitingPacket(QuicPacketSequenceNumber sequence_number);
132 QuicPacketSequenceNumber sequence_number) const OVERRIDE;
|
| D | quic_sent_packet_manager.h | 55 QuicPacketSequenceNumber sequence_number, in OnSentPacket() argument
91 PendingRetransmission(QuicPacketSequenceNumber sequence_number, in PendingRetransmission()
95 : sequence_number(sequence_number), in PendingRetransmission()
101 QuicPacketSequenceNumber sequence_number; member
133 bool IsUnacked(QuicPacketSequenceNumber sequence_number) const;
150 bool HasRetransmittableFrames(QuicPacketSequenceNumber sequence_number) const;
172 virtual bool OnPacketSent(QuicPacketSequenceNumber sequence_number,
312 void MarkPacketRevived(QuicPacketSequenceNumber sequence_number,
318 void MarkPacketHandled(QuicPacketSequenceNumber sequence_number,
325 void MarkForRetransmission(QuicPacketSequenceNumber sequence_number,
|
| /external/chromium_org/third_party/webrtc/modules/pacing/ |
| D | 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, in TimeToSendPacket() argument
68 uint32_t ssrc, uint16_t sequence_number, in SendAndExpectPacket() argument
72 sequence_number, capture_time_ms, size, retransmission)); in SendAndExpectPacket()
74 ssrc, sequence_number, capture_time_ms, false)) in SendAndExpectPacket()
86 uint16_t sequence_number = 1234; in TEST_F() local
88 SendAndExpectPacket(PacedSender::kNormalPriority, ssrc, sequence_number++, in TEST_F()
90 SendAndExpectPacket(PacedSender::kNormalPriority, ssrc, sequence_number++, in TEST_F()
92 SendAndExpectPacket(PacedSender::kNormalPriority, ssrc, sequence_number++, in TEST_F()
96 sequence_number, queued_packet_timestamp, 250, false)); in TEST_F()
[all …]
|
| /external/chromium_org/components/metrics/profiler/ |
| D | tracking_synchronizer.cc | 49 int sequence_number) in RequestContext() argument
51 sequence_number_(sequence_number), in RequestContext()
92 int sequence_number, in Register() argument
97 callback_object, sequence_number); in Register()
98 outstanding_requests_.Get()[sequence_number] = request; in Register()
105 static RequestContext* GetRequestContext(int sequence_number) { in GetRequestContext() argument
109 outstanding_requests_.Get().find(sequence_number); in GetRequestContext()
114 DCHECK_EQ(sequence_number, request->sequence_number_); in GetRequestContext()
121 static void Unregister(int sequence_number) { in Unregister() argument
125 outstanding_requests_.Get().find(sequence_number); in Unregister()
[all …]
|
| /external/chromium_org/content/browser/ |
| D | histogram_synchronizer.cc | 44 RequestContext(const base::Closure& callback, int sequence_number) in RequestContext() argument
46 sequence_number_(sequence_number), in RequestContext()
81 static void Register(const base::Closure& callback, int sequence_number) { in Register() argument
84 RequestContext* request = new RequestContext(callback, sequence_number); in Register()
85 outstanding_requests_.Get()[sequence_number] = request; in Register()
90 static RequestContext* GetRequestContext(int sequence_number) { in GetRequestContext() argument
94 outstanding_requests_.Get().find(sequence_number); in GetRequestContext()
99 DCHECK_EQ(sequence_number, request->sequence_number_); in GetRequestContext()
106 static void Unregister(int sequence_number) { in Unregister() argument
110 outstanding_requests_.Get().find(sequence_number); in Unregister()
[all …]
|
| D | profiler_controller_impl.cc | 33 void ProfilerControllerImpl::OnPendingProcesses(int sequence_number, in OnPendingProcesses() argument
38 subscriber_->OnPendingProcesses(sequence_number, pending_processes, end); in OnPendingProcesses()
42 int sequence_number, in OnProfilerDataCollected() argument
50 sequence_number, in OnProfilerDataCollected()
58 subscriber_->OnProfilerDataCollected(sequence_number, profiler_data, in OnProfilerDataCollected()
75 int sequence_number) { in GetProfilerDataFromChildProcesses() argument
88 if (!iter.Send(new ChildProcessMsg_GetChildProfilerData(sequence_number))) in GetProfilerDataFromChildProcesses()
98 sequence_number, in GetProfilerDataFromChildProcesses()
103 void ProfilerControllerImpl::GetProfilerData(int sequence_number) { in GetProfilerData() argument
111 new ChildProcessMsg_GetChildProfilerData(sequence_number))) { in GetProfilerData()
[all …]
|
| D | histogram_controller.cc | 30 void HistogramController::OnPendingProcesses(int sequence_number, in OnPendingProcesses() argument
35 subscriber_->OnPendingProcesses(sequence_number, pending_processes, end); in OnPendingProcesses()
39 int sequence_number, in OnHistogramDataCollected() argument
46 sequence_number, in OnHistogramDataCollected()
53 subscriber_->OnHistogramDataCollected(sequence_number, in OnHistogramDataCollected()
71 int sequence_number) { in GetHistogramDataFromChildProcesses() argument
93 if (!iter.Send(new ChildProcessMsg_GetChildHistogramData(sequence_number))) in GetHistogramDataFromChildProcesses()
103 sequence_number, in GetHistogramDataFromChildProcesses()
108 void HistogramController::GetHistogramData(int sequence_number) { in GetHistogramData() argument
116 new ChildProcessMsg_GetChildHistogramData(sequence_number))) { in GetHistogramData()
[all …]
|
| /external/chromium_org/net/quic/congestion_control/ |
| D | hybrid_slow_start_test.cc | 30 QuicPacketSequenceNumber sequence_number = 1; in TEST_F() local
34 EXPECT_FALSE(slow_start_->IsEndOfRound(sequence_number++)); in TEST_F()
37 EXPECT_FALSE(slow_start_->IsEndOfRound(sequence_number)); in TEST_F()
39 EXPECT_FALSE(slow_start_->IsEndOfRound(sequence_number++)); in TEST_F()
40 EXPECT_TRUE(slow_start_->IsEndOfRound(sequence_number++)); in TEST_F()
43 EXPECT_TRUE(slow_start_->IsEndOfRound(sequence_number++)); in TEST_F()
47 while (sequence_number < end_sequence_number) { in TEST_F()
48 EXPECT_FALSE(slow_start_->IsEndOfRound(sequence_number++)); in TEST_F()
50 EXPECT_TRUE(slow_start_->IsEndOfRound(sequence_number++)); in TEST_F()
60 QuicPacketSequenceNumber sequence_number = 2; in TEST_F() local
[all …]
|
| /external/chromium_org/content/browser/renderer_host/media/ |
| D | webrtc_identity_service_host.cc | 40 int sequence_number, in OnRequestIdentity() argument
47 SendErrorMessage(sequence_number, net::ERR_INSUFFICIENT_RESOURCES); in OnRequestIdentity()
55 SendErrorMessage(sequence_number, net::ERR_ACCESS_DENIED); in OnRequestIdentity()
65 sequence_number)); in OnRequestIdentity()
67 SendErrorMessage(sequence_number, net::ERR_UNEXPECTED); in OnRequestIdentity()
78 void WebRTCIdentityServiceHost::OnComplete(int sequence_number, in OnComplete() argument
85 sequence_number, certificate, private_key)); in OnComplete()
87 SendErrorMessage(sequence_number, status); in OnComplete()
91 void WebRTCIdentityServiceHost::SendErrorMessage(int sequence_number, in SendErrorMessage() argument
93 Send(new WebRTCIdentityHostMsg_RequestFailed(sequence_number, error)); in SendErrorMessage()
|
| /external/chromium_org/net/quic/test_tools/ |
| D | quic_sent_packet_manager_peer.cc | 58 QuicPacketSequenceNumber sequence_number) { in GetNackCount() argument
60 GetTransmissionInfo(sequence_number).nack_count; in GetNackCount()
78 QuicPacketSequenceNumber sequence_number) { in GetSentTime() argument
79 DCHECK(sent_packet_manager->unacked_packets_.IsUnacked(sequence_number)); in GetSentTime()
82 sequence_number).sent_time; in GetSentTime()
88 QuicPacketSequenceNumber sequence_number) { in IsRetransmission() argument
89 DCHECK(sent_packet_manager->HasRetransmittableFrames(sequence_number)); in IsRetransmission()
90 return sent_packet_manager->HasRetransmittableFrames(sequence_number) && in IsRetransmission()
92 sequence_number).all_transmissions != NULL; in IsRetransmission()
98 QuicPacketSequenceNumber sequence_number, in MarkForRetransmission() argument
[all …]
|
| D | quic_connection_peer.cc | 91 QuicPacketSequenceNumber sequence_number) { in IsSavedForRetransmission() argument
92 return connection->sent_packet_manager_.IsUnacked(sequence_number) && in IsSavedForRetransmission()
94 sequence_number); in IsSavedForRetransmission()
100 QuicPacketSequenceNumber sequence_number) { in IsRetransmission() argument
102 &connection->sent_packet_manager_, sequence_number); in IsRetransmission()
109 QuicPacketSequenceNumber sequence_number) { in GetSentEntropyHash() argument
112 connection->sent_entropy_manager_.UpdateCumulativeEntropy(sequence_number, in GetSentEntropyHash()
120 QuicPacketSequenceNumber sequence_number) { in PacketEntropy() argument
121 return connection->sent_entropy_manager_.GetPacketEntropy(sequence_number); in PacketEntropy()
127 QuicPacketSequenceNumber sequence_number) { in ReceivedEntropyHash() argument
[all …]
|
| /external/chromium_org/net/tools/quic/ |
| D | quic_time_wait_list_manager_test.cc | 124 QuicPacketSequenceNumber sequence_number) { in ProcessPacket() argument
129 sequence_number, in ProcessPacket()
136 QuicPacketSequenceNumber sequence_number) { in ConstructEncryptedPacket() argument
143 header.packet_sequence_number = sequence_number; in ConstructEncryptedPacket()
157 sequence_number, in ConstructEncryptedPacket()
213 QuicPacketSequenceNumber sequence_number) { in PublicResetPacketEq() argument
215 sequence_number)); in PublicResetPacketEq()
255 for (int sequence_number = 1; sequence_number < 101; ++sequence_number) { in TEST_F() local
256 if ((sequence_number & (sequence_number - 1)) == 0) { in TEST_F()
260 ProcessPacket(connection_id_, sequence_number); in TEST_F()
[all …]
|
| /external/chromium_org/third_party/webrtc/modules/audio_coding/main/acm2/ |
| D | nack.cc | 52 void Nack::UpdateLastReceivedPacket(uint16_t sequence_number, in UpdateLastReceivedPacket() argument
57 sequence_num_last_received_rtp_ = sequence_number; in UpdateLastReceivedPacket()
63 sequence_num_last_decoded_rtp_ = sequence_number; in UpdateLastReceivedPacket()
69 if (sequence_number == sequence_num_last_received_rtp_) in UpdateLastReceivedPacket()
73 nack_list_.erase(sequence_number); in UpdateLastReceivedPacket()
76 if (IsNewerSequenceNumber(sequence_num_last_received_rtp_, sequence_number)) in UpdateLastReceivedPacket()
79 UpdateSamplesPerPacket(sequence_number, timestamp); in UpdateLastReceivedPacket()
81 UpdateList(sequence_number); in UpdateLastReceivedPacket()
83 sequence_num_last_received_rtp_ = sequence_number; in UpdateLastReceivedPacket()
149 void Nack::UpdateLastDecodedPacket(uint16_t sequence_number, in UpdateLastDecodedPacket() argument
[all …]
|
| /external/chromium_org/media/cast/net/rtp/ |
| D | receiver_stats_unittest.cc | 77 ++rtp_header_.sequence_number; in TEST_F()
87 const uint32 extended_seq_num = rtp_header_.sequence_number - 1; in TEST_F()
92 rtp_header_.sequence_number = 65500; in TEST_F()
98 ++rtp_header_.sequence_number; in TEST_F()
108 const uint32 extended_seq_num = (1 << 16) + rtp_header_.sequence_number - 1; in TEST_F()
114 rtp_header_.sequence_number = kStartSequenceNumber; in TEST_F()
121 ++rtp_header_.sequence_number; in TEST_F()
131 const uint32 extended_seq_num = (1 << 16) + rtp_header_.sequence_number - 1; in TEST_F()
138 ++rtp_header_.sequence_number; in TEST_F()
149 const uint32 extended_seq_num = rtp_header_.sequence_number - 1; in TEST_F()
[all …]
|
| /external/chromium_org/sync/engine/ |
| D | entity_tracker.cc | 25 int64 sequence_number, in FromCommitRequest() argument
37 sequence_number, in FromCommitRequest()
66 int64 sequence_number, in EntityTracker() argument
78 sequence_number_(sequence_number), in EntityTracker()
95 int64* sequence_number) const { in PrepareCommitProto()
113 *sequence_number = sequence_number_; in PrepareCommitProto()
118 int64 sequence_number, in RequestCommit() argument
128 DCHECK_GE(sequence_number, sequence_number_) in RequestCommit()
133 sequence_number_ = sequence_number; in RequestCommit()
172 int64 sequence_number) { in ReceiveCommitResponse() argument
[all …]
|
| /external/chromium_org/apps/ |
| D | saved_files_service.cc | 70 file_entry.sequence_number); in AddSavedFileEntry()
87 file_entry.sequence_number); in UpdateSavedFileEntry()
130 int sequence_number = 0; in GetSavedFileEntries() local
131 if (!file_entry->GetInteger(kFileEntrySequenceNumber, &sequence_number)) in GetSavedFileEntries()
133 if (!sequence_number) in GetSavedFileEntries()
136 SavedFileEntry(it.key(), file_path, is_directory, sequence_number)); in GetSavedFileEntries()
143 SavedFileEntry::SavedFileEntry() : is_directory(false), sequence_number(0) {} in SavedFileEntry()
148 int sequence_number) in SavedFileEntry() argument
152 sequence_number(sequence_number) {} in SavedFileEntry()
336 int old_sequence_number = file_entry->sequence_number; in EnqueueFileEntry()
[all …]
|
| /external/chromium_org/content/child/ |
| D | child_histogram_message_filter.cc | 45 void ChildHistogramMessageFilter::SendHistograms(int sequence_number) { in SendHistograms() argument
48 this, sequence_number)); in SendHistograms()
51 void ChildHistogramMessageFilter::OnGetChildHistogramData(int sequence_number) { in OnGetChildHistogramData() argument
52 UploadAllHistograms(sequence_number); in OnGetChildHistogramData()
55 void ChildHistogramMessageFilter::UploadAllHistograms(int sequence_number) { in UploadAllHistograms() argument
64 new ChildProcessHostMsg_ChildHistogramData(sequence_number, deltas)); in UploadAllHistograms()
|
| /external/chromium_org/third_party/webrtc/modules/audio_coding/neteq/ |
| D | delay_manager.cc | 72 int DelayManager::Update(uint16_t sequence_number, in Update() argument
82 last_seq_no_ = sequence_number; in Update()
91 !IsNewerSequenceNumber(sequence_number, last_seq_no_)) { in Update()
98 static_cast<uint16_t>(sequence_number - last_seq_no_); in Update()
110 UpdateCumulativeSums(packet_len_ms, sequence_number); in Update()
114 if (IsNewerSequenceNumber(sequence_number, last_seq_no_ + 1)) { in Update()
118 iat_packets -= static_cast<uint16_t>(sequence_number - last_seq_no_ - 1); in Update()
120 } else if (!IsNewerSequenceNumber(sequence_number, last_seq_no_)) { in Update()
121 iat_packets += static_cast<uint16_t>(last_seq_no_ + 1 - sequence_number); in Update()
139 last_seq_no_ = sequence_number; in Update()
[all …]
|
| /external/chromium_org/third_party/webrtc/modules/rtp_rtcp/source/ |
| D | rtp_packet_history.cc | 160 bool RTPPacketHistory::HasRTPPacket(uint16_t sequence_number) const { in HasRTPPacket()
167 bool found = FindSeqNum(sequence_number, &index); in HasRTPPacket()
180 bool RTPPacketHistory::GetPacketAndSetSendTime(uint16_t sequence_number, in GetPacketAndSetSendTime() argument
193 bool found = FindSeqNum(sequence_number, &index); in GetPacketAndSetSendTime()
195 LOG(LS_WARNING) << "No match for getting seqNum " << sequence_number; in GetPacketAndSetSendTime()
202 LOG(LS_WARNING) << "No match for getting seqNum " << sequence_number in GetPacketAndSetSendTime()
252 bool RTPPacketHistory::FindSeqNum(uint16_t sequence_number, in FindSeqNum() argument
263 int32_t idx = (prev_index_ - 1) - (temp_sequence_number - sequence_number); in FindSeqNum()
269 if (temp_sequence_number != sequence_number) { in FindSeqNum()
272 if (stored_seq_nums_[m] == sequence_number) { in FindSeqNum()
[all …]
|