| /linux/net/x25/ |
| H A D | x25_out.c | 149 if (skb_peek(&x25->interrupt_out_queue) != NULL && in x25_kick()
159 if (!skb_peek(&sk->sk_write_queue)) in x25_kick()
164 start = skb_peek(&x25->ack_queue) ? x25->vs : x25->va; in x25_kick()
|
| H A D | x25_subr.c | 62 while (skb_peek(&x25->ack_queue) && x25->va != nr) { in x25_frames_acked()
|
| /linux/net/lapb/ |
| H A D | lapb_out.c | 72 start = !skb_peek(&lapb->ack_queue) ? lapb->va : lapb->vs; in lapb_kick()
76 start != end && skb_peek(&lapb->write_queue)) { in lapb_kick()
|
| H A D | lapb_subr.c | 57 while (skb_peek(&lapb->ack_queue) && lapb->va != nr) { in lapb_frames_acked()
|
| /linux/net/tipc/ |
| H A D | link.c | 403 struct sk_buff *skb = skb_peek(&l->deferdq); in link_bc_rcv_gap()
773 skb = skb_peek(&l->transmq); in link_profile_stats()
1032 hdr = buf_msg(skb_peek(list)); in tipc_link_xmit()
1129 if (txq_len && l->snd_nxt - buf_seqno(skb_peek(txq)) != txq_len) in tipc_link_update_cwin()
1159 skb = skb_peek(&l->backlogq); in tipc_link_advance_backlog()
1198 struct sk_buff *skb = skb_peek(&l->transmq); in link_retransmit_failure()
1449 struct sk_buff *skb = skb_peek(&l->deferdq); in __tipc_build_gap_ack_blks()
1749 u16 rcvgap = buf_seqno(skb_peek(dfq)) - l->rcv_nxt; in tipc_link_build_nack_msg()
1855 rcvgap = buf_seqno(skb_peek(dfq)) - l->rcv_nxt; in tipc_link_build_proto_msg()
2008 pktcnt = l->snd_nxt - buf_seqno(skb_peek(&l->transmq)); in tipc_link_tnl_prepare()
[all …]
|
| H A D | bcast.c | 295 selector = msg_link_selector(buf_msg(skb_peek(pkts))); in tipc_rcast_xmit()
400 skb = skb_peek(pkts); in tipc_mcast_xmit()
792 skb = skb_peek(inputq); in tipc_mcast_filter_msg()
|
| H A D | trace.c | 185 hskb = skb_peek(list); in tipc_list_dump()
|
| H A D | socket.c | 567 skb = skb_peek(&sk->sk_receive_queue); in __tipc_shutdown()
883 trace_tipc_sk_sendmcast(sk, skb_peek(&pkts), in tipc_sendmcast()
1224 if (skb_peek(arrvq) == skb) { in tipc_sk_mcast_rcv()
1255 if (skb_peek(arrvq) == skb) { in tipc_sk_mcast_rcv()
1510 trace_tipc_sk_sendmsg(sk, skb_peek(&pkts), TIPC_DUMP_SK_SNDQ, " "); in __tipc_sendmsg()
1620 trace_tipc_sk_sendstream(sk, skb_peek(txq), in __tipc_sendstream()
1911 skb = skb_peek(&sk->sk_receive_queue); in tipc_recvmsg()
2041 skb = skb_peek(&sk->sk_receive_queue); in tipc_recvstream()
2738 buf = skb_peek(&sk->sk_receive_queue); in tipc_accept()
|
| H A D | msg.c | 785 skb = skb_peek(list); in tipc_msg_reassemble()
840 if (skb_queue_empty(list) || less(seqno, buf_seqno(skb_peek(list)))) { in __tipc_skb_queue_sorted()
|
| /linux/net/mptcp/ |
| H A D | fastopen.c | 29 skb = skb_peek(&ssk->sk_receive_queue); in mptcp_fastopen_subflow_synack_set_params()
|
| H A D | subflow.c | 1078 while ((skb = skb_peek(&ssk->sk_receive_queue))) in validate_data_csum()
1119 skb = skb_peek(&ssk->sk_receive_queue); in get_mapping_status()
1359 if (!skb_peek(&ssk->sk_receive_queue)) in subflow_check_data_avail()
1370 trace_subflow_check_data_avail(status, skb_peek(&ssk->sk_receive_queue)); in subflow_check_data_avail()
1378 skb = skb_peek(&ssk->sk_receive_queue); in subflow_check_data_avail()
1431 while ((skb = skb_peek(&ssk->sk_receive_queue))) in subflow_check_data_avail()
1439 skb = skb_peek(&ssk->sk_receive_queue); in subflow_check_data_avail()
|
| /linux/drivers/net/wireless/ath/carl9170/ |
| H A D | tx.c | 569 skb = skb_peek(&ar->tx_status[i]); in carl9170_check_queue_stop_timeout()
617 skb = skb_peek(&iter->queue); in carl9170_tx_ampdu_timeout()
1170 first = skb_peek(&tid_info->queue); in carl9170_tx_ampdu()
1181 while ((skb = skb_peek(&tid_info->queue))) { in carl9170_tx_ampdu()
1210 carl9170_get_seq(skb_peek(&tid_info->queue)) != in carl9170_tx_ampdu()
1227 carl9170_set_ampdu_params(ar, skb_peek(&agg)); in carl9170_tx_ampdu()
1254 skb = skb_peek(queue); in carl9170_tx_pick_skb()
1450 if (agg->snx == carl9170_get_seq(skb_peek(&agg->queue))) { in carl9170_tx_ampdu_queue()
|
| /linux/drivers/net/wireless/marvell/mwifiex/ |
| H A D | wmm.h | 36 skb = skb_peek(&ptr->skb_head); in mwifiex_get_tid()
|
| H A D | wmm.c | 1253 skb_next = skb_peek(&ptr->skb_head); in mwifiex_send_single_packet()
1298 skb = skb_peek(&ptr->skb_head); in mwifiex_is_ptr_processed()
1339 skb_next = skb_peek(&ptr->skb_head); in mwifiex_send_processed_packet()
|
| /linux/drivers/net/xen-netback/ |
| H A D | rx.c | 119 xenvif_update_needed_slots(queue, skb_peek(&queue->rx_queue)); in xenvif_rx_dequeue()
148 skb = skb_peek(&queue->rx_queue); in xenvif_rx_queue_drop_expired()
552 skb = skb_peek(&queue->rx_queue); in xenvif_rx_queue_timeout()
|
| /linux/net/dccp/ |
| H A D | qpolicy.c | |
| /linux/drivers/net/ |
| H A D | ifb.c | 96 skb = skb_peek(&txp->tq); in ifb_ri_tasklet()
136 skb = skb_peek(&txp->rq); in ifb_ri_tasklet()
|
| /linux/net/phonet/ |
| H A D | datagram.c | 38 skb = skb_peek(&sk->sk_receive_queue); in pn_ioctl()
|
| /linux/drivers/net/wireless/broadcom/brcm80211/include/ |
| H A D | brcmu_utils.h | 98 return skb_peek(&pq->q[prec].skblist); in pktq_ppeek()
|
| /linux/io_uring/ |
| H A D | cmd_net.c | 135 skb = skb_peek(&list); in io_uring_cmd_timestamp()
|
| /linux/net/rxrpc/ |
| H A D | io_thread.c | 456 while ((skb = skb_peek(&local->rx_delay_queue))) { in rxrpc_io_thread()
554 skb = skb_peek(&local->rx_delay_queue); in rxrpc_io_thread()
|
| H A D | recvmsg.c | 206 skb = skb_peek(&rx->recvmsg_oobq); in rxrpc_recvmsg_oob()
273 skb = skb_peek(&call->recvmsg_queue); in rxrpc_recvmsg_data()
|
| /linux/drivers/net/ethernet/netronome/nfp/ |
| H A D | ccm_mbox.c | 133 skb = skb_peek(&nn->mbox_cmsg.queue); in nfp_ccm_mbox_mark_next_runner()
633 skb = skb_peek(&nn->mbox_cmsg.queue); in nfp_ccm_mbox_post_wait_work()
|
| /linux/net/atm/ |
| H A D | ioctl.c | 79 skb = skb_peek(&sk->sk_receive_queue); in do_vcc_ioctl()
|
| /linux/net/sched/ |
| H A D | sch_generic.c | 110 skb = skb_peek(&q->skb_bad_txq); in __skb_dequeue_bad_txq()
137 struct sk_buff *skb = skb_peek(&q->skb_bad_txq); in qdisc_dequeue_skb_bad_txq()
273 skb = skb_peek(&q->gso_skb); in dequeue_skb()
|