kernel/drivers/media/usb/usbvision/usbvision-core.c

   1 /*
   2  * usbvision-core.c - driver for NT100x USB video capture devices
   3  *
   4  *
   5  * Copyright (c) 1999-2005 Joerg Heckenbach <joerg@heckenbach-aw.de>
   6  *                         Dwaine Garden <dwainegarden@rogers.com>
   7  *
   8  * This module is part of usbvision driver project.
   9  * Updates to driver completed by Dwaine P. Garden
  10  *
  11  * This program is free software; you can redistribute it and/or modify
  12  * it under the terms of the GNU General Public License as published by
  13  * the Free Software Foundation; either version 2 of the License, or
  14  * (at your option) any later version.
  15  *
  16  * This program is distributed in the hope that it will be useful,
  17  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  18  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  19  * GNU General Public License for more details.
  20  *
  21  * You should have received a copy of the GNU General Public License
  22  * along with this program; if not, write to the Free Software
  23  * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  24  */
  25
  26 #include <linux/kernel.h>
  27 #include <linux/list.h>
  28 #include <linux/timer.h>
  29 #include <linux/gfp.h>
  30 #include <linux/mm.h>
  31 #include <linux/highmem.h>
  32 #include <linux/vmalloc.h>
  33 #include <linux/module.h>
  34 #include <linux/init.h>
  35 #include <linux/spinlock.h>
  36 #include <linux/io.h>
  37 #include <linux/videodev2.h>
  38 #include <linux/i2c.h>
  39
  40 #include <media/saa7115.h>
  41 #include <media/v4l2-common.h>
  42 #include <media/tuner.h>
  43
  44 #include <linux/workqueue.h>
  45
  46 #include "usbvision.h"
  47
  48 static unsigned int core_debug;
  49 module_param(core_debug, int, 0644);
  50 MODULE_PARM_DESC(core_debug, "enable debug messages [core]");
  51
  52 static int adjust_compression = 1;      /* Set the compression to be adaptive */
  53 module_param(adjust_compression, int, 0444);
  54 MODULE_PARM_DESC(adjust_compression, " Set the ADPCM compression for the device.  Default: 1 (On)");
  55
  56 /* To help people with Black and White output with using s-video input.
  57  * Some cables and input device are wired differently. */
  58 static int switch_svideo_input;
  59 module_param(switch_svideo_input, int, 0444);
  60 MODULE_PARM_DESC(switch_svideo_input, " Set the S-Video input.  Some cables and input device are wired differently. Default: 0 (Off)");
  61
  62 static unsigned int adjust_x_offset = -1;
  63 module_param(adjust_x_offset, int, 0644);
  64 MODULE_PARM_DESC(adjust_x_offset, "adjust X offset display [core]");
  65
  66 static unsigned int adjust_y_offset = -1;
  67 module_param(adjust_y_offset, int, 0644);
  68 MODULE_PARM_DESC(adjust_y_offset, "adjust Y offset display [core]");
  69
  70
  71 #define ENABLE_HEXDUMP  0       /* Enable if you need it */
  72
  73
  74 #ifdef USBVISION_DEBUG
  75         #define PDEBUG(level, fmt, args...) { \
  76                 if (core_debug & (level)) \
  77                         printk(KERN_INFO KBUILD_MODNAME ":[%s:%d] " fmt, \
  78                                 __func__, __LINE__ , ## args); \
  79         }
  80 #else
  81         #define PDEBUG(level, fmt, args...) do {} while (0)
  82 #endif
  83
  84 #define DBG_HEADER      (1 << 0)
  85 #define DBG_IRQ         (1 << 1)
  86 #define DBG_ISOC        (1 << 2)
  87 #define DBG_PARSE       (1 << 3)
  88 #define DBG_SCRATCH     (1 << 4)
  89 #define DBG_FUNC        (1 << 5)
  90
  91 static const int max_imgwidth = MAX_FRAME_WIDTH;
  92 static const int max_imgheight = MAX_FRAME_HEIGHT;
  93 static const int min_imgwidth = MIN_FRAME_WIDTH;
  94 static const int min_imgheight = MIN_FRAME_HEIGHT;
  95
  96 /* The value of 'scratch_buf_size' affects quality of the picture
  97  * in many ways. Shorter buffers may cause loss of data when client
  98  * is too slow. Larger buffers are memory-consuming and take longer
  99  * to work with. This setting can be adjusted, but the default value
 100  * should be OK for most desktop users.
 101  */
 102 #define DEFAULT_SCRATCH_BUF_SIZE        (0x20000)               /* 128kB memory scratch buffer */
 103 static const int scratch_buf_size = DEFAULT_SCRATCH_BUF_SIZE;
 104
 105 /* Function prototypes */
 106 static int usbvision_request_intra(struct usb_usbvision *usbvision);
 107 static int usbvision_unrequest_intra(struct usb_usbvision *usbvision);
 108 static int usbvision_adjust_compression(struct usb_usbvision *usbvision);
 109 static int usbvision_measure_bandwidth(struct usb_usbvision *usbvision);
 110
 111 /*******************************/
 112 /* Memory management functions */
 113 /*******************************/
 114
 115 /*
 116  * Here we want the physical address of the memory.
 117  * This is used when initializing the contents of the area.
 118  */
 119
 120 static void *usbvision_rvmalloc(unsigned long size)
 121 {
 122         void *mem;
 123         unsigned long adr;
 124
 125         size = PAGE_ALIGN(size);
 126         mem = vmalloc_32(size);
 127         if (!mem)
 128                 return NULL;
 129
 130         memset(mem, 0, size); /* Clear the ram out, no junk to the user */
 131         adr = (unsigned long) mem;
 132         while (size > 0) {
 133                 SetPageReserved(vmalloc_to_page((void *)adr));
 134                 adr += PAGE_SIZE;
 135                 size -= PAGE_SIZE;
 136         }
 137
 138         return mem;
 139 }
 140
 141 static void usbvision_rvfree(void *mem, unsigned long size)
 142 {
 143         unsigned long adr;
 144
 145         if (!mem)
 146                 return;
 147
 148         size = PAGE_ALIGN(size);
 149
 150         adr = (unsigned long) mem;
 151         while ((long) size > 0) {
 152                 ClearPageReserved(vmalloc_to_page((void *)adr));
 153                 adr += PAGE_SIZE;
 154                 size -= PAGE_SIZE;
 155         }
 156
 157         vfree(mem);
 158 }
 159
 160
 161 #if ENABLE_HEXDUMP
 162 static void usbvision_hexdump(const unsigned char *data, int len)
 163 {
 164         char tmp[80];
 165         int i, k;
 166
 167         for (i = k = 0; len > 0; i++, len--) {
 168                 if (i > 0 && (i % 16 == 0)) {
 169                         printk("%s\n", tmp);
 170                         k = 0;
 171                 }
 172                 k += sprintf(&tmp[k], "%02x ", data[i]);
 173         }
 174         if (k > 0)
 175                 printk(KERN_CONT "%s\n", tmp);
 176 }
 177 #endif
 178
 179 /********************************
 180  * scratch ring buffer handling
 181  ********************************/
 182 static int scratch_len(struct usb_usbvision *usbvision)    /* This returns the amount of data actually in the buffer */
 183 {
 184         int len = usbvision->scratch_write_ptr - usbvision->scratch_read_ptr;
 185
 186         if (len < 0)
 187                 len += scratch_buf_size;
 188         PDEBUG(DBG_SCRATCH, "scratch_len() = %d\n", len);
 189
 190         return len;
 191 }
 192
 193
 194 /* This returns the free space left in the buffer */
 195 static int scratch_free(struct usb_usbvision *usbvision)
 196 {
 197         int free = usbvision->scratch_read_ptr - usbvision->scratch_write_ptr;
 198         if (free <= 0)
 199                 free += scratch_buf_size;
 200         if (free) {
 201                 free -= 1;                                                      /* at least one byte in the buffer must */
 202                                                                                 /* left blank, otherwise there is no chance to differ between full and empty */
 203         }
 204         PDEBUG(DBG_SCRATCH, "return %d\n", free);
 205
 206         return free;
 207 }
 208
 209
 210 /* This puts data into the buffer */
 211 static int scratch_put(struct usb_usbvision *usbvision, unsigned char *data,
 212                        int len)
 213 {
 214         int len_part;
 215
 216         if (usbvision->scratch_write_ptr + len < scratch_buf_size) {
 217                 memcpy(usbvision->scratch + usbvision->scratch_write_ptr, data, len);
 218                 usbvision->scratch_write_ptr += len;
 219         } else {
 220                 len_part = scratch_buf_size - usbvision->scratch_write_ptr;
 221                 memcpy(usbvision->scratch + usbvision->scratch_write_ptr, data, len_part);
 222                 if (len == len_part) {
 223                         usbvision->scratch_write_ptr = 0;                       /* just set write_ptr to zero */
 224                 } else {
 225                         memcpy(usbvision->scratch, data + len_part, len - len_part);
 226                         usbvision->scratch_write_ptr = len - len_part;
 227                 }
 228         }
 229
 230         PDEBUG(DBG_SCRATCH, "len=%d, new write_ptr=%d\n", len, usbvision->scratch_write_ptr);
 231
 232         return len;
 233 }
 234
 235 /* This marks the write_ptr as position of new frame header */
 236 static void scratch_mark_header(struct usb_usbvision *usbvision)
 237 {
 238         PDEBUG(DBG_SCRATCH, "header at write_ptr=%d\n", usbvision->scratch_headermarker_write_ptr);
 239
 240         usbvision->scratch_headermarker[usbvision->scratch_headermarker_write_ptr] =
 241                                 usbvision->scratch_write_ptr;
 242         usbvision->scratch_headermarker_write_ptr += 1;
 243         usbvision->scratch_headermarker_write_ptr %= USBVISION_NUM_HEADERMARKER;
 244 }
 245
 246 /* This gets data from the buffer at the given "ptr" position */
 247 static int scratch_get_extra(struct usb_usbvision *usbvision,
 248                              unsigned char *data, int *ptr, int len)
 249 {
 250         int len_part;
 251
 252         if (*ptr + len < scratch_buf_size) {
 253                 memcpy(data, usbvision->scratch + *ptr, len);
 254                 *ptr += len;
 255         } else {
 256                 len_part = scratch_buf_size - *ptr;
 257                 memcpy(data, usbvision->scratch + *ptr, len_part);
 258                 if (len == len_part) {
 259                         *ptr = 0;                                                       /* just set the y_ptr to zero */
 260                 } else {
 261                         memcpy(data + len_part, usbvision->scratch, len - len_part);
 262                         *ptr = len - len_part;
 263                 }
 264         }
 265
 266         PDEBUG(DBG_SCRATCH, "len=%d, new ptr=%d\n", len, *ptr);
 267
 268         return len;
 269 }
 270
 271
 272 /* This sets the scratch extra read pointer */
 273 static void scratch_set_extra_ptr(struct usb_usbvision *usbvision, int *ptr,
 274                                   int len)
 275 {
 276         *ptr = (usbvision->scratch_read_ptr + len) % scratch_buf_size;
 277
 278         PDEBUG(DBG_SCRATCH, "ptr=%d\n", *ptr);
 279 }
 280
 281
 282 /* This increments the scratch extra read pointer */
 283 static void scratch_inc_extra_ptr(int *ptr, int len)
 284 {
 285         *ptr = (*ptr + len) % scratch_buf_size;
 286
 287         PDEBUG(DBG_SCRATCH, "ptr=%d\n", *ptr);
 288 }
 289
 290
 291 /* This gets data from the buffer */
 292 static int scratch_get(struct usb_usbvision *usbvision, unsigned char *data,
 293                        int len)
 294 {
 295         int len_part;
 296
 297         if (usbvision->scratch_read_ptr + len < scratch_buf_size) {
 298                 memcpy(data, usbvision->scratch + usbvision->scratch_read_ptr, len);
 299                 usbvision->scratch_read_ptr += len;
 300         } else {
 301                 len_part = scratch_buf_size - usbvision->scratch_read_ptr;
 302                 memcpy(data, usbvision->scratch + usbvision->scratch_read_ptr, len_part);
 303                 if (len == len_part) {
 304                         usbvision->scratch_read_ptr = 0;                                /* just set the read_ptr to zero */
 305                 } else {
 306                         memcpy(data + len_part, usbvision->scratch, len - len_part);
 307                         usbvision->scratch_read_ptr = len - len_part;
 308                 }
 309         }
 310
 311         PDEBUG(DBG_SCRATCH, "len=%d, new read_ptr=%d\n", len, usbvision->scratch_read_ptr);
 312
 313         return len;
 314 }
 315
 316
 317 /* This sets read pointer to next header and returns it */
 318 static int scratch_get_header(struct usb_usbvision *usbvision,
 319                               struct usbvision_frame_header *header)
 320 {
 321         int err_code = 0;
 322
 323         PDEBUG(DBG_SCRATCH, "from read_ptr=%d", usbvision->scratch_headermarker_read_ptr);
 324
 325         while (usbvision->scratch_headermarker_write_ptr -
 326                 usbvision->scratch_headermarker_read_ptr != 0) {
 327                 usbvision->scratch_read_ptr =
 328                         usbvision->scratch_headermarker[usbvision->scratch_headermarker_read_ptr];
 329                 usbvision->scratch_headermarker_read_ptr += 1;
 330                 usbvision->scratch_headermarker_read_ptr %= USBVISION_NUM_HEADERMARKER;
 331                 scratch_get(usbvision, (unsigned char *)header, USBVISION_HEADER_LENGTH);
 332                 if ((header->magic_1 == USBVISION_MAGIC_1)
 333                          && (header->magic_2 == USBVISION_MAGIC_2)
 334                          && (header->header_length == USBVISION_HEADER_LENGTH)) {
 335                         err_code = USBVISION_HEADER_LENGTH;
 336                         header->frame_width  = header->frame_width_lo  + (header->frame_width_hi << 8);
 337                         header->frame_height = header->frame_height_lo + (header->frame_height_hi << 8);
 338                         break;
 339                 }
 340         }
 341
 342         return err_code;
 343 }
 344
 345
 346 /* This removes len bytes of old data from the buffer */
 347 static void scratch_rm_old(struct usb_usbvision *usbvision, int len)
 348 {
 349         usbvision->scratch_read_ptr += len;
 350         usbvision->scratch_read_ptr %= scratch_buf_size;
 351         PDEBUG(DBG_SCRATCH, "read_ptr is now %d\n", usbvision->scratch_read_ptr);
 352 }
 353
 354
 355 /* This resets the buffer - kills all data in it too */
 356 static void scratch_reset(struct usb_usbvision *usbvision)
 357 {
 358         PDEBUG(DBG_SCRATCH, "\n");
 359
 360         usbvision->scratch_read_ptr = 0;
 361         usbvision->scratch_write_ptr = 0;
 362         usbvision->scratch_headermarker_read_ptr = 0;
 363         usbvision->scratch_headermarker_write_ptr = 0;
 364         usbvision->isocstate = isoc_state_no_frame;
 365 }
 366
 367 int usbvision_scratch_alloc(struct usb_usbvision *usbvision)
 368 {
 369         usbvision->scratch = vmalloc_32(scratch_buf_size);
 370         scratch_reset(usbvision);
 371         if (usbvision->scratch == NULL) {
 372                 dev_err(&usbvision->dev->dev,
 373                         "%s: unable to allocate %d bytes for scratch\n",
 374                                 __func__, scratch_buf_size);
 375                 return -ENOMEM;
 376         }
 377         return 0;
 378 }
 379
 380 void usbvision_scratch_free(struct usb_usbvision *usbvision)
 381 {
 382         vfree(usbvision->scratch);
 383         usbvision->scratch = NULL;
 384 }
 385
 386 /*
 387  * usbvision_decompress_alloc()
 388  *
 389  * allocates intermediate buffer for decompression
 390  */
 391 int usbvision_decompress_alloc(struct usb_usbvision *usbvision)
 392 {
 393         int IFB_size = MAX_FRAME_WIDTH * MAX_FRAME_HEIGHT * 3 / 2;
 394
 395         usbvision->intra_frame_buffer = vmalloc_32(IFB_size);
 396         if (usbvision->intra_frame_buffer == NULL) {
 397                 dev_err(&usbvision->dev->dev,
 398                         "%s: unable to allocate %d for compr. frame buffer\n",
 399                                 __func__, IFB_size);
 400                 return -ENOMEM;
 401         }
 402         return 0;
 403 }
 404
 405 /*
 406  * usbvision_decompress_free()
 407  *
 408  * frees intermediate buffer for decompression
 409  */
 410 void usbvision_decompress_free(struct usb_usbvision *usbvision)
 411 {
 412         vfree(usbvision->intra_frame_buffer);
 413         usbvision->intra_frame_buffer = NULL;
 414
 415 }
 416
 417 /************************************************************
 418  * Here comes the data parsing stuff that is run as interrupt
 419  ************************************************************/
 420 /*
 421  * usbvision_find_header()
 422  *
 423  * Locate one of supported header markers in the scratch buffer.
 424  */
 425 static enum parse_state usbvision_find_header(struct usb_usbvision *usbvision)
 426 {
 427         struct usbvision_frame *frame;
 428         int found_header = 0;
 429
 430         frame = usbvision->cur_frame;
 431
 432         while (scratch_get_header(usbvision, &frame->isoc_header) == USBVISION_HEADER_LENGTH) {
 433                 /* found header in scratch */
 434                 PDEBUG(DBG_HEADER, "found header: 0x%02x%02x %d %d %d %d %#x 0x%02x %u %u",
 435                                 frame->isoc_header.magic_2,
 436                                 frame->isoc_header.magic_1,
 437                                 frame->isoc_header.header_length,
 438                                 frame->isoc_header.frame_num,
 439                                 frame->isoc_header.frame_phase,
 440                                 frame->isoc_header.frame_latency,
 441                                 frame->isoc_header.data_format,
 442                                 frame->isoc_header.format_param,
 443                                 frame->isoc_header.frame_width,
 444                                 frame->isoc_header.frame_height);
 445
 446                 if (usbvision->request_intra) {
 447                         if (frame->isoc_header.format_param & 0x80) {
 448                                 found_header = 1;
 449                                 usbvision->last_isoc_frame_num = -1; /* do not check for lost frames this time */
 450                                 usbvision_unrequest_intra(usbvision);
 451                                 break;
 452                         }
 453                 } else {
 454                         found_header = 1;
 455                         break;
 456                 }
 457         }
 458
 459         if (found_header) {
 460                 frame->frmwidth = frame->isoc_header.frame_width * usbvision->stretch_width;
 461                 frame->frmheight = frame->isoc_header.frame_height * usbvision->stretch_height;
 462                 frame->v4l2_linesize = (frame->frmwidth * frame->v4l2_format.depth) >> 3;
 463         } else { /* no header found */
 464                 PDEBUG(DBG_HEADER, "skipping scratch data, no header");
 465                 scratch_reset(usbvision);
 466                 return parse_state_end_parse;
 467         }
 468
 469         /* found header */
 470         if (frame->isoc_header.data_format == ISOC_MODE_COMPRESS) {
 471                 /* check isoc_header.frame_num for lost frames */
 472                 if (usbvision->last_isoc_frame_num >= 0) {
 473                         if (((usbvision->last_isoc_frame_num + 1) % 32) != frame->isoc_header.frame_num) {
 474                                 /* unexpected frame drop: need to request new intra frame */
 475                                 PDEBUG(DBG_HEADER, "Lost frame before %d on USB", frame->isoc_header.frame_num);
 476                                 usbvision_request_intra(usbvision);
 477                                 return parse_state_next_frame;
 478                         }
 479                 }
 480                 usbvision->last_isoc_frame_num = frame->isoc_header.frame_num;
 481         }
 482         usbvision->header_count++;
 483         frame->scanstate = scan_state_lines;
 484         frame->curline = 0;
 485
 486         return parse_state_continue;
 487 }
 488
 489 static enum parse_state usbvision_parse_lines_422(struct usb_usbvision *usbvision,
 490                                            long *pcopylen)
 491 {
 492         volatile struct usbvision_frame *frame;
 493         unsigned char *f;
 494         int len;
 495         int i;
 496         unsigned char yuyv[4] = { 180, 128, 10, 128 }; /* YUV components */
 497         unsigned char rv, gv, bv;       /* RGB components */
 498         int clipmask_index, bytes_per_pixel;
 499         int stretch_bytes, clipmask_add;
 500
 501         frame  = usbvision->cur_frame;
 502         f = frame->data + (frame->v4l2_linesize * frame->curline);
 503
 504         /* Make sure there's enough data for the entire line */
 505         len = (frame->isoc_header.frame_width * 2) + 5;
 506         if (scratch_len(usbvision) < len) {
 507                 PDEBUG(DBG_PARSE, "out of data in line %d, need %u.\n", frame->curline, len);
 508                 return parse_state_out;
 509         }
 510
 511         if ((frame->curline + 1) >= frame->frmheight)
 512                 return parse_state_next_frame;
 513
 514         bytes_per_pixel = frame->v4l2_format.bytes_per_pixel;
 515         stretch_bytes = (usbvision->stretch_width - 1) * bytes_per_pixel;
 516         clipmask_index = frame->curline * MAX_FRAME_WIDTH;
 517         clipmask_add = usbvision->stretch_width;
 518
 519         for (i = 0; i < frame->frmwidth; i += (2 * usbvision->stretch_width)) {
 520                 scratch_get(usbvision, &yuyv[0], 4);
 521
 522                 if (frame->v4l2_format.format == V4L2_PIX_FMT_YUYV) {
 523                         *f++ = yuyv[0]; /* Y */
 524                         *f++ = yuyv[3]; /* U */
 525                 } else {
 526                         YUV_TO_RGB_BY_THE_BOOK(yuyv[0], yuyv[1], yuyv[3], rv, gv, bv);
 527                         switch (frame->v4l2_format.format) {
 528                         case V4L2_PIX_FMT_RGB565:
 529                                 *f++ = (0x1F & rv) |
 530                                         (0xE0 & (gv << 5));
 531                                 *f++ = (0x07 & (gv >> 3)) |
 532                                         (0xF8 &  bv);
 533                                 break;
 534                         case V4L2_PIX_FMT_RGB24:
 535                                 *f++ = rv;
 536                                 *f++ = gv;
 537                                 *f++ = bv;
 538                                 break;
 539                         case V4L2_PIX_FMT_RGB32:
 540                                 *f++ = rv;
 541                                 *f++ = gv;
 542                                 *f++ = bv;
 543                                 f++;
 544                                 break;
 545                         case V4L2_PIX_FMT_RGB555:
 546                                 *f++ = (0x1F & rv) |
 547                                         (0xE0 & (gv << 5));
 548                                 *f++ = (0x03 & (gv >> 3)) |
 549                                         (0x7C & (bv << 2));
 550                                 break;
 551                         }
 552                 }
 553                 clipmask_index += clipmask_add;
 554                 f += stretch_bytes;
 555
 556                 if (frame->v4l2_format.format == V4L2_PIX_FMT_YUYV) {
 557                         *f++ = yuyv[2]; /* Y */
 558                         *f++ = yuyv[1]; /* V */
 559                 } else {
 560                         YUV_TO_RGB_BY_THE_BOOK(yuyv[2], yuyv[1], yuyv[3], rv, gv, bv);
 561                         switch (frame->v4l2_format.format) {
 562                         case V4L2_PIX_FMT_RGB565:
 563                                 *f++ = (0x1F & rv) |
 564                                         (0xE0 & (gv << 5));
 565                                 *f++ = (0x07 & (gv >> 3)) |
 566                                         (0xF8 &  bv);
 567                                 break;
 568                         case V4L2_PIX_FMT_RGB24:
 569                                 *f++ = rv;
 570                                 *f++ = gv;
 571                                 *f++ = bv;
 572                                 break;
 573                         case V4L2_PIX_FMT_RGB32:
 574                                 *f++ = rv;
 575                                 *f++ = gv;
 576                                 *f++ = bv;
 577                                 f++;
 578                                 break;
 579                         case V4L2_PIX_FMT_RGB555:
 580                                 *f++ = (0x1F & rv) |
 581                                         (0xE0 & (gv << 5));
 582                                 *f++ = (0x03 & (gv >> 3)) |
 583                                         (0x7C & (bv << 2));
 584                                 break;
 585                         }
 586                 }
 587                 clipmask_index += clipmask_add;
 588                 f += stretch_bytes;
 589         }
 590
 591         frame->curline += usbvision->stretch_height;
 592         *pcopylen += frame->v4l2_linesize * usbvision->stretch_height;
 593
 594         if (frame->curline >= frame->frmheight)
 595                 return parse_state_next_frame;
 596         return parse_state_continue;
 597 }
 598
 599 /* The decompression routine  */
 600 static int usbvision_decompress(struct usb_usbvision *usbvision, unsigned char *compressed,
 601                                                                 unsigned char *decompressed, int *start_pos,
 602                                                                 int *block_typestart_pos, int len)
 603 {
 604         int rest_pixel, idx, pos, extra_pos, block_len, block_type_pos, block_type_len;
 605         unsigned char block_byte, block_code, block_type, block_type_byte, integrator;
 606
 607         integrator = 0;
 608         pos = *start_pos;
 609         block_type_pos = *block_typestart_pos;
 610         extra_pos = pos;
 611         block_len = 0;
 612         block_byte = 0;
 613         block_code = 0;
 614         block_type = 0;
 615         block_type_byte = 0;
 616         block_type_len = 0;
 617         rest_pixel = len;
 618
 619         for (idx = 0; idx < len; idx++) {
 620                 if (block_len == 0) {
 621                         if (block_type_len == 0) {
 622                                 block_type_byte = compressed[block_type_pos];
 623                                 block_type_pos++;
 624                                 block_type_len = 4;
 625                         }
 626                         block_type = (block_type_byte & 0xC0) >> 6;
 627
 628                         /* statistic: */
 629                         usbvision->compr_block_types[block_type]++;
 630
 631                         pos = extra_pos;
 632                         if (block_type == 0) {
 633                                 if (rest_pixel >= 24) {
 634                                         idx += 23;
 635                                         rest_pixel -= 24;
 636                                         integrator = decompressed[idx];
 637                                 } else {
 638                                         idx += rest_pixel - 1;
 639                                         rest_pixel = 0;
 640                                 }
 641                         } else {
 642                                 block_code = compressed[pos];
 643                                 pos++;
 644                                 if (rest_pixel >= 24)
 645                                         block_len  = 24;
 646                                 else
 647                                         block_len = rest_pixel;
 648                                 rest_pixel -= block_len;
 649                                 extra_pos = pos + (block_len / 4);
 650                         }
 651                         block_type_byte <<= 2;
 652                         block_type_len -= 1;
 653                 }
 654                 if (block_len > 0) {
 655                         if ((block_len % 4) == 0) {
 656                                 block_byte = compressed[pos];
 657                                 pos++;
 658                         }
 659                         if (block_type == 1) /* inter Block */
 660                                 integrator = decompressed[idx];
 661                         switch (block_byte & 0xC0) {
 662                         case 0x03 << 6:
 663                                 integrator += compressed[extra_pos];
 664                                 extra_pos++;
 665                                 break;
 666                         case 0x02 << 6:
 667                                 integrator += block_code;
 668                                 break;
 669                         case 0x00:
 670                                 integrator -= block_code;
 671                                 break;
 672                         }
 673                         decompressed[idx] = integrator;
 674                         block_byte <<= 2;
 675                         block_len -= 1;
 676                 }
 677         }
 678         *start_pos = extra_pos;
 679         *block_typestart_pos = block_type_pos;
 680         return idx;
 681 }
 682
 683
 684 /*
 685  * usbvision_parse_compress()
 686  *
 687  * Parse compressed frame from the scratch buffer, put
 688  * decoded RGB value into the current frame buffer and add the written
 689  * number of bytes (RGB) to the *pcopylen.
 690  *
 691  */
 692 static enum parse_state usbvision_parse_compress(struct usb_usbvision *usbvision,
 693                                            long *pcopylen)
 694 {
 695 #define USBVISION_STRIP_MAGIC           0x5A
 696 #define USBVISION_STRIP_LEN_MAX         400
 697 #define USBVISION_STRIP_HEADER_LEN      3
 698
 699         struct usbvision_frame *frame;
 700         unsigned char *f, *u = NULL, *v = NULL;
 701         unsigned char strip_data[USBVISION_STRIP_LEN_MAX];
 702         unsigned char strip_header[USBVISION_STRIP_HEADER_LEN];
 703         int idx, idx_end, strip_len, strip_ptr, startblock_pos, block_pos, block_type_pos;
 704         int clipmask_index;
 705         int image_size;
 706         unsigned char rv, gv, bv;
 707         static unsigned char *Y, *U, *V;
 708
 709         frame = usbvision->cur_frame;
 710         image_size = frame->frmwidth * frame->frmheight;
 711         if ((frame->v4l2_format.format == V4L2_PIX_FMT_YUV422P) ||
 712             (frame->v4l2_format.format == V4L2_PIX_FMT_YVU420)) {       /* this is a planar format */
 713                 /* ... v4l2_linesize not used here. */
 714                 f = frame->data + (frame->width * frame->curline);
 715         } else
 716                 f = frame->data + (frame->v4l2_linesize * frame->curline);
 717
 718         if (frame->v4l2_format.format == V4L2_PIX_FMT_YUYV) { /* initialise u and v pointers */
 719                 /* get base of u and b planes add halfoffset */
 720                 u = frame->data
 721                         + image_size
 722                         + (frame->frmwidth >> 1) * frame->curline;
 723                 v = u + (image_size >> 1);
 724         } else if (frame->v4l2_format.format == V4L2_PIX_FMT_YVU420) {
 725                 v = frame->data + image_size + ((frame->curline * (frame->width)) >> 2);
 726                 u = v + (image_size >> 2);
 727         }
 728
 729         if (frame->curline == 0)
 730                 usbvision_adjust_compression(usbvision);
 731
 732         if (scratch_len(usbvision) < USBVISION_STRIP_HEADER_LEN)
 733                 return parse_state_out;
 734
 735         /* get strip header without changing the scratch_read_ptr */
 736         scratch_set_extra_ptr(usbvision, &strip_ptr, 0);
 737         scratch_get_extra(usbvision, &strip_header[0], &strip_ptr,
 738                                 USBVISION_STRIP_HEADER_LEN);
 739
 740         if (strip_header[0] != USBVISION_STRIP_MAGIC) {
 741                 /* wrong strip magic */
 742                 usbvision->strip_magic_errors++;
 743                 return parse_state_next_frame;
 744         }
 745
 746         if (frame->curline != (int)strip_header[2]) {
 747                 /* line number mismatch error */
 748                 usbvision->strip_line_number_errors++;
 749         }
 750
 751         strip_len = 2 * (unsigned int)strip_header[1];
 752         if (strip_len > USBVISION_STRIP_LEN_MAX) {
 753                 /* strip overrun */
 754                 /* I think this never happens */
 755                 usbvision_request_intra(usbvision);
 756         }
 757
 758         if (scratch_len(usbvision) < strip_len) {
 759                 /* there is not enough data for the strip */
 760                 return parse_state_out;
 761         }
 762
 763         if (usbvision->intra_frame_buffer) {
 764                 Y = usbvision->intra_frame_buffer + frame->frmwidth * frame->curline;
 765                 U = usbvision->intra_frame_buffer + image_size + (frame->frmwidth / 2) * (frame->curline / 2);
 766                 V = usbvision->intra_frame_buffer + image_size / 4 * 5 + (frame->frmwidth / 2) * (frame->curline / 2);
 767         } else {
 768                 return parse_state_next_frame;
 769         }
 770
 771         clipmask_index = frame->curline * MAX_FRAME_WIDTH;
 772
 773         scratch_get(usbvision, strip_data, strip_len);
 774
 775         idx_end = frame->frmwidth;
 776         block_type_pos = USBVISION_STRIP_HEADER_LEN;
 777         startblock_pos = block_type_pos + (idx_end - 1) / 96 + (idx_end / 2 - 1) / 96 + 2;
 778         block_pos = startblock_pos;
 779
 780         usbvision->block_pos = block_pos;
 781
 782         usbvision_decompress(usbvision, strip_data, Y, &block_pos, &block_type_pos, idx_end);
 783         if (strip_len > usbvision->max_strip_len)
 784                 usbvision->max_strip_len = strip_len;
 785
 786         if (frame->curline % 2)
 787                 usbvision_decompress(usbvision, strip_data, V, &block_pos, &block_type_pos, idx_end / 2);
 788         else
 789                 usbvision_decompress(usbvision, strip_data, U, &block_pos, &block_type_pos, idx_end / 2);
 790
 791         if (block_pos > usbvision->comprblock_pos)
 792                 usbvision->comprblock_pos = block_pos;
 793         if (block_pos > strip_len)
 794                 usbvision->strip_len_errors++;
 795
 796         for (idx = 0; idx < idx_end; idx++) {
 797                 if (frame->v4l2_format.format == V4L2_PIX_FMT_YUYV) {
 798                         *f++ = Y[idx];
 799                         *f++ = idx & 0x01 ? U[idx / 2] : V[idx / 2];
 800                 } else if (frame->v4l2_format.format == V4L2_PIX_FMT_YUV422P) {
 801                         *f++ = Y[idx];
 802                         if (idx & 0x01)
 803                                 *u++ = U[idx >> 1];
 804                         else
 805                                 *v++ = V[idx >> 1];
 806                 } else if (frame->v4l2_format.format == V4L2_PIX_FMT_YVU420) {
 807                         *f++ = Y[idx];
 808                         if (!((idx & 0x01) | (frame->curline & 0x01))) {
 809                                 /* only need do this for 1 in 4 pixels */
 810                                 /* intraframe buffer is YUV420 format */
 811                                 *u++ = U[idx >> 1];
 812                                 *v++ = V[idx >> 1];
 813                         }
 814                 } else {
 815                         YUV_TO_RGB_BY_THE_BOOK(Y[idx], U[idx / 2], V[idx / 2], rv, gv, bv);
 816                         switch (frame->v4l2_format.format) {
 817                         case V4L2_PIX_FMT_GREY:
 818                                 *f++ = Y[idx];
 819                                 break;
 820                         case V4L2_PIX_FMT_RGB555:
 821                                 *f++ = (0x1F & rv) |
 822                                         (0xE0 & (gv << 5));
 823                                 *f++ = (0x03 & (gv >> 3)) |
 824                                         (0x7C & (bv << 2));
 825                                 break;
 826                         case V4L2_PIX_FMT_RGB565:
 827                                 *f++ = (0x1F & rv) |
 828                                         (0xE0 & (gv << 5));
 829                                 *f++ = (0x07 & (gv >> 3)) |
 830                                         (0xF8 & bv);
 831                                 break;
 832                         case V4L2_PIX_FMT_RGB24:
 833                                 *f++ = rv;
 834                                 *f++ = gv;
 835                                 *f++ = bv;
 836                                 break;
 837                         case V4L2_PIX_FMT_RGB32:
 838                                 *f++ = rv;
 839                                 *f++ = gv;
 840                                 *f++ = bv;
 841                                 f++;
 842                                 break;
 843                         }
 844                 }
 845                 clipmask_index++;
 846         }
 847         /* Deal with non-integer no. of bytes for YUV420P */
 848         if (frame->v4l2_format.format != V4L2_PIX_FMT_YVU420)
 849                 *pcopylen += frame->v4l2_linesize;
 850         else
 851                 *pcopylen += frame->curline & 0x01 ? frame->v4l2_linesize : frame->v4l2_linesize << 1;
 852
 853         frame->curline += 1;
 854
 855         if (frame->curline >= frame->frmheight)
 856                 return parse_state_next_frame;
 857         return parse_state_continue;
 858
 859 }
 860
 861
 862 /*
 863  * usbvision_parse_lines_420()
 864  *
 865  * Parse two lines from the scratch buffer, put
 866  * decoded RGB value into the current frame buffer and add the written
 867  * number of bytes (RGB) to the *pcopylen.
 868  *
 869  */
 870 static enum parse_state usbvision_parse_lines_420(struct usb_usbvision *usbvision,
 871                                            long *pcopylen)
 872 {
 873         struct usbvision_frame *frame;
 874         unsigned char *f_even = NULL, *f_odd = NULL;
 875         unsigned int pixel_per_line, block;
 876         int pixel, block_split;
 877         int y_ptr, u_ptr, v_ptr, y_odd_offset;
 878         const int y_block_size = 128;
 879         const int uv_block_size = 64;
 880         const int sub_block_size = 32;
 881         const int y_step[] = { 0, 0, 0, 2 }, y_step_size = 4;
 882         const int uv_step[] = { 0, 0, 0, 4 }, uv_step_size = 4;
 883         unsigned char y[2], u, v;       /* YUV components */
 884         int y_, u_, v_, vb, uvg, ur;
 885         int r_, g_, b_;                 /* RGB components */
 886         unsigned char g;
 887         int clipmask_even_index, clipmask_odd_index, bytes_per_pixel;
 888         int clipmask_add, stretch_bytes;
 889
 890         frame  = usbvision->cur_frame;
 891         f_even = frame->data + (frame->v4l2_linesize * frame->curline);
 892         f_odd  = f_even + frame->v4l2_linesize * usbvision->stretch_height;
 893
 894         /* Make sure there's enough data for the entire line */
 895         /* In this mode usbvision transfer 3 bytes for every 2 pixels */
 896         /* I need two lines to decode the color */
 897         bytes_per_pixel = frame->v4l2_format.bytes_per_pixel;
 898         stretch_bytes = (usbvision->stretch_width - 1) * bytes_per_pixel;
 899         clipmask_even_index = frame->curline * MAX_FRAME_WIDTH;
 900         clipmask_odd_index  = clipmask_even_index + MAX_FRAME_WIDTH;
 901         clipmask_add = usbvision->stretch_width;
 902         pixel_per_line = frame->isoc_header.frame_width;
 903
 904         if (scratch_len(usbvision) < (int)pixel_per_line * 3) {
 905                 /* printk(KERN_DEBUG "out of data, need %d\n", len); */
 906                 return parse_state_out;
 907         }
 908
 909         if ((frame->curline + 1) >= frame->frmheight)
 910                 return parse_state_next_frame;
 911
 912         block_split = (pixel_per_line%y_block_size) ? 1 : 0;    /* are some blocks splitted into different lines? */
 913
 914         y_odd_offset = (pixel_per_line / y_block_size) * (y_block_size + uv_block_size)
 915                         + block_split * uv_block_size;
 916
 917         scratch_set_extra_ptr(usbvision, &y_ptr, y_odd_offset);
 918         scratch_set_extra_ptr(usbvision, &u_ptr, y_block_size);
 919         scratch_set_extra_ptr(usbvision, &v_ptr, y_odd_offset
 920                         + (4 - block_split) * sub_block_size);
 921
 922         for (block = 0; block < (pixel_per_line / sub_block_size); block++) {
 923                 for (pixel = 0; pixel < sub_block_size; pixel += 2) {
 924                         scratch_get(usbvision, &y[0], 2);
 925                         scratch_get_extra(usbvision, &u, &u_ptr, 1);
 926                         scratch_get_extra(usbvision, &v, &v_ptr, 1);
 927
 928                         /* I don't use the YUV_TO_RGB macro for better performance */
 929                         v_ = v - 128;
 930                         u_ = u - 128;
 931                         vb = 132252 * v_;
 932                         uvg = -53281 * u_ - 25625 * v_;
 933                         ur = 104595 * u_;
 934
 935                         if (frame->v4l2_format.format == V4L2_PIX_FMT_YUYV) {
 936                                 *f_even++ = y[0];
 937                                 *f_even++ = v;
 938                         } else {
 939                                 y_ = 76284 * (y[0] - 16);
 940
 941                                 b_ = (y_ + vb) >> 16;
 942                                 g_ = (y_ + uvg) >> 16;
 943                                 r_ = (y_ + ur) >> 16;
 944
 945                                 switch (frame->v4l2_format.format) {
 946                                 case V4L2_PIX_FMT_RGB565:
 947                                         g = LIMIT_RGB(g_);
 948                                         *f_even++ =
 949                                                 (0x1F & LIMIT_RGB(r_)) |
 950                                                 (0xE0 & (g << 5));
 951                                         *f_even++ =
 952                                                 (0x07 & (g >> 3)) |
 953                                                 (0xF8 &  LIMIT_RGB(b_));
 954                                         break;
 955                                 case V4L2_PIX_FMT_RGB24:
 956                                         *f_even++ = LIMIT_RGB(r_);
 957                                         *f_even++ = LIMIT_RGB(g_);
 958                                         *f_even++ = LIMIT_RGB(b_);
 959                                         break;
 960                                 case V4L2_PIX_FMT_RGB32:
 961                                         *f_even++ = LIMIT_RGB(r_);
 962                                         *f_even++ = LIMIT_RGB(g_);
 963                                         *f_even++ = LIMIT_RGB(b_);
 964                                         f_even++;
 965                                         break;
 966                                 case V4L2_PIX_FMT_RGB555:
 967                                         g = LIMIT_RGB(g_);
 968                                         *f_even++ = (0x1F & LIMIT_RGB(r_)) |
 969                                                 (0xE0 & (g << 5));
 970                                         *f_even++ = (0x03 & (g >> 3)) |
 971                                                 (0x7C & (LIMIT_RGB(b_) << 2));
 972                                         break;
 973                                 }
 974                         }
 975                         clipmask_even_index += clipmask_add;
 976                         f_even += stretch_bytes;
 977
 978                         if (frame->v4l2_format.format == V4L2_PIX_FMT_YUYV) {
 979                                 *f_even++ = y[1];
 980                                 *f_even++ = u;
 981                         } else {
 982                                 y_ = 76284 * (y[1] - 16);
 983
 984                                 b_ = (y_ + vb) >> 16;
 985                                 g_ = (y_ + uvg) >> 16;
 986                                 r_ = (y_ + ur) >> 16;
 987
 988                                 switch (frame->v4l2_format.format) {
 989                                 case V4L2_PIX_FMT_RGB565:
 990                                         g = LIMIT_RGB(g_);
 991                                         *f_even++ =
 992                                                 (0x1F & LIMIT_RGB(r_)) |
 993                                                 (0xE0 & (g << 5));
 994                                         *f_even++ =
 995                                                 (0x07 & (g >> 3)) |
 996                                                 (0xF8 &  LIMIT_RGB(b_));
 997                                         break;
 998                                 case V4L2_PIX_FMT_RGB24:
 999                                         *f_even++ = LIMIT_RGB(r_);
1000                                         *f_even++ = LIMIT_RGB(g_);
1001                                         *f_even++ = LIMIT_RGB(b_);
1002                                         break;
1003                                 case V4L2_PIX_FMT_RGB32:
1004                                         *f_even++ = LIMIT_RGB(r_);
1005                                         *f_even++ = LIMIT_RGB(g_);
1006                                         *f_even++ = LIMIT_RGB(b_);
1007                                         f_even++;
1008                                         break;
1009                                 case V4L2_PIX_FMT_RGB555:
1010                                         g = LIMIT_RGB(g_);
1011                                         *f_even++ = (0x1F & LIMIT_RGB(r_)) |
1012                                                 (0xE0 & (g << 5));
1013                                         *f_even++ = (0x03 & (g >> 3)) |
1014                                                 (0x7C & (LIMIT_RGB(b_) << 2));
1015                                         break;
1016                                 }
1017                         }
1018                         clipmask_even_index += clipmask_add;
1019                         f_even += stretch_bytes;
1020
1021                         scratch_get_extra(usbvision, &y[0], &y_ptr, 2);
1022
1023                         if (frame->v4l2_format.format == V4L2_PIX_FMT_YUYV) {
1024                                 *f_odd++ = y[0];
1025                                 *f_odd++ = v;
1026                         } else {
1027                                 y_ = 76284 * (y[0] - 16);
1028
1029                                 b_ = (y_ + vb) >> 16;
1030                                 g_ = (y_ + uvg) >> 16;
1031                                 r_ = (y_ + ur) >> 16;
1032
1033                                 switch (frame->v4l2_format.format) {
1034                                 case V4L2_PIX_FMT_RGB565:
1035                                         g = LIMIT_RGB(g_);
1036                                         *f_odd++ =
1037                                                 (0x1F & LIMIT_RGB(r_)) |
1038                                                 (0xE0 & (g << 5));
1039                                         *f_odd++ =
1040                                                 (0x07 & (g >> 3)) |
1041                                                 (0xF8 &  LIMIT_RGB(b_));
1042                                         break;
1043                                 case V4L2_PIX_FMT_RGB24:
1044                                         *f_odd++ = LIMIT_RGB(r_);
1045                                         *f_odd++ = LIMIT_RGB(g_);
1046                                         *f_odd++ = LIMIT_RGB(b_);
1047                                         break;
1048                                 case V4L2_PIX_FMT_RGB32:
1049                                         *f_odd++ = LIMIT_RGB(r_);
1050                                         *f_odd++ = LIMIT_RGB(g_);
1051                                         *f_odd++ = LIMIT_RGB(b_);
1052                                         f_odd++;
1053                                         break;
1054                                 case V4L2_PIX_FMT_RGB555:
1055                                         g = LIMIT_RGB(g_);
1056                                         *f_odd++ = (0x1F & LIMIT_RGB(r_)) |
1057                                                 (0xE0 & (g << 5));
1058                                         *f_odd++ = (0x03 & (g >> 3)) |
1059                                                 (0x7C & (LIMIT_RGB(b_) << 2));
1060                                         break;
1061                                 }
1062                         }
1063                         clipmask_odd_index += clipmask_add;
1064                         f_odd += stretch_bytes;
1065
1066                         if (frame->v4l2_format.format == V4L2_PIX_FMT_YUYV) {
1067                                 *f_odd++ = y[1];
1068                                 *f_odd++ = u;
1069                         } else {
1070                                 y_ = 76284 * (y[1] - 16);
1071
1072                                 b_ = (y_ + vb) >> 16;
1073                                 g_ = (y_ + uvg) >> 16;
1074                                 r_ = (y_ + ur) >> 16;
1075
1076                                 switch (frame->v4l2_format.format) {
1077                                 case V4L2_PIX_FMT_RGB565:
1078                                         g = LIMIT_RGB(g_);
1079                                         *f_odd++ =
1080                                                 (0x1F & LIMIT_RGB(r_)) |
1081                                                 (0xE0 & (g << 5));
1082                                         *f_odd++ =
1083                                                 (0x07 & (g >> 3)) |
1084                                                 (0xF8 &  LIMIT_RGB(b_));
1085                                         break;
1086                                 case V4L2_PIX_FMT_RGB24:
1087                                         *f_odd++ = LIMIT_RGB(r_);
1088                                         *f_odd++ = LIMIT_RGB(g_);
1089                                         *f_odd++ = LIMIT_RGB(b_);
1090                                         break;
1091                                 case V4L2_PIX_FMT_RGB32:
1092                                         *f_odd++ = LIMIT_RGB(r_);
1093                                         *f_odd++ = LIMIT_RGB(g_);
1094                                         *f_odd++ = LIMIT_RGB(b_);
1095                                         f_odd++;
1096                                         break;
1097                                 case V4L2_PIX_FMT_RGB555:
1098                                         g = LIMIT_RGB(g_);
1099                                         *f_odd++ = (0x1F & LIMIT_RGB(r_)) |
1100                                                 (0xE0 & (g << 5));
1101                                         *f_odd++ = (0x03 & (g >> 3)) |
1102                                                 (0x7C & (LIMIT_RGB(b_) << 2));
1103                                         break;
1104                                 }
1105                         }
1106                         clipmask_odd_index += clipmask_add;
1107                         f_odd += stretch_bytes;
1108                 }
1109
1110                 scratch_rm_old(usbvision, y_step[block % y_step_size] * sub_block_size);
1111                 scratch_inc_extra_ptr(&y_ptr, y_step[(block + 2 * block_split) % y_step_size]
1112                                 * sub_block_size);
1113                 scratch_inc_extra_ptr(&u_ptr, uv_step[block % uv_step_size]
1114                                 * sub_block_size);
1115                 scratch_inc_extra_ptr(&v_ptr, uv_step[(block + 2 * block_split) % uv_step_size]
1116                                 * sub_block_size);
1117         }
1118
1119         scratch_rm_old(usbvision, pixel_per_line * 3 / 2
1120                         + block_split * sub_block_size);
1121
1122         frame->curline += 2 * usbvision->stretch_height;
1123         *pcopylen += frame->v4l2_linesize * 2 * usbvision->stretch_height;
1124
1125         if (frame->curline >= frame->frmheight)
1126                 return parse_state_next_frame;
1127         return parse_state_continue;
1128 }
1129
1130 /*
1131  * usbvision_parse_data()
1132  *
1133  * Generic routine to parse the scratch buffer. It employs either
1134  * usbvision_find_header() or usbvision_parse_lines() to do most
1135  * of work.
1136  *
1137  */
1138 static void usbvision_parse_data(struct usb_usbvision *usbvision)
1139 {
1140         struct usbvision_frame *frame;
1141         enum parse_state newstate;
1142         long copylen = 0;
1143         unsigned long lock_flags;
1144
1145         frame = usbvision->cur_frame;
1146
1147         PDEBUG(DBG_PARSE, "parsing len=%d\n", scratch_len(usbvision));
1148
1149         while (1) {
1150                 newstate = parse_state_out;
1151                 if (scratch_len(usbvision)) {
1152                         if (frame->scanstate == scan_state_scanning) {
1153                                 newstate = usbvision_find_header(usbvision);
1154                         } else if (frame->scanstate == scan_state_lines) {
1155                                 if (usbvision->isoc_mode == ISOC_MODE_YUV420)
1156                                         newstate = usbvision_parse_lines_420(usbvision, &copylen);
1157                                 else if (usbvision->isoc_mode == ISOC_MODE_YUV422)
1158                                         newstate = usbvision_parse_lines_422(usbvision, &copylen);
1159                                 else if (usbvision->isoc_mode == ISOC_MODE_COMPRESS)
1160                                         newstate = usbvision_parse_compress(usbvision, &copylen);
1161                         }
1162                 }
1163                 if (newstate == parse_state_continue)
1164                         continue;
1165                 if ((newstate == parse_state_next_frame) || (newstate == parse_state_out))
1166                         break;
1167                 return; /* parse_state_end_parse */
1168         }
1169
1170         if (newstate == parse_state_next_frame) {
1171                 frame->grabstate = frame_state_done;
1172                 v4l2_get_timestamp(&(frame->timestamp));
1173                 frame->sequence = usbvision->frame_num;
1174
1175                 spin_lock_irqsave(&usbvision->queue_lock, lock_flags);
1176                 list_move_tail(&(frame->frame), &usbvision->outqueue);
1177                 usbvision->cur_frame = NULL;
1178                 spin_unlock_irqrestore(&usbvision->queue_lock, lock_flags);
1179
1180                 usbvision->frame_num++;
1181
1182                 /* This will cause the process to request another frame. */
1183                 if (waitqueue_active(&usbvision->wait_frame)) {
1184                         PDEBUG(DBG_PARSE, "Wake up !");
1185                         wake_up_interruptible(&usbvision->wait_frame);
1186                 }
1187         } else {
1188                 frame->grabstate = frame_state_grabbing;
1189         }
1190
1191         /* Update the frame's uncompressed length. */
1192         frame->scanlength += copylen;
1193 }
1194
1195
1196 /*
1197  * Make all of the blocks of data contiguous
1198  */
1199 static int usbvision_compress_isochronous(struct usb_usbvision *usbvision,
1200                                           struct urb *urb)
1201 {
1202         unsigned char *packet_data;
1203         int i, totlen = 0;
1204
1205         for (i = 0; i < urb->number_of_packets; i++) {
1206                 int packet_len = urb->iso_frame_desc[i].actual_length;
1207                 int packet_stat = urb->iso_frame_desc[i].status;
1208
1209                 packet_data = urb->transfer_buffer + urb->iso_frame_desc[i].offset;
1210
1211                 /* Detect and ignore errored packets */
1212                 if (packet_stat) {      /* packet_stat != 0 ????????????? */
1213                         PDEBUG(DBG_ISOC, "data error: [%d] len=%d, status=%X", i, packet_len, packet_stat);
1214                         usbvision->isoc_err_count++;
1215                         continue;
1216                 }
1217
1218                 /* Detect and ignore empty packets */
1219                 if (packet_len < 0) {
1220                         PDEBUG(DBG_ISOC, "error packet [%d]", i);
1221                         usbvision->isoc_skip_count++;
1222                         continue;
1223                 } else if (packet_len == 0) {   /* Frame end ????? */
1224                         PDEBUG(DBG_ISOC, "null packet [%d]", i);
1225                         usbvision->isocstate = isoc_state_no_frame;
1226                         usbvision->isoc_skip_count++;
1227                         continue;
1228                 } else if (packet_len > usbvision->isoc_packet_size) {
1229                         PDEBUG(DBG_ISOC, "packet[%d] > isoc_packet_size", i);
1230                         usbvision->isoc_skip_count++;
1231                         continue;
1232                 }
1233
1234                 PDEBUG(DBG_ISOC, "packet ok [%d] len=%d", i, packet_len);
1235
1236                 if (usbvision->isocstate == isoc_state_no_frame) { /* new frame begins */
1237                         usbvision->isocstate = isoc_state_in_frame;
1238                         scratch_mark_header(usbvision);
1239                         usbvision_measure_bandwidth(usbvision);
1240                         PDEBUG(DBG_ISOC, "packet with header");
1241                 }
1242
1243                 /*
1244                  * If usbvision continues to feed us with data but there is no
1245                  * consumption (if, for example, V4L client fell asleep) we
1246                  * may overflow the buffer. We have to move old data over to
1247                  * free room for new data. This is bad for old data. If we
1248                  * just drop new data then it's bad for new data... choose
1249                  * your favorite evil here.
1250                  */
1251                 if (scratch_free(usbvision) < packet_len) {
1252                         usbvision->scratch_ovf_count++;
1253                         PDEBUG(DBG_ISOC, "scratch buf overflow! scr_len: %d, n: %d",
1254                                scratch_len(usbvision), packet_len);
1255                         scratch_rm_old(usbvision, packet_len - scratch_free(usbvision));
1256                 }
1257
1258                 /* Now we know that there is enough room in scratch buffer */
1259                 scratch_put(usbvision, packet_data, packet_len);
1260                 totlen += packet_len;
1261                 usbvision->isoc_data_count += packet_len;
1262                 usbvision->isoc_packet_count++;
1263         }
1264 #if ENABLE_HEXDUMP
1265         if (totlen > 0) {
1266                 static int foo;
1267
1268                 if (foo < 1) {
1269                         printk(KERN_DEBUG "+%d.\n", usbvision->scratchlen);
1270                         usbvision_hexdump(data0, (totlen > 64) ? 64 : totlen);
1271                         ++foo;
1272                 }
1273         }
1274 #endif
1275         return totlen;
1276 }
1277
1278 static void usbvision_isoc_irq(struct urb *urb)
1279 {
1280         int err_code = 0;
1281         int len;
1282         struct usb_usbvision *usbvision = urb->context;
1283         int i;
1284         unsigned long start_time = jiffies;
1285         struct usbvision_frame **f;
1286
1287         /* We don't want to do anything if we are about to be removed! */
1288         if (!USBVISION_IS_OPERATIONAL(usbvision))
1289                 return;
1290
1291         /* any urb with wrong status is ignored without acknowledgement */
1292         if (urb->status == -ENOENT)
1293                 return;
1294
1295         f = &usbvision->cur_frame;
1296
1297         /* Manage streaming interruption */
1298         if (usbvision->streaming == stream_interrupt) {
1299                 usbvision->streaming = stream_idle;
1300                 if ((*f)) {
1301                         (*f)->grabstate = frame_state_ready;
1302                         (*f)->scanstate = scan_state_scanning;
1303                 }
1304                 PDEBUG(DBG_IRQ, "stream interrupted");
1305                 wake_up_interruptible(&usbvision->wait_stream);
1306         }
1307
1308         /* Copy the data received into our scratch buffer */
1309         len = usbvision_compress_isochronous(usbvision, urb);
1310
1311         usbvision->isoc_urb_count++;
1312         usbvision->urb_length = len;
1313
1314         if (usbvision->streaming == stream_on) {
1315                 /* If we collected enough data let's parse! */
1316                 if (scratch_len(usbvision) > USBVISION_HEADER_LENGTH &&
1317                     !list_empty(&(usbvision->inqueue))) {
1318                         if (!(*f)) {
1319                                 (*f) = list_entry(usbvision->inqueue.next,
1320                                                   struct usbvision_frame,
1321                                                   frame);
1322                         }
1323                         usbvision_parse_data(usbvision);
1324                 } else {
1325                         /* If we don't have a frame
1326                           we're current working on, complain */
1327                         PDEBUG(DBG_IRQ,
1328                                "received data, but no one needs it");
1329                         scratch_reset(usbvision);
1330                 }
1331         } else {
1332                 PDEBUG(DBG_IRQ, "received data, but no one needs it");
1333                 scratch_reset(usbvision);
1334         }
1335
1336         usbvision->time_in_irq += jiffies - start_time;
1337
1338         for (i = 0; i < USBVISION_URB_FRAMES; i++) {
1339                 urb->iso_frame_desc[i].status = 0;
1340                 urb->iso_frame_desc[i].actual_length = 0;
1341         }
1342
1343         urb->status = 0;
1344         urb->dev = usbvision->dev;
1345         err_code = usb_submit_urb(urb, GFP_ATOMIC);
1346
1347         if (err_code) {
1348                 dev_err(&usbvision->dev->dev,
1349                         "%s: usb_submit_urb failed: error %d\n",
1350                                 __func__, err_code);
1351         }
1352
1353         return;
1354 }
1355
1356 /*************************************/
1357 /* Low level usbvision access functions */
1358 /*************************************/
1359
1360 /*
1361  * usbvision_read_reg()
1362  *
1363  * return  < 0 -> Error
1364  *        >= 0 -> Data
1365  */
1366
1367 int usbvision_read_reg(struct usb_usbvision *usbvision, unsigned char reg)
1368 {
1369         int err_code = 0;
1370         unsigned char buffer[1];
1371
1372         if (!USBVISION_IS_OPERATIONAL(usbvision))
1373                 return -1;
1374
1375         err_code = usb_control_msg(usbvision->dev, usb_rcvctrlpipe(usbvision->dev, 1),
1376                                 USBVISION_OP_CODE,
1377                                 USB_DIR_IN | USB_TYPE_VENDOR | USB_RECIP_ENDPOINT,
1378                                 0, (__u16) reg, buffer, 1, HZ);
1379
1380         if (err_code < 0) {
1381                 dev_err(&usbvision->dev->dev,
1382                         "%s: failed: error %d\n", __func__, err_code);
1383                 return err_code;
1384         }
1385         return buffer[0];
1386 }
1387
1388 /*
1389  * usbvision_write_reg()
1390  *
1391  * return 1 -> Reg written
1392  *        0 -> usbvision is not yet ready
1393  *       -1 -> Something went wrong
1394  */
1395
1396 int usbvision_write_reg(struct usb_usbvision *usbvision, unsigned char reg,
1397                             unsigned char value)
1398 {
1399         int err_code = 0;
1400
1401         if (!USBVISION_IS_OPERATIONAL(usbvision))
1402                 return 0;
1403
1404         err_code = usb_control_msg(usbvision->dev, usb_sndctrlpipe(usbvision->dev, 1),
1405                                 USBVISION_OP_CODE,
1406                                 USB_DIR_OUT | USB_TYPE_VENDOR |
1407                                 USB_RECIP_ENDPOINT, 0, (__u16) reg, &value, 1, HZ);
1408
1409         if (err_code < 0) {
1410                 dev_err(&usbvision->dev->dev,
1411                         "%s: failed: error %d\n", __func__, err_code);
1412         }
1413         return err_code;
1414 }
1415
1416
1417 static void usbvision_ctrl_urb_complete(struct urb *urb)
1418 {
1419         struct usb_usbvision *usbvision = (struct usb_usbvision *)urb->context;
1420
1421         PDEBUG(DBG_IRQ, "");
1422         usbvision->ctrl_urb_busy = 0;
1423         if (waitqueue_active(&usbvision->ctrl_urb_wq))
1424                 wake_up_interruptible(&usbvision->ctrl_urb_wq);
1425 }
1426
1427
1428 static int usbvision_write_reg_irq(struct usb_usbvision *usbvision, int address,
1429                                 unsigned char *data, int len)
1430 {
1431         int err_code = 0;
1432
1433         PDEBUG(DBG_IRQ, "");
1434         if (len > 8)
1435                 return -EFAULT;
1436         if (usbvision->ctrl_urb_busy)
1437                 return -EBUSY;
1438         usbvision->ctrl_urb_busy = 1;
1439
1440         usbvision->ctrl_urb_setup.bRequestType = USB_DIR_OUT | USB_TYPE_VENDOR | USB_RECIP_ENDPOINT;
1441         usbvision->ctrl_urb_setup.bRequest     = USBVISION_OP_CODE;
1442         usbvision->ctrl_urb_setup.wValue       = 0;
1443         usbvision->ctrl_urb_setup.wIndex       = cpu_to_le16(address);
1444         usbvision->ctrl_urb_setup.wLength      = cpu_to_le16(len);
1445         usb_fill_control_urb(usbvision->ctrl_urb, usbvision->dev,
1446                                                         usb_sndctrlpipe(usbvision->dev, 1),
1447                                                         (unsigned char *)&usbvision->ctrl_urb_setup,
1448                                                         (void *)usbvision->ctrl_urb_buffer, len,
1449                                                         usbvision_ctrl_urb_complete,
1450                                                         (void *)usbvision);
1451
1452         memcpy(usbvision->ctrl_urb_buffer, data, len);
1453
1454         err_code = usb_submit_urb(usbvision->ctrl_urb, GFP_ATOMIC);
1455         if (err_code < 0) {
1456                 /* error in usb_submit_urb() */
1457                 usbvision->ctrl_urb_busy = 0;
1458         }
1459         PDEBUG(DBG_IRQ, "submit %d byte: error %d", len, err_code);
1460         return err_code;
1461 }
1462
1463
1464 static int usbvision_init_compression(struct usb_usbvision *usbvision)
1465 {
1466         usbvision->last_isoc_frame_num = -1;
1467         usbvision->isoc_data_count = 0;
1468         usbvision->isoc_packet_count = 0;
1469         usbvision->isoc_skip_count = 0;
1470         usbvision->compr_level = 50;
1471         usbvision->last_compr_level = -1;
1472         usbvision->isoc_urb_count = 0;
1473         usbvision->request_intra = 1;
1474         usbvision->isoc_measure_bandwidth_count = 0;
1475
1476         return 0;
1477 }
1478
1479 /* this function measures the used bandwidth since last call
1480  * return:    0 : no error
1481  * sets used_bandwidth to 1-100 : 1-100% of full bandwidth resp. to isoc_packet_size
1482  */
1483 static int usbvision_measure_bandwidth(struct usb_usbvision *usbvision)
1484 {
1485         if (usbvision->isoc_measure_bandwidth_count < 2) { /* this gives an average bandwidth of 3 frames */
1486                 usbvision->isoc_measure_bandwidth_count++;
1487                 return 0;
1488         }
1489         if ((usbvision->isoc_packet_size > 0) && (usbvision->isoc_packet_count > 0)) {
1490                 usbvision->used_bandwidth = usbvision->isoc_data_count /
1491                                         (usbvision->isoc_packet_count + usbvision->isoc_skip_count) *
1492                                         100 / usbvision->isoc_packet_size;
1493         }
1494         usbvision->isoc_measure_bandwidth_count = 0;
1495         usbvision->isoc_data_count = 0;
1496         usbvision->isoc_packet_count = 0;
1497         usbvision->isoc_skip_count = 0;
1498         return 0;
1499 }
1500
1501 static int usbvision_adjust_compression(struct usb_usbvision *usbvision)
1502 {
1503         int err_code = 0;
1504         unsigned char buffer[6];
1505
1506         PDEBUG(DBG_IRQ, "");
1507         if ((adjust_compression) && (usbvision->used_bandwidth > 0)) {
1508                 usbvision->compr_level += (usbvision->used_bandwidth - 90) / 2;
1509                 RESTRICT_TO_RANGE(usbvision->compr_level, 0, 100);
1510                 if (usbvision->compr_level != usbvision->last_compr_level) {
1511                         int distortion;
1512
1513                         if (usbvision->bridge_type == BRIDGE_NT1004 || usbvision->bridge_type == BRIDGE_NT1005) {
1514                                 buffer[0] = (unsigned char)(4 + 16 * usbvision->compr_level / 100);     /* PCM Threshold 1 */
1515                                 buffer[1] = (unsigned char)(4 + 8 * usbvision->compr_level / 100);      /* PCM Threshold 2 */
1516                                 distortion = 7 + 248 * usbvision->compr_level / 100;
1517                                 buffer[2] = (unsigned char)(distortion & 0xFF);                         /* Average distortion Threshold (inter) */
1518                                 buffer[3] = (unsigned char)(distortion & 0xFF);                         /* Average distortion Threshold (intra) */
1519                                 distortion = 1 + 42 * usbvision->compr_level / 100;
1520                                 buffer[4] = (unsigned char)(distortion & 0xFF);                         /* Maximum distortion Threshold (inter) */
1521                                 buffer[5] = (unsigned char)(distortion & 0xFF);                         /* Maximum distortion Threshold (intra) */
1522                         } else { /* BRIDGE_NT1003 */
1523                                 buffer[0] = (unsigned char)(4 + 16 * usbvision->compr_level / 100);     /* PCM threshold 1 */
1524                                 buffer[1] = (unsigned char)(4 + 8 * usbvision->compr_level / 100);      /* PCM threshold 2 */
1525                                 distortion = 2 + 253 * usbvision->compr_level / 100;
1526                                 buffer[2] = (unsigned char)(distortion & 0xFF);                         /* distortion threshold bit0-7 */
1527                                 buffer[3] = 0;  /* (unsigned char)((distortion >> 8) & 0x0F);           distortion threshold bit 8-11 */
1528                                 distortion = 0 + 43 * usbvision->compr_level / 100;
1529                                 buffer[4] = (unsigned char)(distortion & 0xFF);                         /* maximum distortion bit0-7 */
1530                                 buffer[5] = 0; /* (unsigned char)((distortion >> 8) & 0x01);            maximum distortion bit 8 */
1531                         }
1532                         err_code = usbvision_write_reg_irq(usbvision, USBVISION_PCM_THR1, buffer, 6);
1533                         if (err_code == 0) {
1534                                 PDEBUG(DBG_IRQ, "new compr params %#02x %#02x %#02x %#02x %#02x %#02x", buffer[0],
1535                                                                 buffer[1], buffer[2], buffer[3], buffer[4], buffer[5]);
1536                                 usbvision->last_compr_level = usbvision->compr_level;
1537                         }
1538                 }
1539         }
1540         return err_code;
1541 }
1542
1543 static int usbvision_request_intra(struct usb_usbvision *usbvision)
1544 {
1545         unsigned char buffer[1];
1546
1547         PDEBUG(DBG_IRQ, "");
1548         usbvision->request_intra = 1;
1549         buffer[0] = 1;
1550         usbvision_write_reg_irq(usbvision, USBVISION_FORCE_INTRA, buffer, 1);
1551         return 0;
1552 }
1553
1554 static int usbvision_unrequest_intra(struct usb_usbvision *usbvision)
1555 {
1556         unsigned char buffer[1];
1557
1558         PDEBUG(DBG_IRQ, "");
1559         usbvision->request_intra = 0;
1560         buffer[0] = 0;
1561         usbvision_write_reg_irq(usbvision, USBVISION_FORCE_INTRA, buffer, 1);
1562         return 0;
1563 }
1564
1565 /*******************************
1566  * usbvision utility functions
1567  *******************************/
1568
1569 int usbvision_power_off(struct usb_usbvision *usbvision)
1570 {
1571         int err_code = 0;
1572
1573         PDEBUG(DBG_FUNC, "");
1574
1575         err_code = usbvision_write_reg(usbvision, USBVISION_PWR_REG, USBVISION_SSPND_EN);
1576         if (err_code == 1)
1577                 usbvision->power = 0;
1578         PDEBUG(DBG_FUNC, "%s: err_code %d", (err_code != 1) ? "ERROR" : "power is off", err_code);
1579         return err_code;
1580 }
1581
1582 /* configure webcam image sensor using the serial port */
1583 static int usbvision_init_webcam(struct usb_usbvision *usbvision)
1584 {
1585         int rc;
1586         int i;
1587         static char init_values[38][3] = {
1588                 { 0x04, 0x12, 0x08 }, { 0x05, 0xff, 0xc8 }, { 0x06, 0x18, 0x07 }, { 0x07, 0x90, 0x00 },
1589                 { 0x09, 0x00, 0x00 }, { 0x0a, 0x00, 0x00 }, { 0x0b, 0x08, 0x00 }, { 0x0d, 0xcc, 0xcc },
1590                 { 0x0e, 0x13, 0x14 }, { 0x10, 0x9b, 0x83 }, { 0x11, 0x5a, 0x3f }, { 0x12, 0xe4, 0x73 },
1591                 { 0x13, 0x88, 0x84 }, { 0x14, 0x89, 0x80 }, { 0x15, 0x00, 0x20 }, { 0x16, 0x00, 0x00 },
1592                 { 0x17, 0xff, 0xa0 }, { 0x18, 0x6b, 0x20 }, { 0x19, 0x22, 0x40 }, { 0x1a, 0x10, 0x07 },
1593                 { 0x1b, 0x00, 0x47 }, { 0x1c, 0x03, 0xe0 }, { 0x1d, 0x00, 0x00 }, { 0x1e, 0x00, 0x00 },
1594                 { 0x1f, 0x00, 0x00 }, { 0x20, 0x00, 0x00 }, { 0x21, 0x00, 0x00 }, { 0x22, 0x00, 0x00 },
1595                 { 0x23, 0x00, 0x00 }, { 0x24, 0x00, 0x00 }, { 0x25, 0x00, 0x00 }, { 0x26, 0x00, 0x00 },
1596                 { 0x27, 0x00, 0x00 }, { 0x28, 0x00, 0x00 }, { 0x29, 0x00, 0x00 }, { 0x08, 0x80, 0x60 },
1597                 { 0x0f, 0x2d, 0x24 }, { 0x0c, 0x80, 0x80 }
1598         };
1599         char value[3];
1600
1601         /* the only difference between PAL and NTSC init_values */
1602         if (usbvision_device_data[usbvision->dev_model].video_norm == V4L2_STD_NTSC)
1603                 init_values[4][1] = 0x34;
1604
1605         for (i = 0; i < sizeof(init_values) / 3; i++) {
1606                 usbvision_write_reg(usbvision, USBVISION_SER_MODE, USBVISION_SER_MODE_SOFT);
1607                 memcpy(value, init_values[i], 3);
1608                 rc = usb_control_msg(usbvision->dev,
1609                                      usb_sndctrlpipe(usbvision->dev, 1),
1610                                      USBVISION_OP_CODE,
1611                                      USB_DIR_OUT | USB_TYPE_VENDOR |
1612                                      USB_RECIP_ENDPOINT, 0,
1613                                      (__u16) USBVISION_SER_DAT1, value,
1614                                      3, HZ);
1615                 if (rc < 0)
1616                         return rc;
1617                 usbvision_write_reg(usbvision, USBVISION_SER_MODE, USBVISION_SER_MODE_SIO);
1618                 /* write 3 bytes to the serial port using SIO mode */
1619                 usbvision_write_reg(usbvision, USBVISION_SER_CONT, 3 | 0x10);
1620                 usbvision_write_reg(usbvision, USBVISION_IOPIN_REG, 0);
1621                 usbvision_write_reg(usbvision, USBVISION_SER_MODE, USBVISION_SER_MODE_SOFT);
1622                 usbvision_write_reg(usbvision, USBVISION_IOPIN_REG, USBVISION_IO_2);
1623                 usbvision_write_reg(usbvision, USBVISION_SER_MODE, USBVISION_SER_MODE_SOFT | USBVISION_CLK_OUT);
1624                 usbvision_write_reg(usbvision, USBVISION_SER_MODE, USBVISION_SER_MODE_SOFT | USBVISION_DAT_IO);
1625                 usbvision_write_reg(usbvision, USBVISION_SER_MODE, USBVISION_SER_MODE_SOFT | USBVISION_CLK_OUT | USBVISION_DAT_IO);
1626         }
1627
1628         return 0;
1629 }
1630
1631 /*
1632  * usbvision_set_video_format()
1633  *
1634  */
1635 static int usbvision_set_video_format(struct usb_usbvision *usbvision, int format)
1636 {
1637         static const char proc[] = "usbvision_set_video_format";
1638         int rc;
1639         unsigned char value[2];
1640
1641         if (!USBVISION_IS_OPERATIONAL(usbvision))
1642                 return 0;
1643
1644         PDEBUG(DBG_FUNC, "isoc_mode %#02x", format);
1645
1646         if ((format != ISOC_MODE_YUV422)
1647             && (format != ISOC_MODE_YUV420)
1648             && (format != ISOC_MODE_COMPRESS)) {
1649                 printk(KERN_ERR "usbvision: unknown video format %02x, using default YUV420",
1650                        format);
1651                 format = ISOC_MODE_YUV420;
1652         }
1653         value[0] = 0x0A;  /* TODO: See the effect of the filter */
1654         value[1] = format; /* Sets the VO_MODE register which follows FILT_CONT */
1655         rc = usb_control_msg(usbvision->dev, usb_sndctrlpipe(usbvision->dev, 1),
1656                              USBVISION_OP_CODE,
1657                              USB_DIR_OUT | USB_TYPE_VENDOR |
1658                              USB_RECIP_ENDPOINT, 0,
1659                              (__u16) USBVISION_FILT_CONT, value, 2, HZ);
1660
1661         if (rc < 0) {
1662                 printk(KERN_ERR "%s: ERROR=%d. USBVISION stopped - "
1663                        "reconnect or reload driver.\n", proc, rc);
1664         }
1665         usbvision->isoc_mode = format;
1666         return rc;
1667 }
1668
1669 /*
1670  * usbvision_set_output()
1671  *
1672  */
1673
1674 int usbvision_set_output(struct usb_usbvision *usbvision, int width,
1675                          int height)
1676 {
1677         int err_code = 0;
1678         int usb_width, usb_height;
1679         unsigned int frame_rate = 0, frame_drop = 0;
1680         unsigned char value[4];
1681
1682         if (!USBVISION_IS_OPERATIONAL(usbvision))
1683                 return 0;
1684
1685         if (width > MAX_USB_WIDTH) {
1686                 usb_width = width / 2;
1687                 usbvision->stretch_width = 2;
1688         } else {
1689                 usb_width = width;
1690                 usbvision->stretch_width = 1;
1691         }
1692
1693         if (height > MAX_USB_HEIGHT) {
1694                 usb_height = height / 2;
1695                 usbvision->stretch_height = 2;
1696         } else {
1697                 usb_height = height;
1698                 usbvision->stretch_height = 1;
1699         }
1700
1701         RESTRICT_TO_RANGE(usb_width, MIN_FRAME_WIDTH, MAX_USB_WIDTH);
1702         usb_width &= ~(MIN_FRAME_WIDTH-1);
1703         RESTRICT_TO_RANGE(usb_height, MIN_FRAME_HEIGHT, MAX_USB_HEIGHT);
1704         usb_height &= ~(1);
1705
1706         PDEBUG(DBG_FUNC, "usb %dx%d; screen %dx%d; stretch %dx%d",
1707                                                 usb_width, usb_height, width, height,
1708                                                 usbvision->stretch_width, usbvision->stretch_height);
1709
1710         /* I'll not rewrite the same values */
1711         if ((usb_width != usbvision->curwidth) || (usb_height != usbvision->curheight)) {
1712                 value[0] = usb_width & 0xff;            /* LSB */
1713                 value[1] = (usb_width >> 8) & 0x03;     /* MSB */
1714                 value[2] = usb_height & 0xff;           /* LSB */
1715                 value[3] = (usb_height >> 8) & 0x03;    /* MSB */
1716
1717                 err_code = usb_control_msg(usbvision->dev, usb_sndctrlpipe(usbvision->dev, 1),
1718                              USBVISION_OP_CODE,
1719                              USB_DIR_OUT | USB_TYPE_VENDOR | USB_RECIP_ENDPOINT,
1720                                  0, (__u16) USBVISION_LXSIZE_O, value, 4, HZ);
1721
1722                 if (err_code < 0) {
1723                         dev_err(&usbvision->dev->dev,
1724                                 "%s failed: error %d\n", __func__, err_code);
1725                         return err_code;
1726                 }
1727                 usbvision->curwidth = usbvision->stretch_width * usb_width;
1728                 usbvision->curheight = usbvision->stretch_height * usb_height;
1729         }
1730
1731         if (usbvision->isoc_mode == ISOC_MODE_YUV422)
1732                 frame_rate = (usbvision->isoc_packet_size * 1000) / (usb_width * usb_height * 2);
1733         else if (usbvision->isoc_mode == ISOC_MODE_YUV420)
1734                 frame_rate = (usbvision->isoc_packet_size * 1000) / ((usb_width * usb_height * 12) / 8);
1735         else
1736                 frame_rate = FRAMERATE_MAX;
1737
1738         if (usbvision->tvnorm_id & V4L2_STD_625_50)
1739                 frame_drop = frame_rate * 32 / 25 - 1;
1740         else if (usbvision->tvnorm_id & V4L2_STD_525_60)
1741                 frame_drop = frame_rate * 32 / 30 - 1;
1742
1743         RESTRICT_TO_RANGE(frame_drop, FRAMERATE_MIN, FRAMERATE_MAX);
1744
1745         PDEBUG(DBG_FUNC, "frame_rate %d fps, frame_drop %d", frame_rate, frame_drop);
1746
1747         frame_drop = FRAMERATE_MAX;     /* We can allow the maximum here, because dropping is controlled */
1748
1749         if (usbvision_device_data[usbvision->dev_model].codec == CODEC_WEBCAM) {
1750                 if (usbvision_device_data[usbvision->dev_model].video_norm == V4L2_STD_PAL)
1751                         frame_drop = 25;
1752                 else
1753                         frame_drop = 30;
1754         }
1755
1756         /* frame_drop = 7; => frame_phase = 1, 5, 9, 13, 17, 21, 25, 0, 4, 8, ...
1757                 => frame_skip = 4;
1758                 => frame_rate = (7 + 1) * 25 / 32 = 200 / 32 = 6.25;
1759
1760            frame_drop = 9; => frame_phase = 1, 5, 8, 11, 14, 17, 21, 24, 27, 1, 4, 8, ...
1761             => frame_skip = 4, 3, 3, 3, 3, 4, 3, 3, 3, 3, 4, ...
1762                 => frame_rate = (9 + 1) * 25 / 32 = 250 / 32 = 7.8125;
1763         */
1764         err_code = usbvision_write_reg(usbvision, USBVISION_FRM_RATE, frame_drop);
1765         return err_code;
1766 }
1767
1768
1769 /*
1770  * usbvision_frames_alloc
1771  * allocate the required frames
1772  */
1773 int usbvision_frames_alloc(struct usb_usbvision *usbvision, int number_of_frames)
1774 {
1775         int i;
1776
1777         /* needs to be page aligned cause the buffers can be mapped individually! */
1778         usbvision->max_frame_size = PAGE_ALIGN(usbvision->curwidth *
1779                                                 usbvision->curheight *
1780                                                 usbvision->palette.bytes_per_pixel);
1781
1782         /* Try to do my best to allocate the frames the user want in the remaining memory */
1783         usbvision->num_frames = number_of_frames;
1784         while (usbvision->num_frames > 0) {
1785                 usbvision->fbuf_size = usbvision->num_frames * usbvision->max_frame_size;
1786                 usbvision->fbuf = usbvision_rvmalloc(usbvision->fbuf_size);
1787                 if (usbvision->fbuf)
1788                         break;
1789                 usbvision->num_frames--;
1790         }
1791
1792         spin_lock_init(&usbvision->queue_lock);
1793         init_waitqueue_head(&usbvision->wait_frame);
1794         init_waitqueue_head(&usbvision->wait_stream);
1795
1796         /* Allocate all buffers */
1797         for (i = 0; i < usbvision->num_frames; i++) {
1798                 usbvision->frame[i].index = i;
1799                 usbvision->frame[i].grabstate = frame_state_unused;
1800                 usbvision->frame[i].data = usbvision->fbuf +
1801                         i * usbvision->max_frame_size;
1802                 /*
1803                  * Set default sizes for read operation.
1804                  */
1805                 usbvision->stretch_width = 1;
1806                 usbvision->stretch_height = 1;
1807                 usbvision->frame[i].width = usbvision->curwidth;
1808                 usbvision->frame[i].height = usbvision->curheight;
1809                 usbvision->frame[i].bytes_read = 0;
1810         }
1811         PDEBUG(DBG_FUNC, "allocated %d frames (%d bytes per frame)",
1812                         usbvision->num_frames, usbvision->max_frame_size);
1813         return usbvision->num_frames;
1814 }
1815
1816 /*
1817  * usbvision_frames_free
1818  * frees memory allocated for the frames
1819  */
1820 void usbvision_frames_free(struct usb_usbvision *usbvision)
1821 {
1822         /* Have to free all that memory */
1823         PDEBUG(DBG_FUNC, "free %d frames", usbvision->num_frames);
1824
1825         if (usbvision->fbuf != NULL) {
1826                 usbvision_rvfree(usbvision->fbuf, usbvision->fbuf_size);
1827                 usbvision->fbuf = NULL;
1828
1829                 usbvision->num_frames = 0;
1830         }
1831 }
1832 /*
1833  * usbvision_empty_framequeues()
1834  * prepare queues for incoming and outgoing frames
1835  */
1836 void usbvision_empty_framequeues(struct usb_usbvision *usbvision)
1837 {
1838         u32 i;
1839
1840         INIT_LIST_HEAD(&(usbvision->inqueue));
1841         INIT_LIST_HEAD(&(usbvision->outqueue));
1842
1843         for (i = 0; i < USBVISION_NUMFRAMES; i++) {
1844                 usbvision->frame[i].grabstate = frame_state_unused;
1845                 usbvision->frame[i].bytes_read = 0;
1846         }
1847 }
1848
1849 /*
1850  * usbvision_stream_interrupt()
1851  * stops streaming
1852  */
1853 int usbvision_stream_interrupt(struct usb_usbvision *usbvision)
1854 {
1855         int ret = 0;
1856
1857         /* stop reading from the device */
1858
1859         usbvision->streaming = stream_interrupt;
1860         ret = wait_event_timeout(usbvision->wait_stream,
1861                                  (usbvision->streaming == stream_idle),
1862                                  msecs_to_jiffies(USBVISION_NUMSBUF*USBVISION_URB_FRAMES));
1863         return ret;
1864 }
1865
1866 /*
1867  * usbvision_set_compress_params()
1868  *
1869  */
1870
1871 static int usbvision_set_compress_params(struct usb_usbvision *usbvision)
1872 {
1873         static const char proc[] = "usbvision_set_compresion_params: ";
1874         int rc;
1875         unsigned char value[6];
1876
1877         value[0] = 0x0F;    /* Intra-Compression cycle */
1878         value[1] = 0x01;    /* Reg.45 one line per strip */
1879         value[2] = 0x00;    /* Reg.46 Force intra mode on all new frames */
1880         value[3] = 0x00;    /* Reg.47 FORCE_UP <- 0 normal operation (not force) */
1881         value[4] = 0xA2;    /* Reg.48 BUF_THR I'm not sure if this does something in not compressed mode. */
1882         value[5] = 0x00;    /* Reg.49 DVI_YUV This has nothing to do with compression */
1883
1884         /* catched values for NT1004 */
1885         /* value[0] = 0xFF; Never apply intra mode automatically */
1886         /* value[1] = 0xF1; Use full frame height for virtual strip width; One line per strip */
1887         /* value[2] = 0x01; Force intra mode on all new frames */
1888         /* value[3] = 0x00; Strip size 400 Bytes; do not force up */
1889         /* value[4] = 0xA2; */
1890         if (!USBVISION_IS_OPERATIONAL(usbvision))
1891                 return 0;
1892
1893         rc = usb_control_msg(usbvision->dev, usb_sndctrlpipe(usbvision->dev, 1),
1894                              USBVISION_OP_CODE,
1895                              USB_DIR_OUT | USB_TYPE_VENDOR |
1896                              USB_RECIP_ENDPOINT, 0,
1897                              (__u16) USBVISION_INTRA_CYC, value, 5, HZ);
1898
1899         if (rc < 0) {
1900                 printk(KERN_ERR "%sERROR=%d. USBVISION stopped - "
1901                        "reconnect or reload driver.\n", proc, rc);
1902                 return rc;
1903         }
1904
1905         if (usbvision->bridge_type == BRIDGE_NT1004) {
1906                 value[0] =  20; /* PCM Threshold 1 */
1907                 value[1] =  12; /* PCM Threshold 2 */
1908                 value[2] = 255; /* Distortion Threshold inter */
1909                 value[3] = 255; /* Distortion Threshold intra */
1910                 value[4] =  43; /* Max Distortion inter */
1911                 value[5] =  43; /* Max Distortion intra */
1912         } else {
1913                 value[0] =  20; /* PCM Threshold 1 */
1914                 value[1] =  12; /* PCM Threshold 2 */
1915                 value[2] = 255; /* Distortion Threshold d7-d0 */
1916                 value[3] =   0; /* Distortion Threshold d11-d8 */
1917                 value[4] =  43; /* Max Distortion d7-d0 */
1918                 value[5] =   0; /* Max Distortion d8 */
1919         }
1920
1921         if (!USBVISION_IS_OPERATIONAL(usbvision))
1922                 return 0;
1923
1924         rc = usb_control_msg(usbvision->dev, usb_sndctrlpipe(usbvision->dev, 1),
1925                              USBVISION_OP_CODE,
1926                              USB_DIR_OUT | USB_TYPE_VENDOR |
1927                              USB_RECIP_ENDPOINT, 0,
1928                              (__u16) USBVISION_PCM_THR1, value, 6, HZ);
1929
1930         if (rc < 0) {
1931                 printk(KERN_ERR "%sERROR=%d. USBVISION stopped - "
1932                        "reconnect or reload driver.\n", proc, rc);
1933         }
1934         return rc;
1935 }
1936
1937
1938 /*
1939  * usbvision_set_input()
1940  *
1941  * Set the input (saa711x, ...) size x y and other misc input params
1942  * I've no idea if this parameters are right
1943  *
1944  */
1945 int usbvision_set_input(struct usb_usbvision *usbvision)
1946 {
1947         static const char proc[] = "usbvision_set_input: ";
1948         int rc;
1949         unsigned char value[8];
1950         unsigned char dvi_yuv_value;
1951
1952         if (!USBVISION_IS_OPERATIONAL(usbvision))
1953                 return 0;
1954
1955         /* Set input format expected from decoder*/
1956         if (usbvision_device_data[usbvision->dev_model].vin_reg1_override) {
1957                 value[0] = usbvision_device_data[usbvision->dev_model].vin_reg1;
1958         } else if (usbvision_device_data[usbvision->dev_model].codec == CODEC_SAA7113) {
1959                 /* SAA7113 uses 8 bit output */
1960                 value[0] = USBVISION_8_422_SYNC;
1961         } else {
1962                 /* I'm sure only about d2-d0 [010] 16 bit 4:2:2 usin sync pulses
1963                  * as that is how saa7111 is configured */
1964                 value[0] = USBVISION_16_422_SYNC;
1965                 /* | USBVISION_VSNC_POL | USBVISION_VCLK_POL);*/
1966         }
1967
1968         rc = usbvision_write_reg(usbvision, USBVISION_VIN_REG1, value[0]);
1969         if (rc < 0) {
1970                 printk(KERN_ERR "%sERROR=%d. USBVISION stopped - "
1971                        "reconnect or reload driver.\n", proc, rc);
1972                 return rc;
1973         }
1974
1975
1976         if (usbvision->tvnorm_id & V4L2_STD_PAL) {
1977                 value[0] = 0xC0;
1978                 value[1] = 0x02;        /* 0x02C0 -> 704 Input video line length */
1979                 value[2] = 0x20;
1980                 value[3] = 0x01;        /* 0x0120 -> 288 Input video n. of lines */
1981                 value[4] = 0x60;
1982                 value[5] = 0x00;        /* 0x0060 -> 96 Input video h offset */
1983                 value[6] = 0x16;
1984                 value[7] = 0x00;        /* 0x0016 -> 22 Input video v offset */
1985         } else if (usbvision->tvnorm_id & V4L2_STD_SECAM) {
1986                 value[0] = 0xC0;
1987                 value[1] = 0x02;        /* 0x02C0 -> 704 Input video line length */
1988                 value[2] = 0x20;
1989                 value[3] = 0x01;        /* 0x0120 -> 288 Input video n. of lines */
1990                 value[4] = 0x01;
1991                 value[5] = 0x00;        /* 0x0001 -> 01 Input video h offset */
1992                 value[6] = 0x01;
1993                 value[7] = 0x00;        /* 0x0001 -> 01 Input video v offset */
1994         } else {        /* V4L2_STD_NTSC */
1995                 value[0] = 0xD0;
1996                 value[1] = 0x02;        /* 0x02D0 -> 720 Input video line length */
1997                 value[2] = 0xF0;
1998                 value[3] = 0x00;        /* 0x00F0 -> 240 Input video number of lines */
1999                 value[4] = 0x50;
2000                 value[5] = 0x00;        /* 0x0050 -> 80 Input video h offset */
2001                 value[6] = 0x10;
2002                 value[7] = 0x00;        /* 0x0010 -> 16 Input video v offset */
2003         }
2004
2005         /* webcam is only 480 pixels wide, both PAL and NTSC version */
2006         if (usbvision_device_data[usbvision->dev_model].codec == CODEC_WEBCAM) {
2007                 value[0] = 0xe0;
2008                 value[1] = 0x01;        /* 0x01E0 -> 480 Input video line length */
2009         }
2010
2011         if (usbvision_device_data[usbvision->dev_model].x_offset >= 0) {
2012                 value[4] = usbvision_device_data[usbvision->dev_model].x_offset & 0xff;
2013                 value[5] = (usbvision_device_data[usbvision->dev_model].x_offset & 0x0300) >> 8;
2014         }
2015
2016         if (adjust_x_offset != -1) {
2017                 value[4] = adjust_x_offset & 0xff;
2018                 value[5] = (adjust_x_offset & 0x0300) >> 8;
2019         }
2020
2021         if (usbvision_device_data[usbvision->dev_model].y_offset >= 0) {
2022                 value[6] = usbvision_device_data[usbvision->dev_model].y_offset & 0xff;
2023                 value[7] = (usbvision_device_data[usbvision->dev_model].y_offset & 0x0300) >> 8;
2024         }
2025
2026         if (adjust_y_offset != -1) {
2027                 value[6] = adjust_y_offset & 0xff;
2028                 value[7] = (adjust_y_offset & 0x0300) >> 8;
2029         }
2030
2031         rc = usb_control_msg(usbvision->dev, usb_sndctrlpipe(usbvision->dev, 1),
2032                              USBVISION_OP_CODE, /* USBVISION specific code */
2033                              USB_DIR_OUT | USB_TYPE_VENDOR | USB_RECIP_ENDPOINT, 0,
2034                              (__u16) USBVISION_LXSIZE_I, value, 8, HZ);
2035         if (rc < 0) {
2036                 printk(KERN_ERR "%sERROR=%d. USBVISION stopped - "
2037                        "reconnect or reload driver.\n", proc, rc);
2038                 return rc;
2039         }
2040
2041
2042         dvi_yuv_value = 0x00;   /* U comes after V, Ya comes after U/V, Yb comes after Yb */
2043
2044         if (usbvision_device_data[usbvision->dev_model].dvi_yuv_override) {
2045                 dvi_yuv_value = usbvision_device_data[usbvision->dev_model].dvi_yuv;
2046         } else if (usbvision_device_data[usbvision->dev_model].codec == CODEC_SAA7113) {
2047                 /* This changes as the fine sync control changes. Further investigation necessary */
2048                 dvi_yuv_value = 0x06;
2049         }
2050
2051         return usbvision_write_reg(usbvision, USBVISION_DVI_YUV, dvi_yuv_value);
2052 }
2053
2054
2055 /*
2056  * usbvision_set_dram_settings()
2057  *
2058  * Set the buffer address needed by the usbvision dram to operate
2059  * This values has been taken with usbsnoop.
2060  *
2061  */
2062
2063 static int usbvision_set_dram_settings(struct usb_usbvision *usbvision)
2064 {
2065         int rc;
2066         unsigned char value[8];
2067
2068         if (usbvision->isoc_mode == ISOC_MODE_COMPRESS) {
2069                 value[0] = 0x42;
2070                 value[1] = 0x71;
2071                 value[2] = 0xff;
2072                 value[3] = 0x00;
2073                 value[4] = 0x98;
2074                 value[5] = 0xe0;
2075                 value[6] = 0x71;
2076                 value[7] = 0xff;
2077                 /* UR:  0x0E200-0x3FFFF = 204288 Words (1 Word = 2 Byte) */
2078                 /* FDL: 0x00000-0x0E099 =  57498 Words */
2079                 /* VDW: 0x0E3FF-0x3FFFF */
2080         } else {
2081                 value[0] = 0x42;
2082                 value[1] = 0x00;
2083                 value[2] = 0xff;
2084                 value[3] = 0x00;
2085                 value[4] = 0x00;
2086                 value[5] = 0x00;
2087                 value[6] = 0x00;
2088                 value[7] = 0xff;
2089         }
2090         /* These are the values of the address of the video buffer,
2091          * they have to be loaded into the USBVISION_DRM_PRM1-8
2092          *
2093          * Start address of video output buffer for read:       drm_prm1-2 -> 0x00000
2094          * End address of video output buffer for read:         drm_prm1-3 -> 0x1ffff
2095          * Start address of video frame delay buffer:           drm_prm1-4 -> 0x20000
2096          *    Only used in compressed mode
2097          * End address of video frame delay buffer:             drm_prm1-5-6 -> 0x3ffff
2098          *    Only used in compressed mode
2099          * Start address of video output buffer for write:      drm_prm1-7 -> 0x00000
2100          * End address of video output buffer for write:        drm_prm1-8 -> 0x1ffff
2101          */
2102
2103         if (!USBVISION_IS_OPERATIONAL(usbvision))
2104                 return 0;
2105
2106         rc = usb_control_msg(usbvision->dev, usb_sndctrlpipe(usbvision->dev, 1),
2107                              USBVISION_OP_CODE, /* USBVISION specific code */
2108                              USB_DIR_OUT | USB_TYPE_VENDOR |
2109                              USB_RECIP_ENDPOINT, 0,
2110                              (__u16) USBVISION_DRM_PRM1, value, 8, HZ);
2111
2112         if (rc < 0) {
2113                 dev_err(&usbvision->dev->dev, "%s: ERROR=%d\n", __func__, rc);
2114                 return rc;
2115         }
2116
2117         /* Restart the video buffer logic */
2118         rc = usbvision_write_reg(usbvision, USBVISION_DRM_CONT, USBVISION_RES_UR |
2119                                    USBVISION_RES_FDL | USBVISION_RES_VDW);
2120         if (rc < 0)
2121                 return rc;
2122         rc = usbvision_write_reg(usbvision, USBVISION_DRM_CONT, 0x00);
2123
2124         return rc;
2125 }
2126
2127 /*
2128  * ()
2129  *
2130  * Power on the device, enables suspend-resume logic
2131  * &  reset the isoc End-Point
2132  *
2133  */
2134
2135 int usbvision_power_on(struct usb_usbvision *usbvision)
2136 {
2137         int err_code = 0;
2138
2139         PDEBUG(DBG_FUNC, "");
2140
2141         usbvision_write_reg(usbvision, USBVISION_PWR_REG, USBVISION_SSPND_EN);
2142         usbvision_write_reg(usbvision, USBVISION_PWR_REG,
2143                         USBVISION_SSPND_EN | USBVISION_RES2);
2144
2145         if (usbvision_device_data[usbvision->dev_model].codec == CODEC_WEBCAM) {
2146                 usbvision_write_reg(usbvision, USBVISION_VIN_REG1,
2147                                 USBVISION_16_422_SYNC | USBVISION_HVALID_PO);
2148                 usbvision_write_reg(usbvision, USBVISION_VIN_REG2,
2149                                 USBVISION_NOHVALID | USBVISION_KEEP_BLANK);
2150         }
2151         usbvision_write_reg(usbvision, USBVISION_PWR_REG,
2152                         USBVISION_SSPND_EN | USBVISION_PWR_VID);
2153         mdelay(10);
2154         err_code = usbvision_write_reg(usbvision, USBVISION_PWR_REG,
2155                         USBVISION_SSPND_EN | USBVISION_PWR_VID | USBVISION_RES2);
2156         if (err_code == 1)
2157                 usbvision->power = 1;
2158         PDEBUG(DBG_FUNC, "%s: err_code %d", (err_code < 0) ? "ERROR" : "power is on", err_code);
2159         return err_code;
2160 }
2161
2162
2163 /*
2164  * usbvision timer stuff
2165  */
2166
2167 /* to call usbvision_power_off from task queue */
2168 static void call_usbvision_power_off(struct work_struct *work)
2169 {
2170         struct usb_usbvision *usbvision = container_of(work, struct usb_usbvision, power_off_work);
2171
2172         PDEBUG(DBG_FUNC, "");
2173         if (mutex_lock_interruptible(&usbvision->v4l2_lock))
2174                 return;
2175
2176         if (usbvision->user == 0) {
2177                 usbvision_i2c_unregister(usbvision);
2178
2179                 usbvision_power_off(usbvision);
2180                 usbvision->initialized = 0;
2181         }
2182         mutex_unlock(&usbvision->v4l2_lock);
2183 }
2184
2185 static void usbvision_power_off_timer(unsigned long data)
2186 {
2187         struct usb_usbvision *usbvision = (void *)data;
2188
2189         PDEBUG(DBG_FUNC, "");
2190         del_timer(&usbvision->power_off_timer);
2191         INIT_WORK(&usbvision->power_off_work, call_usbvision_power_off);
2192         (void) schedule_work(&usbvision->power_off_work);
2193 }
2194
2195 void usbvision_init_power_off_timer(struct usb_usbvision *usbvision)
2196 {
2197         setup_timer(&usbvision->power_off_timer, usbvision_power_off_timer,
2198                     (unsigned long)usbvision);
2199 }
2200
2201 void usbvision_set_power_off_timer(struct usb_usbvision *usbvision)
2202 {
2203         mod_timer(&usbvision->power_off_timer, jiffies + USBVISION_POWEROFF_TIME);
2204 }
2205
2206 void usbvision_reset_power_off_timer(struct usb_usbvision *usbvision)
2207 {
2208         if (timer_pending(&usbvision->power_off_timer))
2209                 del_timer(&usbvision->power_off_timer);
2210 }
2211
2212 /*
2213  * usbvision_begin_streaming()
2214  * Sure you have to put bit 7 to 0, if not incoming frames are droped, but no
2215  * idea about the rest
2216  */
2217 int usbvision_begin_streaming(struct usb_usbvision *usbvision)
2218 {
2219         if (usbvision->isoc_mode == ISOC_MODE_COMPRESS)
2220                 usbvision_init_compression(usbvision);
2221         return usbvision_write_reg(usbvision, USBVISION_VIN_REG2,
2222                 USBVISION_NOHVALID | usbvision->vin_reg2_preset);
2223 }
2224
2225 /*
2226  * usbvision_restart_isoc()
2227  * Not sure yet if touching here PWR_REG make loose the config
2228  */
2229
2230 int usbvision_restart_isoc(struct usb_usbvision *usbvision)
2231 {
2232         int ret;
2233
2234         ret = usbvision_write_reg(usbvision, USBVISION_PWR_REG,
2235                               USBVISION_SSPND_EN | USBVISION_PWR_VID);
2236         if (ret < 0)
2237                 return ret;
2238         ret = usbvision_write_reg(usbvision, USBVISION_PWR_REG,
2239                               USBVISION_SSPND_EN | USBVISION_PWR_VID |
2240                               USBVISION_RES2);
2241         if (ret < 0)
2242                 return ret;
2243         ret = usbvision_write_reg(usbvision, USBVISION_VIN_REG2,
2244                               USBVISION_KEEP_BLANK | USBVISION_NOHVALID |
2245                                   usbvision->vin_reg2_preset);
2246         if (ret < 0)
2247                 return ret;
2248
2249         /* TODO: schedule timeout */
2250         while ((usbvision_read_reg(usbvision, USBVISION_STATUS_REG) & 0x01) != 1)
2251                 ;
2252
2253         return 0;
2254 }
2255
2256 int usbvision_audio_off(struct usb_usbvision *usbvision)
2257 {
2258         if (usbvision_write_reg(usbvision, USBVISION_IOPIN_REG, USBVISION_AUDIO_MUTE) < 0) {
2259                 printk(KERN_ERR "usbvision_audio_off: can't write reg\n");
2260                 return -1;
2261         }
2262         usbvision->audio_mute = 0;
2263         usbvision->audio_channel = USBVISION_AUDIO_MUTE;
2264         return 0;
2265 }
2266
2267 int usbvision_set_audio(struct usb_usbvision *usbvision, int audio_channel)
2268 {
2269         if (!usbvision->audio_mute) {
2270                 if (usbvision_write_reg(usbvision, USBVISION_IOPIN_REG, audio_channel) < 0) {
2271                         printk(KERN_ERR "usbvision_set_audio: can't write iopin register for audio switching\n");
2272                         return -1;
2273                 }
2274         }
2275         usbvision->audio_channel = audio_channel;
2276         return 0;
2277 }
2278
2279 int usbvision_setup(struct usb_usbvision *usbvision, int format)
2280 {
2281         if (usbvision_device_data[usbvision->dev_model].codec == CODEC_WEBCAM)
2282                 usbvision_init_webcam(usbvision);
2283         usbvision_set_video_format(usbvision, format);
2284         usbvision_set_dram_settings(usbvision);
2285         usbvision_set_compress_params(usbvision);
2286         usbvision_set_input(usbvision);
2287         usbvision_set_output(usbvision, MAX_USB_WIDTH, MAX_USB_HEIGHT);
2288         usbvision_restart_isoc(usbvision);
2289
2290         /* cosas del PCM */
2291         return USBVISION_IS_OPERATIONAL(usbvision);
2292 }
2293
2294 int usbvision_set_alternate(struct usb_usbvision *dev)
2295 {
2296         int err_code, prev_alt = dev->iface_alt;
2297         int i;
2298
2299         dev->iface_alt = 0;
2300         for (i = 0; i < dev->num_alt; i++)
2301                 if (dev->alt_max_pkt_size[i] > dev->alt_max_pkt_size[dev->iface_alt])
2302                         dev->iface_alt = i;
2303
2304         if (dev->iface_alt != prev_alt) {
2305                 dev->isoc_packet_size = dev->alt_max_pkt_size[dev->iface_alt];
2306                 PDEBUG(DBG_FUNC, "setting alternate %d with max_packet_size=%u",
2307                                 dev->iface_alt, dev->isoc_packet_size);
2308                 err_code = usb_set_interface(dev->dev, dev->iface, dev->iface_alt);
2309                 if (err_code < 0) {
2310                         dev_err(&dev->dev->dev,
2311                                 "cannot change alternate number to %d (error=%i)\n",
2312                                         dev->iface_alt, err_code);
2313                         return err_code;
2314                 }
2315         }
2316
2317         PDEBUG(DBG_ISOC, "ISO Packet Length:%d", dev->isoc_packet_size);
2318
2319         return 0;
2320 }
2321
2322 /*
2323  * usbvision_init_isoc()
2324  *
2325  */
2326 int usbvision_init_isoc(struct usb_usbvision *usbvision)
2327 {
2328         struct usb_device *dev = usbvision->dev;
2329         int buf_idx, err_code, reg_value;
2330         int sb_size;
2331
2332         if (!USBVISION_IS_OPERATIONAL(usbvision))
2333                 return -EFAULT;
2334
2335         usbvision->cur_frame = NULL;
2336         scratch_reset(usbvision);
2337
2338         /* Alternate interface 1 is is the biggest frame size */
2339         err_code = usbvision_set_alternate(usbvision);
2340         if (err_code < 0) {
2341                 usbvision->last_error = err_code;
2342                 return -EBUSY;
2343         }
2344         sb_size = USBVISION_URB_FRAMES * usbvision->isoc_packet_size;
2345
2346         reg_value = (16 - usbvision_read_reg(usbvision,
2347                                             USBVISION_ALTER_REG)) & 0x0F;
2348
2349         usbvision->usb_bandwidth = reg_value >> 1;
2350         PDEBUG(DBG_ISOC, "USB Bandwidth Usage: %dMbit/Sec",
2351                usbvision->usb_bandwidth);
2352
2353
2354
2355         /* We double buffer the Iso lists */
2356
2357         for (buf_idx = 0; buf_idx < USBVISION_NUMSBUF; buf_idx++) {
2358                 int j, k;
2359                 struct urb *urb;
2360
2361                 urb = usb_alloc_urb(USBVISION_URB_FRAMES, GFP_KERNEL);
2362                 if (urb == NULL) {
2363                         dev_err(&usbvision->dev->dev,
2364                                 "%s: usb_alloc_urb() failed\n", __func__);
2365                         return -ENOMEM;
2366                 }
2367                 usbvision->sbuf[buf_idx].urb = urb;
2368                 usbvision->sbuf[buf_idx].data =
2369                         usb_alloc_coherent(usbvision->dev,
2370                                            sb_size,
2371                                            GFP_KERNEL,
2372                                            &urb->transfer_dma);
2373                 urb->dev = dev;
2374                 urb->context = usbvision;
2375                 urb->pipe = usb_rcvisocpipe(dev, usbvision->video_endp);
2376                 urb->transfer_flags = URB_ISO_ASAP | URB_NO_TRANSFER_DMA_MAP;
2377                 urb->interval = 1;
2378                 urb->transfer_buffer = usbvision->sbuf[buf_idx].data;
2379                 urb->complete = usbvision_isoc_irq;
2380                 urb->number_of_packets = USBVISION_URB_FRAMES;
2381                 urb->transfer_buffer_length =
2382                     usbvision->isoc_packet_size * USBVISION_URB_FRAMES;
2383                 for (j = k = 0; j < USBVISION_URB_FRAMES; j++,
2384                      k += usbvision->isoc_packet_size) {
2385                         urb->iso_frame_desc[j].offset = k;
2386                         urb->iso_frame_desc[j].length =
2387                                 usbvision->isoc_packet_size;
2388                 }
2389         }
2390
2391         /* Submit all URBs */
2392         for (buf_idx = 0; buf_idx < USBVISION_NUMSBUF; buf_idx++) {
2393                         err_code = usb_submit_urb(usbvision->sbuf[buf_idx].urb,
2394                                                  GFP_KERNEL);
2395                 if (err_code) {
2396                         dev_err(&usbvision->dev->dev,
2397                                 "%s: usb_submit_urb(%d) failed: error %d\n",
2398                                         __func__, buf_idx, err_code);
2399                 }
2400         }
2401
2402         usbvision->streaming = stream_idle;
2403         PDEBUG(DBG_ISOC, "%s: streaming=1 usbvision->video_endp=$%02x",
2404                __func__,
2405                usbvision->video_endp);
2406         return 0;
2407 }
2408
2409 /*
2410  * usbvision_stop_isoc()
2411  *
2412  * This procedure stops streaming and deallocates URBs. Then it
2413  * activates zero-bandwidth alt. setting of the video interface.
2414  *
2415  */
2416 void usbvision_stop_isoc(struct usb_usbvision *usbvision)
2417 {
2418         int buf_idx, err_code, reg_value;
2419         int sb_size = USBVISION_URB_FRAMES * usbvision->isoc_packet_size;
2420
2421         if ((usbvision->streaming == stream_off) || (usbvision->dev == NULL))
2422                 return;
2423
2424         /* Unschedule all of the iso td's */
2425         for (buf_idx = 0; buf_idx < USBVISION_NUMSBUF; buf_idx++) {
2426                 usb_kill_urb(usbvision->sbuf[buf_idx].urb);
2427                 if (usbvision->sbuf[buf_idx].data) {
2428                         usb_free_coherent(usbvision->dev,
2429                                           sb_size,
2430                                           usbvision->sbuf[buf_idx].data,
2431                                           usbvision->sbuf[buf_idx].urb->transfer_dma);
2432                 }
2433                 usb_free_urb(usbvision->sbuf[buf_idx].urb);
2434                 usbvision->sbuf[buf_idx].urb = NULL;
2435         }
2436
2437         PDEBUG(DBG_ISOC, "%s: streaming=stream_off\n", __func__);
2438         usbvision->streaming = stream_off;
2439
2440         if (!usbvision->remove_pending) {
2441                 /* Set packet size to 0 */
2442                 usbvision->iface_alt = 0;
2443                 err_code = usb_set_interface(usbvision->dev, usbvision->iface,
2444                                             usbvision->iface_alt);
2445                 if (err_code < 0) {
2446                         dev_err(&usbvision->dev->dev,
2447                                 "%s: usb_set_interface() failed: error %d\n",
2448                                         __func__, err_code);
2449                         usbvision->last_error = err_code;
2450                 }
2451                 reg_value = (16-usbvision_read_reg(usbvision, USBVISION_ALTER_REG)) & 0x0F;
2452                 usbvision->isoc_packet_size =
2453                         (reg_value == 0) ? 0 : (reg_value * 64) - 1;
2454                 PDEBUG(DBG_ISOC, "ISO Packet Length:%d",
2455                        usbvision->isoc_packet_size);
2456
2457                 usbvision->usb_bandwidth = reg_value >> 1;
2458                 PDEBUG(DBG_ISOC, "USB Bandwidth Usage: %dMbit/Sec",
2459                        usbvision->usb_bandwidth);
2460         }
2461 }
2462
2463 int usbvision_muxsel(struct usb_usbvision *usbvision, int channel)
2464 {
2465         /* inputs #0 and #3 are constant for every SAA711x. */
2466         /* inputs #1 and #2 are variable for SAA7111 and SAA7113 */
2467         int mode[4] = { SAA7115_COMPOSITE0, 0, 0, SAA7115_COMPOSITE3 };
2468         int audio[] = { 1, 0, 0, 0 };
2469         /* channel 0 is TV with audiochannel 1 (tuner mono) */
2470         /* channel 1 is Composite with audio channel 0 (line in) */
2471         /* channel 2 is S-Video with audio channel 0 (line in) */
2472         /* channel 3 is additional video inputs to the device with audio channel 0 (line in) */
2473
2474         RESTRICT_TO_RANGE(channel, 0, usbvision->video_inputs);
2475         usbvision->ctl_input = channel;
2476
2477         /* set the new channel */
2478         /* Regular USB TV Tuners -> channel: 0 = Television, 1 = Composite, 2 = S-Video */
2479         /* Four video input devices -> channel: 0 = Chan White, 1 = Chan Green, 2 = Chan Yellow, 3 = Chan Red */
2480
2481         switch (usbvision_device_data[usbvision->dev_model].codec) {
2482         case CODEC_SAA7113:
2483                 mode[1] = SAA7115_COMPOSITE2;
2484                 if (switch_svideo_input) {
2485                         /* To handle problems with S-Video Input for
2486                          * some devices.  Use switch_svideo_input
2487                          * parameter when loading the module.*/
2488                         mode[2] = SAA7115_COMPOSITE1;
2489                 } else {
2490                         mode[2] = SAA7115_SVIDEO1;
2491                 }
2492                 break;
2493         case CODEC_SAA7111:
2494         default:
2495                 /* modes for saa7111 */
2496                 mode[1] = SAA7115_COMPOSITE1;
2497                 mode[2] = SAA7115_SVIDEO1;
2498                 break;
2499         }
2500         call_all(usbvision, video, s_routing, mode[channel], 0, 0);
2501         usbvision_set_audio(usbvision, audio[channel]);
2502         return 0;
2503 }