/* * ALMA - Atacama Large Millimeter Array * (c) European Southern Observatory, 2002 * (c) Associated Universities Inc., 2002 * Copyright by ESO (in the framework of the ALMA collaboration), * Copyright by AUI (in the framework of the ALMA collaboration), * All rights reserved. * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public * License as published by the Free software Foundation; either * version 2.1 of the License, or (at your option) any later version. * * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY, without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Lesser General Public License for more details. * * You should have received a copy of the GNU Lesser General Public * License along with this library; if not, write to the Free Software * Foundation, Inc., 59 Temple Place, Suite 330, Boston, * MA 02111-1307 USA * * Warning! * -------------------------------------------------------------------- * | This is generated code! Do not modify this file. | * | If you do, all changes will be lost when the file is re-generated. | * -------------------------------------------------------------------- * * File GainTrackingTable.cpp */ #include #include #include using asdm::ConversionException; using asdm::DuplicateKey; using asdm::OutOfBoundsException; #include #include #include #include using asdm::ASDM; using asdm::GainTrackingTable; using asdm::GainTrackingRow; using asdm::Parser; #include #include #include #include #include #include using namespace std; #include using namespace asdm; #include #include #ifndef WITHOUT_BOOST #include "boost/filesystem/operations.hpp" #include #else #include #endif namespace asdm { // The name of the entity we will store in this table. static string entityNameOfGainTracking = "GainTracking"; // An array of string containing the names of the columns of this table. // The array is filled in the order : key, required value, optional value. // static string attributesNamesOfGainTracking_a[] = { "antennaId" , "spectralWindowId" , "timeInterval" , "feedId" , "numReceptor" , "attenuator" , "polarizationType" , "samplingLevel" , "numAttFreq" , "attFreq" , "attSpectrum" }; // A vector of string whose content is a copy of the strings in the array above. // static vector attributesNamesOfGainTracking_v (attributesNamesOfGainTracking_a, attributesNamesOfGainTracking_a + sizeof(attributesNamesOfGainTracking_a) / sizeof(attributesNamesOfGainTracking_a[0])); // An array of string containing the names of the columns of this table. // The array is filled in the order where the names would be read by default in the XML header of a file containing // the table exported in binary mode. // static string attributesNamesInBinOfGainTracking_a[] = { "antennaId" , "spectralWindowId" , "timeInterval" , "feedId" , "numReceptor" , "attenuator" , "polarizationType" , "samplingLevel" , "numAttFreq" , "attFreq" , "attSpectrum" }; // A vector of string whose content is a copy of the strings in the array above. // static vector attributesNamesInBinOfGainTracking_v(attributesNamesInBinOfGainTracking_a, attributesNamesInBinOfGainTracking_a + sizeof(attributesNamesInBinOfGainTracking_a) / sizeof(attributesNamesInBinOfGainTracking_a[0])); // The array of attributes (or column) names that make up key key. // string keyOfGainTracking_a[] = { "antennaId" , "spectralWindowId" , "timeInterval" , "feedId" }; // A vector of strings which are copies of those stored in the array above. vector keyOfGainTracking_v(keyOfGainTracking_a, keyOfGainTracking_a + sizeof(keyOfGainTracking_a) / sizeof(keyOfGainTracking_a[0])); /** * Return the list of field names that make up key key * as a const reference to a vector of strings. */ const vector& GainTrackingTable::getKeyName() { return keyOfGainTracking_v; } GainTrackingTable::GainTrackingTable(ASDM &c) : container(c) { // Define a default entity. entity.setEntityId(EntityId("uid://X0/X0/X0")); entity.setEntityIdEncrypted("na"); entity.setEntityTypeName("GainTrackingTable"); entity.setEntityVersion("1"); entity.setInstanceVersion("1"); // Archive XML archiveAsBin = false; // File XML fileAsBin = false; // By default the table is considered as present in memory presentInMemory = true; // By default there is no load in progress loadInProgress = false; } /** * A destructor for GainTrackingTable. */ GainTrackingTable::~GainTrackingTable() { for (unsigned int i = 0; i < privateRows.size(); i++) delete(privateRows.at(i)); } /** * Container to which this table belongs. */ ASDM &GainTrackingTable::getContainer() const { return container; } /** * Return the number of rows in the table. */ unsigned int GainTrackingTable::size() const { if (presentInMemory) return privateRows.size(); else return declaredSize; } /** * Return the name of this table. */ string GainTrackingTable::getName() const { return entityNameOfGainTracking; } /** * Return the name of this table. */ string GainTrackingTable::name() { return entityNameOfGainTracking; } /** * Return the the names of the attributes (or columns) of this table. */ const vector& GainTrackingTable::getAttributesNames() { return attributesNamesOfGainTracking_v; } /** * Return the the names of the attributes (or columns) of this table as they appear by default * in an binary export of this table. */ const vector& GainTrackingTable::defaultAttributesNamesInBin() { return attributesNamesInBinOfGainTracking_v; } /** * Return this table's Entity. */ Entity GainTrackingTable::getEntity() const { return entity; } /** * Set this table's Entity. */ void GainTrackingTable::setEntity(Entity e) { this->entity = e; } // // ====> Row creation. // /** * Create a new row. */ GainTrackingRow *GainTrackingTable::newRow() { return new GainTrackingRow (*this); } /** * Create a new row initialized to the specified values. * @return a pointer on the created and initialized row. * @param antennaId * @param spectralWindowId * @param timeInterval * @param feedId * @param numReceptor * @param attenuator * @param polarizationType */ GainTrackingRow* GainTrackingTable::newRow(Tag antennaId, Tag spectralWindowId, ArrayTimeInterval timeInterval, int feedId, int numReceptor, std::vector attenuator, std::vector polarizationType){ GainTrackingRow *row = new GainTrackingRow(*this); row->setAntennaId(antennaId); row->setSpectralWindowId(spectralWindowId); row->setTimeInterval(timeInterval); row->setFeedId(feedId); row->setNumReceptor(numReceptor); row->setAttenuator(attenuator); row->setPolarizationType(polarizationType); return row; } GainTrackingRow* GainTrackingTable::newRow(GainTrackingRow* row) { return new GainTrackingRow(*this, row); } // // Append a row to its table. // /** * Returns a string built by concatenating the ascii representation of the * parameters values suffixed with a "_" character. */ string GainTrackingTable::Key(Tag antennaId, Tag spectralWindowId, int feedId) { ostringstream ostrstr; ostrstr << antennaId.toString() << "_" << spectralWindowId.toString() << "_" << feedId << "_" ; return ostrstr.str(); } GainTrackingRow* GainTrackingTable::add(GainTrackingRow* x) { ArrayTime startTime = x->getTimeInterval().getStart(); /* * Is there already a context for this combination of not temporal * attributes ? */ string k = Key( x->getAntennaId() , x->getSpectralWindowId() , x->getFeedId() ); if (context.find(k) == context.end()) { // There is not yet a context ... // Create and initialize an entry in the context map for this combination.... TIME_ROWS v; context[k] = v; } return insertByStartTime(x, context[k]); } void GainTrackingTable::addWithoutCheckingUnique(GainTrackingRow * x) { GainTrackingRow * dummy = checkAndAdd(x, true); // We require the check for uniqueness to be skipped. // by passing true in the second parameter // whose value by default is false. // this statement is never executed, but it hides the unused return value from the compiler to silence that warning. if (false) cout << (unsigned long long) dummy; } // // A private method to append a row to its table, used by input conversion // methods, with row uniqueness. // GainTrackingRow* GainTrackingTable::checkAndAdd(GainTrackingRow* x, bool /* skipCheckUniqueness */ ) { string keystr = Key( x->getAntennaId() , x->getSpectralWindowId() , x->getFeedId() ); if (context.find(keystr) == context.end()) { vector v; context[keystr] = v; } vector& found = context.find(keystr)->second; return insertByStartTime(x, found); } // // A private method to brutally append a row to its table, without checking for row uniqueness. // void GainTrackingTable::append(GainTrackingRow *x) { privateRows.push_back(x); x->isAdded(true); } vector GainTrackingTable::get() { checkPresenceInMemory(); return privateRows; } const vector& GainTrackingTable::get() const { const_cast(*this).checkPresenceInMemory(); return privateRows; } vector *GainTrackingTable::getByContext(Tag antennaId, Tag spectralWindowId, int feedId) { //if (getContainer().checkRowUniqueness() == false) //throw IllegalAccessException ("The method 'getByContext' can't be called because the dataset has been built without checking the row uniqueness.", "GainTrackingTable"); checkPresenceInMemory(); string k = Key(antennaId, spectralWindowId, feedId); if (context.find(k) == context.end()) return 0; else return &(context[k]); } /* ** Returns a GainTrackingRow* given a key. ** @return a pointer to the row having the key whose values are passed as parameters, or 0 if ** no row exists for that key. ** */ GainTrackingRow* GainTrackingTable::getRowByKey(Tag antennaId, Tag spectralWindowId, ArrayTimeInterval timeInterval, int feedId) { checkPresenceInMemory(); string keystr = Key(antennaId, spectralWindowId, feedId); vector row; if ( context.find(keystr) == context.end()) return 0; row = context[keystr]; // Is the vector empty...impossible in principle ! if (row.size() == 0) return 0; // Only one element in the vector if (row.size() == 1) { GainTrackingRow* r = row.at(0); if ( r->getTimeInterval().contains(timeInterval.getStart())) return r; else return 0; } // Optimizations GainTrackingRow* last = row.at(row.size()-1); if (timeInterval.getStart().get() >= (last->getTimeInterval().getStart().get()+last->getTimeInterval().getDuration().get())) return 0; GainTrackingRow* first = row.at(0); if (timeInterval.getStart().get() < first->getTimeInterval().getStart().get()) return 0; // More than one row // Let's use a dichotomy method for the general case.. int k0 = 0; int k1 = row.size() - 1; GainTrackingRow* r = 0; while (k0!=k1) { // Is the start time contained in the time interval of row #k0 r = row.at(k0); if (r->getTimeInterval().contains(timeInterval.getStart())) return r; // Is the start contained in the time interval of row #k1 r = row.at(k1); if (r->getTimeInterval().contains(timeInterval.getStart())) return r; // Are the rows #k0 and #k1 consecutive // Then we know for sure that there is no row containing the start of timeInterval if (k1==(k0+1)) return 0; // Proceed to the next step of dichotomy. r = row.at((k0+k1)/2); if ( timeInterval.getStart().get() <= r->getTimeInterval().getStart().get()) k1 = (k0 + k1) / 2; else k0 = (k0 + k1) / 2; } return 0; } #ifndef WITHOUT_ACS using asdmIDL::GainTrackingTableIDL; #endif #ifndef WITHOUT_ACS // Conversion Methods GainTrackingTableIDL *GainTrackingTable::toIDL() { GainTrackingTableIDL *x = new GainTrackingTableIDL (); unsigned int nrow = size(); x->row.length(nrow); vector v = get(); for (unsigned int i = 0; i < nrow; ++i) { //x->row[i] = *(v[i]->toIDL()); v[i]->toIDL(x->row[i]); } return x; } void GainTrackingTable::toIDL(asdmIDL::GainTrackingTableIDL& x) const { unsigned int nrow = size(); x.row.length(nrow); vector v = get(); for (unsigned int i = 0; i < nrow; ++i) { v[i]->toIDL(x.row[i]); } } #endif #ifndef WITHOUT_ACS void GainTrackingTable::fromIDL(GainTrackingTableIDL x) { unsigned int nrow = x.row.length(); for (unsigned int i = 0; i < nrow; ++i) { GainTrackingRow *tmp = newRow(); tmp->setFromIDL(x.row[i]); // checkAndAdd(tmp); add(tmp); } } #endif string GainTrackingTable::toXML() { string buf; buf.append(" "); buf.append("\n"); buf.append(entity.toXML()); string s = container.getEntity().toXML(); // Change the "Entity" tag to "ContainerEntity". buf.append(" v = get(); for (unsigned int i = 0; i < v.size(); ++i) { try { buf.append(v[i]->toXML()); } catch (const NoSuchRow &e) { } buf.append(" "); } buf.append(" "); return buf; } string GainTrackingTable::getVersion() const { return version; } void GainTrackingTable::fromXML(string& tableInXML) { // // Look for a version information in the schemaVersion of the XML // xmlDoc *doc; #if LIBXML_VERSION >= 20703 doc = xmlReadMemory(tableInXML.data(), tableInXML.size(), "XMLTableHeader.xml", NULL, XML_PARSE_NOBLANKS|XML_PARSE_HUGE); #else doc = xmlReadMemory(tableInXML.data(), tableInXML.size(), "XMLTableHeader.xml", NULL, XML_PARSE_NOBLANKS); #endif if ( doc == NULL ) throw ConversionException("Failed to parse the xmlHeader into a DOM structure.", "GainTracking"); xmlNode* root_element = xmlDocGetRootElement(doc); if ( root_element == NULL || root_element->type != XML_ELEMENT_NODE ) throw ConversionException("Failed to retrieve the root element in the DOM structure.", "GainTracking"); xmlChar * propValue = xmlGetProp(root_element, (const xmlChar *) "schemaVersion"); if ( propValue != 0 ) { version = string( (const char*) propValue); xmlFree(propValue); } Parser xml(tableInXML); if (!xml.isStr(""); if (s.length() == 0) error(); Entity e; e.setFromXML(s); if (e.getEntityTypeName() != "GainTrackingTable") error(); setEntity(e); // Skip the container's entity; but, it has to be there. s = xml.getElement(""); if (s.length() == 0) error(); // Get each row in the table. s = xml.getElementContent("",""); GainTrackingRow *row; if (getContainer().checkRowUniqueness()) { try { while (s.length() != 0) { row = newRow(); row->setFromXML(s); checkAndAdd(row); s = xml.getElementContent("",""); } } catch (const DuplicateKey &e1) { throw ConversionException(e1.getMessage(),"GainTrackingTable"); } catch (const UniquenessViolationException &e1) { throw ConversionException(e1.getMessage(),"GainTrackingTable"); } catch (...) { // cout << "Unexpected error in GainTrackingTable::checkAndAdd called from GainTrackingTable::fromXML " << endl; } } else { try { while (s.length() != 0) { row = newRow(); row->setFromXML(s); addWithoutCheckingUnique(row); s = xml.getElementContent("",""); } } catch (const DuplicateKey &e1) { throw ConversionException(e1.getMessage(),"GainTrackingTable"); } catch (...) { // cout << "Unexpected error in GainTrackingTable::addWithoutCheckingUnique called from GainTrackingTable::fromXML " << endl; } } if (!xml.isStr("")) error(); //Does not change the convention defined in the model. //archiveAsBin = false; //fileAsBin = false; // clean up the xmlDoc pointer if ( doc != NULL ) xmlFreeDoc(doc); } void GainTrackingTable::error() { throw ConversionException("Invalid xml document","GainTracking"); } string GainTrackingTable::MIMEXMLPart(const asdm::ByteOrder* byteOrder) { string UID = getEntity().getEntityId().toString(); string withoutUID = UID.substr(6); string containerUID = getContainer().getEntity().getEntityId().toString(); ostringstream oss; oss << ""; oss << "\n"; oss << "\n"; oss<< "\n"; oss<< "\n"; oss << "\n"; oss << "\n"; oss << "\n"; oss << "\n"; oss << "\n"; oss << "\n"; oss << "\n"; oss << "\n"; oss << "\n"; oss << "\n"; oss << "\n"; oss << "\n"; oss << "\n"; oss << "\n"; oss << "\n"; return oss.str(); } string GainTrackingTable::toMIME(const asdm::ByteOrder* byteOrder) { EndianOSStream eoss(byteOrder); string UID = getEntity().getEntityId().toString(); // The MIME Header eoss <<"MIME-Version: 1.0"; eoss << "\n"; eoss << "Content-Type: Multipart/Related; boundary='MIME_boundary'; type='text/xml'; start= ''"; eoss <<"\n"; eoss <<"Content-Description: Correlator"; eoss <<"\n"; eoss <<"alma-uid:" << UID; eoss <<"\n"; eoss <<"\n"; // The MIME XML part header. eoss <<"--MIME_boundary"; eoss <<"\n"; eoss <<"Content-Type: text/xml; charset='ISO-8859-1'"; eoss <<"\n"; eoss <<"Content-Transfer-Encoding: 8bit"; eoss <<"\n"; eoss <<"Content-ID: "; eoss <<"\n"; eoss <<"\n"; // The MIME XML part content. eoss << MIMEXMLPart(byteOrder); // The MIME binary part header eoss <<"--MIME_boundary"; eoss <<"\n"; eoss <<"Content-Type: binary/octet-stream"; eoss <<"\n"; eoss <<"Content-ID: "; eoss <<"\n"; eoss <<"\n"; // The MIME binary content entity.toBin(eoss); container.getEntity().toBin(eoss); eoss.writeInt((int) privateRows.size()); for (unsigned int i = 0; i < privateRows.size(); i++) { privateRows.at(i)->toBin(eoss); } // The closing MIME boundary eoss << "\n--MIME_boundary--"; eoss << "\n"; return eoss.str(); } void GainTrackingTable::setFromMIME(const string & mimeMsg) { string xmlPartMIMEHeader = "Content-ID: \n\n"; string binPartMIMEHeader = "--MIME_boundary\nContent-Type: binary/octet-stream\nContent-ID: \n\n"; // Detect the XML header. string::size_type loc0 = mimeMsg.find(xmlPartMIMEHeader, 0); if ( loc0 == string::npos) { // let's try with CRLFs xmlPartMIMEHeader = "Content-ID: \r\n\r\n"; loc0 = mimeMsg.find(xmlPartMIMEHeader, 0); if ( loc0 == string::npos ) throw ConversionException("Failed to detect the beginning of the XML header", "GainTracking"); } loc0 += xmlPartMIMEHeader.size(); // Look for the string announcing the binary part. string::size_type loc1 = mimeMsg.find( binPartMIMEHeader, loc0 ); if ( loc1 == string::npos ) { throw ConversionException("Failed to detect the beginning of the binary part", "GainTracking"); } // // Extract the xmlHeader and analyze it to find out what is the byte order and the sequence // of attribute names. // string xmlHeader = mimeMsg.substr(loc0, loc1-loc0); xmlDoc *doc; doc = xmlReadMemory(xmlHeader.data(), xmlHeader.size(), "BinaryTableHeader.xml", NULL, XML_PARSE_NOBLANKS); if ( doc == NULL ) throw ConversionException("Failed to parse the xmlHeader into a DOM structure.", "GainTracking"); // This vector will be filled by the names of all the attributes of the table // in the order in which they are expected to be found in the binary representation. // vector attributesSeq; xmlNode* root_element = xmlDocGetRootElement(doc); if ( root_element == NULL || root_element->type != XML_ELEMENT_NODE ) throw ConversionException("Failed to parse the xmlHeader into a DOM structure.", "GainTracking"); const ByteOrder* byteOrder=0; if ( string("ASDMBinaryTable").compare((const char*) root_element->name) == 0) { // Then it's an "old fashioned" MIME file for tables. // Just try to deserialize it with Big_Endian for the bytes ordering. byteOrder = asdm::ByteOrder::Big_Endian; // // Let's consider a default order for the sequence of attributes. // attributesSeq.push_back("antennaId") ; attributesSeq.push_back("spectralWindowId") ; attributesSeq.push_back("timeInterval") ; attributesSeq.push_back("feedId") ; attributesSeq.push_back("numReceptor") ; attributesSeq.push_back("attenuator") ; attributesSeq.push_back("polarizationType") ; attributesSeq.push_back("samplingLevel") ; attributesSeq.push_back("numAttFreq") ; attributesSeq.push_back("attFreq") ; attributesSeq.push_back("attSpectrum") ; // And decide that it has version == "2" version = "2"; } else if (string("GainTrackingTable").compare((const char*) root_element->name) == 0) { // It's a new (and correct) MIME file for tables. // // 1st ) Look for a BulkStoreRef element with an attribute byteOrder. // xmlNode* bulkStoreRef = 0; xmlNode* child = root_element->children; if (xmlHasProp(root_element, (const xmlChar*) "schemaVersion")) { xmlChar * value = xmlGetProp(root_element, (const xmlChar *) "schemaVersion"); version = string ((const char *) value); xmlFree(value); } // Skip the two first children (Entity and ContainerEntity). bulkStoreRef = (child == 0) ? 0 : ( (child->next) == 0 ? 0 : child->next->next ); if ( bulkStoreRef == 0 || (bulkStoreRef->type != XML_ELEMENT_NODE) || (string("BulkStoreRef").compare((const char*) bulkStoreRef->name) != 0)) throw ConversionException ("Could not find the element '/GainTrackingTable/BulkStoreRef'. Invalid XML header '"+ xmlHeader + "'.", "GainTracking"); // We found BulkStoreRef, now look for its attribute byteOrder. _xmlAttr* byteOrderAttr = 0; for (struct _xmlAttr* attr = bulkStoreRef->properties; attr; attr = attr->next) if (string("byteOrder").compare((const char*) attr->name) == 0) { byteOrderAttr = attr; break; } if (byteOrderAttr == 0) throw ConversionException("Could not find the element '/GainTrackingTable/BulkStoreRef/@byteOrder'. Invalid XML header '" + xmlHeader +"'.", "GainTracking"); string byteOrderValue = string((const char*) byteOrderAttr->children->content); if (!(byteOrder = asdm::ByteOrder::fromString(byteOrderValue))) throw ConversionException("No valid value retrieved for the element '/GainTrackingTable/BulkStoreRef/@byteOrder'. Invalid XML header '" + xmlHeader + "'.", "GainTracking"); // // 2nd) Look for the Attributes element and grab the names of the elements it contains. // xmlNode* attributes = bulkStoreRef->next; if ( attributes == 0 || (attributes->type != XML_ELEMENT_NODE) || (string("Attributes").compare((const char*) attributes->name) != 0)) throw ConversionException ("Could not find the element '/GainTrackingTable/Attributes'. Invalid XML header '"+ xmlHeader + "'.", "GainTracking"); xmlNode* childOfAttributes = attributes->children; while ( childOfAttributes != 0 && (childOfAttributes->type == XML_ELEMENT_NODE) ) { attributesSeq.push_back(string((const char*) childOfAttributes->name)); childOfAttributes = childOfAttributes->next; } } // Create an EndianISStream from the substring containing the binary part. EndianISStream eiss(mimeMsg.substr(loc1+binPartMIMEHeader.size()), byteOrder); entity = Entity::fromBin((EndianIStream&) eiss); // We do nothing with that but we have to read it. Entity containerEntity = Entity::fromBin((EndianIStream&) eiss); // Let's read numRows but ignore it and rely on the value specified in the ASDM.xml file. int numRows = ((EndianIStream&) eiss).readInt(); if ((numRows != -1) // Then these are *not* data produced at the EVLA. && ((unsigned int) numRows != this->declaredSize )) { // Then the declared size (in ASDM.xml) is not equal to the one // written into the binary representation of the table. cout << "The a number of rows ('" << numRows << "') declared in the binary representation of the table is different from the one declared in ASDM.xml ('" << this->declaredSize << "'). I'll proceed with the value declared in ASDM.xml" << endl; } if (getContainer().checkRowUniqueness()) { try { for (uint32_t i = 0; i < this->declaredSize; i++) { GainTrackingRow* aRow = GainTrackingRow::fromBin((EndianIStream&) eiss, *this, attributesSeq); checkAndAdd(aRow); } } catch (const DuplicateKey &e) { throw ConversionException("Error while writing binary data , the message was " + e.getMessage(), "GainTracking"); } catch (const TagFormatException &e) { throw ConversionException("Error while reading binary data , the message was " + e.getMessage(), "GainTracking"); } } else { for (uint32_t i = 0; i < this->declaredSize; i++) { GainTrackingRow* aRow = GainTrackingRow::fromBin((EndianIStream&) eiss, *this, attributesSeq); append(aRow); } } //Does not change the convention defined in the model. //archiveAsBin = true; //fileAsBin = true; if ( doc != NULL ) xmlFreeDoc(doc); } void GainTrackingTable::setUnknownAttributeBinaryReader(const string& attributeName, BinaryAttributeReaderFunctor* barFctr) { // // Is this attribute really unknown ? // for (vector::const_iterator iter = attributesNamesOfGainTracking_v.begin(); iter != attributesNamesOfGainTracking_v.end(); iter++) { if ((*iter).compare(attributeName) == 0) throw ConversionException("the attribute '"+attributeName+"' is known you can't override the way it's read in the MIME binary file containing the table.", "GainTracking"); } // Ok then register the functor to activate when an unknown attribute is met during the reading of a binary table? unknownAttributes2Functors[attributeName] = barFctr; } BinaryAttributeReaderFunctor* GainTrackingTable::getUnknownAttributeBinaryReader(const string& attributeName) const { map::const_iterator iter = unknownAttributes2Functors.find(attributeName); return (iter == unknownAttributes2Functors.end()) ? 0 : iter->second; } void GainTrackingTable::toFile(string directory) { if (!directoryExists(directory.c_str()) && !createPath(directory.c_str())) { throw ConversionException("Could not create directory " , directory); } string fileName = directory + "/GainTracking.xml"; ofstream tableout(fileName.c_str(),ios::out|ios::trunc); if (tableout.rdstate() == ostream::failbit) throw ConversionException("Could not open file " + fileName + " to write ", "GainTracking"); if (fileAsBin) tableout << MIMEXMLPart(); else tableout << toXML() << endl; tableout.close(); if (tableout.rdstate() == ostream::failbit) throw ConversionException("Could not close file " + fileName, "GainTracking"); if (fileAsBin) { // write the bin serialized string fileName = directory + "/GainTracking.bin"; ofstream tableout(fileName.c_str(),ios::out|ios::trunc); if (tableout.rdstate() == ostream::failbit) throw ConversionException("Could not open file " + fileName + " to write ", "GainTracking"); tableout << toMIME() << endl; tableout.close(); if (tableout.rdstate() == ostream::failbit) throw ConversionException("Could not close file " + fileName, "GainTracking"); } } void GainTrackingTable::setFromFile(const string& directory) { #ifndef WITHOUT_BOOST if (boost::filesystem::exists(boost::filesystem::path(uniqSlashes(directory + "/GainTracking.xml")))) setFromXMLFile(directory); else if (boost::filesystem::exists(boost::filesystem::path(uniqSlashes(directory + "/GainTracking.bin")))) setFromMIMEFile(directory); #else // alternative in Misc.h if (file_exists(uniqSlashes(directory + "/GainTracking.xml"))) setFromXMLFile(directory); else if (file_exists(uniqSlashes(directory + "/GainTracking.bin"))) setFromMIMEFile(directory); #endif else throw ConversionException("No file found for the GainTracking table", "GainTracking"); } void GainTrackingTable::setFromMIMEFile(const string& directory) { string tablePath ; tablePath = directory + "/GainTracking.bin"; ifstream tablefile(tablePath.c_str(), ios::in|ios::binary); if (!tablefile.is_open()) { throw ConversionException("Could not open file " + tablePath, "GainTracking"); } // Read in a stringstream. stringstream ss; ss << tablefile.rdbuf(); if (tablefile.rdstate() == istream::failbit || tablefile.rdstate() == istream::badbit) { throw ConversionException("Error reading file " + tablePath,"GainTracking"); } // And close. tablefile.close(); if (tablefile.rdstate() == istream::failbit) throw ConversionException("Could not close file " + tablePath,"GainTracking"); setFromMIME(ss.str()); } /* void GainTrackingTable::openMIMEFile (const string& directory) { // Open the file. string tablePath ; tablePath = directory + "/GainTracking.bin"; ifstream tablefile(tablePath.c_str(), ios::in|ios::binary); if (!tablefile.is_open()) throw ConversionException("Could not open file " + tablePath, "GainTracking"); // Locate the xmlPartMIMEHeader. string xmlPartMIMEHeader = "CONTENT-ID: \n\n"; CharComparator comparator; istreambuf_iterator BEGIN(tablefile.rdbuf()); istreambuf_iterator END; istreambuf_iterator it = search(BEGIN, END, xmlPartMIMEHeader.begin(), xmlPartMIMEHeader.end(), comparator); if (it == END) throw ConversionException("failed to detect the beginning of the XML header", "GainTracking"); // Locate the binaryPartMIMEHeader while accumulating the characters of the xml header. string binPartMIMEHeader = "--MIME_BOUNDARY\nCONTENT-TYPE: BINARY/OCTET-STREAM\nCONTENT-ID: \n\n"; string xmlHeader; CharCompAccumulator compaccumulator(&xmlHeader, 100000); ++it; it = search(it, END, binPartMIMEHeader.begin(), binPartMIMEHeader.end(), compaccumulator); if (it == END) throw ConversionException("failed to detect the beginning of the binary part", "GainTracking"); cout << xmlHeader << endl; // // We have the xmlHeader , let's parse it. // xmlDoc *doc; doc = xmlReadMemory(xmlHeader.data(), xmlHeader.size(), "BinaryTableHeader.xml", NULL, XML_PARSE_NOBLANKS); if ( doc == NULL ) throw ConversionException("Failed to parse the xmlHeader into a DOM structure.", "GainTracking"); // This vector will be filled by the names of all the attributes of the table // in the order in which they are expected to be found in the binary representation. // vector attributesSeq(attributesNamesInBinOfGainTracking_v); xmlNode* root_element = xmlDocGetRootElement(doc); if ( root_element == NULL || root_element->type != XML_ELEMENT_NODE ) throw ConversionException("Failed to parse the xmlHeader into a DOM structure.", "GainTracking"); const ByteOrder* byteOrder=0; if ( string("ASDMBinaryTable").compare((const char*) root_element->name) == 0) { // Then it's an "old fashioned" MIME file for tables. // Just try to deserialize it with Big_Endian for the bytes ordering. byteOrder = asdm::ByteOrder::Big_Endian; // And decide that it has version == "2" version = "2"; } else if (string("GainTrackingTable").compare((const char*) root_element->name) == 0) { // It's a new (and correct) MIME file for tables. // // 1st ) Look for a BulkStoreRef element with an attribute byteOrder. // xmlNode* bulkStoreRef = 0; xmlNode* child = root_element->children; if (xmlHasProp(root_element, (const xmlChar*) "schemaVersion")) { xmlChar * value = xmlGetProp(root_element, (const xmlChar *) "schemaVersion"); version = string ((const char *) value); xmlFree(value); } // Skip the two first children (Entity and ContainerEntity). bulkStoreRef = (child == 0) ? 0 : ( (child->next) == 0 ? 0 : child->next->next ); if ( bulkStoreRef == 0 || (bulkStoreRef->type != XML_ELEMENT_NODE) || (string("BulkStoreRef").compare((const char*) bulkStoreRef->name) != 0)) throw ConversionException ("Could not find the element '/GainTrackingTable/BulkStoreRef'. Invalid XML header '"+ xmlHeader + "'.", "GainTracking"); // We found BulkStoreRef, now look for its attribute byteOrder. _xmlAttr* byteOrderAttr = 0; for (struct _xmlAttr* attr = bulkStoreRef->properties; attr; attr = attr->next) if (string("byteOrder").compare((const char*) attr->name) == 0) { byteOrderAttr = attr; break; } if (byteOrderAttr == 0) throw ConversionException("Could not find the element '/GainTrackingTable/BulkStoreRef/@byteOrder'. Invalid XML header '" + xmlHeader +"'.", "GainTracking"); string byteOrderValue = string((const char*) byteOrderAttr->children->content); if (!(byteOrder = asdm::ByteOrder::fromString(byteOrderValue))) throw ConversionException("No valid value retrieved for the element '/GainTrackingTable/BulkStoreRef/@byteOrder'. Invalid XML header '" + xmlHeader + "'.", "GainTracking"); // // 2nd) Look for the Attributes element and grab the names of the elements it contains. // xmlNode* attributes = bulkStoreRef->next; if ( attributes == 0 || (attributes->type != XML_ELEMENT_NODE) || (string("Attributes").compare((const char*) attributes->name) != 0)) throw ConversionException ("Could not find the element '/GainTrackingTable/Attributes'. Invalid XML header '"+ xmlHeader + "'.", "GainTracking"); xmlNode* childOfAttributes = attributes->children; while ( childOfAttributes != 0 && (childOfAttributes->type == XML_ELEMENT_NODE) ) { attributesSeq.push_back(string((const char*) childOfAttributes->name)); childOfAttributes = childOfAttributes->next; } } // Create an EndianISStream from the substring containing the binary part. EndianIFStream eifs(&tablefile, byteOrder); entity = Entity::fromBin((EndianIStream &) eifs); // We do nothing with that but we have to read it. Entity containerEntity = Entity::fromBin((EndianIStream &) eifs); // Let's read numRows but ignore it and rely on the value specified in the ASDM.xml file. int numRows = eifs.readInt(); if ((numRows != -1) // Then these are *not* data produced at the EVLA. && ((unsigned int) numRows != this->declaredSize )) { // Then the declared size (in ASDM.xml) is not equal to the one // written into the binary representation of the table. cout << "The a number of rows ('" << numRows << "') declared in the binary representation of the table is different from the one declared in ASDM.xml ('" << this->declaredSize << "'). I'll proceed with the value declared in ASDM.xml" << endl; } // clean up xmlDoc pointer if ( doc != NULL ) xmlFreeDoc(doc); } */ void GainTrackingTable::setFromXMLFile(const string& directory) { string tablePath ; tablePath = directory + "/GainTracking.xml"; /* ifstream tablefile(tablePath.c_str(), ios::in|ios::binary); if (!tablefile.is_open()) { throw ConversionException("Could not open file " + tablePath, "GainTracking"); } // Read in a stringstream. stringstream ss; ss << tablefile.rdbuf(); if (tablefile.rdstate() == istream::failbit || tablefile.rdstate() == istream::badbit) { throw ConversionException("Error reading file '" + tablePath + "'", "GainTracking"); } // And close tablefile.close(); if (tablefile.rdstate() == istream::failbit) throw ConversionException("Could not close file '" + tablePath + "'", "GainTracking"); // Let's make a string out of the stringstream content and empty the stringstream. string xmlDocument = ss.str(); ss.str(""); // Let's make a very primitive check to decide // whether the XML content represents the table // or refers to it via a & row. A reference to the vector where to insert x. * */ GainTrackingRow* GainTrackingTable::insertByStartTime(GainTrackingRow* x, vector& row) { vector ::iterator theIterator; ArrayTime start = x->timeInterval.getStart(); // Is the row vector empty ? if (row.size() == 0) { row.push_back(x); privateRows.push_back(x); x->isAdded(true); return x; } // Optimization for the case of insertion by ascending time. GainTrackingRow* last = *(row.end()-1); if ( start > last->timeInterval.getStart() ) { // // Modify the duration of last if and only if the start time of x // is located strictly before the end time of last. // if ( start < (last->timeInterval.getStart() + last->timeInterval.getDuration())) last->timeInterval.setDuration(start - last->timeInterval.getStart()); row.push_back(x); privateRows.push_back(x); x->isAdded(true); return x; } // Optimization for the case of insertion by descending time. GainTrackingRow* first = *(row.begin()); if ( start < first->timeInterval.getStart() ) { // // Modify the duration of x if and only if the start time of first // is located strictly before the end time of x. // if ( first->timeInterval.getStart() < (start + x->timeInterval.getDuration()) ) x->timeInterval.setDuration(first->timeInterval.getStart() - start); row.insert(row.begin(), x); privateRows.push_back(x); x->isAdded(true); return x; } // Case where x has to be inserted inside row; let's use a dichotomy // method to find the insertion index. unsigned int k0 = 0; unsigned int k1 = row.size() - 1; while (k0 != (k1 - 1)) { if (start == row[k0]->timeInterval.getStart()) { if (row[k0]->equalByRequiredValue(x)) return row[k0]; else throw DuplicateKey("DuplicateKey exception in ", "GainTrackingTable"); } else if (start == row[k1]->timeInterval.getStart()) { if (row[k1]->equalByRequiredValue(x)) return row[k1]; else throw DuplicateKey("DuplicateKey exception in ", "GainTrackingTable"); } else { if (start <= row[(k0+k1)/2]->timeInterval.getStart()) k1 = (k0 + k1) / 2; else k0 = (k0 + k1) / 2; } } if (start == row[k0]->timeInterval.getStart()) { if (row[k0]->equalByRequiredValue(x)) return row[k0]; else throw DuplicateKey("DuplicateKey exception in ", "GainTrackingTable"); } else if (start == row[k1]->timeInterval.getStart()) { if (row[k1]->equalByRequiredValue(x)) return row[k1]; else throw DuplicateKey("DuplicateKey exception in ", "GainTrackingTable"); } row[k0]->timeInterval.setDuration(start-row[k0]->timeInterval.getStart()); x->timeInterval.setDuration(row[k0+1]->timeInterval.getStart() - start); row.insert(row.begin()+(k0+1), x); privateRows.push_back(x); x->isAdded(true); return x; } } // End namespace asdm