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