gspca.c 55 KB

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