Commit 4601cc39 authored by Frank Schaefer's avatar Frank Schaefer Committed by Mauro Carvalho Chehab

[media] em28xx: rename function em28xx_isoc_copy_vbi and extend for USB bulk transfers

The URB data processing for bulk transfers is very similar to what
is done with isoc transfers, so create a common function that works
with both transfer types based on the existing isoc function.

[mchehab@redhat.com: Fix a CodingStyle issue: don't break strings
 into separate lines]
Signed-off-by: default avatarFrank Schäfer <fschaefer.oss@googlemail.com>
Signed-off-by: default avatarMauro Carvalho Chehab <mchehab@redhat.com>
parent 0fa4a402
...@@ -518,18 +518,16 @@ static inline int em28xx_urb_data_copy(struct em28xx *dev, struct urb *urb) ...@@ -518,18 +518,16 @@ static inline int em28xx_urb_data_copy(struct em28xx *dev, struct urb *urb)
return rc; return rc;
} }
/* Version of isoc handler that takes into account a mixture of video and /* Version of the urb data handler that takes into account a mixture of
VBI data */ video and VBI data */
static inline int em28xx_isoc_copy_vbi(struct em28xx *dev, struct urb *urb) static inline int em28xx_urb_data_copy_vbi(struct em28xx *dev, struct urb *urb)
{ {
struct em28xx_buffer *buf, *vbi_buf; struct em28xx_buffer *buf, *vbi_buf;
struct em28xx_dmaqueue *dma_q = &dev->vidq; struct em28xx_dmaqueue *dma_q = &dev->vidq;
struct em28xx_dmaqueue *vbi_dma_q = &dev->vbiq; struct em28xx_dmaqueue *vbi_dma_q = &dev->vbiq;
unsigned char *outp = NULL; int xfer_bulk, vbi_size, num_packets, i, rc = 1;
unsigned char *vbioutp = NULL; unsigned int actual_length, len = 0;
int i, len = 0, rc = 1; unsigned char *p, *outp = NULL, *vbioutp = NULL;
unsigned char *p;
int vbi_size;
if (!dev) if (!dev)
return 0; return 0;
...@@ -540,6 +538,8 @@ static inline int em28xx_isoc_copy_vbi(struct em28xx *dev, struct urb *urb) ...@@ -540,6 +538,8 @@ static inline int em28xx_isoc_copy_vbi(struct em28xx *dev, struct urb *urb)
if (urb->status < 0) if (urb->status < 0)
print_err_status(dev, -1, urb->status); print_err_status(dev, -1, urb->status);
xfer_bulk = usb_pipebulk(urb->pipe);
buf = dev->usb_ctl.vid_buf; buf = dev->usb_ctl.vid_buf;
if (buf != NULL) if (buf != NULL)
outp = videobuf_to_vmalloc(&buf->vb); outp = videobuf_to_vmalloc(&buf->vb);
...@@ -548,28 +548,40 @@ static inline int em28xx_isoc_copy_vbi(struct em28xx *dev, struct urb *urb) ...@@ -548,28 +548,40 @@ static inline int em28xx_isoc_copy_vbi(struct em28xx *dev, struct urb *urb)
if (vbi_buf != NULL) if (vbi_buf != NULL)
vbioutp = videobuf_to_vmalloc(&vbi_buf->vb); vbioutp = videobuf_to_vmalloc(&vbi_buf->vb);
for (i = 0; i < urb->number_of_packets; i++) { if (xfer_bulk) /* bulk */
int status = urb->iso_frame_desc[i].status; num_packets = 1;
else /* isoc */
num_packets = urb->number_of_packets;
if (status < 0) { for (i = 0; i < num_packets; i++) {
print_err_status(dev, i, status); if (xfer_bulk) { /* bulk */
if (urb->iso_frame_desc[i].status != -EPROTO) actual_length = urb->actual_length;
p = urb->transfer_buffer;
} else { /* isoc */
if (urb->iso_frame_desc[i].status < 0) {
print_err_status(dev, i,
urb->iso_frame_desc[i].status);
if (urb->iso_frame_desc[i].status != -EPROTO)
continue;
}
actual_length = urb->iso_frame_desc[i].actual_length;
if (actual_length > dev->max_pkt_size) {
em28xx_isocdbg("packet bigger than packet size");
continue; continue;
} }
len = urb->iso_frame_desc[i].actual_length; p = urb->transfer_buffer +
if (urb->iso_frame_desc[i].actual_length <= 0) { urb->iso_frame_desc[i].offset;
/* em28xx_isocdbg("packet %d is empty",i); - spammy */
continue;
} }
if (urb->iso_frame_desc[i].actual_length >
dev->max_pkt_size) { if (actual_length <= 0) {
em28xx_isocdbg("packet bigger than packet size"); /* NOTE: happens very often with isoc transfers */
/* em28xx_usbdbg("packet %d is empty",i); - spammy */
continue; continue;
} }
p = urb->transfer_buffer + urb->iso_frame_desc[i].offset;
/* capture type 0 = vbi start /* capture type 0 = vbi start
capture type 1 = video start capture type 1 = video start
capture type 2 = video in progress */ capture type 2 = video in progress */
...@@ -579,16 +591,20 @@ static inline int em28xx_isoc_copy_vbi(struct em28xx *dev, struct urb *urb) ...@@ -579,16 +591,20 @@ static inline int em28xx_isoc_copy_vbi(struct em28xx *dev, struct urb *urb)
em28xx_isocdbg("VBI START HEADER!!!\n"); em28xx_isocdbg("VBI START HEADER!!!\n");
dev->cur_field = p[2]; dev->cur_field = p[2];
p += 4; p += 4;
len -= 4; len = actual_length - 4;
} else if (p[0] == 0x88 && p[1] == 0x88 && } else if (p[0] == 0x88 && p[1] == 0x88 &&
p[2] == 0x88 && p[3] == 0x88) { p[2] == 0x88 && p[3] == 0x88) {
/* continuation */ /* continuation */
p += 4; p += 4;
len -= 4; len = actual_length - 4;
} else if (p[0] == 0x22 && p[1] == 0x5a) { } else if (p[0] == 0x22 && p[1] == 0x5a) {
/* start video */ /* start video */
p += 4; p += 4;
len -= 4; len = actual_length - 4;
} else {
/* NOTE: With bulk transfers, intermediate data packets
* have no continuation header */
len = actual_length;
} }
vbi_size = dev->vbi_width * dev->vbi_height; vbi_size = dev->vbi_width * dev->vbi_height;
...@@ -776,7 +792,7 @@ buffer_prepare(struct videobuf_queue *vq, struct videobuf_buffer *vb, ...@@ -776,7 +792,7 @@ buffer_prepare(struct videobuf_queue *vq, struct videobuf_buffer *vb,
EM28XX_NUM_BUFS, EM28XX_NUM_BUFS,
dev->max_pkt_size, dev->max_pkt_size,
EM28XX_NUM_ISOC_PACKETS, EM28XX_NUM_ISOC_PACKETS,
em28xx_isoc_copy_vbi); em28xx_urb_data_copy_vbi);
else else
rc = em28xx_init_usb_xfer(dev, EM28XX_ANALOG_MODE, 0, rc = em28xx_init_usb_xfer(dev, EM28XX_ANALOG_MODE, 0,
EM28XX_NUM_BUFS, EM28XX_NUM_BUFS,
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment