DataDeliveryComm.h

#ifndef DATA_DELIVERY_COMM_H_
#define DATA_DELIVERY_COMM_H_

#include "DTR.h"

namespace DataStaging {

  class DataDeliveryCommHandler;


  class DataDeliveryComm {

    friend class DataDeliveryCommHandler;

   public:
    enum CommStatusType {
      CommInit,    
      CommNoError, 
      CommTimeout, 
      CommClosed,  
      CommExited,  
      CommFailed   
    };
    #pragma pack(4)

    struct Status {
      CommStatusType commstatus;         
      time_t timestamp;                  
      DTRStatus::DTRStatusType status;   
      DTRErrorStatus::DTRErrorStatusType error; 
      DTRErrorStatus::DTRErrorLocation error_location; 
      char error_desc[1024];             
      unsigned int streams;              
      unsigned long long int transferred;
      unsigned long long int offset;     
      unsigned long long int size;       
      unsigned int speed;                
      char checksum[128];                
      unsigned long long int transfer_time; 
    };
    #pragma pack()

   protected:

    Status status_;
    Status status_buf_;
    unsigned int status_pos_;
    Glib::Mutex lock_;
    DataDeliveryCommHandler* handler_;
    TransferParameters transfer_params;
    Arc::Time start_;
    DTRLogger logger_;


    virtual void PullStatus() = 0;


    DataDeliveryComm(DTR_ptr dtr, const TransferParameters& params);

   public:
    static DataDeliveryComm* CreateInstance(DTR_ptr dtr, const TransferParameters& params);

    virtual ~DataDeliveryComm() {};

    Status GetStatus() const;


    static bool CheckComm(DTR_ptr dtr, std::vector<std::string>& allowed_dirs, std::string& load_avg);

    std::string GetError() const { return status_.error_desc; };

    virtual operator bool() const = 0;
    virtual bool operator!() const = 0;
  };


  class DataDeliveryCommHandler {

   private:
    Glib::Mutex lock_;
    static void func(void* arg);
    std::list<DataDeliveryComm*> items_;
    static DataDeliveryCommHandler* comm_handler;

    DataDeliveryCommHandler();
    DataDeliveryCommHandler(const DataDeliveryCommHandler&);
    DataDeliveryCommHandler& operator=(const DataDeliveryCommHandler&);

   public:
    ~DataDeliveryCommHandler() {};
    void Add(DataDeliveryComm* item);
    void Remove(DataDeliveryComm* item);
    static DataDeliveryCommHandler* getInstance();
  };

} // namespace DataStaging

#endif // DATA_DELIVERY_COMM_H_