Skip to content
Permalink
Browse files
WIP media: uvc: Use dma_alloc_noncontiguos API
Port uvc to dma_alloc_nontiguous.

This patch is "inspired" on https://lkml.org/lkml/2019/8/2/951

Signed-off-by: Ricardo Ribalda <ribalda@chromium.org>
  • Loading branch information
ribalda committed Nov 17, 2020
1 parent 817731c commit 08aff4b45dd51b3dfba18af4aa40b0fa5e2b5529
Show file tree
Hide file tree
Showing 2 changed files with 50 additions and 22 deletions.
@@ -15,6 +15,7 @@
#include <linux/vmalloc.h>
#include <linux/wait.h>
#include <linux/atomic.h>
#include <linux/usb/hcd.h>
#include <asm/unaligned.h>

#include <media/v4l2-common.h>
@@ -1641,6 +1642,11 @@ static void uvc_video_encode_bulk(struct uvc_urb *uvc_urb,
urb->transfer_buffer_length = stream->urb_size - len;
}

static inline struct device *stream_to_dmadev(struct uvc_streaming *stream)
{
return stream->dev->udev->bus->controller->parent;
}

static void uvc_video_complete(struct urb *urb)
{
struct uvc_urb *uvc_urb = urb->context;
@@ -1693,6 +1699,11 @@ static void uvc_video_complete(struct urb *urb)
* Process the URB headers, and optionally queue expensive memcpy tasks
* to be deferred to a work queue.
*/
if (uvc_urb->pages)
dma_sync_single_for_cpu(stream_to_dmadev(stream),
urb->transfer_dma,
urb->transfer_buffer_length,
DMA_FROM_DEVICE);
stream->decode(uvc_urb, buf, buf_meta);

/* If no async work is needed, resubmit the URB immediately. */
@@ -1722,18 +1733,48 @@ static void uvc_free_urb_buffers(struct uvc_streaming *stream)
if (!uvc_urb->buffer)
continue;

#ifndef CONFIG_DMA_NONCOHERENT
usb_free_coherent(stream->dev->udev, stream->urb_size,
uvc_urb->buffer, uvc_urb->dma);
#else
kfree(uvc_urb->buffer);
#endif
if (uvc_urb->pages) {
vunmap(uvc_urb->buffer);
dma_free_noncontiguous(stream_to_dmadev(stream),
stream->urb_size,
uvc_urb->pages, uvc_urb->dma);
} else {
usb_free_coherent(stream->dev->udev, stream->urb_size,
uvc_urb->buffer, uvc_urb->dma);
}

uvc_urb->buffer = NULL;
}

stream->urb_size = 0;
}

static bool uvc_alloc_urb_buffer(struct uvc_streaming *stream, struct uvc_urb *uvc_urb,
gfp_t gfp_flags)
{
struct device *dma_dev = stream_to_dmadev(stream);

if (!dma_can_alloc_noncontiguous(dma_dev)) {
uvc_urb->buffer = usb_alloc_coherent(stream->dev->udev, stream->urb_size,
gfp_flags | __GFP_NOWARN, &uvc_urb->dma);
return uvc_urb->buffer != NULL;
}

uvc_urb->pages = dma_alloc_noncontiguous(dma_dev, stream->urb_size,
&uvc_urb->dma, gfp_flags | __GFP_NOWARN, 0);
if (!uvc_urb->pages)
return false;

uvc_urb->buffer = vmap(uvc_urb->pages, PAGE_ALIGN(stream->urb_size) >> PAGE_SHIFT,
VM_DMA_COHERENT, PAGE_KERNEL);
if (!uvc_urb->buffer) {
dma_free_noncontiguous(dma_dev, stream->urb_size, uvc_urb->pages, uvc_urb->dma);
return false;
}

return true;
}

/*
* Allocate transfer buffers. This function can be called with buffers
* already allocated when resuming from suspend, in which case it will
@@ -1764,19 +1805,11 @@ static int uvc_alloc_urb_buffers(struct uvc_streaming *stream,

/* Retry allocations until one succeed. */
for (; npackets > 1; npackets /= 2) {
stream->urb_size = psize * npackets;
for (i = 0; i < UVC_URBS; ++i) {
struct uvc_urb *uvc_urb = &stream->uvc_urb[i];

stream->urb_size = psize * npackets;
#ifndef CONFIG_DMA_NONCOHERENT
uvc_urb->buffer = usb_alloc_coherent(
stream->dev->udev, stream->urb_size,
gfp_flags | __GFP_NOWARN, &uvc_urb->dma);
#else
uvc_urb->buffer =
kmalloc(stream->urb_size, gfp_flags | __GFP_NOWARN);
#endif
if (!uvc_urb->buffer) {
if (!uvc_alloc_urb_buffer(stream, uvc_urb, gfp_flags)) {
uvc_free_urb_buffers(stream);
break;
}
@@ -1885,12 +1918,8 @@ static int uvc_init_video_isoc(struct uvc_streaming *stream,
urb->context = uvc_urb;
urb->pipe = usb_rcvisocpipe(stream->dev->udev,
ep->desc.bEndpointAddress);
#ifndef CONFIG_DMA_NONCOHERENT
urb->transfer_flags = URB_ISO_ASAP | URB_NO_TRANSFER_DMA_MAP;
urb->transfer_dma = uvc_urb->dma;
#else
urb->transfer_flags = URB_ISO_ASAP;
#endif
urb->interval = ep->desc.bInterval;
urb->transfer_buffer = uvc_urb->buffer;
urb->complete = uvc_video_complete;
@@ -1950,10 +1979,8 @@ static int uvc_init_video_bulk(struct uvc_streaming *stream,

usb_fill_bulk_urb(urb, stream->dev->udev, pipe, uvc_urb->buffer,
size, uvc_video_complete, uvc_urb);
#ifndef CONFIG_DMA_NONCOHERENT
urb->transfer_flags = URB_NO_TRANSFER_DMA_MAP;
urb->transfer_dma = uvc_urb->dma;
#endif

uvc_urb->urb = urb;
}
@@ -544,6 +544,7 @@ struct uvc_urb {

char *buffer;
dma_addr_t dma;
struct page **pages;

unsigned int async_operations;
struct uvc_copy_op copy_operations[UVC_MAX_PACKETS];

0 comments on commit 08aff4b

Please sign in to comment.