Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Showing content from http://www.ncbi.nlm.nih.gov/IEB/ToolBox/CPP_DOC/doxyhtml/dbapi__conn__factory_8cpp_source.html below:

NCBI C++ ToolKit: src/dbapi/driver/dbapi_conn_factory.cpp Source File

m_MapperFactory(svc_mapper_factory,

, def_mapping),

m_MaxNumOfConnAttempts(1),

m_MaxNumOfValidationAttempts(1),

m_MaxNumOfServerAlternatives(32),

m_MaxNumOfDispatches(0),

m_ConnectionTimeout(0),

m_TryServerToo(

)

section_name(

);

->

(section_name,

,

);

validator_name;

validator_name = validator->

();

& srv_name,

, m_ServerName(srv_name)

: driver_ctx(driver_ctx_in), service_info(service_info_in),

unique_ptr<CDB_Connection> t_con;

}

(ctx_impl !=

) {

( dsp_srv.

() ) {

single_server(params.

(

));

is_pooled(params.

(

));

(single_server !=

(is_pooled ==

) {

}

(single_server !=

&& is_pooled ==

) {

(t_con.get() ==

) {

(single_server !=

) {

(t_con.get() ==

) {

t_con.release();

do_not_dispatch = params.

(

) ==

;

list<TSvrRef> tried_servers;

full_retry_made =

;

alternatives

=

(service_info.

().size());

(alternatives < 1) {

alternatives =

(2U, max_alternatives);

alternatives =

(alternatives * 2U, max_alternatives);

( !do_not_dispatch && !service_name.empty() ) {

(service_info, params.

(

),

params.

(

) ==

));

( ; !t_con && alternatives > 0; --alternatives ) {

(do_not_dispatch) {

(!service_name.empty()) {

.excluded =

.service_info.GetExcluded();

dsp_srv = balancer->GetServer(&t_con, &params);

.errors.push_back(ex.

());

(dsp_srv.

()) {

(dsp_srv.

()) {

(tried_servers.empty()

&& (dsp_srv.

()

|| (dsp_srv->

() == service_name

(

<< service_name

<<

);

(dsp_srv.

()) {

.errors.push_back(

(dsp_srv->

() == service_name

&& !tried_servers.empty())

(full_retry_made) {

.errors.push_back(

+ service_name +

,

(

<< service_name

<<

);

(list<TSvrRef>, it, tried_servers) {

(service_info, params.

(

),

full_retry_made =

;

cur_srv_name = dsp_srv->

();

cur_host = dsp_srv->

();

cur_port = dsp_srv->

();

}

(params.

(

).empty()) {

(

, 111000);

need_exclude =

;

(; attempts > 0; --attempts) {

(t_con !=

) {

need_exclude =

;

.handlers.PostMsg(&ex);

need_exclude =

;

(do_not_dispatch) {

(cur_srv_name == service_name && cur_host == 0 && cur_port == 0

.errors.push_back(

,

balancer->LocallyPenalize(

.last_tried);

tried_servers.push_back(

.last_tried);

.errors.push_back(

<<

<< params.

());

unique_ptr<CDB_Connection>

;

(candidate ==

) {

.excluded =

.service_info.GetExcluded();

.reset(candidate);

.last_tried.Reset(

.service_info.GetDispatchedServer());

(

.last_tried.Empty()) {

.last_tried.Reset

(

->IsReusable() && !params.

(

).empty()) {

(

->Host() != 0) {

.tried.back() =

->ServerName();

(

->Host() == 0) {

(

->IsReusable()) {

.handlers.PostMsg(&ex);

(

->IsReusable()) {

.handlers.PostMsg(&ex);

.tried.pop_back();

->FinishOpening();

.last_tried.Reset(

.service_info.GetDispatchedServer());

(

.last_tried.Empty()) {

.last_tried.Reset

.errors.push_back(

,

.release();

& service_name,

list<string>* serv_list)

& service_name,

& server)

( !server.empty() ) {

service_info.SetDispatchedServer(svr);

(rctx.

(

) == rid_str) {

rctx.

(

, connection_no);

connection_no +

;

rctx.

(

,

);

(dsp_srv.

()) {

dsp_srv.

(&stub_dsp_srv);

* status_str =

;

(

.conn_status) {

status_str =

;

status_str =

;

status_str =

;

extra.

(prefix +

, status_str);

extra.

(prefix +

, service);

( !dsp_srv->

().empty() ) {

extra.

(prefix +

, dsp_srv->

());

}

(connection !=

&& !connection->

().empty()) {

(dsp_srv->

() != 0) {

extra.

(prefix +

,

}

(params.

() != 0) {

}

(connection !=

&& connection->

() != 0) {

extra.

(prefix +

,

(dsp_srv->

() != 0) {

extra.

(prefix +

, dsp_srv->

());

}

(params.

() != 0) {

extra.

(prefix +

, params.

());

}

(connection !=

&& connection->

() != 0) {

extra.

(prefix +

, connection->

());

(connection !=

&& !connection->

().empty() ) {

}

( !params.

(

).empty() ) {

extra.

(prefix +

, params.

(

));

extra.

(prefix +

, validator->

());

driver_name = ((connection ==

)

?

.driver_ctx.GetDriverName()

( !driver_name.empty() ) {

extra.

(prefix +

, driver_name);

retries =

.tried.size();

extra.

(prefix +

, retries);

( !

.tried.empty() ) {

( !

.excluded.empty() ) {

extra.

(prefix +

,

.excluded);

(connection !=

) {

make_valid_connection_elapsed =

.make_valid_connection_sw.Elapsed();

(make_valid_connection_elapsed != 0.0) {

extra.

(prefix +

,

make_valid_connection_elapsed);

dispatch_server_name_elapsed =

.dispatch_server_name_sw.Elapsed();

(dispatch_server_name_elapsed != 0.0) {

extra.

(prefix +

,

dispatch_server_name_elapsed);

(m_ServiceName.find(

) !=

) {

(m_Options.empty()) {

host =

.GetHost();

port =

.GetPort();

(m_ServiceName, host, port, 1.0));

}

(m_Options.empty()) {

m_Mapper->GetServerOptions(m_ServiceName, &m_Options);

refresh =

;

(

&it : m_Options) {

(it->GetExpireTime() < now) {

m_Mapper->GetServerOptions(m_ServiceName, &options);

( !options.empty() ) {

(options, m_Options);

(server.

()) {

m_Dispatched = server;

++m_NumValidationFailures;

limit = m_Factory.GetMaxNumOfValidationAttempts();

(limit != 0 && m_NumValidationFailures >= limit) {

( !m_Mapper->HasExclusions(m_ServiceName) ) {

m_Mapper->GetServerOptions(m_ServiceName, &m_Options);

(

&it : m_Options) {

(it->IsExcluded()) {

(it->GetHost() != 0) {

(it->GetPort() != 0) {

}

( !it->GetName().empty() ) {

exclusion = it->GetName();

( !exclusion.empty() ) {

+= delim + exclusion;

m_DBServiceMapper(mapper)

& entry = m_ServiceInfoMap[service_name];

(entry.Empty()) {

(*m_Parent, *m_DBServiceMapper, service_name));

m_SvcMapperFactory(svc_mapper_factory),

m_DefMapping(def_mapping)

,

(m_SvcMapperFactory) {

(m_SvcMapperFactory) {

m_SvcMapperFactory(m_Registry);

(

);

+= (*vr_it)->GetName();

unique_ptr<CDB_LangCmd> set_cmd(

.LangCmd(

));

set_cmd->DumpResults();

.SetDatabaseName(

);

(

);

void Push(const CRef< IConnValidator > &validator)

virtual EConnStatus Validate(CDB_Connection &conn)

virtual string GetName(void) const

vector< CRef< IConnValidator > > TValidators

virtual ~CConnValidatorCoR(void)

CRef< IConnValidator > Top(void) const

CMapperFactory(IDBServiceMapper::TFactory svc_mapper_factory, const IRegistry *registry, EDefaultMapping def_mapping)

IDBServiceMapper * Make(void) const

const IDBServiceMapper::TFactory m_SvcMapperFactory

CRuntimeData(const CDBConnectionFactory &parent, const CRef< IDBServiceMapper > &mapper)

const IDBServiceMapper & GetDBServiceMapper(void) const

CServiceInfo & GetServiceInfo(const string &service_name)

string GetMapperName(void) const

bool HasExclusions(void) const

void Exclude(const TSvrRef &server)

TSvrRef GetDispatchedServer(void) const

void SetDispatchedServer(const TSvrRef &server)

unsigned int GetNumOfDispatches(void) const

void IncNumOfValidationFailures(const TSvrRef &dsp_srv)

TSvrRef GetMappedServer(void) override

unsigned int GetNumOfValidationFailures(void) const

const TOptions & GetOptions(void) override

unsigned int GetMaxNumOfServerAlternatives(void) const

void SetMaxNumOfConnAttempts(unsigned int max_num)

void SetMaxNumOfDispatches(unsigned int max_num)

void x_LogConnection(const SOpeningContext &ctx, const CDB_Connection *connection, const CDBConnParams &params)

void SetLoginTimeout(unsigned int timeout)

CDBConnectionFactory(IDBServiceMapper::TFactory svc_mapper_factory, const IRegistry *registry=NULL, EDefaultMapping def_mapping=eUseDefaultMapper)

CDBConnectionFactory won't take ownership of registry.

unsigned int m_MaxNumOfServerAlternatives

void SetMaxNumOfServerAlternatives(unsigned int max_num)

unsigned int GetMaxNumOfConnAttempts(void) const

friend class CServiceInfo

void ConfigureFromRegistry(const IRegistry *registry=NULL)

unsigned int m_MaxNumOfConnAttempts

void GetServersList(const string &validator_name, const string &service_name, list< string > *serv_list)

unsigned int m_MaxNumOfValidationAttempts

CDB_Connection * DispatchServerName(SOpeningContext &ctx, const CDBConnParams &params)

void SetConnectionTimeout(unsigned int timeout)

CRuntimeData & GetRuntimeData(const CRef< IConnValidator > validator)

CFastMutex m_ValidatorSetMutex

unsigned int m_LoginTimeout

virtual void Configure(const IRegistry *registry=NULL)

Configure connection policy using registry.

void WorkWithSingleServer(const string &validator_name, const string &service_name, const string &server)

CDB_Connection * MakeValidConnection(SOpeningContext &ctx, const CDBConnParams &params, CDB_Connection *candidate=NULL)

unsigned int GetMaxNumOfDispatches(void) const

unsigned int m_ConnectionTimeout

unsigned int GetMaxNumOfValidationAttempts(void) const

const CMapperFactory m_MapperFactory

unsigned int m_MaxNumOfDispatches

virtual CDB_Connection * MakeDBConnection(I_DriverContext &ctx, const CDBConnParams &params, CDB_UserHandler::TExceptions &exceptions)

Create new connection object for the given context and connection attributes.

void SetMaxNumOfValidationAttempts(unsigned int max_num)

TValidatorSet m_ValidatorSet

virtual ~CDBGiveUpFactory(void)

CDBGiveUpFactory(IDBServiceMapper::TFactory svc_mapper_factory, const IRegistry *registry=NULL, EDefaultMapping def_mapping=eUseDefaultMapper)

CDBRedispatchFactory(IDBServiceMapper::TFactory svc_mapper_factory, const IRegistry *registry=NULL, EDefaultMapping def_mapping=eUseDefaultMapper)

virtual ~CDBRedispatchFactory(void)

CDBServerOption – CDBServer extended with additional information that helps maintain a balanced pool ...

time_t GetExpireTime(void) const

Uint2 GetPort(void) const

const string & GetName(void) const

Uint4 GetHost(void) const

virtual Uint4 GetHost(void) const

virtual Uint2 GetPort(void) const

const string m_ServerName

impl::CDBHandlerStack & SetOpeningMsgHandlers(void)

impl::CDBHandlerStack m_OpeningMsgHandlers

virtual string GetServerName(void) const

CDB_DBLB_Delegate(const string &srv_name, Uint4 host, Uint2 port, const CDBConnParams &other)

virtual const impl::CDBHandlerStack & GetOpeningMsgHandlers(void) const

virtual ~CDB_DBLB_Delegate(void)

Lightweight representation of just a host and a port.

static CNcbiApplication * Instance(void)

Singleton method.

CTempString implements a light-weight string on top of a storage buffer whose lifetime management is ...

CTrivialConnValidator(const string &db_name, int attr=eDefaultValidateAttr)

virtual string GetName(void) const

const string & GetDBName(void) const

virtual ~CTrivialConnValidator(void)

@ eKeepModifiedConnection

virtual EConnStatus Validate(CDB_Connection &conn)

virtual EConnStatus ValidateException(const CDB_Exception &ex)

virtual string GetName(void) const

static CDB_Connection * CtxMakeConnection(I_DriverContext &ctx, const CDBConnParams &params)

Helper method to provide access to a protected method in I_DriverContext for child classses.

virtual bool RecordServer(I_ConnectionExtra &) const

Given a connection that succeeded even though this service mapper was unable to identify a good serve...

list< CRef< CDBServerOption > > TOptions

IDBServiceMapper *(* TFactory)(const IRegistry *registry)

virtual void GetServersList(const string &, list< string > *serv_list) const

Get list of all servers for the given service disregarding any exclusions.

size_t GetSize(void) const

void PostMsg(CDB_Exception *ex, const TDbgInfo *dbg_info=NULL, const CConnection *connection=NULL, const CDBParams *params=NULL) const

void Push(CDB_UserHandler *h, EOwnership ownership=eNoOwnership)

const CDBHandlerStack & GetCtxHandlerStack(void) const

container_type::iterator iterator

const_iterator end() const

iterator_bool insert(const value_type &val)

container_type::value_type value_type

const_iterator find(const key_type &key) const

void(*)(CSeq_entry_Handle seh, IWorkbench *wb, const CSerialObject &obj) handler

static string s_GetNextLogPrefix(void)

EDefaultMapping

CDBConnectionFactory.

Help distribute connections within a pool across servers.

static CS_CONNECTION * conn

const CNcbiRegistry & GetConfig(void) const

Get the application's cached configuration parameters (read-only).

#define ITERATE(Type, Var, Cont)

ITERATE macro to sequence through container elements.

#define NON_CONST_ITERATE(Type, Var, Cont)

Non constant version of ITERATE macro.

void swap(NCBI_NS_NCBI::pair_base_member< T1, T2 > &pair1, NCBI_NS_NCBI::pair_base_member< T1, T2 > &pair2)

@ eRetriable_No

It makes no sense to retry the action.

@ eTakeOwnership

An object can take ownership of another.

virtual CDB_Exception * Clone(void) const

int GetDBErrCode(void) const

#define DATABASE_DRIVER_ERROR(message, err_code)

static CDB_UserHandler & GetDefault(void)

#define CHECK_DRIVER_ERROR(failed, message, err_code)

EErrCode

Error types that can be generated.

deque< CDB_Exception * > TExceptions

Exception container type.

virtual const impl::CDBHandlerStack & GetOpeningMsgHandlers(void) const =0

virtual Uint4 GetHost(void) const =0

virtual string GetServerName(void) const =0

virtual Uint2 GetPort(void) const =0

virtual string GetDatabaseName(void) const =0

virtual CRef< IConnValidator > GetConnValidator(void) const =0

virtual string GetUserName(void) const =0

virtual string GetParam(const string &key) const =0

Parameters, which are not listed above explicitly, should be retrieved via SetParam() method.

virtual string GetDriverName(void) const

virtual Uint4 Host() const

Get the host.

unsigned int GetReuseCount() const

Indicate how many times (if at all) this connection has been previously used.

virtual const string & PoolName() const

Find out which connection pool this connection belongs to.

virtual const string & ServerName() const

Get the server name.

virtual Uint2 Port() const

Get the port.

CDiagContext_Extra & Print(const string &name, const string &value)

The method does not print the argument, but adds it to the string.

CDiagContext & GetDiagContext(void)

Get diag context instance.

CDiagContext_Extra Extra(void) const

Create a temporary CDiagContext_Extra object.

#define DIAG_COMPILE_INFO

Make compile time diagnostic information object to use in CNcbiDiag and CException.

const string & GetProperty(const string &name) const

Get property value or empty string.

void SetProperty(const string &name, const string &value)

Add/change property.

static CRequestContext & GetRequestContext(void)

Shortcut to CDiagContextThreadData::GetThreadData().GetRequestContext()

TCount GetRequestID(void) const

Get request ID (or zero if not set).

#define ERR_POST_X(err_subcode, message)

Error posting with default error code and given error subcode.

@ eDiag_Error

Error message.

@ eDiag_Warning

Warning message.

@ eDiagSevMax

Verbosity level for max. severity.

void Warning(CExceptionArgs_Base &args)

bool NotNull(void) const THROWS_NONE

Check if pointer is not null – same effect as NotEmpty().

TObjectType * GetPointer(void) THROWS_NONE

Get pointer,.

void Reset(void)

Reset reference object.

bool NotEmpty(void) const THROWS_NONE

Check if CRef is not empty – pointing to an object and has a non-null value.

TObjectType * Release(void)

Release a reference to the object and return a pointer to the object.

bool Empty(void) const THROWS_NONE

Check if CRef is empty – not pointing to any object, which means having a null value.

uint32_t Uint4

4-byte (32-bit) unsigned integer

uint16_t Uint2

2-byte (16-bit) unsigned integer

virtual bool GetBool(const string &section, const string &name, bool default_value, TFlags flags=0, EErrAction err_action=eThrow) const

Get boolean value of specified parameter name.

virtual int GetInt(const string &section, const string &name, int default_value, TFlags flags=0, EErrAction err_action=eThrow) const

Get integer value of specified parameter name.

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

static TNumeric StringToNumeric(const CTempString str, TStringToNumFlags flags=0, int base=10)

Convert string to a numeric value.

static string Join(const TContainer &arr, const CTempString &delim)

Join strings using the specified delimiter.

static string UIntToString(unsigned int value, TNumToStringFlags flags=0, int base=10)

Convert UInt to string.

static bool SplitInTwo(const CTempString str, const CTempString delim, string &str1, string &str2, TSplitFlags flags=0)

Split a string into two pieces using the specified delimiters.

static unsigned int StringToUInt(const CTempString str, TStringToNumFlags flags=0, int base=10)

Convert string to unsigned int.

static enable_if< is_arithmetic< TNumeric >::value||is_convertible< TNumeric, Int8 >::value, string >::type NumericToString(TNumeric value, TNumToStringFlags flags=0, int base=10)

Convert numeric value to string.

unsigned short m_Port

TCP port to listen on.

CTime CurrentTime(CTime::ETimeZone tz=CTime::eLocal, CTime::ETimeZonePrecision tzp=CTime::eTZPrecisionDefault)

time_t GetTimeT(void) const

Get time in time_t format.

@ eUTC

UTC (Universal Coordinated Time)

Definition of all error codes used in dbapi libraries (dbapi_driver.lib and others).

string ConvertN2A(Uint4 host)

const struct ncbi::grid::netcache::search::fields::KEY key

CRef< CDBServer > TSvrRef

Defines the CNcbiApplication and CAppException classes for creating NCBI applications.

Defines CRequestContext class for NCBI C++ diagnostic API.

IConnValidator::EConnStatus conn_status

SOpeningContext(I_DriverContext &driver_ctx_in, CServiceInfo &service_info_in, CDB_UserHandler::TExceptions &exceptions)

impl::CDBHandlerStack handlers

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4