Lines Matching defs:sock
42 static int recvmsg_nofs(struct socket *sock, struct msghdr *msg,
50 ret = kernel_recvmsg(sock, msg, vec, num, size, flags);
56 static int sendmsg_nofs(struct socket *sock, struct msghdr *msg,
64 ret = kernel_sendmsg(sock, msg, vec, num, size);
70 static int tcp_set_recvtimeo(struct socket *sock, int timeout)
74 tcp_sock_set_nodelay(sock->sk);
75 tcp_sock_set_user_timeout(sock->sk, jiffies_left);
89 if (tcp->sock)
90 rtt_us = tcp_sk(tcp->sock->sk)->srtt_us >> 3;
95 static int tcp_read_head_from_socket(struct socket *sock, void *buf,
108 rc = recvmsg_nofs(sock, &hmdfs_msg, &iov, 1, to_read,
123 static int tcp_read_buffer_from_socket(struct socket *sock, void *buf,
139 rc = recvmsg_nofs(sock, &hmdfs_msg, &iov, 1,
165 static int hmdfs_drop_readpage_buffer(struct socket *sock,
183 err = tcp_read_buffer_from_socket(sock, buf, len);
189 static int hmdfs_get_readpage_buffer(struct socket *sock,
204 err = tcp_read_buffer_from_socket(sock, page_buf, out_len);
249 ret = hmdfs_get_readpage_buffer(tcp->sock, recv, page);
264 ret = hmdfs_drop_readpage_buffer(tcp->sock, recv);
426 ret = tcp_read_buffer_from_socket(tcp->sock, cipherbuffer,
476 ret = tcp_read_buffer_from_socket(tcp->sock, outdata, outlen);
503 if (!tcp->sock) {
504 hmdfs_info("tcp recv thread !sock");
514 ret = tcp_read_head_from_socket(tcp->sock, recv,
560 if (!tcp || !tcp->sock || !tcp->sock->sk) {
565 if (tcp->sock->sk->sk_state != TCP_ESTABLISHED) {
567 tcp->fd, tcp->sock->sk->sk_state);
571 if (tcp->sock->state != SS_CONNECTING &&
572 tcp->sock->state != SS_CONNECTED) {
573 hmdfs_err("TCP conn %d is broken, current sock state is %d",
574 tcp->fd, tcp->sock->state);
579 tls_ctx = tls_get_ctx(tcp->sock->sk);
600 WARN_ON(!tcp->sock);
640 hmdfs_info("Exiting. Now, sock state = %d", tcp->sock->state);
658 if (!tcp || !tcp->sock) {
685 send_len = sendmsg_nofs(tcp->sock, &tcp_msg, iov, send_vec_cnt,
712 if (!tcp || !tcp->sock) {
732 send_len = sendmsg_nofs(tcp->sock, &tcp_msg, iov, send_vec_cnt,
894 if (!tcp || !tcp->sock || !tcp->sock->sk) {
899 lock_sock(tcp->sock->sk);
900 if (tcp->sock->sk->sk_protocol != IPPROTO_TCP ||
901 tcp->sock->type != SOCK_STREAM ||
902 tcp->sock->sk->sk_family != AF_INET) {
904 release_sock(tcp->sock->sk);
908 icsk = inet_csk(tcp->sock->sk);
911 release_sock(tcp->sock->sk);
915 release_sock(tcp->sock->sk);
928 tcp->sock = socket;
1001 tcp->sock = NULL;
1020 tcp->sock = NULL;
1099 if (tcp->sock) {
1100 hmdfs_info("shudown sock: fd = %d, sockref = %ld, connref = %u stop_thread = %d",
1101 tcp->fd, file_count(tcp->sock->file),
1103 kernel_sock_shutdown(tcp->sock, SHUT_RDWR);
1124 if (tcp->sock == socket) {