Lines Matching refs:tinc
45 struct rds_tcp_incoming *tinc;
46 tinc = container_of(inc, struct rds_tcp_incoming, ti_inc);
47 rdsdebug("purging tinc %p inc %p\n", tinc, inc);
48 skb_queue_purge(&tinc->ti_skb_list);
53 struct rds_tcp_incoming *tinc;
54 tinc = container_of(inc, struct rds_tcp_incoming, ti_inc);
56 rdsdebug("freeing tinc %p inc %p\n", tinc, inc);
57 kmem_cache_free(rds_tcp_incoming_slab, tinc);
65 struct rds_tcp_incoming *tinc;
72 tinc = container_of(inc, struct rds_tcp_incoming, ti_inc);
74 skb_queue_walk(&tinc->ti_skb_list, skb) {
107 struct rds_tcp_incoming *tinc)
117 if (be32_to_cpu(tinc->ti_inc.i_hdr.h_len) != RDS_CONG_MAP_BYTES)
124 skb_queue_walk(&tinc->ti_skb_list, skb) {
161 struct rds_tcp_incoming *tinc = tc->t_tinc;
173 if (!tinc) {
174 tinc = kmem_cache_alloc(rds_tcp_incoming_slab,
176 if (!tinc) {
180 tc->t_tinc = tinc;
181 rdsdebug("allocated tinc %p\n", tinc);
182 rds_inc_path_init(&tinc->ti_inc, cp,
184 tinc->ti_inc.i_rx_lat_trace[RDS_MSG_RX_HDR] =
191 skb_queue_head_init(&tinc->ti_skb_list);
199 (char *)&tinc->ti_inc.i_hdr +
210 be32_to_cpu(tinc->ti_inc.i_hdr.h_len);
211 tinc->ti_inc.i_rx_lat_trace[RDS_MSG_RX_START] =
225 skb_queue_tail(&tinc->ti_skb_list, clone);
240 if (tinc->ti_inc.i_hdr.h_flags == RDS_FLAG_CONG_BITMAP)
241 rds_tcp_cong_recv(conn, tinc);
245 &tinc->ti_inc,
251 rds_inc_put(&tinc->ti_inc);
252 tinc = NULL;