pipeline.hpp

Go to the documentation of this file.

 
#ifndef __SERVER_PIPELINE_HPP_
#define __SERVER_PIPELINE_HPP_
 
#ifdef _WIN32
#if _MSC_VER > 1000
#pragma once
#endif
#endif  
 
#if defined(__unix__) && defined(__clang__)
#pragma once
#endif  
 
#include <workflow/WFGraphTask.h>
#include <workflow/WFTaskFactory.h>
 
#include "cbWebserver.hpp"
#include "cbRestfulHttpServer.hpp"
#include "task/cbComputeGraph.hpp"
#include "trivial/cbVirtualDevice.hpp"
 
namespace cb {
namespace pipeline {
 
class graphContainer {
 public:
  ~graphContainer();
  graphContainer(int32_t n);
  graphContainer(graphContainer&) = delete;
  graphContainer(const graphContainer&) = delete;
  graphContainer operator=(graphContainer&) = delete;
  graphContainer operator=(const graphContainer&) = delete;
 
  void addGraph(graph::cbComputeGraph* g);
 
  graph::cbComputeGraph* getGraph(int32_t idx);
 
  void execMain();
 
  void setTerminated(bool enable);
 
  size_t nums();
 
 private:
  bool m_isTerminated = false;
  std::vector<graph::cbComputeGraph*> m_graphs;
  int32_t m_loopTime = 10;  
};
 
struct appCfg {
  unsigned short webPort;
  const char* webRoot;
  unsigned short rHttpPort;
  int32_t graphExecSec;
  const char* redisHost;
  const char* redisPassword;
  const char* redisPort;
  int32_t redisDBNum = 1;
  bool redisSSL = false;
};
 
class app {
 public:
  app(const appCfg& cfg);
 
  void initRHttp();
 
  void execMain();
 
  void stopMain();
 
 private:
  graphContainer m_graphs;
  utils::cbWebserver m_web;
  utils::cbRestfulHttpServer m_rHttp;
  trivial::cbVirtualDeviceManager m_VDM;
};
 
}  // namespace pipeline
}  // namespace cb
 
#endif