140 static void o2net_listen_data_ready(struct sock *sk);
600 static void o2net_data_ready(struct sock *sk)  in o2net_data_ready()
602 	void (*ready)(struct sock *sk);  in o2net_data_ready()
620 static void o2net_state_change(struct sock *sk)  in o2net_state_change()
622 	void (*state_change)(struct sock *sk);  in o2net_state_change()
661 static void o2net_register_callbacks(struct sock *sk,  in o2net_register_callbacks()
686 static int o2net_unregister_callbacks(struct sock *sk,  in o2net_unregister_callbacks()
917 static int o2net_recv_tcp_msg(struct socket *sock, void *data, size_t len)  in o2net_recv_tcp_msg()  argument
921 	return kernel_recvmsg(sock, &msg, &vec, 1, len, msg.msg_flags);  in o2net_recv_tcp_msg()
924 static int o2net_send_tcp_msg(struct socket *sock, struct kvec *vec,  in o2net_send_tcp_msg()  argument
930 	if (sock == NULL) {  in o2net_send_tcp_msg()
935 	ret = kernel_sendmsg(sock, &msg, vec, veclen, total);  in o2net_send_tcp_msg()
1159 static int o2net_send_status_magic(struct socket *sock, struct o2net_msg *hdr,  in o2net_send_status_magic()  argument
1178 	return o2net_send_tcp_msg(sock, &vec, 1, sizeof(struct o2net_msg));  in o2net_send_status_magic()
1459 static int o2net_set_nodelay(struct socket *sock)  in o2net_set_nodelay()  argument
1477 	ret = sock->ops->setsockopt(sock, SOL_TCP, TCP_NODELAY,  in o2net_set_nodelay()
1484 static int o2net_set_usertimeout(struct socket *sock)  in o2net_set_usertimeout()  argument
1488 	return kernel_setsockopt(sock, SOL_TCP, TCP_USER_TIMEOUT,  in o2net_set_usertimeout()
1601 	struct socket *sock = NULL;  in o2net_start_connect()  local
1656 	ret = sock_create(PF_INET, SOCK_STREAM, IPPROTO_TCP, &sock);  in o2net_start_connect()
1661 	sc->sc_sock = sock; /* freed by sc_kref_release */  in o2net_start_connect()
1663 	sock->sk->sk_allocation = GFP_ATOMIC;  in o2net_start_connect()
1669 	ret = sock->ops->bind(sock, (struct sockaddr *)&myaddr,  in o2net_start_connect()
1683 	ret = o2net_set_usertimeout(sock);  in o2net_start_connect()
1840 static int o2net_accept_one(struct socket *sock, int *more)  in o2net_accept_one()  argument
1859 	BUG_ON(sock == NULL);  in o2net_accept_one()
1861 	ret = sock_create_lite(sock->sk->sk_family, sock->sk->sk_type,  in o2net_accept_one()
1862 			       sock->sk->sk_protocol, &new_sock);  in o2net_accept_one()
1866 	new_sock->type = sock->type;  in o2net_accept_one()
1867 	new_sock->ops = sock->ops;  in o2net_accept_one()
1868 	ret = sock->ops->accept(sock, new_sock, O_NONBLOCK);  in o2net_accept_one()
1987 	struct socket *sock = o2net_listen_sock;  in o2net_accept_many()  local
2004 		err = o2net_accept_one(sock, &more);  in o2net_accept_many()
2011 static void o2net_listen_data_ready(struct sock *sk)  in o2net_listen_data_ready()
2013 	void (*ready)(struct sock *sk);  in o2net_listen_data_ready()
2049 	struct socket *sock = NULL;  in o2net_open_listening_sock()  local
2057 	ret = sock_create(PF_INET, SOCK_STREAM, IPPROTO_TCP, &sock);  in o2net_open_listening_sock()
2063 	sock->sk->sk_allocation = GFP_ATOMIC;  in o2net_open_listening_sock()
2065 	write_lock_bh(&sock->sk->sk_callback_lock);  in o2net_open_listening_sock()
2066 	sock->sk->sk_user_data = sock->sk->sk_data_ready;  in o2net_open_listening_sock()
2067 	sock->sk->sk_data_ready = o2net_listen_data_ready;  in o2net_open_listening_sock()
2068 	write_unlock_bh(&sock->sk->sk_callback_lock);  in o2net_open_listening_sock()
2070 	o2net_listen_sock = sock;  in o2net_open_listening_sock()
2073 	sock->sk->sk_reuse = SK_CAN_REUSE;  in o2net_open_listening_sock()
2074 	ret = sock->ops->bind(sock, (struct sockaddr *)&sin, sizeof(sin));  in o2net_open_listening_sock()
2081 	ret = sock->ops->listen(sock, 64);  in o2net_open_listening_sock()
2089 		if (sock)  in o2net_open_listening_sock()
2090 			sock_release(sock);  in o2net_open_listening_sock()
2131 	struct socket *sock = o2net_listen_sock;  in o2net_stop_listening()  local
2138 	write_lock_bh(&sock->sk->sk_callback_lock);  in o2net_stop_listening()
2139 	sock->sk->sk_data_ready = sock->sk->sk_user_data;  in o2net_stop_listening()
2140 	sock->sk->sk_user_data = NULL;  in o2net_stop_listening()
2141 	write_unlock_bh(&sock->sk->sk_callback_lock);  in o2net_stop_listening()