Lines Matching refs:sk

24 static void dccp_write_err(struct sock *sk)  in dccp_write_err()  argument
26 sk->sk_err = sk->sk_err_soft ? : ETIMEDOUT; in dccp_write_err()
27 sk->sk_error_report(sk); in dccp_write_err()
29 dccp_send_reset(sk, DCCP_RESET_CODE_ABORTED); in dccp_write_err()
30 dccp_done(sk); in dccp_write_err()
35 static int dccp_write_timeout(struct sock *sk) in dccp_write_timeout() argument
37 const struct inet_connection_sock *icsk = inet_csk(sk); in dccp_write_timeout()
40 if (sk->sk_state == DCCP_REQUESTING || sk->sk_state == DCCP_PARTOPEN) { in dccp_write_timeout()
42 dst_negative_advice(sk); in dccp_write_timeout()
67 dst_negative_advice(sk); in dccp_write_timeout()
78 dccp_write_err(sk); in dccp_write_timeout()
87 static void dccp_retransmit_timer(struct sock *sk) in dccp_retransmit_timer() argument
89 struct inet_connection_sock *icsk = inet_csk(sk); in dccp_retransmit_timer()
95 if (dccp_write_timeout(sk)) in dccp_retransmit_timer()
105 if (dccp_retransmit_skb(sk) != 0) { in dccp_retransmit_timer()
112 inet_csk_reset_xmit_timer(sk, ICSK_TIME_RETRANS, in dccp_retransmit_timer()
122 inet_csk_reset_xmit_timer(sk, ICSK_TIME_RETRANS, icsk->icsk_rto, in dccp_retransmit_timer()
125 __sk_dst_reset(sk); in dccp_retransmit_timer()
132 struct sock *sk = &icsk->icsk_inet.sk; in dccp_write_timer() local
135 bh_lock_sock(sk); in dccp_write_timer()
136 if (sock_owned_by_user(sk)) { in dccp_write_timer()
138 sk_reset_timer(sk, &icsk->icsk_retransmit_timer, in dccp_write_timer()
143 if (sk->sk_state == DCCP_CLOSED || !icsk->icsk_pending) in dccp_write_timer()
147 sk_reset_timer(sk, &icsk->icsk_retransmit_timer, in dccp_write_timer()
157 dccp_retransmit_timer(sk); in dccp_write_timer()
161 bh_unlock_sock(sk); in dccp_write_timer()
162 sock_put(sk); in dccp_write_timer()
167 struct sock *sk = from_timer(sk, t, sk_timer); in dccp_keepalive_timer() local
170 sock_put(sk); in dccp_keepalive_timer()
178 struct sock *sk = &icsk->icsk_inet.sk; in dccp_delack_timer() local
180 bh_lock_sock(sk); in dccp_delack_timer()
181 if (sock_owned_by_user(sk)) { in dccp_delack_timer()
184 __NET_INC_STATS(sock_net(sk), LINUX_MIB_DELAYEDACKLOCKED); in dccp_delack_timer()
185 sk_reset_timer(sk, &icsk->icsk_delack_timer, in dccp_delack_timer()
190 if (sk->sk_state == DCCP_CLOSED || in dccp_delack_timer()
194 sk_reset_timer(sk, &icsk->icsk_delack_timer, in dccp_delack_timer()
201 if (inet_csk_ack_scheduled(sk)) { in dccp_delack_timer()
213 dccp_send_ack(sk); in dccp_delack_timer()
214 __NET_INC_STATS(sock_net(sk), LINUX_MIB_DELAYEDACKS); in dccp_delack_timer()
217 bh_unlock_sock(sk); in dccp_delack_timer()
218 sock_put(sk); in dccp_delack_timer()
227 struct sock *sk = (struct sock *)data; in dccp_write_xmitlet() local
229 bh_lock_sock(sk); in dccp_write_xmitlet()
230 if (sock_owned_by_user(sk)) in dccp_write_xmitlet()
231 sk_reset_timer(sk, &dccp_sk(sk)->dccps_xmit_timer, jiffies + 1); in dccp_write_xmitlet()
233 dccp_write_xmit(sk); in dccp_write_xmitlet()
234 bh_unlock_sock(sk); in dccp_write_xmitlet()
235 sock_put(sk); in dccp_write_xmitlet()
241 struct sock *sk = &dp->dccps_inet_connection.icsk_inet.sk; in dccp_write_xmit_timer() local
243 dccp_write_xmitlet((unsigned long)sk); in dccp_write_xmit_timer()
246 void dccp_init_xmit_timers(struct sock *sk) in dccp_init_xmit_timers() argument
248 struct dccp_sock *dp = dccp_sk(sk); in dccp_init_xmit_timers()
250 tasklet_init(&dp->dccps_xmitlet, dccp_write_xmitlet, (unsigned long)sk); in dccp_init_xmit_timers()
252 inet_csk_init_xmit_timers(sk, &dccp_write_timer, &dccp_delack_timer, in dccp_init_xmit_timers()