Lines Matching refs:sk
41 struct sock *sk;
44 while ((sk = smc_accept_dequeue(parent, NULL)))
45 smc_close_non_accepted(sk);
52 struct sock *sk = &smc->sk;
64 add_wait_queue(sk_sleep(sk), &wait);
68 rc = sk_wait_event(sk, &timeout,
70 READ_ONCE(sk->sk_err) == ECONNABORTED ||
71 READ_ONCE(sk->sk_err) == ECONNRESET ||
77 remove_wait_queue(sk_sleep(sk), &wait);
85 smc->sk.sk_state_change(&smc->sk);
116 struct sock *sk = &smc->sk;
118 release_sock(sk);
120 sock_put(sk);
122 lock_sock(sk);
130 struct sock *sk = &smc->sk;
133 if (sk->sk_state != SMC_INIT && smc->clcsock && smc->clcsock->sk) {
134 sk->sk_err = ECONNABORTED;
135 if (smc->clcsock && smc->clcsock->sk)
136 tcp_abort(smc->clcsock->sk, ECONNABORTED);
138 switch (sk->sk_state) {
142 sk->sk_state = SMC_PEERABORTWAIT;
144 if (sk->sk_state != SMC_PEERABORTWAIT)
146 sk->sk_state = SMC_CLOSED;
147 sock_put(sk); /* (postponed) passive closing */
152 sk->sk_state = SMC_PEERABORTWAIT;
154 if (sk->sk_state != SMC_PEERABORTWAIT)
156 sk->sk_state = SMC_CLOSED;
159 sock_put(sk); /* passive closing */
163 sk->sk_state = SMC_PEERABORTWAIT;
165 if (sk->sk_state != SMC_PEERABORTWAIT)
167 sk->sk_state = SMC_CLOSED;
177 smc_sock_set_flag(sk, SOCK_DEAD);
178 sk->sk_state_change(sk);
181 release_sock(sk);
183 lock_sock(sk);
198 struct sock *sk = &smc->sk;
205 0 : sock_flag(sk, SOCK_LINGER) ?
206 sk->sk_lingertime : SMC_MAX_STREAM_WAIT_TIMEOUT;
208 old_state = sk->sk_state;
210 switch (sk->sk_state) {
212 sk->sk_state = SMC_CLOSED;
215 sk->sk_state = SMC_CLOSED;
216 sk->sk_state_change(sk); /* wake up accept */
217 if (smc->clcsock && smc->clcsock->sk) {
218 write_lock_bh(&smc->clcsock->sk->sk_callback_lock);
219 smc_clcsock_restore_cb(&smc->clcsock->sk->sk_data_ready,
221 smc->clcsock->sk->sk_user_data = NULL;
222 write_unlock_bh(&smc->clcsock->sk->sk_callback_lock);
225 smc_close_cleanup_listen(sk);
226 release_sock(sk);
228 lock_sock(sk);
232 release_sock(sk);
234 lock_sock(sk);
235 if (sk->sk_state == SMC_ACTIVE) {
238 sk->sk_state = SMC_PEERCLOSEWAIT1;
243 if (smc->clcsock && smc->clcsock->sk) {
260 sk->sk_state = SMC_CLOSED;
266 release_sock(sk);
268 lock_sock(sk);
269 if (sk->sk_state != SMC_APPCLOSEWAIT1 &&
270 sk->sk_state != SMC_APPCLOSEWAIT2)
276 sk->sk_state = SMC_CLOSED;
277 sock_put(sk); /* postponed passive closing */
280 sk->sk_state = SMC_PEERFINCLOSEWAIT;
297 sk->sk_state = SMC_CLOSED;
300 sk->sk_state = SMC_CLOSED;
307 if (old_state != sk->sk_state)
308 sk->sk_state_change(sk);
316 struct sock *sk = &smc->sk;
318 switch (sk->sk_state) {
322 sk->sk_state = SMC_PROCESSABORT;
323 sock_put(sk); /* passive closing */
326 sk->sk_state = SMC_PROCESSABORT;
333 sk->sk_state = SMC_PROCESSABORT;
335 sk->sk_state = SMC_CLOSED;
336 sock_put(sk); /* passive closing */
340 sk->sk_state = SMC_CLOSED;
341 sock_put(sk); /* passive closing */
344 sk->sk_state = SMC_CLOSED;
364 struct sock *sk = &smc->sk;
367 lock_sock(sk);
368 old_state = sk->sk_state;
374 release_sock(sk);
376 lock_sock(sk);
380 switch (sk->sk_state) {
382 sk->sk_state = SMC_APPCLOSEWAIT1;
385 sk->sk_state = SMC_APPCLOSEWAIT1;
392 sk->sk_state = SMC_PEERCLOSEWAIT2;
398 if (sock_flag(sk, SOCK_DEAD) &&
401 sk->sk_state = SMC_CLOSED;
404 sk->sk_state = SMC_APPFINCLOSEWAIT;
406 sock_put(sk); /* passive closing */
410 sk->sk_state = SMC_CLOSED;
411 sock_put(sk); /* passive closing */
429 sk->sk_data_ready(sk); /* wakeup blocked rcvbuf consumers */
430 sk->sk_write_space(sk); /* wakeup blocked sndbuf producers */
432 if (old_state != sk->sk_state) {
433 sk->sk_state_change(sk);
434 if ((sk->sk_state == SMC_CLOSED) &&
435 (sock_flag(sk, SOCK_DEAD) || !sk->sk_socket)) {
441 release_sock(sk);
444 sock_put(sk); /* sock_hold done by schedulers of close_work */
450 struct sock *sk = &smc->sk;
456 0 : sock_flag(sk, SOCK_LINGER) ?
457 sk->sk_lingertime : SMC_MAX_STREAM_WAIT_TIMEOUT;
459 old_state = sk->sk_state;
461 switch (sk->sk_state) {
464 release_sock(sk);
466 lock_sock(sk);
467 if (sk->sk_state != SMC_ACTIVE)
471 sk->sk_state = SMC_PEERCLOSEWAIT1;
477 release_sock(sk);
479 lock_sock(sk);
480 if (sk->sk_state != SMC_APPCLOSEWAIT1)
484 sk->sk_state = SMC_APPCLOSEWAIT2;
497 if (old_state != sk->sk_state)
498 sk->sk_state_change(sk);