Lines Matching defs:sock
12 #include <net/sock.h>
95 struct socket *sock;
137 void (*data_ready)(struct sock *);
138 void (*state_change)(struct sock *);
139 void (*write_space)(struct sock *);
143 struct socket *sock;
147 void (*data_ready)(struct sock *);
223 return queue->sock->sk->sk_incoming_cpu;
335 kernel_sock_shutdown(queue->sock, SHUT_RDWR);
342 kernel_sock_shutdown(queue->sock, SHUT_RDWR);
566 ret = kernel_sendpage(cmd->queue->sock, virt_to_page(cmd->data_pdu),
598 ret = kernel_sendpage(cmd->queue->sock, page, cmd->offset,
647 ret = kernel_sendpage(cmd->queue->sock, virt_to_page(cmd->rsp_pdu),
676 ret = kernel_sendpage(cmd->queue->sock, virt_to_page(cmd->r2t_pdu),
706 ret = kernel_sendmsg(queue->sock, &msg, &iov, 1, iov.iov_len);
885 ret = kernel_sendmsg(queue->sock, &msg, &iov, 1, iov.iov_len);
1081 len = kernel_recvmsg(queue->sock, &msg, &iov, 1,
1140 ret = sock_recvmsg(cmd->queue->sock, &cmd->recv_msg,
1172 ret = kernel_recvmsg(queue->sock, &msg, &iov, 1,
1388 struct socket *sock = queue->sock;
1390 write_lock_bh(&sock->sk->sk_callback_lock);
1391 sock->sk->sk_data_ready = queue->data_ready;
1392 sock->sk->sk_state_change = queue->state_change;
1393 sock->sk->sk_write_space = queue->write_space;
1394 sock->sk->sk_user_data = NULL;
1395 write_unlock_bh(&sock->sk->sk_callback_lock);
1438 sock_release(queue->sock);
1449 static void nvmet_tcp_data_ready(struct sock *sk)
1460 static void nvmet_tcp_write_space(struct sock *sk)
1482 static void nvmet_tcp_state_change(struct sock *sk)
1511 struct socket *sock = queue->sock;
1512 struct inet_sock *inet = inet_sk(sock->sk);
1515 ret = kernel_getsockname(sock,
1520 ret = kernel_getpeername(sock,
1530 sock_no_linger(sock->sk);
1533 sock_set_priority(sock->sk, so_priority);
1537 ip_sock_set_tos(sock->sk, inet->rcv_tos);
1540 write_lock_bh(&sock->sk->sk_callback_lock);
1541 if (sock->sk->sk_state != TCP_ESTABLISHED) {
1548 sock->sk->sk_user_data = queue;
1549 queue->data_ready = sock->sk->sk_data_ready;
1550 sock->sk->sk_data_ready = nvmet_tcp_data_ready;
1551 queue->state_change = sock->sk->sk_state_change;
1552 sock->sk->sk_state_change = nvmet_tcp_state_change;
1553 queue->write_space = sock->sk->sk_write_space;
1554 sock->sk->sk_write_space = nvmet_tcp_write_space;
1557 write_unlock_bh(&sock->sk->sk_callback_lock);
1574 queue->sock = newsock;
1630 ret = kernel_accept(port->sock, &newsock, O_NONBLOCK);
1644 static void nvmet_tcp_listen_data_ready(struct sock *sk)
1697 IPPROTO_TCP, &port->sock);
1703 port->sock->sk->sk_user_data = port;
1704 port->data_ready = port->sock->sk->sk_data_ready;
1705 port->sock->sk->sk_data_ready = nvmet_tcp_listen_data_ready;
1706 sock_set_reuseaddr(port->sock->sk);
1707 tcp_sock_set_nodelay(port->sock->sk);
1709 sock_set_priority(port->sock->sk, so_priority);
1711 ret = kernel_bind(port->sock, (struct sockaddr *)&port->addr,
1718 ret = kernel_listen(port->sock, 128);
1720 pr_err("failed to listen %d on port sock\n", ret);
1731 sock_release(port->sock);
1744 kernel_sock_shutdown(queue->sock, SHUT_RDWR);
1752 write_lock_bh(&port->sock->sk->sk_callback_lock);
1753 port->sock->sk->sk_data_ready = port->data_ready;
1754 port->sock->sk->sk_user_data = NULL;
1755 write_unlock_bh(&port->sock->sk->sk_callback_lock);
1763 sock_release(port->sock);
1774 kernel_sock_shutdown(queue->sock, SHUT_RDWR);
1852 kernel_sock_shutdown(queue->sock, SHUT_RDWR);