Lines Matching +full:serial +full:- +full:state
1 // SPDX-License-Identifier: GPL-2.0-or-later
2 /* connection-level event handling
17 #include "ar-internal.h"
40 u32 serial, mtu, call_id, padding; in rxrpc_conn_retransmit_call() local
42 _enter("%d", conn->debug_id); in rxrpc_conn_retransmit_call()
44 chan = &conn->channels[channel]; in rxrpc_conn_retransmit_call()
49 call_id = READ_ONCE(chan->last_call); in rxrpc_conn_retransmit_call()
52 if (skb && call_id != sp->hdr.callNumber) 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()
72 pkt.whdr.type = chan->last_type; 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()
80 switch (chan->last_type) { in rxrpc_conn_retransmit_call()
82 pkt.abort_code = htonl(chan->last_abort); 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()
92 pkt.ack.maxSkew = htons(skb ? skb->priority : 0); in rxrpc_conn_retransmit_call()
93 pkt.ack.firstPacket = htonl(chan->last_seq + 1); in rxrpc_conn_retransmit_call()
94 pkt.ack.previousPacket = htonl(chan->last_seq); in rxrpc_conn_retransmit_call()
95 pkt.ack.serial = htonl(skb ? sp->hdr.serial : 0); in rxrpc_conn_retransmit_call()
117 if (READ_ONCE(chan->last_call) != call_id) in rxrpc_conn_retransmit_call()
120 serial = atomic_inc_return(&conn->serial); in rxrpc_conn_retransmit_call()
121 pkt.whdr.serial = htonl(serial); in rxrpc_conn_retransmit_call()
123 switch (chan->last_type) { in rxrpc_conn_retransmit_call()
125 _proto("Tx ABORT %%%u { %d } [re]", serial, conn->abort_code); in rxrpc_conn_retransmit_call()
128 trace_rxrpc_tx_ack(chan->call_debug_id, serial, in rxrpc_conn_retransmit_call()
130 ntohl(pkt.ack.serial), in rxrpc_conn_retransmit_call()
132 _proto("Tx ACK %%%u [re]", serial); 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()
139 trace_rxrpc_tx_fail(chan->call_debug_id, serial, ret, in rxrpc_conn_retransmit_call()
142 trace_rxrpc_tx_packet(chan->call_debug_id, &pkt.whdr, in rxrpc_conn_retransmit_call()
149 * pass a connection-level abort onto all calls on that connection
153 rxrpc_serial_t serial) in rxrpc_abort_calls() argument
158 _enter("{%d},%x", conn->debug_id, conn->abort_code); in rxrpc_abort_calls()
160 spin_lock(&conn->bundle->channel_lock); in rxrpc_abort_calls()
164 conn->channels[i].call, in rxrpc_abort_calls()
165 lockdep_is_held(&conn->bundle->channel_lock)); in rxrpc_abort_calls()
168 trace_rxrpc_abort(call->debug_id, in rxrpc_abort_calls()
169 "CON", call->cid, in rxrpc_abort_calls()
170 call->call_id, 0, in rxrpc_abort_calls()
171 conn->abort_code, in rxrpc_abort_calls()
172 conn->error); in rxrpc_abort_calls()
174 trace_rxrpc_rx_abort(call, serial, 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()
182 spin_unlock(&conn->bundle->channel_lock); in rxrpc_abort_calls()
187 * generate a connection-level abort
197 u32 serial; in rxrpc_abort_connection() local
200 _enter("%d,,%u,%u", conn->debug_id, error, abort_code); in rxrpc_abort_connection()
202 /* generate a connection-level abort */ in rxrpc_abort_connection()
203 spin_lock_bh(&conn->state_lock); in rxrpc_abort_connection()
204 if (conn->state >= RXRPC_CONN_REMOTELY_ABORTED) { in rxrpc_abort_connection()
205 spin_unlock_bh(&conn->state_lock); in rxrpc_abort_connection()
210 conn->error = error; in rxrpc_abort_connection()
211 conn->abort_code = abort_code; in rxrpc_abort_connection()
212 conn->state = RXRPC_CONN_LOCALLY_ABORTED; in rxrpc_abort_connection()
213 set_bit(RXRPC_CONN_DONT_REUSE, &conn->flags); 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()
244 whdr.serial = htonl(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()
252 return -EAGAIN; 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()
264 * mark a call as being on a now-secured channel
265 * - must be called with BH's disabled.
271 write_lock_bh(&call->state_lock); in rxrpc_call_is_secure()
272 if (call->state == RXRPC_CALL_SERVER_SECURING) { in rxrpc_call_is_secure()
273 call->state = RXRPC_CALL_SERVER_RECV_REQUEST; in rxrpc_call_is_secure()
276 write_unlock_bh(&call->state_lock); in rxrpc_call_is_secure()
281 * connection-level Rx packet processor
292 if (conn->state >= RXRPC_CONN_REMOTELY_ABORTED) { in rxrpc_process_event()
293 _leave(" = -ECONNABORTED [%u]", conn->state); in rxrpc_process_event()
294 return -ECONNABORTED; in rxrpc_process_event()
297 _enter("{%d},{%u,%%%u},", conn->debug_id, sp->hdr.type, sp->hdr.serial); in rxrpc_process_event()
299 switch (sp->hdr.type) { in rxrpc_process_event()
303 sp->hdr.cid & RXRPC_CHANNELMASK); in rxrpc_process_event()
313 trace_rxrpc_rx_eproto(NULL, sp->hdr.serial, in rxrpc_process_event()
315 return -EPROTO; in rxrpc_process_event()
318 _proto("Rx ABORT %%%u { ac=%d }", sp->hdr.serial, abort_code); 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 set_bit(RXRPC_CONN_DONT_REUSE, &conn->flags); in rxrpc_process_event()
324 rxrpc_abort_calls(conn, RXRPC_CALL_REMOTELY_ABORTED, sp->hdr.serial); in rxrpc_process_event()
325 return -ECONNABORTED; in rxrpc_process_event()
328 return conn->security->respond_to_challenge(conn, skb, in rxrpc_process_event()
332 ret = conn->security->verify_response(conn, skb, _abort_code); in rxrpc_process_event()
336 ret = conn->security->init_connection_security(conn); in rxrpc_process_event()
340 ret = conn->security->prime_packet_security(conn); in rxrpc_process_event()
344 spin_lock(&conn->bundle->channel_lock); in rxrpc_process_event()
345 spin_lock_bh(&conn->state_lock); in rxrpc_process_event()
347 if (conn->state == RXRPC_CONN_SERVICE_CHALLENGING) { in rxrpc_process_event()
348 conn->state = RXRPC_CONN_SERVICE; in rxrpc_process_event()
349 spin_unlock_bh(&conn->state_lock); in rxrpc_process_event()
353 conn->channels[loop].call, in rxrpc_process_event()
354 lockdep_is_held(&conn->bundle->channel_lock))); in rxrpc_process_event()
356 spin_unlock_bh(&conn->state_lock); in rxrpc_process_event()
359 spin_unlock(&conn->bundle->channel_lock); in rxrpc_process_event()
363 trace_rxrpc_rx_eproto(NULL, sp->hdr.serial, in rxrpc_process_event()
365 return -EPROTO; in rxrpc_process_event()
377 _enter("{%d}", conn->debug_id); in rxrpc_secure_connection()
379 ASSERT(conn->security_ix != 0); in rxrpc_secure_connection()
380 ASSERT(conn->server_key); in rxrpc_secure_connection()
382 if (conn->security->issue_challenge(conn) < 0) { in rxrpc_secure_connection()
384 ret = -ENOMEM; in rxrpc_secure_connection()
410 struct rxrpc_channel *chan = &conn->channels[channel]; in rxrpc_process_delayed_final_acks()
413 if (!test_bit(RXRPC_CONN_FINAL_ACK_0 + channel, &conn->flags)) in rxrpc_process_delayed_final_acks()
417 ack_at = READ_ONCE(chan->final_ack_at); in rxrpc_process_delayed_final_acks()
428 &conn->flags)) in rxrpc_process_delayed_final_acks()
440 * connection-level event processor
448 if (test_and_clear_bit(RXRPC_CONN_EV_CHALLENGE, &conn->events)) in rxrpc_do_process_connection()
452 if (conn->flags & RXRPC_CONN_FINAL_ACK_MASK) in rxrpc_do_process_connection()
455 /* go through the conn-level event packets, releasing the ref on this in rxrpc_do_process_connection()
457 while ((skb = skb_dequeue(&conn->rx_queue))) { in rxrpc_do_process_connection()
461 case -EPROTO: in rxrpc_do_process_connection()
462 case -EKEYEXPIRED: in rxrpc_do_process_connection()
463 case -EKEYREJECTED: in rxrpc_do_process_connection()
465 case -ENOMEM: in rxrpc_do_process_connection()
466 case -EAGAIN: in rxrpc_do_process_connection()
468 case -ECONNABORTED: in rxrpc_do_process_connection()
478 skb_queue_head(&conn->rx_queue, skb); in rxrpc_do_process_connection()
495 if (__rxrpc_use_local(conn->params.local)) { in rxrpc_process_connection()
497 rxrpc_unuse_local(conn->params.local); in rxrpc_process_connection()