source: trunk/external-alma/oldasdm2ASAP/OldASDMReader.cc@ 3126

Last change on this file since 3126 was 3106, checked in by Takeshi Nakazato, 8 years ago

New Development: No

JIRA Issue: No

Ready for Test: Yes/No

Interface Changes: Yes/No

What Interface Changed: Please list interface changes

Test Programs: List test programs

Put in Release Notes: Yes/No

Module(s): Module Names change impacts.

Description: Describe your changes here...


Check-in asap modifications from Jim regarding casacore namespace conversion.
File size: 63.3 KB
RevLine 
[2273]1#include <iostream>
2#include <sstream>
[2301]3#include "limits.h"
[2307]4//#include "float.h"
[2273]5
6#include <measures/Measures/MEpoch.h>
7#include <measures/Measures/MPosition.h>
8#include <measures/Measures/MDirection.h>
9#include <measures/Measures/MCDirection.h>
10#include <measures/Measures/MeasFrame.h>
11#include <measures/Measures/MeasConvert.h>
12#include <casa/Logging/LogMessage.h>
13#include <casa/BasicSL/Constants.h>
14
15#include "OldASDMReader.h"
16#include <atnf/PKSIO/SrcType.h>
17
18using namespace std ;
19//using namespace casa ;
20using namespace asdm ;
21using namespace sdmbin ;
22
23// sec to day
24double s2d = 1.0 / 86400.0 ;
25
26OldASDMReader::OldASDMReader()
27 : asdm_(0),
28 sdmBin_(0),
29 vmsData_(0),
30 antennaId_( -1 ),
31 antennaName_( "" ),
[2301]32 stationName_( "" ),
[2273]33 row_(-1),
34 apc_(AP_CORRECTED),
[2301]35 className_("OldASDMReader"),
36 dataIndex_( UINT_MAX ),
37 //antennaRow_p( 0 ),
38 //stationRow_p( 0 ),
39 specWinRow_p( 0 ),
40 polarizationRow_p( 0 ),
41 fieldRow_p( 0 )
[2273]42{
43 configDescIdList_.resize(0) ;
44 feedIdList_.resize(0) ;
45 fieldIdList_.resize(0) ;
46 mainRow_.resize(0) ;
47 ifno_.clear() ;
48 corrMode_.reset() ;
49 timeSampling_.reset() ;
50}
51
52OldASDMReader::~OldASDMReader()
53{
54 close() ;
55 logsink_ = 0 ;
56}
57
[3106]58bool OldASDMReader::open( const string &filename, const casacore::Record &rec )
[2273]59{
[3106]60 casacore::String funcName = "open" ;
[2273]61
62 // return value
63 bool status = true ;
64
65 // set default
66 timeSampling_.reset() ;
67 corrMode_.reset() ;
68 resolutionType_.reset() ;
69 apc_ = AP_CORRECTED ;
70
71 // parsing ASDM options
72 if ( rec.isDefined( "asdm" ) ) {
[3106]73 casacore::Record asdmrec = rec.asRecord( "asdm" ) ;
[2273]74
75 // antenna
76 if ( asdmrec.isDefined( "antenna" ) ) {
[3106]77 if ( asdmrec.type( asdmrec.fieldNumber( "antenna" ) ) == casacore::TpInt ) {
[2273]78 antennaId_ = asdmrec.asInt( "antenna" ) ;
79 }
80 else {
81 antennaName_ = asdmrec.asString( "antenna" ) ;
82 }
83 }
84 else {
85 antennaId_ = 0 ;
86 }
87
88 // ATM phase correction
89 if ( asdmrec.isDefined( "apc" ) ) {
90 if ( asdmrec.asBool( "apc" ) )
91 apc_ = AP_CORRECTED ;
92 else
93 apc_ = AP_UNCORRECTED ;
94 }
95
96 // time sampling
97 String timeSampling = "all" ; // take all time sampling by default
98 if ( asdmrec.isDefined( "sampling" ) ) {
99 timeSampling = asdmrec.asString( "sampling" ) ;
100 }
101 if ( timeSampling == "all" ) {
102 timeSampling_.set( INTEGRATION ) ;
103 timeSampling_.set( SUBINTEGRATION ) ;
104 }
105 else if ( timeSampling == "integration" ) {
106 timeSampling_.set( INTEGRATION ) ;
107 }
108 else if ( timeSampling == "subintegration" ) {
109 timeSampling_.set( SUBINTEGRATION ) ;
110 }
111 else {
112 //throw AipsError( "Unrecognized option for sampling" ) ;
113 logsink_->postLocally( LogMessage( "Unrecognized option for time sampling: "+String::toString(timeSampling), LogOrigin(className_,funcName,WHERE), LogMessage::WARN ) ) ;
114 status = false ;
115 }
116
117 // spectral resolution type
118 string resolutionType = "all" ;
119 if ( asdmrec.isDefined( "srt" ) ) {
120 resolutionType = string( asdmrec.asString( "srt" ) ) ;
121 }
122 string resolutionTypes[3] ;
123 Int numType = split( resolutionType, resolutionTypes, 3, "," ) ;
124 for ( Int it = 0 ; it < numType ; it++ ) {
125 if ( resolutionTypes[it] == "all" ) {
126 resolutionType_.reset() ;
127 resolutionType_.set( FULL_RESOLUTION ) ;
128 resolutionType_.set( BASEBAND_WIDE ) ;
129 resolutionType_.set( CHANNEL_AVERAGE ) ;
130 break ;
131 }
132 else if ( resolutionTypes[it] == "fr" ) {
133 resolutionType_.set( FULL_RESOLUTION ) ;
134 }
135 else if ( resolutionTypes[it] == "bw" ) {
136 resolutionType_.set( BASEBAND_WIDE ) ;
137 }
138 else if ( resolutionTypes[it] == "ca" ) {
139 resolutionType_.set( CHANNEL_AVERAGE ) ;
140 }
141 }
142 if ( resolutionType_.size() == 0 ) {
143 logsink_->postLocally( LogMessage( "Unrecognized option for spectral resolution type: "+String::toString(resolutionType), LogOrigin(className_,funcName,WHERE), LogMessage::WARN ) ) ;
144 status = false ;
145 }
146
147 // input correlation mode
148 string corrMode = "ao,ca" ;
149 if ( asdmrec.isDefined( "corr" ) ) {
150 corrMode = string( asdmrec.asString( "corr" ) ) ;
151 //logsink_->postLocally( LogMessage("corrMode = "+String(corrMode),LogOrigin(className_,funcName,WHERE)) ) ;
152 }
153 string corrModes[3] ;
154 Int numCorr = split( corrMode, corrModes, 3, "," ) ;
155 for ( Int ic = 0 ; ic < numCorr ; ic++ ) {
156 if ( corrModes[ic] == "ao" ) {
157 corrMode_.set( AUTO_ONLY ) ;
158 }
159 else if ( corrModes[ic] == "ca" ) {
160 corrMode_.set( CROSS_AND_AUTO ) ;
161 }
162 }
163 if ( corrMode_.size() == 0 ) {
164 logsink_->postLocally( LogMessage( "Invalid option for correlation mode: "+String::toString(corrMode), LogOrigin(className_,funcName,WHERE), LogMessage::WARN ) ) ;
165 status = false ;
166 }
167
168// logsink_->postLocally( LogMessage( "### asdmrec summary ###", LogOrigin(className_,funcName,WHERE) ) ) ;
169// ostringstream oss ;
170// asdmrec.print( oss ) ;
171// logsink_->postLocally( LogMessage( oss.str(), LogOrigin(className_,funcName,WHERE) ) ) ;
172// logsink_->postLocally( LogMessage( "#######################", LogOrigin(className_,funcName,WHERE) ) ) ;
173 }
174
175 // create ASDM object
176 asdm_ = new ASDM() ;
177 asdm_->setFromFile( filename ) ;
178
[2301]179 AntennaTable &atab = asdm_->getAntenna() ;
180 AntennaRow *antennaRow ;
[2273]181 if ( antennaId_ == -1 ) {
182 vector<AntennaRow *> rows = atab.get() ;
183 int idx = -1 ;
[3106]184 for ( casacore::uInt irow = 0 ; irow < rows.size() ; irow++ ) {
185 if ( casacore::String(rows[irow]->getName()) == antennaName_ ) {
[2273]186 idx = rows[irow]->getAntennaId().getTagValue() ;
187 break ;
188 }
189 }
190 if ( idx == -1 ) {
191 close() ;
[3106]192 throw (casacore::AipsError( antennaName_ + " not found." )) ;
[2273]193 }
194 else {
195 antennaId_ = idx ;
196 }
[2301]197 antennaTag_ = Tag( antennaId_, TagType::Antenna ) ;
198 antennaRow = rows[antennaId_] ;
[2273]199 }
[2301]200 else {
201 antennaTag_ = Tag( antennaId_, TagType::Antenna ) ;
202 antennaRow = atab.getRowByKey( antennaTag_ ) ;
203 if ( antennaRow == 0 ) {
204 close() ;
[3106]205 throw (casacore::AipsError( "AntennaId " + casacore::String::toString(antennaId_) + " is invalid." ) ) ;
[2301]206 }
207 }
208
[2273]209
210 // set antenna name
211 if ( antennaName_.size() == 0 ) {
[3106]212 antennaName_ = casacore::String( antennaRow->getName() ) ;
[2273]213 }
214
[2301]215 // get Station row
216 StationRow *stationRow = antennaRow->getStationUsingStationId() ;
217
218 // station name
[3106]219 stationName_ = casacore::String( stationRow->getName() ) ;
[2301]220
221 // antenna position
222 antennaPosition_.resize( 3 ) ;
223 vector<Length> antpos = stationRow->getPosition() ;
[3106]224 for ( casacore::uInt i = 0 ; i < 3 ; i++ )
225 antennaPosition_[i] = Quantity( casacore::Double( antpos[i].get() ), Unit( "m" ) ) ;
[2301]226
[2273]227 // create SDMBinData object
228 sdmBin_ = new SDMBinData( asdm_, filename ) ;
229
230 // get Main rows
[3106]231 //mainRow_ = casacore::Vector<MainRow *>(asdm_->getMain().get()) ;
[2273]232
233 // set up IFNO
234 setupIFNO() ;
235
236 // process Station table
237 processStation() ;
238
[2301]239 //logsink_->postLocally( LogMessage( "antennaId_ = "+String::toString(antennaId_), LogOrigin(className_,funcName,WHERE) ) ) ;
240 //logsink_->postLocally( LogMessage( "antennaName_ = "+antennaName_, LogOrigin(className_,funcName,WHERE) ) ) ;
[2273]241
242 return true ;
243}
244
245// void OldASDMReader::fill()
246// {
247// }
248
249void OldASDMReader::close()
250{
251 clearMainRow() ;
252
253 if ( sdmBin_ )
254 delete sdmBin_ ;
255 sdmBin_ = 0 ;
256
257 if ( asdm_ )
258 delete asdm_ ;
259 asdm_ = 0 ;
260
261 return ;
262}
263
[3106]264void OldASDMReader::fillHeader( casacore::Int &nchan,
265 casacore::Int &npol,
266 casacore::Int &nif,
267 casacore::Int &nbeam,
268 casacore::String &observer,
269 casacore::String &project,
270 casacore::String &obstype,
271 casacore::String &antennaname,
272 casacore::Vector<casacore::Double> &antennaposition,
273 casacore::Float &equinox,
274 casacore::String &freqref,
275 casacore::Double &reffreq,
276 casacore::Double &bandwidth,
277 casacore::Double &utc,
278 casacore::String &fluxunit,
279 casacore::String &epoch,
280 casacore::String &poltype )
[2273]281{
[3106]282 casacore::String funcName = "fillHeader" ;
[2273]283
284 ExecBlockTable &ebtab = asdm_->getExecBlock() ;
285 // at the moment take first row of ExecBlock table
286 ExecBlockRow *ebrow = ebtab.get()[0] ;
[3106]287 casacore::String telescopeName( ebrow->getTelescopeName() ) ;
288 //casacore::String stationName( stationRow_p->getName() ) ;
[2273]289
290 // antennaname
291 // <telescopeName>//<antennaName>@stationName
[2301]292 antennaname = telescopeName + "//" + antennaName_ + "@" + stationName_ ;
[2273]293 //logsink_->postLocally( LogMessage("antennaName = "+antennaname,LogOrigin(className_,funcName,WHERE)) ) ;
294
295 // antennaposition
296 antennaposition.resize( 3 ) ;
[3106]297 for ( casacore::uInt i = 0 ; i < 3 ; i++ )
[2301]298 antennaposition[i] = antennaPosition_[i].getValue( Unit("m") ) ;
[2273]299
300 // observer
301 observer = ebrow->getObserverName() ;
302
303 // project
304 // T.B.D. (project UID?)
305 project = "T.B.D. (" + ebrow->getProjectId().toString() + ")" ;
306
307 // utc
308 // start time of the project
[3106]309 utc = casacore::Double( ebrow->getStartTime().getMJD() ) ;
[2273]310
311
312 SpectralWindowTable &spwtab = asdm_->getSpectralWindow() ;
313 vector<SpectralWindowRow *> spwrows = spwtab.get() ;
314 int nspwrow = spwrows.size() ;
315
316 // nif
317 //nif = spwrows.size() ;
318 nif = getNumIFs() ;
319
320 // nchan
321 int refidx = -1 ;
322 vector<int> nchans ;
323 for ( int irow = 0 ; irow < nspwrow ; irow++ ) {
324 nchans.push_back( spwrows[irow]->getNumChan() ) ;
325 if ( refidx == -1 && nchans[irow] != 1 && nchans[irow] != 4 )
326 refidx = irow ;
327 }
[3106]328 nchan = casacore::Int( *max_element( nchans.begin(), nchans.end() ) ) ;
[2273]329
330 //logsink_->postLocally( LogMessage("refidx = "+String::toString(refidx),LogOrigin(className_,funcName,WHERE)) ) ;
331
332 // bandwidth
333 vector<double> bws ;
334 for ( int irow = 0 ; irow < nspwrow ; irow++ ) {
335 if ( nchans[irow] != 4 ) { // exclude WVR data
336 bws.push_back( spwrows[irow]->getTotBandwidth().get() ) ;
337 }
338 }
[3106]339 bandwidth = casacore::Double( *max_element( bws.begin(), bws.end() ) ) ;
[2273]340
341 // reffreq
[3106]342 reffreq = casacore::Double( spwrows[refidx]->getRefFreq().get() ) ;
[2273]343
344 // freqref
345 if ( spwrows[refidx]->isMeasFreqRefExists() ) {
346 string mfr = CFrequencyReferenceCode::name( spwrows[refidx]->getMeasFreqRef() ) ;
347// if (mfr == "TOPO") {
348// freqref = "TOPOCENT";
349// } else if (mfr == "GEO") {
350// freqref = "GEOCENTR";
351// } else if (mfr == "BARY") {
352// freqref = "BARYCENT";
353// } else if (mfr == "GALACTO") {
354// freqref = "GALACTOC";
355// } else if (mfr == "LGROUP") {
356// freqref = "LOCALGRP";
357// } else if (mfr == "CMB") {
358// freqref = "CMBDIPOL";
359// } else if (mfr == "REST") {
360// freqref = "SOURCE";
361// }
362 freqref = String( mfr ) ;
363 }
364 else {
365 // frequency reference is TOPOCENT by default
366 //freqref = "TOPOCENT" ;
367 freqref = "TOPO" ;
368 }
369
370
371 PolarizationTable &ptab = asdm_->getPolarization() ;
372 vector<PolarizationRow *> prows = ptab.get() ;
373 vector<int> npols ;
374 refidx = -1 ;
375 for ( unsigned int irow = 0 ; irow < prows.size() ; irow++ ) {
376 npols.push_back( prows[irow]->getNumCorr() ) ;
377 if ( refidx == -1 && npols[irow] != 1 )
378 refidx = irow ;
379 }
380 if ( refidx == -1 )
381 refidx = 0 ;
382
383 // npol
[3106]384 npol = casacore::Int( *max_element( npols.begin(), npols.end() ) ) ;
[2273]385
386 // poltype
387 vector<StokesParameter> corrType = prows[refidx]->getCorrType() ;
388 if ( corrType[0] == I ||
389 corrType[0] == Q ||
390 corrType[0] == U ||
391 corrType[0] == V )
392 poltype = "stokes" ;
393 else if ( corrType[0] == RR ||
394 corrType[0] == RL ||
395 corrType[0] == LR ||
396 corrType[0] == LL )
397 poltype = "circular" ;
398 else if ( corrType[0] == XX ||
399 corrType[0] == XY ||
400 corrType[0] == YX ||
401 corrType[0] == YY )
402 poltype = "linear" ;
403 else if ( corrType[0] == PLINEAR ||
404 corrType[0] == PANGLE ) {
405 poltype = "linpol" ;
406 }
407 else {
408 poltype = "notype" ;
409 }
410
411
412 FeedTable &ftab = asdm_->getFeed() ;
413 vector<FeedRow *> frows = ftab.get() ;
414 vector<int> nbeams ;
415 for ( unsigned int irow = 0 ; irow < frows.size() ; irow++ ) {
416 if ( frows[irow]->isFeedNumExists() )
417 nbeams.push_back( frows[irow]->getFeedNum() ) ;
418 else
419 nbeams.push_back( 1 ) ;
420 }
421
422 // nbeam
[3106]423 nbeam = casacore::Int( *max_element( nbeams.begin(), nbeams.end() ) ) ;
[2273]424
425 // fluxunit
426 // tentatively set 'K'? or empty?
427 fluxunit = "K" ;
428
429 // equinox
430 // tentatively set 2000.0
431 equinox = 2000.0 ;
432
433 // epoch
434 // tentatively set "UTC"
435 epoch = "UTC" ;
436
437 // obstype
438 // at the moment take observingMode attribute in SBSummary table
439 SBSummaryRow *sbrow = ebrow->getSBSummaryUsingSBSummaryId() ;
440 vector<string> obsmode = sbrow->getObservingMode() ;
441 obstype = "" ;
442 for ( unsigned int imode = 0 ; imode < obsmode.size() ; imode++ ) {
[3106]443 obstype += casacore::String(obsmode[imode]) ;
[2273]444 if ( imode != obsmode.size()-1 )
445 obstype += "#" ;
446 }
447}
448
449void OldASDMReader::selectConfigDescription()
450{
[3106]451 casacore::String funcName = "selectConfigDescription" ;
[2273]452
453 vector<ConfigDescriptionRow *> cdrows = asdm_->getConfigDescription().get() ;
454 vector<Tag> cdidTags ;
455 for ( unsigned int irow = 0 ; irow < cdrows.size() ; irow++ ) {
456 //logsink_->postLocally( LogMessage("correlationMode["+String::toString(irow)+"] = "+String::toString(cdrows[irow]->getCorrelationMode()),LogOrigin(className_,funcName,WHERE)) ) ;
457 if ( cdrows[irow]->getCorrelationMode() != CROSS_ONLY ) {
458 cdidTags.push_back( cdrows[irow]->getConfigDescriptionId() ) ;
459 }
460 }
461
462 configDescIdList_.resize( cdidTags.size() ) ;
463 for ( unsigned int i = 0 ; i < cdidTags.size() ; i++ ) {
[3106]464 configDescIdList_[i] = casacore::uInt( cdidTags[i].getTagValue() ) ;
[2273]465 }
466}
467
468void OldASDMReader::selectFeed()
469{
470 feedIdList_.resize(0) ;
471 vector<FeedRow *> frows = asdm_->getFeed().get() ;
472 Tag atag( antennaId_, TagType::Antenna ) ;
473 for ( unsigned int irow = 0 ; irow < frows.size() ; irow++ ) {
[3106]474 casacore::uInt feedId = (casacore::uInt)(frows[irow]->getFeedId() ) ;
475 if ( casacore::anyEQ( feedIdList_, feedId ) )
[2273]476 continue ;
477 if ( frows[irow]->getAntennaId() == atag ) {
478 unsigned int oldsize = feedIdList_.size() ;
479 feedIdList_.resize( oldsize+1, true ) ;
480 feedIdList_[oldsize] = feedId ;
481 }
482 }
483}
484
[3106]485casacore::Vector<casacore::uInt> OldASDMReader::getFieldIdList()
[2273]486{
[3106]487 casacore::String funcName = "getFieldIdList" ;
[2273]488
489 vector<FieldRow *> frows = asdm_->getField().get() ;
490 fieldIdList_.resize( frows.size() ) ;
491 for ( unsigned int irow = 0 ; irow < frows.size() ; irow++ ) {
492 //logsink_->postLocally( LogMessage("fieldId["+String::toString(irow)+"]="+String(frows[irow]->getFieldId().toString()),LogOrigin(className_,funcName,WHERE)) ) ;
493 fieldIdList_[irow] = frows[irow]->getFieldId().getTagValue() ;
494 }
495
496 return fieldIdList_ ;
497}
498
[3106]499casacore::uInt OldASDMReader::getNumMainRow()
[2273]500{
[3106]501 casacore::uInt nrow = casacore::uInt( mainRow_.size() ) ;
[2273]502
503 return nrow ;
504}
505
506void OldASDMReader::select()
507{
508 // selection by input CorrelationMode
509 EnumSet<CorrelationMode> esCorrs ;
510 sdmBin_->select( corrMode_ ) ;
511
512 // selection by TimeSampling
513 sdmBin_->select( timeSampling_ ) ;
514
515 // selection by SpectralResolutionType
516 sdmBin_->select( resolutionType_ ) ;
517
518 // selection by AtmPhaseCorrection and output CorrelationMode
519 EnumSet<AtmPhaseCorrection> esApcs ;
520 esApcs.set( apc_ ) ;
521 // always take only autocorrelation data
522 Enum<CorrelationMode> esCorr = AUTO_ONLY ;
523 sdmBin_->selectDataSubset( esCorr, esApcs ) ;
524
525 // select valid configDescriptionId
526 selectConfigDescription() ;
527
528 // select valid feedId
529 selectFeed() ;
530}
531
[3106]532casacore::Bool OldASDMReader::setMainRow( casacore::uInt irow )
[2273]533{
[3106]534 casacore::Bool status = true ;
[2273]535 row_ = irow ;
[2301]536 execBlockTag_ = mainRow_[row_]->getExecBlockId() ;
[2273]537
538 unsigned int cdid = mainRow_[row_]->getConfigDescriptionId().getTagValue() ;
539 if ( (int)count(configDescIdList_.begin(),configDescIdList_.end(),cdid) == 0 )
540 status = false ;
541 else {
[3106]542 status = (casacore::Bool)(sdmBin_->acceptMainRow( mainRow_[row_] )) ;
[2273]543 }
544 return status ;
545}
546
[3106]547casacore::Bool OldASDMReader::setMainRow( casacore::uInt configDescId, casacore::uInt fieldId )
[2273]548{
549 clearMainRow() ;
550
551 Tag configDescTag( (unsigned int)configDescId, TagType::ConfigDescription ) ;
552 Tag fieldTag( (unsigned int)fieldId, TagType::Field ) ;
[3106]553 mainRow_ = casacore::Vector<MainRow *>( *(asdm_->getMain().getByContext( configDescTag, fieldTag ) ) ) ;
[2273]554
555 return true ;
556}
557
558void OldASDMReader::clearMainRow()
559{
560 mainRow_.resize(0) ;
561}
562
563void OldASDMReader::setupIFNO()
564{
[3106]565 casacore::String funcName = "setupIFNO" ;
[2273]566
567 vector<SpectralWindowRow *> spwrows = asdm_->getSpectralWindow().get() ;
568 unsigned int nrow = spwrows.size() ;
569 ifno_.clear() ;
[3106]570 casacore::uInt idx = 0 ;
571 casacore::uInt wvridx = 0 ;
[2273]572 for ( unsigned int irow = 0 ; irow < nrow ; irow++ ) {
[3106]573 casacore::uInt index ;
[2273]574 if ( isWVR( spwrows[irow] ) ) {
575 //logsink_->postLocally( LogMessage(spwrows[irow]->getSpectralWindowId().toString()+" is WVR",LogOrigin(className_,funcName,WHERE)) ) ;
576 index = wvridx ;
577 }
578 else {
579 index = ++idx ;
580 }
[3106]581 ifno_.insert( pair<Tag,casacore::uInt>(spwrows[irow]->getSpectralWindowId(),index) ) ;
[2273]582 //logsink_->postLocally( LogMessage(spwrows[irow]->getSpectralWindowId().toString()+": IFNO="+String::toString(index),LogOrigin(className_,funcName,WHERE)) ) ;
583 }
584}
585
586bool OldASDMReader::isWVR( SpectralWindowRow *row )
587{
588 BasebandName bbname = row->getBasebandName() ;
589 int nchan = row->getNumChan() ;
590 if ( bbname == NOBB && nchan == 4 )
591 return true ;
592 else
593 return false ;
594}
595
[3106]596casacore::Bool OldASDMReader::setData()
[2273]597{
[3106]598 casacore::String funcName = "setData" ;
[2273]599
600 //logsink_->postLocally( LogMessage("try to retrieve binary data",LogOrigin(className_,funcName,WHERE)) ) ;
601
602// EnumSet<AtmPhaseCorrection> esApcs ;
603// esApcs.set( apc_ ) ;
604// // always take only autocorrelation data
605// Enum<CorrelationMode> esCorr = AUTO_ONLY ;
606// vmsData_ = sdmBin_->getDataCols( esCorr, esApcs ) ;
607
608 // 2011/07/06 TN
609 // Workaround to avoid unwanted message from SDMBinData::getDataCols()
610 ostringstream oss ;
611 streambuf *buforg = cout.rdbuf(oss.rdbuf()) ;
612 vmsData_ = sdmBin_->getDataCols() ;
613 cout.rdbuf(buforg) ;
614
615// logsink_->postLocally( LogMessage("oss.str() = "+oss.str(),LogOrigin(className_,funcName,WHERE)) ) ;
616// cout << "This is test: oss.str()=" << oss.str() << endl ;
617
618
619 //logsink_->postLocally( LogMessage("processorId = "+String::toString(vmsData_->processorId),LogOrigin(className_,funcName,WHERE)) ) ;
620 //logsink_->postLocally( LogMessage("v_time.size() = "+String::toString(vmsData_->v_time.size()),LogOrigin(className_,funcName,WHERE)) ) ;
621 //logsink_->postLocally( LogMessage(" v_time[0] = "+String::toString(vmsData_->v_time[0]),LogOrigin(className_,funcName,WHERE)) ) ;
622 //logsink_->postLocally( LogMessage("v_interval.size() = "+String::toString(vmsData_->v_interval.size()),LogOrigin(className_,funcName,WHERE)) ) ;
623 //logsink_->postLocally( LogMessage(" v_interval[0] = "+String::toString(vmsData_->v_interval[0]),LogOrigin(className_,funcName,WHERE)) ) ;
624 //logsink_->postLocally( LogMessage("v_atmPhaseCorrection.size() = "+String::toString(vmsData_->v_atmPhaseCorrection.size()),LogOrigin(className_,funcName,WHERE)) ) ;
625 //logsink_->postLocally( LogMessage("binNum = "+String::toString(vmsData_->binNum),LogOrigin(className_,funcName,WHERE)) ) ;
626 //logsink_->postLocally( LogMessage("v_projectPath.size() = "+String::toString(vmsData_->v_projectPath.size()),LogOrigin(className_,funcName,WHERE)) ) ;
627 //logsink_->postLocally( LogMessage("v_antennaId1.size() = "+String::toString(vmsData_->v_antennaId1.size()),LogOrigin(className_,funcName,WHERE)) ) ;
628 //logsink_->postLocally( LogMessage("v_antennaId2.size() = "+String::toString(vmsData_->v_antennaId2.size()),LogOrigin(className_,funcName,WHERE)) ) ;
629 //logsink_->postLocally( LogMessage("v_feedId1.size() = "+String::toString(vmsData_->v_feedId1.size()),LogOrigin(className_,funcName,WHERE)) ) ;
630 //logsink_->postLocally( LogMessage("v_feedId2.size() = "+String::toString(vmsData_->v_feedId2.size()),LogOrigin(className_,funcName,WHERE)) ) ;
631 //logsink_->postLocally( LogMessage("v_dataDescId.size() = "+String::toString(vmsData_->v_dataDescId.size()),LogOrigin(className_,funcName,WHERE)) ) ;
632 //logsink_->postLocally( LogMessage("v_timeCentroid.size() = "+String::toString(vmsData_->v_timeCentroid.size()),LogOrigin(className_,funcName,WHERE)) ) ;
633 //logsink_->postLocally( LogMessage("v_exposure.size() = "+String::toString(vmsData_->v_exposure.size()),LogOrigin(className_,funcName,WHERE)) ) ;
634 //logsink_->postLocally( LogMessage("v_numData.size() = "+String::toString(vmsData_->v_numData.size()),LogOrigin(className_,funcName,WHERE)) ) ;
635 //logsink_->postLocally( LogMessage("vv_dataShape.size() = "+String::toString(vmsData_->vv_dataShape.size()),LogOrigin(className_,funcName,WHERE)) ) ;
636 //logsink_->postLocally( LogMessage("v_m_data.size() = "+String::toString(vmsData_->v_m_data.size()),LogOrigin(className_,funcName,WHERE)) ) ;
637 //logsink_->postLocally( LogMessage("v_phaseDir.size() = "+String::toString(vmsData_->v_phaseDir.size()),LogOrigin(className_,funcName,WHERE)) ) ;
638 //logsink_->postLocally( LogMessage("v_stateId.size() = "+String::toString(vmsData_->v_stateId.size()),LogOrigin(className_,funcName,WHERE)) ) ;
639 //logsink_->postLocally( LogMessage("v_msState.size() = "+String::toString(vmsData_->v_msState.size()),LogOrigin(className_,funcName,WHERE)) ) ;
640 //logsink_->postLocally( LogMessage("v_flag.size() = "+String::toString(vmsData_->v_flag.size()),LogOrigin(className_,funcName,WHERE)) ) ;
641
642 dataIdList_.clear() ;
643 unsigned int numTotalData = vmsData_->v_m_data.size() ;
644 for ( unsigned int idata = 0 ; idata < numTotalData ; idata++ ) {
645 if ( vmsData_->v_antennaId1[idata] == (int)antennaId_
646 && vmsData_->v_antennaId2[idata] == (int)antennaId_ )
647 dataIdList_.push_back( idata ) ;
648 }
649 numData_ = dataIdList_.size() ;
650 //logsink_->postLocally( LogMessage("numData_ = "+String::toString(numData_),LogOrigin(className_,funcName,WHERE)) ) ;
651 //logsink_->postLocally( LogMessage("dataSize = "+String::toString(mainRow_[row_]->getDataSize()),LogOrigin(className_,funcName,WHERE)) ) ;
652
653 return true ;
654}
655
[2301]656void OldASDMReader::prepareData( unsigned int idx )
657{
658 unsigned int i = dataIdList_[idx] ;
659 if ( i != dataIndex_ ) {
660 dataIndex_ = dataIdList_[idx] ;
661 Tag dataDescTag( vmsData_->v_dataDescId[dataIndex_], TagType::DataDescription ) ;
662 DataDescriptionRow *dataDescRow = asdm_->getDataDescription().getRowByKey( dataDescTag ) ;
663 specWinTag_ = dataDescRow->getSpectralWindowId() ;
664 specWinRow_p = dataDescRow->getSpectralWindowUsingSpectralWindowId() ;
665 polarizationRow_p = dataDescRow->getPolarizationUsingPolOrHoloId() ;
666 Tag fieldTag( vmsData_->v_fieldId[dataIndex_], TagType::Field ) ;
667 fieldRow_p = asdm_->getField().getRowByKey( fieldTag ) ;
668 double startSec = vmsData_->v_time[dataIndex_] - 0.5 * vmsData_->v_interval[dataIndex_] ;
669 timeInterval_ = ArrayTimeInterval( startSec*s2d, vmsData_->v_interval[dataIndex_]*s2d ) ;
670 }
671}
672
[3106]673casacore::uInt OldASDMReader::getIFNo( unsigned int idx )
[2273]674{
[2301]675 prepareData( idx ) ;
676 return getIFNo() ;
677}
678
[3106]679casacore::uInt OldASDMReader::getIFNo()
[2301]680{
[3106]681 map<Tag,casacore::uInt>::iterator iter = ifno_.find( specWinTag_ ) ;
[2273]682 if ( iter != ifno_.end() )
683 return iter->second ;
684 else {
685 return 0 ;
686 }
687}
688
689int OldASDMReader::getNumPol( unsigned int idx )
690{
[2301]691 prepareData( idx ) ;
692 return getNumPol() ;
[2273]693}
694
[2301]695int OldASDMReader::getNumPol()
696{
697 return polarizationRow_p->getNumCorr() ;
698}
699
[2273]700void OldASDMReader::getFrequency( unsigned int idx,
701 double &refpix,
702 double &refval,
703 double &incr,
704 string &freqref )
705{
[2301]706 prepareData( idx ) ;
707 getFrequency( refpix, refval, incr, freqref ) ;
708}
709
710void OldASDMReader::getFrequency( double &refpix,
711 double &refval,
712 double &incr,
713 string &freqref )
714{
[3106]715 casacore::String funcName = "getFrequency" ;
[2273]716
[2301]717 int nchan = specWinRow_p->getNumChan() ;
[2273]718 freqref = "TOPO" ;
[2301]719 if ( specWinRow_p->isMeasFreqRefExists() )
720 freqref = CFrequencyReferenceCode::toString( specWinRow_p->getMeasFreqRef() ) ;
[2273]721 if ( nchan == 1 ) {
722 //logsink_->postLocally( LogMessage("channel averaged data",LogOrigin(className_,funcName,WHERE)) ) ;
723 refpix = 0.0 ;
[2301]724 incr = specWinRow_p->getTotBandwidth().get() ;
725 if ( specWinRow_p->isChanFreqStartExists() ) {
726 refval = specWinRow_p->getChanFreqStart().get() ;
[2273]727 }
[2301]728 else if ( specWinRow_p->isChanFreqArrayExists() ) {
729 refval = specWinRow_p->getChanFreqArray()[0].get() ;
[2273]730 }
731 else {
[3106]732 throw (casacore::AipsError( "Either chanFreqArray or chanFreqStart must exist." )) ;
[2273]733 }
734 }
735 else if ( nchan % 2 ) {
736 // odd
737 //logsink_->postLocally( LogMessage("odd case",LogOrigin(className_,funcName,WHERE)) ) ;
738 refpix = 0.5 * ( (double)nchan - 1.0 ) ;
739 int ic = ( nchan - 1 ) / 2 ;
[2301]740 if ( specWinRow_p->isChanWidthExists() ) {
741 incr = specWinRow_p->getChanWidth().get() ;
[2273]742 }
[2301]743 else if ( specWinRow_p->isChanWidthArrayExists() ) {
744 incr = specWinRow_p->getChanWidthArray()[0].get() ;
[2273]745 }
746 else {
[3106]747 throw (casacore::AipsError( "Either chanWidthArray or chanWidth must exist." )) ;
[2273]748 }
[2301]749 if ( specWinRow_p->isChanFreqStepExists() ) {
750 if ( specWinRow_p->getChanFreqStep().get() < 0.0 )
[2273]751 incr *= -1.0 ;
752 }
[2301]753 else if ( specWinRow_p->isChanFreqArrayExists() ) {
754 vector<Frequency> chanFreqArr = specWinRow_p->getChanFreqArray() ;
[2273]755 if ( chanFreqArr[0].get() > chanFreqArr[1].get() )
756 incr *= -1.0 ;
757 }
758 else {
[3106]759 throw (casacore::AipsError( "Either chanFreqArray or chanFreqStep must exist." )) ;
[2273]760 }
[2301]761 if ( specWinRow_p->isChanFreqStartExists() ) {
762 refval = specWinRow_p->getChanFreqStart().get() + refpix * incr ;
[2273]763 }
[2301]764 else if ( specWinRow_p->isChanFreqArrayExists() ) {
765 refval = specWinRow_p->getChanFreqArray()[ic].get() ;
[2273]766 }
767 else {
[3106]768 throw (casacore::AipsError( "Either chanFreqArray or chanFreqStart must exist." )) ;
[2273]769 }
770 }
771 else {
772 // even
773 //logsink_->postLocally( LogMessage("even case",LogOrigin(className_,funcName,WHERE)) ) ;
774 refpix = 0.5 * ( (double)nchan - 1.0 ) ;
775 int ic = nchan / 2 ;
[2301]776 if ( specWinRow_p->isChanWidthExists() ) {
777 incr = specWinRow_p->getChanWidth().get() ;
[2273]778 }
[2301]779 else if ( specWinRow_p->isChanWidthArrayExists() ) {
780 incr = specWinRow_p->getChanWidthArray()[0].get() ;
[2273]781 }
782 else {
[3106]783 throw (casacore::AipsError( "Either chanWidthArray or chanWidth must exist." )) ;
[2273]784 }
[2301]785 if ( specWinRow_p->isChanFreqStepExists() ) {
786 if ( specWinRow_p->getChanFreqStep().get() < 0.0 )
[2273]787 incr *= -1.0 ;
788 }
[2301]789 else if ( specWinRow_p->isChanFreqArrayExists() ) {
790 vector<Frequency> chanFreqArr = specWinRow_p->getChanFreqArray() ;
[2273]791 if ( chanFreqArr[0].get() > chanFreqArr[1].get() )
792 incr *= -1.0 ;
793 }
794 else {
[3106]795 throw (casacore::AipsError( "Either chanFreqArray or chanFreqStep must exist." )) ;
[2273]796 }
[2301]797 if ( specWinRow_p->isChanFreqStartExists() ) {
798 refval = specWinRow_p->getChanFreqStart().get() + refpix * incr ;
[2273]799 }
[2301]800 else if ( specWinRow_p->isChanFreqArrayExists() ) {
801 vector<Frequency> freqs = specWinRow_p->getChanFreqArray() ;
[2273]802 refval = 0.5 * ( freqs[ic-1].get() + freqs[ic].get() ) ;
803 }
804 else {
[3106]805 throw (casacore::AipsError( "Either chanFreqArray or chanFreqStart must exist." )) ;
[2273]806 }
807 }
808}
809
[2301]810double OldASDMReader::getTime( unsigned int idx )
[2273]811{
[2301]812 prepareData( idx ) ;
813 return getTime() ;
[2273]814}
815
[2301]816double OldASDMReader::getTime()
[2273]817{
[2301]818 double tsec = vmsData_->v_time[dataIndex_] ;
[2273]819 return tsec * s2d ;
820}
821
822double OldASDMReader::getInterval( unsigned int idx )
823{
[2301]824 prepareData( idx ) ;
825 return getInterval() ;
[2273]826}
827
[2301]828double OldASDMReader::getInterval()
[2273]829{
[2301]830 return vmsData_->v_interval[dataIndex_] ;
831}
832
833void OldASDMReader::getSourceProperty( unsigned int idx,
834 string &srcname,
835 string &fieldname,
836 vector<double> &srcdir,
837 vector<double> &srcpm,
838 double &sysvel,
839 vector<double> &restfreq )
840{
841 prepareData( idx ) ;
842 getSourceProperty( srcname, fieldname, srcdir, srcpm, sysvel, restfreq ) ;
843}
844
845void OldASDMReader::getSourceProperty( string &srcname,
846 string &fieldname,
847 vector<double> &srcdir,
848 vector<double> &srcpm,
849 double &sysvel,
850 vector<double> &restfreq )
851{
852 ostringstream oss ;
853 oss << fieldRow_p->getFieldName() << "__" << vmsData_->v_fieldId[dataIndex_] ;
854 fieldname = oss.str() ;
855 if ( fieldRow_p->isSourceIdExists() ) {
856 int sourceId = fieldRow_p->getSourceId() ;
857 SourceRow *srow = asdm_->getSource().getRowByKey( sourceId, timeInterval_, specWinTag_ ) ;
858
859 // source name
[2273]860 srcname = srow->getSourceName() ;
[2301]861
862 // source direction
863 vector<Angle> srcdirA = srow->getDirection() ;
864 srcdir.resize( 2 ) ;
865 srcdir[0] = limitedAngle( srcdirA[0].get() ) ;
866 srcdir[1] = limitedAngle( srcdirA[1].get() ) ;
867 if ( srow->isDirectionCodeExists() ) {
868 DirectionReferenceCode dircode = srow->getDirectionCode() ;
869 //logsink_->postLocally( LogMessage("dircode="+CDirectionReferenceCode::toString(dircode),LogOrigin(className_,funcName,WHERE)) ) ;
870 if ( dircode != J2000 ) {
871 // if not J2000, need direction conversion
872 String ref( CDirectionReferenceCode::toString( dircode ) ) ;
873 double mjd = vmsData_->v_time[dataIndex_] * s2d ;
874 srcdir = toJ2000( srcdir, ref, mjd, antennaPosition_ ) ;
875 }
876 }
877
878 // source proper motion
879 srcpm.resize( 2 ) ;
880 vector<AngularRate> srcpmA = srow->getProperMotion() ;
881 srcpm[0] = srcpmA[0].get() ;
882 srcpm[1] = srcpmA[1].get() ;
883
884 // systemic velocity
885 if ( srow->isSysVelExists() ) {
886 vector<Speed> sysvelV = srow->getSysVel() ;
887 if ( sysvelV.size() > 0 )
888 sysvel = sysvelV[0].get() ;
889 }
890 else {
891 sysvel = 0.0 ;
892 }
893
894 // rest frequency
895 if ( srow->isRestFrequencyExists() ) {
896 //logsink_->postLocally( LogMessage("restFrequency exists",LogOrigin(className_,funcName,WHERE)) ) ;
897 vector<Frequency> rf = srow->getRestFrequency() ;
898 restfreq.resize( rf.size() ) ;
899 for ( unsigned int i = 0 ; i < restfreq.size() ; i++ )
900 restfreq[i] = rf[i].get() ;
901 }
902 else {
903 restfreq.resize( 0 ) ;
904 }
[2273]905 }
906 else {
[2301]907 srcname = fieldRow_p->getFieldName() ;
908 srcdir.resize( 2 ) ;
909 srcdir[0] = 0.0 ;
910 srcdir[1] = 0.0 ;
911 srcpm = srcdir ;
912 sysvel = 0.0 ;
913 restfreq.resize( 0 ) ;
[2273]914 }
915}
916
917int OldASDMReader::getSrcType( unsigned int scan,
918 unsigned int subscan )
919{
920 int srctype = SrcType::NOTYPE ;
[2301]921 ScanRow *scanrow = asdm_->getScan().getRowByKey( execBlockTag_, (int)scan ) ;
[2273]922 ScanIntent scanIntent = scanrow->getScanIntent()[0] ;
[2301]923 SubscanRow *subrow = asdm_->getSubscan().getRowByKey( execBlockTag_, (int)scan, (int)subscan ) ;
[2273]924 SubscanIntent subIntent = subrow->getSubscanIntent() ;
[2299]925 SwitchingMode swmode = NO_SWITCHING ;
926 if ( subrow->isSubscanModeExists() )
927 swmode = subrow->getSubscanMode() ;
[2273]928 if ( scanIntent == OBSERVE_TARGET ) {
929 // on sky scan
930 if ( swmode == NO_SWITCHING || swmode == POSITION_SWITCHING ) {
931 // position switching
932 // tentatively set NO_SWITCHING = POSITION_SWITCHING
933 if ( subIntent == ON_SOURCE ) {
934 srctype = SrcType::PSON ;
935 }
936 else if ( subIntent == OFF_SOURCE ) {
937 srctype = SrcType::PSOFF ;
938 }
939 }
940 else if ( swmode == FREQUENCY_SWITCHING ) {
941 // frequency switching
942 if ( subIntent == ON_SOURCE ) {
943 srctype = SrcType::FSON ;
944 }
945 else if ( subIntent == OFF_SOURCE ) {
946 srctype = SrcType::FSOFF ;
947 }
948 }
949 else if ( swmode == NUTATOR_SWITCHING ) {
950 // nutator switching
951 if ( subIntent == ON_SOURCE ) {
952 srctype = SrcType::PSON ;
953 }
954 else if ( subIntent == OFF_SOURCE ) {
955 srctype = SrcType::PSOFF ;
956 }
957 }
958 else {
959 // other switching mode
960 if ( subIntent == ON_SOURCE ) {
961 srctype = SrcType::SIG ;
962 }
963 else if ( subIntent == OFF_SOURCE ) {
964 srctype = SrcType::REF ;
965 }
966 }
967 }
968 else if ( scanIntent == CALIBRATE_ATMOSPHERE ) {
969 if ( swmode == NO_SWITCHING || swmode == POSITION_SWITCHING ) {
970 // position switching
971 // tentatively set NO_SWITCHING = POSITION_SWITCHING
972 if ( subIntent == ON_SOURCE ) {
973 srctype = SrcType::PONCAL ;
974 }
975 else if ( subIntent == OFF_SOURCE ) {
976 srctype = SrcType::POFFCAL ;
977 }
978 }
979 else if ( swmode == FREQUENCY_SWITCHING ) {
980 // frequency switching
981 if ( subIntent == ON_SOURCE ) {
982 srctype = SrcType::FONCAL ;
983 }
984 else if ( subIntent == OFF_SOURCE ) {
985 srctype = SrcType::FOFFCAL ;
986 }
987 }
988 else if ( swmode == NUTATOR_SWITCHING ) {
989 // nutator switching
990 if ( subIntent == ON_SOURCE ) {
991 srctype = SrcType::PONCAL ;
992 }
993 else if ( subIntent == OFF_SOURCE ) {
994 srctype = SrcType::POFFCAL ;
995 }
996 }
997 else {
998 // other switching mode
999 if ( subIntent == ON_SOURCE ) {
1000 srctype = SrcType::CAL ;
1001 }
1002 else if ( subIntent == OFF_SOURCE ) {
1003 srctype = SrcType::CAL ;
1004 }
1005 }
1006 }
1007 else {
1008 // off sky (e.g. calibrator device) scan
1009 if ( subIntent == ON_SOURCE ) {
1010 srctype = SrcType::SIG ;
1011 }
1012 else if ( subIntent == OFF_SOURCE ) {
1013 srctype = SrcType::REF ;
1014 }
1015 else if ( subIntent == HOT ) {
1016 srctype = SrcType::HOT ;
1017 }
1018 else if ( subIntent == AMBIENT ) {
1019 srctype = SrcType::SKY ;
1020 }
1021 else {
1022 srctype = SrcType::CAL ;
1023 }
1024 }
1025
1026 return srctype ;
1027}
1028
1029unsigned int OldASDMReader::getSubscanNo( unsigned int idx )
1030{
[2301]1031 prepareData( idx ) ;
1032 return getSubscanNo() ;
[2273]1033}
1034
[2301]1035unsigned int OldASDMReader::getSubscanNo()
[2273]1036{
[2301]1037 //logsink_->postLocally( LogMessage("subscan"+String::toString(vmsData_->v_msState[dataIdList_[idx]].subscanNum)+": obsmode="+String::toString(vmsData_->v_msState[dataIdList_[idx]].obsMode),LogOrigin(className_,funcName,WHERE)) ) ;
1038 return vmsData_->v_msState[dataIndex_].subscanNum ;
[2273]1039}
1040
1041void OldASDMReader::getSourceDirection( vector<double> &dir, string &ref )
1042{
1043 dir.resize( 2 ) ;
1044 ref = "J2000" ; // default is J2000
1045 SourceTable &tab = asdm_->getSource() ;
1046 SourceRow *row = tab.get()[0] ;
1047 vector<Angle> dirA = row->getDirection() ;
1048 dir[0] = dirA[0].get() ;
1049 dir[1] = dirA[1].get() ;
1050 if ( row->isDirectionCodeExists() ) {
1051 ref = CDirectionReferenceCode::toString( row->getDirectionCode() ) ;
1052 }
1053}
1054
[2301]1055unsigned int OldASDMReader::getFlagRow( unsigned int idx )
[2273]1056{
[2301]1057 prepareData( idx ) ;
1058 return getFlagRow() ;
[2273]1059}
1060
[2301]1061unsigned int OldASDMReader::getFlagRow()
[2273]1062{
[2301]1063 return vmsData_->v_flag[dataIndex_] ;
[2273]1064}
1065
[2301]1066vector<unsigned int> OldASDMReader::getDataShape( unsigned int idx )
[2273]1067{
[2301]1068 prepareData( idx ) ;
1069 return getDataShape() ;
[2273]1070}
1071
[2301]1072vector<unsigned int> OldASDMReader::getDataShape()
[2273]1073{
[2301]1074 return vmsData_->vv_dataShape[dataIndex_] ;
[2273]1075}
1076
1077float * OldASDMReader::getSpectrum( unsigned int idx )
1078{
[2301]1079 prepareData( idx ) ;
1080 return getSpectrum() ;
1081}
1082
1083float * OldASDMReader::getSpectrum()
1084{
1085 map<AtmPhaseCorrection, float*> data = vmsData_->v_m_data[dataIndex_] ;
[2273]1086 //map<AtmPhaseCorrection, float*>::iterator iter = data.find(AP_UNCORRECTED) ;
1087 map<AtmPhaseCorrection, float*>::iterator iter = data.find(apc_) ;
1088 float *autoCorr = iter->second ;
1089 return autoCorr ;
1090}
1091
1092vector< vector<float> > OldASDMReader::getTsys( unsigned int idx )
1093{
[2301]1094 prepareData( idx ) ;
1095 return getTsys() ;
1096}
1097
1098vector< vector<float> > OldASDMReader::getTsys()
1099{
[2273]1100 vector< vector<float> > defaultTsys( 1, vector<float>( 1, 1.0 ) ) ;
[2301]1101 SysCalRow *scrow = getSysCalRow() ;
[2273]1102 if ( scrow != 0 && scrow->isTsysSpectrumExists() ) {
1103 vector< vector<Temperature> > tsysSpec = scrow->getTsysSpectrum() ;
1104 unsigned int numReceptor = tsysSpec.size() ;
1105 unsigned int numChan = tsysSpec[0].size() ;
1106 vector< vector<float> > tsys( numReceptor, vector<float>( numChan, 1.0 ) ) ;
1107 for ( unsigned int ir = 0 ; ir < numReceptor ; ir++ ) {
1108 for ( unsigned int ic = 0 ; ic < numChan ; ic++ ) {
1109 tsys[ir][ic] = tsysSpec[ir][ic].get() ;
1110 }
1111 }
1112 return tsys ;
1113 }
1114// else if ( scrow->isTsysExists() ) {
1115// vector<Temperature> tsysScalar = scrow->getTsys() ;
1116// unsigned int numReceptor = tsysScalar.size() ;
1117// vector< vector<float> > tsys( numReceptor ) ;
1118// for ( unsigned int ir = 0 ; ir < numReceptor ; ir++ )
1119// tsys[ir] = vector<float>( 1, tsysScalar[ir].get() ) ;
1120// return tsys ;
1121// }
1122 else {
1123 return defaultTsys ;
1124 }
1125}
1126
1127vector< vector<float> > OldASDMReader::getTcal( unsigned int idx )
1128{
[2301]1129 prepareData( idx ) ;
1130 return getTcal() ;
1131}
1132
1133vector< vector<float> > OldASDMReader::getTcal()
1134{
[2273]1135 vector< vector<float> > defaultTcal( 1, vector<float>( 1, 1.0 ) ) ;
[2301]1136 SysCalRow *scrow = getSysCalRow() ;
[2273]1137 if ( scrow != 0 && scrow->isTcalSpectrumExists() ) {
1138 vector< vector<Temperature> > tcalSpec = scrow->getTcalSpectrum() ;
1139 unsigned int numReceptor = tcalSpec.size() ;
1140 unsigned int numChan = tcalSpec[0].size() ;
1141 vector< vector<float> > tcal( numReceptor, vector<float>( numChan, 1.0 ) ) ;
1142 for ( unsigned int ir = 0 ; ir < numReceptor ; ir++ ) {
1143 for ( unsigned int ic = 0 ; ic < numChan ; ic++ ) {
1144 tcal[ir][ic] = tcalSpec[ir][ic].get() ;
1145 }
1146 }
1147 return tcal ;
1148 }
1149// else if ( scrow->isTcalExists() ) {
1150// vector<Temperature> tcalScalar = scrow->getTcal() ;
1151// unsigned int numReceptor = tcalScalar.size() ;
1152// vector< vector<float> > tcal( numReceptor, vector<float>( 1, 1.0 ) ) ;
1153// for ( unsigned int ir = 0 ; ir < numReceptor ; ir++ )
1154// tcal[ir][0] = tcalScalar[ir][0].get() ;
1155// return tcal ;
1156// }
1157 else {
1158 return defaultTcal ;
1159 }
1160}
1161
1162void OldASDMReader::getTcalAndTsys( unsigned int idx,
1163 vector< vector<float> > &tcal,
1164 vector< vector<float> > &tsys )
1165{
[2301]1166 prepareData( idx ) ;
1167 getTcalAndTsys( tcal, tsys ) ;
1168}
1169
1170void OldASDMReader::getTcalAndTsys( vector< vector<float> > &tcal,
1171 vector< vector<float> > &tsys )
1172{
[2273]1173 String funcName = "getTcalAndTsys" ;
1174
1175 vector< vector<float> > defaultT( 1, vector<float>( 1, 1.0 ) ) ;
[2301]1176 SysCalRow *scrow = getSysCalRow() ;
[2273]1177 if ( scrow == 0 ) {
1178 tcal = defaultT ;
1179 tsys = defaultT ;
1180 }
1181 else {
1182 if ( scrow->isTsysSpectrumExists() ) {
1183 vector< vector<Temperature> > tsysSpec = scrow->getTsysSpectrum() ;
1184 unsigned int numReceptor = tsysSpec.size() ;
1185 unsigned int numChan = tsysSpec[0].size() ;
1186 tsys.resize( numReceptor ) ;
1187 for ( unsigned int ir = 0 ; ir < numReceptor ; ir++ ) {
1188 tsys[ir].resize( numChan ) ;
1189 for ( unsigned int ic = 0 ; ic < numChan ; ic++ ) {
1190 tsys[ir][ic] = tsysSpec[ir][ic].get() ;
1191 }
1192 }
1193 }
1194 else {
1195 tsys = defaultT ;
1196 }
1197 if ( scrow->isTcalSpectrumExists() ) {
1198 vector< vector<Temperature> > tcalSpec = scrow->getTcalSpectrum() ;
1199 unsigned int numReceptor = tcalSpec.size() ;
1200 unsigned int numChan = tcalSpec[0].size() ;
1201 tcal.resize( numReceptor ) ;
1202 for ( unsigned int ir = 0 ; ir < numReceptor ; ir++ ) {
[2355]1203 tcal[ir].resize( numChan ) ;
[2273]1204 for ( unsigned int ic = 0 ; ic < numChan ; ic++ ) {
1205 tcal[ir][ic] = tcalSpec[ir][ic].get() ;
1206 }
1207 }
1208 }
1209 else {
1210 tcal = defaultT ;
1211 }
1212 }
1213}
1214
1215vector<float> OldASDMReader::getOpacity( unsigned int idx )
1216{
[2301]1217 prepareData( idx ) ;
1218 return getOpacity() ;
1219}
1220
1221vector<float> OldASDMReader::getOpacity()
1222{
[2273]1223 vector<float> tau(0) ;
1224 CalAtmosphereTable &atmtab = asdm_->getCalAtmosphere() ;
1225 unsigned int nrow = atmtab.size() ;
1226 if ( nrow > 0 ) {
1227 //int feedid = vmsData_->v_feedId1[index] ;
1228 //BasebandName bbname = spwrow->getBasebandName() ;
1229 //FeedRow *frow = asdm_->getFeed().getRowByKey( atag, spwtag, tint, feedid ) ;
1230 //int nfeed = frow->getNumReceptor() ;
1231 //vector<ReceiverRow *> rrows = frow->getReceivers() ;
1232 vector<CalAtmosphereRow *> atmrows = atmtab.get() ;
1233 //ReceiverBand rb = rrows[0]->getFrequencyBand() ;
1234 int row0 = -1 ;
[2307]1235 //double eps = DBL_MAX ;
1236 double eps = 1.0e10 ;
[2273]1237 for ( unsigned int irow = 0 ; irow < nrow ; irow++ ) {
1238 CalAtmosphereRow *atmrow = atmrows[irow] ;
[3106]1239 if ( casacore::String(atmrow->getAntennaName()) != antennaName_
[2273]1240 //|| atmrow->getReceiverBand() != rb
1241 //|| atmrow->getBasebandName() != bbname
1242 || atmrow->getCalDataUsingCalDataId()->getCalType() != CAL_ATMOSPHERE )
1243 continue ;
1244 else {
[2301]1245 double dt = timeInterval_.getStart().getMJD() - atmrow->getEndValidTime().getMJD() ;
[2273]1246 if ( dt >= 0 && dt < eps ) {
1247 eps = dt ;
1248 row0 = (int)irow ;
1249 }
1250 }
1251 }
1252 if ( row0 != -1 ) {
1253 CalAtmosphereRow *atmrow = atmrows[row0] ;
1254 tau = atmrow->getTau() ;
1255 }
1256 }
1257 else {
1258 tau.resize( 1 ) ;
1259 tau[0] = 0.0 ;
1260 }
1261 return tau ;
1262}
1263
1264void OldASDMReader::getWeatherInfo( unsigned int idx,
1265 float &temperature,
1266 float &pressure,
1267 float &humidity,
1268 float &windspeed,
1269 float &windaz )
1270{
[2301]1271 prepareData( idx ) ;
1272 getWeatherInfo( temperature, pressure, humidity, windspeed, windaz ) ;
1273}
1274
1275void OldASDMReader::getWeatherInfo( float &temperature,
1276 float &pressure,
1277 float &humidity,
1278 float &windspeed,
1279 float &windaz )
1280{
[3106]1281 casacore::String funcName = "getWeatherInfo" ;
[2273]1282
1283 temperature = 0.0 ;
1284 pressure = 0.0 ;
1285 humidity = 0.0 ;
1286 windspeed = 0.0 ;
1287 windaz = 0.0 ;
1288
1289 //logsink_->postLocally( LogMessage("weatherStationId_ = "+String::toString(weatherStationId_),LogOrigin(className_,funcName,WHERE)) ) ;
1290
1291 WeatherTable &wtab = asdm_->getWeather() ;
1292 if ( wtab.size() == 0 || weatherStationId_ == -1 )
1293 return ;
1294
1295 Tag sttag( (unsigned int)weatherStationId_, TagType::Station ) ;
1296 //WeatherRow *wrow = wtab.getRowByKey( sttag, tint ) ;
1297 vector<WeatherRow *> *wrows = wtab.getByContext( sttag ) ;
1298 WeatherRow *wrow = (*wrows)[0] ;
1299 unsigned int nrow = wrows->size() ;
1300 //logsink_->postLocally( LogMessage("There are "+String::toString(nrow)+" rows for given context: stationId "+String::toString(weatherStationId_),LogOrigin(className_,funcName,WHERE)) ) ;
[2301]1301 ArrayTime startTime = getMidTime( timeInterval_ ) ;
[2273]1302 if ( startTime < (*wrows)[0]->getTimeInterval().getStart() ) {
1303 temperature = (*wrows)[0]->getTemperature().get() ;
1304 pressure = (*wrows)[0]->getPressure().get() ;
1305 humidity = (*wrows)[0]->getRelHumidity().get() ;
1306 windspeed = (*wrows)[0]->getWindSpeed().get() ;
1307 windaz = (*wrows)[0]->getWindDirection().get() ;
1308 }
1309 else if ( startTime > getEndTime( (*wrows)[nrow-1]->getTimeInterval() ) ) {
1310 temperature = (*wrows)[nrow-1]->getTemperature().get() ;
1311 pressure = (*wrows)[nrow-1]->getPressure().get() ;
1312 humidity = (*wrows)[nrow-1]->getRelHumidity().get() ;
1313 windspeed = (*wrows)[nrow-1]->getWindSpeed().get() ;
1314 windaz = (*wrows)[nrow-1]->getWindDirection().get() ;
1315 }
1316 else {
1317 for ( unsigned int irow = 1 ; irow < wrows->size() ; irow++ ) {
1318 wrow = (*wrows)[irow-1] ;
1319 ArrayTime tStart = wrow->getTimeInterval().getStart() ;
1320 ArrayTime tEnd = (*wrows)[irow]->getTimeInterval().getStart() ;
1321 if ( startTime >= tStart && startTime <= tEnd ) {
1322 temperature = wrow->getTemperature().get() ;
1323 pressure = wrow->getPressure().get() ;
1324 humidity = wrow->getRelHumidity().get() ;
1325 windspeed = wrow->getWindSpeed().get() ;
1326 windaz = wrow->getWindDirection().get() ;
1327 break ;
1328 }
1329 }
1330 }
1331
1332 // Pa -> hPa
1333 pressure /= 100.0 ;
1334
1335 return ;
1336}
1337
1338void OldASDMReader::processStation()
1339{
1340 antennaPad_.resize(0) ;
1341 weatherStation_.resize(0) ;
1342 StationTable &stab = asdm_->getStation() ;
1343 vector<StationRow *> srows = stab.get() ;
1344 for ( unsigned int irow = 0 ; irow < srows.size() ; irow++ ) {
1345 StationType stype = srows[irow]->getType() ;
1346 Tag stag = srows[irow]->getStationId() ;
1347 if ( stype == ANTENNA_PAD )
1348 antennaPad_.push_back( stag ) ;
1349 else if ( stype == WEATHER_STATION )
1350 weatherStation_.push_back( stag ) ;
1351 }
1352
1353 weatherStationId_ = getClosestWeatherStation() ;
1354}
1355
1356int OldASDMReader::getClosestWeatherStation()
1357{
1358 if ( weatherStation_.size() == 0 )
1359 return -1 ;
1360
1361 vector<double> apos( 3 ) ;
1362 StationTable &stab = asdm_->getStation() ;
[2301]1363 apos[0] = antennaPosition_[0].getValue( Unit("m") ) ;
1364 apos[1] = antennaPosition_[1].getValue( Unit("m") ) ;
1365 apos[2] = antennaPosition_[2].getValue( Unit("m") ) ;
[2273]1366
[2307]1367 //double eps = DBL_MAX ;
1368 double eps = 1.0e10 ;
[2273]1369 int retval = -1 ;
1370 for ( unsigned int ir = 0 ; ir < weatherStation_.size() ; ir++ ) {
[2301]1371 StationRow *srow = stab.getRowByKey( weatherStation_[ir] ) ;
[2273]1372 vector<Length> wpos = srow->getPosition() ;
1373 double dist = (apos[0]-wpos[0].get())*(apos[0]-wpos[0].get())
1374 + (apos[1]-wpos[1].get())*(apos[1]-wpos[1].get())
1375 + (apos[2]-wpos[2].get())*(apos[2]-wpos[2].get()) ;
1376 if ( dist < eps ) {
1377 retval = (int)(weatherStation_[ir].getTagValue()) ;
1378 }
1379 }
1380
1381 return retval ;
1382}
1383
1384void OldASDMReader::getPointingInfo( unsigned int idx,
1385 vector<double> &dir,
1386 double &az,
1387 double &el,
1388 vector<double> &srate )
1389{
[2301]1390 prepareData( idx ) ;
1391 getPointingInfo( dir, az, el, srate ) ;
1392}
1393
1394void OldASDMReader::getPointingInfo( vector<double> &dir,
1395 double &az,
1396 double &el,
1397 vector<double> &srate )
1398{
[2273]1399 String funcName = "getPointingInfo" ;
1400
1401 dir.resize(0) ;
1402 az = -1.0 ;
1403 el = -1.0 ;
1404 srate.resize(0) ;
1405
[2301]1406 //Tag atag( antennaId_, TagType::Antenna ) ;
1407 //unsigned int index = dataIdList_[idx] ;
1408 //vector<PointingRow *> *prows = asdm_->getPointing().getByContext( atag ) ;
1409 vector<PointingRow *> *prows = asdm_->getPointing().getByContext( antennaTag_ ) ;
[2273]1410
1411 if ( prows == 0 )
1412 return ;
1413
1414 PointingRow *prow ;
1415 PointingRow *qrow ;
1416 //ArrayTimeInterval tint( vmsData_->v_time[index]*s2d, vmsData_->v_interval[index]*s2d ) ;
[2301]1417 //double startSec = vmsData_->v_time[index] - 0.5 * vmsData_->v_interval[index] ;
1418 //ArrayTimeInterval tint( startSec*s2d, vmsData_->v_interval[index]*s2d ) ;
[2273]1419
1420 unsigned int nrow = prows->size() ;
1421 //logsink_->postLocally( LogMessage("There are " << nrow << " rows for given context: antennaId "+String::toString(antennaId_),LogOrigin(className_,funcName,WHERE)) ) ;
1422
1423// for ( unsigned int irow = 0 ; irow < nrow ; irow++ ) {
1424// prow = (*prows)[irow] ;
1425// ArrayTimeInterval ati = prow->getTimeInterval() ;
1426// ArrayTime pst = ati.getStart() ;
1427// ArrayTime pet( ati.getStartInMJD()+ati.getDurationInDays() ) ;
1428// logsink_->postLocally( LogMessage("start: "+pst.toFITS(),LogOrigin(className_,funcName,WHERE)) ) ;
1429// logsink_->postLocally( LogMessage("end: "+pet.toFITS(),LogOrigin(className_,funcName,WHERE)) ) ;
1430// }
1431
1432 srate.resize(2) ;
1433 srate[0] = 0.0 ;
1434 srate[1] = 0.0 ;
1435 az = 0.0 ;
1436 el = 0.0 ;
1437 //double tcen = 0.0 ;
[2301]1438 //double tcen = getMidTime( tint ).getMJD() ;
1439 double tcen = getMidTime( timeInterval_ ).getMJD() ;
[2273]1440
1441 //
1442 // shape of pointingDirection is (numSample,2) if usePolynomial = False, while it is
1443 // (numTerm,2) if usePolynomial = True.
1444 //
1445 // In the former case, typical sampled time interval is 48msec, which is very small
1446 // compared with typical integration time (~a few sec).
1447 // Scan rate for this case is always [0,0] (or get slope?).
1448 //
1449 // In the later case, scan rate is (pointingDirection[1][0],pointingDirection[1][1])
1450 //
1451 // PointingDirection seems to store AZEL
1452 //
1453 ArrayTimeInterval pTime0 = (*prows)[0]->getTimeInterval() ;
1454 ArrayTimeInterval pTime1 = (*prows)[nrow-1]->getTimeInterval() ;
1455 //if ( tint.getStartInMJD()+tint.getDurationInDays() < pTime0.getStartInMJD() ) {
[2301]1456 //if ( getEndTime( tint ) < getStartTime( pTime0 ) ) {
1457 if ( getEndTime( timeInterval_ ) < getStartTime( pTime0 ) ) {
[2273]1458 logsink_->postLocally( LogMessage( "ArrayTimeInterval out of bounds: no data for given position (tint < ptime)", LogOrigin(className_,funcName,WHERE), LogMessage::WARN ) ) ;
1459 prow = (*prows)[0] ;
1460 vector< vector<double> > dirA = pointingDir( prow ) ;
1461 az = dirA[0][0] ;
1462 el = dirA[0][1] ;
1463 if ( prow->getUsePolynomials() && prow->getNumTerm() > 1 ) {
1464 srate[0] = dirA[1][0] ;
1465 srate[1] = dirA[1][1] ;
1466 }
1467 }
1468 //else if ( tint.getStartInMJD() > pTime1.getStartInMJD()+pTime1.getDurationInDays() ) {
[2301]1469 //else if ( getStartTime( tint ) > getEndTime( pTime1 ) ) {
1470 else if ( getStartTime( timeInterval_ ) > getEndTime( pTime1 ) ) {
[2273]1471 logsink_->postLocally( LogMessage( "ArrayTimeInterval out of bounds: no data for given position (tint > ptime)", LogOrigin(className_,funcName,WHERE), LogMessage::WARN ) ) ;
1472 prow = (*prows)[nrow-1] ;
1473 int numSample = prow->getNumSample() ;
1474 vector< vector<double> > dirA = pointingDir( prow ) ;
1475 if ( prow->getUsePolynomials() ) {
1476 az = dirA[0][0] ;
1477 el = dirA[0][1] ;
1478 if ( prow->getNumTerm() > 1 ) {
1479 srate[0] = dirA[1][0] ;
1480 srate[1] = dirA[1][1] ;
1481 }
1482 }
1483 else {
1484 az = dirA[numSample-1][0] ;
1485 el = dirA[numSample-1][1] ;
1486 }
1487 }
1488 else {
[2301]1489 //ArrayTime startTime = tint.getStart() ;
1490 //ArrayTime endTime = getEndTime( tint ) ;
1491 ArrayTime startTime = timeInterval_.getStart() ;
1492 ArrayTime endTime = getEndTime( timeInterval_ ) ;
[2273]1493 int row0 = -1 ;
1494 int row1 = -1 ;
1495 int row2 = -1 ;
[2301]1496 //double dt0 = getMidTime( tint ).getMJD() ;
1497 double dt0 = getMidTime( timeInterval_ ).getMJD() ;
[2273]1498 for ( unsigned int irow = 0 ; irow < nrow ; irow++ ) {
1499 prow = (*prows)[irow] ;
[2301]1500 //double dt = getMidTime( tint ).getMJD() - getMidTime( prow->getTimeInterval() ).getMJD() ;
1501 double dt = getMidTime( timeInterval_ ).getMJD() - getMidTime( prow->getTimeInterval() ).getMJD() ;
[2273]1502 if ( dt > 0 && dt < dt0 ) {
1503 dt0 = dt ;
1504 row2 = irow ;
1505 }
1506 if ( prow->getTimeInterval().contains( startTime ) )
1507 row0 = irow ;
1508 else if ( prow->getTimeInterval().contains( endTime ) )
1509 row1 = irow ;
1510 if ( row0 != -1 && row1 != -1 )
1511 break ;
1512 }
1513 //logsink_->postLocally( LogMessage("row0 = "+String::toString(row0)+", row1 = "+String::toString(row1)+", row2 = "+String::toString(row2),LogOrigin(className_,funcName,WHERE)) ) ;
1514 if ( row0 == -1 && row1 == -1 ) {
1515 prow = (*prows)[row2] ;
1516 qrow = (*prows)[row2+1] ;
1517 double t0 = getEndTime( prow->getTimeInterval() ).getMJD() ;
1518 double t1 = qrow->getTimeInterval().getStartInMJD() ;
1519 vector< vector<double> > dirA = pointingDir( prow ) ;
1520 vector< vector<double> > dirB = pointingDir( qrow ) ;
1521 double da0 = dirA[0][0] ;
1522 double db0 = dirB[0][0] ;
1523 double da1 = dirA[0][1] ;
1524 double db1 = dirB[0][1] ;
1525 if ( prow->getUsePolynomials() && qrow->getUsePolynomials() ) {
1526 double dt = ( tcen - t0 ) / ( t1 - t0 ) ;
1527 az = da0 + ( db0 - da0 ) * dt ;
1528 el = da1 + ( db1 - da1 ) * dt ;
1529 if ( prow->getNumTerm() > 0 && qrow->getNumTerm() > 1 ) {
1530 double ra0 = dirA[1][0] ;
1531 double rb0 = dirB[1][0] ;
1532 double ra1 = dirA[1][1] ;
1533 double rb1 = dirB[1][1] ;
1534 srate[0] = ra0 + ( rb0 - ra0 ) * dt ;
1535 srate[1] = ra1 + ( rb1 - ra1 ) * dt ;
1536 }
1537 }
1538 else if ( !(qrow->getUsePolynomials()) ) {
1539 double dt = ( tcen - t0 ) / ( t1 - t0 ) ;
1540 az = da0 + ( db0 - da0 ) * dt ;
1541 el = da1 + ( db1 - da1 ) * dt ;
1542 }
1543 //else {
1544 // nothing to do
1545 //}
1546 }
1547 else {
1548 int ndir = 0 ;
1549 if ( row0 == -1 ) {
1550 row0 = row1 ;
1551 }
1552 else if ( row1 == -1 ) {
1553 row1 = row0 ;
1554 }
1555 prow = (*prows)[row0] ;
1556 qrow = (*prows)[row1] ;
1557 if ( prow->getUsePolynomials() && qrow->getUsePolynomials() ) {
1558 //logsink_->postLocally( LogMessage("usePolynomial = True",LogOrigin(className_,funcName,WHERE)) ) ;
1559 if ( row0 == row1 ) {
1560 prow = (*prows)[row0] ;
1561 vector< vector<double> > dirA = pointingDir( prow ) ;
1562 az = dirA[0][0] ;
1563 el = dirA[0][1] ;
1564 if ( prow->getNumTerm() > 1 ) {
1565 srate[0] = dirA[1][0] ;
1566 srate[1] = dirA[1][1] ;
1567 }
1568 }
1569 else {
1570 prow = (*prows)[row0] ;
1571 qrow = (*prows)[row1] ;
1572 vector< vector<double> > dirA = pointingDir( prow ) ;
1573 vector< vector<double> > dirB = pointingDir( qrow ) ;
1574 double t0 = getMidTime( prow->getTimeInterval() ).getMJD() ;
1575 double t1 = getMidTime( qrow->getTimeInterval() ).getMJD() ;
1576 double dt = ( tcen - t0 ) / ( t1 - t0 ) ;
1577 double da0 = dirA[0][0] ;
1578 double db0 = dirB[0][0] ;
1579 double da1 = dirA[0][1] ;
1580 double db1 = dirB[0][1] ;
1581 az = da0 + ( db0 - da0 ) * dt ;
1582 el = da1 + ( db1 - db0 ) * dt ;
1583 if ( prow->getNumTerm() > 0 && qrow->getNumTerm() > 1 ) {
1584 double ra0 = dirA[1][0] ;
1585 double rb0 = dirB[1][0] ;
1586 double ra1 = dirA[1][1] ;
1587 double rb1 = dirB[1][1] ;
1588 srate[0] = ra0 + ( rb0 - ra0 ) * dt ;
1589 srate[1] = ra1 + ( rb1 - ra1 ) * dt ;
1590 }
1591 }
1592 }
1593 else if ( prow->getUsePolynomials() == qrow->getUsePolynomials() ) {
1594 //logsink_->postLocally( LogMessage("numSample == numTerm",LogOrigin(className_,funcName,WHERE)) ) ;
1595 tcen = 0.0 ;
1596 for ( int irow = row0 ; irow <= row1 ; irow++ ) {
1597 prow = (*prows)[irow] ;
1598 int numSample = prow->getNumSample() ;
1599 //logsink_->postLocally( LogMessage("numSample = "+String::toString(numSample),LogOrigin(className_,funcName,WHERE)) ) ;
1600 vector< vector<double> > dirA = pointingDir( prow ) ;
1601 if ( prow->isSampledTimeIntervalExists() ) {
1602 //logsink_->postLocally( LogMessage("sampledTimeIntervalExists",LogOrigin(className_,funcName,WHERE)) ) ;
1603 vector<ArrayTimeInterval> stime = prow->getSampledTimeInterval() ;
1604 for ( int isam = 0 ; isam < numSample ; isam++ ) {
1605 //if ( tint.overlaps( stime[isam] ) ) {
[2301]1606 //if ( tint.contains( stime[isam] ) ) {
1607 if ( timeInterval_.contains( stime[isam] ) ) {
[2273]1608 az += dirA[isam][0] ;
1609 el += dirA[isam][1] ;
1610 tcen += getMidTime( stime[isam] ).getMJD() ;
1611 ndir++ ;
1612 }
1613 }
1614 }
1615 else {
1616 double sampleStart = prow->getTimeInterval().getStartInMJD() ;
1617 double sampleInterval = prow->getTimeInterval().getDurationInDays() / (double)numSample ;
1618 //logsink_->postLocally( LogMessage("sampleStart = "+String::toString(sampleStart),LogOrigin(className_,funcName,WHERE)) )
1619 //logsink_->postLocally( LogMessage("sampleInterval = "+String::toString(sampleInterval),LogOrigin(className_,funcName,WHERE)) ) ;
1620 //logsink_->postLocally( LogMessage("tint = "+tint.toString(),LogOrigin(className_,funcName,WHERE)) ) ;
1621 for ( int isam = 0 ; isam < numSample ; isam++ ) {
1622 ArrayTimeInterval stime( sampleStart+isam*sampleInterval, sampleInterval ) ;
1623 //if ( tint.overlaps( stime ) ) {
[2301]1624 //if ( tint.contains( stime ) ) {
1625 if ( timeInterval_.contains( stime ) ) {
[2273]1626 az += dirA[isam][0] ;
1627 el += dirA[isam][1] ;
1628 tcen += getMidTime( stime ).getMJD() ;
1629 ndir++ ;
1630 }
1631 }
1632 }
1633 }
1634 if ( ndir > 1 ) {
1635 az /= (double)ndir ;
1636 el /= (double)ndir ;
1637 tcen /= (double)ndir ;
1638 }
1639 }
1640 //else {
1641 // nothing to do
1642 //}
1643 }
1644
[2301]1645 toJ2000( dir, az, el, tcen, antennaPosition_ ) ;
[2273]1646 }
1647
1648 return ;
1649}
1650
1651ArrayTime OldASDMReader::getMidTime( const ArrayTimeInterval &t )
1652{
1653 return ArrayTime( t.getStartInMJD() + 0.5 * t.getDurationInDays() ) ;
1654}
1655
1656ArrayTime OldASDMReader::getEndTime( const ArrayTimeInterval &t )
1657{
1658 return ArrayTime( t.getStartInMJD() + t.getDurationInDays() ) ;
1659}
1660
1661ArrayTime OldASDMReader::getStartTime( const ArrayTimeInterval &t )
1662{
1663 return ArrayTime( t.getStartInMJD() ) ;
1664}
1665
1666void OldASDMReader::toJ2000( vector<double> &dir,
[2301]1667 double &az,
1668 double &el,
1669 double &mjd,
[3106]1670 casacore::Vector<casacore::Quantity> &antpos )
1671// casacore::Vector<casacore::Double> antpos )
[2273]1672{
1673 String funcName = "toJ2000" ;
1674
[2301]1675 String ref = "AZELGEO" ;
[2273]1676 vector<double> azel( 2 ) ;
1677 azel[0] = az ;
1678 azel[1] = el ;
[2301]1679 dir = toJ2000( azel, ref, mjd, antpos ) ;
[2273]1680}
1681
[2301]1682vector<double> OldASDMReader::toJ2000( vector<double> &dir,
[3106]1683 casacore::String &dirref,
[2301]1684 double &mjd,
[3106]1685 casacore::Vector<casacore::Quantity> &antpos )
1686// casacore::Vector<casacore::Double> antpos )
[2273]1687{
[3106]1688 casacore::String funcName = "toJ2000" ;
[2273]1689
1690 vector<double> newd( dir ) ;
1691 if ( dirref != "J2000" ) {
[3106]1692 casacore::MEpoch me( casacore::Quantity( (casacore::Double)mjd, "d" ), casacore::MEpoch::UTC ) ;
1693 casacore::MPosition mp( casacore::MVPosition( antpos ),
1694 casacore::MPosition::ITRF ) ;
[2273]1695 //ostringstream oss ;
1696 //mp.print( oss ) ;
1697 //logsink_->postLocally( LogMessage(oss.str(),LogOrigin(className_,funcName,WHERE)) ) ;
1698
[3106]1699 casacore::MeasFrame mf( me, mp ) ;
1700 casacore::MDirection::Types dirtype ;
1701 casacore::Bool b = casacore::MDirection::getType( dirtype, dirref ) ;
[2273]1702 if ( b ) {
[3106]1703 casacore::MDirection::Convert toj2000( dirtype,
1704 casacore::MDirection::Ref( casacore::MDirection::J2000, mf ) ) ;
1705 casacore::Vector<casacore::Double> cdir = toj2000( dir ).getAngle( "rad" ).getValue() ;
[2273]1706 //logsink_->postLocally( LogMessage("cdir = "+String::toString(cdir),LogOrigin(className_,funcName,WHERE)) ) ;
1707 newd[0] = (double)(cdir[0]) ;
1708 newd[1] = (double)(cdir[1]) ;
1709 }
1710 }
1711 return newd ;
1712}
1713
1714void OldASDMReader::setLogger( CountedPtr<LogSinkInterface> &logsink )
1715{
1716 logsink_ = logsink ;
1717}
1718
1719string OldASDMReader::getFrame()
1720{
[3106]1721 casacore::String funcName = "getFrame" ;
[2273]1722
1723 // default is TOPO
1724 string frame = "TOPO" ;
1725
1726 SpectralWindowTable &spwtab = asdm_->getSpectralWindow() ;
1727 vector<SpectralWindowRow *> rows = spwtab.get() ;
1728 vector<FrequencyReferenceCode> measFreqRef( rows.size() ) ;
1729 int nref = 0 ;
1730 for ( unsigned int irow = 0 ; irow < rows.size() ; irow++ ) {
1731 int nchan = rows[irow]->getNumChan() ;
1732 if ( nchan != 4 ) {
1733 if ( rows[irow]->isMeasFreqRefExists() ) {
1734 measFreqRef[nref] = rows[irow]->getMeasFreqRef() ;
1735 nref++ ;
1736 }
1737 }
1738 }
1739 if ( nref != 0 ) {
1740 frame = CFrequencyReferenceCode::toString( measFreqRef[0] ) ;
1741 }
1742
1743 //logsink_->postLocally( LogMessage("frame = "+String::toString(frame),LogOrigin(className_,funcName,WHERE)) ) ;
1744
1745 return frame ;
1746}
1747
1748int OldASDMReader::getNumIFs()
1749{
[3106]1750 casacore::String funcName = "getNumIFs" ;
[2273]1751
1752 int nif = 0 ;
1753 vector<SpectralWindowRow *> rows = asdm_->getSpectralWindow().get() ;
1754 unsigned int nrow = rows.size() ;
1755 // check if all rows have freqGroup attribute
1756 bool freqGroupExists = true ;
1757 bool countedWvr = false ;
1758 for ( unsigned int irow = 0 ; irow < nrow ; irow++ ) {
1759 freqGroupExists &= rows[irow]->isFreqGroupExists() ;
1760 if ( rows[irow]->getNumChan() == 4 ) {
1761 if ( !countedWvr ) {
1762 countedWvr = true ;
1763 nif++ ;
1764 }
1765 }
1766 else {
1767 nif++ ;
1768 }
1769 }
1770
1771 if ( freqGroupExists ) {
1772 vector<int> freqGroup(0) ;
1773 for ( unsigned int irow = 0 ; irow < nrow ; irow++ ) {
1774 int fg = rows[irow]->getFreqGroup() ;
1775 if ( (int)count( freqGroup.begin(), freqGroup.end(), fg ) == 0 ) {
1776 freqGroup.push_back( fg ) ;
1777 }
1778 }
1779 nif = freqGroup.size() ;
1780 }
1781
1782 //logsink_->postLocally( LogMessage("nif = "+String::toString(nif),LogOrigin(className_,funcName,WHERE)) ) ;
1783
1784 return nif ;
1785}
1786
1787SysCalRow *OldASDMReader::getSysCalRow( unsigned int idx )
1788{
[2301]1789 prepareData( idx ) ;
1790 return getSysCalRow() ;
1791}
1792
1793SysCalRow *OldASDMReader::getSysCalRow()
1794{
[2273]1795 String funcName = "getSysCalRow" ;
1796
1797 SysCalRow *row = 0 ;
[2301]1798 int feedid = vmsData_->v_feedId1[dataIndex_] ;
[2273]1799 SysCalTable &sctab = asdm_->getSysCal() ;
[2301]1800 vector<SysCalRow *> *rows = sctab.getByContext( antennaTag_, specWinTag_, feedid ) ;
[2273]1801 //if ( nrow == 0 ) {
1802 if ( rows == 0 ) {
1803 //logsink_->postLocally( LogMessage("no rows in SysCal table",LogOrigin(className_,funcName,WHERE)) ) ;
1804 row = 0 ;
1805 }
1806 else {
1807 unsigned int nrow = rows->size() ;
1808 //logsink_->postLocally( LogMessage("nrow = "+String::toString(nrow),LogOrigin(className_,funcName,WHERE)) ) ;
1809 int scindex = -1 ;
1810 if ( nrow == 1 ) {
1811 scindex = 0 ;
1812 }
[2301]1813 else if ( getEndTime( timeInterval_ ) <= getStartTime( (*rows)[0]->getTimeInterval() ) )
[2273]1814 scindex = 0 ;
1815 else {
1816 for ( unsigned int irow = 0 ; irow < nrow-1 ; irow++ ) {
[2301]1817 ArrayTime t = getMidTime( timeInterval_ ) ;
[2273]1818 if ( t > getStartTime( (*rows)[irow]->getTimeInterval() )
1819 && t <= getStartTime( (*rows)[irow+1]->getTimeInterval() ) ) {
1820 scindex = irow ;
1821 break ;
1822 }
1823 }
1824 if ( scindex == -1 )
1825 scindex = nrow-1 ;
1826 }
1827 //logsink_->postLocally( LogMessage("irow = "+String::toString(scindex),LogOrigin(className_,funcName,WHERE)) ) ;
1828 row = (*rows)[scindex] ;
1829 }
1830 return row ;
1831}
1832
1833double OldASDMReader::limitedAngle( double angle )
1834{
1835 if ( angle > C::pi )
1836 while ( angle > C::pi ) angle -= C::_2pi ;
1837 else if ( angle < -C::pi )
1838 while ( angle < -C::pi ) angle += C::_2pi ;
1839 return angle ;
1840}
1841
1842vector< vector<double> > OldASDMReader::pointingDir( PointingRow *row )
1843{
[2301]1844 //String funcName = "pointingDir" ;
[2273]1845 vector< vector<Angle> > aTar = row->getTarget() ;
1846 vector< vector<Angle> > aOff = row->getOffset() ;
1847 vector< vector<Angle> > aDir = row->getPointingDirection() ;
1848 vector< vector<Angle> > aEnc = row->getEncoder() ;
1849 unsigned int n = aTar.size() ;
1850 vector< vector<double> > dir( n ) ;
1851 double factor = 1.0 / cos( aTar[0][1].get() ) ;
1852 for ( unsigned int i = 0 ; i < n ; i++ ) {
1853 dir[i].resize( 2 ) ;
1854 /**
1855 * This is approximate way to add offset taking tracking error
1856 * into account
1857 *
1858 * az = dir[0][0] = target[0][0] + offset[0][0] / cos(el)
1859 * + encorder[0][0] - direction[0][0]
1860 * el = dir[0][1] = target[0][1] + offset[0][1]
1861 * + encorder[0][1] - direction[0][1]
1862 **/
1863 dir[i][0] = aTar[i][0].get() + factor * aOff[i][0].get()
1864 + aEnc[i][0].get() - aDir[i][0].get() ;
1865 dir[i][1] = aTar[i][1].get() + aOff[i][1].get()
1866 + aEnc[i][1].get() - aDir[i][1].get() ;
[2301]1867 //logsink_->postLocally( LogMessage("tracking offset: ["+String::toString(aEnc[i][0].get()-aDir[i][0].get())+","+String::toString(aEnc[i][0]-aDir[i][0].get())+"]",LogOrigin(className_,funcName,WHERE)) ) ;
[2273]1868 }
1869 return dir ;
1870}
Note: See TracBrowser for help on using the repository browser.