104 	struct socket *sock;	/* NULL if not connected */  member
127 	void (*orig_error_report)(struct sock *sk);
406 static void lowcomms_data_ready(struct sock *sk)  in lowcomms_data_ready()
413 static void lowcomms_write_space(struct sock *sk)  in lowcomms_write_space()
420 	clear_bit(SOCK_NOSPACE, &con->sock->flags);  in lowcomms_write_space()
423 		con->sock->sk->sk_write_pending--;  in lowcomms_write_space()
424 		clear_bit(SOCKWQ_ASYNC_NOSPACE, &con->sock->flags);  in lowcomms_write_space()
439 static void lowcomms_state_change(struct sock *sk)  in lowcomms_state_change()
468 static void lowcomms_error_report(struct sock *sk)  in lowcomms_error_report()
506 static void add_sock(struct socket *sock, struct connection *con)  in add_sock()  argument
508 	con->sock = sock;  in add_sock()
511 	con->sock->sk->sk_data_ready = lowcomms_data_ready;  in add_sock()
512 	con->sock->sk->sk_write_space = lowcomms_write_space;  in add_sock()
513 	con->sock->sk->sk_state_change = lowcomms_state_change;  in add_sock()
514 	con->sock->sk->sk_user_data = con;  in add_sock()
515 	con->sock->sk->sk_allocation = GFP_NOFS;  in add_sock()
516 	con->orig_error_report = con->sock->sk->sk_error_report;  in add_sock()
517 	con->sock->sk->sk_error_report = lowcomms_error_report;  in add_sock()
551 	if (con->sock) {  in close_connection()
552 		sock_release(con->sock);  in close_connection()
553 		con->sock = NULL;  in close_connection()
581 	if (con->sock == NULL) {  in receive_from_sock()
622 	r = ret = kernel_recvmsg(con->sock, &msg, iov, nvec, len,  in receive_from_sock()
699 	if (con->sock == NULL)  in tcp_accept_from_sock()
702 	newsock->type = con->sock->type;  in tcp_accept_from_sock()
703 	newsock->ops = con->sock->ops;  in tcp_accept_from_sock()
705 	result = con->sock->ops->accept(con->sock, newsock, O_NONBLOCK);  in tcp_accept_from_sock()
742 	if (newcon->sock) {  in tcp_accept_from_sock()
760 		if (!othercon->sock) {  in tcp_accept_from_sock()
762 			othercon->sock = newsock;  in tcp_accept_from_sock()
823 	ret = kernel_accept(con->sock, &newsock, O_NONBLOCK);  in sctp_accept_from_sock()
855 	if (newcon->sock) {  in sctp_accept_from_sock()
873 		if (!othercon->sock) {  in sctp_accept_from_sock()
875 			othercon->sock = newsock;  in sctp_accept_from_sock()
954 			result = kernel_bind(con->sock,  in sctp_bind_addrs()
958 			result = kernel_setsockopt(con->sock, SOL_SCTP,  in sctp_bind_addrs()
982 	struct socket *sock;  in sctp_connect_to_sock()  local
995 	if (con->sock) {  in sctp_connect_to_sock()
1009 				  SOCK_STREAM, IPPROTO_SCTP, &sock);  in sctp_connect_to_sock()
1013 	sock->sk->sk_user_data = con;  in sctp_connect_to_sock()
1016 	add_sock(sock, con);  in sctp_connect_to_sock()
1027 	kernel_setsockopt(sock, SOL_TCP, TCP_NODELAY, (char *)&one,  in sctp_connect_to_sock()
1030 	result = sock->ops->connect(sock, (struct sockaddr *)&daddr, addr_len,  in sctp_connect_to_sock()
1039 	con->sock = NULL;  in sctp_connect_to_sock()
1040 	sock_release(sock);  in sctp_connect_to_sock()
1071 	struct socket *sock = NULL;  in tcp_connect_to_sock()  local
1085 	if (con->sock)  in tcp_connect_to_sock()
1090 				  SOCK_STREAM, IPPROTO_TCP, &sock);  in tcp_connect_to_sock()
1101 	sock->sk->sk_user_data = con;  in tcp_connect_to_sock()
1104 	add_sock(sock, con);  in tcp_connect_to_sock()
1110 	result = sock->ops->bind(sock, (struct sockaddr *) &src_addr,  in tcp_connect_to_sock()
1122 	kernel_setsockopt(sock, SOL_TCP, TCP_NODELAY, (char *)&one,  in tcp_connect_to_sock()
1125 	result = sock->ops->connect(sock, (struct sockaddr *)&saddr, addr_len,  in tcp_connect_to_sock()
1133 	if (con->sock) {  in tcp_connect_to_sock()
1134 		sock_release(con->sock);  in tcp_connect_to_sock()
1135 		con->sock = NULL;  in tcp_connect_to_sock()
1136 	} else if (sock) {  in tcp_connect_to_sock()
1137 		sock_release(sock);  in tcp_connect_to_sock()
1165 	struct socket *sock = NULL;  in tcp_create_listen_sock()  local
1177 				  SOCK_STREAM, IPPROTO_TCP, &sock);  in tcp_create_listen_sock()
1184 	kernel_setsockopt(sock, SOL_TCP, TCP_NODELAY, (char *)&one,  in tcp_create_listen_sock()
1187 	result = kernel_setsockopt(sock, SOL_SOCKET, SO_REUSEADDR,  in tcp_create_listen_sock()
1198 	result = sock->ops->bind(sock, (struct sockaddr *) saddr, addr_len);  in tcp_create_listen_sock()
1201 		sock_release(sock);  in tcp_create_listen_sock()
1202 		sock = NULL;  in tcp_create_listen_sock()
1203 		con->sock = NULL;  in tcp_create_listen_sock()
1206 	result = kernel_setsockopt(sock, SOL_SOCKET, SO_KEEPALIVE,  in tcp_create_listen_sock()
1212 	result = sock->ops->listen(sock, 5);  in tcp_create_listen_sock()
1215 		sock_release(sock);  in tcp_create_listen_sock()
1216 		sock = NULL;  in tcp_create_listen_sock()
1221 	return sock;  in tcp_create_listen_sock()
1246 	struct socket *sock = NULL;  in sctp_listen_for_all()  local
1258 				  SOCK_STREAM, IPPROTO_SCTP, &sock);  in sctp_listen_for_all()
1264 	result = kernel_setsockopt(sock, SOL_SOCKET, SO_RCVBUFFORCE,  in sctp_listen_for_all()
1269 	result = kernel_setsockopt(sock, SOL_SCTP, SCTP_NODELAY, (char *)&one,  in sctp_listen_for_all()
1275 	sock->sk->sk_user_data = con;  in sctp_listen_for_all()
1276 	con->sock = sock;  in sctp_listen_for_all()
1277 	con->sock->sk->sk_data_ready = lowcomms_data_ready;  in sctp_listen_for_all()
1285 	result = sock->ops->listen(sock, 5);  in sctp_listen_for_all()
1294 	sock_release(sock);  in sctp_listen_for_all()
1295 	con->sock = NULL;  in sctp_listen_for_all()
1302 	struct socket *sock = NULL;  in tcp_listen_for_all()  local
1318 	sock = tcp_create_listen_sock(con, dlm_local_addr[0]);  in tcp_listen_for_all()
1319 	if (sock) {  in tcp_listen_for_all()
1320 		add_sock(sock, con);  in tcp_listen_for_all()
1430 	if (con->sock == NULL)  in send_to_sock()
1447 			ret = kernel_sendpage(con->sock, e->page, offset, len,  in send_to_sock()
1451 				    test_bit(SOCKWQ_ASYNC_NOSPACE, &con->sock->flags) &&  in send_to_sock()
1456 					set_bit(SOCK_NOSPACE, &con->sock->flags);  in send_to_sock()
1457 					con->sock->sk->sk_write_pending++;  in send_to_sock()
1589 	if (con->sock && con->sock->sk)  in stop_conn()
1590 		con->sock->sk->sk_user_data = NULL;  in stop_conn()