22 static void rxrpc_conn_retransmit_call(struct rxrpc_connection *conn,  in rxrpc_conn_retransmit_call()  argument
42 	_enter("%d", conn->debug_id);  in rxrpc_conn_retransmit_call()
44 	chan = &conn->channels[channel];  in rxrpc_conn_retransmit_call()
55 	msg.msg_name	= &conn->params.peer->srx.transport;  in rxrpc_conn_retransmit_call()
56 	msg.msg_namelen	= conn->params.peer->srx.transport_len;  in rxrpc_conn_retransmit_call()
68 	pkt.whdr.epoch		= htonl(conn->proto.epoch);  in rxrpc_conn_retransmit_call()
69 	pkt.whdr.cid		= htonl(conn->proto.cid | channel);  in rxrpc_conn_retransmit_call()
73 	pkt.whdr.flags		= conn->out_clientflag;  in rxrpc_conn_retransmit_call()
75 	pkt.whdr.securityIndex	= conn->security_ix;  in rxrpc_conn_retransmit_call()
77 	pkt.whdr.serviceId	= htons(conn->service_id);  in rxrpc_conn_retransmit_call()
89 		mtu = conn->params.peer->if_mtu;  in rxrpc_conn_retransmit_call()
90 		mtu -= conn->params.peer->hdrsize;  in rxrpc_conn_retransmit_call()
120 	serial = atomic_inc_return(&conn->serial);  in rxrpc_conn_retransmit_call()
125 		_proto("Tx ABORT %%%u { %d } [re]", serial, conn->abort_code);  in rxrpc_conn_retransmit_call()
136 	ret = kernel_sendmsg(conn->params.local->socket, &msg, iov, ioc, len);  in rxrpc_conn_retransmit_call()
137 	conn->params.peer->last_tx_at = ktime_get_seconds();  in rxrpc_conn_retransmit_call()
151 static void rxrpc_abort_calls(struct rxrpc_connection *conn,  in rxrpc_abort_calls()  argument
158 	_enter("{%d},%x", conn->debug_id, conn->abort_code);  in rxrpc_abort_calls()
160 	spin_lock(&conn->channel_lock);  in rxrpc_abort_calls()
164 			conn->channels[i].call,  in rxrpc_abort_calls()
165 			lockdep_is_held(&conn->channel_lock));  in rxrpc_abort_calls()
171 						  conn->abort_code,  in rxrpc_abort_calls()
172 						  conn->error);  in rxrpc_abort_calls()
175 						     conn->abort_code);  in rxrpc_abort_calls()
177 						      conn->abort_code,  in rxrpc_abort_calls()
178 						      conn->error))  in rxrpc_abort_calls()
183 	spin_unlock(&conn->channel_lock);  in rxrpc_abort_calls()
190 static int rxrpc_abort_connection(struct rxrpc_connection *conn,  in rxrpc_abort_connection()  argument
201 	_enter("%d,,%u,%u", conn->debug_id, error, abort_code);  in rxrpc_abort_connection()
204 	spin_lock_bh(&conn->state_lock);  in rxrpc_abort_connection()
205 	if (conn->state >= RXRPC_CONN_REMOTELY_ABORTED) {  in rxrpc_abort_connection()
206 		spin_unlock_bh(&conn->state_lock);  in rxrpc_abort_connection()
211 	conn->error = error;  in rxrpc_abort_connection()
212 	conn->abort_code = abort_code;  in rxrpc_abort_connection()
213 	conn->state = RXRPC_CONN_LOCALLY_ABORTED;  in rxrpc_abort_connection()
214 	spin_unlock_bh(&conn->state_lock);  in rxrpc_abort_connection()
216 	msg.msg_name	= &conn->params.peer->srx.transport;  in rxrpc_abort_connection()
217 	msg.msg_namelen	= conn->params.peer->srx.transport_len;  in rxrpc_abort_connection()
222 	whdr.epoch	= htonl(conn->proto.epoch);  in rxrpc_abort_connection()
223 	whdr.cid	= htonl(conn->proto.cid);  in rxrpc_abort_connection()
227 	whdr.flags	= conn->out_clientflag;  in rxrpc_abort_connection()
229 	whdr.securityIndex = conn->security_ix;  in rxrpc_abort_connection()
231 	whdr.serviceId	= htons(conn->service_id);  in rxrpc_abort_connection()
233 	word		= htonl(conn->abort_code);  in rxrpc_abort_connection()
242 	serial = atomic_inc_return(&conn->serial);  in rxrpc_abort_connection()
243 	rxrpc_abort_calls(conn, RXRPC_CALL_LOCALLY_ABORTED, serial);  in rxrpc_abort_connection()
245 	_proto("Tx CONN ABORT %%%u { %d }", serial, conn->abort_code);  in rxrpc_abort_connection()
247 	ret = kernel_sendmsg(conn->params.local->socket, &msg, iov, 2, len);  in rxrpc_abort_connection()
249 		trace_rxrpc_tx_fail(conn->debug_id, serial, ret,  in rxrpc_abort_connection()
255 	trace_rxrpc_tx_packet(conn->debug_id, &whdr, rxrpc_tx_point_conn_abort);  in rxrpc_abort_connection()
257 	conn->params.peer->last_tx_at = ktime_get_seconds();  in rxrpc_abort_connection()
283 static int rxrpc_process_event(struct rxrpc_connection *conn,  in rxrpc_process_event()  argument
292 	if (conn->state >= RXRPC_CONN_REMOTELY_ABORTED) {  in rxrpc_process_event()
293 		_leave(" = -ECONNABORTED [%u]", conn->state);  in rxrpc_process_event()
297 	_enter("{%d},{%u,%%%u},", conn->debug_id, sp->hdr.type, sp->hdr.serial);  in rxrpc_process_event()
302 		rxrpc_conn_retransmit_call(conn, skb,  in rxrpc_process_event()
320 		conn->error = -ECONNABORTED;  in rxrpc_process_event()
321 		conn->abort_code = abort_code;  in rxrpc_process_event()
322 		conn->state = RXRPC_CONN_REMOTELY_ABORTED;  in rxrpc_process_event()
323 		rxrpc_abort_calls(conn, RXRPC_CALL_REMOTELY_ABORTED, sp->hdr.serial);  in rxrpc_process_event()
327 		return conn->security->respond_to_challenge(conn, skb,  in rxrpc_process_event()
331 		ret = conn->security->verify_response(conn, skb, _abort_code);  in rxrpc_process_event()
335 		ret = conn->security->init_connection_security(conn);  in rxrpc_process_event()
339 		ret = conn->security->prime_packet_security(conn);  in rxrpc_process_event()
343 		spin_lock(&conn->channel_lock);  in rxrpc_process_event()
344 		spin_lock(&conn->state_lock);  in rxrpc_process_event()
346 		if (conn->state == RXRPC_CONN_SERVICE_CHALLENGING) {  in rxrpc_process_event()
347 			conn->state = RXRPC_CONN_SERVICE;  in rxrpc_process_event()
348 			spin_unlock(&conn->state_lock);  in rxrpc_process_event()
352 						conn->channels[loop].call,  in rxrpc_process_event()
353 						lockdep_is_held(&conn->channel_lock)));  in rxrpc_process_event()
355 			spin_unlock(&conn->state_lock);  in rxrpc_process_event()
358 		spin_unlock(&conn->channel_lock);  in rxrpc_process_event()
371 static void rxrpc_secure_connection(struct rxrpc_connection *conn)  in rxrpc_secure_connection()  argument
376 	_enter("{%d}", conn->debug_id);  in rxrpc_secure_connection()
378 	ASSERT(conn->security_ix != 0);  in rxrpc_secure_connection()
380 	if (!conn->params.key) {  in rxrpc_secure_connection()
382 		ret = rxrpc_init_server_conn_security(conn);  in rxrpc_secure_connection()
395 	if (conn->security->issue_challenge(conn) < 0) {  in rxrpc_secure_connection()
406 	rxrpc_abort_connection(conn, ret, abort_code);  in rxrpc_secure_connection()
413 static void rxrpc_process_delayed_final_acks(struct rxrpc_connection *conn)  in rxrpc_process_delayed_final_acks()  argument
423 		struct rxrpc_channel *chan = &conn->channels[channel];  in rxrpc_process_delayed_final_acks()
426 		if (!test_bit(RXRPC_CONN_FINAL_ACK_0 + channel, &conn->flags))  in rxrpc_process_delayed_final_acks()
441 				       &conn->flags))  in rxrpc_process_delayed_final_acks()
442 			rxrpc_conn_retransmit_call(conn, NULL, channel);  in rxrpc_process_delayed_final_acks()
449 		rxrpc_reduce_conn_timer(conn, next_j);  in rxrpc_process_delayed_final_acks()
457 	struct rxrpc_connection *conn =  in rxrpc_process_connection()  local
463 	rxrpc_see_connection(conn);  in rxrpc_process_connection()
465 	if (test_and_clear_bit(RXRPC_CONN_EV_CHALLENGE, &conn->events))  in rxrpc_process_connection()
466 		rxrpc_secure_connection(conn);  in rxrpc_process_connection()
469 	if (conn->flags & RXRPC_CONN_FINAL_ACK_MASK)  in rxrpc_process_connection()
470 		rxrpc_process_delayed_final_acks(conn);  in rxrpc_process_connection()
474 	while ((skb = skb_dequeue(&conn->rx_queue))) {  in rxrpc_process_connection()
476 		ret = rxrpc_process_event(conn, skb, &abort_code);  in rxrpc_process_connection()
493 	rxrpc_put_connection(conn);  in rxrpc_process_connection()
498 	skb_queue_head(&conn->rx_queue, skb);  in rxrpc_process_connection()
502 	if (rxrpc_abort_connection(conn, ret, abort_code) < 0)  in rxrpc_process_connection()