| /dports/net-im/tg_owt/tg_owt-d578c76/src/modules/congestion_controller/goog_cc/ |
| H A D | inter_arrival_delta.cc | 31 bool InterArrivalDelta::ComputeDeltas(Timestamp send_time, in ComputeDeltas() argument
42 current_timestamp_group_.send_time = send_time; in ComputeDeltas()
43 current_timestamp_group_.first_send_time = send_time; in ComputeDeltas()
48 } else if (NewTimestampGroup(arrival_time, send_time)) { in ComputeDeltas()
52 current_timestamp_group_.send_time - prev_timestamp_group_.send_time; in ComputeDeltas()
89 current_timestamp_group_.first_send_time = send_time; in ComputeDeltas()
90 current_timestamp_group_.send_time = send_time; in ComputeDeltas()
94 current_timestamp_group_.send_time = in ComputeDeltas()
95 std::max(current_timestamp_group_.send_time, send_time); in ComputeDeltas()
111 } else if (BelongsToBurst(arrival_time, send_time)) { in NewTimestampGroup()
[all …]
|
| H A D | inter_arrival_delta.h | 47 bool ComputeDeltas(Timestamp send_time,
60 send_time(Timestamp::MinusInfinity()), in SendTimeGroup()
69 Timestamp send_time; member
77 bool NewTimestampGroup(Timestamp arrival_time, Timestamp send_time) const;
79 bool BelongsToBurst(Timestamp arrival_time, Timestamp send_time) const;
|
| /dports/net-p2p/libktorrent/libktorrent-21.12.3/src/utp/ |
| H A D | remotewindow.cpp | 17 UnackedPacket::UnackedPacket(const PacketBuffer &packet, bt::Uint16 seq_nr, bt::TimeStamp send_time) in UnackedPacket() argument
20 , send_time(send_time) in UnackedPacket()
60 conn->updateRTT(hdr, now - i->send_time, i->packet.payloadSize()); in packetReceived()
65 conn->updateRTT(hdr, now - i->send_time, i->packet.payloadSize()); in packetReceived()
79 void RemoteWindow::addPacket(const PacketBuffer &packet, bt::Uint16 seq_nr, bt::TimeStamp send_time) in addPacket() argument
83 unacked_packets.append(UnackedPacket(packet, seq_nr, send_time)); in addPacket()
95 … if (!first_unacked.retransmitted || now - first_unacked.send_time > conn->currentTimeout()) { in checkLostPackets()
98 first_unacked.send_time = now; in checkLostPackets()
115 itr->send_time = now; in checkLostPackets()
156 if (!pkt.retransmitted || now - pkt.send_time > conn->currentTimeout()) { in timeout()
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/openscreen/src/cast/streaming/ |
| H A D | compound_rtcp_builder_unittest.cc | 63 const auto send_time = Clock::now(); in TEST_F() local
65 const auto packet = builder()->BuildPacket(send_time, buffer); in TEST_F()
91 const auto send_time = Clock::now(); in TEST_F() local
93 const auto packet = builder()->BuildPacket(send_time, buffer); in TEST_F()
136 auto send_time = Clock::now(); in TEST_F() local
163 send_time += std::chrono::milliseconds(500); in TEST_F()
187 const auto send_time = Clock::now(); in TEST_F() local
189 const auto packet = builder()->BuildPacket(send_time, buffer); in TEST_F()
234 auto send_time = Clock::now(); in TEST_F() local
251 send_time += std::chrono::milliseconds(500); in TEST_F()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/openscreen/src/cast/streaming/ |
| H A D | compound_rtcp_builder_unittest.cc | 64 const auto send_time = Clock::now(); in TEST_F() local
66 const auto packet = builder()->BuildPacket(send_time, buffer); in TEST_F()
92 const auto send_time = Clock::now(); in TEST_F() local
94 const auto packet = builder()->BuildPacket(send_time, buffer); in TEST_F()
119 const auto second_send_time = send_time + milliseconds(500); in TEST_F()
137 auto send_time = Clock::now(); in TEST_F() local
164 send_time += milliseconds(500); in TEST_F()
188 const auto send_time = Clock::now(); in TEST_F() local
235 auto send_time = Clock::now(); in TEST_F() local
252 send_time += milliseconds(500); in TEST_F()
[all …]
|
| H A D | sender_packet_router_unittest.cc | 87 Clock::time_point send_time, in MakeFakePacketWithFlag() argument
99 absl::Span<uint8_t> MakeFakePacket(Clock::time_point send_time, in MakeFakePacket() argument
101 return MakeFakePacketWithFlag('?', send_time, buffer); in MakeFakePacket()
125 absl::Span<uint8_t> ToEmptyPacketBuffer(Clock::time_point send_time, in ToEmptyPacketBuffer() argument
142 (Clock::time_point send_time, absl::Span<uint8_t> buffer),
415 return MakeFakePacket(send_time, buffer); in TEST_F()
420 return ToEmptyPacketBuffer(send_time, buffer); in TEST_F()
523 return MakeFakePacketWithFlag('3', send_time, buffer); in TEST_F()
533 return MakeFakePacketWithFlag('1', send_time, buffer); in TEST_F()
540 return MakeFakePacketWithFlag('2', send_time, buffer); in TEST_F()
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/third_party/quiche/src/quic/test_tools/ |
| H A D | packet_dropping_test_writer.cc | 132 QuicTime send_time = clock_->ApproximateNow() + fake_packet_delay_; in WritePacket() local
137 send_time = delayed_packets_.empty() in WritePacket()
138 ? send_time + bandwidth_delay in WritePacket()
139 : delayed_packets_.back().send_time + bandwidth_delay; in WritePacket()
147 std::move(delayed_options), send_time)); in WritePacket()
152 delay_alarm_->Set(send_time); in WritePacket()
189 delayed_packets_.begin()->send_time = iter->send_time; in ReleaseNextPacket()
206 return delayed_packets_.begin()->send_time; in ReleaseNextPacket()
211 QuicTime next_send_time = delayed_packets_.front().send_time; in ReleaseOldPackets()
241 QuicTime send_time) in DelayedWrite() argument
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/net/third_party/quiche/src/quic/test_tools/ |
| H A D | packet_dropping_test_writer.cc | 143 QuicTime send_time = clock_->ApproximateNow() + fake_packet_delay_; in WritePacket() local
148 send_time = delayed_packets_.empty() in WritePacket()
149 ? send_time + bandwidth_delay in WritePacket()
150 : delayed_packets_.back().send_time + bandwidth_delay; in WritePacket()
158 std::move(delayed_options), send_time)); in WritePacket()
163 delay_alarm_->Set(send_time); in WritePacket()
200 delayed_packets_.begin()->send_time = iter->send_time; in ReleaseNextPacket()
217 return delayed_packets_.begin()->send_time; in ReleaseNextPacket()
222 QuicTime next_send_time = delayed_packets_.front().send_time; in ReleaseOldPackets()
245 QuicTime send_time) in DelayedWrite() argument
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/webrtc/modules/congestion_controller/bbr/ |
| H A D | data_transfer_tracker.cc | 23 Timestamp send_time, in AddSample() argument
30 samples_.back().send_time = send_time; in AddSample()
35 new_sample.send_time = send_time; in AddSample()
72 res.send_timespan = window_end->send_time - window_begin->send_time; in GetRatesByAckTime()
|
| /dports/math/lis/lis-2.0.30/src/fortran/amg/ |
| H A D | lis_m_count_time_mod.F90 | 49 REAL (kind=kreal) :: recv_time, send_time, out_time local
79 send_time = time_table(time_kind)
81 CALL MPI_REDUCE(send_time, recv_time, 1, MPI_DOUBLE_PRECISION, MPI_SUM, 0, SOLVER_COMM, ierr)
97 send_time = time_table(i)
101 IF(prt_ech_PE(i)) WRITE(*,'( i3,"--#", i3, ":", 1pe16.6, " sec")') my_rank, i, send_time
102 … CALL MPI_REDUCE(send_time, recv_time, 1, MPI_DOUBLE_PRECISION, MPI_SUM, 0, SOLVER_COMM, ierr)
|
| /dports/devel/py-applicationinsights/applicationinsights-0.11.10/tests/applicationinsights_tests/channel_tests/ |
| H A D | TestAsynchronousSender.py | 16 self.assertEqual(3.0, sender.send_time)
26 self.assertEqual(3.0, sender.send_time)
27 sender.send_time = 10.0
28 self.assertEqual(10.0, sender.send_time)
33 sender.send_time = 3.0
40 time.sleep(2.0 * sender.send_time / 3.0)
42 time.sleep((1.0 * sender.send_time / 3.0) + 2.0)
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/webrtc/modules/congestion_controller/rtp/ |
| H A D | transport_feedback_adapter.cc | 33 RTC_DCHECK(packet.sent.send_time.IsFinite()); in AddInFlightPacketBytes()
44 if (packet.sent.send_time.IsInfinite()) in RemoveInFlightPacketBytes()
115 auto send_time = Timestamp::Millis(sent_packet.send_time_ms); in ProcessSentPacket() local
122 bool packet_retransmit = it->second.sent.send_time.IsFinite(); in ProcessSentPacket()
123 it->second.sent.send_time = send_time; in ProcessSentPacket()
124 last_send_time_ = std::max(last_send_time_, send_time); in ProcessSentPacket()
127 if (send_time < last_untracked_send_time_) in ProcessSentPacket()
130 << ToString(last_untracked_send_time_ - send_time) << " ms.)"; in ProcessSentPacket()
142 if (send_time < last_send_time_) { in ProcessSentPacket()
172 msg.first_unacked_send_time = it->second.sent.send_time; in ProcessTransportFeedback()
[all …]
|
| /dports/net-im/tg_owt/tg_owt-d578c76/src/modules/congestion_controller/rtp/ |
| H A D | transport_feedback_adapter.cc | 33 RTC_DCHECK(packet.sent.send_time.IsFinite()); in AddInFlightPacketBytes()
44 if (packet.sent.send_time.IsInfinite()) in RemoveInFlightPacketBytes()
115 auto send_time = Timestamp::Millis(sent_packet.send_time_ms); in ProcessSentPacket() local
122 bool packet_retransmit = it->second.sent.send_time.IsFinite(); in ProcessSentPacket()
123 it->second.sent.send_time = send_time; in ProcessSentPacket()
124 last_send_time_ = std::max(last_send_time_, send_time); in ProcessSentPacket()
127 if (send_time < last_untracked_send_time_) in ProcessSentPacket()
130 << ToString(last_untracked_send_time_ - send_time) << " ms.)"; in ProcessSentPacket()
142 if (send_time < last_send_time_) { in ProcessSentPacket()
172 msg.first_unacked_send_time = it->second.sent.send_time; in ProcessTransportFeedback()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/webrtc/modules/congestion_controller/rtp/ |
| H A D | transport_feedback_adapter.cc | 33 RTC_DCHECK(packet.sent.send_time.IsFinite()); in AddInFlightPacketBytes()
44 if (packet.sent.send_time.IsInfinite()) in RemoveInFlightPacketBytes()
115 auto send_time = Timestamp::Millis(sent_packet.send_time_ms); in ProcessSentPacket() local
122 bool packet_retransmit = it->second.sent.send_time.IsFinite(); in ProcessSentPacket()
123 it->second.sent.send_time = send_time; in ProcessSentPacket()
124 last_send_time_ = std::max(last_send_time_, send_time); in ProcessSentPacket()
127 if (send_time < last_untracked_send_time_) in ProcessSentPacket()
130 << ToString(last_untracked_send_time_ - send_time) << " ms.)"; in ProcessSentPacket()
142 if (send_time < last_send_time_) { in ProcessSentPacket()
172 msg.first_unacked_send_time = it->second.sent.send_time; in ProcessTransportFeedback()
[all …]
|
| /dports/www/firefox/firefox-99.0/third_party/libwebrtc/modules/congestion_controller/rtp/ |
| H A D | transport_feedback_adapter.cc | 33 RTC_DCHECK(packet.sent.send_time.IsFinite()); in AddInFlightPacketBytes()
44 if (packet.sent.send_time.IsInfinite()) in RemoveInFlightPacketBytes()
115 auto send_time = Timestamp::Millis(sent_packet.send_time_ms); in ProcessSentPacket() local
122 bool packet_retransmit = it->second.sent.send_time.IsFinite(); in ProcessSentPacket()
123 it->second.sent.send_time = send_time; in ProcessSentPacket()
124 last_send_time_ = std::max(last_send_time_, send_time); in ProcessSentPacket()
127 if (send_time < last_untracked_send_time_) in ProcessSentPacket()
130 << ToString(last_untracked_send_time_ - send_time) << " ms.)"; in ProcessSentPacket()
142 if (send_time < last_send_time_) { in ProcessSentPacket()
172 msg.first_unacked_send_time = it->second.sent.send_time; in ProcessTransportFeedback()
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/webrtc/modules/congestion_controller/pcc/ |
| H A D | pcc_network_controller.cc | 130 start_time_ = msg.send_time; in OnSentPacket()
133 monitor_intervals_.emplace_back(bandwidth_estimate_, msg.send_time, in OnSentPacket()
142 last_sent_packet_time_ = msg.send_time; in OnSentPacket()
144 msg.send_time >= monitor_intervals_.back().GetEndTime() && in OnSentPacket()
151 if (IsTimeoutExpired(msg.send_time)) { in OnSentPacket()
169 msg.send_time - start_time_ >= kStartupDuration) { in OnSentPacket()
190 return CreateRateUpdate(msg.send_time); in OnSentPacket()
192 if (IsFeedbackCollectionDone() || IsTimeoutExpired(msg.send_time)) { in OnSentPacket()
204 kSlowStartModeIncrease * bandwidth_estimate_, msg.send_time, in OnSentPacket()
224 msg.send_time, in OnSentPacket()
[all …]
|
| /dports/net-im/tg_owt/tg_owt-d578c76/src/modules/congestion_controller/pcc/ |
| H A D | pcc_network_controller.cc | 130 start_time_ = msg.send_time; in OnSentPacket()
133 monitor_intervals_.emplace_back(bandwidth_estimate_, msg.send_time, in OnSentPacket()
142 last_sent_packet_time_ = msg.send_time; in OnSentPacket()
144 msg.send_time >= monitor_intervals_.back().GetEndTime() && in OnSentPacket()
151 if (IsTimeoutExpired(msg.send_time)) { in OnSentPacket()
169 msg.send_time - start_time_ >= kStartupDuration) { in OnSentPacket()
190 return CreateRateUpdate(msg.send_time); in OnSentPacket()
192 if (IsFeedbackCollectionDone() || IsTimeoutExpired(msg.send_time)) { in OnSentPacket()
204 kSlowStartModeIncrease * bandwidth_estimate_, msg.send_time, in OnSentPacket()
224 msg.send_time, in OnSentPacket()
[all …]
|
| /dports/www/firefox/firefox-99.0/third_party/libwebrtc/modules/congestion_controller/pcc/ |
| H A D | pcc_network_controller.cc | 130 start_time_ = msg.send_time; in OnSentPacket()
133 monitor_intervals_.emplace_back(bandwidth_estimate_, msg.send_time, in OnSentPacket()
142 last_sent_packet_time_ = msg.send_time; in OnSentPacket()
144 msg.send_time >= monitor_intervals_.back().GetEndTime() && in OnSentPacket()
151 if (IsTimeoutExpired(msg.send_time)) { in OnSentPacket()
169 msg.send_time - start_time_ >= kStartupDuration) { in OnSentPacket()
190 return CreateRateUpdate(msg.send_time); in OnSentPacket()
192 if (IsFeedbackCollectionDone() || IsTimeoutExpired(msg.send_time)) { in OnSentPacket()
204 kSlowStartModeIncrease * bandwidth_estimate_, msg.send_time, in OnSentPacket()
224 msg.send_time, in OnSentPacket()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/webrtc/modules/congestion_controller/pcc/ |
| H A D | pcc_network_controller.cc | 130 start_time_ = msg.send_time; in OnSentPacket()
133 monitor_intervals_.emplace_back(bandwidth_estimate_, msg.send_time, in OnSentPacket()
142 last_sent_packet_time_ = msg.send_time; in OnSentPacket()
144 msg.send_time >= monitor_intervals_.back().GetEndTime() && in OnSentPacket()
151 if (IsTimeoutExpired(msg.send_time)) { in OnSentPacket()
169 msg.send_time - start_time_ >= kStartupDuration) { in OnSentPacket()
190 return CreateRateUpdate(msg.send_time); in OnSentPacket()
192 if (IsFeedbackCollectionDone() || IsTimeoutExpired(msg.send_time)) { in OnSentPacket()
204 kSlowStartModeIncrease * bandwidth_estimate_, msg.send_time, in OnSentPacket()
224 msg.send_time, in OnSentPacket()
[all …]
|
| /dports/net-p2p/vuze/vuze-5.7.4.0_2/com/aelitis/net/udp/uc/impl/ |
| H A D | PRUDPPacketHandlerRequestImpl.java | 51 private long send_time; field in PRUDPPacketHandlerRequestImpl
66 send_time = SystemTime.getCurrentTime(); in sent()
72 return( send_time ); in getSendTime()
84 if ( send_time == 0 || reply_time == 0 ){ in getElapsedTime()
89 long res = reply_time - send_time; in getElapsedTime()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/webrtc/modules/rtp_rtcp/source/ |
| H A D | absolute_capture_time_sender.cc | 48 const Timestamp send_time = clock_->CurrentTime(); in OnSendPacket() local
52 if (!ShouldSendExtension(send_time, source, rtp_timestamp, in OnSendPacket()
64 last_send_time_ = send_time; in OnSendPacket()
73 Timestamp send_time, in ShouldSendExtension() argument
85 if ((send_time - last_send_time_) > kInterpolationMaxInterval) { in ShouldSendExtension()
|
| /dports/net-im/tg_owt/tg_owt-d578c76/src/modules/rtp_rtcp/source/ |
| H A D | absolute_capture_time_sender.cc | 48 const Timestamp send_time = clock_->CurrentTime(); in OnSendPacket() local
52 if (!ShouldSendExtension(send_time, source, rtp_timestamp, in OnSendPacket()
64 last_send_time_ = send_time; in OnSendPacket()
73 Timestamp send_time, in ShouldSendExtension() argument
85 if ((send_time - last_send_time_) > kInterpolationMaxInterval) { in ShouldSendExtension()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/webrtc/modules/rtp_rtcp/source/ |
| H A D | absolute_capture_time_sender.cc | 48 const Timestamp send_time = clock_->CurrentTime(); in OnSendPacket() local
52 if (!ShouldSendExtension(send_time, source, rtp_timestamp, in OnSendPacket()
64 last_send_time_ = send_time; in OnSendPacket()
73 Timestamp send_time, in ShouldSendExtension() argument
85 if ((send_time - last_send_time_) > kInterpolationMaxInterval) { in ShouldSendExtension()
|
| /dports/www/firefox/firefox-99.0/third_party/libwebrtc/modules/rtp_rtcp/source/ |
| H A D | absolute_capture_time_sender.cc | 48 const Timestamp send_time = clock_->CurrentTime(); in OnSendPacket() local
52 if (!ShouldSendExtension(send_time, source, rtp_timestamp, in OnSendPacket()
64 last_send_time_ = send_time; in OnSendPacket()
73 Timestamp send_time, in ShouldSendExtension() argument
85 if ((send_time - last_send_time_) > kInterpolationMaxInterval) { in ShouldSendExtension()
|
| /dports/databases/pgpool-II-41/pgpool-II-4.1.10/src/watchdog/ |
| H A D | wd_heartbeat.c | 64 struct timeval send_time; member
452 WD_TIME_BEFORE(node->hb_send_time, pkt.send_time)) in wd_hb_receiver()
458 node->hb_send_time = pkt.send_time; in wd_hb_receiver()
549 gettimeofday(&pkt.send_time, NULL); in wd_hb_sender()
621 to->send_time.tv_sec = htonl(from->send_time.tv_sec); in hton_wd_hb_packet()
622 to->send_time.tv_usec = htonl(from->send_time.tv_usec); in hton_wd_hb_packet()
638 to->send_time.tv_sec = ntohl(from->send_time.tv_sec); in ntoh_wd_hb_packet()
639 to->send_time.tv_usec = ntohl(from->send_time.tv_usec); in ntoh_wd_hb_packet()
654 pkt->send_time.tv_sec, pkt->send_time.tv_usec, pkt->from); in packet_to_string_hb()
|