Method enqueueSamples

src/cinder/audio/linux/ContextPulseAudio.cpp:551–600

}

void InputStream::enqueueSamples( pa_stream *s, size_t nbytes )
{
	CI_ASSERT( nbytes % mBytesPerFrame == 0 );

	// TODO: use the result of pa_stream_readable_size here?
	// - can use it to check if there is enough room in the ringbuffer left to write to
	while( pa_stream_readable_size( s ) > 0 ) {
		const void *data;

		if( pa_stream_peek( s, &data, &nbytes ) < 0 ) {
			auto errorStr = pa_strerror( pa_context_errno( mContext->mPaContext ) );
			CI_LOG_E( "pa_stream_peek() failed: " << errorStr );
			CI_ASSERT_NOT_REACHABLE();
			return;
		}

		CI_ASSERT( nbytes > 0 );

		const size_t numFramesRead = nbytes / mBytesPerFrame;

		// resize mReadBuffer if necessary
		mReadBuffer.setSize( numFramesRead, mNumChannels );

		if( data ) {
			// de-interleave and write data to a ringbuffer that will be consumed in InpudeDeviceNode's process method
			ci::audio::dsp::deinterleave( (const float *)data, mReadBuffer.getData(), numFramesRead, mNumChannels, numFramesRead );
		}
		else {
			// there is a hole in the stream, generate silence
			mReadBuffer.zero();
		}

		size_t framesBuffered = 0;
		for( size_t ch = 0; ch < mRingBuffers.size(); ch++ ) {
			if( mRingBuffers[ch].write( mReadBuffer.getChannel( ch ), numFramesRead ) ) {
				// only set this to non-zero if we succeeded at writing to the ringbuffer
				framesBuffered = numFramesRead;
			}
			else {
				//CI_LOG_W( "RingBuffer full for channel: " << ch );
				if( mMarkOverrunFn )
					mMarkOverrunFn();
			}
		}

		mNumFramesBuffered += framesBuffered;
		pa_stream_drop( s );
	}

}

} // namespace pulse