cx18-streams.c 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660
  1. /*
  2. * cx18 init/start/stop/exit stream functions
  3. *
  4. * Derived from ivtv-streams.c
  5. *
  6. * Copyright (C) 2007 Hans Verkuil <hverkuil@xs4all.nl>
  7. * Copyright (C) 2008 Andy Walls <awalls@radix.net>
  8. *
  9. * This program is free software; you can redistribute it and/or modify
  10. * it under the terms of the GNU General Public License as published by
  11. * the Free Software Foundation; either version 2 of the License, or
  12. * (at your option) any later version.
  13. *
  14. * This program is distributed in the hope that it will be useful,
  15. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  16. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  17. * GNU General Public License for more details.
  18. *
  19. * You should have received a copy of the GNU General Public License
  20. * along with this program; if not, write to the Free Software
  21. * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA
  22. * 02111-1307 USA
  23. */
  24. #include "cx18-driver.h"
  25. #include "cx18-io.h"
  26. #include "cx18-fileops.h"
  27. #include "cx18-mailbox.h"
  28. #include "cx18-i2c.h"
  29. #include "cx18-queue.h"
  30. #include "cx18-ioctl.h"
  31. #include "cx18-streams.h"
  32. #include "cx18-cards.h"
  33. #include "cx18-scb.h"
  34. #include "cx18-av-core.h"
  35. #include "cx18-dvb.h"
  36. #define CX18_DSP0_INTERRUPT_MASK 0xd0004C
  37. static struct file_operations cx18_v4l2_enc_fops = {
  38. .owner = THIS_MODULE,
  39. .read = cx18_v4l2_read,
  40. .open = cx18_v4l2_open,
  41. /* FIXME change to video_ioctl2 if serialization lock can be removed */
  42. .ioctl = cx18_v4l2_ioctl,
  43. .compat_ioctl = v4l_compat_ioctl32,
  44. .release = cx18_v4l2_close,
  45. .poll = cx18_v4l2_enc_poll,
  46. };
  47. /* offset from 0 to register ts v4l2 minors on */
  48. #define CX18_V4L2_ENC_TS_OFFSET 16
  49. /* offset from 0 to register pcm v4l2 minors on */
  50. #define CX18_V4L2_ENC_PCM_OFFSET 24
  51. /* offset from 0 to register yuv v4l2 minors on */
  52. #define CX18_V4L2_ENC_YUV_OFFSET 32
  53. static struct {
  54. const char *name;
  55. int vfl_type;
  56. int num_offset;
  57. int dma;
  58. enum v4l2_buf_type buf_type;
  59. struct file_operations *fops;
  60. } cx18_stream_info[] = {
  61. { /* CX18_ENC_STREAM_TYPE_MPG */
  62. "encoder MPEG",
  63. VFL_TYPE_GRABBER, 0,
  64. PCI_DMA_FROMDEVICE, V4L2_BUF_TYPE_VIDEO_CAPTURE,
  65. &cx18_v4l2_enc_fops
  66. },
  67. { /* CX18_ENC_STREAM_TYPE_TS */
  68. "TS",
  69. VFL_TYPE_GRABBER, -1,
  70. PCI_DMA_FROMDEVICE, V4L2_BUF_TYPE_VIDEO_CAPTURE,
  71. &cx18_v4l2_enc_fops
  72. },
  73. { /* CX18_ENC_STREAM_TYPE_YUV */
  74. "encoder YUV",
  75. VFL_TYPE_GRABBER, CX18_V4L2_ENC_YUV_OFFSET,
  76. PCI_DMA_FROMDEVICE, V4L2_BUF_TYPE_VIDEO_CAPTURE,
  77. &cx18_v4l2_enc_fops
  78. },
  79. { /* CX18_ENC_STREAM_TYPE_VBI */
  80. "encoder VBI",
  81. VFL_TYPE_VBI, 0,
  82. PCI_DMA_FROMDEVICE, V4L2_BUF_TYPE_VBI_CAPTURE,
  83. &cx18_v4l2_enc_fops
  84. },
  85. { /* CX18_ENC_STREAM_TYPE_PCM */
  86. "encoder PCM audio",
  87. VFL_TYPE_GRABBER, CX18_V4L2_ENC_PCM_OFFSET,
  88. PCI_DMA_FROMDEVICE, V4L2_BUF_TYPE_PRIVATE,
  89. &cx18_v4l2_enc_fops
  90. },
  91. { /* CX18_ENC_STREAM_TYPE_IDX */
  92. "encoder IDX",
  93. VFL_TYPE_GRABBER, -1,
  94. PCI_DMA_FROMDEVICE, V4L2_BUF_TYPE_VIDEO_CAPTURE,
  95. &cx18_v4l2_enc_fops
  96. },
  97. { /* CX18_ENC_STREAM_TYPE_RAD */
  98. "encoder radio",
  99. VFL_TYPE_RADIO, 0,
  100. PCI_DMA_NONE, V4L2_BUF_TYPE_PRIVATE,
  101. &cx18_v4l2_enc_fops
  102. },
  103. };
  104. static void cx18_stream_init(struct cx18 *cx, int type)
  105. {
  106. struct cx18_stream *s = &cx->streams[type];
  107. struct video_device *dev = s->v4l2dev;
  108. /* we need to keep v4l2dev, so restore it afterwards */
  109. memset(s, 0, sizeof(*s));
  110. s->v4l2dev = dev;
  111. /* initialize cx18_stream fields */
  112. s->cx = cx;
  113. s->type = type;
  114. s->name = cx18_stream_info[type].name;
  115. s->handle = CX18_INVALID_TASK_HANDLE;
  116. s->dma = cx18_stream_info[type].dma;
  117. s->buffers = cx->stream_buffers[type];
  118. s->buf_size = cx->stream_buf_size[type];
  119. mutex_init(&s->qlock);
  120. init_waitqueue_head(&s->waitq);
  121. s->id = -1;
  122. cx18_queue_init(&s->q_free);
  123. cx18_queue_init(&s->q_busy);
  124. cx18_queue_init(&s->q_full);
  125. }
  126. static int cx18_prep_dev(struct cx18 *cx, int type)
  127. {
  128. struct cx18_stream *s = &cx->streams[type];
  129. u32 cap = cx->v4l2_cap;
  130. int num_offset = cx18_stream_info[type].num_offset;
  131. int num = cx->num + cx18_first_minor + num_offset;
  132. /* These four fields are always initialized. If v4l2dev == NULL, then
  133. this stream is not in use. In that case no other fields but these
  134. four can be used. */
  135. s->v4l2dev = NULL;
  136. s->cx = cx;
  137. s->type = type;
  138. s->name = cx18_stream_info[type].name;
  139. /* Check whether the radio is supported */
  140. if (type == CX18_ENC_STREAM_TYPE_RAD && !(cap & V4L2_CAP_RADIO))
  141. return 0;
  142. /* Check whether VBI is supported */
  143. if (type == CX18_ENC_STREAM_TYPE_VBI &&
  144. !(cap & (V4L2_CAP_VBI_CAPTURE | V4L2_CAP_SLICED_VBI_CAPTURE)))
  145. return 0;
  146. /* User explicitly selected 0 buffers for these streams, so don't
  147. create them. */
  148. if (cx18_stream_info[type].dma != PCI_DMA_NONE &&
  149. cx->stream_buffers[type] == 0) {
  150. CX18_INFO("Disabled %s device\n", cx18_stream_info[type].name);
  151. return 0;
  152. }
  153. cx18_stream_init(cx, type);
  154. if (num_offset == -1)
  155. return 0;
  156. /* allocate and initialize the v4l2 video device structure */
  157. s->v4l2dev = video_device_alloc();
  158. if (s->v4l2dev == NULL) {
  159. CX18_ERR("Couldn't allocate v4l2 video_device for %s\n",
  160. s->name);
  161. return -ENOMEM;
  162. }
  163. snprintf(s->v4l2dev->name, sizeof(s->v4l2dev->name), "cx18-%d",
  164. cx->num);
  165. s->v4l2dev->num = num;
  166. s->v4l2dev->parent = &cx->dev->dev;
  167. s->v4l2dev->fops = cx18_stream_info[type].fops;
  168. s->v4l2dev->release = video_device_release;
  169. s->v4l2dev->tvnorms = V4L2_STD_ALL;
  170. cx18_set_funcs(s->v4l2dev);
  171. return 0;
  172. }
  173. /* Initialize v4l2 variables and register v4l2 devices */
  174. int cx18_streams_setup(struct cx18 *cx)
  175. {
  176. int type, ret;
  177. /* Setup V4L2 Devices */
  178. for (type = 0; type < CX18_MAX_STREAMS; type++) {
  179. /* Prepare device */
  180. ret = cx18_prep_dev(cx, type);
  181. if (ret < 0)
  182. break;
  183. /* Allocate Stream */
  184. ret = cx18_stream_alloc(&cx->streams[type]);
  185. if (ret < 0)
  186. break;
  187. }
  188. if (type == CX18_MAX_STREAMS)
  189. return 0;
  190. /* One or more streams could not be initialized. Clean 'em all up. */
  191. cx18_streams_cleanup(cx, 0);
  192. return ret;
  193. }
  194. static int cx18_reg_dev(struct cx18 *cx, int type)
  195. {
  196. struct cx18_stream *s = &cx->streams[type];
  197. int vfl_type = cx18_stream_info[type].vfl_type;
  198. int num, ret;
  199. /* TODO: Shouldn't this be a VFL_TYPE_TRANSPORT or something?
  200. * We need a VFL_TYPE_TS defined.
  201. */
  202. if (strcmp("TS", s->name) == 0) {
  203. /* just return if no DVB is supported */
  204. if ((cx->card->hw_all & CX18_HW_DVB) == 0)
  205. return 0;
  206. ret = cx18_dvb_register(s);
  207. if (ret < 0) {
  208. CX18_ERR("DVB failed to register\n");
  209. return ret;
  210. }
  211. }
  212. if (s->v4l2dev == NULL)
  213. return 0;
  214. num = s->v4l2dev->num;
  215. /* card number + user defined offset + device offset */
  216. if (type != CX18_ENC_STREAM_TYPE_MPG) {
  217. struct cx18_stream *s_mpg = &cx->streams[CX18_ENC_STREAM_TYPE_MPG];
  218. if (s_mpg->v4l2dev)
  219. num = s_mpg->v4l2dev->num + cx18_stream_info[type].num_offset;
  220. }
  221. /* Register device. First try the desired minor, then any free one. */
  222. ret = video_register_device(s->v4l2dev, vfl_type, num);
  223. if (ret < 0) {
  224. CX18_ERR("Couldn't register v4l2 device for %s kernel number %d\n",
  225. s->name, num);
  226. video_device_release(s->v4l2dev);
  227. s->v4l2dev = NULL;
  228. return ret;
  229. }
  230. num = s->v4l2dev->num;
  231. switch (vfl_type) {
  232. case VFL_TYPE_GRABBER:
  233. CX18_INFO("Registered device video%d for %s (%d x %d kB)\n",
  234. num, s->name, cx->stream_buffers[type],
  235. cx->stream_buf_size[type]/1024);
  236. break;
  237. case VFL_TYPE_RADIO:
  238. CX18_INFO("Registered device radio%d for %s\n",
  239. num, s->name);
  240. break;
  241. case VFL_TYPE_VBI:
  242. if (cx->stream_buffers[type])
  243. CX18_INFO("Registered device vbi%d for %s "
  244. "(%d x %d bytes)\n",
  245. num, s->name, cx->stream_buffers[type],
  246. cx->stream_buf_size[type]);
  247. else
  248. CX18_INFO("Registered device vbi%d for %s\n",
  249. num, s->name);
  250. break;
  251. }
  252. return 0;
  253. }
  254. /* Register v4l2 devices */
  255. int cx18_streams_register(struct cx18 *cx)
  256. {
  257. int type;
  258. int err;
  259. int ret = 0;
  260. /* Register V4L2 devices */
  261. for (type = 0; type < CX18_MAX_STREAMS; type++) {
  262. err = cx18_reg_dev(cx, type);
  263. if (err && ret == 0)
  264. ret = err;
  265. }
  266. if (ret == 0)
  267. return 0;
  268. /* One or more streams could not be initialized. Clean 'em all up. */
  269. cx18_streams_cleanup(cx, 1);
  270. return ret;
  271. }
  272. /* Unregister v4l2 devices */
  273. void cx18_streams_cleanup(struct cx18 *cx, int unregister)
  274. {
  275. struct video_device *vdev;
  276. int type;
  277. /* Teardown all streams */
  278. for (type = 0; type < CX18_MAX_STREAMS; type++) {
  279. if (cx->streams[type].dvb.enabled) {
  280. cx18_dvb_unregister(&cx->streams[type]);
  281. cx->streams[type].dvb.enabled = false;
  282. }
  283. vdev = cx->streams[type].v4l2dev;
  284. cx->streams[type].v4l2dev = NULL;
  285. if (vdev == NULL)
  286. continue;
  287. cx18_stream_free(&cx->streams[type]);
  288. /* Unregister or release device */
  289. if (unregister)
  290. video_unregister_device(vdev);
  291. else
  292. video_device_release(vdev);
  293. }
  294. }
  295. static void cx18_vbi_setup(struct cx18_stream *s)
  296. {
  297. struct cx18 *cx = s->cx;
  298. int raw = cx18_raw_vbi(cx);
  299. u32 data[CX2341X_MBOX_MAX_DATA];
  300. int lines;
  301. if (cx->is_60hz) {
  302. cx->vbi.count = 12;
  303. cx->vbi.start[0] = 10;
  304. cx->vbi.start[1] = 273;
  305. } else { /* PAL/SECAM */
  306. cx->vbi.count = 18;
  307. cx->vbi.start[0] = 6;
  308. cx->vbi.start[1] = 318;
  309. }
  310. /* setup VBI registers */
  311. cx18_av_cmd(cx, VIDIOC_S_FMT, &cx->vbi.in);
  312. /* determine number of lines and total number of VBI bytes.
  313. A raw line takes 1443 bytes: 2 * 720 + 4 byte frame header - 1
  314. The '- 1' byte is probably an unused U or V byte. Or something...
  315. A sliced line takes 51 bytes: 4 byte frame header, 4 byte internal
  316. header, 42 data bytes + checksum (to be confirmed) */
  317. if (raw) {
  318. lines = cx->vbi.count * 2;
  319. } else {
  320. lines = cx->is_60hz ? 24 : 38;
  321. if (cx->is_60hz)
  322. lines += 2;
  323. }
  324. cx->vbi.enc_size = lines *
  325. (raw ? cx->vbi.raw_size : cx->vbi.sliced_size);
  326. data[0] = s->handle;
  327. /* Lines per field */
  328. data[1] = (lines / 2) | ((lines / 2) << 16);
  329. /* bytes per line */
  330. data[2] = (raw ? cx->vbi.raw_size : cx->vbi.sliced_size);
  331. /* Every X number of frames a VBI interrupt arrives
  332. (frames as in 25 or 30 fps) */
  333. data[3] = 1;
  334. /* Setup VBI for the cx25840 digitizer */
  335. if (raw) {
  336. data[4] = 0x20602060;
  337. data[5] = 0x30703070;
  338. } else {
  339. data[4] = 0xB0F0B0F0;
  340. data[5] = 0xA0E0A0E0;
  341. }
  342. CX18_DEBUG_INFO("Setup VBI h: %d lines %x bpl %d fr %d %x %x\n",
  343. data[0], data[1], data[2], data[3], data[4], data[5]);
  344. if (s->type == CX18_ENC_STREAM_TYPE_VBI)
  345. cx18_api(cx, CX18_CPU_SET_RAW_VBI_PARAM, 6, data);
  346. }
  347. struct cx18_queue *cx18_stream_put_buf_fw(struct cx18_stream *s,
  348. struct cx18_buffer *buf)
  349. {
  350. struct cx18 *cx = s->cx;
  351. struct cx18_queue *q;
  352. /* Don't give it to the firmware, if we're not running a capture */
  353. if (s->handle == CX18_INVALID_TASK_HANDLE ||
  354. !test_bit(CX18_F_S_STREAMING, &s->s_flags))
  355. return cx18_enqueue(s, buf, &s->q_free);
  356. q = cx18_enqueue(s, buf, &s->q_busy);
  357. if (q != &s->q_busy)
  358. return q; /* The firmware has the max buffers it can handle */
  359. cx18_buf_sync_for_device(s, buf);
  360. cx18_vapi(cx, CX18_CPU_DE_SET_MDL, 5, s->handle,
  361. (void __iomem *) &cx->scb->cpu_mdl[buf->id] - cx->enc_mem,
  362. 1, buf->id, s->buf_size);
  363. return q;
  364. }
  365. void cx18_stream_load_fw_queue(struct cx18_stream *s)
  366. {
  367. struct cx18_queue *q;
  368. struct cx18_buffer *buf;
  369. if (atomic_read(&s->q_free.buffers) == 0 ||
  370. atomic_read(&s->q_busy.buffers) >= 63)
  371. return;
  372. /* Move from q_free to q_busy notifying the firmware, until the limit */
  373. do {
  374. buf = cx18_dequeue(s, &s->q_free);
  375. if (buf == NULL)
  376. break;
  377. q = cx18_stream_put_buf_fw(s, buf);
  378. } while (atomic_read(&s->q_busy.buffers) < 63 && q == &s->q_busy);
  379. }
  380. int cx18_start_v4l2_encode_stream(struct cx18_stream *s)
  381. {
  382. u32 data[MAX_MB_ARGUMENTS];
  383. struct cx18 *cx = s->cx;
  384. struct list_head *p;
  385. struct cx18_buffer *buf;
  386. int ts = 0;
  387. int captype = 0;
  388. if (s->v4l2dev == NULL && s->dvb.enabled == 0)
  389. return -EINVAL;
  390. CX18_DEBUG_INFO("Start encoder stream %s\n", s->name);
  391. switch (s->type) {
  392. case CX18_ENC_STREAM_TYPE_MPG:
  393. captype = CAPTURE_CHANNEL_TYPE_MPEG;
  394. cx->mpg_data_received = cx->vbi_data_inserted = 0;
  395. cx->dualwatch_jiffies = jiffies;
  396. cx->dualwatch_stereo_mode = cx->params.audio_properties & 0x300;
  397. cx->search_pack_header = 0;
  398. break;
  399. case CX18_ENC_STREAM_TYPE_TS:
  400. captype = CAPTURE_CHANNEL_TYPE_TS;
  401. ts = 1;
  402. break;
  403. case CX18_ENC_STREAM_TYPE_YUV:
  404. captype = CAPTURE_CHANNEL_TYPE_YUV;
  405. break;
  406. case CX18_ENC_STREAM_TYPE_PCM:
  407. captype = CAPTURE_CHANNEL_TYPE_PCM;
  408. break;
  409. case CX18_ENC_STREAM_TYPE_VBI:
  410. captype = cx18_raw_vbi(cx) ?
  411. CAPTURE_CHANNEL_TYPE_VBI : CAPTURE_CHANNEL_TYPE_SLICED_VBI;
  412. cx->vbi.frame = 0;
  413. cx->vbi.inserted_frame = 0;
  414. memset(cx->vbi.sliced_mpeg_size,
  415. 0, sizeof(cx->vbi.sliced_mpeg_size));
  416. break;
  417. default:
  418. return -EINVAL;
  419. }
  420. /* mute/unmute video */
  421. cx18_vapi(cx, CX18_CPU_SET_VIDEO_MUTE, 2,
  422. s->handle, !!test_bit(CX18_F_I_RADIO_USER, &cx->i_flags));
  423. /* Clear Streamoff flags in case left from last capture */
  424. clear_bit(CX18_F_S_STREAMOFF, &s->s_flags);
  425. cx18_vapi_result(cx, data, CX18_CREATE_TASK, 1, CPU_CMD_MASK_CAPTURE);
  426. s->handle = data[0];
  427. cx18_vapi(cx, CX18_CPU_SET_CHANNEL_TYPE, 2, s->handle, captype);
  428. if (atomic_read(&cx->ana_capturing) == 0 && !ts) {
  429. /* Stuff from Windows, we don't know what it is */
  430. cx18_vapi(cx, CX18_CPU_SET_VER_CROP_LINE, 2, s->handle, 0);
  431. cx18_vapi(cx, CX18_CPU_SET_MISC_PARAMETERS, 3, s->handle, 3, 1);
  432. cx18_vapi(cx, CX18_CPU_SET_MISC_PARAMETERS, 3, s->handle, 8, 0);
  433. cx18_vapi(cx, CX18_CPU_SET_MISC_PARAMETERS, 3, s->handle, 4, 1);
  434. cx18_vapi(cx, CX18_CPU_SET_MISC_PARAMETERS, 2, s->handle, 12);
  435. cx18_vapi(cx, CX18_CPU_SET_CAPTURE_LINE_NO, 3,
  436. s->handle, cx->digitizer, cx->digitizer);
  437. /* Setup VBI */
  438. if (cx->v4l2_cap & V4L2_CAP_VBI_CAPTURE)
  439. cx18_vbi_setup(s);
  440. /* assign program index info.
  441. Mask 7: select I/P/B, Num_req: 400 max */
  442. cx18_vapi_result(cx, data, CX18_CPU_SET_INDEXTABLE, 1, 0);
  443. /* Setup API for Stream */
  444. cx2341x_update(cx, cx18_api_func, NULL, &cx->params);
  445. }
  446. if (atomic_read(&cx->tot_capturing) == 0) {
  447. clear_bit(CX18_F_I_EOS, &cx->i_flags);
  448. cx18_write_reg(cx, 7, CX18_DSP0_INTERRUPT_MASK);
  449. }
  450. cx18_vapi(cx, CX18_CPU_DE_SET_MDL_ACK, 3, s->handle,
  451. (void __iomem *)&cx->scb->cpu_mdl_ack[s->type][0] - cx->enc_mem,
  452. (void __iomem *)&cx->scb->cpu_mdl_ack[s->type][1] - cx->enc_mem);
  453. /* Init all the cpu_mdls for this stream */
  454. cx18_flush_queues(s);
  455. mutex_lock(&s->qlock);
  456. list_for_each(p, &s->q_free.list) {
  457. buf = list_entry(p, struct cx18_buffer, list);
  458. cx18_writel(cx, buf->dma_handle,
  459. &cx->scb->cpu_mdl[buf->id].paddr);
  460. cx18_writel(cx, s->buf_size, &cx->scb->cpu_mdl[buf->id].length);
  461. }
  462. mutex_unlock(&s->qlock);
  463. cx18_stream_load_fw_queue(s);
  464. /* begin_capture */
  465. if (cx18_vapi(cx, CX18_CPU_CAPTURE_START, 1, s->handle)) {
  466. CX18_DEBUG_WARN("Error starting capture!\n");
  467. /* Ensure we're really not capturing before releasing MDLs */
  468. if (s->type == CX18_ENC_STREAM_TYPE_MPG)
  469. cx18_vapi(cx, CX18_CPU_CAPTURE_STOP, 2, s->handle, 1);
  470. else
  471. cx18_vapi(cx, CX18_CPU_CAPTURE_STOP, 1, s->handle);
  472. clear_bit(CX18_F_S_STREAMING, &s->s_flags);
  473. /* FIXME - CX18_F_S_STREAMOFF as well? */
  474. cx18_vapi(cx, CX18_CPU_DE_RELEASE_MDL, 1, s->handle);
  475. cx18_vapi(cx, CX18_DESTROY_TASK, 1, s->handle);
  476. s->handle = CX18_INVALID_TASK_HANDLE;
  477. if (atomic_read(&cx->tot_capturing) == 0) {
  478. set_bit(CX18_F_I_EOS, &cx->i_flags);
  479. cx18_write_reg(cx, 5, CX18_DSP0_INTERRUPT_MASK);
  480. }
  481. return -EINVAL;
  482. }
  483. /* you're live! sit back and await interrupts :) */
  484. if (!ts)
  485. atomic_inc(&cx->ana_capturing);
  486. atomic_inc(&cx->tot_capturing);
  487. return 0;
  488. }
  489. void cx18_stop_all_captures(struct cx18 *cx)
  490. {
  491. int i;
  492. for (i = CX18_MAX_STREAMS - 1; i >= 0; i--) {
  493. struct cx18_stream *s = &cx->streams[i];
  494. if (s->v4l2dev == NULL && s->dvb.enabled == 0)
  495. continue;
  496. if (test_bit(CX18_F_S_STREAMING, &s->s_flags))
  497. cx18_stop_v4l2_encode_stream(s, 0);
  498. }
  499. }
  500. int cx18_stop_v4l2_encode_stream(struct cx18_stream *s, int gop_end)
  501. {
  502. struct cx18 *cx = s->cx;
  503. unsigned long then;
  504. if (s->v4l2dev == NULL && s->dvb.enabled == 0)
  505. return -EINVAL;
  506. /* This function assumes that you are allowed to stop the capture
  507. and that we are actually capturing */
  508. CX18_DEBUG_INFO("Stop Capture\n");
  509. if (atomic_read(&cx->tot_capturing) == 0)
  510. return 0;
  511. if (s->type == CX18_ENC_STREAM_TYPE_MPG)
  512. cx18_vapi(cx, CX18_CPU_CAPTURE_STOP, 2, s->handle, !gop_end);
  513. else
  514. cx18_vapi(cx, CX18_CPU_CAPTURE_STOP, 1, s->handle);
  515. then = jiffies;
  516. if (s->type == CX18_ENC_STREAM_TYPE_MPG && gop_end) {
  517. CX18_INFO("ignoring gop_end: not (yet?) supported by the firmware\n");
  518. }
  519. if (s->type != CX18_ENC_STREAM_TYPE_TS)
  520. atomic_dec(&cx->ana_capturing);
  521. atomic_dec(&cx->tot_capturing);
  522. /* Clear capture and no-read bits */
  523. clear_bit(CX18_F_S_STREAMING, &s->s_flags);
  524. /* Tell the CX23418 it can't use our buffers anymore */
  525. cx18_vapi(cx, CX18_CPU_DE_RELEASE_MDL, 1, s->handle);
  526. cx18_vapi(cx, CX18_DESTROY_TASK, 1, s->handle);
  527. s->handle = CX18_INVALID_TASK_HANDLE;
  528. if (atomic_read(&cx->tot_capturing) > 0)
  529. return 0;
  530. cx18_write_reg(cx, 5, CX18_DSP0_INTERRUPT_MASK);
  531. wake_up(&s->waitq);
  532. return 0;
  533. }
  534. u32 cx18_find_handle(struct cx18 *cx)
  535. {
  536. int i;
  537. /* find first available handle to be used for global settings */
  538. for (i = 0; i < CX18_MAX_STREAMS; i++) {
  539. struct cx18_stream *s = &cx->streams[i];
  540. if (s->v4l2dev && (s->handle != CX18_INVALID_TASK_HANDLE))
  541. return s->handle;
  542. }
  543. return CX18_INVALID_TASK_HANDLE;
  544. }
  545. struct cx18_stream *cx18_handle_to_stream(struct cx18 *cx, u32 handle)
  546. {
  547. int i;
  548. struct cx18_stream *s;
  549. if (handle == CX18_INVALID_TASK_HANDLE)
  550. return NULL;
  551. for (i = 0; i < CX18_MAX_STREAMS; i++) {
  552. s = &cx->streams[i];
  553. if (s->handle != handle)
  554. continue;
  555. if (s->v4l2dev || s->dvb.enabled)
  556. return s;
  557. }
  558. return NULL;
  559. }