28 void sk_stream_write_space(struct sock *sk)  in sk_stream_write_space()  argument
30 	struct socket *sock = sk->sk_socket;  in sk_stream_write_space()
33 	if (sk_stream_is_writeable(sk) && sock) {  in sk_stream_write_space()
37 		wq = rcu_dereference(sk->sk_wq);  in sk_stream_write_space()
41 		if (wq && wq->fasync_list && !(sk->sk_shutdown & SEND_SHUTDOWN))  in sk_stream_write_space()
55 int sk_stream_wait_connect(struct sock *sk, long *timeo_p)  in sk_stream_wait_connect()  argument
62 		int err = sock_error(sk);  in sk_stream_wait_connect()
65 		if ((1 << sk->sk_state) & ~(TCPF_SYN_SENT | TCPF_SYN_RECV))  in sk_stream_wait_connect()
72 		prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE);  in sk_stream_wait_connect()
73 		sk->sk_write_pending++;  in sk_stream_wait_connect()
74 		done = sk_wait_event(sk, timeo_p,  in sk_stream_wait_connect()
75 				     !sk->sk_err &&  in sk_stream_wait_connect()
76 				     !((1 << sk->sk_state) &  in sk_stream_wait_connect()
78 		finish_wait(sk_sleep(sk), &wait);  in sk_stream_wait_connect()
79 		sk->sk_write_pending--;  in sk_stream_wait_connect()
89 static inline int sk_stream_closing(struct sock *sk)  in sk_stream_closing()  argument
91 	return (1 << sk->sk_state) &  in sk_stream_closing()
95 void sk_stream_wait_close(struct sock *sk, long timeout)  in sk_stream_wait_close()  argument
101 			prepare_to_wait(sk_sleep(sk), &wait,  in sk_stream_wait_close()
103 			if (sk_wait_event(sk, &timeout, !sk_stream_closing(sk)))  in sk_stream_wait_close()
107 		finish_wait(sk_sleep(sk), &wait);  in sk_stream_wait_close()
117 int sk_stream_wait_memory(struct sock *sk, long *timeo_p)  in sk_stream_wait_memory()  argument
125 	if (sk_stream_memory_free(sk))  in sk_stream_wait_memory()
129 		sk_set_bit(SOCKWQ_ASYNC_NOSPACE, sk);  in sk_stream_wait_memory()
131 		prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE);  in sk_stream_wait_memory()
133 		if (sk->sk_err || (sk->sk_shutdown & SEND_SHUTDOWN))  in sk_stream_wait_memory()
137 				set_bit(SOCK_NOSPACE, &sk->sk_socket->flags);  in sk_stream_wait_memory()
142 		sk_clear_bit(SOCKWQ_ASYNC_NOSPACE, sk);  in sk_stream_wait_memory()
143 		if (sk_stream_memory_free(sk) && !vm_wait)  in sk_stream_wait_memory()
146 		set_bit(SOCK_NOSPACE, &sk->sk_socket->flags);  in sk_stream_wait_memory()
147 		sk->sk_write_pending++;  in sk_stream_wait_memory()
148 		sk_wait_event(sk, &current_timeo, sk->sk_err ||  in sk_stream_wait_memory()
149 						  (sk->sk_shutdown & SEND_SHUTDOWN) ||  in sk_stream_wait_memory()
150 						  (sk_stream_memory_free(sk) &&  in sk_stream_wait_memory()
152 		sk->sk_write_pending--;  in sk_stream_wait_memory()
165 	finish_wait(sk_sleep(sk), &wait);  in sk_stream_wait_memory()
180 int sk_stream_error(struct sock *sk, int flags, int err)  in sk_stream_error()  argument
183 		err = sock_error(sk) ? : -EPIPE;  in sk_stream_error()
190 void sk_stream_kill_queues(struct sock *sk)  in sk_stream_kill_queues()  argument
193 	__skb_queue_purge(&sk->sk_receive_queue);  in sk_stream_kill_queues()
196 	__skb_queue_purge(&sk->sk_error_queue);  in sk_stream_kill_queues()
199 	WARN_ON(!skb_queue_empty(&sk->sk_write_queue));  in sk_stream_kill_queues()
202 	sk_mem_reclaim(sk);  in sk_stream_kill_queues()
204 	WARN_ON(sk->sk_wmem_queued);  in sk_stream_kill_queues()
205 	WARN_ON(sk->sk_forward_alloc);  in sk_stream_kill_queues()