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.

779 lines
27KB

  1. /*
  2. Copyright (C) 2008 Grame & RTL 2008
  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, write to the Free Software
  13. Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  14. */
  15. #include "JackOSSAdapter.h"
  16. #include "JackServerGlobals.h"
  17. #include "JackEngineControl.h"
  18. #include "memops.h"
  19. #include <sys/ioctl.h>
  20. #include <sys/soundcard.h>
  21. #include <fcntl.h>
  22. #include <iostream>
  23. #include <assert.h>
  24. namespace Jack
  25. {
  26. inline int int2pow2(int x) { int r = 0; while ((1 << r) < x) r++; return r; }
  27. static inline void CopyAndConvertIn(jack_sample_t *dst, void *src, size_t nframes, int channel, int chcount, int bits)
  28. {
  29. switch (bits) {
  30. case 16: {
  31. signed short *s16src = (signed short*)src;
  32. s16src += channel;
  33. sample_move_dS_s16(dst, (char*)s16src, nframes, chcount<<1);
  34. break;
  35. }
  36. case 24: {
  37. signed short *s32src = (signed short*)src;
  38. s32src += channel;
  39. sample_move_dS_s24(dst, (char*)s32src, nframes, chcount<<2);
  40. break;
  41. }
  42. case 32: {
  43. signed short *s32src = (signed short*)src;
  44. s32src += channel;
  45. sample_move_dS_s32u24(dst, (char*)s32src, nframes, chcount<<2);
  46. break;
  47. }
  48. }
  49. }
  50. static inline void CopyAndConvertOut(void *dst, jack_sample_t *src, size_t nframes, int channel, int chcount, int bits)
  51. {
  52. switch (bits) {
  53. case 16: {
  54. signed short *s16dst = (signed short*)dst;
  55. s16dst += channel;
  56. sample_move_d16_sS((char*)s16dst, src, nframes, chcount<<1, NULL); // No dithering for now...
  57. break;
  58. }
  59. case 24: {
  60. signed int *s32dst = (signed int*)dst;
  61. s32dst += channel;
  62. sample_move_d24_sS((char*)s32dst, src, nframes, chcount<<2, NULL); // No dithering for now...
  63. break;
  64. }
  65. case 32: {
  66. signed int *s32dst = (signed int*)dst;
  67. s32dst += channel;
  68. sample_move_d32u24_sS((char*)s32dst, src, nframes, chcount<<2, NULL);
  69. break;
  70. }
  71. }
  72. }
  73. void JackOSSAdapter::SetSampleFormat()
  74. {
  75. switch (fBits) {
  76. case 24: /* native-endian LSB aligned 24-bits in 32-bits integer */
  77. fSampleFormat = AFMT_S24_NE;
  78. fSampleSize = sizeof(int);
  79. break;
  80. case 32: /* native-endian 32-bit integer */
  81. fSampleFormat = AFMT_S32_NE;
  82. fSampleSize = sizeof(int);
  83. break;
  84. case 16: /* native-endian 16-bit integer */
  85. default:
  86. fSampleFormat = AFMT_S16_NE;
  87. fSampleSize = sizeof(short);
  88. break;
  89. }
  90. }
  91. JackOSSAdapter::JackOSSAdapter(jack_nframes_t buffer_size, jack_nframes_t sample_rate, const JSList* params)
  92. :JackAudioAdapterInterface(buffer_size, sample_rate)
  93. ,fThread(this),
  94. fInFD(-1), fOutFD(-1), fBits(OSS_DRIVER_DEF_BITS),
  95. fSampleFormat(0), fNperiods(OSS_DRIVER_DEF_NPERIODS), fRWMode(0), fIgnoreHW(true), fExcl(false),
  96. fInputBufferSize(0), fOutputBufferSize(0),
  97. fInputBuffer(NULL), fOutputBuffer(NULL), fFirstCycle(true)
  98. {
  99. const JSList* node;
  100. const jack_driver_param_t* param;
  101. fCaptureChannels = 2;
  102. fPlaybackChannels = 2;
  103. strcpy(fCaptureDriverName, OSS_DRIVER_DEF_DEV);
  104. strcpy(fPlaybackDriverName, OSS_DRIVER_DEF_DEV);
  105. for (node = params; node; node = jack_slist_next(node)) {
  106. param = (const jack_driver_param_t*) node->data;
  107. switch (param->character) {
  108. case 'r':
  109. SetAdaptedSampleRate(param->value.ui);
  110. break;
  111. case 'p':
  112. SetAdaptedBufferSize(param->value.ui);
  113. break;
  114. case 'n':
  115. fNperiods = param->value.ui;
  116. break;
  117. case 'w':
  118. fBits = param->value.i;
  119. break;
  120. case 'i':
  121. fCaptureChannels = param->value.ui;
  122. break;
  123. case 'o':
  124. fPlaybackChannels = param->value.ui;
  125. break;
  126. case 'e':
  127. fExcl = true;
  128. break;
  129. case 'C':
  130. fRWMode |= kRead;
  131. if (strcmp(param->value.str, "none") != 0) {
  132. strcpy(fCaptureDriverName, param->value.str);
  133. }
  134. break;
  135. case 'P':
  136. fRWMode |= kWrite;
  137. if (strcmp(param->value.str, "none") != 0) {
  138. strcpy(fPlaybackDriverName, param->value.str);
  139. }
  140. break;
  141. case 'd':
  142. fRWMode |= kRead;
  143. fRWMode |= kWrite;
  144. strcpy(fCaptureDriverName, param->value.str);
  145. strcpy(fPlaybackDriverName, param->value.str);
  146. break;
  147. case 'b':
  148. fIgnoreHW = true;
  149. break;
  150. case 'q':
  151. fQuality = param->value.ui;
  152. break;
  153. case 'g':
  154. fRingbufferSize = param->value.ui;
  155. break;
  156. }
  157. }
  158. fRWMode |= kRead;
  159. fRWMode |= kWrite;
  160. }
  161. void JackOSSAdapter::DisplayDeviceInfo()
  162. {
  163. audio_buf_info info;
  164. oss_audioinfo ai_in, ai_out;
  165. memset(&info, 0, sizeof(audio_buf_info));
  166. int cap = 0;
  167. // Duplex cards : http://manuals.opensound.com/developer/full_duplex.html
  168. jack_info("Audio Interface Description :");
  169. jack_info("Sampling Frequency : %d, Sample Format : %d, Mode : %d", fAdaptedSampleRate, fSampleFormat, fRWMode);
  170. if (fRWMode & kWrite) {
  171. oss_sysinfo si;
  172. if (ioctl(fOutFD, OSS_SYSINFO, &si) == -1) {
  173. jack_error("JackOSSAdapter::DisplayDeviceInfo OSS_SYSINFO failed : %s@%i, errno = %d", __FILE__, __LINE__, errno);
  174. } else {
  175. jack_info("OSS product %s", si.product);
  176. jack_info("OSS version %s", si.version);
  177. jack_info("OSS version num %d", si.versionnum);
  178. jack_info("OSS numaudios %d", si.numaudios);
  179. jack_info("OSS numaudioengines %d", si.numaudioengines);
  180. jack_info("OSS numcards %d", si.numcards);
  181. }
  182. jack_info("Output capabilities - %d channels : ", fPlaybackChannels);
  183. jack_info("Output block size = %d", fOutputBufferSize);
  184. if (ioctl(fOutFD, SNDCTL_DSP_GETOSPACE, &info) == -1) {
  185. jack_error("JackOSSAdapter::DisplayDeviceInfo SNDCTL_DSP_GETOSPACE failed : %s@%i, errno = %d", __FILE__, __LINE__, errno);
  186. } else {
  187. jack_info("output space info: fragments = %d, fragstotal = %d, fragsize = %d, bytes = %d",
  188. info.fragments, info.fragstotal, info.fragsize, info.bytes);
  189. }
  190. if (ioctl(fOutFD, SNDCTL_DSP_GETCAPS, &cap) == -1) {
  191. jack_error("JackOSSAdapter::DisplayDeviceInfo SNDCTL_DSP_GETCAPS failed : %s@%i, errno = %d", __FILE__, __LINE__, errno);
  192. } else {
  193. if (cap & DSP_CAP_DUPLEX) jack_info(" DSP_CAP_DUPLEX");
  194. if (cap & DSP_CAP_REALTIME) jack_info(" DSP_CAP_REALTIME");
  195. if (cap & DSP_CAP_BATCH) jack_info(" DSP_CAP_BATCH");
  196. if (cap & DSP_CAP_COPROC) jack_info(" DSP_CAP_COPROC");
  197. if (cap & DSP_CAP_TRIGGER) jack_info(" DSP_CAP_TRIGGER");
  198. if (cap & DSP_CAP_MMAP) jack_info(" DSP_CAP_MMAP");
  199. if (cap & DSP_CAP_MULTI) jack_info(" DSP_CAP_MULTI");
  200. if (cap & DSP_CAP_BIND) jack_info(" DSP_CAP_BIND");
  201. }
  202. }
  203. if (fRWMode & kRead) {
  204. oss_sysinfo si;
  205. if (ioctl(fInFD, OSS_SYSINFO, &si) == -1) {
  206. jack_error("JackOSSAdapter::DisplayDeviceInfo OSS_SYSINFO failed : %s@%i, errno = %d", __FILE__, __LINE__, errno);
  207. } else {
  208. jack_info("OSS product %s", si.product);
  209. jack_info("OSS version %s", si.version);
  210. jack_info("OSS version num %d", si.versionnum);
  211. jack_info("OSS numaudios %d", si.numaudios);
  212. jack_info("OSS numaudioengines %d", si.numaudioengines);
  213. jack_info("OSS numcards %d", si.numcards);
  214. }
  215. jack_info("Input capabilities - %d channels : ", fCaptureChannels);
  216. jack_info("Input block size = %d", fInputBufferSize);
  217. if (ioctl(fInFD, SNDCTL_DSP_GETOSPACE, &info) == -1) {
  218. jack_error("JackOSSAdapter::DisplayDeviceInfo SNDCTL_DSP_GETOSPACE failed : %s@%i, errno = %d", __FILE__, __LINE__, errno);
  219. } else {
  220. jack_info("input space info: fragments = %d, fragstotal = %d, fragsize = %d, bytes = %d",
  221. info.fragments, info.fragstotal, info.fragsize, info.bytes);
  222. }
  223. if (ioctl(fInFD, SNDCTL_DSP_GETCAPS, &cap) == -1) {
  224. jack_error("JackOSSAdapter::DisplayDeviceInfo SNDCTL_DSP_GETCAPS failed : %s@%i, errno = %d", __FILE__, __LINE__, errno);
  225. } else {
  226. if (cap & DSP_CAP_DUPLEX) jack_info(" DSP_CAP_DUPLEX");
  227. if (cap & DSP_CAP_REALTIME) jack_info(" DSP_CAP_REALTIME");
  228. if (cap & DSP_CAP_BATCH) jack_info(" DSP_CAP_BATCH");
  229. if (cap & DSP_CAP_COPROC) jack_info(" DSP_CAP_COPROC");
  230. if (cap & DSP_CAP_TRIGGER) jack_info(" DSP_CAP_TRIGGER");
  231. if (cap & DSP_CAP_MMAP) jack_info(" DSP_CAP_MMAP");
  232. if (cap & DSP_CAP_MULTI) jack_info(" DSP_CAP_MULTI");
  233. if (cap & DSP_CAP_BIND) jack_info(" DSP_CAP_BIND");
  234. }
  235. }
  236. if (ioctl(fInFD, SNDCTL_AUDIOINFO, &ai_in) != -1) {
  237. jack_info("Using audio engine %d = %s for input", ai_in.dev, ai_in.name);
  238. }
  239. if (ioctl(fOutFD, SNDCTL_AUDIOINFO, &ai_out) != -1) {
  240. jack_info("Using audio engine %d = %s for output", ai_out.dev, ai_out.name);
  241. }
  242. if (ai_in.rate_source != ai_out.rate_source) {
  243. jack_info("Warning : input and output are not necessarily driven by the same clock!");
  244. }
  245. }
  246. int JackOSSAdapter::OpenInput()
  247. {
  248. int flags = 0;
  249. int gFragFormat;
  250. int cur_sample_format, cur_capture_channels;
  251. jack_nframes_t cur_sample_rate;
  252. if (fCaptureChannels == 0) fCaptureChannels = 2;
  253. if ((fInFD = open(fCaptureDriverName, O_RDONLY | ((fExcl) ? O_EXCL : 0))) < 0) {
  254. jack_error("JackOSSAdapter::OpenInput failed to open device : %s@%i, errno = %d", __FILE__, __LINE__, errno);
  255. return -1;
  256. }
  257. jack_log("JackOSSAdapter::OpenInput input fInFD = %d", fInFD);
  258. if (fExcl) {
  259. if (ioctl(fInFD, SNDCTL_DSP_COOKEDMODE, &flags) == -1) {
  260. jack_error("JackOSSAdapter::OpenInput failed to set cooked mode : %s@%i, errno = %d", __FILE__, __LINE__, errno);
  261. goto error;
  262. }
  263. }
  264. printf("fAdaptedBufferSize %d %d %d %d %s\n", fExcl, fAdaptedBufferSize, fSampleSize, fCaptureChannels, fCaptureDriverName);
  265. gFragFormat = (2 << 16) + int2pow2(fAdaptedBufferSize * fSampleSize * fCaptureChannels);
  266. if (ioctl(fInFD, SNDCTL_DSP_SETFRAGMENT, &gFragFormat) == -1) {
  267. jack_error("JackOSSAdapter::OpenInput failed to set fragments : %s@%i, errno = %d", __FILE__, __LINE__, errno);
  268. goto error;
  269. }
  270. cur_sample_format = fSampleFormat;
  271. if (ioctl(fInFD, SNDCTL_DSP_SETFMT, &fSampleFormat) == -1) {
  272. jack_error("JackOSSAdapter::OpenInput failed to set format : %s@%i, errno = %d", __FILE__, __LINE__, errno);
  273. goto error;
  274. }
  275. if (cur_sample_format != fSampleFormat) {
  276. jack_info("JackOSSAdapter::OpenInput driver forced the sample format %ld", fSampleFormat);
  277. }
  278. cur_capture_channels = fCaptureChannels;
  279. if (ioctl(fInFD, SNDCTL_DSP_CHANNELS, &fCaptureChannels) == -1) {
  280. jack_error("JackOSSAdapter::OpenInput failed to set channels : %s@%i, errno = %d", __FILE__, __LINE__, errno);
  281. goto error;
  282. }
  283. if (cur_capture_channels != fCaptureChannels) {
  284. jack_info("JackOSSAdapter::OpenInput driver forced the number of capture channels %ld", fCaptureChannels);
  285. }
  286. cur_sample_rate = fAdaptedSampleRate;
  287. if (ioctl(fInFD, SNDCTL_DSP_SPEED, &fAdaptedSampleRate) == -1) {
  288. jack_error("JackOSSAdapter::OpenInput failed to set sample rate : %s@%i, errno = %d", __FILE__, __LINE__, errno);
  289. goto error;
  290. }
  291. if (cur_sample_rate != fAdaptedSampleRate) {
  292. jack_info("JackOSSAdapter::OpenInput driver forced the sample rate %ld", fAdaptedSampleRate);
  293. }
  294. fInputBufferSize = 0;
  295. if (ioctl(fInFD, SNDCTL_DSP_GETBLKSIZE, &fInputBufferSize) == -1) {
  296. jack_error("JackOSSAdapter::OpenInput failed to get fragments : %s@%i, errno = %d", __FILE__, __LINE__, errno);
  297. goto error;
  298. }
  299. if (fInputBufferSize != fAdaptedBufferSize * fSampleSize * fCaptureChannels) {
  300. if (fIgnoreHW) {
  301. jack_info("JackOSSAdapter::OpenInput driver forced buffer size %ld", fOutputBufferSize);
  302. } else {
  303. jack_error("JackOSSAdapter::OpenInput wanted buffer size cannot be obtained");
  304. goto error;
  305. }
  306. }
  307. fInputBuffer = (void*)calloc(fInputBufferSize, 1);
  308. assert(fInputBuffer);
  309. fInputSampleBuffer = (float**)malloc(fCaptureChannels * sizeof(float*));
  310. assert(fInputSampleBuffer);
  311. for (int i = 0; i < fCaptureChannels; i++) {
  312. fInputSampleBuffer[i] = (float*)malloc(fAdaptedBufferSize * sizeof(float));
  313. assert(fInputSampleBuffer[i]);
  314. }
  315. return 0;
  316. error:
  317. ::close(fInFD);
  318. return -1;
  319. }
  320. int JackOSSAdapter::OpenOutput()
  321. {
  322. int flags = 0;
  323. int gFragFormat;
  324. int cur_sample_format, cur_playback_channels;
  325. jack_nframes_t cur_sample_rate;
  326. if (fPlaybackChannels == 0) fPlaybackChannels = 2;
  327. if ((fOutFD = open(fPlaybackDriverName, O_WRONLY | ((fExcl) ? O_EXCL : 0))) < 0) {
  328. jack_error("JackOSSAdapter::OpenOutput failed to open device : %s@%i, errno = %d", __FILE__, __LINE__, errno);
  329. return -1;
  330. }
  331. if (fExcl) {
  332. if (ioctl(fOutFD, SNDCTL_DSP_COOKEDMODE, &flags) == -1) {
  333. jack_error("JackOSSAdapter::OpenOutput failed to set cooked mode : %s@%i, errno = %d", __FILE__, __LINE__, errno);
  334. goto error;
  335. }
  336. }
  337. printf("fAdaptedBufferSize %d %d %d %d %s\n", fExcl, fAdaptedBufferSize, fSampleSize, fPlaybackChannels, fPlaybackDriverName);
  338. gFragFormat = (2 << 16) + int2pow2(fAdaptedBufferSize * fSampleSize * fPlaybackChannels);
  339. if (ioctl(fOutFD, SNDCTL_DSP_SETFRAGMENT, &gFragFormat) == -1) {
  340. jack_error("JackOSSAdapter::OpenOutput failed to set fragments : %s@%i, errno = %d", __FILE__, __LINE__, errno);
  341. goto error;
  342. }
  343. cur_sample_format = fSampleFormat;
  344. if (ioctl(fOutFD, SNDCTL_DSP_SETFMT, &fSampleFormat) == -1) {
  345. jack_error("JackOSSAdapter::OpenOutput failed to set format : %s@%i, errno = %d", __FILE__, __LINE__, errno);
  346. goto error;
  347. }
  348. if (cur_sample_format != fSampleFormat) {
  349. jack_info("JackOSSAdapter::OpenOutput driver forced the sample format %ld", fSampleFormat);
  350. }
  351. cur_playback_channels = fPlaybackChannels;
  352. if (ioctl(fOutFD, SNDCTL_DSP_CHANNELS, &fPlaybackChannels) == -1) {
  353. jack_error("JackOSSAdapter::OpenOutput failed to set channels : %s@%i, errno = %d", __FILE__, __LINE__, errno);
  354. goto error;
  355. }
  356. if (cur_playback_channels != fPlaybackChannels) {
  357. jack_info("JackOSSAdapter::OpenOutput driver forced the number of playback channels %ld", fPlaybackChannels);
  358. }
  359. cur_sample_rate = fAdaptedSampleRate;
  360. if (ioctl(fOutFD, SNDCTL_DSP_SPEED, &fAdaptedSampleRate) == -1) {
  361. jack_error("JackOSSAdapter::OpenOutput failed to set sample rate : %s@%i, errno = %d", __FILE__, __LINE__, errno);
  362. goto error;
  363. }
  364. if (cur_sample_rate != fAdaptedSampleRate) {
  365. jack_info("JackOSSAdapter::OpenInput driver forced the sample rate %ld", fAdaptedSampleRate);
  366. }
  367. fOutputBufferSize = 0;
  368. if (ioctl(fOutFD, SNDCTL_DSP_GETBLKSIZE, &fOutputBufferSize) == -1) {
  369. jack_error("JackOSSAdapter::OpenOutput failed to get fragments : %s@%i, errno = %d", __FILE__, __LINE__, errno);
  370. goto error;
  371. }
  372. if (fOutputBufferSize != fAdaptedBufferSize * fSampleSize * fPlaybackChannels) {
  373. if (fIgnoreHW) {
  374. jack_info("JackOSSAdapter::OpenOutput driver forced buffer size %ld", fOutputBufferSize);
  375. } else {
  376. jack_error("JackOSSAdapter::OpenInput wanted buffer size cannot be obtained");
  377. goto error;
  378. }
  379. }
  380. fOutputBuffer = (void*)calloc(fOutputBufferSize, 1);
  381. assert(fOutputBuffer);
  382. fOutputSampleBuffer = (float**)malloc(fPlaybackChannels * sizeof(float*));
  383. assert(fOutputSampleBuffer);
  384. for (int i = 0; i < fPlaybackChannels; i++) {
  385. fOutputSampleBuffer[i] = (float*)malloc(fAdaptedBufferSize * sizeof(float));
  386. assert(fOutputSampleBuffer[i]);
  387. }
  388. fFirstCycle = true;
  389. return 0;
  390. error:
  391. ::close(fOutFD);
  392. return -1;
  393. }
  394. int JackOSSAdapter::Open()
  395. {
  396. SetSampleFormat();
  397. if ((fRWMode & kRead) && (OpenInput() < 0)) {
  398. return -1;
  399. }
  400. if ((fRWMode & kWrite) && (OpenOutput() < 0)) {
  401. return -1;
  402. }
  403. // In duplex mode, check that input and output use the same buffer size
  404. if ((fRWMode & kRead) && (fRWMode & kWrite) && (fInputBufferSize != fOutputBufferSize)) {
  405. jack_error("JackOSSAdapter::OpenAux input and output buffer size are not the same!!");
  406. goto error;
  407. }
  408. DisplayDeviceInfo();
  409. fThread.AcquireRealTime(JackServerGlobals::fInstance->GetEngineControl()->fClientPriority);
  410. return fThread.StartSync();
  411. error:
  412. CloseAux();
  413. return -1;
  414. }
  415. int JackOSSAdapter::Close()
  416. {
  417. #ifdef DEBUG
  418. fTable.Save();
  419. #endif
  420. fThread.Stop();
  421. CloseAux();
  422. return 0;
  423. }
  424. void JackOSSAdapter::CloseAux()
  425. {
  426. if (fRWMode & kRead) {
  427. close(fInFD);
  428. fInFD = -1;
  429. }
  430. if (fRWMode & kWrite) {
  431. close(fOutFD);
  432. fOutFD = -1;
  433. }
  434. free(fInputBuffer);
  435. fInputBuffer = NULL;
  436. free(fOutputBuffer);
  437. fOutputBuffer = NULL;
  438. for (int i = 0; i < fCaptureChannels; i++) {
  439. free(fInputSampleBuffer[i]);
  440. }
  441. free(fInputSampleBuffer);
  442. for (int i = 0; i < fPlaybackChannels; i++) {
  443. free(fOutputSampleBuffer[i]);
  444. }
  445. free(fOutputSampleBuffer);
  446. }
  447. int JackOSSAdapter::Read()
  448. {
  449. ssize_t count = ::read(fInFD, fInputBuffer, fInputBufferSize);
  450. if (count < fInputBufferSize) {
  451. jack_error("JackOSSAdapter::Read error bytes read = %ld", count);
  452. return -1;
  453. } else {
  454. for (int i = 0; i < fCaptureChannels; i++) {
  455. CopyAndConvertIn(fInputSampleBuffer[i], fInputBuffer, fAdaptedBufferSize, i, fCaptureChannels, fBits);
  456. }
  457. return 0;
  458. }
  459. }
  460. int JackOSSAdapter::Write()
  461. {
  462. ssize_t count;
  463. // Maybe necessay to write an empty output buffer first time : see http://manuals.opensound.com/developer/fulldup.c.html
  464. if (fFirstCycle) {
  465. fFirstCycle = false;
  466. memset(fOutputBuffer, 0, fOutputBufferSize);
  467. // Prefill ouput buffer
  468. for (int i = 0; i < fNperiods; i++) {
  469. count = ::write(fOutFD, fOutputBuffer, fOutputBufferSize);
  470. if (count < fOutputBufferSize) {
  471. jack_error("JackOSSDriver::Write error bytes written = %ld", count);
  472. return -1;
  473. }
  474. }
  475. int delay;
  476. if (ioctl(fOutFD, SNDCTL_DSP_GETODELAY, &delay) == -1) {
  477. jack_error("JackOSSDriver::Write error get out delay : %s@%i, errno = %d", __FILE__, __LINE__, errno);
  478. return -1;
  479. }
  480. delay /= fSampleSize * fPlaybackChannels;
  481. jack_info("JackOSSDriver::Write output latency frames = %ld", delay);
  482. }
  483. for (int i = 0; i < fPlaybackChannels; i++) {
  484. CopyAndConvertOut(fOutputBuffer, fOutputSampleBuffer[i], fAdaptedBufferSize, i, fCaptureChannels, fBits);
  485. }
  486. count = ::write(fOutFD, fOutputBuffer, fOutputBufferSize);
  487. if (count < fOutputBufferSize) {
  488. jack_error("JackOSSAdapter::Write error bytes written = %ld", count);
  489. return -1;
  490. } else {
  491. return 0;
  492. }
  493. }
  494. bool JackOSSAdapter::Execute()
  495. {
  496. if (Read() < 0)
  497. return false;
  498. bool failure = false;
  499. jack_time_t time1, time2;
  500. ResampleFactor(time1, time2);
  501. for (int i = 0; i < fCaptureChannels; i++) {
  502. fCaptureRingBuffer[i]->SetRatio(time1, time2);
  503. if (fCaptureRingBuffer[i]->WriteResample(fInputSampleBuffer[i], fAdaptedBufferSize) < fAdaptedBufferSize)
  504. failure = true;
  505. }
  506. for (int i = 0; i < fPlaybackChannels; i++) {
  507. fPlaybackRingBuffer[i]->SetRatio(time2, time1);
  508. if (fPlaybackRingBuffer[i]->ReadResample(fOutputSampleBuffer[i], fAdaptedBufferSize) < fAdaptedBufferSize)
  509. failure = true;
  510. }
  511. #ifdef DEBUG
  512. fTable.Write(time1, time2, double(time1) / double(time2), double(time2) / double(time1),
  513. fCaptureRingBuffer[0]->ReadSpace(), fPlaybackRingBuffer[0]->WriteSpace());
  514. #endif
  515. if (Write() < 0)
  516. return false;
  517. // Reset all ringbuffers in case of failure
  518. if (failure) {
  519. jack_error("JackOSSAdapter::Execute ringbuffer failure... reset");
  520. ResetRingBuffers();
  521. }
  522. return true;
  523. }
  524. int JackOSSAdapter::SetBufferSize(jack_nframes_t buffer_size)
  525. {
  526. JackAudioAdapterInterface::SetBufferSize(buffer_size);
  527. Close();
  528. return Open();
  529. }
  530. } // namespace
  531. #ifdef __cplusplus
  532. extern "C"
  533. {
  534. #endif
  535. SERVER_EXPORT jack_driver_desc_t* jack_get_descriptor()
  536. {
  537. jack_driver_desc_t *desc;
  538. unsigned int i;
  539. desc = (jack_driver_desc_t*)calloc(1, sizeof(jack_driver_desc_t));
  540. strcpy(desc->name, "audioadapter"); // size MUST be less then JACK_DRIVER_NAME_MAX + 1
  541. strcpy(desc->desc, "netjack audio <==> net backend adapter"); // size MUST be less then JACK_DRIVER_PARAM_DESC + 1
  542. desc->nparams = OSS_DRIVER_N_PARAMS;
  543. desc->params = (jack_driver_param_desc_t*)calloc(desc->nparams, sizeof(jack_driver_param_desc_t));
  544. i = 0;
  545. strcpy(desc->params[i].name, "rate");
  546. desc->params[i].character = 'r';
  547. desc->params[i].type = JackDriverParamUInt;
  548. desc->params[i].value.ui = OSS_DRIVER_DEF_FS;
  549. strcpy(desc->params[i].short_desc, "Sample rate");
  550. strcpy(desc->params[i].long_desc, desc->params[i].short_desc);
  551. i++;
  552. strcpy(desc->params[i].name, "period");
  553. desc->params[i].character = 'p';
  554. desc->params[i].type = JackDriverParamUInt;
  555. desc->params[i].value.ui = OSS_DRIVER_DEF_BLKSIZE;
  556. strcpy(desc->params[i].short_desc, "Frames per period");
  557. strcpy(desc->params[i].long_desc, desc->params[i].short_desc);
  558. i++;
  559. strcpy(desc->params[i].name, "nperiods");
  560. desc->params[i].character = 'n';
  561. desc->params[i].type = JackDriverParamUInt;
  562. desc->params[i].value.ui = OSS_DRIVER_DEF_NPERIODS;
  563. strcpy(desc->params[i].short_desc, "Number of periods to prefill output buffer");
  564. strcpy(desc->params[i].long_desc, desc->params[i].short_desc);
  565. i++;
  566. strcpy(desc->params[i].name, "wordlength");
  567. desc->params[i].character = 'w';
  568. desc->params[i].type = JackDriverParamInt;
  569. desc->params[i].value.i = OSS_DRIVER_DEF_BITS;
  570. strcpy(desc->params[i].short_desc, "Word length");
  571. strcpy(desc->params[i].long_desc, desc->params[i].short_desc);
  572. i++;
  573. strcpy(desc->params[i].name, "inchannels");
  574. desc->params[i].character = 'i';
  575. desc->params[i].type = JackDriverParamUInt;
  576. desc->params[i].value.ui = OSS_DRIVER_DEF_INS;
  577. strcpy(desc->params[i].short_desc, "Capture channels");
  578. strcpy(desc->params[i].long_desc, desc->params[i].short_desc);
  579. i++;
  580. strcpy(desc->params[i].name, "outchannels");
  581. desc->params[i].character = 'o';
  582. desc->params[i].type = JackDriverParamUInt;
  583. desc->params[i].value.ui = OSS_DRIVER_DEF_OUTS;
  584. strcpy(desc->params[i].short_desc, "Playback channels");
  585. strcpy(desc->params[i].long_desc, desc->params[i].short_desc);
  586. i++;
  587. strcpy(desc->params[i].name, "excl");
  588. desc->params[i].character = 'e';
  589. desc->params[i].type = JackDriverParamBool;
  590. desc->params[i].value.i = false;
  591. strcpy(desc->params[i].short_desc, "Exclusif (O_EXCL) access mode");
  592. strcpy(desc->params[i].long_desc, desc->params[i].short_desc);
  593. i++;
  594. strcpy(desc->params[i].name, "capture");
  595. desc->params[i].character = 'C';
  596. desc->params[i].type = JackDriverParamString;
  597. strcpy(desc->params[i].value.str, OSS_DRIVER_DEF_DEV);
  598. strcpy(desc->params[i].short_desc, "Input device");
  599. strcpy(desc->params[i].long_desc, desc->params[i].short_desc);
  600. i++;
  601. strcpy(desc->params[i].name, "playback");
  602. desc->params[i].character = 'P';
  603. desc->params[i].type = JackDriverParamString;
  604. strcpy(desc->params[i].value.str, OSS_DRIVER_DEF_DEV);
  605. strcpy(desc->params[i].short_desc, "Output device");
  606. strcpy(desc->params[i].long_desc, desc->params[i].short_desc);
  607. i++;
  608. strcpy (desc->params[i].name, "device");
  609. desc->params[i].character = 'd';
  610. desc->params[i].type = JackDriverParamString;
  611. strcpy(desc->params[i].value.str, OSS_DRIVER_DEF_DEV);
  612. strcpy(desc->params[i].short_desc, "OSS device name");
  613. strcpy(desc->params[i].long_desc, desc->params[i].short_desc);
  614. i++;
  615. strcpy(desc->params[i].name, "ignorehwbuf");
  616. desc->params[i].character = 'b';
  617. desc->params[i].type = JackDriverParamBool;
  618. desc->params[i].value.i = true;
  619. strcpy(desc->params[i].short_desc, "Ignore hardware period size");
  620. strcpy(desc->params[i].long_desc, desc->params[i].short_desc);
  621. i++;
  622. strcpy(desc->params[i].name, "quality");
  623. desc->params[i].character = 'q';
  624. desc->params[i].type = JackDriverParamInt;
  625. desc->params[i].value.ui = 0;
  626. strcpy(desc->params[i].short_desc, "Resample algorithm quality (0 - 4)");
  627. strcpy(desc->params[i].long_desc, desc->params[i].short_desc);
  628. i++;
  629. strcpy(desc->params[i].name, "ring-buffer");
  630. desc->params[i].character = 'g';
  631. desc->params[i].type = JackDriverParamInt;
  632. desc->params[i].value.ui = 0;
  633. strcpy(desc->params[i].short_desc, "Resampling ringbuffer size in frames (default = 32768)");
  634. strcpy(desc->params[i].long_desc, desc->params[i].short_desc);
  635. return desc;
  636. }
  637. #ifdef __cplusplus
  638. }
  639. #endif