Lines Matching refs:sock
12 #include <net/sock.h>
43 static void nvme_tcp_reclassify_socket(struct socket *sock)
45 struct sock *sk = sock->sk;
68 static void nvme_tcp_reclassify_socket(struct socket *sock) { }
113 struct socket *sock;
148 void (*state_change)(struct sock *);
149 void (*data_ready)(struct sock *);
150 void (*write_space)(struct sock *);
882 static void nvme_tcp_data_ready(struct sock *sk)
894 static void nvme_tcp_write_space(struct sock *sk)
907 static void nvme_tcp_state_change(struct sock *sk)
972 ret = kernel_sendpage(queue->sock, page, offset, len,
975 ret = sock_no_sendpage(queue->sock, page, offset, len,
1027 ret = kernel_sendpage(queue->sock, virt_to_page(pdu),
1060 ret = kernel_sendpage(queue->sock, virt_to_page(pdu),
1096 ret = kernel_sendmsg(queue->sock, &msg, &iov, 1, iov.iov_len);
1157 struct socket *sock = queue->sock;
1158 struct sock *sk = sock->sk;
1166 consumed = sock->ops->read_sock(sk, &rd_desc, nvme_tcp_recv_skb);
1273 sock_release(queue->sock);
1311 ret = kernel_sendmsg(queue->sock, &msg, &iov, 1, iov.iov_len);
1318 ret = kernel_recvmsg(queue->sock, &msg, &iov, 1,
1452 IPPROTO_TCP, &queue->sock);
1459 nvme_tcp_reclassify_socket(queue->sock);
1462 tcp_sock_set_syncnt(queue->sock->sk, 1);
1465 tcp_sock_set_nodelay(queue->sock->sk);
1472 sock_no_linger(queue->sock->sk);
1475 sock_set_priority(queue->sock->sk, so_priority);
1479 ip_sock_set_tos(queue->sock->sk, nctrl->opts->tos);
1482 queue->sock->sk->sk_rcvtimeo = 10 * HZ;
1484 queue->sock->sk->sk_allocation = GFP_ATOMIC;
1491 sk_set_memalloc(queue->sock->sk);
1494 ret = kernel_bind(queue->sock, (struct sockaddr *)&ctrl->src_addr,
1526 ret = kernel_connect(queue->sock, (struct sockaddr *)&ctrl->addr,
1543 kernel_sock_shutdown(queue->sock, SHUT_RDWR);
1550 sock_release(queue->sock);
1551 queue->sock = NULL;
1559 struct socket *sock = queue->sock;
1561 write_lock_bh(&sock->sk->sk_callback_lock);
1562 sock->sk->sk_user_data = NULL;
1563 sock->sk->sk_data_ready = queue->data_ready;
1564 sock->sk->sk_state_change = queue->state_change;
1565 sock->sk->sk_write_space = queue->write_space;
1566 write_unlock_bh(&sock->sk->sk_callback_lock);
1571 kernel_sock_shutdown(queue->sock, SHUT_RDWR);
1589 write_lock_bh(&queue->sock->sk->sk_callback_lock);
1590 queue->sock->sk->sk_user_data = queue;
1591 queue->state_change = queue->sock->sk->sk_state_change;
1592 queue->data_ready = queue->sock->sk->sk_data_ready;
1593 queue->write_space = queue->sock->sk->sk_write_space;
1594 queue->sock->sk->sk_data_ready = nvme_tcp_data_ready;
1595 queue->sock->sk->sk_state_change = nvme_tcp_state_change;
1596 queue->sock->sk->sk_write_space = nvme_tcp_write_space;
1598 queue->sock->sk->sk_ll_usec = 1;
1600 write_unlock_bh(&queue->sock->sk->sk_callback_lock);
2464 struct sock *sk = queue->sock->sk;