gspca.c 54 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261
  1. /*
  2. * Main USB camera driver
  3. *
  4. * Copyright (C) 2008-2009 Jean-Francois Moine (http://moinejf.free.fr)
  5. *
  6. * This program is free software; you can redistribute it and/or modify it
  7. * under the terms of the GNU General Public License as published by the
  8. * Free Software Foundation; either version 2 of the License, or (at your
  9. * option) any later version.
  10. *
  11. * This program is distributed in the hope that it will be useful, but
  12. * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
  13. * or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
  14. * for more details.
  15. *
  16. * You should have received a copy of the GNU General Public License
  17. * along with this program; if not, write to the Free Software Foundation,
  18. * Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  19. */
  20. #define MODULE_NAME "gspca"
  21. #include <linux/init.h>
  22. #include <linux/version.h>
  23. #include <linux/fs.h>
  24. #include <linux/vmalloc.h>
  25. #include <linux/sched.h>
  26. #include <linux/slab.h>
  27. #include <linux/mm.h>
  28. #include <linux/string.h>
  29. #include <linux/pagemap.h>
  30. #include <linux/io.h>
  31. #include <asm/page.h>
  32. #include <linux/uaccess.h>
  33. #include <linux/jiffies.h>
  34. #include <media/v4l2-ioctl.h>
  35. #include "gspca.h"
  36. /* global values */
  37. #define DEF_NURBS 3 /* default number of URBs */
  38. #if DEF_NURBS > MAX_NURBS
  39. #error "DEF_NURBS too big"
  40. #endif
  41. MODULE_AUTHOR("Jean-Francois Moine <http://moinejf.free.fr>");
  42. MODULE_DESCRIPTION("GSPCA USB Camera Driver");
  43. MODULE_LICENSE("GPL");
  44. #define DRIVER_VERSION_NUMBER KERNEL_VERSION(2, 8, 0)
  45. #ifdef GSPCA_DEBUG
  46. int gspca_debug = D_ERR | D_PROBE;
  47. EXPORT_SYMBOL(gspca_debug);
  48. static void PDEBUG_MODE(char *txt, __u32 pixfmt, int w, int h)
  49. {
  50. if ((pixfmt >> 24) >= '0' && (pixfmt >> 24) <= 'z') {
  51. PDEBUG(D_CONF|D_STREAM, "%s %c%c%c%c %dx%d",
  52. txt,
  53. pixfmt & 0xff,
  54. (pixfmt >> 8) & 0xff,
  55. (pixfmt >> 16) & 0xff,
  56. pixfmt >> 24,
  57. w, h);
  58. } else {
  59. PDEBUG(D_CONF|D_STREAM, "%s 0x%08x %dx%d",
  60. txt,
  61. pixfmt,
  62. w, h);
  63. }
  64. }
  65. #else
  66. #define PDEBUG_MODE(txt, pixfmt, w, h)
  67. #endif
  68. /* specific memory types - !! should be different from V4L2_MEMORY_xxx */
  69. #define GSPCA_MEMORY_NO 0 /* V4L2_MEMORY_xxx starts from 1 */
  70. #define GSPCA_MEMORY_READ 7
  71. #define BUF_ALL_FLAGS (V4L2_BUF_FLAG_QUEUED | V4L2_BUF_FLAG_DONE)
  72. /*
  73. * VMA operations.
  74. */
  75. static void gspca_vm_open(struct vm_area_struct *vma)
  76. {
  77. struct gspca_frame *frame = vma->vm_private_data;
  78. frame->vma_use_count++;
  79. frame->v4l2_buf.flags |= V4L2_BUF_FLAG_MAPPED;
  80. }
  81. static void gspca_vm_close(struct vm_area_struct *vma)
  82. {
  83. struct gspca_frame *frame = vma->vm_private_data;
  84. if (--frame->vma_use_count <= 0)
  85. frame->v4l2_buf.flags &= ~V4L2_BUF_FLAG_MAPPED;
  86. }
  87. static const struct vm_operations_struct gspca_vm_ops = {
  88. .open = gspca_vm_open,
  89. .close = gspca_vm_close,
  90. };
  91. /* get the current input frame buffer */
  92. struct gspca_frame *gspca_get_i_frame(struct gspca_dev *gspca_dev)
  93. {
  94. struct gspca_frame *frame;
  95. int i;
  96. i = gspca_dev->fr_i;
  97. i = gspca_dev->fr_queue[i];
  98. frame = &gspca_dev->frame[i];
  99. if ((frame->v4l2_buf.flags & BUF_ALL_FLAGS)
  100. != V4L2_BUF_FLAG_QUEUED)
  101. return NULL;
  102. return frame;
  103. }
  104. EXPORT_SYMBOL(gspca_get_i_frame);
  105. /*
  106. * fill a video frame from an URB and resubmit
  107. */
  108. static void fill_frame(struct gspca_dev *gspca_dev,
  109. struct urb *urb)
  110. {
  111. u8 *data; /* address of data in the iso message */
  112. int i, len, st;
  113. cam_pkt_op pkt_scan;
  114. if (urb->status != 0) {
  115. if (urb->status == -ESHUTDOWN)
  116. return; /* disconnection */
  117. #ifdef CONFIG_PM
  118. if (gspca_dev->frozen)
  119. return;
  120. #endif
  121. PDEBUG(D_ERR|D_PACK, "urb status: %d", urb->status);
  122. urb->status = 0;
  123. goto resubmit;
  124. }
  125. pkt_scan = gspca_dev->sd_desc->pkt_scan;
  126. for (i = 0; i < urb->number_of_packets; i++) {
  127. /* check the packet status and length */
  128. len = urb->iso_frame_desc[i].actual_length;
  129. if (len == 0) {
  130. if (gspca_dev->empty_packet == 0)
  131. gspca_dev->empty_packet = 1;
  132. continue;
  133. }
  134. st = urb->iso_frame_desc[i].status;
  135. if (st) {
  136. PDEBUG(D_ERR,
  137. "ISOC data error: [%d] len=%d, status=%d",
  138. i, len, st);
  139. gspca_dev->last_packet_type = DISCARD_PACKET;
  140. continue;
  141. }
  142. /* let the packet be analyzed by the subdriver */
  143. PDEBUG(D_PACK, "packet [%d] o:%d l:%d",
  144. i, urb->iso_frame_desc[i].offset, len);
  145. data = (u8 *) urb->transfer_buffer
  146. + urb->iso_frame_desc[i].offset;
  147. pkt_scan(gspca_dev, gspca_dev->cur_frame, data, len);
  148. }
  149. resubmit:
  150. /* resubmit the URB */
  151. st = usb_submit_urb(urb, GFP_ATOMIC);
  152. if (st < 0)
  153. PDEBUG(D_ERR|D_PACK, "usb_submit_urb() ret %d", st);
  154. }
  155. /*
  156. * ISOC message interrupt from the USB device
  157. *
  158. * Analyse each packet and call the subdriver for copy to the frame buffer.
  159. */
  160. static void isoc_irq(struct urb *urb)
  161. {
  162. struct gspca_dev *gspca_dev = (struct gspca_dev *) urb->context;
  163. PDEBUG(D_PACK, "isoc irq");
  164. if (!gspca_dev->streaming)
  165. return;
  166. fill_frame(gspca_dev, urb);
  167. }
  168. /*
  169. * bulk message interrupt from the USB device
  170. */
  171. static void bulk_irq(struct urb *urb)
  172. {
  173. struct gspca_dev *gspca_dev = (struct gspca_dev *) urb->context;
  174. int st;
  175. PDEBUG(D_PACK, "bulk irq");
  176. if (!gspca_dev->streaming)
  177. return;
  178. switch (urb->status) {
  179. case 0:
  180. break;
  181. case -ESHUTDOWN:
  182. return; /* disconnection */
  183. default:
  184. #ifdef CONFIG_PM
  185. if (gspca_dev->frozen)
  186. return;
  187. #endif
  188. PDEBUG(D_ERR|D_PACK, "urb status: %d", urb->status);
  189. urb->status = 0;
  190. goto resubmit;
  191. }
  192. PDEBUG(D_PACK, "packet l:%d", urb->actual_length);
  193. gspca_dev->sd_desc->pkt_scan(gspca_dev,
  194. gspca_dev->frame,
  195. urb->transfer_buffer,
  196. urb->actual_length);
  197. resubmit:
  198. /* resubmit the URB */
  199. if (gspca_dev->cam.bulk_nurbs != 0) {
  200. st = usb_submit_urb(urb, GFP_ATOMIC);
  201. if (st < 0)
  202. PDEBUG(D_ERR|D_PACK, "usb_submit_urb() ret %d", st);
  203. }
  204. }
  205. /*
  206. * add data to the current frame
  207. *
  208. * This function is called by the subdrivers at interrupt level.
  209. *
  210. * To build a frame, these ones must add
  211. * - one FIRST_PACKET
  212. * - 0 or many INTER_PACKETs
  213. * - one LAST_PACKET
  214. * DISCARD_PACKET invalidates the whole frame.
  215. * On LAST_PACKET, a new frame is returned.
  216. */
  217. struct gspca_frame *gspca_frame_add(struct gspca_dev *gspca_dev,
  218. enum gspca_packet_type packet_type,
  219. struct gspca_frame *dummy,
  220. const __u8 *data,
  221. int len)
  222. {
  223. struct gspca_frame *frame;
  224. int i, j;
  225. PDEBUG(D_PACK, "add t:%d l:%d", packet_type, len);
  226. /* check the availability of the frame buffer */
  227. frame = gspca_dev->cur_frame;
  228. if ((frame->v4l2_buf.flags & BUF_ALL_FLAGS)
  229. != V4L2_BUF_FLAG_QUEUED) {
  230. gspca_dev->last_packet_type = DISCARD_PACKET;
  231. return frame;
  232. }
  233. /* when start of a new frame, if the current frame buffer
  234. * is not queued, discard the whole frame */
  235. if (packet_type == FIRST_PACKET) {
  236. frame->data_end = frame->data;
  237. jiffies_to_timeval(get_jiffies_64(),
  238. &frame->v4l2_buf.timestamp);
  239. frame->v4l2_buf.sequence = ++gspca_dev->sequence;
  240. } else if (gspca_dev->last_packet_type == DISCARD_PACKET) {
  241. if (packet_type == LAST_PACKET)
  242. gspca_dev->last_packet_type = packet_type;
  243. return frame;
  244. }
  245. /* append the packet to the frame buffer */
  246. if (len > 0) {
  247. if (frame->data_end - frame->data + len
  248. > frame->v4l2_buf.length) {
  249. PDEBUG(D_ERR|D_PACK, "frame overflow %zd > %d",
  250. frame->data_end - frame->data + len,
  251. frame->v4l2_buf.length);
  252. packet_type = DISCARD_PACKET;
  253. } else {
  254. memcpy(frame->data_end, data, len);
  255. frame->data_end += len;
  256. }
  257. }
  258. gspca_dev->last_packet_type = packet_type;
  259. /* if last packet, wake up the application and advance in the queue */
  260. if (packet_type == LAST_PACKET) {
  261. frame->v4l2_buf.bytesused = frame->data_end - frame->data;
  262. frame->v4l2_buf.flags &= ~V4L2_BUF_FLAG_QUEUED;
  263. frame->v4l2_buf.flags |= V4L2_BUF_FLAG_DONE;
  264. wake_up_interruptible(&gspca_dev->wq); /* event = new frame */
  265. i = (gspca_dev->fr_i + 1) % gspca_dev->nframes;
  266. gspca_dev->fr_i = i;
  267. PDEBUG(D_FRAM, "frame complete len:%d q:%d i:%d o:%d",
  268. frame->v4l2_buf.bytesused,
  269. gspca_dev->fr_q,
  270. i,
  271. gspca_dev->fr_o);
  272. j = gspca_dev->fr_queue[i];
  273. gspca_dev->cur_frame = frame = &gspca_dev->frame[j];
  274. }
  275. return frame;
  276. }
  277. EXPORT_SYMBOL(gspca_frame_add);
  278. static int gspca_is_compressed(__u32 format)
  279. {
  280. switch (format) {
  281. case V4L2_PIX_FMT_MJPEG:
  282. case V4L2_PIX_FMT_JPEG:
  283. case V4L2_PIX_FMT_SPCA561:
  284. case V4L2_PIX_FMT_PAC207:
  285. case V4L2_PIX_FMT_MR97310A:
  286. return 1;
  287. }
  288. return 0;
  289. }
  290. static void *rvmalloc(unsigned long size)
  291. {
  292. void *mem;
  293. unsigned long adr;
  294. mem = vmalloc_32(size);
  295. if (mem != NULL) {
  296. adr = (unsigned long) mem;
  297. while ((long) size > 0) {
  298. SetPageReserved(vmalloc_to_page((void *) adr));
  299. adr += PAGE_SIZE;
  300. size -= PAGE_SIZE;
  301. }
  302. }
  303. return mem;
  304. }
  305. static void rvfree(void *mem, long size)
  306. {
  307. unsigned long adr;
  308. adr = (unsigned long) mem;
  309. while (size > 0) {
  310. ClearPageReserved(vmalloc_to_page((void *) adr));
  311. adr += PAGE_SIZE;
  312. size -= PAGE_SIZE;
  313. }
  314. vfree(mem);
  315. }
  316. static int frame_alloc(struct gspca_dev *gspca_dev,
  317. unsigned int count)
  318. {
  319. struct gspca_frame *frame;
  320. unsigned int frsz;
  321. int i;
  322. i = gspca_dev->curr_mode;
  323. frsz = gspca_dev->cam.cam_mode[i].sizeimage;
  324. PDEBUG(D_STREAM, "frame alloc frsz: %d", frsz);
  325. frsz = PAGE_ALIGN(frsz);
  326. gspca_dev->frsz = frsz;
  327. if (count > GSPCA_MAX_FRAMES)
  328. count = GSPCA_MAX_FRAMES;
  329. gspca_dev->frbuf = rvmalloc(frsz * count);
  330. if (!gspca_dev->frbuf) {
  331. err("frame alloc failed");
  332. return -ENOMEM;
  333. }
  334. gspca_dev->nframes = count;
  335. for (i = 0; i < count; i++) {
  336. frame = &gspca_dev->frame[i];
  337. frame->v4l2_buf.index = i;
  338. frame->v4l2_buf.type = V4L2_BUF_TYPE_VIDEO_CAPTURE;
  339. frame->v4l2_buf.flags = 0;
  340. frame->v4l2_buf.field = V4L2_FIELD_NONE;
  341. frame->v4l2_buf.length = frsz;
  342. frame->v4l2_buf.memory = gspca_dev->memory;
  343. frame->v4l2_buf.sequence = 0;
  344. frame->data = frame->data_end =
  345. gspca_dev->frbuf + i * frsz;
  346. frame->v4l2_buf.m.offset = i * frsz;
  347. }
  348. gspca_dev->fr_i = gspca_dev->fr_o = gspca_dev->fr_q = 0;
  349. gspca_dev->cur_frame = &gspca_dev->frame[0];
  350. gspca_dev->last_packet_type = DISCARD_PACKET;
  351. gspca_dev->sequence = 0;
  352. return 0;
  353. }
  354. static void frame_free(struct gspca_dev *gspca_dev)
  355. {
  356. int i;
  357. PDEBUG(D_STREAM, "frame free");
  358. if (gspca_dev->frbuf != NULL) {
  359. rvfree(gspca_dev->frbuf,
  360. gspca_dev->nframes * gspca_dev->frsz);
  361. gspca_dev->frbuf = NULL;
  362. for (i = 0; i < gspca_dev->nframes; i++)
  363. gspca_dev->frame[i].data = NULL;
  364. }
  365. gspca_dev->nframes = 0;
  366. }
  367. static void destroy_urbs(struct gspca_dev *gspca_dev)
  368. {
  369. struct urb *urb;
  370. unsigned int i;
  371. PDEBUG(D_STREAM, "kill transfer");
  372. for (i = 0; i < MAX_NURBS; i++) {
  373. urb = gspca_dev->urb[i];
  374. if (urb == NULL)
  375. break;
  376. gspca_dev->urb[i] = NULL;
  377. usb_kill_urb(urb);
  378. if (urb->transfer_buffer != NULL)
  379. usb_buffer_free(gspca_dev->dev,
  380. urb->transfer_buffer_length,
  381. urb->transfer_buffer,
  382. urb->transfer_dma);
  383. usb_free_urb(urb);
  384. }
  385. }
  386. /*
  387. * look for an input transfer endpoint in an alternate setting
  388. */
  389. static struct usb_host_endpoint *alt_xfer(struct usb_host_interface *alt,
  390. int xfer)
  391. {
  392. struct usb_host_endpoint *ep;
  393. int i, attr;
  394. for (i = 0; i < alt->desc.bNumEndpoints; i++) {
  395. ep = &alt->endpoint[i];
  396. attr = ep->desc.bmAttributes & USB_ENDPOINT_XFERTYPE_MASK;
  397. if (attr == xfer
  398. && ep->desc.wMaxPacketSize != 0)
  399. return ep;
  400. }
  401. return NULL;
  402. }
  403. /*
  404. * look for an input (isoc or bulk) endpoint
  405. *
  406. * The endpoint is defined by the subdriver.
  407. * Use only the first isoc (some Zoran - 0x0572:0x0001 - have two such ep).
  408. * This routine may be called many times when the bandwidth is too small
  409. * (the bandwidth is checked on urb submit).
  410. */
  411. static struct usb_host_endpoint *get_ep(struct gspca_dev *gspca_dev)
  412. {
  413. struct usb_interface *intf;
  414. struct usb_host_endpoint *ep;
  415. int xfer, i, ret;
  416. intf = usb_ifnum_to_if(gspca_dev->dev, gspca_dev->iface);
  417. ep = NULL;
  418. xfer = gspca_dev->cam.bulk ? USB_ENDPOINT_XFER_BULK
  419. : USB_ENDPOINT_XFER_ISOC;
  420. i = gspca_dev->alt; /* previous alt setting */
  421. if (gspca_dev->cam.reverse_alts) {
  422. while (++i < gspca_dev->nbalt) {
  423. ep = alt_xfer(&intf->altsetting[i], xfer);
  424. if (ep)
  425. break;
  426. }
  427. } else {
  428. while (--i >= 0) {
  429. ep = alt_xfer(&intf->altsetting[i], xfer);
  430. if (ep)
  431. break;
  432. }
  433. }
  434. if (ep == NULL) {
  435. err("no transfer endpoint found");
  436. return NULL;
  437. }
  438. PDEBUG(D_STREAM, "use alt %d ep 0x%02x",
  439. i, ep->desc.bEndpointAddress);
  440. gspca_dev->alt = i; /* memorize the current alt setting */
  441. if (gspca_dev->nbalt > 1) {
  442. ret = usb_set_interface(gspca_dev->dev, gspca_dev->iface, i);
  443. if (ret < 0) {
  444. err("set alt %d err %d", i, ret);
  445. return NULL;
  446. }
  447. }
  448. return ep;
  449. }
  450. /*
  451. * create the URBs for image transfer
  452. */
  453. static int create_urbs(struct gspca_dev *gspca_dev,
  454. struct usb_host_endpoint *ep)
  455. {
  456. struct urb *urb;
  457. int n, nurbs, i, psize, npkt, bsize;
  458. /* calculate the packet size and the number of packets */
  459. psize = le16_to_cpu(ep->desc.wMaxPacketSize);
  460. if (!gspca_dev->cam.bulk) { /* isoc */
  461. /* See paragraph 5.9 / table 5-11 of the usb 2.0 spec. */
  462. if (gspca_dev->pkt_size == 0)
  463. psize = (psize & 0x07ff) * (1 + ((psize >> 11) & 3));
  464. else
  465. psize = gspca_dev->pkt_size;
  466. npkt = gspca_dev->cam.npkt;
  467. if (npkt == 0)
  468. npkt = 32; /* default value */
  469. bsize = psize * npkt;
  470. PDEBUG(D_STREAM,
  471. "isoc %d pkts size %d = bsize:%d",
  472. npkt, psize, bsize);
  473. nurbs = DEF_NURBS;
  474. } else { /* bulk */
  475. npkt = 0;
  476. bsize = gspca_dev->cam.bulk_size;
  477. if (bsize == 0)
  478. bsize = psize;
  479. PDEBUG(D_STREAM, "bulk bsize:%d", bsize);
  480. if (gspca_dev->cam.bulk_nurbs != 0)
  481. nurbs = gspca_dev->cam.bulk_nurbs;
  482. else
  483. nurbs = 1;
  484. }
  485. gspca_dev->nurbs = nurbs;
  486. for (n = 0; n < nurbs; n++) {
  487. urb = usb_alloc_urb(npkt, GFP_KERNEL);
  488. if (!urb) {
  489. err("usb_alloc_urb failed");
  490. destroy_urbs(gspca_dev);
  491. return -ENOMEM;
  492. }
  493. urb->transfer_buffer = usb_buffer_alloc(gspca_dev->dev,
  494. bsize,
  495. GFP_KERNEL,
  496. &urb->transfer_dma);
  497. if (urb->transfer_buffer == NULL) {
  498. usb_free_urb(urb);
  499. err("usb_buffer_urb failed");
  500. destroy_urbs(gspca_dev);
  501. return -ENOMEM;
  502. }
  503. gspca_dev->urb[n] = urb;
  504. urb->dev = gspca_dev->dev;
  505. urb->context = gspca_dev;
  506. urb->transfer_buffer_length = bsize;
  507. if (npkt != 0) { /* ISOC */
  508. urb->pipe = usb_rcvisocpipe(gspca_dev->dev,
  509. ep->desc.bEndpointAddress);
  510. urb->transfer_flags = URB_ISO_ASAP
  511. | URB_NO_TRANSFER_DMA_MAP;
  512. urb->interval = ep->desc.bInterval;
  513. urb->complete = isoc_irq;
  514. urb->number_of_packets = npkt;
  515. for (i = 0; i < npkt; i++) {
  516. urb->iso_frame_desc[i].length = psize;
  517. urb->iso_frame_desc[i].offset = psize * i;
  518. }
  519. } else { /* bulk */
  520. urb->pipe = usb_rcvbulkpipe(gspca_dev->dev,
  521. ep->desc.bEndpointAddress),
  522. urb->transfer_flags = URB_NO_TRANSFER_DMA_MAP;
  523. urb->complete = bulk_irq;
  524. }
  525. }
  526. return 0;
  527. }
  528. /*
  529. * start the USB transfer
  530. */
  531. static int gspca_init_transfer(struct gspca_dev *gspca_dev)
  532. {
  533. struct usb_host_endpoint *ep;
  534. int n, ret;
  535. if (mutex_lock_interruptible(&gspca_dev->usb_lock))
  536. return -ERESTARTSYS;
  537. if (!gspca_dev->present) {
  538. ret = -ENODEV;
  539. goto out;
  540. }
  541. /* set the higher alternate setting and
  542. * loop until urb submit succeeds */
  543. if (gspca_dev->cam.reverse_alts)
  544. gspca_dev->alt = 0;
  545. else
  546. gspca_dev->alt = gspca_dev->nbalt;
  547. if (gspca_dev->sd_desc->isoc_init) {
  548. ret = gspca_dev->sd_desc->isoc_init(gspca_dev);
  549. if (ret < 0)
  550. goto out;
  551. }
  552. ep = get_ep(gspca_dev);
  553. if (ep == NULL) {
  554. ret = -EIO;
  555. goto out;
  556. }
  557. for (;;) {
  558. PDEBUG(D_STREAM, "init transfer alt %d", gspca_dev->alt);
  559. ret = create_urbs(gspca_dev, ep);
  560. if (ret < 0)
  561. goto out;
  562. /* clear the bulk endpoint */
  563. if (gspca_dev->cam.bulk)
  564. usb_clear_halt(gspca_dev->dev,
  565. gspca_dev->urb[0]->pipe);
  566. /* start the cam */
  567. ret = gspca_dev->sd_desc->start(gspca_dev);
  568. if (ret < 0) {
  569. destroy_urbs(gspca_dev);
  570. goto out;
  571. }
  572. gspca_dev->streaming = 1;
  573. /* some bulk transfers are started by the subdriver */
  574. if (gspca_dev->cam.bulk && gspca_dev->cam.bulk_nurbs == 0)
  575. break;
  576. /* submit the URBs */
  577. for (n = 0; n < gspca_dev->nurbs; n++) {
  578. ret = usb_submit_urb(gspca_dev->urb[n], GFP_KERNEL);
  579. if (ret < 0)
  580. break;
  581. }
  582. if (ret >= 0)
  583. break;
  584. gspca_dev->streaming = 0;
  585. destroy_urbs(gspca_dev);
  586. if (ret != -ENOSPC) {
  587. PDEBUG(D_ERR|D_STREAM,
  588. "usb_submit_urb alt %d err %d",
  589. gspca_dev->alt, ret);
  590. goto out;
  591. }
  592. /* the bandwidth is not wide enough
  593. * negociate or try a lower alternate setting */
  594. PDEBUG(D_ERR|D_STREAM,
  595. "bandwidth not wide enough - trying again");
  596. msleep(20); /* wait for kill complete */
  597. if (gspca_dev->sd_desc->isoc_nego) {
  598. ret = gspca_dev->sd_desc->isoc_nego(gspca_dev);
  599. if (ret < 0)
  600. goto out;
  601. } else {
  602. ep = get_ep(gspca_dev);
  603. if (ep == NULL) {
  604. ret = -EIO;
  605. goto out;
  606. }
  607. }
  608. }
  609. out:
  610. mutex_unlock(&gspca_dev->usb_lock);
  611. return ret;
  612. }
  613. static int gspca_set_alt0(struct gspca_dev *gspca_dev)
  614. {
  615. int ret;
  616. if (gspca_dev->alt == 0)
  617. return 0;
  618. ret = usb_set_interface(gspca_dev->dev, gspca_dev->iface, 0);
  619. if (ret < 0)
  620. PDEBUG(D_ERR|D_STREAM, "set alt 0 err %d", ret);
  621. return ret;
  622. }
  623. /* Note: both the queue and the usb locks should be held when calling this */
  624. static void gspca_stream_off(struct gspca_dev *gspca_dev)
  625. {
  626. gspca_dev->streaming = 0;
  627. if (gspca_dev->present) {
  628. if (gspca_dev->sd_desc->stopN)
  629. gspca_dev->sd_desc->stopN(gspca_dev);
  630. destroy_urbs(gspca_dev);
  631. gspca_set_alt0(gspca_dev);
  632. }
  633. /* always call stop0 to free the subdriver's resources */
  634. if (gspca_dev->sd_desc->stop0)
  635. gspca_dev->sd_desc->stop0(gspca_dev);
  636. PDEBUG(D_STREAM, "stream off OK");
  637. }
  638. static void gspca_set_default_mode(struct gspca_dev *gspca_dev)
  639. {
  640. int i;
  641. i = gspca_dev->cam.nmodes - 1; /* take the highest mode */
  642. gspca_dev->curr_mode = i;
  643. gspca_dev->width = gspca_dev->cam.cam_mode[i].width;
  644. gspca_dev->height = gspca_dev->cam.cam_mode[i].height;
  645. gspca_dev->pixfmt = gspca_dev->cam.cam_mode[i].pixelformat;
  646. }
  647. static int wxh_to_mode(struct gspca_dev *gspca_dev,
  648. int width, int height)
  649. {
  650. int i;
  651. for (i = gspca_dev->cam.nmodes; --i > 0; ) {
  652. if (width >= gspca_dev->cam.cam_mode[i].width
  653. && height >= gspca_dev->cam.cam_mode[i].height)
  654. break;
  655. }
  656. return i;
  657. }
  658. /*
  659. * search a mode with the right pixel format
  660. */
  661. static int gspca_get_mode(struct gspca_dev *gspca_dev,
  662. int mode,
  663. int pixfmt)
  664. {
  665. int modeU, modeD;
  666. modeU = modeD = mode;
  667. while ((modeU < gspca_dev->cam.nmodes) || modeD >= 0) {
  668. if (--modeD >= 0) {
  669. if (gspca_dev->cam.cam_mode[modeD].pixelformat
  670. == pixfmt)
  671. return modeD;
  672. }
  673. if (++modeU < gspca_dev->cam.nmodes) {
  674. if (gspca_dev->cam.cam_mode[modeU].pixelformat
  675. == pixfmt)
  676. return modeU;
  677. }
  678. }
  679. return -EINVAL;
  680. }
  681. #ifdef CONFIG_VIDEO_ADV_DEBUG
  682. static int vidioc_g_register(struct file *file, void *priv,
  683. struct v4l2_dbg_register *reg)
  684. {
  685. int ret;
  686. struct gspca_dev *gspca_dev = priv;
  687. if (!gspca_dev->sd_desc->get_chip_ident)
  688. return -EINVAL;
  689. if (!gspca_dev->sd_desc->get_register)
  690. return -EINVAL;
  691. if (mutex_lock_interruptible(&gspca_dev->usb_lock))
  692. return -ERESTARTSYS;
  693. if (gspca_dev->present)
  694. ret = gspca_dev->sd_desc->get_register(gspca_dev, reg);
  695. else
  696. ret = -ENODEV;
  697. mutex_unlock(&gspca_dev->usb_lock);
  698. return ret;
  699. }
  700. static int vidioc_s_register(struct file *file, void *priv,
  701. struct v4l2_dbg_register *reg)
  702. {
  703. int ret;
  704. struct gspca_dev *gspca_dev = priv;
  705. if (!gspca_dev->sd_desc->get_chip_ident)
  706. return -EINVAL;
  707. if (!gspca_dev->sd_desc->set_register)
  708. return -EINVAL;
  709. if (mutex_lock_interruptible(&gspca_dev->usb_lock))
  710. return -ERESTARTSYS;
  711. if (gspca_dev->present)
  712. ret = gspca_dev->sd_desc->set_register(gspca_dev, reg);
  713. else
  714. ret = -ENODEV;
  715. mutex_unlock(&gspca_dev->usb_lock);
  716. return ret;
  717. }
  718. #endif
  719. static int vidioc_g_chip_ident(struct file *file, void *priv,
  720. struct v4l2_dbg_chip_ident *chip)
  721. {
  722. int ret;
  723. struct gspca_dev *gspca_dev = priv;
  724. if (!gspca_dev->sd_desc->get_chip_ident)
  725. return -EINVAL;
  726. if (mutex_lock_interruptible(&gspca_dev->usb_lock))
  727. return -ERESTARTSYS;
  728. if (gspca_dev->present)
  729. ret = gspca_dev->sd_desc->get_chip_ident(gspca_dev, chip);
  730. else
  731. ret = -ENODEV;
  732. mutex_unlock(&gspca_dev->usb_lock);
  733. return ret;
  734. }
  735. static int vidioc_enum_fmt_vid_cap(struct file *file, void *priv,
  736. struct v4l2_fmtdesc *fmtdesc)
  737. {
  738. struct gspca_dev *gspca_dev = priv;
  739. int i, j, index;
  740. __u32 fmt_tb[8];
  741. /* give an index to each format */
  742. index = 0;
  743. j = 0;
  744. for (i = gspca_dev->cam.nmodes; --i >= 0; ) {
  745. fmt_tb[index] = gspca_dev->cam.cam_mode[i].pixelformat;
  746. j = 0;
  747. for (;;) {
  748. if (fmt_tb[j] == fmt_tb[index])
  749. break;
  750. j++;
  751. }
  752. if (j == index) {
  753. if (fmtdesc->index == index)
  754. break; /* new format */
  755. index++;
  756. if (index >= ARRAY_SIZE(fmt_tb))
  757. return -EINVAL;
  758. }
  759. }
  760. if (i < 0)
  761. return -EINVAL; /* no more format */
  762. fmtdesc->pixelformat = fmt_tb[index];
  763. if (gspca_is_compressed(fmt_tb[index]))
  764. fmtdesc->flags = V4L2_FMT_FLAG_COMPRESSED;
  765. fmtdesc->description[0] = fmtdesc->pixelformat & 0xff;
  766. fmtdesc->description[1] = (fmtdesc->pixelformat >> 8) & 0xff;
  767. fmtdesc->description[2] = (fmtdesc->pixelformat >> 16) & 0xff;
  768. fmtdesc->description[3] = fmtdesc->pixelformat >> 24;
  769. fmtdesc->description[4] = '\0';
  770. return 0;
  771. }
  772. static int vidioc_g_fmt_vid_cap(struct file *file, void *priv,
  773. struct v4l2_format *fmt)
  774. {
  775. struct gspca_dev *gspca_dev = priv;
  776. int mode;
  777. mode = gspca_dev->curr_mode;
  778. memcpy(&fmt->fmt.pix, &gspca_dev->cam.cam_mode[mode],
  779. sizeof fmt->fmt.pix);
  780. return 0;
  781. }
  782. static int try_fmt_vid_cap(struct gspca_dev *gspca_dev,
  783. struct v4l2_format *fmt)
  784. {
  785. int w, h, mode, mode2;
  786. w = fmt->fmt.pix.width;
  787. h = fmt->fmt.pix.height;
  788. #ifdef GSPCA_DEBUG
  789. if (gspca_debug & D_CONF)
  790. PDEBUG_MODE("try fmt cap", fmt->fmt.pix.pixelformat, w, h);
  791. #endif
  792. /* search the closest mode for width and height */
  793. mode = wxh_to_mode(gspca_dev, w, h);
  794. /* OK if right palette */
  795. if (gspca_dev->cam.cam_mode[mode].pixelformat
  796. != fmt->fmt.pix.pixelformat) {
  797. /* else, search the closest mode with the same pixel format */
  798. mode2 = gspca_get_mode(gspca_dev, mode,
  799. fmt->fmt.pix.pixelformat);
  800. if (mode2 >= 0)
  801. mode = mode2;
  802. /* else
  803. ; * no chance, return this mode */
  804. }
  805. memcpy(&fmt->fmt.pix, &gspca_dev->cam.cam_mode[mode],
  806. sizeof fmt->fmt.pix);
  807. return mode; /* used when s_fmt */
  808. }
  809. static int vidioc_try_fmt_vid_cap(struct file *file,
  810. void *priv,
  811. struct v4l2_format *fmt)
  812. {
  813. struct gspca_dev *gspca_dev = priv;
  814. int ret;
  815. ret = try_fmt_vid_cap(gspca_dev, fmt);
  816. if (ret < 0)
  817. return ret;
  818. return 0;
  819. }
  820. static int vidioc_s_fmt_vid_cap(struct file *file, void *priv,
  821. struct v4l2_format *fmt)
  822. {
  823. struct gspca_dev *gspca_dev = priv;
  824. int ret;
  825. if (mutex_lock_interruptible(&gspca_dev->queue_lock))
  826. return -ERESTARTSYS;
  827. ret = try_fmt_vid_cap(gspca_dev, fmt);
  828. if (ret < 0)
  829. goto out;
  830. if (gspca_dev->nframes != 0
  831. && fmt->fmt.pix.sizeimage > gspca_dev->frsz) {
  832. ret = -EINVAL;
  833. goto out;
  834. }
  835. if (ret == gspca_dev->curr_mode) {
  836. ret = 0;
  837. goto out; /* same mode */
  838. }
  839. if (gspca_dev->streaming) {
  840. ret = -EBUSY;
  841. goto out;
  842. }
  843. gspca_dev->width = fmt->fmt.pix.width;
  844. gspca_dev->height = fmt->fmt.pix.height;
  845. gspca_dev->pixfmt = fmt->fmt.pix.pixelformat;
  846. gspca_dev->curr_mode = ret;
  847. ret = 0;
  848. out:
  849. mutex_unlock(&gspca_dev->queue_lock);
  850. return ret;
  851. }
  852. static int vidioc_enum_framesizes(struct file *file, void *priv,
  853. struct v4l2_frmsizeenum *fsize)
  854. {
  855. struct gspca_dev *gspca_dev = priv;
  856. int i;
  857. __u32 index = 0;
  858. for (i = 0; i < gspca_dev->cam.nmodes; i++) {
  859. if (fsize->pixel_format !=
  860. gspca_dev->cam.cam_mode[i].pixelformat)
  861. continue;
  862. if (fsize->index == index) {
  863. fsize->type = V4L2_FRMSIZE_TYPE_DISCRETE;
  864. fsize->discrete.width =
  865. gspca_dev->cam.cam_mode[i].width;
  866. fsize->discrete.height =
  867. gspca_dev->cam.cam_mode[i].height;
  868. return 0;
  869. }
  870. index++;
  871. }
  872. return -EINVAL;
  873. }
  874. static void gspca_release(struct video_device *vfd)
  875. {
  876. struct gspca_dev *gspca_dev = container_of(vfd, struct gspca_dev, vdev);
  877. PDEBUG(D_PROBE, "/dev/video%d released", gspca_dev->vdev.num);
  878. kfree(gspca_dev->usb_buf);
  879. kfree(gspca_dev);
  880. }
  881. static int dev_open(struct file *file)
  882. {
  883. struct gspca_dev *gspca_dev;
  884. int ret;
  885. PDEBUG(D_STREAM, "[%s] open", current->comm);
  886. gspca_dev = (struct gspca_dev *) video_devdata(file);
  887. if (mutex_lock_interruptible(&gspca_dev->queue_lock))
  888. return -ERESTARTSYS;
  889. if (!gspca_dev->present) {
  890. ret = -ENODEV;
  891. goto out;
  892. }
  893. if (gspca_dev->users > 4) { /* (arbitrary value) */
  894. ret = -EBUSY;
  895. goto out;
  896. }
  897. /* protect the subdriver against rmmod */
  898. if (!try_module_get(gspca_dev->module)) {
  899. ret = -ENODEV;
  900. goto out;
  901. }
  902. gspca_dev->users++;
  903. file->private_data = gspca_dev;
  904. #ifdef GSPCA_DEBUG
  905. /* activate the v4l2 debug */
  906. if (gspca_debug & D_V4L2)
  907. gspca_dev->vdev.debug |= V4L2_DEBUG_IOCTL
  908. | V4L2_DEBUG_IOCTL_ARG;
  909. else
  910. gspca_dev->vdev.debug &= ~(V4L2_DEBUG_IOCTL
  911. | V4L2_DEBUG_IOCTL_ARG);
  912. #endif
  913. ret = 0;
  914. out:
  915. mutex_unlock(&gspca_dev->queue_lock);
  916. if (ret != 0)
  917. PDEBUG(D_ERR|D_STREAM, "open failed err %d", ret);
  918. else
  919. PDEBUG(D_STREAM, "open done");
  920. return ret;
  921. }
  922. static int dev_close(struct file *file)
  923. {
  924. struct gspca_dev *gspca_dev = file->private_data;
  925. PDEBUG(D_STREAM, "[%s] close", current->comm);
  926. if (mutex_lock_interruptible(&gspca_dev->queue_lock))
  927. return -ERESTARTSYS;
  928. gspca_dev->users--;
  929. /* if the file did the capture, free the streaming resources */
  930. if (gspca_dev->capt_file == file) {
  931. if (gspca_dev->streaming) {
  932. mutex_lock(&gspca_dev->usb_lock);
  933. gspca_stream_off(gspca_dev);
  934. mutex_unlock(&gspca_dev->usb_lock);
  935. }
  936. frame_free(gspca_dev);
  937. gspca_dev->capt_file = NULL;
  938. gspca_dev->memory = GSPCA_MEMORY_NO;
  939. }
  940. file->private_data = NULL;
  941. module_put(gspca_dev->module);
  942. mutex_unlock(&gspca_dev->queue_lock);
  943. PDEBUG(D_STREAM, "close done");
  944. return 0;
  945. }
  946. static int vidioc_querycap(struct file *file, void *priv,
  947. struct v4l2_capability *cap)
  948. {
  949. struct gspca_dev *gspca_dev = priv;
  950. int ret;
  951. /* protect the access to the usb device */
  952. if (mutex_lock_interruptible(&gspca_dev->usb_lock))
  953. return -ERESTARTSYS;
  954. if (!gspca_dev->present) {
  955. ret = -ENODEV;
  956. goto out;
  957. }
  958. strncpy(cap->driver, gspca_dev->sd_desc->name, sizeof cap->driver);
  959. if (gspca_dev->dev->product != NULL) {
  960. strncpy(cap->card, gspca_dev->dev->product,
  961. sizeof cap->card);
  962. } else {
  963. snprintf(cap->card, sizeof cap->card,
  964. "USB Camera (%04x:%04x)",
  965. le16_to_cpu(gspca_dev->dev->descriptor.idVendor),
  966. le16_to_cpu(gspca_dev->dev->descriptor.idProduct));
  967. }
  968. usb_make_path(gspca_dev->dev, cap->bus_info, sizeof(cap->bus_info));
  969. cap->version = DRIVER_VERSION_NUMBER;
  970. cap->capabilities = V4L2_CAP_VIDEO_CAPTURE
  971. | V4L2_CAP_STREAMING
  972. | V4L2_CAP_READWRITE;
  973. ret = 0;
  974. out:
  975. mutex_unlock(&gspca_dev->usb_lock);
  976. return ret;
  977. }
  978. static const struct ctrl *get_ctrl(struct gspca_dev *gspca_dev,
  979. int id)
  980. {
  981. const struct ctrl *ctrls;
  982. int i;
  983. for (i = 0, ctrls = gspca_dev->sd_desc->ctrls;
  984. i < gspca_dev->sd_desc->nctrls;
  985. i++, ctrls++) {
  986. if (gspca_dev->ctrl_dis & (1 << i))
  987. continue;
  988. if (id == ctrls->qctrl.id)
  989. return ctrls;
  990. }
  991. return NULL;
  992. }
  993. static int vidioc_queryctrl(struct file *file, void *priv,
  994. struct v4l2_queryctrl *q_ctrl)
  995. {
  996. struct gspca_dev *gspca_dev = priv;
  997. const struct ctrl *ctrls;
  998. int i;
  999. u32 id;
  1000. ctrls = NULL;
  1001. id = q_ctrl->id;
  1002. if (id & V4L2_CTRL_FLAG_NEXT_CTRL) {
  1003. id &= V4L2_CTRL_ID_MASK;
  1004. id++;
  1005. for (i = 0; i < gspca_dev->sd_desc->nctrls; i++) {
  1006. if (gspca_dev->ctrl_dis & (1 << i))
  1007. continue;
  1008. if (gspca_dev->sd_desc->ctrls[i].qctrl.id < id)
  1009. continue;
  1010. if (ctrls && gspca_dev->sd_desc->ctrls[i].qctrl.id
  1011. > ctrls->qctrl.id)
  1012. continue;
  1013. ctrls = &gspca_dev->sd_desc->ctrls[i];
  1014. }
  1015. } else {
  1016. ctrls = get_ctrl(gspca_dev, id);
  1017. i = ctrls - gspca_dev->sd_desc->ctrls;
  1018. }
  1019. if (ctrls == NULL)
  1020. return -EINVAL;
  1021. memcpy(q_ctrl, ctrls, sizeof *q_ctrl);
  1022. if (gspca_dev->ctrl_inac & (1 << i))
  1023. q_ctrl->flags |= V4L2_CTRL_FLAG_INACTIVE;
  1024. return 0;
  1025. }
  1026. static int vidioc_s_ctrl(struct file *file, void *priv,
  1027. struct v4l2_control *ctrl)
  1028. {
  1029. struct gspca_dev *gspca_dev = priv;
  1030. const struct ctrl *ctrls;
  1031. int ret;
  1032. ctrls = get_ctrl(gspca_dev, ctrl->id);
  1033. if (ctrls == NULL)
  1034. return -EINVAL;
  1035. if (ctrl->value < ctrls->qctrl.minimum
  1036. || ctrl->value > ctrls->qctrl.maximum)
  1037. return -ERANGE;
  1038. PDEBUG(D_CONF, "set ctrl [%08x] = %d", ctrl->id, ctrl->value);
  1039. if (mutex_lock_interruptible(&gspca_dev->usb_lock))
  1040. return -ERESTARTSYS;
  1041. if (gspca_dev->present)
  1042. ret = ctrls->set(gspca_dev, ctrl->value);
  1043. else
  1044. ret = -ENODEV;
  1045. mutex_unlock(&gspca_dev->usb_lock);
  1046. return ret;
  1047. }
  1048. static int vidioc_g_ctrl(struct file *file, void *priv,
  1049. struct v4l2_control *ctrl)
  1050. {
  1051. struct gspca_dev *gspca_dev = priv;
  1052. const struct ctrl *ctrls;
  1053. int ret;
  1054. ctrls = get_ctrl(gspca_dev, ctrl->id);
  1055. if (ctrls == NULL)
  1056. return -EINVAL;
  1057. if (mutex_lock_interruptible(&gspca_dev->usb_lock))
  1058. return -ERESTARTSYS;
  1059. if (gspca_dev->present)
  1060. ret = ctrls->get(gspca_dev, &ctrl->value);
  1061. else
  1062. ret = -ENODEV;
  1063. mutex_unlock(&gspca_dev->usb_lock);
  1064. return ret;
  1065. }
  1066. /*fixme: have an audio flag in gspca_dev?*/
  1067. static int vidioc_s_audio(struct file *file, void *priv,
  1068. struct v4l2_audio *audio)
  1069. {
  1070. if (audio->index != 0)
  1071. return -EINVAL;
  1072. return 0;
  1073. }
  1074. static int vidioc_g_audio(struct file *file, void *priv,
  1075. struct v4l2_audio *audio)
  1076. {
  1077. strcpy(audio->name, "Microphone");
  1078. return 0;
  1079. }
  1080. static int vidioc_enumaudio(struct file *file, void *priv,
  1081. struct v4l2_audio *audio)
  1082. {
  1083. if (audio->index != 0)
  1084. return -EINVAL;
  1085. strcpy(audio->name, "Microphone");
  1086. audio->capability = 0;
  1087. audio->mode = 0;
  1088. return 0;
  1089. }
  1090. static int vidioc_querymenu(struct file *file, void *priv,
  1091. struct v4l2_querymenu *qmenu)
  1092. {
  1093. struct gspca_dev *gspca_dev = priv;
  1094. if (!gspca_dev->sd_desc->querymenu)
  1095. return -EINVAL;
  1096. return gspca_dev->sd_desc->querymenu(gspca_dev, qmenu);
  1097. }
  1098. static int vidioc_enum_input(struct file *file, void *priv,
  1099. struct v4l2_input *input)
  1100. {
  1101. struct gspca_dev *gspca_dev = priv;
  1102. if (input->index != 0)
  1103. return -EINVAL;
  1104. input->type = V4L2_INPUT_TYPE_CAMERA;
  1105. input->status = gspca_dev->cam.input_flags;
  1106. strncpy(input->name, gspca_dev->sd_desc->name,
  1107. sizeof input->name);
  1108. return 0;
  1109. }
  1110. static int vidioc_g_input(struct file *file, void *priv, unsigned int *i)
  1111. {
  1112. *i = 0;
  1113. return 0;
  1114. }
  1115. static int vidioc_s_input(struct file *file, void *priv, unsigned int i)
  1116. {
  1117. if (i > 0)
  1118. return -EINVAL;
  1119. return (0);
  1120. }
  1121. static int vidioc_reqbufs(struct file *file, void *priv,
  1122. struct v4l2_requestbuffers *rb)
  1123. {
  1124. struct gspca_dev *gspca_dev = priv;
  1125. int i, ret = 0;
  1126. switch (rb->memory) {
  1127. case GSPCA_MEMORY_READ: /* (internal call) */
  1128. case V4L2_MEMORY_MMAP:
  1129. case V4L2_MEMORY_USERPTR:
  1130. break;
  1131. default:
  1132. return -EINVAL;
  1133. }
  1134. if (mutex_lock_interruptible(&gspca_dev->queue_lock))
  1135. return -ERESTARTSYS;
  1136. if (gspca_dev->memory != GSPCA_MEMORY_NO
  1137. && gspca_dev->memory != rb->memory) {
  1138. ret = -EBUSY;
  1139. goto out;
  1140. }
  1141. /* only one file may do the capture */
  1142. if (gspca_dev->capt_file != NULL
  1143. && gspca_dev->capt_file != file) {
  1144. ret = -EBUSY;
  1145. goto out;
  1146. }
  1147. /* if allocated, the buffers must not be mapped */
  1148. for (i = 0; i < gspca_dev->nframes; i++) {
  1149. if (gspca_dev->frame[i].vma_use_count) {
  1150. ret = -EBUSY;
  1151. goto out;
  1152. }
  1153. }
  1154. /* stop streaming */
  1155. if (gspca_dev->streaming) {
  1156. mutex_lock(&gspca_dev->usb_lock);
  1157. gspca_stream_off(gspca_dev);
  1158. mutex_unlock(&gspca_dev->usb_lock);
  1159. }
  1160. /* free the previous allocated buffers, if any */
  1161. if (gspca_dev->nframes != 0) {
  1162. frame_free(gspca_dev);
  1163. gspca_dev->capt_file = NULL;
  1164. }
  1165. if (rb->count == 0) /* unrequest */
  1166. goto out;
  1167. gspca_dev->memory = rb->memory;
  1168. ret = frame_alloc(gspca_dev, rb->count);
  1169. if (ret == 0) {
  1170. rb->count = gspca_dev->nframes;
  1171. gspca_dev->capt_file = file;
  1172. }
  1173. out:
  1174. mutex_unlock(&gspca_dev->queue_lock);
  1175. PDEBUG(D_STREAM, "reqbufs st:%d c:%d", ret, rb->count);
  1176. return ret;
  1177. }
  1178. static int vidioc_querybuf(struct file *file, void *priv,
  1179. struct v4l2_buffer *v4l2_buf)
  1180. {
  1181. struct gspca_dev *gspca_dev = priv;
  1182. struct gspca_frame *frame;
  1183. if (v4l2_buf->index < 0
  1184. || v4l2_buf->index >= gspca_dev->nframes)
  1185. return -EINVAL;
  1186. frame = &gspca_dev->frame[v4l2_buf->index];
  1187. memcpy(v4l2_buf, &frame->v4l2_buf, sizeof *v4l2_buf);
  1188. return 0;
  1189. }
  1190. static int vidioc_streamon(struct file *file, void *priv,
  1191. enum v4l2_buf_type buf_type)
  1192. {
  1193. struct gspca_dev *gspca_dev = priv;
  1194. int ret;
  1195. if (buf_type != V4L2_BUF_TYPE_VIDEO_CAPTURE)
  1196. return -EINVAL;
  1197. if (mutex_lock_interruptible(&gspca_dev->queue_lock))
  1198. return -ERESTARTSYS;
  1199. if (gspca_dev->nframes == 0
  1200. || !(gspca_dev->frame[0].v4l2_buf.flags & V4L2_BUF_FLAG_QUEUED)) {
  1201. ret = -EINVAL;
  1202. goto out;
  1203. }
  1204. if (!gspca_dev->streaming) {
  1205. ret = gspca_init_transfer(gspca_dev);
  1206. if (ret < 0)
  1207. goto out;
  1208. }
  1209. #ifdef GSPCA_DEBUG
  1210. if (gspca_debug & D_STREAM) {
  1211. PDEBUG_MODE("stream on OK",
  1212. gspca_dev->pixfmt,
  1213. gspca_dev->width,
  1214. gspca_dev->height);
  1215. }
  1216. #endif
  1217. ret = 0;
  1218. out:
  1219. mutex_unlock(&gspca_dev->queue_lock);
  1220. return ret;
  1221. }
  1222. static int vidioc_streamoff(struct file *file, void *priv,
  1223. enum v4l2_buf_type buf_type)
  1224. {
  1225. struct gspca_dev *gspca_dev = priv;
  1226. int i, ret;
  1227. if (buf_type != V4L2_BUF_TYPE_VIDEO_CAPTURE)
  1228. return -EINVAL;
  1229. if (!gspca_dev->streaming)
  1230. return 0;
  1231. if (mutex_lock_interruptible(&gspca_dev->queue_lock))
  1232. return -ERESTARTSYS;
  1233. /* stop streaming */
  1234. if (mutex_lock_interruptible(&gspca_dev->usb_lock)) {
  1235. ret = -ERESTARTSYS;
  1236. goto out;
  1237. }
  1238. gspca_stream_off(gspca_dev);
  1239. mutex_unlock(&gspca_dev->usb_lock);
  1240. /* empty the application queues */
  1241. for (i = 0; i < gspca_dev->nframes; i++)
  1242. gspca_dev->frame[i].v4l2_buf.flags &= ~BUF_ALL_FLAGS;
  1243. gspca_dev->fr_i = gspca_dev->fr_o = gspca_dev->fr_q = 0;
  1244. gspca_dev->last_packet_type = DISCARD_PACKET;
  1245. gspca_dev->sequence = 0;
  1246. ret = 0;
  1247. out:
  1248. mutex_unlock(&gspca_dev->queue_lock);
  1249. return ret;
  1250. }
  1251. static int vidioc_g_jpegcomp(struct file *file, void *priv,
  1252. struct v4l2_jpegcompression *jpegcomp)
  1253. {
  1254. struct gspca_dev *gspca_dev = priv;
  1255. int ret;
  1256. if (!gspca_dev->sd_desc->get_jcomp)
  1257. return -EINVAL;
  1258. if (mutex_lock_interruptible(&gspca_dev->usb_lock))
  1259. return -ERESTARTSYS;
  1260. if (gspca_dev->present)
  1261. ret = gspca_dev->sd_desc->get_jcomp(gspca_dev, jpegcomp);
  1262. else
  1263. ret = -ENODEV;
  1264. mutex_unlock(&gspca_dev->usb_lock);
  1265. return ret;
  1266. }
  1267. static int vidioc_s_jpegcomp(struct file *file, void *priv,
  1268. struct v4l2_jpegcompression *jpegcomp)
  1269. {
  1270. struct gspca_dev *gspca_dev = priv;
  1271. int ret;
  1272. if (!gspca_dev->sd_desc->set_jcomp)
  1273. return -EINVAL;
  1274. if (mutex_lock_interruptible(&gspca_dev->usb_lock))
  1275. return -ERESTARTSYS;
  1276. if (gspca_dev->present)
  1277. ret = gspca_dev->sd_desc->set_jcomp(gspca_dev, jpegcomp);
  1278. else
  1279. ret = -ENODEV;
  1280. mutex_unlock(&gspca_dev->usb_lock);
  1281. return ret;
  1282. }
  1283. static int vidioc_g_parm(struct file *filp, void *priv,
  1284. struct v4l2_streamparm *parm)
  1285. {
  1286. struct gspca_dev *gspca_dev = priv;
  1287. parm->parm.capture.readbuffers = gspca_dev->nbufread;
  1288. if (gspca_dev->sd_desc->get_streamparm) {
  1289. int ret;
  1290. if (mutex_lock_interruptible(&gspca_dev->usb_lock))
  1291. return -ERESTARTSYS;
  1292. if (gspca_dev->present)
  1293. ret = gspca_dev->sd_desc->get_streamparm(gspca_dev,
  1294. parm);
  1295. else
  1296. ret = -ENODEV;
  1297. mutex_unlock(&gspca_dev->usb_lock);
  1298. return ret;
  1299. }
  1300. return 0;
  1301. }
  1302. static int vidioc_s_parm(struct file *filp, void *priv,
  1303. struct v4l2_streamparm *parm)
  1304. {
  1305. struct gspca_dev *gspca_dev = priv;
  1306. int n;
  1307. n = parm->parm.capture.readbuffers;
  1308. if (n == 0 || n > GSPCA_MAX_FRAMES)
  1309. parm->parm.capture.readbuffers = gspca_dev->nbufread;
  1310. else
  1311. gspca_dev->nbufread = n;
  1312. if (gspca_dev->sd_desc->set_streamparm) {
  1313. int ret;
  1314. if (mutex_lock_interruptible(&gspca_dev->usb_lock))
  1315. return -ERESTARTSYS;
  1316. if (gspca_dev->present)
  1317. ret = gspca_dev->sd_desc->set_streamparm(gspca_dev,
  1318. parm);
  1319. else
  1320. ret = -ENODEV;
  1321. mutex_unlock(&gspca_dev->usb_lock);
  1322. return ret;
  1323. }
  1324. return 0;
  1325. }
  1326. #ifdef CONFIG_VIDEO_V4L1_COMPAT
  1327. static int vidiocgmbuf(struct file *file, void *priv,
  1328. struct video_mbuf *mbuf)
  1329. {
  1330. struct gspca_dev *gspca_dev = file->private_data;
  1331. int i;
  1332. PDEBUG(D_STREAM, "cgmbuf");
  1333. if (gspca_dev->nframes == 0) {
  1334. int ret;
  1335. {
  1336. struct v4l2_format fmt;
  1337. fmt.type = V4L2_BUF_TYPE_VIDEO_CAPTURE;
  1338. i = gspca_dev->cam.nmodes - 1; /* highest mode */
  1339. fmt.fmt.pix.width = gspca_dev->cam.cam_mode[i].width;
  1340. fmt.fmt.pix.height = gspca_dev->cam.cam_mode[i].height;
  1341. fmt.fmt.pix.pixelformat = V4L2_PIX_FMT_BGR24;
  1342. ret = vidioc_s_fmt_vid_cap(file, priv, &fmt);
  1343. if (ret != 0)
  1344. return ret;
  1345. }
  1346. {
  1347. struct v4l2_requestbuffers rb;
  1348. memset(&rb, 0, sizeof rb);
  1349. rb.count = 4;
  1350. rb.type = V4L2_BUF_TYPE_VIDEO_CAPTURE;
  1351. rb.memory = V4L2_MEMORY_MMAP;
  1352. ret = vidioc_reqbufs(file, priv, &rb);
  1353. if (ret != 0)
  1354. return ret;
  1355. }
  1356. }
  1357. mbuf->frames = gspca_dev->nframes;
  1358. mbuf->size = gspca_dev->frsz * gspca_dev->nframes;
  1359. for (i = 0; i < mbuf->frames; i++)
  1360. mbuf->offsets[i] = gspca_dev->frame[i].v4l2_buf.m.offset;
  1361. return 0;
  1362. }
  1363. #endif
  1364. static int dev_mmap(struct file *file, struct vm_area_struct *vma)
  1365. {
  1366. struct gspca_dev *gspca_dev = file->private_data;
  1367. struct gspca_frame *frame;
  1368. struct page *page;
  1369. unsigned long addr, start, size;
  1370. int i, ret;
  1371. start = vma->vm_start;
  1372. size = vma->vm_end - vma->vm_start;
  1373. PDEBUG(D_STREAM, "mmap start:%08x size:%d", (int) start, (int) size);
  1374. if (mutex_lock_interruptible(&gspca_dev->queue_lock))
  1375. return -ERESTARTSYS;
  1376. if (!gspca_dev->present) {
  1377. ret = -ENODEV;
  1378. goto out;
  1379. }
  1380. if (gspca_dev->capt_file != file) {
  1381. ret = -EINVAL;
  1382. goto out;
  1383. }
  1384. frame = NULL;
  1385. for (i = 0; i < gspca_dev->nframes; ++i) {
  1386. if (gspca_dev->frame[i].v4l2_buf.memory != V4L2_MEMORY_MMAP) {
  1387. PDEBUG(D_STREAM, "mmap bad memory type");
  1388. break;
  1389. }
  1390. if ((gspca_dev->frame[i].v4l2_buf.m.offset >> PAGE_SHIFT)
  1391. == vma->vm_pgoff) {
  1392. frame = &gspca_dev->frame[i];
  1393. break;
  1394. }
  1395. }
  1396. if (frame == NULL) {
  1397. PDEBUG(D_STREAM, "mmap no frame buffer found");
  1398. ret = -EINVAL;
  1399. goto out;
  1400. }
  1401. #ifdef CONFIG_VIDEO_V4L1_COMPAT
  1402. /* v4l1 maps all the buffers */
  1403. if (i != 0
  1404. || size != frame->v4l2_buf.length * gspca_dev->nframes)
  1405. #endif
  1406. if (size != frame->v4l2_buf.length) {
  1407. PDEBUG(D_STREAM, "mmap bad size");
  1408. ret = -EINVAL;
  1409. goto out;
  1410. }
  1411. /*
  1412. * - VM_IO marks the area as being a mmaped region for I/O to a
  1413. * device. It also prevents the region from being core dumped.
  1414. */
  1415. vma->vm_flags |= VM_IO;
  1416. addr = (unsigned long) frame->data;
  1417. while (size > 0) {
  1418. page = vmalloc_to_page((void *) addr);
  1419. ret = vm_insert_page(vma, start, page);
  1420. if (ret < 0)
  1421. goto out;
  1422. start += PAGE_SIZE;
  1423. addr += PAGE_SIZE;
  1424. size -= PAGE_SIZE;
  1425. }
  1426. vma->vm_ops = (struct vm_operations_struct *) &gspca_vm_ops;
  1427. vma->vm_private_data = frame;
  1428. gspca_vm_open(vma);
  1429. ret = 0;
  1430. out:
  1431. mutex_unlock(&gspca_dev->queue_lock);
  1432. return ret;
  1433. }
  1434. /*
  1435. * wait for a video frame
  1436. *
  1437. * If a frame is ready, its index is returned.
  1438. */
  1439. static int frame_wait(struct gspca_dev *gspca_dev,
  1440. int nonblock_ing)
  1441. {
  1442. struct gspca_frame *frame;
  1443. int i, j, ret;
  1444. /* check if a frame is ready */
  1445. i = gspca_dev->fr_o;
  1446. j = gspca_dev->fr_queue[i];
  1447. frame = &gspca_dev->frame[j];
  1448. if (!(frame->v4l2_buf.flags & V4L2_BUF_FLAG_DONE)) {
  1449. if (nonblock_ing)
  1450. return -EAGAIN;
  1451. /* wait till a frame is ready */
  1452. ret = wait_event_interruptible_timeout(gspca_dev->wq,
  1453. (frame->v4l2_buf.flags & V4L2_BUF_FLAG_DONE) ||
  1454. !gspca_dev->streaming || !gspca_dev->present,
  1455. msecs_to_jiffies(3000));
  1456. if (ret < 0)
  1457. return ret;
  1458. if (ret == 0 || !gspca_dev->streaming || !gspca_dev->present)
  1459. return -EIO;
  1460. }
  1461. gspca_dev->fr_o = (i + 1) % gspca_dev->nframes;
  1462. PDEBUG(D_FRAM, "frame wait q:%d i:%d o:%d",
  1463. gspca_dev->fr_q,
  1464. gspca_dev->fr_i,
  1465. gspca_dev->fr_o);
  1466. if (gspca_dev->sd_desc->dq_callback) {
  1467. mutex_lock(&gspca_dev->usb_lock);
  1468. if (gspca_dev->present)
  1469. gspca_dev->sd_desc->dq_callback(gspca_dev);
  1470. mutex_unlock(&gspca_dev->usb_lock);
  1471. }
  1472. return j;
  1473. }
  1474. /*
  1475. * dequeue a video buffer
  1476. *
  1477. * If nonblock_ing is false, block until a buffer is available.
  1478. */
  1479. static int vidioc_dqbuf(struct file *file, void *priv,
  1480. struct v4l2_buffer *v4l2_buf)
  1481. {
  1482. struct gspca_dev *gspca_dev = priv;
  1483. struct gspca_frame *frame;
  1484. int i, ret;
  1485. PDEBUG(D_FRAM, "dqbuf");
  1486. if (v4l2_buf->memory != gspca_dev->memory)
  1487. return -EINVAL;
  1488. if (!gspca_dev->present)
  1489. return -ENODEV;
  1490. /* if not streaming, be sure the application will not loop forever */
  1491. if (!(file->f_flags & O_NONBLOCK)
  1492. && !gspca_dev->streaming && gspca_dev->users == 1)
  1493. return -EINVAL;
  1494. /* only the capturing file may dequeue */
  1495. if (gspca_dev->capt_file != file)
  1496. return -EINVAL;
  1497. /* only one dequeue / read at a time */
  1498. if (mutex_lock_interruptible(&gspca_dev->read_lock))
  1499. return -ERESTARTSYS;
  1500. ret = frame_wait(gspca_dev, file->f_flags & O_NONBLOCK);
  1501. if (ret < 0)
  1502. goto out;
  1503. i = ret; /* frame index */
  1504. frame = &gspca_dev->frame[i];
  1505. if (gspca_dev->memory == V4L2_MEMORY_USERPTR) {
  1506. if (copy_to_user((__u8 __user *) frame->v4l2_buf.m.userptr,
  1507. frame->data,
  1508. frame->v4l2_buf.bytesused)) {
  1509. PDEBUG(D_ERR|D_STREAM,
  1510. "dqbuf cp to user failed");
  1511. ret = -EFAULT;
  1512. goto out;
  1513. }
  1514. }
  1515. frame->v4l2_buf.flags &= ~V4L2_BUF_FLAG_DONE;
  1516. memcpy(v4l2_buf, &frame->v4l2_buf, sizeof *v4l2_buf);
  1517. PDEBUG(D_FRAM, "dqbuf %d", i);
  1518. ret = 0;
  1519. out:
  1520. mutex_unlock(&gspca_dev->read_lock);
  1521. return ret;
  1522. }
  1523. /*
  1524. * queue a video buffer
  1525. *
  1526. * Attempting to queue a buffer that has already been
  1527. * queued will return -EINVAL.
  1528. */
  1529. static int vidioc_qbuf(struct file *file, void *priv,
  1530. struct v4l2_buffer *v4l2_buf)
  1531. {
  1532. struct gspca_dev *gspca_dev = priv;
  1533. struct gspca_frame *frame;
  1534. int i, index, ret;
  1535. PDEBUG(D_FRAM, "qbuf %d", v4l2_buf->index);
  1536. if (mutex_lock_interruptible(&gspca_dev->queue_lock))
  1537. return -ERESTARTSYS;
  1538. index = v4l2_buf->index;
  1539. if ((unsigned) index >= gspca_dev->nframes) {
  1540. PDEBUG(D_FRAM,
  1541. "qbuf idx %d >= %d", index, gspca_dev->nframes);
  1542. ret = -EINVAL;
  1543. goto out;
  1544. }
  1545. if (v4l2_buf->memory != gspca_dev->memory) {
  1546. PDEBUG(D_FRAM, "qbuf bad memory type");
  1547. ret = -EINVAL;
  1548. goto out;
  1549. }
  1550. frame = &gspca_dev->frame[index];
  1551. if (frame->v4l2_buf.flags & BUF_ALL_FLAGS) {
  1552. PDEBUG(D_FRAM, "qbuf bad state");
  1553. ret = -EINVAL;
  1554. goto out;
  1555. }
  1556. frame->v4l2_buf.flags |= V4L2_BUF_FLAG_QUEUED;
  1557. if (frame->v4l2_buf.memory == V4L2_MEMORY_USERPTR) {
  1558. frame->v4l2_buf.m.userptr = v4l2_buf->m.userptr;
  1559. frame->v4l2_buf.length = v4l2_buf->length;
  1560. }
  1561. /* put the buffer in the 'queued' queue */
  1562. i = gspca_dev->fr_q;
  1563. gspca_dev->fr_queue[i] = index;
  1564. gspca_dev->fr_q = (i + 1) % gspca_dev->nframes;
  1565. PDEBUG(D_FRAM, "qbuf q:%d i:%d o:%d",
  1566. gspca_dev->fr_q,
  1567. gspca_dev->fr_i,
  1568. gspca_dev->fr_o);
  1569. v4l2_buf->flags |= V4L2_BUF_FLAG_QUEUED;
  1570. v4l2_buf->flags &= ~V4L2_BUF_FLAG_DONE;
  1571. ret = 0;
  1572. out:
  1573. mutex_unlock(&gspca_dev->queue_lock);
  1574. return ret;
  1575. }
  1576. /*
  1577. * allocate the resources for read()
  1578. */
  1579. static int read_alloc(struct gspca_dev *gspca_dev,
  1580. struct file *file)
  1581. {
  1582. struct v4l2_buffer v4l2_buf;
  1583. int i, ret;
  1584. PDEBUG(D_STREAM, "read alloc");
  1585. if (gspca_dev->nframes == 0) {
  1586. struct v4l2_requestbuffers rb;
  1587. memset(&rb, 0, sizeof rb);
  1588. rb.count = gspca_dev->nbufread;
  1589. rb.type = V4L2_BUF_TYPE_VIDEO_CAPTURE;
  1590. rb.memory = GSPCA_MEMORY_READ;
  1591. ret = vidioc_reqbufs(file, gspca_dev, &rb);
  1592. if (ret != 0) {
  1593. PDEBUG(D_STREAM, "read reqbuf err %d", ret);
  1594. return ret;
  1595. }
  1596. memset(&v4l2_buf, 0, sizeof v4l2_buf);
  1597. v4l2_buf.type = V4L2_BUF_TYPE_VIDEO_CAPTURE;
  1598. v4l2_buf.memory = GSPCA_MEMORY_READ;
  1599. for (i = 0; i < gspca_dev->nbufread; i++) {
  1600. v4l2_buf.index = i;
  1601. ret = vidioc_qbuf(file, gspca_dev, &v4l2_buf);
  1602. if (ret != 0) {
  1603. PDEBUG(D_STREAM, "read qbuf err: %d", ret);
  1604. return ret;
  1605. }
  1606. }
  1607. gspca_dev->memory = GSPCA_MEMORY_READ;
  1608. }
  1609. /* start streaming */
  1610. ret = vidioc_streamon(file, gspca_dev, V4L2_BUF_TYPE_VIDEO_CAPTURE);
  1611. if (ret != 0)
  1612. PDEBUG(D_STREAM, "read streamon err %d", ret);
  1613. return ret;
  1614. }
  1615. static unsigned int dev_poll(struct file *file, poll_table *wait)
  1616. {
  1617. struct gspca_dev *gspca_dev = file->private_data;
  1618. int i, ret;
  1619. PDEBUG(D_FRAM, "poll");
  1620. poll_wait(file, &gspca_dev->wq, wait);
  1621. /* if reqbufs is not done, the user would use read() */
  1622. if (gspca_dev->nframes == 0) {
  1623. if (gspca_dev->memory != GSPCA_MEMORY_NO)
  1624. return POLLERR; /* not the 1st time */
  1625. ret = read_alloc(gspca_dev, file);
  1626. if (ret != 0)
  1627. return POLLERR;
  1628. }
  1629. if (mutex_lock_interruptible(&gspca_dev->queue_lock) != 0)
  1630. return POLLERR;
  1631. /* check the next incoming buffer */
  1632. i = gspca_dev->fr_o;
  1633. i = gspca_dev->fr_queue[i];
  1634. if (gspca_dev->frame[i].v4l2_buf.flags & V4L2_BUF_FLAG_DONE)
  1635. ret = POLLIN | POLLRDNORM; /* something to read */
  1636. else
  1637. ret = 0;
  1638. mutex_unlock(&gspca_dev->queue_lock);
  1639. if (!gspca_dev->present)
  1640. return POLLHUP;
  1641. return ret;
  1642. }
  1643. static ssize_t dev_read(struct file *file, char __user *data,
  1644. size_t count, loff_t *ppos)
  1645. {
  1646. struct gspca_dev *gspca_dev = file->private_data;
  1647. struct gspca_frame *frame;
  1648. struct v4l2_buffer v4l2_buf;
  1649. struct timeval timestamp;
  1650. int n, ret, ret2;
  1651. PDEBUG(D_FRAM, "read (%zd)", count);
  1652. if (!gspca_dev->present)
  1653. return -ENODEV;
  1654. switch (gspca_dev->memory) {
  1655. case GSPCA_MEMORY_NO: /* first time */
  1656. ret = read_alloc(gspca_dev, file);
  1657. if (ret != 0)
  1658. return ret;
  1659. break;
  1660. case GSPCA_MEMORY_READ:
  1661. if (gspca_dev->capt_file == file)
  1662. break;
  1663. /* fall thru */
  1664. default:
  1665. return -EINVAL;
  1666. }
  1667. /* get a frame */
  1668. jiffies_to_timeval(get_jiffies_64(), &timestamp);
  1669. timestamp.tv_sec--;
  1670. n = 2;
  1671. for (;;) {
  1672. memset(&v4l2_buf, 0, sizeof v4l2_buf);
  1673. v4l2_buf.type = V4L2_BUF_TYPE_VIDEO_CAPTURE;
  1674. v4l2_buf.memory = GSPCA_MEMORY_READ;
  1675. ret = vidioc_dqbuf(file, gspca_dev, &v4l2_buf);
  1676. if (ret != 0) {
  1677. PDEBUG(D_STREAM, "read dqbuf err %d", ret);
  1678. return ret;
  1679. }
  1680. /* if the process slept for more than 1 second,
  1681. * get a newer frame */
  1682. frame = &gspca_dev->frame[v4l2_buf.index];
  1683. if (--n < 0)
  1684. break; /* avoid infinite loop */
  1685. if (frame->v4l2_buf.timestamp.tv_sec >= timestamp.tv_sec)
  1686. break;
  1687. ret = vidioc_qbuf(file, gspca_dev, &v4l2_buf);
  1688. if (ret != 0) {
  1689. PDEBUG(D_STREAM, "read qbuf err %d", ret);
  1690. return ret;
  1691. }
  1692. }
  1693. /* copy the frame */
  1694. if (count > frame->v4l2_buf.bytesused)
  1695. count = frame->v4l2_buf.bytesused;
  1696. ret = copy_to_user(data, frame->data, count);
  1697. if (ret != 0) {
  1698. PDEBUG(D_ERR|D_STREAM,
  1699. "read cp to user lack %d / %zd", ret, count);
  1700. ret = -EFAULT;
  1701. goto out;
  1702. }
  1703. ret = count;
  1704. out:
  1705. /* in each case, requeue the buffer */
  1706. ret2 = vidioc_qbuf(file, gspca_dev, &v4l2_buf);
  1707. if (ret2 != 0)
  1708. return ret2;
  1709. return ret;
  1710. }
  1711. static struct v4l2_file_operations dev_fops = {
  1712. .owner = THIS_MODULE,
  1713. .open = dev_open,
  1714. .release = dev_close,
  1715. .read = dev_read,
  1716. .mmap = dev_mmap,
  1717. .unlocked_ioctl = video_ioctl2,
  1718. .poll = dev_poll,
  1719. };
  1720. static const struct v4l2_ioctl_ops dev_ioctl_ops = {
  1721. .vidioc_querycap = vidioc_querycap,
  1722. .vidioc_dqbuf = vidioc_dqbuf,
  1723. .vidioc_qbuf = vidioc_qbuf,
  1724. .vidioc_enum_fmt_vid_cap = vidioc_enum_fmt_vid_cap,
  1725. .vidioc_try_fmt_vid_cap = vidioc_try_fmt_vid_cap,
  1726. .vidioc_g_fmt_vid_cap = vidioc_g_fmt_vid_cap,
  1727. .vidioc_s_fmt_vid_cap = vidioc_s_fmt_vid_cap,
  1728. .vidioc_streamon = vidioc_streamon,
  1729. .vidioc_queryctrl = vidioc_queryctrl,
  1730. .vidioc_g_ctrl = vidioc_g_ctrl,
  1731. .vidioc_s_ctrl = vidioc_s_ctrl,
  1732. .vidioc_g_audio = vidioc_g_audio,
  1733. .vidioc_s_audio = vidioc_s_audio,
  1734. .vidioc_enumaudio = vidioc_enumaudio,
  1735. .vidioc_querymenu = vidioc_querymenu,
  1736. .vidioc_enum_input = vidioc_enum_input,
  1737. .vidioc_g_input = vidioc_g_input,
  1738. .vidioc_s_input = vidioc_s_input,
  1739. .vidioc_reqbufs = vidioc_reqbufs,
  1740. .vidioc_querybuf = vidioc_querybuf,
  1741. .vidioc_streamoff = vidioc_streamoff,
  1742. .vidioc_g_jpegcomp = vidioc_g_jpegcomp,
  1743. .vidioc_s_jpegcomp = vidioc_s_jpegcomp,
  1744. .vidioc_g_parm = vidioc_g_parm,
  1745. .vidioc_s_parm = vidioc_s_parm,
  1746. .vidioc_enum_framesizes = vidioc_enum_framesizes,
  1747. #ifdef CONFIG_VIDEO_ADV_DEBUG
  1748. .vidioc_g_register = vidioc_g_register,
  1749. .vidioc_s_register = vidioc_s_register,
  1750. #endif
  1751. .vidioc_g_chip_ident = vidioc_g_chip_ident,
  1752. #ifdef CONFIG_VIDEO_V4L1_COMPAT
  1753. .vidiocgmbuf = vidiocgmbuf,
  1754. #endif
  1755. };
  1756. static struct video_device gspca_template = {
  1757. .name = "gspca main driver",
  1758. .fops = &dev_fops,
  1759. .ioctl_ops = &dev_ioctl_ops,
  1760. .release = gspca_release,
  1761. .minor = -1,
  1762. };
  1763. /*
  1764. * probe and create a new gspca device
  1765. *
  1766. * This function must be called by the sub-driver when it is
  1767. * called for probing a new device.
  1768. */
  1769. int gspca_dev_probe(struct usb_interface *intf,
  1770. const struct usb_device_id *id,
  1771. const struct sd_desc *sd_desc,
  1772. int dev_size,
  1773. struct module *module)
  1774. {
  1775. struct usb_interface_descriptor *interface;
  1776. struct gspca_dev *gspca_dev;
  1777. struct usb_device *dev = interface_to_usbdev(intf);
  1778. int ret;
  1779. PDEBUG(D_PROBE, "probing %04x:%04x", id->idVendor, id->idProduct);
  1780. /* we don't handle multi-config cameras */
  1781. if (dev->descriptor.bNumConfigurations != 1) {
  1782. PDEBUG(D_ERR, "Too many config");
  1783. return -ENODEV;
  1784. }
  1785. interface = &intf->cur_altsetting->desc;
  1786. if (interface->bInterfaceNumber > 0) {
  1787. PDEBUG(D_ERR, "intf != 0");
  1788. return -ENODEV;
  1789. }
  1790. /* create the device */
  1791. if (dev_size < sizeof *gspca_dev)
  1792. dev_size = sizeof *gspca_dev;
  1793. gspca_dev = kzalloc(dev_size, GFP_KERNEL);
  1794. if (!gspca_dev) {
  1795. err("couldn't kzalloc gspca struct");
  1796. return -ENOMEM;
  1797. }
  1798. gspca_dev->usb_buf = kmalloc(USB_BUF_SZ, GFP_KERNEL);
  1799. if (!gspca_dev->usb_buf) {
  1800. err("out of memory");
  1801. ret = -ENOMEM;
  1802. goto out;
  1803. }
  1804. gspca_dev->dev = dev;
  1805. gspca_dev->iface = interface->bInterfaceNumber;
  1806. gspca_dev->nbalt = intf->num_altsetting;
  1807. gspca_dev->sd_desc = sd_desc;
  1808. gspca_dev->nbufread = 2;
  1809. gspca_dev->empty_packet = -1; /* don't check the empty packets */
  1810. /* configure the subdriver and initialize the USB device */
  1811. ret = sd_desc->config(gspca_dev, id);
  1812. if (ret < 0)
  1813. goto out;
  1814. ret = sd_desc->init(gspca_dev);
  1815. if (ret < 0)
  1816. goto out;
  1817. ret = gspca_set_alt0(gspca_dev);
  1818. if (ret < 0)
  1819. goto out;
  1820. gspca_set_default_mode(gspca_dev);
  1821. mutex_init(&gspca_dev->usb_lock);
  1822. mutex_init(&gspca_dev->read_lock);
  1823. mutex_init(&gspca_dev->queue_lock);
  1824. init_waitqueue_head(&gspca_dev->wq);
  1825. /* init video stuff */
  1826. memcpy(&gspca_dev->vdev, &gspca_template, sizeof gspca_template);
  1827. gspca_dev->vdev.parent = &intf->dev;
  1828. gspca_dev->module = module;
  1829. gspca_dev->present = 1;
  1830. ret = video_register_device(&gspca_dev->vdev,
  1831. VFL_TYPE_GRABBER,
  1832. -1);
  1833. if (ret < 0) {
  1834. err("video_register_device err %d", ret);
  1835. goto out;
  1836. }
  1837. usb_set_intfdata(intf, gspca_dev);
  1838. PDEBUG(D_PROBE, "/dev/video%d created", gspca_dev->vdev.num);
  1839. return 0;
  1840. out:
  1841. kfree(gspca_dev->usb_buf);
  1842. kfree(gspca_dev);
  1843. return ret;
  1844. }
  1845. EXPORT_SYMBOL(gspca_dev_probe);
  1846. /*
  1847. * USB disconnection
  1848. *
  1849. * This function must be called by the sub-driver
  1850. * when the device disconnects, after the specific resources are freed.
  1851. */
  1852. void gspca_disconnect(struct usb_interface *intf)
  1853. {
  1854. struct gspca_dev *gspca_dev = usb_get_intfdata(intf);
  1855. PDEBUG(D_PROBE, "/dev/video%d disconnect", gspca_dev->vdev.num);
  1856. mutex_lock(&gspca_dev->usb_lock);
  1857. gspca_dev->present = 0;
  1858. if (gspca_dev->streaming) {
  1859. destroy_urbs(gspca_dev);
  1860. wake_up_interruptible(&gspca_dev->wq);
  1861. }
  1862. /* the device is freed at exit of this function */
  1863. gspca_dev->dev = NULL;
  1864. mutex_unlock(&gspca_dev->usb_lock);
  1865. usb_set_intfdata(intf, NULL);
  1866. /* release the device */
  1867. /* (this will call gspca_release() immediatly or on last close) */
  1868. video_unregister_device(&gspca_dev->vdev);
  1869. /* PDEBUG(D_PROBE, "disconnect complete"); */
  1870. }
  1871. EXPORT_SYMBOL(gspca_disconnect);
  1872. #ifdef CONFIG_PM
  1873. int gspca_suspend(struct usb_interface *intf, pm_message_t message)
  1874. {
  1875. struct gspca_dev *gspca_dev = usb_get_intfdata(intf);
  1876. if (!gspca_dev->streaming)
  1877. return 0;
  1878. gspca_dev->frozen = 1; /* avoid urb error messages */
  1879. if (gspca_dev->sd_desc->stopN)
  1880. gspca_dev->sd_desc->stopN(gspca_dev);
  1881. destroy_urbs(gspca_dev);
  1882. gspca_set_alt0(gspca_dev);
  1883. if (gspca_dev->sd_desc->stop0)
  1884. gspca_dev->sd_desc->stop0(gspca_dev);
  1885. return 0;
  1886. }
  1887. EXPORT_SYMBOL(gspca_suspend);
  1888. int gspca_resume(struct usb_interface *intf)
  1889. {
  1890. struct gspca_dev *gspca_dev = usb_get_intfdata(intf);
  1891. gspca_dev->frozen = 0;
  1892. gspca_dev->sd_desc->init(gspca_dev);
  1893. if (gspca_dev->streaming)
  1894. return gspca_init_transfer(gspca_dev);
  1895. return 0;
  1896. }
  1897. EXPORT_SYMBOL(gspca_resume);
  1898. #endif
  1899. /* -- cam driver utility functions -- */
  1900. /* auto gain and exposure algorithm based on the knee algorithm described here:
  1901. http://ytse.tricolour.net/docs/LowLightOptimization.html
  1902. Returns 0 if no changes were made, 1 if the gain and or exposure settings
  1903. where changed. */
  1904. int gspca_auto_gain_n_exposure(struct gspca_dev *gspca_dev, int avg_lum,
  1905. int desired_avg_lum, int deadzone, int gain_knee, int exposure_knee)
  1906. {
  1907. int i, steps, gain, orig_gain, exposure, orig_exposure, autogain;
  1908. const struct ctrl *gain_ctrl = NULL;
  1909. const struct ctrl *exposure_ctrl = NULL;
  1910. const struct ctrl *autogain_ctrl = NULL;
  1911. int retval = 0;
  1912. for (i = 0; i < gspca_dev->sd_desc->nctrls; i++) {
  1913. if (gspca_dev->sd_desc->ctrls[i].qctrl.id == V4L2_CID_GAIN)
  1914. gain_ctrl = &gspca_dev->sd_desc->ctrls[i];
  1915. if (gspca_dev->sd_desc->ctrls[i].qctrl.id == V4L2_CID_EXPOSURE)
  1916. exposure_ctrl = &gspca_dev->sd_desc->ctrls[i];
  1917. if (gspca_dev->sd_desc->ctrls[i].qctrl.id == V4L2_CID_AUTOGAIN)
  1918. autogain_ctrl = &gspca_dev->sd_desc->ctrls[i];
  1919. }
  1920. if (!gain_ctrl || !exposure_ctrl || !autogain_ctrl) {
  1921. PDEBUG(D_ERR, "Error: gspca_auto_gain_n_exposure called "
  1922. "on cam without (auto)gain/exposure");
  1923. return 0;
  1924. }
  1925. if (gain_ctrl->get(gspca_dev, &gain) ||
  1926. exposure_ctrl->get(gspca_dev, &exposure) ||
  1927. autogain_ctrl->get(gspca_dev, &autogain) || !autogain)
  1928. return 0;
  1929. orig_gain = gain;
  1930. orig_exposure = exposure;
  1931. /* If we are of a multiple of deadzone, do multiple steps to reach the
  1932. desired lumination fast (with the risc of a slight overshoot) */
  1933. steps = abs(desired_avg_lum - avg_lum) / deadzone;
  1934. PDEBUG(D_FRAM, "autogain: lum: %d, desired: %d, steps: %d",
  1935. avg_lum, desired_avg_lum, steps);
  1936. for (i = 0; i < steps; i++) {
  1937. if (avg_lum > desired_avg_lum) {
  1938. if (gain > gain_knee)
  1939. gain--;
  1940. else if (exposure > exposure_knee)
  1941. exposure--;
  1942. else if (gain > gain_ctrl->qctrl.default_value)
  1943. gain--;
  1944. else if (exposure > exposure_ctrl->qctrl.minimum)
  1945. exposure--;
  1946. else if (gain > gain_ctrl->qctrl.minimum)
  1947. gain--;
  1948. else
  1949. break;
  1950. } else {
  1951. if (gain < gain_ctrl->qctrl.default_value)
  1952. gain++;
  1953. else if (exposure < exposure_knee)
  1954. exposure++;
  1955. else if (gain < gain_knee)
  1956. gain++;
  1957. else if (exposure < exposure_ctrl->qctrl.maximum)
  1958. exposure++;
  1959. else if (gain < gain_ctrl->qctrl.maximum)
  1960. gain++;
  1961. else
  1962. break;
  1963. }
  1964. }
  1965. if (gain != orig_gain) {
  1966. gain_ctrl->set(gspca_dev, gain);
  1967. retval = 1;
  1968. }
  1969. if (exposure != orig_exposure) {
  1970. exposure_ctrl->set(gspca_dev, exposure);
  1971. retval = 1;
  1972. }
  1973. return retval;
  1974. }
  1975. EXPORT_SYMBOL(gspca_auto_gain_n_exposure);
  1976. /* -- module insert / remove -- */
  1977. static int __init gspca_init(void)
  1978. {
  1979. info("main v%d.%d.%d registered",
  1980. (DRIVER_VERSION_NUMBER >> 16) & 0xff,
  1981. (DRIVER_VERSION_NUMBER >> 8) & 0xff,
  1982. DRIVER_VERSION_NUMBER & 0xff);
  1983. return 0;
  1984. }
  1985. static void __exit gspca_exit(void)
  1986. {
  1987. info("main deregistered");
  1988. }
  1989. module_init(gspca_init);
  1990. module_exit(gspca_exit);
  1991. #ifdef GSPCA_DEBUG
  1992. module_param_named(debug, gspca_debug, int, 0644);
  1993. MODULE_PARM_DESC(debug,
  1994. "Debug (bit) 0x01:error 0x02:probe 0x04:config"
  1995. " 0x08:stream 0x10:frame 0x20:packet 0x40:USBin 0x80:USBout"
  1996. " 0x0100: v4l2");
  1997. #endif