| /dports/www/h2o-devel/h2o-dcc7134/deps/quicly/lib/ |
| H A D | sendstate.c | 31 quicly_ranges_init_with_range(&state->acked, 0, 0); in quicly_sendstate_init()
40 state->acked.ranges[0].end = 1; in quicly_sendstate_init_closed()
46 quicly_ranges_clear(&state->acked); in quicly_sendstate_dispose()
92 ret = quicly_ranges_add(&state->acked, 0, state->final_size + 1); in quicly_sendstate_reset()
122 uint64_t prev_sent_upto = state->acked.ranges[0].end; in quicly_sendstate_acked()
133 if (prev_sent_upto != state->acked.ranges[0].end) { in quicly_sendstate_acked()
134 uint64_t sent_upto = state->acked.ranges[0].end; in quicly_sendstate_acked()
155 if (start < state->acked.ranges[acked_slot].end) in quicly_sendstate_lost()
156 start = state->acked.ranges[acked_slot].end; in quicly_sendstate_lost()
158 if (acked_slot == state->acked.num_ranges || end <= state->acked.ranges[acked_slot].start) { in quicly_sendstate_lost()
[all …]
|
| H A D | sentmap.c | 42 while (iter->p->acked == NULL) in next_entry()
73 assert(iter->p->acked != NULL); in discard_entry()
74 iter->p->acked = NULL; in discard_entry()
129 } while (iter->p->acked != quicly_sentmap__type_packet); in quicly_sentmap_skip()
138 assert(iter->p->acked == quicly_sentmap__type_packet); in quicly_sentmap_update()
161 for (next_entry(iter); iter->p->acked != quicly_sentmap__type_packet; next_entry(iter)) { in quicly_sentmap_update()
162 …if (should_notify && (ret = iter->p->acked(map, &packet, event == QUICLY_SENTMAP_EVENT_ACKED, iter… in quicly_sentmap_update()
172 …ype_packet(quicly_sentmap_t *map, const quicly_sent_packet_t *packet, int acked, quicly_sent_t *se… in quicly_sentmap__type_packet() argument
|
| /dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/fpga/usrp3/lib/vivado_ipi/axi_dmac/ |
| H A D | splitter.v | 52 reg [NUM_M-1:0] acked; register
54 assign s_ready = &(m_ready | acked);
55 assign m_valid = s_valid ? ~acked : {NUM_M{1'b0}};
60 acked <= {NUM_M{1'b0}};
63 acked <= {NUM_M{1'b0}};
65 acked <= acked | (m_ready & m_valid);
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/lib/logmsg/tests/ |
| H A D | test_logmsg_ack.c | 33 gboolean acked; member
42 self->acked = FALSE; in _init()
62 self->acked = TRUE; in _ack_message()
114 cr_assert(t->acked); in Test()
127 cr_assert_not(t->acked); in Test()
130 cr_assert(t->acked); in Test()
172 cr_assert_not(t->acked); in ParameterizedTest()
175 cr_assert_not(t->acked); in ParameterizedTest()
178 cr_assert_not(t->acked); in ParameterizedTest()
181 cr_assert(t->acked); in ParameterizedTest()
|
| /dports/www/h2o-devel/h2o-dcc7134/deps/quicly/include/quicly/ |
| H A D | sentmap.h | 92 …_acked_cb)(quicly_sentmap_t *map, const quicly_sent_packet_t *packet, int acked, quicly_sent_t *da…
105 quicly_sent_acked_cb acked; member
255 static quicly_sent_t *quicly_sentmap_allocate(quicly_sentmap_t *map, quicly_sent_acked_cb acked);
275 …ype_packet(quicly_sentmap_t *map, const quicly_sent_packet_t *packet, int acked, quicly_sent_t *se…
304 inline quicly_sent_t *quicly_sentmap_allocate(quicly_sentmap_t *map, quicly_sent_acked_cb acked) in quicly_sentmap_allocate() argument
316 sent->acked = acked; in quicly_sentmap_allocate()
327 for (iter->p = map->head->entries; iter->p->acked == NULL; ++iter->p) in quicly_sentmap_init_iter()
329 assert(iter->p->acked == quicly_sentmap__type_packet); in quicly_sentmap_init_iter()
339 assert(iter->p->acked == quicly_sentmap__type_packet); in quicly_sentmap_get()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/net/ipv4/ |
| H A D | tcp_scalable.c | 18 static void tcp_scalable_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_scalable_cong_avoid() argument
26 acked = tcp_slow_start(tp, acked); in tcp_scalable_cong_avoid()
27 if (!acked) in tcp_scalable_cong_avoid()
31 acked); in tcp_scalable_cong_avoid()
|
| H A D | tcp_veno.c | 119 static void tcp_veno_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_veno_cong_avoid() argument
125 tcp_reno_cong_avoid(sk, ack, acked); in tcp_veno_cong_avoid()
138 tcp_reno_cong_avoid(sk, ack, acked); in tcp_veno_cong_avoid()
157 acked = tcp_slow_start(tp, acked); in tcp_veno_cong_avoid()
158 if (!acked) in tcp_veno_cong_avoid()
167 tcp_cong_avoid_ai(tp, tp->snd_cwnd, acked); in tcp_veno_cong_avoid()
181 tp->snd_cwnd_cnt += acked; in tcp_veno_cong_avoid()
|
| H A D | tcp_cong.c | 396 u32 tcp_slow_start(struct tcp_sock *tp, u32 acked) in tcp_slow_start() argument
398 u32 cwnd = min(tp->snd_cwnd + acked, tp->snd_ssthresh); in tcp_slow_start()
400 acked -= cwnd - tp->snd_cwnd; in tcp_slow_start()
403 return acked; in tcp_slow_start()
410 void tcp_cong_avoid_ai(struct tcp_sock *tp, u32 w, u32 acked) in tcp_cong_avoid_ai() argument
418 tp->snd_cwnd_cnt += acked; in tcp_cong_avoid_ai()
436 void tcp_reno_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_reno_cong_avoid() argument
445 acked = tcp_slow_start(tp, acked); in tcp_reno_cong_avoid()
446 if (!acked) in tcp_reno_cong_avoid()
450 tcp_cong_avoid_ai(tp, tp->snd_cwnd, acked); in tcp_reno_cong_avoid()
|
| H A D | tcp_yeah.c | 58 static void tcp_yeah_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_yeah_cong_avoid() argument
67 acked = tcp_slow_start(tp, acked); in tcp_yeah_cong_avoid()
68 if (!acked) in tcp_yeah_cong_avoid()
75 acked); in tcp_yeah_cong_avoid()
78 tcp_cong_avoid_ai(tp, tp->snd_cwnd, acked); in tcp_yeah_cong_avoid()
|
| H A D | tcp_illinois.c | 52 u16 acked; /* # packets acked by current ACK */ member
78 ca->acked = 0; in tcp_illinois_init()
91 ca->acked = sample->pkts_acked; in tcp_illinois_acked()
260 static void tcp_illinois_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_illinois_cong_avoid() argument
274 tcp_slow_start(tp, acked); in tcp_illinois_cong_avoid()
280 tp->snd_cwnd_cnt += ca->acked; in tcp_illinois_cong_avoid()
281 ca->acked = 1; in tcp_illinois_cong_avoid()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/net/ipv4/ |
| H A D | tcp_scalable.c | 18 static void tcp_scalable_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_scalable_cong_avoid() argument
26 acked = tcp_slow_start(tp, acked); in tcp_scalable_cong_avoid()
27 if (!acked) in tcp_scalable_cong_avoid()
31 acked); in tcp_scalable_cong_avoid()
|
| H A D | tcp_veno.c | 119 static void tcp_veno_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_veno_cong_avoid() argument
125 tcp_reno_cong_avoid(sk, ack, acked); in tcp_veno_cong_avoid()
138 tcp_reno_cong_avoid(sk, ack, acked); in tcp_veno_cong_avoid()
157 acked = tcp_slow_start(tp, acked); in tcp_veno_cong_avoid()
158 if (!acked) in tcp_veno_cong_avoid()
167 tcp_cong_avoid_ai(tp, tp->snd_cwnd, acked); in tcp_veno_cong_avoid()
181 tp->snd_cwnd_cnt += acked; in tcp_veno_cong_avoid()
|
| H A D | tcp_cong.c | 396 u32 tcp_slow_start(struct tcp_sock *tp, u32 acked) in tcp_slow_start() argument
398 u32 cwnd = min(tp->snd_cwnd + acked, tp->snd_ssthresh); in tcp_slow_start()
400 acked -= cwnd - tp->snd_cwnd; in tcp_slow_start()
403 return acked; in tcp_slow_start()
410 void tcp_cong_avoid_ai(struct tcp_sock *tp, u32 w, u32 acked) in tcp_cong_avoid_ai() argument
418 tp->snd_cwnd_cnt += acked; in tcp_cong_avoid_ai()
436 void tcp_reno_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_reno_cong_avoid() argument
445 acked = tcp_slow_start(tp, acked); in tcp_reno_cong_avoid()
446 if (!acked) in tcp_reno_cong_avoid()
450 tcp_cong_avoid_ai(tp, tp->snd_cwnd, acked); in tcp_reno_cong_avoid()
|
| H A D | tcp_yeah.c | 58 static void tcp_yeah_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_yeah_cong_avoid() argument
67 acked = tcp_slow_start(tp, acked); in tcp_yeah_cong_avoid()
68 if (!acked) in tcp_yeah_cong_avoid()
75 acked); in tcp_yeah_cong_avoid()
78 tcp_cong_avoid_ai(tp, tp->snd_cwnd, acked); in tcp_yeah_cong_avoid()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/net/ipv4/ |
| H A D | tcp_scalable.c | 18 static void tcp_scalable_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_scalable_cong_avoid() argument
26 acked = tcp_slow_start(tp, acked); in tcp_scalable_cong_avoid()
27 if (!acked) in tcp_scalable_cong_avoid()
31 acked); in tcp_scalable_cong_avoid()
|
| H A D | tcp_veno.c | 119 static void tcp_veno_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_veno_cong_avoid() argument
125 tcp_reno_cong_avoid(sk, ack, acked); in tcp_veno_cong_avoid()
138 tcp_reno_cong_avoid(sk, ack, acked); in tcp_veno_cong_avoid()
157 acked = tcp_slow_start(tp, acked); in tcp_veno_cong_avoid()
158 if (!acked) in tcp_veno_cong_avoid()
167 tcp_cong_avoid_ai(tp, tp->snd_cwnd, acked); in tcp_veno_cong_avoid()
181 tp->snd_cwnd_cnt += acked; in tcp_veno_cong_avoid()
|
| H A D | tcp_cong.c | 396 u32 tcp_slow_start(struct tcp_sock *tp, u32 acked) in tcp_slow_start() argument
398 u32 cwnd = min(tp->snd_cwnd + acked, tp->snd_ssthresh); in tcp_slow_start()
400 acked -= cwnd - tp->snd_cwnd; in tcp_slow_start()
403 return acked; in tcp_slow_start()
410 void tcp_cong_avoid_ai(struct tcp_sock *tp, u32 w, u32 acked) in tcp_cong_avoid_ai() argument
418 tp->snd_cwnd_cnt += acked; in tcp_cong_avoid_ai()
436 void tcp_reno_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_reno_cong_avoid() argument
445 acked = tcp_slow_start(tp, acked); in tcp_reno_cong_avoid()
446 if (!acked) in tcp_reno_cong_avoid()
450 tcp_cong_avoid_ai(tp, tp->snd_cwnd, acked); in tcp_reno_cong_avoid()
|
| H A D | tcp_yeah.c | 58 static void tcp_yeah_cong_avoid(struct sock *sk, u32 ack, u32 acked) in tcp_yeah_cong_avoid() argument
67 acked = tcp_slow_start(tp, acked); in tcp_yeah_cong_avoid()
68 if (!acked) in tcp_yeah_cong_avoid()
75 acked); in tcp_yeah_cong_avoid()
78 tcp_cong_avoid_ai(tp, tp->snd_cwnd, acked); in tcp_yeah_cong_avoid()
|
| /dports/net-mgmt/icingaweb2/icingaweb2-2.8.2/library/Icinga/Web/Widget/ |
| H A D | Announcements.php | 31 $acked = array();
33 $acked[] = Filter::expression('hash', '!=', $hash);
35 $acked = Filter::matchAll($acked);
37 $announcements->applyFilter($acked);
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/neilalexander/utp/ |
| H A D | send.go | 9 acked Event member
26 first = !s.acked.IsSet()
34 s.acked.Set()
53 if s.acked.IsSet() || s.conn.destroyed.IsSet() {
63 if s.acked.IsSet() {
|
| /dports/net/tcptrace/tcptrace-508f73a/ |
| H A D | rexmit.c | 358 if (!pseg->acked) in collapse_quad()
363 if (pseg->acked && pseg->next->acked && in collapse_quad()
368 pseg->acked = pseg->next->acked; in collapse_quad()
535 if (!pseg->acked) { in rtt_retrans()
586 if (!pseg->acked) { in ack_in()
587 ++pseg->acked; in ack_in()
612 if (pseg->acked) { in ack_in()
624 if (pseg->acked == 4) { in ack_in()
652 ++pseg->acked; in ack_in()
653 if (pseg->acked == 4) { in ack_in()
[all …]
|
| /dports/net/quiche/quiche-0.9.0/src/recovery/ |
| H A D | cubic.rs | 457 let acked = vec![Acked { in cubic_slow_start() localVariable
500 let acked = vec![ in cubic_slow_start_multi_acks() localVariable
575 let acked = vec![Acked { in cubic_congestion_avoidance() localVariable
609 let acked = vec![Acked { in cubic_collapse_cwnd_and_restart() localVariable
673 let acked = vec![Acked { in cubic_hystart_limited_slow_start() localVariable
679 r.on_packets_acked(acked, epoch, now); in cubic_hystart_limited_slow_start()
708 let acked = vec![Acked { in cubic_hystart_limited_slow_start() localVariable
730 let acked = vec![Acked { in cubic_hystart_limited_slow_start() localVariable
765 let acked = vec![Acked { in cubic_spurious_congestion_event() localVariable
777 acked, in cubic_spurious_congestion_event()
[all …]
|
| /dports/sysutils/apcctrl/apcctrl-0.8.21/src/drivers/apcsmart/ |
| H A D | smartoper.c | 43 goto acked; in kill_power()
65 goto acked; in kill_power()
72 goto acked; in kill_power()
78 acked: in kill_power()
|
| /dports/sysutils/apcupsd/apcupsd-3.14.14/src/drivers/apcsmart/ |
| H A D | smartoper.c | 43 goto acked; in kill_power()
65 goto acked; in kill_power()
72 goto acked; in kill_power()
78 acked: in kill_power()
|
| /dports/www/h2o-devel/h2o-dcc7134/deps/quicly/t/ |
| H A D | loss.c | 34 static void acked(quicly_loss_t *loss, uint64_t pn, size_t epoch) in acked() function
74 acked(&loss, 0, QUICLY_EPOCH_INITIAL); in test_time_detection()
81 acked(&loss, 2, QUICLY_EPOCH_INITIAL); in test_time_detection()
118 acked(&loss, 2, QUICLY_EPOCH_INITIAL); in test_pn_detection()
124 acked(&loss, 3, QUICLY_EPOCH_INITIAL); in test_pn_detection()
157 acked(&loss, 1, QUICLY_EPOCH_HANDSHAKE); in test_slow_cert_verify()
179 acked(&loss, 3, QUICLY_EPOCH_HANDSHAKE); in test_slow_cert_verify()
|