/dports/security/suricata/suricata-6.0.4/src/ |
H A D | stream-tcp-sack.c | 224 if (SEQ_LT(re, stream->last_ack)) { in StreamTcpSackInsertRange() 265 stream->last_ack, le, re); in StreamTcpSackUpdatePacket() 313 rec->le = stream->last_ack; in StreamTcpSackPruneList() 565 stream.last_ack = 10; in StreamTcpSackTest07() 600 stream.last_ack = 41; in StreamTcpSackTest08() 636 stream.last_ack = 39; in StreamTcpSackTest09() 671 stream.last_ack = 99; in StreamTcpSackTest10() 706 stream.last_ack = 99; in StreamTcpSackTest11() 744 stream.last_ack = 500; in StreamTcpSackTest12() 761 stream.last_ack = 10000; in StreamTcpSackTest13() [all …]
|
H A D | stream-tcp.c | 816 (stream)->last_ack = (ack); \ 982 ssn->client.last_ack); in StreamTcpPacketStateNone() 986 ssn->server.last_ack); in StreamTcpPacketStateNone() 1132 ssn->client.last_ack, ssn->server.last_ack); in StreamTcpPacketStateNone() 1329 ssn->client.last_ack = q->ack; in StreamTcp3whsSynAckUpdate() 1361 ssn->server.last_ack, ssn->client.last_ack); in StreamTcp3whsSynAckUpdate() 1543 ssn->client.last_ack, ssn->server.last_ack); in StreamTcpPacketStateSynSent() 4666 ostream->next_seq - ostream->last_ack, stream->next_seq - stream->last_ack); in StreamTcpPacketIsBadWindowUpdate() 9138 ssn.client.last_ack = 10; 9278 ssn.client.last_ack = 10; [all …]
|
H A D | stream-tcp-reassemble.h | 136 if (STREAM_BASE_OFFSET(stream) == 0 && stream->last_ack == 0) in STREAM_LASTACK_GT_BASESEQ() 138 if (SEQ_GT(stream->last_ack, stream->base_seq)) in STREAM_LASTACK_GT_BASESEQ()
|
H A D | stream-tcp-reassemble.c | 2874 ssn.server.last_ack = 10; in StreamTcpReassembleTest40() 2903 ssn.server.last_ack = 11; in StreamTcpReassembleTest40() 2913 ssn.client.last_ack = 55; in StreamTcpReassembleTest40() 2923 ssn.server.last_ack = 12; in StreamTcpReassembleTest40() 2938 ssn.client.last_ack = 100; in StreamTcpReassembleTest40() 2948 ssn.server.last_ack = 13; in StreamTcpReassembleTest40() 2968 ssn.server.last_ack = 16; in StreamTcpReassembleTest40() 3113 ssn.client.last_ack = 21; in StreamTcpReassembleTest47() 3488 ssn.client.last_ack = 10; in StreamTcpReassembleInlineTest09() 3530 ssn.server.last_ack = 2; in StreamTcpReassembleInlineTest10() [all …]
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/infiniband/core/ |
H A D | mad_rmpp.c | 59 int last_ack; member 124 rmpp_recv->last_ack = rmpp_recv->seg_num; in format_ack() 305 rmpp_recv->last_ack = 0; in create_rmpp_recv() 489 if ((seg_num <= rmpp_recv->last_ack) || in continue_rmpp() 610 if ((mad_send_wr->last_ack == mad_send_wr->send_buf.seg_count) || in abort_send() 631 wr->last_ack = seg_num; in adjust_last_ack() 701 if (seg_num > mad_send_wr->last_ack) { in process_rmpp_ack() 706 if (mad_send_wr->last_ack == mad_send_wr->send_buf.seg_count) { in process_rmpp_ack() 921 if (mad_send_wr->last_ack == mad_send_wr->send_buf.seg_count) { in ib_process_rmpp_send_wc() 949 if (mad_send_wr->last_ack == mad_send_wr->send_buf.seg_count) in ib_retry_rmpp() [all …]
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/infiniband/core/ |
H A D | mad_rmpp.c | 59 int last_ack; member 124 rmpp_recv->last_ack = rmpp_recv->seg_num; in format_ack() 305 rmpp_recv->last_ack = 0; in create_rmpp_recv() 489 if ((seg_num <= rmpp_recv->last_ack) || in continue_rmpp() 610 if ((mad_send_wr->last_ack == mad_send_wr->send_buf.seg_count) || in abort_send() 631 wr->last_ack = seg_num; in adjust_last_ack() 701 if (seg_num > mad_send_wr->last_ack) { in process_rmpp_ack() 706 if (mad_send_wr->last_ack == mad_send_wr->send_buf.seg_count) { in process_rmpp_ack() 921 if (mad_send_wr->last_ack == mad_send_wr->send_buf.seg_count) { in ib_process_rmpp_send_wc() 949 if (mad_send_wr->last_ack == mad_send_wr->send_buf.seg_count) in ib_retry_rmpp() [all …]
|
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/infiniband/core/ |
H A D | mad_rmpp.c | 59 int last_ack; member 124 rmpp_recv->last_ack = rmpp_recv->seg_num; in format_ack() 305 rmpp_recv->last_ack = 0; in create_rmpp_recv() 489 if ((seg_num <= rmpp_recv->last_ack) || in continue_rmpp() 610 if ((mad_send_wr->last_ack == mad_send_wr->send_buf.seg_count) || in abort_send() 631 wr->last_ack = seg_num; in adjust_last_ack() 701 if (seg_num > mad_send_wr->last_ack) { in process_rmpp_ack() 706 if (mad_send_wr->last_ack == mad_send_wr->send_buf.seg_count) { in process_rmpp_ack() 921 if (mad_send_wr->last_ack == mad_send_wr->send_buf.seg_count) { in ib_process_rmpp_send_wc() 949 if (mad_send_wr->last_ack == mad_send_wr->send_buf.seg_count) in ib_retry_rmpp() [all …]
|
/dports/multimedia/libv4l/linux-5.13-rc2/net/ipv4/ |
H A D | tcp_cdg.c | 93 u32 last_ack; member 152 if (ca->last_ack == 0 || !tcp_is_cwnd_limited(sk)) { in tcp_cdg_hystart_update() 153 ca->last_ack = now_us; in tcp_cdg_hystart_update() 155 } else if (before(now_us, ca->last_ack + 3000)) { in tcp_cdg_hystart_update() 158 ca->last_ack = now_us; in tcp_cdg_hystart_update() 280 ca->last_ack = 0; in tcp_cdg_cong_avoid()
|
H A D | tcp_cubic.c | 101 u32 last_ack; /* last time when the ACK spacing is close */ member 121 ca->round_start = ca->last_ack = bictcp_clock_us(sk); in bictcp_hystart_reset() 396 if ((s32)(now - ca->last_ack) <= hystart_ack_delta_us) { in hystart_update() 397 ca->last_ack = now; in hystart_update()
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/net/ipv4/ |
H A D | tcp_cdg.c | 93 u32 last_ack; member 152 if (ca->last_ack == 0 || !tcp_is_cwnd_limited(sk)) { in tcp_cdg_hystart_update() 153 ca->last_ack = now_us; in tcp_cdg_hystart_update() 155 } else if (before(now_us, ca->last_ack + 3000)) { in tcp_cdg_hystart_update() 158 ca->last_ack = now_us; in tcp_cdg_hystart_update() 280 ca->last_ack = 0; in tcp_cdg_cong_avoid()
|
H A D | tcp_cubic.c | 101 u32 last_ack; /* last time when the ACK spacing is close */ member 121 ca->round_start = ca->last_ack = bictcp_clock_us(sk); in bictcp_hystart_reset() 396 if ((s32)(now - ca->last_ack) <= hystart_ack_delta_us) { in hystart_update() 397 ca->last_ack = now; in hystart_update()
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/net/ipv4/ |
H A D | tcp_cdg.c | 93 u32 last_ack; member 152 if (ca->last_ack == 0 || !tcp_is_cwnd_limited(sk)) { in tcp_cdg_hystart_update() 153 ca->last_ack = now_us; in tcp_cdg_hystart_update() 155 } else if (before(now_us, ca->last_ack + 3000)) { in tcp_cdg_hystart_update() 158 ca->last_ack = now_us; in tcp_cdg_hystart_update() 280 ca->last_ack = 0; in tcp_cdg_cong_avoid()
|
H A D | tcp_cubic.c | 101 u32 last_ack; /* last time when the ACK spacing is close */ member 121 ca->round_start = ca->last_ack = bictcp_clock_us(sk); in bictcp_hystart_reset() 396 if ((s32)(now - ca->last_ack) <= hystart_ack_delta_us) { in hystart_update() 397 ca->last_ack = now; in hystart_update()
|
/dports/net-im/py-slixmpp/slixmpp-1.7.1/slixmpp/plugins/xep_0198/ |
H A D | stream_management.py | 173 self.last_ack = 0 281 if ack['h'] == self.last_ack: 284 num_acked = (ack['h'] - self.last_ack) % MAX_SEQ 290 self.last_ack, 301 self.last_ack = ack['h']
|
/dports/security/suricata/suricata-6.0.4/src/tests/ |
H A D | stream-tcp-reassemble.c | 80 ssn.server.last_ack = (isn) + 1; \ 81 ssn.client.last_ack = (isn) + 1; \ 110 stream->last_ack = (lastack); \
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/components/viz/service/display/ |
H A D | display_damage_tracker.cc | 87 !it->second.last_ack.frame_id.IsNextInSequenceTo(ack.frame_id)) { in ProcessSurfaceDamage() 88 it->second.last_ack = ack; in ProcessSurfaceDamage() 125 if (state.last_ack.frame_id == begin_frame_args.frame_id) { in HasPendingSurfaces()
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/components/viz/service/display/ |
H A D | display_damage_tracker.cc | 87 !it->second.last_ack.frame_id.IsNextInSequenceTo(ack.frame_id)) { in ProcessSurfaceDamage() 88 it->second.last_ack = ack; in ProcessSurfaceDamage() 125 if (state.last_ack.frame_id == begin_frame_args.frame_id) { in HasPendingSurfaces()
|
/dports/net/wireshark/wireshark-3.6.1/ui/qt/ |
H A D | tcp_stream_dialog.cpp | 941 if (tcp_seq_before(last_ack, unacked->second)) { in goodput_adjust_for_sacks() 944 *seglen -= (last_ack - unacked->first); in goodput_adjust_for_sacks() 945 unacked->first = last_ack; in goodput_adjust_for_sacks() 970 new_sacks[next_new_idx].first = last_ack; in goodput_adjust_for_sacks() 1219 guint32 last_ack = 0; local 1223 last_ack = seg->th_ack; 1257 seglen = seg->th_ack - last_ack; 1258 last_ack = seg->th_ack; 1548 guint32 last_ack = 0; local 1559 tcp_seq_eq_or_after(end_seq, last_ack)) { [all …]
|
/dports/net/wireshark-lite/wireshark-3.6.1/ui/qt/ |
H A D | tcp_stream_dialog.cpp | 941 if (tcp_seq_before(last_ack, unacked->second)) { 944 *seglen -= (last_ack - unacked->first); 945 unacked->first = last_ack; 970 new_sacks[next_new_idx].first = last_ack; 1219 guint32 last_ack = 0; 1223 last_ack = seg->th_ack; 1257 seglen = seg->th_ack - last_ack; 1258 last_ack = seg->th_ack; 1548 guint32 last_ack = 0; 1559 tcp_seq_eq_or_after(end_seq, last_ack)) { [all …]
|
/dports/net/tshark/wireshark-3.6.1/ui/qt/ |
H A D | tcp_stream_dialog.cpp | 941 if (tcp_seq_before(last_ack, unacked->second)) { in goodput_adjust_for_sacks() 944 *seglen -= (last_ack - unacked->first); in goodput_adjust_for_sacks() 945 unacked->first = last_ack; in goodput_adjust_for_sacks() 970 new_sacks[next_new_idx].first = last_ack; in goodput_adjust_for_sacks() 1219 guint32 last_ack = 0; local 1223 last_ack = seg->th_ack; 1257 seglen = seg->th_ack - last_ack; 1258 last_ack = seg->th_ack; 1548 guint32 last_ack = 0; local 1559 tcp_seq_eq_or_after(end_seq, last_ack)) { [all …]
|
/dports/net/tshark-lite/wireshark-3.6.1/ui/qt/ |
H A D | tcp_stream_dialog.cpp | 941 if (tcp_seq_before(last_ack, unacked->second)) { 944 *seglen -= (last_ack - unacked->first); 945 unacked->first = last_ack; 970 new_sacks[next_new_idx].first = last_ack; 1219 guint32 last_ack = 0; 1223 last_ack = seg->th_ack; 1257 seglen = seg->th_ack - last_ack; 1258 last_ack = seg->th_ack; 1548 guint32 last_ack = 0; 1559 tcp_seq_eq_or_after(end_seq, last_ack)) { [all …]
|
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbit/src/ |
H A D | gm.erl | 417 -record(member, { pending_ack, last_pub, last_ack }). 829 #member { pending_ack = PALeft, last_ack = LA } = 837 {Member #member { last_ack = LA }, 1242 #member { last_pub = LP, last_ack = LA } = 1441 last_ack = LA }, 1448 LA1 = last_ack(Acks, LA), 1453 last_ack = LA1 }, 1459 LA1 = last_ack(Acks, LA), 1463 last_ack = LA1 }, 1605 last_ack( [], LA) -> LA; function [all …]
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/tools/testing/selftests/bpf/progs/ |
H A D | bpf_cubic.c | 90 __u32 last_ack; /* last time when the ACK spacing is close */ member 166 ca->round_start = ca->last_ack = bictcp_clock_us(sk); in bictcp_hystart_reset() 463 if ((__s32)(now - ca->last_ack) <= hystart_ack_delta_us) { in hystart_update() 464 ca->last_ack = now; in hystart_update()
|
/dports/multimedia/libv4l/linux-5.13-rc2/tools/testing/selftests/bpf/progs/ |
H A D | bpf_cubic.c | 90 __u32 last_ack; /* last time when the ACK spacing is close */ member 166 ca->round_start = ca->last_ack = bictcp_clock_us(sk); in bictcp_hystart_reset() 463 if ((__s32)(now - ca->last_ack) <= hystart_ack_delta_us) { in hystart_update() 464 ca->last_ack = now; in hystart_update()
|
/dports/multimedia/v4l-utils/linux-5.13-rc2/tools/testing/selftests/bpf/progs/ |
H A D | bpf_cubic.c | 90 __u32 last_ack; /* last time when the ACK spacing is close */ member 166 ca->round_start = ca->last_ack = bictcp_clock_us(sk); in bictcp_hystart_reset() 463 if ((__s32)(now - ca->last_ack) <= hystart_ack_delta_us) { in hystart_update() 464 ca->last_ack = now; in hystart_update()
|