v4l2-input.c 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829
  1. /*
  2. Copyright (C) 2014 by Leonhard Oelke <[email protected]>
  3. This program is free software: you can redistribute it and/or modify
  4. it under the terms of the GNU General Public License as published by
  5. the Free Software Foundation, either version 2 of the License, or
  6. (at your option) any later version.
  7. This program is distributed in the hope that it will be useful,
  8. but WITHOUT ANY WARRANTY; without even the implied warranty of
  9. MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  10. GNU General Public License for more details.
  11. You should have received a copy of the GNU General Public License
  12. along with this program. If not, see <http://www.gnu.org/licenses/>.
  13. */
  14. #include <stdio.h>
  15. #include <stdlib.h>
  16. #include <unistd.h>
  17. #include <string.h>
  18. #include <inttypes.h>
  19. #include <fcntl.h>
  20. #include <dirent.h>
  21. #include <sys/time.h>
  22. #include <sys/types.h>
  23. #include <sys/ioctl.h>
  24. #include <sys/select.h>
  25. #include <linux/videodev2.h>
  26. #include <libv4l2.h>
  27. #include <util/threading.h>
  28. #include <util/bmem.h>
  29. #include <util/dstr.h>
  30. #include <util/platform.h>
  31. #include <obs-module.h>
  32. #include "v4l2-helpers.h"
  33. #if HAVE_UDEV
  34. #include "v4l2-udev.h"
  35. #endif
  36. #define V4L2_DATA(voidptr) struct v4l2_data *data = voidptr;
  37. #define timeval2ns(tv) \
  38. (((uint64_t) tv.tv_sec * 1000000000) + ((uint64_t) tv.tv_usec * 1000))
  39. #define blog(level, msg, ...) blog(level, "v4l2-input: " msg, ##__VA_ARGS__)
  40. /**
  41. * Data structure for the v4l2 source
  42. */
  43. struct v4l2_data {
  44. /* settings */
  45. char *device_id;
  46. int input;
  47. int pixfmt;
  48. int resolution;
  49. int framerate;
  50. bool sys_timing;
  51. /* internal data */
  52. obs_source_t *source;
  53. pthread_t thread;
  54. os_event_t *event;
  55. void *udev;
  56. int_fast32_t dev;
  57. int width;
  58. int height;
  59. int linesize;
  60. struct v4l2_buffer_data buffers;
  61. };
  62. /* forward declarations */
  63. static void v4l2_init(struct v4l2_data *data);
  64. static void v4l2_terminate(struct v4l2_data *data);
  65. /**
  66. * Prepare the output frame structure for obs and compute plane offsets
  67. *
  68. * Basically all data apart from memory pointers and the timestamp is known
  69. * before the capture starts. This function prepares the obs_source_frame
  70. * struct with all the data that is already known.
  71. *
  72. * v4l2 uses a continuous memory segment for all planes so we simply compute
  73. * offsets to add to the start address in order to give obs the correct data
  74. * pointers for the individual planes.
  75. */
  76. static void v4l2_prep_obs_frame(struct v4l2_data *data,
  77. struct obs_source_frame *frame, size_t *plane_offsets)
  78. {
  79. memset(frame, 0, sizeof(struct obs_source_frame));
  80. memset(plane_offsets, 0, sizeof(size_t) * MAX_AV_PLANES);
  81. frame->width = data->width;
  82. frame->height = data->height;
  83. frame->format = v4l2_to_obs_video_format(data->pixfmt);
  84. video_format_get_parameters(VIDEO_CS_DEFAULT, VIDEO_RANGE_PARTIAL,
  85. frame->color_matrix, frame->color_range_min,
  86. frame->color_range_max);
  87. switch(data->pixfmt) {
  88. case V4L2_PIX_FMT_NV12:
  89. frame->linesize[0] = data->linesize;
  90. frame->linesize[1] = data->linesize / 2;
  91. plane_offsets[1] = data->linesize * data->height;
  92. break;
  93. case V4L2_PIX_FMT_YVU420:
  94. frame->linesize[0] = data->linesize;
  95. frame->linesize[1] = data->linesize / 2;
  96. frame->linesize[2] = data->linesize / 2;
  97. plane_offsets[1] = data->linesize * data->height * 5 / 4;
  98. plane_offsets[2] = data->linesize * data->height;
  99. break;
  100. case V4L2_PIX_FMT_YUV420:
  101. frame->linesize[0] = data->linesize;
  102. frame->linesize[1] = data->linesize / 2;
  103. frame->linesize[2] = data->linesize / 2;
  104. plane_offsets[1] = data->linesize * data->height;
  105. plane_offsets[2] = data->linesize * data->height * 5 / 4;
  106. break;
  107. default:
  108. frame->linesize[0] = data->linesize;
  109. break;
  110. }
  111. }
  112. /*
  113. * Worker thread to get video data
  114. */
  115. static void *v4l2_thread(void *vptr)
  116. {
  117. V4L2_DATA(vptr);
  118. int r;
  119. fd_set fds;
  120. uint8_t *start;
  121. uint64_t frames;
  122. uint64_t first_ts;
  123. struct timeval tv;
  124. struct v4l2_buffer buf;
  125. struct obs_source_frame out;
  126. size_t plane_offsets[MAX_AV_PLANES];
  127. if (v4l2_start_capture(data->dev, &data->buffers) < 0)
  128. goto exit;
  129. frames = 0;
  130. first_ts = 0;
  131. v4l2_prep_obs_frame(data, &out, plane_offsets);
  132. while (os_event_try(data->event) == EAGAIN) {
  133. FD_ZERO(&fds);
  134. FD_SET(data->dev, &fds);
  135. tv.tv_sec = 1;
  136. tv.tv_usec = 0;
  137. r = select(data->dev + 1, &fds, NULL, NULL, &tv);
  138. if (r < 0) {
  139. if (errno == EINTR)
  140. continue;
  141. blog(LOG_DEBUG, "select failed");
  142. break;
  143. } else if (r == 0) {
  144. blog(LOG_DEBUG, "select timeout");
  145. continue;
  146. }
  147. buf.type = V4L2_BUF_TYPE_VIDEO_CAPTURE;
  148. buf.memory = V4L2_MEMORY_MMAP;
  149. if (v4l2_ioctl(data->dev, VIDIOC_DQBUF, &buf) < 0) {
  150. if (errno == EAGAIN)
  151. continue;
  152. blog(LOG_DEBUG, "failed to dequeue buffer");
  153. break;
  154. }
  155. out.timestamp = data->sys_timing ?
  156. os_gettime_ns() : timeval2ns(buf.timestamp);
  157. if (!frames)
  158. first_ts = out.timestamp;
  159. out.timestamp -= first_ts;
  160. start = (uint8_t *) data->buffers.info[buf.index].start;
  161. for (uint_fast32_t i = 0; i < MAX_AV_PLANES; ++i)
  162. out.data[i] = start + plane_offsets[i];
  163. obs_source_output_video(data->source, &out);
  164. if (v4l2_ioctl(data->dev, VIDIOC_QBUF, &buf) < 0) {
  165. blog(LOG_DEBUG, "failed to enqueue buffer");
  166. break;
  167. }
  168. frames++;
  169. }
  170. blog(LOG_INFO, "Stopped capture after %"PRIu64" frames", frames);
  171. exit:
  172. v4l2_stop_capture(data->dev);
  173. return NULL;
  174. }
  175. static const char* v4l2_getname(void)
  176. {
  177. return obs_module_text("V4L2Input");
  178. }
  179. static void v4l2_defaults(obs_data_t *settings)
  180. {
  181. obs_data_set_default_int(settings, "input", -1);
  182. obs_data_set_default_int(settings, "pixelformat", -1);
  183. obs_data_set_default_int(settings, "resolution", -1);
  184. obs_data_set_default_int(settings, "framerate", -1);
  185. obs_data_set_default_bool(settings, "system_timing", false);
  186. }
  187. /**
  188. * Enable/Disable all properties for the source.
  189. *
  190. * @note A property that should be ignored can be specified
  191. *
  192. * @param props the source properties
  193. * @param ignore ignore this property
  194. * @param enable enable/disable all properties
  195. */
  196. static void v4l2_props_set_enabled(obs_properties_t *props,
  197. obs_property_t *ignore, bool enable)
  198. {
  199. if (!props)
  200. return;
  201. for (obs_property_t *prop = obs_properties_first(props); prop != NULL;
  202. obs_property_next(&prop)) {
  203. if (prop == ignore)
  204. continue;
  205. obs_property_set_enabled(prop, enable);
  206. }
  207. }
  208. /*
  209. * List available devices
  210. */
  211. static void v4l2_device_list(obs_property_t *prop, obs_data_t *settings)
  212. {
  213. DIR *dirp;
  214. struct dirent *dp;
  215. struct dstr device;
  216. bool cur_device_found;
  217. size_t cur_device_index;
  218. const char *cur_device_name;
  219. dirp = opendir("/sys/class/video4linux");
  220. if (!dirp)
  221. return;
  222. cur_device_found = false;
  223. cur_device_name = obs_data_get_string(settings, "device_id");
  224. obs_property_list_clear(prop);
  225. dstr_init_copy(&device, "/dev/");
  226. while ((dp = readdir(dirp)) != NULL) {
  227. int fd;
  228. uint32_t caps;
  229. struct v4l2_capability video_cap;
  230. if (dp->d_type == DT_DIR)
  231. continue;
  232. dstr_resize(&device, 5);
  233. dstr_cat(&device, dp->d_name);
  234. if ((fd = v4l2_open(device.array, O_RDWR | O_NONBLOCK)) == -1) {
  235. blog(LOG_INFO, "Unable to open %s", device.array);
  236. continue;
  237. }
  238. if (v4l2_ioctl(fd, VIDIOC_QUERYCAP, &video_cap) == -1) {
  239. blog(LOG_INFO, "Failed to query capabilities for %s",
  240. device.array);
  241. v4l2_close(fd);
  242. continue;
  243. }
  244. caps = (video_cap.capabilities & V4L2_CAP_DEVICE_CAPS)
  245. ? video_cap.device_caps
  246. : video_cap.capabilities;
  247. if (!(caps & V4L2_CAP_VIDEO_CAPTURE)) {
  248. blog(LOG_INFO, "%s seems to not support video capture",
  249. device.array);
  250. v4l2_close(fd);
  251. continue;
  252. }
  253. obs_property_list_add_string(prop, (char *) video_cap.card,
  254. device.array);
  255. blog(LOG_INFO, "Found device '%s' at %s", video_cap.card,
  256. device.array);
  257. /* check if this is the currently used device */
  258. if (cur_device_name && !strcmp(cur_device_name, device.array))
  259. cur_device_found = true;
  260. v4l2_close(fd);
  261. }
  262. /* add currently selected device if not present, but disable it ... */
  263. if (!cur_device_found && cur_device_name && strlen(cur_device_name)) {
  264. cur_device_index = obs_property_list_add_string(prop,
  265. cur_device_name, cur_device_name);
  266. obs_property_list_item_disable(prop, cur_device_index, true);
  267. }
  268. closedir(dirp);
  269. dstr_free(&device);
  270. }
  271. /*
  272. * List inputs for device
  273. */
  274. static void v4l2_input_list(int_fast32_t dev, obs_property_t *prop)
  275. {
  276. struct v4l2_input in;
  277. memset(&in, 0, sizeof(in));
  278. obs_property_list_clear(prop);
  279. obs_property_list_add_int(prop, obs_module_text("LeaveUnchanged"), -1);
  280. while (v4l2_ioctl(dev, VIDIOC_ENUMINPUT, &in) == 0) {
  281. obs_property_list_add_int(prop, (char *) in.name, in.index);
  282. blog(LOG_INFO, "Found input '%s' (Index %d)", in.name,
  283. in.index);
  284. in.index++;
  285. }
  286. }
  287. /*
  288. * List formats for device
  289. */
  290. static void v4l2_format_list(int dev, obs_property_t *prop)
  291. {
  292. struct v4l2_fmtdesc fmt;
  293. fmt.type = V4L2_BUF_TYPE_VIDEO_CAPTURE;
  294. fmt.index = 0;
  295. struct dstr buffer;
  296. dstr_init(&buffer);
  297. obs_property_list_clear(prop);
  298. obs_property_list_add_int(prop, obs_module_text("LeaveUnchanged"), -1);
  299. while (v4l2_ioctl(dev, VIDIOC_ENUM_FMT, &fmt) == 0) {
  300. dstr_copy(&buffer, (char *) fmt.description);
  301. if (fmt.flags & V4L2_FMT_FLAG_EMULATED)
  302. dstr_cat(&buffer, " (Emulated)");
  303. if (v4l2_to_obs_video_format(fmt.pixelformat)
  304. != VIDEO_FORMAT_NONE) {
  305. obs_property_list_add_int(prop, buffer.array,
  306. fmt.pixelformat);
  307. blog(LOG_INFO, "Pixelformat: %s (available)",
  308. buffer.array);
  309. } else {
  310. blog(LOG_INFO, "Pixelformat: %s (unavailable)",
  311. buffer.array);
  312. }
  313. fmt.index++;
  314. }
  315. dstr_free(&buffer);
  316. }
  317. /*
  318. * List video standards for the device
  319. */
  320. static void v4l2_standard_list(int dev, obs_property_t *prop)
  321. {
  322. struct v4l2_standard std;
  323. std.index = 0;
  324. obs_property_list_clear(prop);
  325. obs_property_list_add_int(prop, obs_module_text("LeaveUnchanged"), -1);
  326. while (v4l2_ioctl(dev, VIDIOC_ENUMSTD, &std) == 0) {
  327. obs_property_list_add_int(prop, (char *) std.name, std.id);
  328. std.index++;
  329. }
  330. }
  331. /*
  332. * List resolutions for device and format
  333. */
  334. static void v4l2_resolution_list(int dev, uint_fast32_t pixelformat,
  335. obs_property_t *prop)
  336. {
  337. struct v4l2_frmsizeenum frmsize;
  338. frmsize.pixel_format = pixelformat;
  339. frmsize.index = 0;
  340. struct dstr buffer;
  341. dstr_init(&buffer);
  342. obs_property_list_clear(prop);
  343. obs_property_list_add_int(prop, obs_module_text("LeaveUnchanged"), -1);
  344. v4l2_ioctl(dev, VIDIOC_ENUM_FRAMESIZES, &frmsize);
  345. switch(frmsize.type) {
  346. case V4L2_FRMSIZE_TYPE_DISCRETE:
  347. while (v4l2_ioctl(dev, VIDIOC_ENUM_FRAMESIZES, &frmsize) == 0) {
  348. dstr_printf(&buffer, "%dx%d", frmsize.discrete.width,
  349. frmsize.discrete.height);
  350. obs_property_list_add_int(prop, buffer.array,
  351. v4l2_pack_tuple(frmsize.discrete.width,
  352. frmsize.discrete.height));
  353. frmsize.index++;
  354. }
  355. break;
  356. default:
  357. blog(LOG_INFO, "Stepwise and Continuous framesizes "
  358. "are currently hardcoded");
  359. for (const int *packed = v4l2_framesizes; *packed; ++packed) {
  360. int width;
  361. int height;
  362. v4l2_unpack_tuple(&width, &height, *packed);
  363. dstr_printf(&buffer, "%dx%d", width, height);
  364. obs_property_list_add_int(prop, buffer.array, *packed);
  365. }
  366. break;
  367. }
  368. dstr_free(&buffer);
  369. }
  370. /*
  371. * List framerates for device and resolution
  372. */
  373. static void v4l2_framerate_list(int dev, uint_fast32_t pixelformat,
  374. uint_fast32_t width, uint_fast32_t height, obs_property_t *prop)
  375. {
  376. struct v4l2_frmivalenum frmival;
  377. frmival.pixel_format = pixelformat;
  378. frmival.width = width;
  379. frmival.height = height;
  380. frmival.index = 0;
  381. struct dstr buffer;
  382. dstr_init(&buffer);
  383. obs_property_list_clear(prop);
  384. obs_property_list_add_int(prop, obs_module_text("LeaveUnchanged"), -1);
  385. v4l2_ioctl(dev, VIDIOC_ENUM_FRAMEINTERVALS, &frmival);
  386. switch(frmival.type) {
  387. case V4L2_FRMIVAL_TYPE_DISCRETE:
  388. while (v4l2_ioctl(dev, VIDIOC_ENUM_FRAMEINTERVALS,
  389. &frmival) == 0) {
  390. float fps = (float) frmival.discrete.denominator /
  391. frmival.discrete.numerator;
  392. int pack = v4l2_pack_tuple(frmival.discrete.numerator,
  393. frmival.discrete.denominator);
  394. dstr_printf(&buffer, "%.2f", fps);
  395. obs_property_list_add_int(prop, buffer.array, pack);
  396. frmival.index++;
  397. }
  398. break;
  399. default:
  400. blog(LOG_INFO, "Stepwise and Continuous framerates "
  401. "are currently hardcoded");
  402. for (const int *packed = v4l2_framerates; *packed; ++packed) {
  403. int num;
  404. int denom;
  405. v4l2_unpack_tuple(&num, &denom, *packed);
  406. float fps = (float) denom / num;
  407. dstr_printf(&buffer, "%.2f", fps);
  408. obs_property_list_add_int(prop, buffer.array, *packed);
  409. }
  410. break;
  411. }
  412. dstr_free(&buffer);
  413. }
  414. /*
  415. * Device selected callback
  416. */
  417. static bool device_selected(obs_properties_t *props, obs_property_t *p,
  418. obs_data_t *settings)
  419. {
  420. int dev = v4l2_open(obs_data_get_string(settings, "device_id"),
  421. O_RDWR | O_NONBLOCK);
  422. v4l2_props_set_enabled(props, p, (dev == -1) ? false : true);
  423. if (dev == -1)
  424. return false;
  425. obs_property_t *prop = obs_properties_get(props, "input");
  426. v4l2_input_list(dev, prop);
  427. v4l2_close(dev);
  428. obs_property_modified(prop, settings);
  429. return true;
  430. }
  431. /*
  432. * Input selected callback
  433. */
  434. static bool input_selected(obs_properties_t *props, obs_property_t *p,
  435. obs_data_t *settings)
  436. {
  437. UNUSED_PARAMETER(p);
  438. int dev = v4l2_open(obs_data_get_string(settings, "device_id"),
  439. O_RDWR | O_NONBLOCK);
  440. if (dev == -1)
  441. return false;
  442. obs_property_t *prop = obs_properties_get(props, "pixelformat");
  443. v4l2_format_list(dev, prop);
  444. v4l2_close(dev);
  445. obs_property_modified(prop, settings);
  446. return true;
  447. }
  448. /*
  449. * Format selected callback
  450. */
  451. static bool format_selected(obs_properties_t *props, obs_property_t *p,
  452. obs_data_t *settings)
  453. {
  454. UNUSED_PARAMETER(p);
  455. int dev = v4l2_open(obs_data_get_string(settings, "device_id"),
  456. O_RDWR | O_NONBLOCK);
  457. if (dev == -1)
  458. return false;
  459. obs_property_t *prop = obs_properties_get(props, "resolution");
  460. v4l2_resolution_list(dev, obs_data_get_int(settings, "pixelformat"),
  461. prop);
  462. v4l2_close(dev);
  463. obs_property_modified(prop, settings);
  464. return true;
  465. }
  466. /*
  467. * Resolution selected callback
  468. */
  469. static bool resolution_selected(obs_properties_t *props, obs_property_t *p,
  470. obs_data_t *settings)
  471. {
  472. UNUSED_PARAMETER(p);
  473. int width, height;
  474. int dev = v4l2_open(obs_data_get_string(settings, "device_id"),
  475. O_RDWR | O_NONBLOCK);
  476. if (dev == -1)
  477. return false;
  478. obs_property_t *prop = obs_properties_get(props, "framerate");
  479. v4l2_unpack_tuple(&width, &height, obs_data_get_int(settings,
  480. "resolution"));
  481. v4l2_framerate_list(dev, obs_data_get_int(settings, "pixelformat"),
  482. width, height, prop);
  483. v4l2_close(dev);
  484. obs_property_modified(prop, settings);
  485. return true;
  486. }
  487. #if HAVE_UDEV
  488. /**
  489. * Device added callback
  490. *
  491. * If everything went fine we can start capturing again when the device is
  492. * reconnected
  493. */
  494. static void device_added(const char *dev, void *vptr)
  495. {
  496. V4L2_DATA(vptr);
  497. obs_source_update_properties(data->source);
  498. if (strcmp(data->device_id, dev))
  499. return;
  500. blog(LOG_INFO, "Device %s reconnected", dev);
  501. v4l2_init(data);
  502. }
  503. /**
  504. * Device removed callback
  505. *
  506. * We stop recording here so we don't block the device node
  507. */
  508. static void device_removed(const char *dev, void *vptr)
  509. {
  510. V4L2_DATA(vptr);
  511. obs_source_update_properties(data->source);
  512. if (strcmp(data->device_id, dev))
  513. return;
  514. blog(LOG_INFO, "Device %s disconnected", dev);
  515. v4l2_terminate(data);
  516. }
  517. #endif
  518. static obs_properties_t *v4l2_properties(void *vptr)
  519. {
  520. V4L2_DATA(vptr);
  521. obs_properties_t *props = obs_properties_create();
  522. obs_property_t *device_list = obs_properties_add_list(props,
  523. "device_id", obs_module_text("Device"),
  524. OBS_COMBO_TYPE_LIST, OBS_COMBO_FORMAT_STRING);
  525. obs_property_t *input_list = obs_properties_add_list(props,
  526. "input", obs_module_text("Input"),
  527. OBS_COMBO_TYPE_LIST, OBS_COMBO_FORMAT_INT);
  528. obs_property_t *format_list = obs_properties_add_list(props,
  529. "pixelformat", obs_module_text("VideoFormat"),
  530. OBS_COMBO_TYPE_LIST, OBS_COMBO_FORMAT_INT);
  531. obs_property_t *resolution_list = obs_properties_add_list(props,
  532. "resolution", obs_module_text("Resolution"),
  533. OBS_COMBO_TYPE_LIST, OBS_COMBO_FORMAT_INT);
  534. obs_properties_add_list(props,
  535. "framerate", obs_module_text("FrameRate"),
  536. OBS_COMBO_TYPE_LIST, OBS_COMBO_FORMAT_INT);
  537. obs_properties_add_bool(props,
  538. "system_timing", obs_module_text("UseSystemTiming"));
  539. obs_data_t *settings = obs_source_get_settings(data->source);
  540. v4l2_device_list(device_list, settings);
  541. obs_data_release(settings);
  542. obs_property_set_modified_callback(device_list, device_selected);
  543. obs_property_set_modified_callback(input_list, input_selected);
  544. obs_property_set_modified_callback(format_list, format_selected);
  545. obs_property_set_modified_callback(resolution_list,
  546. resolution_selected);
  547. return props;
  548. }
  549. static void v4l2_terminate(struct v4l2_data *data)
  550. {
  551. if (data->thread) {
  552. os_event_signal(data->event);
  553. pthread_join(data->thread, NULL);
  554. os_event_destroy(data->event);
  555. data->thread = 0;
  556. }
  557. v4l2_destroy_mmap(&data->buffers);
  558. if (data->dev != -1) {
  559. v4l2_close(data->dev);
  560. data->dev = -1;
  561. }
  562. }
  563. static void v4l2_destroy(void *vptr)
  564. {
  565. V4L2_DATA(vptr);
  566. if (!data)
  567. return;
  568. v4l2_terminate(data);
  569. if (data->device_id)
  570. bfree(data->device_id);
  571. #if HAVE_UDEV
  572. v4l2_unref_udev(data->udev);
  573. #endif
  574. bfree(data);
  575. }
  576. /**
  577. * Initialize the v4l2 device
  578. *
  579. * This function:
  580. * - tries to open the device
  581. * - sets pixelformat and requested resolution
  582. * - sets the requested framerate
  583. * - maps the buffers
  584. * - starts the capture thread
  585. */
  586. static void v4l2_init(struct v4l2_data *data)
  587. {
  588. int fps_num, fps_denom;
  589. blog(LOG_INFO, "Start capture from %s", data->device_id);
  590. data->dev = v4l2_open(data->device_id, O_RDWR | O_NONBLOCK);
  591. if (data->dev == -1) {
  592. blog(LOG_ERROR, "Unable to open device");
  593. goto fail;
  594. }
  595. /* set input */
  596. if (v4l2_set_input(data->dev, &data->input) < 0) {
  597. blog(LOG_ERROR, "Unable to set input %d", data->input);
  598. goto fail;
  599. }
  600. blog(LOG_INFO, "Input: %d", data->input);
  601. /* set pixel format and resolution */
  602. if (v4l2_set_format(data->dev, &data->resolution, &data->pixfmt,
  603. &data->linesize) < 0) {
  604. blog(LOG_ERROR, "Unable to set format");
  605. goto fail;
  606. }
  607. if (v4l2_to_obs_video_format(data->pixfmt) == VIDEO_FORMAT_NONE) {
  608. blog(LOG_ERROR, "Selected video format not supported");
  609. goto fail;
  610. }
  611. v4l2_unpack_tuple(&data->width, &data->height, data->resolution);
  612. blog(LOG_INFO, "Resolution: %dx%d", data->width, data->height);
  613. blog(LOG_INFO, "Pixelformat: %d", data->pixfmt);
  614. blog(LOG_INFO, "Linesize: %d Bytes", data->linesize);
  615. /* set framerate */
  616. if (v4l2_set_framerate(data->dev, &data->framerate) < 0) {
  617. blog(LOG_ERROR, "Unable to set framerate");
  618. goto fail;
  619. }
  620. v4l2_unpack_tuple(&fps_num, &fps_denom, data->framerate);
  621. blog(LOG_INFO, "Framerate: %.2f fps", (float) fps_denom / fps_num);
  622. /* map buffers */
  623. if (v4l2_create_mmap(data->dev, &data->buffers) < 0) {
  624. blog(LOG_ERROR, "Failed to map buffers");
  625. goto fail;
  626. }
  627. /* start the capture thread */
  628. if (os_event_init(&data->event, OS_EVENT_TYPE_MANUAL) != 0)
  629. goto fail;
  630. if (pthread_create(&data->thread, NULL, v4l2_thread, data) != 0)
  631. goto fail;
  632. return;
  633. fail:
  634. blog(LOG_ERROR, "Initialization failed");
  635. v4l2_terminate(data);
  636. }
  637. /**
  638. * Update the settings for the v4l2 source
  639. *
  640. * Since there are very few settings that can be changed without restarting the
  641. * stream we don't bother to even try. Whenever this is called the currently
  642. * active stream (if exists) is stopped, the settings are updated and finally
  643. * the new stream is started.
  644. */
  645. static void v4l2_update(void *vptr, obs_data_t *settings)
  646. {
  647. V4L2_DATA(vptr);
  648. v4l2_terminate(data);
  649. if (data->device_id)
  650. bfree(data->device_id);
  651. data->device_id = bstrdup(obs_data_get_string(settings, "device_id"));
  652. data->input = obs_data_get_int(settings, "input");
  653. data->pixfmt = obs_data_get_int(settings, "pixelformat");
  654. data->resolution = obs_data_get_int(settings, "resolution");
  655. data->framerate = obs_data_get_int(settings, "framerate");
  656. data->sys_timing = obs_data_get_bool(settings, "system_timing");
  657. v4l2_init(data);
  658. }
  659. static void *v4l2_create(obs_data_t *settings, obs_source_t *source)
  660. {
  661. struct v4l2_data *data = bzalloc(sizeof(struct v4l2_data));
  662. data->dev = -1;
  663. data->source = source;
  664. v4l2_update(data, settings);
  665. #if HAVE_UDEV
  666. data->udev = v4l2_init_udev();
  667. v4l2_set_device_added_callback(data->udev, &device_added, data);
  668. v4l2_set_device_removed_callback(data->udev, &device_removed, data);
  669. #endif
  670. return data;
  671. }
  672. struct obs_source_info v4l2_input = {
  673. .id = "v4l2_input",
  674. .type = OBS_SOURCE_TYPE_INPUT,
  675. .output_flags = OBS_SOURCE_ASYNC_VIDEO,
  676. .get_name = v4l2_getname,
  677. .create = v4l2_create,
  678. .destroy = v4l2_destroy,
  679. .update = v4l2_update,
  680. .get_defaults = v4l2_defaults,
  681. .get_properties = v4l2_properties
  682. };