Lines Matching defs:rxq
447 amb_rxq * rxq = &dev->rxq[pool];
452 spin_lock_irqsave (&rxq->lock, flags);
454 if (rxq->pending < rxq->maximum) {
455 PRINTD (DBG_RX, "RX in slot %p", rxq->in.ptr);
457 *rxq->in.ptr = *rx;
458 rxq->pending++;
459 rxq->in.ptr = NEXTQ (rxq->in.ptr, rxq->in.start, rxq->in.limit);
461 wr_mem (dev, offsetof(amb_mem, mb.adapter.rx_address[pool]), virt_to_bus (rxq->in.ptr));
463 spin_unlock_irqrestore (&rxq->lock, flags);
466 spin_unlock_irqrestore (&rxq->lock, flags);
472 amb_rxq * rxq = &dev->rxq[pool];
477 spin_lock_irqsave (&rxq->lock, flags);
479 if (rxq->pending && (rxq->out.ptr->status || rxq->out.ptr->length)) {
481 rx_complete (dev, rxq->out.ptr);
483 rxq->out.ptr->status = 0;
484 rxq->out.ptr->length = 0;
486 rxq->pending--;
487 rxq->out.ptr = NEXTQ (rxq->out.ptr, rxq->out.start, rxq->out.limit);
489 if (rxq->pending < rxq->low)
490 rxq->low = rxq->pending;
491 spin_unlock_irqrestore (&rxq->lock, flags);
494 if (!rxq->pending && rxq->buffers_wanted)
495 rxq->emptied++;
496 spin_unlock_irqrestore (&rxq->lock, flags);
505 amb_rxq * rxq = &dev->rxq[pool];
515 if (rxq->pending > rxq->buffers_wanted) {
522 while (rxq->pending > rxq->buffers_wanted)
543 amb_rxq * rxq;
550 rxq = &dev->rxq[pool];
551 while (rxq->pending < rxq->maximum && rxq->pending < rxq->buffers_wanted) {
553 struct sk_buff * skb = alloc_skb (rxq->buffer_size, priority);
863 if ((unsigned int) rxtp->max_sdu <= dev->rxq[pool].buffer_size) {
865 pool, rxtp->max_sdu, dev->rxq[pool].buffer_size);
942 if (!dev->rxq[pool].buffers_wanted)
943 dev->rxq[pool].buffers_wanted = rx_lats;
944 dev->rxq[pool].buffers_wanted += 1;
1035 dev->rxq[pool].buffers_wanted -= 1;
1036 if (dev->rxq[pool].buffers_wanted == rx_lats) {
1037 dev->rxq[pool].buffers_wanted = 0;
1170 amb_rxq * r = &dev->rxq[pool];
1181 amb_rxq * r = &dev->rxq[pool];
1297 amb_rxq * rxq = &dev->rxq[pool];
1299 rxq->buffer_size = rx_buffer_sizes[pool];
1300 rxq->buffers_wanted = 0;
1302 rxq->pending = 0;
1303 rxq->low = rxs[pool] - 1;
1304 rxq->emptied = 0;
1305 rxq->maximum = rxs[pool] - 1;
1307 rxq->in.start = in;
1308 rxq->in.ptr = in;
1309 rxq->in.limit = in + rxs[pool];
1311 memory = rxq->in.limit;
1314 rxq->out.start = out;
1315 rxq->out.ptr = out;
1316 rxq->out.limit = out + rxs[pool];
1318 memory = rxq->out.limit;
1336 // includes txq.in, txq.out, rxq[].in and rxq[].out
1697 a.rec_struct[pool].buffer_start = bus_addr (dev->rxq[pool].in.start);
1698 a.rec_struct[pool].buffer_end = bus_addr (dev->rxq[pool].in.limit);
1699 a.rec_struct[pool].rx_start = bus_addr (dev->rxq[pool].out.start);
1700 a.rec_struct[pool].rx_end = bus_addr (dev->rxq[pool].out.limit);
1701 a.rec_struct[pool].buffer_size = cpu_to_be32 (dev->rxq[pool].buffer_size);
1867 spin_lock_init (&dev->rxq[pool].lock);