480 static int drbd_recv_short(struct socket *sock, void *buf, size_t size, int flags)  in drbd_recv_short()
496 	rv = drbd_recv_short(connection->data.socket, buf, size, 0);  in drbd_recv()
553 static void drbd_setbufsize(struct socket *sock, unsigned int snd,  in drbd_setbufsize()
567 static struct socket *drbd_try_connect(struct drbd_connection *connection)  in drbd_try_connect()
570 	struct socket *sock;  in drbd_try_connect()
657 	struct socket *s_listen;
678 	struct socket *s_listen;  in prepare_listen_socket()
745 static struct socket *drbd_wait_for_connect(struct drbd_connection *connection, struct accept_wait_…  in drbd_wait_for_connect()
748 	struct socket *s_estab = NULL;  in drbd_wait_for_connect()
792 static int receive_first_packet(struct drbd_connection *connection, struct socket *sock)  in receive_first_packet()
824 static bool drbd_socket_okay(struct socket **sock)  in drbd_socket_okay()
844 				   struct socket **sock1,  in connection_established()
845 				   struct socket **sock2)  in connection_established()
922 	sock.socket = NULL;  in conn_connect()
926 	msock.socket = NULL;  in conn_connect()
935 		struct socket *s;  in conn_connect()
939 			if (!sock.socket) {  in conn_connect()
940 				sock.socket = s;  in conn_connect()
942 			} else if (!msock.socket) {  in conn_connect()
944 				msock.socket = s;  in conn_connect()
952 		if (connection_established(connection, &sock.socket, &msock.socket))  in conn_connect()
959 			drbd_socket_okay(&sock.socket);  in conn_connect()
960 			drbd_socket_okay(&msock.socket);  in conn_connect()
963 				if (sock.socket) {  in conn_connect()
965 					sock_release(sock.socket);  in conn_connect()
966 					sock.socket = s;  in conn_connect()
969 				sock.socket = s;  in conn_connect()
973 				if (msock.socket) {  in conn_connect()
975 					sock_release(msock.socket);  in conn_connect()
976 					msock.socket = s;  in conn_connect()
979 				msock.socket = s;  in conn_connect()
999 		ok = connection_established(connection, &sock.socket, &msock.socket);  in conn_connect()
1005 	sock.socket->sk->sk_reuse = SK_CAN_REUSE; /* SO_REUSEADDR */  in conn_connect()
1006 	msock.socket->sk->sk_reuse = SK_CAN_REUSE; /* SO_REUSEADDR */  in conn_connect()
1008 	sock.socket->sk->sk_allocation = GFP_NOIO;  in conn_connect()
1009 	msock.socket->sk->sk_allocation = GFP_NOIO;  in conn_connect()
1011 	sock.socket->sk->sk_priority = TC_PRIO_INTERACTIVE_BULK;  in conn_connect()
1012 	msock.socket->sk->sk_priority = TC_PRIO_INTERACTIVE;  in conn_connect()
1022 	sock.socket->sk->sk_sndtimeo =  in conn_connect()
1023 	sock.socket->sk->sk_rcvtimeo = nc->ping_timeo*4*HZ/10;  in conn_connect()
1025 	msock.socket->sk->sk_rcvtimeo = nc->ping_int*HZ;  in conn_connect()
1030 	msock.socket->sk->sk_sndtimeo = timeout;  in conn_connect()
1034 	drbd_tcp_nodelay(sock.socket);  in conn_connect()
1035 	drbd_tcp_nodelay(msock.socket);  in conn_connect()
1037 	connection->data.socket = sock.socket;  in conn_connect()
1038 	connection->meta.socket = msock.socket;  in conn_connect()
1057 	connection->data.socket->sk->sk_sndtimeo = timeout;  in conn_connect()
1058 	connection->data.socket->sk->sk_rcvtimeo = MAX_SCHEDULE_TIMEOUT;  in conn_connect()
1116 	if (sock.socket)  in conn_connect()
1117 		sock_release(sock.socket);  in conn_connect()
1118 	if (msock.socket)  in conn_connect()
1119 		sock_release(msock.socket);  in conn_connect()
4532 	drbd_tcp_quickack(connection->data.socket);  in receive_UnplugRemote()
5153 	connection->meta.socket->sk->sk_rcvtimeo = connection->net_conf->ping_int*HZ;  in got_PingAck()
5529 			connection->meta.socket->sk->sk_rcvtimeo = ping_timeo * HZ / 10;  in drbd_asender()
5536 			drbd_tcp_cork(connection->meta.socket);  in drbd_asender()
5543 			drbd_tcp_uncork(connection->meta.socket);  in drbd_asender()
5549 		rv = drbd_recv_short(connection->meta.socket, buf, expect-received, 0);  in drbd_asender()
5587 				jiffies - connection->meta.socket->sk->sk_rcvtimeo))  in drbd_asender()
5631 				connection->meta.socket->sk->sk_rcvtimeo = ping_int * HZ;  in drbd_asender()
5642 		rv = drbd_recv_short(connection->meta.socket, buf, expect-received, MSG_DONTWAIT);  in drbd_asender()