99 	struct socket *sock;	/* NULL if not connected */  member
261 static void lowcomms_data_ready(struct sock *sk, int count_unused)  in lowcomms_data_ready()
268 static void lowcomms_write_space(struct sock *sk)  in lowcomms_write_space()
282 static void lowcomms_state_change(struct sock *sk)  in lowcomms_state_change()
289 static int add_sock(struct socket *sock, struct connection *con)  in add_sock()  argument
291 	con->sock = sock;  in add_sock()
294 	con->sock->sk->sk_data_ready = lowcomms_data_ready;  in add_sock()
295 	con->sock->sk->sk_write_space = lowcomms_write_space;  in add_sock()
296 	con->sock->sk->sk_state_change = lowcomms_state_change;  in add_sock()
297 	con->sock->sk->sk_user_data = con;  in add_sock()
298 	con->sock->sk->sk_allocation = GFP_NOFS;  in add_sock()
326 	if (con->sock) {  in close_connection()
327 		sock_release(con->sock);  in close_connection()
328 		con->sock = NULL;  in close_connection()
373 	ret = kernel_sendmsg(con->sock, &outmessage, NULL, 0, 0);  in sctp_send_shutdown()
438 			ret = kernel_getsockopt(con->sock,  in process_sctp_notification()
473 			ret = kernel_getsockopt(con->sock, IPPROTO_SCTP,  in process_sctp_notification()
482 			new_con->sock = SOCKET_I(file->f_dentry->d_inode);  in process_sctp_notification()
483 			add_sock(new_con->sock, new_con);  in process_sctp_notification()
544 	if (con->sock == NULL) {  in receive_from_sock()
586 	r = ret = kernel_recvmsg(con->sock, &msg, iov, nvec, len,  in receive_from_sock()
669 	if (con->sock == NULL)  in tcp_accept_from_sock()
672 	newsock->type = con->sock->type;  in tcp_accept_from_sock()
673 	newsock->ops = con->sock->ops;  in tcp_accept_from_sock()
675 	result = con->sock->ops->accept(con->sock, newsock, O_NONBLOCK);  in tcp_accept_from_sock()
709 	if (newcon->sock) {  in tcp_accept_from_sock()
727 		if (!othercon->sock) {  in tcp_accept_from_sock()
729 			othercon->sock = newsock;  in tcp_accept_from_sock()
841 	ret = kernel_sendmsg(base_con->sock, &outmessage, iov, 1, len);  in sctp_init_assoc()
869 	struct socket *sock;  in tcp_connect_to_sock()  local
881 	if (con->sock) {  in tcp_connect_to_sock()
888 				  IPPROTO_TCP, &sock);  in tcp_connect_to_sock()
894 		sock_release(sock);  in tcp_connect_to_sock()
898 	sock->sk->sk_user_data = con;  in tcp_connect_to_sock()
901 	add_sock(sock, con);  in tcp_connect_to_sock()
907 	result = sock->ops->bind(sock, (struct sockaddr *) &src_addr,  in tcp_connect_to_sock()
918 		sock->ops->connect(sock, (struct sockaddr *)&saddr, addr_len,  in tcp_connect_to_sock()
926 	if (con->sock) {  in tcp_connect_to_sock()
927 		sock_release(con->sock);  in tcp_connect_to_sock()
928 		con->sock = NULL;  in tcp_connect_to_sock()
948 	struct socket *sock = NULL;  in tcp_create_listen_sock()  local
960 				  IPPROTO_TCP, &sock);  in tcp_create_listen_sock()
966 	result = kernel_setsockopt(sock, SOL_SOCKET, SO_REUSEADDR,  in tcp_create_listen_sock()
972 	sock->sk->sk_user_data = con;  in tcp_create_listen_sock()
975 	con->sock = sock;  in tcp_create_listen_sock()
979 	result = sock->ops->bind(sock, (struct sockaddr *) saddr, addr_len);  in tcp_create_listen_sock()
982 		sock_release(sock);  in tcp_create_listen_sock()
983 		sock = NULL;  in tcp_create_listen_sock()
984 		con->sock = NULL;  in tcp_create_listen_sock()
987 	result = kernel_setsockopt(sock, SOL_SOCKET, SO_KEEPALIVE,  in tcp_create_listen_sock()
993 	result = sock->ops->listen(sock, 5);  in tcp_create_listen_sock()
996 		sock_release(sock);  in tcp_create_listen_sock()
997 		sock = NULL;  in tcp_create_listen_sock()
1002 	return sock;  in tcp_create_listen_sock()
1033 		result = kernel_bind(sctp_con->sock,  in add_sctp_bind_addr()
1037 		result = kernel_setsockopt(sctp_con->sock, SOL_SCTP,  in add_sctp_bind_addr()
1051 	struct socket *sock = NULL;  in sctp_listen_for_all()  local
1064 				  IPPROTO_SCTP, &sock);  in sctp_listen_for_all()
1078 	result = kernel_setsockopt(sock, SOL_SOCKET, SO_RCVBUFFORCE,  in sctp_listen_for_all()
1083 	result = kernel_setsockopt(sock, SOL_SCTP, SCTP_EVENTS,  in sctp_listen_for_all()
1092 	sock->sk->sk_user_data = con;  in sctp_listen_for_all()
1093 	con->sock = sock;  in sctp_listen_for_all()
1094 	con->sock->sk->sk_data_ready = lowcomms_data_ready;  in sctp_listen_for_all()
1109 	result = sock->ops->listen(sock, 5);  in sctp_listen_for_all()
1118 	sock_release(sock);  in sctp_listen_for_all()
1119 	con->sock = NULL;  in sctp_listen_for_all()
1126 	struct socket *sock = NULL;  in tcp_listen_for_all()  local
1142 	sock = tcp_create_listen_sock(con, dlm_local_addr[0]);  in tcp_listen_for_all()
1143 	if (sock) {  in tcp_listen_for_all()
1144 		add_sock(sock, con);  in tcp_listen_for_all()
1255 	if (con->sock == NULL)  in send_to_sock()
1258 	sendpage = con->sock->ops->sendpage;  in send_to_sock()
1274 			ret = sendpage(con->sock, e->page, offset, len,  in send_to_sock()
1422 			if (con->sock)  in dlm_lowcomms_stop()
1423 				con->sock->sk->sk_user_data = NULL;  in dlm_lowcomms_stop()