diff --git a/objectstore/RetrieveToFileRequest.cpp b/objectstore/RetrieveToFileRequest.cpp index a11ca956e07b69818452f61a23e7be528ce7a451..0205ed4efe518a2ada656bf887b5397c248b5f8f 100644 --- a/objectstore/RetrieveToFileRequest.cpp +++ b/objectstore/RetrieveToFileRequest.cpp @@ -68,12 +68,19 @@ void cta::objectstore::RetrieveToFileRequest::setPriority(uint64_t priority) { m_payload.set_priority(priority); } -void cta::objectstore::RetrieveToFileRequest::setLog( +void cta::objectstore::RetrieveToFileRequest::setCreationLog( const objectstore::CreationLog& creationLog) { checkPayloadReadable(); creationLog.serialize(*m_payload.mutable_log()); } +auto cta::objectstore::RetrieveToFileRequest::getCreationLog() -> CreationLog { + checkPayloadReadable(); + CreationLog ret; + ret.deserialize(m_payload.log()); + return ret; +} + void cta::objectstore::RetrieveToFileRequest::setRetrieveToDirRequestAddress( const std::string& dirRequestAddress) { checkPayloadWritable(); diff --git a/objectstore/RetrieveToFileRequest.hpp b/objectstore/RetrieveToFileRequest.hpp index c2d95ce6bfb45c84331d82c536812890bb5a946d..0a10533215a63df17afafe313204b96168f27315 100644 --- a/objectstore/RetrieveToFileRequest.hpp +++ b/objectstore/RetrieveToFileRequest.hpp @@ -41,7 +41,8 @@ public: void setRemoteFile (const std::string & remoteFile); std::string getRemoteFile(); void setPriority (uint64_t priority); - void setLog (const objectstore::CreationLog& creationLog); + void setCreationLog (const objectstore::CreationLog& creationLog); + CreationLog getCreationLog(); void setRetrieveToDirRequestAddress(const std::string & dirRequestAddress); void setSize(uint64_t size); uint64_t getSize(); diff --git a/scheduler/OStoreDB/OStoreDB.cpp b/scheduler/OStoreDB/OStoreDB.cpp index 9c65e1b73d7f97363cfcfacada108d4ba8e49223..a482cc3ce4d69d3ce0ef4905e362f9021e8c4147 100644 --- a/scheduler/OStoreDB/OStoreDB.cpp +++ b/scheduler/OStoreDB/OStoreDB.cpp @@ -493,7 +493,7 @@ void OStoreDB::queue(const cta::RetrieveToFileRequest& rqst) { rtfr.setArchiveFile(rqst.getArchiveFile()); rtfr.setRemoteFile(rqst.getRemoteFile()); rtfr.setPriority(rqst.getPriority()); - rtfr.setLog(rqst.getCreationLog()); + rtfr.setCreationLog(rqst.getCreationLog()); // We will need to identity tapes is order to construct the request RootEntry re(m_objectStore); ScopedSharedLock rel(re);