Searched refs:collect_queue (Results 1 – 7 of 7) sorted by relevance
354 if (!skb_queue_empty(&p_ch->collect_queue)) { in claw_pack_skb()356 held_skb = skb_dequeue(&p_ch->collect_queue); in claw_pack_skb()367 skb_queue_head(&p_ch->collect_queue,held_skb); in claw_pack_skb()382 held_skb = skb_dequeue(&p_ch->collect_queue); in claw_pack_skb()388 skb_queue_head(&p_ch->collect_queue,held_skb); in claw_pack_skb()463 &privptr->channel[WRITE_CHANNEL].collect_queue); in claw_open()822 &privptr->channel[WRITE_CHANNEL].collect_queue); in claw_release()966 !skb_queue_empty(&p_ch->collect_queue)) { in claw_write_next()1293 skb_queue_tail(&ch->collect_queue, skb); in claw_hw_tx()1305 skb_queue_tail(&ch->collect_queue, skb); in claw_hw_tx()[all …]
293 if (ch->prof.maxcqueue < skb_queue_len(&ch->collect_queue)) in chx_txdone()294 ch->prof.maxcqueue = skb_queue_len(&ch->collect_queue); in chx_txdone()297 while ((skb = skb_dequeue(&ch->collect_queue))) { in chx_txdone()730 ctcm_purge_skb_queue(&ch->collect_queue); in ctcm_chx_cleanup()1275 if (ch->prof.maxcqueue < skb_queue_len(&ch->collect_queue)) in ctcmpc_chx_txdone()1276 ch->prof.maxcqueue = skb_queue_len(&ch->collect_queue); in ctcmpc_chx_txdone()1285 while ((skb = skb_dequeue(&ch->collect_queue))) { in ctcmpc_chx_txdone()1307 peekskb = skb_peek(&ch->collect_queue); in ctcmpc_chx_txdone()
159 struct sk_buff_head collect_queue; member
279 struct sk_buff_head collect_queue; member
220 struct sk_buff_head collect_queue; member787 while ((skb = skb_dequeue(&conn->collect_queue))) { in conn_action_txdone()1005 netiucv_purge_skb_queue(&conn->collect_queue); in conn_action_stop()1208 skb_queue_tail(&conn->collect_queue, skb); in netiucv_transmit_skb()1917 skb_queue_head_init(&conn->collect_queue); in netiucv_new_connection()1973 netiucv_purge_skb_queue(&conn->collect_queue); in netiucv_remove_connection()
492 skb_queue_tail(&ch->collect_queue, skb); in ctcm_transmit_skb()707 skb_queue_tail(&ch->collect_queue, skb); in ctcmpc_transmit_skb()759 skb_queue_tail(&ch->collect_queue, skb); in ctcmpc_transmit_skb()761 skb = skb_dequeue(&ch->collect_queue); in ctcmpc_transmit_skb()1480 skb_queue_head_init(&ch->collect_queue); in add_channel()
914 ctcm_purge_skb_queue(&ch->collect_queue); in mpc_group_ready()