diff options
author | sletz <sletz@0c269be4-1314-0410-8aa9-9f06e86f4224> | 2009-02-11 12:31:20 +0000 |
---|---|---|
committer | sletz <sletz@0c269be4-1314-0410-8aa9-9f06e86f4224> | 2009-02-11 12:31:20 +0000 |
commit | 32987ca1d2c885250e8f3b74fad368fe83e88c9f (patch) | |
tree | 9e9decf1c9e5fd8c7714a1c3fb9c6b32d3a5e2f3 /solaris/oss/JackOSSDriver.cpp | |
parent | 4117315c2fb31d8b7ebd2c7dde53fe9c7b79d399 (diff) | |
download | jack2-32987ca1d2c885250e8f3b74fad368fe83e88c9f.tar.gz |
Merge Solaris branch back on trunk.
git-svn-id: http://subversion.jackaudio.org/jack/jack2/trunk/jackmp@3306 0c269be4-1314-0410-8aa9-9f06e86f4224
Diffstat (limited to 'solaris/oss/JackOSSDriver.cpp')
-rw-r--r-- | solaris/oss/JackOSSDriver.cpp | 1010 |
1 files changed, 1010 insertions, 0 deletions
diff --git a/solaris/oss/JackOSSDriver.cpp b/solaris/oss/JackOSSDriver.cpp new file mode 100644 index 00000000..5731d28a --- /dev/null +++ b/solaris/oss/JackOSSDriver.cpp @@ -0,0 +1,1010 @@ +/* +Copyright (C) 2003-2007 Jussi Laako <jussi@sonarnerd.net> +Copyright (C) 2008 Grame & RTL 2008 + +This program is free software; you can redistribute it and/or modify +it under the terms of the GNU General Public License as published by +the Free Software Foundation; either version 2 of the License, or +(at your option) any later version. + +This program is distributed in the hope that it will be useful, +but WITHOUT ANY WARRANTY; without even the implied warranty of +MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +GNU General Public License for more details. + +You should have received a copy of the GNU General Public License +along with this program; if not, write to the Free Software +Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + +*/ + +#include "driver_interface.h" +#include "JackThreadedDriver.h" +#include "JackDriverLoader.h" +#include "JackOSSDriver.h" +#include "JackEngineControl.h" +#include "JackGraphManager.h" +#include "JackError.h" +#include "JackTime.h" +#include "JackShmMem.h" +#include "memops.h" + +#include <sys/ioctl.h> +#include <sys/soundcard.h> +#include <fcntl.h> +#include <iostream> +#include <assert.h> +#include <stdio.h> + +using namespace std; + +namespace Jack +{ + +#ifdef JACK_MONITOR + +#define CYCLE_POINTS 500000 + +struct OSSCycle { + jack_time_t fBeforeRead; + jack_time_t fAfterRead; + jack_time_t fAfterReadConvert; + jack_time_t fBeforeWrite; + jack_time_t fAfterWrite; + jack_time_t fBeforeWriteConvert; +}; + +struct OSSCycleTable { + jack_time_t fBeforeFirstWrite; + jack_time_t fAfterFirstWrite; + OSSCycle fTable[CYCLE_POINTS]; +}; + +OSSCycleTable gCycleTable; +int gCycleCount = 0; + +#endif + +inline int int2pow2(int x) { int r = 0; while ((1 << r) < x) r++; return r; } + +static inline void CopyAndConvertIn(jack_sample_t *dst, void *src, size_t nframes, int channel, int chcount, int bits) +{ + switch (bits) { + + case 16: { + signed short *s16src = (signed short*)src; + s16src += channel; + sample_move_dS_s16(dst, (char*)s16src, nframes, chcount<<1); + break; + } + case 24: { + signed short *s32src = (signed short*)src; + s32src += channel; + sample_move_dS_s24(dst, (char*)s32src, nframes, chcount<<2); + break; + } + case 32: { + signed short *s32src = (signed short*)src; + s32src += channel; + sample_move_dS_s32u24(dst, (char*)s32src, nframes, chcount<<2); + break; + } + } +} + +static inline void CopyAndConvertOut(void *dst, jack_sample_t *src, size_t nframes, int channel, int chcount, int bits) +{ + switch (bits) { + + case 16: { + signed short *s16dst = (signed short*)dst; + s16dst += channel; + sample_move_d16_sS((char*)s16dst, src, nframes, chcount<<1, NULL); // No dithering for now... + break; + } + case 24: { + signed int *s32dst = (signed int*)dst; + s32dst += channel; + sample_move_d24_sS((char*)s32dst, src, nframes, chcount<<2, NULL); // No dithering for now... + break; + } + case 32: { + signed int *s32dst = (signed int*)dst; + s32dst += channel; + sample_move_d32u24_sS((char*)s32dst, src, nframes, chcount<<2, NULL); + break; + } + } +} + +void JackOSSDriver::SetSampleFormat() +{ + switch (fBits) { + + case 24: /* native-endian LSB aligned 24-bits in 32-bits integer */ + fSampleFormat = AFMT_S24_NE; + fSampleSize = sizeof(int); + break; + case 32: /* native-endian 32-bit integer */ + fSampleFormat = AFMT_S32_NE; + fSampleSize = sizeof(int); + break; + case 16: /* native-endian 16-bit integer */ + default: + fSampleFormat = AFMT_S16_NE; + fSampleSize = sizeof(short); + break; + } +} + +void JackOSSDriver::DisplayDeviceInfo() +{ + audio_buf_info info; + oss_audioinfo ai_in, ai_out; + memset(&info, 0, sizeof(audio_buf_info)); + int cap = 0; + + // Duplex cards : http://manuals.opensound.com/developer/full_duplex.html + jack_info("Audio Interface Description :"); + jack_info("Sampling Frequency : %d, Sample Format : %d, Mode : %d", fEngineControl->fSampleRate, fSampleFormat, fRWMode); + + if (fRWMode & kWrite) { + + oss_sysinfo si; + if (ioctl(fOutFD, OSS_SYSINFO, &si) == -1) { + jack_error("JackOSSDriver::DisplayDeviceInfo OSS_SYSINFO failed : %s@%i, errno = %d", __FILE__, __LINE__, errno); + } else { + jack_info("OSS product %s", si.product); + jack_info("OSS version %s", si.version); + jack_info("OSS version num %d", si.versionnum); + jack_info("OSS numaudios %d", si.numaudios); + jack_info("OSS numaudioengines %d", si.numaudioengines); + jack_info("OSS numcards %d", si.numcards); + } + + jack_info("Output capabilities - %d channels : ", fPlaybackChannels); + jack_info("Output block size = %d", fOutputBufferSize); + + if (ioctl(fOutFD, SNDCTL_DSP_GETOSPACE, &info) == -1) { + jack_error("JackOSSDriver::DisplayDeviceInfo SNDCTL_DSP_GETOSPACE failed : %s@%i, errno = %d", __FILE__, __LINE__, errno); + } else { + jack_info("output space info: fragments = %d, fragstotal = %d, fragsize = %d, bytes = %d", + info.fragments, info.fragstotal, info.fragsize, info.bytes); + } + + if (ioctl(fOutFD, SNDCTL_DSP_GETCAPS, &cap) == -1) { + jack_error("JackOSSDriver::DisplayDeviceInfo SNDCTL_DSP_GETCAPS failed : %s@%i, errno = %d", __FILE__, __LINE__, errno); + } else { + if (cap & DSP_CAP_DUPLEX) jack_info(" DSP_CAP_DUPLEX"); + if (cap & DSP_CAP_REALTIME) jack_info(" DSP_CAP_REALTIME"); + if (cap & DSP_CAP_BATCH) jack_info(" DSP_CAP_BATCH"); + if (cap & DSP_CAP_COPROC) jack_info(" DSP_CAP_COPROC"); + if (cap & DSP_CAP_TRIGGER) jack_info(" DSP_CAP_TRIGGER"); + if (cap & DSP_CAP_MMAP) jack_info(" DSP_CAP_MMAP"); + if (cap & DSP_CAP_MULTI) jack_info(" DSP_CAP_MULTI"); + if (cap & DSP_CAP_BIND) jack_info(" DSP_CAP_BIND"); + } + } + + if (fRWMode & kRead) { + + oss_sysinfo si; + if (ioctl(fInFD, OSS_SYSINFO, &si) == -1) { + jack_error("JackOSSDriver::DisplayDeviceInfo OSS_SYSINFO failed : %s@%i, errno = %d", __FILE__, __LINE__, errno); + } else { + jack_info("OSS product %s", si.product); + jack_info("OSS version %s", si.version); + jack_info("OSS version num %d", si.versionnum); + jack_info("OSS numaudios %d", si.numaudios); + jack_info("OSS numaudioengines %d", si.numaudioengines); + jack_info("OSS numcards %d", si.numcards); + } + + jack_info("Input capabilities - %d channels : ", fCaptureChannels); + jack_info("Input block size = %d", fInputBufferSize); + + if (ioctl(fInFD, SNDCTL_DSP_GETISPACE, &info) == -1) { + jack_error("JackOSSDriver::DisplayDeviceInfo SNDCTL_DSP_GETOSPACE failed : %s@%i, errno = %d", __FILE__, __LINE__, errno); + } else { + jack_info("input space info: fragments = %d, fragstotal = %d, fragsize = %d, bytes = %d", + info.fragments, info.fragstotal, info.fragsize, info.bytes); + } + + if (ioctl(fInFD, SNDCTL_DSP_GETCAPS, &cap) == -1) { + jack_error("JackOSSDriver::DisplayDeviceInfo SNDCTL_DSP_GETCAPS failed : %s@%i, errno = %d", __FILE__, __LINE__, errno); + } else { + if (cap & DSP_CAP_DUPLEX) jack_info(" DSP_CAP_DUPLEX"); + if (cap & DSP_CAP_REALTIME) jack_info(" DSP_CAP_REALTIME"); + if (cap & DSP_CAP_BATCH) jack_info(" DSP_CAP_BATCH"); + if (cap & DSP_CAP_COPROC) jack_info(" DSP_CAP_COPROC"); + if (cap & DSP_CAP_TRIGGER) jack_info(" DSP_CAP_TRIGGER"); + if (cap & DSP_CAP_MMAP) jack_info(" DSP_CAP_MMAP"); + if (cap & DSP_CAP_MULTI) jack_info(" DSP_CAP_MULTI"); + if (cap & DSP_CAP_BIND) jack_info(" DSP_CAP_BIND"); + } + } + /* + TODO + + ai_in.dev = fInFD; + jack_log("JackOSSDriver::DisplayDeviceInfo input fInFD = %d", ai_in.dev); + if (ioctl(fInFD, SNDCTL_AUDIOINFO, &ai_in) != -1) { + jack_info("Using audio engine %d = %s for input", ai_in.dev, ai_in.name); + if (ai_in.iformats & AFMT_S24_NE) + jack_info("Available input format : AFMT_S24_NE"); + if (ai_in.iformats & AFMT_S16_NE) + jack_info("Available input format : AFMT_S16_NE"); + if (ai_in.iformats & AFMT_S32_NE) + jack_info("Available input format : AFMT_S32_NE"); + } + + ai_out.dev = fOutFD; + jack_log("JackOSSDriver::DisplayDeviceInfo output fOutFD = %d", ai_out.dev); + if (ioctl(fOutFD, SNDCTL_AUDIOINFO, &ai_out) != -1) { + jack_info("Using audio engine %d = %s for output", ai_out.dev, ai_out.name); + if (ai_out.oformats & AFMT_S24_NE) + jack_info("Available output format : AFMT_S24_NE"); + if (ai_out.oformats & AFMT_S16_NE) + jack_info("Available output format : AFMT_S16_NE"); + if (ai_out.oformats & AFMT_S32_NE) + jack_info("Available output format : AFMT_S32_NE"); + } + */ + + if (ai_in.rate_source != ai_out.rate_source) { + jack_info("Warning : input and output are not necessarily driven by the same clock!"); + } +} + +int JackOSSDriver::OpenInput() +{ + int flags = 0; + int gFragFormat; + int cur_capture_channels; + int cur_sample_format; + jack_nframes_t cur_sample_rate; + + if (fCaptureChannels == 0) fCaptureChannels = 2; + + if ((fInFD = open(fCaptureDriverName, O_RDONLY | ((fExcl) ? O_EXCL : 0))) < 0) { + jack_error("JackOSSDriver::OpenInput failed to open device : %s@%i, errno = %d", __FILE__, __LINE__, errno); + return -1; + } + + jack_log("JackOSSDriver::OpenInput input fInFD = %d", fInFD); + + if (fExcl) { + if (ioctl(fInFD, SNDCTL_DSP_COOKEDMODE, &flags) == -1) { + jack_error("JackOSSDriver::OpenInput failed to set cooked mode : %s@%i, errno = %d", __FILE__, __LINE__, errno); + goto error; + } + } + + gFragFormat = (2 << 16) + int2pow2(fEngineControl->fBufferSize * fSampleSize * fCaptureChannels); + if (ioctl(fInFD, SNDCTL_DSP_SETFRAGMENT, &gFragFormat) == -1) { + jack_error("JackOSSDriver::OpenInput failed to set fragments : %s@%i, errno = %d", __FILE__, __LINE__, errno); + goto error; + } + + cur_sample_format = fSampleFormat; + if (ioctl(fInFD, SNDCTL_DSP_SETFMT, &fSampleFormat) == -1) { + jack_error("JackOSSDriver::OpenInput failed to set format : %s@%i, errno = %d", __FILE__, __LINE__, errno); + goto error; + } + if (cur_sample_format != fSampleFormat) { + jack_info("JackOSSDriver::OpenInput driver forced the sample format %ld", fSampleFormat); + } + + cur_capture_channels = fCaptureChannels; + if (ioctl(fInFD, SNDCTL_DSP_CHANNELS, &fCaptureChannels) == -1) { + jack_error("JackOSSDriver::OpenInput failed to set channels : %s@%i, errno = %d", __FILE__, __LINE__, errno); + goto error; + } + if (cur_capture_channels != fCaptureChannels) { + jack_info("JackOSSDriver::OpenInput driver forced the number of capture channels %ld", fCaptureChannels); + } + + cur_sample_rate = fEngineControl->fSampleRate; + if (ioctl(fInFD, SNDCTL_DSP_SPEED, &fEngineControl->fSampleRate) == -1) { + jack_error("JackOSSDriver::OpenInput failed to set sample rate : %s@%i, errno = %d", __FILE__, __LINE__, errno); + goto error; + } + if (cur_sample_rate != fEngineControl->fSampleRate) { + jack_info("JackOSSDriver::OpenInput driver forced the sample rate %ld", fEngineControl->fSampleRate); + } + + fInputBufferSize = 0; + if (ioctl(fInFD, SNDCTL_DSP_GETBLKSIZE, &fInputBufferSize) == -1) { + jack_error("JackOSSDriver::OpenInput failed to get fragments : %s@%i, errno = %d", __FILE__, __LINE__, errno); + goto error; + } + + if (fInputBufferSize != fEngineControl->fBufferSize * fSampleSize * fCaptureChannels) { + if (fIgnoreHW) { + int new_buffer_size = fInputBufferSize / (fSampleSize * fCaptureChannels); + jack_info("JackOSSDriver::OpenInput driver forced buffer size %ld", new_buffer_size); + JackAudioDriver::SetBufferSize(new_buffer_size); // never fails + } else { + jack_error("JackOSSDriver::OpenInput wanted buffer size cannot be obtained"); + goto error; + } + } + + fInputBuffer = (void*)calloc(fInputBufferSize, 1); + assert(fInputBuffer); + return 0; + +error: + ::close(fInFD); + return -1; +} + +int JackOSSDriver::OpenOutput() +{ + int flags = 0; + int gFragFormat; + int cur_sample_format; + int cur_playback_channels; + jack_nframes_t cur_sample_rate; + + if (fPlaybackChannels == 0) fPlaybackChannels = 2; + + if ((fOutFD = open(fPlaybackDriverName, O_WRONLY | ((fExcl) ? O_EXCL : 0))) < 0) { + jack_error("JackOSSDriver::OpenOutput failed to open device : %s@%i, errno = %d", __FILE__, __LINE__, errno); + return -1; + } + + jack_log("JackOSSDriver::OpenOutput output fOutFD = %d", fOutFD); + + if (fExcl) { + if (ioctl(fOutFD, SNDCTL_DSP_COOKEDMODE, &flags) == -1) { + jack_error("JackOSSDriver::OpenOutput failed to set cooked mode : %s@%i, errno = %d", __FILE__, __LINE__, errno); + goto error; + } + } + + gFragFormat = (2 << 16) + int2pow2(fEngineControl->fBufferSize * fSampleSize * fPlaybackChannels); + if (ioctl(fOutFD, SNDCTL_DSP_SETFRAGMENT, &gFragFormat) == -1) { + jack_error("JackOSSDriver::OpenOutput failed to set fragments : %s@%i, errno = %d", __FILE__, __LINE__, errno); + goto error; + } + + cur_sample_format = fSampleFormat; + if (ioctl(fOutFD, SNDCTL_DSP_SETFMT, &fSampleFormat) == -1) { + jack_error("JackOSSDriver::OpenOutput failed to set format : %s@%i, errno = %d", __FILE__, __LINE__, errno); + goto error; + } + if (cur_sample_format != fSampleFormat) { + jack_info("JackOSSDriver::OpenOutput driver forced the sample format %ld", fSampleFormat); + } + + cur_playback_channels = fPlaybackChannels; + if (ioctl(fOutFD, SNDCTL_DSP_CHANNELS, &fPlaybackChannels) == -1) { + jack_error("JackOSSDriver::OpenOutput failed to set channels : %s@%i, errno = %d", __FILE__, __LINE__, errno); + goto error; + } + if (cur_playback_channels != fPlaybackChannels) { + jack_info("JackOSSDriver::OpenOutput driver forced the number of playback channels %ld", fPlaybackChannels); + } + + cur_sample_rate = fEngineControl->fSampleRate; + if (ioctl(fOutFD, SNDCTL_DSP_SPEED, &fEngineControl->fSampleRate) == -1) { + jack_error("JackOSSDriver::OpenOutput failed to set sample rate : %s@%i, errno = %d", __FILE__, __LINE__, errno); + goto error; + } + if (cur_sample_rate != fEngineControl->fSampleRate) { + jack_info("JackOSSDriver::OpenInput driver forced the sample rate %ld", fEngineControl->fSampleRate); + } + + fOutputBufferSize = 0; + if (ioctl(fOutFD, SNDCTL_DSP_GETBLKSIZE, &fOutputBufferSize) == -1) { + jack_error("JackOSSDriver::OpenOutput failed to get fragments : %s@%i, errno = %d", __FILE__, __LINE__, errno); + goto error; + } + + if (fOutputBufferSize != fEngineControl->fBufferSize * fSampleSize * fPlaybackChannels) { + if (fIgnoreHW) { + int new_buffer_size = fOutputBufferSize / (fSampleSize * fPlaybackChannels); + jack_info("JackOSSDriver::OpenOutput driver forced buffer size %ld", new_buffer_size); + JackAudioDriver::SetBufferSize(new_buffer_size); // never fails + } else { + jack_error("JackOSSDriver::OpenInput wanted buffer size cannot be obtained"); + goto error; + } + } + + fOutputBuffer = (void*)calloc(fOutputBufferSize, 1); + fFirstCycle = true; + assert(fOutputBuffer); + return 0; + +error: + ::close(fOutFD); + return -1; +} + +int JackOSSDriver::Open(jack_nframes_t nframes, + int user_nperiods, + jack_nframes_t samplerate, + bool capturing, + bool playing, + int inchannels, + int outchannels, + bool excl, + bool monitor, + const char* capture_driver_uid, + const char* playback_driver_uid, + jack_nframes_t capture_latency, + jack_nframes_t playback_latency, + int bits, + bool ignorehwbuf) +{ + // Generic JackAudioDriver Open + if (JackAudioDriver::Open(nframes, samplerate, capturing, playing, inchannels, outchannels, monitor, + capture_driver_uid, playback_driver_uid, capture_latency, playback_latency) != 0) { + return -1; + } else { + + if (!fEngineControl->fSyncMode) { + jack_error("Cannot run in asynchronous mode, use the -S parameter for jackd"); + return -1; + } + + fRWMode |= ((capturing) ? kRead : 0); + fRWMode |= ((playing) ? kWrite : 0); + fBits = bits; + fIgnoreHW = ignorehwbuf; + fNperiods = user_nperiods; + fExcl = excl; + + #ifdef JACK_MONITOR + // Force memory page in + memset(&gCycleTable, 0, sizeof(gCycleTable)); + #endif + + if (OpenAux() < 0) { + Close(); + return -1; + } else { + return 0; + } + } +} + +int JackOSSDriver::Close() +{ + #ifdef JACK_MONITOR + FILE* file = fopen("OSSProfiling.log", "w"); + + if (file) { + jack_info("Writing OSS driver timing data...."); + for (int i = 1; i < gCycleCount; i++) { + int d1 = gCycleTable.fTable[i].fAfterRead - gCycleTable.fTable[i].fBeforeRead; + int d2 = gCycleTable.fTable[i].fAfterReadConvert - gCycleTable.fTable[i].fAfterRead; + int d3 = gCycleTable.fTable[i].fAfterWrite - gCycleTable.fTable[i].fBeforeWrite; + int d4 = gCycleTable.fTable[i].fBeforeWrite - gCycleTable.fTable[i].fBeforeWriteConvert; + fprintf(file, "%d \t %d \t %d \t %d \t \n", d1, d2, d3, d4); + } + fclose(file); + } else { + jack_error("JackOSSDriver::Close : cannot open OSSProfiling.log file"); + } + + file = fopen("TimingOSS.plot", "w"); + + if (file == NULL) { + jack_error("JackOSSDriver::Close cannot open TimingOSS.plot file"); + } else { + + fprintf(file, "set grid\n"); + fprintf(file, "set title \"OSS audio driver timing\"\n"); + fprintf(file, "set xlabel \"audio cycles\"\n"); + fprintf(file, "set ylabel \"usec\"\n"); + fprintf(file, "plot \"OSSProfiling.log\" using 1 title \"Driver read wait\" with lines, \ + \"OSSProfiling.log\" using 2 title \"Driver read convert duration\" with lines, \ + \"OSSProfiling.log\" using 3 title \"Driver write wait\" with lines, \ + \"OSSProfiling.log\" using 4 title \"Driver write convert duration\" with lines\n"); + + fprintf(file, "set output 'TimingOSS.pdf\n"); + fprintf(file, "set terminal pdf\n"); + + fprintf(file, "set grid\n"); + fprintf(file, "set title \"OSS audio driver timing\"\n"); + fprintf(file, "set xlabel \"audio cycles\"\n"); + fprintf(file, "set ylabel \"usec\"\n"); + fprintf(file, "plot \"OSSProfiling.log\" using 1 title \"Driver read wait\" with lines, \ + \"OSSProfiling.log\" using 2 title \"Driver read convert duration\" with lines, \ + \"OSSProfiling.log\" using 3 title \"Driver write wait\" with lines, \ + \"OSSProfiling.log\" using 4 title \"Driver write convert duration\" with lines\n"); + + fclose(file); + } + #endif + int res = JackAudioDriver::Close(); + CloseAux(); + return res; +} + + +int JackOSSDriver::OpenAux() +{ + SetSampleFormat(); + + if ((fRWMode & kRead) && (OpenInput() < 0)) { + return -1; + } + + if ((fRWMode & kWrite) && (OpenOutput() < 0)) { + return -1; + } + + // In duplex mode, check that input and output use the same buffer size + if ((fRWMode & kRead) && (fRWMode & kWrite) && (fInputBufferSize != fOutputBufferSize)) { + jack_error("JackOSSDriver::OpenAux input and output buffer size are not the same!!"); + return -1; + } + + DisplayDeviceInfo(); + return 0; +} + +void JackOSSDriver::CloseAux() +{ + if (fRWMode & kRead && fInFD > 0) { + close(fInFD); + fInFD = -1; + } + + if (fRWMode & kWrite && fOutFD > 0) { + close(fOutFD); + fOutFD = -1; + } + + if (fInputBuffer) + free(fInputBuffer); + fInputBuffer = NULL; + + if (fOutputBuffer) + free(fOutputBuffer); + fOutputBuffer = NULL; +} + +int JackOSSDriver::Read() +{ + if (fInFD < 0) { + // Keep begin cycle time + JackDriver::CycleTakeBeginTime(); + return 0; + } + + ssize_t count; +/* + // Maybe necessary to write an empty output buffer first time : see http://manuals.opensound.com/developer/fulldup.c.html + if (fFirstCycle) { + + fFirstCycle = false; + memset(fOutputBuffer, 0, fOutputBufferSize); + + // Prefill ouput buffer + for (int i = 0; i < fNperiods; i++) { + count = ::write(fOutFD, fOutputBuffer, fOutputBufferSize); + if (count < fOutputBufferSize) { + jack_error("JackOSSDriver::Write error bytes written = %ld", count); + return -1; + } + } + + int delay; + if (ioctl(fOutFD, SNDCTL_DSP_GETODELAY, &delay) == -1) { + jack_error("JackOSSDriver::Write error get out delay : %s@%i, errno = %d", __FILE__, __LINE__, errno); + return -1; + } + + delay /= fSampleSize * fPlaybackChannels; + jack_info("JackOSSDriver::Write output latency frames = %ld", delay); + } +*/ + +#ifdef JACK_MONITOR + gCycleTable.fTable[gCycleCount].fBeforeRead = GetMicroSeconds(); +#endif + + audio_errinfo ei_in; + count = ::read(fInFD, fInputBuffer, fInputBufferSize); + +#ifdef JACK_MONITOR + if (count > 0 && count != fInputBufferSize) + jack_log("JackOSSDriver::Read count = %ld", count / (fSampleSize * fCaptureChannels)); + gCycleTable.fTable[gCycleCount].fAfterRead = GetMicroSeconds(); +#endif + + // XRun detection + if (ioctl(fInFD, SNDCTL_DSP_GETERROR, &ei_in) == 0) { + + if (ei_in.rec_overruns > 0 ) { + jack_error("JackOSSDriver::Read overruns"); + jack_time_t cur_time = GetMicroSeconds(); + NotifyXRun(cur_time, float(cur_time - fBeginDateUst)); // Better this value than nothing... + } + + if (ei_in.rec_errorcount > 0 && ei_in.rec_lasterror != 0) { + jack_error("%d OSS rec event(s), last=%05d:%d", ei_in.rec_errorcount, ei_in.rec_lasterror, ei_in.rec_errorparm); + } + } + + if (count < 0) { + jack_log("JackOSSDriver::Read error = %s", strerror(errno)); + return -1; + } else if (count < fInputBufferSize) { + jack_error("JackOSSDriver::Read error bytes read = %ld", count); + return -1; + } else { + + // Keep begin cycle time + JackDriver::CycleTakeBeginTime(); + for (int i = 0; i < fCaptureChannels; i++) { + if (fGraphManager->GetConnectionsNum(fCapturePortList[i]) > 0) { + CopyAndConvertIn(GetInputBuffer(i), fInputBuffer, fEngineControl->fBufferSize, i, fCaptureChannels, fBits); + } + } + + #ifdef JACK_MONITOR + gCycleTable.fTable[gCycleCount].fAfterReadConvert = GetMicroSeconds(); + #endif + + return 0; + } +} + +int JackOSSDriver::Write() +{ + if (fOutFD < 0) { + // Keep end cycle time + JackDriver::CycleTakeEndTime(); + return 0; + } + + ssize_t count; + audio_errinfo ei_out; + + // Maybe necessary to write an empty output buffer first time : see http://manuals.opensound.com/developer/fulldup.c.html + if (fFirstCycle) { + + fFirstCycle = false; + memset(fOutputBuffer, 0, fOutputBufferSize); + + // Prefill ouput buffer + for (int i = 0; i < fNperiods; i++) { + count = ::write(fOutFD, fOutputBuffer, fOutputBufferSize); + if (count < fOutputBufferSize) { + jack_error("JackOSSDriver::Write error bytes written = %ld", count); + return -1; + } + } + + int delay; + if (ioctl(fOutFD, SNDCTL_DSP_GETODELAY, &delay) == -1) { + jack_error("JackOSSDriver::Write error get out delay : %s@%i, errno = %d", __FILE__, __LINE__, errno); + return -1; + } + + delay /= fSampleSize * fPlaybackChannels; + jack_info("JackOSSDriver::Write output latency frames = %ld", delay); + } + +#ifdef JACK_MONITOR + gCycleTable.fTable[gCycleCount].fBeforeWriteConvert = GetMicroSeconds(); +#endif + + memset(fOutputBuffer, 0, fOutputBufferSize); + for (int i = 0; i < fPlaybackChannels; i++) { + if (fGraphManager->GetConnectionsNum(fPlaybackPortList[i]) > 0) { + CopyAndConvertOut(fOutputBuffer, GetOutputBuffer(i), fEngineControl->fBufferSize, i, fPlaybackChannels, fBits); + } + } + + #ifdef JACK_MONITOR + gCycleTable.fTable[gCycleCount].fBeforeWrite = GetMicroSeconds(); + #endif + + // Keep end cycle time + JackDriver::CycleTakeEndTime(); + count = ::write(fOutFD, fOutputBuffer, fOutputBufferSize); + + #ifdef JACK_MONITOR + if (count > 0 && count != fOutputBufferSize) + jack_log("JackOSSDriver::Write count = %ld", count / (fSampleSize * fPlaybackChannels)); + gCycleTable.fTable[gCycleCount].fAfterWrite = GetMicroSeconds(); + gCycleCount = (gCycleCount == CYCLE_POINTS - 1) ? gCycleCount: gCycleCount + 1; + #endif + + // XRun detection + if (ioctl(fOutFD, SNDCTL_DSP_GETERROR, &ei_out) == 0) { + + if (ei_out.play_underruns > 0) { + jack_error("JackOSSDriver::Write underruns"); + jack_time_t cur_time = GetMicroSeconds(); + NotifyXRun(cur_time, float(cur_time - fBeginDateUst)); // Better this value than nothing... + } + + if (ei_out.play_errorcount > 0 && ei_out.play_lasterror != 0) { + jack_error("%d OSS play event(s), last=%05d:%d",ei_out.play_errorcount, ei_out.play_lasterror, ei_out.play_errorparm); + } + } + + if (count < 0) { + jack_log("JackOSSDriver::Write error = %s", strerror(errno)); + return -1; + } else if (count < fOutputBufferSize) { + jack_error("JackOSSDriver::Write error bytes written = %ld", count); + return -1; + } else { + return 0; + } +} + +int JackOSSDriver::SetBufferSize(jack_nframes_t buffer_size) +{ + CloseAux(); + JackAudioDriver::SetBufferSize(buffer_size); // never fails + return OpenAux(); +} + +int JackOSSDriver::ProcessSync() +{ + // Read input buffers for the current cycle + if (Read() < 0) { + jack_error("ProcessSync: read error, skip cycle"); + return 0; // Skip cycle, but continue processing... + } + + if (fIsMaster) { + ProcessGraphSync(); + } else { + fGraphManager->ResumeRefNum(&fClientControl, fSynchroTable); + } + + // Write output buffers for the current cycle + if (Write() < 0) { + jack_error("JackAudioDriver::ProcessSync: write error, skip cycle"); + return 0; // Skip cycle, but continue processing... + } + + return 0; +} + +} // end of namespace + +#ifdef __cplusplus +extern "C" +{ +#endif + +SERVER_EXPORT jack_driver_desc_t* driver_get_descriptor() +{ + jack_driver_desc_t *desc; + unsigned int i; + desc = (jack_driver_desc_t*)calloc(1, sizeof(jack_driver_desc_t)); + + strcpy(desc->name, "oss"); // size MUST be less then JACK_DRIVER_NAME_MAX + 1 + strcpy(desc->desc, "OSS API based audio backend"); // size MUST be less then JACK_DRIVER_PARAM_DESC + 1 + + desc->nparams = OSS_DRIVER_N_PARAMS; + desc->params = (jack_driver_param_desc_t*)calloc(desc->nparams, sizeof(jack_driver_param_desc_t)); + + i = 0; + strcpy(desc->params[i].name, "rate"); + desc->params[i].character = 'r'; + desc->params[i].type = JackDriverParamUInt; + desc->params[i].value.ui = OSS_DRIVER_DEF_FS; + strcpy(desc->params[i].short_desc, "Sample rate"); + strcpy(desc->params[i].long_desc, desc->params[i].short_desc); + + i++; + strcpy(desc->params[i].name, "period"); + desc->params[i].character = 'p'; + desc->params[i].type = JackDriverParamUInt; + desc->params[i].value.ui = OSS_DRIVER_DEF_BLKSIZE; + strcpy(desc->params[i].short_desc, "Frames per period"); + strcpy(desc->params[i].long_desc, desc->params[i].short_desc); + + i++; + strcpy(desc->params[i].name, "nperiods"); + desc->params[i].character = 'n'; + desc->params[i].type = JackDriverParamUInt; + desc->params[i].value.ui = OSS_DRIVER_DEF_NPERIODS; + strcpy(desc->params[i].short_desc, "Number of periods to prefill output buffer"); + strcpy(desc->params[i].long_desc, desc->params[i].short_desc); + + i++; + strcpy(desc->params[i].name, "wordlength"); + desc->params[i].character = 'w'; + desc->params[i].type = JackDriverParamInt; + desc->params[i].value.i = OSS_DRIVER_DEF_BITS; + strcpy(desc->params[i].short_desc, "Word length"); + strcpy(desc->params[i].long_desc, desc->params[i].short_desc); + + i++; + strcpy(desc->params[i].name, "inchannels"); + desc->params[i].character = 'i'; + desc->params[i].type = JackDriverParamUInt; + desc->params[i].value.ui = OSS_DRIVER_DEF_INS; + strcpy(desc->params[i].short_desc, "Capture channels"); + strcpy(desc->params[i].long_desc, desc->params[i].short_desc); + + i++; + strcpy(desc->params[i].name, "outchannels"); + desc->params[i].character = 'o'; + desc->params[i].type = JackDriverParamUInt; + desc->params[i].value.ui = OSS_DRIVER_DEF_OUTS; + strcpy(desc->params[i].short_desc, "Playback channels"); + strcpy(desc->params[i].long_desc, desc->params[i].short_desc); + + i++; + strcpy(desc->params[i].name, "excl"); + desc->params[i].character = 'e'; + desc->params[i].type = JackDriverParamBool; + desc->params[i].value.i = false; + strcpy(desc->params[i].short_desc, "Exclusif (O_EXCL) access mode"); + strcpy(desc->params[i].long_desc, desc->params[i].short_desc); + + i++; + strcpy(desc->params[i].name, "capture"); + desc->params[i].character = 'C'; + desc->params[i].type = JackDriverParamString; + strcpy(desc->params[i].value.str, OSS_DRIVER_DEF_DEV); + strcpy(desc->params[i].short_desc, "Input device"); + strcpy(desc->params[i].long_desc, desc->params[i].short_desc); + + i++; + strcpy(desc->params[i].name, "playback"); + desc->params[i].character = 'P'; + desc->params[i].type = JackDriverParamString; + strcpy(desc->params[i].value.str, OSS_DRIVER_DEF_DEV); + strcpy(desc->params[i].short_desc, "Output device"); + strcpy(desc->params[i].long_desc, desc->params[i].short_desc); + + i++; + strcpy (desc->params[i].name, "device"); + desc->params[i].character = 'd'; + desc->params[i].type = JackDriverParamString; + strcpy(desc->params[i].value.str, OSS_DRIVER_DEF_DEV); + strcpy(desc->params[i].short_desc, "OSS device name"); + strcpy(desc->params[i].long_desc, desc->params[i].short_desc); + + i++; + strcpy(desc->params[i].name, "ignorehwbuf"); + desc->params[i].character = 'b'; + desc->params[i].type = JackDriverParamBool; + desc->params[i].value.i = TRUE; + strcpy(desc->params[i].short_desc, "Ignore hardware period size"); + strcpy(desc->params[i].long_desc, desc->params[i].short_desc); + + i++; + strcpy(desc->params[i].name, "input-latency"); + desc->params[i].character = 'I'; + desc->params[i].type = JackDriverParamUInt; + desc->params[i].value.i = 0; + strcpy(desc->params[i].short_desc, "Extra input latency"); + strcpy(desc->params[i].long_desc, desc->params[i].short_desc); + + i++; + strcpy(desc->params[i].name, "output-latency"); + desc->params[i].character = 'O'; + desc->params[i].type = JackDriverParamUInt; + desc->params[i].value.i = 0; + strcpy(desc->params[i].short_desc, "Extra output latency"); + strcpy(desc->params[i].long_desc, desc->params[i].short_desc); + + return desc; +} + +EXPORT Jack::JackDriverClientInterface* driver_initialize(Jack::JackLockedEngine* engine, Jack::JackSynchro* table, const JSList* params) +{ + int bits = OSS_DRIVER_DEF_BITS; + jack_nframes_t srate = OSS_DRIVER_DEF_FS; + jack_nframes_t frames_per_interrupt = OSS_DRIVER_DEF_BLKSIZE; + const char* capture_pcm_name = OSS_DRIVER_DEF_DEV; + const char* playback_pcm_name = OSS_DRIVER_DEF_DEV; + bool capture = false; + bool playback = false; + int chan_in = 0; + int chan_out = 0; + bool monitor = false; + bool excl = false; + unsigned int nperiods = OSS_DRIVER_DEF_NPERIODS; + const JSList *node; + const jack_driver_param_t *param; + bool ignorehwbuf = false; + jack_nframes_t systemic_input_latency = 0; + jack_nframes_t systemic_output_latency = 0; + + for (node = params; node; node = jack_slist_next(node)) { + + param = (const jack_driver_param_t *)node->data; + + switch (param->character) { + + case 'r': + srate = param->value.ui; + break; + + case 'p': + frames_per_interrupt = (unsigned int)param->value.ui; + break; + + case 'n': + nperiods = (unsigned int)param->value.ui; + break; + + case 'w': + bits = param->value.i; + break; + + case 'i': + chan_in = (int)param->value.ui; + break; + + case 'o': + chan_out = (int)param->value.ui; + break; + + case 'C': + capture = true; + if (strcmp(param->value.str, "none") != 0) { + capture_pcm_name = strdup(param->value.str); + } + break; + + case 'P': + playback = true; + if (strcmp(param->value.str, "none") != 0) { + playback_pcm_name = strdup(param->value.str); + } + break; + + case 'd': + playback_pcm_name = strdup (param->value.str); + capture_pcm_name = strdup (param->value.str); + break; + + case 'b': + ignorehwbuf = true; + break; + + case 'e': + excl = true; + break; + + case 'I': + systemic_input_latency = param->value.ui; + break; + + case 'O': + systemic_output_latency = param->value.ui; + break; + } + } + + // duplex is the default + if (!capture && !playback) { + capture = true; + playback = true; + } + + Jack::JackOSSDriver* oss_driver = new Jack::JackOSSDriver("system", "oss", engine, table); + Jack::JackDriverClientInterface* threaded_driver = new Jack::JackThreadedDriver(oss_driver); + + // Special open for OSS driver... + if (oss_driver->Open(frames_per_interrupt, nperiods, srate, capture, playback, chan_in, chan_out, + excl, monitor, capture_pcm_name, playback_pcm_name, systemic_input_latency, systemic_output_latency, bits, ignorehwbuf) == 0) { + return threaded_driver; + } else { + delete threaded_driver; // Delete the decorated driver + return NULL; + } +} + +#ifdef __cplusplus +} +#endif |