Lines Matching defs:sock
12 #include <net/sock.h>
17 #include <trace/events/sock.h>
131 struct socket *sock;
175 void (*data_ready)(struct sock *);
176 void (*state_change)(struct sock *);
177 void (*write_space)(struct sock *);
181 struct socket *sock;
185 void (*data_ready)(struct sock *);
261 return queue->sock->sk->sk_incoming_cpu;
371 kernel_sock_shutdown(queue->sock, SHUT_RDWR);
378 kernel_sock_shutdown(queue->sock, SHUT_RDWR);
591 ret = sock_sendmsg(cmd->queue->sock, &msg);
626 ret = sock_sendmsg(cmd->queue->sock, &msg);
675 ret = sock_sendmsg(cmd->queue->sock, &msg);
705 ret = sock_sendmsg(cmd->queue->sock, &msg);
734 ret = kernel_sendmsg(queue->sock, &msg, &iov, 1, iov.iov_len);
913 ret = kernel_sendmsg(queue->sock, &msg, &iov, 1, iov.iov_len);
1123 len = kernel_recvmsg(queue->sock, &msg, &iov, 1,
1182 ret = sock_recvmsg(cmd->queue->sock, &cmd->recv_msg,
1213 ret = kernel_recvmsg(queue->sock, &msg, &iov, 1,
1448 struct socket *sock = queue->sock;
1450 write_lock_bh(&sock->sk->sk_callback_lock);
1451 sock->sk->sk_data_ready = queue->data_ready;
1452 sock->sk->sk_state_change = queue->state_change;
1453 sock->sk->sk_write_space = queue->write_space;
1454 sock->sk->sk_user_data = NULL;
1455 write_unlock_bh(&sock->sk->sk_callback_lock);
1507 sock_release(queue->sock);
1518 static void nvmet_tcp_data_ready(struct sock *sk)
1531 static void nvmet_tcp_write_space(struct sock *sk)
1553 static void nvmet_tcp_state_change(struct sock *sk)
1582 struct socket *sock = queue->sock;
1583 struct inet_sock *inet = inet_sk(sock->sk);
1586 ret = kernel_getsockname(sock,
1591 ret = kernel_getpeername(sock,
1601 sock_no_linger(sock->sk);
1604 sock_set_priority(sock->sk, so_priority);
1608 ip_sock_set_tos(sock->sk, inet->rcv_tos);
1611 write_lock_bh(&sock->sk->sk_callback_lock);
1612 if (sock->sk->sk_state != TCP_ESTABLISHED) {
1619 sock->sk->sk_user_data = queue;
1620 queue->data_ready = sock->sk->sk_data_ready;
1621 sock->sk->sk_data_ready = nvmet_tcp_data_ready;
1622 queue->state_change = sock->sk->sk_state_change;
1623 sock->sk->sk_state_change = nvmet_tcp_state_change;
1624 queue->write_space = sock->sk->sk_write_space;
1625 sock->sk->sk_write_space = nvmet_tcp_write_space;
1630 write_unlock_bh(&sock->sk->sk_callback_lock);
1647 queue->sock = newsock;
1703 ret = kernel_accept(port->sock, &newsock, O_NONBLOCK);
1717 static void nvmet_tcp_listen_data_ready(struct sock *sk)
1772 IPPROTO_TCP, &port->sock);
1778 port->sock->sk->sk_user_data = port;
1779 port->data_ready = port->sock->sk->sk_data_ready;
1780 port->sock->sk->sk_data_ready = nvmet_tcp_listen_data_ready;
1781 sock_set_reuseaddr(port->sock->sk);
1782 tcp_sock_set_nodelay(port->sock->sk);
1784 sock_set_priority(port->sock->sk, so_priority);
1786 ret = kernel_bind(port->sock, (struct sockaddr *)&port->addr,
1793 ret = kernel_listen(port->sock, 128);
1795 pr_err("failed to listen %d on port sock\n", ret);
1806 sock_release(port->sock);
1819 kernel_sock_shutdown(queue->sock, SHUT_RDWR);
1827 write_lock_bh(&port->sock->sk->sk_callback_lock);
1828 port->sock->sk->sk_data_ready = port->data_ready;
1829 port->sock->sk->sk_user_data = NULL;
1830 write_unlock_bh(&port->sock->sk->sk_callback_lock);
1838 sock_release(port->sock);
1849 kernel_sock_shutdown(queue->sock, SHUT_RDWR);
1925 kernel_sock_shutdown(queue->sock, SHUT_RDWR);