diff --git a/tapeserver/castor/tape/tapeserver/daemon/RecallReportPacker.cpp b/tapeserver/castor/tape/tapeserver/daemon/RecallReportPacker.cpp index 2207dcd0cdc335843375a83f14da9d41afd944f4..16fa55552ff2f9a32d05438603cfd858c8f4912f 100644 --- a/tapeserver/castor/tape/tapeserver/daemon/RecallReportPacker.cpp +++ b/tapeserver/castor/tape/tapeserver/daemon/RecallReportPacker.cpp @@ -396,22 +396,22 @@ void RecallReportPacker::fullCheckAndFinishAsyncExecute() { //reportTapeDone() //------------------------------------------------------------------------------ void RecallReportPacker::setTapeDone() { - cta::threading::MutexLocker mutexLocker(m_mutexTapeDone); + cta::threading::MutexLocker mutexLocker(m_mutex); m_tapeThreadComplete = true; } void RecallReportPacker::setTapeComplete(){ - cta::threading::MutexLocker mutexLocker(m_mutexSetTapeComplete); + cta::threading::MutexLocker mutexLocker(m_mutex); m_retrieveMount->tapeComplete(); } void RecallReportPacker::setDiskComplete(){ - cta::threading::MutexLocker mutexLocker(m_mutexSetDiskComplete); + cta::threading::MutexLocker mutexLocker(m_mutex); m_retrieveMount->diskComplete(); } bool RecallReportPacker::isDiskDone(){ - cta::threading::MutexLocker mutexLocker(m_mutexDiskDone); + cta::threading::MutexLocker mutexLocker(m_mutex); return m_diskThreadComplete; } @@ -419,7 +419,7 @@ bool RecallReportPacker::isDiskDone(){ //reportDiskDone() //------------------------------------------------------------------------------ void RecallReportPacker::setDiskDone() { - cta::threading::MutexLocker mutexLocker(m_mutexDiskDone); + cta::threading::MutexLocker mutexLocker(m_mutex); m_diskThreadComplete = true; } diff --git a/tapeserver/castor/tape/tapeserver/daemon/RecallReportPacker.hpp b/tapeserver/castor/tape/tapeserver/daemon/RecallReportPacker.hpp index 25b4e7686939a62dba184476ac39edebe103c422..0ec6868ac981f1fc8c5a6b70e7919d55a9842624 100644 --- a/tapeserver/castor/tape/tapeserver/daemon/RecallReportPacker.hpp +++ b/tapeserver/castor/tape/tapeserver/daemon/RecallReportPacker.hpp @@ -233,13 +233,7 @@ private: */ bool m_diskThreadComplete; - cta::threading::Mutex m_mutexSetTapeComplete; - - cta::threading::Mutex m_mutexSetDiskComplete; - - cta::threading::Mutex m_mutexDiskDone; - - cta::threading::Mutex m_mutexTapeDone; + cta::threading::Mutex m_mutex; /* * Proceed finish procedure for async execute for all reports.