Skip to content
Snippets Groups Projects
Commit b926def9 authored by Jan David Mol's avatar Jan David Mol
Browse files

TMSS-821: Move last_block to processingFeedback as it is only needed there

parent be2e9e27
No related branches found
No related tags found
1 merge request!639Cherry pick COBALT feedback changes
...@@ -44,9 +44,8 @@ namespace LOFAR ...@@ -44,9 +44,8 @@ namespace LOFAR
std::string LTAFeedback::feedback_version(boost::str(boost::format("%02d.%02d.%02d") % std::string LTAFeedback::feedback_version(boost::str(boost::format("%02d.%02d.%02d") %
major_version % minor_version % patch_number)); major_version % minor_version % patch_number));
LTAFeedback::LTAFeedback(const ObservationSettings &settings, ssize_t last_block): LTAFeedback::LTAFeedback(const ObservationSettings &settings):
settings(settings), settings(settings)
last_block(last_block)
{ {
} }
...@@ -235,7 +234,7 @@ namespace LOFAR ...@@ -235,7 +234,7 @@ namespace LOFAR
} }
ParameterSet LTAFeedback::processingFeedback() const ParameterSet LTAFeedback::processingFeedback(ssize_t last_block) const
{ {
ParameterSet ps; ParameterSet ps;
......
...@@ -33,8 +33,7 @@ namespace LOFAR ...@@ -33,8 +33,7 @@ namespace LOFAR
class LTAFeedback class LTAFeedback
{ {
public: public:
// Generate feedback for these parset settings, given that "last_block" was the last block processed. LTAFeedback(const ObservationSettings &settings);
LTAFeedback(const ObservationSettings &settings, ssize_t last_block);
// Subset name of each correlated and beamFormed file, respectively. // Subset name of each correlated and beamFormed file, respectively.
static std::string correlatedPrefix(size_t fileno); static std::string correlatedPrefix(size_t fileno);
...@@ -51,8 +50,10 @@ namespace LOFAR ...@@ -51,8 +50,10 @@ namespace LOFAR
// \note Details about the meaning of the different meta-data parameters // \note Details about the meaning of the different meta-data parameters
// can be found in the XSD that describes the Submission Information // can be found in the XSD that describes the Submission Information
// Package (sip) for the LTA. // Package (sip) for the LTA.
//
// "last_block" is the last block processed.
// \see http://proposal.astron.nl/schemas/LTA-SIP.xsd // \see http://proposal.astron.nl/schemas/LTA-SIP.xsd
ParameterSet processingFeedback() const; ParameterSet processingFeedback(ssize_t last_block) const;
// Return the LTA feedback parameters. // Return the LTA feedback parameters.
// \note Details about the meaning of the different meta-data parameters // \note Details about the meaning of the different meta-data parameters
......
...@@ -622,7 +622,7 @@ int main(int argc, char **argv) ...@@ -622,7 +622,7 @@ int main(int argc, char **argv)
// send processing feedback // send processing feedback
ToBus bus("otdb.task.feedback.processing", broker_feedback()); ToBus bus("otdb.task.feedback.processing", broker_feedback());
LTAFeedback fb(ps.settings, last_block); LTAFeedback fb(ps.settings);
Protocols::TaskFeedbackProcessing msg( Protocols::TaskFeedbackProcessing msg(
"Cobalt/GPUProc/rtcp", "Cobalt/GPUProc/rtcp",
...@@ -630,7 +630,7 @@ int main(int argc, char **argv) ...@@ -630,7 +630,7 @@ int main(int argc, char **argv)
"Processing feedback", "Processing feedback",
str(format("%s") % ps.settings.momID), str(format("%s") % ps.settings.momID),
str(format("%s") % ps.settings.observationID), str(format("%s") % ps.settings.observationID),
fb.processingFeedback()); fb.processingFeedback(last_block));
bus.send(msg); bus.send(msg);
......
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