Skip to content
GitLab
Menu
Projects
Groups
Snippets
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
Menu
Open sidebar
dCache
cta
Commits
e0b5936d
Commit
e0b5936d
authored
Mar 02, 2020
by
Cedric CAFFY
Browse files
Used one mutex instead of 4 in RecallReportPacker
parent
5c78c81e
Changes
2
Hide whitespace changes
Inline
Side-by-side
tapeserver/castor/tape/tapeserver/daemon/RecallReportPacker.cpp
View file @
e0b5936d
...
...
@@ -396,22 +396,22 @@ void RecallReportPacker::fullCheckAndFinishAsyncExecute() {
//reportTapeDone()
//------------------------------------------------------------------------------
void
RecallReportPacker
::
setTapeDone
()
{
cta
::
threading
::
MutexLocker
mutexLocker
(
m_mutex
TapeDone
);
cta
::
threading
::
MutexLocker
mutexLocker
(
m_mutex
);
m_tapeThreadComplete
=
true
;
}
void
RecallReportPacker
::
setTapeComplete
(){
cta
::
threading
::
MutexLocker
mutexLocker
(
m_mutex
SetTapeComplete
);
cta
::
threading
::
MutexLocker
mutexLocker
(
m_mutex
);
m_retrieveMount
->
tapeComplete
();
}
void
RecallReportPacker
::
setDiskComplete
(){
cta
::
threading
::
MutexLocker
mutexLocker
(
m_mutex
SetDiskComplete
);
cta
::
threading
::
MutexLocker
mutexLocker
(
m_mutex
);
m_retrieveMount
->
diskComplete
();
}
bool
RecallReportPacker
::
isDiskDone
(){
cta
::
threading
::
MutexLocker
mutexLocker
(
m_mutex
DiskDone
);
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_mutex
DiskDone
);
cta
::
threading
::
MutexLocker
mutexLocker
(
m_mutex
);
m_diskThreadComplete
=
true
;
}
...
...
tapeserver/castor/tape/tapeserver/daemon/RecallReportPacker.hpp
View file @
e0b5936d
...
...
@@ -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.
...
...
Write
Preview
Supports
Markdown
0%
Try again
or
attach a new file
.
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment