| /linux-4.4.14/net/dccp/ |
| D | qpolicy.c | 20 skb_queue_tail(&sk->sk_write_queue, skb); in qpolicy_simple_push()
26 sk->sk_write_queue.qlen >= dccp_sk(sk)->dccps_tx_qlen; in qpolicy_simple_full()
31 return skb_peek(&sk->sk_write_queue); in qpolicy_simple_top()
43 skb_queue_walk(&sk->sk_write_queue, skb) in qpolicy_prio_best_skb()
53 skb_queue_walk(&sk->sk_write_queue, skb) in qpolicy_prio_worst_skb()
109 skb_unlink(skb, &sk->sk_write_queue); in dccp_qpolicy_drop()
126 skb_unlink(skb, &sk->sk_write_queue); in dccp_qpolicy_pop()
|
| D | output.c | 313 while (*time_budget > 0 && (skb = skb_peek(&sk->sk_write_queue))) { in dccp_flush_write_queue()
339 skb_dequeue(&sk->sk_write_queue); in dccp_flush_write_queue()
|
| D | proto.c | 276 __skb_queue_purge(&sk->sk_write_queue); in dccp_disconnect()
1035 __skb_queue_purge(&sk->sk_write_queue); in dccp_close()
|
| D | input.c | 185 if (sk->sk_write_queue.qlen > 0 || !(sk->sk_shutdown & SEND_SHUTDOWN)) in dccp_deliver_input_to_ccids()
|
| /linux-4.4.14/net/x25/ |
| D | x25_out.c | 105 skb_queue_tail(&sk->sk_write_queue, skbn); in x25_output()
111 skb_queue_tail(&sk->sk_write_queue, skb); in x25_output()
164 if (!skb_peek(&sk->sk_write_queue)) in x25_kick()
182 skb = skb_dequeue(&sk->sk_write_queue); in x25_kick()
186 skb_queue_head(&sk->sk_write_queue, skb); in x25_kick()
205 (skb = skb_dequeue(&sk->sk_write_queue)) != NULL); in x25_kick()
|
| D | x25_subr.c | 43 skb_queue_purge(&sk->sk_write_queue); in x25_clear_queues()
84 skb_queue_head(&sk->sk_write_queue, skb); in x25_requeue_frames()
86 skb_append(skb_prev, skb, &sk->sk_write_queue); in x25_requeue_frames()
|
| /linux-4.4.14/net/rose/ |
| D | rose_out.c | 60 if (!skb_peek(&sk->sk_write_queue)) in rose_kick()
76 skb = skb_dequeue(&sk->sk_write_queue); in rose_kick()
80 skb_queue_head(&sk->sk_write_queue, skb); in rose_kick()
99 (skb = skb_dequeue(&sk->sk_write_queue)) != NULL); in rose_kick()
|
| D | rose_subr.c | 37 skb_queue_purge(&sk->sk_write_queue); in rose_clear_queues()
74 skb_queue_head(&sk->sk_write_queue, skb); in rose_requeue_frames()
76 skb_append(skb_prev, skb, &sk->sk_write_queue); in rose_requeue_frames()
|
| D | af_rose.c | 1196 skb_queue_tail(&sk->sk_write_queue, skbn); /* Throw it on the queue */ in rose_sendmsg()
1202 skb_queue_tail(&sk->sk_write_queue, skb); /* Throw it on the queue */ in rose_sendmsg()
1205 skb_queue_tail(&sk->sk_write_queue, skb); /* Shove it onto the queue */ in rose_sendmsg()
|
| /linux-4.4.14/net/nfc/ |
| D | rawsock.c | 52 spin_lock_bh(&sk->sk_write_queue.lock); in rawsock_write_queue_purge()
53 __skb_queue_purge(&sk->sk_write_queue); in rawsock_write_queue_purge()
55 spin_unlock_bh(&sk->sk_write_queue.lock); in rawsock_write_queue_purge()
170 spin_lock_bh(&sk->sk_write_queue.lock); in rawsock_data_exchange_complete()
171 if (!skb_queue_empty(&sk->sk_write_queue)) in rawsock_data_exchange_complete()
175 spin_unlock_bh(&sk->sk_write_queue.lock); in rawsock_data_exchange_complete()
203 skb = skb_dequeue(&sk->sk_write_queue); in rawsock_tx_work()
239 spin_lock_bh(&sk->sk_write_queue.lock); in rawsock_sendmsg()
240 __skb_queue_tail(&sk->sk_write_queue, skb); in rawsock_sendmsg()
245 spin_unlock_bh(&sk->sk_write_queue.lock); in rawsock_sendmsg()
|
| /linux-4.4.14/net/netrom/ |
| D | nr_out.c | 67 skb_queue_tail(&sk->sk_write_queue, skbn); /* Throw it on the queue */ in nr_output()
72 skb_queue_tail(&sk->sk_write_queue, skb); /* Throw it on the queue */ in nr_output()
137 if (!skb_peek(&sk->sk_write_queue)) in nr_kick()
156 skb = skb_dequeue(&sk->sk_write_queue); in nr_kick()
160 skb_queue_head(&sk->sk_write_queue, skb); in nr_kick()
179 (skb = skb_dequeue(&sk->sk_write_queue)) != NULL); in nr_kick()
|
| D | nr_subr.c | 38 skb_queue_purge(&sk->sk_write_queue); in nr_clear_queues()
77 skb_queue_head(&sk->sk_write_queue, skb); in nr_requeue_frames()
79 skb_append(skb_prev, skb, &sk->sk_write_queue); in nr_requeue_frames()
|
| /linux-4.4.14/include/net/ |
| D | tcp.h | 1453 while ((skb = __skb_dequeue(&sk->sk_write_queue)) != NULL) in tcp_write_queue_purge()
1461 return skb_peek(&sk->sk_write_queue); in tcp_write_queue_head()
1466 return skb_peek_tail(&sk->sk_write_queue); in tcp_write_queue_tail()
1472 return skb_queue_next(&sk->sk_write_queue, skb); in tcp_write_queue_next()
1478 return skb_queue_prev(&sk->sk_write_queue, skb); in tcp_write_queue_prev()
1482 skb_queue_walk(&(sk)->sk_write_queue, skb)
1485 skb_queue_walk_from(&(sk)->sk_write_queue, skb)
1488 skb_queue_walk_from_safe(&(sk)->sk_write_queue, skb, tmp)
1498 return skb_queue_is_last(&sk->sk_write_queue, skb); in tcp_skb_is_last()
1522 __skb_queue_tail(&sk->sk_write_queue, skb); in __tcp_add_write_queue_tail()
[all …]
|
| D | udplite.h | 101 skb_queue_walk(&sk->sk_write_queue, skb) { in udplite_csum_outgoing()
|
| D | udp.h | 135 skb_queue_walk(&sk->sk_write_queue, skb) { in udp_csum_outgoing()
|
| D | ip.h | 146 return __ip_make_skb(sk, fl4, &sk->sk_write_queue, &inet_sk(sk)->cork.base); in ip_finish_skb()
|
| D | ipv6.h | 866 return __ip6_make_skb(sk, &sk->sk_write_queue, &inet_sk(sk)->cork, in ip6_finish_skb()
|
| D | sock.h | 399 struct sk_buff_head sk_write_queue; member
|
| /linux-4.4.14/net/bluetooth/bnep/ |
| D | netdev.c | 104 skb_queue_tail(&sk->sk_write_queue, skb); in bnep_net_set_mc_list()
192 skb_queue_tail(&sk->sk_write_queue, skb); in bnep_net_xmit()
195 if (skb_queue_len(&sk->sk_write_queue) >= BNEP_TX_QUEUE_LEN) { in bnep_net_xmit()
|
| D | core.c | 513 while ((skb = skb_dequeue(&sk->sk_write_queue))) in bnep_session()
|
| /linux-4.4.14/net/llc/ |
| D | llc_conn.c | 199 skb_queue_tail(&sk->sk_write_queue, skb); in llc_conn_send_pdu()
250 skb_queue_tail(&sk->sk_write_queue, skb); in llc_conn_resend_i_pdu_as_cmd()
291 skb_queue_tail(&sk->sk_write_queue, skb); in llc_conn_resend_i_pdu_as_rsp()
350 while ((skb = skb_dequeue(&sk->sk_write_queue)) != NULL) { in llc_conn_send_pdus()
967 skb_queue_len(&sk->sk_write_queue)); in llc_sk_free()
970 skb_queue_purge(&sk->sk_write_queue); in llc_sk_free()
999 skb_queue_purge(&sk->sk_write_queue); in llc_sk_reset()
|
| /linux-4.4.14/net/ipv4/ |
| D | ip_output.c | 1179 if (skb_queue_empty(&sk->sk_write_queue)) { in ip_append_data()
1187 return __ip_append_data(sk, fl4, &sk->sk_write_queue, &inet->cork.base, in ip_append_data()
1212 if (skb_queue_empty(&sk->sk_write_queue)) in ip_append_page()
1236 skb = skb_peek_tail(&sk->sk_write_queue); in ip_append_page()
1302 __skb_queue_tail(&sk->sk_write_queue, skb); in ip_append_page()
1484 __ip_flush_pending_frames(sk, &sk->sk_write_queue, &inet_sk(sk)->cork.base); in ip_flush_pending_frames()
1599 nskb = skb_peek(&sk->sk_write_queue); in ip_send_unicast_reply()
|
| D | tcp.c | 929 skb_queue_empty(&sk->sk_write_queue)); in do_tcp_sendpages()
1011 if (unlikely(skb_queue_len(&sk->sk_write_queue) == 0 && err == -EAGAIN)) in do_tcp_sendpages()
1172 skb_queue_empty(&sk->sk_write_queue)); in tcp_sendmsg()
1305 if (unlikely(skb_queue_len(&sk->sk_write_queue) == 0 && err == -EAGAIN)) in tcp_sendmsg()
1368 skb_queue_walk(&sk->sk_write_queue, skb) { in tcp_peek_sndq()
|
| D | icmp.c | 368 } else if ((skb = skb_peek(&sk->sk_write_queue)) != NULL) { in icmp_push_reply()
373 skb_queue_walk(&sk->sk_write_queue, skb1) { in icmp_push_reply()
|
| D | ping.c | 646 struct sk_buff *skb = skb_peek(&sk->sk_write_queue); in ping_v4_push_pending_frames()
|
| D | udp.c | 1102 else if (unlikely(skb_queue_empty(&sk->sk_write_queue))) in udp_sendmsg()
|
| D | tcp_input.c | 3529 prefetchw(sk->sk_write_queue.next); in tcp_ack()
|
| /linux-4.4.14/net/core/ |
| D | stream.c | 199 WARN_ON(!skb_queue_empty(&sk->sk_write_queue)); in sk_stream_kill_queues()
|
| D | sock.c | 1530 skb_queue_head_init(&newsk->sk_write_queue); in sk_clone_lock()
2367 skb_queue_head_init(&sk->sk_write_queue); in sock_init_data()
|
| /linux-4.4.14/net/ipv6/ |
| D | icmp.c | 246 skb = skb_peek(&sk->sk_write_queue); in icmpv6_push_pending_frames()
254 if (skb_queue_len(&sk->sk_write_queue) == 1) { in icmpv6_push_pending_frames()
264 skb_queue_walk(&sk->sk_write_queue, skb) { in icmpv6_push_pending_frames()
|
| D | raw.c | 551 skb = skb_peek(&sk->sk_write_queue); in rawv6_push_pending_frames()
564 if (skb_queue_len(&sk->sk_write_queue) == 1) { in rawv6_push_pending_frames()
573 skb_queue_walk(&sk->sk_write_queue, skb) { in rawv6_push_pending_frames()
|
| D | ip6_output.c | 1573 if (skb_queue_empty(&sk->sk_write_queue)) { in ip6_append_data()
1590 return __ip6_append_data(sk, fl6, &sk->sk_write_queue, &inet->cork.base, in ip6_append_data()
1739 __ip6_flush_pending_frames(sk, &sk->sk_write_queue, in ip6_flush_pending_frames()
|
| D | udp.c | 1350 else if (unlikely(skb_queue_empty(&sk->sk_write_queue))) in udpv6_sendmsg()
|
| /linux-4.4.14/net/l2tp/ |
| D | l2tp_ip.c | 235 while ((skb = __skb_dequeue_tail(&sk->sk_write_queue)) != NULL) in l2tp_ip_destroy_sock()
|
| D | l2tp_ip6.c | 469 skb = skb_peek(&sk->sk_write_queue); in l2tp_ip6_push_pending_frames()
|
| D | l2tp_ppp.c | 509 skb_queue_purge(&sk->sk_write_queue); in pppol2tp_release()
|
| /linux-4.4.14/net/netlink/ |
| D | af_netlink.c | 387 queue = tx_ring ? &sk->sk_write_queue : &sk->sk_receive_queue; in __netlink_set_ring()
708 spin_lock_bh(&sk->sk_write_queue.lock); in netlink_poll()
713 spin_unlock_bh(&sk->sk_write_queue.lock); in netlink_poll()
1306 skb_queue_purge(&sk->sk_write_queue); in netlink_release()
|
| /linux-4.4.14/net/sched/ |
| D | em_meta.c | 440 dst->value = sk->sk_write_queue.qlen; in META_COLLECTOR()
|
| /linux-4.4.14/net/bluetooth/rfcomm/ |
| D | sock.c | 162 skb_queue_purge(&sk->sk_write_queue); in rfcomm_sock_destruct()
|
| /linux-4.4.14/net/bluetooth/ |
| D | sco.c | 371 skb_queue_purge(&sk->sk_write_queue); in sco_sock_destruct()
|
| D | hci_sock.c | 591 skb_queue_purge(&sk->sk_write_queue); in hci_sock_release()
|
| D | l2cap_sock.c | 1485 skb_queue_purge(&sk->sk_write_queue); in l2cap_sock_destruct()
|
| /linux-4.4.14/net/packet/ |
| D | af_packet.c | 3950 spin_lock_bh(&sk->sk_write_queue.lock); in packet_poll()
3955 spin_unlock_bh(&sk->sk_write_queue.lock); in packet_poll()
4077 rb_queue = tx_ring ? &sk->sk_write_queue : &sk->sk_receive_queue; in packet_set_ring()
|
| /linux-4.4.14/net/ax25/ |
| D | af_ax25.c | 323 skb_queue_purge(&ax25->sk->sk_write_queue); in ax25_destroy_socket()
|
| /linux-4.4.14/net/key/ |
| D | af_key.c | 182 skb_queue_purge(&sk->sk_write_queue); in pfkey_release()
|