added PulseAudio-support
git-svn-id: https://lmms.svn.sf.net/svnroot/lmms/trunk/lmms@1037 0778d3d1-df1d-0410-868b-ea421aaaa00d
This commit is contained in:
Tobias Doerffel
311
src/core/audio/audio_pulseaudio.cpp
Normal file
311
src/core/audio/audio_pulseaudio.cpp
Normal file
@@ -0,0 +1,311 @@
|
||||
#ifndef SINGLE_SOURCE_COMPILE
|
||||
|
||||
/*
|
||||
* audio_pulseaudio.cpp - device-class which implements PulseAudio-output
|
||||
*
|
||||
* Copyright (c) 2008 Tobias Doerffel <tobydox/at/users.sourceforge.net>
|
||||
*
|
||||
* This file is part of Linux MultiMedia Studio - http://lmms.sourceforge.net
|
||||
*
|
||||
* 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 (see COPYING); if not, write to the
|
||||
* Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
|
||||
* Boston, MA 02110-1301 USA.
|
||||
*
|
||||
*/
|
||||
|
||||
|
||||
|
||||
#include <QtGui/QLineEdit>
|
||||
#include <QtGui/QLabel>
|
||||
|
||||
|
||||
#include "audio_pulseaudio.h"
|
||||
|
||||
|
||||
#ifdef PULSEAUDIO_SUPPORT
|
||||
|
||||
#include "endian_handling.h"
|
||||
#include "config_mgr.h"
|
||||
#include "lcd_spinbox.h"
|
||||
#include "gui_templates.h"
|
||||
#include "templates.h"
|
||||
|
||||
|
||||
static void stream_write_callback(pa_stream *s, size_t length, void *userdata)
|
||||
{
|
||||
static_cast<audioPulseAudio *>( userdata )->streamWriteCallback( s, length );
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
audioPulseAudio::audioPulseAudio( bool & _success_ful, mixer * _mixer ) :
|
||||
audioDevice( tLimit<ch_cnt_t>(
|
||||
configManager::inst()->value( "audiopa", "channels" ).toInt(),
|
||||
DEFAULT_CHANNELS, SURROUND_CHANNELS ),
|
||||
_mixer ),
|
||||
m_s( NULL ),
|
||||
m_convertEndian( FALSE )
|
||||
{
|
||||
_success_ful = FALSE;
|
||||
|
||||
m_sampleSpec.format = PA_SAMPLE_S16LE;
|
||||
m_sampleSpec.rate = sampleRate();
|
||||
m_sampleSpec.channels = channels();
|
||||
|
||||
_success_ful = TRUE;
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
audioPulseAudio::~audioPulseAudio()
|
||||
{
|
||||
stopProcessing();
|
||||
|
||||
if( m_s != NULL )
|
||||
{
|
||||
pa_stream_unref( m_s );
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
QString audioPulseAudio::probeDevice( void )
|
||||
{
|
||||
QString dev = configManager::inst()->value( "audiopa", "device" );
|
||||
if( dev == "" )
|
||||
{
|
||||
if( getenv( "AUDIODEV" ) != NULL )
|
||||
{
|
||||
return( getenv( "AUDIODEV" ) );
|
||||
}
|
||||
return( "default" );
|
||||
}
|
||||
return( dev );
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
void audioPulseAudio::startProcessing( void )
|
||||
{
|
||||
if( !isRunning() )
|
||||
{
|
||||
start( QThread::HighPriority );
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
void audioPulseAudio::stopProcessing( void )
|
||||
{
|
||||
if( isRunning() )
|
||||
{
|
||||
wait( 1000 );
|
||||
terminate();
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
void audioPulseAudio::applyQualitySettings( void )
|
||||
{
|
||||
if( hqAudio() )
|
||||
{
|
||||
// setSampleRate( engine::getMixer()->processingSampleRate() );
|
||||
|
||||
}
|
||||
|
||||
audioDevice::applyQualitySettings();
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
/* This routine is called whenever the stream state changes */
|
||||
static void stream_state_callback( pa_stream *s, void * userdata )
|
||||
{
|
||||
switch( pa_stream_get_state( s ) )
|
||||
{
|
||||
case PA_STREAM_CREATING:
|
||||
case PA_STREAM_TERMINATED:
|
||||
break;
|
||||
|
||||
case PA_STREAM_READY:
|
||||
fprintf(stderr, "Stream successfully created\n");
|
||||
break;
|
||||
|
||||
case PA_STREAM_FAILED:
|
||||
default:
|
||||
fprintf(stderr, "Stream errror: %s\n",
|
||||
pa_strerror(pa_context_errno(
|
||||
pa_stream_get_context( s ) ) ) );
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
/* This is called whenever the context status changes */
|
||||
static void context_state_callback(pa_context *c, void *userdata)
|
||||
{
|
||||
audioPulseAudio * _this = static_cast<audioPulseAudio *>( userdata );
|
||||
switch( pa_context_get_state( c ) )
|
||||
{
|
||||
case PA_CONTEXT_CONNECTING:
|
||||
case PA_CONTEXT_AUTHORIZING:
|
||||
case PA_CONTEXT_SETTING_NAME:
|
||||
break;
|
||||
|
||||
case PA_CONTEXT_READY:
|
||||
{
|
||||
pa_cvolume cv;
|
||||
fprintf(stderr, "Connection established.\n");
|
||||
_this->m_s = pa_stream_new(c, "lmms", &_this->m_sampleSpec, NULL);
|
||||
pa_stream_set_state_callback(_this->m_s, stream_state_callback, _this );
|
||||
pa_stream_set_write_callback(_this->m_s, stream_write_callback, _this);
|
||||
pa_stream_connect_playback(_this->m_s, NULL, NULL, (pa_stream_flags) 0, pa_cvolume_set(&cv, _this->m_sampleSpec.channels, PA_VOLUME_NORM), NULL);
|
||||
break;
|
||||
}
|
||||
|
||||
case PA_CONTEXT_TERMINATED:
|
||||
break;
|
||||
|
||||
case PA_CONTEXT_FAILED:
|
||||
default:
|
||||
fprintf(stderr, "Connection failure: %s\n", pa_strerror(pa_context_errno(c)));
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
void audioPulseAudio::run( void )
|
||||
{
|
||||
pa_mainloop * m = NULL;
|
||||
|
||||
|
||||
if (!(m = pa_mainloop_new())) {
|
||||
fprintf(stderr, "pa_mainloop_new() failed.\n");
|
||||
return;
|
||||
}
|
||||
pa_mainloop_api * mainloop_api = pa_mainloop_get_api(m);
|
||||
|
||||
pa_context *context = pa_context_new(mainloop_api, "lmms");
|
||||
if ( context == NULL )
|
||||
{
|
||||
fprintf(stderr, "pa_context_new() failed.\n");
|
||||
return;
|
||||
}
|
||||
|
||||
pa_context_set_state_callback(context, context_state_callback, this );
|
||||
/* Connect the context */
|
||||
pa_context_connect(context, NULL, (pa_context_flags) 0, NULL);
|
||||
|
||||
int ret;
|
||||
/* Run the main loop */
|
||||
if (pa_mainloop_run(m, &ret) < 0)
|
||||
{
|
||||
fprintf(stderr, "pa_mainloop_run() failed.\n");
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
void audioPulseAudio::streamWriteCallback(pa_stream *s, size_t length)
|
||||
{
|
||||
const fpp_t fpp = getMixer()->framesPerPeriod();
|
||||
surroundSampleFrame * temp = new surroundSampleFrame[fpp];
|
||||
Sint16 * pcmbuf = (Sint16*)pa_xmalloc( fpp * channels() * sizeof(Sint16) );
|
||||
|
||||
int error;
|
||||
|
||||
int fd = 0;
|
||||
while( fd < length/4 )
|
||||
{
|
||||
const fpp_t frames = getNextBuffer( temp );
|
||||
if( !frames )
|
||||
{
|
||||
return;
|
||||
}
|
||||
int bytes = convertToS16( temp, frames,
|
||||
getMixer()->masterGain(),
|
||||
pcmbuf,
|
||||
m_convertEndian );
|
||||
if( bytes > 0 )
|
||||
{
|
||||
pa_stream_write( m_s, pcmbuf, bytes, NULL, 0,
|
||||
PA_SEEK_RELATIVE );
|
||||
}
|
||||
fd += frames;
|
||||
}
|
||||
|
||||
pa_xfree( pcmbuf );
|
||||
delete[] temp;
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
audioPulseAudio::setupWidget::setupWidget( QWidget * _parent ) :
|
||||
audioDevice::setupWidget( audioPulseAudio::name(), _parent )
|
||||
{
|
||||
m_device = new QLineEdit( audioPulseAudio::probeDevice(), this );
|
||||
m_device->setGeometry( 10, 20, 160, 20 );
|
||||
|
||||
QLabel * dev_lbl = new QLabel( tr( "DEVICE" ), this );
|
||||
dev_lbl->setFont( pointSize<6>( dev_lbl->font() ) );
|
||||
dev_lbl->setGeometry( 10, 40, 160, 10 );
|
||||
|
||||
lcdSpinBoxModel * m = new lcdSpinBoxModel( /* this */ );
|
||||
m->setRange( DEFAULT_CHANNELS, SURROUND_CHANNELS );
|
||||
m->setStep( 2 );
|
||||
m->setValue( configManager::inst()->value( "audiopa",
|
||||
"channels" ).toInt() );
|
||||
|
||||
m_channels = new lcdSpinBox( 1, this );
|
||||
m_channels->setModel( m );
|
||||
m_channels->setLabel( tr( "CHANNELS" ) );
|
||||
m_channels->move( 180, 20 );
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
audioPulseAudio::setupWidget::~setupWidget()
|
||||
{
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
void audioPulseAudio::setupWidget::saveSettings( void )
|
||||
{
|
||||
configManager::inst()->setValue( "audiopa", "device",
|
||||
m_device->text() );
|
||||
configManager::inst()->setValue( "audiopa", "channels",
|
||||
QString::number( m_channels->value<int>() ) );
|
||||
}
|
||||
|
||||
|
||||
#endif
|
||||
|
||||
|
||||
#endif
|
||||
@@ -54,6 +54,7 @@
|
||||
#include "audio_alsa.h"
|
||||
#include "audio_jack.h"
|
||||
#include "audio_oss.h"
|
||||
#include "audio_pulseaudio.h"
|
||||
#include "audio_sdl.h"
|
||||
#include "audio_dummy.h"
|
||||
|
||||
@@ -912,6 +913,20 @@ audioDevice * mixer::tryAudioDevices( void )
|
||||
#endif
|
||||
|
||||
|
||||
#ifdef PULSEAUDIO_SUPPORT
|
||||
if( dev_name == audioPulseAudio::name() || dev_name == "" )
|
||||
{
|
||||
dev = new audioPulseAudio( success_ful, this );
|
||||
if( success_ful )
|
||||
{
|
||||
m_audioDevName = audioPulseAudio::name();
|
||||
return( dev );
|
||||
}
|
||||
delete dev;
|
||||
}
|
||||
#endif
|
||||
|
||||
|
||||
#ifdef OSS_SUPPORT
|
||||
if( dev_name == audioOSS::name() || dev_name == "" )
|
||||
{
|
||||
|
||||
@@ -55,6 +55,7 @@
|
||||
#include "audio_alsa.h"
|
||||
#include "audio_jack.h"
|
||||
#include "audio_oss.h"
|
||||
#include "audio_pulseaudio.h"
|
||||
#include "audio_sdl.h"
|
||||
#include "audio_dummy.h"
|
||||
|
||||
@@ -487,6 +488,11 @@ setupDialog::setupDialog( ConfigTabs _tab_to_open ) :
|
||||
new audioALSA::setupWidget( asw );
|
||||
#endif
|
||||
|
||||
#ifdef PULSEAUDIO_SUPPORT
|
||||
m_audioIfaceSetupWidgets[audioPulseAudio::name()] =
|
||||
new audioPulseAudio::setupWidget( asw );
|
||||
#endif
|
||||
|
||||
#ifdef SDL_AUDIO_SUPPORT
|
||||
m_audioIfaceSetupWidgets[audioSDL::name()] =
|
||||
new audioSDL::setupWidget( asw );
|
||||
|
||||
Reference in New Issue
Block a user