gspca.c 54 KB

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