First attempt of test for DiskkWriteThreadPool

castor/tape/tapeserver/daemon/DiskWriteThreadPoolTest.cpp

+#include "castor/tape/tapeserver/daemon/DiskWriteThreadPool.hpp"
+#include "castor/tape/tapeserver/daemon/RecallTaskInjector.hpp"
+#include "castor/tape/tapeserver/daemon/RecallReportPacker.hpp"
+#include "castor/tape/tapegateway/FileToRecallStruct.hpp"
+#include "castor/tape/tapeserver/daemon/ReportPackerInterface.hpp"
+#include "castor/tape/tapeserver/client/ClientInterface.hpp"
+#include "castor/tape/tapeserver/client/FakeClient.hpp"
+#include "castor/tape/tapeserver/client/ClientInterface.hpp"
+#include "castor/log/LogContext.hpp"
+#include "castor/log/StringLogger.hpp"
+#include "castor/tape/tapeserver/daemon/MemManager.hpp"
+#include <gtest/gtest.h>
+
+namespace unitTests{
+  using namespace castor::tape::tapeserver;
+  struct MockRecallReportPacker : public daemon::ReportPackerInterface<daemon::detail::Recall>{
+    MOCK_METHOD1(reportCompletedJob,void(const FileStruct&));
+    MOCK_METHOD3(reportFailedJob, void(const FileStruct& ,const std::string&,int));
+    MOCK_METHOD0(reportEndOfSession, void());
+    MOCK_METHOD2(reportEndOfSessionWithErrors, void(const std::string,int));
+    MockRecallReportPacker(client::ClientInterface& client,castor::log::LogContext lc):
+    daemon::ReportPackerInterface<daemon::detail::Recall>(client,lc){}
+  };
+  
+  struct MockTaskInjector : public daemon::TaskInjector{
+    MOCK_METHOD3(requestInjection, void(int maxFiles, int maxBlocks, bool lastCall));
+  };
+  
+  TEST(castor_tape_tapeserver_daemon, DiskWriteThreadPoolTest){
+    using ::testing::_;
+    MockTaskInjector tskInjectorl;
+    MockClient client;
+    castor::log::StringLogger log("castor_tape_tapeserver_daemon_DiskWriteThreadPoolTest");
+    castor::log::LogContext lc(log);
+    
+    MockRecallReportPacker report(client,lc);
+    EXPECT_CALL(report,reportCompletedJob(_)).Times(5);
+    //EXPECT_CALL(tskInjectorl,requestInjection(_,_,_)).Times(2);
+    EXPECT_CALL(report,reportEndOfSession()).Times(1);     
+    
+    daemon::MemoryManager mm(10,100);
+//    mm.startThreads();
+    
+    daemon::DiskWriteThreadPool dwtp(2,5,500,report,lc);
+    dwtp.setJobInjector(&tskInjectorl);
+    dwtp.startThreads();
+    
+    tapegateway::FileToRecallStruct file;
+    file.setPath("/dev/null");
+    file.setBlockId3(1);
+       
+     for(int i=0;i<5;++i){
+
+       daemon::DiskWriteTask* t=new daemon::DiskWriteTask(dynamic_cast<tapegateway::FileToRecallStruct*>(file.clone()),mm);
+       daemon::MemBlock* mb=mm.getFreeBlock();
+       mb->m_fileid=0;
+       mb->m_fileBlock=0;
+       t->pushDataBlock(mb);
+       t->pushDataBlock(NULL);
+       dwtp.push(t);
+     }
+     
+    dwtp.finish();
+    dwtp.waitThreads(); 
+//    mm.waitThreads();
+  }
+}
+

test/CMakeLists.txt

@@ -104,6 +104,7 @@ add_executable(castorUnitTests
   ../castor/tape/tapeserver/daemon/RecallTaskInjectorTest.cpp
   ../castor/tape/tapeserver/daemon/MigrationReportPackerTest.cpp
   ../castor/tape/tapeserver/daemon/RecallReportPackerTest.cpp
+  ../castor/tape/tapeserver/daemon/DiskWriteThreadPoolTest.cpp
   ../castor/tape/tapeserver/drive/DriveTest.cpp
   ../castor/tape/tapeserver/exception/ExceptionTest.cpp
   ../castor/tape/tapeserver/file/StructuresTest.cpp