Cheetah - SKA - PSS - Prototype Time Domain Search Pipeline
GeneratorApp.cpp
1 /*
2  * The MIT License (MIT)
3  *
4  * Copyright (c) 2016 The SKA organisation
5  *
6  * Permission is hereby granted, free of charge, to any person obtaining a copy
7  * of this software and associated documentation files (the "Software"), to deal
8  * in the Software without restriction, including without limitation the rights
9  * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
10  * copies of the Software, and to permit persons to whom the Software is
11  * furnished to do so, subject to the following conditions:
12  *
13  * The above copyright notice and this permission notice shall be included in all
14  * copies or substantial portions of the Software.
15  *
16  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
17  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
18  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
19  * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
20  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
21  * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
22  * SOFTWARE.
23  */
24 #include "cheetah/generators/GeneratorApp.h"
25 #include "pss/astrotypes/units/ModifiedJulianClock.h"
26 
27 
28 namespace ska {
29 namespace cheetah {
30 namespace generators {
31 
32 
33 template<typename T>
34 GeneratorApp<T>::GeneratorApp(GeneratorAppConfig const& config, GeneratorFactory<T>& generator_factory)
35  : _data_ptr(std::make_shared<DataType>(data::DimensionSize<data::Time>(config.number_of_time_samples()), data::DimensionSize<data::Frequency>(config.number_of_channels())))
36  , _data(*_data_ptr)
37  , _iters(config.number_of_chunks())
38  , _writer(config.sigproc_config())
39 {
40  _data.set_channel_frequencies_const_width(config.start_frequency(), config.channel_width());
41  _data.sample_interval(config.sample_interval());
42  _data.start_time(pss::astrotypes::units::ModifiedJulianClock::now());
43  for(auto const& generator_name : config.data_generator()) {
44  _models.emplace_back(std::unique_ptr<DataGenerator>(generator_factory.create(generator_name)));
45  }
46 }
47 
48 template<typename T>
49 GeneratorApp<T>::~GeneratorApp()
50 {
51 }
52 
53 template<typename T>
54 void GeneratorApp<T>::exec()
55 {
56  std::size_t iter = _iters;
57  while(iter) {
58  for(auto& model : _models) {
59  model->next(_data);
60  }
61  _writer << _data;
62  _data.start_time(_data.end_time() + _data.sample_interval());
63  --iter;
64  }
65 }
66 
67 } // namespace generators
68 } // namespace cheetah
69 } // namespace ska
Some limits and constants for FLDO.
Definition: Brdz.h:35