32 static int nr_queue_rx_frame(struct sock *sk, struct sk_buff *skb, int more)  in nr_queue_rx_frame()  argument
35 	struct nr_sock *nr = nr_sk(sk);  in nr_queue_rx_frame()
39 	nr_start_idletimer(sk);  in nr_queue_rx_frame()
66 	return sock_queue_rcv_skb(sk, skbn);  in nr_queue_rx_frame()
74 static int nr_state1_machine(struct sock *sk, struct sk_buff *skb,  in nr_state1_machine()  argument
79 		struct nr_sock *nr = nr_sk(sk);  in nr_state1_machine()
81 		nr_stop_t1timer(sk);  in nr_state1_machine()
82 		nr_start_idletimer(sk);  in nr_state1_machine()
92 		sk->sk_state   = TCP_ESTABLISHED;  in nr_state1_machine()
93 		if (!sock_flag(sk, SOCK_DEAD))  in nr_state1_machine()
94 			sk->sk_state_change(sk);  in nr_state1_machine()
99 		nr_disconnect(sk, ECONNREFUSED);  in nr_state1_machine()
104 			nr_disconnect(sk, ECONNRESET);  in nr_state1_machine()
118 static int nr_state2_machine(struct sock *sk, struct sk_buff *skb,  in nr_state2_machine()  argument
123 		nr_disconnect(sk, ECONNRESET);  in nr_state2_machine()
127 		nr_write_internal(sk, NR_DISCACK);  in nr_state2_machine()
130 		nr_disconnect(sk, 0);  in nr_state2_machine()
135 			nr_disconnect(sk, ECONNRESET);  in nr_state2_machine()
149 static int nr_state3_machine(struct sock *sk, struct sk_buff *skb, int frametype)  in nr_state3_machine()  argument
151 	struct nr_sock *nrom = nr_sk(sk);  in nr_state3_machine()
163 		nr_write_internal(sk, NR_CONNACK);  in nr_state3_machine()
167 		nr_write_internal(sk, NR_DISCACK);  in nr_state3_machine()
168 		nr_disconnect(sk, 0);  in nr_state3_machine()
173 		nr_disconnect(sk, ECONNRESET);  in nr_state3_machine()
182 			nr_start_t4timer(sk);  in nr_state3_machine()
185 			nr_stop_t4timer(sk);  in nr_state3_machine()
187 		if (!nr_validate_nr(sk, nr)) {  in nr_state3_machine()
191 			nr_frames_acked(sk, nr);  in nr_state3_machine()
192 			nr_send_nak_frame(sk);  in nr_state3_machine()
195 				nr_frames_acked(sk, nr);  in nr_state3_machine()
197 				nr_check_iframes_acked(sk, nr);  in nr_state3_machine()
212 			nr_start_t4timer(sk);  in nr_state3_machine()
215 			nr_stop_t4timer(sk);  in nr_state3_machine()
217 		if (nr_validate_nr(sk, nr)) {  in nr_state3_machine()
219 				nr_frames_acked(sk, nr);  in nr_state3_machine()
220 				nr_send_nak_frame(sk);  in nr_state3_machine()
223 					nr_frames_acked(sk, nr);  in nr_state3_machine()
225 					nr_check_iframes_acked(sk, nr);  in nr_state3_machine()
239 					if (nr_queue_rx_frame(sk, skbn, frametype & NR_MORE_FLAG) == 0) {  in nr_state3_machine()
245 				} else if (nr_in_rx_window(sk, ns)) {  in nr_state3_machine()
259 			nr_enquiry_response(sk);  in nr_state3_machine()
263 				nr_start_t2timer(sk);  in nr_state3_machine()
270 			nr_disconnect(sk, ECONNRESET);  in nr_state3_machine()
280 int nr_process_rx_frame(struct sock *sk, struct sk_buff *skb)  in nr_process_rx_frame()  argument
282 	struct nr_sock *nr = nr_sk(sk);  in nr_process_rx_frame()
292 		queued = nr_state1_machine(sk, skb, frametype);  in nr_process_rx_frame()
295 		queued = nr_state2_machine(sk, skb, frametype);  in nr_process_rx_frame()
298 		queued = nr_state3_machine(sk, skb, frametype);  in nr_process_rx_frame()
302 	nr_kick(sk);  in nr_process_rx_frame()