Lines Matching refs:session
158 static void l2tp_session_free(struct l2tp_session *session) in l2tp_session_free() argument
160 trace_free_session(session); in l2tp_session_free()
161 if (session->tunnel) in l2tp_session_free()
162 l2tp_tunnel_dec_refcount(session->tunnel); in l2tp_session_free()
163 kfree(session); in l2tp_session_free()
191 void l2tp_session_inc_refcount(struct l2tp_session *session) in l2tp_session_inc_refcount() argument
193 refcount_inc(&session->ref_count); in l2tp_session_inc_refcount()
197 void l2tp_session_dec_refcount(struct l2tp_session *session) in l2tp_session_dec_refcount() argument
199 if (refcount_dec_and_test(&session->ref_count)) in l2tp_session_dec_refcount()
200 l2tp_session_free(session); in l2tp_session_dec_refcount()
249 struct l2tp_session *session; in l2tp_tunnel_get_session() local
254 hlist_for_each_entry(session, session_list, hlist) in l2tp_tunnel_get_session()
255 if (session->session_id == session_id) { in l2tp_tunnel_get_session()
256 l2tp_session_inc_refcount(session); in l2tp_tunnel_get_session()
259 return session; in l2tp_tunnel_get_session()
270 struct l2tp_session *session; in l2tp_session_get() local
275 hlist_for_each_entry_rcu(session, session_list, global_hlist) in l2tp_session_get()
276 if (session->session_id == session_id) { in l2tp_session_get()
277 l2tp_session_inc_refcount(session); in l2tp_session_get()
280 return session; in l2tp_session_get()
291 struct l2tp_session *session; in l2tp_session_get_nth() local
296 hlist_for_each_entry(session, &tunnel->session_hlist[hash], hlist) { in l2tp_session_get_nth()
298 l2tp_session_inc_refcount(session); in l2tp_session_get_nth()
300 return session; in l2tp_session_get_nth()
319 struct l2tp_session *session; in l2tp_session_get_by_ifname() local
323 hlist_for_each_entry_rcu(session, &pn->l2tp_session_hlist[hash], global_hlist) { in l2tp_session_get_by_ifname()
324 if (!strcmp(session->ifname, ifname)) { in l2tp_session_get_by_ifname()
325 l2tp_session_inc_refcount(session); in l2tp_session_get_by_ifname()
328 return session; in l2tp_session_get_by_ifname()
339 int l2tp_session_register(struct l2tp_session *session, in l2tp_session_register() argument
348 head = l2tp_session_id_hash(tunnel, session->session_id); in l2tp_session_register()
357 if (session_walk->session_id == session->session_id) { in l2tp_session_register()
364 g_head = l2tp_session_id_hash_2(pn, session->session_id); in l2tp_session_register()
372 if (session_walk->session_id == session->session_id && in l2tp_session_register()
380 hlist_add_head_rcu(&session->global_hlist, g_head); in l2tp_session_register()
387 hlist_add_head(&session->hlist, head); in l2tp_session_register()
390 trace_register_session(session); in l2tp_session_register()
410 static void l2tp_recv_queue_skb(struct l2tp_session *session, struct sk_buff *skb) in l2tp_recv_queue_skb() argument
416 spin_lock_bh(&session->reorder_q.lock); in l2tp_recv_queue_skb()
417 skb_queue_walk_safe(&session->reorder_q, skbp, tmp) { in l2tp_recv_queue_skb()
419 __skb_queue_before(&session->reorder_q, skbp, skb); in l2tp_recv_queue_skb()
420 atomic_long_inc(&session->stats.rx_oos_packets); in l2tp_recv_queue_skb()
425 __skb_queue_tail(&session->reorder_q, skb); in l2tp_recv_queue_skb()
428 spin_unlock_bh(&session->reorder_q.lock); in l2tp_recv_queue_skb()
433 static void l2tp_recv_dequeue_skb(struct l2tp_session *session, struct sk_buff *skb) in l2tp_recv_dequeue_skb() argument
435 struct l2tp_tunnel *tunnel = session->tunnel; in l2tp_recv_dequeue_skb()
445 atomic_long_inc(&session->stats.rx_packets); in l2tp_recv_dequeue_skb()
446 atomic_long_add(length, &session->stats.rx_bytes); in l2tp_recv_dequeue_skb()
450 session->nr++; in l2tp_recv_dequeue_skb()
451 session->nr &= session->nr_max; in l2tp_recv_dequeue_skb()
452 trace_session_seqnum_update(session); in l2tp_recv_dequeue_skb()
456 if (session->recv_skb) in l2tp_recv_dequeue_skb()
457 (*session->recv_skb)(session, skb, L2TP_SKB_CB(skb)->length); in l2tp_recv_dequeue_skb()
465 static void l2tp_recv_dequeue(struct l2tp_session *session) in l2tp_recv_dequeue() argument
475 spin_lock_bh(&session->reorder_q.lock); in l2tp_recv_dequeue()
476 skb_queue_walk_safe(&session->reorder_q, skb, tmp) { in l2tp_recv_dequeue()
481 atomic_long_inc(&session->stats.rx_seq_discards); in l2tp_recv_dequeue()
482 atomic_long_inc(&session->stats.rx_errors); in l2tp_recv_dequeue()
483 trace_session_pkt_expired(session, cb->ns); in l2tp_recv_dequeue()
484 session->reorder_skip = 1; in l2tp_recv_dequeue()
485 __skb_unlink(skb, &session->reorder_q); in l2tp_recv_dequeue()
491 if (session->reorder_skip) { in l2tp_recv_dequeue()
492 session->reorder_skip = 0; in l2tp_recv_dequeue()
493 session->nr = cb->ns; in l2tp_recv_dequeue()
494 trace_session_seqnum_reset(session); in l2tp_recv_dequeue()
496 if (cb->ns != session->nr) in l2tp_recv_dequeue()
499 __skb_unlink(skb, &session->reorder_q); in l2tp_recv_dequeue()
504 spin_unlock_bh(&session->reorder_q.lock); in l2tp_recv_dequeue()
505 l2tp_recv_dequeue_skb(session, skb); in l2tp_recv_dequeue()
510 spin_unlock_bh(&session->reorder_q.lock); in l2tp_recv_dequeue()
513 static int l2tp_seq_check_rx_window(struct l2tp_session *session, u32 nr) in l2tp_seq_check_rx_window() argument
517 if (nr >= session->nr) in l2tp_seq_check_rx_window()
518 nws = nr - session->nr; in l2tp_seq_check_rx_window()
520 nws = (session->nr_max + 1) - (session->nr - nr); in l2tp_seq_check_rx_window()
522 return nws < session->nr_window_size; in l2tp_seq_check_rx_window()
528 static int l2tp_recv_data_seq(struct l2tp_session *session, struct sk_buff *skb) in l2tp_recv_data_seq() argument
532 if (!l2tp_seq_check_rx_window(session, cb->ns)) { in l2tp_recv_data_seq()
536 trace_session_pkt_outside_rx_window(session, cb->ns); in l2tp_recv_data_seq()
540 if (session->reorder_timeout != 0) { in l2tp_recv_data_seq()
544 l2tp_recv_queue_skb(session, skb); in l2tp_recv_data_seq()
553 if (cb->ns == session->nr) { in l2tp_recv_data_seq()
554 skb_queue_tail(&session->reorder_q, skb); in l2tp_recv_data_seq()
557 u32 nr_next = (session->nr_oos + 1) & session->nr_max; in l2tp_recv_data_seq()
560 session->nr_oos_count++; in l2tp_recv_data_seq()
562 session->nr_oos_count = 0; in l2tp_recv_data_seq()
564 session->nr_oos = nr_oos; in l2tp_recv_data_seq()
565 if (session->nr_oos_count > session->nr_oos_count_max) { in l2tp_recv_data_seq()
566 session->reorder_skip = 1; in l2tp_recv_data_seq()
568 if (!session->reorder_skip) { in l2tp_recv_data_seq()
569 atomic_long_inc(&session->stats.rx_seq_discards); in l2tp_recv_data_seq()
570 trace_session_pkt_oos(session, cb->ns); in l2tp_recv_data_seq()
573 skb_queue_tail(&session->reorder_q, skb); in l2tp_recv_data_seq()
642 void l2tp_recv_common(struct l2tp_session *session, struct sk_buff *skb, in l2tp_recv_common() argument
646 struct l2tp_tunnel *tunnel = session->tunnel; in l2tp_recv_common()
650 if (session->peer_cookie_len > 0) { in l2tp_recv_common()
651 if (memcmp(ptr, &session->peer_cookie[0], session->peer_cookie_len)) { in l2tp_recv_common()
654 session->session_id); in l2tp_recv_common()
655 atomic_long_inc(&session->stats.rx_cookie_discards); in l2tp_recv_common()
658 ptr += session->peer_cookie_len; in l2tp_recv_common()
679 } else if (session->l2specific_type == L2TP_L2SPECTYPE_DEFAULT) { in l2tp_recv_common()
695 if (!session->lns_mode && !session->send_seq) { in l2tp_recv_common()
696 trace_session_seqnum_lns_enable(session); in l2tp_recv_common()
697 session->send_seq = 1; in l2tp_recv_common()
698 l2tp_session_set_header_len(session, tunnel->version); in l2tp_recv_common()
704 if (session->recv_seq) { in l2tp_recv_common()
706 session->name); in l2tp_recv_common()
707 atomic_long_inc(&session->stats.rx_seq_discards); in l2tp_recv_common()
716 if (!session->lns_mode && session->send_seq) { in l2tp_recv_common()
717 trace_session_seqnum_lns_disable(session); in l2tp_recv_common()
718 session->send_seq = 0; in l2tp_recv_common()
719 l2tp_session_set_header_len(session, tunnel->version); in l2tp_recv_common()
720 } else if (session->send_seq) { in l2tp_recv_common()
722 session->name); in l2tp_recv_common()
723 atomic_long_inc(&session->stats.rx_seq_discards); in l2tp_recv_common()
751 (session->reorder_timeout ? session->reorder_timeout : HZ); in l2tp_recv_common()
757 if (l2tp_recv_data_seq(session, skb)) in l2tp_recv_common()
764 skb_queue_tail(&session->reorder_q, skb); in l2tp_recv_common()
768 l2tp_recv_dequeue(session); in l2tp_recv_common()
773 atomic_long_inc(&session->stats.rx_errors); in l2tp_recv_common()
780 static void l2tp_session_queue_purge(struct l2tp_session *session) in l2tp_session_queue_purge() argument
784 while ((skb = skb_dequeue(&session->reorder_q))) { in l2tp_session_queue_purge()
785 atomic_long_inc(&session->stats.rx_errors); in l2tp_session_queue_purge()
798 struct l2tp_session *session = NULL; in l2tp_udp_recv_core() local
860 session = l2tp_tunnel_get_session(tunnel, session_id); in l2tp_udp_recv_core()
861 if (!session || !session->recv_skb) { in l2tp_udp_recv_core()
862 if (session) in l2tp_udp_recv_core()
863 l2tp_session_dec_refcount(session); in l2tp_udp_recv_core()
872 l2tp_v3_ensure_opt_in_linear(session, skb, &ptr, &optr)) { in l2tp_udp_recv_core()
873 l2tp_session_dec_refcount(session); in l2tp_udp_recv_core()
877 l2tp_recv_common(session, skb, ptr, optr, hdrflags, length); in l2tp_udp_recv_core()
878 l2tp_session_dec_refcount(session); in l2tp_udp_recv_core()
930 static int l2tp_build_l2tpv2_header(struct l2tp_session *session, void *buf) in l2tp_build_l2tpv2_header() argument
932 struct l2tp_tunnel *tunnel = session->tunnel; in l2tp_build_l2tpv2_header()
937 u32 session_id = session->peer_session_id; in l2tp_build_l2tpv2_header()
939 if (session->send_seq) in l2tp_build_l2tpv2_header()
946 if (session->send_seq) { in l2tp_build_l2tpv2_header()
947 *bufp++ = htons(session->ns); in l2tp_build_l2tpv2_header()
949 session->ns++; in l2tp_build_l2tpv2_header()
950 session->ns &= 0xffff; in l2tp_build_l2tpv2_header()
951 trace_session_seqnum_update(session); in l2tp_build_l2tpv2_header()
957 static int l2tp_build_l2tpv3_header(struct l2tp_session *session, void *buf) in l2tp_build_l2tpv3_header() argument
959 struct l2tp_tunnel *tunnel = session->tunnel; in l2tp_build_l2tpv3_header()
974 *((__be32 *)bufp) = htonl(session->peer_session_id); in l2tp_build_l2tpv3_header()
976 if (session->cookie_len) { in l2tp_build_l2tpv3_header()
977 memcpy(bufp, &session->cookie[0], session->cookie_len); in l2tp_build_l2tpv3_header()
978 bufp += session->cookie_len; in l2tp_build_l2tpv3_header()
980 if (session->l2specific_type == L2TP_L2SPECTYPE_DEFAULT) { in l2tp_build_l2tpv3_header()
983 if (session->send_seq) { in l2tp_build_l2tpv3_header()
984 l2h = 0x40000000 | session->ns; in l2tp_build_l2tpv3_header()
985 session->ns++; in l2tp_build_l2tpv3_header()
986 session->ns &= 0xffffff; in l2tp_build_l2tpv3_header()
987 trace_session_seqnum_update(session); in l2tp_build_l2tpv3_header()
1014 static int l2tp_xmit_core(struct l2tp_session *session, struct sk_buff *skb, unsigned int *len) in l2tp_xmit_core() argument
1016 struct l2tp_tunnel *tunnel = session->tunnel; in l2tp_xmit_core()
1029 headroom = NET_SKB_PAD + sizeof(struct iphdr) + uhlen + session->hdr_len; in l2tp_xmit_core()
1037 l2tp_build_l2tpv2_header(session, __skb_push(skb, session->hdr_len)); in l2tp_xmit_core()
1039 l2tp_build_l2tpv3_header(session, __skb_push(skb, session->hdr_len)); in l2tp_xmit_core()
1076 udp_len = uhlen + session->hdr_len + data_len; in l2tp_xmit_core()
1106 int l2tp_xmit_skb(struct l2tp_session *session, struct sk_buff *skb) in l2tp_xmit_skb() argument
1111 ret = l2tp_xmit_core(session, skb, &len); in l2tp_xmit_skb()
1113 atomic_long_inc(&session->tunnel->stats.tx_packets); in l2tp_xmit_skb()
1114 atomic_long_add(len, &session->tunnel->stats.tx_bytes); in l2tp_xmit_skb()
1115 atomic_long_inc(&session->stats.tx_packets); in l2tp_xmit_skb()
1116 atomic_long_add(len, &session->stats.tx_bytes); in l2tp_xmit_skb()
1118 atomic_long_inc(&session->tunnel->stats.tx_errors); in l2tp_xmit_skb()
1119 atomic_long_inc(&session->stats.tx_errors); in l2tp_xmit_skb()
1166 static void l2tp_session_unhash(struct l2tp_session *session) in l2tp_session_unhash() argument
1168 struct l2tp_tunnel *tunnel = session->tunnel; in l2tp_session_unhash()
1174 hlist_del_init(&session->hlist); in l2tp_session_unhash()
1182 hlist_del_init_rcu(&session->global_hlist); in l2tp_session_unhash()
1196 struct l2tp_session *session; in l2tp_tunnel_closeall() local
1203 session = hlist_entry(walk, struct l2tp_session, hlist); in l2tp_tunnel_closeall()
1204 hlist_del_init(&session->hlist); in l2tp_tunnel_closeall()
1207 l2tp_session_delete(session); in l2tp_tunnel_closeall()
1547 void l2tp_session_delete(struct l2tp_session *session) in l2tp_session_delete() argument
1549 if (test_and_set_bit(0, &session->dead)) in l2tp_session_delete()
1552 trace_delete_session(session); in l2tp_session_delete()
1553 l2tp_session_unhash(session); in l2tp_session_delete()
1554 l2tp_session_queue_purge(session); in l2tp_session_delete()
1555 if (session->session_close) in l2tp_session_delete()
1556 (*session->session_close)(session); in l2tp_session_delete()
1558 l2tp_session_dec_refcount(session); in l2tp_session_delete()
1565 void l2tp_session_set_header_len(struct l2tp_session *session, int version) in l2tp_session_set_header_len() argument
1568 session->hdr_len = 6; in l2tp_session_set_header_len()
1569 if (session->send_seq) in l2tp_session_set_header_len()
1570 session->hdr_len += 4; in l2tp_session_set_header_len()
1572 session->hdr_len = 4 + session->cookie_len; in l2tp_session_set_header_len()
1573 session->hdr_len += l2tp_get_l2specific_len(session); in l2tp_session_set_header_len()
1574 if (session->tunnel->encap == L2TP_ENCAPTYPE_UDP) in l2tp_session_set_header_len()
1575 session->hdr_len += 4; in l2tp_session_set_header_len()
1583 struct l2tp_session *session; in l2tp_session_create() local
1585 session = kzalloc(sizeof(*session) + priv_size, GFP_KERNEL); in l2tp_session_create()
1586 if (session) { in l2tp_session_create()
1587 session->magic = L2TP_SESSION_MAGIC; in l2tp_session_create()
1588 session->tunnel = tunnel; in l2tp_session_create()
1590 session->session_id = session_id; in l2tp_session_create()
1591 session->peer_session_id = peer_session_id; in l2tp_session_create()
1592 session->nr = 0; in l2tp_session_create()
1594 session->nr_max = 0xffff; in l2tp_session_create()
1596 session->nr_max = 0xffffff; in l2tp_session_create()
1597 session->nr_window_size = session->nr_max / 2; in l2tp_session_create()
1598 session->nr_oos_count_max = 4; in l2tp_session_create()
1601 session->reorder_skip = 1; in l2tp_session_create()
1603 sprintf(&session->name[0], "sess %u/%u", in l2tp_session_create()
1604 tunnel->tunnel_id, session->session_id); in l2tp_session_create()
1606 skb_queue_head_init(&session->reorder_q); in l2tp_session_create()
1608 INIT_HLIST_NODE(&session->hlist); in l2tp_session_create()
1609 INIT_HLIST_NODE(&session->global_hlist); in l2tp_session_create()
1612 session->pwtype = cfg->pw_type; in l2tp_session_create()
1613 session->send_seq = cfg->send_seq; in l2tp_session_create()
1614 session->recv_seq = cfg->recv_seq; in l2tp_session_create()
1615 session->lns_mode = cfg->lns_mode; in l2tp_session_create()
1616 session->reorder_timeout = cfg->reorder_timeout; in l2tp_session_create()
1617 session->l2specific_type = cfg->l2specific_type; in l2tp_session_create()
1618 session->cookie_len = cfg->cookie_len; in l2tp_session_create()
1619 memcpy(&session->cookie[0], &cfg->cookie[0], cfg->cookie_len); in l2tp_session_create()
1620 session->peer_cookie_len = cfg->peer_cookie_len; in l2tp_session_create()
1621 memcpy(&session->peer_cookie[0], &cfg->peer_cookie[0], cfg->peer_cookie_len); in l2tp_session_create()
1624 l2tp_session_set_header_len(session, tunnel->version); in l2tp_session_create()
1626 refcount_set(&session->ref_count, 1); in l2tp_session_create()
1628 return session; in l2tp_session_create()