481 static int drbd_recv_short(struct socket *sock, void *buf, size_t size, int flags)  in drbd_recv_short()
497 	rv = drbd_recv_short(connection->data.socket, buf, size, 0);  in drbd_recv()
554 static void drbd_setbufsize(struct socket *sock, unsigned int snd,  in drbd_setbufsize()
568 static struct socket *drbd_try_connect(struct drbd_connection *connection)  in drbd_try_connect()
571 	struct socket *sock;  in drbd_try_connect()
658 	struct socket *s_listen;
679 	struct socket *s_listen;  in prepare_listen_socket()
746 static struct socket *drbd_wait_for_connect(struct drbd_connection *connection, struct accept_wait_…  in drbd_wait_for_connect()
749 	struct socket *s_estab = NULL;  in drbd_wait_for_connect()
793 static int receive_first_packet(struct drbd_connection *connection, struct socket *sock)  in receive_first_packet()
825 static bool drbd_socket_okay(struct socket **sock)  in drbd_socket_okay()
845 				   struct socket **sock1,  in connection_established()
846 				   struct socket **sock2)  in connection_established()
923 	sock.socket = NULL;  in conn_connect()
927 	msock.socket = NULL;  in conn_connect()
936 		struct socket *s;  in conn_connect()
940 			if (!sock.socket) {  in conn_connect()
941 				sock.socket = s;  in conn_connect()
943 			} else if (!msock.socket) {  in conn_connect()
945 				msock.socket = s;  in conn_connect()
953 		if (connection_established(connection, &sock.socket, &msock.socket))  in conn_connect()
960 			drbd_socket_okay(&sock.socket);  in conn_connect()
961 			drbd_socket_okay(&msock.socket);  in conn_connect()
964 				if (sock.socket) {  in conn_connect()
966 					sock_release(sock.socket);  in conn_connect()
967 					sock.socket = s;  in conn_connect()
970 				sock.socket = s;  in conn_connect()
974 				if (msock.socket) {  in conn_connect()
976 					sock_release(msock.socket);  in conn_connect()
977 					msock.socket = s;  in conn_connect()
980 				msock.socket = s;  in conn_connect()
1000 		ok = connection_established(connection, &sock.socket, &msock.socket);  in conn_connect()
1006 	sock.socket->sk->sk_reuse = SK_CAN_REUSE; /* SO_REUSEADDR */  in conn_connect()
1007 	msock.socket->sk->sk_reuse = SK_CAN_REUSE; /* SO_REUSEADDR */  in conn_connect()
1009 	sock.socket->sk->sk_allocation = GFP_NOIO;  in conn_connect()
1010 	msock.socket->sk->sk_allocation = GFP_NOIO;  in conn_connect()
1012 	sock.socket->sk->sk_priority = TC_PRIO_INTERACTIVE_BULK;  in conn_connect()
1013 	msock.socket->sk->sk_priority = TC_PRIO_INTERACTIVE;  in conn_connect()
1023 	sock.socket->sk->sk_sndtimeo =  in conn_connect()
1024 	sock.socket->sk->sk_rcvtimeo = nc->ping_timeo*4*HZ/10;  in conn_connect()
1026 	msock.socket->sk->sk_rcvtimeo = nc->ping_int*HZ;  in conn_connect()
1031 	msock.socket->sk->sk_sndtimeo = timeout;  in conn_connect()
1035 	drbd_tcp_nodelay(sock.socket);  in conn_connect()
1036 	drbd_tcp_nodelay(msock.socket);  in conn_connect()
1038 	connection->data.socket = sock.socket;  in conn_connect()
1039 	connection->meta.socket = msock.socket;  in conn_connect()
1058 	connection->data.socket->sk->sk_sndtimeo = timeout;  in conn_connect()
1059 	connection->data.socket->sk->sk_rcvtimeo = MAX_SCHEDULE_TIMEOUT;  in conn_connect()
1117 	if (sock.socket)  in conn_connect()
1118 		sock_release(sock.socket);  in conn_connect()
1119 	if (msock.socket)  in conn_connect()
1120 		sock_release(msock.socket);  in conn_connect()
4533 	drbd_tcp_quickack(connection->data.socket);  in receive_UnplugRemote()
5154 	connection->meta.socket->sk->sk_rcvtimeo = connection->net_conf->ping_int*HZ;  in got_PingAck()
5530 			connection->meta.socket->sk->sk_rcvtimeo = ping_timeo * HZ / 10;  in drbd_asender()
5537 			drbd_tcp_cork(connection->meta.socket);  in drbd_asender()
5544 			drbd_tcp_uncork(connection->meta.socket);  in drbd_asender()
5550 		rv = drbd_recv_short(connection->meta.socket, buf, expect-received, 0);  in drbd_asender()
5588 				jiffies - connection->meta.socket->sk->sk_rcvtimeo))  in drbd_asender()
5632 				connection->meta.socket->sk->sk_rcvtimeo = ping_int * HZ;  in drbd_asender()
5643 		rv = drbd_recv_short(connection->meta.socket, buf, expect-received, MSG_DONTWAIT);  in drbd_asender()