Lines Matching refs:sk
42 struct sock *sk; in smc_close_cleanup_listen() local
45 while ((sk = smc_accept_dequeue(parent, NULL))) in smc_close_cleanup_listen()
46 smc_close_non_accepted(sk); in smc_close_cleanup_listen()
53 struct sock *sk = &smc->sk; in smc_close_stream_wait() local
62 add_wait_queue(sk_sleep(sk), &wait); in smc_close_stream_wait()
66 rc = sk_wait_event(sk, &timeout, in smc_close_stream_wait()
68 (sk->sk_err == ECONNABORTED) || in smc_close_stream_wait()
69 (sk->sk_err == ECONNRESET), in smc_close_stream_wait()
74 remove_wait_queue(sk_sleep(sk), &wait); in smc_close_stream_wait()
82 smc->sk.sk_state_change(&smc->sk); in smc_close_wake_tx_prepared()
114 struct sock *sk = &smc->sk; in smc_close_active_abort() local
119 if (sk->sk_state != SMC_INIT && smc->clcsock && smc->clcsock->sk) { in smc_close_active_abort()
120 sk->sk_err = ECONNABORTED; in smc_close_active_abort()
121 if (smc->clcsock && smc->clcsock->sk) { in smc_close_active_abort()
122 smc->clcsock->sk->sk_err = ECONNABORTED; in smc_close_active_abort()
123 smc->clcsock->sk->sk_state_change(smc->clcsock->sk); in smc_close_active_abort()
126 switch (sk->sk_state) { in smc_close_active_abort()
128 sk->sk_state = SMC_PEERABORTWAIT; in smc_close_active_abort()
129 release_sock(sk); in smc_close_active_abort()
131 lock_sock(sk); in smc_close_active_abort()
132 sock_put(sk); /* passive closing */ in smc_close_active_abort()
137 sk->sk_state = SMC_PEERABORTWAIT; in smc_close_active_abort()
139 sk->sk_state = SMC_CLOSED; in smc_close_active_abort()
140 release_sock(sk); in smc_close_active_abort()
142 lock_sock(sk); in smc_close_active_abort()
148 sk->sk_state = SMC_PEERABORTWAIT; in smc_close_active_abort()
150 sk->sk_state = SMC_CLOSED; in smc_close_active_abort()
152 sock_put(sk); /* passive closing */ in smc_close_active_abort()
156 sk->sk_state = SMC_CLOSED; in smc_close_active_abort()
159 sock_put(sk); /* passive closing */ in smc_close_active_abort()
167 sock_set_flag(sk, SOCK_DEAD); in smc_close_active_abort()
168 sk->sk_state_change(sk); in smc_close_active_abort()
182 struct sock *sk = &smc->sk; in smc_close_active() local
188 0 : sock_flag(sk, SOCK_LINGER) ? in smc_close_active()
189 sk->sk_lingertime : SMC_MAX_STREAM_WAIT_TIMEOUT; in smc_close_active()
191 old_state = sk->sk_state; in smc_close_active()
193 switch (sk->sk_state) { in smc_close_active()
195 sk->sk_state = SMC_CLOSED; in smc_close_active()
198 sk->sk_state = SMC_CLOSED; in smc_close_active()
199 sk->sk_state_change(sk); /* wake up accept */ in smc_close_active()
200 if (smc->clcsock && smc->clcsock->sk) { in smc_close_active()
203 smc->clcsock->sk->sk_data_ready(smc->clcsock->sk); in smc_close_active()
205 smc_close_cleanup_listen(sk); in smc_close_active()
206 release_sock(sk); in smc_close_active()
208 lock_sock(sk); in smc_close_active()
212 release_sock(sk); in smc_close_active()
214 lock_sock(sk); in smc_close_active()
215 if (sk->sk_state == SMC_ACTIVE) { in smc_close_active()
220 sk->sk_state = SMC_PEERCLOSEWAIT1; in smc_close_active()
235 sk->sk_state = SMC_CLOSED; in smc_close_active()
241 release_sock(sk); in smc_close_active()
243 lock_sock(sk); in smc_close_active()
244 if (sk->sk_state != SMC_APPCLOSEWAIT1 && in smc_close_active()
245 sk->sk_state != SMC_APPCLOSEWAIT2) in smc_close_active()
253 sk->sk_state = SMC_CLOSED; in smc_close_active()
254 sock_put(sk); /* postponed passive closing */ in smc_close_active()
257 sk->sk_state = SMC_PEERFINCLOSEWAIT; in smc_close_active()
276 sk->sk_state = SMC_CLOSED; in smc_close_active()
284 if (old_state != sk->sk_state) in smc_close_active()
285 sk->sk_state_change(sk); in smc_close_active()
293 struct sock *sk = &smc->sk; in smc_close_passive_abort_received() local
295 switch (sk->sk_state) { in smc_close_passive_abort_received()
299 sk->sk_state = SMC_PROCESSABORT; in smc_close_passive_abort_received()
300 sock_put(sk); /* passive closing */ in smc_close_passive_abort_received()
303 sk->sk_state = SMC_PROCESSABORT; in smc_close_passive_abort_received()
310 sk->sk_state = SMC_PROCESSABORT; in smc_close_passive_abort_received()
312 sk->sk_state = SMC_CLOSED; in smc_close_passive_abort_received()
313 sock_put(sk); /* passive closing */ in smc_close_passive_abort_received()
317 sk->sk_state = SMC_CLOSED; in smc_close_passive_abort_received()
318 sock_put(sk); /* passive closing */ in smc_close_passive_abort_received()
321 sk->sk_state = SMC_CLOSED; in smc_close_passive_abort_received()
341 struct sock *sk = &smc->sk; in smc_close_passive_work() local
344 lock_sock(sk); in smc_close_passive_work()
345 old_state = sk->sk_state; in smc_close_passive_work()
357 release_sock(&smc->sk); in smc_close_passive_work()
359 lock_sock(&smc->sk); in smc_close_passive_work()
363 switch (sk->sk_state) { in smc_close_passive_work()
365 sk->sk_state = SMC_APPCLOSEWAIT1; in smc_close_passive_work()
368 sk->sk_state = SMC_APPCLOSEWAIT1; in smc_close_passive_work()
375 sk->sk_state = SMC_PEERCLOSEWAIT2; in smc_close_passive_work()
381 if (sock_flag(sk, SOCK_DEAD) && in smc_close_passive_work()
384 sk->sk_state = SMC_CLOSED; in smc_close_passive_work()
387 sk->sk_state = SMC_APPFINCLOSEWAIT; in smc_close_passive_work()
389 sock_put(sk); /* passive closing */ in smc_close_passive_work()
393 sk->sk_state = SMC_CLOSED; in smc_close_passive_work()
394 sock_put(sk); /* passive closing */ in smc_close_passive_work()
412 sk->sk_data_ready(sk); /* wakeup blocked rcvbuf consumers */ in smc_close_passive_work()
413 sk->sk_write_space(sk); /* wakeup blocked sndbuf producers */ in smc_close_passive_work()
415 if (old_state != sk->sk_state) { in smc_close_passive_work()
416 sk->sk_state_change(sk); in smc_close_passive_work()
417 if ((sk->sk_state == SMC_CLOSED) && in smc_close_passive_work()
418 (sock_flag(sk, SOCK_DEAD) || !sk->sk_socket)) { in smc_close_passive_work()
424 release_sock(sk); in smc_close_passive_work()
427 sock_put(sk); /* sock_hold done by schedulers of close_work */ in smc_close_passive_work()
433 struct sock *sk = &smc->sk; in smc_close_shutdown_write() local
439 0 : sock_flag(sk, SOCK_LINGER) ? in smc_close_shutdown_write()
440 sk->sk_lingertime : SMC_MAX_STREAM_WAIT_TIMEOUT; in smc_close_shutdown_write()
442 old_state = sk->sk_state; in smc_close_shutdown_write()
444 switch (sk->sk_state) { 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_ACTIVE) in smc_close_shutdown_write()
456 sk->sk_state = SMC_PEERCLOSEWAIT1; in smc_close_shutdown_write()
462 release_sock(sk); in smc_close_shutdown_write()
464 lock_sock(sk); in smc_close_shutdown_write()
465 if (sk->sk_state != SMC_APPCLOSEWAIT1) in smc_close_shutdown_write()
471 sk->sk_state = SMC_APPCLOSEWAIT2; in smc_close_shutdown_write()
484 if (old_state != sk->sk_state) in smc_close_shutdown_write()
485 sk->sk_state_change(sk); in smc_close_shutdown_write()