transfer_interface_abstract.hpp

Go to the documentation of this file.

 
#ifndef SNBMODULES_INCLUDE_SNBMODULES_INTERFACES_TRANSFER_INTERFACE_ABSTRACT_HPP_
#define SNBMODULES_INCLUDE_SNBMODULES_INTERFACES_TRANSFER_INTERFACE_ABSTRACT_HPP_
 
#include "appfwk/cmd/Nljs.hpp"
#include "snbmodules/group_metadata.hpp"
#include "snbmodules/ip_format.hpp"
#include "snbmodules/transfer_metadata.hpp"
 
// errors handling
#include "logging/Logging.hpp"
#include "snbmodules/common/errors_declaration.hpp"
 
#include <iostream>
#include <set>
 
namespace dunedaq::snbmodules {
class TransferInterfaceAbstract
{
 
public:
  explicit TransferInterfaceAbstract(GroupMetadata& config)
    : m_config(config)
  {
  }
  virtual ~TransferInterfaceAbstract() = default;
 
  GroupMetadata& get_transfer_options() { return m_config; }
 
  virtual bool upload_file(TransferMetadata& f_meta) = 0;
  virtual bool download_file(TransferMetadata& f_meta, std::filesystem::path dest) = 0;
  virtual bool pause_file(TransferMetadata& f_meta) = 0;
  virtual bool resume_file(TransferMetadata& f_meta) = 0;
  virtual bool hash_file(TransferMetadata& f_meta) = 0;
  virtual bool cancel_file(TransferMetadata& f_meta) = 0;
 
protected:
  GroupMetadata& m_config;
};

class TransferInterfaceDummy : public TransferInterfaceAbstract
{
 
public:
  explicit TransferInterfaceDummy(GroupMetadata& config)
    : TransferInterfaceAbstract(config)
  {
  }
 
  bool upload_file(TransferMetadata& f_meta) override
  {
    TLOG() << "Upload file " << f_meta.get_file_name();
    return true;
  }
  bool download_file(TransferMetadata& f_meta, std::filesystem::path dest) override
  {
    (void)dest;
    TLOG() << "Download file " << f_meta.get_file_name();
    return true;
  }
  bool pause_file(TransferMetadata& f_meta) override
  {
    TLOG() << "Pause file " << f_meta.get_file_name();
    return true;
  }
  bool resume_file(TransferMetadata& f_meta) override
  {
    TLOG() << "Resume file " << f_meta.get_file_name();
    return true;
  }
  bool cancel_file(TransferMetadata& f_meta) override
  {
    TLOG() << "Cancel file " << f_meta.get_file_name();
    return true;
  }
  bool hash_file(TransferMetadata& f_meta) override
  {
    TLOG() << "Hash file " << f_meta.get_file_name();
    return true;
  }
};
} // namespace dunedaq::snbmodules
#endif // SNBMODULES_INCLUDE_SNBMODULES_INTERFACES_TRANSFER_INTERFACE_ABSTRACT_HPP_