iomanager_wrapper.hpp

Go to the documentation of this file.

 
#ifndef SNBMODULES_INCLUDE_SNBMODULES_IOMANAGER_WRAPPER_HPP_
#define SNBMODULES_INCLUDE_SNBMODULES_IOMANAGER_WRAPPER_HPP_
 
#include "snbmodules/common/notification_enum.hpp"
#include "snbmodules/ip_format.hpp"
 
#include "confmodel/NetworkConnection.hpp"
#include "confmodel/Queue.hpp"
#include "iomanager/IOManager.hpp"
#include "iomanager/network/ConfigClient.hpp"
#include "iomanager/network/NetworkIssues.hpp"
 
#include <string>
 
namespace dunedaq::snbmodules {
// Singleton
class IOManagerWrapper
{
 
public:
  static IOManagerWrapper& get()
  {
    static IOManagerWrapper instance;
    return instance;
  }
 
  // not cloneable
  IOManagerWrapper(IOManagerWrapper& other) = delete;
  // not assignable
  void operator=(const IOManagerWrapper&) = delete;

  // TEMP_REMOVED//void init_connection_interface(const std::string &session_name, bool use_connectivity_service =
  // false, const IPFormat &ip = IPFormat("localhost", 5000));

  iomanager::ConnectionResponse lookups_connection(const iomanager::ConnectionId& conn_id, bool restrict_single);

  // TEMP_REMOVED//void add_connection(const IPFormat &ip, std::string id, std::string data_type);
 
protected:
  std::vector<const confmodel::NetworkConnection*> m_connections;
  std::vector<const confmodel::Queue*> m_queues;
 
private:
  IOManagerWrapper() = default;
};
 
} // namespace dunedaq::snbmodules
 
#endif // SNBMODULES_INCLUDE_SNBMODULES_IOMANAGER_WRAPPER_HPP_