Lines Matching refs:socket_ptr

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()
164 if (head_packet_ptr == socket_ptr -> nx_tcp_socket_receive_queue_tail) in _nx_tcp_socket_receive()
168 socket_ptr -> nx_tcp_socket_receive_queue_head = NX_NULL; in _nx_tcp_socket_receive()
169 socket_ptr -> nx_tcp_socket_receive_queue_tail = NX_NULL; in _nx_tcp_socket_receive()
176socket_ptr -> nx_tcp_socket_receive_queue_head = head_packet_ptr -> nx_packet_union_next.nx_packe… in _nx_tcp_socket_receive()
180 socket_ptr -> nx_tcp_socket_receive_queue_count--; in _nx_tcp_socket_receive()
204 if (socket_ptr -> nx_tcp_socket_receive_queue_count == 0) in _nx_tcp_socket_receive()
208socket_ptr -> nx_tcp_socket_rx_window_current = socket_ptr -> nx_tcp_socket_rx_window_default; in _nx_tcp_socket_receive()
214 socket_ptr -> nx_tcp_socket_rx_window_current += (*packet_ptr) -> nx_packet_length; in _nx_tcp_socket_receive()
219 …if (((socket_ptr -> nx_tcp_socket_rx_window_current - socket_ptr -> nx_tcp_socket_rx_window_last_s… in _nx_tcp_socket_receive()
220 …((socket_ptr -> nx_tcp_socket_state == NX_TCP_ESTABLISHED) || (socket_ptr -> nx_tcp_socket_state =… in _nx_tcp_socket_receive()
224 _nx_tcp_packet_send_ack(socket_ptr, socket_ptr -> nx_tcp_socket_tx_sequence); in _nx_tcp_socket_receive()
229 …TCP_SOCKET_RECEIVE, 0, *packet_ptr, (*packet_ptr) -> nx_packet_length, socket_ptr -> nx_tcp_socket… in _nx_tcp_socket_receive()
247 socket_ptr -> nx_tcp_socket_receive_suspended_count++; in _nx_tcp_socket_receive()
251 …_nx_tcp_socket_thread_suspend(&(socket_ptr -> nx_tcp_socket_receive_suspension_list), _nx_tcp_rece… in _nx_tcp_socket_receive()
257 …TCP_SOCKET_RECEIVE, 0, *packet_ptr, (*packet_ptr) -> nx_packet_length, socket_ptr -> nx_tcp_socket… in _nx_tcp_socket_receive()