Lines Matching defs:sock
309 dout("%s con %p sock %d -> %d\n", __func__, con, old_state,
320 dout("%s con %p sock %d -> %d\n", __func__, con, old_state,
331 dout("%s con %p sock %d -> %d\n", __func__, con, old_state,
344 dout("%s con %p sock %d -> %d\n", __func__, con, old_state,
358 dout("%s con %p sock %d -> %d\n", __func__, con, old_state,
367 static void ceph_sock_data_ready(struct sock *sk)
382 static void ceph_sock_write_space(struct sock *sk)
405 static void ceph_sock_state_change(struct sock *sk)
435 static void set_sock_callbacks(struct socket *sock,
438 struct sock *sk = sock->sk;
456 struct socket *sock;
460 BUG_ON(con->sock);
465 SOCK_STREAM, IPPROTO_TCP, &sock);
469 sock->sk->sk_allocation = GFP_NOFS;
472 lockdep_set_class(&sock->sk->sk_lock, &socket_class);
475 set_sock_callbacks(sock, con);
480 ret = kernel_connect(sock, (struct sockaddr *)&ss, sizeof(ss),
485 sock->sk->sk_state);
489 sock_release(sock);
494 tcp_sock_set_nodelay(sock->sk);
496 con->sock = sock;
503 static int ceph_tcp_recvmsg(struct socket *sock, void *buf, size_t len)
513 r = sock_recvmsg(sock, &msg, msg.msg_flags);
519 static int ceph_tcp_recvpage(struct socket *sock, struct page *page,
532 r = sock_recvmsg(sock, &msg, msg.msg_flags);
542 static int ceph_tcp_sendmsg(struct socket *sock, struct kvec *iov,
553 r = kernel_sendmsg(sock, &msg, iov, kvlen, len);
562 static int ceph_tcp_sendpage(struct socket *sock, struct page *page,
565 ssize_t (*sendpage)(struct socket *sock, struct page *page,
579 sendpage = sock->ops->sendpage;
583 ret = sendpage(sock, page, offset, size, flags);
597 dout("con_close_socket on %p sock %p\n", con, con->sock);
598 if (con->sock) {
599 rc = con->sock->ops->shutdown(con->sock, SHUT_RDWR);
600 sock_release(con->sock);
601 con->sock = NULL;
1502 ret = ceph_tcp_sendmsg(con->sock, con->out_kvec_cur,
1588 ret = ceph_tcp_sendpage(con->sock, page, page_offset, length,
1628 ret = ceph_tcp_sendpage(con->sock, zero_page, 0, size, more);
1698 int ret = ceph_tcp_recvmsg(con->sock, object + have, left);
2298 ret = ceph_tcp_recvmsg(con->sock, (char *)section->iov_base +
2333 ret = ceph_tcp_recvpage(con->sock, page, page_offset, length);
2573 BUG_ON(con->sock);
2593 BUG_ON(!con->sock);
2667 BUG_ON(!con->sock);
2714 ret = ceph_tcp_recvmsg(con->sock, NULL, -con->in_base_pos);
2726 ret = ceph_tcp_recvmsg(con->sock, &con->in_tag, 1);
2932 BUG_ON(con->sock);
2937 BUG_ON(con->sock);