diff --git a/scheduler/ArchiveMount.cpp b/scheduler/ArchiveMount.cpp
index 3288c31a402abba8cce4dece13fd2956b078e227..bfe1bffddeb7451c484d3a58aa98d1a5b4bcfeaf 100644
--- a/scheduler/ArchiveMount.cpp
+++ b/scheduler/ArchiveMount.cpp
@@ -59,6 +59,13 @@ std::string cta::ArchiveMount::getPoolName() const {
return m_dbMount->mountInfo.tapePool;
}
+//------------------------------------------------------------------------------
+// getNbFiles
+//------------------------------------------------------------------------------
+uint32_t cta::ArchiveMount::getNbFiles() const {
+ return m_dbMount->nbFilesCurrentlyOnTape;
+}
+
//------------------------------------------------------------------------------
// getMountTransactionId
//------------------------------------------------------------------------------
diff --git a/scheduler/ArchiveMount.hpp b/scheduler/ArchiveMount.hpp
index 478866cdecb3cad44a9812c2a4c1ba48407c4dae..dc4003b2b2d631d7e5ae4fb1f68068901f00a2e4 100644
--- a/scheduler/ArchiveMount.hpp
+++ b/scheduler/ArchiveMount.hpp
@@ -101,6 +101,13 @@ namespace cta {
*/
virtual std::string getPoolName() const;
+ /**
+ * Returns the mount transaction id.
+ *
+ * @return The mount transaction id.
+ */
+ virtual uint32_t getNbFiles() const;
+
/**
* Destructor.
*/
diff --git a/scheduler/OStoreDB/OStoreDB.cpp b/scheduler/OStoreDB/OStoreDB.cpp
index 31114f7985278a8884606ba5ba669412cb315982..aeb586b7053be40fdfb98f4db825ff235f20e8e6 100644
--- a/scheduler/OStoreDB/OStoreDB.cpp
+++ b/scheduler/OStoreDB/OStoreDB.cpp
@@ -1203,7 +1203,7 @@ std::unique_ptr<SchedulerDatabase::ArchiveMount>
m_agent.addToOwnership(t.getAddressIfSet());
m_agent.commit();
}
- am.m_nextFseq = t.getLastFseq() + 1;
+ am.nbFilesCurrentlyOnTape = t.getLastFseq();
am.mountInfo.vid = t.getVid();
t.setBusy(driveName, objectstore::Tape::MountType::Archive, hostName, startTime,
m_agent.getAddressIfSet());
@@ -1416,7 +1416,7 @@ auto OStoreDB::ArchiveMount::getNextJob() -> std::unique_ptr<SchedulerDatabase::
tp.commit();
privateRet->archiveFile = privateRet->m_atfr.getArchiveFile();
privateRet->remoteFile = privateRet->m_atfr.getRemoteFile();
- privateRet->nameServerTapeFile.tapeFileLocation.fSeq = m_nextFseq++;
+ privateRet->nameServerTapeFile.tapeFileLocation.fSeq = ++nbFilesCurrentlyOnTape;
privateRet->nameServerTapeFile.tapeFileLocation.copyNb = privateRet->m_copyNb;
privateRet->nameServerTapeFile.tapeFileLocation.vid = mountInfo.vid;
privateRet->nameServerTapeFile.tapeFileLocation.blockId =
diff --git a/scheduler/OStoreDB/OStoreDB.hpp b/scheduler/OStoreDB/OStoreDB.hpp
index 7350a8d0f2b95b4a0b8ccb88e415cf550f82eb42..d10f5be2396dbe18b87ad3896f73a7920c7e64fe 100644
--- a/scheduler/OStoreDB/OStoreDB.hpp
+++ b/scheduler/OStoreDB/OStoreDB.hpp
@@ -80,7 +80,6 @@ public:
ArchiveMount(objectstore::Backend &, objectstore::Agent &);
objectstore::Backend & m_objectStore;
objectstore::Agent & m_agent;
- uint64_t m_nextFseq;
public:
virtual const MountInfo & getMountInfo();
virtual std::unique_ptr<ArchiveJob> getNextJob();
diff --git a/scheduler/RetrieveMount.cpp b/scheduler/RetrieveMount.cpp
index ee5de6392bd4e6ca3a7f491324108fca8bba4f0b..524a9d94da09e51b66f1c66c3529b9fc614d1b67 100644
--- a/scheduler/RetrieveMount.cpp
+++ b/scheduler/RetrieveMount.cpp
@@ -40,6 +40,13 @@ cta::MountType::Enum cta::RetrieveMount::getMountType() const{
return MountType::RETRIEVE;
}
+//------------------------------------------------------------------------------
+// getNbFiles
+//------------------------------------------------------------------------------
+uint32_t cta::RetrieveMount::getNbFiles() const {
+ return m_dbMount->nbFilesCurrentlyOnTape;
+}
+
//------------------------------------------------------------------------------
// getVid
//------------------------------------------------------------------------------
diff --git a/scheduler/RetrieveMount.hpp b/scheduler/RetrieveMount.hpp
index 1bbedfcfc6bec73f96228ce9f078b4017bbb7977..e44dc2d52bf69a00b52ec3619a9e80689ab70d41 100644
--- a/scheduler/RetrieveMount.hpp
+++ b/scheduler/RetrieveMount.hpp
@@ -73,6 +73,13 @@ namespace cta {
* @return The mount transaction id.
*/
virtual std::string getMountTransactionId() const;
+
+ /**
+ * Returns the mount transaction id.
+ *
+ * @return The mount transaction id.
+ */
+ virtual uint32_t getNbFiles() const;
/**
* Indicates that the mount was completed.
diff --git a/scheduler/SchedulerDatabase.hpp b/scheduler/SchedulerDatabase.hpp
index 069c59362ba07853ffb55fe6536c50f0731802db..a578bed12dee2fa13ed6828c5acce31143e9016b 100644
--- a/scheduler/SchedulerDatabase.hpp
+++ b/scheduler/SchedulerDatabase.hpp
@@ -172,6 +172,7 @@ public:
virtual std::unique_ptr<ArchiveJob> getNextJob() = 0;
virtual void complete(time_t completionTime) = 0;
virtual ~ArchiveMount() {}
+ uint32_t nbFilesCurrentlyOnTape;
};
/**
@@ -250,6 +251,7 @@ public:
virtual std::unique_ptr<RetrieveJob> getNextJob() = 0;
virtual void complete(time_t completionTime) = 0;
virtual ~RetrieveMount() {}
+ uint32_t nbFilesCurrentlyOnTape;
};
class RetrieveJob {
diff --git a/scheduler/TapeMount.hpp b/scheduler/TapeMount.hpp
index d1c11a832db89c938d0879dbad3ac44356d76629..ddcc303fe4fc011a8732170b2553b23733f62961 100644
--- a/scheduler/TapeMount.hpp
+++ b/scheduler/TapeMount.hpp
@@ -49,7 +49,14 @@ namespace cta {
*
* @return The mount transaction id.
*/
- virtual std::string getMountTransactionId() const = 0;
+ virtual std::string getMountTransactionId() const = 0;
+
+ /**
+ * Returns the mount transaction id.
+ *
+ * @return The mount transaction id.
+ */
+ virtual uint32_t getNbFiles() const = 0;
/**
* Indicates that the mount was completed.
diff --git a/tapeserver/castor/messages/ArchiveJobFromCTA.proto b/tapeserver/castor/messages/ArchiveJobFromCTA.proto
index 46a07569a29f5cd3400ee11e1df3c2ed9d3a8ee1..638ec75a4944375c876293b944904c27763534c2 100644
--- a/tapeserver/castor/messages/ArchiveJobFromCTA.proto
+++ b/tapeserver/castor/messages/ArchiveJobFromCTA.proto
@@ -20,4 +20,5 @@ package castor.messages;
message ArchiveJobFromCTA {
required string vid = 1;
required string unitname = 2;
+ required uint32 nbfiles = 3;
}
diff --git a/tapeserver/castor/messages/TapeserverProxy.hpp b/tapeserver/castor/messages/TapeserverProxy.hpp
index d815f2cb7d6a38214f07fc48fc58dcf8ecc3461c..34840131841a55f919855b618c4321c896bdd0a9 100644
--- a/tapeserver/castor/messages/TapeserverProxy.hpp
+++ b/tapeserver/castor/messages/TapeserverProxy.hpp
@@ -84,7 +84,7 @@ public:
* @return The number of files currently stored on the tape
*/
virtual uint32_t gotArchiveJobFromCTA(const std::string &vid,
- const std::string &unitName) = 0;
+ const std::string &unitName, const uint32_t nbFiles) = 0;
/**
* Notifies the tapeserverd daemon that the mount-session child-process got
diff --git a/tapeserver/castor/messages/TapeserverProxyDummy.cpp b/tapeserver/castor/messages/TapeserverProxyDummy.cpp
index feea71b47e45dc255dd62b9f5346de1d3c806736..c632fa86a7c1cde3d616a85c15b2c336093b245f 100644
--- a/tapeserver/castor/messages/TapeserverProxyDummy.cpp
+++ b/tapeserver/castor/messages/TapeserverProxyDummy.cpp
@@ -25,7 +25,7 @@
// gotArchiveJobFromCTA
//------------------------------------------------------------------------------
uint32_t castor::messages::TapeserverProxyDummy::gotArchiveJobFromCTA(
- const std::string &vid, const std::string &unitName) {
+ const std::string &vid, const std::string &unitName, const uint32_t nbFiles) {
return 0;
}
diff --git a/tapeserver/castor/messages/TapeserverProxyDummy.hpp b/tapeserver/castor/messages/TapeserverProxyDummy.hpp
index c02aa3e067b2de36b2143575abc7781ca8a8e12f..d9dfff95aa9df340bcdc568745953877de26ec86 100644
--- a/tapeserver/castor/messages/TapeserverProxyDummy.hpp
+++ b/tapeserver/castor/messages/TapeserverProxyDummy.hpp
@@ -41,7 +41,7 @@ public:
* @return The number of files currently stored on the tape
*/
virtual uint32_t gotArchiveJobFromCTA(const std::string &vid,
- const std::string &unitName);
+ const std::string &unitName, const uint32_t nbFiles);
/**
* Notifies the tapeserverd daemon that the mount-session child-process got
diff --git a/tapeserver/castor/messages/TapeserverProxyZmq.cpp b/tapeserver/castor/messages/TapeserverProxyZmq.cpp
index 4088b8e5498fdf26191af2b3e0806351acc2aa54..442edea96eb1e01ef2e75564ba36417564705815 100644
--- a/tapeserver/castor/messages/TapeserverProxyZmq.cpp
+++ b/tapeserver/castor/messages/TapeserverProxyZmq.cpp
@@ -56,11 +56,11 @@ castor::messages::TapeserverProxyZmq::TapeserverProxyZmq(log::Logger &log,
// gotArchiveJobFromCTA
//------------------------------------------------------------------------------
uint32_t castor::messages::TapeserverProxyZmq::gotArchiveJobFromCTA(
- const std::string &vid, const std::string &unitName) {
+ const std::string &vid, const std::string &unitName, const uint32_t nbFiles) {
MutexLocker lock(&m_mutex);
try {
- const Frame rqst = createArchiveJobFromCTAFrame(vid, unitName);
+ const Frame rqst = createArchiveJobFromCTAFrame(vid, unitName, nbFiles);
sendFrame(m_serverSocket, rqst);
NbFilesOnTape reply;
@@ -303,7 +303,7 @@ castor::messages::Frame castor::messages::TapeserverProxyZmq::
//------------------------------------------------------------------------------
castor::messages::Frame castor::messages::TapeserverProxyZmq::
createArchiveJobFromCTAFrame(const std::string &vid,
- const std::string &unitName) {
+ const std::string &unitName, const uint32_t nbFiles) {
try {
Frame frame;
@@ -314,6 +314,7 @@ castor::messages::Frame castor::messages::TapeserverProxyZmq::
ArchiveJobFromCTA body;
body.set_vid(vid);
body.set_unitname(unitName);
+ body.set_nbfiles(nbFiles);
frame.serializeProtocolBufferIntoBody(body);
return frame;
diff --git a/tapeserver/castor/messages/TapeserverProxyZmq.hpp b/tapeserver/castor/messages/TapeserverProxyZmq.hpp
index 711aea00f23097572996d2f136058575b49868f2..b681ffff62705db785a31a07192659a358c3236b 100644
--- a/tapeserver/castor/messages/TapeserverProxyZmq.hpp
+++ b/tapeserver/castor/messages/TapeserverProxyZmq.hpp
@@ -57,7 +57,7 @@ public:
* @return The number of files currently stored on the tape
*/
virtual uint32_t gotArchiveJobFromCTA(const std::string &vid,
- const std::string &unitName);
+ const std::string &unitName, const uint32_t nbFiles);
/**
* Notifies the tapeserverd daemon that the mount-session child-process got
@@ -219,7 +219,7 @@ private:
* @return The frame.
*/
Frame createArchiveJobFromCTAFrame(const std::string &vid,
- const std::string &unitName);
+ const std::string &unitName, const uint32_t nbFiles);
/**
* Creates a frame containing a RetrieveJobFromCTA message.
diff --git a/tapeserver/castor/tape/tapeserver/daemon/DataTransferSession.cpp b/tapeserver/castor/tape/tapeserver/daemon/DataTransferSession.cpp
index 8a22c5ea6f47fcf58c82e4d62445118b1e33553c..503f01127f1abf4f6a731581e5057ae4ea2a9777 100644
--- a/tapeserver/castor/tape/tapeserver/daemon/DataTransferSession.cpp
+++ b/tapeserver/castor/tape/tapeserver/daemon/DataTransferSession.cpp
@@ -101,6 +101,7 @@ castor::tape::tapeserver::daemon::Session::EndOfSessionAction
return MARK_DRIVE_AS_UP;
m_volInfo.vid=tapeMount->getVid();
m_volInfo.mountType=tapeMount->getMountType();
+ m_volInfo.nbFiles=tapeMount->getNbFiles();
// 2b) ... and log.
// Make the DGN and TPVID parameter permanent.
log::ScopedParamContainer params(lc);
@@ -290,8 +291,9 @@ castor::tape::tapeserver::daemon::Session::EndOfSessionAction
//theses 2 numbers should match. Otherwise, it means the stager went mad
if(firstFseqFromClient != nbOfFileOnTape + 1) {
- lc.log(LOG_ERR, "First file to write's fseq and number of files on "
- "the tape according to the VMGR dont match");
+ std::stringstream ss;
+ ss << "First file to write's fseq(" << firstFseqFromClient << ") and number of files on the tape (" << nbOfFileOnTape << " + 1) dont match";
+ lc.log(LOG_ERR, ss.str());
//no mount at all, drive to be kept up = return 0
return MARK_DRIVE_AS_UP;
}
diff --git a/tapeserver/castor/tape/tapeserver/daemon/TapeMessageHandler.cpp b/tapeserver/castor/tape/tapeserver/daemon/TapeMessageHandler.cpp
index 371a2616198646bd4c0f0092d88a6ed9fef183eb..fd343a459ea2eff898d1c2b5528e163c81704823 100644
--- a/tapeserver/castor/tape/tapeserver/daemon/TapeMessageHandler.cpp
+++ b/tapeserver/castor/tape/tapeserver/daemon/TapeMessageHandler.cpp
@@ -337,19 +337,10 @@ castor::messages::Frame castor::tape::tapeserver::daemon::TapeMessageHandler::
castor::messages::ArchiveJobFromCTA rqstBody;
rqst.parseBodyIntoProtocolBuffer(rqstBody);
- CatalogueDrive &drive =
- m_driveCatalogue.findDrive(rqstBody.unitname());
+ CatalogueDrive &drive = m_driveCatalogue.findDrive(rqstBody.unitname());
drive.getTransferSession().receivedMigrationJob(rqstBody.vid());
-
- {
- std::ostringstream msg;
- msg << __FUNCTION__ << ": Not fully implemented because the number of"
- " files on tape is not known because there is no vmgr in the CTA"
- " project";
- throw castor::exception::Exception(msg.str());
- }
- //messages::Frame reply = createNbFilesOnTapeFrame(tapeInfo.nbFiles);
- //return reply;
+ messages::Frame reply = createNbFilesOnTapeFrame(rqstBody.nbfiles());
+ return reply;
} catch(castor::exception::Exception &ne) {
castor::exception::Exception ex;
ex.getMessage() <<
diff --git a/tapeserver/castor/tape/tapeserver/daemon/TapeServerReporter.cpp b/tapeserver/castor/tape/tapeserver/daemon/TapeServerReporter.cpp
index 9795e267c0e9d3c87dae86e3ebbb81fa4c0e802a..769fb9b39e9e6d3be1e5e6370e1f4535d430f96d 100644
--- a/tapeserver/castor/tape/tapeserver/daemon/TapeServerReporter.cpp
+++ b/tapeserver/castor/tape/tapeserver/daemon/TapeServerReporter.cpp
@@ -96,7 +96,7 @@ TapeServerReporter::TapeServerReporter(
m_lc.log(LOG_ERR,"TapeServerReporter is running but calling a synchronous operation on it"
"Could cause a race with the underlying zmq sockets in the proxy");
}
- return m_tapeserverProxy.gotArchiveJobFromCTA(m_volume.vid, m_unitName);
+ return m_tapeserverProxy.gotArchiveJobFromCTA(m_volume.vid, m_unitName, m_volume.nbFiles);
}
//------------------------------------------------------------------------------
//gotReadMountDetailsFromClient
diff --git a/tapeserver/castor/tape/tapeserver/daemon/VolumeInfo.hpp b/tapeserver/castor/tape/tapeserver/daemon/VolumeInfo.hpp
index 82628a84d0db40e9c7fed3c62e16606ae9b85c86..f87e6aeacd7c456f9b8fb33dfe34592bc058cf03 100644
--- a/tapeserver/castor/tape/tapeserver/daemon/VolumeInfo.hpp
+++ b/tapeserver/castor/tape/tapeserver/daemon/VolumeInfo.hpp
@@ -43,6 +43,8 @@ namespace daemon {
std::string vid;
/** The mount type: archive or retrieve */
cta::MountType::Enum mountType;
+ /** The number of files currently on tape*/
+ uint32_t nbFiles;
};
} // namespace daemon