multi_publisher.ipp

Go to the documentation of this file.

#ifndef adc_publisher_ipp
#define adc_publisher_ipp
 
#ifdef ADC_DEBUG_MULTI_PUBLISHER
#define multi_publisher_debug 1
#else
#define multi_publisher_debug 0
#endif
 
namespace adc {
 
 
class multi_publisher : public multi_publisher_api
{
public:
    enum state {
        ok,
        err
    };
private:
    const string vers;
        const std::vector<string> tags;
    enum state state;
    int debug;
    publisher_vector pvec;
 
public:
    multi_publisher() : vers("1.0.0") , tags({"none"}), state(ok), debug(multi_publisher_debug) {}
 
 
        string_view version() const {
                return vers;
        }
 
    void add(std::shared_ptr<publisher_api> p) {
        pvec.push_back(p);
    }
 
    int publish(std::shared_ptr<builder_api> b)
        {
        if (state != ok)
            return EBADFD;
        int err = 0;
        for (auto& element : pvec) {
            int e = element->publish(b);
            if (e) {
                err += 1;
                if (debug)
                    std::cout << "publish failed for plugin "
                            << element->name() << std::endl;
            }   
        }
        return err;
    }
 
    void terminate()
    {
        for (auto& element : pvec) {
            element->finalize();
        }
        pvec.clear();
    }
 
    void pause()
    {
        for (auto& element : pvec) {
            element->pause();
        }
    }
 
    void resume()
    {
        for (auto& element : pvec) {
            element->resume();
        }
    }
};  // class multi_publisher
 
} // namespace adc
#endif // adc_multi_publisher_ipp