/dports/mail/thunderbird/thunderbird-91.8.0/third_party/libwebrtc/webrtc/voice_engine/ |
H A D | transport_feedback_packet_loss_tracker.cc | 92 SentPacket sent_packet(send_time_ms, PacketStatus::Unacked); in OnPacketAdded() 132 if (it->second.status != PacketStatus::Unacked) { in UpdatePacketStatus() 183 RTC_DCHECK(!apply || it->second.status != PacketStatus::Unacked); in UpdateMetrics() 185 if (it->second.status != PacketStatus::Unacked) { in UpdateMetrics() 197 case PacketStatus::Unacked: in UpdatePlr() 213 if (it->second.status == PacketStatus::Unacked) { in UpdateRplr() 221 if (prev->second.status != PacketStatus::Unacked) { in UpdateRplr() 234 next->second.status != PacketStatus::Unacked) { in UpdateRplr() 302 case PacketStatus::Unacked: in Validate() 322 if (it->second.status != PacketStatus::Unacked && in Validate() [all …]
|
H A D | transport_feedback_packet_loss_tracker.h | 61 enum class PacketStatus { Unacked = 0, Received = 1, Lost = 2 }; enumerator
|
/dports/www/firefox-esr/firefox-91.8.0/third_party/libwebrtc/webrtc/voice_engine/ |
H A D | transport_feedback_packet_loss_tracker.cc | 92 SentPacket sent_packet(send_time_ms, PacketStatus::Unacked); in OnPacketAdded() 132 if (it->second.status != PacketStatus::Unacked) { in UpdatePacketStatus() 183 RTC_DCHECK(!apply || it->second.status != PacketStatus::Unacked); in UpdateMetrics() 185 if (it->second.status != PacketStatus::Unacked) { in UpdateMetrics() 197 case PacketStatus::Unacked: in UpdatePlr() 213 if (it->second.status == PacketStatus::Unacked) { in UpdateRplr() 221 if (prev->second.status != PacketStatus::Unacked) { in UpdateRplr() 234 next->second.status != PacketStatus::Unacked) { in UpdateRplr() 302 case PacketStatus::Unacked: in Validate() 322 if (it->second.status != PacketStatus::Unacked && in Validate() [all …]
|
H A D | transport_feedback_packet_loss_tracker.h | 61 enum class PacketStatus { Unacked = 0, Received = 1, Lost = 2 }; enumerator
|
/dports/lang/spidermonkey78/firefox-78.9.0/media/webrtc/trunk/webrtc/voice_engine/ |
H A D | transport_feedback_packet_loss_tracker.cc | 92 SentPacket sent_packet(send_time_ms, PacketStatus::Unacked); in OnPacketAdded() 132 if (it->second.status != PacketStatus::Unacked) { in UpdatePacketStatus() 183 RTC_DCHECK(!apply || it->second.status != PacketStatus::Unacked); in UpdateMetrics() 185 if (it->second.status != PacketStatus::Unacked) { in UpdateMetrics() 197 case PacketStatus::Unacked: in UpdatePlr() 213 if (it->second.status == PacketStatus::Unacked) { in UpdateRplr() 221 if (prev->second.status != PacketStatus::Unacked) { in UpdateRplr() 234 next->second.status != PacketStatus::Unacked) { in UpdateRplr() 302 case PacketStatus::Unacked: in Validate() 322 if (it->second.status != PacketStatus::Unacked && in Validate() [all …]
|
H A D | transport_feedback_packet_loss_tracker.h | 61 enum class PacketStatus { Unacked = 0, Received = 1, Lost = 2 }; enumerator
|
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbit/src/ |
H A D | rabbit_mirror_queue_sync.erl | 88 fun (Msg, MsgProps, Unacked, Acc) -> 89 Acc1 = append_to_acc(Msg, MsgProps, Unacked, Acc), 124 append_to_acc(Msg, MsgProps, Unacked, {Batch, I, {Curr, Len}, T}) -> 125 {[{Msg, MsgProps, Unacked} | Batch], I, {Curr + 1, Len}, T}. 390 {_Msg, _MsgProps, Unacked} = hd(Batch), 391 process_batch(Batch, Unacked, [], MA, BQ, BQS). 393 process_batch([{Msg, Props, true = Unacked} | Rest], true = Unacked, 397 process_batch(Rest, Unacked, [{Msg, props(Props)} | Acc], 399 process_batch([{Msg, Props, false = Unacked} | Rest], false = Unacked, 403 process_batch(Rest, Unacked, [{Msg, props(Props), true} | Acc], [all …]
|
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_federation/src/ |
H A D | rabbit_federation_link_util.erl | 211 remove_delivery_tags(Seq, false, Unacked) -> 212 gb_trees:delete(Seq, Unacked); 213 remove_delivery_tags(Seq, true, Unacked) -> 214 case gb_trees:is_empty(Unacked) of 215 true -> Unacked; 218 true -> Unacked; 226 Ch, DCh, PublishMethod, HeadersFun, ForwardFun, Msg, Unacked) -> 238 gb_trees:insert(Seq, DT, Unacked); 241 Unacked; 243 Unacked [all …]
|
H A D | rabbit_federation_queue_link.erl | 123 unacked = Unacked}) -> 124 Unacked1 = rabbit_federation_link_util:ack(Ack, Ch, Unacked), 128 unacked = Unacked}) -> 129 Unacked1 = rabbit_federation_link_util:nack(Nack, Ch, Unacked), 140 unacked = Unacked}) when ?is_amqqueue(Q) -> 148 HeadersFun, ForwardFun, Msg, Unacked), 207 Unacked = rabbit_federation_link_util:unacked_new(), 238 unacked = Unacked}}
|
H A D | rabbit_federation_exchange_link.erl | 124 unacked = Unacked}) -> 125 Unacked1 = rabbit_federation_link_util:ack(Ack, Ch, Unacked), 129 unacked = Unacked}) -> 130 Unacked1 = rabbit_federation_link_util:nack(Nack, Ch, Unacked), 142 unacked = Unacked}) -> 155 HeadersFun, ForwardFun, Msg, Unacked), 423 Unacked = rabbit_federation_link_util:unacked_new(), 469 unacked = Unacked,
|
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_shovel/src/ |
H A D | rabbit_amqp091_shovel.erl | 273 State0 = #{dest := #{unacked := Unacked} = Dst}) -> 274 #{Seq := InTag} = Unacked, 276 {Unacked1, Removed} = remove_delivery_tags(Seq, Multiple, Unacked, 0), 291 #{unacked := Unacked, 304 State#{dest => Dst#{unacked => Unacked#{Seq => IncomingTag}}}; 388 remove_delivery_tags(Seq, false, Unacked, 0) -> 389 {maps:remove(Seq, Unacked), 1}; 390 remove_delivery_tags(Seq, true, Unacked, Count) -> 391 case maps:size(Unacked) of 392 0 -> {Unacked, Count}; [all …]
|
H A D | rabbit_amqp10_shovel.erl | 209 dest := #{unacked := Unacked} = Dst, 211 State1 = State0#{dest => Dst#{unacked => maps:remove(Tag, Unacked)}}, 213 case {Unacked, Result} of 310 unacked := Unacked} = Dst, 323 State#{dest => Dst#{unacked => Unacked#{OutTag => Tag}}};
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/nomad/ |
H A D | eval_broker_test.go | 134 if stats.ByScheduler[eval.Type].Unacked != 1 { 169 if stats.ByScheduler[eval.Type].Unacked != 0 { 225 if stats.ByScheduler[eval.Type].Unacked != 0 { 272 if stats.ByScheduler[eval.Type].Unacked != 0 { 291 if stats.ByScheduler[eval.Type].Unacked != 0 { 336 if stats.ByScheduler[eval.Type].Unacked != 0 { 383 if stats.ByScheduler[eval.Type].Unacked != 0 { 1103 if stats.ByScheduler[failedQueue].Unacked != 0 { 1127 if stats.ByScheduler[failedQueue].Unacked != 1 { 1152 if stats.ByScheduler[failedQueue].Unacked != 0 {
|
H A D | eval_broker.go | 454 bySched.Unacked += 1 561 bySched.Unacked -= 1 621 bySched.Unacked -= 1 836 metrics.SetGauge([]string{"nomad", "broker", sched, "unacked"}, float32(schedStats.Unacked)) 857 Unacked int member
|
/dports/sysutils/nomad/nomad-1.1.0/nomad/ |
H A D | eval_broker_test.go | 134 if stats.ByScheduler[eval.Type].Unacked != 1 { 169 if stats.ByScheduler[eval.Type].Unacked != 0 { 225 if stats.ByScheduler[eval.Type].Unacked != 0 { 272 if stats.ByScheduler[eval.Type].Unacked != 0 { 291 if stats.ByScheduler[eval.Type].Unacked != 0 { 336 if stats.ByScheduler[eval.Type].Unacked != 0 { 383 if stats.ByScheduler[eval.Type].Unacked != 0 { 1103 if stats.ByScheduler[failedQueue].Unacked != 0 { 1127 if stats.ByScheduler[failedQueue].Unacked != 1 { 1152 if stats.ByScheduler[failedQueue].Unacked != 0 {
|
H A D | eval_broker.go | 454 bySched.Unacked += 1 561 bySched.Unacked -= 1 621 bySched.Unacked -= 1 836 metrics.SetGauge([]string{"nomad", "broker", sched, "unacked"}, float32(schedStats.Unacked)) 857 Unacked int member
|
/dports/net/ooni-mini/probe-engine-0.23.0/experiment/ndt7/ |
H A D | spec.go | 57 Unacked uint32 `csv:"TCP.Unacked"` // offset 24 member
|
/dports/net/ooni-probe-cli/probe-cli-3.10.1/internal/engine/experiment/ndt7/ |
H A D | spec.go | 57 Unacked uint32 `csv:"TCP.Unacked"` // offset 24 member
|
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_management/priv/www/js/tmpl/ |
H A D | channels-list.ejs | 42 <th><%= fmt_sort('Unacked', 'messages_unacknowledged') %></th> 92 <th>Unacked</th>
|
/dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/google.golang.org/grpc/channelz/service/ |
H A D | func_linux.go | 79 TcpiUnacked: skopts.TCPInfo.Unacked,
|
/dports/net/grpcox/grpcox-1.0.0/vendor/google.golang.org/grpc/channelz/service/ |
H A D | func_linux.go | 79 TcpiUnacked: skopts.TCPInfo.Unacked,
|
/dports/security/lego/lego-4.5.3/vendor/google.golang.org/grpc/channelz/service/ |
H A D | func_linux.go | 79 TcpiUnacked: skopts.TCPInfo.Unacked,
|
/dports/net/rclone/rclone-1.57.0/vendor/google.golang.org/grpc/channelz/service/ |
H A D | func_linux.go | 76 TcpiUnacked: skopts.TCPInfo.Unacked,
|
/dports/net/drive/drive-0.4.0/vendor/google.golang.org/grpc/channelz/service/ |
H A D | func_linux.go | 76 TcpiUnacked: skopts.TCPInfo.Unacked,
|
/dports/www/gohugo/hugo-0.91.2/vendor/google.golang.org/grpc/channelz/service/ |
H A D | func_linux.go | 76 TcpiUnacked: skopts.TCPInfo.Unacked,
|