| /NetX-Duo-v6.2.1/common/src/ |
| D | nx_tcp_socket_state_syn_sent.c | 85 VOID _nx_tcp_socket_state_syn_sent(NX_TCP_SOCKET *socket_ptr, NX_TCP_HEADER *tcp_header_ptr, NX_PA… in _nx_tcp_socket_state_syn_sent() argument
99 … (tcp_header_ptr -> nx_tcp_acknowledgment_number == socket_ptr -> nx_tcp_socket_tx_sequence)) in _nx_tcp_socket_state_syn_sent()
105 (socket_ptr -> nx_tcp_socket_ip_ptr) -> nx_ip_tcp_resets_received++; in _nx_tcp_socket_state_syn_sent()
109 …_IN_LINE_INSERT(NX_TRACE_INTERNAL_TCP_RESET_RECEIVE, socket_ptr -> nx_tcp_socket_ip_ptr, socket_pt… in _nx_tcp_socket_state_syn_sent()
112 _nx_tcp_socket_connection_reset(socket_ptr); in _nx_tcp_socket_state_syn_sent()
121 … (tcp_header_ptr -> nx_tcp_acknowledgment_number == socket_ptr -> nx_tcp_socket_tx_sequence)) in _nx_tcp_socket_state_syn_sent()
129 socket_ptr -> nx_tcp_socket_rx_sequence = tcp_header_ptr -> nx_tcp_sequence_number + 1; in _nx_tcp_socket_state_syn_sent()
132 …socket_ptr -> nx_tcp_socket_tx_window_advertised = tcp_header_ptr -> nx_tcp_header_word_3 & NX_LOW… in _nx_tcp_socket_state_syn_sent()
138 if (socket_ptr -> nx_tcp_snd_win_scale_value == 0xFF) in _nx_tcp_socket_state_syn_sent()
141 socket_ptr -> nx_tcp_snd_win_scale_value = 0; in _nx_tcp_socket_state_syn_sent()
[all …]
|
| D | nx_tcp_fast_periodic_processing.c | 85 NX_TCP_SOCKET *socket_ptr; in _nx_tcp_fast_periodic_processing() local
97 socket_ptr = ip_ptr -> nx_ip_tcp_created_sockets_ptr; in _nx_tcp_fast_periodic_processing()
105 if ((socket_ptr -> nx_tcp_socket_state >= NX_TCP_ESTABLISHED) && in _nx_tcp_fast_periodic_processing()
106 … ((socket_ptr -> nx_tcp_socket_rx_sequence != socket_ptr -> nx_tcp_socket_rx_sequence_acked) || in _nx_tcp_fast_periodic_processing()
107 …(socket_ptr -> nx_tcp_socket_rx_window_last_sent < socket_ptr -> nx_tcp_socket_rx_window_current))) in _nx_tcp_fast_periodic_processing()
111 if (socket_ptr -> nx_tcp_socket_delayed_ack_timeout <= timer_rate) in _nx_tcp_fast_periodic_processing()
115 _nx_tcp_packet_send_ack(socket_ptr, socket_ptr -> nx_tcp_socket_tx_sequence); in _nx_tcp_fast_periodic_processing()
121 socket_ptr -> nx_tcp_socket_delayed_ack_timeout -= timer_rate; in _nx_tcp_fast_periodic_processing()
126 if (socket_ptr -> nx_tcp_socket_timeout) in _nx_tcp_fast_periodic_processing()
130 if (socket_ptr -> nx_tcp_socket_timeout > timer_rate) in _nx_tcp_fast_periodic_processing()
[all …]
|
| D | nx_tcp_socket_disconnect.c | 87 UINT _nx_tcp_socket_disconnect(NX_TCP_SOCKET *socket_ptr, ULONG wait_option) in _nx_tcp_socket_disconnect() argument
100 ip_ptr = socket_ptr -> nx_tcp_socket_ip_ptr; in _nx_tcp_socket_disconnect()
103 …ACE_IN_LINE_INSERT(NX_TRACE_TCP_SOCKET_DISCONNECT, ip_ptr, socket_ptr, wait_option, socket_ptr -> … in _nx_tcp_socket_disconnect()
117 if ((socket_ptr -> nx_tcp_socket_state != NX_TCP_ESTABLISHED) && in _nx_tcp_socket_disconnect()
118 (socket_ptr -> nx_tcp_socket_state != NX_TCP_SYN_SENT) && in _nx_tcp_socket_disconnect()
119 (socket_ptr -> nx_tcp_socket_state != NX_TCP_SYN_RECEIVED) && in _nx_tcp_socket_disconnect()
120 (socket_ptr -> nx_tcp_socket_state != NX_TCP_CLOSE_WAIT)) in _nx_tcp_socket_disconnect()
133 socket_ptr -> nx_tcp_socket_keepalive_timeout = 0; in _nx_tcp_socket_disconnect()
134 socket_ptr -> nx_tcp_socket_keepalive_retries = 0; in _nx_tcp_socket_disconnect()
138 interface_ptr = socket_ptr -> nx_tcp_socket_connect_interface; in _nx_tcp_socket_disconnect()
[all …]
|
| D | nx_tcp_server_socket_accept.c | 78 UINT _nx_tcp_server_socket_accept(NX_TCP_SOCKET *socket_ptr, ULONG wait_option) in _nx_tcp_server_socket_accept() argument
85 ip_ptr = socket_ptr -> nx_tcp_socket_ip_ptr; in _nx_tcp_server_socket_accept()
88 …_IN_LINE_INSERT(NX_TRACE_TCP_SERVER_SOCKET_ACCEPT, ip_ptr, socket_ptr, wait_option, socket_ptr -> … in _nx_tcp_server_socket_accept()
91 if (socket_ptr -> nx_tcp_socket_state == NX_TCP_ESTABLISHED) in _nx_tcp_server_socket_accept()
98 …if ((socket_ptr -> nx_tcp_socket_state != NX_TCP_LISTEN_STATE) && (socket_ptr -> nx_tcp_socket_sta… in _nx_tcp_server_socket_accept()
109 if (socket_ptr -> nx_tcp_socket_state == NX_TCP_LISTEN_STATE) in _nx_tcp_server_socket_accept()
113 if (socket_ptr -> nx_tcp_socket_tx_sequence == 0) in _nx_tcp_server_socket_accept()
115 … socket_ptr -> nx_tcp_socket_tx_sequence = (((ULONG)NX_RAND()) << NX_SHIFT_BY_16) & 0xFFFFFFFF; in _nx_tcp_server_socket_accept()
116 socket_ptr -> nx_tcp_socket_tx_sequence |= (ULONG)NX_RAND(); in _nx_tcp_server_socket_accept()
120 …socket_ptr -> nx_tcp_socket_tx_sequence = socket_ptr -> nx_tcp_socket_tx_sequence + ((ULONG)(((UL… in _nx_tcp_server_socket_accept()
[all …]
|
| D | nx_tcp_socket_state_fin_wait1.c | 74 VOID _nx_tcp_socket_state_fin_wait1(NX_TCP_SOCKET *socket_ptr) in _nx_tcp_socket_state_fin_wait1() argument
80 if ((socket_ptr -> nx_tcp_socket_fin_acked) && in _nx_tcp_socket_state_fin_wait1()
81 (socket_ptr -> nx_tcp_socket_fin_received == NX_FALSE)) in _nx_tcp_socket_state_fin_wait1()
85 …INE_INSERT(NX_TRACE_INTERNAL_TCP_STATE_CHANGE, socket_ptr -> nx_tcp_socket_ip_ptr, socket_ptr, soc… in _nx_tcp_socket_state_fin_wait1()
89 socket_ptr -> nx_tcp_socket_state = NX_TCP_FIN_WAIT_2; in _nx_tcp_socket_state_fin_wait1()
92 socket_ptr -> nx_tcp_socket_timeout = 0; in _nx_tcp_socket_state_fin_wait1()
94 else if ((socket_ptr -> nx_tcp_socket_fin_acked) && in _nx_tcp_socket_state_fin_wait1()
95 (socket_ptr -> nx_tcp_socket_fin_sequence == socket_ptr -> nx_tcp_socket_rx_sequence)) in _nx_tcp_socket_state_fin_wait1()
103 …INE_INSERT(NX_TRACE_INTERNAL_TCP_STATE_CHANGE, socket_ptr -> nx_tcp_socket_ip_ptr, socket_ptr, soc… in _nx_tcp_socket_state_fin_wait1()
106 socket_ptr -> nx_tcp_socket_state = NX_TCP_TIMED_WAIT; in _nx_tcp_socket_state_fin_wait1()
[all …]
|
| D | nx_tcp_socket_state_ack_check.c | 97 UINT _nx_tcp_socket_state_ack_check(NX_TCP_SOCKET *socket_ptr, NX_TCP_HEADER *tcp_header_ptr) in _nx_tcp_socket_state_ack_check() argument
124 if (socket_ptr -> nx_tcp_socket_zero_window_probe_has_data) in _nx_tcp_socket_state_ack_check()
126 ending_tx_sequence = socket_ptr -> nx_tcp_socket_tx_sequence + 1; in _nx_tcp_socket_state_ack_check()
130 ending_tx_sequence = socket_ptr -> nx_tcp_socket_tx_sequence; in _nx_tcp_socket_state_ack_check()
132 …starting_tx_sequence = socket_ptr -> nx_tcp_socket_tx_sequence - socket_ptr -> nx_tcp_socket_tx_ou… in _nx_tcp_socket_state_ack_check()
135 if (socket_ptr -> nx_tcp_socket_receive_queue_tail) in _nx_tcp_socket_state_ack_check()
137 search_ptr = socket_ptr -> nx_tcp_socket_receive_queue_tail; in _nx_tcp_socket_state_ack_check()
182 ending_rx_sequence = socket_ptr -> nx_tcp_socket_rx_sequence; in _nx_tcp_socket_state_ack_check()
187 if (socket_ptr -> nx_tcp_socket_state == NX_TCP_ESTABLISHED) in _nx_tcp_socket_state_ack_check()
191 if (socket_ptr -> nx_tcp_socket_keepalive_enabled) in _nx_tcp_socket_state_ack_check()
[all …]
|
| D | nx_tcp_socket_state_syn_received.c | 77 VOID _nx_tcp_socket_state_syn_received(NX_TCP_SOCKET *socket_ptr, NX_TCP_HEADER *tcp_header_ptr) in _nx_tcp_socket_state_syn_received() argument
86 … if (tcp_header_ptr -> nx_tcp_acknowledgment_number == socket_ptr -> nx_tcp_socket_tx_sequence) in _nx_tcp_socket_state_syn_received()
90 …INE_INSERT(NX_TRACE_INTERNAL_TCP_STATE_CHANGE, socket_ptr -> nx_tcp_socket_ip_ptr, socket_ptr, soc… in _nx_tcp_socket_state_syn_received()
93 socket_ptr -> nx_tcp_socket_tx_window_advertised = in _nx_tcp_socket_state_syn_received()
100 if (socket_ptr -> nx_tcp_snd_win_scale_value == 0xFF) in _nx_tcp_socket_state_syn_received()
104 socket_ptr -> nx_tcp_snd_win_scale_value = 0; in _nx_tcp_socket_state_syn_received()
105 socket_ptr -> nx_tcp_rcv_win_scale_value = 0; in _nx_tcp_socket_state_syn_received()
109 if (socket_ptr -> nx_tcp_socket_rx_window_maximum > 65535) in _nx_tcp_socket_state_syn_received()
111 socket_ptr -> nx_tcp_socket_rx_window_default = 65535; in _nx_tcp_socket_state_syn_received()
112 socket_ptr -> nx_tcp_socket_rx_window_current = 65535; in _nx_tcp_socket_state_syn_received()
[all …]
|
| D | nx_tcp_socket_create.c | 87 UINT _nx_tcp_socket_create(NX_IP *ip_ptr, NX_TCP_SOCKET *socket_ptr, CHAR *name, in _nx_tcp_socket_create() argument
89 VOID (*tcp_urgent_data_callback)(NX_TCP_SOCKET *socket_ptr), in _nx_tcp_socket_create() argument
90 VOID (*tcp_disconnect_callback)(NX_TCP_SOCKET *socket_ptr)) in _nx_tcp_socket_create() argument
98 memset((void *)socket_ptr, 0, sizeof(NX_TCP_SOCKET)); in _nx_tcp_socket_create()
103 socket_ptr -> nx_tcp_socket_ip_ptr = ip_ptr; in _nx_tcp_socket_create()
106 socket_ptr -> nx_tcp_socket_client_type = NX_TRUE; in _nx_tcp_socket_create()
109 socket_ptr -> nx_tcp_socket_name = name; in _nx_tcp_socket_create()
112 socket_ptr -> nx_tcp_socket_duplicated_ack_received = 0; in _nx_tcp_socket_create()
115 socket_ptr -> nx_tcp_socket_mss = 0; in _nx_tcp_socket_create()
118 socket_ptr -> nx_tcp_socket_connect_mss = NX_TCP_MSS_SIZE; in _nx_tcp_socket_create()
[all …]
|
| D | nxd_tcp_client_socket_connect.c | 81 static UINT _nxd_tcp_client_socket_driver_connect(NX_TCP_SOCKET *socket_ptr, in _nxd_tcp_client_socket_driver_connect() argument
92 ip_ptr = socket_ptr -> nx_tcp_socket_ip_ptr; in _nxd_tcp_client_socket_driver_connect()
95 socket_ptr -> nx_tcp_socket_timeout = 0; in _nxd_tcp_client_socket_driver_connect()
98 interface_ptr = socket_ptr -> nx_tcp_socket_connect_interface; in _nxd_tcp_client_socket_driver_connect()
99 status = interface_ptr -> nx_interface_tcpip_offload_handler(ip_ptr, interface_ptr, socket_ptr, in _nxd_tcp_client_socket_driver_connect()
102 socket_ptr -> nx_tcp_socket_port, in _nxd_tcp_client_socket_driver_connect()
111 socket_ptr -> nx_tcp_socket_mss = in _nxd_tcp_client_socket_driver_connect()
118 socket_ptr -> nx_tcp_socket_mss = in _nxd_tcp_client_socket_driver_connect()
122 socket_ptr -> nx_tcp_socket_connect_mss = socket_ptr -> nx_tcp_socket_mss; in _nxd_tcp_client_socket_driver_connect()
123 socket_ptr -> nx_tcp_socket_peer_mss = socket_ptr -> nx_tcp_socket_mss; in _nxd_tcp_client_socket_driver_connect()
[all …]
|
| D | nx_tcp_socket_retransmit.c | 86 VOID _nx_tcp_socket_retransmit(NX_IP *ip_ptr, NX_TCP_SOCKET *socket_ptr, UINT need_fast_retransmit) in _nx_tcp_socket_retransmit() argument
102 if (socket_ptr -> nx_tcp_socket_tx_window_advertised == 0) in _nx_tcp_socket_retransmit()
106 packet_ptr = socket_ptr -> nx_tcp_socket_transmit_sent_head; in _nx_tcp_socket_retransmit()
120 …socket_ptr -> nx_tcp_socket_zero_window_probe_data = *(packet_ptr -> nx_packet_prepend_ptr + ((hea… in _nx_tcp_socket_retransmit()
123 socket_ptr -> nx_tcp_socket_zero_window_probe_has_data = NX_TRUE; in _nx_tcp_socket_retransmit()
124 … socket_ptr -> nx_tcp_socket_zero_window_probe_sequence = header_ptr -> nx_tcp_sequence_number; in _nx_tcp_socket_retransmit()
125 socket_ptr -> nx_tcp_socket_zero_window_probe_failure = 0; in _nx_tcp_socket_retransmit()
130 else if (socket_ptr -> nx_tcp_socket_zero_window_probe_has_data == NX_FALSE) in _nx_tcp_socket_retransmit()
139 socket_ptr -> nx_tcp_socket_timeout_retries++; in _nx_tcp_socket_retransmit()
140 socket_ptr -> nx_tcp_socket_zero_window_probe_failure++; in _nx_tcp_socket_retransmit()
[all …]
|
| D | nx_tcp_server_socket_unaccept.c | 74 UINT _nx_tcp_server_socket_unaccept(NX_TCP_SOCKET *socket_ptr) in _nx_tcp_server_socket_unaccept() argument
84 ip_ptr = socket_ptr -> nx_tcp_socket_ip_ptr; in _nx_tcp_server_socket_unaccept()
87 …NX_TRACE_IN_LINE_INSERT(NX_TRACE_TCP_SERVER_SOCKET_UNACCEPT, ip_ptr, socket_ptr, socket_ptr -> nx_… in _nx_tcp_server_socket_unaccept()
93 if ((socket_ptr -> nx_tcp_socket_state >= NX_TCP_CLOSE_WAIT) || in _nx_tcp_server_socket_unaccept()
94 …((socket_ptr -> nx_tcp_socket_state == NX_TCP_CLOSED) && (socket_ptr -> nx_tcp_socket_bound_next))) in _nx_tcp_server_socket_unaccept()
98 …NX_TRACE_IN_LINE_INSERT(NX_TRACE_INTERNAL_TCP_STATE_CHANGE, ip_ptr, socket_ptr, socket_ptr -> nx_t… in _nx_tcp_server_socket_unaccept()
101 socket_ptr -> nx_tcp_socket_state = NX_TCP_LISTEN_STATE; in _nx_tcp_server_socket_unaccept()
104 socket_ptr -> nx_tcp_socket_connect_ip.nxd_ip_version = 0; in _nx_tcp_server_socket_unaccept()
107 SET_UNSPECIFIED_ADDRESS(socket_ptr -> nx_tcp_socket_connect_ip.nxd_ip_address.v6); in _nx_tcp_server_socket_unaccept()
109 socket_ptr -> nx_tcp_socket_connect_ip.nxd_ip_address.v4 = 0; in _nx_tcp_server_socket_unaccept()
[all …]
|
| D | nx_tcp_socket_state_data_check.c | 340 UINT _nx_tcp_socket_state_data_check(NX_TCP_SOCKET *socket_ptr, NX_PACKET *packet_ptr) in _nx_tcp_socket_state_data_check() argument
370 ip_ptr = socket_ptr -> nx_tcp_socket_ip_ptr; in _nx_tcp_socket_state_data_check()
374 tcpip_offload = socket_ptr -> nx_tcp_socket_connect_interface -> nx_interface_capability_flag & in _nx_tcp_socket_state_data_check()
386 original_rx_sequence = socket_ptr -> nx_tcp_socket_rx_sequence; in _nx_tcp_socket_state_data_check()
406 if (((INT)(socket_ptr -> nx_tcp_socket_rx_sequence - packet_begin_sequence)) > 0) in _nx_tcp_socket_state_data_check()
410 trim_data_length = socket_ptr -> nx_tcp_socket_rx_sequence - packet_begin_sequence; in _nx_tcp_socket_state_data_check()
424 if (((INT)((packet_end_sequence - socket_ptr -> nx_tcp_socket_rx_sequence) - in _nx_tcp_socket_state_data_check()
425 socket_ptr -> nx_tcp_socket_rx_window_current)) > 0) in _nx_tcp_socket_state_data_check()
429 …trim_data_length = packet_end_sequence - (socket_ptr -> nx_tcp_socket_rx_sequence + socket_ptr -> … in _nx_tcp_socket_state_data_check()
445 …socket_ptr -> nx_tcp_socket_fin_sequence = tcp_header_ptr -> nx_tcp_sequence_number + packet_data… in _nx_tcp_socket_state_data_check()
[all …]
|
| D | nx_udp_socket_create.c | 81 UINT _nx_udp_socket_create(NX_IP *ip_ptr, NX_UDP_SOCKET *socket_ptr, CHAR *name, in _nx_udp_socket_create() argument
90 memset((void *)socket_ptr, 0, sizeof(NX_UDP_SOCKET)); in _nx_udp_socket_create()
95 socket_ptr -> nx_udp_socket_ip_ptr = ip_ptr; in _nx_udp_socket_create()
98 socket_ptr -> nx_udp_socket_name = name; in _nx_udp_socket_create()
101 socket_ptr -> nx_udp_socket_type_of_service = type_of_service; in _nx_udp_socket_create()
104 socket_ptr -> nx_udp_socket_fragment_enable = fragment & NX_DONT_FRAGMENT; in _nx_udp_socket_create()
107 socket_ptr -> nx_udp_socket_time_to_live = time_to_live; in _nx_udp_socket_create()
111 socket_ptr -> nx_udp_socket_disable_checksum = NX_FALSE; in _nx_udp_socket_create()
114 socket_ptr -> nx_udp_socket_bind_in_progress = NX_FALSE; in _nx_udp_socket_create()
117 socket_ptr -> nx_udp_socket_bound_next = NX_NULL; in _nx_udp_socket_create()
[all …]
|
| D | nx_tcp_socket_state_fin_wait2.c | 74 VOID _nx_tcp_socket_state_fin_wait2(NX_TCP_SOCKET *socket_ptr) in _nx_tcp_socket_state_fin_wait2() argument
80 if ((socket_ptr -> nx_tcp_socket_fin_received) && in _nx_tcp_socket_state_fin_wait2()
81 (socket_ptr -> nx_tcp_socket_fin_sequence == socket_ptr -> nx_tcp_socket_rx_sequence)) in _nx_tcp_socket_state_fin_wait2()
89 …INE_INSERT(NX_TRACE_INTERNAL_TCP_STATE_CHANGE, socket_ptr -> nx_tcp_socket_ip_ptr, socket_ptr, soc… in _nx_tcp_socket_state_fin_wait2()
92 socket_ptr -> nx_tcp_socket_state = NX_TCP_TIMED_WAIT; in _nx_tcp_socket_state_fin_wait2()
95 socket_ptr -> nx_tcp_socket_timeout = _nx_tcp_2MSL_timer_rate; in _nx_tcp_socket_state_fin_wait2()
100 socket_ptr -> nx_tcp_socket_rx_sequence++; in _nx_tcp_socket_state_fin_wait2()
103 _nx_tcp_packet_send_ack(socket_ptr, socket_ptr -> nx_tcp_socket_tx_sequence); in _nx_tcp_socket_state_fin_wait2()
106 if (socket_ptr -> nx_tcp_socket_disconnect_suspended_thread) in _nx_tcp_socket_state_fin_wait2()
110 …_nx_tcp_socket_thread_resume(&(socket_ptr -> nx_tcp_socket_disconnect_suspended_thread), NX_SUCCES… in _nx_tcp_socket_state_fin_wait2()
[all …]
|
| D | nx_tcp_packet_send_syn.c | 85 VOID _nx_tcp_packet_send_syn(NX_TCP_SOCKET *socket_ptr, ULONG tx_sequence) in _nx_tcp_packet_send_syn() argument
105 if (socket_ptr -> nx_tcp_socket_connect_ip.nxd_ip_version == NX_IP_VERSION_V4) in _nx_tcp_packet_send_syn()
108 …src_addr.nxd_ip_address.v4 = socket_ptr -> nx_tcp_socket_connect_interface -> nx_interface_ip_addr… in _nx_tcp_packet_send_syn()
113 if (socket_ptr -> nx_tcp_socket_connect_ip.nxd_ip_version == NX_IP_VERSION_V6) in _nx_tcp_packet_send_syn()
117 …COPY_IPV6_ADDRESS(socket_ptr -> nx_tcp_socket_ipv6_addr -> nxd_ipv6_address, src_addr.nxd_ip_addre… in _nx_tcp_packet_send_syn()
122 …if (socket_ptr -> nx_tcp_socket_ip_ptr -> nx_ip_packet_egress_sa_lookup != NX_NULL) … in _nx_tcp_packet_send_syn()
126 …ret = socket_ptr -> nx_tcp_socket_ip_ptr -> nx_ip_packet_egress_sa_lookup(socket_ptr -> nx_tcp_soc… in _nx_tcp_packet_send_syn()
128 … &socket_ptr -> nx_tcp_socket_connect_ip, /* dest_addr */ in _nx_tcp_packet_send_syn()
130 … socket_ptr -> nx_tcp_socket_port, /* src_port */ in _nx_tcp_packet_send_syn()
131 … socket_ptr -> nx_tcp_socket_connect_port, /* dest_port */ in _nx_tcp_packet_send_syn()
[all …]
|
| D | nx_tcp_socket_packet_process.c | 103 VOID _nx_tcp_socket_packet_process(NX_TCP_SOCKET *socket_ptr, NX_PACKET *packet_ptr) in _nx_tcp_socket_packet_process() argument
108 VOID (*urgent_callback)(NX_TCP_SOCKET *socket_ptr); in _nx_tcp_socket_packet_process()
119 tcpip_offload = socket_ptr -> nx_tcp_socket_connect_interface -> nx_interface_capability_flag & in _nx_tcp_socket_packet_process()
136 if ((socket_ptr -> nx_tcp_socket_state >= NX_TCP_SYN_RECEIVED) in _nx_tcp_socket_packet_process()
152 rx_sequence = socket_ptr -> nx_tcp_socket_rx_sequence; in _nx_tcp_socket_packet_process()
155 if ((socket_ptr -> nx_tcp_socket_rx_window_current == 0) && in _nx_tcp_socket_packet_process()
156 (socket_ptr -> nx_tcp_socket_receive_queue_head == NX_NULL) && in _nx_tcp_socket_packet_process()
163 … socket_ptr -> nx_tcp_socket_rx_window_current = socket_ptr -> nx_tcp_socket_rx_window_default; in _nx_tcp_socket_packet_process()
168 rx_window = socket_ptr -> nx_tcp_socket_rx_window_current; in _nx_tcp_socket_packet_process()
222 _nx_tcp_packet_send_ack(socket_ptr, socket_ptr -> nx_tcp_socket_tx_sequence); in _nx_tcp_socket_packet_process()
[all …]
|
| D | nx_tcp_socket_send_internal.c | 84 static UINT _nx_tcp_socket_driver_send(NX_TCP_SOCKET *socket_ptr, NX_PACKET *packet_ptr, ULONG wait… in _nx_tcp_socket_driver_send() argument
88 NX_INTERFACE *interface_ptr = socket_ptr -> nx_tcp_socket_connect_interface; in _nx_tcp_socket_driver_send()
96 ip_ptr = socket_ptr -> nx_tcp_socket_ip_ptr; in _nx_tcp_socket_driver_send()
115 …header_ptr -> nx_tcp_header_word_0 = (((ULONG)(socket_ptr -> nx_tcp_socket_port)) << NX_SHIFT_BY_1… in _nx_tcp_socket_driver_send()
116 (ULONG)socket_ptr -> nx_tcp_socket_connect_port; in _nx_tcp_socket_driver_send()
128 if (socket_ptr -> nx_tcp_socket_connect_ip.nxd_ip_version == NX_IP_VERSION_V4) in _nx_tcp_socket_driver_send()
131 … socket_ptr -> nx_tcp_socket_connect_interface -> nx_interface_ip_address, in _nx_tcp_socket_driver_send()
132 socket_ptr -> nx_tcp_socket_connect_ip.nxd_ip_address.v4, in _nx_tcp_socket_driver_send()
133 socket_ptr -> nx_tcp_socket_type_of_service, in _nx_tcp_socket_driver_send()
134 socket_ptr -> nx_tcp_socket_time_to_live, in _nx_tcp_socket_driver_send()
[all …]
|
| D | nx_tcp_socket_receive.c | 81 UINT _nx_tcp_socket_receive(NX_TCP_SOCKET *socket_ptr, NX_PACKET **packet_ptr, ULONG wait_option) in _nx_tcp_socket_receive() argument
95 ip_ptr = socket_ptr -> nx_tcp_socket_ip_ptr; in _nx_tcp_socket_receive()
101 …NX_TRACE_IN_LINE_INSERT(NX_TRACE_TCP_SOCKET_RECEIVE, socket_ptr, 0, 0, 0, NX_TRACE_TCP_EVENTS, &tr… in _nx_tcp_socket_receive()
107 if (!socket_ptr -> nx_tcp_socket_bound_next) in _nx_tcp_socket_receive()
118 if (!socket_ptr -> nx_tcp_socket_receive_queue_head) in _nx_tcp_socket_receive()
125 if ((socket_ptr -> nx_tcp_socket_state < NX_TCP_SYN_SENT) || in _nx_tcp_socket_receive()
126 (socket_ptr -> nx_tcp_socket_state == NX_TCP_CLOSE_WAIT) || in _nx_tcp_socket_receive()
127 (socket_ptr -> nx_tcp_socket_state >= NX_TCP_CLOSING)) in _nx_tcp_socket_receive()
142 if (socket_ptr -> nx_tcp_socket_receive_queue_head) in _nx_tcp_socket_receive()
147 head_packet_ptr = socket_ptr -> nx_tcp_socket_receive_queue_head; in _nx_tcp_socket_receive()
[all …]
|
| D | nx_tcp_socket_state_established.c | 84 VOID _nx_tcp_socket_state_established(NX_TCP_SOCKET *socket_ptr) in _nx_tcp_socket_state_established() argument
91 ip_ptr = socket_ptr -> nx_tcp_socket_ip_ptr; in _nx_tcp_socket_state_established()
95 if ((socket_ptr -> nx_tcp_socket_fin_received) && in _nx_tcp_socket_state_established()
96 (socket_ptr -> nx_tcp_socket_fin_sequence == socket_ptr -> nx_tcp_socket_rx_sequence)) in _nx_tcp_socket_state_established()
106 if (socket_ptr -> nx_tcp_socket_keepalive_enabled) in _nx_tcp_socket_state_established()
110 socket_ptr -> nx_tcp_socket_keepalive_timeout = 0; in _nx_tcp_socket_state_established()
111 socket_ptr -> nx_tcp_socket_keepalive_retries = 0; in _nx_tcp_socket_state_established()
116 …NX_TRACE_IN_LINE_INSERT(NX_TRACE_INTERNAL_TCP_STATE_CHANGE, ip_ptr, socket_ptr, socket_ptr -> nx_t… in _nx_tcp_socket_state_established()
119 socket_ptr -> nx_tcp_socket_state = NX_TCP_CLOSE_WAIT; in _nx_tcp_socket_state_established()
122 socket_ptr -> nx_tcp_socket_rx_sequence++; in _nx_tcp_socket_state_established()
[all …]
|
| D | nx_tcp_socket_state_transmit_check.c | 77 VOID _nx_tcp_socket_state_transmit_check(NX_TCP_SOCKET *socket_ptr) in _nx_tcp_socket_state_transmit_check() argument
83 if (socket_ptr -> nx_tcp_socket_transmit_suspension_list) in _nx_tcp_socket_state_transmit_check()
91 …if (socket_ptr -> nx_tcp_socket_tx_window_advertised > socket_ptr -> nx_tcp_socket_tx_window_conge… in _nx_tcp_socket_state_transmit_check()
93 tx_window_current = socket_ptr -> nx_tcp_socket_tx_window_congestion; in _nx_tcp_socket_state_transmit_check()
98 if ((socket_ptr -> nx_tcp_socket_duplicated_ack_received == 1) || in _nx_tcp_socket_state_transmit_check()
99 (socket_ptr -> nx_tcp_socket_duplicated_ack_received == 2)) in _nx_tcp_socket_state_transmit_check()
101 tx_window_current += (socket_ptr -> nx_tcp_socket_connect_mss << 1); in _nx_tcp_socket_state_transmit_check()
105 if (tx_window_current > socket_ptr -> nx_tcp_socket_tx_window_advertised) in _nx_tcp_socket_state_transmit_check()
107 tx_window_current = socket_ptr -> nx_tcp_socket_tx_window_advertised; in _nx_tcp_socket_state_transmit_check()
112 tx_window_current = socket_ptr -> nx_tcp_socket_tx_window_advertised; in _nx_tcp_socket_state_transmit_check()
[all …]
|
| D | nx_udp_socket_unbind.c | 71 static UINT _nx_udp_socket_driver_unbind(NX_UDP_SOCKET *socket_ptr) in _nx_udp_socket_driver_unbind() argument
79 ip_ptr = socket_ptr -> nx_udp_socket_ip_ptr; in _nx_udp_socket_driver_unbind()
107 socket_ptr, in _nx_udp_socket_driver_unbind()
110 socket_ptr -> nx_udp_socket_port, in _nx_udp_socket_driver_unbind()
167 UINT _nx_udp_socket_unbind(NX_UDP_SOCKET *socket_ptr) in _nx_udp_socket_unbind() argument
181 ip_ptr = socket_ptr -> nx_udp_socket_ip_ptr; in _nx_udp_socket_unbind()
184 …NX_TRACE_IN_LINE_INSERT(NX_TRACE_UDP_SOCKET_UNBIND, ip_ptr, socket_ptr, socket_ptr -> nx_udp_socke… in _nx_udp_socket_unbind()
191 if (!socket_ptr -> nx_udp_socket_bound_next) in _nx_udp_socket_unbind()
197 if (socket_ptr -> nx_udp_socket_bind_in_progress) in _nx_udp_socket_unbind()
201 _nx_udp_bind_cleanup(socket_ptr -> nx_udp_socket_bind_in_progress NX_CLEANUP_ARGUMENT); in _nx_udp_socket_unbind()
[all …]
|
| D | nx_tcp_server_socket_relisten.c | 87 UINT _nx_tcp_server_socket_relisten(NX_IP *ip_ptr, UINT port, NX_TCP_SOCKET *socket_ptr) in _nx_tcp_server_socket_relisten() argument
104 VOID (*listen_callback)(NX_TCP_SOCKET *socket_ptr, UINT port); in _nx_tcp_server_socket_relisten()
108 …N_LINE_INSERT(NX_TRACE_TCP_SERVER_SOCKET_RELISTEN, ip_ptr, port, socket_ptr, socket_ptr -> nx_tcp_… in _nx_tcp_server_socket_relisten()
114 if (socket_ptr -> nx_tcp_socket_state != NX_TCP_CLOSED) in _nx_tcp_server_socket_relisten()
126 if ((socket_ptr -> nx_tcp_socket_bound_next) || in _nx_tcp_server_socket_relisten()
127 (socket_ptr -> nx_tcp_socket_bind_in_progress)) in _nx_tcp_server_socket_relisten()
157 if (_nx_tcp_server_socket_driver_listen(ip_ptr, port, socket_ptr)) in _nx_tcp_server_socket_relisten()
176 listen_ptr -> nx_tcp_listen_socket_ptr = socket_ptr; in _nx_tcp_server_socket_relisten()
179 socket_ptr -> nx_tcp_socket_client_type = NX_FALSE; in _nx_tcp_server_socket_relisten()
182 socket_ptr -> nx_tcp_socket_connect_interface = NX_NULL; in _nx_tcp_server_socket_relisten()
[all …]
|
| D | nx_tcp_socket_block_cleanup.c | 80 VOID _nx_tcp_socket_block_cleanup(NX_TCP_SOCKET *socket_ptr) in _nx_tcp_socket_block_cleanup() argument
85 socket_ptr -> nx_tcp_socket_connect_ip.nxd_ip_version = 0; in _nx_tcp_socket_block_cleanup()
88 SET_UNSPECIFIED_ADDRESS(socket_ptr -> nx_tcp_socket_connect_ip.nxd_ip_address.v6); in _nx_tcp_socket_block_cleanup()
90 socket_ptr -> nx_tcp_socket_connect_ip.nxd_ip_address.v4 = 0; in _nx_tcp_socket_block_cleanup()
94 socket_ptr -> nx_tcp_socket_connect_port = 0; in _nx_tcp_socket_block_cleanup()
97 socket_ptr -> nx_tcp_socket_zero_window_probe_has_data = NX_FALSE; in _nx_tcp_socket_block_cleanup()
100 socket_ptr -> nx_tcp_socket_timeout = 0; in _nx_tcp_socket_block_cleanup()
103 socket_ptr -> nx_tcp_socket_duplicated_ack_received = 0; in _nx_tcp_socket_block_cleanup()
106 socket_ptr -> nx_tcp_socket_fast_recovery = NX_FALSE; in _nx_tcp_socket_block_cleanup()
109 if (socket_ptr -> nx_tcp_socket_client_type) in _nx_tcp_socket_block_cleanup()
[all …]
|
| D | nx_tcp_socket_driver_establish.c | 78 UINT _nx_tcp_socket_driver_establish(NX_TCP_SOCKET *socket_ptr, NX_INTERFACE *interface_ptr, UINT r… in _nx_tcp_socket_driver_establish() argument
88 ip_ptr = socket_ptr -> nx_tcp_socket_ip_ptr; in _nx_tcp_socket_driver_establish()
94 if ((socket_ptr -> nx_tcp_socket_state != NX_TCP_SYN_SENT) && in _nx_tcp_socket_driver_establish()
95 (socket_ptr -> nx_tcp_socket_state != NX_TCP_LISTEN_STATE)&& in _nx_tcp_socket_driver_establish()
96 (socket_ptr -> nx_tcp_socket_state != NX_TCP_SYN_RECEIVED)) in _nx_tcp_socket_driver_establish()
105 if (socket_ptr -> nx_tcp_socket_client_type == NX_FALSE) in _nx_tcp_socket_driver_establish()
107 if (socket_ptr -> nx_tcp_socket_bound_next) in _nx_tcp_socket_driver_establish()
117 port = socket_ptr -> nx_tcp_socket_port; in _nx_tcp_socket_driver_establish()
118 … status = interface_ptr -> nx_interface_tcpip_offload_handler(ip_ptr, interface_ptr, socket_ptr, in _nx_tcp_socket_driver_establish()
133 socket_ptr -> nx_tcp_socket_connect_interface = interface_ptr; in _nx_tcp_socket_driver_establish()
[all …]
|
| /NetX-Duo-v6.2.1/common/inc/ |
| D | nx_tcp.h | 241 UINT _nxd_tcp_client_socket_connect(NX_TCP_SOCKET *socket_ptr, NXD_ADDRESS *server_ip, UINT server_…
242 UINT _nxd_tcp_socket_peer_info_get(NX_TCP_SOCKET *socket_ptr, NXD_ADDRESS *peer_ip_address, ULONG *…
243 UINT _nx_tcp_client_socket_bind(NX_TCP_SOCKET *socket_ptr, UINT port, ULONG wait_option);
244 UINT _nx_tcp_client_socket_connect(NX_TCP_SOCKET *socket_ptr, ULONG server_ip, UINT server_port, UL…
245 UINT _nx_tcp_client_socket_port_get(NX_TCP_SOCKET *socket_ptr, UINT *port_ptr);
246 UINT _nx_tcp_client_socket_unbind(NX_TCP_SOCKET *socket_ptr);
255 UINT _nx_tcp_server_socket_accept(NX_TCP_SOCKET *socket_ptr, ULONG wait_option);
256 UINT _nx_tcp_server_socket_listen(NX_IP *ip_ptr, UINT port, NX_TCP_SOCKET *socket_ptr, UINT listen_…
257 … VOID (*tcp_listen_callback)(NX_TCP_SOCKET *socket_ptr, UINT port));
258 UINT _nx_tcp_server_socket_relisten(NX_IP *ip_ptr, UINT port, NX_TCP_SOCKET *socket_ptr);
[all …]
|
