Searched refs:send_queue (Results 1 – 9 of 9) sorted by relevance
/linux/drivers/net/wireless/ath/ath6kl/ |
H A D | htc_pipe.c | 303 struct list_head send_queue; /* temp queue to hold packets */ in htc_try_send() local 315 INIT_LIST_HEAD(&send_queue); in htc_try_send() 357 list_splice_tail_init(txq, &send_queue); in htc_try_send() 373 list_move_tail(&packet->list, &send_queue); in htc_try_send() 398 &send_queue); in htc_try_send() 402 if (list_empty(&send_queue)) { in htc_try_send() 418 if (!list_empty(&send_queue)) { in htc_try_send() 420 list_splice_tail_init(&send_queue, &ep->txq); in htc_try_send() 421 if (!list_empty(&send_queue)) { in htc_try_send() 426 INIT_LIST_HEAD(&send_queue); in htc_try_send() [all …]
|
/linux/net/rxrpc/ |
H A D | sendmsg.c | 245 struct rxrpc_txqueue *sq = call->send_queue; in rxrpc_queue_packet() 271 call->send_queue = NULL; in rxrpc_queue_packet() 293 if (call->send_queue) { in rxrpc_alloc_txqueue() 295 call->send_queue->next = tq; in rxrpc_alloc_txqueue() 296 call->send_queue = tq; in rxrpc_alloc_txqueue() 306 call->send_queue = tq; in rxrpc_alloc_txqueue() 397 if (!call->send_queue || !((call->send_top + 1) & RXRPC_TXQ_MASK)) { in rxrpc_send_data()
|
H A D | ar-internal.h | 700 struct rxrpc_txqueue *send_queue; /* Queue that sendmsg is writing into */ member
|
/linux/drivers/net/ethernet/mellanox/mlx5/core/steering/hws/ |
H A D | send.c | 562 return hws_send_engine_poll(&ctx->send_queue[queue_id], res, res_nb); in mlx5hws_send_queue_poll() 951 mlx5hws_send_queue_close(&ctx->send_queue[queues]); in __hws_send_queues_close() 975 kfree(ctx->send_queue); in mlx5hws_send_queues_close() 1030 ctx->send_queue = kcalloc(ctx->queues, sizeof(*ctx->send_queue), GFP_KERNEL); in mlx5hws_send_queues_open() 1031 if (!ctx->send_queue) { in mlx5hws_send_queues_open() 1043 err = mlx5hws_send_queue_open(ctx, &ctx->send_queue[i], queue_size); in mlx5hws_send_queues_open() 1053 kfree(ctx->send_queue); in mlx5hws_send_queues_open() 1070 queue = &ctx->send_queue[queue_id]; in mlx5hws_send_queue_action() 1192 queue_id = queue - ctx->send_queue; in mlx5hws_send_stes_fw()
|
/linux/drivers/infiniband/core/ |
H A D | mad.c | 1004 mad_send_wr->mad_list.mad_queue = &qp_info->send_queue; in ib_send_mad() 1031 spin_lock_irqsave(&qp_info->send_queue.lock, flags); in ib_send_mad() 1032 if (qp_info->send_queue.count < qp_info->send_queue.max_active) { in ib_send_mad() 1036 list = &qp_info->send_queue.list; in ib_send_mad() 1043 qp_info->send_queue.count++; in ib_send_mad() 1046 spin_unlock_irqrestore(&qp_info->send_queue.lock, flags); in ib_send_mad() 2273 struct ib_mad_queue *send_queue; in ib_mad_send_done() local 2288 send_queue = mad_list->mad_queue; in ib_mad_send_done() 2289 qp_info = send_queue->qp_info; in ib_mad_send_done() 2302 spin_lock_irqsave(&send_queue->lock, flags); in ib_mad_send_done() [all …]
|
H A D | mad_priv.h | 189 struct ib_mad_queue send_queue; member
|
/linux/fs/dlm/ |
H A D | midcomms.c | 164 struct list_head send_queue; member 310 list_for_each_entry_rcu(mh, &node->send_queue, list) { in dlm_send_queue_flush() 362 INIT_LIST_HEAD(&node->send_queue); in dlm_midcomms_addr() 455 list_for_each_entry_rcu(mh, &node->send_queue, list) { in dlm_receive_ack() 466 list_for_each_entry_rcu(mh, &node->send_queue, list) { in dlm_receive_ack() 941 list_for_each_entry_rcu(mh, &node->send_queue, list) { in dlm_midcomms_unack_msg_resend() 971 list_add_tail_rcu(&mh->list, &mh->node->send_queue); in midcomms_new_msg_cb()
|
/linux/drivers/net/hamradio/ |
H A D | yam.c | 125 struct sk_buff_head send_queue; /* Packets awaiting transmission */ member 588 skb_queue_tail(&yp->send_queue, skb); in yam_send_packet() 608 skb_queue_empty(&yp->send_queue)) in yam_arbitrate() 658 if (!(skb = skb_dequeue(&yp->send_queue))) { in yam_tx_byte() 702 if (skb_queue_empty(&yp->send_queue)) { in yam_tx_byte() 913 while ((skb = skb_dequeue(&yp->send_queue))) in yam_close() 1098 skb_queue_head_init(&yp->send_queue); in yam_setup()
|
/linux/drivers/net/ |
H A D | virtio_net.c | 281 struct send_queue { struct 392 struct send_queue *sq; 517 static void virtnet_xsk_completed(struct send_queue *sq, int num); 564 static int virtnet_add_outbuf(struct send_queue *sq, int num, void *data, in virtnet_add_outbuf() 583 static void __free_old_xmit(struct send_queue *sq, struct netdev_queue *txq, in __free_old_xmit() 627 static void virtnet_free_old_xmit(struct send_queue *sq, in virtnet_free_old_xmit() 1062 static void free_old_xmit(struct send_queue *sq, struct netdev_queue *txq, in free_old_xmit() 1093 struct send_queue *sq) in check_sq_full_and_disable() 1438 static int virtnet_xsk_xmit_one(struct send_queue *sq, in virtnet_xsk_xmit_one() 1459 static int virtnet_xsk_xmit_batch(struct send_queue *sq, in virtnet_xsk_xmit_batch() [all …]
|