gspca.c 54 KB

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