23 void rxrpc_remove_user_ID(struct rxrpc_sock *rx, struct rxrpc_call *call)  in rxrpc_remove_user_ID()  argument
25 	_debug("RELEASE CALL %d", call->debug_id);  in rxrpc_remove_user_ID()
27 	if (test_bit(RXRPC_CALL_HAS_USERID, &call->flags)) {  in rxrpc_remove_user_ID()
29 		rb_erase(&call->sock_node, &call->socket->calls);  in rxrpc_remove_user_ID()
30 		clear_bit(RXRPC_CALL_HAS_USERID, &call->flags);  in rxrpc_remove_user_ID()
34 	read_lock_bh(&call->state_lock);  in rxrpc_remove_user_ID()
35 	if (!test_bit(RXRPC_CALL_RELEASED, &call->flags) &&  in rxrpc_remove_user_ID()
36 	    !test_and_set_bit(RXRPC_CALL_RELEASE, &call->events))  in rxrpc_remove_user_ID()
37 		rxrpc_queue_call(call);  in rxrpc_remove_user_ID()
38 	read_unlock_bh(&call->state_lock);  in rxrpc_remove_user_ID()
50 	struct rxrpc_call *call = NULL, *continue_call = NULL;  in rxrpc_recvmsg()  local
113 		call = sp->call;  in rxrpc_recvmsg()
114 		ASSERT(call != NULL);  in rxrpc_recvmsg()
119 		spin_lock_bh(&call->lock);  in rxrpc_recvmsg()
120 		spin_unlock_bh(&call->lock);  in rxrpc_recvmsg()
122 		if (test_bit(RXRPC_CALL_RELEASED, &call->flags)) {  in rxrpc_recvmsg()
133 			if (call != continue_call ||  in rxrpc_recvmsg()
142 		rxrpc_get_call(call);  in rxrpc_recvmsg()
148 					sizeof(call->conn->trans->peer->srx);  in rxrpc_recvmsg()
150 				       &call->conn->trans->peer->srx, len);  in rxrpc_recvmsg()
166 				       ullen, &call->user_call_ID);  in rxrpc_recvmsg()
169 			ASSERT(test_bit(RXRPC_CALL_HAS_USERID, &call->flags));  in rxrpc_recvmsg()
172 		ASSERTCMP(ntohl(sp->hdr.seq), >=, call->rx_data_recv);  in rxrpc_recvmsg()
173 		ASSERTCMP(ntohl(sp->hdr.seq), <=, call->rx_data_recv + 1);  in rxrpc_recvmsg()
174 		call->rx_data_recv = ntohl(sp->hdr.seq);  in rxrpc_recvmsg()
176 		ASSERTCMP(ntohl(sp->hdr.seq), >, call->rx_data_eaten);  in rxrpc_recvmsg()
206 			if (call->conn->out_clientflag) {  in rxrpc_recvmsg()
227 			continue_call = sp->call;  in rxrpc_recvmsg()
229 			rxrpc_put_call(call);  in rxrpc_recvmsg()
230 		call = NULL;  in rxrpc_recvmsg()
250 	if (call)  in rxrpc_recvmsg()
251 		rxrpc_put_call(call);  in rxrpc_recvmsg()
276 		       ullen, &call->user_call_ID);  in rxrpc_recvmsg()
279 	ASSERT(test_bit(RXRPC_CALL_HAS_USERID, &call->flags));  in rxrpc_recvmsg()
291 		abort_code = call->abort_code;  in rxrpc_recvmsg()
323 		rxrpc_remove_user_ID(rx, call);  in rxrpc_recvmsg()
327 	rxrpc_put_call(call);  in rxrpc_recvmsg()
336 	rxrpc_put_call(call);  in rxrpc_recvmsg()
365 	struct rxrpc_call *call = sp->call;  in rxrpc_kernel_data_delivered()  local
367 	ASSERTCMP(ntohl(sp->hdr.seq), >=, call->rx_data_recv);  in rxrpc_kernel_data_delivered()
368 	ASSERTCMP(ntohl(sp->hdr.seq), <=, call->rx_data_recv + 1);  in rxrpc_kernel_data_delivered()
369 	call->rx_data_recv = ntohl(sp->hdr.seq);  in rxrpc_kernel_data_delivered()
371 	ASSERTCMP(ntohl(sp->hdr.seq), >, call->rx_data_eaten);  in rxrpc_kernel_data_delivered()
406 	return sp->call->abort_code;  in rxrpc_kernel_get_abort_code()