Mercurial > mplayer.hg
annotate libmpdemux/tvi_v4l2.c @ 11744:70b8047bc7df
sync, tested :-P
BTW, xml/pl fails to compile.
author | nauj27 |
---|---|
date | Mon, 05 Jan 2004 10:39:04 +0000 |
parents | 36879e2df6cd |
children | 66e491c35dc8 |
rev | line source |
---|---|
10536 | 1 /* |
2 ** Video 4 Linux 2 input | |
3 ** | |
4 ** This file is part of MPlayer, see http://mplayerhq.hu/ for info. | |
5 ** | |
6 ** (c) 2003 Martin Olschewski <olschewski@zpr.uni-koeln.de> | |
7 ** (c) 2003 Jindrich Makovicka <makovick@kmlinux.fjfi.cvut.cz> | |
8 ** | |
9 ** File licensed under the GPL, see http://www.fsf.org/ for more info. | |
10 ** | |
11 ** Some ideas are based on works from | |
12 ** Alex Beregszaszi <alex@naxine.org> | |
13 ** Gerd Knorr <kraxel@bytesex.org> | |
14 ** | |
15 ** CODE IS UNDER DEVELOPMENT, NO FEATURE REQUESTS PLEASE! | |
16 */ | |
17 | |
18 /* | |
19 | |
20 known issues: | |
21 - norm setting isn't consistent with tvi_v4l | |
22 - the same for volume/bass/treble/balance | |
23 | |
24 */ | |
25 | |
26 #include "config.h" | |
27 | |
28 #if defined(USE_TV) && defined(HAVE_TV_V4L2) | |
29 | |
30 #include <errno.h> | |
31 #include <fcntl.h> | |
32 #include <pthread.h> | |
33 #include <stdio.h> | |
34 #include <string.h> | |
35 #include <sys/ioctl.h> | |
36 #include <sys/mman.h> | |
37 #include <sys/time.h> | |
38 #include <sys/types.h> | |
39 #include <unistd.h> | |
40 #ifdef HAVE_SYS_SYSINFO_H | |
41 #include <sys/sysinfo.h> | |
42 #endif | |
43 #include "videodev2.h" | |
44 #include "../mp_msg.h" | |
45 #include "../libvo/img_format.h" | |
46 #include "../libao2/afmt.h" | |
47 #include "tv.h" | |
48 #include "audio_in.h" | |
49 | |
50 /* information about this file */ | |
51 static tvi_info_t info = { | |
52 "Video 4 Linux 2 input", | |
53 "v4l2", | |
54 "Martin Olschewski <olschewski@zpr.uni-koeln.de>", | |
55 "first try, more to come ;-)" | |
56 }; | |
57 | |
58 struct map { | |
59 struct v4l2_buffer buf; | |
60 void *addr; | |
61 size_t len; | |
62 }; | |
63 | |
64 #define BUFFER_COUNT 6 | |
65 | |
66 /* private data */ | |
67 typedef struct { | |
68 /* video */ | |
69 char *video_dev; | |
70 int video_fd; | |
71 int mp_format; | |
72 struct v4l2_capability capability; | |
73 struct v4l2_input input; | |
74 struct v4l2_format format; | |
75 struct v4l2_standard standard; | |
76 struct v4l2_tuner tuner; | |
77 struct map *map; | |
78 int mapcount; | |
79 int frames; | |
10851 | 80 volatile long long first_frame; |
10536 | 81 long long curr_frame; |
82 /* audio video interleaving ;-) */ | |
83 volatile int streamon; | |
84 pthread_t audio_grabber_thread; | |
85 pthread_mutex_t skew_mutex; | |
86 | |
87 /* 2nd level video buffers */ | |
88 int first; | |
89 int immediate_mode; | |
90 | |
91 int video_buffer_size_max; | |
92 volatile int video_buffer_size_current; | |
93 unsigned char **video_ringbuffer; | |
94 long long *video_timebuffer; | |
95 volatile int video_head; | |
96 volatile int video_tail; | |
97 volatile int video_cnt; | |
98 pthread_t video_grabber_thread; | |
99 pthread_mutex_t video_buffer_mutex; | |
100 | |
101 /* audio */ | |
102 char *audio_dev; | |
103 audio_in_t audio_in; | |
104 | |
105 long long audio_start_time; | |
106 int audio_buffer_size; | |
107 int aud_skew_cnt; | |
108 unsigned char *audio_ringbuffer; | |
109 long long *audio_skew_buffer; | |
10653 | 110 long long *audio_skew_delta_buffer; |
10536 | 111 volatile int audio_head; |
112 volatile int audio_tail; | |
113 volatile int audio_cnt; | |
114 volatile long long audio_skew; | |
115 volatile double audio_skew_factor; | |
116 volatile long long audio_skew_measure_time; | |
117 volatile int audio_drop; | |
118 volatile int shutdown; | |
119 | |
120 double audio_secs_per_block; | |
121 long long audio_skew_total; | |
10653 | 122 long long audio_skew_delta_total; |
10536 | 123 long audio_recv_blocks_total; |
124 long audio_sent_blocks_total; | |
125 } priv_t; | |
126 | |
127 #include "tvi_def.h" | |
128 | |
129 static void *audio_grabber(void *data); | |
130 static void *video_grabber(void *data); | |
131 | |
132 /**********************************************************************\ | |
133 | |
134 Only few of the fourccs are the same in v4l2 and mplayer: | |
135 | |
136 IMGFMT_YVU9 == V4L2_PIX_FMT_YVU410 | |
137 IMGFMT_YV12 == V4L2_PIX_FMT_YVU420 | |
138 IMGFMT_NV12 == V4L2_PIX_FMT_NV12 | |
139 IMGFMT_422P == V4L2_PIX_FMT_YUV422P | |
140 IMGFMT_411P == V4L2_PIX_FMT_YUV411P | |
141 IMGFMT_UYVY == V4L2_PIX_FMT_UYVY | |
142 IMGFMT_Y41P == V4L2_PIX_FMT_Y41P | |
143 | |
144 This may be an useful translation table for some others: | |
145 | |
146 IMGFMT_RGB8 == V4L2_PIX_FMT_RGB332 | |
147 IMGFMT_RGB15 == V4L2_PIX_FMT_RGB555 | |
148 IMGFMT_RGB16 == V4L2_PIX_FMT_RGB565 | |
149 IMGFMT_RGB24 == V4L2_PIX_FMT_RGB24 | |
150 IMGFMT_RGB32 == V4L2_PIX_FMT_RGB32 | |
151 IMGFMT_BGR24 == V4L2_PIX_FMT_BGR24 | |
152 IMGFMT_BGR32 == V4L2_PIX_FMT_BGR32 | |
153 IMGFMT_Y800 == V4L2_PIX_FMT_GREY | |
154 IMGFMT_IF09 == V4L2_PIX_FMT_YUV410 | |
155 IMGFMT_I420 == V4L2_PIX_FMT_YUV420 | |
156 IMGFMT_YUY2 == V4L2_PIX_FMT_YUYV | |
157 | |
158 \**********************************************************************/ | |
159 | |
160 /* | |
161 ** Translate a mplayer fourcc to a video4linux2 pixel format. | |
162 */ | |
163 static int fcc_mp2vl(int fcc) | |
164 { | |
165 switch (fcc) { | |
166 case IMGFMT_RGB8: return V4L2_PIX_FMT_RGB332; | |
167 case IMGFMT_RGB15: return V4L2_PIX_FMT_RGB555; | |
168 case IMGFMT_RGB16: return V4L2_PIX_FMT_RGB565; | |
169 case IMGFMT_RGB24: return V4L2_PIX_FMT_RGB24; | |
170 case IMGFMT_RGB32: return V4L2_PIX_FMT_RGB32; | |
171 case IMGFMT_BGR24: return V4L2_PIX_FMT_BGR24; | |
172 case IMGFMT_BGR32: return V4L2_PIX_FMT_BGR32; | |
173 case IMGFMT_Y800: return V4L2_PIX_FMT_GREY; | |
174 case IMGFMT_IF09: return V4L2_PIX_FMT_YUV410; | |
175 case IMGFMT_I420: return V4L2_PIX_FMT_YUV420; | |
176 case IMGFMT_YUY2: return V4L2_PIX_FMT_YUYV; | |
177 case IMGFMT_YV12: return V4L2_PIX_FMT_YUV420; | |
11657 | 178 case IMGFMT_UYVY: return V4L2_PIX_FMT_UYVY; |
10536 | 179 } |
180 return fcc; | |
181 } | |
182 | |
183 /* | |
184 ** Translate a video4linux2 fourcc aka pixel format to mplayer. | |
185 */ | |
186 static int fcc_vl2mp(int fcc) | |
187 { | |
188 switch (fcc) { | |
189 case V4L2_PIX_FMT_RGB332: return IMGFMT_RGB8; | |
190 case V4L2_PIX_FMT_RGB555: return IMGFMT_RGB15; | |
191 case V4L2_PIX_FMT_RGB565: return IMGFMT_RGB16; | |
192 case V4L2_PIX_FMT_RGB24: return IMGFMT_RGB24; | |
193 case V4L2_PIX_FMT_RGB32: return IMGFMT_RGB32; | |
194 case V4L2_PIX_FMT_BGR24: return IMGFMT_BGR24; | |
195 case V4L2_PIX_FMT_BGR32: return IMGFMT_BGR32; | |
196 case V4L2_PIX_FMT_GREY: return IMGFMT_Y800; | |
197 case V4L2_PIX_FMT_YUV410: return IMGFMT_IF09; | |
198 case V4L2_PIX_FMT_YUV420: return IMGFMT_I420; | |
199 case V4L2_PIX_FMT_YUYV: return IMGFMT_YUY2; | |
11657 | 200 case V4L2_PIX_FMT_UYVY: return IMGFMT_UYVY; |
10536 | 201 } |
202 return fcc; | |
203 } | |
204 | |
205 /* | |
206 ** Translate a video4linux2 fourcc aka pixel format | |
207 ** to a human readable string. | |
208 */ | |
209 static char *pixfmt2name(int pixfmt) | |
210 { | |
211 static char unknown[24]; | |
212 | |
213 switch (pixfmt) { | |
214 case V4L2_PIX_FMT_RGB332: return "RGB332"; | |
215 case V4L2_PIX_FMT_RGB555: return "RGB555"; | |
216 case V4L2_PIX_FMT_RGB565: return "RGB565"; | |
217 case V4L2_PIX_FMT_RGB555X: return "RGB555X"; | |
218 case V4L2_PIX_FMT_RGB565X: return "RGB565X"; | |
219 case V4L2_PIX_FMT_BGR24: return "BGR24"; | |
220 case V4L2_PIX_FMT_RGB24: return "RGB24"; | |
221 case V4L2_PIX_FMT_BGR32: return "BGR32"; | |
222 case V4L2_PIX_FMT_RGB32: return "RGB32"; | |
223 case V4L2_PIX_FMT_GREY: return "GREY"; | |
224 case V4L2_PIX_FMT_YVU410: return "YVU410"; | |
225 case V4L2_PIX_FMT_YVU420: return "YVU420"; | |
226 case V4L2_PIX_FMT_YUYV: return "YUYV"; | |
227 case V4L2_PIX_FMT_UYVY: return "UYVY"; | |
228 /* case V4L2_PIX_FMT_YVU422P: return "YVU422P"; */ | |
229 /* case V4L2_PIX_FMT_YVU411P: return "YVU411P"; */ | |
230 case V4L2_PIX_FMT_YUV422P: return "YUV422P"; | |
231 case V4L2_PIX_FMT_YUV411P: return "YUV411P"; | |
232 case V4L2_PIX_FMT_Y41P: return "Y41P"; | |
233 case V4L2_PIX_FMT_NV12: return "NV12"; | |
234 case V4L2_PIX_FMT_NV21: return "NV21"; | |
235 case V4L2_PIX_FMT_YUV410: return "YUV410"; | |
236 case V4L2_PIX_FMT_YUV420: return "YUV420"; | |
237 case V4L2_PIX_FMT_YYUV: return "YYUV"; | |
238 case V4L2_PIX_FMT_HI240: return "HI240"; | |
239 case V4L2_PIX_FMT_WNVA: return "WNVA"; | |
240 } | |
241 sprintf(unknown, "unknown (0x%x)", pixfmt); | |
242 return unknown; | |
243 } | |
244 | |
245 | |
246 /* | |
247 ** Gives the depth of a video4linux2 fourcc aka pixel format in bits. | |
248 */ | |
249 static int pixfmt2depth(int pixfmt) | |
250 { | |
251 switch (pixfmt) { | |
252 case V4L2_PIX_FMT_RGB332: | |
253 return 8; | |
254 case V4L2_PIX_FMT_RGB555: | |
255 case V4L2_PIX_FMT_RGB565: | |
256 case V4L2_PIX_FMT_RGB555X: | |
257 case V4L2_PIX_FMT_RGB565X: | |
258 return 16; | |
259 case V4L2_PIX_FMT_BGR24: | |
260 case V4L2_PIX_FMT_RGB24: | |
261 return 24; | |
262 case V4L2_PIX_FMT_BGR32: | |
263 case V4L2_PIX_FMT_RGB32: | |
264 return 32; | |
265 case V4L2_PIX_FMT_GREY: | |
266 return 8; | |
267 case V4L2_PIX_FMT_YVU410: | |
268 return 9; | |
269 case V4L2_PIX_FMT_YVU420: | |
270 return 12; | |
271 case V4L2_PIX_FMT_YUYV: | |
272 case V4L2_PIX_FMT_UYVY: | |
273 case V4L2_PIX_FMT_YUV422P: | |
274 case V4L2_PIX_FMT_YUV411P: | |
275 return 16; | |
276 case V4L2_PIX_FMT_Y41P: | |
277 case V4L2_PIX_FMT_NV12: | |
278 case V4L2_PIX_FMT_NV21: | |
279 return 12; | |
280 case V4L2_PIX_FMT_YUV410: | |
281 return 9; | |
282 case V4L2_PIX_FMT_YUV420: | |
283 return 12; | |
284 case V4L2_PIX_FMT_YYUV: | |
285 return 16; | |
286 case V4L2_PIX_FMT_HI240: | |
287 return 8; | |
288 | |
289 } | |
290 return 0; | |
291 } | |
292 | |
293 static int amode2v4l(int amode) | |
294 { | |
295 switch (amode) { | |
296 case 0: | |
297 return V4L2_TUNER_MODE_MONO; | |
298 case 1: | |
299 return V4L2_TUNER_MODE_STEREO; | |
300 case 2: | |
301 return V4L2_TUNER_MODE_LANG1; | |
302 case 3: | |
303 return V4L2_TUNER_MODE_LANG2; | |
304 default: | |
305 return -1; | |
306 } | |
307 } | |
308 | |
309 | |
310 // sets and sanitizes audio buffer/block sizes | |
311 static void setup_audio_buffer_sizes(priv_t *priv) | |
312 { | |
313 int bytes_per_sample = priv->audio_in.bytes_per_sample; | |
314 double fps = priv->standard.frameperiod.denominator / | |
315 priv->standard.frameperiod.numerator; | |
316 int seconds = priv->video_buffer_size_max/fps; | |
317 | |
318 if (seconds < 5) seconds = 5; | |
319 if (seconds > 500) seconds = 500; | |
320 | |
321 // make the audio buffer at least as the video buffer capacity (or 5 seconds) long | |
322 priv->audio_buffer_size = 1 + seconds*priv->audio_in.samplerate | |
323 *priv->audio_in.channels | |
324 *bytes_per_sample/priv->audio_in.blocksize; | |
325 if (priv->audio_buffer_size < 256) priv->audio_buffer_size = 256; | |
326 | |
327 // make the skew buffer at least 1 second long | |
328 priv->aud_skew_cnt = 1 + 1*priv->audio_in.samplerate | |
329 *priv->audio_in.channels | |
330 *bytes_per_sample/priv->audio_in.blocksize; | |
331 if (priv->aud_skew_cnt < 16) priv->aud_skew_cnt = 16; | |
332 | |
333 mp_msg(MSGT_TV, MSGL_V, "Audio capture - buffer %d blocks of %d bytes, skew average from %d meas.\n", | |
334 priv->audio_buffer_size, priv->audio_in.blocksize, priv->aud_skew_cnt); | |
335 } | |
336 | |
337 #if 0 | |
338 /* | |
339 ** the number of milliseconds elapsed between time0 and time1 | |
340 */ | |
341 static size_t difftv(struct timeval time1, struct timeval time0) | |
342 { | |
343 return (time1.tv_sec - time0.tv_sec) * 1000 + | |
344 (time1.tv_usec - time0.tv_usec) / 1000; | |
345 } | |
346 #endif | |
347 | |
348 /* | |
349 ** Get current video capture format. | |
350 */ | |
351 static int getfmt(priv_t *priv) | |
352 { | |
353 int i; | |
354 | |
355 priv->format.type = V4L2_BUF_TYPE_VIDEO_CAPTURE; | |
356 if ((i = ioctl(priv->video_fd, VIDIOC_G_FMT, &priv->format)) < 0) { | |
357 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl get format failed: %s\n", | |
358 info.short_name, strerror(errno)); | |
359 } | |
360 return i; | |
361 } | |
362 | |
363 | |
364 /* | |
365 ** Get current video capture standard. | |
366 */ | |
367 static int getstd(priv_t *priv) | |
368 { | |
369 v4l2_std_id id; | |
370 int i=0; | |
371 | |
372 if (ioctl(priv->video_fd, VIDIOC_G_STD, &id) < 0) { | |
373 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl get standard failed: %s\n", | |
374 info.short_name, strerror(errno)); | |
375 return -1; | |
376 } | |
377 do { | |
378 priv->standard.index = i++; | |
379 if (ioctl(priv->video_fd, VIDIOC_ENUMSTD, &priv->standard) < 0) { | |
380 return -1; | |
381 } | |
382 } while (priv->standard.id != id); | |
383 return 0; | |
384 } | |
385 | |
386 /***********************************************************************\ | |
387 * * | |
388 * * | |
389 * Interface to mplayer * | |
390 * * | |
391 * * | |
392 \***********************************************************************/ | |
393 | |
394 static int set_mute(priv_t *priv, int value) | |
395 { | |
396 struct v4l2_control control; | |
397 control.id = V4L2_CID_AUDIO_MUTE; | |
398 control.value = value; | |
399 if (ioctl(priv->video_fd, VIDIOC_S_CTRL, &control) < 0) { | |
400 mp_msg(MSGT_TV,MSGL_ERR,"%s: ioctl set mute failed: %s\n", | |
401 info.short_name, strerror(errno)); | |
402 return 0; | |
403 } | |
404 return 1; | |
405 } | |
406 | |
407 /* | |
408 ** Mplayer uses values from -100 up to 100 for controls. | |
409 ** Here they are scaled to what the tv card needs and applied. | |
410 */ | |
411 static int set_control(priv_t *priv, struct v4l2_control *control, int val_signed) { | |
412 struct v4l2_queryctrl qctrl; | |
413 | |
414 qctrl.id = control->id; | |
415 if (ioctl(priv->video_fd, VIDIOC_QUERYCTRL, &qctrl) < 0) { | |
416 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl query control failed: %s\n", | |
417 info.short_name, strerror(errno)); | |
418 return TVI_CONTROL_FALSE; | |
419 } | |
420 | |
421 if (val_signed) { | |
422 if (control->value < 0) { | |
423 control->value = qctrl.default_value + control->value * | |
424 (qctrl.default_value - qctrl.minimum) / 100; | |
425 } else { | |
426 control->value = qctrl.default_value + control->value * | |
427 (qctrl.maximum - qctrl.default_value) / 100; | |
428 } | |
429 } else { | |
430 if (control->value < 50) { | |
431 control->value = qctrl.default_value + (control->value-50) * | |
432 (qctrl.default_value - qctrl.minimum) / 50; | |
433 } else { | |
434 control->value = qctrl.default_value + (control->value-50) * | |
435 (qctrl.maximum - qctrl.default_value) / 50; | |
436 } | |
437 } | |
438 | |
439 | |
440 if (ioctl(priv->video_fd, VIDIOC_S_CTRL, control) < 0) { | |
441 mp_msg(MSGT_TV, MSGL_ERR,"%s: ioctl set %s %d failed: %s\n", | |
442 info.short_name, qctrl.name, control->value, strerror(errno)); | |
443 return TVI_CONTROL_FALSE; | |
444 } | |
445 mp_msg(MSGT_TV, MSGL_V, "%s: set %s: %d [%d, %d]\n", info.short_name, | |
446 qctrl.name, control->value, qctrl.minimum, qctrl.maximum); | |
447 | |
448 return TVI_CONTROL_TRUE; | |
449 } | |
450 | |
451 | |
452 /* | |
453 ** Scale the control values back to what mplayer needs. | |
454 */ | |
455 static int get_control(priv_t *priv, struct v4l2_control *control, int val_signed) { | |
456 struct v4l2_queryctrl qctrl; | |
457 | |
458 qctrl.id = control->id; | |
459 if (ioctl(priv->video_fd, VIDIOC_QUERYCTRL, &qctrl) < 0) { | |
460 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl query control failed: %s\n", | |
461 info.short_name, strerror(errno)); | |
462 return TVI_CONTROL_FALSE; | |
463 } | |
464 | |
465 if (ioctl(priv->video_fd, VIDIOC_G_CTRL, control) < 0) { | |
466 mp_msg(MSGT_TV, MSGL_ERR,"%s: ioctl get %s failed: %s\n", | |
467 info.short_name, qctrl.name, strerror(errno)); | |
468 return TVI_CONTROL_FALSE; | |
469 } | |
470 mp_msg(MSGT_TV, MSGL_V, "%s: get %s: %d [%d, %d]\n", info.short_name, | |
471 qctrl.name, control->value, qctrl.minimum, qctrl.maximum); | |
472 | |
473 if (val_signed) { | |
474 if (control->value < qctrl.default_value) { | |
475 control->value = (control->value - qctrl.default_value) * 100 / | |
476 (qctrl.default_value - qctrl.minimum); | |
477 } else { | |
478 control->value = (control->value - qctrl.default_value) * 100 / | |
479 (qctrl.maximum - qctrl.default_value); | |
480 } | |
481 } else { | |
482 if (control->value < qctrl.default_value) { | |
483 control->value = (control->value - qctrl.default_value) * 50 / | |
484 (qctrl.default_value - qctrl.minimum) + 50; | |
485 } else { | |
486 control->value = (control->value - qctrl.default_value) * 50 / | |
487 (qctrl.maximum - qctrl.default_value) + 50; | |
488 } | |
489 } | |
490 | |
491 return TVI_CONTROL_TRUE; | |
492 } | |
493 | |
494 static int control(priv_t *priv, int cmd, void *arg) | |
495 { | |
496 struct v4l2_control control; | |
497 struct v4l2_frequency frequency; | |
498 | |
499 switch(cmd) { | |
500 case TVI_CONTROL_IS_AUDIO: | |
501 if (tv_param_force_audio) return TVI_CONTROL_TRUE; | |
502 return priv->input.audioset ? TVI_CONTROL_TRUE: TVI_CONTROL_FALSE; | |
503 case TVI_CONTROL_IS_VIDEO: | |
504 return priv->capability.capabilities & V4L2_CAP_VIDEO_CAPTURE? | |
505 TVI_CONTROL_TRUE: TVI_CONTROL_FALSE; | |
506 case TVI_CONTROL_IS_TUNER: | |
507 return priv->capability.capabilities & V4L2_CAP_TUNER? | |
508 TVI_CONTROL_TRUE: TVI_CONTROL_FALSE; | |
509 case TVI_CONTROL_IMMEDIATE: | |
510 priv->immediate_mode = 1; | |
511 return TVI_CONTROL_TRUE; | |
512 case TVI_CONTROL_VID_GET_FPS: | |
513 *(float *)arg = priv->standard.frameperiod.denominator / | |
514 priv->standard.frameperiod.numerator; | |
515 mp_msg(MSGT_TV, MSGL_V, "%s: get fps: %f\n", info.short_name, | |
516 *(float *)arg); | |
517 return TVI_CONTROL_TRUE; | |
518 case TVI_CONTROL_VID_GET_BITS: | |
519 if (getfmt(priv) < 0) return TVI_CONTROL_FALSE; | |
520 *(int *)arg = pixfmt2depth(priv->format.fmt.pix.pixelformat); | |
521 mp_msg(MSGT_TV, MSGL_V, "%s: get depth: %d\n", info.short_name, | |
522 *(int *)arg); | |
523 return TVI_CONTROL_TRUE; | |
524 case TVI_CONTROL_VID_GET_FORMAT: | |
525 if (getfmt(priv) < 0) return TVI_CONTROL_FALSE; | |
526 if (priv->mp_format == IMGFMT_YV12 && priv->format.fmt.pix.pixelformat == V4L2_PIX_FMT_YUV420) { | |
527 *(int *)arg = IMGFMT_YV12; | |
528 } else { | |
529 *(int *)arg = fcc_vl2mp(priv->format.fmt.pix.pixelformat); | |
530 } | |
531 mp_msg(MSGT_TV, MSGL_V, "%s: get format: %s\n", info.short_name, | |
532 pixfmt2name(priv->format.fmt.pix.pixelformat)); | |
533 return TVI_CONTROL_TRUE; | |
534 case TVI_CONTROL_VID_SET_FORMAT: | |
535 if (getfmt(priv) < 0) return TVI_CONTROL_FALSE; | |
536 priv->format.fmt.pix.pixelformat = fcc_mp2vl(*(int *)arg); | |
537 priv->format.fmt.pix.field = V4L2_FIELD_ANY; | |
538 | |
539 priv->mp_format = *(int *)arg; | |
540 mp_msg(MSGT_TV, MSGL_V, "%s: set format: %s\n", info.short_name, | |
541 pixfmt2name(priv->format.fmt.pix.pixelformat)); | |
542 if (ioctl(priv->video_fd, VIDIOC_S_FMT, &priv->format) < 0) { | |
543 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl set format failed: %s\n", | |
544 info.short_name, strerror(errno)); | |
545 return TVI_CONTROL_FALSE; | |
546 } | |
547 return TVI_CONTROL_TRUE; | |
548 case TVI_CONTROL_VID_GET_WIDTH: | |
549 if (getfmt(priv) < 0) return TVI_CONTROL_FALSE; | |
550 *(int *)arg = priv->format.fmt.pix.width; | |
551 mp_msg(MSGT_TV, MSGL_V, "%s: get width: %d\n", info.short_name, | |
552 *(int *)arg); | |
553 return TVI_CONTROL_TRUE; | |
554 case TVI_CONTROL_VID_CHK_WIDTH: | |
555 return TVI_CONTROL_TRUE; | |
556 case TVI_CONTROL_VID_SET_WIDTH: | |
557 if (getfmt(priv) < 0) return TVI_CONTROL_FALSE; | |
558 priv->format.fmt.pix.width = *(int *)arg; | |
559 mp_msg(MSGT_TV, MSGL_V, "%s: set width: %d\n", info.short_name, | |
560 *(int *)arg); | |
561 if (ioctl(priv->video_fd, VIDIOC_S_FMT, &priv->format) < 0) { | |
562 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl set width failed: %s\n", | |
563 info.short_name, strerror(errno)); | |
564 return TVI_CONTROL_FALSE; | |
565 } | |
566 return TVI_CONTROL_TRUE; | |
567 case TVI_CONTROL_VID_GET_HEIGHT: | |
568 if (getfmt(priv) < 0) return TVI_CONTROL_FALSE; | |
569 *(int *)arg = priv->format.fmt.pix.height; | |
570 mp_msg(MSGT_TV, MSGL_V, "%s: get height: %d\n", info.short_name, | |
571 *(int *)arg); | |
572 return TVI_CONTROL_TRUE; | |
573 case TVI_CONTROL_VID_CHK_HEIGHT: | |
574 return TVI_CONTROL_TRUE; | |
575 case TVI_CONTROL_VID_SET_HEIGHT: | |
576 if (getfmt(priv) < 0) return TVI_CONTROL_FALSE; | |
577 priv->format.fmt.pix.height = *(int *)arg; | |
578 mp_msg(MSGT_TV, MSGL_V, "%s: set height: %d\n", info.short_name, | |
579 *(int *)arg); | |
580 if (ioctl(priv->video_fd, VIDIOC_S_FMT, &priv->format) < 0) { | |
581 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl set height failed: %s\n", | |
582 info.short_name, strerror(errno)); | |
583 return TVI_CONTROL_FALSE; | |
584 } | |
585 return TVI_CONTROL_TRUE; | |
586 case TVI_CONTROL_VID_GET_BRIGHTNESS: | |
587 control.id = V4L2_CID_BRIGHTNESS; | |
588 if (get_control(priv, &control, 1) == TVI_CONTROL_TRUE) { | |
589 *(int *)arg = control.value; | |
590 return TVI_CONTROL_TRUE; | |
591 } | |
592 return TVI_CONTROL_FALSE; | |
593 case TVI_CONTROL_VID_SET_BRIGHTNESS: | |
594 control.id = V4L2_CID_BRIGHTNESS; | |
595 control.value = *(int *)arg; | |
596 return set_control(priv, &control, 1); | |
597 case TVI_CONTROL_VID_GET_HUE: | |
598 control.id = V4L2_CID_HUE; | |
599 if (get_control(priv, &control, 1) == TVI_CONTROL_TRUE) { | |
600 *(int *)arg = control.value; | |
601 return TVI_CONTROL_TRUE; | |
602 } | |
603 return TVI_CONTROL_FALSE; | |
604 case TVI_CONTROL_VID_SET_HUE: | |
605 control.id = V4L2_CID_HUE; | |
606 control.value = *(int *)arg; | |
607 return set_control(priv, &control, 1); | |
608 case TVI_CONTROL_VID_GET_SATURATION: | |
609 control.id = V4L2_CID_SATURATION; | |
610 if (get_control(priv, &control, 1) == TVI_CONTROL_TRUE) { | |
611 *(int *)arg = control.value; | |
612 return TVI_CONTROL_TRUE; | |
613 } | |
614 return TVI_CONTROL_FALSE; | |
615 case TVI_CONTROL_VID_SET_SATURATION: | |
616 control.id = V4L2_CID_SATURATION; | |
617 control.value = *(int *)arg; | |
618 return set_control(priv, &control, 1); | |
619 case TVI_CONTROL_VID_GET_CONTRAST: | |
620 control.id = V4L2_CID_CONTRAST; | |
621 if (get_control(priv, &control, 1) == TVI_CONTROL_TRUE) { | |
622 *(int *)arg = control.value; | |
623 return TVI_CONTROL_TRUE; | |
624 } | |
625 return TVI_CONTROL_FALSE; | |
626 case TVI_CONTROL_VID_SET_CONTRAST: | |
627 control.id = V4L2_CID_CONTRAST; | |
628 control.value = *(int *)arg; | |
629 return set_control(priv, &control, 1); | |
630 case TVI_CONTROL_TUN_GET_FREQ: | |
631 frequency.tuner = 0; | |
632 frequency.type = V4L2_TUNER_ANALOG_TV; | |
633 if (ioctl(priv->video_fd, VIDIOC_G_FREQUENCY, &frequency) < 0) { | |
634 mp_msg(MSGT_TV,MSGL_ERR,"%s: ioctl get frequency failed: %s\n", | |
635 info.short_name, strerror(errno)); | |
636 return TVI_CONTROL_FALSE; | |
637 } | |
638 *(int *)arg = frequency.frequency; | |
639 return TVI_CONTROL_TRUE; | |
640 case TVI_CONTROL_TUN_SET_FREQ: | |
641 #if 0 | |
642 if (priv->input.audioset) { | |
643 set_mute(priv, 1); | |
644 usleep(100000); // wait to supress noise during switching | |
645 } | |
646 #endif | |
647 frequency.tuner = 0; | |
648 frequency.type = V4L2_TUNER_ANALOG_TV; | |
649 frequency.frequency = *(int *)arg; | |
650 if (ioctl(priv->video_fd, VIDIOC_S_FREQUENCY, &frequency) < 0) { | |
651 mp_msg(MSGT_TV,MSGL_ERR,"%s: ioctl set frequency failed: %s\n", | |
652 info.short_name, strerror(errno)); | |
653 return TVI_CONTROL_FALSE; | |
654 } | |
655 #if 0 | |
656 if (priv->input.audioset) { | |
657 usleep(100000); // wait to supress noise during switching | |
658 set_mute(priv, 0); | |
659 } | |
660 #endif | |
661 return TVI_CONTROL_TRUE; | |
662 case TVI_CONTROL_TUN_GET_TUNER: | |
10735
8a10d5d0ce86
serious bugs - 1l absinth (changed to absinth against cola inflation)
alex
parents:
10704
diff
changeset
|
663 mp_msg(MSGT_TV, MSGL_V, "%s: get tuner\n",info.short_name); |
10536 | 664 if (ioctl(priv->video_fd, VIDIOC_G_TUNER, &priv->tuner) < 0) { |
665 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl get tuner failed: %s\n", | |
666 info.short_name, strerror(errno)); | |
667 return TVI_CONTROL_FALSE; | |
668 } | |
669 return TVI_CONTROL_TRUE; | |
670 case TVI_CONTROL_TUN_SET_TUNER: | |
10735
8a10d5d0ce86
serious bugs - 1l absinth (changed to absinth against cola inflation)
alex
parents:
10704
diff
changeset
|
671 mp_msg(MSGT_TV, MSGL_V, "%s: set tuner\n",info.short_name); |
10536 | 672 if (ioctl(priv->video_fd, VIDIOC_S_TUNER, &priv->tuner) < 0) { |
673 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl set tuner failed: %s\n", | |
674 info.short_name, strerror(errno)); | |
675 return TVI_CONTROL_FALSE; | |
676 } | |
677 return TVI_CONTROL_TRUE; | |
678 case TVI_CONTROL_TUN_GET_NORM: | |
679 *(int *)arg = priv->standard.index; | |
680 return TVI_CONTROL_TRUE; | |
681 case TVI_CONTROL_TUN_SET_NORM: | |
682 priv->standard.index = *(int *)arg; | |
683 if (ioctl(priv->video_fd, VIDIOC_ENUMSTD, &priv->standard) < 0) { | |
684 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl enum norm failed: %s\n", | |
685 info.short_name, strerror(errno)); | |
686 return TVI_CONTROL_FALSE; | |
687 } | |
688 mp_msg(MSGT_TV, MSGL_V, "%s: set norm: %s\n", info.short_name, priv->standard.name); | |
689 if (ioctl(priv->video_fd, VIDIOC_S_STD, &priv->standard.id) < 0) { | |
690 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl set norm failed: %s\n", | |
691 info.short_name, strerror(errno)); | |
692 return TVI_CONTROL_FALSE; | |
693 } | |
694 return TVI_CONTROL_TRUE; | |
695 case TVI_CONTROL_SPC_GET_INPUT: | |
696 if (ioctl(priv->video_fd, VIDIOC_G_INPUT, (int *)arg) < 0) { | |
697 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl get input failed: %s\n", | |
698 info.short_name, strerror(errno)); | |
699 return TVI_CONTROL_FALSE; | |
700 } | |
701 return TVI_CONTROL_TRUE; | |
702 case TVI_CONTROL_SPC_SET_INPUT: | |
703 mp_msg(MSGT_TV, MSGL_V, "%s: set input: %d\n", info.short_name, *(int *)arg); | |
704 priv->input.index = *(int *)arg; | |
705 if (ioctl(priv->video_fd, VIDIOC_ENUMINPUT, &priv->input) < 0) { | |
706 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl enum input failed: %s\n", | |
707 info.short_name, strerror(errno)); | |
708 return TVI_CONTROL_FALSE; | |
709 } | |
710 if (ioctl(priv->video_fd, VIDIOC_S_INPUT, (int *)arg) < 0) { | |
711 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl set input failed: %s\n", | |
712 info.short_name, strerror(errno)); | |
713 return TVI_CONTROL_FALSE; | |
714 } | |
715 return TVI_CONTROL_TRUE; | |
716 case TVI_CONTROL_AUD_GET_FORMAT: | |
717 *(int *)arg = AFMT_S16_LE; | |
718 mp_msg(MSGT_TV, MSGL_V, "%s: get audio format: %d\n", | |
719 info.short_name, *(int *)arg); | |
720 return TVI_CONTROL_TRUE; | |
721 case TVI_CONTROL_AUD_GET_SAMPLERATE: | |
722 *(int *)arg = priv->audio_in.samplerate; | |
723 mp_msg(MSGT_TV, MSGL_V, "%s: get audio samplerate: %d\n", | |
724 info.short_name, *(int *)arg); | |
725 return TVI_CONTROL_TRUE; | |
726 case TVI_CONTROL_AUD_GET_SAMPLESIZE: | |
727 *(int *)arg = priv->audio_in.bytes_per_sample;; | |
728 mp_msg(MSGT_TV, MSGL_V, "%s: get audio samplesize: %d\n", | |
729 info.short_name, *(int *)arg); | |
730 return TVI_CONTROL_TRUE; | |
731 case TVI_CONTROL_AUD_GET_CHANNELS: | |
732 *(int *)arg = priv->audio_in.channels; | |
733 mp_msg(MSGT_TV, MSGL_V, "%s: get audio channels: %d\n", | |
734 info.short_name, *(int *)arg); | |
735 return TVI_CONTROL_TRUE; | |
736 case TVI_CONTROL_AUD_SET_SAMPLERATE: | |
737 mp_msg(MSGT_TV, MSGL_V, "%s: set audio samplerate: %d\n", | |
738 info.short_name, *(int *)arg); | |
739 if (audio_in_set_samplerate(&priv->audio_in, (int)*(void **)arg) < 0) return TVI_CONTROL_FALSE; | |
740 // setup_audio_buffer_sizes(priv); | |
741 return TVI_CONTROL_TRUE; | |
742 } | |
743 mp_msg(MSGT_TV, MSGL_V, "%s: unknown control: %d\n", info.short_name, cmd); | |
744 return(TVI_CONTROL_UNKNOWN); | |
745 } | |
746 | |
747 | |
748 #define PRIV ((priv_t *) (tvi_handle->priv)) | |
749 | |
750 /* handler creator - entry point ! */ | |
751 tvi_handle_t *tvi_init_v4l2(char *video_dev, char *audio_dev) | |
752 { | |
753 tvi_handle_t *tvi_handle; | |
754 | |
755 /* new_handle initializes priv with memset 0 */ | |
756 tvi_handle = new_handle(); | |
757 if (!tvi_handle) { | |
758 return NULL; | |
759 } | |
760 PRIV->video_fd = -1; | |
761 | |
762 PRIV->video_dev = strdup(video_dev? video_dev: "/dev/video"); | |
763 if (!PRIV->video_dev) { | |
764 free_handle(tvi_handle); | |
765 return NULL; | |
766 } | |
767 | |
768 if (audio_dev) { | |
769 PRIV->audio_dev = strdup(audio_dev); | |
770 if (!PRIV->audio_dev) { | |
771 free(PRIV->video_dev); | |
772 free_handle(tvi_handle); | |
773 return NULL; | |
774 } | |
775 } | |
776 | |
777 return tvi_handle; | |
778 } | |
779 | |
780 #undef PRIV | |
781 | |
782 | |
783 static int uninit(priv_t *priv) | |
784 { | |
785 int i, frames, dropped = 0; | |
786 | |
787 priv->shutdown = 1; | |
788 pthread_join(priv->audio_grabber_thread, NULL); | |
789 pthread_mutex_destroy(&priv->video_buffer_mutex); | |
790 | |
791 if (priv->streamon) { | |
792 struct v4l2_buffer buf; | |
793 | |
794 /* get performance */ | |
795 frames = 1 + (priv->curr_frame - priv->first_frame) * | |
796 priv->standard.frameperiod.denominator / | |
797 priv->standard.frameperiod.numerator / 1000000; | |
798 dropped = frames - priv->frames; | |
799 | |
800 /* turn off streaming */ | |
801 if (ioctl(priv->video_fd, VIDIOC_STREAMOFF, &(priv->map[0].buf.type)) < 0) { | |
802 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl streamoff failed: %s\n", | |
803 info.short_name, strerror(errno)); | |
804 } | |
805 priv->streamon = 0; | |
806 | |
807 /* unqueue all remaining buffers */ | |
808 memset(&buf,0,sizeof(buf)); | |
809 buf.type = V4L2_BUF_TYPE_VIDEO_CAPTURE; | |
810 while (!ioctl(priv->video_fd, VIDIOC_DQBUF, &buf)); | |
811 } | |
812 | |
813 /* unmap all buffers */ | |
814 for (i = 0; i < priv->mapcount; i++) { | |
815 if (munmap(priv->map[i].addr, priv->map[i].len) < 0) { | |
816 mp_msg(MSGT_TV, MSGL_ERR, "%s: munmap capture buffer failed: %s\n", | |
817 info.short_name, strerror(errno)); | |
818 } | |
819 } | |
820 | |
821 /* stop audio thread */ | |
822 if (!tv_param_noaudio) { | |
823 pthread_join(priv->audio_grabber_thread, NULL); | |
824 pthread_mutex_destroy(&priv->skew_mutex); | |
825 } | |
826 | |
827 if (priv->input.audioset) { | |
828 set_mute(priv, 1); | |
829 } | |
830 | |
831 /* free memory and close device */ | |
832 free(priv->map); priv->map = NULL; | |
833 priv->mapcount = 0; | |
834 close(priv->video_fd); priv->video_fd = -1; | |
835 free(priv->video_dev); priv->video_dev = NULL; | |
836 | |
837 if (priv->video_ringbuffer) { | |
838 int i; | |
839 for (i = 0; i < priv->video_buffer_size_current; i++) { | |
840 free(priv->video_ringbuffer[i]); | |
841 } | |
842 free(priv->video_ringbuffer); | |
843 } | |
844 if (priv->video_timebuffer) | |
845 free(priv->video_timebuffer); | |
846 if (!tv_param_noaudio) { | |
847 if (priv->audio_ringbuffer) | |
848 free(priv->audio_ringbuffer); | |
849 if (priv->audio_skew_buffer) | |
850 free(priv->audio_skew_buffer); | |
10653 | 851 if (priv->audio_skew_delta_buffer) |
852 free(priv->audio_skew_delta_buffer); | |
10536 | 853 } |
854 | |
855 /* show some nice statistics ;-) */ | |
856 mp_msg(MSGT_TV, MSGL_INFO, | |
857 "%s: %d frames successfully processed, %d frames dropped.\n", | |
858 info.short_name, priv->frames, dropped); | |
859 mp_msg(MSGT_TV, MSGL_V, "%s: up to %u video frames buffered.\n", | |
860 info.short_name, priv->video_buffer_size_current); | |
861 return 1; | |
862 } | |
863 | |
864 | |
865 /* initialisation */ | |
866 static int init(priv_t *priv) | |
867 { | |
868 int i; | |
869 | |
870 if (tv_param_immediate == 1) | |
871 tv_param_noaudio = 1; | |
872 | |
873 priv->audio_ringbuffer = NULL; | |
874 priv->audio_skew_buffer = NULL; | |
10653 | 875 priv->audio_skew_delta_buffer = NULL; |
10536 | 876 |
877 /* Open the video device. */ | |
878 priv->video_fd = open(priv->video_dev, O_RDWR); | |
879 if (priv->video_fd < 0) { | |
880 mp_msg(MSGT_TV, MSGL_ERR, "%s: unable to open '%s': %s\n", | |
881 info.short_name, priv->video_dev, strerror(errno)); | |
882 uninit(priv); | |
883 return 0; | |
884 } | |
885 mp_msg(MSGT_TV, MSGL_DBG2, "%s: video fd: %s: %d\n", | |
886 info.short_name, priv->video_dev, priv->video_fd); | |
887 | |
888 /* | |
889 ** Query the video capabilities and current settings | |
890 ** for further control calls. | |
891 */ | |
892 if (ioctl(priv->video_fd, VIDIOC_QUERYCAP, &priv->capability) < 0) { | |
893 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl query capabilities failed: %s\n", | |
894 info.short_name, strerror(errno)); | |
895 uninit(priv); | |
896 return 0; | |
897 } | |
898 | |
899 if (!(priv->capability.capabilities & V4L2_CAP_VIDEO_CAPTURE)) | |
900 { | |
901 mp_msg(MSGT_TV, MSGL_ERR, "Device %s is not a video capture device.\n", | |
902 priv->video_dev); | |
903 return 0; | |
904 } | |
905 | |
906 if (getfmt(priv) < 0 || getstd(priv) < 0) { | |
907 uninit(priv); | |
908 return 0; | |
909 } | |
910 /* | |
911 ** if this device has got a tuner query it's settings | |
912 ** otherwise set some nice defaults | |
913 */ | |
914 if (priv->capability.capabilities & V4L2_CAP_TUNER) { | |
915 if (ioctl(priv->video_fd, VIDIOC_G_TUNER, &priv->tuner) < 0) { | |
916 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl get tuner failed: %s\n", | |
917 info.short_name, strerror(errno)); | |
918 uninit(priv); | |
919 return 0; | |
920 } | |
921 } | |
922 mp_msg(MSGT_TV, MSGL_INFO, "Selected device: %s\n", priv->capability.card); | |
923 if (priv->capability.capabilities & V4L2_CAP_TUNER) { | |
924 mp_msg(MSGT_TV, MSGL_INFO, " Tuner cap:%s%s%s\n", | |
925 (priv->tuner.capability & V4L2_TUNER_CAP_STEREO) ? " STEREO" : "", | |
926 (priv->tuner.capability & V4L2_TUNER_CAP_LANG1) ? " LANG1" : "", | |
927 (priv->tuner.capability & V4L2_TUNER_CAP_LANG2) ? " LANG2" : ""); | |
928 mp_msg(MSGT_TV, MSGL_INFO, " Tuner rxs:%s%s%s%s\n", | |
929 (priv->tuner.rxsubchans & V4L2_TUNER_SUB_MONO) ? " MONO" : "", | |
930 (priv->tuner.rxsubchans & V4L2_TUNER_SUB_STEREO) ? " STEREO" : "", | |
931 (priv->tuner.rxsubchans & V4L2_TUNER_SUB_LANG1) ? " LANG1" : "", | |
932 (priv->tuner.rxsubchans & V4L2_TUNER_SUB_LANG2) ? " LANG2" : ""); | |
933 } | |
934 mp_msg(MSGT_TV, MSGL_INFO, " Capabilites:%s%s%s%s%s%s%s%s%s%s%s\n", | |
935 priv->capability.capabilities & V4L2_CAP_VIDEO_CAPTURE? | |
936 " video capture": "", | |
937 priv->capability.capabilities & V4L2_CAP_VIDEO_OUTPUT? | |
938 " video output": "", | |
939 priv->capability.capabilities & V4L2_CAP_VIDEO_OVERLAY? | |
940 " video overlay": "", | |
941 priv->capability.capabilities & V4L2_CAP_VBI_CAPTURE? | |
942 " VBI capture device": "", | |
943 priv->capability.capabilities & V4L2_CAP_VBI_OUTPUT? | |
944 " VBI output": "", | |
945 priv->capability.capabilities & V4L2_CAP_RDS_CAPTURE? | |
946 " RDS data capture": "", | |
947 priv->capability.capabilities & V4L2_CAP_TUNER? | |
948 " tuner": "", | |
949 priv->capability.capabilities & V4L2_CAP_AUDIO? | |
950 " audio": "", | |
951 priv->capability.capabilities & V4L2_CAP_READWRITE? | |
952 " read/write": "", | |
953 priv->capability.capabilities & V4L2_CAP_ASYNCIO? | |
954 " async i/o": "", | |
955 priv->capability.capabilities & V4L2_CAP_STREAMING? | |
956 " streaming": ""); | |
957 mp_msg(MSGT_TV, MSGL_INFO, " supported norms:"); | |
958 for (i = 0;; i++) { | |
959 struct v4l2_standard standard; | |
960 memset(&standard, 0, sizeof(standard)); | |
961 standard.index = i; | |
962 if (-1 == ioctl(priv->video_fd, VIDIOC_ENUMSTD, &standard)) | |
963 break; | |
964 printf(" %d = %s;", i, standard.name); | |
965 } | |
966 mp_msg(MSGT_TV, MSGL_INFO, "\n inputs:"); | |
967 for (i = 0; 1; i++) { | |
968 struct v4l2_input input; | |
969 | |
970 input.index = i; | |
971 if (ioctl(priv->video_fd, VIDIOC_ENUMINPUT, &input) < 0) { | |
972 break; | |
973 } | |
974 mp_msg(MSGT_TV, MSGL_INFO, " %d = %s;", i, input.name); | |
975 } | |
976 if (ioctl(priv->video_fd, VIDIOC_G_INPUT, &i) < 0) { | |
977 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl get input failed: %s\n", | |
978 info.short_name, strerror(errno)); | |
979 } | |
980 mp_msg(MSGT_TV, MSGL_INFO, "\n Current input: %d\n", i); | |
981 for (i = 0; ; i++) { | |
982 struct v4l2_fmtdesc fmtdesc; | |
983 | |
984 fmtdesc.index = i; | |
985 fmtdesc.type = V4L2_BUF_TYPE_VIDEO_CAPTURE; | |
986 if (ioctl(priv->video_fd, VIDIOC_ENUM_FMT, &fmtdesc) < 0) { | |
987 break; | |
988 } | |
989 mp_msg(MSGT_TV, MSGL_V, " Format %-6s (%2d bits, %s): %s\n", | |
990 pixfmt2name(fmtdesc.pixelformat), pixfmt2depth(fmtdesc.pixelformat), | |
991 fmtdesc.description, vo_format_name(fcc_vl2mp(fmtdesc.pixelformat))); | |
992 } | |
993 mp_msg(MSGT_TV, MSGL_INFO, " Current format: %s\n", | |
994 pixfmt2name(priv->format.fmt.pix.pixelformat)); | |
995 | |
996 /* set some nice defaults */ | |
997 if (getfmt(priv) < 0) return 0; | |
998 priv->format.fmt.pix.width = 640; | |
999 priv->format.fmt.pix.height = 480; | |
1000 if (ioctl(priv->video_fd, VIDIOC_S_FMT, &priv->format) < 0) { | |
1001 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl set format failed: %s\n", | |
1002 info.short_name, strerror(errno)); | |
1003 uninit(priv); | |
1004 return 0; | |
1005 } | |
1006 | |
1007 // if (!(priv->capability.capabilities & V4L2_CAP_AUDIO) && !tv_param_force_audio) tv_param_noaudio = 1; | |
1008 | |
1009 if (priv->capability.capabilities & V4L2_CAP_TUNER) { | |
1010 struct v4l2_control control; | |
1011 if (tv_param_amode >= 0) { | |
1012 mp_msg(MSGT_TV, MSGL_V, "%s: setting audio mode\n", info.short_name); | |
1013 priv->tuner.audmode = amode2v4l(tv_param_amode); | |
1014 if (ioctl(priv->video_fd, VIDIOC_S_TUNER, &priv->tuner) < 0) { | |
1015 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl set tuner failed: %s\n", | |
1016 info.short_name, strerror(errno)); | |
1017 return TVI_CONTROL_FALSE; | |
1018 } | |
1019 } | |
1020 mp_msg(MSGT_TV, MSGL_INFO, "%s: current audio mode is :%s%s%s%s\n", info.short_name, | |
1021 (priv->tuner.audmode == V4L2_TUNER_MODE_MONO) ? " MONO" : "", | |
1022 (priv->tuner.audmode == V4L2_TUNER_MODE_STEREO) ? " STEREO" : "", | |
1023 (priv->tuner.audmode == V4L2_TUNER_MODE_LANG1) ? " LANG1" : "", | |
1024 (priv->tuner.audmode == V4L2_TUNER_MODE_LANG2) ? " LANG2" : ""); | |
1025 | |
1026 if (tv_param_volume >= 0) { | |
1027 control.id = V4L2_CID_AUDIO_VOLUME; | |
1028 control.value = tv_param_volume; | |
1029 set_control(priv, &control, 0); | |
1030 } | |
1031 if (tv_param_bass >= 0) { | |
1032 control.id = V4L2_CID_AUDIO_BASS; | |
1033 control.value = tv_param_bass; | |
1034 set_control(priv, &control, 0); | |
1035 } | |
1036 if (tv_param_treble >= 0) { | |
1037 control.id = V4L2_CID_AUDIO_TREBLE; | |
1038 control.value = tv_param_treble; | |
1039 set_control(priv, &control, 0); | |
1040 } | |
1041 if (tv_param_balance >= 0) { | |
1042 control.id = V4L2_CID_AUDIO_BALANCE; | |
1043 control.value = tv_param_balance; | |
1044 set_control(priv, &control, 0); | |
1045 } | |
1046 } | |
1047 | |
1048 /* audio init */ | |
1049 if (!tv_param_noaudio) { | |
1050 #ifdef HAVE_ALSA9 | |
1051 if (tv_param_alsa) | |
1052 audio_in_init(&priv->audio_in, AUDIO_IN_ALSA); | |
1053 else | |
1054 audio_in_init(&priv->audio_in, AUDIO_IN_OSS); | |
1055 #else | |
1056 audio_in_init(&priv->audio_in, AUDIO_IN_OSS); | |
1057 #endif | |
1058 | |
1059 if (priv->audio_dev) { | |
1060 audio_in_set_device(&priv->audio_in, priv->audio_dev); | |
1061 } | |
1062 | |
1063 audio_in_set_samplerate(&priv->audio_in, 44100); | |
1064 if (priv->capability.capabilities & V4L2_CAP_TUNER) { | |
1065 if (priv->tuner.audmode == V4L2_TUNER_MODE_STEREO) { | |
1066 audio_in_set_channels(&priv->audio_in, 2); | |
1067 } else { | |
1068 audio_in_set_channels(&priv->audio_in, 1); | |
1069 } | |
1070 } else { | |
1071 if (tv_param_forcechan >= 0) { | |
1072 audio_in_set_channels(&priv->audio_in, tv_param_forcechan); | |
1073 } else { | |
1074 audio_in_set_channels(&priv->audio_in, 2); | |
1075 } | |
1076 } | |
1077 if (audio_in_setup(&priv->audio_in) < 0) return 0; | |
1078 // setup_audio_buffer_sizes(priv); | |
1079 } | |
1080 | |
1081 return 1; | |
1082 } | |
1083 | |
1084 static int get_capture_buffer_size(priv_t *priv) | |
1085 { | |
1086 int bufsize, cnt; | |
1087 int w = priv->format.fmt.pix.width; | |
1088 int h = priv->format.fmt.pix.height; | |
1089 int d = pixfmt2depth(priv->format.fmt.pix.pixelformat); | |
1090 int bytesperline = w*d/8; | |
1091 | |
1092 if (tv_param_buffer_size >= 0) { | |
1093 bufsize = tv_param_buffer_size*1024*1024; | |
1094 } else { | |
1095 #ifdef HAVE_SYS_SYSINFO_H | |
1096 struct sysinfo si; | |
1097 | |
1098 sysinfo(&si); | |
1099 if (si.totalram<2*1024*1024) { | |
1100 bufsize = 1024*1024; | |
1101 } else { | |
1102 bufsize = si.totalram/2; | |
1103 } | |
1104 #else | |
1105 bufsize = 16*1024*1024; | |
1106 #endif | |
1107 } | |
1108 | |
1109 cnt = bufsize/(h*bytesperline); | |
1110 if (cnt < 2) cnt = 2; | |
1111 | |
1112 return cnt; | |
1113 } | |
1114 | |
1115 /* that's the real start, we'got the format parameters (checked with control) */ | |
1116 static int start(priv_t *priv) | |
1117 { | |
1118 struct v4l2_requestbuffers request; | |
1119 int i; | |
1120 | |
1121 /* setup audio parameters */ | |
1122 | |
1123 /* we need this to size the audio buffer properly */ | |
1124 if (priv->immediate_mode) { | |
1125 priv->video_buffer_size_max = 2; | |
1126 } else { | |
1127 priv->video_buffer_size_max = get_capture_buffer_size(priv); | |
1128 } | |
1129 | |
1130 if (!tv_param_noaudio) { | |
1131 setup_audio_buffer_sizes(priv); | |
1132 priv->audio_skew_buffer = (long long*)malloc(sizeof(long long)*priv->aud_skew_cnt); | |
1133 if (!priv->audio_skew_buffer) { | |
1134 mp_msg(MSGT_TV, MSGL_ERR, "cannot allocate skew buffer: %s\n", strerror(errno)); | |
1135 return 0; | |
1136 } | |
10653 | 1137 priv->audio_skew_delta_buffer = (long long*)malloc(sizeof(long long)*priv->aud_skew_cnt); |
1138 if (!priv->audio_skew_delta_buffer) { | |
1139 mp_msg(MSGT_TV, MSGL_ERR, "cannot allocate skew buffer: %s\n", strerror(errno)); | |
1140 return 0; | |
1141 } | |
10536 | 1142 |
1143 priv->audio_ringbuffer = (unsigned char*)malloc(priv->audio_in.blocksize*priv->audio_buffer_size); | |
1144 if (!priv->audio_ringbuffer) { | |
1145 mp_msg(MSGT_TV, MSGL_ERR, "cannot allocate audio buffer: %s\n", strerror(errno)); | |
1146 return 0; | |
1147 } | |
1148 | |
1149 priv->audio_secs_per_block = (double)priv->audio_in.blocksize/(priv->audio_in.samplerate | |
1150 *priv->audio_in.channels | |
1151 *priv->audio_in.bytes_per_sample); | |
1152 priv->audio_head = 0; | |
1153 priv->audio_tail = 0; | |
1154 priv->audio_cnt = 0; | |
1155 priv->audio_drop = 0; | |
1156 priv->audio_skew = 0; | |
1157 priv->audio_skew_total = 0; | |
10653 | 1158 priv->audio_skew_delta_total = 0; |
10536 | 1159 priv->audio_recv_blocks_total = 0; |
1160 priv->audio_sent_blocks_total = 0; | |
1161 } | |
1162 | |
1163 /* setup video parameters */ | |
1164 if (!tv_param_noaudio) { | |
1165 if (priv->video_buffer_size_max < 3.0*(priv->standard.frameperiod.denominator / | |
1166 priv->standard.frameperiod.numerator) | |
1167 *priv->audio_secs_per_block) { | |
1168 mp_msg(MSGT_TV, MSGL_ERR, "Video buffer shorter than 3 times audio frame duration.\n" | |
1169 "You will probably experience heavy framedrops.\n"); | |
1170 } | |
1171 } | |
1172 | |
1173 { | |
1174 int bytesperline = priv->format.fmt.pix.width*pixfmt2depth(priv->format.fmt.pix.pixelformat)/8; | |
1175 | |
1176 mp_msg(MSGT_TV, MSGL_V, "Using a ring buffer for maximum %d frames, %d MB total size.\n", | |
1177 priv->video_buffer_size_max, | |
1178 priv->video_buffer_size_max*priv->format.fmt.pix.height*bytesperline/(1024*1024)); | |
1179 } | |
1180 | |
1181 priv->video_ringbuffer = (unsigned char**)malloc(priv->video_buffer_size_max*sizeof(unsigned char*)); | |
1182 if (!priv->video_ringbuffer) { | |
1183 mp_msg(MSGT_TV, MSGL_ERR, "cannot allocate video buffer: %s\n", strerror(errno)); | |
1184 return 0; | |
1185 } | |
1186 for (i = 0; i < priv->video_buffer_size_max; i++) | |
1187 priv->video_ringbuffer[i] = NULL; | |
1188 priv->video_timebuffer = (long long*)malloc(sizeof(long long) * priv->video_buffer_size_max); | |
1189 if (!priv->video_timebuffer) { | |
1190 mp_msg(MSGT_TV, MSGL_ERR, "cannot allocate time buffer: %s\n", strerror(errno)); | |
1191 return 0; | |
1192 } | |
1193 | |
1194 priv->video_head = 0; | |
1195 priv->video_tail = 0; | |
1196 priv->video_cnt = 0; | |
1197 | |
1198 /* request buffers */ | |
1199 if (priv->immediate_mode) { | |
1200 request.count = 2; | |
1201 } else { | |
1202 request.count = BUFFER_COUNT; | |
1203 } | |
1204 | |
1205 request.type = V4L2_BUF_TYPE_VIDEO_CAPTURE; | |
1206 request.memory = V4L2_MEMORY_MMAP; | |
1207 if (ioctl(priv->video_fd, VIDIOC_REQBUFS, &request) < 0) { | |
1208 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl request buffers failed: %s\n", | |
1209 info.short_name, strerror(errno)); | |
1210 return 0; | |
1211 } | |
1212 | |
1213 /* query buffers */ | |
1214 if (!(priv->map = malloc(sizeof(struct map) * request.count))) { | |
1215 mp_msg(MSGT_TV, MSGL_ERR, "%s: malloc capture buffers failed: %s\n", | |
1216 info.short_name, strerror(errno)); | |
1217 return 0; | |
1218 } | |
1219 | |
1220 /* map and queue buffers */ | |
1221 for (i = 0; i < request.count; i++) { | |
1222 memset(&priv->map[i].buf,0,sizeof(priv->map[i].buf)); | |
1223 priv->map[i].buf.index = i; | |
1224 priv->map[i].buf.type = V4L2_BUF_TYPE_VIDEO_CAPTURE; | |
1225 priv->map[i].buf.memory = V4L2_MEMORY_MMAP; | |
1226 if (ioctl(priv->video_fd, VIDIOC_QUERYBUF, &(priv->map[i].buf)) < 0) { | |
1227 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl query buffer failed: %s\n", | |
1228 info.short_name, strerror(errno)); | |
1229 free(priv->map); | |
1230 priv->map = NULL; | |
1231 return 0; | |
1232 } | |
1233 priv->map[i].addr = mmap (0, priv->map[i].buf.length, PROT_READ | | |
1234 PROT_WRITE, MAP_SHARED, priv->video_fd, priv->map[i].buf.m.offset); | |
1235 if (priv->map[i].addr == MAP_FAILED) { | |
1236 mp_msg(MSGT_TV, MSGL_ERR, "%s: mmap capture buffer failed: %s\n", | |
1237 info.short_name, strerror(errno)); | |
1238 priv->map[i].len = 0; | |
1239 return 0; | |
1240 } | |
1241 priv->map[i].len = priv->map[i].buf.length; | |
1242 /* count up to make sure this is correct everytime */ | |
1243 priv->mapcount++; | |
1244 | |
1245 if (ioctl(priv->video_fd, VIDIOC_QBUF, &(priv->map[i].buf)) < 0) { | |
1246 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl queue buffer failed: %s\n", | |
1247 info.short_name, strerror(errno)); | |
1248 return 0; | |
1249 } | |
1250 } | |
1251 | |
1252 /* start audio thread */ | |
1253 priv->shutdown = 0; | |
1254 priv->audio_skew_measure_time = 0; | |
1255 priv->first_frame = 0; | |
1256 priv->audio_skew = 0; | |
1257 priv->first = 1; | |
1258 | |
1259 if (priv->input.audioset) { | |
1260 set_mute(priv, 0); | |
1261 } | |
1262 | |
1263 return 1; | |
1264 } | |
1265 | |
1266 | |
1267 #ifdef HAVE_TV_BSDBT848 | |
1268 static double grabimmediate_video_frame(priv_t *priv, char *buffer, int len) | |
1269 { | |
1270 memset(buffer, 0xCC, len); | |
1271 return(1); | |
1272 } | |
1273 #endif /* HAVE_TV_BSDBT848 */ | |
1274 | |
1275 // copies a video frame | |
1276 // for YV12 swaps the 2nd and 3rd plane | |
1277 static inline void copy_frame(priv_t *priv, unsigned char *dest, unsigned char *source) | |
1278 { | |
1279 int w = priv->format.fmt.pix.width; | |
1280 int h = priv->format.fmt.pix.height; | |
1281 int d = pixfmt2depth(priv->format.fmt.pix.pixelformat); | |
1282 int bytesperline = w*d/8; | |
1283 | |
1284 // YV12 uses VIDEO_PALETTE_YUV420P, but the planes are swapped | |
1285 switch (priv->mp_format) { | |
1286 case IMGFMT_YV12: | |
1287 memcpy(dest, source, w * h); | |
1288 memcpy(dest+w * h*5/4, source+w * h, w * h/4); | |
1289 memcpy(dest+w * h, source+w * h*5/4, w * h/4); | |
1290 break; | |
1291 default: | |
1292 memcpy(dest, source, bytesperline * h); | |
1293 } | |
1294 | |
1295 } | |
1296 | |
1297 // maximum skew change, in frames | |
1298 #define MAX_SKEW_DELTA 0.6 | |
1299 static void *video_grabber(void *data) | |
1300 { | |
1301 priv_t *priv = (priv_t*)data; | |
1302 long long skew, prev_skew, xskew, interval, prev_interval; | |
1303 int i; | |
1304 int framesize = priv->format.fmt.pix.height*priv->format.fmt.pix.width* | |
1305 pixfmt2depth(priv->format.fmt.pix.pixelformat)/8; | |
1306 fd_set rdset; | |
1307 struct timeval timeout; | |
1308 struct v4l2_buffer buf; | |
1309 | |
1310 xskew = 0; | |
1311 skew = 0; | |
1312 interval = 0; | |
1313 prev_interval = 0; | |
1314 prev_skew = 0; | |
1315 | |
1316 mp_msg(MSGT_TV, MSGL_V, "%s: going to capture\n", info.short_name); | |
1317 if (ioctl(priv->video_fd, VIDIOC_STREAMON, &(priv->format.type)) < 0) { | |
1318 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl streamon failed: %s\n", | |
1319 info.short_name, strerror(errno)); | |
1320 return 0; | |
1321 } | |
1322 priv->streamon = 1; | |
1323 | |
1324 if (!tv_param_noaudio) { | |
1325 pthread_mutex_init(&priv->skew_mutex, NULL); | |
1326 pthread_create(&priv->audio_grabber_thread, NULL, audio_grabber, priv); | |
1327 } | |
1328 | |
1329 for (priv->frames = 0; !priv->shutdown;) | |
1330 { | |
1331 int ret; | |
1332 | |
1333 if (priv->immediate_mode) { | |
1334 while (priv->video_cnt == priv->video_buffer_size_max) { | |
1335 usleep(10000); | |
1336 if (priv->shutdown) { | |
1337 return NULL; | |
1338 } | |
1339 } | |
1340 } | |
1341 | |
1342 FD_ZERO (&rdset); | |
1343 FD_SET (priv->video_fd, &rdset); | |
1344 | |
1345 timeout.tv_sec = 1; | |
1346 timeout.tv_usec = 0; | |
1347 | |
1348 i = select(priv->video_fd + 1, &rdset, NULL, NULL, &timeout); | |
1349 if (i < 0) { | |
1350 mp_msg(MSGT_TV, MSGL_ERR, "%s: select failed: %s\n", | |
1351 info.short_name, strerror(errno)); | |
1352 continue; | |
1353 } | |
1354 else if (i == 0) { | |
1355 mp_msg(MSGT_TV, MSGL_ERR, "%s: select timeout\n", info.short_name); | |
1356 continue; | |
1357 } | |
1358 else if (!FD_ISSET(priv->video_fd, &rdset)) { | |
1359 continue; | |
1360 } | |
1361 | |
1362 memset(&buf,0,sizeof(buf)); | |
1363 buf.type = V4L2_BUF_TYPE_VIDEO_CAPTURE; | |
1364 ret = ioctl(priv->video_fd, VIDIOC_DQBUF, &buf); | |
1365 | |
1366 if (ret < 0) { | |
1367 /* | |
1368 if there's no signal, the buffer might me dequeued | |
1369 so we query all the buffers to see which one we should | |
1370 put back to queue | |
1371 | |
1372 observed with saa7134 0.2.8 | |
1373 don't know if is it a bug or (mis)feature | |
1374 */ | |
1375 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl dequeue buffer failed: %s, idx = %d\n", | |
1376 info.short_name, strerror(errno), buf.index); | |
1377 for (i = 0; i < priv->mapcount; i++) { | |
1378 memset(&buf,0,sizeof(buf)); | |
1379 buf.type = V4L2_BUF_TYPE_VIDEO_CAPTURE; | |
1380 buf.index = i; | |
1381 ret = ioctl(priv->video_fd, VIDIOC_QUERYBUF, &buf); | |
1382 if (ret < 0) { | |
1383 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl query buffer failed: %s, idx = %d\n", | |
1384 info.short_name, strerror(errno), buf.index); | |
1385 return 0; | |
1386 } | |
1387 if ((buf.flags & (V4L2_BUF_FLAG_QUEUED | V4L2_BUF_FLAG_MAPPED | V4L2_BUF_FLAG_DONE)) == V4L2_BUF_FLAG_MAPPED) { | |
1388 if (ioctl(priv->video_fd, VIDIOC_QBUF, &(priv->map[i].buf)) < 0) { | |
1389 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl queue buffer failed: %s\n", | |
1390 info.short_name, strerror(errno)); | |
1391 return 0; | |
1392 } | |
1393 } | |
1394 } | |
1395 continue; | |
1396 } | |
1397 | |
1398 /* store the timestamp of the very first frame as reference */ | |
1399 if (!priv->frames++) { | |
10851 | 1400 pthread_mutex_lock(&priv->skew_mutex); |
10536 | 1401 priv->first_frame = (long long)1e6*buf.timestamp.tv_sec + buf.timestamp.tv_usec; |
10851 | 1402 pthread_mutex_unlock(&priv->skew_mutex); |
10536 | 1403 } |
1404 priv->curr_frame = (long long)buf.timestamp.tv_sec*1e6+buf.timestamp.tv_usec; | |
1405 // fprintf(stderr, "idx = %d, ts = %lf\n", buf.index, (double)(priv->curr_frame) / 1e6); | |
1406 | |
1407 interval = priv->curr_frame - priv->first_frame; | |
1408 | |
1409 if (!priv->immediate_mode) { | |
1410 // interpolate the skew in time | |
1411 pthread_mutex_lock(&priv->skew_mutex); | |
1412 xskew = priv->audio_skew + (interval - priv->audio_skew_measure_time)*priv->audio_skew_factor; | |
1413 pthread_mutex_unlock(&priv->skew_mutex); | |
1414 // correct extreme skew changes to avoid (especially) moving backwards in time | |
1415 if (xskew - prev_skew > (interval - prev_interval)*MAX_SKEW_DELTA) { | |
1416 skew = prev_skew + (interval - prev_interval)*MAX_SKEW_DELTA; | |
1417 } else if (xskew - prev_skew < -(interval - prev_interval)*MAX_SKEW_DELTA) { | |
1418 skew = prev_skew - (interval - prev_interval)*MAX_SKEW_DELTA; | |
1419 } else { | |
1420 skew = xskew; | |
1421 } | |
1422 } | |
1423 | |
1424 mp_msg(MSGT_TV, MSGL_DBG3, "\nfps = %lf, interval = %lf, a_skew = %f, corr_skew = %f\n", | |
1425 (interval != prev_interval) ? (double)1e6/(interval - prev_interval) : -1, | |
1426 (double)1e-6*interval, (double)1e-6*xskew, (double)1e-6*skew); | |
1427 mp_msg(MSGT_TV, MSGL_DBG3, "vcnt = %d, acnt = %d\n", priv->video_cnt, priv->audio_cnt); | |
1428 | |
1429 prev_skew = skew; | |
1430 prev_interval = interval; | |
1431 | |
1432 /* allocate a new buffer, if needed */ | |
1433 pthread_mutex_lock(&priv->video_buffer_mutex); | |
1434 if (priv->video_buffer_size_current < priv->video_buffer_size_max) { | |
1435 if (priv->video_cnt == priv->video_buffer_size_current) { | |
1436 unsigned char *newbuf = (unsigned char*)malloc(framesize); | |
1437 if (newbuf) { | |
1438 memmove(priv->video_ringbuffer+priv->video_tail+1, priv->video_ringbuffer+priv->video_tail, | |
1439 (priv->video_buffer_size_current-priv->video_tail)*sizeof(unsigned char *)); | |
1440 memmove(priv->video_timebuffer+priv->video_tail+1, priv->video_timebuffer+priv->video_tail, | |
1441 (priv->video_buffer_size_current-priv->video_tail)*sizeof(long long)); | |
1442 priv->video_ringbuffer[priv->video_tail] = newbuf; | |
1443 if ((priv->video_head >= priv->video_tail) && (priv->video_cnt > 0)) priv->video_head++; | |
1444 priv->video_buffer_size_current++; | |
1445 } | |
1446 } | |
1447 } | |
1448 pthread_mutex_unlock(&priv->video_buffer_mutex); | |
1449 | |
1450 if (priv->video_cnt == priv->video_buffer_size_current) { | |
1451 if (!priv->immediate_mode) { | |
1452 mp_msg(MSGT_TV, MSGL_ERR, "\nvideo buffer full - dropping frame\n"); | |
1453 } | |
1454 } else { | |
1455 if (priv->immediate_mode) { | |
1456 priv->video_timebuffer[priv->video_tail] = 0; | |
1457 } else { | |
1458 // compensate for audio skew | |
1459 // negative skew => there are more audio samples, increase interval | |
1460 // positive skew => less samples, shorten the interval | |
1461 priv->video_timebuffer[priv->video_tail] = interval - skew; | |
1462 } | |
1463 | |
1464 copy_frame(priv, priv->video_ringbuffer[priv->video_tail], priv->map[buf.index].addr); | |
1465 priv->video_tail = (priv->video_tail+1)%priv->video_buffer_size_current; | |
1466 priv->video_cnt++; | |
1467 } | |
1468 if (ioctl(priv->video_fd, VIDIOC_QBUF, &buf) < 0) { | |
1469 mp_msg(MSGT_TV, MSGL_ERR, "%s: ioctl queue buffer failed: %s\n", | |
1470 info.short_name, strerror(errno)); | |
1471 return 0; | |
1472 } | |
1473 } | |
1474 return NULL; | |
1475 } | |
1476 | |
1477 static double grab_video_frame(priv_t *priv, char *buffer, int len) | |
1478 { | |
1479 double interval; | |
1480 | |
1481 if (priv->first) { | |
1482 pthread_create(&priv->video_grabber_thread, NULL, video_grabber, priv); | |
1483 priv->first = 0; | |
1484 } | |
1485 | |
1486 while (priv->video_cnt == 0) { | |
1487 usleep(10000); | |
1488 } | |
1489 | |
1490 pthread_mutex_lock(&priv->video_buffer_mutex); | |
1491 interval = (double)priv->video_timebuffer[priv->video_head]*1e-6; | |
1492 memcpy(buffer, priv->video_ringbuffer[priv->video_head], len); | |
1493 priv->video_cnt--; | |
1494 priv->video_head = (priv->video_head+1)%priv->video_buffer_size_current; | |
1495 pthread_mutex_unlock(&priv->video_buffer_mutex); | |
1496 | |
1497 return interval; | |
1498 } | |
1499 | |
1500 static int get_video_framesize(priv_t *priv) | |
1501 { | |
1502 return priv->format.fmt.pix.sizeimage; | |
1503 } | |
1504 | |
10704 | 1505 //#define DOUBLESPEED |
1506 #ifdef DOUBLESPEED | |
10536 | 1507 // for testing purposes only |
1508 static void read_doublespeed(priv_t *priv) | |
1509 { | |
1510 char *bufx = (char*)malloc(priv->audio_in.blocksize*2); | |
1511 short *s; | |
1512 short *d; | |
1513 int i; | |
1514 | |
1515 audio_in_read_chunk(&priv->audio_in, bufx); | |
1516 audio_in_read_chunk(&priv->audio_in, bufx+priv->audio_in.blocksize); | |
1517 | |
1518 s = bufx; | |
1519 d = priv->audio_ringbuffer+priv->audio_tail*priv->audio_in.blocksize; | |
1520 for (i = 0; i < priv->audio_in.blocksize/2; i++) { | |
1521 *d++ = *s++; | |
1522 *s++; | |
1523 } | |
1524 | |
1525 } | |
10704 | 1526 #endif |
10536 | 1527 |
1528 static void *audio_grabber(void *data) | |
1529 { | |
1530 priv_t *priv = (priv_t*)data; | |
1531 struct timeval tv; | |
1532 int i, audio_skew_ptr = 0; | |
10653 | 1533 long long current_time, prev_skew = 0, prev_skew_uncorr = 0; |
10852 | 1534 long long start_time_avg; |
10536 | 1535 |
1536 gettimeofday(&tv, NULL); | |
10852 | 1537 start_time_avg = priv->audio_start_time = (long long)1e6*tv.tv_sec + tv.tv_usec; |
10536 | 1538 audio_in_start_capture(&priv->audio_in); |
1539 for (i = 0; i < priv->aud_skew_cnt; i++) | |
1540 priv->audio_skew_buffer[i] = 0; | |
10653 | 1541 for (i = 0; i < priv->aud_skew_cnt; i++) |
1542 priv->audio_skew_delta_buffer[i] = 0; | |
10536 | 1543 |
1544 for (; !priv->shutdown;) | |
1545 { | |
10704 | 1546 #ifdef DOUBLESPEED |
1547 read_doublespeed(priv); | |
1548 #else | |
10536 | 1549 if (audio_in_read_chunk(&priv->audio_in, priv->audio_ringbuffer+priv->audio_tail*priv->audio_in.blocksize) < 0) |
1550 continue; | |
10704 | 1551 #endif |
10536 | 1552 pthread_mutex_lock(&priv->skew_mutex); |
1553 if (priv->first_frame == 0) { | |
1554 // there is no first frame yet (unlikely to happen) | |
10810 | 1555 gettimeofday(&tv, NULL); |
10852 | 1556 start_time_avg = priv->audio_start_time = (long long)1e6*tv.tv_sec + tv.tv_usec; |
10536 | 1557 // fprintf(stderr, "warning - first frame not yet available!\n"); |
1558 pthread_mutex_unlock(&priv->skew_mutex); | |
1559 continue; | |
1560 } | |
1561 pthread_mutex_unlock(&priv->skew_mutex); | |
1562 | |
1563 gettimeofday(&tv, NULL); | |
1564 | |
1565 priv->audio_recv_blocks_total++; | |
1566 current_time = (long long)1e6*tv.tv_sec + tv.tv_usec - priv->audio_start_time; | |
1567 | |
10852 | 1568 if (priv->audio_recv_blocks_total < priv->aud_skew_cnt*2) { |
1569 start_time_avg += (long long)1e6*tv.tv_sec + tv.tv_usec - 1e6*priv->audio_secs_per_block*priv->audio_recv_blocks_total; | |
1570 priv->audio_start_time = start_time_avg/(priv->audio_recv_blocks_total+1); | |
1571 } | |
1572 | |
10536 | 1573 // fprintf(stderr, "spb = %lf, bs = %d, skew = %lf\n", priv->audio_secs_per_block, priv->audio_in.blocksize, |
1574 // (double)(current_time - 1e6*priv->audio_secs_per_block*priv->audio_recv_blocks_total)/1e6); | |
1575 | |
10704 | 1576 // put the current skew into the ring buffer |
10536 | 1577 priv->audio_skew_total -= priv->audio_skew_buffer[audio_skew_ptr]; |
1578 priv->audio_skew_buffer[audio_skew_ptr] = current_time | |
1579 - 1e6*priv->audio_secs_per_block*priv->audio_recv_blocks_total; | |
1580 priv->audio_skew_total += priv->audio_skew_buffer[audio_skew_ptr]; | |
1581 | |
1582 pthread_mutex_lock(&priv->skew_mutex); | |
10704 | 1583 |
1584 // skew calculation | |
1585 | |
1586 // compute the sliding average of the skews | |
10536 | 1587 if (priv->audio_recv_blocks_total > priv->aud_skew_cnt) { |
1588 priv->audio_skew = priv->audio_skew_total/priv->aud_skew_cnt; | |
1589 } else { | |
10704 | 1590 priv->audio_skew = priv->audio_skew_total/priv->audio_recv_blocks_total; |
10536 | 1591 } |
10653 | 1592 |
10704 | 1593 // put the current skew change (skew-prev_skew) into the ring buffer |
10653 | 1594 priv->audio_skew_delta_total -= priv->audio_skew_delta_buffer[audio_skew_ptr]; |
1595 priv->audio_skew_delta_buffer[audio_skew_ptr] = priv->audio_skew - prev_skew_uncorr; | |
1596 priv->audio_skew_delta_total += priv->audio_skew_delta_buffer[audio_skew_ptr]; | |
10704 | 1597 prev_skew_uncorr = priv->audio_skew; // remember the _uncorrected_ average value |
1598 | |
1599 audio_skew_ptr = (audio_skew_ptr+1) % priv->aud_skew_cnt; // rotate the buffer pointer | |
10653 | 1600 |
10704 | 1601 // sliding average approximates the value in the middle of the interval |
1602 // so interpolate the skew value further to the current time | |
1603 priv->audio_skew += priv->audio_skew_delta_total/2; | |
10653 | 1604 |
10704 | 1605 // now finally, priv->audio_skew contains fairly good approximation |
1606 // of the current value | |
10653 | 1607 |
10536 | 1608 // current skew factor (assuming linearity) |
1609 // used for further interpolation in video_grabber | |
1610 // probably overkill but seems to be necessary for | |
1611 // stress testing by dropping half of the audio frames ;) | |
1612 // especially when using ALSA with large block sizes | |
1613 // where audio_skew remains a long while behind | |
1614 if ((priv->audio_skew_measure_time != 0) && (current_time - priv->audio_skew_measure_time != 0)) { | |
1615 priv->audio_skew_factor = (double)(priv->audio_skew-prev_skew)/(current_time - priv->audio_skew_measure_time); | |
1616 } else { | |
1617 priv->audio_skew_factor = 0.0; | |
1618 } | |
10852 | 1619 |
10536 | 1620 priv->audio_skew_measure_time = current_time; |
1621 prev_skew = priv->audio_skew; | |
10852 | 1622 priv->audio_skew += priv->audio_start_time - priv->first_frame; |
1623 pthread_mutex_unlock(&priv->skew_mutex); | |
1624 | |
1625 // fprintf(stderr, "audio_skew = %lf, delta = %lf\n", (double)priv->audio_skew/1e6, (double)priv->audio_skew_delta_total/1e6); | |
10851 | 1626 |
10536 | 1627 if ((priv->audio_tail+1) % priv->audio_buffer_size == priv->audio_head) { |
1628 mp_msg(MSGT_TV, MSGL_ERR, "\ntoo bad - dropping audio frame !\n"); | |
1629 priv->audio_drop++; | |
1630 } else { | |
1631 priv->audio_tail = (priv->audio_tail+1) % priv->audio_buffer_size; | |
1632 priv->audio_cnt++; | |
1633 } | |
1634 } | |
1635 return NULL; | |
1636 } | |
1637 | |
1638 static double grab_audio_frame(priv_t *priv, char *buffer, int len) | |
1639 { | |
1640 mp_dbg(MSGT_TV, MSGL_DBG2, "grab_audio_frame(priv=%p, buffer=%p, len=%d)\n", | |
1641 priv, buffer, len); | |
1642 | |
10776
80402283a017
Fix immediatemode with mplayer (ie playing both sound and video)
albeu
parents:
10735
diff
changeset
|
1643 if (priv->first) { |
80402283a017
Fix immediatemode with mplayer (ie playing both sound and video)
albeu
parents:
10735
diff
changeset
|
1644 pthread_create(&priv->video_grabber_thread, NULL, video_grabber, priv); |
80402283a017
Fix immediatemode with mplayer (ie playing both sound and video)
albeu
parents:
10735
diff
changeset
|
1645 priv->first = 0; |
80402283a017
Fix immediatemode with mplayer (ie playing both sound and video)
albeu
parents:
10735
diff
changeset
|
1646 } |
80402283a017
Fix immediatemode with mplayer (ie playing both sound and video)
albeu
parents:
10735
diff
changeset
|
1647 |
10536 | 1648 // compensate for dropped audio frames |
1649 if (priv->audio_drop && (priv->audio_head == priv->audio_tail)) { | |
1650 priv->audio_drop--; | |
1651 priv->audio_sent_blocks_total++; | |
1652 memset(buffer, 0, len); | |
1653 return (double)priv->audio_sent_blocks_total*priv->audio_secs_per_block; | |
1654 } | |
1655 | |
1656 while (priv->audio_head == priv->audio_tail) { | |
1657 usleep(10000); | |
1658 } | |
1659 memcpy(buffer, priv->audio_ringbuffer+priv->audio_head*priv->audio_in.blocksize, len); | |
1660 priv->audio_head = (priv->audio_head+1) % priv->audio_buffer_size; | |
1661 priv->audio_cnt--; | |
1662 priv->audio_sent_blocks_total++; | |
1663 return (double)priv->audio_sent_blocks_total*priv->audio_secs_per_block; | |
1664 } | |
1665 | |
1666 static int get_audio_framesize(priv_t *priv) | |
1667 { | |
1668 return(priv->audio_in.blocksize); | |
1669 } | |
1670 | |
10538 | 1671 #endif /* USE_TV && HAVE_TV_V4L2 */ |