BESCatalogList.cc

Go to the documentation of this file.

// BESCatalogList.cc

// This file is part of bes, A C++ back-end server implementation framework
// for the OPeNDAP Data Access Protocol.

// Copyright (c) 2004-2009 University Corporation for Atmospheric Research
// Author: Patrick West <pwest@ucar.edu> and Jose Garcia <jgarcia@ucar.edu>
//
// This library is free software; you can redistribute it and/or
// modify it under the terms of the GNU Lesser General Public
// License as published by the Free Software Foundation; either
// version 2.1 of the License, or (at your option) any later version.
//
// This library is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
// Lesser General Public License for more details.
//
// You should have received a copy of the GNU Lesser General Public
// License along with this library; if not, write to the Free Software
// Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
//
// You can contact University Corporation for Atmospheric Research at
// 3080 Center Green Drive, Boulder, CO 80301

// (c) COPYRIGHT University Corporation for Atmospheric Research 2004-2005
// Please read the full copyright statement in the file COPYRIGHT_UCAR.
//
// Authors:
//      pwest       Patrick West <pwest@ucar.edu>
//      jgarcia     Jose Garcia <jgarcia@ucar.edu>

#include "config.h"

#ifdef HAVE_STDLIB_H
#include <stdlib.h>
#endif

#include <pthread.h>

#include <sstream>

using std::ostringstream;

#include "BESCatalogList.h"
#include "BESCatalog.h"
#include "BESCatalogEntry.h"
#include "BESInfo.h"
#include "BESSyntaxUserError.h"
#include "TheBESKeys.h"
#include "BESNames.h"

static pthread_once_t BESCatalogList_instance_control = PTHREAD_ONCE_INIT;

BESCatalogList *BESCatalogList::_instance = 0;

BESCatalogList *
BESCatalogList::TheCatalogList() {
    pthread_once(&BESCatalogList_instance_control, initialize_instance);
    return _instance;
}

void BESCatalogList::initialize_instance() {
    if (_instance == 0) {
        _instance = new BESCatalogList;
#if HAVE_ATEXIT
        atexit(delete_instance);
#endif
    }
}

void BESCatalogList::delete_instance() {
    delete _instance;
    _instance = 0;
}

BESCatalogList::BESCatalogList() {
    bool found = false;
    string key = "BES.Catalog.Default";
    try {
        TheBESKeys::TheKeys()->get_value(key, _default_catalog, found);
    }
    catch (BESError &) {
        found = false;
    }
    if (!found || _default_catalog.empty()) {
        _default_catalog = BES_DEFAULT_CATALOG;
    }
}

BESCatalogList::~BESCatalogList() {
    catalog_iter i = _catalogs.begin();
    catalog_iter e = _catalogs.end();
    for (; i != e; i++) {
        BESCatalog *catalog = (*i).second;
        if (catalog) delete catalog;
    }
}

bool BESCatalogList::add_catalog(BESCatalog * catalog) {
    bool result = false;
    if (catalog) {
        if (find_catalog(catalog->get_catalog_name()) == 0) {
#if 0
            _catalogs[catalog->get_catalog_name()] = catalog;
#endif
            string name = catalog->get_catalog_name();
            std::pair<const std::string, BESCatalog*> p = std::make_pair(name, catalog);
            result = _catalogs.insert(p).second;
#if 0
            result = true;
#endif
        }
    }
    return result;
}

bool BESCatalogList::ref_catalog(const string &catalog_name) {
    bool ret = false;
    BESCatalog *cat = 0;
    BESCatalogList::catalog_iter i;
    i = _catalogs.find(catalog_name);
    if (i != _catalogs.end()) {
        cat = (*i).second;
        cat->reference_catalog();
        ret = true;
    }
    return ret;
}

bool BESCatalogList::deref_catalog(const string &catalog_name) {
    bool ret = false;
    BESCatalog *cat = 0;
    BESCatalogList::catalog_iter i;
    i = _catalogs.find(catalog_name);
    if (i != _catalogs.end()) {
        cat = (*i).second;
        if (!cat->dereference_catalog()) {
            _catalogs.erase(i);
            delete cat;
        }
        ret = true;
    }
    return ret;
}

BESCatalog *
BESCatalogList::find_catalog(const string &catalog_name) {
    BESCatalog *ret = 0;
    BESCatalogList::catalog_citer i;
    i = _catalogs.find(catalog_name);
    if (i != _catalogs.end()) {
        ret = (*i).second;
    }
    return ret;
}

BESCatalogEntry *
BESCatalogList::show_catalogs(BESDataHandlerInterface &/*dhi*/, BESCatalogEntry *entry, bool show_default) {
    BESCatalogEntry *myentry = entry;
    if (!myentry) {
        myentry = new BESCatalogEntry("/", "");
    }
    catalog_citer i = _catalogs.begin();
    catalog_citer e = _catalogs.end();
    for (; i != e; i++) {
        // if show_default is true then display all catalogs
        // if !show_default but this current catalog is not the default
        // then display
        if (show_default || (*i).first != default_catalog()) {
            BESCatalog *catalog = (*i).second;
            catalog->show_catalog("", SHOW_INFO_RESPONSE, myentry);
        }
    }

    return myentry;
}

void BESCatalogList::dump(ostream &strm) const {
    strm << BESIndent::LMarg << "BESCatalogList::dump - (" << (void *) this << ")" << endl;
    BESIndent::Indent();
    strm << BESIndent::LMarg << "default catalog: " << _default_catalog << endl;
    if (_catalogs.size()) {
        strm << BESIndent::LMarg << "catalog list:" << endl;
        BESIndent::Indent();
        catalog_citer i = _catalogs.begin();
        catalog_citer e = _catalogs.end();
        for (; i != e; i++) {
            BESCatalog *catalog = (*i).second;
            strm << BESIndent::LMarg << (*i).first << catalog << endl;
        }
        BESIndent::UnIndent();
    }
    else {
        strm << BESIndent::LMarg << "catalog list: empty" << endl;
    }
    BESIndent::UnIndent();
}