Lines Matching refs:tinc

44 	struct rds_tcp_incoming *tinc;  in rds_tcp_inc_purge()  local
45 tinc = container_of(inc, struct rds_tcp_incoming, ti_inc); in rds_tcp_inc_purge()
46 rdsdebug("purging tinc %p inc %p\n", tinc, inc); in rds_tcp_inc_purge()
47 skb_queue_purge(&tinc->ti_skb_list); in rds_tcp_inc_purge()
52 struct rds_tcp_incoming *tinc; in rds_tcp_inc_free() local
53 tinc = container_of(inc, struct rds_tcp_incoming, ti_inc); in rds_tcp_inc_free()
55 rdsdebug("freeing tinc %p inc %p\n", tinc, inc); in rds_tcp_inc_free()
56 kmem_cache_free(rds_tcp_incoming_slab, tinc); in rds_tcp_inc_free()
64 struct rds_tcp_incoming *tinc; in rds_tcp_inc_copy_to_user() local
71 tinc = container_of(inc, struct rds_tcp_incoming, ti_inc); in rds_tcp_inc_copy_to_user()
73 skb_queue_walk(&tinc->ti_skb_list, skb) { in rds_tcp_inc_copy_to_user()
106 struct rds_tcp_incoming *tinc) in rds_tcp_cong_recv() argument
116 if (be32_to_cpu(tinc->ti_inc.i_hdr.h_len) != RDS_CONG_MAP_BYTES) in rds_tcp_cong_recv()
123 skb_queue_walk(&tinc->ti_skb_list, skb) { in rds_tcp_cong_recv()
160 struct rds_tcp_incoming *tinc = tc->t_tinc; in rds_tcp_data_recv() local
172 if (!tinc) { in rds_tcp_data_recv()
173 tinc = kmem_cache_alloc(rds_tcp_incoming_slab, in rds_tcp_data_recv()
175 if (!tinc) { in rds_tcp_data_recv()
179 tc->t_tinc = tinc; in rds_tcp_data_recv()
180 rdsdebug("alloced tinc %p\n", tinc); in rds_tcp_data_recv()
181 rds_inc_init(&tinc->ti_inc, conn, conn->c_faddr); in rds_tcp_data_recv()
186 skb_queue_head_init(&tinc->ti_skb_list); in rds_tcp_data_recv()
194 (char *)&tinc->ti_inc.i_hdr + in rds_tcp_data_recv()
205 be32_to_cpu(tinc->ti_inc.i_hdr.h_len); in rds_tcp_data_recv()
226 skb_queue_tail(&tinc->ti_skb_list, clone); in rds_tcp_data_recv()
239 if (tinc->ti_inc.i_hdr.h_flags == RDS_FLAG_CONG_BITMAP) in rds_tcp_data_recv()
240 rds_tcp_cong_recv(conn, tinc); in rds_tcp_data_recv()
243 conn->c_laddr, &tinc->ti_inc, in rds_tcp_data_recv()
249 rds_inc_put(&tinc->ti_inc); in rds_tcp_data_recv()
250 tinc = NULL; in rds_tcp_data_recv()