Skip to content
Snippets Groups Projects
Commit 34a64555 authored by Eric Cano's avatar Eric Cano
Browse files

Added log and timing to deletion of retrieve requests.

parent 1713e731
No related branches found
No related tags found
No related merge requests found
......@@ -2644,6 +2644,7 @@ OStoreDB::RetrieveJob::~RetrieveJob() {
//------------------------------------------------------------------------------
void OStoreDB::RetrieveJob::succeed() {
// Lock the request and set the request as successful (delete it).
utils::Timer t;
objectstore::ScopedExclusiveLock rtfrl(m_retrieveRequest);
m_retrieveRequest.fetch();
std::string rtfrAddress = m_retrieveRequest.getAddressIfSet();
......@@ -2651,6 +2652,11 @@ void OStoreDB::RetrieveJob::succeed() {
m_jobOwned = false;
// Remove ownership form the agent
m_agentReference.removeFromOwnership(rtfrAddress, m_objectStore);
log::LogContext lc(m_logger);
log::ScopedParamContainer params(lc);
params.add("requestObject", rtfrAddress)
.add("schedulerDbTime", t.secs());
lc.log(log::INFO, "In RetrieveJob::succeed(): deleted completed retrieve request.");
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment