Lines Matching refs:tw

29 void inet_twsk_bind_unhash(struct inet_timewait_sock *tw,  in inet_twsk_bind_unhash()  argument
32 struct inet_bind_bucket *tb = tw->tw_tb; in inet_twsk_bind_unhash()
37 __hlist_del(&tw->tw_bind_node); in inet_twsk_bind_unhash()
38 tw->tw_tb = NULL; in inet_twsk_bind_unhash()
40 __sock_put((struct sock *)tw); in inet_twsk_bind_unhash()
44 static void inet_twsk_kill(struct inet_timewait_sock *tw) in inet_twsk_kill() argument
46 struct inet_hashinfo *hashinfo = tw->tw_dr->hashinfo; in inet_twsk_kill()
47 spinlock_t *lock = inet_ehash_lockp(hashinfo, tw->tw_hash); in inet_twsk_kill()
51 sk_nulls_del_node_init_rcu((struct sock *)tw); in inet_twsk_kill()
55 bhead = &hashinfo->bhash[inet_bhashfn(twsk_net(tw), tw->tw_num, in inet_twsk_kill()
59 inet_twsk_bind_unhash(tw, hashinfo); in inet_twsk_kill()
62 atomic_dec(&tw->tw_dr->tw_count); in inet_twsk_kill()
63 inet_twsk_put(tw); in inet_twsk_kill()
66 void inet_twsk_free(struct inet_timewait_sock *tw) in inet_twsk_free() argument
68 struct module *owner = tw->tw_prot->owner; in inet_twsk_free()
69 twsk_destructor((struct sock *)tw); in inet_twsk_free()
71 pr_debug("%s timewait_sock %p released\n", tw->tw_prot->name, tw); in inet_twsk_free()
73 kmem_cache_free(tw->tw_prot->twsk_prot->twsk_slab, tw); in inet_twsk_free()
77 void inet_twsk_put(struct inet_timewait_sock *tw) in inet_twsk_put() argument
79 if (atomic_dec_and_test(&tw->tw_refcnt)) in inet_twsk_put()
80 inet_twsk_free(tw); in inet_twsk_put()
84 static void inet_twsk_add_node_rcu(struct inet_timewait_sock *tw, in inet_twsk_add_node_rcu() argument
87 hlist_nulls_add_head_rcu(&tw->tw_node, list); in inet_twsk_add_node_rcu()
90 static void inet_twsk_add_bind_node(struct inet_timewait_sock *tw, in inet_twsk_add_bind_node() argument
93 hlist_add_head(&tw->tw_bind_node, list); in inet_twsk_add_bind_node()
101 void __inet_twsk_hashdance(struct inet_timewait_sock *tw, struct sock *sk, in __inet_twsk_hashdance() argument
113 bhead = &hashinfo->bhash[inet_bhashfn(twsk_net(tw), inet->inet_num, in __inet_twsk_hashdance()
116 tw->tw_tb = icsk->icsk_bind_hash; in __inet_twsk_hashdance()
118 inet_twsk_add_bind_node(tw, &tw->tw_tb->owners); in __inet_twsk_hashdance()
134 atomic_set(&tw->tw_refcnt, 4); in __inet_twsk_hashdance()
135 inet_twsk_add_node_rcu(tw, &ehead->chain); in __inet_twsk_hashdance()
147 struct inet_timewait_sock *tw = (struct inet_timewait_sock *)data; in tw_timer_handler() local
149 if (tw->tw_kill) in tw_timer_handler()
150 NET_INC_STATS_BH(twsk_net(tw), LINUX_MIB_TIMEWAITKILLED); in tw_timer_handler()
152 NET_INC_STATS_BH(twsk_net(tw), LINUX_MIB_TIMEWAITED); in tw_timer_handler()
153 inet_twsk_kill(tw); in tw_timer_handler()
160 struct inet_timewait_sock *tw; in inet_twsk_alloc() local
165 tw = kmem_cache_alloc(sk->sk_prot_creator->twsk_prot->twsk_slab, in inet_twsk_alloc()
167 if (tw) { in inet_twsk_alloc()
170 kmemcheck_annotate_bitfield(tw, flags); in inet_twsk_alloc()
172 tw->tw_dr = dr; in inet_twsk_alloc()
174 tw->tw_daddr = inet->inet_daddr; in inet_twsk_alloc()
175 tw->tw_rcv_saddr = inet->inet_rcv_saddr; in inet_twsk_alloc()
176 tw->tw_bound_dev_if = sk->sk_bound_dev_if; in inet_twsk_alloc()
177 tw->tw_tos = inet->tos; in inet_twsk_alloc()
178 tw->tw_num = inet->inet_num; in inet_twsk_alloc()
179 tw->tw_state = TCP_TIME_WAIT; in inet_twsk_alloc()
180 tw->tw_substate = state; in inet_twsk_alloc()
181 tw->tw_sport = inet->inet_sport; in inet_twsk_alloc()
182 tw->tw_dport = inet->inet_dport; in inet_twsk_alloc()
183 tw->tw_family = sk->sk_family; in inet_twsk_alloc()
184 tw->tw_reuse = sk->sk_reuse; in inet_twsk_alloc()
185 tw->tw_hash = sk->sk_hash; in inet_twsk_alloc()
186 tw->tw_ipv6only = 0; in inet_twsk_alloc()
187 tw->tw_transparent = inet->transparent; in inet_twsk_alloc()
188 tw->tw_prot = sk->sk_prot_creator; in inet_twsk_alloc()
189 atomic64_set(&tw->tw_cookie, atomic64_read(&sk->sk_cookie)); in inet_twsk_alloc()
190 twsk_net_set(tw, sock_net(sk)); in inet_twsk_alloc()
191 setup_timer(&tw->tw_timer, tw_timer_handler, (unsigned long)tw); in inet_twsk_alloc()
197 atomic_set(&tw->tw_refcnt, 0); in inet_twsk_alloc()
199 __module_get(tw->tw_prot->owner); in inet_twsk_alloc()
202 return tw; in inet_twsk_alloc()
214 void inet_twsk_deschedule_put(struct inet_timewait_sock *tw) in inet_twsk_deschedule_put() argument
216 if (del_timer_sync(&tw->tw_timer)) in inet_twsk_deschedule_put()
217 inet_twsk_kill(tw); in inet_twsk_deschedule_put()
218 inet_twsk_put(tw); in inet_twsk_deschedule_put()
222 void __inet_twsk_schedule(struct inet_timewait_sock *tw, int timeo, bool rearm) in __inet_twsk_schedule() argument
249 tw->tw_kill = timeo <= 4*HZ; in __inet_twsk_schedule()
251 BUG_ON(mod_timer_pinned(&tw->tw_timer, jiffies + timeo)); in __inet_twsk_schedule()
252 atomic_inc(&tw->tw_dr->tw_count); in __inet_twsk_schedule()
254 mod_timer_pending(&tw->tw_timer, jiffies + timeo); in __inet_twsk_schedule()
262 struct inet_timewait_sock *tw; in inet_twsk_purge() local
276 tw = inet_twsk(sk); in inet_twsk_purge()
277 if ((tw->tw_family != family) || in inet_twsk_purge()
278 atomic_read(&twsk_net(tw)->count)) in inet_twsk_purge()
281 if (unlikely(!atomic_inc_not_zero(&tw->tw_refcnt))) in inet_twsk_purge()
284 if (unlikely((tw->tw_family != family) || in inet_twsk_purge()
285 atomic_read(&twsk_net(tw)->count))) { in inet_twsk_purge()
286 inet_twsk_put(tw); in inet_twsk_purge()
292 inet_twsk_deschedule_put(tw); in inet_twsk_purge()