35 void nr_init_timers(struct sock *sk)  in nr_init_timers()  argument
37 	struct nr_sock *nr = nr_sk(sk);  in nr_init_timers()
45 	sk->sk_timer.function = nr_heartbeat_expiry;  in nr_init_timers()
48 void nr_start_t1timer(struct sock *sk)  in nr_start_t1timer()  argument
50 	struct nr_sock *nr = nr_sk(sk);  in nr_start_t1timer()
52 	sk_reset_timer(sk, &nr->t1timer, jiffies + nr->t1);  in nr_start_t1timer()
55 void nr_start_t2timer(struct sock *sk)  in nr_start_t2timer()  argument
57 	struct nr_sock *nr = nr_sk(sk);  in nr_start_t2timer()
59 	sk_reset_timer(sk, &nr->t2timer, jiffies + nr->t2);  in nr_start_t2timer()
62 void nr_start_t4timer(struct sock *sk)  in nr_start_t4timer()  argument
64 	struct nr_sock *nr = nr_sk(sk);  in nr_start_t4timer()
66 	sk_reset_timer(sk, &nr->t4timer, jiffies + nr->t4);  in nr_start_t4timer()
69 void nr_start_idletimer(struct sock *sk)  in nr_start_idletimer()  argument
71 	struct nr_sock *nr = nr_sk(sk);  in nr_start_idletimer()
74 		sk_reset_timer(sk, &nr->idletimer, jiffies + nr->idle);  in nr_start_idletimer()
77 void nr_start_heartbeat(struct sock *sk)  in nr_start_heartbeat()  argument
79 	sk_reset_timer(sk, &sk->sk_timer, jiffies + 5 * HZ);  in nr_start_heartbeat()
82 void nr_stop_t1timer(struct sock *sk)  in nr_stop_t1timer()  argument
84 	sk_stop_timer(sk, &nr_sk(sk)->t1timer);  in nr_stop_t1timer()
87 void nr_stop_t2timer(struct sock *sk)  in nr_stop_t2timer()  argument
89 	sk_stop_timer(sk, &nr_sk(sk)->t2timer);  in nr_stop_t2timer()
92 void nr_stop_t4timer(struct sock *sk)  in nr_stop_t4timer()  argument
94 	sk_stop_timer(sk, &nr_sk(sk)->t4timer);  in nr_stop_t4timer()
97 void nr_stop_idletimer(struct sock *sk)  in nr_stop_idletimer()  argument
99 	sk_stop_timer(sk, &nr_sk(sk)->idletimer);  in nr_stop_idletimer()
102 void nr_stop_heartbeat(struct sock *sk)  in nr_stop_heartbeat()  argument
104 	sk_stop_timer(sk, &sk->sk_timer);  in nr_stop_heartbeat()
107 int nr_t1timer_running(struct sock *sk)  in nr_t1timer_running()  argument
109 	return timer_pending(&nr_sk(sk)->t1timer);  in nr_t1timer_running()
114 	struct sock *sk = from_timer(sk, t, sk_timer);  in nr_heartbeat_expiry()  local
115 	struct nr_sock *nr = nr_sk(sk);  in nr_heartbeat_expiry()
117 	bh_lock_sock(sk);  in nr_heartbeat_expiry()
122 		if (sock_flag(sk, SOCK_DESTROY) ||  in nr_heartbeat_expiry()
123 		    (sk->sk_state == TCP_LISTEN && sock_flag(sk, SOCK_DEAD))) {  in nr_heartbeat_expiry()
124 			if (sk->sk_state == TCP_LISTEN)  in nr_heartbeat_expiry()
125 				sock_hold(sk);  in nr_heartbeat_expiry()
126 			bh_unlock_sock(sk);  in nr_heartbeat_expiry()
127 			nr_destroy_socket(sk);  in nr_heartbeat_expiry()
136 		if (atomic_read(&sk->sk_rmem_alloc) < (sk->sk_rcvbuf / 2) &&  in nr_heartbeat_expiry()
141 			nr_write_internal(sk, NR_INFOACK);  in nr_heartbeat_expiry()
147 	nr_start_heartbeat(sk);  in nr_heartbeat_expiry()
148 	bh_unlock_sock(sk);  in nr_heartbeat_expiry()
150 	sock_put(sk);  in nr_heartbeat_expiry()
156 	struct sock *sk = &nr->sock;  in nr_t2timer_expiry()  local
158 	bh_lock_sock(sk);  in nr_t2timer_expiry()
161 		nr_enquiry_response(sk);  in nr_t2timer_expiry()
163 	bh_unlock_sock(sk);  in nr_t2timer_expiry()
164 	sock_put(sk);  in nr_t2timer_expiry()
170 	struct sock *sk = &nr->sock;  in nr_t4timer_expiry()  local
172 	bh_lock_sock(sk);  in nr_t4timer_expiry()
173 	nr_sk(sk)->condition &= ~NR_COND_PEER_RX_BUSY;  in nr_t4timer_expiry()
174 	bh_unlock_sock(sk);  in nr_t4timer_expiry()
175 	sock_put(sk);  in nr_t4timer_expiry()
181 	struct sock *sk = &nr->sock;  in nr_idletimer_expiry()  local
183 	bh_lock_sock(sk);  in nr_idletimer_expiry()
185 	nr_clear_queues(sk);  in nr_idletimer_expiry()
188 	nr_write_internal(sk, NR_DISCREQ);  in nr_idletimer_expiry()
191 	nr_start_t1timer(sk);  in nr_idletimer_expiry()
192 	nr_stop_t2timer(sk);  in nr_idletimer_expiry()
193 	nr_stop_t4timer(sk);  in nr_idletimer_expiry()
195 	sk->sk_state     = TCP_CLOSE;  in nr_idletimer_expiry()
196 	sk->sk_err       = 0;  in nr_idletimer_expiry()
197 	sk->sk_shutdown |= SEND_SHUTDOWN;  in nr_idletimer_expiry()
199 	if (!sock_flag(sk, SOCK_DEAD)) {  in nr_idletimer_expiry()
200 		sk->sk_state_change(sk);  in nr_idletimer_expiry()
201 		sock_set_flag(sk, SOCK_DEAD);  in nr_idletimer_expiry()
203 	bh_unlock_sock(sk);  in nr_idletimer_expiry()
204 	sock_put(sk);  in nr_idletimer_expiry()
210 	struct sock *sk = &nr->sock;  in nr_t1timer_expiry()  local
212 	bh_lock_sock(sk);  in nr_t1timer_expiry()
216 			nr_disconnect(sk, ETIMEDOUT);  in nr_t1timer_expiry()
220 			nr_write_internal(sk, NR_CONNREQ);  in nr_t1timer_expiry()
226 			nr_disconnect(sk, ETIMEDOUT);  in nr_t1timer_expiry()
230 			nr_write_internal(sk, NR_DISCREQ);  in nr_t1timer_expiry()
236 			nr_disconnect(sk, ETIMEDOUT);  in nr_t1timer_expiry()
240 			nr_requeue_frames(sk);  in nr_t1timer_expiry()
245 	nr_start_t1timer(sk);  in nr_t1timer_expiry()
247 	bh_unlock_sock(sk);  in nr_t1timer_expiry()
248 	sock_put(sk);  in nr_t1timer_expiry()