fs/afs/rxrpc.c

2 /* Maintain an RxRPC server socket to do AFS communications through
45  * open an RxRPC socket and bind it to be a server for callback notifications
46  * - the socket is left in blocking mode and non-blocking ops use MSG_DONTWAIT
51 	struct socket *socket;
56 	ret = sock_create_kern(net->net, AF_RXRPC, SOCK_DGRAM, PF_INET6, &socket);
60 	socket->sk->sk_allocation = GFP_NOFS;
61 	socket->sk->sk_user_data = net;
63 	/* bind the callback manager's address to make this a server socket */
72 	ret = rxrpc_sock_set_min_security_level(socket->sk,
77 	ret = rxrpc_sock_set_manage_response(socket->sk, true);
81 	ret = afs_create_token_key(net, socket);
85 	ret = kernel_bind(socket, (struct sockaddr *) &srx, sizeof(srx));
88 		ret = kernel_bind(socket, (struct sockaddr *) &srx, sizeof(srx));
94 	ret = kernel_bind(socket, (struct sockaddr *) &srx, sizeof(srx));
105 	rxrpc_kernel_set_notifications(socket, &afs_rxrpc_callback_ops);
107 	ret = kernel_listen(socket, INT_MAX);
111 	net->socket = socket;
117 	sock_release(socket);
124  * close the RxRPC socket AFS was using
130 	kernel_listen(net->socket, 0);
143 	kernel_sock_shutdown(net->socket, SHUT_RDWR);
145 	net->socket->sk->sk_user_data = NULL;
146 	sock_release(net->socket);
194 		rxrpc_kernel_shutdown_call(net->socket, call->rxcall);
195 		rxrpc_kernel_put_call(net->socket, call->rxcall);
374 	rxcall = rxrpc_kernel_begin_call(call->net->socket, call->peer, call->key,
407 	ret = rxrpc_kernel_send_data(call->net->socket, rxcall,
418 		ret = rxrpc_kernel_send_data(call->net->socket,
439 		rxrpc_kernel_abort_call(call->net->socket, rxcall,
450 		rxrpc_kernel_recv_data(call->net->socket, rxcall,
468 		rxrpc_kernel_shutdown_call(call->net->socket, call->rxcall);
534 			ret = rxrpc_kernel_recv_data(call->net->socket,
577 			rxrpc_kernel_abort_call(call->net->socket, call->rxcall,
593 			rxrpc_kernel_abort_call(call->net->socket, call->rxcall,
599 			rxrpc_kernel_abort_call(call->net->socket, call->rxcall,
648 			if (!rxrpc_kernel_check_life(call->net->socket, call->rxcall)) {
667 			if (rxrpc_kernel_abort_call(call->net->socket, call->rxcall,
758 		if (rxrpc_kernel_charge_accept(net->socket,
770  * Discard a preallocated call when a socket is shut down.
799  * Grab the operation ID from an incoming cache manager call.  The socket
856 	rxrpc_kernel_set_tx_length(net->socket, call->rxcall, 0);
865 	switch (rxrpc_kernel_send_data(net->socket, call->rxcall, &msg, 0,
873 		rxrpc_kernel_abort_call(net->socket, call->rxcall,
895 	rxrpc_kernel_set_tx_length(net->socket, call->rxcall, len);
906 	n = rxrpc_kernel_send_data(net->socket, call->rxcall, &msg, len,
916 		rxrpc_kernel_abort_call(net->socket, call->rxcall,
924  * Extract a piece of data from the received data socket buffers.
937 	ret = rxrpc_kernel_recv_data(net->socket, call->rxcall, iter,