22 static bool rxrpc_set_conn_aborted(struct rxrpc_connection *conn, struct sk_buff *skb,  in rxrpc_set_conn_aborted()  argument
28 	if (conn->state != RXRPC_CONN_ABORTED) {  in rxrpc_set_conn_aborted()
29 		spin_lock_irq(&conn->state_lock);  in rxrpc_set_conn_aborted()
30 		if (conn->state != RXRPC_CONN_ABORTED) {  in rxrpc_set_conn_aborted()
31 			conn->abort_code = abort_code;  in rxrpc_set_conn_aborted()
32 			conn->error	 = err;  in rxrpc_set_conn_aborted()
33 			conn->completion = compl;  in rxrpc_set_conn_aborted()
35 			smp_store_release(&conn->state, RXRPC_CONN_ABORTED);  in rxrpc_set_conn_aborted()
36 			set_bit(RXRPC_CONN_DONT_REUSE, &conn->flags);  in rxrpc_set_conn_aborted()
37 			set_bit(RXRPC_CONN_EV_ABORT_CALLS, &conn->events);  in rxrpc_set_conn_aborted()
40 		spin_unlock_irq(&conn->state_lock);  in rxrpc_set_conn_aborted()
49 int rxrpc_abort_conn(struct rxrpc_connection *conn, struct sk_buff *skb,  in rxrpc_abort_conn()  argument
54 	if (rxrpc_set_conn_aborted(conn, skb, abort_code, err,  in rxrpc_abort_conn()
58 		rxrpc_poke_conn(conn, rxrpc_conn_get_poke_abort);  in rxrpc_abort_conn()
66 static void rxrpc_input_conn_abort(struct rxrpc_connection *conn,  in rxrpc_input_conn_abort()  argument
69 	trace_rxrpc_rx_conn_abort(conn, skb);  in rxrpc_input_conn_abort()
70 	rxrpc_set_conn_aborted(conn, skb, skb->priority, -ECONNABORTED,  in rxrpc_input_conn_abort()
77 void rxrpc_conn_retransmit_call(struct rxrpc_connection *conn,  in rxrpc_conn_retransmit_call()  argument
97 	_enter("%d", conn->debug_id);  in rxrpc_conn_retransmit_call()
107 	chan = &conn->channels[channel];  in rxrpc_conn_retransmit_call()
116 	msg.msg_name	= &conn->peer->srx.transport;  in rxrpc_conn_retransmit_call()
117 	msg.msg_namelen	= conn->peer->srx.transport_len;  in rxrpc_conn_retransmit_call()
129 	serial = rxrpc_get_next_serial(conn);  in rxrpc_conn_retransmit_call()
131 	pkt.whdr.epoch		= htonl(conn->proto.epoch);  in rxrpc_conn_retransmit_call()
132 	pkt.whdr.cid		= htonl(conn->proto.cid | channel);  in rxrpc_conn_retransmit_call()
137 	pkt.whdr.flags		= conn->out_clientflag;  in rxrpc_conn_retransmit_call()
139 	pkt.whdr.securityIndex	= conn->security_ix;  in rxrpc_conn_retransmit_call()
141 	pkt.whdr.serviceId	= htons(conn->service_id);  in rxrpc_conn_retransmit_call()
153 		if_mtu = conn->peer->if_mtu - conn->peer->hdrsize;  in rxrpc_conn_retransmit_call()
154 		if (conn->peer->ackr_adv_pmtud) {  in rxrpc_conn_retransmit_call()
155 			max_mtu = umax(conn->peer->max_data, rxrpc_rx_mtu);  in rxrpc_conn_retransmit_call()
188 	ret = kernel_sendmsg(conn->local->socket, &msg, iov, ioc, len);  in rxrpc_conn_retransmit_call()
189 	conn->peer->last_tx_at = ktime_get_seconds();  in rxrpc_conn_retransmit_call()
203 static void rxrpc_abort_calls(struct rxrpc_connection *conn)  in rxrpc_abort_calls()  argument
208 	_enter("{%d},%x", conn->debug_id, conn->abort_code);  in rxrpc_abort_calls()
211 		call = conn->channels[i].call;  in rxrpc_abort_calls()
215 						  conn->completion,  in rxrpc_abort_calls()
216 						  conn->abort_code,  in rxrpc_abort_calls()
217 						  conn->error);  in rxrpc_abort_calls()
238 static int rxrpc_process_event(struct rxrpc_connection *conn,  in rxrpc_process_event()  argument
244 	if (conn->state == RXRPC_CONN_ABORTED)  in rxrpc_process_event()
247 	_enter("{%d},{%u,%%%u},", conn->debug_id, sp->hdr.type, sp->hdr.serial);  in rxrpc_process_event()
251 		return conn->security->respond_to_challenge(conn, skb);  in rxrpc_process_event()
254 		ret = conn->security->verify_response(conn, skb);  in rxrpc_process_event()
258 		ret = conn->security->init_connection_security(  in rxrpc_process_event()
259 			conn, conn->key->payload.data[0]);  in rxrpc_process_event()
263 		spin_lock_irq(&conn->state_lock);  in rxrpc_process_event()
264 		if (conn->state == RXRPC_CONN_SERVICE_CHALLENGING)  in rxrpc_process_event()
265 			conn->state = RXRPC_CONN_SERVICE;  in rxrpc_process_event()
266 		spin_unlock_irq(&conn->state_lock);  in rxrpc_process_event()
268 		if (conn->state == RXRPC_CONN_SERVICE) {  in rxrpc_process_event()
273 			sp->conn = rxrpc_get_connection(conn, rxrpc_conn_get_poke_secured);  in rxrpc_process_event()
276 			skb_queue_head(&conn->local->rx_queue, skb);  in rxrpc_process_event()
277 			rxrpc_wake_up_io_thread(conn->local);  in rxrpc_process_event()
290 static void rxrpc_secure_connection(struct rxrpc_connection *conn)  in rxrpc_secure_connection()  argument
292 	if (conn->security->issue_challenge(conn) < 0)  in rxrpc_secure_connection()
293 		rxrpc_abort_conn(conn, NULL, RX_CALL_DEAD, -ENOMEM,  in rxrpc_secure_connection()
300 void rxrpc_process_delayed_final_acks(struct rxrpc_connection *conn, bool force)  in rxrpc_process_delayed_final_acks()  argument
310 		struct rxrpc_channel *chan = &conn->channels[channel];  in rxrpc_process_delayed_final_acks()
313 		if (!test_bit(RXRPC_CONN_FINAL_ACK_0 + channel, &conn->flags))  in rxrpc_process_delayed_final_acks()
326 				       &conn->flags))  in rxrpc_process_delayed_final_acks()
327 			rxrpc_conn_retransmit_call(conn, NULL, channel);  in rxrpc_process_delayed_final_acks()
334 		rxrpc_reduce_conn_timer(conn, next_j);  in rxrpc_process_delayed_final_acks()
340 static void rxrpc_do_process_connection(struct rxrpc_connection *conn)  in rxrpc_do_process_connection()  argument
345 	if (test_and_clear_bit(RXRPC_CONN_EV_CHALLENGE, &conn->events))  in rxrpc_do_process_connection()
346 		rxrpc_secure_connection(conn);  in rxrpc_do_process_connection()
350 	while ((skb = skb_dequeue(&conn->rx_queue))) {  in rxrpc_do_process_connection()
352 		ret = rxrpc_process_event(conn, skb);  in rxrpc_do_process_connection()
356 			skb_queue_head(&conn->rx_queue, skb);  in rxrpc_do_process_connection()
357 			rxrpc_queue_conn(conn, rxrpc_conn_queue_retry_work);  in rxrpc_do_process_connection()
368 	struct rxrpc_connection *conn =  in rxrpc_process_connection()  local
371 	rxrpc_see_connection(conn, rxrpc_conn_see_work);  in rxrpc_process_connection()
373 	if (__rxrpc_use_local(conn->local, rxrpc_local_use_conn_work)) {  in rxrpc_process_connection()
374 		rxrpc_do_process_connection(conn);  in rxrpc_process_connection()
375 		rxrpc_unuse_local(conn->local, rxrpc_local_unuse_conn_work);  in rxrpc_process_connection()
384 static void rxrpc_post_packet_to_conn(struct rxrpc_connection *conn,  in rxrpc_post_packet_to_conn()  argument
387 	_enter("%p,%p", conn, skb);  in rxrpc_post_packet_to_conn()
390 	skb_queue_tail(&conn->rx_queue, skb);  in rxrpc_post_packet_to_conn()
391 	rxrpc_queue_conn(conn, rxrpc_conn_queue_rx_work);  in rxrpc_post_packet_to_conn()
397 bool rxrpc_input_conn_packet(struct rxrpc_connection *conn, struct sk_buff *skb)  in rxrpc_input_conn_packet()  argument
407 		if (rxrpc_is_conn_aborted(conn))  in rxrpc_input_conn_packet()
409 		rxrpc_input_conn_abort(conn, skb);  in rxrpc_input_conn_packet()
410 		rxrpc_abort_calls(conn);  in rxrpc_input_conn_packet()
415 		if (rxrpc_is_conn_aborted(conn)) {  in rxrpc_input_conn_packet()
416 			if (conn->completion == RXRPC_CALL_LOCALLY_ABORTED)  in rxrpc_input_conn_packet()
417 				rxrpc_send_conn_abort(conn);  in rxrpc_input_conn_packet()
420 		rxrpc_post_packet_to_conn(conn, skb);  in rxrpc_input_conn_packet()
432 void rxrpc_input_conn_event(struct rxrpc_connection *conn, struct sk_buff *skb)  in rxrpc_input_conn_event()  argument
436 	if (test_and_clear_bit(RXRPC_CONN_EV_ABORT_CALLS, &conn->events))  in rxrpc_input_conn_event()
437 		rxrpc_abort_calls(conn);  in rxrpc_input_conn_event()
442 			if (conn->state != RXRPC_CONN_SERVICE)  in rxrpc_input_conn_event()
446 				rxrpc_call_is_secure(conn->channels[loop].call);  in rxrpc_input_conn_event()
452 	if (conn->flags & RXRPC_CONN_FINAL_ACK_MASK)  in rxrpc_input_conn_event()
453 		rxrpc_process_delayed_final_acks(conn, false);  in rxrpc_input_conn_event()