/* ------------------------------------------------------------------ * Copyright (C) 2019 Matthias P. Braendli * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either * express or implied. * See the License for the specific language governing permissions * and limitations under the License. * ------------------------------------------------------------------- */ /*! \file GSTInput.h * * This input uses GStreamer to get audio data. */ #pragma once #include "config.h" #if HAVE_GST #include <string> #include <atomic> #include <thread> #include <vector> #include <cstddef> #include <cstdint> #include <gst/gst.h> #include "SampleQueue.h" #include "common.h" #include "InputInterface.h" #include "utils.h" struct GSTData { GSTData(SampleQueue<uint8_t>& samplequeue); // When using URL and uridecodebin GstElement *pipeline = nullptr; GstElement *uridecodebin = nullptr; GstElement *audio_convert = nullptr; GstElement *audio_resample = nullptr; GstElement *caps_filter = nullptr; GstElement *app_sink = nullptr; // When using pipeline GstElement *custom_bin = nullptr; GstBus *bus = nullptr; SampleQueue<uint8_t>& samplequeue; }; class GSTInput : public InputInterface { public: GSTInput(const std::string& uri, const std::string& pipeline, int rate, unsigned channels, SampleQueue<uint8_t>& queue); GSTInput(const GSTInput& other) = delete; GSTInput& operator=(const GSTInput& other) = delete; virtual ~GSTInput(); virtual void prepare() override; virtual bool read_source(size_t num_bytes) override; ICY_TEXT_t get_icy_text() const; int getRate() { return m_rate; } virtual bool fault_detected(void) const override { return m_fault; }; private: std::string m_uri; std::string m_pipeline; unsigned m_channels; int m_rate; GSTData m_gst_data; mutable std::mutex m_nowplaying_mutex; ICY_TEXT_t m_nowplaying; void process(); std::atomic<bool> m_fault = ATOMIC_VAR_INIT(false); std::atomic<bool> m_running; std::thread m_thread; }; #endif // HAVE_GST