Lines Matching refs:sk
35 void rose_start_heartbeat(struct sock *sk) in rose_start_heartbeat() argument
37 del_timer(&sk->sk_timer); in rose_start_heartbeat()
39 sk->sk_timer.function = rose_heartbeat_expiry; in rose_start_heartbeat()
40 sk->sk_timer.expires = jiffies + 5 * HZ; in rose_start_heartbeat()
42 add_timer(&sk->sk_timer); in rose_start_heartbeat()
45 void rose_start_t1timer(struct sock *sk) in rose_start_t1timer() argument
47 struct rose_sock *rose = rose_sk(sk); in rose_start_t1timer()
57 void rose_start_t2timer(struct sock *sk) in rose_start_t2timer() argument
59 struct rose_sock *rose = rose_sk(sk); in rose_start_t2timer()
69 void rose_start_t3timer(struct sock *sk) in rose_start_t3timer() argument
71 struct rose_sock *rose = rose_sk(sk); in rose_start_t3timer()
81 void rose_start_hbtimer(struct sock *sk) in rose_start_hbtimer() argument
83 struct rose_sock *rose = rose_sk(sk); in rose_start_hbtimer()
93 void rose_start_idletimer(struct sock *sk) in rose_start_idletimer() argument
95 struct rose_sock *rose = rose_sk(sk); in rose_start_idletimer()
107 void rose_stop_heartbeat(struct sock *sk) in rose_stop_heartbeat() argument
109 del_timer(&sk->sk_timer); in rose_stop_heartbeat()
112 void rose_stop_timer(struct sock *sk) in rose_stop_timer() argument
114 del_timer(&rose_sk(sk)->timer); in rose_stop_timer()
117 void rose_stop_idletimer(struct sock *sk) in rose_stop_idletimer() argument
119 del_timer(&rose_sk(sk)->idletimer); in rose_stop_idletimer()
124 struct sock *sk = from_timer(sk, t, sk_timer); in rose_heartbeat_expiry() local
125 struct rose_sock *rose = rose_sk(sk); in rose_heartbeat_expiry()
127 bh_lock_sock(sk); in rose_heartbeat_expiry()
132 if (sock_flag(sk, SOCK_DESTROY) || in rose_heartbeat_expiry()
133 (sk->sk_state == TCP_LISTEN && sock_flag(sk, SOCK_DEAD))) { in rose_heartbeat_expiry()
134 bh_unlock_sock(sk); in rose_heartbeat_expiry()
135 rose_destroy_socket(sk); in rose_heartbeat_expiry()
144 if (atomic_read(&sk->sk_rmem_alloc) < (sk->sk_rcvbuf / 2) && in rose_heartbeat_expiry()
149 rose_write_internal(sk, ROSE_RR); in rose_heartbeat_expiry()
150 rose_stop_timer(sk); /* HB */ in rose_heartbeat_expiry()
156 rose_start_heartbeat(sk); in rose_heartbeat_expiry()
157 bh_unlock_sock(sk); in rose_heartbeat_expiry()
163 struct sock *sk = &rose->sock; in rose_timer_expiry() local
165 bh_lock_sock(sk); in rose_timer_expiry()
169 rose_write_internal(sk, ROSE_CLEAR_REQUEST); in rose_timer_expiry()
171 rose_start_t3timer(sk); in rose_timer_expiry()
176 rose_disconnect(sk, ETIMEDOUT, -1, -1); in rose_timer_expiry()
182 rose_enquiry_response(sk); in rose_timer_expiry()
186 bh_unlock_sock(sk); in rose_timer_expiry()
192 struct sock *sk = &rose->sock; in rose_idletimer_expiry() local
194 bh_lock_sock(sk); in rose_idletimer_expiry()
195 rose_clear_queues(sk); in rose_idletimer_expiry()
197 rose_write_internal(sk, ROSE_CLEAR_REQUEST); in rose_idletimer_expiry()
198 rose_sk(sk)->state = ROSE_STATE_2; in rose_idletimer_expiry()
200 rose_start_t3timer(sk); in rose_idletimer_expiry()
202 sk->sk_state = TCP_CLOSE; in rose_idletimer_expiry()
203 sk->sk_err = 0; in rose_idletimer_expiry()
204 sk->sk_shutdown |= SEND_SHUTDOWN; in rose_idletimer_expiry()
206 if (!sock_flag(sk, SOCK_DEAD)) { in rose_idletimer_expiry()
207 sk->sk_state_change(sk); in rose_idletimer_expiry()
208 sock_set_flag(sk, SOCK_DEAD); in rose_idletimer_expiry()
210 bh_unlock_sock(sk); in rose_idletimer_expiry()