Lines Matching refs:skb
50 struct sk_buff *skb; in __nfp_ccm_reply() local
52 skb_queue_walk(&ccm->replies, skb) { in __nfp_ccm_reply()
53 msg_tag = nfp_ccm_get_tag(skb); in __nfp_ccm_reply()
56 __skb_unlink(skb, &ccm->replies); in __nfp_ccm_reply()
57 return skb; in __nfp_ccm_reply()
67 struct sk_buff *skb; in nfp_ccm_reply() local
70 skb = __nfp_ccm_reply(ccm, tag); in nfp_ccm_reply()
73 return skb; in nfp_ccm_reply()
79 struct sk_buff *skb; in nfp_ccm_reply_drop_tag() local
82 skb = __nfp_ccm_reply(ccm, tag); in nfp_ccm_reply_drop_tag()
83 if (!skb) in nfp_ccm_reply_drop_tag()
87 return skb; in nfp_ccm_reply_drop_tag()
94 struct sk_buff *skb; in nfp_ccm_wait_reply() local
99 skb = nfp_ccm_reply(ccm, app, tag); in nfp_ccm_wait_reply()
100 if (skb) in nfp_ccm_wait_reply()
101 return skb; in nfp_ccm_wait_reply()
105 skb = nfp_ccm_reply(ccm, app, in nfp_ccm_wait_reply()
111 if (!skb) in nfp_ccm_wait_reply()
112 skb = nfp_ccm_reply_drop_tag(ccm, app, tag); in nfp_ccm_wait_reply()
119 if (!skb) { in nfp_ccm_wait_reply()
124 return skb; in nfp_ccm_wait_reply()
128 nfp_ccm_communicate(struct nfp_ccm *ccm, struct sk_buff *skb, in nfp_ccm_communicate() argument
139 dev_kfree_skb_any(skb); in nfp_ccm_communicate()
143 hdr = (void *)skb->data; in nfp_ccm_communicate()
148 __nfp_app_ctrl_tx(app, skb); in nfp_ccm_communicate()
152 skb = nfp_ccm_wait_reply(ccm, app, type, tag); in nfp_ccm_communicate()
153 if (IS_ERR(skb)) in nfp_ccm_communicate()
154 return skb; in nfp_ccm_communicate()
156 reply_type = nfp_ccm_get_type(skb); in nfp_ccm_communicate()
163 if (reply_size && skb->len != reply_size) { in nfp_ccm_communicate()
165 type, skb->len, reply_size); in nfp_ccm_communicate()
169 return skb; in nfp_ccm_communicate()
171 dev_kfree_skb_any(skb); in nfp_ccm_communicate()
175 void nfp_ccm_rx(struct nfp_ccm *ccm, struct sk_buff *skb) in nfp_ccm_rx() argument
180 if (unlikely(skb->len < sizeof(struct nfp_ccm_hdr))) { in nfp_ccm_rx()
181 ccm_warn(app, "cmsg drop - too short %d!\n", skb->len); in nfp_ccm_rx()
187 tag = nfp_ccm_get_tag(skb); in nfp_ccm_rx()
194 __skb_queue_tail(&ccm->replies, skb); in nfp_ccm_rx()
203 dev_kfree_skb_any(skb); in nfp_ccm_rx()