DataDelivery.h

#ifndef DATA_DELIVERY_H_
#define DATA_DELIVERY_H_

#include <list>

#include <arc/Logger.h>
#include <arc/Thread.h>
#include "DTR.h"
#include "DTRList.h"
#include "DTRStatus.h"

namespace DataStaging {


  class DataDelivery: public DTRCallback {      

   private:

    Arc::SimpleCondition dtr_list_lock;

    class delivery_pair_t;
    std::list<delivery_pair_t*> dtr_list;

    TransferParameters transfer_params;

    static Arc::Logger logger;

    ProcessState delivery_state;

    Arc::SimpleCondition run_signal;

    Arc::SimpleCondition cond;

    static void start_delivery(void* arg);

    static void stop_delivery(void* arg);

    bool delete_delivery_pair(delivery_pair_t* dp);

    static void main_thread(void* arg);
    void main_thread(void);

    DataDelivery(const DataDelivery&);
    DataDelivery& operator=(const DataDelivery&);

   public:
      
    DataDelivery();
    ~DataDelivery() { stop(); };


    virtual void receiveDTR(DTR_ptr request);

    bool cancelDTR(DTR_ptr request);

    bool start();

    bool stop();

    void SetTransferParameters(const TransferParameters& params);

  };   
  
} // namespace DataStaging
#endif /*DATA_DELIVERY_H_*/