jack2 codebase
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

998 lines
33KB

  1. /*
  2. Copyright (C) 2001 Paul Davis
  3. Copyright (C) 2004 Grame
  4. This program is free software; you can redistribute it and/or modify
  5. it under the terms of the GNU General Public License as published by
  6. the Free Software Foundation; either version 2 of the License, or
  7. (at your option) any later version.
  8. This program is distributed in the hope that it will be useful,
  9. but WITHOUT ANY WARRANTY; without even the implied warranty of
  10. MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  11. GNU General Public License for more details.
  12. You should have received a copy of the GNU General Public License
  13. along with this program; if not, write to the Free Software
  14. Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  15. */
  16. #define __STDC_FORMAT_MACROS // For inttypes.h to work in C++
  17. #include <iostream>
  18. #include <math.h>
  19. #include <stdio.h>
  20. #include <memory.h>
  21. #include <unistd.h>
  22. #include <stdlib.h>
  23. #include <errno.h>
  24. #include <stdarg.h>
  25. #include <signal.h>
  26. #include <sys/types.h>
  27. #include <sys/time.h>
  28. #include <string.h>
  29. #include "JackAlsaDriver.h"
  30. #include "JackEngineControl.h"
  31. #include "JackClientControl.h"
  32. #include "JackPort.h"
  33. #include "JackGraphManager.h"
  34. #include "JackLockedEngine.h"
  35. #include "JackPosixThread.h"
  36. #include "JackCompilerDeps.h"
  37. #include "JackServerGlobals.h"
  38. namespace Jack
  39. {
  40. int JackAlsaDriver::SetBufferSize(jack_nframes_t buffer_size)
  41. {
  42. jack_log("JackAlsaDriver::SetBufferSize %ld", buffer_size);
  43. int res = alsa_driver_reset_parameters((alsa_driver_t *)fDriver, buffer_size,
  44. ((alsa_driver_t *)fDriver)->user_nperiods,
  45. ((alsa_driver_t *)fDriver)->frame_rate);
  46. if (res == 0) { // update fEngineControl and fGraphManager
  47. JackAudioDriver::SetBufferSize(buffer_size); // Generic change, never fails
  48. // ALSA specific
  49. UpdateLatencies();
  50. } else {
  51. // Restore old values
  52. alsa_driver_reset_parameters((alsa_driver_t *)fDriver, fEngineControl->fBufferSize,
  53. ((alsa_driver_t *)fDriver)->user_nperiods,
  54. ((alsa_driver_t *)fDriver)->frame_rate);
  55. }
  56. return res;
  57. }
  58. void JackAlsaDriver::UpdateLatencies()
  59. {
  60. jack_latency_range_t range;
  61. alsa_driver_t* alsa_driver = (alsa_driver_t*)fDriver;
  62. for (int i = 0; i < fCaptureChannels; i++) {
  63. range.min = range.max = alsa_driver->frames_per_cycle + alsa_driver->capture_frame_latency;
  64. fGraphManager->GetPort(fCapturePortList[i])->SetLatencyRange(JackCaptureLatency, &range);
  65. }
  66. for (int i = 0; i < fPlaybackChannels; i++) {
  67. // Add one buffer more latency if "async" mode is used...
  68. range.min = range.max = (alsa_driver->frames_per_cycle * (alsa_driver->user_nperiods - 1)) +
  69. ((fEngineControl->fSyncMode) ? 0 : fEngineControl->fBufferSize) + alsa_driver->playback_frame_latency;
  70. fGraphManager->GetPort(fPlaybackPortList[i])->SetLatencyRange(JackPlaybackLatency, &range);
  71. // Monitor port
  72. if (fWithMonitorPorts) {
  73. range.min = range.max = alsa_driver->frames_per_cycle;
  74. fGraphManager->GetPort(fMonitorPortList[i])->SetLatencyRange(JackCaptureLatency, &range);
  75. }
  76. }
  77. }
  78. int JackAlsaDriver::Attach()
  79. {
  80. JackPort* port;
  81. jack_port_id_t port_index;
  82. unsigned long port_flags = (unsigned long)CaptureDriverFlags;
  83. char name[REAL_JACK_PORT_NAME_SIZE];
  84. char alias[REAL_JACK_PORT_NAME_SIZE];
  85. assert(fCaptureChannels < DRIVER_PORT_NUM);
  86. assert(fPlaybackChannels < DRIVER_PORT_NUM);
  87. alsa_driver_t* alsa_driver = (alsa_driver_t*)fDriver;
  88. if (alsa_driver->has_hw_monitoring)
  89. port_flags |= JackPortCanMonitor;
  90. // ALSA driver may have changed the values
  91. JackAudioDriver::SetBufferSize(alsa_driver->frames_per_cycle);
  92. JackAudioDriver::SetSampleRate(alsa_driver->frame_rate);
  93. jack_log("JackAlsaDriver::Attach fBufferSize %ld fSampleRate %ld", fEngineControl->fBufferSize, fEngineControl->fSampleRate);
  94. for (int i = 0; i < fCaptureChannels; i++) {
  95. snprintf(alias, sizeof(alias), "%s:%s:out%d", fAliasName, fCaptureDriverName, i + 1);
  96. snprintf(name, sizeof(name), "%s:capture_%d", fClientControl.fName, i + 1);
  97. if (fEngine->PortRegister(fClientControl.fRefNum, name, JACK_DEFAULT_AUDIO_TYPE, (JackPortFlags)port_flags, fEngineControl->fBufferSize, &port_index) < 0) {
  98. jack_error("driver: cannot register port for %s", name);
  99. return -1;
  100. }
  101. port = fGraphManager->GetPort(port_index);
  102. port->SetAlias(alias);
  103. fCapturePortList[i] = port_index;
  104. jack_log("JackAlsaDriver::Attach fCapturePortList[i] %ld ", port_index);
  105. }
  106. port_flags = (unsigned long)PlaybackDriverFlags;
  107. for (int i = 0; i < fPlaybackChannels; i++) {
  108. snprintf(alias, sizeof(alias), "%s:%s:in%d", fAliasName, fPlaybackDriverName, i + 1);
  109. snprintf(name, sizeof(name), "%s:playback_%d", fClientControl.fName, i + 1);
  110. if (fEngine->PortRegister(fClientControl.fRefNum, name, JACK_DEFAULT_AUDIO_TYPE, (JackPortFlags)port_flags, fEngineControl->fBufferSize, &port_index) < 0) {
  111. jack_error("driver: cannot register port for %s", name);
  112. return -1;
  113. }
  114. port = fGraphManager->GetPort(port_index);
  115. port->SetAlias(alias);
  116. fPlaybackPortList[i] = port_index;
  117. jack_log("JackAlsaDriver::Attach fPlaybackPortList[i] %ld ", port_index);
  118. // Monitor ports
  119. if (fWithMonitorPorts) {
  120. jack_log("Create monitor port");
  121. snprintf(name, sizeof(name), "%s:monitor_%d", fClientControl.fName, i + 1);
  122. if (fEngine->PortRegister(fClientControl.fRefNum, name, JACK_DEFAULT_AUDIO_TYPE, MonitorDriverFlags, fEngineControl->fBufferSize, &port_index) < 0) {
  123. jack_error("ALSA: cannot register monitor port for %s", name);
  124. } else {
  125. fMonitorPortList[i] = port_index;
  126. }
  127. }
  128. }
  129. UpdateLatencies();
  130. if (alsa_driver->midi) {
  131. int err = (alsa_driver->midi->attach)(alsa_driver->midi);
  132. if (err)
  133. jack_error ("ALSA: cannot attach MIDI: %d", err);
  134. }
  135. return 0;
  136. }
  137. int JackAlsaDriver::Detach()
  138. {
  139. alsa_driver_t* alsa_driver = (alsa_driver_t*)fDriver;
  140. if (alsa_driver->midi)
  141. (alsa_driver->midi->detach)(alsa_driver->midi);
  142. return JackAudioDriver::Detach();
  143. }
  144. extern "C" char* get_control_device_name(const char * device_name)
  145. {
  146. char * ctl_name;
  147. const char * comma;
  148. /* the user wants a hw or plughw device, the ctl name
  149. * should be hw:x where x is the card identification.
  150. * We skip the subdevice suffix that starts with comma */
  151. if (strncasecmp(device_name, "plughw:", 7) == 0) {
  152. /* skip the "plug" prefix" */
  153. device_name += 4;
  154. }
  155. comma = strchr(device_name, ',');
  156. if (comma == NULL) {
  157. ctl_name = strdup(device_name);
  158. if (ctl_name == NULL) {
  159. jack_error("strdup(\"%s\") failed.", device_name);
  160. }
  161. } else {
  162. ctl_name = strndup(device_name, comma - device_name);
  163. if (ctl_name == NULL) {
  164. jack_error("strndup(\"%s\", %u) failed.", device_name, (unsigned int)(comma - device_name));
  165. }
  166. }
  167. return ctl_name;
  168. }
  169. static int card_to_num(const char* device)
  170. {
  171. int err;
  172. char* ctl_name;
  173. snd_ctl_card_info_t *card_info;
  174. snd_ctl_t* ctl_handle;
  175. int i = -1;
  176. snd_ctl_card_info_alloca (&card_info);
  177. ctl_name = get_control_device_name(device);
  178. if (ctl_name == NULL) {
  179. jack_error("get_control_device_name() failed.");
  180. goto fail;
  181. }
  182. if ((err = snd_ctl_open (&ctl_handle, ctl_name, 0)) < 0) {
  183. jack_error ("control open \"%s\" (%s)", ctl_name,
  184. snd_strerror(err));
  185. goto free;
  186. }
  187. if ((err = snd_ctl_card_info(ctl_handle, card_info)) < 0) {
  188. jack_error ("control hardware info \"%s\" (%s)",
  189. device, snd_strerror (err));
  190. goto close;
  191. }
  192. i = snd_ctl_card_info_get_card(card_info);
  193. close:
  194. snd_ctl_close(ctl_handle);
  195. free:
  196. free(ctl_name);
  197. fail:
  198. return i;
  199. }
  200. int JackAlsaDriver::Open(jack_nframes_t nframes,
  201. jack_nframes_t user_nperiods,
  202. jack_nframes_t samplerate,
  203. bool hw_monitoring,
  204. bool hw_metering,
  205. bool capturing,
  206. bool playing,
  207. DitherAlgorithm dither,
  208. bool soft_mode,
  209. bool monitor,
  210. int inchannels,
  211. int outchannels,
  212. bool shorts_first,
  213. const char* capture_driver_name,
  214. const char* playback_driver_name,
  215. jack_nframes_t capture_latency,
  216. jack_nframes_t playback_latency,
  217. const char* midi_driver_name)
  218. {
  219. // Generic JackAudioDriver Open
  220. if (JackAudioDriver::Open(nframes, samplerate, capturing, playing,
  221. inchannels, outchannels, monitor, capture_driver_name, playback_driver_name,
  222. capture_latency, playback_latency) != 0) {
  223. return -1;
  224. }
  225. alsa_midi_t *midi = 0;
  226. if (strcmp(midi_driver_name, "seq") == 0)
  227. midi = alsa_seqmidi_new((jack_client_t*)this, 0);
  228. else if (strcmp(midi_driver_name, "raw") == 0)
  229. midi = alsa_rawmidi_new((jack_client_t*)this);
  230. if (JackServerGlobals::on_device_acquire != NULL) {
  231. int capture_card = card_to_num(capture_driver_name);
  232. int playback_card = card_to_num(playback_driver_name);
  233. char audio_name[32];
  234. if (capture_card >= 0) {
  235. snprintf(audio_name, sizeof(audio_name), "Audio%d", capture_card);
  236. if (!JackServerGlobals::on_device_acquire(audio_name)) {
  237. jack_error("Audio device %s cannot be acquired...", capture_driver_name);
  238. return -1;
  239. }
  240. }
  241. if (playback_card >= 0 && playback_card != capture_card) {
  242. snprintf(audio_name, sizeof(audio_name), "Audio%d", playback_card);
  243. if (!JackServerGlobals::on_device_acquire(audio_name)) {
  244. jack_error("Audio device %s cannot be acquired...", playback_driver_name);
  245. if (capture_card >= 0) {
  246. snprintf(audio_name, sizeof(audio_name), "Audio%d", capture_card);
  247. JackServerGlobals::on_device_release(audio_name);
  248. }
  249. return -1;
  250. }
  251. }
  252. }
  253. fDriver = alsa_driver_new ((char*)"alsa_pcm", (char*)playback_driver_name, (char*)capture_driver_name,
  254. NULL,
  255. nframes,
  256. user_nperiods,
  257. samplerate,
  258. hw_monitoring,
  259. hw_metering,
  260. capturing,
  261. playing,
  262. dither,
  263. soft_mode,
  264. monitor,
  265. inchannels,
  266. outchannels,
  267. shorts_first,
  268. capture_latency,
  269. playback_latency,
  270. midi);
  271. if (fDriver) {
  272. // ALSA driver may have changed the in/out values
  273. fCaptureChannels = ((alsa_driver_t *)fDriver)->capture_nchannels;
  274. fPlaybackChannels = ((alsa_driver_t *)fDriver)->playback_nchannels;
  275. return 0;
  276. } else {
  277. JackAudioDriver::Close();
  278. return -1;
  279. }
  280. }
  281. int JackAlsaDriver::Close()
  282. {
  283. // Generic audio driver close
  284. int res = JackAudioDriver::Close();
  285. alsa_driver_delete((alsa_driver_t*)fDriver);
  286. if (JackServerGlobals::on_device_release != NULL)
  287. {
  288. char audio_name[32];
  289. int capture_card = card_to_num(fCaptureDriverName);
  290. if (capture_card >= 0) {
  291. snprintf(audio_name, sizeof(audio_name), "Audio%d", capture_card);
  292. JackServerGlobals::on_device_release(audio_name);
  293. }
  294. int playback_card = card_to_num(fPlaybackDriverName);
  295. if (playback_card >= 0 && playback_card != capture_card) {
  296. snprintf(audio_name, sizeof(audio_name), "Audio%d", playback_card);
  297. JackServerGlobals::on_device_release(audio_name);
  298. }
  299. }
  300. return res;
  301. }
  302. int JackAlsaDriver::Start()
  303. {
  304. int res = JackAudioDriver::Start();
  305. if (res >= 0) {
  306. res = alsa_driver_start((alsa_driver_t *)fDriver);
  307. if (res < 0) {
  308. JackAudioDriver::Stop();
  309. }
  310. }
  311. return res;
  312. }
  313. int JackAlsaDriver::Stop()
  314. {
  315. int res = alsa_driver_stop((alsa_driver_t *)fDriver);
  316. if (JackAudioDriver::Stop() < 0) {
  317. res = -1;
  318. }
  319. return res;
  320. }
  321. int JackAlsaDriver::Read()
  322. {
  323. /* Taken from alsa_driver_run_cycle */
  324. int wait_status;
  325. jack_nframes_t nframes;
  326. fDelayedUsecs = 0.f;
  327. retry:
  328. nframes = alsa_driver_wait((alsa_driver_t *)fDriver, -1, &wait_status, &fDelayedUsecs);
  329. if (wait_status < 0)
  330. return -1; /* driver failed */
  331. if (nframes == 0) {
  332. /* we detected an xrun and restarted: notify
  333. * clients about the delay.
  334. */
  335. jack_log("ALSA XRun wait_status = %d", wait_status);
  336. NotifyXRun(fBeginDateUst, fDelayedUsecs);
  337. goto retry; /* recoverable error*/
  338. }
  339. if (nframes != fEngineControl->fBufferSize)
  340. jack_log("JackAlsaDriver::Read warning fBufferSize = %ld nframes = %ld", fEngineControl->fBufferSize, nframes);
  341. // Has to be done before read
  342. JackDriver::CycleIncTime();
  343. return alsa_driver_read((alsa_driver_t *)fDriver, fEngineControl->fBufferSize);
  344. }
  345. int JackAlsaDriver::Write()
  346. {
  347. return alsa_driver_write((alsa_driver_t *)fDriver, fEngineControl->fBufferSize);
  348. }
  349. void JackAlsaDriver::ReadInputAux(jack_nframes_t orig_nframes, snd_pcm_sframes_t contiguous, snd_pcm_sframes_t nread)
  350. {
  351. for (int chn = 0; chn < fCaptureChannels; chn++) {
  352. if (fGraphManager->GetConnectionsNum(fCapturePortList[chn]) > 0) {
  353. jack_default_audio_sample_t* buf = (jack_default_audio_sample_t*)fGraphManager->GetBuffer(fCapturePortList[chn], orig_nframes);
  354. alsa_driver_read_from_channel((alsa_driver_t *)fDriver, chn, buf + nread, contiguous);
  355. }
  356. }
  357. }
  358. void JackAlsaDriver::MonitorInputAux()
  359. {
  360. for (int chn = 0; chn < fCaptureChannels; chn++) {
  361. JackPort* port = fGraphManager->GetPort(fCapturePortList[chn]);
  362. if (port->MonitoringInput()) {
  363. ((alsa_driver_t *)fDriver)->input_monitor_mask |= (1 << chn);
  364. }
  365. }
  366. }
  367. void JackAlsaDriver::ClearOutputAux()
  368. {
  369. for (int chn = 0; chn < fPlaybackChannels; chn++) {
  370. jack_default_audio_sample_t* buf =
  371. (jack_default_audio_sample_t*)fGraphManager->GetBuffer(fPlaybackPortList[chn], fEngineControl->fBufferSize);
  372. memset(buf, 0, sizeof (jack_default_audio_sample_t) * fEngineControl->fBufferSize);
  373. }
  374. }
  375. void JackAlsaDriver::SetTimetAux(jack_time_t time)
  376. {
  377. fBeginDateUst = time;
  378. }
  379. void JackAlsaDriver::WriteOutputAux(jack_nframes_t orig_nframes, snd_pcm_sframes_t contiguous, snd_pcm_sframes_t nwritten)
  380. {
  381. for (int chn = 0; chn < fPlaybackChannels; chn++) {
  382. // Output ports
  383. if (fGraphManager->GetConnectionsNum(fPlaybackPortList[chn]) > 0) {
  384. jack_default_audio_sample_t* buf = (jack_default_audio_sample_t*)fGraphManager->GetBuffer(fPlaybackPortList[chn], orig_nframes);
  385. alsa_driver_write_to_channel(((alsa_driver_t *)fDriver), chn, buf + nwritten, contiguous);
  386. // Monitor ports
  387. if (fWithMonitorPorts && fGraphManager->GetConnectionsNum(fMonitorPortList[chn]) > 0) {
  388. jack_default_audio_sample_t* monbuf = (jack_default_audio_sample_t*)fGraphManager->GetBuffer(fMonitorPortList[chn], orig_nframes);
  389. memcpy(monbuf + nwritten, buf + nwritten, contiguous * sizeof(jack_default_audio_sample_t));
  390. }
  391. }
  392. }
  393. }
  394. int JackAlsaDriver::is_realtime() const
  395. {
  396. return fEngineControl->fRealTime;
  397. }
  398. int JackAlsaDriver::create_thread(pthread_t *thread, int priority, int realtime, void *(*start_routine)(void*), void *arg)
  399. {
  400. return JackPosixThread::StartImp(thread, priority, realtime, start_routine, arg);
  401. }
  402. jack_port_id_t JackAlsaDriver::port_register(const char *port_name, const char *port_type, unsigned long flags, unsigned long buffer_size)
  403. {
  404. jack_port_id_t port_index;
  405. int res = fEngine->PortRegister(fClientControl.fRefNum, port_name, port_type, flags, buffer_size, &port_index);
  406. return (res == 0) ? port_index : 0;
  407. }
  408. int JackAlsaDriver::port_unregister(jack_port_id_t port_index)
  409. {
  410. return fEngine->PortUnRegister(fClientControl.fRefNum, port_index);
  411. }
  412. void* JackAlsaDriver::port_get_buffer(int port, jack_nframes_t nframes)
  413. {
  414. return fGraphManager->GetBuffer(port, nframes);
  415. }
  416. int JackAlsaDriver::port_set_alias(int port, const char* name)
  417. {
  418. return fGraphManager->GetPort(port)->SetAlias(name);
  419. }
  420. jack_nframes_t JackAlsaDriver::get_sample_rate() const
  421. {
  422. return fEngineControl->fSampleRate;
  423. }
  424. jack_nframes_t JackAlsaDriver::frame_time() const
  425. {
  426. JackTimer timer;
  427. fEngineControl->ReadFrameTime(&timer);
  428. return timer.Time2Frames(GetMicroSeconds(), fEngineControl->fBufferSize);
  429. }
  430. jack_nframes_t JackAlsaDriver::last_frame_time() const
  431. {
  432. JackTimer timer;
  433. fEngineControl->ReadFrameTime(&timer);
  434. return timer.CurFrame();
  435. }
  436. } // end of namespace
  437. #ifdef __cplusplus
  438. extern "C"
  439. {
  440. #endif
  441. static
  442. void
  443. fill_device(
  444. jack_driver_param_constraint_desc_t ** constraint_ptr_ptr,
  445. uint32_t * array_size_ptr,
  446. const char * device_id,
  447. const char * device_description)
  448. {
  449. jack_driver_param_value_enum_t * possible_value_ptr;
  450. //jack_info("%6s - %s", device_id, device_description);
  451. if (*constraint_ptr_ptr == NULL)
  452. {
  453. *constraint_ptr_ptr = (jack_driver_param_constraint_desc_t *)calloc(1, sizeof(jack_driver_param_value_enum_t));
  454. *array_size_ptr = 0;
  455. }
  456. if ((*constraint_ptr_ptr)->constraint.enumeration.count == *array_size_ptr)
  457. {
  458. *array_size_ptr += 10;
  459. (*constraint_ptr_ptr)->constraint.enumeration.possible_values_array =
  460. (jack_driver_param_value_enum_t *)realloc(
  461. (*constraint_ptr_ptr)->constraint.enumeration.possible_values_array,
  462. sizeof(jack_driver_param_value_enum_t) * *array_size_ptr);
  463. }
  464. possible_value_ptr = (*constraint_ptr_ptr)->constraint.enumeration.possible_values_array + (*constraint_ptr_ptr)->constraint.enumeration.count;
  465. (*constraint_ptr_ptr)->constraint.enumeration.count++;
  466. strcpy(possible_value_ptr->value.str, device_id);
  467. strcpy(possible_value_ptr->short_desc, device_description);
  468. }
  469. static
  470. jack_driver_param_constraint_desc_t *
  471. enum_alsa_devices()
  472. {
  473. snd_ctl_t * handle;
  474. snd_ctl_card_info_t * info;
  475. snd_pcm_info_t * pcminfo_capture;
  476. snd_pcm_info_t * pcminfo_playback;
  477. int card_no = -1;
  478. char card_id[JACK_DRIVER_PARAM_STRING_MAX + 1];
  479. char device_id[JACK_DRIVER_PARAM_STRING_MAX + 1];
  480. char description[64];
  481. int device_no;
  482. bool has_capture;
  483. bool has_playback;
  484. jack_driver_param_constraint_desc_t * constraint_ptr;
  485. uint32_t array_size = 0;
  486. snd_ctl_card_info_alloca(&info);
  487. snd_pcm_info_alloca(&pcminfo_capture);
  488. snd_pcm_info_alloca(&pcminfo_playback);
  489. constraint_ptr = NULL;
  490. while(snd_card_next(&card_no) >= 0 && card_no >= 0)
  491. {
  492. snprintf(card_id, sizeof(card_id), "hw:%d", card_no);
  493. if (snd_ctl_open(&handle, card_id, 0) >= 0 &&
  494. snd_ctl_card_info(handle, info) >= 0)
  495. {
  496. snprintf(card_id, sizeof(card_id), "hw:%s", snd_ctl_card_info_get_id(info));
  497. fill_device(&constraint_ptr, &array_size, card_id, snd_ctl_card_info_get_name(info));
  498. device_no = -1;
  499. while (snd_ctl_pcm_next_device(handle, &device_no) >= 0 && device_no != -1)
  500. {
  501. snprintf(device_id, sizeof(device_id), "%s,%d", card_id, device_no);
  502. snd_pcm_info_set_device(pcminfo_capture, device_no);
  503. snd_pcm_info_set_subdevice(pcminfo_capture, 0);
  504. snd_pcm_info_set_stream(pcminfo_capture, SND_PCM_STREAM_CAPTURE);
  505. has_capture = snd_ctl_pcm_info(handle, pcminfo_capture) >= 0;
  506. snd_pcm_info_set_device(pcminfo_playback, device_no);
  507. snd_pcm_info_set_subdevice(pcminfo_playback, 0);
  508. snd_pcm_info_set_stream(pcminfo_playback, SND_PCM_STREAM_PLAYBACK);
  509. has_playback = snd_ctl_pcm_info(handle, pcminfo_playback) >= 0;
  510. if (has_capture && has_playback)
  511. {
  512. snprintf(description, sizeof(description),"%s (duplex)", snd_pcm_info_get_name(pcminfo_capture));
  513. }
  514. else if (has_capture)
  515. {
  516. snprintf(description, sizeof(description),"%s (capture)", snd_pcm_info_get_name(pcminfo_capture));
  517. }
  518. else if (has_playback)
  519. {
  520. snprintf(description, sizeof(description),"%s (playback)", snd_pcm_info_get_name(pcminfo_playback));
  521. }
  522. else
  523. {
  524. continue;
  525. }
  526. fill_device(&constraint_ptr, &array_size, device_id, description);
  527. }
  528. snd_ctl_close(handle);
  529. }
  530. }
  531. return constraint_ptr;
  532. }
  533. static
  534. jack_driver_param_constraint_desc_t *
  535. get_midi_driver_constraint()
  536. {
  537. jack_driver_param_constraint_desc_t * constraint_ptr;
  538. jack_driver_param_value_enum_t * possible_value_ptr;
  539. //jack_info("%6s - %s", device_id, device_description);
  540. constraint_ptr = (jack_driver_param_constraint_desc_t *)calloc(1, sizeof(jack_driver_param_value_enum_t));
  541. constraint_ptr->flags = JACK_CONSTRAINT_FLAG_STRICT | JACK_CONSTRAINT_FLAG_FAKE_VALUE;
  542. constraint_ptr->constraint.enumeration.possible_values_array = (jack_driver_param_value_enum_t *)malloc(3 * sizeof(jack_driver_param_value_enum_t));
  543. constraint_ptr->constraint.enumeration.count = 3;
  544. possible_value_ptr = constraint_ptr->constraint.enumeration.possible_values_array;
  545. strcpy(possible_value_ptr->value.str, "none");
  546. strcpy(possible_value_ptr->short_desc, "no MIDI driver");
  547. possible_value_ptr++;
  548. strcpy(possible_value_ptr->value.str, "seq");
  549. strcpy(possible_value_ptr->short_desc, "ALSA Sequencer driver");
  550. possible_value_ptr++;
  551. strcpy(possible_value_ptr->value.str, "raw");
  552. strcpy(possible_value_ptr->short_desc, "ALSA RawMIDI driver");
  553. return constraint_ptr;
  554. }
  555. static
  556. jack_driver_param_constraint_desc_t *
  557. get_dither_constraint()
  558. {
  559. jack_driver_param_constraint_desc_t * constraint_ptr;
  560. jack_driver_param_value_enum_t * possible_value_ptr;
  561. //jack_info("%6s - %s", device_id, device_description);
  562. constraint_ptr = (jack_driver_param_constraint_desc_t *)calloc(1, sizeof(jack_driver_param_value_enum_t));
  563. constraint_ptr->flags = JACK_CONSTRAINT_FLAG_STRICT | JACK_CONSTRAINT_FLAG_FAKE_VALUE;
  564. constraint_ptr->constraint.enumeration.possible_values_array = (jack_driver_param_value_enum_t *)malloc(4 * sizeof(jack_driver_param_value_enum_t));
  565. constraint_ptr->constraint.enumeration.count = 4;
  566. possible_value_ptr = constraint_ptr->constraint.enumeration.possible_values_array;
  567. possible_value_ptr->value.c = 'n';
  568. strcpy(possible_value_ptr->short_desc, "none");
  569. possible_value_ptr++;
  570. possible_value_ptr->value.c = 'r';
  571. strcpy(possible_value_ptr->short_desc, "rectangular");
  572. possible_value_ptr++;
  573. possible_value_ptr->value.c = 's';
  574. strcpy(possible_value_ptr->short_desc, "shaped");
  575. possible_value_ptr++;
  576. possible_value_ptr->value.c = 't';
  577. strcpy(possible_value_ptr->short_desc, "triangular");
  578. return constraint_ptr;
  579. }
  580. static int
  581. dither_opt (char c, DitherAlgorithm* dither)
  582. {
  583. switch (c) {
  584. case '-':
  585. case 'n':
  586. *dither = None;
  587. break;
  588. case 'r':
  589. *dither = Rectangular;
  590. break;
  591. case 's':
  592. *dither = Shaped;
  593. break;
  594. case 't':
  595. *dither = Triangular;
  596. break;
  597. default:
  598. fprintf (stderr, "ALSA driver: illegal dithering mode %c\n", c);
  599. return -1;
  600. }
  601. return 0;
  602. }
  603. SERVER_EXPORT const jack_driver_desc_t* driver_get_descriptor ()
  604. {
  605. jack_driver_desc_t * desc;
  606. jack_driver_desc_filler_t filler;
  607. jack_driver_param_value_t value;
  608. desc = jack_driver_descriptor_construct("alsa", JackDriverMaster, "Linux ALSA API based audio backend", &filler);
  609. strcpy(value.str, "hw:0");
  610. jack_driver_descriptor_add_parameter(desc, &filler, "device", 'd', JackDriverParamString, &value, enum_alsa_devices(), "ALSA device name", NULL);
  611. strcpy(value.str, "none");
  612. jack_driver_descriptor_add_parameter(desc, &filler, "capture", 'C', JackDriverParamString, &value, NULL, "Provide capture ports. Optionally set device", NULL);
  613. jack_driver_descriptor_add_parameter(desc, &filler, "playback", 'P', JackDriverParamString, &value, NULL, "Provide playback ports. Optionally set device", NULL);
  614. value.ui = 48000U;
  615. jack_driver_descriptor_add_parameter(desc, &filler, "rate", 'r', JackDriverParamUInt, &value, NULL, "Sample rate", NULL);
  616. value.ui = 1024U;
  617. jack_driver_descriptor_add_parameter(desc, &filler, "period", 'p', JackDriverParamUInt, &value, NULL, "Frames per period", NULL);
  618. value.ui = 2U;
  619. jack_driver_descriptor_add_parameter(desc, &filler, "nperiods", 'n', JackDriverParamUInt, &value, NULL, "Number of periods of playback latency", NULL);
  620. value.i = 0;
  621. jack_driver_descriptor_add_parameter(desc, &filler, "hwmon", 'H', JackDriverParamBool, &value, NULL, "Hardware monitoring, if available", NULL);
  622. value.i = 0;
  623. jack_driver_descriptor_add_parameter(desc, &filler, "hwmeter", 'M', JackDriverParamBool, &value, NULL, "Hardware metering, if available", NULL);
  624. value.i = 1;
  625. jack_driver_descriptor_add_parameter(desc, &filler, "duplex", 'D', JackDriverParamBool, &value, NULL, "Provide both capture and playback ports", NULL);
  626. value.i = 0;
  627. jack_driver_descriptor_add_parameter(desc, &filler, "softmode", 's', JackDriverParamBool, &value, NULL, "Soft-mode, no xrun handling", NULL);
  628. value.i = 0;
  629. jack_driver_descriptor_add_parameter(desc, &filler, "monitor", 'm', JackDriverParamBool, &value, NULL, "Provide monitor ports for the output", NULL);
  630. value.c = 'n';
  631. jack_driver_descriptor_add_parameter(
  632. desc,
  633. &filler,
  634. "dither",
  635. 'z',
  636. JackDriverParamChar,
  637. &value,
  638. get_dither_constraint(),
  639. "Dithering mode",
  640. "Dithering mode:\n"
  641. " n - none\n"
  642. " r - rectangular\n"
  643. " s - shaped\n"
  644. " t - triangular");
  645. value.ui = 0;
  646. jack_driver_descriptor_add_parameter(desc, &filler, "inchannels", 'i', JackDriverParamUInt, &value, NULL, "Number of capture channels (defaults to hardware max)", NULL);
  647. jack_driver_descriptor_add_parameter(desc, &filler, "outchannels", 'o', JackDriverParamUInt, &value, NULL, "Number of playback channels (defaults to hardware max)", NULL);
  648. value.i = FALSE;
  649. jack_driver_descriptor_add_parameter(desc, &filler, "shorts", 'S', JackDriverParamBool, &value, NULL, "Try 16-bit samples before 32-bit", NULL);
  650. value.ui = 0;
  651. jack_driver_descriptor_add_parameter(desc, &filler, "input-latency", 'I', JackDriverParamUInt, &value, NULL, "Extra input latency (frames)", NULL);
  652. jack_driver_descriptor_add_parameter(desc, &filler, "output-latency", 'O', JackDriverParamUInt, &value, NULL, "Extra output latency (frames)", NULL);
  653. strcpy(value.str, "none");
  654. jack_driver_descriptor_add_parameter(
  655. desc,
  656. &filler,
  657. "midi-driver",
  658. 'X',
  659. JackDriverParamString,
  660. &value,
  661. get_midi_driver_constraint(),
  662. "ALSA device name",
  663. "ALSA MIDI driver:\n"
  664. " none - no MIDI driver\n"
  665. " seq - ALSA Sequencer driver\n"
  666. " raw - ALSA RawMIDI driver\n");
  667. return desc;
  668. }
  669. static Jack::JackAlsaDriver* g_alsa_driver;
  670. SERVER_EXPORT Jack::JackDriverClientInterface* driver_initialize(Jack::JackLockedEngine* engine, Jack::JackSynchro* table, const JSList* params)
  671. {
  672. jack_nframes_t srate = 48000;
  673. jack_nframes_t frames_per_interrupt = 1024;
  674. unsigned long user_nperiods = 2;
  675. const char *playback_pcm_name = "hw:0";
  676. const char *capture_pcm_name = "hw:0";
  677. int hw_monitoring = FALSE;
  678. int hw_metering = FALSE;
  679. int capture = FALSE;
  680. int playback = FALSE;
  681. int soft_mode = FALSE;
  682. int monitor = FALSE;
  683. DitherAlgorithm dither = None;
  684. int user_capture_nchnls = 0;
  685. int user_playback_nchnls = 0;
  686. int shorts_first = FALSE;
  687. jack_nframes_t systemic_input_latency = 0;
  688. jack_nframes_t systemic_output_latency = 0;
  689. const JSList * node;
  690. const jack_driver_param_t * param;
  691. const char *midi_driver = "none";
  692. for (node = params; node; node = jack_slist_next (node)) {
  693. param = (const jack_driver_param_t *) node->data;
  694. switch (param->character) {
  695. case 'C':
  696. capture = TRUE;
  697. if (strcmp (param->value.str, "none") != 0) {
  698. capture_pcm_name = strdup (param->value.str);
  699. jack_log("capture device %s", capture_pcm_name);
  700. }
  701. break;
  702. case 'P':
  703. playback = TRUE;
  704. if (strcmp (param->value.str, "none") != 0) {
  705. playback_pcm_name = strdup (param->value.str);
  706. jack_log("playback device %s", playback_pcm_name);
  707. }
  708. break;
  709. case 'D':
  710. playback = TRUE;
  711. capture = TRUE;
  712. break;
  713. case 'd':
  714. if (strcmp (param->value.str, "none") != 0) {
  715. playback_pcm_name = strdup (param->value.str);
  716. capture_pcm_name = strdup (param->value.str);
  717. jack_log("playback device %s", playback_pcm_name);
  718. jack_log("capture device %s", capture_pcm_name);
  719. }
  720. break;
  721. case 'H':
  722. hw_monitoring = param->value.i;
  723. break;
  724. case 'm':
  725. monitor = param->value.i;
  726. break;
  727. case 'M':
  728. hw_metering = param->value.i;
  729. break;
  730. case 'r':
  731. srate = param->value.ui;
  732. jack_log("apparent rate = %d", srate);
  733. break;
  734. case 'p':
  735. frames_per_interrupt = param->value.ui;
  736. jack_log("frames per period = %d", frames_per_interrupt);
  737. break;
  738. case 'n':
  739. user_nperiods = param->value.ui;
  740. if (user_nperiods < 2) { /* enforce minimum value */
  741. user_nperiods = 2;
  742. }
  743. break;
  744. case 's':
  745. soft_mode = param->value.i;
  746. break;
  747. case 'z':
  748. if (dither_opt (param->value.c, &dither)) {
  749. return NULL;
  750. }
  751. break;
  752. case 'i':
  753. user_capture_nchnls = param->value.ui;
  754. break;
  755. case 'o':
  756. user_playback_nchnls = param->value.ui;
  757. break;
  758. case 'S':
  759. shorts_first = param->value.i;
  760. break;
  761. case 'I':
  762. systemic_input_latency = param->value.ui;
  763. break;
  764. case 'O':
  765. systemic_output_latency = param->value.ui;
  766. break;
  767. case 'X':
  768. midi_driver = strdup(param->value.str);
  769. break;
  770. }
  771. }
  772. /* duplex is the default */
  773. if (!capture && !playback) {
  774. capture = TRUE;
  775. playback = TRUE;
  776. }
  777. g_alsa_driver = new Jack::JackAlsaDriver("system", "alsa_pcm", engine, table);
  778. Jack::JackDriverClientInterface* threaded_driver = new Jack::JackThreadedDriver(g_alsa_driver);
  779. // Special open for ALSA driver...
  780. if (g_alsa_driver->Open(frames_per_interrupt, user_nperiods, srate, hw_monitoring, hw_metering, capture, playback, dither, soft_mode, monitor,
  781. user_capture_nchnls, user_playback_nchnls, shorts_first, capture_pcm_name, playback_pcm_name,
  782. systemic_input_latency, systemic_output_latency, midi_driver) == 0) {
  783. return threaded_driver;
  784. } else {
  785. delete threaded_driver; // Delete the decorated driver
  786. return NULL;
  787. }
  788. }
  789. // Code to be used in alsa_driver.c
  790. void ReadInput(jack_nframes_t orig_nframes, snd_pcm_sframes_t contiguous, snd_pcm_sframes_t nread)
  791. {
  792. g_alsa_driver->ReadInputAux(orig_nframes, contiguous, nread);
  793. }
  794. void MonitorInput()
  795. {
  796. g_alsa_driver->MonitorInputAux();
  797. }
  798. void ClearOutput()
  799. {
  800. g_alsa_driver->ClearOutputAux();
  801. }
  802. void WriteOutput(jack_nframes_t orig_nframes, snd_pcm_sframes_t contiguous, snd_pcm_sframes_t nwritten)
  803. {
  804. g_alsa_driver->WriteOutputAux(orig_nframes, contiguous, nwritten);
  805. }
  806. void SetTime(jack_time_t time)
  807. {
  808. g_alsa_driver->SetTimetAux(time);
  809. }
  810. int Restart()
  811. {
  812. int res;
  813. if ((res = g_alsa_driver->Stop()) == 0) {
  814. res = g_alsa_driver->Start();
  815. }
  816. return res;
  817. }
  818. #ifdef __cplusplus
  819. }
  820. #endif