Home
last modified time | relevance | path

Searched refs:sk_write_queue (Results 1 – 25 of 37) sorted by relevance

12

/linux/net/dccp/
H A Dqpolicy.c
H A Doutput.c
H A Dproto.c
H A Dinput.c
/linux/net/x25/
H A Dx25_out.c100 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 Dx25_subr.c38 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 Drawsock.c41 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 in rawsock_sendmsg()
[all...]
/linux/net/rose/
H A Drose_out.c57 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 Drose_subr.c34 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 Daf_rose.c1257 skb_queue_tail(&sk->sk_write_queue, skbn); /* Throw it on the queue */ in rose_sendmsg()
1263 skb_queue_tail(&sk->sk_write_queue, skb); /* Throw it on the queue */ in rose_sendmsg()
1266 skb_queue_tail(&sk->sk_write_queue, skb); /* Shove it onto the queue */ in rose_sendmsg()
/linux/net/netrom/
H A Dnr_out.c66 skb_queue_tail(&sk->sk_write_queue, skbn); /* Throw it on the queue */ in nr_output()
71 skb_queue_tail(&sk->sk_write_queue, skb); /* Throw it on the queue */ in nr_output()
136 if (!skb_peek(&sk->sk_write_queue)) in nr_kick()
155 skb = skb_dequeue(&sk->sk_write_queue); in nr_kick()
159 skb_queue_head(&sk->sk_write_queue, skb); in nr_kick()
178 (skb = skb_dequeue(&sk->sk_write_queue)) != NULL); in nr_kick()
H A Dnr_subr.c35 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 Dnetdev.c104 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()
H A Dcore.c508 while ((skb = skb_dequeue(&sk->sk_write_queue))) in bnep_session()
/linux/net/llc/
H A Dllc_conn.c181 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 Dnested_acquire.c17 ptr = bpf_kfunc_nested_acquire_nonzero_offset_test(&sk->sk_write_queue); in BPF_PROG()
/linux/net/kcm/
H A Dkcmproc.c121 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 Dstream.c212 WARN_ON_ONCE(!skb_queue_empty(&sk->sk_write_queue)); in sk_stream_kill_queues()
/linux/include/net/
H A Dtcp.h2132 return skb_peek_tail(&sk->sk_write_queue); in tcp_write_queue_tail()
2136 skb_queue_walk_from_safe(&(sk)->sk_write_queue, skb, tmp)
2140 return skb_peek(&sk->sk_write_queue); in tcp_send_head()
2146 return skb_queue_is_last(&sk->sk_write_queue, skb); in tcp_skb_is_last()
2175 __skb_queue_tail(&sk->sk_write_queue, skb); in tcp_add_write_queue_tail()
2178 if (sk->sk_write_queue.next == skb) in tcp_add_write_queue_tail()
2187 __skb_queue_before(&sk->sk_write_queue, skb, new); in tcp_insert_write_queue_before()
2193 __skb_unlink(skb, &sk->sk_write_queue); in tcp_unlink_write_queue()
/linux/net/ipv4/
H A Dip_output.c1370 if (skb_queue_empty(&sk->sk_write_queue)) { in ip_append_data()
1378 return __ip_append_data(sk, fl4, &sk->sk_write_queue, &inet->cork.base, in ip_append_data()
1548 __ip_flush_pending_frames(sk, &sk->sk_write_queue, &inet_sk(sk)->cork.base); in ip_flush_pending_frames()
1662 nskb = skb_peek(&sk->sk_write_queue); in ip_send_unicast_reply()
H A Dicmp.c382 } else if ((skb = skb_peek(&sk->sk_write_queue)) != NULL) { in icmp_push_reply()
390 skb_queue_walk(&sk->sk_write_queue, skb1) { in icmp_push_reply()
H A Dtcp_output.c78 __skb_unlink(skb, &sk->sk_write_queue); in tcp_event_new_data_sent()
1749 __skb_queue_after(&sk->sk_write_queue, skb, buff); in tcp_insert_write_queue_after()
2535 skb_queue_walk(&sk->sk_write_queue, skb) { in tcp_clone_payload()
4241 __skb_queue_tail(&sk->sk_write_queue, syn_data); in tcp_send_syn_data()
/linux/net/l2tp/
H A Dl2tp_ip6.c502 skb = skb_peek(&sk->sk_write_queue); in l2tp_ip6_push_pending_frames()
654 ulen = len + (skb_queue_empty(&sk->sk_write_queue) ? transhdrlen : 0); in l2tp_ip6_sendmsg()
/linux/net/sched/
H A Dem_meta.c441 dst->value = sk->sk_write_queue.qlen; in META_COLLECTOR()
/linux/net/bluetooth/rfcomm/
H A Dsock.c160 skb_queue_purge(&sk->sk_write_queue); in rfcomm_sock_destruct()

12