mac-audio.c 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822
  1. #include <AudioUnit/AudioUnit.h>
  2. #include <CoreFoundation/CFString.h>
  3. #include <CoreAudio/CoreAudio.h>
  4. #include <unistd.h>
  5. #include <errno.h>
  6. #include <obs-module.h>
  7. #include <util/threading.h>
  8. #include <util/c99defs.h>
  9. #include "mac-helpers.h"
  10. #include "audio-device-enum.h"
  11. #define PROPERTY_DEFAULT_DEVICE kAudioHardwarePropertyDefaultInputDevice
  12. #define PROPERTY_FORMATS kAudioStreamPropertyAvailablePhysicalFormats
  13. #define SCOPE_OUTPUT kAudioUnitScope_Output
  14. #define SCOPE_INPUT kAudioUnitScope_Input
  15. #define SCOPE_GLOBAL kAudioUnitScope_Global
  16. #define BUS_OUTPUT 0
  17. #define BUS_INPUT 1
  18. #define MAX_DEVICES 20
  19. #define set_property AudioUnitSetProperty
  20. #define get_property AudioUnitGetProperty
  21. #define TEXT_AUDIO_INPUT obs_module_text("CoreAudio.InputCapture");
  22. #define TEXT_AUDIO_OUTPUT obs_module_text("CoreAudio.OutputCapture");
  23. #define TEXT_DEVICE obs_module_text("CoreAudio.Device")
  24. #define TEXT_DEVICE_DEFAULT obs_module_text("CoreAudio.Device.Default")
  25. struct coreaudio_data {
  26. char *device_name;
  27. char *device_uid;
  28. AudioUnit unit;
  29. AudioDeviceID device_id;
  30. AudioBufferList *buf_list;
  31. bool au_initialized;
  32. bool active;
  33. bool default_device;
  34. bool input;
  35. bool no_devices;
  36. uint32_t sample_rate;
  37. enum audio_format format;
  38. enum speaker_layout speakers;
  39. pthread_t reconnect_thread;
  40. os_event_t *exit_event;
  41. volatile bool reconnecting;
  42. unsigned long retry_time;
  43. obs_source_t *source;
  44. };
  45. static bool get_default_output_device(struct coreaudio_data *ca)
  46. {
  47. struct device_list list;
  48. memset(&list, 0, sizeof(struct device_list));
  49. coreaudio_enum_devices(&list, false);
  50. if (!list.items.num)
  51. return false;
  52. bfree(ca->device_uid);
  53. ca->device_uid = bstrdup(list.items.array[0].value.array);
  54. device_list_free(&list);
  55. return true;
  56. }
  57. static bool find_device_id_by_uid(struct coreaudio_data *ca)
  58. {
  59. UInt32 size = sizeof(AudioDeviceID);
  60. CFStringRef cf_uid = NULL;
  61. CFStringRef qual = NULL;
  62. UInt32 qual_size = 0;
  63. OSStatus stat;
  64. bool success;
  65. AudioObjectPropertyAddress addr = {
  66. .mScope = kAudioObjectPropertyScopeGlobal,
  67. .mElement = kAudioObjectPropertyElementMaster
  68. };
  69. if (!ca->device_uid)
  70. ca->device_uid = bstrdup("default");
  71. /* have to do this because mac output devices don't actually exist */
  72. if (astrcmpi(ca->device_uid, "default") == 0) {
  73. if (ca->input) {
  74. ca->default_device = true;
  75. } else {
  76. if (!get_default_output_device(ca)) {
  77. ca->no_devices = true;
  78. return false;
  79. }
  80. }
  81. }
  82. cf_uid = CFStringCreateWithCString(NULL, ca->device_uid,
  83. kCFStringEncodingUTF8);
  84. if (ca->default_device) {
  85. addr.mSelector = PROPERTY_DEFAULT_DEVICE;
  86. stat = AudioObjectGetPropertyData(kAudioObjectSystemObject,
  87. &addr, qual_size, &qual, &size, &ca->device_id);
  88. success = (stat == noErr);
  89. } else {
  90. success = coreaudio_get_device_id(cf_uid, &ca->device_id);
  91. }
  92. if (cf_uid)
  93. CFRelease(cf_uid);
  94. return success;
  95. }
  96. static inline void ca_warn(struct coreaudio_data *ca, const char *func,
  97. const char *format, ...)
  98. {
  99. va_list args;
  100. struct dstr str = {0};
  101. va_start(args, format);
  102. dstr_printf(&str, "[%s]:[device '%s'] ", func, ca->device_name);
  103. dstr_vcatf(&str, format, args);
  104. blog(LOG_WARNING, "%s", str.array);
  105. dstr_free(&str);
  106. va_end(args);
  107. }
  108. static inline bool ca_success(OSStatus stat, struct coreaudio_data *ca,
  109. const char *func, const char *action)
  110. {
  111. if (stat != noErr) {
  112. blog(LOG_WARNING, "[%s]:[device '%s'] %s failed: %d",
  113. func, ca->device_name, action, (int)stat);
  114. return false;
  115. }
  116. return true;
  117. }
  118. enum coreaudio_io_type {
  119. IO_TYPE_INPUT,
  120. IO_TYPE_OUTPUT,
  121. };
  122. static inline bool enable_io(struct coreaudio_data *ca,
  123. enum coreaudio_io_type type, bool enable)
  124. {
  125. UInt32 enable_int = enable;
  126. return set_property(ca->unit, kAudioOutputUnitProperty_EnableIO,
  127. (type == IO_TYPE_INPUT) ? SCOPE_INPUT : SCOPE_OUTPUT,
  128. (type == IO_TYPE_INPUT) ? BUS_INPUT : BUS_OUTPUT,
  129. &enable_int, sizeof(enable_int));
  130. }
  131. static inline enum audio_format convert_ca_format(UInt32 format_flags,
  132. UInt32 bits)
  133. {
  134. bool planar = (format_flags & kAudioFormatFlagIsNonInterleaved) != 0;
  135. if (format_flags & kAudioFormatFlagIsFloat)
  136. return planar ? AUDIO_FORMAT_FLOAT_PLANAR : AUDIO_FORMAT_FLOAT;
  137. if (!(format_flags & kAudioFormatFlagIsSignedInteger) && bits == 8)
  138. return planar ? AUDIO_FORMAT_U8BIT_PLANAR : AUDIO_FORMAT_U8BIT;
  139. /* not float? not signed int? no clue, fail */
  140. if ((format_flags & kAudioFormatFlagIsSignedInteger) == 0)
  141. return AUDIO_FORMAT_UNKNOWN;
  142. if (bits == 16)
  143. return planar ? AUDIO_FORMAT_16BIT_PLANAR : AUDIO_FORMAT_16BIT;
  144. else if (bits == 32)
  145. return planar ? AUDIO_FORMAT_32BIT_PLANAR : AUDIO_FORMAT_32BIT;
  146. return AUDIO_FORMAT_UNKNOWN;
  147. }
  148. static inline enum speaker_layout convert_ca_speaker_layout(UInt32 channels)
  149. {
  150. switch (channels) {
  151. case 1: return SPEAKERS_MONO;
  152. case 2: return SPEAKERS_STEREO;
  153. case 3: return SPEAKERS_2POINT1;
  154. case 4: return SPEAKERS_4POINT0;
  155. case 5: return SPEAKERS_4POINT1;
  156. case 6: return SPEAKERS_5POINT1;
  157. case 8: return SPEAKERS_7POINT1;
  158. }
  159. return SPEAKERS_UNKNOWN;
  160. }
  161. static bool coreaudio_init_format(struct coreaudio_data *ca)
  162. {
  163. AudioStreamBasicDescription desc;
  164. OSStatus stat;
  165. UInt32 size = sizeof(desc);
  166. struct obs_audio_info aoi;
  167. int channels;
  168. if (!obs_get_audio_info(&aoi)) {
  169. blog(LOG_WARNING, "No active audio");
  170. return false;
  171. }
  172. channels = get_audio_channels(aoi.speakers);
  173. stat = get_property(ca->unit, kAudioUnitProperty_StreamFormat,
  174. SCOPE_INPUT, BUS_INPUT, &desc, &size);
  175. if (!ca_success(stat, ca, "coreaudio_init_format", "get input format"))
  176. return false;
  177. /* Certain types of devices have no limit on channel count, and
  178. * there's no way to know the actual number of channels it's using,
  179. * so if we encounter this situation just force to what is defined in output */
  180. if (desc.mChannelsPerFrame > 8) {
  181. desc.mChannelsPerFrame = channels;
  182. desc.mBytesPerFrame = channels * desc.mBitsPerChannel / 8;
  183. desc.mBytesPerPacket =
  184. desc.mFramesPerPacket * desc.mBytesPerFrame;
  185. }
  186. stat = set_property(ca->unit, kAudioUnitProperty_StreamFormat,
  187. SCOPE_OUTPUT, BUS_INPUT, &desc, size);
  188. if (!ca_success(stat, ca, "coreaudio_init_format", "set output format"))
  189. return false;
  190. if (desc.mFormatID != kAudioFormatLinearPCM) {
  191. ca_warn(ca, "coreaudio_init_format", "format is not PCM");
  192. return false;
  193. }
  194. ca->format = convert_ca_format(desc.mFormatFlags, desc.mBitsPerChannel);
  195. if (ca->format == AUDIO_FORMAT_UNKNOWN) {
  196. ca_warn(ca, "coreaudio_init_format", "unknown format flags: "
  197. "%u, bits: %u",
  198. (unsigned int)desc.mFormatFlags,
  199. (unsigned int)desc.mBitsPerChannel);
  200. return false;
  201. }
  202. ca->sample_rate = (uint32_t)desc.mSampleRate;
  203. ca->speakers = convert_ca_speaker_layout(desc.mChannelsPerFrame);
  204. if (ca->speakers == SPEAKERS_UNKNOWN) {
  205. ca_warn(ca, "coreaudio_init_format", "unknown speaker layout: "
  206. "%u channels",
  207. (unsigned int)desc.mChannelsPerFrame);
  208. return false;
  209. }
  210. return true;
  211. }
  212. static bool coreaudio_init_buffer(struct coreaudio_data *ca)
  213. {
  214. UInt32 buf_size = 0;
  215. UInt32 size = 0;
  216. UInt32 frames = 0;
  217. OSStatus stat;
  218. AudioObjectPropertyAddress addr = {
  219. kAudioDevicePropertyStreamConfiguration,
  220. kAudioDevicePropertyScopeInput,
  221. kAudioObjectPropertyElementMaster
  222. };
  223. stat = AudioObjectGetPropertyDataSize(ca->device_id, &addr, 0, NULL,
  224. &buf_size);
  225. if (!ca_success(stat, ca, "coreaudio_init_buffer", "get list size"))
  226. return false;
  227. size = sizeof(frames);
  228. stat = get_property(ca->unit, kAudioDevicePropertyBufferFrameSize,
  229. SCOPE_GLOBAL, 0, &frames, &size);
  230. if (!ca_success(stat, ca, "coreaudio_init_buffer", "get frame size"))
  231. return false;
  232. /* ---------------------- */
  233. ca->buf_list = bmalloc(buf_size);
  234. stat = AudioObjectGetPropertyData(ca->device_id, &addr, 0, NULL,
  235. &buf_size, ca->buf_list);
  236. if (!ca_success(stat, ca, "coreaudio_init_buffer", "allocate")) {
  237. bfree(ca->buf_list);
  238. ca->buf_list = NULL;
  239. return false;
  240. }
  241. for (UInt32 i = 0; i < ca->buf_list->mNumberBuffers; i++) {
  242. size = ca->buf_list->mBuffers[i].mDataByteSize;
  243. ca->buf_list->mBuffers[i].mData = bmalloc(size);
  244. }
  245. return true;
  246. }
  247. static void buf_list_free(AudioBufferList *buf_list)
  248. {
  249. if (buf_list) {
  250. for (UInt32 i = 0; i < buf_list->mNumberBuffers; i++)
  251. bfree(buf_list->mBuffers[i].mData);
  252. bfree(buf_list);
  253. }
  254. }
  255. static OSStatus input_callback(
  256. void *data,
  257. AudioUnitRenderActionFlags *action_flags,
  258. const AudioTimeStamp *ts_data,
  259. UInt32 bus_num,
  260. UInt32 frames,
  261. AudioBufferList *ignored_buffers)
  262. {
  263. struct coreaudio_data *ca = data;
  264. OSStatus stat;
  265. struct obs_source_audio audio;
  266. stat = AudioUnitRender(ca->unit, action_flags, ts_data, bus_num, frames,
  267. ca->buf_list);
  268. if (!ca_success(stat, ca, "input_callback", "audio retrieval"))
  269. return noErr;
  270. for (UInt32 i = 0; i < ca->buf_list->mNumberBuffers; i++)
  271. audio.data[i] = ca->buf_list->mBuffers[i].mData;
  272. audio.frames = frames;
  273. audio.speakers = ca->speakers;
  274. audio.format = ca->format;
  275. audio.samples_per_sec = ca->sample_rate;
  276. audio.timestamp = ts_data->mHostTime;
  277. obs_source_output_audio(ca->source, &audio);
  278. UNUSED_PARAMETER(ignored_buffers);
  279. return noErr;
  280. }
  281. static void coreaudio_stop(struct coreaudio_data *ca);
  282. static bool coreaudio_init(struct coreaudio_data *ca);
  283. static void coreaudio_uninit(struct coreaudio_data *ca);
  284. static void *reconnect_thread(void *param)
  285. {
  286. struct coreaudio_data *ca = param;
  287. ca->reconnecting = true;
  288. while (os_event_timedwait(ca->exit_event, ca->retry_time) == ETIMEDOUT) {
  289. if (coreaudio_init(ca))
  290. break;
  291. }
  292. blog(LOG_DEBUG, "coreaudio: exit the reconnect thread");
  293. ca->reconnecting = false;
  294. return NULL;
  295. }
  296. static void coreaudio_begin_reconnect(struct coreaudio_data *ca)
  297. {
  298. int ret;
  299. if (ca->reconnecting)
  300. return;
  301. ret = pthread_create(&ca->reconnect_thread, NULL, reconnect_thread, ca);
  302. if (ret != 0)
  303. blog(LOG_WARNING, "[coreaudio_begin_reconnect] failed to "
  304. "create thread, error code: %d", ret);
  305. }
  306. static OSStatus notification_callback(
  307. AudioObjectID id,
  308. UInt32 num_addresses,
  309. const AudioObjectPropertyAddress addresses[],
  310. void *data)
  311. {
  312. struct coreaudio_data *ca = data;
  313. coreaudio_stop(ca);
  314. coreaudio_uninit(ca);
  315. if (addresses[0].mSelector == PROPERTY_DEFAULT_DEVICE)
  316. ca->retry_time = 300;
  317. else
  318. ca->retry_time = 2000;
  319. blog(LOG_INFO, "coreaudio: device '%s' disconnected or changed. "
  320. "attempting to reconnect", ca->device_name);
  321. coreaudio_begin_reconnect(ca);
  322. UNUSED_PARAMETER(id);
  323. UNUSED_PARAMETER(num_addresses);
  324. return noErr;
  325. }
  326. static OSStatus add_listener(struct coreaudio_data *ca, UInt32 property)
  327. {
  328. AudioObjectPropertyAddress addr = {
  329. property,
  330. kAudioObjectPropertyScopeGlobal,
  331. kAudioObjectPropertyElementMaster
  332. };
  333. return AudioObjectAddPropertyListener(ca->device_id, &addr,
  334. notification_callback, ca);
  335. }
  336. static bool coreaudio_init_hooks(struct coreaudio_data *ca)
  337. {
  338. OSStatus stat;
  339. AURenderCallbackStruct callback_info = {
  340. .inputProc = input_callback,
  341. .inputProcRefCon = ca
  342. };
  343. stat = add_listener(ca, kAudioDevicePropertyDeviceIsAlive);
  344. if (!ca_success(stat, ca, "coreaudio_init_hooks",
  345. "set disconnect callback"))
  346. return false;
  347. stat = add_listener(ca, PROPERTY_FORMATS);
  348. if (!ca_success(stat, ca, "coreaudio_init_hooks",
  349. "set format change callback"))
  350. return false;
  351. if (ca->default_device) {
  352. AudioObjectPropertyAddress addr = {
  353. PROPERTY_DEFAULT_DEVICE,
  354. kAudioObjectPropertyScopeGlobal,
  355. kAudioObjectPropertyElementMaster
  356. };
  357. stat = AudioObjectAddPropertyListener(kAudioObjectSystemObject,
  358. &addr, notification_callback, ca);
  359. if (!ca_success(stat, ca, "coreaudio_init_hooks",
  360. "set device change callback"))
  361. return false;
  362. }
  363. stat = set_property(ca->unit, kAudioOutputUnitProperty_SetInputCallback,
  364. SCOPE_GLOBAL, 0, &callback_info, sizeof(callback_info));
  365. if (!ca_success(stat, ca, "coreaudio_init_hooks", "set input callback"))
  366. return false;
  367. return true;
  368. }
  369. static void coreaudio_remove_hooks(struct coreaudio_data *ca)
  370. {
  371. AURenderCallbackStruct callback_info = {
  372. .inputProc = NULL,
  373. .inputProcRefCon = NULL
  374. };
  375. AudioObjectPropertyAddress addr = {
  376. kAudioDevicePropertyDeviceIsAlive,
  377. kAudioObjectPropertyScopeGlobal,
  378. kAudioObjectPropertyElementMaster
  379. };
  380. AudioObjectRemovePropertyListener(ca->device_id, &addr,
  381. notification_callback, ca);
  382. addr.mSelector = PROPERTY_FORMATS;
  383. AudioObjectRemovePropertyListener(ca->device_id, &addr,
  384. notification_callback, ca);
  385. if (ca->default_device) {
  386. addr.mSelector = PROPERTY_DEFAULT_DEVICE;
  387. AudioObjectRemovePropertyListener(kAudioObjectSystemObject,
  388. &addr, notification_callback, ca);
  389. }
  390. set_property(ca->unit, kAudioOutputUnitProperty_SetInputCallback,
  391. SCOPE_GLOBAL, 0, &callback_info, sizeof(callback_info));
  392. }
  393. static bool coreaudio_get_device_name(struct coreaudio_data *ca)
  394. {
  395. CFStringRef cf_name = NULL;
  396. UInt32 size = sizeof(CFStringRef);
  397. char name[1024];
  398. const AudioObjectPropertyAddress addr = {
  399. kAudioDevicePropertyDeviceNameCFString,
  400. kAudioObjectPropertyScopeInput,
  401. kAudioObjectPropertyElementMaster
  402. };
  403. OSStatus stat = AudioObjectGetPropertyData(ca->device_id, &addr,
  404. 0, NULL, &size, &cf_name);
  405. if (stat != noErr) {
  406. blog(LOG_WARNING, "[coreaudio_get_device_name] failed to "
  407. "get name: %d", (int)stat);
  408. return false;
  409. }
  410. if (!cf_to_cstr(cf_name, name, 1024)) {
  411. blog(LOG_WARNING, "[coreaudio_get_device_name] failed to "
  412. "convert name to cstr for some reason");
  413. return false;
  414. }
  415. bfree(ca->device_name);
  416. ca->device_name = bstrdup(name);
  417. if (cf_name)
  418. CFRelease(cf_name);
  419. return true;
  420. }
  421. static bool coreaudio_start(struct coreaudio_data *ca)
  422. {
  423. OSStatus stat;
  424. if (ca->active)
  425. return true;
  426. stat = AudioOutputUnitStart(ca->unit);
  427. return ca_success(stat, ca, "coreaudio_start", "start audio");
  428. }
  429. static void coreaudio_stop(struct coreaudio_data *ca)
  430. {
  431. OSStatus stat;
  432. if (!ca->active)
  433. return;
  434. ca->active = false;
  435. stat = AudioOutputUnitStop(ca->unit);
  436. ca_success(stat, ca, "coreaudio_stop", "stop audio");
  437. }
  438. static bool coreaudio_init_unit(struct coreaudio_data *ca)
  439. {
  440. AudioComponentDescription desc = {
  441. .componentType = kAudioUnitType_Output,
  442. .componentSubType = kAudioUnitSubType_HALOutput
  443. };
  444. AudioComponent component = AudioComponentFindNext(NULL, &desc);
  445. if (!component) {
  446. ca_warn(ca, "coreaudio_init_unit", "find component failed");
  447. return false;
  448. }
  449. OSStatus stat = AudioComponentInstanceNew(component, &ca->unit);
  450. if (!ca_success(stat, ca, "coreaudio_init_unit", "instance unit"))
  451. return false;
  452. ca->au_initialized = true;
  453. return true;
  454. }
  455. static bool coreaudio_init(struct coreaudio_data *ca)
  456. {
  457. OSStatus stat;
  458. if (ca->au_initialized)
  459. return true;
  460. if (!find_device_id_by_uid(ca))
  461. return false;
  462. if (!coreaudio_get_device_name(ca))
  463. return false;
  464. if (!coreaudio_init_unit(ca))
  465. return false;
  466. stat = enable_io(ca, IO_TYPE_INPUT, true);
  467. if (!ca_success(stat, ca, "coreaudio_init", "enable input io"))
  468. goto fail;
  469. stat = enable_io(ca, IO_TYPE_OUTPUT, false);
  470. if (!ca_success(stat, ca, "coreaudio_init", "disable output io"))
  471. goto fail;
  472. stat = set_property(ca->unit, kAudioOutputUnitProperty_CurrentDevice,
  473. SCOPE_GLOBAL, 0, &ca->device_id, sizeof(ca->device_id));
  474. if (!ca_success(stat, ca, "coreaudio_init", "set current device"))
  475. goto fail;
  476. if (!coreaudio_init_format(ca))
  477. goto fail;
  478. if (!coreaudio_init_buffer(ca))
  479. goto fail;
  480. if (!coreaudio_init_hooks(ca))
  481. goto fail;
  482. stat = AudioUnitInitialize(ca->unit);
  483. if (!ca_success(stat, ca, "coreaudio_initialize", "initialize"))
  484. goto fail;
  485. if (!coreaudio_start(ca))
  486. goto fail;
  487. blog(LOG_INFO, "coreaudio: device '%s' initialized", ca->device_name);
  488. return ca->au_initialized;
  489. fail:
  490. coreaudio_uninit(ca);
  491. return false;
  492. }
  493. static void coreaudio_try_init(struct coreaudio_data *ca)
  494. {
  495. if (!coreaudio_init(ca)) {
  496. blog(LOG_INFO, "coreaudio: failed to find device "
  497. "uid: %s, waiting for connection",
  498. ca->device_uid);
  499. ca->retry_time = 2000;
  500. if (ca->no_devices)
  501. blog(LOG_INFO, "coreaudio: no device found");
  502. else
  503. coreaudio_begin_reconnect(ca);
  504. }
  505. }
  506. static void coreaudio_uninit(struct coreaudio_data *ca)
  507. {
  508. if (!ca->au_initialized)
  509. return;
  510. if (ca->unit) {
  511. coreaudio_stop(ca);
  512. OSStatus stat = AudioUnitUninitialize(ca->unit);
  513. ca_success(stat, ca, "coreaudio_uninit", "uninitialize");
  514. coreaudio_remove_hooks(ca);
  515. stat = AudioComponentInstanceDispose(ca->unit);
  516. ca_success(stat, ca, "coreaudio_uninit", "dispose");
  517. ca->unit = NULL;
  518. }
  519. ca->au_initialized = false;
  520. buf_list_free(ca->buf_list);
  521. ca->buf_list = NULL;
  522. }
  523. /* ------------------------------------------------------------------------- */
  524. static const char *coreaudio_input_getname(void *unused)
  525. {
  526. UNUSED_PARAMETER(unused);
  527. return TEXT_AUDIO_INPUT;
  528. }
  529. static const char *coreaudio_output_getname(void *unused)
  530. {
  531. UNUSED_PARAMETER(unused);
  532. return TEXT_AUDIO_OUTPUT;
  533. }
  534. static void coreaudio_shutdown(struct coreaudio_data *ca)
  535. {
  536. if (ca->reconnecting) {
  537. os_event_signal(ca->exit_event);
  538. pthread_join(ca->reconnect_thread, NULL);
  539. os_event_reset(ca->exit_event);
  540. }
  541. coreaudio_uninit(ca);
  542. if (ca->unit)
  543. AudioComponentInstanceDispose(ca->unit);
  544. }
  545. static void coreaudio_destroy(void *data)
  546. {
  547. struct coreaudio_data *ca = data;
  548. if (ca) {
  549. coreaudio_shutdown(ca);
  550. os_event_destroy(ca->exit_event);
  551. bfree(ca->device_name);
  552. bfree(ca->device_uid);
  553. bfree(ca);
  554. }
  555. }
  556. static void coreaudio_update(void *data, obs_data_t *settings)
  557. {
  558. struct coreaudio_data *ca = data;
  559. coreaudio_shutdown(ca);
  560. bfree(ca->device_uid);
  561. ca->device_uid = bstrdup(obs_data_get_string(settings, "device_id"));
  562. coreaudio_try_init(ca);
  563. }
  564. static void coreaudio_defaults(obs_data_t *settings)
  565. {
  566. obs_data_set_default_string(settings, "device_id", "default");
  567. }
  568. static void *coreaudio_create(obs_data_t *settings, obs_source_t *source,
  569. bool input)
  570. {
  571. struct coreaudio_data *ca = bzalloc(sizeof(struct coreaudio_data));
  572. if (os_event_init(&ca->exit_event, OS_EVENT_TYPE_MANUAL) != 0) {
  573. blog(LOG_ERROR, "[coreaudio_create] failed to create "
  574. "semephore: %d", errno);
  575. bfree(ca);
  576. return NULL;
  577. }
  578. ca->device_uid = bstrdup(obs_data_get_string(settings, "device_id"));
  579. ca->source = source;
  580. ca->input = input;
  581. if (!ca->device_uid)
  582. ca->device_uid = bstrdup("default");
  583. coreaudio_try_init(ca);
  584. return ca;
  585. }
  586. static void *coreaudio_create_input_capture(obs_data_t *settings,
  587. obs_source_t *source)
  588. {
  589. return coreaudio_create(settings, source, true);
  590. }
  591. static void *coreaudio_create_output_capture(obs_data_t *settings,
  592. obs_source_t *source)
  593. {
  594. return coreaudio_create(settings, source, false);
  595. }
  596. static obs_properties_t *coreaudio_properties(bool input)
  597. {
  598. obs_properties_t *props = obs_properties_create();
  599. obs_property_t *property;
  600. struct device_list devices;
  601. memset(&devices, 0, sizeof(struct device_list));
  602. property = obs_properties_add_list(props, "device_id", TEXT_DEVICE,
  603. OBS_COMBO_TYPE_LIST, OBS_COMBO_FORMAT_STRING);
  604. coreaudio_enum_devices(&devices, input);
  605. if (devices.items.num)
  606. obs_property_list_add_string(property, TEXT_DEVICE_DEFAULT,
  607. "default");
  608. for (size_t i = 0; i < devices.items.num; i++) {
  609. struct device_item *item = devices.items.array+i;
  610. obs_property_list_add_string(property,
  611. item->name.array, item->value.array);
  612. }
  613. device_list_free(&devices);
  614. return props;
  615. }
  616. static obs_properties_t *coreaudio_input_properties(void *unused)
  617. {
  618. UNUSED_PARAMETER(unused);
  619. return coreaudio_properties(true);
  620. }
  621. static obs_properties_t *coreaudio_output_properties(void *unused)
  622. {
  623. UNUSED_PARAMETER(unused);
  624. return coreaudio_properties(false);
  625. }
  626. struct obs_source_info coreaudio_input_capture_info = {
  627. .id = "coreaudio_input_capture",
  628. .type = OBS_SOURCE_TYPE_INPUT,
  629. .output_flags = OBS_SOURCE_AUDIO |
  630. OBS_SOURCE_DO_NOT_DUPLICATE,
  631. .get_name = coreaudio_input_getname,
  632. .create = coreaudio_create_input_capture,
  633. .destroy = coreaudio_destroy,
  634. .update = coreaudio_update,
  635. .get_defaults = coreaudio_defaults,
  636. .get_properties = coreaudio_input_properties
  637. };
  638. struct obs_source_info coreaudio_output_capture_info = {
  639. .id = "coreaudio_output_capture",
  640. .type = OBS_SOURCE_TYPE_INPUT,
  641. .output_flags = OBS_SOURCE_AUDIO |
  642. OBS_SOURCE_DO_NOT_DUPLICATE |
  643. OBS_SOURCE_DO_NOT_SELF_MONITOR,
  644. .get_name = coreaudio_output_getname,
  645. .create = coreaudio_create_output_capture,
  646. .destroy = coreaudio_destroy,
  647. .update = coreaudio_update,
  648. .get_defaults = coreaudio_defaults,
  649. .get_properties = coreaudio_output_properties
  650. };