Home
last modified time | relevance | path

Searched refs:thread_ptr (Results 1 – 25 of 53) sorted by relevance

123

/NetX-Duo-v6.2.1/common/src/
Dnx_tcp_deferred_cleanup_check.c83 TX_THREAD *thread_ptr; in _nx_tcp_deferred_cleanup_check() local
100 thread_ptr = socket_ptr -> nx_tcp_socket_bind_suspension_list; in _nx_tcp_deferred_cleanup_check()
108 if (thread_ptr -> tx_thread_suspend_cleanup == _nx_tcp_cleanup_deferred) in _nx_tcp_deferred_cleanup_check()
112 _nx_tcp_client_bind_cleanup(thread_ptr NX_CLEANUP_ARGUMENT); in _nx_tcp_deferred_cleanup_check()
116 thread_ptr = thread_ptr -> tx_thread_suspended_next; in _nx_tcp_deferred_cleanup_check()
121 thread_ptr = socket_ptr -> nx_tcp_socket_connect_suspended_thread; in _nx_tcp_deferred_cleanup_check()
122 if (thread_ptr) in _nx_tcp_deferred_cleanup_check()
126 if (thread_ptr -> tx_thread_suspend_cleanup == _nx_tcp_cleanup_deferred) in _nx_tcp_deferred_cleanup_check()
130 _nx_tcp_connect_cleanup(thread_ptr NX_CLEANUP_ARGUMENT); in _nx_tcp_deferred_cleanup_check()
135 thread_ptr = socket_ptr -> nx_tcp_socket_disconnect_suspended_thread; in _nx_tcp_deferred_cleanup_check()
[all …]
Dnx_tcp_socket_thread_suspend.c88 TX_THREAD *thread_ptr; in _nx_tcp_socket_thread_suspend() local
95 thread_ptr = _tx_thread_current_ptr; in _nx_tcp_socket_thread_suspend() local
102 thread_ptr -> tx_thread_suspended_next = *suspension_list_head; in _nx_tcp_socket_thread_suspend()
103thread_ptr -> tx_thread_suspended_previous = (*suspension_list_head) -> tx_thread_suspended_previ… in _nx_tcp_socket_thread_suspend()
104 …(*suspension_list_head) -> tx_thread_suspended_previous) -> tx_thread_suspended_next = thread_ptr; in _nx_tcp_socket_thread_suspend()
105 (*suspension_list_head) -> tx_thread_suspended_previous = thread_ptr; in _nx_tcp_socket_thread_suspend()
112 *suspension_list_head = thread_ptr; in _nx_tcp_socket_thread_suspend()
113 thread_ptr -> tx_thread_suspended_next = thread_ptr; in _nx_tcp_socket_thread_suspend()
114 thread_ptr -> tx_thread_suspended_previous = thread_ptr; in _nx_tcp_socket_thread_suspend()
118 thread_ptr -> tx_thread_suspend_cleanup = suspend_cleanup; in _nx_tcp_socket_thread_suspend()
[all …]
Dnx_tcp_transmit_cleanup.c81 VOID _nx_tcp_transmit_cleanup(TX_THREAD *thread_ptr NX_CLEANUP_PARAMETER) in _nx_tcp_transmit_cleanup()
95 socket_ptr = (NX_TCP_SOCKET *)thread_ptr -> tx_thread_suspend_control_block; in _nx_tcp_transmit_cleanup()
108 if (!(thread_ptr -> tx_thread_suspend_cleanup)) in _nx_tcp_transmit_cleanup()
128 thread_ptr -> tx_thread_suspend_cleanup = _nx_tcp_cleanup_deferred; in _nx_tcp_transmit_cleanup()
148 thread_ptr -> tx_thread_suspend_cleanup = TX_NULL; in _nx_tcp_transmit_cleanup()
153 if (thread_ptr == thread_ptr -> tx_thread_suspended_next) in _nx_tcp_transmit_cleanup()
167 … socket_ptr -> nx_tcp_socket_transmit_suspension_list = thread_ptr -> tx_thread_suspended_next; in _nx_tcp_transmit_cleanup()
170 (thread_ptr -> tx_thread_suspended_next) -> tx_thread_suspended_previous = in _nx_tcp_transmit_cleanup()
171 thread_ptr -> tx_thread_suspended_previous; in _nx_tcp_transmit_cleanup()
172 (thread_ptr -> tx_thread_suspended_previous) -> tx_thread_suspended_next = in _nx_tcp_transmit_cleanup()
[all …]
Dnx_ip_raw_packet_receive.c82 TX_THREAD *thread_ptr; /* Working thread pointer */ in _nx_ip_raw_packet_receive() local
137 thread_ptr = _tx_thread_current_ptr; in _nx_ip_raw_packet_receive()
140 thread_ptr -> tx_thread_suspend_cleanup = _nx_ip_raw_packet_cleanup; in _nx_ip_raw_packet_receive()
144 thread_ptr -> tx_thread_suspend_control_block = (void *)ip_ptr; in _nx_ip_raw_packet_receive()
147 thread_ptr -> tx_thread_additional_suspend_info = (void *)packet_ptr; in _nx_ip_raw_packet_receive()
154 thread_ptr -> tx_thread_suspended_next = in _nx_ip_raw_packet_receive()
156 thread_ptr -> tx_thread_suspended_previous = in _nx_ip_raw_packet_receive()
158 …_packet_suspension_list) -> tx_thread_suspended_previous) -> tx_thread_suspended_next = thread_ptr; in _nx_ip_raw_packet_receive()
159 … (ip_ptr -> nx_ip_raw_packet_suspension_list) -> tx_thread_suspended_previous = thread_ptr; in _nx_ip_raw_packet_receive()
166 ip_ptr -> nx_ip_raw_packet_suspension_list = thread_ptr; in _nx_ip_raw_packet_receive()
[all …]
Dnx_packet_pool_cleanup.c75 VOID _nx_packet_pool_cleanup(TX_THREAD *thread_ptr NX_CLEANUP_PARAMETER) in _nx_packet_pool_cleanup()
85 pool_ptr = (NX_PACKET_POOL *)thread_ptr -> tx_thread_suspend_control_block; in _nx_packet_pool_cleanup()
91 if ((thread_ptr -> tx_thread_suspend_cleanup) && (pool_ptr) && in _nx_packet_pool_cleanup()
98 thread_ptr -> tx_thread_suspend_cleanup = TX_NULL; in _nx_packet_pool_cleanup()
103 if (thread_ptr == thread_ptr -> tx_thread_suspended_next) in _nx_packet_pool_cleanup()
117 if (pool_ptr -> nx_packet_pool_suspension_list == thread_ptr) in _nx_packet_pool_cleanup()
119 … pool_ptr -> nx_packet_pool_suspension_list = thread_ptr -> tx_thread_suspended_next; in _nx_packet_pool_cleanup()
123 (thread_ptr -> tx_thread_suspended_next) -> tx_thread_suspended_previous = in _nx_packet_pool_cleanup()
124 thread_ptr -> tx_thread_suspended_previous; in _nx_packet_pool_cleanup()
125 (thread_ptr -> tx_thread_suspended_previous) -> tx_thread_suspended_next = in _nx_packet_pool_cleanup()
[all …]
Dnx_icmp_cleanup.c77 VOID _nx_icmp_cleanup(TX_THREAD *thread_ptr NX_CLEANUP_PARAMETER) in _nx_icmp_cleanup()
87 ip_ptr = (NX_IP *)thread_ptr -> tx_thread_suspend_control_block; in _nx_icmp_cleanup()
93 if ((thread_ptr -> tx_thread_suspend_cleanup) && (ip_ptr) && in _nx_icmp_cleanup()
100 thread_ptr -> tx_thread_suspend_cleanup = TX_NULL; in _nx_icmp_cleanup()
105 if (thread_ptr == thread_ptr -> tx_thread_suspended_next) in _nx_icmp_cleanup()
119 if (ip_ptr -> nx_ip_icmp_ping_suspension_list == thread_ptr) in _nx_icmp_cleanup()
121 ip_ptr -> nx_ip_icmp_ping_suspension_list = thread_ptr -> tx_thread_suspended_next; in _nx_icmp_cleanup()
125 (thread_ptr -> tx_thread_suspended_next) -> tx_thread_suspended_previous = in _nx_icmp_cleanup()
126 thread_ptr -> tx_thread_suspended_previous; in _nx_icmp_cleanup()
127 (thread_ptr -> tx_thread_suspended_previous) -> tx_thread_suspended_next = in _nx_icmp_cleanup()
[all …]
Dnx_tcp_receive_cleanup.c81 VOID _nx_tcp_receive_cleanup(TX_THREAD *thread_ptr NX_CLEANUP_PARAMETER) in _nx_tcp_receive_cleanup()
95 socket_ptr = (NX_TCP_SOCKET *)thread_ptr -> tx_thread_suspend_control_block; in _nx_tcp_receive_cleanup()
108 if (!(thread_ptr -> tx_thread_suspend_cleanup)) in _nx_tcp_receive_cleanup()
128 thread_ptr -> tx_thread_suspend_cleanup = _nx_tcp_cleanup_deferred; in _nx_tcp_receive_cleanup()
148 thread_ptr -> tx_thread_suspend_cleanup = TX_NULL; in _nx_tcp_receive_cleanup()
153 if (thread_ptr == thread_ptr -> tx_thread_suspended_next) in _nx_tcp_receive_cleanup()
167 … socket_ptr -> nx_tcp_socket_receive_suspension_list = thread_ptr -> tx_thread_suspended_next; in _nx_tcp_receive_cleanup()
170 (thread_ptr -> tx_thread_suspended_next) -> tx_thread_suspended_previous = in _nx_tcp_receive_cleanup()
171 thread_ptr -> tx_thread_suspended_previous; in _nx_tcp_receive_cleanup()
172 (thread_ptr -> tx_thread_suspended_previous) -> tx_thread_suspended_next = in _nx_tcp_receive_cleanup()
[all …]
Dnx_ip_raw_packet_cleanup.c77 VOID _nx_ip_raw_packet_cleanup(TX_THREAD *thread_ptr NX_CLEANUP_PARAMETER) in _nx_ip_raw_packet_cleanup()
87 ip_ptr = (NX_IP *)thread_ptr -> tx_thread_suspend_control_block; in _nx_ip_raw_packet_cleanup()
93 if ((thread_ptr -> tx_thread_suspend_cleanup) && (ip_ptr) && in _nx_ip_raw_packet_cleanup()
100 thread_ptr -> tx_thread_suspend_cleanup = TX_NULL; in _nx_ip_raw_packet_cleanup()
105 if (thread_ptr == thread_ptr -> tx_thread_suspended_next) in _nx_ip_raw_packet_cleanup()
119 ip_ptr -> nx_ip_raw_packet_suspension_list = thread_ptr -> tx_thread_suspended_next; in _nx_ip_raw_packet_cleanup()
122 (thread_ptr -> tx_thread_suspended_next) -> tx_thread_suspended_previous = in _nx_ip_raw_packet_cleanup()
123 thread_ptr -> tx_thread_suspended_previous; in _nx_ip_raw_packet_cleanup()
124 (thread_ptr -> tx_thread_suspended_previous) -> tx_thread_suspended_next = in _nx_ip_raw_packet_cleanup()
125 thread_ptr -> tx_thread_suspended_next; in _nx_ip_raw_packet_cleanup()
[all …]
Dnx_udp_receive_cleanup.c75 VOID _nx_udp_receive_cleanup(TX_THREAD *thread_ptr NX_CLEANUP_PARAMETER) in _nx_udp_receive_cleanup()
85 socket_ptr = (NX_UDP_SOCKET *)thread_ptr -> tx_thread_suspend_control_block; in _nx_udp_receive_cleanup()
91 if ((thread_ptr -> tx_thread_suspend_cleanup) && (socket_ptr) && in _nx_udp_receive_cleanup()
98 thread_ptr -> tx_thread_suspend_cleanup = TX_NULL; in _nx_udp_receive_cleanup()
103 if (thread_ptr == thread_ptr -> tx_thread_suspended_next) in _nx_udp_receive_cleanup()
117 … socket_ptr -> nx_udp_socket_receive_suspension_list = thread_ptr -> tx_thread_suspended_next; in _nx_udp_receive_cleanup()
120 (thread_ptr -> tx_thread_suspended_next) -> tx_thread_suspended_previous = in _nx_udp_receive_cleanup()
121 thread_ptr -> tx_thread_suspended_previous; in _nx_udp_receive_cleanup()
122 (thread_ptr -> tx_thread_suspended_previous) -> tx_thread_suspended_next = in _nx_udp_receive_cleanup()
123 thread_ptr -> tx_thread_suspended_next; in _nx_udp_receive_cleanup()
[all …]
Dnx_tcp_socket_thread_resume.c91 TX_THREAD *thread_ptr; in _nx_tcp_socket_thread_resume() local
98 thread_ptr = *suspension_list_head; in _nx_tcp_socket_thread_resume() local
101 if (thread_ptr) in _nx_tcp_socket_thread_resume()
105 if (thread_ptr == thread_ptr -> tx_thread_suspended_next) in _nx_tcp_socket_thread_resume()
118 *suspension_list_head = thread_ptr -> tx_thread_suspended_next; in _nx_tcp_socket_thread_resume()
121 (thread_ptr -> tx_thread_suspended_next) -> tx_thread_suspended_previous = in _nx_tcp_socket_thread_resume()
122 thread_ptr -> tx_thread_suspended_previous; in _nx_tcp_socket_thread_resume()
123 (thread_ptr -> tx_thread_suspended_previous) -> tx_thread_suspended_next = in _nx_tcp_socket_thread_resume()
124 thread_ptr -> tx_thread_suspended_next; in _nx_tcp_socket_thread_resume()
130 thread_ptr -> tx_thread_suspend_cleanup = TX_NULL; in _nx_tcp_socket_thread_resume()
[all …]
Dnx_icmpv4_process_echo_reply.c86 TX_THREAD *thread_ptr; in _nx_icmpv4_process_echo_reply() local
116 thread_ptr = ip_ptr -> nx_ip_icmp_ping_suspension_list; in _nx_icmpv4_process_echo_reply() local
131 if ((USHORT)(thread_ptr -> tx_thread_suspend_info) == sequence_num) in _nx_icmpv4_process_echo_reply()
138 if (thread_ptr == thread_ptr -> tx_thread_suspended_next) in _nx_icmpv4_process_echo_reply()
152 if (ip_ptr -> nx_ip_icmp_ping_suspension_list == thread_ptr) in _nx_icmpv4_process_echo_reply()
154 … ip_ptr -> nx_ip_icmp_ping_suspension_list = thread_ptr -> tx_thread_suspended_next; in _nx_icmpv4_process_echo_reply()
158 (thread_ptr -> tx_thread_suspended_next) -> tx_thread_suspended_previous = in _nx_icmpv4_process_echo_reply()
159 thread_ptr -> tx_thread_suspended_previous; in _nx_icmpv4_process_echo_reply()
160 (thread_ptr -> tx_thread_suspended_previous) -> tx_thread_suspended_next = in _nx_icmpv4_process_echo_reply()
161 thread_ptr -> tx_thread_suspended_next; in _nx_icmpv4_process_echo_reply()
[all …]
Dnx_udp_bind_cleanup.c76 VOID _nx_udp_bind_cleanup(TX_THREAD *thread_ptr NX_CLEANUP_PARAMETER) in _nx_udp_bind_cleanup()
87 socket_ptr = (NX_UDP_SOCKET *)thread_ptr -> tx_thread_suspend_control_block; in _nx_udp_bind_cleanup()
93 if ((thread_ptr -> tx_thread_suspend_cleanup) && (socket_ptr) && in _nx_udp_bind_cleanup()
103 thread_ptr -> tx_thread_suspend_cleanup = TX_NULL; in _nx_udp_bind_cleanup()
112 if (thread_ptr == thread_ptr -> tx_thread_suspended_next) in _nx_udp_bind_cleanup()
126 … owning_socket_ptr -> nx_udp_socket_bind_suspension_list = thread_ptr -> tx_thread_suspended_next; in _nx_udp_bind_cleanup()
129 (thread_ptr -> tx_thread_suspended_next) -> tx_thread_suspended_previous = in _nx_udp_bind_cleanup()
130 thread_ptr -> tx_thread_suspended_previous; in _nx_udp_bind_cleanup()
131 (thread_ptr -> tx_thread_suspended_previous) -> tx_thread_suspended_next = in _nx_udp_bind_cleanup()
132 thread_ptr -> tx_thread_suspended_next; in _nx_udp_bind_cleanup()
[all …]
Dnx_tcp_client_bind_cleanup.c80 VOID _nx_tcp_client_bind_cleanup(TX_THREAD *thread_ptr NX_CLEANUP_PARAMETER) in _nx_tcp_client_bind_cleanup()
95 socket_ptr = (NX_TCP_SOCKET *)thread_ptr -> tx_thread_suspend_control_block; in _nx_tcp_client_bind_cleanup()
108 if (!(thread_ptr -> tx_thread_suspend_cleanup)) in _nx_tcp_client_bind_cleanup()
128 thread_ptr -> tx_thread_suspend_cleanup = _nx_tcp_cleanup_deferred; in _nx_tcp_client_bind_cleanup()
151 thread_ptr -> tx_thread_suspend_cleanup = TX_NULL; in _nx_tcp_client_bind_cleanup()
160 if (thread_ptr == thread_ptr -> tx_thread_suspended_next) in _nx_tcp_client_bind_cleanup()
174 … owning_socket_ptr -> nx_tcp_socket_bind_suspension_list = thread_ptr -> tx_thread_suspended_next; in _nx_tcp_client_bind_cleanup()
177 (thread_ptr -> tx_thread_suspended_next) -> tx_thread_suspended_previous = in _nx_tcp_client_bind_cleanup()
178 thread_ptr -> tx_thread_suspended_previous; in _nx_tcp_client_bind_cleanup()
179 (thread_ptr -> tx_thread_suspended_previous) -> tx_thread_suspended_next = in _nx_tcp_client_bind_cleanup()
[all …]
Dnx_packet_allocate.c85 TX_THREAD *thread_ptr; /* Working thread pointer */ in _nx_packet_allocate() local
200 thread_ptr = _tx_thread_current_ptr; in _nx_packet_allocate()
203 thread_ptr -> tx_thread_suspend_cleanup = _nx_packet_pool_cleanup; in _nx_packet_allocate()
207 thread_ptr -> tx_thread_suspend_control_block = (void *)pool_ptr; in _nx_packet_allocate()
210 thread_ptr -> tx_thread_additional_suspend_info = (void *)packet_ptr; in _nx_packet_allocate()
214 thread_ptr -> tx_thread_suspend_info = packet_type; in _nx_packet_allocate()
221 thread_ptr -> tx_thread_suspended_next = in _nx_packet_allocate()
223 thread_ptr -> tx_thread_suspended_previous = in _nx_packet_allocate()
226 thread_ptr; in _nx_packet_allocate()
227 … (pool_ptr -> nx_packet_pool_suspension_list) -> tx_thread_suspended_previous = thread_ptr; in _nx_packet_allocate()
[all …]
Dnx_icmpv6_process_echo_reply.c93 TX_THREAD *thread_ptr; in _nx_icmpv6_process_echo_reply() local
173 thread_ptr = ip_ptr -> nx_ip_icmp_ping_suspension_list; in _nx_icmpv6_process_echo_reply() local
188 if (thread_ptr -> tx_thread_suspend_info == sequence_num) in _nx_icmpv6_process_echo_reply()
195 if (thread_ptr == thread_ptr -> tx_thread_suspended_next) in _nx_icmpv6_process_echo_reply()
209 if (ip_ptr -> nx_ip_icmp_ping_suspension_list == thread_ptr) in _nx_icmpv6_process_echo_reply()
211 … ip_ptr -> nx_ip_icmp_ping_suspension_list = thread_ptr -> tx_thread_suspended_next; in _nx_icmpv6_process_echo_reply()
215 (thread_ptr -> tx_thread_suspended_next) -> tx_thread_suspended_previous = in _nx_icmpv6_process_echo_reply()
216 thread_ptr -> tx_thread_suspended_previous; in _nx_icmpv6_process_echo_reply()
217 (thread_ptr -> tx_thread_suspended_previous) -> tx_thread_suspended_next = in _nx_icmpv6_process_echo_reply()
218 thread_ptr -> tx_thread_suspended_next; in _nx_icmpv6_process_echo_reply()
[all …]
Dnx_ip_raw_packet_processing.c82 TX_THREAD *thread_ptr; in _nx_ip_raw_packet_processing() local
109 thread_ptr = ip_ptr -> nx_ip_raw_packet_suspension_list; in _nx_ip_raw_packet_processing() local
110 if (thread_ptr) in _nx_ip_raw_packet_processing()
116 if (thread_ptr == thread_ptr -> tx_thread_suspended_next) in _nx_ip_raw_packet_processing()
130 ip_ptr -> nx_ip_raw_packet_suspension_list = thread_ptr -> tx_thread_suspended_next; in _nx_ip_raw_packet_processing()
133 (thread_ptr -> tx_thread_suspended_next) -> tx_thread_suspended_previous = in _nx_ip_raw_packet_processing()
134 thread_ptr -> tx_thread_suspended_previous; in _nx_ip_raw_packet_processing()
135 (thread_ptr -> tx_thread_suspended_previous) -> tx_thread_suspended_next = in _nx_ip_raw_packet_processing()
136 thread_ptr -> tx_thread_suspended_next; in _nx_ip_raw_packet_processing()
145 thread_ptr -> tx_thread_suspend_cleanup = TX_NULL; in _nx_ip_raw_packet_processing()
[all …]
Dnx_packet_release.c78 TX_THREAD *thread_ptr; /* Working thread pointer */ in _nx_packet_release() local
132 thread_ptr = pool_ptr -> nx_packet_pool_suspension_list; in _nx_packet_release()
133 if (thread_ptr) in _nx_packet_release()
139 if (thread_ptr == thread_ptr -> tx_thread_suspended_next) in _nx_packet_release()
153 … pool_ptr -> nx_packet_pool_suspension_list = thread_ptr -> tx_thread_suspended_next; in _nx_packet_release()
156 (thread_ptr -> tx_thread_suspended_next) -> tx_thread_suspended_previous = in _nx_packet_release()
157 thread_ptr -> tx_thread_suspended_previous; in _nx_packet_release()
158 (thread_ptr -> tx_thread_suspended_previous) -> tx_thread_suspended_next = in _nx_packet_release()
159 thread_ptr -> tx_thread_suspended_next; in _nx_packet_release()
168 thread_ptr -> tx_thread_suspend_cleanup = TX_NULL; in _nx_packet_release()
[all …]
Dnx_icmp_interface_ping.c112 TX_THREAD *thread_ptr; in _nx_icmp_interface_ping() local
295 thread_ptr = _tx_thread_current_ptr; in _nx_icmp_interface_ping()
304 thread_ptr -> tx_thread_suspend_cleanup = _nx_icmp_cleanup; in _nx_icmp_interface_ping()
306 thread_ptr -> tx_thread_suspend_status = NX_NO_RESPONSE; in _nx_icmp_interface_ping()
310 thread_ptr -> tx_thread_suspend_control_block = (void *)ip_ptr; in _nx_icmp_interface_ping()
313 thread_ptr -> tx_thread_additional_suspend_info = (void *)response_ptr; in _nx_icmp_interface_ping()
317 thread_ptr -> tx_thread_suspend_info = sequence; in _nx_icmp_interface_ping()
324 thread_ptr -> tx_thread_suspended_next = in _nx_icmp_interface_ping()
326 thread_ptr -> tx_thread_suspended_previous = in _nx_icmp_interface_ping()
329 thread_ptr; in _nx_icmp_interface_ping()
[all …]
Dnx_icmp_interface_ping6.c116 TX_THREAD *thread_ptr; in _nx_icmp_interface_ping6() local
310 thread_ptr = _tx_thread_current_ptr; in _nx_icmp_interface_ping6()
319 thread_ptr -> tx_thread_suspend_cleanup = _nx_icmp_cleanup; in _nx_icmp_interface_ping6()
321 thread_ptr -> tx_thread_suspend_status = NX_NO_RESPONSE; in _nx_icmp_interface_ping6()
325 thread_ptr -> tx_thread_suspend_control_block = (void *)ip_ptr; in _nx_icmp_interface_ping6()
328 thread_ptr -> tx_thread_additional_suspend_info = (void *)response_ptr; in _nx_icmp_interface_ping6()
332 thread_ptr -> tx_thread_suspend_info = sequence; in _nx_icmp_interface_ping6()
339 thread_ptr -> tx_thread_suspended_next = in _nx_icmp_interface_ping6()
342 thread_ptr -> tx_thread_suspended_previous = in _nx_icmp_interface_ping6()
346 thread_ptr; in _nx_icmp_interface_ping6()
[all …]
Dnx_udp_socket_receive.c95 TX_THREAD *thread_ptr; in _nx_udp_socket_receive() local
162 thread_ptr = _tx_thread_current_ptr; in _nx_udp_socket_receive()
165 thread_ptr -> tx_thread_suspend_cleanup = _nx_udp_receive_cleanup; in _nx_udp_socket_receive()
169 thread_ptr -> tx_thread_suspend_control_block = (void *)socket_ptr; in _nx_udp_socket_receive()
172 thread_ptr -> tx_thread_additional_suspend_info = (void *)packet_ptr; in _nx_udp_socket_receive()
179 thread_ptr -> tx_thread_suspended_next = in _nx_udp_socket_receive()
181 thread_ptr -> tx_thread_suspended_previous = in _nx_udp_socket_receive()
184 thread_ptr; in _nx_udp_socket_receive()
185 …ocket_ptr -> nx_udp_socket_receive_suspension_list) -> tx_thread_suspended_previous = thread_ptr; in _nx_udp_socket_receive()
192 socket_ptr -> nx_udp_socket_receive_suspension_list = thread_ptr; in _nx_udp_socket_receive()
[all …]
Dnx_udp_socket_unbind.c174 TX_THREAD *thread_ptr; in _nx_udp_socket_unbind() local
308 thread_ptr = socket_ptr -> nx_udp_socket_receive_suspension_list; in _nx_udp_socket_unbind()
323 thread_ptr -> tx_thread_suspend_cleanup = TX_NULL; in _nx_udp_socket_unbind()
332 thread_ptr -> tx_thread_suspend_status = NX_SOCKET_UNBOUND; in _nx_udp_socket_unbind()
335 thread_ptr = thread_ptr -> tx_thread_suspended_next; in _nx_udp_socket_unbind()
338 _tx_thread_system_resume(thread_ptr -> tx_thread_suspended_previous); in _nx_udp_socket_unbind()
350 thread_ptr = socket_ptr -> nx_udp_socket_bind_suspension_list; in _nx_udp_socket_unbind() local
351 if (thread_ptr) in _nx_udp_socket_unbind()
357 if (thread_ptr == thread_ptr -> tx_thread_suspended_next) in _nx_udp_socket_unbind()
371 … socket_ptr -> nx_udp_socket_bind_suspension_list = thread_ptr -> tx_thread_suspended_next; in _nx_udp_socket_unbind()
[all …]
Dnx_udp_socket_bind.c199 TX_THREAD *thread_ptr; in _nx_udp_socket_bind() local
346 thread_ptr = _tx_thread_current_ptr; in _nx_udp_socket_bind() local
349 thread_ptr -> tx_thread_suspend_cleanup = _nx_udp_bind_cleanup; in _nx_udp_socket_bind()
353 thread_ptr -> tx_thread_suspend_control_block = (void *)socket_ptr; in _nx_udp_socket_bind()
360 socket_ptr -> nx_udp_socket_bind_in_progress = thread_ptr; in _nx_udp_socket_bind()
367thread_ptr -> tx_thread_suspended_next = search_ptr -> nx_udp_socket_bind_suspension_list; in _nx_udp_socket_bind()
368thread_ptr -> tx_thread_suspended_previous = (search_ptr -> nx_udp_socket_bind_suspension_list) -… in _nx_udp_socket_bind()
369 …t_bind_suspension_list) -> tx_thread_suspended_previous) -> tx_thread_suspended_next = thread_ptr; in _nx_udp_socket_bind()
370 … (search_ptr -> nx_udp_socket_bind_suspension_list) -> tx_thread_suspended_previous = thread_ptr; in _nx_udp_socket_bind()
377 search_ptr -> nx_udp_socket_bind_suspension_list = thread_ptr; in _nx_udp_socket_bind()
[all …]
Dnx_tcp_disconnect_cleanup.c81 VOID _nx_tcp_disconnect_cleanup(TX_THREAD *thread_ptr NX_CLEANUP_PARAMETER) in _nx_tcp_disconnect_cleanup()
95 socket_ptr = (NX_TCP_SOCKET *)thread_ptr -> tx_thread_suspend_control_block; in _nx_tcp_disconnect_cleanup()
108 if (!(thread_ptr -> tx_thread_suspend_cleanup)) in _nx_tcp_disconnect_cleanup()
128 thread_ptr -> tx_thread_suspend_cleanup = _nx_tcp_cleanup_deferred; in _nx_tcp_disconnect_cleanup()
148 thread_ptr -> tx_thread_suspend_cleanup = TX_NULL; in _nx_tcp_disconnect_cleanup()
155 if (thread_ptr -> tx_thread_state == TX_TCP_IP) in _nx_tcp_disconnect_cleanup()
162 thread_ptr -> tx_thread_suspend_status = NX_DISCONNECT_FAILED; in _nx_tcp_disconnect_cleanup()
173 _tx_thread_system_resume(thread_ptr); in _nx_tcp_disconnect_cleanup()
Dnx_tcp_connect_cleanup.c81 VOID _nx_tcp_connect_cleanup(TX_THREAD *thread_ptr NX_CLEANUP_PARAMETER) in _nx_tcp_connect_cleanup()
95 socket_ptr = (NX_TCP_SOCKET *)thread_ptr -> tx_thread_suspend_control_block; in _nx_tcp_connect_cleanup()
108 if (!(thread_ptr -> tx_thread_suspend_cleanup)) in _nx_tcp_connect_cleanup()
131 thread_ptr -> tx_thread_suspend_cleanup = _nx_tcp_cleanup_deferred; in _nx_tcp_connect_cleanup()
148 thread_ptr -> tx_thread_suspend_cleanup = TX_NULL; in _nx_tcp_connect_cleanup()
181 if (thread_ptr -> tx_thread_state == TX_TCP_IP) in _nx_tcp_connect_cleanup()
188 thread_ptr -> tx_thread_suspend_status = NX_NOT_CONNECTED; in _nx_tcp_connect_cleanup()
199 _tx_thread_system_resume(thread_ptr); in _nx_tcp_connect_cleanup()
/NetX-Duo-v6.2.1/test/cmake/netxduo64/
Dnx_user.h55 TX_THREAD *thread_ptr; \
56 thread_ptr = (TX_THREAD *) (a); \
57 … (thread_ptr -> tx_thread_extension_ptr) = (VOID *)(b); \
61 TX_THREAD *thread_ptr; \
62 thread_ptr = tx_thread_identify(); \
65 … if (thread_ptr -> tx_thread_extension_ptr) \
67 … (a) = (b *)(thread_ptr -> tx_thread_extension_ptr); \

123