00001 #ifndef GENERATOR_H_
00002 #define GENERATOR_H_
00003
00004 #include <arc/Thread.h>
00005 #include <arc/Logger.h>
00006
00007 #include "DTR.h"
00008
00009 namespace DataStaging {
00010
00012
00018 class Generator: public DTRCallback {
00019
00020 private:
00021
00023 static Arc::SimpleCondition cond;
00024
00025 std::list<DTR_ptr> dtrs;
00026
00028 static void shutdown(int sig);
00029
00031 static Arc::Logger logger;
00032
00033 public:
00034
00036
00042 virtual void receiveDTR(DTR_ptr dtr);
00043
00045 void run(const std::string& source, const std::string& destination);
00046 };
00047
00048 }
00049
00050 #endif