Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 199972
b: refs/heads/master
c: 4b6ed9f
h: refs/heads/master
v: v3
  • Loading branch information
Stefan Ringel authored and Mauro Carvalho Chehab committed Jun 1, 2010
1 parent 938ce47 commit 962ee1d
Show file tree
Hide file tree
Showing 2 changed files with 46 additions and 44 deletions.
2 changes: 1 addition & 1 deletion [refs]
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
---
refs/heads/master: 3569417e5a2c20764158961a2f6c514d26136e5f
refs/heads/master: 4b6ed9fd0baf34da6912bebee46c36eda0411984
88 changes: 45 additions & 43 deletions trunk/drivers/staging/tm6000/tm6000-video.c
Original file line number Diff line number Diff line change
Expand Up @@ -339,14 +339,23 @@ static int copy_packet(struct urb *urb, u32 header, u8 **ptr, u8 *endp,
return rc;
}

static int copy_streams(u8 *data, u8 *out_p, unsigned long len,
struct urb *urb, struct tm6000_buffer **buf)
static int copy_streams(u8 *data, unsigned long len,
struct urb *urb)
{
struct tm6000_dmaqueue *dma_q = urb->context;
struct tm6000_core *dev= container_of(dma_q,struct tm6000_core,vidq);
u8 *ptr=data, *endp=data+len;
unsigned long header=0;
int rc=0;
struct tm6000_buffer *buf;
char *outp = NULL;

get_next_buf(dma_q, &buf);
if (buf)
outp = videobuf_to_vmalloc(&buf->vb);

if (!outp)
return 0;

for (ptr=data; ptr<endp;) {
if (!dev->isoc_ctl.cmd) {
Expand Down Expand Up @@ -394,14 +403,14 @@ static int copy_streams(u8 *data, u8 *out_p, unsigned long len,
}
HEADER:
/* Copy or continue last copy */
rc=copy_packet(urb,header,&ptr,endp,out_p,buf);
rc=copy_packet(urb,header,&ptr,endp,outp,&buf);
if (rc<0) {
buf=NULL;
printk(KERN_ERR "tm6000: buffer underrun at %ld\n",
jiffies);
return rc;
}
if (!*buf)
if (!buf)
return 0;
}

Expand All @@ -410,31 +419,40 @@ static int copy_streams(u8 *data, u8 *out_p, unsigned long len,
/*
* Identify the tm5600/6000 buffer header type and properly handles
*/
static int copy_multiplexed(u8 *ptr, u8 *out_p, unsigned long len,
struct urb *urb, struct tm6000_buffer **buf)
static int copy_multiplexed(u8 *ptr, unsigned long len,
struct urb *urb)
{
struct tm6000_dmaqueue *dma_q = urb->context;
struct tm6000_core *dev= container_of(dma_q,struct tm6000_core,vidq);
unsigned int pos=dev->isoc_ctl.pos,cpysize;
int rc=1;
struct tm6000_buffer *buf;
char *outp = NULL;

get_next_buf(dma_q, &buf);
if (buf)
outp = videobuf_to_vmalloc(&buf->vb);

if (!outp)
return 0;

while (len>0) {
cpysize=min(len,(*buf)->vb.size-pos);
//printk("Copying %d bytes (max=%lu) from %p to %p[%u]\n",cpysize,(*buf)->vb.size,ptr,out_p,pos);
memcpy(&out_p[pos], ptr, cpysize);
cpysize=min(len,buf->vb.size-pos);
//printk("Copying %d bytes (max=%lu) from %p to %p[%u]\n",cpysize,(*buf)->vb.size,ptr,out_p,pos);
memcpy(&outp[pos], ptr, cpysize);
pos+=cpysize;
ptr+=cpysize;
len-=cpysize;
if (pos >= (*buf)->vb.size) {
if (pos >= buf->vb.size) {
pos=0;
/* Announces that a new buffer were filled */
buffer_filled (dev, dma_q, *buf);
buffer_filled (dev, dma_q, buf);
dprintk(dev, V4L2_DEBUG_ISOC, "new buffer filled\n");
get_next_buf (dma_q, buf);
if (!*buf)
get_next_buf (dma_q, &buf);
if (!buf)
break;
out_p = videobuf_to_vmalloc(&((*buf)->vb));
if (!out_p)
outp = videobuf_to_vmalloc(&(buf->vb));
if (!outp)
return rc;
pos = 0;
}
Expand Down Expand Up @@ -493,52 +511,36 @@ static inline int tm6000_isoc_copy(struct urb *urb)
struct tm6000_dmaqueue *dma_q = urb->context;
struct tm6000_core *dev= container_of(dma_q,struct tm6000_core,vidq);
struct tm6000_buffer *buf;
int i, len=0, rc=1;
int size;
char *outp = NULL, *p;
unsigned long copied;
int i, len=0, rc=1, status;
char *p;

get_next_buf(dma_q, &buf);
if (buf)
outp = videobuf_to_vmalloc(&buf->vb);

if (!outp)
return 0;

size = buf->vb.size;

copied=0;

if (urb->status<0) {
print_err_status (dev,-1,urb->status);
if (urb->status < 0) {
print_err_status (dev, -1, urb->status);
return 0;
}

for (i = 0; i < urb->number_of_packets; i++) {
int status = urb->iso_frame_desc[i].status;
status = urb->iso_frame_desc[i].status;

if (status<0) {
print_err_status (dev,i,status);
continue;
}

len=urb->iso_frame_desc[i].actual_length;
len = urb->iso_frame_desc[i].actual_length;

// if (len>=TM6000_URB_MSG_LEN) {
p=urb->transfer_buffer + urb->iso_frame_desc[i].offset;
if (len > 0) {
p = urb->transfer_buffer + urb->iso_frame_desc[i].offset;
if (!urb->iso_frame_desc[i].status) {
if ((buf->fmt->fourcc)==V4L2_PIX_FMT_TM6000) {
rc=copy_multiplexed(p, outp, len, urb, &buf);
if ((dev->fourcc)==V4L2_PIX_FMT_TM6000) {
rc=copy_multiplexed(p, len, urb);
if (rc<=0)
return rc;
} else {
copy_streams(p, outp, len, urb, &buf);
copy_streams(p, len, urb);
}
}
copied += len;
if (copied >= size || !buf)
break;
// }
}
}
return rc;
}
Expand Down

0 comments on commit 962ee1d

Please sign in to comment.