obs-output.c 3.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138
  1. /******************************************************************************
  2. Copyright (C) 2013 by Hugh Bailey <[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 "obs.h"
  15. #include "obs-internal.h"
  16. bool load_output_info(void *module, const char *module_name,
  17. const char *id, struct output_info *info)
  18. {
  19. LOAD_MODULE_SUBFUNC(getname, true);
  20. LOAD_MODULE_SUBFUNC(create, true);
  21. LOAD_MODULE_SUBFUNC(destroy, true);
  22. LOAD_MODULE_SUBFUNC(update, true);
  23. LOAD_MODULE_SUBFUNC(start, true);
  24. LOAD_MODULE_SUBFUNC(stop, true);
  25. LOAD_MODULE_SUBFUNC(active, true);
  26. LOAD_MODULE_SUBFUNC(properties, false);
  27. LOAD_MODULE_SUBFUNC(pause, false);
  28. info->id = id;
  29. return true;
  30. }
  31. static inline const struct output_info *find_output(const char *id)
  32. {
  33. size_t i;
  34. for (i = 0; i < obs->output_types.num; i++)
  35. if (strcmp(obs->output_types.array[i].id, id) == 0)
  36. return obs->output_types.array+i;
  37. return NULL;
  38. }
  39. obs_output_t obs_output_create(const char *id, const char *name,
  40. obs_data_t settings)
  41. {
  42. const struct output_info *info = find_output(id);
  43. struct obs_output *output;
  44. if (!info) {
  45. blog(LOG_WARNING, "Output '%s' not found", id);
  46. return NULL;
  47. }
  48. output = bmalloc(sizeof(struct obs_output));
  49. output->callbacks = *info;
  50. output->settings = obs_data_newref(settings);
  51. output->data = info->create(output->settings, output);
  52. if (!output->data) {
  53. obs_data_release(output->settings);
  54. bfree(output);
  55. return NULL;
  56. }
  57. output->name = bstrdup(name);
  58. pthread_mutex_lock(&obs->data.outputs_mutex);
  59. da_push_back(obs->data.outputs, &output);
  60. pthread_mutex_unlock(&obs->data.outputs_mutex);
  61. return output;
  62. }
  63. void obs_output_destroy(obs_output_t output)
  64. {
  65. if (output) {
  66. if (output->callbacks.active) {
  67. if (output->callbacks.active(output->data))
  68. output->callbacks.stop(output->data);
  69. }
  70. pthread_mutex_lock(&obs->data.outputs_mutex);
  71. da_erase_item(obs->data.outputs, &output);
  72. pthread_mutex_unlock(&obs->data.outputs_mutex);
  73. output->callbacks.destroy(output->data);
  74. obs_data_release(output->settings);
  75. bfree(output->name);
  76. bfree(output);
  77. }
  78. }
  79. bool obs_output_start(obs_output_t output)
  80. {
  81. return output->callbacks.start(output->data);
  82. }
  83. void obs_output_stop(obs_output_t output)
  84. {
  85. output->callbacks.stop(output->data);
  86. }
  87. bool obs_output_active(obs_output_t output)
  88. {
  89. return output->callbacks.active(output);
  90. }
  91. obs_properties_t obs_output_properties(const char *id, const char *locale)
  92. {
  93. const struct output_info *info = find_output(id);
  94. if (info && info->properties)
  95. return info->properties(locale);
  96. return NULL;
  97. }
  98. void obs_output_update(obs_output_t output, obs_data_t settings)
  99. {
  100. obs_data_replace(&output->settings, settings);
  101. if (output->callbacks.update)
  102. output->callbacks.update(output->data, output->settings);
  103. }
  104. bool obs_output_canpause(obs_output_t output)
  105. {
  106. return output->callbacks.pause != NULL;
  107. }
  108. void obs_output_pause(obs_output_t output)
  109. {
  110. if (output->callbacks.pause)
  111. output->callbacks.pause(output->data);
  112. }