CbmHistoServer.h

Go to the documentation of this file.

/********************************************************************************
 *    Copyright (C) 2014 GSI Helmholtzzentrum fuer Schwerionenforschung GmbH    *
 *                                                                              *
 *              This software is distributed under the terms of the             *
 *              GNU Lesser General Public Licence (LGPL) version 3,             *
 *                  copied verbatim in the file "LICENSE"                       *
 ********************************************************************************/
#ifndef FAIRMQEXHISTOSERVER
#define FAIRMQEXHISTOSERVER
 
#include "FairMQDevice.h"
 
#include "THttpServer.h"
#include "TObjArray.h"
 
#include <memory>
#include <string>
#include <thread>
 
//class FairMQExHistoCanvasDrawer;
 
class CbmHistoServer : public FairMQDevice {
public:
  CbmHistoServer();
 
 
  virtual ~CbmHistoServer();
 
  void UpdateHttpServer();
 
  /*
    void SetCanvasDrawer(std::unique_ptr<FairMQExHistoCanvasDrawer> canvasDrawer)
    {
        fCanvasDrawer = std::move(canvasDrawer);
    }
*/
 
protected:
  virtual void InitTask();
 
  bool ReceiveData(FairMQMessagePtr& msg, int index);
 
  virtual void PreRun();
 
  virtual void PostRun();
 
private:
  std::string fInputChannelName;
 
  TObjArray fArrayHisto;
 
  int fNMessages;
 
  THttpServer fServer;
 
  //    std::unique_ptr<FairMQExHistoCanvasDrawer> fCanvasDrawer;
 
  std::thread fThread;
  bool fStopThread;
 
  int FindHistogram(const std::string& name);
};
 
#endif