Home
last modified time | relevance | path

Searched refs:skb_peek (Results 1 – 25 of 114) sorted by relevance

12345

/linux/net/netrom/
H A Dnr_out.c102 if ((skb = skb_peek(&nr->ack_queue)) == NULL) in nr_send_nak_frame()
134 if (!skb_peek(&sk->sk_write_queue)) in nr_kick()
137 start = (skb_peek(&nr->ack_queue) == NULL) ? nr->va : nr->vs; in nr_kick()
246 if (skb_peek(&nr->reseq_queue) != NULL) in nr_enquiry_response()
H A Dnr_subr.c55 while (skb_peek(&nrom->ack_queue) != NULL && nrom->va != nr) { in nr_frames_acked()
/linux/net/x25/
H A Dx25_out.c149 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 Dx25_subr.c61 while (skb_peek(&x25->ack_queue) && x25->va != nr) { in x25_frames_acked()
/linux/net/rose/
H A Drose_out.c57 if (!skb_peek(&sk->sk_write_queue)) in rose_kick()
60 start = (skb_peek(&rose->ack_queue) == NULL) ? rose->va : rose->vs; in rose_kick()
/linux/net/ax25/
H A Dax25_ds_subr.c70 …if (ax25->state == AX25_STATE_1 || ax25->state == AX25_STATE_2 || skb_peek(&ax25->ack_queue) != NU… in ax25_ds_enquiry_response()
96 …if (ax25o->state == AX25_STATE_1 || ax25o->state == AX25_STATE_2 || skb_peek(&ax25o->ack_queue) !=… in ax25_ds_enquiry_response()
H A Dax25_out.c253 if (skb_peek(&ax25->write_queue) == NULL) in ax25_kick()
256 start = (skb_peek(&ax25->ack_queue) == NULL) ? ax25->va : ax25->vs; in ax25_kick()
H A Dax25_subr.c54 while (skb_peek(&ax25->ack_queue) != NULL && ax25->va != nr) { in ax25_frames_acked()
/linux/net/lapb/
H A Dlapb_out.c72 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 Dlapb_subr.c57 while (skb_peek(&lapb->ack_queue) && lapb->va != nr) { in lapb_frames_acked()
/linux/net/tipc/
H A Dlink.c403 struct sk_buff *skb = skb_peek(&l->deferdq); in link_bc_rcv_gap()
776 skb = skb_peek(&l->transmq); in link_profile_stats()
1035 hdr = buf_msg(skb_peek(list)); in tipc_link_xmit()
1131 if (txq_len && l->snd_nxt - buf_seqno(skb_peek(txq)) != txq_len) in tipc_link_update_cwin()
1161 skb = skb_peek(&l->backlogq); in tipc_link_advance_backlog()
1200 struct sk_buff *skb = skb_peek(&l->transmq); in link_retransmit_failure()
1451 struct sk_buff *skb = skb_peek(&l->deferdq); in __tipc_build_gap_ack_blks()
1751 u16 rcvgap = buf_seqno(skb_peek(dfq)) - l->rcv_nxt; in tipc_link_build_nack_msg()
1857 rcvgap = buf_seqno(skb_peek(dfq)) - l->rcv_nxt; in tipc_link_build_proto_msg()
2011 pktcnt = l->snd_nxt - buf_seqno(skb_peek(&l->transmq)); in tipc_link_tnl_prepare()
[all …]
H A Dbcast.c295 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()
/linux/drivers/net/wireless/marvell/mwifiex/
H A D11n_aggr.c157 skb_src = skb_peek(&pra_list->skb_head); in mwifiex_11n_aggregate_pkt()
215 skb_src = skb_peek(&pra_list->skb_head); in mwifiex_11n_aggregate_pkt()
H A Dwmm.h36 skb = skb_peek(&ptr->skb_head); in mwifiex_get_tid()
/linux/drivers/net/wireless/ath/carl9170/
H A Dtx.c570 skb = skb_peek(&ar->tx_status[i]); in carl9170_check_queue_stop_timeout()
618 skb = skb_peek(&iter->queue); in carl9170_tx_ampdu_timeout()
1171 first = skb_peek(&tid_info->queue); in carl9170_tx_ampdu()
1182 while ((skb = skb_peek(&tid_info->queue))) { in carl9170_tx_ampdu()
1211 carl9170_get_seq(skb_peek(&tid_info->queue)) != in carl9170_tx_ampdu()
1228 carl9170_set_ampdu_params(ar, skb_peek(&agg)); in carl9170_tx_ampdu()
1255 skb = skb_peek(queue); in carl9170_tx_pick_skb()
1451 if (agg->snx == carl9170_get_seq(skb_peek(&agg->queue))) { in carl9170_tx_ampdu_queue()
/linux/net/mptcp/
H A Dfastopen.c28 skb = skb_peek(&ssk->sk_receive_queue); in mptcp_fastopen_subflow_synack_set_params()
H A Dsubflow.c1068 while ((skb = skb_peek(&ssk->sk_receive_queue))) in validate_data_csum()
1109 skb = skb_peek(&ssk->sk_receive_queue); in get_mapping_status()
1335 if (!skb_peek(&ssk->sk_receive_queue)) in subflow_check_data_avail()
1346 trace_subflow_check_data_avail(status, skb_peek(&ssk->sk_receive_queue)); in subflow_check_data_avail()
1354 skb = skb_peek(&ssk->sk_receive_queue); in subflow_check_data_avail()
1408 while ((skb = skb_peek(&ssk->sk_receive_queue))) in subflow_check_data_avail()
1418 skb = skb_peek(&ssk->sk_receive_queue); in subflow_check_data_avail()
/linux/drivers/net/xen-netback/
H A Drx.c119 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 Dqpolicy.c28 return skb_peek(&sk->sk_write_queue); in qpolicy_simple_top()
/linux/net/phonet/
H A Ddatagram.c38 skb = skb_peek(&sk->sk_receive_queue); in pn_ioctl()
/linux/net/rxrpc/
H A Dio_thread.c517 while ((skb = skb_peek(&local->rx_delay_queue))) { in rxrpc_io_thread()
548 skb = skb_peek(&local->rx_delay_queue); in rxrpc_io_thread()
/linux/drivers/net/wireless/broadcom/brcm80211/include/
H A Dbrcmu_utils.h98 return skb_peek(&pq->q[prec].skblist); in pktq_ppeek()
/linux/drivers/net/ethernet/chelsio/inline_crypto/chtls/
H A Dchtls_io.c615 while (csk->wr_credits && (skb = skb_peek(&csk->txq)) && in chtls_push_frames()
1378 skb = skb_peek(&sk->sk_receive_queue); in chtls_pt_recvmsg()
1519 next_skb = skb_peek(&sk->sk_receive_queue); in chtls_pt_recvmsg()
1716 skb = skb_peek(&sk->sk_receive_queue); in chtls_recvmsg()
1832 !skb_peek(&sk->sk_receive_queue)) in chtls_recvmsg()
/linux/drivers/net/ethernet/netronome/nfp/
H A Dccm_mbox.c133 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 Dsignaling.c204 if (skb_peek(&sk_atm(vcc)->sk_receive_queue)) in sigd_close()

12345