Home
last modified time | relevance | path

Searched refs:last_ack (Results 1 – 25 of 93) sorted by relevance

1234

/dports/security/suricata/suricata-6.0.4/src/
H A Dstream-tcp-sack.c224 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 Dstream-tcp.c816 (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 Dstream-tcp-reassemble.h136 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 Dstream-tcp-reassemble.c2874 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 Dmad_rmpp.c59 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 Dmad_rmpp.c59 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 Dmad_rmpp.c59 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 Dtcp_cdg.c93 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 Dtcp_cubic.c101 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 Dtcp_cdg.c93 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 Dtcp_cubic.c101 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 Dtcp_cdg.c93 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 Dtcp_cubic.c101 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 Dstream_management.py173 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 Dstream-tcp-reassemble.c80 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 Ddisplay_damage_tracker.cc87 !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 Ddisplay_damage_tracker.cc87 !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 Dtcp_stream_dialog.cpp941 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 Dtcp_stream_dialog.cpp941 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 Dtcp_stream_dialog.cpp941 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 Dtcp_stream_dialog.cpp941 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 Dgm.erl417 -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 Dbpf_cubic.c90 __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 Dbpf_cubic.c90 __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 Dbpf_cubic.c90 __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()

1234