Skip to content
Snippets Groups Projects
Select Git revision
  • 1adb48c2c7102700c0115d800a104e007caabe6d
  • master default protected
  • release/202005
  • release/202001
  • release/201912
  • release/201911
  • release/releaseWindowsTestOne
  • release/windowsReleaseTest
  • release/releaseTest
  • release/releaseWindowsTest
  • release/201910
  • release/qt/201910
  • release/windows-test/201910
  • release/201908
  • release/201906
  • release/201905
  • release/201904
  • release/201903
  • release/201902
  • release/201901
  • release/201812
  • 4.0.0
  • 2.2.0
  • 2.1.0
  • 2.0.1
  • 2.0.0
  • 1.4.1
  • 1.4.0
  • 1.3.0
  • 1.2.0
  • 1.1.0
31 results

audiostream.h

Blame
  • Code owners
    Assign users and groups as approvers for specific file changes. Learn more.
    audiostream.h 5.04 KiB
    /*
     *  Copyright (C) 2004, 2005, 2006, 2009, 2008, 2009, 2010, 2011 Savoir-Faire Linux Inc.
     *  Author: Emmanuel Milou <emmanuel.milou@savoirfairelinux.com>
     *
     *  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 3 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.
     *
     *  Additional permission under GNU GPL version 3 section 7:
     *
     *  If you modify this program, or any covered work, by linking or
     *  combining it with the OpenSSL project's OpenSSL library (or a
     *  modified version of that library), containing parts covered by the
     *  terms of the OpenSSL or SSLeay licenses, Savoir-Faire Linux Inc.
     *  grants you additional permission to convey the resulting work.
     *  Corresponding Source for a non-source form of such a combination
     *  shall include the source code for the parts of OpenSSL used as well
     *  as that of the covered work.
     */
    
    #ifndef _AUDIO_STREAM_H
    #define _AUDIO_STREAM_H
    
    #include <pulse/pulseaudio.h>
    #include <string>
    
    #include "global.h"
    #include "audio/ringbuffer.h"
    #include "audio/audioloop.h"
    
    #include <cc++/thread.h>
    
    /**
     * This data structure contains the different king of audio streams available
     */
    enum STREAM_TYPE {
    	PLAYBACK_STREAM, CAPTURE_STREAM, RINGTONE_STREAM, UPLOAD_STREAM
    };
    
    struct AudioStreamParams {
    	pa_context * context;
    	pa_threaded_mainloop * mainloop;
    	std::string description;
    	int type;
    	int smplrate;
    };
    
    class AudioStream {
    public:
    
    	/**
    	 * Constructor
    	 *
    	 * @param context pulseaudio's application context.
    	 * @param mainloop pulseaudio's main loop
    	 * @param description
    	 * @param types
    	 * @param audio sampling rate
    	 */
    	AudioStream(pa_context *, pa_threaded_mainloop *, std::string, int, int);
    
    	/**
    	 * Destructor
    	 */
    	~AudioStream();
    
    	/**
    	 * Write data to the main abstraction ring buffer.
    	 * @param buffer The buffer containing the data to be played
    	 * @param toCopy The number of samples, in bytes
    	 * @return int The number of bytes played
    	 */
    	int putMain(void* buffer, int toCopy);
    
    	/**
    	 * Write data to the urgent abstraction ring buffer. ( dtmf , double calls )
    	 * @param buffer The buffer containing the data to be played
    	 * @param toCopy The number of samples, in bytes
    	 * @return int The number of bytes played
    	 */
    	int putUrgent(void* buffer, int toCopy);
    
    	/**
    	 * Connect the pulse audio stream
    	 */
    	bool connectStream(std::string* deviceName);
    
    	/**
    	 * Drain the given stream.
    	 */
    	bool drainStream(void);
    
    	/**
    	 * Disconnect the pulseaudio stream
    	 */
    	bool disconnectStream();
    
    	/**
    	 * Accessor: Get the pulseaudio stream object
    	 * @return pa_stream* The stream
    	 */
    	pa_stream* pulseStream() {
    		return _audiostream;
    	}
    
    	/**
    	 * Accessor
    	 * @return std::string  The stream name
    	 */
    	std::string getStreamName(void) {
    		return _streamDescription;
    	}
    
    	/**
    	 * Accessor
    	 * @param name  The stream name
    	 */
    	void setStreamName(std::string name) {
    		_streamDescription = name;
    	}
    
    	void setVolume(double pc) {
    		_volume.values[0] *= pc / 100;
    	}
    	pa_cvolume getVolume(void) {
    		return _volume;
    	}
    
    	/**
    	 * Accessor
    	 * @return stream state
    	 */
    	pa_stream_state_t getStreamState(void);
    
    private:
    
    	// Copy Constructor
    	AudioStream(const AudioStream& rh);
    
    	// Assignment Operator
    	AudioStream& operator=(const AudioStream& rh);
    
    	/**
    	 * Create the audio stream into the given context
    	 * @param c	The pulseaudio context
    	 * @return pa_stream* The newly created audio stream
    	 */
    	pa_stream* createStream(pa_context* c, std::string* deviceName);
    
    	/**
    	 * Mandatory asynchronous callback on the audio stream state
    	 */
    	static void stream_state_callback(pa_stream* s, void* user_data);
    
    	/**
    	 * Asynchronous callback on data processing ( write and read )
    	 */
    	static void audioCallback(pa_stream* s, size_t bytes, void* userdata);
    
    	/**
    	 * Write data to the sound device
    	 */
    	void write(void);
    
    	/**
    	 * The pulse audio object
    	 */
    	pa_stream* _audiostream;
    
    	/**
    	 * The pulse audio context
    	 */
    	pa_context* _context;
    
    	/**
    	 * The type of the stream
    	 */
    	int _streamType;
    
    	/**
    	 * The name of the stream
    	 */
    	std::string _streamDescription;
    
    	/**
    	 * Streams parameters
    	 */
    	pa_cvolume _volume;
    
    	/**
    	 * Some special flags for stream connections.
    	 * ex: PA_STREAM_ADJUST_LATENCY, PA_STREAM_START_MUTED, PA_STREAM_VARIABLE_RATE
    	 */
    	pa_stream_flags_t _flag;
    
    	/**
    	 * A sample format and attribute specification
    	 */
    	pa_sample_spec _sample_spec;
    
    	/**
    	 * A pointer to the opaque threaded main loop object
    	 */
    	pa_threaded_mainloop * _mainloop;
    
    	ost::Mutex _mutex;
    
    	bool _stream_is_ready;
    
    };
    
    #endif // _AUDIO_STREAM_H