Lines Matching defs:sock
49 #include <trace/events/sock.h>
84 mlog(ML_SOCKET, "[sc %p refs %d sock %p node %u page %p " \
102 * quorum work is queued as sock containers are shutdown.. stop_listening
103 * tears down all the node's sock containers, preventing future shutdowns
126 static void o2net_listen_data_ready(struct sock *sk);
584 static void o2net_data_ready(struct sock *sk)
586 void (*ready)(struct sock *sk);
607 static void o2net_state_change(struct sock *sk)
609 void (*state_change)(struct sock *sk);
648 static void o2net_register_callbacks(struct sock *sk,
673 static int o2net_unregister_callbacks(struct sock *sk,
902 static int o2net_recv_tcp_msg(struct socket *sock, void *data, size_t len)
907 return sock_recvmsg(sock, &msg, MSG_DONTWAIT);
910 static int o2net_send_tcp_msg(struct socket *sock, struct kvec *vec,
916 if (sock == NULL) {
921 ret = kernel_sendmsg(sock, &msg, vec, veclen, total);
1146 static int o2net_send_status_magic(struct socket *sock, struct o2net_msg *hdr,
1165 return o2net_send_tcp_msg(sock, &vec, 1, sizeof(struct o2net_msg));
1458 /* called when a connect completes and after a sock is accepted. the
1554 struct socket *sock = NULL;
1561 * sock_create allocates the sock with GFP_KERNEL. We must
1603 ret = sock_create(PF_INET, SOCK_STREAM, IPPROTO_TCP, &sock);
1608 sc->sc_sock = sock; /* freed by sc_kref_release */
1610 sock->sk->sk_allocation = GFP_ATOMIC;
1611 sock->sk->sk_use_task_frag = false;
1617 ret = sock->ops->bind(sock, (struct sockaddr *)&myaddr,
1626 tcp_sock_set_user_timeout(sock->sk, O2NET_TCP_USER_TIMEOUT);
1779 static int o2net_accept_one(struct socket *sock, int *more)
1791 * sock_create_lite allocates the sock with GFP_KERNEL. We must
1796 BUG_ON(sock == NULL);
1798 ret = sock_create_lite(sock->sk->sk_family, sock->sk->sk_type,
1799 sock->sk->sk_protocol, &new_sock);
1803 new_sock->type = sock->type;
1804 new_sock->ops = sock->ops;
1805 ret = sock->ops->accept(sock, new_sock, O_NONBLOCK, false);
1913 struct socket *sock = o2net_listen_sock;
1929 o2net_accept_one(sock, &more);
1936 static void o2net_listen_data_ready(struct sock *sk)
1938 void (*ready)(struct sock *sk);
1976 struct socket *sock = NULL;
1984 ret = sock_create(PF_INET, SOCK_STREAM, IPPROTO_TCP, &sock);
1990 sock->sk->sk_allocation = GFP_ATOMIC;
1992 write_lock_bh(&sock->sk->sk_callback_lock);
1993 sock->sk->sk_user_data = sock->sk->sk_data_ready;
1994 sock->sk->sk_data_ready = o2net_listen_data_ready;
1995 write_unlock_bh(&sock->sk->sk_callback_lock);
1997 o2net_listen_sock = sock;
2000 sock->sk->sk_reuse = SK_CAN_REUSE;
2001 ret = sock->ops->bind(sock, (struct sockaddr *)&sin, sizeof(sin));
2008 ret = sock->ops->listen(sock, 64);
2016 if (sock)
2017 sock_release(sock);
2058 struct socket *sock = o2net_listen_sock;
2065 write_lock_bh(&sock->sk->sk_callback_lock);
2066 sock->sk->sk_data_ready = sock->sk->sk_user_data;
2067 sock->sk->sk_user_data = NULL;
2068 write_unlock_bh(&sock->sk->sk_callback_lock);