30 void sk_stream_write_space(struct sock *sk)  in sk_stream_write_space()  argument
32 	struct socket *sock = sk->sk_socket;  in sk_stream_write_space()
35 	if (sk_stream_is_writeable(sk) && sock) {  in sk_stream_write_space()
39 		wq = rcu_dereference(sk->sk_wq);  in sk_stream_write_space()
43 		if (wq && wq->fasync_list && !(sk->sk_shutdown & SEND_SHUTDOWN))  in sk_stream_write_space()
56 int sk_stream_wait_connect(struct sock *sk, long *timeo_p)  in sk_stream_wait_connect()  argument
63 		int err = sock_error(sk);  in sk_stream_wait_connect()
66 		if ((1 << sk->sk_state) & ~(TCPF_SYN_SENT | TCPF_SYN_RECV))  in sk_stream_wait_connect()
73 		add_wait_queue(sk_sleep(sk), &wait);  in sk_stream_wait_connect()
74 		sk->sk_write_pending++;  in sk_stream_wait_connect()
75 		done = sk_wait_event(sk, timeo_p,  in sk_stream_wait_connect()
76 				     !sk->sk_err &&  in sk_stream_wait_connect()
77 				     !((1 << sk->sk_state) &  in sk_stream_wait_connect()
79 		remove_wait_queue(sk_sleep(sk), &wait);  in sk_stream_wait_connect()
80 		sk->sk_write_pending--;  in sk_stream_wait_connect()
90 static inline int sk_stream_closing(struct sock *sk)  in sk_stream_closing()  argument
92 	return (1 << sk->sk_state) &  in sk_stream_closing()
96 void sk_stream_wait_close(struct sock *sk, long timeout)  in sk_stream_wait_close()  argument
101 		add_wait_queue(sk_sleep(sk), &wait);  in sk_stream_wait_close()
104 			if (sk_wait_event(sk, &timeout, !sk_stream_closing(sk), &wait))  in sk_stream_wait_close()
108 		remove_wait_queue(sk_sleep(sk), &wait);  in sk_stream_wait_close()
118 int sk_stream_wait_memory(struct sock *sk, long *timeo_p)  in sk_stream_wait_memory()  argument
126 	if (sk_stream_memory_free(sk))  in sk_stream_wait_memory()
129 	add_wait_queue(sk_sleep(sk), &wait);  in sk_stream_wait_memory()
132 		sk_set_bit(SOCKWQ_ASYNC_NOSPACE, sk);  in sk_stream_wait_memory()
134 		if (sk->sk_err || (sk->sk_shutdown & SEND_SHUTDOWN))  in sk_stream_wait_memory()
138 				set_bit(SOCK_NOSPACE, &sk->sk_socket->flags);  in sk_stream_wait_memory()
143 		sk_clear_bit(SOCKWQ_ASYNC_NOSPACE, sk);  in sk_stream_wait_memory()
144 		if (sk_stream_memory_free(sk) && !vm_wait)  in sk_stream_wait_memory()
147 		set_bit(SOCK_NOSPACE, &sk->sk_socket->flags);  in sk_stream_wait_memory()
148 		sk->sk_write_pending++;  in sk_stream_wait_memory()
149 		sk_wait_event(sk, &current_timeo, sk->sk_err ||  in sk_stream_wait_memory()
150 						  (sk->sk_shutdown & SEND_SHUTDOWN) ||  in sk_stream_wait_memory()
151 						  (sk_stream_memory_free(sk) &&  in sk_stream_wait_memory()
153 		sk->sk_write_pending--;  in sk_stream_wait_memory()
166 	remove_wait_queue(sk_sleep(sk), &wait);  in sk_stream_wait_memory()
181 int sk_stream_error(struct sock *sk, int flags, int err)  in sk_stream_error()  argument
184 		err = sock_error(sk) ? : -EPIPE;  in sk_stream_error()
191 void sk_stream_kill_queues(struct sock *sk)  in sk_stream_kill_queues()  argument
194 	__skb_queue_purge(&sk->sk_receive_queue);  in sk_stream_kill_queues()
197 	__skb_queue_purge(&sk->sk_error_queue);  in sk_stream_kill_queues()
200 	WARN_ON(!skb_queue_empty(&sk->sk_write_queue));  in sk_stream_kill_queues()
203 	sk_mem_reclaim(sk);  in sk_stream_kill_queues()
205 	WARN_ON(sk->sk_wmem_queued);  in sk_stream_kill_queues()
206 	WARN_ON(sk->sk_forward_alloc);  in sk_stream_kill_queues()