1 files changed, 64 insertions, 0 deletions
diff --git a/libs/audiographer/audiographer/general/sr_converter.h b/libs/audiographer/audiographer/general/sr_converter.h
new file mode 100644
index 0000000000..f28c8f6953
--- /dev/null
+++ b/libs/audiographer/audiographer/general/sr_converter.h
@@ -0,0 +1,64 @@
+#ifndef AUDIOGRAPHER_SR_CONVERTER_H
+#define AUDIOGRAPHER_SR_CONVERTER_H
+
+#include <samplerate.h>
+
+#include "audiographer/flag_debuggable.h"
+#include "audiographer/sink.h"
+#include "audiographer/throwing.h"
+#include "audiographer/types.h"
+#include "audiographer/utils/listed_source.h"
+
+namespace AudioGrapher
+{
+
+/// Samplerate converter
+class SampleRateConverter
+  : public ListedSource<float>
+  , public Sink<float>
+  , public FlagDebuggable<>
+  , public Throwing<>
+{
+  public:
+	/// Constructor. \n RT safe
+	SampleRateConverter (uint32_t channels);
+	~SampleRateConverter ();
+
+	/// Init converter \n Not RT safe
+	void init (nframes_t in_rate, nframes_t out_rate, int quality = 0);
+	
+	/// Returns max amount of frames that will be output \n RT safe
+	nframes_t allocate_buffers (nframes_t max_frames);
+	
+	/** Does sample rate conversion.
+	  * Note that outpt size may vary a lot.
+	  * May or may not output several contexts of data.
+	  * \n Should be RT safe.
+	  * \TODO Check RT safety from libsamplerate
+	  */
+	void process (ProcessContext<float> const & c);
+	using Sink<float>::process;
+
+  private:
+
+	void set_end_of_input (ProcessContext<float> const & c);
+	void reset ();
+
+	bool           active;
+	uint32_t       channels;
+	nframes_t      max_frames_in;
+	
+	float *        leftover_data;
+	nframes_t      leftover_frames;
+	nframes_t      max_leftover_frames;
+
+	float *        data_out;
+	nframes_t      data_out_size;
+
+	SRC_DATA       src_data;
+	SRC_STATE*     src_state;
+};
+
+} // namespace
+
+#endif // AUDIOGRAPHER_SR_CONVERTER_H