/net/tipc/ |
D | msg.c | 252 bool tipc_msg_validate(struct sk_buff **_skb) in tipc_msg_validate() argument 254 struct sk_buff *skb = *_skb; in tipc_msg_validate() 263 kfree_skb(*_skb); in tipc_msg_validate() 264 *_skb = skb; in tipc_msg_validate() 311 struct sk_buff *_skb; in tipc_msg_fragment() local 331 _skb = tipc_buf_acquire(INT_H_SIZE + eat, GFP_ATOMIC); in tipc_msg_fragment() 332 if (!_skb) in tipc_msg_fragment() 334 skb_orphan(_skb); in tipc_msg_fragment() 335 __skb_queue_tail(frags, _skb); in tipc_msg_fragment() 337 skb_copy_to_linear_data(_skb, hdr, INT_H_SIZE); in tipc_msg_fragment() [all …]
|
D | bcast.c | 181 struct sk_buff *skb, *_skb; in tipc_bcbase_xmit() local 201 _skb = pskb_copy_for_clone(skb, GFP_ATOMIC); in tipc_bcbase_xmit() 202 if (!_skb) in tipc_bcbase_xmit() 204 __skb_queue_tail(&_xmitq, _skb); in tipc_bcbase_xmit() 323 struct sk_buff *_skb; in tipc_mcast_send_sync() local 338 _skb = tipc_buf_acquire(MCAST_H_SIZE, GFP_KERNEL); in tipc_mcast_send_sync() 339 if (!_skb) in tipc_mcast_send_sync() 346 skb_copy_to_linear_data(_skb, hdr, MCAST_H_SIZE); in tipc_mcast_send_sync() 347 skb_orphan(_skb); in tipc_mcast_send_sync() 350 _hdr = buf_msg(_skb); in tipc_mcast_send_sync() [all …]
|
D | msg.h | 1179 bool tipc_msg_validate(struct sk_buff **_skb); 1269 struct sk_buff *_skb, *tmp, *skb = NULL; in tipc_skb_dequeue() local 1272 skb_queue_walk_safe(list, _skb, tmp) { in tipc_skb_dequeue() 1273 if (msg_destport(buf_msg(_skb)) == dport) { in tipc_skb_dequeue() 1274 __skb_unlink(_skb, list); in tipc_skb_dequeue() 1275 skb = _skb; in tipc_skb_dequeue()
|
D | link.c | 1041 struct sk_buff *skb, *_skb; in tipc_link_xmit() local 1088 _skb = skb_clone(skb, GFP_ATOMIC); in tipc_link_xmit() 1089 if (!_skb) { in tipc_link_xmit() 1096 __skb_queue_tail(xmitq, _skb); in tipc_link_xmit() 1175 struct sk_buff *skb, *_skb; in tipc_link_advance_backlog() local 1186 _skb = skb_clone(skb, GFP_ATOMIC); in tipc_link_advance_backlog() 1187 if (!_skb) in tipc_link_advance_backlog() 1198 __skb_queue_tail(xmitq, _skb); in tipc_link_advance_backlog() 1563 struct sk_buff *skb, *_skb, *tmp; in tipc_link_advance_transmq() local 1648 _skb = pskb_copy(skb, GFP_ATOMIC); in tipc_link_advance_transmq() [all …]
|
D | udp_media.c | 260 struct sk_buff *_skb; in tipc_udp_send_msg() local 262 _skb = pskb_copy(skb, GFP_ATOMIC); in tipc_udp_send_msg() 263 if (!_skb) { in tipc_udp_send_msg() 268 err = tipc_udp_xmit(net, _skb, ub, src, &rcast->addr, in tipc_udp_send_msg()
|
D | group.c | 476 struct sk_buff *_skb, *tmp; in tipc_group_sort_msg() local 481 skb_queue_walk_safe(defq, _skb, tmp) { in tipc_group_sort_msg() 482 _hdr = buf_msg(_skb); in tipc_group_sort_msg() 485 __skb_queue_before(defq, _skb, skb); in tipc_group_sort_msg()
|
D | bearer.c | 751 struct sk_buff *skb, *_skb; in tipc_clone_to_loopback() local 754 skb_queue_walk(pkts, _skb) { in tipc_clone_to_loopback() 755 skb = pskb_copy(_skb, GFP_ATOMIC); in tipc_clone_to_loopback()
|
D | crypto.c | 292 static inline void tipc_crypto_clone_msg(struct net *net, struct sk_buff *_skb, 1652 static inline void tipc_crypto_clone_msg(struct net *net, struct sk_buff *_skb, in tipc_crypto_clone_msg() argument 1659 skb = skb_clone(_skb, GFP_ATOMIC); in tipc_crypto_clone_msg()
|
D | socket.c | 1198 struct sk_buff *skb, *_skb; in tipc_sk_mcast_rcv() local 1249 _skb = __pskb_copy(skb, hlen, GFP_ATOMIC); in tipc_sk_mcast_rcv() 1250 if (_skb) { in tipc_sk_mcast_rcv() 1251 msg_set_destport(buf_msg(_skb), portid); in tipc_sk_mcast_rcv() 1252 __skb_queue_tail(&tmpq, _skb); in tipc_sk_mcast_rcv()
|