ZeroCopyRx.c 988 B

123456789101112131415161718192021222324252627282930313233343536373839
  1. typedef struct my_custom_pbuf
  2. {
  3. struct pbuf_custom p;
  4. void* dma_descriptor;
  5. } my_custom_pbuf_t;
  6. LWIP_MEMPOOL_DECLARE(RX_POOL, 10, sizeof(my_custom_pbuf_t), "Zero-copy RX PBUF pool");
  7. void my_pbuf_free_custom(void* p)
  8. {
  9. my_custom_pbuf_t* my_puf = (my_custom_pbuf_t*)p;
  10. LOCK_INTERRUPTS();
  11. free_rx_dma_descriptor(my_pbuf->dma_descriptor);
  12. LWIP_MEMPOOL_FREE(RX_POOL, my_pbuf);
  13. UNLOCK_INTERRUPTS();
  14. }
  15. void eth_rx_irq()
  16. {
  17. dma_descriptor* dma_desc = get_RX_DMA_descriptor_from_ethernet();
  18. my_custom_pbuf_t* my_pbuf = (my_custom_pbuf_t*)LWIP_MEMPOOL_ALLOC(RX_POOL);
  19. my_pbuf->p.custom_free_function = my_pbuf_free_custom;
  20. my_pbuf->dma_descriptor = dma_desc;
  21. invalidate_cpu_cache(dma_desc->rx_data, dma_desc->rx_length);
  22. struct pbuf* p = pbuf_alloced_custom(PBUF_RAW,
  23. dma_desc->rx_length,
  24. PBUF_REF,
  25. &my_pbuf->p,
  26. dma_desc->rx_data,
  27. dma_desc->max_buffer_size);
  28. if(netif->input(p, netif) != ERR_OK) {
  29. pbuf_free(p);
  30. }
  31. }