ConfigurationManagerRW.cc

#include "otsdaq/ConfigurationInterface/ConfigurationManagerRW.h"
 
#include <dirent.h>
 
using namespace ots;
 
#undef __MF_SUBJECT__
#define __MF_SUBJECT__ "ConfigurationManagerRW"
 
#define TABLE_INFO_PATH std::string(__ENV__("TABLE_INFO_PATH")) + "/"
#define TABLE_INFO_EXT "Info.xml"
 
#define CORE_TABLE_INFO_FILENAME                                \
    ((getenv("SERVICE_DATA_PATH") == NULL)                      \
         ? (std::string(__ENV__("USER_DATA")) + "/ServiceData") \
         : (std::string(__ENV__("SERVICE_DATA_PATH")))) +       \
        "/CoreTableInfoNames.dat"
 
std::atomic<bool> ConfigurationManagerRW::firstTimeConstructed_ = true;
 
//==============================================================================
ConfigurationManagerRW::ConfigurationManagerRW(const std::string& username)
    : ConfigurationManager(username)  // for use as author of new views
{
    __GEN_COUT__ << "Instantiating Config Manager with Write Access! (for " << username
                 << ") time=" << time(0) << " runTimeSeconds()=" << runTimeSeconds()
                 << __E__;
 
    theInterface_ = ConfigurationInterface::getInstance(
        ConfigurationInterface::CONFIGURATION_MODE::
            ARTDAQ_DATABASE);  // false to use artdaq DB
 
    //=========================
    // dump names of core tables (so UpdateOTS.sh can copy core tables for user)
    // only if table does not exist
    if(firstTimeConstructed_)
    {
        firstTimeConstructed_ = false;
 
        // make table group history directory here and at Gateway Supervisor (just in case)
        mkdir((ConfigurationManager::LAST_TABLE_GROUP_SAVE_PATH).c_str(), 0755);
 
        const std::set<std::string>& contextMemberNames  = getFixedContextMemberNames();
        const std::set<std::string>& backboneMemberNames = getBackboneMemberNames();
        const std::set<std::string>& iterateMemberNames  = getIterateMemberNames();
 
        FILE* fp = fopen((CORE_TABLE_INFO_FILENAME).c_str(), "r");
 
        if(fp)  // check for all core table names in file, and force their presence
        {
            std::vector<unsigned int> foundVector;
            char                      line[100];
            for(const auto& name : contextMemberNames)
            {
                foundVector.push_back(false);
                rewind(fp);
                while(fgets(line, 100, fp))
                {
                    if(strlen(line) < 1)
                        continue;
                    line[strlen(line) - 1] = '\0';  // remove endline
                    if(strcmp(line, ("ContextGroup/" + name).c_str()) == 0)  // is match?
                    {
                        foundVector.back() = true;
                        break;
                    }
                }
            }
 
            for(const auto& name : backboneMemberNames)
            {
                foundVector.push_back(false);
                rewind(fp);
                while(fgets(line, 100, fp))
                {
                    if(strlen(line) < 1)
                        continue;
                    line[strlen(line) - 1] = '\0';  // remove endline
                    if(strcmp(line, ("BackboneGroup/" + name).c_str()) == 0)  // is match?
                    {
                        foundVector.back() = true;
                        break;
                    }
                }
            }
 
            for(const auto& name : iterateMemberNames)
            {
                foundVector.push_back(false);
                rewind(fp);
                while(fgets(line, 100, fp))
                {
                    if(strlen(line) < 1)
                        continue;
                    line[strlen(line) - 1] = '\0';  // remove endline
                    if(strcmp(line, ("IterateGroup/" + name).c_str()) == 0)  // is match?
                    {
                        foundVector.back() = true;
                        break;
                    }
                }
            }
 
            //look for optional Context table ConfigurationManager::CONTEXT_SUBSYSTEM_OPTIONAL_TABLE
            {
                foundVector.push_back(false);
                rewind(fp);
                while(fgets(line, 100, fp))
                {
                    if(strlen(line) < 1)
                        continue;
                    line[strlen(line) - 1] = '\0';  // remove endline
                    if(strcmp(line,
                              ("ContextGroup/" +
                               ConfigurationManager::CONTEXT_SUBSYSTEM_OPTIONAL_TABLE)
                                  .c_str()) == 0)  // is match?
                    {
                        foundVector.back() = true;
                        break;
                    }
                }
            }
 
            fclose(fp);
 
            // open file for appending the missing names
            fp = fopen((CORE_TABLE_INFO_FILENAME).c_str(), "a");
            if(fp)
            {
                unsigned int i = 0;
                for(const auto& name : contextMemberNames)
                {
                    if(!foundVector[i])
                        fprintf(fp, "\nContextGroup/%s", name.c_str());
 
                    ++i;
                }
                for(const auto& name : backboneMemberNames)
                {
                    if(!foundVector[i])
                        fprintf(fp, "\nBackboneGroup/%s", name.c_str());
 
                    ++i;
                }
                for(const auto& name : iterateMemberNames)
                {
                    if(!foundVector[i])
                        fprintf(fp, "\nIterateGroup/%s", name.c_str());
 
                    ++i;
                }
 
                //last is optional Context table ConfigurationManager::CONTEXT_SUBSYSTEM_OPTIONAL_TABLE
                if(!foundVector[i])
                    fprintf(
                        fp,
                        "\nContextGroup/%s",
                        ConfigurationManager::CONTEXT_SUBSYSTEM_OPTIONAL_TABLE.c_str());
 
                fclose(fp);
            }
            else
            {
                __SS__ << "Failed to open core table info file for appending: "
                       << CORE_TABLE_INFO_FILENAME << __E__;
                __SS_THROW__;
            }
        }
        else
        {
            fp = fopen((CORE_TABLE_INFO_FILENAME).c_str(), "w");
            if(fp)
            {
                fprintf(fp, "ARTDAQ/*");
                fprintf(fp, "\nConfigCore/*");
                for(const auto& name : contextMemberNames)
                    fprintf(fp, "\nContextGroup/%s", name.c_str());
                for(const auto& name : backboneMemberNames)
                    fprintf(fp, "\nBackboneGroup/%s", name.c_str());
                for(const auto& name : iterateMemberNames)
                    fprintf(fp, "\nIterateGroup/%s", name.c_str());
                fclose(fp);
            }
            else
            {
                __SS__ << "Failed to open core table info file: "
                       << CORE_TABLE_INFO_FILENAME << __E__;
                __SS_THROW__;
            }
        }
    }  // end dump names of core tables
 
    __GEN_COUTV__(runTimeSeconds());
}  // end constructor
 
//==============================================================================
const std::map<std::string, TableInfo>& ConfigurationManagerRW::getAllTableInfo(
    bool               refresh /* = false */,
    std::string*       accumulatedWarnings /* = 0 */,
    const std::string& errorFilterName /* = "" */,
    bool               getGroupKeys /* = false */,
    bool               getGroupInfo /* = false */,
    bool               initializeActiveGroups /* = false */)
{
    // allTableInfo_ is container to be returned
 
    if(!refresh)
        return allTableInfo_;
 
    // else refresh!
    allTableInfo_.clear();
 
    TableBase* table;
 
    // existing configurations are defined by which infos are in TABLE_INFO_PATH
    // can test that the class exists based on this
    // and then which versions
    __GEN_COUT__ << "======================================================== "
                    "getAllTableInfo start runTimeSeconds()="
                 << runTimeSeconds() << __E__;
    {
        __GEN_COUT__ << "Refreshing all! Extracting list of tables..." << __E__;
        DIR*                pDIR;
        struct dirent*      entry;
        std::string         path              = TABLE_INFO_PATH;
        char                fileExt[]         = TABLE_INFO_EXT;
        const unsigned char MIN_TABLE_NAME_SZ = 3;
 
        const int numOfThreads = PROCESSOR_COUNT / 2;
        __GEN_COUT__ << " PROCESSOR_COUNT " << PROCESSOR_COUNT << " ==> " << numOfThreads
                     << " threads." << __E__;
        if(numOfThreads < 2)  // no multi-threading
        {
            if((pDIR = opendir(path.c_str())) != 0)
            {
                while((entry = readdir(pDIR)) != 0)
                {
                    // enforce table name length
                    if(strlen(entry->d_name) < strlen(fileExt) + MIN_TABLE_NAME_SZ)
                        continue;
 
                    // find file names with correct file extenstion
                    if(strcmp(&(entry->d_name[strlen(entry->d_name) - strlen(fileExt)]),
                              fileExt) != 0)
                        continue;  // skip different extentions
 
                    entry->d_name[strlen(entry->d_name) - strlen(fileExt)] =
                        '\0';  // remove file extension to get table name
 
                    // 0 will force the creation of new instance (and reload from Info)
                    table = 0;
 
                    try  // only add valid table instances to maps
                    {
                        theInterface_->get(table,
                                           entry->d_name,
                                           0,
                                           0,
                                           true);  // dont fill
                    }
                    catch(cet::exception const&)
                    {
                        if(table)
                            delete table;
                        table = 0;
 
                        __GEN_COUT__ << "Skipping! No valid class found for... "
                                     << entry->d_name << "\n";
                        continue;
                    }
                    catch(std::runtime_error& e)
                    {
                        if(table)
                            delete table;
                        table = 0;
 
                        __GEN_COUT__ << "Skipping! No valid class found for... "
                                     << entry->d_name << "\n";
                        __GEN_COUT__ << "Error: " << e.what() << __E__;
 
                        // for a runtime_error, it is likely that columns are the problem
                        //  the Table Editor needs to still fix these.. so attempt to
                        //  proceed.
                        if(accumulatedWarnings)
                        {
                            if(errorFilterName == "" || errorFilterName == entry->d_name)
                            {
                                *accumulatedWarnings += std::string("\nIn table '") +
                                                        entry->d_name + "'..." +
                                                        e.what();  // global accumulate
 
                                __SS__ << "Attempting to allow illegal columns!" << __E__;
                                *accumulatedWarnings += ss.str();
                            }
 
                            // attempt to recover and build a mock-up
                            __GEN_COUT__ << "Attempting to allow illegal columns!"
                                         << __E__;
 
                            std::string returnedAccumulatedErrors;
                            try
                            {
                                table = new TableBase(entry->d_name,
                                                      &returnedAccumulatedErrors);
                            }
                            catch(...)
                            {
                                __GEN_COUT__ << "Skipping! Allowing illegal columns "
                                                "didn't work either... "
                                             << entry->d_name << "\n";
                                continue;
                            }
                            __GEN_COUT__
                                << "Error (but allowed): " << returnedAccumulatedErrors
                                << __E__;
 
                            if(errorFilterName == "" || errorFilterName == entry->d_name)
                                *accumulatedWarnings +=
                                    std::string("\nIn table '") + entry->d_name + "'..." +
                                    returnedAccumulatedErrors;  // global accumulate
                        }
                        else
                            continue;
                    }
 
                    if(nameToTableMap_[entry->d_name])  // handle if instance existed
                    {
                        // copy the existing temporary versions! (or else all is lost)
                        std::set<TableVersion> versions =
                            nameToTableMap_[entry->d_name]->getStoredVersions();
                        for(auto& version : versions)
                            if(version.isTemporaryVersion())
                            {
                                try  // do NOT let TableView::init() throw here
                                {
                                    nameToTableMap_[entry->d_name]->setActiveView(
                                        version);
                                    table->copyView(  // this calls TableView::init()
                                        nameToTableMap_[entry->d_name]->getView(),
                                        version,
                                        username_);
                                }
                                catch(
                                    ...)  // do NOT let invalid temporary version throw at this
                                          // point
                                {
                                }  // just trust configurationBase throws out the failed version
                            }
 
                        delete nameToTableMap_[entry->d_name];
                        nameToTableMap_[entry->d_name] = 0;
                    }
 
                    nameToTableMap_[entry->d_name] = table;
 
                    allTableInfo_[entry->d_name].tablePtr_ = table;
                    allTableInfo_[entry->d_name].versions_ =
                        theInterface_->getVersions(table);
 
                    // also add any existing temporary versions to all table info
                    //  because the interface wont find those versions
                    std::set<TableVersion> versions =
                        nameToTableMap_[entry->d_name]->getStoredVersions();
                    for(auto& version : versions)
                        if(version.isTemporaryVersion())
                        {
                            allTableInfo_[entry->d_name].versions_.emplace(version);
                        }
                }  //end table name handling from directory
                closedir(pDIR);
            }
        }
        else  //multi-threading
        {
            int         threadsLaunched  = 0;
            int         foundThreadIndex = 0;
            std::string tableName;
 
            std::vector<std::shared_ptr<std::atomic<bool>>> threadDone;
            for(int i = 0; i < numOfThreads; ++i)
                threadDone.push_back(std::make_shared<std::atomic<bool>>(true));
 
            std::vector<std::shared_ptr<ots::TableInfo>> sharedTableInfoPtrs;
 
            if((pDIR = opendir(path.c_str())) != 0)
            {
                while((entry = readdir(pDIR)) != 0)
                {
                    // enforce table name length
                    if(strlen(entry->d_name) < strlen(fileExt) + MIN_TABLE_NAME_SZ)
                        continue;
 
                    // find file names with correct file extenstion
                    if(strcmp(&(entry->d_name[strlen(entry->d_name) - strlen(fileExt)]),
                              fileExt) != 0)
                        continue;  // skip different extentions
 
                    entry->d_name[strlen(entry->d_name) - strlen(fileExt)] =
                        '\0';  // remove file extension to get table name
                    tableName =
                        entry
                            ->d_name;  //copy immediate, thread does not like using pointer to char*, corrupts immediately on wraparound
 
                    //make temporary table info for thread
                    sharedTableInfoPtrs.push_back(std::make_shared<ots::TableInfo>());
                    sharedTableInfoPtrs.back()->accumulatedWarnings_ =
                        accumulatedWarnings ? "ALLOW"
                                            : "";  //mark to allow accumulated warnings
 
                    if(threadsLaunched >= numOfThreads)
                    {
                        //find availableThreadIndex
                        foundThreadIndex = -1;
                        size_t ii        = 0;
                        while(foundThreadIndex == -1)
                        {
                            for(int i = 0; i < numOfThreads; ++i)
                                if(*(threadDone[i]))
                                {
                                    foundThreadIndex = i;
                                    break;
                                }
                            if(foundThreadIndex == -1)
                            {
                                __GEN_COUT_TYPE__(TLVL_DEBUG + 2)
                                    << __COUT_HDR__
                                    << "Waiting for available thread... iteration # "
                                    << ii << __E__;
                                if(++ii > 100 /* 1s */ * 10)
                                {
                                    __GEN_SS__ << "Threads seem to be stuck getting "
                                                  "table info! Timeout while waiting..."
                                               << __E__;
                                    __GEN_SS_THROW__;
                                }
                                usleep(10000);
                            }
                        }  //end thread search loop
                        threadsLaunched = numOfThreads - 1;
                    }
                    __GEN_COUTT__ << "Starting thread... " << foundThreadIndex
                                  << " for table " << tableName << __E__;
 
                    *(threadDone[foundThreadIndex]) = false;
                    std::thread(
                        [](ConfigurationManagerRW*            theCfgMgr,
                           std::string                        theTableName,
                           TableBase*                         existingTable,
                           std::shared_ptr<ots::TableInfo>    theTableInfo,
                           std::shared_ptr<std::atomic<bool>> theThreadDone) {
                            ConfigurationManagerRW::loadTableInfoThread(theCfgMgr,
                                                                        theTableName,
                                                                        existingTable,
                                                                        theTableInfo,
                                                                        theThreadDone);
                        },
                        this,
                        tableName,
                        nameToTableMap_[tableName],
                        sharedTableInfoPtrs.back(),
                        threadDone[foundThreadIndex])
                        .detach();
 
                    ++threadsLaunched;
                    ++foundThreadIndex;
                }  //end table name handling from directory
                closedir(pDIR);
            }  //end tableInfo thread loop
 
            //check for all threads done
            do
            {
                foundThreadIndex = -1;
                for(int i = 0; i < numOfThreads; ++i)
                    if(!*(threadDone[i]))
                    {
                        foundThreadIndex = i;
                        break;
                    }
                if(foundThreadIndex != -1)
                {
                    __GEN_COUTT__ << "Waiting for thread to finish... "
                                  << foundThreadIndex << __E__;
                    usleep(10000);
                }
            } while(foundThreadIndex != -1);  //end thread done search loop
 
            //threads done now, so copy table info
            for(auto& tableInfo : sharedTableInfoPtrs)
            {
                __GEN_COUT_TYPE__(TLVL_DEBUG + 3)
                    << __COUT_HDR__ << "Copying table info for "
                    << tableInfo->tablePtr_->getTableName() << __E__;
                nameToTableMap_[tableInfo->tablePtr_->getTableName()] =
                    tableInfo->tablePtr_;
                allTableInfo_[tableInfo->tablePtr_->getTableName()].tablePtr_ =
                    tableInfo->tablePtr_;
                allTableInfo_[tableInfo->tablePtr_->getTableName()].versions_ =
                    tableInfo->versions_;
            }  //end copy group info loop
        }
        __GEN_COUT__ << "Extracting list of tables complete." << __E__;
    }  //end Extracting list of tables
 
    // call init to load active versions by default, activate with warnings allowed (assuming development going on)
    if(initializeActiveGroups)
    {
        __GEN_COUT__ << "Now initializing..." << __E__;
        // if there is a filter name, do not include init warnings (it just scares people in the table editor)
        std::string tmpAccumulateWarnings;
        init(0 /*accumulatedErrors*/,
             false /*initForWriteAccess*/,
             accumulatedWarnings ? &tmpAccumulateWarnings : nullptr);
 
        if(accumulatedWarnings && errorFilterName == "")
            *accumulatedWarnings += tmpAccumulateWarnings;
    }
    __GEN_COUT__ << "======================================================== "
                    "getAllTableInfo end runTimeSeconds()="
                 << runTimeSeconds() << __E__;
 
    // get Group Info too!
    if(getGroupKeys || getGroupInfo)
    {
        allGroupInfo_.clear();
        try
        {
            // build allGroupInfo_ for the ConfigurationManagerRW
 
            std::set<std::string /*name*/> tableGroups =
                theInterface_->getAllTableGroupNames();
            __GEN_COUT__ << "Number of Groups: " << tableGroups.size() << __E__;
 
            __GEN_COUTT__ << "Group Info start runTimeSeconds()=" << runTimeSeconds()
                          << __E__;
 
            TableGroupKey key;
            std::string   name;
            for(const auto& fullName : tableGroups)
            {
                TableGroupKey::getGroupNameAndKey(fullName, name, key);
                allGroupInfo_[name].keys_.emplace(key);  //store in cache
            }
 
            __GEN_COUTT__ << "Group Keys end runTimeSeconds()=" << runTimeSeconds()
                          << __E__;
 
            // for each group get member map & comment, author, time, and type for latest key
            if(getGroupInfo)
            {
                const int numOfThreads = PROCESSOR_COUNT / 2;
                __GEN_COUT__ << " PROCESSOR_COUNT " << PROCESSOR_COUNT << " ==> "
                             << numOfThreads << " threads." << __E__;
                if(numOfThreads < 2)  // no multi-threading
                    for(auto& groupInfo : allGroupInfo_)
                    {
                        try
                        {
                            groupInfo.second.latestKey_ = groupInfo.second.getLastKey();
                            loadTableGroup(
                                groupInfo.first /*groupName*/,
                                groupInfo.second.latestKey_,
                                false /*doActivate*/,
                                &groupInfo.second.latestKeyMemberMap_ /*groupMembers*/,
                                0 /*progressBar*/,
                                0 /*accumulateErrors*/,
                                &groupInfo.second.latestKeyGroupComment_,
                                &groupInfo.second.latestKeyGroupAuthor_,
                                &groupInfo.second.latestKeyGroupCreationTime_,
                                true /*doNotLoadMember*/,
                                &groupInfo.second.latestKeyGroupTypeString_);
                        }
                        catch(...)
                        {
                            __GEN_COUT_WARN__ << "Error occurred loading latest group "
                                                 "info into cache for '"
                                              << groupInfo.first << "("
                                              << groupInfo.second.latestKey_ << ")'..."
                                              << __E__;
                            groupInfo.second.latestKey_ = TableGroupKey::INVALID;
                            groupInfo.second.latestKeyGroupComment_ =
                                ConfigurationManager::UNKNOWN_INFO;
                            groupInfo.second.latestKeyGroupAuthor_ =
                                ConfigurationManager::UNKNOWN_INFO;
                            groupInfo.second.latestKeyGroupCreationTime_ =
                                ConfigurationManager::UNKNOWN_TIME;
                            groupInfo.second.latestKeyGroupTypeString_ =
                                ConfigurationManager::GROUP_TYPE_NAME_UNKNOWN;
                            groupInfo.second.latestKeyMemberMap_ = {};
                        }
                    }  // end group info loop
                else   //multi-threading
                {
                    int threadsLaunched  = 0;
                    int foundThreadIndex = 0;
 
                    std::vector<std::shared_ptr<std::atomic<bool>>> threadDone;
                    for(int i = 0; i < numOfThreads; ++i)
                        threadDone.push_back(std::make_shared<std::atomic<bool>>(true));
 
                    std::vector<std::shared_ptr<ots::GroupInfo>> sharedGroupInfoPtrs;
 
                    for(auto& groupInfo : allGroupInfo_)
                    {
                        //make temporary group info for thread
                        sharedGroupInfoPtrs.push_back(std::make_shared<ots::GroupInfo>());
 
                        if(threadsLaunched >= numOfThreads)
                        {
                            //find availableThreadIndex
                            foundThreadIndex = -1;
                            while(foundThreadIndex == -1)
                            {
                                for(int i = 0; i < numOfThreads; ++i)
                                    if(*(threadDone[i]))
                                    {
                                        foundThreadIndex = i;
                                        break;
                                    }
                                if(foundThreadIndex == -1)
                                {
                                    __GEN_COUTT__ << "Waiting for available thread..."
                                                  << __E__;
                                    usleep(10000);
                                }
                            }  //end thread search loop
                            threadsLaunched = numOfThreads - 1;
                        }
                        __GEN_COUTT__ << "Starting thread... " << foundThreadIndex
                                      << " for " << groupInfo.first << "("
                                      << groupInfo.second.getLastKey() << ")" << __E__;
 
                        *(threadDone[foundThreadIndex]) = false;
 
                        std::thread(
                            [](ConfigurationManagerRW*            theCfgMgr,
                               std::string                        theGroupName,
                               ots::TableGroupKey                 theGroupKey,
                               std::shared_ptr<ots::GroupInfo>    theGroupInfo,
                               std::shared_ptr<std::atomic<bool>> theThreadDone) {
                                ConfigurationManagerRW::loadTableGroupThread(
                                    theCfgMgr,
                                    theGroupName,
                                    theGroupKey,
                                    theGroupInfo,
                                    theThreadDone);
                            },
                            this,
                            groupInfo.first,
                            groupInfo.second.getLastKey(),
                            sharedGroupInfoPtrs.back(),
                            threadDone[foundThreadIndex])
                            .detach();
 
                        ++threadsLaunched;
                        ++foundThreadIndex;
                    }  //end groupInfo thread loop
 
                    //check for all threads done
                    do
                    {
                        foundThreadIndex = -1;
                        for(int i = 0; i < numOfThreads; ++i)
                            if(!*(threadDone[i]))
                            {
                                foundThreadIndex = i;
                                break;
                            }
                        if(foundThreadIndex != -1)
                        {
                            __GEN_COUTT__ << "Waiting for thread to finish... "
                                          << foundThreadIndex << __E__;
                            usleep(10000);
                        }
                    } while(foundThreadIndex != -1);  //end thread done search loop
 
                    //threads done now, so copy group info
                    size_t i = 0;
                    for(auto& groupInfo : allGroupInfo_)
                    {
                        groupInfo.second.latestKey_ = sharedGroupInfoPtrs[i]->latestKey_;
                        groupInfo.second.latestKeyGroupComment_ =
                            sharedGroupInfoPtrs[i]->latestKeyGroupComment_;
                        groupInfo.second.latestKeyGroupAuthor_ =
                            sharedGroupInfoPtrs[i]->latestKeyGroupAuthor_;
                        groupInfo.second.latestKeyGroupCreationTime_ =
                            sharedGroupInfoPtrs[i]->latestKeyGroupCreationTime_;
                        groupInfo.second.latestKeyGroupTypeString_ =
                            sharedGroupInfoPtrs[i]->latestKeyGroupTypeString_;
                        groupInfo.second.latestKeyMemberMap_ =
                            sharedGroupInfoPtrs[i]->latestKeyMemberMap_;
                        ++i;
                    }  //end copy group info loop
 
                }  //end multi-thread handling
            }
        }  // end get group info
        catch(const std::runtime_error& e)
        {
            __SS__
                << "A fatal error occurred reading the info for all table groups. Error: "
                << e.what() << __E__;
            __GEN_COUT_ERR__ << "Error at time: " << time(0) << "\n" << ss.str();
            if(accumulatedWarnings)
                *accumulatedWarnings += ss.str();
            else
                throw;
        }
        catch(...)
        {
            __SS__ << "An unknown fatal error occurred reading the info for all table "
                      "groups."
                   << __E__;
            try
            {
                throw;
            }  //one more try to printout extra info
            catch(const std::exception& e)
            {
                ss << "Exception message: " << e.what();
            }
            catch(...)
            {
            }
            __GEN_COUT_ERR__ << "\n" << ss.str();
            if(accumulatedWarnings)
                *accumulatedWarnings += ss.str();
            else
                throw;
        }
        __GEN_COUTT__ << "Group Info end runTimeSeconds()=" << runTimeSeconds() << __E__;
    }  //end getGroupInfo
    else
        __GEN_COUTT__ << "Table Info end runTimeSeconds()=" << runTimeSeconds() << __E__;
 
    return allTableInfo_;
}  // end getAllTableInfo()
 
//==============================================================================
void ConfigurationManagerRW::loadTableInfoThread(
    ConfigurationManagerRW*            cfgMgr,
    std::string                        tableName,
    TableBase*                         existingTable,
    std::shared_ptr<ots::TableInfo>    tableInfo,
    std::shared_ptr<std::atomic<bool>> threadDone)
try
{
    __COUTT__ << "Thread started... table " << tableName << __E__;
 
    // 0 will force the creation of new instance (and reload from Info)
    tableInfo->tablePtr_ = 0;
 
    try  // only add valid table instances to maps
    {
        cfgMgr->theInterface_->get(tableInfo->tablePtr_,
                                   tableName,
                                   0,
                                   0,
                                   true);  // dont fill
    }
    catch(cet::exception const&)
    {
        if(tableInfo->tablePtr_)
            delete tableInfo->tablePtr_;
        tableInfo->tablePtr_ = 0;
 
        __COUT__ << "Skipping! No valid class found for... " << tableName << "\n";
        *(threadDone) = true;
        return;
    }
    catch(std::runtime_error& e)
    {
        if(tableInfo->tablePtr_)
            delete tableInfo->tablePtr_;
        tableInfo->tablePtr_ = 0;
 
        __COUT__ << "Skipping! No valid class found for... " << tableName << "\n";
        __COUTT__ << "Error: " << e.what() << __E__;
 
        // for a runtime_error, it is likely that columns are the problem
        //  the Table Editor needs to still fix these.. so attempt to
        //  proceed.
        if(tableInfo->accumulatedWarnings_ == "ALLOW")
        {
            tableInfo->accumulatedWarnings_ = "";
            if(1)  //errorFilterName == "" || errorFilterName == tableName)
            {
                tableInfo->accumulatedWarnings_ += std::string("\nIn table '") +
                                                   tableName + "'..." +
                                                   e.what();  // global accumulate
 
                __SS__ << "Attempting to allow illegal columns!" << __E__;
                tableInfo->accumulatedWarnings_ += ss.str();
            }
 
            // attempt to recover and build a mock-up
            __COUT__ << "Attempting to allow illegal columns!" << __E__;
 
            std::string returnedAccumulatedErrors;
            try
            {
                tableInfo->tablePtr_ =
                    new TableBase(tableName, &returnedAccumulatedErrors);
            }
            catch(...)
            {
                __COUT__ << "Skipping! Allowing illegal columns didn't work either... "
                         << tableName << "\n";
                *(threadDone) = true;
                return;
            }
            __COUT_WARN__ << "Error (but allowed): " << returnedAccumulatedErrors
                          << __E__;
 
            if(1)  //errorFilterName == "" || errorFilterName == entry->d_name)
                tableInfo->accumulatedWarnings_ +=
                    std::string("\nIn table '") + tableName + "'..." +
                    returnedAccumulatedErrors;  // global accumulate
        }
        else
        {
            tableInfo->accumulatedWarnings_ = "";
            *(threadDone)                   = true;
            return;
        }
    }
 
    if(existingTable)  // handle if instance existed
    {
        __COUTT__ << "Copying temporary version from existing table object for "
                  << tableName << __E__;
        // copy the existing temporary versions! (or else all is lost)
        std::set<TableVersion> versions = existingTable->getStoredVersions();
        for(auto& version : versions)
            if(version.isTemporaryVersion())
            {
                try  // do NOT let TableView::init() throw here
                {
                    existingTable->setActiveView(version);
                    tableInfo->tablePtr_->copyView(  // this calls TableView::init()
                        existingTable->getView(),
                        version,
                        cfgMgr->username_);
                }
                catch(...)  // do NOT let invalid temporary version throw at this
                            // point
                {
                }  // just trust configurationBase throws out the failed version
            }
 
        delete existingTable;
        existingTable = 0;
    }
 
    tableInfo->versions_ = cfgMgr->theInterface_->getVersions(tableInfo->tablePtr_);
 
    // also add any existing temporary versions to all table info
    //  because the interface wont find those versions
    std::set<TableVersion> versions = tableInfo->tablePtr_->getStoredVersions();
    for(auto& version : versions)
        if(version.isTemporaryVersion())
        {
            tableInfo->versions_.emplace(version);
        }
 
    __COUTT__ << "Thread done... table " << tableName << __E__;
    *(threadDone) = true;
}  // end loadTableInfoThread
catch(...)
{
    __COUT_ERR__ << "Error occurred loading latest table info into cache for '"
                 << tableName << "'..." << __E__;
    *(threadDone) = true;
}  // end loadTableInfoThread catch
 
//==============================================================================
void ConfigurationManagerRW::loadTableGroup(
    const std::string&   groupName,
    const TableGroupKey& groupKey,
    bool                 doActivate /*=false*/,
    std::map<std::string /*table name*/, TableVersion>*
                 groupMembers /*=0 , note: db time intensive! */,
    ProgressBar* progressBar /*=0*/,
    std::string* accumulatedWarnings /*=0*/,
    std::string* groupComment /*=0 , note: in metadata */,
    std::string* groupAuthor /*=0 , note: in metadata */,
    std::string* groupCreateTime /*=0 , note: in metadata */,
    bool         doNotLoadMembers /*=false*/,
    std::string* groupTypeString /*=0 , note: db time intensive! */,
    std::map<std::string /*name*/, std::string /*alias*/>*
        groupAliases /*=0 , note: in metadata */,
    ConfigurationManager::LoadGroupType
         groupTypeToLoad /*=ConfigurationManager::LoadGroupType::ALL_TYPES*/,
    bool ignoreVersionTracking /*=false*/)
{
    ConfigurationManager::loadTableGroup(groupName,
                                         groupKey,
                                         doActivate,
                                         groupMembers,
                                         progressBar,
                                         accumulatedWarnings,
                                         groupComment,
                                         groupAuthor,
                                         groupCreateTime,
                                         doNotLoadMembers,
                                         groupTypeString,
                                         groupAliases,
                                         groupTypeToLoad,
                                         ignoreVersionTracking);
 
    if(!groupMembers || !groupMembers->size() || !groupComment || groupKey.isInvalid() ||
       !groupAuthor || !groupCreateTime)
        return;
 
    //treat successfull load as latest group key
    auto groupInfo = allGroupInfo_.find(groupName);
    if(groupInfo == allGroupInfo_.end())
        return;  //ignore if no group info cache
 
    groupInfo->second.latestKey_                  = groupKey;
    groupInfo->second.latestKeyGroupComment_      = *groupComment;
    groupInfo->second.latestKeyGroupAuthor_       = *groupAuthor;
    groupInfo->second.latestKeyGroupCreationTime_ = *groupCreateTime;
    if(groupTypeString)  //assume unlikely to change types
        groupInfo->second.latestKeyGroupTypeString_ = *groupTypeString;
    groupInfo->second.latestKeyMemberMap_ = *groupMembers;
 
}  //end loadTableGroup() RW version
 
//==============================================================================
void ConfigurationManagerRW::loadTableGroupThread(
    ConfigurationManagerRW*            cfgMgr,
    std::string                        groupName,
    ots::TableGroupKey                 groupKey,
    std::shared_ptr<ots::GroupInfo>    groupInfo,
    std::shared_ptr<std::atomic<bool>> threadDone)
try
{
    __COUTT__ << "Thread started... " << groupName << "(" << groupKey << ")" << __E__;
 
    groupInfo->latestKey_ = groupKey;
    cfgMgr->loadTableGroup(groupName,
                           groupKey,
                           false /*doActivate*/,
                           &(groupInfo->latestKeyMemberMap_) /*groupMembers*/,
                           0 /*progressBar*/,
                           0 /*accumulateErrors*/,
                           &(groupInfo->latestKeyGroupComment_),
                           &(groupInfo->latestKeyGroupAuthor_),
                           &(groupInfo->latestKeyGroupCreationTime_),
                           true /*doNotLoadMember*/,
                           &(groupInfo->latestKeyGroupTypeString_));
 
    *(threadDone) = true;
}  // end loadTableGroupThread
catch(...)
{
    __COUT_WARN__ << "Error occurred loading latest group info into cache for '"
                  << groupName << "(" << groupInfo->latestKey_ << ")'..." << __E__;
    groupInfo->latestKey_                  = TableGroupKey::INVALID;
    groupInfo->latestKeyGroupComment_      = ConfigurationManager::UNKNOWN_INFO;
    groupInfo->latestKeyGroupAuthor_       = ConfigurationManager::UNKNOWN_INFO;
    groupInfo->latestKeyGroupCreationTime_ = ConfigurationManager::UNKNOWN_TIME;
    groupInfo->latestKeyGroupTypeString_ = ConfigurationManager::GROUP_TYPE_NAME_UNKNOWN;
    groupInfo->latestKeyMemberMap_       = {};
    *(threadDone)                        = true;
}  // end loadTableGroupThread catch
 
//==============================================================================
void ConfigurationManagerRW::compareTableGroupThread(
    ConfigurationManagerRW*                                      cfgMgr,
    std::string                                                  groupName,
    ots::TableGroupKey                                           groupKeyToCompare,
    const std::map<std::string, TableVersion>&                   groupMemberMap,
    const std::map<std::string /*name*/, std::string /*alias*/>& memberTableAliases,
    std::atomic<bool>*                                           foundIdentical,
    ots::TableGroupKey*                                          identicalKey,
    std::mutex*                                                  threadMutex,
    std::shared_ptr<std::atomic<bool>>                           threadDone)
try
{
    std::map<std::string /*name*/, TableVersion /*version*/> compareToMemberMap;
    std::map<std::string /*name*/, std::string /*alias*/>    compareToMemberTableAliases;
    std::map<std::string /*name*/, std::string /*alias*/>*
        compareToMemberTableAliasesPtr = nullptr;
    if(memberTableAliases
           .size())  //only give pointer if necessary, without will load group faster
        compareToMemberTableAliasesPtr = &compareToMemberTableAliases;
 
    cfgMgr->loadTableGroup(groupName,
                           groupKeyToCompare,
                           false /*doActivate*/,
                           &compareToMemberMap /*memberMap*/,
                           0, /*progressBar*/
                           0, /*accumulatedWarnings*/
                           0, /*groupComment*/
                           0,
                           0, /*null pointers*/
                           true /*doNotLoadMember*/,
                           0 /*groupTypeString*/,
                           compareToMemberTableAliasesPtr);
 
    bool debug = false;
    if(TTEST(9))  // = DEBUG+9
    {
        debug = true;
        for(auto& memberPair : groupMemberMap)
            __COUTS__(9) << "member " << memberPair.first << " (" << memberPair.second
                         << ")" << __E__;
        for(auto& memberPair : compareToMemberMap)
            __COUTS__(9) << "compare " << groupName << " (" << groupKeyToCompare
                         << ") member:" << memberPair.first << " (" << memberPair.second
                         << ")" << __E__;
    }
 
    bool isDifferent = false;
    for(auto& memberPair : groupMemberMap)
    {
        if(memberTableAliases.find(memberPair.first) != memberTableAliases.end())
        {
            // handle this table as alias, not version
            if(compareToMemberTableAliases.find(memberPair.first) ==
                   compareToMemberTableAliases.end() ||  // alias is missing
               memberTableAliases.at(memberPair.first) !=
                   compareToMemberTableAliases.at(memberPair.first))
            {  // then different
                isDifferent = true;
                if(debug)
                    __COUTT__ << "diff " << groupName << " (" << groupKeyToCompare
                              << ") on alias " << memberPair.first << __E__;
                break;
            }
            else
                continue;
        }  // else check if compareTo group is using an alias for table
        else if(compareToMemberTableAliases.find(memberPair.first) !=
                compareToMemberTableAliases.end())
        {
            // then different
            isDifferent = true;
            if(debug)
                __COUTT__ << "diff " << groupName << " (" << groupKeyToCompare
                          << ") on reverse alias " << memberPair.first << __E__;
            break;
 
        }  // else handle as table version comparison
        else if(compareToMemberMap.find(memberPair.first) ==
                    compareToMemberMap.end() ||  // name is missing
                memberPair.second !=
                    compareToMemberMap.at(memberPair.first))  // or version mismatch
        {
            // then different
            isDifferent = true;
            if(debug)
                __COUTT__ << "diff " << groupName << " (" << groupKeyToCompare
                          << ") on mismatch " << memberPair.first << __E__;
            break;
        }
    }
 
    // check member size for exact match
    if(!isDifferent &&
       groupMemberMap.size() !=
           compareToMemberMap
               .size())  // different size, so not same (groupMemberMap is a subset of memberPairs)
    {
        isDifferent = true;
 
        if(debug)
            __COUTT__ << "diff " << groupName << " (" << groupKeyToCompare << ") on size "
                      << __E__;
    }
 
    if(!isDifferent)  //found an exact match!
    {
        *foundIdentical = true;
        __COUT__ << "=====> Found exact match with key: " << groupKeyToCompare << __E__;
 
        std::lock_guard<std::mutex> lock(*threadMutex);
        *identicalKey = groupKeyToCompare;
    }
 
    *(threadDone) = true;
}  // end compareTableGroupThread
catch(...)
{
    __COUT_WARN__ << "Error occurred comparing group '" << groupName << "("
                  << groupKeyToCompare << ")'..." << __E__;
 
    *(threadDone) = true;
}  // end compareTableGroupThread catch
 
//==============================================================================
std::map<std::string /*table name*/,
         std::map<std::string /*version alias*/, TableVersion /*aliased version*/>>
ConfigurationManagerRW::getVersionAliases(void) const
{
    std::map<std::string /*table name*/,
             std::map<std::string /*version alias*/, TableVersion /*aliased version*/>>
        retMap = ConfigurationManager::getVersionAliases();
 
    // always have scratch alias for each table that has a scratch version
    //  overwrite map entry if necessary
    if(!ConfigurationInterface::isVersionTrackingEnabled())
        for(const auto& tableInfo : allTableInfo_)
            for(const auto& version : tableInfo.second.versions_)
                if(version.isScratchVersion())
                    retMap[tableInfo.first][ConfigurationManager::SCRATCH_VERSION_ALIAS] =
                        TableVersion(TableVersion::SCRATCH);
 
    return retMap;
}  // end getVersionAliases()
 
//==============================================================================
void ConfigurationManagerRW::activateTableGroup(const std::string& tableGroupName,
                                                TableGroupKey      tableGroupKey,
                                                std::string*       accumulatedTreeErrors,
                                                std::string*       groupTypeString)
{
    try
    {
        loadTableGroup(tableGroupName,
                       tableGroupKey,
                       true,                   // loads and activates
                       0,                      // no members needed
                       0,                      // no progress bar
                       accumulatedTreeErrors,  // accumulate warnings or not
                       0 /* groupComment */,
                       0 /* groupAuthor */,
                       0 /* groupCreateTime */,
                       false /* doNotLoadMember */,
                       groupTypeString);
    }
    catch(...)
    {
        __GEN_COUT_ERR__ << "There were errors, so de-activating group: "
                         << tableGroupName << " (" << tableGroupKey << ")" << __E__;
        try  // just in case any lingering pieces, let's deactivate
        {
            destroyTableGroup(tableGroupName, true);
        }
        catch(...)
        {
        }
        throw;  // re-throw original exception
    }
 
    __GEN_COUT_INFO__ << "Updating persistent active groups to "
                      << ConfigurationManager::ACTIVE_GROUPS_FILENAME << " ..." << __E__;
 
    __COUT_INFO__ << "Active Context table group: " << theContextTableGroup_ << "("
                  << (theContextTableGroupKey_
                          ? theContextTableGroupKey_->toString().c_str()
                          : "-1")
                  << ")" << __E__;
    __COUT_INFO__ << "Active Backbone table group: " << theBackboneTableGroup_ << "("
                  << (theBackboneTableGroupKey_
                          ? theBackboneTableGroupKey_->toString().c_str()
                          : "-1")
                  << ")" << __E__;
    __COUT_INFO__ << "Active Iterate table group: " << theIterateTableGroup_ << "("
                  << (theIterateTableGroupKey_
                          ? theIterateTableGroupKey_->toString().c_str()
                          : "-1")
                  << ")" << __E__;
    __COUT_INFO__ << "Active Configuration table group: " << theConfigurationTableGroup_
                  << "("
                  << (theConfigurationTableGroupKey_
                          ? theConfigurationTableGroupKey_->toString().c_str()
                          : "-1")
                  << ")" << __E__;
 
    std::string fn = ConfigurationManager::ACTIVE_GROUPS_FILENAME;
    FILE*       fp = fopen(fn.c_str(), "w");
    if(!fp)
    {
        __SS__ << "Fatal Error! Unable to open the file "
               << ConfigurationManager::ACTIVE_GROUPS_FILENAME
               << " for editing! Is there a permissions problem?" << __E__;
        __GEN_COUT_ERR__ << ss.str();
        __SS_THROW__;
        return;
    }
    fprintf(fp, "%s\n", theContextTableGroup_.c_str());
    fprintf(
        fp,
        "%s\n",
        theContextTableGroupKey_ ? theContextTableGroupKey_->toString().c_str() : "-1");
    fprintf(fp, "%s\n", theBackboneTableGroup_.c_str());
    fprintf(
        fp,
        "%s\n",
        theBackboneTableGroupKey_ ? theBackboneTableGroupKey_->toString().c_str() : "-1");
    fprintf(fp, "%s\n", theIterateTableGroup_.c_str());
    fprintf(
        fp,
        "%s\n",
        theIterateTableGroupKey_ ? theIterateTableGroupKey_->toString().c_str() : "-1");
    fprintf(fp, "%s\n", theConfigurationTableGroup_.c_str());
    fprintf(fp,
            "%s\n",
            theConfigurationTableGroupKey_
                ? theConfigurationTableGroupKey_->toString().c_str()
                : "-1");
    fclose(fp);
 
    // save last activated group
    {
        std::pair<std::string /*group name*/, TableGroupKey> activatedGroup(
            std::string(tableGroupName), tableGroupKey);
        if(theConfigurationTableGroupKey_ &&
           theConfigurationTableGroup_ == tableGroupName &&
           *theConfigurationTableGroupKey_ == tableGroupKey)
        {
            ConfigurationManager::saveGroupNameAndKey(
                activatedGroup,
                ConfigurationManager::LAST_ACTIVATED_CONFIG_GROUP_FILE,
                false /* appendMode */,
                username_);
            ConfigurationManager::saveGroupNameAndKey(
                activatedGroup,
                ConfigurationManager::ACTIVATED_CONFIGS_FILE,
                true /* appendMode */,
                username_);
        }
        else if(theContextTableGroupKey_ && theContextTableGroup_ == tableGroupName &&
                *theContextTableGroupKey_ == tableGroupKey)
        {
            ConfigurationManager::saveGroupNameAndKey(
                activatedGroup,
                ConfigurationManager::LAST_ACTIVATED_CONTEXT_GROUP_FILE,
                false /* appendMode */,
                username_);
            ConfigurationManager::saveGroupNameAndKey(
                activatedGroup,
                ConfigurationManager::ACTIVATED_CONTEXTS_FILE,
                true /* appendMode */,
                username_);
        }
        else if(theBackboneTableGroupKey_ && theBackboneTableGroup_ == tableGroupName &&
                *theBackboneTableGroupKey_ == tableGroupKey)
        {
            ConfigurationManager::saveGroupNameAndKey(
                activatedGroup,
                ConfigurationManager::LAST_ACTIVATED_BACKBONE_GROUP_FILE,
                false /* appendMode */,
                username_);
            ConfigurationManager::saveGroupNameAndKey(
                activatedGroup,
                ConfigurationManager::ACTIVATED_BACKBONES_FILE,
                true /* appendMode */,
                username_);
        }
        else if(theIterateTableGroupKey_ && theIterateTableGroup_ == tableGroupName &&
                *theIterateTableGroupKey_ == tableGroupKey)
        {
            ConfigurationManager::saveGroupNameAndKey(
                activatedGroup,
                ConfigurationManager::LAST_ACTIVATED_ITERATE_GROUP_FILE,
                false /* appendMode */,
                username_);
            ConfigurationManager::saveGroupNameAndKey(
                activatedGroup,
                ConfigurationManager::ACTIVATED_ITERATES_FILE,
                true /* appendMode */,
                username_);
        }
    }  // end save last activated group
 
}  // end activateTableGroup()
 
//==============================================================================
TableVersion ConfigurationManagerRW::createTemporaryBackboneView(
    TableVersion sourceViewVersion)
{
    __GEN_COUT_INFO__ << "Creating temporary backbone view from version "
                      << sourceViewVersion << __E__;
 
    // find common available temporary version among backbone members
    TableVersion tmpVersion =
        TableVersion::getNextTemporaryVersion();  // get the default temporary version
    TableVersion retTmpVersion;
    auto         backboneMemberNames = ConfigurationManager::getBackboneMemberNames();
    for(auto& name : backboneMemberNames)
    {
        retTmpVersion =
            ConfigurationManager::getTableByName(name)->getNextTemporaryVersion();
        if(retTmpVersion < tmpVersion)
            tmpVersion = retTmpVersion;
    }
 
    __GEN_COUT__ << "Common temporary backbone version found as " << tmpVersion << __E__;
 
    // create temporary views from source version to destination temporary version
    for(auto& name : backboneMemberNames)
    {
        retTmpVersion =
            getTableByName(name)->createTemporaryView(sourceViewVersion, tmpVersion);
        if(retTmpVersion != tmpVersion)
        {
            __SS__ << "Failure! Temporary view requested was " << tmpVersion
                   << ". Mismatched temporary view created: " << retTmpVersion << __E__;
            __GEN_COUT_ERR__ << ss.str();
            __SS_THROW__;
        }
    }
 
    return tmpVersion;
}  // end createTemporaryBackboneView()
 
//==============================================================================
TableBase* ConfigurationManagerRW::getTableByName(const std::string& tableName)
{
    if(nameToTableMap_.find(tableName) == nameToTableMap_.end())
    {
        if(tableName == ConfigurationManager::ARTDAQ_TOP_TABLE_NAME)
        {
            __GEN_COUT_WARN__
                << "Since target table was the artdaq top configuration level, "
                   "attempting to help user by appending to core tables file: "
                << CORE_TABLE_INFO_FILENAME << __E__;
            FILE* fp = fopen((CORE_TABLE_INFO_FILENAME).c_str(), "a");
            if(fp)
            {
                fprintf(fp, "\nARTDAQ/*");
                fclose(fp);
            }
        }
 
        __SS__ << "Table not found with name: " << tableName << __E__;
        size_t f;
        if((f = tableName.find(' ')) != std::string::npos)
            ss << "There was a space character found in the table name needle at "
                  "position "
               << f << " in the string (was this intended?). " << __E__;
 
        ss << "\nIf you think this table should exist in the core set of tables, try "
              "running 'UpdateOTS.sh --tables' to update your tables, then relaunch ots."
           << __E__;
        ss << "\nTables must be defined at path $USER_DATA/TableInfo/ to exist in ots. "
              "Please verify your table definitions, and then restart ots."
           << __E__;
        __GEN_COUT_ERR__ << "\n" << ss.str();
        __SS_THROW__;
    }
    return nameToTableMap_[tableName];
}  // end getTableByName()
 
//==============================================================================
TableBase* ConfigurationManagerRW::getVersionedTableByName(
    const std::string& tableName,
    TableVersion       version,
    bool               looseColumnMatching /* = false */,
    std::string*       accumulatedErrors /* = 0 */,
    bool               getRawData /* = false */)
{
    auto it = nameToTableMap_.find(tableName);
    if(it == nameToTableMap_.end())
    {
        __SS__ << "\nCan not find table named '" << tableName
               << "'\n\n\n\nYou need to load the table before it can be used."
               << "It probably is missing from the member list of the Table "
                  "Group that was loaded?\n\n\n\n\n"
               << __E__;
        __SS_THROW__;
    }
    TableBase* table = it->second;
 
    if(version.isTemporaryVersion())
    {
        table->setActiveView(version);
 
        if(getRawData)
        {
            std::stringstream jsonSs;
            table->getViewP()->printJSON(jsonSs);
            table->getViewP()->doGetSourceRawData(true);
            table->getViewP()->fillFromJSON(jsonSs.str());
        }
    }
    else
    {
        theInterface_->get(table,
                           tableName,
                           0 /* groupKey */,
                           0 /* groupName */,
                           false /* dontFill */,  // false to fill w/version
                           version,
                           false /* resetConfiguration*/,  // false to not reset
                           looseColumnMatching,
                           getRawData,
                           accumulatedErrors);
    }
    return table;
}  // end getVersionedTableByName()
 
//==============================================================================
TableVersion ConfigurationManagerRW::saveNewTable(const std::string& tableName,
                                                  TableVersion       temporaryVersion,
                                                  bool               makeTemporary)  //,
{
    TableVersion newVersion(temporaryVersion);
 
    // set author of version
    TableBase* table = getTableByName(tableName);
    table->getTemporaryView(temporaryVersion)->setAuthor(username_);
    // NOTE: author is assigned to permanent versions when saved to DBI
 
    if(!makeTemporary)  // saveNewVersion makes the new version the active version
        newVersion = theInterface_->saveNewVersion(table, temporaryVersion);
    else  // make the temporary version active
        table->setActiveView(newVersion);
 
    // if there is a problem, try to recover
    while(!makeTemporary && !newVersion.isScratchVersion() &&
          allTableInfo_[tableName].versions_.find(newVersion) !=
              allTableInfo_[tableName].versions_.end())
    {
        __GEN_COUT_ERR__
            << "What happenened!?? ERROR::: new persistent version v" << newVersion
            << " already exists!? How is it possible? Retrace your steps and "
               "tell an admin."
            << __E__;
 
        // create a new temporary version of the target view
        temporaryVersion = table->createTemporaryView(newVersion);
 
        if(newVersion.isTemporaryVersion())
            newVersion = temporaryVersion;
        else
            newVersion = TableVersion::getNextVersion(newVersion);
 
        __GEN_COUT_WARN__ << "Attempting to recover and use v" << newVersion << __E__;
 
        if(!makeTemporary)  // saveNewVersion makes the new version the active version
            newVersion =
                theInterface_->saveNewVersion(table, temporaryVersion, newVersion);
        else  // make the temporary version active
            table->setActiveView(newVersion);
    }
 
    if(newVersion.isInvalid())
    {
        __SS__ << "Something went wrong saving the new version v" << newVersion
               << ". What happened?! (duplicates? database error?)" << __E__;
        __GEN_COUT_ERR__ << "\n" << ss.str();
        __SS_THROW__;
    }
 
    // update allTableInfo_ with the new version
    allTableInfo_[tableName].versions_.insert(newVersion);
 
    // table->getView().print();
    return newVersion;
}  // end saveNewTable()
 
//==============================================================================
void ConfigurationManagerRW::eraseTemporaryVersion(const std::string& tableName,
                                                   TableVersion       targetVersion)
{
    TableBase* table = getTableByName(tableName);
 
    table->trimTemporary(targetVersion);
 
    // if allTableInfo_ is not setup, then done
    if(allTableInfo_.find(tableName) == allTableInfo_.end())
        return;
    // else cleanup table info
 
    if(targetVersion.isInvalid())
    {
        // erase all temporary versions!
        for(auto it = allTableInfo_[tableName].versions_.begin();
            it != allTableInfo_[tableName].versions_.end();
            /*no increment*/)
        {
            if(it->isTemporaryVersion())
            {
                __GEN_COUT__ << "Removing '" << tableName << "' version info: " << *it
                             << __E__;
                allTableInfo_[tableName].versions_.erase(it++);
            }
            else
                ++it;
        }
    }
    else  // erase target version only
    {
        //__GEN_COUT__ << "Removing '" << tableName << "' version info: " << targetVersion << __E__;
        auto it = allTableInfo_[tableName].versions_.find(targetVersion);
        if(it == allTableInfo_[tableName].versions_.end())
        {
            __GEN_COUT__ << "Target '" << tableName << "' version v" << targetVersion
                         << " was not found in info versions..." << __E__;
            return;
        }
        allTableInfo_[tableName].versions_.erase(
            allTableInfo_[tableName].versions_.find(targetVersion));
    }
}  // end eraseTemporaryVersion()
 
//==============================================================================
void ConfigurationManagerRW::clearCachedVersions(const std::string& tableName)
{
    TableBase* table = getTableByName(tableName);
 
    table->trimCache(0);
}  // end clearCachedVersions()
 
//==============================================================================
void ConfigurationManagerRW::clearAllCachedVersions()
{
    for(auto configInfo : allTableInfo_)
        configInfo.second.tablePtr_->trimCache(0);
}  // end clearAllCachedVersions()
 
//==============================================================================
TableVersion ConfigurationManagerRW::copyViewToCurrentColumns(
    const std::string& tableName, TableVersion sourceVersion)
{
    getTableByName(tableName)->reset();
 
    // make sure source version is loaded
    // need to load with loose column rules!
    TableBase* table =
        getVersionedTableByName(tableName, TableVersion(sourceVersion), true);
 
    // copy from source version to a new temporary version
    TableVersion newTemporaryVersion =
        table->copyView(table->getView(), TableVersion(), username_);
 
    // update allTableInfo_ with the new version
    allTableInfo_[tableName].versions_.insert(newTemporaryVersion);
 
    return newTemporaryVersion;
}  // end copyViewToCurrentColumns()
 
//==============================================================================
const GroupInfo& ConfigurationManagerRW::getGroupInfo(
    const std::string& groupName, bool attemptToReloadKeys /* = false */)
{
    //  //NOTE: seems like this filter is taking the long amount of time
    //  std::set<std::string /*name*/> fullGroupNames =
    //          theInterface_->getAllTableGroupNames(groupName); //db filter by group name
 
    // so instead caching ourselves...
    auto it = allGroupInfo_.find(groupName);
    if(it == allGroupInfo_.end())
    {
        __SS__ << "Group name '" << groupName
               << "' not found in group info! (creating empty info)" << __E__;
        __GEN_COUT_WARN__ << ss.str();
        //__SS_THROW__;
        return allGroupInfo_[groupName];
    }
 
    if(attemptToReloadKeys)  //load keys from Interface group cache
    {
        __GEN_COUT__ << "Reloading keys from special db group cache if it exists..."
                     << __E__;
 
        std::set<TableGroupKey> keys;
        {  //load keys from special db group cache (this avoids pre-cache filling and avoids long db lookup, unless speed table cache missing for this group)
            //attempt to use cache first! (potentially way faster .04 s vs 4 s)
            bool cacheFailed = false;
            try
            {
                TableBase localGroupMemberCacheLoader(
                    true /*special table*/
                    ,  //special table only allows 1 view in cache and does not load schema (which is perfect for this temporary table),,
                    TableBase::GROUP_CACHE_PREPEND + groupName);
                auto versions = theInterface_->getVersions(&localGroupMemberCacheLoader);
                for(const auto& version : versions)
                    keys.emplace(TableGroupKey(version.version()));
            }
            catch(...)
            {
                __GEN_COUT__ << "Ignoring cache loading error. Doing full load of keys..."
                             << __E__;
                cacheFailed = true;
            }
 
            if(cacheFailed && 0)  //could consider full load if cache failed
                keys = theInterface_->getKeys(groupName);
 
            if(!cacheFailed)  //take keys
            {
                __GEN_COUT__ << "Key from special db group cache were loaded." << __E__;
                it->second.keys_ = keys;  //update ConfigManager cache!
            }
        }
    }
 
    return it->second;
}  // end getGroupInfo()
 
//==============================================================================
TableGroupKey ConfigurationManagerRW::findTableGroup(
    const std::string&                                           groupName,
    const std::map<std::string, TableVersion>&                   groupMemberMap,
    const std::map<std::string /*name*/, std::string /*alias*/>& memberTableAliases)
{
    if(!groupMemberMap.size() || groupName.empty())
    {
        __SS__ << "Illegal name/members for requested group of name '" << groupName
               << "' and member count = " << groupMemberMap.size() << __E__;
        __SS_THROW__;
    }
 
    //  //NOTE: seems like this filter is taking the long amount of time
    //  std::set<std::string /*name*/> fullGroupNames =
    //          theInterface_->getAllTableGroupNames(groupName); //db filter bygroup  name
    // const GroupInfo& groupInfo = getGroupInfo(groupName); // Note this also seems to take too long because requires a pre-cache load!
    std::set<TableGroupKey> keys;
    {  //so instead load keys from special db group cache (this avoids pre-cache filling and avoids long db lookup, unless speed table cache missing for this group)
        //attempt to use cache first! (potentially way faster .04 s vs 4 s)
        bool cacheFailed = false;
        try
        {
            TableBase localGroupMemberCacheLoader(
                true /*special table*/
                ,  //special table only allows 1 view in cache and does not load schema (which is perfect for this temporary table),,
                TableBase::GROUP_CACHE_PREPEND + groupName);
            auto versions = theInterface_->getVersions(&localGroupMemberCacheLoader);
            for(const auto& version : versions)
                keys.emplace(TableGroupKey(version.version()));
        }
        catch(...)
        {
            __COUT__ << "Ignoring cache loading error. Doing full load of keys..."
                     << __E__;
            cacheFailed = true;
        }
 
        if(cacheFailed)  //since cache failed, do full load
            keys = theInterface_->getKeys(groupName);
    }
 
    __COUTTV__(StringMacros::setToString(keys));
 
    const unsigned int MAX_DEPTH_TO_CHECK = 20;
    unsigned int       keyMinToCheck      = 0;
 
    if(keys.size())
        keyMinToCheck = keys.rbegin()->key();
    if(keyMinToCheck > MAX_DEPTH_TO_CHECK)
    {
        keyMinToCheck -= MAX_DEPTH_TO_CHECK;
        __GEN_COUT__ << "Checking groups back to key... " << keyMinToCheck << __E__;
    }
    else
    {
        keyMinToCheck = 0;
        __GEN_COUT__ << "Checking all groups." << __E__;
    }
 
    __GEN_COUTTV__(StringMacros::mapToString(groupMemberMap));
 
    // have min key to check, now loop through and check groups
 
    const int numOfThreads = PROCESSOR_COUNT / 2;
    __GEN_COUT__ << " PROCESSOR_COUNT " << PROCESSOR_COUNT << " ==> " << numOfThreads
                 << " threads." << __E__;
    if(numOfThreads < 2)  // no multi-threading
    {
        std::map<std::string /*name*/, TableVersion /*version*/> compareToMemberMap;
        std::map<std::string /*name*/, std::string /*alias*/> compareToMemberTableAliases;
        std::map<std::string /*name*/, std::string /*alias*/>*
            compareToMemberTableAliasesPtr = nullptr;
        if(memberTableAliases.size())
            compareToMemberTableAliasesPtr = &compareToMemberTableAliases;
 
        bool isDifferent;
        for(const auto& key : keys)
        {
            if(key.key() < keyMinToCheck)
                continue;  // skip keys that are too old
 
            loadTableGroup(groupName,
                           key,
                           false /*doActivate*/,
                           &compareToMemberMap /*memberMap*/,
                           0, /*progressBar*/
                           0, /*accumulatedWarnings*/
                           0, /*groupComment*/
                           0, /*groupAuthor*/
                           0, /*groupCreateTime*/
                           true /*doNotLoadMember*/,
                           0 /*groupTypeString*/,
                           compareToMemberTableAliasesPtr);
 
            isDifferent = false;
            for(auto& memberPair : groupMemberMap)
            {
                if(memberTableAliases.find(memberPair.first) != memberTableAliases.end())
                {
                    // handle this table as alias, not version
                    if(compareToMemberTableAliases.find(memberPair.first) ==
                           compareToMemberTableAliases.end() ||  // alias is missing
                       memberTableAliases.at(memberPair.first) !=
                           compareToMemberTableAliases.at(memberPair.first))
                    {  // then different
                        isDifferent = true;
                        break;
                    }
                    else
                        continue;
                }  // else check if compareTo group is using an alias for table
                else if(compareToMemberTableAliases.find(memberPair.first) !=
                        compareToMemberTableAliases.end())
                {
                    // then different
                    isDifferent = true;
                    break;
 
                }  // else handle as table version comparison
                else if(compareToMemberMap.find(memberPair.first) ==
                            compareToMemberMap.end() ||  // name is missing
                        memberPair.second !=
                            compareToMemberMap.at(
                                memberPair.first))  // or version mismatch
                {
                    // then different
                    isDifferent = true;
                    break;
                }
            }
            if(isDifferent)
                continue;
 
            // check member size for exact match
            if(groupMemberMap.size() != compareToMemberMap.size())
                continue;  // different size, so not same (groupMemberMap is a subset of
                           // memberPairs)
 
            __GEN_COUT__ << "Found exact match with key: " << key << __E__;
            // else found an exact match!
            return key;
        }
        __GEN_COUT__ << "No match found - this group is new!" << __E__;
        // if here, then no match found
        return TableGroupKey();  // return invalid key
    }
    else  //multi-threading
    {
        int                threadsLaunched  = 0;
        int                foundThreadIndex = 0;
        std::atomic<bool>  foundIdentical   = false;
        ots::TableGroupKey identicalKey;
        std::mutex         threadMutex;
 
        std::vector<std::shared_ptr<std::atomic<bool>>> threadDone;
        for(int i = 0; i < numOfThreads; ++i)
            threadDone.push_back(std::make_shared<std::atomic<bool>>(true));
 
        for(const auto& key : keys)
        {
            if(foundIdentical)
                break;
            if(key.key() < keyMinToCheck)
                continue;  // skip keys that are too old
 
            if(threadsLaunched >= numOfThreads)
            {
                //find availableThreadIndex
                foundThreadIndex = -1;
                while(foundThreadIndex == -1)
                {
                    if(foundIdentical)
                        break;
 
                    for(int i = 0; i < numOfThreads; ++i)
                        if(*(threadDone[i]))
                        {
                            foundThreadIndex = i;
                            break;
                        }
                    if(foundThreadIndex == -1)
                    {
                        __GEN_COUTT__ << "Waiting for available thread..." << __E__;
                        usleep(10000);
                    }
                }  //end thread search loop
                threadsLaunched = numOfThreads - 1;
            }
            if(foundIdentical)
                break;
 
            __GEN_COUTT__ << "Starting thread... " << foundThreadIndex << __E__;
            *(threadDone[foundThreadIndex]) = false;
 
            std::thread(
                [](ConfigurationManagerRW*                    cfgMgr,
                   std::string                                theGroupName,
                   ots::TableGroupKey                         groupKeyToCompare,
                   const std::map<std::string, TableVersion>& groupMemberMap,
                   const std::map<std::string /*name*/, std::string /*alias*/>&
                                                      memberTableAliases,
                   std::atomic<bool>*                 theFoundIdentical,
                   ots::TableGroupKey*                theIdenticalKey,
                   std::mutex*                        theThreadMutex,
                   std::shared_ptr<std::atomic<bool>> theThreadDone) {
                    ConfigurationManagerRW::compareTableGroupThread(cfgMgr,
                                                                    theGroupName,
                                                                    groupKeyToCompare,
                                                                    groupMemberMap,
                                                                    memberTableAliases,
                                                                    theFoundIdentical,
                                                                    theIdenticalKey,
                                                                    theThreadMutex,
                                                                    theThreadDone);
                },
                this,
                groupName,
                key,
                groupMemberMap,
                memberTableAliases,
                &foundIdentical,
                &identicalKey,
                &threadMutex,
                threadDone[foundThreadIndex])
                .detach();
 
            ++threadsLaunched;
            ++foundThreadIndex;
        }  //end group key check thread loop
 
        //check for all threads done
        do
        {
            foundThreadIndex = -1;
            for(int i = 0; i < numOfThreads; ++i)
                if(!*(threadDone[i]))
                {
                    foundThreadIndex = i;
                    break;
                }
            if(foundThreadIndex != -1)
            {
                __GEN_COUTT__ << "Waiting for thread to finish... " << foundThreadIndex
                              << __E__;
                usleep(10000);
            }
        } while(foundThreadIndex != -1);  //end thread done search loop
 
        if(foundIdentical)
        {
            __GEN_COUT__ << "Found exact match with key: " << identicalKey << __E__;
            return identicalKey;
        }
 
        // if here, then no match found
        return TableGroupKey();  // return invalid key
    }                            //end multi-thread handling
}  // end findTableGroup()
 
//==============================================================================
TableBase* ConfigurationManagerRW::getMetadataTable(
    TableVersion fillVersion /* = TableVersion()*/)
{
    if(fillVersion.isInvalid())
        return &groupMetadataTable_;
    //else load specified fill version
 
    //only lock metadata table since it is shared by all group accesses
    std::lock_guard<std::mutex> lock(metaDataTableMutex_);
 
    // clear table
    while(groupMetadataTable_.getView().getNumberOfRows())
        groupMetadataTable_.getViewP()->deleteRow(0);
 
    // retrieve metadata from database
    try
    {
        theInterface_->fill(&groupMetadataTable_, fillVersion);
    }
    catch(const std::runtime_error& e)
    {
        __GEN_COUT_WARN__ << "Failed to load " << groupMetadataTable_.getTableName()
                          << "-v" << fillVersion << ". Metadata error: " << e.what()
                          << __E__;
    }
    catch(...)
    {
        __GEN_COUT_WARN__ << "Failed to load " << groupMetadataTable_.getTableName()
                          << "-v" << fillVersion << ". Ignoring unknown metadata error. "
                          << __E__;
    }
 
    // check that there is only 1 row
    if(groupMetadataTable_.getView().getNumberOfRows() != 1)
    {
        groupMetadataTable_.print();
        __GEN_COUT_ERR__ << "Ignoring that groupMetadataTable_ v" << fillVersion
                         << " has wrong "
                            "number of rows!' Must "
                            "be 1. Going with anonymous defaults."
                         << __E__;
 
        // fix metadata table
        while(groupMetadataTable_.getViewP()->getNumberOfRows() > 1)
            groupMetadataTable_.getViewP()->deleteRow(0);
        if(groupMetadataTable_.getViewP()->getNumberOfRows() == 0)
            groupMetadataTable_.getViewP()->addRow();
    }
 
    return &groupMetadataTable_;
}  // end getMetadataTable()
 
//==============================================================================
TableGroupKey ConfigurationManagerRW::saveNewTableGroup(
    const std::string&                                      groupName,
    std::map<std::string, TableVersion>&                    groupMembers,
    const std::string&                                      groupComment,
    std::map<std::string /*table*/, std::string /*alias*/>* groupAliases)
{
    // steps:
    //  determine new group key
    //  verify group members
    //  verify groupNameWithKey
    //  verify store
 
    if(groupMembers.size() == 0)  // do not allow empty groups
    {
        __SS__ << "Empty group member list. Can not create a group without members!"
               << __E__;
        __SS_THROW__;
    }
 
    __GEN_COUTT__ << "saveNewTableGroup runTimeSeconds()=" << runTimeSeconds() << __E__;
 
    //  verify group members
    //      - use all table info
    std::map<std::string, TableInfo> allCfgInfo = getAllTableInfo();
    for(auto& memberPair : groupMembers)
    {
        // check member name
        if(allCfgInfo.find(memberPair.first) == allCfgInfo.end())
        {
            __GEN_COUT_ERR__ << "Group member \"" << memberPair.first
                             << "\" not found in database!";
 
            if(groupMetadataTable_.getTableName() == memberPair.first)
            {
                __GEN_COUT_WARN__
                    << "Looks like this is the groupMetadataTable_ '"
                    << TableBase::GROUP_METADATA_TABLE_NAME
                    << ".' Note that this table is added to the member map when groups "
                       "are saved."
                    << "It should not be part of member map when calling this function."
                    << __E__;
                __GEN_COUT__ << "Attempting to recover." << __E__;
                groupMembers.erase(groupMembers.find(memberPair.first));
            }
            else
            {
                __SS__ << ("Group member not found!") << __E__;
                __SS_THROW__;
            }
        }
        // check member version
        if(allCfgInfo[memberPair.first].versions_.find(memberPair.second) ==
           allCfgInfo[memberPair.first].versions_.end())
        {
            __SS__ << "Group member  \"" << memberPair.first << "\" version \""
                   << memberPair.second << "\" not found in database!";
            __SS_THROW__;
        }
    }  // end verify members
 
    __GEN_COUTT__ << "saveNewTableGroup runTimeSeconds()=" << runTimeSeconds() << __E__;
 
    // verify group aliases
    if(groupAliases)
    {
        for(auto& aliasPair : *groupAliases)
        {
            // check for alias table in member names
            if(groupMembers.find(aliasPair.first) == groupMembers.end())
            {
                __GEN_COUT_ERR__ << "Group member \"" << aliasPair.first
                                 << "\" not found in group member map!";
 
                __SS__ << ("Alias table not found in member list!") << __E__;
                __SS_THROW__;
            }
        }
    }  // end verify group aliases
 
    TableGroupKey newKey =
        TableGroupKey::getNextKey(theInterface_->findLatestGroupKey(groupName));
    __GEN_COUT__ << "New Key for group: " << groupName << " found as " << newKey << __E__;
    __GEN_COUTT__ << "saveNewTableGroup runTimeSeconds()=" << runTimeSeconds() << __E__;
 
    time_t groupCreationTime = time(0);
    // capture group type before adding metadata table!
    std::string groupType = getTypeNameOfGroup(groupMembers);
    std::map<std::string /*name*/, TableVersion /*version*/> groupMembersWithoutMeta =
        groupMembers;
 
    // verify groupNameWithKey and attempt to store
    try
    {
        // save meta data for group; reuse groupMetadataTable_
        std::string groupAliasesString = "";
        if(groupAliases)
            groupAliasesString = StringMacros::mapToString(
                *groupAliases, "," /*primary delimeter*/, ":" /*secondary delimeter*/);
        __GEN_COUT__ << "Metadata: " << username_ << " " << groupCreationTime << " "
                     << groupComment << " " << groupAliasesString << " " << groupType
                     << __E__;
 
        // to compensate for unusual errors upstream, make sure the metadata table has one
        // row
        while(groupMetadataTable_.getViewP()->getNumberOfRows() > 1)
            groupMetadataTable_.getViewP()->deleteRow(0);
        if(groupMetadataTable_.getViewP()->getNumberOfRows() == 0)
            groupMetadataTable_.getViewP()->addRow();
 
        // columns are uid,comment,author,time
        groupMetadataTable_.getViewP()->setValue(
            groupAliasesString, 0, ConfigurationManager::METADATA_COL_ALIASES);
        groupMetadataTable_.getViewP()->setValue(
            groupComment, 0, ConfigurationManager::METADATA_COL_COMMENT);
        groupMetadataTable_.getViewP()->setValue(
            username_, 0, ConfigurationManager::METADATA_COL_AUTHOR);
        groupMetadataTable_.getViewP()->setValue(
            groupCreationTime, 0, ConfigurationManager::METADATA_COL_TIMESTAMP);
 
        if(TTEST(2))
        {
            std::stringstream ss;
            groupMetadataTable_.print(ss);
            __COUT_MULTI__(2, ss.str());
        }
 
        // save table, and retry on save collision
        {
            // set version to first available persistent version
            TableVersion newVersion = TableVersion::getNextVersion(
                theInterface_->findLatestVersion(&groupMetadataTable_));
            groupMetadataTable_.getViewP()->setVersion(newVersion);
 
            uint16_t retries = 0;
            while(1)
            {
                try
                {
                    theInterface_->saveActiveVersion(&groupMetadataTable_);
                }
                catch(const std::runtime_error& e)
                {
                    __GEN_COUT__ << "Caught runtime_error exception during table save."
                                 << __E__;
                    if(std::string(e.what()).find("there was a collision") !=
                       std::string::npos)
                    {
                        __GEN_COUT_WARN__
                            << "There was a collision saving the new table "
                            << groupMetadataTable_ << "(" << newVersion
                            << "), trying incremented table version... retries="
                            << retries << __E__;
                        if(++retries > 3)  //give up
                            throw;
                        newVersion = TableVersion::getNextVersion(
                            newVersion);  //increment table version
                        groupMetadataTable_.getViewP()->setVersion(newVersion);
                        __GEN_COUT__ << "New version for table: " << groupMetadataTable_
                                     << " found as " << newVersion << __E__;
                        continue;
                    }
                    else
                        throw;
                }
 
                __GEN_COUT__ << "Created table: " << groupMetadataTable_ << "-v"
                             << newVersion << __E__;
                break;
            }  //end collission retry loop
        }
 
        __GEN_COUTT__ << "saveNewTableGroup runTimeSeconds()=" << runTimeSeconds()
                      << __E__;
 
        // force groupMetadataTable_ to be a member for the group
        groupMembers[groupMetadataTable_.getTableName()] =
            groupMetadataTable_.getViewVersion();
 
        // save group, and retry on save collision
        {
            uint16_t retries = 0;
            while(1)
            {
                __GEN_COUTT__ << "saveNewTableGroup runTimeSeconds()=" << runTimeSeconds()
                              << __E__;
 
                try
                {
                    theInterface_->saveTableGroup(
                        groupMembers,
                        TableGroupKey::getFullGroupString(groupName, newKey));
                }
                catch(const std::runtime_error& e)
                {
                    __GEN_COUT__ << "Caught runtime_error exception during group save."
                                 << __E__;
                    if(std::string(e.what()).find("there was a collision") !=
                       std::string::npos)
                    {
                        __GEN_COUT_WARN__
                            << "There was a collision saving the new group " << groupName
                            << "(" << newKey
                            << "), trying incremented group key... retries=" << retries
                            << __E__;
                        if(++retries > 3)  //give up
                            throw;
                        newKey = TableGroupKey::getNextKey(newKey);  //increment group key
                        __GEN_COUT__ << "New Key for group: " << groupName << " found as "
                                     << newKey << __E__;
                        continue;
                    }
                    else
                        throw;
                }
 
                __GEN_COUT__ << "Created table group: " << groupName << "(" << newKey
                             << ")" << __E__;
                break;
            }  //end collission retry loop
        }
 
        __GEN_COUTT__ << "saveNewTableGroup runTimeSeconds()=" << runTimeSeconds()
                      << __E__;
    }
    catch(std::runtime_error& e)
    {
        __GEN_COUT_ERR__ << "Failed to create table group: " << groupName << "(" << newKey
                         << ")" << __E__;
        __GEN_COUT_ERR__ << "\n\n" << e.what() << __E__;
        throw;
    }
    catch(...)
    {
        __GEN_COUT_ERR__ << "Failed to create table group: " << groupName << ":" << newKey
                         << __E__;
        throw;
    }
 
    __GEN_COUTT__ << "saveNewTableGroup runTimeSeconds()=" << runTimeSeconds() << __E__;
 
    // store cache of recent groups
    allGroupInfo_[groupName].keys_.emplace(newKey);
    //update latest group info with this group's info
    allGroupInfo_.at(groupName).latestKey_                  = newKey;
    allGroupInfo_.at(groupName).latestKeyGroupAuthor_       = username_;
    allGroupInfo_.at(groupName).latestKeyGroupComment_      = groupComment;
    allGroupInfo_.at(groupName).latestKeyGroupCreationTime_ = groupCreationTime;
    allGroupInfo_.at(groupName).latestKeyGroupTypeString_   = groupType;
    allGroupInfo_.at(groupName).latestKeyMemberMap_         = groupMembersWithoutMeta;
 
    __GEN_COUT__ << "Saved " << groupName << "(" << newKey << ") of type " << groupType
                 << __E__;
 
    __GEN_COUTT__ << "saveNewTableGroup runTimeSeconds()=" << runTimeSeconds() << __E__;
 
    // at this point succeeded!
    return newKey;
}  // end saveNewTableGroup()
 
//==============================================================================
TableVersion ConfigurationManagerRW::saveNewBackbone(TableVersion temporaryVersion)
{
    __GEN_COUT_INFO__ << "Creating new backbone from temporary version "
                      << temporaryVersion << __E__;
 
    // find common available temporary version among backbone members
    TableVersion newVersion(TableVersion::DEFAULT);
    TableVersion retNewVersion;
    auto         backboneMemberNames = ConfigurationManager::getBackboneMemberNames();
    for(auto& name : backboneMemberNames)
    {
        retNewVersion = ConfigurationManager::getTableByName(name)->getNextVersion();
        __GEN_COUT__ << "New version for backbone member (" << name
                     << "): " << retNewVersion << __E__;
        if(retNewVersion > newVersion)
            newVersion = retNewVersion;
    }
 
    __GEN_COUT__ << "Common new backbone version found as " << newVersion << __E__;
 
    // create new views from source temporary version
    for(auto& name : backboneMemberNames)
    {
        // saveNewVersion makes the new version the active version
        retNewVersion = getConfigurationInterface()->saveNewVersion(
            getTableByName(name), temporaryVersion, newVersion);
        if(retNewVersion != newVersion)
        {
            __SS__ << "Failure! New view requested was " << newVersion
                   << ". Mismatched new view created: " << retNewVersion << __E__;
            __GEN_COUT_ERR__ << ss.str();
            __SS_THROW__;
        }
    }
 
    return newVersion;
}  // end saveNewBackbone()
 
//==============================================================================
TableVersion ConfigurationManagerRW::saveModifiedVersion(
    const std::string& tableName,
    TableVersion       originalVersion,
    bool               makeTemporary,
    TableBase*         table,
    TableVersion       temporaryModifiedVersion,
    bool               ignoreDuplicates /*= false*/,
    bool               lookForEquivalent /*= false*/,
    bool*              foundEquivalent /*= nullptr*/)
{
    bool needToEraseTemporarySource =
        (originalVersion.isTemporaryVersion() && !makeTemporary);
 
    if(foundEquivalent)
        *foundEquivalent = false;  // initialize
 
    // check for duplicate tables already in cache, plus highest version numbers not in cache
    if(!ignoreDuplicates)
    {
        __GEN_COUT__ << "Checking for duplicate '" << tableName << "' tables..." << __E__;
 
        TableVersion duplicateVersion;
 
        {
            //"DEEP" checking
            //  load into cache 'recent' versions for this table
            //      'recent' := those already in cache, plus highest version numbers not in cache
            const std::map<std::string, TableInfo>& allTableInfo =
                getAllTableInfo();  // do not refresh
 
            auto versionReverseIterator =
                allTableInfo.at(tableName).versions_.rbegin();  // get reverse iterator
            __GEN_COUT__ << "Filling up '" << tableName << "' cache from "
                         << table->getNumberOfStoredViews() << " to max count of "
                         << table->MAX_VIEWS_IN_CACHE << __E__;
            for(; table->getNumberOfStoredViews() < table->MAX_VIEWS_IN_CACHE &&
                  versionReverseIterator != allTableInfo.at(tableName).versions_.rend();
                ++versionReverseIterator)
            {
                __GEN_COUTT__ << "'" << tableName << "' versions in reverse order "
                              << *versionReverseIterator << __E__;
                try
                {
                    getVersionedTableByName(tableName,
                                            *versionReverseIterator);  // load to cache
                }
                catch(const std::runtime_error& e)
                {
                    // ignore error
                    __COUTT__ << "'" << tableName
                              << "' version failed to load: " << *versionReverseIterator
                              << __E__;
                }
            }
        }
 
        __GEN_COUT__ << "Checking '" << tableName << "' for duplicate..." << __E__;
 
        duplicateVersion = table->checkForDuplicate(
            temporaryModifiedVersion,
            (!originalVersion.isTemporaryVersion() && !makeTemporary)
                ? TableVersion()
                :  // if from persistent to persistent, then include original version in search
                originalVersion);
 
        if(lookForEquivalent && !duplicateVersion.isInvalid())
        {
            // found an equivalent!
            __GEN_COUT__ << "Equivalent '" << tableName << "' table found in version v"
                         << duplicateVersion << __E__;
 
            // if duplicate version was temporary, do not use
            if(duplicateVersion.isTemporaryVersion() && !makeTemporary)
            {
                __GEN_COUT__ << "Need persistent. Duplicate '" << tableName
                             << "' version was temporary. "
                                "Abandoning duplicate."
                             << __E__;
                duplicateVersion = TableVersion();  // set invalid
            }
            else
            {
                // erase and return equivalent version
 
                // erase modified equivalent version
                eraseTemporaryVersion(tableName, temporaryModifiedVersion);
 
                // erase original if needed
                if(needToEraseTemporarySource)
                    eraseTemporaryVersion(tableName, originalVersion);
 
                if(foundEquivalent)
                    *foundEquivalent = true;
 
                __GEN_COUT__ << "\t\t Equivalent '" << tableName
                             << "' assigned version: " << duplicateVersion << __E__;
 
                return duplicateVersion;
            }
        }
 
        if(!duplicateVersion.isInvalid())
        {
            __SS__ << "This version of table '" << tableName
                   << "' is identical to another version currently cached v"
                   << duplicateVersion << ". No reason to save a duplicate." << __E__;
            __GEN_COUT_ERR__ << "\n" << ss.str();
 
            // delete temporaryModifiedVersion
            table->eraseView(temporaryModifiedVersion);
            __SS_THROW__;
        }
 
        __GEN_COUT__ << "Check for duplicate '" << tableName << "' tables complete."
                     << __E__;
    }
 
    if(makeTemporary)
        __GEN_COUT__ << "\t\t**************************** Save as temporary '"
                     << tableName << "' table version" << __E__;
    else
        __GEN_COUT__ << "\t\t**************************** Save as new '" << tableName
                     << "' table version" << __E__;
 
    TableVersion newAssignedVersion =
        saveNewTable(tableName, temporaryModifiedVersion, makeTemporary);
 
    __GEN_COUTTV__(table->getView().getComment());
 
    if(needToEraseTemporarySource)
        eraseTemporaryVersion(tableName, originalVersion);
 
    __GEN_COUT__ << "\t\t '" << tableName
                 << "' new assigned version: " << newAssignedVersion << __E__;
    return newAssignedVersion;
}  // end saveModifiedVersion()
 
//==============================================================================
GroupEditStruct::GroupEditStruct(const ConfigurationManager::GroupType& groupType,
                                 ConfigurationManagerRW*                cfgMgr)
    : groupType_(groupType)
    , originalGroupName_(cfgMgr->getActiveGroupName(groupType))
    , originalGroupKey_(cfgMgr->getActiveGroupKey(groupType))
    , cfgMgr_(cfgMgr)
    , mfSubject_(cfgMgr->getUsername())
{
    if(originalGroupName_ == "" || originalGroupKey_.isInvalid())
    {
        __SS__ << "Error! No active group found for type '"
               << ConfigurationManager::convertGroupTypeToName(groupType)
               << ".' There must be an active group to edit the group." << __E__ << __E__
               << StringMacros::stackTrace() << __E__;
        __SS_THROW__;
    }
 
    __GEN_COUT__ << "Extracting Group-Edit Struct for type "
                 << ConfigurationManager::convertGroupTypeToName(groupType) << __E__;
 
    std::map<std::string, TableVersion> activeTables = cfgMgr->getActiveVersions();
 
    const std::set<std::string>& memberNames =
        groupType == ConfigurationManager::GroupType::CONTEXT_TYPE
            ? cfgMgr->getActiveContextMemberNames()
            : (groupType == ConfigurationManager::GroupType::BACKBONE_TYPE
                   ? ConfigurationManager::getBackboneMemberNames()
                   : (groupType == ConfigurationManager::GroupType::ITERATE_TYPE
                          ? ConfigurationManager::getIterateMemberNames()
                          : cfgMgr->getConfigurationMemberNames()));
 
    for(auto& memberName : memberNames)
        try
        {
            groupMembers_.emplace(
                std::make_pair(memberName, activeTables.at(memberName)));
            groupTables_.emplace(std::make_pair(
                memberName,
                TableEditStruct(memberName, cfgMgr)));  // Table ready for editing!
        }
        catch(...)
        {
            __GEN_COUTV__(StringMacros::mapToString(activeTables));
            __SS__ << "Error! Could not find group member table '" << memberName
                   << "' for group type '"
                   << ConfigurationManager::convertGroupTypeToName(groupType)
                   << ".' All group members must be present to create the group editing "
                      "structure."
                   << __E__ << __E__ << StringMacros::stackTrace() << __E__;
            __SS_THROW__;
        }
 
}  // end GroupEditStruct constructor()
 
//==============================================================================
GroupEditStruct::~GroupEditStruct()
{
    __GEN_COUT__ << "GroupEditStruct from editing '" << originalGroupName_ << "("
                 << originalGroupKey_ << ")' Destructing..." << __E__;
    dropChanges();
    __GEN_COUT__ << "GroupEditStruct from editing '" << originalGroupName_ << "("
                 << originalGroupKey_ << ")' Desctructed." << __E__;
}  // end GroupEditStruct destructor()
 
//==============================================================================
TableEditStruct& GroupEditStruct::getTableEditStruct(const std::string& tableName,
                                                     bool markModified /*= false*/)
{
    auto it = groupTables_.find(tableName);
    if(it == groupTables_.end())
    {
        if(groupType_ == ConfigurationManager::GroupType::CONFIGURATION_TYPE &&
           markModified)
        {
            __GEN_COUT__ << "Table '" << tableName
                         << "' not found in configuration table members from editing '"
                         << originalGroupName_ << "(" << originalGroupKey_ << ")..."
                         << " Attempting to add it!" << __E__;
 
            // emplace returns pair<object,bool wasAdded>
            auto newIt = groupTables_.emplace(std::make_pair(
                tableName,
                TableEditStruct(tableName, cfgMgr_)));  // Table ready for editing!
            if(newIt.second)
            {
                newIt.first->second.modified_ =
                    markModified;  // could indicate 'dirty' immediately in user code, which will cause a save of table
                groupMembers_.emplace(
                    std::make_pair(tableName, newIt.first->second.temporaryVersion_));
                return newIt.first->second;
            }
            __GEN_COUT_ERR__ << "Failed to emplace new table..." << __E__;
        }
 
        __SS__ << "Table '" << tableName << "' not found in table members from editing '"
               << originalGroupName_ << "(" << originalGroupKey_ << ")!'" << __E__;
        __SS_THROW__;
    }
    it->second.modified_ =
        markModified;  // could indicate 'dirty' immediately in user code, which will cause a save of table
    return it->second;
}  // end getTableEditStruct()
 
//==============================================================================
void GroupEditStruct::dropChanges()
{
    __GEN_COUT__ << "Dropping unsaved changes from editing '" << originalGroupName_ << "("
                 << originalGroupKey_ << ")'..." << __E__;
 
    ConfigurationManagerRW* cfgMgr = cfgMgr_;
 
    // drop all temporary versions
    for(auto& groupTable : groupTables_)
        if(groupTable.second
               .createdTemporaryVersion_)  // if temporary version created here
        {
            // erase with proper version management
            cfgMgr->eraseTemporaryVersion(groupTable.second.tableName_,
                                          groupTable.second.temporaryVersion_);
            groupTable.second.createdTemporaryVersion_ = false;
            groupTable.second.modified_                = false;
        }
 
    __GEN_COUT__ << "Unsaved changes dropped from editing '" << originalGroupName_ << "("
                 << originalGroupKey_ << ").'" << __E__;
}  // end GroupEditStruct::dropChanges()
 
//==============================================================================
void GroupEditStruct::saveChanges(const std::string& groupNameToSave,
                                  TableGroupKey&     newGroupKey,
                                  bool*          foundEquivalentGroupKey /*= nullptr*/,
                                  bool           activateNewGroup /*= false*/,
                                  bool           updateGroupAliases /*= false*/,
                                  bool           updateTableAliases /*= false*/,
                                  TableGroupKey* newBackboneKey /*= nullptr*/,
                                  bool*          foundEquivalentBackboneKey /*= nullptr*/,
                                  std::string*   accumulatedWarnings /*= nullptr*/)
{
    __GEN_COUT__ << "Saving changes..." << __E__;
 
    newGroupKey = TableGroupKey();  // invalidate reference parameter
    if(newBackboneKey)
        *newBackboneKey = TableGroupKey();  // invalidate reference parameter
    if(foundEquivalentBackboneKey)
        *foundEquivalentBackboneKey = false;  // clear to start
    ConfigurationManagerRW* cfgMgr = cfgMgr_;
 
    // save all temporary modified versions
    bool anyTableNew = false;
    for(auto& groupTable : groupTables_)
    {
        if(!groupTable.second.modified_)
            continue;  // skip if not modified
 
        __GEN_COUT__ << "Original version is " << groupTable.second.tableName_ << "-v"
                     << groupTable.second.originalVersion_ << __E__;
 
        groupMembers_.at(groupTable.first) = cfgMgr->saveModifiedVersion(
            groupTable.second.tableName_,
            groupTable.second.originalVersion_,
            true /*make temporary*/,
            groupTable.second.table_,
            groupTable.second.temporaryVersion_,
            true /*ignoreDuplicates*/);  // make temporary version to save persistent version properly
 
        __GEN_COUT__ << "Temporary target version is " << groupTable.second.tableName_
                     << "-v" << groupMembers_.at(groupTable.first) << "-v"
                     << groupTable.second.temporaryVersion_ << __E__;
 
        groupMembers_.at(groupTable.first) = cfgMgr->saveModifiedVersion(
            groupTable.second.tableName_,
            groupTable.second.originalVersion_,
            false /*make temporary*/,
            groupTable.second.table_,
            groupTable.second.temporaryVersion_,
            false /*ignoreDuplicates*/,
            true /*lookForEquivalent*/);  // save persistent version properly
 
        if(groupTable.second.originalVersion_ != groupMembers_.at(groupTable.first))
        {
            anyTableNew = true;
            __GEN_COUT__ << "Final NEW target version is " << groupTable.second.tableName_
                         << "-v" << groupMembers_.at(groupTable.first) << __E__;
        }
        else
            __GEN_COUT__ << "Final target version is " << groupTable.second.tableName_
                         << "-v" << groupMembers_.at(groupTable.first) << __E__;
 
        groupTable.second.modified_                = false;  // clear modified flag
        groupTable.second.createdTemporaryVersion_ = false;  // modified version is gone
    }  // loop through table edit structs
 
    for(auto& table : groupMembers_)
    {
        __GEN_COUT__ << table.first << " v" << table.second << __E__;
    }
 
    if(!anyTableNew)  //then could be duplicate group
    {
        __GEN_COUT__ << "Checking for duplicate groups..." << __E__;
        newGroupKey = cfgMgr->findTableGroup(groupNameToSave, groupMembers_);
    }
    else
        __GEN_COUT__ << "New table found, so no need to check duplicate groups." << __E__;
 
    if(!newGroupKey.isInvalid())
    {
        __GEN_COUT__ << "Found equivalent group key (" << newGroupKey << ") for "
                     << groupNameToSave << "." << __E__;
        if(foundEquivalentGroupKey)
            *foundEquivalentGroupKey = true;
    }
    else
    {
        newGroupKey = cfgMgr->saveNewTableGroup(groupNameToSave, groupMembers_);
        __GEN_COUT__ << "Saved new Context group key (" << newGroupKey << ") for "
                     << groupNameToSave << "." << __E__;
    }
 
    bool groupAliasChange = false;
    bool tableAliasChange = false;
 
    if(groupType_ !=
       ConfigurationManager::GroupType::
           BACKBONE_TYPE)  //if not backbone group save, consider changing aliases (not if it is backbone group, tables not necessarily active yet, which causes error in GroupEditStruct backboneGroupEdit)
    {
        GroupEditStruct backboneGroupEdit(ConfigurationManager::GroupType::BACKBONE_TYPE,
                                          cfgMgr);
 
        if(groupType_ != ConfigurationManager::GroupType::BACKBONE_TYPE &&
           updateGroupAliases)
        {
            // check group aliases ... a la
            // ConfigurationGUISupervisor::handleSetGroupAliasInBackboneXML
 
            TableEditStruct& groupAliasTable = backboneGroupEdit.getTableEditStruct(
                ConfigurationManager::GROUP_ALIASES_TABLE_NAME, true /*markModified*/);
            TableView* tableView = groupAliasTable.tableView_;
 
            // unsigned int col;
            unsigned int row = 0;
 
            std::vector<std::pair<std::string, ConfigurationTree>> aliasNodePairs =
                cfgMgr->getNode(ConfigurationManager::GROUP_ALIASES_TABLE_NAME)
                    .getChildren();
            std::string groupName, groupKey;
            for(auto& aliasNodePair : aliasNodePairs)
            {
                groupName = aliasNodePair.second.getNode("GroupName").getValueAsString();
                groupKey  = aliasNodePair.second.getNode("GroupKey").getValueAsString();
 
                __GEN_COUT__ << "Group Alias: " << aliasNodePair.first << " => "
                             << groupName << "(" << groupKey << "); row=" << row << __E__;
 
                if(groupName == originalGroupName_ &&
                   TableGroupKey(groupKey) == originalGroupKey_)
                {
                    __GEN_COUT__ << "Found alias! Changing group key from ("
                                 << originalGroupKey_ << ") to (" << newGroupKey << ")"
                                 << __E__;
 
                    groupAliasChange = true;
 
                    tableView->setValueAsString(
                        newGroupKey.toString(), row, tableView->findCol("GroupKey"));
                }
 
                ++row;
            }
 
            if(groupAliasChange)
            {
                std::stringstream ss;
                tableView->print(ss);
                __GEN_COUT__ << ss.str();
            }
        }  // end updateGroupAliases handling
 
        if(groupType_ != ConfigurationManager::GroupType::BACKBONE_TYPE &&
           updateTableAliases)
        {
            // update all table version aliases
            TableView* tableView =
                backboneGroupEdit
                    .getTableEditStruct(ConfigurationManager::VERSION_ALIASES_TABLE_NAME,
                                        true /*markModified*/)
                    .tableView_;
 
            for(auto& groupTable : groupTables_)
            {
                if(groupTable.second.originalVersion_ ==
                   groupMembers_.at(groupTable.second.tableName_))
                    continue;  // skip if no change
 
                __GEN_COUT__ << "Checking alias... original version is "
                             << groupTable.second.tableName_ << "-v"
                             << groupTable.second.originalVersion_
                             << " and new version is v"
                             << groupMembers_.at(groupTable.second.tableName_) << __E__;
 
                // unsigned int col;
                unsigned int row = 0;
 
                std::vector<std::pair<std::string, ConfigurationTree>> aliasNodePairs =
                    cfgMgr->getNode(ConfigurationManager::VERSION_ALIASES_TABLE_NAME)
                        .getChildren();
                std::string tableName, tableVersion;
                for(auto& aliasNodePair : aliasNodePairs)
                {
                    tableName =
                        aliasNodePair.second.getNode("TableName").getValueAsString();
                    tableVersion =
                        aliasNodePair.second.getNode("Version").getValueAsString();
 
                    __GEN_COUT__ << "Table Alias: " << aliasNodePair.first << " => "
                                 << tableName << "-v" << tableVersion << "" << __E__;
 
                    if(tableName == groupTable.second.tableName_ &&
                       TableVersion(tableVersion) == groupTable.second.originalVersion_)
                    {
                        __GEN_COUT__ << "Found alias! Changing icon table version alias."
                                     << __E__;
 
                        tableAliasChange = true;
 
                        tableView->setValueAsString(
                            groupMembers_.at(groupTable.second.tableName_).toString(),
                            row,
                            tableView->findCol("Version"));
                    }
 
                    ++row;
                }
            }
 
            if(tableAliasChange)
            {
                std::stringstream ss;
                tableView->print(ss);
                __GEN_COUT__ << ss.str();
            }
        }  // end updateTableAliases handling
 
        TableGroupKey localNewBackboneKey;
        //  if backbone modified, save group and activate it
        if(groupAliasChange || tableAliasChange)
        {
            for(auto& table : backboneGroupEdit.groupMembers_)
            {
                __GEN_COUT__ << table.first << " v" << table.second << __E__;
            }
            backboneGroupEdit.saveChanges(
                backboneGroupEdit.originalGroupName_,
                localNewBackboneKey,
                foundEquivalentBackboneKey ? foundEquivalentBackboneKey : nullptr);
 
            if(newBackboneKey)
                *newBackboneKey = localNewBackboneKey;
        }
 
        // acquire all active groups and ignore errors, so that activateTableGroup does not
        // erase other active groups
        {
            __GEN_COUT__
                << "Restoring active table groups, before activating new groups..."
                << __E__;
 
            std::string localAccumulatedWarnings;
            cfgMgr->restoreActiveTableGroups(
                false /*throwErrors*/,
                "" /*pathToActiveGroupsFile*/,
                ConfigurationManager::LoadGroupType::
                    ALL_TYPES /*onlyLoadIfBackboneOrContext*/,
                &localAccumulatedWarnings);
        }
 
        // activate new groups
        if(!localNewBackboneKey.isInvalid())
            cfgMgr->activateTableGroup(
                backboneGroupEdit.originalGroupName_,
                localNewBackboneKey,
                accumulatedWarnings ? accumulatedWarnings : nullptr);
 
    }     //end non-backbone save type handling
    else  //is backbone save type
    {
        // acquire all active groups and ignore errors, so that activateTableGroup does not
        // erase other active groups
        {
            __GEN_COUT__
                << "Restoring active table groups, before activating new groups..."
                << __E__;
 
            std::string localAccumulatedWarnings;
            cfgMgr->restoreActiveTableGroups(
                false /*throwErrors*/,
                "" /*pathToActiveGroupsFile*/,
                ConfigurationManager::LoadGroupType::
                    ALL_TYPES /*onlyLoadIfBackboneOrContext*/,
                &localAccumulatedWarnings);
        }
    }  //end backbone save type handling
 
    if(activateNewGroup)
        cfgMgr->activateTableGroup(groupNameToSave,
                                   newGroupKey,
                                   accumulatedWarnings ? accumulatedWarnings : nullptr);
 
    __GEN_COUT__ << "Changes saved." << __E__;
}  // end GroupEditStruct::saveChanges()
 
//==============================================================================
void ConfigurationManagerRW::testXDAQContext()
{
    if(1)
        return;  //if 0 to debug
    __GEN_COUTV__(runTimeSeconds());
 
    std::string  accumulatedWarningsStr;
    std::string* accumulatedWarnings = &accumulatedWarningsStr;
 
    // get Group Info too!
    try
    {
        //test lookup of which groups a table is in
        {
            std::string  documentNameToLoad = "XDAQApplicationTable";
            TableVersion documentVersionToLoad(
                (int)134);  //1 is easy, 134 is hard on daq13 mongodb
 
            std::set<std::string> groupsContainingTable =
                theInterface_->findGroupsWithTable(documentNameToLoad,
                                                   documentVersionToLoad);
            __GEN_COUT__ << "Groups containing " << documentNameToLoad << "-v"
                         << documentVersionToLoad
                         << " count: " << groupsContainingTable.size() << __E__;
            for(const auto& group : groupsContainingTable)
            {
                __GEN_COUT__ << "\t" << group << __E__;
            }
        }
 
        std::string debugGroupName = "Mu2eHWEmulatorContext";
 
        //final solution demo of getting latest group key:
        {
            TableGroupKey latestGroupKey =
                theInterface_->findLatestGroupKey(debugGroupName);
            __GEN_COUTV__(latestGroupKey);
 
            __GEN_COUTV__(runTimeSeconds());
        }
 
        //steps to do time comparison for getting last group key and table key:
 
        // build allGroupInfo_ for the ConfigurationManagerRW
 
        std::set<std::string /*name*/> tableGroups =
            theInterface_->getAllTableGroupNames();
        __GEN_COUT__ << "Number of Groups: " << tableGroups.size() << __E__;
 
        __GEN_COUTV__(runTimeSeconds());
        // return;
 
        TableGroupKey key;
        std::string   name;
        for(const auto& fullName : tableGroups)
        {
            TableGroupKey::getGroupNameAndKey(fullName, name, key);
            allGroupInfo_[name].keys_.emplace(key);
 
            if(name == debugGroupName)
            {
                __GEN_COUTV__(key);
            }
        }
        __GEN_COUTV__(runTimeSeconds());
 
        std::set<std::string /*name*/> tableNames = theInterface_->getAllTableNames();
        __GEN_COUT__ << "Number of Tables: " << tableNames.size() << __E__;
 
        __GEN_COUTV__(runTimeSeconds());
 
        for(const auto& fullName : tableNames)
        {
            if(fullName.find(debugGroupName) != std::string::npos)
            {
                __GEN_COUTV__(fullName);
            }
        }
        __GEN_COUTV__(runTimeSeconds());
 
        TableGroupKey latestGroupKey = theInterface_->findLatestGroupKey(debugGroupName);
        __GEN_COUTV__(latestGroupKey);
 
        __GEN_COUTV__(runTimeSeconds());
 
        TableBase localGroupMemberCacheSaver(
            true /*special table*/
            ,  //special table only allows 1 view in cache and does not load schema (which is perfect for this temporary table),
            TableBase::GROUP_CACHE_PREPEND + debugGroupName);
        TableVersion lastestGroupCacheKey =
            theInterface_->findLatestVersion(&localGroupMemberCacheSaver);
        __GEN_COUTV__(lastestGroupCacheKey);
 
        __GEN_COUTV__(runTimeSeconds());
 
        //test a group save that already exists
        try
        {
            TableGroupKey groupKey(int(0));
            __GEN_COUT__ << "Testing group save of pre-existing " << debugGroupName << "("
                         << groupKey << ")" << __E__;
            std::map<std::string, TableVersion> groupMembers;
            groupMembers["DesktopIconTable"] = TableVersion(123);
            theInterface_->saveTableGroup(
                groupMembers,
                TableGroupKey::getFullGroupString(debugGroupName, groupKey));
        }
        catch(...)
        {
            __GEN_COUT__ << "Exception during group save." << __E__;
        }
        __GEN_COUTV__(runTimeSeconds());
 
        //test a group save that does not already exists
        try
        {
            std::string   debugGroupName = "testGroupSave";
            TableGroupKey groupKey(int(2));
            __GEN_COUT__ << "Testing group save of non-existing " << debugGroupName << "("
                         << groupKey << ")" << __E__;
            std::map<std::string, TableVersion> groupMembers;
            groupMembers["DesktopIconTable"]     = TableVersion(123);
            groupMembers["MessageFacilityTable"] = TableVersion(7);
            theInterface_->saveTableGroup(
                groupMembers,
                TableGroupKey::getFullGroupString(debugGroupName, groupKey));
        }
        catch(...)
        {
            __GEN_COUT__ << "Exception during new group save." << __E__;
        }
        __GEN_COUTV__(runTimeSeconds());
 
        //test a table save that already exists
        {
            std::string  documentNameToLoad = "XDAQApplicationTable";
            TableVersion documentVersionToLoad(134);
 
            __GEN_COUT__ << "Testing table save of pre-existing " << documentNameToLoad
                         << __E__;
 
            {  //load to prove it exists
                TableBase localDocLoader(
                    documentNameToLoad);  //can not use special table when filling
                localDocLoader.changeVersionAndActivateView(
                    localDocLoader.createTemporaryView(), documentVersionToLoad);
                theInterface_->fill(&localDocLoader, documentVersionToLoad);
                __SS__;
                localDocLoader.print(ss);
                __GEN_COUTV__(ss.str());
            }
            __GEN_COUTV__(runTimeSeconds());
 
            try
            {  //attempt to save over existing version
                std::string documentNameToSave = documentNameToLoad;
                TableBase
                    localDocSaver(  //true /*special table*/, //special table only allows 1 view in cache and does not load schema (which is perfect for this check),
                        documentNameToSave);  //can not use special table when filling
                localDocSaver.changeVersionAndActivateView(
                    localDocSaver.createTemporaryView(), documentVersionToLoad);
 
                std::string json = "{ }";
                localDocSaver.getViewP()->setCustomStorageData(json);
 
                __COUTT__ << "Saving JSON string: "
                          << localDocSaver.getViewP()->getCustomStorageData() << __E__;
 
                __COUTT__ << "Saving JSON doc as "
                          << localDocSaver.getView().getTableName() << "("
                          << localDocSaver.getView().getVersion().toString() << ")"
                          << __E__;
 
                // save to db, and do not allow overwrite
                theInterface_->saveActiveVersion(&localDocSaver, false /* overwrite */);
            }
            catch(...)
            {
                __GEN_COUT__ << "Exception during table save." << __E__;
            }
            __GEN_COUTV__(runTimeSeconds());
 
            {  //load to prove it exists
                TableBase localDocLoader(
                    documentNameToLoad);  //can not use special table when filling
                localDocLoader.changeVersionAndActivateView(
                    localDocLoader.createTemporaryView(), documentVersionToLoad);
                theInterface_->fill(&localDocLoader, documentVersionToLoad);
                __SS__;
                localDocLoader.print(ss);
                __GEN_COUTV__(ss.str());
            }
            __GEN_COUTV__(runTimeSeconds());
        }
        __GEN_COUTV__(runTimeSeconds());
 
        //test a table save that does not already exist
        {
            std::string  documentNameToLoad = "MessageFacilityTable";
            TableVersion documentVersionToLoad(7);
            TableBase    localDocLoader(
                documentNameToLoad);  //can not use special table when filling
 
            __GEN_COUT__ << "Testing table save of non-existing " << documentNameToLoad
                         << __E__;
 
            {  //load to prove it exists
                localDocLoader.changeVersionAndActivateView(
                    localDocLoader.createTemporaryView(), documentVersionToLoad);
                theInterface_->fill(&localDocLoader, documentVersionToLoad);
                __SS__;
                localDocLoader.print(ss);
                __GEN_COUTV__(ss.str());
                __GEN_COUTV__(runTimeSeconds());
            }
            __GEN_COUTV__(runTimeSeconds());
 
            try
            {  //attempt to save new version
 
                // modify it
                TableVersion newVersion = TableVersion::getNextVersion(
                    theInterface_->findLatestVersion(&localDocLoader));
                localDocLoader.getViewP()->setVersion(newVersion);
 
                __GEN_COUTT__ << "Saving new table as "
                              << localDocLoader.getView().getTableName() << "("
                              << localDocLoader.getView().getVersion().toString() << ")"
                              << __E__;
 
                localDocLoader.getViewP()->setValueAsString(
                    "10.226.9.17", 0, 4);  //modify value that is 10.226.9.16
 
                __SS__;
                localDocLoader.print(ss);
                __GEN_COUTV__(ss.str());
 
                // save to db, and do not allow overwrite
                theInterface_->saveActiveVersion(&localDocLoader, false /* overwrite */);
            }
            catch(...)
            {
                __GEN_COUT__ << "Exception during new table save." << __E__;
            }
            __GEN_COUTV__(runTimeSeconds());
        }
        __GEN_COUTV__(runTimeSeconds());
        return;
 
        // for each group get member map & comment, author, time, and type for latest key
        for(auto& groupInfo : allGroupInfo_)
        {
            try
            {
                groupInfo.second.latestKey_ = groupInfo.second.getLastKey();
                loadTableGroup(groupInfo.first /*groupName*/,
                               groupInfo.second.latestKey_,
                               false /*doActivate*/,
                               &groupInfo.second.latestKeyMemberMap_ /*groupMembers*/,
                               0 /*progressBar*/,
                               0 /*accumulateErrors*/,
                               &groupInfo.second.latestKeyGroupComment_,
                               &groupInfo.second.latestKeyGroupAuthor_,
                               &groupInfo.second.latestKeyGroupCreationTime_,
                               true /*doNotLoadMember*/,
                               &groupInfo.second.latestKeyGroupTypeString_);
            }
            catch(const std::runtime_error& e)
            {
                __GEN_COUT_WARN__
                    << "Error occurred loading latest group info into cache for '"
                    << groupInfo.first << "(" << groupInfo.second.latestKey_ << ")': \n"
                    << e.what() << __E__;
 
                groupInfo.second.latestKey_ = TableGroupKey::INVALID;
                groupInfo.second.latestKeyGroupComment_ =
                    ConfigurationManager::UNKNOWN_INFO;
                groupInfo.second.latestKeyGroupAuthor_ =
                    ConfigurationManager::UNKNOWN_INFO;
                groupInfo.second.latestKeyGroupCreationTime_ =
                    ConfigurationManager::UNKNOWN_TIME;
                groupInfo.second.latestKeyGroupTypeString_ =
                    ConfigurationManager::GROUP_TYPE_NAME_UNKNOWN;
                groupInfo.second.latestKeyMemberMap_ = {};
            }
            catch(...)
            {
                __GEN_COUT_WARN__
                    << "Error occurred loading latest group info into cache for '"
                    << groupInfo.first << "(" << groupInfo.second.latestKey_ << ")'..."
                    << __E__;
 
                groupInfo.second.latestKey_ = TableGroupKey::INVALID;
                groupInfo.second.latestKeyGroupComment_ =
                    ConfigurationManager::UNKNOWN_INFO;
                groupInfo.second.latestKeyGroupAuthor_ =
                    ConfigurationManager::UNKNOWN_INFO;
                groupInfo.second.latestKeyGroupCreationTime_ =
                    ConfigurationManager::UNKNOWN_TIME;
                groupInfo.second.latestKeyGroupTypeString_ =
                    ConfigurationManager::GROUP_TYPE_NAME_UNKNOWN;
                groupInfo.second.latestKeyMemberMap_ = {};
            }
        }  // end group info loop
        __GEN_COUTV__(runTimeSeconds());
    }  // end get group info
    catch(const std::runtime_error& e)
    {
        __SS__ << "A fatal error occurred reading the info for all table groups. Error: "
               << e.what() << __E__;
        __GEN_COUT_ERR__ << "\n" << ss.str();
        if(accumulatedWarnings)
            *accumulatedWarnings += ss.str();
        else
            throw;
    }
    catch(...)
    {
        __SS__ << "An unknown fatal error occurred reading the info for all table groups."
               << __E__;
        __GEN_COUT_ERR__ << "\n" << ss.str();
        if(accumulatedWarnings)
            *accumulatedWarnings += ss.str();
        else
            throw;
    }  //end catch
 
    __GEN_COUT__ << "testXDAQContext() end runTimeSeconds()=" << runTimeSeconds()
                 << __E__;
    return;
 
    try
    {
        __GEN_COUT__ << "Loading table..." << __E__;
        loadTableGroup("FETest", TableGroupKey(2));  // Context_1
        ConfigurationTree t = getNode("/FETable/DEFAULT/FrontEndType");
 
        std::string v;
 
        __GEN_COUT__ << __E__;
        t.getValue(v);
        __GEN_COUT__ << "Value: " << v << __E__;
        __GEN_COUT__ << "Value index: " << t.getValue<int>() << __E__;
 
        return;
    }
    catch(...)
    {
        __GEN_COUT__ << "Failed to load table..." << __E__;
    }
}  //end testXDAQContext()