Processor.h

#ifndef PROCESSOR_H_
#define PROCESSOR_H_

#include <arc/Logger.h>

#include "DTR.h"

namespace DataStaging {


  class Processor: public DTRCallback {

   private:

    Processor(const Processor&);
    Processor& operator=(const Processor&);

    class ThreadArgument {
     public:
      Processor* proc;
      DTR_ptr dtr;
      ThreadArgument(Processor* proc_, DTR_ptr dtr_):proc(proc_),dtr(dtr_) { };
    };

    class BulkThreadArgument {
     public:
      Processor* proc;
      std::list<DTR_ptr> dtrs;
      BulkThreadArgument(Processor* proc_, const std::list<DTR_ptr>& dtrs_):proc(proc_),dtrs(dtrs_) { };
    };

    Arc::SimpleCounter thread_count;

    std::list<DTR_ptr> bulk_list;

    static std::string hostname;

    /* Thread methods which deal with each state */
    static void DTRCheckCache(void* arg);
    static void DTRResolve(void* arg);
    static void DTRBulkResolve(void* arg);
    static void DTRQueryReplica(void* arg);
    static void DTRBulkQueryReplica(void* arg);
    static void DTRPreClean(void *arg);
    static void DTRStagePrepare(void* arg);
    static void DTRReleaseRequest(void* arg);
    static void DTRRegisterReplica(void* arg);
    static void DTRProcessCache(void* arg);

   public:

    Processor();
    ~Processor() { stop(); };


    void start(void);


    void stop(void);


    virtual void receiveDTR(DTR_ptr dtr);
  };


} // namespace DataStaging


#endif /* PROCESSOR_H_ */