Skip to content
Snippets Groups Projects
Commit 33c25812 authored by Michael Davis's avatar Michael Davis
Browse files

[os-failedrequests] Terminate streams

parent 9f175254
Branches
Tags
No related merge requests found
......@@ -83,14 +83,15 @@ public:
// List failed archive requests
streambuf = new XrdSsiPb::OStreamBuffer<Data>(dlen);
//auto aqList = m_scheduler.getArchiveJobsFailedQueues(m_lc);
pushRecord(streambuf, admin::RequestType::ARCHIVE_REQUEST);
m_isArchive = false;
} else if(m_isRetrieve) {
// List failed retrieve requests
streambuf = new XrdSsiPb::OStreamBuffer<Data>(dlen);
pushRecord(streambuf, admin::RequestType::RETRIEVE_REQUEST);
/*
Take a look at OStoreDB::getNextRetrieveJobsFailedBatch()
......@@ -101,6 +102,7 @@ public:
5. when all queues are done and all jobs are done, set m_isRetrieve to false
*/
m_isRetrieve = false;
} else {
// Nothing more to send, close the stream
last = true;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment