26 	struct sock *sk;  in smc_close_cleanup_listen()  local
29 	while ((sk = smc_accept_dequeue(parent, NULL)))  in smc_close_cleanup_listen()
30 		smc_close_non_accepted(sk);  in smc_close_cleanup_listen()
37 	struct sock *sk = &smc->sk;  in smc_close_stream_wait()  local
46 	add_wait_queue(sk_sleep(sk), &wait);  in smc_close_stream_wait()
50 		rc = sk_wait_event(sk, &timeout,  in smc_close_stream_wait()
52 				   (sk->sk_err == ECONNABORTED) ||  in smc_close_stream_wait()
53 				   (sk->sk_err == ECONNRESET),  in smc_close_stream_wait()
58 	remove_wait_queue(sk_sleep(sk), &wait);  in smc_close_stream_wait()
66 		smc->sk.sk_state_change(&smc->sk);  in smc_close_wake_tx_prepared()
98 	struct sock *sk = &smc->sk;  in smc_close_active_abort()  local
103 	if (sk->sk_state != SMC_INIT && smc->clcsock && smc->clcsock->sk) {  in smc_close_active_abort()
104 		sk->sk_err = ECONNABORTED;  in smc_close_active_abort()
105 		if (smc->clcsock && smc->clcsock->sk) {  in smc_close_active_abort()
106 			smc->clcsock->sk->sk_err = ECONNABORTED;  in smc_close_active_abort()
107 			smc->clcsock->sk->sk_state_change(smc->clcsock->sk);  in smc_close_active_abort()
110 	switch (sk->sk_state) {  in smc_close_active_abort()
112 		sk->sk_state = SMC_PEERABORTWAIT;  in smc_close_active_abort()
113 		release_sock(sk);  in smc_close_active_abort()
115 		lock_sock(sk);  in smc_close_active_abort()
116 		sock_put(sk); /* passive closing */  in smc_close_active_abort()
121 			sk->sk_state = SMC_PEERABORTWAIT;  in smc_close_active_abort()
123 			sk->sk_state = SMC_CLOSED;  in smc_close_active_abort()
124 		release_sock(sk);  in smc_close_active_abort()
126 		lock_sock(sk);  in smc_close_active_abort()
132 			sk->sk_state = SMC_PEERABORTWAIT;  in smc_close_active_abort()
134 			sk->sk_state = SMC_CLOSED;  in smc_close_active_abort()
136 		sock_put(sk); /* passive closing */  in smc_close_active_abort()
140 		sk->sk_state = SMC_CLOSED;  in smc_close_active_abort()
143 		sock_put(sk); /* passive closing */  in smc_close_active_abort()
151 	sock_set_flag(sk, SOCK_DEAD);  in smc_close_active_abort()
152 	sk->sk_state_change(sk);  in smc_close_active_abort()
166 	struct sock *sk = &smc->sk;  in smc_close_active()  local
172 		  0 : sock_flag(sk, SOCK_LINGER) ?  in smc_close_active()
173 		      sk->sk_lingertime : SMC_MAX_STREAM_WAIT_TIMEOUT;  in smc_close_active()
175 	old_state = sk->sk_state;  in smc_close_active()
177 	switch (sk->sk_state) {  in smc_close_active()
179 		sk->sk_state = SMC_CLOSED;  in smc_close_active()
182 		sk->sk_state = SMC_CLOSED;  in smc_close_active()
183 		sk->sk_state_change(sk); /* wake up accept */  in smc_close_active()
184 		if (smc->clcsock && smc->clcsock->sk) {  in smc_close_active()
187 			smc->clcsock->sk->sk_data_ready(smc->clcsock->sk);  in smc_close_active()
189 		smc_close_cleanup_listen(sk);  in smc_close_active()
190 		release_sock(sk);  in smc_close_active()
192 		lock_sock(sk);  in smc_close_active()
196 		release_sock(sk);  in smc_close_active()
198 		lock_sock(sk);  in smc_close_active()
199 		if (sk->sk_state == SMC_ACTIVE) {  in smc_close_active()
204 			sk->sk_state = SMC_PEERCLOSEWAIT1;  in smc_close_active()
219 		sk->sk_state = SMC_CLOSED;  in smc_close_active()
225 		release_sock(sk);  in smc_close_active()
227 		lock_sock(sk);  in smc_close_active()
228 		if (sk->sk_state != SMC_APPCLOSEWAIT1 &&  in smc_close_active()
229 		    sk->sk_state != SMC_APPCLOSEWAIT2)  in smc_close_active()
237 			sk->sk_state = SMC_CLOSED;  in smc_close_active()
238 			sock_put(sk); /* postponed passive closing */  in smc_close_active()
241 			sk->sk_state = SMC_PEERFINCLOSEWAIT;  in smc_close_active()
260 		sk->sk_state = SMC_CLOSED;  in smc_close_active()
268 	if (old_state != sk->sk_state)  in smc_close_active()
269 		sk->sk_state_change(sk);  in smc_close_active()
277 	struct sock *sk = &smc->sk;  in smc_close_passive_abort_received()  local
279 	switch (sk->sk_state) {  in smc_close_passive_abort_received()
283 		sk->sk_state = SMC_PROCESSABORT;  in smc_close_passive_abort_received()
284 		sock_put(sk); /* passive closing */  in smc_close_passive_abort_received()
287 		sk->sk_state = SMC_PROCESSABORT;  in smc_close_passive_abort_received()
294 			sk->sk_state = SMC_PROCESSABORT;  in smc_close_passive_abort_received()
296 			sk->sk_state = SMC_CLOSED;  in smc_close_passive_abort_received()
297 		sock_put(sk); /* passive closing */  in smc_close_passive_abort_received()
301 		sk->sk_state = SMC_CLOSED;  in smc_close_passive_abort_received()
302 		sock_put(sk); /* passive closing */  in smc_close_passive_abort_received()
305 		sk->sk_state = SMC_CLOSED;  in smc_close_passive_abort_received()
324 	struct sock *sk = &smc->sk;  in smc_close_passive_work()  local
327 	lock_sock(sk);  in smc_close_passive_work()
328 	old_state = sk->sk_state;  in smc_close_passive_work()
340 		release_sock(&smc->sk);  in smc_close_passive_work()
342 		lock_sock(&smc->sk);  in smc_close_passive_work()
346 	switch (sk->sk_state) {  in smc_close_passive_work()
351 			sk->sk_state = SMC_APPCLOSEWAIT1;  in smc_close_passive_work()
353 			sk->sk_state = SMC_CLOSED;  in smc_close_passive_work()
354 			sock_put(sk); /* passive closing */  in smc_close_passive_work()
358 		sk->sk_state = SMC_APPCLOSEWAIT1;  in smc_close_passive_work()
365 			sk->sk_state = SMC_PEERCLOSEWAIT2;  in smc_close_passive_work()
371 		if (sock_flag(sk, SOCK_DEAD) &&  in smc_close_passive_work()
374 			sk->sk_state = SMC_CLOSED;  in smc_close_passive_work()
377 			sk->sk_state = SMC_APPFINCLOSEWAIT;  in smc_close_passive_work()
379 		sock_put(sk); /* passive closing */  in smc_close_passive_work()
383 			sk->sk_state = SMC_CLOSED;  in smc_close_passive_work()
384 			sock_put(sk); /* passive closing */  in smc_close_passive_work()
402 	sk->sk_data_ready(sk); /* wakeup blocked rcvbuf consumers */  in smc_close_passive_work()
403 	sk->sk_write_space(sk); /* wakeup blocked sndbuf producers */  in smc_close_passive_work()
405 	if (old_state != sk->sk_state) {  in smc_close_passive_work()
406 		sk->sk_state_change(sk);  in smc_close_passive_work()
407 		if ((sk->sk_state == SMC_CLOSED) &&  in smc_close_passive_work()
408 		    (sock_flag(sk, SOCK_DEAD) || !sk->sk_socket))  in smc_close_passive_work()
411 	release_sock(sk);  in smc_close_passive_work()
412 	sock_put(sk); /* sock_hold done by schedulers of close_work */  in smc_close_passive_work()
418 	struct sock *sk = &smc->sk;  in smc_close_shutdown_write()  local
424 		  0 : sock_flag(sk, SOCK_LINGER) ?  in smc_close_shutdown_write()
425 		      sk->sk_lingertime : SMC_MAX_STREAM_WAIT_TIMEOUT;  in smc_close_shutdown_write()
427 	old_state = sk->sk_state;  in smc_close_shutdown_write()
429 	switch (sk->sk_state) {  in smc_close_shutdown_write()
432 		release_sock(sk);  in smc_close_shutdown_write()
434 		lock_sock(sk);  in smc_close_shutdown_write()
435 		if (sk->sk_state != SMC_ACTIVE)  in smc_close_shutdown_write()
441 		sk->sk_state = SMC_PEERCLOSEWAIT1;  in smc_close_shutdown_write()
447 		release_sock(sk);  in smc_close_shutdown_write()
449 		lock_sock(sk);  in smc_close_shutdown_write()
450 		if (sk->sk_state != SMC_APPCLOSEWAIT1)  in smc_close_shutdown_write()
456 		sk->sk_state = SMC_APPCLOSEWAIT2;  in smc_close_shutdown_write()
469 	if (old_state != sk->sk_state)  in smc_close_shutdown_write()
470 		sk->sk_state_change(sk);  in smc_close_shutdown_write()