blob_storage.cpp

Go to the documentation of this file.

Go to the SVN repository for this file.

/*  $Id: blob_storage.cpp 77706 2017-05-03 12:26:07Z ivanov $
 * ===========================================================================
 *
 *                            PUBLIC DOMAIN NOTICE
 *               National Center for Biotechnology Information
 *
 *  This software/database is a "United States Government Work" under the
 *  terms of the United States Copyright Act.  It was written as part of
 *  the author's official duties as a United States Government employee and
 *  thus cannot be copyrighted.  This software/database is freely available
 *  to the public for use. The National Library of Medicine and the U.S.
 *  Government have not placed any restriction on its use or reproduction.
 *
 *  Although all reasonable efforts have been taken to ensure the accuracy
 *  and reliability of the software and data, the NLM and the U.S.
 *  Government do not and cannot warrant the performance or results that
 *  may be obtained by using this software or data. The NLM and the U.S.
 *  Government disclaim all warranties, express or implied, including
 *  warranties of performance, merchantability or fitness for any particular
 *  purpose.
 *
 *  Please cite the author in any work or product based on this material.
 *
 * ===========================================================================
 *
 * Author:  Maxim Didenko
 *
 *
 */
 
 
#include <ncbi_pch.hpp>
#include <corelib/blob_storage.hpp>
#include <corelib/ncbi_config.hpp>
#include <corelib/plugin_manager_store.hpp>
#include <corelib/error_codes.hpp>
 
 
#define NCBI_USE_ERRCODE_X   Corelib_Blob
 
 
BEGIN_NCBI_SCOPE
 
 
IBlobStorage::~IBlobStorage()
{
}
void IBlobStorage::DeleteStorage(void)
{
    NCBI_THROW(CBlobStorageException, eNotImplemented,
               "DeleteStorage operation is not implemented.");
}
 
 
IBlobStorageFactory::~IBlobStorageFactory()
{
}
 
 
CBlobStorageFactory::CBlobStorageFactory(const IRegistry& reg)
    : m_Params(CConfig::ConvertRegToTree(reg), eTakeOwnership)
{
}
CBlobStorageFactory::CBlobStorageFactory(const TPluginManagerParamTree* params,
                                         EOwnership own)
    : m_Params(params, own)
{
}
 
CBlobStorageFactory::~CBlobStorageFactory()
{
}
 
IBlobStorage* CBlobStorageFactory::CreateInstance()
{
    typedef CPluginManager<IBlobStorage> TCacheManager;
    typedef CPluginManagerGetter<IBlobStorage> TCacheManagerStore;
 
    CRef<TCacheManager> cache_manager( TCacheManagerStore::Get() );
    //unique_ptr<TPluginManagerParamTree> params( MakeParamTree() );
    IBlobStorage* drv = NULL;
 
    _ASSERT( cache_manager );
 
    const TPluginManagerParamTree* storage_tree =
            m_Params->FindSubNode("blob_storage");
 
    string driver_name = "netcache";
    if (storage_tree) {
        const TPluginManagerParamTree* driver_tree =
            storage_tree->FindSubNode("driver");
        if (driver_tree  && !driver_tree->GetValue().value.empty()) {
            driver_name = driver_tree->GetValue().value;
            storage_tree = m_Params->FindSubNode(driver_name);
        }
    } else
        storage_tree = m_Params->FindSubNode("netcache_api");
    if (!storage_tree)
        storage_tree = m_Params->FindSubNode("netcache_client");
 
 
    try {
        drv = cache_manager->CreateInstance(
                                     driver_name,
                                     NCBI_INTERFACE_VERSION(IBlobStorage),
                                     storage_tree
                                     );
    } catch (CPluginManagerException& ex) {
        if (ex.GetErrCode() == CPluginManagerException::eResolveFailure) {
            ERR_POST_X(1, Warning << ex);
        } else if (ex.GetErrCode() == CPluginManagerException::eNullInstance) {
        } else {
            throw;
        }
    }
 
    if (!drv)
        drv = new CBlobStorage_Null;
 
    return drv;
}
 
 
const char* CBlobStorageException::GetErrCodeString(void) const
{
    switch (GetErrCode())
    {
    case eReader:         return "eReaderError";
    case eWriter:         return "eWriterError";
    case eBlocked:        return "eBlocked";
    case eBlobNotFound:   return "eBlobNotFound";
    case eBusy:           return "eBusy";
    case eNotImplemented: return "eNotImplemented";
    default:              return CException::GetErrCodeString();
    }
}
 
 
END_NCBI_SCOPE