Lines Matching defs:socket
2 /* Maintain an RxRPC server socket to do AFS communications through
35 * open an RxRPC socket and bind it to be a server for callback notifications
36 * - the socket is left in blocking mode and non-blocking ops use MSG_DONTWAIT
41 struct socket *socket;
46 ret = sock_create_kern(net->net, AF_RXRPC, SOCK_DGRAM, PF_INET6, &socket);
50 socket->sk->sk_allocation = GFP_NOFS;
52 /* bind the callback manager's address to make this a server socket */
61 ret = rxrpc_sock_set_min_security_level(socket->sk,
66 ret = kernel_bind(socket, (struct sockaddr *) &srx, sizeof(srx));
69 ret = kernel_bind(socket, (struct sockaddr *) &srx, sizeof(srx));
75 ret = kernel_bind(socket, (struct sockaddr *) &srx, sizeof(srx));
86 rxrpc_kernel_new_call_notification(socket, afs_rx_new_call,
89 ret = kernel_listen(socket, INT_MAX);
93 net->socket = socket;
99 sock_release(socket);
106 * close the RxRPC socket AFS was using
112 kernel_listen(net->socket, 0);
125 kernel_sock_shutdown(net->socket, SHUT_RDWR);
127 sock_release(net->socket);
182 rxrpc_kernel_shutdown_call(net->socket, call->rxcall);
183 rxrpc_kernel_put_call(net->socket, call->rxcall);
336 rxcall = rxrpc_kernel_begin_call(call->net->socket, srx, call->key,
368 ret = rxrpc_kernel_send_data(call->net->socket, rxcall,
379 ret = rxrpc_kernel_send_data(call->net->socket,
400 rxrpc_kernel_abort_call(call->net->socket, rxcall,
406 rxrpc_kernel_recv_data(call->net->socket, rxcall,
423 rxrpc_kernel_shutdown_call(call->net->socket, call->rxcall);
489 ret = rxrpc_kernel_recv_data(call->net->socket,
529 rxrpc_kernel_abort_call(call->net->socket, call->rxcall,
545 rxrpc_kernel_abort_call(call->net->socket, call->rxcall,
551 rxrpc_kernel_abort_call(call->net->socket, call->rxcall,
606 if (!rxrpc_kernel_check_life(call->net->socket, call->rxcall)) {
624 if (rxrpc_kernel_abort_call(call->net->socket, call->rxcall,
737 if (rxrpc_kernel_charge_accept(net->socket,
750 * Discard a preallocated call when a socket is shut down.
773 * Grab the operation ID from an incoming cache manager call. The socket
825 rxrpc_kernel_set_tx_length(net->socket, call->rxcall, 0);
834 switch (rxrpc_kernel_send_data(net->socket, call->rxcall, &msg, 0,
842 rxrpc_kernel_abort_call(net->socket, call->rxcall,
864 rxrpc_kernel_set_tx_length(net->socket, call->rxcall, len);
875 n = rxrpc_kernel_send_data(net->socket, call->rxcall, &msg, len,
885 rxrpc_kernel_abort_call(net->socket, call->rxcall,
893 * Extract a piece of data from the received data socket buffers.
906 ret = rxrpc_kernel_recv_data(net->socket, call->rxcall, iter,