Home
last modified time | relevance | path

Searched refs:Unacked (Results 1 – 25 of 3374) sorted by relevance

12345678910>>...135

/dports/mail/thunderbird/thunderbird-91.8.0/third_party/libwebrtc/webrtc/voice_engine/
H A Dtransport_feedback_packet_loss_tracker.cc92 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 Dtransport_feedback_packet_loss_tracker.h61 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 Dtransport_feedback_packet_loss_tracker.cc92 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 Dtransport_feedback_packet_loss_tracker.h61 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 Dtransport_feedback_packet_loss_tracker.cc92 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 Dtransport_feedback_packet_loss_tracker.h61 enum class PacketStatus { Unacked = 0, Received = 1, Lost = 2 }; enumerator
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbit/src/
H A Drabbit_mirror_queue_sync.erl88 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 Drabbit_federation_link_util.erl211 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 Drabbit_federation_queue_link.erl123 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 Drabbit_federation_exchange_link.erl124 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 Drabbit_amqp091_shovel.erl273 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 Drabbit_amqp10_shovel.erl209 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 Deval_broker_test.go134 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 Deval_broker.go454 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 Deval_broker_test.go134 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 Deval_broker.go454 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 Dspec.go57 Unacked uint32 `csv:"TCP.Unacked"` // offset 24 member
/dports/net/ooni-probe-cli/probe-cli-3.10.1/internal/engine/experiment/ndt7/
H A Dspec.go57 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 Dchannels-list.ejs42 <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 Dfunc_linux.go79 TcpiUnacked: skopts.TCPInfo.Unacked,
/dports/net/grpcox/grpcox-1.0.0/vendor/google.golang.org/grpc/channelz/service/
H A Dfunc_linux.go79 TcpiUnacked: skopts.TCPInfo.Unacked,
/dports/security/lego/lego-4.5.3/vendor/google.golang.org/grpc/channelz/service/
H A Dfunc_linux.go79 TcpiUnacked: skopts.TCPInfo.Unacked,
/dports/net/rclone/rclone-1.57.0/vendor/google.golang.org/grpc/channelz/service/
H A Dfunc_linux.go76 TcpiUnacked: skopts.TCPInfo.Unacked,
/dports/net/drive/drive-0.4.0/vendor/google.golang.org/grpc/channelz/service/
H A Dfunc_linux.go76 TcpiUnacked: skopts.TCPInfo.Unacked,
/dports/www/gohugo/hugo-0.91.2/vendor/google.golang.org/grpc/channelz/service/
H A Dfunc_linux.go76 TcpiUnacked: skopts.TCPInfo.Unacked,

12345678910>>...135