casa
5.7.0-16
|
#include <DataAccumulator.h>
Classes | |
struct | DataAccumulatorKey |
Public Member Functions | |
DataAccumulator () | |
virtual | ~DataAccumulator () |
size_t | getNumberOfChunks () const |
size_t | getNumberOfActiveChunks () const |
bool | queryForGet (DataRecord const &record) const |
bool | queryForGet (casacore::Double const &time) const |
void | clear () |
bool | get (size_t ichunk, MSDataRecord &record) |
bool | accumulate (DataRecord const &record) |
casacore::String | getPolType (size_t ichunk) const |
casacore::uInt | getNumPol (size_t ichunk) const |
Private Member Functions | |
bool | isValidRecord (DataRecord const &record) |
Private Attributes | |
std::vector< DataChunk * > | pool_ |
std::vector< casacore::Int > | antenna_id_ |
std::vector< casacore::Int > | spw_id_ |
std::vector< casacore::Int > | field_id_ |
std::vector< casacore::Int > | feed_id_ |
std::vector< casacore::Int > | scan_ |
std::vector< casacore::Int > | subscan_ |
std::vector< casacore::String > | intent_ |
std::vector< casacore::Matrix < casacore::Double > > | direction_ |
std::vector< casacore::Double > | interval_ |
std::vector< casacore::Float > | temperature_ |
std::vector< casacore::Float > | pressure_ |
std::vector< casacore::Float > | rel_humidity_ |
std::vector< casacore::Float > | wind_speed_ |
std::vector< casacore::Float > | wind_direction_ |
std::map< DataAccumulatorKey, casacore::uInt, DataAccumulatorKey > | indexer_ |
casacore::Double | time_ |
std::vector< bool > | is_free_ |
Definition at line 785 of file DataAccumulator.h.
|
inline |
Definition at line 819 of file DataAccumulator.h.
|
inlinevirtual |
Definition at line 824 of file DataAccumulator.h.
References POST_END, and POST_START.
|
inline |
std::cout << "record is not a valid one" << std::endl;
std::cout << "timestamp mismatch" << std::endl;
std::cout << "(ant, spw, pol, pol_type, field, feed, intent) = (" << key.antenna_id << ", " << key.spw_id << ", " << record.pol<< ", " << key.pol_type << ", " << key.field_id << ", " << key.feed_id << ", " << key.intent << ", " << std::endl;
std::cout << "status = " << status << std::endl; std::cout << "key (a" << key.antenna_id << ",f" << key.field_id << ",s" << key.spw_id << ",i" << key.intent << ",p" << key.pol_type << ",d" << key.feed_id << "(index " << indexer_[key] << "): TIME=" << time_ << " INTERVAL=" << interval << " polno=" << record.pol << std::endl;
Definition at line 898 of file DataAccumulator.h.
References casa::sdfiller::DataRecord::antenna_id, casa::sdfiller::DataAccumulator::DataAccumulatorKey::antenna_id, casacore::String::assign(), casa::sdfiller::DataRecord::direction, casa::sdfiller::DataRecord::feed_id, casa::sdfiller::DataAccumulator::DataAccumulatorKey::feed_id, casa::sdfiller::DataRecord::field_id, casa::sdfiller::DataAccumulator::DataAccumulatorKey::field_id, casa::sdfiller::DataRecord::intent, casa::sdfiller::DataAccumulator::DataAccumulatorKey::intent, casa::sdfiller::DataRecord::interval, casa::isValidRecord(), casa::sdfiller::DataRecord::pol_type, casa::sdfiller::DataAccumulator::DataAccumulatorKey::pol_type, POST_END, POST_START, casa::sdfiller::DataRecord::pressure, casa::sdfiller::DataRecord::rel_humidity, casa::sdfiller::DataRecord::scan, casacore::String::size(), casa::sdfiller::DataRecord::spw_id, casa::sdfiller::DataAccumulator::DataAccumulatorKey::spw_id, casa::sdfiller::DataRecord::subscan, casa::sdfiller::DataRecord::temperature, casa::time, casa::sdfiller::DataRecord::time, casa::sdfiller::DataRecord::wind_direction, and casa::sdfiller::DataRecord::wind_speed.
|
inline |
Definition at line 856 of file DataAccumulator.h.
|
inline |
std::cout << "get Chunk status = " << status << std::endl;
Definition at line 863 of file DataAccumulator.h.
References casa::sdfiller::MSDataRecord::antenna_id, casa::sdfiller::MSDataRecord::clear(), casa::sdfiller::MSDataRecord::direction, casa::sdfiller::MSDataRecord::feed_id, casa::sdfiller::MSDataRecord::field_id, casa::sdfiller::MSDataRecord::intent, casa::sdfiller::MSDataRecord::interval, casa::sdfiller::MSDataRecord::pol_type, POST_END, POST_START, casa::sdfiller::MSDataRecord::pressure, casa::sdfiller::MSDataRecord::rel_humidity, casa::sdfiller::MSDataRecord::scan, casa::sdfiller::MSDataRecord::spw_id, casa::sdfiller::MSDataRecord::subscan, casa::sdfiller::MSDataRecord::temperature, casa::sdfiller::MSDataRecord::time, casa::sdfiller::MSDataRecord::wind_direction, and casa::sdfiller::MSDataRecord::wind_speed.
|
inline |
Definition at line 838 of file DataAccumulator.h.
References casacore::C::c.
|
inline |
Definition at line 834 of file DataAccumulator.h.
|
inline |
Definition at line 1012 of file DataAccumulator.h.
|
inline |
Definition at line 1007 of file DataAccumulator.h.
|
inlineprivate |
std::cout << record.time << " " << record.interval << " " << record.antenna_id << " " << record.field_id << " " << record.feed_id << " " << record.spw_id << " " << record.scan << " " << record.subscan << " " << record.direction << std::endl;
Definition at line 1018 of file DataAccumulator.h.
References casa::sdfiller::DataRecord::antenna_id, casa::sdfiller::DataRecord::direction, casacore::ArrayBase::empty(), casa::sdfiller::DataRecord::feed_id, casa::sdfiller::DataRecord::field_id, casa::sdfiller::DataRecord::interval, casa::sdfiller::DataRecord::scan, casa::sdfiller::DataRecord::spw_id, casa::sdfiller::DataRecord::subscan, and casa::sdfiller::DataRecord::time.
|
inline |
Definition at line 845 of file DataAccumulator.h.
References casa::time, and casa::sdfiller::DataRecord::time.
|
inline |
Definition at line 851 of file DataAccumulator.h.
|
private |
Definition at line 1030 of file DataAccumulator.h.
|
private |
Definition at line 1037 of file DataAccumulator.h.
|
private |
Definition at line 1033 of file DataAccumulator.h.
|
private |
Definition at line 1032 of file DataAccumulator.h.
|
private |
Definition at line 1044 of file DataAccumulator.h.
|
private |
Definition at line 1036 of file DataAccumulator.h.
|
private |
Definition at line 1038 of file DataAccumulator.h.
|
private |
Definition at line 1046 of file DataAccumulator.h.
|
private |
Definition at line 1029 of file DataAccumulator.h.
|
private |
Definition at line 1040 of file DataAccumulator.h.
|
private |
Definition at line 1041 of file DataAccumulator.h.
|
private |
Definition at line 1034 of file DataAccumulator.h.
|
private |
Definition at line 1031 of file DataAccumulator.h.
|
private |
Definition at line 1035 of file DataAccumulator.h.
|
private |
Definition at line 1039 of file DataAccumulator.h.
|
private |
Definition at line 1045 of file DataAccumulator.h.
|
private |
Definition at line 1043 of file DataAccumulator.h.
|
private |
Definition at line 1042 of file DataAccumulator.h.