datastreamer_base.h

Go to the documentation of this file.

/*
 * This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this
 * file, You can obtain one at https://mozilla.org/MPL/2.0/.
 */

#ifndef DATA_STREAMER_TEMPLATE_H
#define DATA_STREAMER_TEMPLATE_H

#include <mutex>
#include <unordered_set>
#include "PlotJuggler/plotdata.h"
#include "PlotJuggler/pj_plugin.h"
#include "PlotJuggler/messageparser_base.h"

namespace PJ
{
class DataStreamer : public PlotJugglerPlugin
{
  Q_OBJECT
public:
  DataStreamer() = default;

  virtual ~DataStreamer() = default;

  virtual bool start(QStringList* pre_selected_sources) = 0;

  virtual void shutdown() = 0;

  virtual bool isRunning() const = 0;

  virtual std::pair<QAction*, int> notificationAction()
  {
    return { nullptr, 0 };
  }

  std::mutex& mutex()
  {
    return _mutex;
  }

  void setMaximumRangeX(double range);

  PlotDataMapRef& dataMap()
  {
    return _data_map;
  }

  const PlotDataMapRef& dataMap() const
  {
    return _data_map;
  }

  void setParserFactories( ParserFactories* parsers);

  const ParserFactories* parserFactories() const;

signals:

  void clearBuffers();

  void removeGroup(std::string group_name);

  void dataReceived();

  void closed();

  // Plugin notifications.
  // PJ modifies the "notifications" button to indicate whether there are any
  void notificationsChanged(int active_notification_count);

private:

  std::mutex _mutex;
  PlotDataMapRef _data_map;
  QAction* _start_streamer;
  ParserFactories* _parser_factories = nullptr;
};

using DataStreamerPtr = std::shared_ptr<DataStreamer>;

}  // namespace PJ

QT_BEGIN_NAMESPACE
#define DataStream_iid "facontidavide.PlotJuggler3.DataStreamer"
Q_DECLARE_INTERFACE(PJ::DataStreamer, DataStream_iid)
QT_END_NAMESPACE

#endif