s2255drv.c 72.4 KB
Newer Older
1 2 3
/*
 *  s2255drv.c - a driver for the Sensoray 2255 USB video capture device
 *
4
 *   Copyright (C) 2007-2014 by Sensoray Company Inc.
5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42
 *                              Dean Anderson
 *
 * Some video buffer code based on vivi driver:
 *
 * Sensoray 2255 device supports 4 simultaneous channels.
 * The channels are not "crossbar" inputs, they are physically
 * attached to separate video decoders.
 *
 * Because of USB2.0 bandwidth limitations. There is only a
 * certain amount of data which may be transferred at one time.
 *
 * Example maximum bandwidth utilization:
 *
 * -full size, color mode YUYV or YUV422P: 2 channels at once
 * -full or half size Grey scale: all 4 channels at once
 * -half size, color mode YUYV or YUV422P: all 4 channels at once
 * -full size, color mode YUYV or YUV422P 1/2 frame rate: all 4 channels
 *  at once.
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
 */

#include <linux/module.h>
#include <linux/firmware.h>
#include <linux/kernel.h>
#include <linux/mutex.h>
43
#include <linux/slab.h>
44
#include <linux/videodev2.h>
45
#include <linux/mm.h>
46 47
#include <linux/vmalloc.h>
#include <linux/usb.h>
48 49
#include <media/videobuf-vmalloc.h>
#include <media/v4l2-common.h>
50
#include <media/v4l2-device.h>
51
#include <media/v4l2-ioctl.h>
52
#include <media/v4l2-ctrls.h>
53
#include <media/v4l2-event.h>
54

55
#define S2255_VERSION		"1.24.1"
56 57
#define FIRMWARE_FILE_NAME "f2255usb.bin"

58 59
/* default JPEG quality */
#define S2255_DEF_JPEG_QUAL     50
60 61 62 63 64 65 66 67 68
/* vendor request in */
#define S2255_VR_IN		0
/* vendor request out */
#define S2255_VR_OUT		1
/* firmware query */
#define S2255_VR_FW		0x30
/* USB endpoint number for configuring the device */
#define S2255_CONFIG_EP         2
/* maximum time for DSP to start responding after last FW word loaded(ms) */
69
#define S2255_DSP_BOOTTIME      800
70
/* maximum time to wait for firmware to load (ms) */
71
#define S2255_LOAD_TIMEOUT      (5000 + S2255_DSP_BOOTTIME)
72
#define S2255_MIN_BUFS          2
73
#define S2255_SETMODE_TIMEOUT   500
74
#define S2255_VIDSTATUS_TIMEOUT 350
75 76 77 78 79
#define S2255_MARKER_FRAME	cpu_to_le32(0x2255DA4AL)
#define S2255_MARKER_RESPONSE	cpu_to_le32(0x2255ACACL)
#define S2255_RESPONSE_SETMODE  cpu_to_le32(0x01)
#define S2255_RESPONSE_FW       cpu_to_le32(0x10)
#define S2255_RESPONSE_STATUS   cpu_to_le32(0x20)
80
#define S2255_USB_XFER_SIZE	(16 * 1024)
81 82 83
#define MAX_CHANNELS		4
#define SYS_FRAMES		4
/* maximum size is PAL full size plus room for the marker header(s) */
84 85
#define SYS_FRAMES_MAXSIZE	(720*288*2*2 + 4096)
#define DEF_USB_BLOCK		S2255_USB_XFER_SIZE
86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108
#define LINE_SZ_4CIFS_NTSC	640
#define LINE_SZ_2CIFS_NTSC	640
#define LINE_SZ_1CIFS_NTSC	320
#define LINE_SZ_4CIFS_PAL	704
#define LINE_SZ_2CIFS_PAL	704
#define LINE_SZ_1CIFS_PAL	352
#define NUM_LINES_4CIFS_NTSC	240
#define NUM_LINES_2CIFS_NTSC	240
#define NUM_LINES_1CIFS_NTSC	240
#define NUM_LINES_4CIFS_PAL	288
#define NUM_LINES_2CIFS_PAL	288
#define NUM_LINES_1CIFS_PAL	288
#define LINE_SZ_DEF		640
#define NUM_LINES_DEF		240


/* predefined settings */
#define FORMAT_NTSC	1
#define FORMAT_PAL	2

#define SCALE_4CIFS	1	/* 640x480(NTSC) or 704x576(PAL) */
#define SCALE_2CIFS	2	/* 640x240(NTSC) or 704x288(PAL) */
#define SCALE_1CIFS	3	/* 320x240(NTSC) or 352x288(PAL) */
109 110
/* SCALE_4CIFSI is the 2 fields interpolated into one */
#define SCALE_4CIFSI	4	/* 640x480(NTSC) or 704x576(PAL) high quality */
111 112 113 114

#define COLOR_YUVPL	1	/* YUV planar */
#define COLOR_YUVPK	2	/* YUV packed */
#define COLOR_Y8	4	/* monochrome */
115
#define COLOR_JPG       5       /* JPEG */
116

117 118 119
#define MASK_COLOR       0x000000ff
#define MASK_JPG_QUALITY 0x0000ff00
#define MASK_INPUT_TYPE  0x000f0000
120
/* frame decimation. */
121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137
#define FDEC_1		1	/* capture every frame. default */
#define FDEC_2		2	/* capture every 2nd frame */
#define FDEC_3		3	/* capture every 3rd frame */
#define FDEC_5		5	/* capture every 5th frame */

/*-------------------------------------------------------
 * Default mode parameters.
 *-------------------------------------------------------*/
#define DEF_SCALE	SCALE_4CIFS
#define DEF_COLOR	COLOR_YUVPL
#define DEF_FDEC	FDEC_1
#define DEF_BRIGHT	0
#define DEF_CONTRAST	0x5c
#define DEF_SATURATION	0x80
#define DEF_HUE		0

/* usb config commands */
138
#define IN_DATA_TOKEN	cpu_to_le32(0x2255c0de)
139
#define CMD_2255	0xc2255000
140 141 142 143
#define CMD_SET_MODE	cpu_to_le32((CMD_2255 | 0x10))
#define CMD_START	cpu_to_le32((CMD_2255 | 0x20))
#define CMD_STOP	cpu_to_le32((CMD_2255 | 0x30))
#define CMD_STATUS	cpu_to_le32((CMD_2255 | 0x40))
144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159

struct s2255_mode {
	u32 format;	/* input video format (NTSC, PAL) */
	u32 scale;	/* output video scale */
	u32 color;	/* output video color format */
	u32 fdec;	/* frame decimation */
	u32 bright;	/* brightness */
	u32 contrast;	/* contrast */
	u32 saturation;	/* saturation */
	u32 hue;	/* hue (NTSC only)*/
	u32 single;	/* capture 1 frame at a time (!=0), continuously (==0)*/
	u32 usb_block;	/* block size. should be 4096 of DEF_USB_BLOCK */
	u32 restart;	/* if DSP requires restart */
};


160 161
#define S2255_READ_IDLE		0
#define S2255_READ_FRAME	1
162

163
/* frame structure */
164 165
struct s2255_framei {
	unsigned long size;
166
	unsigned long ulState;	/* ulState:S2255_READ_IDLE, S2255_READ_FRAME*/
167 168 169 170 171 172 173 174 175 176 177 178
	void *lpvbits;		/* image data */
	unsigned long cur_size;	/* current data copied to it */
};

/* image buffer structure */
struct s2255_bufferi {
	unsigned long dwFrames;			/* number of frames in buffer */
	struct s2255_framei frame[SYS_FRAMES];	/* array of FRAME structures */
};

#define DEF_MODEI_NTSC_CONT	{FORMAT_NTSC, DEF_SCALE, DEF_COLOR,	\
			DEF_FDEC, DEF_BRIGHT, DEF_CONTRAST, DEF_SATURATION, \
179
			DEF_HUE, 0, DEF_USB_BLOCK, 0}
180 181 182 183 184 185

/* for firmware loading, fw_state */
#define S2255_FW_NOTLOADED	0
#define S2255_FW_LOADED_DSPWAIT	1
#define S2255_FW_SUCCESS	2
#define S2255_FW_FAILED		3
186
#define S2255_FW_DISCONNECTING  4
187
#define S2255_FW_MARKER		cpu_to_le32(0x22552f2f)
188 189 190
/* 2255 read states */
#define S2255_READ_IDLE         0
#define S2255_READ_FRAME        1
191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212
struct s2255_fw {
	int		      fw_loaded;
	int		      fw_size;
	struct urb	      *fw_urb;
	atomic_t	      fw_state;
	void		      *pfw_data;
	wait_queue_head_t     wait_fw;
	const struct firmware *fw;
};

struct s2255_pipeinfo {
	u32 max_transfer_size;
	u32 cur_transfer_size;
	u8 *transfer_buffer;
	u32 state;
	void *stream_urb;
	void *dev;	/* back pointer to s2255_dev struct*/
	u32 err_count;
	u32 idx;
};

struct s2255_fmt; /*forward declaration */
213 214
struct s2255_dev;

215 216
/* 2255 video channel */
struct s2255_vc {
217
	struct s2255_dev        *dev;
218
	struct video_device	vdev;
219
	struct v4l2_ctrl_handler hdl;
220
	struct v4l2_ctrl	*jpegqual_ctrl;
221
	int			resources;
222
	struct list_head        buf_list;
223 224
	struct s2255_bufferi	buffer;
	struct s2255_mode	mode;
225
	v4l2_std_id		std;
226
	/* jpeg compression */
227
	unsigned		jpegqual;
228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255
	/* capture parameters (for high quality mode full size) */
	struct v4l2_captureparm cap_parm;
	int			cur_frame;
	int			last_frame;

	int			b_acquire;
	/* allocated image size */
	unsigned long		req_image_size;
	/* received packet size */
	unsigned long		pkt_size;
	int			bad_payload;
	unsigned long		frame_count;
	/* if JPEG image */
	int                     jpg_size;
	/* if channel configured to default state */
	int                     configured;
	wait_queue_head_t       wait_setmode;
	int                     setmode_ready;
	/* video status items */
	int                     vidstatus;
	wait_queue_head_t       wait_vidstatus;
	int                     vidstatus_ready;
	unsigned int		width;
	unsigned int		height;
	const struct s2255_fmt	*fmt;
	int idx; /* channel number on device, 0-3 */
};

256 257

struct s2255_dev {
258
	struct s2255_vc         vc[MAX_CHANNELS];
259
	struct v4l2_device      v4l2_dev;
260
	atomic_t                num_channels;
261
	int			frames;
P
Pete Eberlein 已提交
262
	struct mutex		lock;	/* channels[].vdev.lock */
263
	struct mutex		cmdlock; /* protects cmdbuf */
264 265 266 267 268
	struct usb_device	*udev;
	struct usb_interface	*interface;
	u8			read_endpoint;
	struct timer_list	timer;
	struct s2255_fw	*fw_data;
D
Dean Anderson 已提交
269
	struct s2255_pipeinfo	pipe;
270 271
	u32			cc;	/* current channel */
	int			frame_ready;
272
	int                     chn_ready;
273
	spinlock_t              slock;
274 275
	/* dsp firmware version (f2255usb.bin) */
	int                     dsp_fw_ver;
276
	u16                     pid; /* product id */
277 278
#define S2255_CMDBUF_SIZE 512
	__le32                  *cmdbuf;
279
};
280 281 282 283 284

static inline struct s2255_dev *to_s2255_dev(struct v4l2_device *v4l2_dev)
{
	return container_of(v4l2_dev, struct s2255_dev, v4l2_dev);
}
285 286 287 288 289 290 291 292 293 294 295 296 297 298

struct s2255_fmt {
	char *name;
	u32 fourcc;
	int depth;
};

/* buffer for one video frame */
struct s2255_buffer {
	/* common v4l buffer stuff -- must be first */
	struct videobuf_buffer vb;
};

struct s2255_fh {
299 300
	/* this must be the first field in this struct */
	struct v4l2_fh		fh;
301 302 303
	struct s2255_dev	*dev;
	struct videobuf_queue	vb_vidq;
	enum v4l2_buf_type	type;
304
	struct s2255_vc	*vc;
305
	int			resources;
306 307
};

308
/* current cypress EEPROM firmware version */
309
#define S2255_CUR_USB_FWVER	((3 << 8) | 12)
310
/* current DSP FW version */
311
#define S2255_CUR_DSP_FWVER     10104
312
/* Need DSP version 5+ for video status feature */
313 314
#define S2255_MIN_DSP_STATUS      5
#define S2255_MIN_DSP_COLORFILTER 8
315
#define S2255_NORMS		(V4L2_STD_ALL)
316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344

/* private V4L2 controls */

/*
 * The following chart displays how COLORFILTER should be set
 *  =========================================================
 *  =     fourcc              =     COLORFILTER             =
 *  =                         ===============================
 *  =                         =   0             =    1      =
 *  =========================================================
 *  =  V4L2_PIX_FMT_GREY(Y8)  = monochrome from = monochrome=
 *  =                         = s-video or      = composite =
 *  =                         = B/W camera      = input     =
 *  =========================================================
 *  =    other                = color, svideo   = color,    =
 *  =                         =                 = composite =
 *  =========================================================
 *
 * Notes:
 *   channels 0-3 on 2255 are composite
 *   channels 0-1 on 2257 are composite, 2-3 are s-video
 * If COLORFILTER is 0 with a composite color camera connected,
 * the output will appear monochrome but hatching
 * will occur.
 * COLORFILTER is different from "color killer" and "color effects"
 * for reasons above.
 */
#define S2255_V4L2_YC_ON  1
#define S2255_V4L2_YC_OFF 0
345
#define V4L2_CID_S2255_COLORFILTER (V4L2_CID_USER_S2255_BASE + 0)
346

347 348 349 350
/* frame prefix size (sent once every frame) */
#define PREFIX_SIZE		512

/* Channels on box are in reverse order */
351
static unsigned long G_chnmap[MAX_CHANNELS] = {3, 2, 1, 0};
352 353 354 355 356

static int debug;

static int s2255_start_readpipe(struct s2255_dev *dev);
static void s2255_stop_readpipe(struct s2255_dev *dev);
357 358 359
static int s2255_start_acquire(struct s2255_vc *vc);
static int s2255_stop_acquire(struct s2255_vc *vc);
static void s2255_fillbuff(struct s2255_vc *vc, struct s2255_buffer *buf,
360
			   int jpgsize);
361
static int s2255_set_mode(struct s2255_vc *vc, struct s2255_mode *mode);
362
static int s2255_board_shutdown(struct s2255_dev *dev);
363
static void s2255_fwload_start(struct s2255_dev *dev, int reset);
364
static void s2255_destroy(struct s2255_dev *dev);
365 366 367
static long s2255_vendor_req(struct s2255_dev *dev, unsigned char req,
			     u16 index, u16 value, void *buf,
			     s32 buf_len, int bOut);
368

369 370 371 372 373
/* dev_err macro with driver name */
#define S2255_DRIVER_NAME "s2255"
#define s2255_dev_err(dev, fmt, arg...)					\
		dev_err(dev, S2255_DRIVER_NAME " - " fmt, ##arg)

374 375
#define dprintk(dev, level, fmt, arg...) \
	v4l2_dbg(level, debug, &dev->v4l2_dev, fmt, ## arg)
376 377 378 379 380 381

static struct usb_driver s2255_driver;

/* start video number */
static int video_nr = -1;	/* /dev/videoN, -1 for autodetect */

382 383 384
/* Enable jpeg capture. */
static int jpeg_enable = 1;

385
module_param(debug, int, 0644);
386
MODULE_PARM_DESC(debug, "Debug level(0-100) default 0");
387
module_param(video_nr, int, 0644);
388
MODULE_PARM_DESC(video_nr, "start video minor(-1 default autodetect)");
389 390
module_param(jpeg_enable, int, 0644);
MODULE_PARM_DESC(jpeg_enable, "Jpeg enable(1-on 0-off) default 1");
391 392

/* USB device table */
393
#define USB_SENSORAY_VID	0x1943
394
static struct usb_device_id s2255_table[] = {
395 396
	{USB_DEVICE(USB_SENSORAY_VID, 0x2255)},
	{USB_DEVICE(USB_SENSORAY_VID, 0x2257)}, /*same family as 2255*/
397 398 399 400 401 402 403
	{ }			/* Terminating entry */
};
MODULE_DEVICE_TABLE(usb, s2255_table);

#define BUFFER_TIMEOUT msecs_to_jiffies(400)

/* image formats.  */
404
/* JPEG formats must be defined last to support jpeg_enable parameter */
405 406 407 408 409 410 411 412 413 414
static const struct s2255_fmt formats[] = {
	{
		.name = "4:2:2, packed, YUYV",
		.fourcc = V4L2_PIX_FMT_YUYV,
		.depth = 16

	}, {
		.name = "4:2:2, packed, UYVY",
		.fourcc = V4L2_PIX_FMT_UYVY,
		.depth = 16
415 416 417 418 419
	}, {
		.name = "4:2:2, planar, YUV422P",
		.fourcc = V4L2_PIX_FMT_YUV422P,
		.depth = 16

420 421 422 423
	}, {
		.name = "8bpp GREY",
		.fourcc = V4L2_PIX_FMT_GREY,
		.depth = 8
424 425 426 427
	}, {
		.name = "JPG",
		.fourcc = V4L2_PIX_FMT_JPEG,
		.depth = 24
428 429 430 431
	}, {
		.name = "MJPG",
		.fourcc = V4L2_PIX_FMT_MJPEG,
		.depth = 24
432 433 434
	}
};

435
static int norm_maxw(struct s2255_vc *vc)
436
{
437
	return (vc->std & V4L2_STD_525_60) ?
438 439 440
	    LINE_SZ_4CIFS_NTSC : LINE_SZ_4CIFS_PAL;
}

441
static int norm_maxh(struct s2255_vc *vc)
442
{
443
	return (vc->std & V4L2_STD_525_60) ?
444 445 446
	    (NUM_LINES_1CIFS_NTSC * 2) : (NUM_LINES_1CIFS_PAL * 2);
}

447
static int norm_minw(struct s2255_vc *vc)
448
{
449
	return (vc->std & V4L2_STD_525_60) ?
450 451 452
	    LINE_SZ_1CIFS_NTSC : LINE_SZ_1CIFS_PAL;
}

453
static int norm_minh(struct s2255_vc *vc)
454
{
455
	return (vc->std & V4L2_STD_525_60) ?
456 457 458 459
	    (NUM_LINES_1CIFS_NTSC) : (NUM_LINES_1CIFS_PAL);
}


460 461 462 463
/*
 * TODO: fixme: move YUV reordering to hardware
 * converts 2255 planar format to yuyv or uyvy
 */
464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485
static void planar422p_to_yuv_packed(const unsigned char *in,
				     unsigned char *out,
				     int width, int height,
				     int fmt)
{
	unsigned char *pY;
	unsigned char *pCb;
	unsigned char *pCr;
	unsigned long size = height * width;
	unsigned int i;
	pY = (unsigned char *)in;
	pCr = (unsigned char *)in + height * width;
	pCb = (unsigned char *)in + height * width + (height * width / 2);
	for (i = 0; i < size * 2; i += 4) {
		out[i] = (fmt == V4L2_PIX_FMT_YUYV) ? *pY++ : *pCr++;
		out[i + 1] = (fmt == V4L2_PIX_FMT_YUYV) ? *pCr++ : *pY++;
		out[i + 2] = (fmt == V4L2_PIX_FMT_YUYV) ? *pY++ : *pCb++;
		out[i + 3] = (fmt == V4L2_PIX_FMT_YUYV) ? *pCb++ : *pY++;
	}
	return;
}

486
static void s2255_reset_dsppower(struct s2255_dev *dev)
487
{
488
	s2255_vendor_req(dev, 0x40, 0x0000, 0x0001, NULL, 0, 1);
489
	msleep(20);
490
	s2255_vendor_req(dev, 0x50, 0x0000, 0x0000, NULL, 0, 1);
491 492
	msleep(600);
	s2255_vendor_req(dev, 0x10, 0x0000, 0x0000, NULL, 0, 1);
493 494
	return;
}
495 496 497 498 499 500 501

/* kickstarts the firmware loading. from probe
 */
static void s2255_timer(unsigned long user_data)
{
	struct s2255_fw *data = (struct s2255_fw *)user_data;
	if (usb_submit_urb(data->fw_urb, GFP_ATOMIC) < 0) {
502
		pr_err("s2255: can't submit urb\n");
503 504 505
		atomic_set(&data->fw_state, S2255_FW_FAILED);
		/* wake up anything waiting for the firmware */
		wake_up(&data->wait_fw);
506 507 508 509 510 511
		return;
	}
}


/* this loads the firmware asynchronously.
512
   Originally this was done synchronously in probe.
513 514 515 516 517 518 519 520 521 522
   But it is better to load it asynchronously here than block
   inside the probe function. Blocking inside probe affects boot time.
   FW loading is triggered by the timer in the probe function
*/
static void s2255_fwchunk_complete(struct urb *urb)
{
	struct s2255_fw *data = urb->context;
	struct usb_device *udev = urb->dev;
	int len;
	if (urb->status) {
523
		dev_err(&udev->dev, "URB failed with status %d\n", urb->status);
524 525 526
		atomic_set(&data->fw_state, S2255_FW_FAILED);
		/* wake up anything waiting for the firmware */
		wake_up(&data->wait_fw);
527 528 529
		return;
	}
	if (data->fw_urb == NULL) {
530
		s2255_dev_err(&udev->dev, "disconnected\n");
531 532 533
		atomic_set(&data->fw_state, S2255_FW_FAILED);
		/* wake up anything waiting for the firmware */
		wake_up(&data->wait_fw);
534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561
		return;
	}
#define CHUNK_SIZE 512
	/* all USB transfers must be done with continuous kernel memory.
	   can't allocate more than 128k in current linux kernel, so
	   upload the firmware in chunks
	 */
	if (data->fw_loaded < data->fw_size) {
		len = (data->fw_loaded + CHUNK_SIZE) > data->fw_size ?
		    data->fw_size % CHUNK_SIZE : CHUNK_SIZE;

		if (len < CHUNK_SIZE)
			memset(data->pfw_data, 0, CHUNK_SIZE);

		memcpy(data->pfw_data,
		       (char *) data->fw->data + data->fw_loaded, len);

		usb_fill_bulk_urb(data->fw_urb, udev, usb_sndbulkpipe(udev, 2),
				  data->pfw_data, CHUNK_SIZE,
				  s2255_fwchunk_complete, data);
		if (usb_submit_urb(data->fw_urb, GFP_ATOMIC) < 0) {
			dev_err(&udev->dev, "failed submit URB\n");
			atomic_set(&data->fw_state, S2255_FW_FAILED);
			/* wake up anything waiting for the firmware */
			wake_up(&data->wait_fw);
			return;
		}
		data->fw_loaded += len;
562
	} else
563 564 565 566 567
		atomic_set(&data->fw_state, S2255_FW_LOADED_DSPWAIT);
	return;

}

568
static int s2255_got_frame(struct s2255_vc *vc, int jpgsize)
569 570
{
	struct s2255_buffer *buf;
571
	struct s2255_dev *dev = to_s2255_dev(vc->vdev.v4l2_dev);
572 573 574
	unsigned long flags = 0;
	int rc = 0;
	spin_lock_irqsave(&dev->slock, flags);
575
	if (list_empty(&vc->buf_list)) {
576
		dprintk(dev, 1, "No active queue to serve\n");
577 578 579
		rc = -1;
		goto unlock;
	}
580
	buf = list_entry(vc->buf_list.next,
581 582
			 struct s2255_buffer, vb.queue);
	list_del(&buf->vb.queue);
583
	v4l2_get_timestamp(&buf->vb.ts);
584
	s2255_fillbuff(vc, buf, jpgsize);
585
	wake_up(&buf->vb.done);
586
	dprintk(dev, 2, "%s: [buf/i] [%p/%d]\n", __func__, buf, buf->vb.i);
587 588
unlock:
	spin_unlock_irqrestore(&dev->slock, flags);
589
	return rc;
590 591 592 593 594 595 596 597
}

static const struct s2255_fmt *format_by_fourcc(int fourcc)
{
	unsigned int i;
	for (i = 0; i < ARRAY_SIZE(formats); i++) {
		if (-1 == formats[i].fourcc)
			continue;
598 599 600
		if (!jpeg_enable && ((formats[i].fourcc == V4L2_PIX_FMT_JPEG) ||
				     (formats[i].fourcc == V4L2_PIX_FMT_MJPEG)))
			continue;
601 602 603 604 605 606 607 608 609 610 611 612 613 614
		if (formats[i].fourcc == fourcc)
			return formats + i;
	}
	return NULL;
}

/* video buffer vmalloc implementation based partly on VIVI driver which is
 *          Copyright (c) 2006 by
 *                  Mauro Carvalho Chehab <mchehab--a.t--infradead.org>
 *                  Ted Walther <ted--a.t--enumera.com>
 *                  John Sokol <sokol--a.t--videotechnology.com>
 *                  http://v4l.videotechnology.com/
 *
 */
615
static void s2255_fillbuff(struct s2255_vc *vc,
616
			   struct s2255_buffer *buf, int jpgsize)
617 618 619 620 621
{
	int pos = 0;
	const char *tmpbuf;
	char *vbuf = videobuf_to_vmalloc(&buf->vb);
	unsigned long last_frame;
622
	struct s2255_dev *dev = vc->dev;
623 624 625

	if (!vbuf)
		return;
626
	last_frame = vc->last_frame;
627 628
	if (last_frame != -1) {
		tmpbuf =
629
		    (const char *)vc->buffer.frame[last_frame].lpvbits;
630
		switch (vc->fmt->fourcc) {
631 632 633 634 635
		case V4L2_PIX_FMT_YUYV:
		case V4L2_PIX_FMT_UYVY:
			planar422p_to_yuv_packed((const unsigned char *)tmpbuf,
						 vbuf, buf->vb.width,
						 buf->vb.height,
636
						 vc->fmt->fourcc);
637 638 639 640
			break;
		case V4L2_PIX_FMT_GREY:
			memcpy(vbuf, tmpbuf, buf->vb.width * buf->vb.height);
			break;
641
		case V4L2_PIX_FMT_JPEG:
642
		case V4L2_PIX_FMT_MJPEG:
643 644 645
			buf->vb.size = jpgsize;
			memcpy(vbuf, tmpbuf, buf->vb.size);
			break;
646 647 648 649 650
		case V4L2_PIX_FMT_YUV422P:
			memcpy(vbuf, tmpbuf,
			       buf->vb.width * buf->vb.height * 2);
			break;
		default:
651
			pr_info("s2255: unknown format?\n");
652
		}
653
		vc->last_frame = -1;
654
	} else {
655
		pr_err("s2255: =======no frame\n");
656 657
		return;
	}
658
	dprintk(dev, 2, "s2255fill at : Buffer 0x%08lx size= %d\n",
659 660
		(unsigned long)vbuf, pos);
	/* tell v4l buffer was filled */
661
	buf->vb.field_count = vc->frame_count * 2;
662
	v4l2_get_timestamp(&buf->vb.ts);
663 664 665 666 667 668 669 670
	buf->vb.state = VIDEOBUF_DONE;
}


/* ------------------------------------------------------------------
   Videobuf operations
   ------------------------------------------------------------------*/

671
static int buffer_setup(struct videobuf_queue *vq, unsigned int *nbuffers,
672 673 674
			unsigned int *size)
{
	struct s2255_fh *fh = vq->priv_data;
675 676
	struct s2255_vc *vc = fh->vc;
	*size = vc->width * vc->height * (vc->fmt->depth >> 3);
677

678 679
	if (*nbuffers < S2255_MIN_BUFS)
		*nbuffers = S2255_MIN_BUFS;
680 681 682 683 684 685 686 687 688 689 690 691 692 693

	return 0;
}

static void free_buffer(struct videobuf_queue *vq, struct s2255_buffer *buf)
{
	videobuf_vmalloc_free(&buf->vb);
	buf->vb.state = VIDEOBUF_NEEDS_INIT;
}

static int buffer_prepare(struct videobuf_queue *vq, struct videobuf_buffer *vb,
			  enum v4l2_field field)
{
	struct s2255_fh *fh = vq->priv_data;
694
	struct s2255_vc *vc = fh->vc;
695 696
	struct s2255_buffer *buf = container_of(vb, struct s2255_buffer, vb);
	int rc;
697 698
	int w = vc->width;
	int h = vc->height;
699
	dprintk(fh->dev, 4, "%s, field=%d\n", __func__, field);
700
	if (vc->fmt == NULL)
701 702
		return -EINVAL;

703 704 705 706
	if ((w < norm_minw(vc)) ||
	    (w > norm_maxw(vc)) ||
	    (h < norm_minh(vc)) ||
	    (h > norm_maxh(vc))) {
707
		dprintk(fh->dev, 4, "invalid buffer prepare\n");
708 709
		return -EINVAL;
	}
710
	buf->vb.size = w * h * (vc->fmt->depth >> 3);
711
	if (0 != buf->vb.baddr && buf->vb.bsize < buf->vb.size) {
712
		dprintk(fh->dev, 4, "invalid buffer prepare\n");
713 714 715
		return -EINVAL;
	}

716 717
	buf->vb.width = w;
	buf->vb.height = h;
718 719 720 721 722 723 724 725 726 727 728 729 730 731 732 733 734 735 736
	buf->vb.field = field;

	if (VIDEOBUF_NEEDS_INIT == buf->vb.state) {
		rc = videobuf_iolock(vq, &buf->vb, NULL);
		if (rc < 0)
			goto fail;
	}

	buf->vb.state = VIDEOBUF_PREPARED;
	return 0;
fail:
	free_buffer(vq, buf);
	return rc;
}

static void buffer_queue(struct videobuf_queue *vq, struct videobuf_buffer *vb)
{
	struct s2255_buffer *buf = container_of(vb, struct s2255_buffer, vb);
	struct s2255_fh *fh = vq->priv_data;
737
	struct s2255_vc *vc = fh->vc;
738
	dprintk(fh->dev, 1, "%s\n", __func__);
739
	buf->vb.state = VIDEOBUF_QUEUED;
740
	list_add_tail(&buf->vb.queue, &vc->buf_list);
741 742 743 744 745 746 747
}

static void buffer_release(struct videobuf_queue *vq,
			   struct videobuf_buffer *vb)
{
	struct s2255_buffer *buf = container_of(vb, struct s2255_buffer, vb);
	struct s2255_fh *fh = vq->priv_data;
748
	dprintk(fh->dev, 4, "%s %d\n", __func__, fh->vc->idx);
749 750 751 752 753 754 755 756 757 758 759
	free_buffer(vq, buf);
}

static struct videobuf_queue_ops s2255_video_qops = {
	.buf_setup = buffer_setup,
	.buf_prepare = buffer_prepare,
	.buf_queue = buffer_queue,
	.buf_release = buffer_release,
};


760
static int res_get(struct s2255_fh *fh)
761
{
762
	struct s2255_vc *vc = fh->vc;
P
Pete Eberlein 已提交
763
	/* is it free? */
764
	if (vc->resources)
P
Pete Eberlein 已提交
765
		return 0; /* no, someone else uses it */
766
	/* it's free, grab it */
767
	vc->resources = 1;
768
	fh->resources = 1;
769
	dprintk(fh->dev, 1, "s2255: res: get\n");
770 771 772
	return 1;
}

773
static int res_locked(struct s2255_fh *fh)
774
{
775
	return fh->vc->resources;
776 777
}

778 779
static int res_check(struct s2255_fh *fh)
{
780
	return fh->resources;
781 782 783
}


784
static void res_free(struct s2255_fh *fh)
785
{
786 787
	struct s2255_vc *vc = fh->vc;
	vc->resources = 0;
788
	fh->resources = 0;
789 790 791 792 793 794 795
}

static int vidioc_querycap(struct file *file, void *priv,
			   struct v4l2_capability *cap)
{
	struct s2255_fh *fh = file->private_data;
	struct s2255_dev *dev = fh->dev;
796

797 798
	strlcpy(cap->driver, "s2255", sizeof(cap->driver));
	strlcpy(cap->card, "s2255", sizeof(cap->card));
799
	usb_make_path(dev->udev, cap->bus_info, sizeof(cap->bus_info));
800 801
	cap->device_caps = V4L2_CAP_VIDEO_CAPTURE | V4L2_CAP_STREAMING;
	cap->capabilities = cap->device_caps | V4L2_CAP_DEVICE_CAPS;
802 803 804 805 806 807
	return 0;
}

static int vidioc_enum_fmt_vid_cap(struct file *file, void *priv,
			       struct v4l2_fmtdesc *f)
{
808
	int index = f->index;
809 810 811

	if (index >= ARRAY_SIZE(formats))
		return -EINVAL;
812 813 814
	if (!jpeg_enable && ((formats[index].fourcc == V4L2_PIX_FMT_JPEG) ||
			(formats[index].fourcc == V4L2_PIX_FMT_MJPEG)))
		return -EINVAL;
815 816 817 818 819 820 821 822 823
	strlcpy(f->description, formats[index].name, sizeof(f->description));
	f->pixelformat = formats[index].fourcc;
	return 0;
}

static int vidioc_g_fmt_vid_cap(struct file *file, void *priv,
			    struct v4l2_format *f)
{
	struct s2255_fh *fh = priv;
824 825
	struct s2255_vc *vc = fh->vc;
	int is_ntsc = vc->std & V4L2_STD_525_60;
826

827 828
	f->fmt.pix.width = vc->width;
	f->fmt.pix.height = vc->height;
H
Hans Verkuil 已提交
829 830 831 832 833
	if (f->fmt.pix.height >=
	    (is_ntsc ? NUM_LINES_1CIFS_NTSC : NUM_LINES_1CIFS_PAL) * 2)
		f->fmt.pix.field = V4L2_FIELD_INTERLACED;
	else
		f->fmt.pix.field = V4L2_FIELD_TOP;
834 835
	f->fmt.pix.pixelformat = vc->fmt->fourcc;
	f->fmt.pix.bytesperline = f->fmt.pix.width * (vc->fmt->depth >> 3);
836
	f->fmt.pix.sizeimage = f->fmt.pix.height * f->fmt.pix.bytesperline;
837 838
	f->fmt.pix.colorspace = V4L2_COLORSPACE_SMPTE170M;
	f->fmt.pix.priv = 0;
839
	return 0;
840 841 842 843 844 845 846 847
}

static int vidioc_try_fmt_vid_cap(struct file *file, void *priv,
			      struct v4l2_format *f)
{
	const struct s2255_fmt *fmt;
	enum v4l2_field field;
	struct s2255_fh *fh = priv;
848 849
	struct s2255_vc *vc = fh->vc;
	int is_ntsc = vc->std & V4L2_STD_525_60;
850 851 852 853 854 855 856 857

	fmt = format_by_fourcc(f->fmt.pix.pixelformat);

	if (fmt == NULL)
		return -EINVAL;

	field = f->fmt.pix.field;

858
	dprintk(fh->dev, 50, "%s NTSC: %d suggested width: %d, height: %d\n",
859
		__func__, is_ntsc, f->fmt.pix.width, f->fmt.pix.height);
860 861 862 863
	if (is_ntsc) {
		/* NTSC */
		if (f->fmt.pix.height >= NUM_LINES_1CIFS_NTSC * 2) {
			f->fmt.pix.height = NUM_LINES_1CIFS_NTSC * 2;
H
Hans Verkuil 已提交
864
			field = V4L2_FIELD_INTERLACED;
865 866
		} else {
			f->fmt.pix.height = NUM_LINES_1CIFS_NTSC;
H
Hans Verkuil 已提交
867
			field = V4L2_FIELD_TOP;
868 869 870 871 872 873 874 875 876 877 878 879 880
		}
		if (f->fmt.pix.width >= LINE_SZ_4CIFS_NTSC)
			f->fmt.pix.width = LINE_SZ_4CIFS_NTSC;
		else if (f->fmt.pix.width >= LINE_SZ_2CIFS_NTSC)
			f->fmt.pix.width = LINE_SZ_2CIFS_NTSC;
		else if (f->fmt.pix.width >= LINE_SZ_1CIFS_NTSC)
			f->fmt.pix.width = LINE_SZ_1CIFS_NTSC;
		else
			f->fmt.pix.width = LINE_SZ_1CIFS_NTSC;
	} else {
		/* PAL */
		if (f->fmt.pix.height >= NUM_LINES_1CIFS_PAL * 2) {
			f->fmt.pix.height = NUM_LINES_1CIFS_PAL * 2;
H
Hans Verkuil 已提交
881
			field = V4L2_FIELD_INTERLACED;
882 883
		} else {
			f->fmt.pix.height = NUM_LINES_1CIFS_PAL;
H
Hans Verkuil 已提交
884
			field = V4L2_FIELD_TOP;
885
		}
H
Hans Verkuil 已提交
886
		if (f->fmt.pix.width >= LINE_SZ_4CIFS_PAL)
887
			f->fmt.pix.width = LINE_SZ_4CIFS_PAL;
H
Hans Verkuil 已提交
888
		else if (f->fmt.pix.width >= LINE_SZ_2CIFS_PAL)
889
			f->fmt.pix.width = LINE_SZ_2CIFS_PAL;
H
Hans Verkuil 已提交
890
		else if (f->fmt.pix.width >= LINE_SZ_1CIFS_PAL)
891
			f->fmt.pix.width = LINE_SZ_1CIFS_PAL;
H
Hans Verkuil 已提交
892
		else
893 894 895 896 897
			f->fmt.pix.width = LINE_SZ_1CIFS_PAL;
	}
	f->fmt.pix.field = field;
	f->fmt.pix.bytesperline = (f->fmt.pix.width * fmt->depth) >> 3;
	f->fmt.pix.sizeimage = f->fmt.pix.height * f->fmt.pix.bytesperline;
898 899
	f->fmt.pix.colorspace = V4L2_COLORSPACE_SMPTE170M;
	f->fmt.pix.priv = 0;
900
	dprintk(fh->dev, 50, "%s: set width %d height %d field %d\n", __func__,
901
		f->fmt.pix.width, f->fmt.pix.height, f->fmt.pix.field);
902 903 904 905 906 907 908
	return 0;
}

static int vidioc_s_fmt_vid_cap(struct file *file, void *priv,
			    struct v4l2_format *f)
{
	struct s2255_fh *fh = priv;
909
	struct s2255_vc *vc = fh->vc;
910 911
	const struct s2255_fmt *fmt;
	struct videobuf_queue *q = &fh->vb_vidq;
912
	struct s2255_mode mode;
913 914 915 916 917
	int ret;

	ret = vidioc_try_fmt_vid_cap(file, fh, f);

	if (ret < 0)
918
		return ret;
919 920 921 922 923 924 925 926 927

	fmt = format_by_fourcc(f->fmt.pix.pixelformat);

	if (fmt == NULL)
		return -EINVAL;

	mutex_lock(&q->vb_lock);

	if (videobuf_queue_is_busy(&fh->vb_vidq)) {
928
		dprintk(fh->dev, 1, "queue busy\n");
929 930 931 932
		ret = -EBUSY;
		goto out_s_fmt;
	}

933
	if (res_locked(fh)) {
934
		dprintk(fh->dev, 1, "%s: channel busy\n", __func__);
935 936 937
		ret = -EBUSY;
		goto out_s_fmt;
	}
938 939 940 941
	mode = vc->mode;
	vc->fmt = fmt;
	vc->width = f->fmt.pix.width;
	vc->height = f->fmt.pix.height;
942 943
	fh->vb_vidq.field = f->fmt.pix.field;
	fh->type = f->type;
944 945 946
	if (vc->width > norm_minw(vc)) {
		if (vc->height > norm_minh(vc)) {
			if (vc->cap_parm.capturemode &
947
			    V4L2_MODE_HIGHQUALITY)
948
				mode.scale = SCALE_4CIFSI;
949
			else
950
				mode.scale = SCALE_4CIFS;
951
		} else
952
			mode.scale = SCALE_2CIFS;
953 954

	} else {
955
		mode.scale = SCALE_1CIFS;
956 957
	}
	/* color mode */
958
	switch (vc->fmt->fourcc) {
959
	case V4L2_PIX_FMT_GREY:
960 961
		mode.color &= ~MASK_COLOR;
		mode.color |= COLOR_Y8;
962
		break;
963
	case V4L2_PIX_FMT_JPEG:
964
	case V4L2_PIX_FMT_MJPEG:
965 966
		mode.color &= ~MASK_COLOR;
		mode.color |= COLOR_JPG;
967
		mode.color |= (vc->jpegqual << 8);
968
		break;
969
	case V4L2_PIX_FMT_YUV422P:
970 971
		mode.color &= ~MASK_COLOR;
		mode.color |= COLOR_YUVPL;
972 973 974 975
		break;
	case V4L2_PIX_FMT_YUYV:
	case V4L2_PIX_FMT_UYVY:
	default:
976 977
		mode.color &= ~MASK_COLOR;
		mode.color |= COLOR_YUVPK;
978 979
		break;
	}
980
	if ((mode.color & MASK_COLOR) != (vc->mode.color & MASK_COLOR))
981
		mode.restart = 1;
982
	else if (mode.scale != vc->mode.scale)
983
		mode.restart = 1;
984
	else if (mode.format != vc->mode.format)
985
		mode.restart = 1;
986 987
	vc->mode = mode;
	(void) s2255_set_mode(vc, &mode);
988 989 990 991 992 993 994 995 996 997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017 1018 1019 1020 1021 1022 1023 1024 1025 1026 1027 1028 1029 1030 1031 1032 1033 1034 1035 1036 1037 1038 1039 1040 1041 1042 1043 1044 1045 1046 1047 1048 1049 1050 1051 1052 1053 1054
	ret = 0;
out_s_fmt:
	mutex_unlock(&q->vb_lock);
	return ret;
}

static int vidioc_reqbufs(struct file *file, void *priv,
			  struct v4l2_requestbuffers *p)
{
	int rc;
	struct s2255_fh *fh = priv;
	rc = videobuf_reqbufs(&fh->vb_vidq, p);
	return rc;
}

static int vidioc_querybuf(struct file *file, void *priv, struct v4l2_buffer *p)
{
	int rc;
	struct s2255_fh *fh = priv;
	rc = videobuf_querybuf(&fh->vb_vidq, p);
	return rc;
}

static int vidioc_qbuf(struct file *file, void *priv, struct v4l2_buffer *p)
{
	int rc;
	struct s2255_fh *fh = priv;
	rc = videobuf_qbuf(&fh->vb_vidq, p);
	return rc;
}

static int vidioc_dqbuf(struct file *file, void *priv, struct v4l2_buffer *p)
{
	int rc;
	struct s2255_fh *fh = priv;
	rc = videobuf_dqbuf(&fh->vb_vidq, p, file->f_flags & O_NONBLOCK);
	return rc;
}

/* write to the configuration pipe, synchronously */
static int s2255_write_config(struct usb_device *udev, unsigned char *pbuf,
			      int size)
{
	int pipe;
	int done;
	long retval = -1;
	if (udev) {
		pipe = usb_sndbulkpipe(udev, S2255_CONFIG_EP);
		retval = usb_bulk_msg(udev, pipe, pbuf, size, &done, 500);
	}
	return retval;
}

static u32 get_transfer_size(struct s2255_mode *mode)
{
	int linesPerFrame = LINE_SZ_DEF;
	int pixelsPerLine = NUM_LINES_DEF;
	u32 outImageSize;
	u32 usbInSize;
	unsigned int mask_mult;

	if (mode == NULL)
		return 0;

	if (mode->format == FORMAT_NTSC) {
		switch (mode->scale) {
		case SCALE_4CIFS:
1055
		case SCALE_4CIFSI:
1056 1057 1058 1059 1060 1061 1062 1063 1064 1065 1066 1067 1068 1069 1070 1071 1072
			linesPerFrame = NUM_LINES_4CIFS_NTSC * 2;
			pixelsPerLine = LINE_SZ_4CIFS_NTSC;
			break;
		case SCALE_2CIFS:
			linesPerFrame = NUM_LINES_2CIFS_NTSC;
			pixelsPerLine = LINE_SZ_2CIFS_NTSC;
			break;
		case SCALE_1CIFS:
			linesPerFrame = NUM_LINES_1CIFS_NTSC;
			pixelsPerLine = LINE_SZ_1CIFS_NTSC;
			break;
		default:
			break;
		}
	} else if (mode->format == FORMAT_PAL) {
		switch (mode->scale) {
		case SCALE_4CIFS:
1073
		case SCALE_4CIFSI:
1074 1075 1076 1077 1078 1079 1080 1081 1082 1083 1084 1085 1086 1087 1088 1089
			linesPerFrame = NUM_LINES_4CIFS_PAL * 2;
			pixelsPerLine = LINE_SZ_4CIFS_PAL;
			break;
		case SCALE_2CIFS:
			linesPerFrame = NUM_LINES_2CIFS_PAL;
			pixelsPerLine = LINE_SZ_2CIFS_PAL;
			break;
		case SCALE_1CIFS:
			linesPerFrame = NUM_LINES_1CIFS_PAL;
			pixelsPerLine = LINE_SZ_1CIFS_PAL;
			break;
		default:
			break;
		}
	}
	outImageSize = linesPerFrame * pixelsPerLine;
1090
	if ((mode->color & MASK_COLOR) != COLOR_Y8) {
1091 1092 1093 1094 1095 1096 1097 1098 1099 1100 1101 1102 1103 1104
		/* 2 bytes/pixel if not monochrome */
		outImageSize *= 2;
	}

	/* total bytes to send including prefix and 4K padding;
	   must be a multiple of USB_READ_SIZE */
	usbInSize = outImageSize + PREFIX_SIZE;	/* always send prefix */
	mask_mult = 0xffffffffUL - DEF_USB_BLOCK + 1;
	/* if size not a multiple of USB_READ_SIZE */
	if (usbInSize & ~mask_mult)
		usbInSize = (usbInSize & mask_mult) + (DEF_USB_BLOCK);
	return usbInSize;
}

1105
static void s2255_print_cfg(struct s2255_dev *sdev, struct s2255_mode *mode)
1106 1107 1108
{
	struct device *dev = &sdev->udev->dev;
	dev_info(dev, "------------------------------------------------\n");
1109 1110
	dev_info(dev, "format: %d\nscale %d\n", mode->format, mode->scale);
	dev_info(dev, "fdec: %d\ncolor %d\n", mode->fdec, mode->color);
1111 1112 1113 1114 1115 1116 1117 1118 1119 1120 1121 1122
	dev_info(dev, "bright: 0x%x\n", mode->bright);
	dev_info(dev, "------------------------------------------------\n");
}

/*
 * set mode is the function which controls the DSP.
 * the restart parameter in struct s2255_mode should be set whenever
 * the image size could change via color format, video system or image
 * size.
 * When the restart parameter is set, we sleep for ONE frame to allow the
 * DSP time to get the new frame
 */
1123
static int s2255_set_mode(struct s2255_vc *vc,
1124 1125 1126 1127
			  struct s2255_mode *mode)
{
	int res;
	unsigned long chn_rev;
1128
	struct s2255_dev *dev = to_s2255_dev(vc->vdev.v4l2_dev);
1129
	int i;
1130
	__le32 *buffer = dev->cmdbuf;
1131

1132
	mutex_lock(&dev->cmdlock);
1133 1134
	chn_rev = G_chnmap[vc->idx];
	dprintk(dev, 3, "%s channel: %d\n", __func__, vc->idx);
1135
	/* if JPEG, set the quality */
1136 1137 1138 1139
	if ((mode->color & MASK_COLOR) == COLOR_JPG) {
		mode->color &= ~MASK_COLOR;
		mode->color |= COLOR_JPG;
		mode->color &= ~MASK_JPG_QUALITY;
1140
		mode->color |= (vc->jpegqual << 8);
1141
	}
1142
	/* save the mode */
1143 1144 1145
	vc->mode = *mode;
	vc->req_image_size = get_transfer_size(mode);
	dprintk(dev, 1, "%s: reqsize %ld\n", __func__, vc->req_image_size);
1146 1147
	/* set the mode */
	buffer[0] = IN_DATA_TOKEN;
1148
	buffer[1] = (__le32) cpu_to_le32(chn_rev);
1149
	buffer[2] = CMD_SET_MODE;
1150
	for (i = 0; i < sizeof(struct s2255_mode) / sizeof(u32); i++)
1151 1152
		buffer[3 + i] = cpu_to_le32(((u32 *)&vc->mode)[i]);
	vc->setmode_ready = 0;
1153 1154
	res = s2255_write_config(dev->udev, (unsigned char *)buffer, 512);
	if (debug)
1155
		s2255_print_cfg(dev, mode);
1156
	/* wait at least 3 frames before continuing */
1157
	if (mode->restart) {
1158 1159
		wait_event_timeout(vc->wait_setmode,
				   (vc->setmode_ready != 0),
1160
				   msecs_to_jiffies(S2255_SETMODE_TIMEOUT));
1161
		if (vc->setmode_ready != 1) {
1162
			dprintk(dev, 0, "s2255: no set mode response\n");
1163 1164 1165
			res = -EFAULT;
		}
	}
1166
	/* clear the restart flag */
1167 1168
	vc->mode.restart = 0;
	dprintk(dev, 1, "%s chn %d, result: %d\n", __func__, vc->idx, res);
1169
	mutex_unlock(&dev->cmdlock);
1170 1171 1172
	return res;
}

1173
static int s2255_cmd_status(struct s2255_vc *vc, u32 *pstatus)
1174 1175 1176
{
	int res;
	u32 chn_rev;
1177
	struct s2255_dev *dev = to_s2255_dev(vc->vdev.v4l2_dev);
1178 1179 1180
	__le32 *buffer = dev->cmdbuf;

	mutex_lock(&dev->cmdlock);
1181 1182
	chn_rev = G_chnmap[vc->idx];
	dprintk(dev, 4, "%s chan %d\n", __func__, vc->idx);
1183 1184
	/* form the get vid status command */
	buffer[0] = IN_DATA_TOKEN;
1185
	buffer[1] = (__le32) cpu_to_le32(chn_rev);
1186 1187
	buffer[2] = CMD_STATUS;
	*pstatus = 0;
1188
	vc->vidstatus_ready = 0;
1189
	res = s2255_write_config(dev->udev, (unsigned char *)buffer, 512);
1190 1191
	wait_event_timeout(vc->wait_vidstatus,
			   (vc->vidstatus_ready != 0),
1192
			   msecs_to_jiffies(S2255_VIDSTATUS_TIMEOUT));
1193
	if (vc->vidstatus_ready != 1) {
1194
		dprintk(dev, 0, "s2255: no vidstatus response\n");
1195 1196
		res = -EFAULT;
	}
1197
	*pstatus = vc->vidstatus;
1198
	dprintk(dev, 4, "%s, vid status %d\n", __func__, *pstatus);
1199
	mutex_unlock(&dev->cmdlock);
1200 1201 1202
	return res;
}

1203 1204 1205 1206 1207
static int vidioc_streamon(struct file *file, void *priv, enum v4l2_buf_type i)
{
	int res;
	struct s2255_fh *fh = priv;
	struct s2255_dev *dev = fh->dev;
1208
	struct s2255_vc *vc = fh->vc;
1209
	int j;
1210
	dprintk(dev, 4, "%s\n", __func__);
1211 1212 1213 1214 1215 1216 1217 1218 1219
	if (fh->type != V4L2_BUF_TYPE_VIDEO_CAPTURE) {
		dev_err(&dev->udev->dev, "invalid fh type0\n");
		return -EINVAL;
	}
	if (i != fh->type) {
		dev_err(&dev->udev->dev, "invalid fh type1\n");
		return -EINVAL;
	}

1220
	if (!res_get(fh)) {
1221
		s2255_dev_err(&dev->udev->dev, "stream busy\n");
1222 1223
		return -EBUSY;
	}
1224 1225 1226 1227
	vc->last_frame = -1;
	vc->bad_payload = 0;
	vc->cur_frame = 0;
	vc->frame_count = 0;
1228
	for (j = 0; j < SYS_FRAMES; j++) {
1229 1230
		vc->buffer.frame[j].ulState = S2255_READ_IDLE;
		vc->buffer.frame[j].cur_size = 0;
1231 1232 1233
	}
	res = videobuf_streamon(&fh->vb_vidq);
	if (res == 0) {
1234 1235
		s2255_start_acquire(vc);
		vc->b_acquire = 1;
1236 1237 1238
	} else
		res_free(fh);

1239 1240 1241 1242 1243 1244
	return res;
}

static int vidioc_streamoff(struct file *file, void *priv, enum v4l2_buf_type i)
{
	struct s2255_fh *fh = priv;
1245
	dprintk(fh->dev, 4, "%s\n, channel: %d", __func__, fh->vc->idx);
1246
	if (fh->type != V4L2_BUF_TYPE_VIDEO_CAPTURE) {
1247
		dprintk(fh->dev, 1, "invalid fh type0\n");
1248 1249
		return -EINVAL;
	}
1250
	if (i != fh->type)
1251
		return -EINVAL;
1252
	s2255_stop_acquire(fh->vc);
1253
	videobuf_streamoff(&fh->vb_vidq);
1254
	res_free(fh);
1255
	return 0;
1256 1257
}

1258
static int vidioc_s_std(struct file *file, void *priv, v4l2_std_id i)
1259 1260
{
	struct s2255_fh *fh = priv;
1261
	struct s2255_mode mode;
1262
	struct videobuf_queue *q = &fh->vb_vidq;
1263
	struct s2255_vc *vc = fh->vc;
1264
	int ret = 0;
1265

1266
	mutex_lock(&q->vb_lock);
1267
	if (res_locked(fh)) {
1268
		dprintk(fh->dev, 1, "can't change standard after started\n");
1269 1270 1271
		ret = -EBUSY;
		goto out_s_std;
	}
1272
	mode = fh->vc->mode;
1273
	if (i & V4L2_STD_525_60) {
1274
		dprintk(fh->dev, 4, "%s 60 Hz\n", __func__);
1275
		/* if changing format, reset frame decimation/intervals */
1276 1277 1278 1279
		if (mode.format != FORMAT_NTSC) {
			mode.restart = 1;
			mode.format = FORMAT_NTSC;
			mode.fdec = FDEC_1;
1280 1281
			vc->width = LINE_SZ_4CIFS_NTSC;
			vc->height = NUM_LINES_4CIFS_NTSC * 2;
1282
		}
1283
	} else if (i & V4L2_STD_625_50) {
1284
		dprintk(fh->dev, 4, "%s 50 Hz\n", __func__);
1285 1286 1287 1288
		if (mode.format != FORMAT_PAL) {
			mode.restart = 1;
			mode.format = FORMAT_PAL;
			mode.fdec = FDEC_1;
1289 1290
			vc->width = LINE_SZ_4CIFS_PAL;
			vc->height = NUM_LINES_4CIFS_PAL * 2;
1291
		}
1292 1293
	} else {
		ret = -EINVAL;
1294
		goto out_s_std;
1295
	}
1296
	fh->vc->std = i;
1297
	if (mode.restart)
1298
		s2255_set_mode(fh->vc, &mode);
1299 1300 1301 1302 1303
out_s_std:
	mutex_unlock(&q->vb_lock);
	return ret;
}

1304 1305 1306 1307
static int vidioc_g_std(struct file *file, void *priv, v4l2_std_id *i)
{
	struct s2255_fh *fh = priv;

1308
	*i = fh->vc->std;
1309 1310 1311
	return 0;
}

1312 1313 1314 1315 1316 1317 1318 1319 1320 1321
/* Sensoray 2255 is a multiple channel capture device.
   It does not have a "crossbar" of inputs.
   We use one V4L device per channel. The user must
   be aware that certain combinations are not allowed.
   For instance, you cannot do full FPS on more than 2 channels(2 videodevs)
   at once in color(you can do full fps on 4 channels with greyscale.
*/
static int vidioc_enum_input(struct file *file, void *priv,
			     struct v4l2_input *inp)
{
1322 1323
	struct s2255_fh *fh = priv;
	struct s2255_dev *dev = fh->dev;
1324
	struct s2255_vc *vc = fh->vc;
1325
	u32 status = 0;
1326 1327 1328 1329
	if (inp->index != 0)
		return -EINVAL;
	inp->type = V4L2_INPUT_TYPE_CAMERA;
	inp->std = S2255_NORMS;
1330 1331 1332
	inp->status = 0;
	if (dev->dsp_fw_ver >= S2255_MIN_DSP_STATUS) {
		int rc;
1333
		rc = s2255_cmd_status(fh->vc, &status);
1334 1335
		dprintk(dev, 4, "s2255_cmd_status rc: %d status %x\n",
			rc, status);
1336 1337 1338 1339
		if (rc == 0)
			inp->status =  (status & 0x01) ? 0
				: V4L2_IN_ST_NO_SIGNAL;
	}
1340 1341 1342 1343 1344 1345
	switch (dev->pid) {
	case 0x2255:
	default:
		strlcpy(inp->name, "Composite", sizeof(inp->name));
		break;
	case 0x2257:
1346
		strlcpy(inp->name, (vc->idx < 2) ? "Composite" : "S-Video",
1347 1348 1349
			sizeof(inp->name));
		break;
	}
1350
	return 0;
1351 1352 1353 1354 1355 1356 1357 1358 1359 1360 1361 1362 1363 1364
}

static int vidioc_g_input(struct file *file, void *priv, unsigned int *i)
{
	*i = 0;
	return 0;
}
static int vidioc_s_input(struct file *file, void *priv, unsigned int i)
{
	if (i > 0)
		return -EINVAL;
	return 0;
}

1365
static int s2255_s_ctrl(struct v4l2_ctrl *ctrl)
1366
{
1367 1368
	struct s2255_vc *vc =
		container_of(ctrl->handler, struct s2255_vc, hdl);
1369
	struct s2255_mode mode;
1370
	mode = vc->mode;
1371 1372 1373
	/* update the mode to the corresponding value */
	switch (ctrl->id) {
	case V4L2_CID_BRIGHTNESS:
1374
		mode.bright = ctrl->val;
1375 1376
		break;
	case V4L2_CID_CONTRAST:
1377
		mode.contrast = ctrl->val;
1378 1379
		break;
	case V4L2_CID_HUE:
1380
		mode.hue = ctrl->val;
1381 1382
		break;
	case V4L2_CID_SATURATION:
1383
		mode.saturation = ctrl->val;
1384
		break;
1385
	case V4L2_CID_S2255_COLORFILTER:
1386
		mode.color &= ~MASK_INPUT_TYPE;
1387
		mode.color |= !ctrl->val << 16;
1388
		break;
1389
	case V4L2_CID_JPEG_COMPRESSION_QUALITY:
1390
		vc->jpegqual = ctrl->val;
1391
		return 0;
1392 1393
	default:
		return -EINVAL;
1394
	}
1395
	mode.restart = 0;
1396 1397 1398 1399
	/* set mode here.  Note: stream does not need restarted.
	   some V4L programs restart stream unnecessarily
	   after a s_crtl.
	*/
1400
	s2255_set_mode(vc, &mode);
1401
	return 0;
1402 1403
}

1404 1405 1406 1407
static int vidioc_g_jpegcomp(struct file *file, void *priv,
			 struct v4l2_jpegcompression *jc)
{
	struct s2255_fh *fh = priv;
1408
	struct s2255_vc *vc = fh->vc;
1409 1410

	memset(jc, 0, sizeof(*jc));
1411
	jc->quality = vc->jpegqual;
1412
	dprintk(fh->dev, 2, "%s: quality %d\n", __func__, jc->quality);
1413 1414 1415 1416
	return 0;
}

static int vidioc_s_jpegcomp(struct file *file, void *priv,
1417
			 const struct v4l2_jpegcompression *jc)
1418 1419
{
	struct s2255_fh *fh = priv;
1420
	struct s2255_vc *vc = fh->vc;
1421 1422
	if (jc->quality < 0 || jc->quality > 100)
		return -EINVAL;
1423
	v4l2_ctrl_s_ctrl(vc->jpegqual_ctrl, jc->quality);
1424
	dprintk(fh->dev, 2, "%s: quality %d\n", __func__, jc->quality);
1425 1426
	return 0;
}
1427 1428 1429 1430 1431

static int vidioc_g_parm(struct file *file, void *priv,
			 struct v4l2_streamparm *sp)
{
	struct s2255_fh *fh = priv;
1432
	__u32 def_num, def_dem;
1433
	struct s2255_vc *vc = fh->vc;
1434 1435
	if (sp->type != V4L2_BUF_TYPE_VIDEO_CAPTURE)
		return -EINVAL;
1436
	sp->parm.capture.capability = V4L2_CAP_TIMEPERFRAME;
1437 1438 1439
	sp->parm.capture.capturemode = vc->cap_parm.capturemode;
	def_num = (vc->mode.format == FORMAT_NTSC) ? 1001 : 1000;
	def_dem = (vc->mode.format == FORMAT_NTSC) ? 30000 : 25000;
1440
	sp->parm.capture.timeperframe.denominator = def_dem;
1441
	switch (vc->mode.fdec) {
1442 1443 1444 1445 1446 1447 1448 1449 1450 1451 1452 1453 1454 1455
	default:
	case FDEC_1:
		sp->parm.capture.timeperframe.numerator = def_num;
		break;
	case FDEC_2:
		sp->parm.capture.timeperframe.numerator = def_num * 2;
		break;
	case FDEC_3:
		sp->parm.capture.timeperframe.numerator = def_num * 3;
		break;
	case FDEC_5:
		sp->parm.capture.timeperframe.numerator = def_num * 5;
		break;
	}
1456 1457
	dprintk(fh->dev, 4, "%s capture mode, %d timeperframe %d/%d\n",
		__func__,
1458 1459 1460
		sp->parm.capture.capturemode,
		sp->parm.capture.timeperframe.numerator,
		sp->parm.capture.timeperframe.denominator);
1461 1462 1463 1464 1465 1466 1467
	return 0;
}

static int vidioc_s_parm(struct file *file, void *priv,
			 struct v4l2_streamparm *sp)
{
	struct s2255_fh *fh = priv;
1468
	struct s2255_vc *vc = fh->vc;
1469
	struct s2255_mode mode;
1470 1471
	int fdec = FDEC_1;
	__u32 def_num, def_dem;
1472 1473
	if (sp->type != V4L2_BUF_TYPE_VIDEO_CAPTURE)
		return -EINVAL;
1474
	mode = vc->mode;
1475
	/* high quality capture mode requires a stream restart */
1476
	if (vc->cap_parm.capturemode
1477
	    != sp->parm.capture.capturemode && res_locked(fh))
1478
		return -EBUSY;
1479 1480
	def_num = (mode.format == FORMAT_NTSC) ? 1001 : 1000;
	def_dem = (mode.format == FORMAT_NTSC) ? 30000 : 25000;
1481 1482 1483 1484 1485 1486 1487 1488 1489 1490 1491 1492 1493 1494
	if (def_dem != sp->parm.capture.timeperframe.denominator)
		sp->parm.capture.timeperframe.numerator = def_num;
	else if (sp->parm.capture.timeperframe.numerator <= def_num)
		sp->parm.capture.timeperframe.numerator = def_num;
	else if (sp->parm.capture.timeperframe.numerator <= (def_num * 2)) {
		sp->parm.capture.timeperframe.numerator = def_num * 2;
		fdec = FDEC_2;
	} else if (sp->parm.capture.timeperframe.numerator <= (def_num * 3)) {
		sp->parm.capture.timeperframe.numerator = def_num * 3;
		fdec = FDEC_3;
	} else {
		sp->parm.capture.timeperframe.numerator = def_num * 5;
		fdec = FDEC_5;
	}
1495
	mode.fdec = fdec;
1496
	sp->parm.capture.timeperframe.denominator = def_dem;
1497
	s2255_set_mode(vc, &mode);
1498
	dprintk(fh->dev, 4, "%s capture mode, %d timeperframe %d/%d, fdec %d\n",
1499 1500 1501 1502 1503 1504
		__func__,
		sp->parm.capture.capturemode,
		sp->parm.capture.timeperframe.numerator,
		sp->parm.capture.timeperframe.denominator, fdec);
	return 0;
}
1505

1506 1507 1508 1509 1510 1511 1512 1513 1514 1515 1516 1517 1518 1519 1520 1521
#define NUM_SIZE_ENUMS 3
static const struct v4l2_frmsize_discrete ntsc_sizes[] = {
	{ 640, 480 },
	{ 640, 240 },
	{ 320, 240 },
};
static const struct v4l2_frmsize_discrete pal_sizes[] = {
	{ 704, 576 },
	{ 704, 288 },
	{ 352, 288 },
};

static int vidioc_enum_framesizes(struct file *file, void *priv,
			    struct v4l2_frmsizeenum *fe)
{
	struct s2255_fh *fh = priv;
1522 1523
	struct s2255_vc *vc = fh->vc;
	int is_ntsc = vc->std & V4L2_STD_525_60;
1524 1525 1526 1527 1528 1529 1530 1531 1532 1533 1534 1535 1536
	const struct s2255_fmt *fmt;

	if (fe->index >= NUM_SIZE_ENUMS)
		return -EINVAL;

	fmt = format_by_fourcc(fe->pixel_format);
	if (fmt == NULL)
		return -EINVAL;
	fe->type = V4L2_FRMSIZE_TYPE_DISCRETE;
	fe->discrete = is_ntsc ?  ntsc_sizes[fe->index] : pal_sizes[fe->index];
	return 0;
}

1537 1538 1539
static int vidioc_enum_frameintervals(struct file *file, void *priv,
			    struct v4l2_frmivalenum *fe)
{
1540
	struct s2255_fh *fh = priv;
1541
	struct s2255_vc *vc = fh->vc;
1542 1543
	const struct s2255_fmt *fmt;
	const struct v4l2_frmsize_discrete *sizes;
1544
	int is_ntsc = vc->std & V4L2_STD_525_60;
1545 1546
#define NUM_FRAME_ENUMS 4
	int frm_dec[NUM_FRAME_ENUMS] = {1, 2, 3, 5};
1547 1548
	int i;

1549
	if (fe->index >= NUM_FRAME_ENUMS)
1550
		return -EINVAL;
1551 1552 1553

	fmt = format_by_fourcc(fe->pixel_format);
	if (fmt == NULL)
1554
		return -EINVAL;
1555 1556 1557 1558 1559 1560 1561 1562 1563

	sizes = is_ntsc ? ntsc_sizes : pal_sizes;
	for (i = 0; i < NUM_SIZE_ENUMS; i++, sizes++)
		if (fe->width == sizes->width &&
		    fe->height == sizes->height)
			break;
	if (i == NUM_SIZE_ENUMS)
		return -EINVAL;

1564 1565 1566
	fe->type = V4L2_FRMIVAL_TYPE_DISCRETE;
	fe->discrete.denominator = is_ntsc ? 30000 : 25000;
	fe->discrete.numerator = (is_ntsc ? 1001 : 1000) * frm_dec[fe->index];
1567 1568
	dprintk(fh->dev, 4, "%s discrete %d/%d\n", __func__,
		fe->discrete.numerator,
1569
		fe->discrete.denominator);
1570 1571
	return 0;
}
1572

1573
static int __s2255_open(struct file *file)
1574
{
1575
	struct video_device *vdev = video_devdata(file);
1576
	struct s2255_vc *vc = video_drvdata(file);
1577
	struct s2255_dev *dev = to_s2255_dev(vdev->v4l2_dev);
1578
	struct s2255_fh *fh;
1579
	enum v4l2_buf_type type = V4L2_BUF_TYPE_VIDEO_CAPTURE;
1580
	int state;
1581
	dprintk(dev, 1, "s2255: open called (dev=%s)\n",
1582
		video_device_node_name(vdev));
1583 1584 1585
	state = atomic_read(&dev->fw_data->fw_state);
	switch (state) {
	case S2255_FW_DISCONNECTING:
1586 1587
		return -ENODEV;
	case S2255_FW_FAILED:
1588 1589
		s2255_dev_err(&dev->udev->dev,
			"firmware load failed. retrying.\n");
1590
		s2255_fwload_start(dev, 1);
1591
		wait_event_timeout(dev->fw_data->wait_fw,
1592 1593 1594 1595
				   ((atomic_read(&dev->fw_data->fw_state)
				     == S2255_FW_SUCCESS) ||
				    (atomic_read(&dev->fw_data->fw_state)
				     == S2255_FW_DISCONNECTING)),
1596
				   msecs_to_jiffies(S2255_LOAD_TIMEOUT));
1597 1598
		/* state may have changed, re-read */
		state = atomic_read(&dev->fw_data->fw_state);
1599 1600 1601
		break;
	case S2255_FW_NOTLOADED:
	case S2255_FW_LOADED_DSPWAIT:
1602 1603
		/* give S2255_LOAD_TIMEOUT time for firmware to load in case
		   driver loaded and then device immediately opened */
1604
		pr_info("%s waiting for firmware load\n", __func__);
1605
		wait_event_timeout(dev->fw_data->wait_fw,
1606 1607 1608 1609
				   ((atomic_read(&dev->fw_data->fw_state)
				     == S2255_FW_SUCCESS) ||
				    (atomic_read(&dev->fw_data->fw_state)
				     == S2255_FW_DISCONNECTING)),
1610
				   msecs_to_jiffies(S2255_LOAD_TIMEOUT));
1611 1612
		/* state may have changed, re-read */
		state = atomic_read(&dev->fw_data->fw_state);
1613 1614 1615 1616 1617
		break;
	case S2255_FW_SUCCESS:
	default:
		break;
	}
1618 1619 1620 1621 1622
	/* state may have changed in above switch statement */
	switch (state) {
	case S2255_FW_SUCCESS:
		break;
	case S2255_FW_FAILED:
1623
		pr_info("2255 firmware load failed.\n");
1624 1625
		return -ENODEV;
	case S2255_FW_DISCONNECTING:
1626
		pr_info("%s: disconnecting\n", __func__);
1627 1628 1629
		return -ENODEV;
	case S2255_FW_LOADED_DSPWAIT:
	case S2255_FW_NOTLOADED:
1630 1631
		pr_info("%s: firmware not loaded, please retry\n",
			__func__);
1632 1633 1634 1635 1636 1637 1638
		/*
		 * Timeout on firmware load means device unusable.
		 * Set firmware failure state.
		 * On next s2255_open the firmware will be reloaded.
		 */
		atomic_set(&dev->fw_data->fw_state,
			   S2255_FW_FAILED);
1639 1640
		return -EAGAIN;
	default:
1641
		pr_info("%s: unknown state\n", __func__);
1642
		return -EFAULT;
1643 1644 1645
	}
	/* allocate + initialize per filehandle data */
	fh = kzalloc(sizeof(*fh), GFP_KERNEL);
1646
	if (NULL == fh)
1647
		return -ENOMEM;
1648 1649 1650
	v4l2_fh_init(&fh->fh, vdev);
	v4l2_fh_add(&fh->fh);
	file->private_data = &fh->fh;
1651 1652
	fh->dev = dev;
	fh->type = V4L2_BUF_TYPE_VIDEO_CAPTURE;
1653 1654
	fh->vc = vc;
	if (!vc->configured) {
1655
		/* configure channel to default state */
1656 1657 1658
		vc->fmt = &formats[0];
		s2255_set_mode(vc, &vc->mode);
		vc->configured = 1;
1659
	}
1660
	dprintk(dev, 1, "%s: dev=%s type=%s\n", __func__,
1661
		video_device_node_name(vdev), v4l2_type_names[type]);
1662 1663
	dprintk(dev, 2, "%s: fh=0x%08lx, dev=0x%08lx\n", __func__,
		(unsigned long)fh, (unsigned long)dev);
1664
	dprintk(dev, 4, "%s: list_empty active=%d\n", __func__,
1665
		list_empty(&vc->buf_list));
1666 1667 1668 1669
	videobuf_queue_vmalloc_init(&fh->vb_vidq, &s2255_video_qops,
				    NULL, &dev->slock,
				    fh->type,
				    V4L2_FIELD_INTERLACED,
P
Pete Eberlein 已提交
1670 1671
				    sizeof(struct s2255_buffer),
				    fh, vdev->lock);
1672 1673 1674
	return 0;
}

1675 1676 1677 1678 1679 1680 1681 1682 1683 1684 1685
static int s2255_open(struct file *file)
{
	struct video_device *vdev = video_devdata(file);
	int ret;

	if (mutex_lock_interruptible(vdev->lock))
		return -ERESTARTSYS;
	ret = __s2255_open(file);
	mutex_unlock(vdev->lock);
	return ret;
}
1686 1687 1688 1689 1690

static unsigned int s2255_poll(struct file *file,
			       struct poll_table_struct *wait)
{
	struct s2255_fh *fh = file->private_data;
1691
	struct s2255_dev *dev = fh->dev;
1692 1693
	int rc = v4l2_ctrl_poll(file, wait);

1694
	dprintk(dev, 100, "%s\n", __func__);
1695 1696
	if (V4L2_BUF_TYPE_VIDEO_CAPTURE != fh->type)
		return POLLERR;
1697
	mutex_lock(&dev->lock);
1698
	rc |= videobuf_poll_stream(file, &fh->vb_vidq, wait);
1699
	mutex_unlock(&dev->lock);
1700 1701 1702
	return rc;
}

1703
static void s2255_destroy(struct s2255_dev *dev)
1704
{
1705
	dprintk(dev, 1, "%s", __func__);
1706 1707 1708
	/* board shutdown stops the read pipe if it is running */
	s2255_board_shutdown(dev);
	/* make sure firmware still not trying to load */
1709
	del_timer(&dev->timer);  /* only started in .probe and .open */
1710 1711 1712 1713 1714
	if (dev->fw_data->fw_urb) {
		usb_kill_urb(dev->fw_data->fw_urb);
		usb_free_urb(dev->fw_data->fw_urb);
		dev->fw_data->fw_urb = NULL;
	}
1715
	release_firmware(dev->fw_data->fw);
1716 1717
	kfree(dev->fw_data->pfw_data);
	kfree(dev->fw_data);
1718 1719 1720
	/* reset the DSP so firmware can be reloaded next time */
	s2255_reset_dsppower(dev);
	mutex_destroy(&dev->lock);
1721
	usb_put_dev(dev->udev);
1722
	v4l2_device_unregister(&dev->v4l2_dev);
1723
	kfree(dev->cmdbuf);
1724
	kfree(dev);
1725 1726
}

1727
static int s2255_release(struct file *file)
1728 1729 1730
{
	struct s2255_fh *fh = file->private_data;
	struct s2255_dev *dev = fh->dev;
1731
	struct video_device *vdev = video_devdata(file);
1732
	struct s2255_vc *vc = fh->vc;
1733 1734
	if (!dev)
		return -ENODEV;
1735
	mutex_lock(&dev->lock);
1736 1737
	/* turn off stream */
	if (res_check(fh)) {
1738 1739
		if (vc->b_acquire)
			s2255_stop_acquire(fh->vc);
1740
		videobuf_streamoff(&fh->vb_vidq);
1741
		res_free(fh);
1742
	}
1743
	videobuf_mmap_free(&fh->vb_vidq);
1744
	mutex_unlock(&dev->lock);
1745
	dprintk(dev, 1, "%s[%s]\n", __func__, video_device_node_name(vdev));
1746 1747
	v4l2_fh_del(&fh->fh);
	v4l2_fh_exit(&fh->fh);
1748
	kfree(fh);
1749 1750 1751 1752 1753 1754
	return 0;
}

static int s2255_mmap_v4l(struct file *file, struct vm_area_struct *vma)
{
	struct s2255_fh *fh = file->private_data;
1755
	struct s2255_dev *dev;
1756 1757 1758
	int ret;
	if (!fh)
		return -ENODEV;
1759
	dev = fh->dev;
1760
	dprintk(dev, 4, "%s, vma=0x%08lx\n", __func__, (unsigned long)vma);
1761 1762
	if (mutex_lock_interruptible(&dev->lock))
		return -ERESTARTSYS;
1763
	ret = videobuf_mmap_mapper(&fh->vb_vidq, vma);
1764
	mutex_unlock(&dev->lock);
1765
	dprintk(dev, 4, "%s vma start=0x%08lx, size=%ld, ret=%d\n", __func__,
1766 1767 1768 1769 1770
		(unsigned long)vma->vm_start,
		(unsigned long)vma->vm_end - (unsigned long)vma->vm_start, ret);
	return ret;
}

1771
static const struct v4l2_file_operations s2255_fops_v4l = {
1772 1773
	.owner = THIS_MODULE,
	.open = s2255_open,
1774
	.release = s2255_release,
1775
	.poll = s2255_poll,
P
Pete Eberlein 已提交
1776
	.unlocked_ioctl = video_ioctl2,	/* V4L2 ioctl handler */
1777 1778 1779
	.mmap = s2255_mmap_v4l,
};

1780
static const struct v4l2_ioctl_ops s2255_ioctl_ops = {
1781 1782 1783 1784 1785 1786 1787 1788 1789 1790
	.vidioc_querycap = vidioc_querycap,
	.vidioc_enum_fmt_vid_cap = vidioc_enum_fmt_vid_cap,
	.vidioc_g_fmt_vid_cap = vidioc_g_fmt_vid_cap,
	.vidioc_try_fmt_vid_cap = vidioc_try_fmt_vid_cap,
	.vidioc_s_fmt_vid_cap = vidioc_s_fmt_vid_cap,
	.vidioc_reqbufs = vidioc_reqbufs,
	.vidioc_querybuf = vidioc_querybuf,
	.vidioc_qbuf = vidioc_qbuf,
	.vidioc_dqbuf = vidioc_dqbuf,
	.vidioc_s_std = vidioc_s_std,
1791
	.vidioc_g_std = vidioc_g_std,
1792 1793 1794 1795 1796
	.vidioc_enum_input = vidioc_enum_input,
	.vidioc_g_input = vidioc_g_input,
	.vidioc_s_input = vidioc_s_input,
	.vidioc_streamon = vidioc_streamon,
	.vidioc_streamoff = vidioc_streamoff,
1797 1798
	.vidioc_s_jpegcomp = vidioc_s_jpegcomp,
	.vidioc_g_jpegcomp = vidioc_g_jpegcomp,
1799 1800
	.vidioc_s_parm = vidioc_s_parm,
	.vidioc_g_parm = vidioc_g_parm,
1801
	.vidioc_enum_framesizes = vidioc_enum_framesizes,
1802
	.vidioc_enum_frameintervals = vidioc_enum_frameintervals,
1803 1804 1805
	.vidioc_log_status  = v4l2_ctrl_log_status,
	.vidioc_subscribe_event = v4l2_ctrl_subscribe_event,
	.vidioc_unsubscribe_event = v4l2_event_unsubscribe,
1806 1807
};

1808 1809
static void s2255_video_device_release(struct video_device *vdev)
{
1810
	struct s2255_dev *dev = to_s2255_dev(vdev->v4l2_dev);
1811 1812
	struct s2255_vc *vc =
		container_of(vdev, struct s2255_vc, vdev);
1813

1814
	dprintk(dev, 4, "%s, chnls: %d\n", __func__,
1815
		atomic_read(&dev->num_channels));
1816

1817
	v4l2_ctrl_handler_free(&vc->hdl);
1818

1819
	if (atomic_dec_and_test(&dev->num_channels))
1820
		s2255_destroy(dev);
1821 1822 1823
	return;
}

1824 1825 1826 1827
static struct video_device template = {
	.name = "s2255v",
	.fops = &s2255_fops_v4l,
	.ioctl_ops = &s2255_ioctl_ops,
1828
	.release = s2255_video_device_release,
1829 1830 1831
	.tvnorms = S2255_NORMS,
};

1832 1833 1834 1835 1836 1837 1838 1839 1840 1841 1842 1843 1844 1845
static const struct v4l2_ctrl_ops s2255_ctrl_ops = {
	.s_ctrl = s2255_s_ctrl,
};

static const struct v4l2_ctrl_config color_filter_ctrl = {
	.ops = &s2255_ctrl_ops,
	.name = "Color Filter",
	.id = V4L2_CID_S2255_COLORFILTER,
	.type = V4L2_CTRL_TYPE_BOOLEAN,
	.max = 1,
	.step = 1,
	.def = 1,
};

1846 1847 1848 1849 1850
static int s2255_probe_v4l(struct s2255_dev *dev)
{
	int ret;
	int i;
	int cur_nr = video_nr;
1851
	struct s2255_vc *vc;
1852 1853 1854
	ret = v4l2_device_register(&dev->interface->dev, &dev->v4l2_dev);
	if (ret)
		return ret;
1855 1856 1857
	/* initialize all video 4 linux */
	/* register 4 video devices */
	for (i = 0; i < MAX_CHANNELS; i++) {
1858 1859
		vc = &dev->vc[i];
		INIT_LIST_HEAD(&vc->buf_list);
1860

1861 1862
		v4l2_ctrl_handler_init(&vc->hdl, 6);
		v4l2_ctrl_new_std(&vc->hdl, &s2255_ctrl_ops,
1863
				V4L2_CID_BRIGHTNESS, -127, 127, 1, DEF_BRIGHT);
1864
		v4l2_ctrl_new_std(&vc->hdl, &s2255_ctrl_ops,
1865
				V4L2_CID_CONTRAST, 0, 255, 1, DEF_CONTRAST);
1866
		v4l2_ctrl_new_std(&vc->hdl, &s2255_ctrl_ops,
1867
				V4L2_CID_SATURATION, 0, 255, 1, DEF_SATURATION);
1868
		v4l2_ctrl_new_std(&vc->hdl, &s2255_ctrl_ops,
1869
				V4L2_CID_HUE, 0, 255, 1, DEF_HUE);
1870
		vc->jpegqual_ctrl = v4l2_ctrl_new_std(&vc->hdl,
1871 1872 1873
				&s2255_ctrl_ops,
				V4L2_CID_JPEG_COMPRESSION_QUALITY,
				0, 100, 1, S2255_DEF_JPEG_QUAL);
1874
		if (dev->dsp_fw_ver >= S2255_MIN_DSP_COLORFILTER &&
1875 1876
		    (dev->pid != 0x2257 || vc->idx <= 1))
			v4l2_ctrl_new_custom(&vc->hdl, &color_filter_ctrl,
1877
					     NULL);
1878 1879 1880
		if (vc->hdl.error) {
			ret = vc->hdl.error;
			v4l2_ctrl_handler_free(&vc->hdl);
1881 1882 1883
			dev_err(&dev->udev->dev, "couldn't register control\n");
			break;
		}
1884
		/* register 4 video devices */
1885 1886 1887 1888 1889 1890
		vc->vdev = template;
		vc->vdev.ctrl_handler = &vc->hdl;
		vc->vdev.lock = &dev->lock;
		vc->vdev.v4l2_dev = &dev->v4l2_dev;
		set_bit(V4L2_FL_USE_FH_PRIO, &vc->vdev.flags);
		video_set_drvdata(&vc->vdev, vc);
1891
		if (video_nr == -1)
1892
			ret = video_register_device(&vc->vdev,
1893 1894 1895
						    VFL_TYPE_GRABBER,
						    video_nr);
		else
1896
			ret = video_register_device(&vc->vdev,
1897 1898
						    VFL_TYPE_GRABBER,
						    cur_nr + i);
1899

1900
		if (ret) {
1901 1902
			dev_err(&dev->udev->dev,
				"failed to register video device!\n");
1903
			break;
1904
		}
1905
		atomic_inc(&dev->num_channels);
1906
		v4l2_info(&dev->v4l2_dev, "V4L2 device registered as %s\n",
1907
			  video_device_node_name(&vc->vdev));
1908

1909
	}
1910 1911
	pr_info("Sensoray 2255 V4L driver Revision: %s\n",
		S2255_VERSION);
1912
	/* if no channels registered, return error and probe will fail*/
1913
	if (atomic_read(&dev->num_channels) == 0) {
1914
		v4l2_device_unregister(&dev->v4l2_dev);
1915
		return ret;
1916
	}
1917
	if (atomic_read(&dev->num_channels) != MAX_CHANNELS)
1918
		pr_warn("s2255: Not all channels available.\n");
1919
	return 0;
1920 1921 1922 1923 1924 1925 1926 1927
}

/* this function moves the usb stream read pipe data
 * into the system buffers.
 * returns 0 on success, EAGAIN if more data to process( call this
 * function again).
 *
 * Received frame structure:
1928
 * bytes 0-3:  marker : 0x2255DA4AL (S2255_MARKER_FRAME)
1929 1930 1931 1932 1933 1934 1935 1936
 * bytes 4-7:  channel: 0-3
 * bytes 8-11: payload size:  size of the frame
 * bytes 12-payloadsize+12:  frame data
 */
static int save_frame(struct s2255_dev *dev, struct s2255_pipeinfo *pipe_info)
{
	char *pdest;
	u32 offset = 0;
1937
	int bframe = 0;
1938 1939 1940 1941 1942 1943
	char *psrc;
	unsigned long copy_size;
	unsigned long size;
	s32 idx = -1;
	struct s2255_framei *frm;
	unsigned char *pdata;
1944
	struct s2255_vc *vc;
1945
	dprintk(dev, 100, "buffer to user\n");
1946 1947 1948
	vc = &dev->vc[dev->cc];
	idx = vc->cur_frame;
	frm = &vc->buffer.frame[idx];
1949 1950 1951
	if (frm->ulState == S2255_READ_IDLE) {
		int jj;
		unsigned int cc;
1952
		__le32 *pdword; /*data from dsp is little endian */
1953 1954 1955
		int payload;
		/* search for marker codes */
		pdata = (unsigned char *)pipe_info->transfer_buffer;
1956
		pdword = (__le32 *)pdata;
1957
		for (jj = 0; jj < (pipe_info->cur_transfer_size - 12); jj++) {
1958
			switch (*pdword) {
1959
			case S2255_MARKER_FRAME:
1960 1961
				dprintk(dev, 4, "marker @ offset: %d [%x %x]\n",
					jj, pdata[0], pdata[1]);
1962 1963
				offset = jj + PREFIX_SIZE;
				bframe = 1;
1964
				cc = le32_to_cpu(pdword[1]);
1965
				if (cc >= MAX_CHANNELS) {
1966 1967
					dprintk(dev, 0,
						"bad channel\n");
1968 1969 1970 1971
					return -EINVAL;
				}
				/* reverse it */
				dev->cc = G_chnmap[cc];
1972
				vc = &dev->vc[dev->cc];
1973
				payload =  le32_to_cpu(pdword[3]);
1974 1975
				if (payload > vc->req_image_size) {
					vc->bad_payload++;
1976 1977 1978
					/* discard the bad frame */
					return -EINVAL;
				}
1979 1980
				vc->pkt_size = payload;
				vc->jpg_size = le32_to_cpu(pdword[4]);
1981 1982
				break;
			case S2255_MARKER_RESPONSE:
1983

1984 1985
				pdata += DEF_USB_BLOCK;
				jj += DEF_USB_BLOCK;
1986
				if (le32_to_cpu(pdword[1]) >= MAX_CHANNELS)
1987
					break;
1988
				cc = G_chnmap[le32_to_cpu(pdword[1])];
1989
				if (cc >= MAX_CHANNELS)
1990
					break;
1991
				vc = &dev->vc[cc];
1992
				switch (pdword[2]) {
1993
				case S2255_RESPONSE_SETMODE:
1994 1995
					/* check if channel valid */
					/* set mode ready */
1996 1997
					vc->setmode_ready = 1;
					wake_up(&vc->wait_setmode);
1998
					dprintk(dev, 5, "setmode rdy %d\n", cc);
1999
					break;
2000
				case S2255_RESPONSE_FW:
2001 2002 2003 2004
					dev->chn_ready |= (1 << cc);
					if ((dev->chn_ready & 0x0f) != 0x0f)
						break;
					/* all channels ready */
2005
					pr_info("s2255: fw loaded\n");
2006 2007 2008 2009
					atomic_set(&dev->fw_data->fw_state,
						   S2255_FW_SUCCESS);
					wake_up(&dev->fw_data->wait_fw);
					break;
2010
				case S2255_RESPONSE_STATUS:
2011 2012 2013
					vc->vidstatus = le32_to_cpu(pdword[3]);
					vc->vidstatus_ready = 1;
					wake_up(&vc->wait_vidstatus);
2014
					dprintk(dev, 5, "vstat %x chan %d\n",
2015
						le32_to_cpu(pdword[3]), cc);
2016
					break;
2017
				default:
2018
					pr_info("s2255 unknown resp\n");
2019
				}
2020
			default:
2021
				pdata++;
2022
				break;
2023
			}
2024 2025 2026 2027 2028
			if (bframe)
				break;
		} /* for */
		if (!bframe)
			return -EINVAL;
2029
	}
2030 2031 2032
	vc = &dev->vc[dev->cc];
	idx = vc->cur_frame;
	frm = &vc->buffer.frame[idx];
2033
	/* search done.  now find out if should be acquiring on this channel */
2034
	if (!vc->b_acquire) {
2035 2036 2037
		/* we found a frame, but this channel is turned off */
		frm->ulState = S2255_READ_IDLE;
		return -EINVAL;
2038 2039
	}

2040 2041 2042
	if (frm->ulState == S2255_READ_IDLE) {
		frm->ulState = S2255_READ_FRAME;
		frm->cur_size = 0;
2043 2044
	}

2045 2046 2047 2048
	/* skip the marker 512 bytes (and offset if out of sync) */
	psrc = (u8 *)pipe_info->transfer_buffer + offset;


2049
	if (frm->lpvbits == NULL) {
2050
		dprintk(dev, 1, "s2255 frame buffer == NULL.%p %p %d %d",
2051 2052 2053 2054 2055 2056
			frm, dev, dev->cc, idx);
		return -ENOMEM;
	}

	pdest = frm->lpvbits + frm->cur_size;

2057
	copy_size = (pipe_info->cur_transfer_size - offset);
2058

2059
	size = vc->pkt_size - PREFIX_SIZE;
2060

2061
	/* sanity check on pdest */
2062
	if ((copy_size + frm->cur_size) < vc->req_image_size)
2063
		memcpy(pdest, psrc, copy_size);
2064 2065

	frm->cur_size += copy_size;
2066
	dprintk(dev, 4, "cur_size: %lu, size: %lu\n", frm->cur_size, size);
2067 2068

	if (frm->cur_size >= size) {
2069
		dprintk(dev, 2, "******[%d]Buffer[%d]full*******\n",
2070
			dev->cc, idx);
2071 2072
		vc->last_frame = vc->cur_frame;
		vc->cur_frame++;
2073
		/* end of system frame ring buffer, start at zero */
2074 2075 2076
		if ((vc->cur_frame == SYS_FRAMES) ||
		    (vc->cur_frame == vc->buffer.dwFrames))
			vc->cur_frame = 0;
2077
		/* frame ready */
2078 2079 2080
		if (vc->b_acquire)
			s2255_got_frame(vc, vc->jpg_size);
		vc->frame_count++;
2081 2082 2083
		frm->ulState = S2255_READ_IDLE;
		frm->cur_size = 0;

2084 2085 2086 2087 2088 2089 2090 2091 2092
	}
	/* done successfully */
	return 0;
}

static void s2255_read_video_callback(struct s2255_dev *dev,
				      struct s2255_pipeinfo *pipe_info)
{
	int res;
2093
	dprintk(dev, 50, "callback read video\n");
2094 2095 2096 2097 2098 2099 2100 2101

	if (dev->cc >= MAX_CHANNELS) {
		dev->cc = 0;
		dev_err(&dev->udev->dev, "invalid channel\n");
		return;
	}
	/* otherwise copy to the system buffers */
	res = save_frame(dev, pipe_info);
2102
	if (res != 0)
2103
		dprintk(dev, 4, "s2255: read callback failed\n");
2104

2105
	dprintk(dev, 50, "callback read video done\n");
2106 2107 2108 2109 2110 2111 2112 2113 2114 2115 2116 2117 2118 2119 2120 2121 2122 2123 2124 2125 2126 2127 2128 2129 2130 2131 2132 2133 2134 2135 2136 2137 2138 2139 2140 2141 2142
	return;
}

static long s2255_vendor_req(struct s2255_dev *dev, unsigned char Request,
			     u16 Index, u16 Value, void *TransferBuffer,
			     s32 TransferBufferLength, int bOut)
{
	int r;
	if (!bOut) {
		r = usb_control_msg(dev->udev, usb_rcvctrlpipe(dev->udev, 0),
				    Request,
				    USB_TYPE_VENDOR | USB_RECIP_DEVICE |
				    USB_DIR_IN,
				    Value, Index, TransferBuffer,
				    TransferBufferLength, HZ * 5);
	} else {
		r = usb_control_msg(dev->udev, usb_sndctrlpipe(dev->udev, 0),
				    Request, USB_TYPE_VENDOR | USB_RECIP_DEVICE,
				    Value, Index, TransferBuffer,
				    TransferBufferLength, HZ * 5);
	}
	return r;
}

/*
 * retrieve FX2 firmware version. future use.
 * @param dev pointer to device extension
 * @return -1 for fail, else returns firmware version as an int(16 bits)
 */
static int s2255_get_fx2fw(struct s2255_dev *dev)
{
	int fw;
	int ret;
	unsigned char transBuffer[64];
	ret = s2255_vendor_req(dev, S2255_VR_FW, 0, 0, transBuffer, 2,
			       S2255_VR_IN);
	if (ret < 0)
2143
		dprintk(dev, 2, "get fw error: %x\n", ret);
2144
	fw = transBuffer[0] + (transBuffer[1] << 8);
2145
	dprintk(dev, 2, "Get FW %x %x\n", transBuffer[0], transBuffer[1]);
2146 2147 2148 2149 2150 2151 2152
	return fw;
}

/*
 * Create the system ring buffer to copy frames into from the
 * usb read pipe.
 */
2153
static int s2255_create_sys_buffers(struct s2255_vc *vc)
2154 2155 2156
{
	unsigned long i;
	unsigned long reqsize;
2157
	vc->buffer.dwFrames = SYS_FRAMES;
2158 2159 2160 2161 2162 2163 2164 2165
	/* always allocate maximum size(PAL) for system buffers */
	reqsize = SYS_FRAMES_MAXSIZE;

	if (reqsize > SYS_FRAMES_MAXSIZE)
		reqsize = SYS_FRAMES_MAXSIZE;

	for (i = 0; i < SYS_FRAMES; i++) {
		/* allocate the frames */
2166 2167 2168
		vc->buffer.frame[i].lpvbits = vmalloc(reqsize);
		vc->buffer.frame[i].size = reqsize;
		if (vc->buffer.frame[i].lpvbits == NULL) {
2169
			pr_info("out of memory.  using less frames\n");
2170
			vc->buffer.dwFrames = i;
2171 2172 2173 2174 2175 2176
			break;
		}
	}

	/* make sure internal states are set */
	for (i = 0; i < SYS_FRAMES; i++) {
2177 2178
		vc->buffer.frame[i].ulState = 0;
		vc->buffer.frame[i].cur_size = 0;
2179 2180
	}

2181 2182
	vc->cur_frame = 0;
	vc->last_frame = -1;
2183 2184 2185
	return 0;
}

2186
static int s2255_release_sys_buffers(struct s2255_vc *vc)
2187 2188 2189
{
	unsigned long i;
	for (i = 0; i < SYS_FRAMES; i++) {
2190 2191 2192
		if (vc->buffer.frame[i].lpvbits)
			vfree(vc->buffer.frame[i].lpvbits);
		vc->buffer.frame[i].lpvbits = NULL;
2193 2194 2195 2196 2197 2198 2199 2200
	}
	return 0;
}

static int s2255_board_init(struct s2255_dev *dev)
{
	struct s2255_mode mode_def = DEF_MODEI_NTSC_CONT;
	int fw_ver;
D
Dean Anderson 已提交
2201 2202
	int j;
	struct s2255_pipeinfo *pipe = &dev->pipe;
2203
	dprintk(dev, 4, "board init: %p", dev);
D
Dean Anderson 已提交
2204 2205 2206 2207 2208 2209 2210 2211
	memset(pipe, 0, sizeof(*pipe));
	pipe->dev = dev;
	pipe->cur_transfer_size = S2255_USB_XFER_SIZE;
	pipe->max_transfer_size = S2255_USB_XFER_SIZE;

	pipe->transfer_buffer = kzalloc(pipe->max_transfer_size,
					GFP_KERNEL);
	if (pipe->transfer_buffer == NULL) {
2212
		dprintk(dev, 1, "out of memory!\n");
D
Dean Anderson 已提交
2213
		return -ENOMEM;
2214 2215 2216 2217
	}
	/* query the firmware */
	fw_ver = s2255_get_fx2fw(dev);

2218 2219 2220
	pr_info("s2255: usb firmware version %d.%d\n",
		(fw_ver >> 8) & 0xff,
		fw_ver & 0xff);
2221 2222

	if (fw_ver < S2255_CUR_USB_FWVER)
2223
		pr_info("s2255: newer USB firmware available\n");
2224 2225

	for (j = 0; j < MAX_CHANNELS; j++) {
2226 2227 2228
		struct s2255_vc *vc = &dev->vc[j];
		vc->b_acquire = 0;
		vc->mode = mode_def;
2229
		if (dev->pid == 0x2257 && j > 1)
2230 2231 2232 2233 2234 2235 2236 2237 2238
			vc->mode.color |= (1 << 16);
		vc->jpegqual = S2255_DEF_JPEG_QUAL;
		vc->width = LINE_SZ_4CIFS_NTSC;
		vc->height = NUM_LINES_4CIFS_NTSC * 2;
		vc->std = V4L2_STD_NTSC_M;
		vc->fmt = &formats[0];
		vc->mode.restart = 1;
		vc->req_image_size = get_transfer_size(&mode_def);
		vc->frame_count = 0;
2239
		/* create the system buffers */
2240
		s2255_create_sys_buffers(vc);
2241 2242 2243
	}
	/* start read pipe */
	s2255_start_readpipe(dev);
2244
	dprintk(dev, 1, "%s: success\n", __func__);
2245 2246 2247 2248 2249 2250
	return 0;
}

static int s2255_board_shutdown(struct s2255_dev *dev)
{
	u32 i;
2251
	dprintk(dev, 1, "%s: dev: %p", __func__,  dev);
2252 2253

	for (i = 0; i < MAX_CHANNELS; i++) {
2254 2255
		if (dev->vc[i].b_acquire)
			s2255_stop_acquire(&dev->vc[i]);
2256 2257 2258
	}
	s2255_stop_readpipe(dev);
	for (i = 0; i < MAX_CHANNELS; i++)
2259
		s2255_release_sys_buffers(&dev->vc[i]);
D
Dean Anderson 已提交
2260 2261
	/* release transfer buffer */
	kfree(dev->pipe.transfer_buffer);
2262 2263 2264 2265 2266 2267 2268 2269 2270 2271 2272
	return 0;
}

static void read_pipe_completion(struct urb *purb)
{
	struct s2255_pipeinfo *pipe_info;
	struct s2255_dev *dev;
	int status;
	int pipe;
	pipe_info = purb->context;
	if (pipe_info == NULL) {
2273
		dev_err(&purb->dev->dev, "no context!\n");
2274 2275 2276 2277
		return;
	}
	dev = pipe_info->dev;
	if (dev == NULL) {
2278
		dev_err(&purb->dev->dev, "no context!\n");
2279 2280 2281
		return;
	}
	status = purb->status;
2282 2283
	/* if shutting down, do not resubmit, exit immediately */
	if (status == -ESHUTDOWN) {
2284
		dprintk(dev, 2, "%s: err shutdown\n", __func__);
2285
		pipe_info->err_count++;
2286 2287 2288 2289
		return;
	}

	if (pipe_info->state == 0) {
2290
		dprintk(dev, 2, "%s: exiting USB pipe", __func__);
2291 2292 2293
		return;
	}

2294 2295 2296 2297
	if (status == 0)
		s2255_read_video_callback(dev, pipe_info);
	else {
		pipe_info->err_count++;
2298
		dprintk(dev, 1, "%s: failed URB %d\n", __func__, status);
2299
	}
2300 2301 2302 2303 2304 2305 2306 2307 2308 2309

	pipe = usb_rcvbulkpipe(dev->udev, dev->read_endpoint);
	/* reuse urb */
	usb_fill_bulk_urb(pipe_info->stream_urb, dev->udev,
			  pipe,
			  pipe_info->transfer_buffer,
			  pipe_info->cur_transfer_size,
			  read_pipe_completion, pipe_info);

	if (pipe_info->state != 0) {
2310
		if (usb_submit_urb(pipe_info->stream_urb, GFP_ATOMIC))
2311 2312
			dev_err(&dev->udev->dev, "error submitting urb\n");
	} else {
2313
		dprintk(dev, 2, "%s :complete state 0\n", __func__);
2314 2315 2316 2317 2318 2319 2320 2321
	}
	return;
}

static int s2255_start_readpipe(struct s2255_dev *dev)
{
	int pipe;
	int retval;
D
Dean Anderson 已提交
2322
	struct s2255_pipeinfo *pipe_info = &dev->pipe;
2323
	pipe = usb_rcvbulkpipe(dev->udev, dev->read_endpoint);
2324
	dprintk(dev, 2, "%s: IN %d\n", __func__, dev->read_endpoint);
D
Dean Anderson 已提交
2325 2326 2327 2328 2329 2330 2331
	pipe_info->state = 1;
	pipe_info->err_count = 0;
	pipe_info->stream_urb = usb_alloc_urb(0, GFP_KERNEL);
	if (!pipe_info->stream_urb) {
		dev_err(&dev->udev->dev,
			"ReadStream: Unable to alloc URB\n");
		return -ENOMEM;
2332
	}
D
Dean Anderson 已提交
2333 2334 2335 2336 2337 2338 2339 2340
	/* transfer buffer allocated in board_init */
	usb_fill_bulk_urb(pipe_info->stream_urb, dev->udev,
			  pipe,
			  pipe_info->transfer_buffer,
			  pipe_info->cur_transfer_size,
			  read_pipe_completion, pipe_info);
	retval = usb_submit_urb(pipe_info->stream_urb, GFP_KERNEL);
	if (retval) {
2341
		pr_err("s2255: start read pipe failed\n");
D
Dean Anderson 已提交
2342 2343
		return retval;
	}
2344 2345 2346 2347
	return 0;
}

/* starts acquisition process */
2348
static int s2255_start_acquire(struct s2255_vc *vc)
2349 2350 2351 2352
{
	int res;
	unsigned long chn_rev;
	int j;
2353
	struct s2255_dev *dev = to_s2255_dev(vc->vdev.v4l2_dev);
2354
	__le32 *buffer = dev->cmdbuf;
2355

2356 2357
	mutex_lock(&dev->cmdlock);
	chn_rev = G_chnmap[vc->idx];
2358 2359 2360
	vc->last_frame = -1;
	vc->bad_payload = 0;
	vc->cur_frame = 0;
2361
	for (j = 0; j < SYS_FRAMES; j++) {
2362 2363
		vc->buffer.frame[j].ulState = 0;
		vc->buffer.frame[j].cur_size = 0;
2364 2365 2366
	}

	/* send the start command */
2367 2368 2369
	buffer[0] = IN_DATA_TOKEN;
	buffer[1] = (__le32) cpu_to_le32(chn_rev);
	buffer[2] = CMD_START;
2370 2371 2372 2373
	res = s2255_write_config(dev->udev, (unsigned char *)buffer, 512);
	if (res != 0)
		dev_err(&dev->udev->dev, "CMD_START error\n");

2374
	dprintk(dev, 2, "start acquire exit[%d] %d\n", vc->idx, res);
2375
	mutex_unlock(&dev->cmdlock);
2376 2377 2378
	return 0;
}

2379
static int s2255_stop_acquire(struct s2255_vc *vc)
2380 2381 2382
{
	int res;
	unsigned long chn_rev;
2383
	struct s2255_dev *dev = to_s2255_dev(vc->vdev.v4l2_dev);
2384 2385 2386
	__le32 *buffer = dev->cmdbuf;

	mutex_lock(&dev->cmdlock);
2387
	chn_rev = G_chnmap[vc->idx];
2388 2389 2390 2391 2392 2393
	buffer = kzalloc(512, GFP_KERNEL);
	if (buffer == NULL) {
		dev_err(&dev->udev->dev, "out of mem\n");
		return -ENOMEM;
	}
	/* send the stop command */
2394 2395 2396 2397
	buffer[0] = IN_DATA_TOKEN;
	buffer[1] = (__le32) cpu_to_le32(chn_rev);
	buffer[2] = CMD_STOP;

2398 2399 2400
	res = s2255_write_config(dev->udev, (unsigned char *)buffer, 512);
	if (res != 0)
		dev_err(&dev->udev->dev, "CMD_STOP error\n");
2401

2402 2403
	vc->b_acquire = 0;
	dprintk(dev, 4, "%s: chn %d, res %d\n", __func__, vc->idx, res);
2404
	mutex_unlock(&dev->cmdlock);
2405
	return res;
2406 2407 2408 2409
}

static void s2255_stop_readpipe(struct s2255_dev *dev)
{
D
Dean Anderson 已提交
2410
	struct s2255_pipeinfo *pipe = &dev->pipe;
2411

D
Dean Anderson 已提交
2412 2413 2414 2415 2416 2417
	pipe->state = 0;
	if (pipe->stream_urb) {
		/* cancel urb */
		usb_kill_urb(pipe->stream_urb);
		usb_free_urb(pipe->stream_urb);
		pipe->stream_urb = NULL;
2418
	}
2419
	dprintk(dev, 4, "%s", __func__);
2420 2421 2422
	return;
}

2423
static void s2255_fwload_start(struct s2255_dev *dev, int reset)
2424
{
2425 2426
	if (reset)
		s2255_reset_dsppower(dev);
2427 2428 2429 2430 2431 2432 2433 2434 2435 2436 2437 2438 2439 2440 2441 2442 2443 2444 2445 2446 2447 2448
	dev->fw_data->fw_size = dev->fw_data->fw->size;
	atomic_set(&dev->fw_data->fw_state, S2255_FW_NOTLOADED);
	memcpy(dev->fw_data->pfw_data,
	       dev->fw_data->fw->data, CHUNK_SIZE);
	dev->fw_data->fw_loaded = CHUNK_SIZE;
	usb_fill_bulk_urb(dev->fw_data->fw_urb, dev->udev,
			  usb_sndbulkpipe(dev->udev, 2),
			  dev->fw_data->pfw_data,
			  CHUNK_SIZE, s2255_fwchunk_complete,
			  dev->fw_data);
	mod_timer(&dev->timer, jiffies + HZ);
}

/* standard usb probe function */
static int s2255_probe(struct usb_interface *interface,
		       const struct usb_device_id *id)
{
	struct s2255_dev *dev = NULL;
	struct usb_host_interface *iface_desc;
	struct usb_endpoint_descriptor *endpoint;
	int i;
	int retval = -ENOMEM;
2449 2450
	__le32 *pdata;
	int fw_size;
2451

2452 2453 2454
	/* allocate memory for our device state and initialize it to zero */
	dev = kzalloc(sizeof(struct s2255_dev), GFP_KERNEL);
	if (dev == NULL) {
2455
		s2255_dev_err(&interface->dev, "out of memory\n");
2456
		return -ENOMEM;
2457
	}
2458 2459 2460 2461 2462 2463 2464

	dev->cmdbuf = kzalloc(S2255_CMDBUF_SIZE, GFP_KERNEL);
	if (dev->cmdbuf == NULL) {
		s2255_dev_err(&interface->dev, "out of memory\n");
		return -ENOMEM;
	}

2465
	atomic_set(&dev->num_channels, 0);
2466
	dev->pid = le16_to_cpu(id->idProduct);
2467 2468
	dev->fw_data = kzalloc(sizeof(struct s2255_fw), GFP_KERNEL);
	if (!dev->fw_data)
2469
		goto errorFWDATA1;
2470
	mutex_init(&dev->lock);
2471
	mutex_init(&dev->cmdlock);
2472 2473 2474 2475 2476
	/* grab usb_device and save it */
	dev->udev = usb_get_dev(interface_to_usbdev(interface));
	if (dev->udev == NULL) {
		dev_err(&interface->dev, "null usb device\n");
		retval = -ENODEV;
2477
		goto errorUDEV;
2478
	}
2479 2480
	dev_dbg(&interface->dev, "dev: %p, udev %p interface %p\n",
		dev, dev->udev, interface);
2481 2482 2483
	dev->interface = interface;
	/* set up the endpoint information  */
	iface_desc = interface->cur_altsetting;
2484 2485
	dev_dbg(&interface->dev, "num EP: %d\n",
		iface_desc->desc.bNumEndpoints);
2486 2487 2488 2489 2490 2491 2492 2493 2494
	for (i = 0; i < iface_desc->desc.bNumEndpoints; ++i) {
		endpoint = &iface_desc->endpoint[i].desc;
		if (!dev->read_endpoint && usb_endpoint_is_bulk_in(endpoint)) {
			/* we found the bulk in endpoint */
			dev->read_endpoint = endpoint->bEndpointAddress;
		}
	}

	if (!dev->read_endpoint) {
2495
		dev_err(&interface->dev, "Could not find bulk-in endpoint\n");
2496
		goto errorEP;
2497 2498 2499 2500 2501
	}
	init_timer(&dev->timer);
	dev->timer.function = s2255_timer;
	dev->timer.data = (unsigned long)dev->fw_data;
	init_waitqueue_head(&dev->fw_data->wait_fw);
2502
	for (i = 0; i < MAX_CHANNELS; i++) {
2503 2504 2505 2506 2507
		struct s2255_vc *vc = &dev->vc[i];
		vc->idx = i;
		vc->dev = dev;
		init_waitqueue_head(&vc->wait_setmode);
		init_waitqueue_head(&vc->wait_vidstatus);
2508
	}
2509 2510 2511 2512

	dev->fw_data->fw_urb = usb_alloc_urb(0, GFP_KERNEL);
	if (!dev->fw_data->fw_urb) {
		dev_err(&interface->dev, "out of memory!\n");
2513
		goto errorFWURB;
2514
	}
2515

2516 2517 2518
	dev->fw_data->pfw_data = kzalloc(CHUNK_SIZE, GFP_KERNEL);
	if (!dev->fw_data->pfw_data) {
		dev_err(&interface->dev, "out of memory!\n");
2519
		goto errorFWDATA2;
2520 2521 2522 2523
	}
	/* load the first chunk */
	if (request_firmware(&dev->fw_data->fw,
			     FIRMWARE_FILE_NAME, &dev->udev->dev)) {
2524
		dev_err(&interface->dev, "sensoray 2255 failed to get firmware\n");
2525
		goto errorREQFW;
2526
	}
2527 2528 2529
	/* check the firmware is valid */
	fw_size = dev->fw_data->fw->size;
	pdata = (__le32 *) &dev->fw_data->fw->data[fw_size - 8];
2530

2531
	if (*pdata != S2255_FW_MARKER) {
2532
		dev_err(&interface->dev, "Firmware invalid.\n");
2533
		retval = -ENODEV;
2534
		goto errorFWMARKER;
2535 2536 2537 2538
	} else {
		/* make sure firmware is the latest */
		__le32 *pRel;
		pRel = (__le32 *) &dev->fw_data->fw->data[fw_size - 4];
2539
		pr_info("s2255 dsp fw version %x\n", le32_to_cpu(*pRel));
2540 2541
		dev->dsp_fw_ver = le32_to_cpu(*pRel);
		if (dev->dsp_fw_ver < S2255_CUR_DSP_FWVER)
2542
			pr_info("s2255: f2255usb.bin out of date.\n");
2543 2544
		if (dev->pid == 0x2257 &&
				dev->dsp_fw_ver < S2255_MIN_DSP_COLORFILTER)
2545 2546
			pr_warn("2257 needs firmware %d or above.\n",
				S2255_MIN_DSP_COLORFILTER);
2547 2548
	}
	usb_reset_device(dev->udev);
2549
	/* load 2255 board specific */
2550 2551
	retval = s2255_board_init(dev);
	if (retval)
2552
		goto errorBOARDINIT;
2553
	spin_lock_init(&dev->slock);
2554
	s2255_fwload_start(dev, 0);
2555 2556 2557
	/* loads v4l specific */
	retval = s2255_probe_v4l(dev);
	if (retval)
2558
		goto errorBOARDINIT;
2559 2560
	dev_info(&interface->dev, "Sensoray 2255 detected\n");
	return 0;
2561 2562 2563 2564 2565 2566 2567 2568 2569 2570 2571 2572 2573 2574 2575 2576
errorBOARDINIT:
	s2255_board_shutdown(dev);
errorFWMARKER:
	release_firmware(dev->fw_data->fw);
errorREQFW:
	kfree(dev->fw_data->pfw_data);
errorFWDATA2:
	usb_free_urb(dev->fw_data->fw_urb);
errorFWURB:
	del_timer(&dev->timer);
errorEP:
	usb_put_dev(dev->udev);
errorUDEV:
	kfree(dev->fw_data);
	mutex_destroy(&dev->lock);
errorFWDATA1:
2577
	kfree(dev->cmdbuf);
2578
	kfree(dev);
2579
	pr_warn("Sensoray 2255 driver load failed: 0x%x\n", retval);
2580 2581 2582 2583 2584 2585
	return retval;
}

/* disconnect routine. when board is removed physically or with rmmod */
static void s2255_disconnect(struct usb_interface *interface)
{
2586
	struct s2255_dev *dev = to_s2255_dev(usb_get_intfdata(interface));
2587
	int i;
2588
	int channels = atomic_read(&dev->num_channels);
P
Pete Eberlein 已提交
2589
	mutex_lock(&dev->lock);
2590
	v4l2_device_disconnect(&dev->v4l2_dev);
P
Pete Eberlein 已提交
2591
	mutex_unlock(&dev->lock);
2592
	/*see comments in the uvc_driver.c usb disconnect function */
2593
	atomic_inc(&dev->num_channels);
2594
	/* unregister each video device. */
2595
	for (i = 0; i < channels; i++)
2596
		video_unregister_device(&dev->vc[i].vdev);
2597
	/* wake up any of our timers */
2598 2599 2600
	atomic_set(&dev->fw_data->fw_state, S2255_FW_DISCONNECTING);
	wake_up(&dev->fw_data->wait_fw);
	for (i = 0; i < MAX_CHANNELS; i++) {
2601 2602 2603 2604
		dev->vc[i].setmode_ready = 1;
		wake_up(&dev->vc[i].wait_setmode);
		dev->vc[i].vidstatus_ready = 1;
		wake_up(&dev->vc[i].wait_vidstatus);
2605
	}
2606
	if (atomic_dec_and_test(&dev->num_channels))
2607
		s2255_destroy(dev);
2608
	dev_info(&interface->dev, "%s\n", __func__);
2609 2610 2611
}

static struct usb_driver s2255_driver = {
2612
	.name = S2255_DRIVER_NAME,
2613 2614 2615 2616 2617
	.probe = s2255_probe,
	.disconnect = s2255_disconnect,
	.id_table = s2255_table,
};

2618
module_usb_driver(s2255_driver);
2619 2620 2621 2622

MODULE_DESCRIPTION("Sensoray 2255 Video for Linux driver");
MODULE_AUTHOR("Dean Anderson (Sensoray Company Inc.)");
MODULE_LICENSE("GPL");
2623
MODULE_VERSION(S2255_VERSION);
2624
MODULE_FIRMWARE(FIRMWARE_FILE_NAME);