Mercurial > hg > opencollidoscope
diff CollidoscopeApp/include/BufferToWaveRecorderNode.h @ 0:02467299402e
First import
CollidoscopeApp for Raspberry Pi
JackDevice
Teensy code for Collidoscope
author | Fiore Martin <f.martin@qmul.ac.uk> |
---|---|
date | Thu, 30 Jun 2016 14:50:06 +0200 |
parents | |
children | dd889fff8423 |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/CollidoscopeApp/include/BufferToWaveRecorderNode.h Thu Jun 30 14:50:06 2016 +0200 @@ -0,0 +1,92 @@ +#pragma once + +#include "cinder/Cinder.h" +#include "cinder/audio/Node.h" +#include "cinder/audio/SampleRecorderNode.h" +#include "cinder/audio/dsp/RingBuffer.h" +#include "cinder/Filesystem.h" + +#include "Messages.h" + +typedef std::shared_ptr<class BufferToWaveRecorderNode> BufferToWaveRecorderNodeRef; + +typedef ci::audio::dsp::RingBufferT<RecordWaveMsg> RecordWaveMsgRingBuffer; + + +class BufferToWaveRecorderNode : public ci::audio::SampleRecorderNode { +public: + + static const float kRampTime; + + //! Constructor. numChunks is the total number of chunks this biffer has to be borken down in. + //! numSeconds lenght of the buffer in seconds + BufferToWaveRecorderNode( std::size_t numChunks, double numSeconds ); + + //! Starts recording. Resets the write position to zero (call disable() to pause recording). + void start(); + //! Stops recording. Same as calling disable(). + void stop(); + + //! \brief Sets the length of the recording buffer in frames. + //! + //! If the write position is non-zero, the old contents will be preserved (by copying it to the newly allocated Buffer). + //! If \a shrinkToFit is set to `true`, the internal Buffer will be down-sized if necessary, otherwise it will only re-allocate when growing while changing its dimensions to match \a numFrames (default shrinkToFit = false). + void setNumFrames(size_t numFrames, bool shrinkToFit = false); + //! Sets the length of the recording buffer in seconds. \see setNumFrames + void setNumSeconds(double numSeconds, bool shrinkToFit = false); + + //! Returns the length of the recording buffer in frames. + size_t getNumFrames() const { return mRecorderBuffer.getNumFrames(); } + //! Returns the length of the recording buffer in seconds. + double getNumSeconds() const; + + //! \brief Returns a copy of the recored samples, up to the current write position. + //! + //! This method is non locking, and as such any resizing calls must be performed on the same thread or be otherwise synchronized. + ci::audio::BufferRef getRecordedCopy() const; + + //! \brief Writes the currently recorded samples to a file at \a filePath + //! + //! The encoding format is derived from \a filePath's extension and \a sampleType (default = SampleType::INT_16). + //! \note throws AudioFileExc if the write request cannot be completed. + void writeToFile(const ci::fs::path &filePath, ci::audio::SampleType sampleType = ci::audio::SampleType::INT_16); + + //! Returns the frame of the last buffer overrun or 0 if none since the last time this method was called. When this happens, it means the recorded buffer probably has skipped some frames. + uint64_t getLastOverrun(); + + RecordWaveMsgRingBuffer& getRingBuffer() { return mRingBuffer; } + + ci::audio::Buffer* getRecorderBuffer() { return &mRecorderBuffer; } + + +protected: + void initialize() override; + void process(ci::audio::Buffer *buffer) override; + + void initBuffers(size_t numFrames); + + static const float kMinAudioVal; + static const float kMaxAudioVal; + + ci::audio::BufferDynamic mRecorderBuffer; + ci::audio::BufferDynamicRef mCopiedBuffer; + std::atomic<uint64_t> mLastOverrun; + + RecordWaveMsgRingBuffer mRingBuffer; + + const std::size_t mNumChunks; + const double mNumSeconds; + std::size_t mNumSamplesPerChunk; + std::atomic<std::size_t> mChunkIndex; + + size_t mChunkSampleCounter; + float mChunkMaxAudioVal; + float mChunkMinAudioVal; + + float mEnvRamp; + float mEnvRampRate; + size_t mEnvRampLen; + size_t mEnvDecayStart; + +}; +