Lines Matching defs:sock
85 mlog(ML_SOCKET, "[sc %p refs %d sock %p node %u page %p " \
103 * quorum work is queued as sock containers are shutdown.. stop_listening
104 * tears down all the node's sock containers, preventing future shutdowns
127 static void o2net_listen_data_ready(struct sock *sk);
585 static void o2net_data_ready(struct sock *sk)
587 void (*ready)(struct sock *sk);
606 static void o2net_state_change(struct sock *sk)
608 void (*state_change)(struct sock *sk);
647 static void o2net_register_callbacks(struct sock *sk,
672 static int o2net_unregister_callbacks(struct sock *sk,
901 static int o2net_recv_tcp_msg(struct socket *sock, void *data, size_t len)
906 return sock_recvmsg(sock, &msg, MSG_DONTWAIT);
909 static int o2net_send_tcp_msg(struct socket *sock, struct kvec *vec,
915 if (sock == NULL) {
920 ret = kernel_sendmsg(sock, &msg, vec, veclen, total);
1144 static int o2net_send_status_magic(struct socket *sock, struct o2net_msg *hdr,
1163 return o2net_send_tcp_msg(sock, &vec, 1, sizeof(struct o2net_msg));
1457 /* called when a connect completes and after a sock is accepted. the
1553 struct socket *sock = NULL;
1560 * sock_create allocates the sock with GFP_KERNEL. We must
1602 ret = sock_create(PF_INET, SOCK_STREAM, IPPROTO_TCP, &sock);
1607 sc->sc_sock = sock; /* freed by sc_kref_release */
1609 sock->sk->sk_allocation = GFP_ATOMIC;
1615 ret = sock->ops->bind(sock, (struct sockaddr *)&myaddr,
1624 tcp_sock_set_user_timeout(sock->sk, O2NET_TCP_USER_TIMEOUT);
1777 static int o2net_accept_one(struct socket *sock, int *more)
1789 * sock_create_lite allocates the sock with GFP_KERNEL. We must
1794 BUG_ON(sock == NULL);
1796 ret = sock_create_lite(sock->sk->sk_family, sock->sk->sk_type,
1797 sock->sk->sk_protocol, &new_sock);
1801 new_sock->type = sock->type;
1802 new_sock->ops = sock->ops;
1803 ret = sock->ops->accept(sock, new_sock, O_NONBLOCK, false);
1911 struct socket *sock = o2net_listen_sock;
1927 o2net_accept_one(sock, &more);
1934 static void o2net_listen_data_ready(struct sock *sk)
1936 void (*ready)(struct sock *sk);
1972 struct socket *sock = NULL;
1980 ret = sock_create(PF_INET, SOCK_STREAM, IPPROTO_TCP, &sock);
1986 sock->sk->sk_allocation = GFP_ATOMIC;
1988 write_lock_bh(&sock->sk->sk_callback_lock);
1989 sock->sk->sk_user_data = sock->sk->sk_data_ready;
1990 sock->sk->sk_data_ready = o2net_listen_data_ready;
1991 write_unlock_bh(&sock->sk->sk_callback_lock);
1993 o2net_listen_sock = sock;
1996 sock->sk->sk_reuse = SK_CAN_REUSE;
1997 ret = sock->ops->bind(sock, (struct sockaddr *)&sin, sizeof(sin));
2004 ret = sock->ops->listen(sock, 64);
2012 if (sock)
2013 sock_release(sock);
2054 struct socket *sock = o2net_listen_sock;
2061 write_lock_bh(&sock->sk->sk_callback_lock);
2062 sock->sk->sk_data_ready = sock->sk->sk_user_data;
2063 sock->sk->sk_user_data = NULL;
2064 write_unlock_bh(&sock->sk->sk_callback_lock);