/linux/net/dccp/ |
H A D | qpolicy.c | 17 skb_queue_tail(&sk->sk_write_queue, skb); in qpolicy_simple_push() 23 sk->sk_write_queue.qlen >= dccp_sk(sk)->dccps_tx_qlen; in qpolicy_simple_full() 28 return skb_peek(&sk->sk_write_queue); in qpolicy_simple_top() 40 skb_queue_walk(&sk->sk_write_queue, skb) in qpolicy_prio_best_skb() 50 skb_queue_walk(&sk->sk_write_queue, skb) in qpolicy_prio_worst_skb() 108 skb_unlink(skb, &sk->sk_write_queue); in dccp_qpolicy_drop() 125 skb_unlink(skb, &sk->sk_write_queue); in dccp_qpolicy_pop()
|
H A D | output.c | 317 while (*time_budget > 0 && (skb = skb_peek(&sk->sk_write_queue))) { in dccp_flush_write_queue() 343 skb_dequeue(&sk->sk_write_queue); in dccp_flush_write_queue()
|
H A D | proto.c | 224 __skb_queue_purge(&sk->sk_write_queue); in dccp_destroy_sock() 283 __skb_queue_purge(&sk->sk_write_queue); in dccp_disconnect() 1050 __skb_queue_purge(&sk->sk_write_queue); in dccp_close()
|
H A D | input.c | 181 if (sk->sk_write_queue.qlen > 0 || !(sk->sk_shutdown & SEND_SHUTDOWN)) in dccp_deliver_input_to_ccids()
|
/linux/net/x25/ |
H A D | x25_out.c | 100 skb_queue_tail(&sk->sk_write_queue, skbn); in x25_output() 106 skb_queue_tail(&sk->sk_write_queue, skb); in x25_output() 159 if (!skb_peek(&sk->sk_write_queue)) in x25_kick() 177 skb = skb_dequeue(&sk->sk_write_queue); in x25_kick() 181 skb_queue_head(&sk->sk_write_queue, skb); in x25_kick() 200 (skb = skb_dequeue(&sk->sk_write_queue)) != NULL); in x25_kick()
|
H A D | x25_subr.c | 38 skb_queue_purge(&sk->sk_write_queue); in x25_clear_queues() 79 skb_queue_head(&sk->sk_write_queue, skb); in x25_requeue_frames() 81 skb_append(skb_prev, skb, &sk->sk_write_queue); in x25_requeue_frames()
|
/linux/net/nfc/ |
H A D | rawsock.c | 41 spin_lock_bh(&sk->sk_write_queue.lock); in rawsock_write_queue_purge() 42 __skb_queue_purge(&sk->sk_write_queue); in rawsock_write_queue_purge() 44 spin_unlock_bh(&sk->sk_write_queue.lock); in rawsock_write_queue_purge() 159 spin_lock_bh(&sk->sk_write_queue.lock); in rawsock_data_exchange_complete() 160 if (!skb_queue_empty(&sk->sk_write_queue)) in rawsock_data_exchange_complete() 164 spin_unlock_bh(&sk->sk_write_queue.lock); in rawsock_data_exchange_complete() 192 skb = skb_dequeue(&sk->sk_write_queue); in rawsock_tx_work() 230 spin_lock_bh(&sk->sk_write_queue.lock); in rawsock_sendmsg() 231 __skb_queue_tail(&sk->sk_write_queue, skb); in rawsock_sendmsg() 236 spin_unlock_bh(&sk->sk_write_queue.lock); in rawsock_sendmsg()
|
/linux/net/rose/ |
H A D | rose_out.c | 57 if (!skb_peek(&sk->sk_write_queue)) in rose_kick() 73 skb = skb_dequeue(&sk->sk_write_queue); in rose_kick() 77 skb_queue_head(&sk->sk_write_queue, skb); in rose_kick() 96 (skb = skb_dequeue(&sk->sk_write_queue)) != NULL); in rose_kick()
|
H A D | rose_subr.c | 34 skb_queue_purge(&sk->sk_write_queue); in rose_clear_queues() 71 skb_queue_head(&sk->sk_write_queue, skb); in rose_requeue_frames() 73 skb_append(skb_prev, skb, &sk->sk_write_queue); in rose_requeue_frames()
|
H A D | af_rose.c | 1247 skb_queue_tail(&sk->sk_write_queue, skbn); /* Throw it on the queue */ in rose_sendmsg() 1253 skb_queue_tail(&sk->sk_write_queue, skb); /* Throw it on the queue */ in rose_sendmsg() 1256 skb_queue_tail(&sk->sk_write_queue, skb); /* Shove it onto the queue */ in rose_sendmsg()
|
/linux/net/netrom/ |
H A D | nr_out.c | 64 skb_queue_tail(&sk->sk_write_queue, skbn); /* Throw it on the queue */ in nr_output() 69 skb_queue_tail(&sk->sk_write_queue, skb); /* Throw it on the queue */ in nr_output() 134 if (!skb_peek(&sk->sk_write_queue)) in nr_kick() 153 skb = skb_dequeue(&sk->sk_write_queue); in nr_kick() 157 skb_queue_head(&sk->sk_write_queue, skb); in nr_kick() 176 (skb = skb_dequeue(&sk->sk_write_queue)) != NULL); in nr_kick()
|
H A D | nr_subr.c | 35 skb_queue_purge(&sk->sk_write_queue); in nr_clear_queues() 74 skb_queue_head(&sk->sk_write_queue, skb); in nr_requeue_frames() 76 skb_append(skb_prev, skb, &sk->sk_write_queue); in nr_requeue_frames()
|
/linux/net/bluetooth/bnep/ |
H A 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()
|
/linux/net/llc/ |
H A D | llc_conn.c | 181 skb_queue_tail(&sk->sk_write_queue, skb); in llc_conn_send_pdu() 232 skb_queue_tail(&sk->sk_write_queue, skb); in llc_conn_resend_i_pdu_as_cmd() 273 skb_queue_tail(&sk->sk_write_queue, skb); in llc_conn_resend_i_pdu_as_rsp() 332 while ((skb = skb_dequeue(&sk->sk_write_queue)) != NULL) { in llc_conn_send_pdus() 983 skb_queue_len(&sk->sk_write_queue)); in llc_sk_free() 986 skb_queue_purge(&sk->sk_write_queue); in llc_sk_free() 1015 skb_queue_purge(&sk->sk_write_queue); in llc_sk_reset()
|
/linux/tools/testing/selftests/bpf/progs/ |
H A D | nested_acquire.c | 17 ptr = bpf_kfunc_nested_acquire_nonzero_offset_test(&sk->sk_write_queue); in BPF_PROG()
|
/linux/net/kcm/ |
H A D | kcmsock.c | 598 if (skb_queue_empty(&sk->sk_write_queue)) in kcm_write_msgs() 601 kcm_tx_msg(skb_peek(&sk->sk_write_queue))->started_tx = false; in kcm_write_msgs() 605 while ((head = skb_peek(&sk->sk_write_queue))) { in kcm_write_msgs() 693 skb_dequeue(&sk->sk_write_queue); in kcm_write_msgs() 700 WARN_ON(!skb_queue_empty(&sk->sk_write_queue)); in kcm_write_msgs() 895 bool not_busy = skb_queue_empty(&sk->sk_write_queue); in kcm_sendmsg() 899 __skb_queue_tail(&sk->sk_write_queue, head); in kcm_sendmsg() 952 if (unlikely(skb_queue_len(&sk->sk_write_queue) == 0 && err == -EAGAIN)) in kcm_sendmsg() 965 if (skb_queue_empty_lockless(&sk->sk_write_queue)) in kcm_splice_eof() 1689 __skb_queue_purge(&sk->sk_write_queue); in kcm_release()
|
H A D | kcmproc.c | 121 kcm->sk.sk_write_queue.qlen, in kcm_format_sock() 151 psock->sk->sk_write_queue.qlen, in kcm_format_psock()
|
/linux/net/core/ |
H A D | stream.c | 208 WARN_ON_ONCE(!skb_queue_empty(&sk->sk_write_queue)); in sk_stream_kill_queues()
|
/linux/include/net/ |
H A D | tcp.h | 2015 return skb_peek_tail(&sk->sk_write_queue); in tcp_write_queue_tail() 2019 skb_queue_walk_from_safe(&(sk)->sk_write_queue, skb, tmp) 2023 return skb_peek(&sk->sk_write_queue); in tcp_send_head() 2029 return skb_queue_is_last(&sk->sk_write_queue, skb); in tcp_skb_is_last() 2058 __skb_queue_tail(&sk->sk_write_queue, skb); in tcp_add_write_queue_tail() 2061 if (sk->sk_write_queue.next == skb) in tcp_add_write_queue_tail() 2070 __skb_queue_before(&sk->sk_write_queue, skb, new); in tcp_insert_write_queue_before() 2076 __skb_unlink(skb, &sk->sk_write_queue); in tcp_unlink_write_queue()
|
H A D | udp.h | 244 skb_queue_walk(&sk->sk_write_queue, skb) { in udp_csum_outgoing()
|
/linux/net/ipv6/ |
H A D | icmp.c | 282 skb = skb_peek(&sk->sk_write_queue); in icmpv6_push_pending_frames() 290 if (skb_queue_len(&sk->sk_write_queue) == 1) { in icmpv6_push_pending_frames() 300 skb_queue_walk(&sk->sk_write_queue, skb) { in icmpv6_push_pending_frames()
|
/linux/net/tipc/ |
H A D | socket.c | 564 __skb_queue_purge(&sk->sk_write_queue); in __tipc_shutdown() 1272 struct sk_buff_head *txq = &tsk->sk.sk_write_queue; in tipc_sk_push_backlog() 1504 if (unlikely(syn && !tipc_msg_skb_clone(&pkts, &sk->sk_write_queue))) { in __tipc_sendmsg() 1557 struct sk_buff_head *txq = &sk->sk_write_queue; in __tipc_sendstream() 1677 __skb_queue_purge(&sk->sk_write_queue); in tipc_sk_finish_conn() 2233 if (skb_queue_empty(&sk->sk_write_queue)) in tipc_sk_filter_connect() 2252 if (!skb_queue_empty(&sk->sk_write_queue)) in tipc_sk_filter_connect() 2860 tipc_msg_skb_clone(&sk->sk_write_queue, list); in tipc_sk_retry_connect() 3658 skb_queue_len(&sk->sk_write_queue)) || in tipc_sk_fill_sock_diag() 3991 i += tipc_list_dump(&sk->sk_write_queue, false, buf + i); in tipc_sk_dump()
|
/linux/net/ipv4/ |
H A D | ip_output.c | 1367 if (skb_queue_empty(&sk->sk_write_queue)) { in ip_append_data() 1375 return __ip_append_data(sk, fl4, &sk->sk_write_queue, &inet->cork.base, in ip_append_data() 1545 __ip_flush_pending_frames(sk, &sk->sk_write_queue, &inet_sk(sk)->cork.base); in ip_flush_pending_frames() 1659 nskb = skb_peek(&sk->sk_write_queue); in ip_send_unicast_reply()
|
H A D | icmp.c | 380 } else if ((skb = skb_peek(&sk->sk_write_queue)) != NULL) { in icmp_push_reply() 388 skb_queue_walk(&sk->sk_write_queue, skb1) { in icmp_push_reply()
|
/linux/net/l2tp/ |
H A D | l2tp_ip6.c | 501 skb = skb_peek(&sk->sk_write_queue); in l2tp_ip6_push_pending_frames() 659 ulen = len + (skb_queue_empty(&sk->sk_write_queue) ? transhdrlen : 0); in l2tp_ip6_sendmsg()
|