Lines Matching refs:trk

35 bool TcpStateEstablished::syn_sent(TcpSegmentDescriptor& tsd, TcpStreamTracker& trk)  in syn_sent()  argument
37 trk.session->check_for_repeated_syn(tsd); in syn_sent()
41 bool TcpStateEstablished::syn_recv(TcpSegmentDescriptor& tsd, TcpStreamTracker& trk) in syn_recv() argument
43 trk.session->check_for_repeated_syn(tsd); in syn_recv()
44 trk.normalizer.ecn_tracker(tsd.get_tcph(), trk.session->tcp_config->require_3whs()); in syn_recv()
48 bool TcpStateEstablished::syn_ack_sent(TcpSegmentDescriptor& tsd, TcpStreamTracker& trk) in syn_ack_sent() argument
50 if ( trk.session->tcp_config->midstream_allowed(tsd.get_pkt()) ) in syn_ack_sent()
57 trk.session->update_session_on_syn_ack(); in syn_ack_sent()
60 if ( trk.is_server_tracker() ) in syn_ack_sent()
61 trk.normalizer.ecn_tracker(tsd.get_tcph(), trk.session->tcp_config->require_3whs() ); in syn_ack_sent()
66 bool TcpStateEstablished::ack_sent(TcpSegmentDescriptor& tsd, TcpStreamTracker& trk) in ack_sent() argument
68 trk.update_tracker_ack_sent(tsd); in ack_sent()
72 bool TcpStateEstablished::ack_recv(TcpSegmentDescriptor& tsd, TcpStreamTracker& trk) in ack_recv() argument
74 trk.update_tracker_ack_recv(tsd); in ack_recv()
78 bool TcpStateEstablished::data_seg_sent(TcpSegmentDescriptor& tsd, TcpStreamTracker& trk) in data_seg_sent() argument
80 trk.update_tracker_ack_sent(tsd); in data_seg_sent()
81 if ( trk.session->no_ack_mode_enabled() ) in data_seg_sent()
82 trk.update_tracker_no_ack_recv(tsd); in data_seg_sent()
86 bool TcpStateEstablished::data_seg_recv(TcpSegmentDescriptor& tsd, TcpStreamTracker& trk) in data_seg_recv() argument
88 trk.update_tracker_ack_recv(tsd); in data_seg_recv()
89 trk.session->handle_data_segment(tsd); in data_seg_recv()
90 if ( trk.session->no_ack_mode_enabled() ) in data_seg_recv()
91 trk.update_tracker_no_ack_sent(tsd); in data_seg_recv()
95 bool TcpStateEstablished::fin_sent(TcpSegmentDescriptor& tsd, TcpStreamTracker& trk) in fin_sent() argument
97 trk.update_on_fin_sent(tsd); in fin_sent()
98 trk.session->flow->call_handlers(tsd.get_pkt(), true); in fin_sent()
99 trk.set_tcp_state(TcpStreamTracker::TCP_FIN_WAIT1); in fin_sent()
103 bool TcpStateEstablished::fin_recv(TcpSegmentDescriptor& tsd, TcpStreamTracker& trk) in fin_recv() argument
105 trk.update_tracker_ack_recv(tsd); in fin_recv()
106 trk.perform_fin_recv_flush(tsd); in fin_recv()
108 if ( trk.update_on_fin_recv(tsd) ) in fin_recv()
110 trk.session->update_perf_base_state(TcpStreamTracker::TCP_CLOSING); in fin_recv()
111 trk.set_tcp_state(TcpStreamTracker::TCP_CLOSE_WAIT); in fin_recv()
117 bool TcpStateEstablished::rst_recv(TcpSegmentDescriptor& tsd, TcpStreamTracker& trk) in rst_recv() argument
119 if ( trk.update_on_rst_recv(tsd) ) in rst_recv()
121 trk.session->update_session_on_rst(tsd, false); in rst_recv()
122 trk.session->update_perf_base_state(TcpStreamTracker::TCP_CLOSING); in rst_recv()
123 trk.session->set_pkt_action_flag(ACTION_RST); in rst_recv()
128 trk.session->tel.set_tcp_event(EVENT_DATA_AFTER_RST_RCVD); in rst_recv()
134 TcpSegmentDescriptor& tsd, TcpStreamTracker& trk) in do_pre_sm_packet_actions() argument
136 return trk.session->validate_packet_established_session(tsd); in do_pre_sm_packet_actions()
140 TcpSegmentDescriptor& tsd, TcpStreamTracker& trk) in do_post_sm_packet_actions() argument
142 trk.session->update_paws_timestamps(tsd); in do_post_sm_packet_actions()
143 trk.session->check_for_window_slam(tsd); in do_post_sm_packet_actions()