Lines Matching defs:socket
2 /* Maintain an RxRPC server socket to do AFS communications through
33 * open an RxRPC socket and bind it to be a server for callback notifications
34 * - the socket is left in blocking mode and non-blocking ops use MSG_DONTWAIT
39 struct socket *socket;
44 ret = sock_create_kern(net->net, AF_RXRPC, SOCK_DGRAM, PF_INET6, &socket);
48 socket->sk->sk_allocation = GFP_NOFS;
50 /* bind the callback manager's address to make this a server socket */
59 ret = rxrpc_sock_set_min_security_level(socket->sk,
64 ret = kernel_bind(socket, (struct sockaddr *) &srx, sizeof(srx));
67 ret = kernel_bind(socket, (struct sockaddr *) &srx, sizeof(srx));
73 ret = kernel_bind(socket, (struct sockaddr *) &srx, sizeof(srx));
84 rxrpc_kernel_new_call_notification(socket, afs_rx_new_call,
87 ret = kernel_listen(socket, INT_MAX);
91 net->socket = socket;
97 sock_release(socket);
104 * close the RxRPC socket AFS was using
110 kernel_listen(net->socket, 0);
123 kernel_sock_shutdown(net->socket, SHUT_RDWR);
125 sock_release(net->socket);
178 rxrpc_kernel_end_call(net->socket, call->rxcall);
342 ret = rxrpc_kernel_send_data(op->net->socket, call->rxcall, msg,
411 rxcall = rxrpc_kernel_begin_call(call->net->socket, srx, call->key,
430 rxrpc_kernel_set_max_life(call->net->socket, rxcall,
445 ret = rxrpc_kernel_send_data(call->net->socket, rxcall,
467 rxrpc_kernel_abort_call(call->net->socket, rxcall,
471 rxrpc_kernel_recv_data(call->net->socket, rxcall,
488 rxrpc_kernel_end_call(call->net->socket, call->rxcall);
521 ret = rxrpc_kernel_recv_data(call->net->socket,
560 rxrpc_kernel_abort_call(call->net->socket, call->rxcall,
575 rxrpc_kernel_abort_call(call->net->socket, call->rxcall,
580 rxrpc_kernel_abort_call(call->net->socket, call->rxcall,
634 if (!rxrpc_kernel_check_life(call->net->socket, call->rxcall)) {
652 if (rxrpc_kernel_abort_call(call->net->socket, call->rxcall,
765 if (rxrpc_kernel_charge_accept(net->socket,
778 * Discard a preallocated call when a socket is shut down.
801 * Grab the operation ID from an incoming cache manager call. The socket
853 rxrpc_kernel_set_tx_length(net->socket, call->rxcall, 0);
862 switch (rxrpc_kernel_send_data(net->socket, call->rxcall, &msg, 0,
870 rxrpc_kernel_abort_call(net->socket, call->rxcall,
891 rxrpc_kernel_set_tx_length(net->socket, call->rxcall, len);
902 n = rxrpc_kernel_send_data(net->socket, call->rxcall, &msg, len,
912 rxrpc_kernel_abort_call(net->socket, call->rxcall,
919 * Extract a piece of data from the received data socket buffers.
931 ret = rxrpc_kernel_recv_data(net->socket, call->rxcall, iter,