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__impl__context_8cpp_source.html below:

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

& server_name)

(pool_name.empty()) {

->ServerName() == server_name

||

->GetRequestedServer() == server_name;

->PoolName() == pool_name;

success =

;

success =

;

con->PopMsgHandler(h);

con->PopMsgHandler(h);

(

.Get(

) ==

) {

.Set(

,

);

(!

.Get(

).empty()) {

reset =

.Get(

);

( !consumer.selected

&& (consumer.subject_is_pool

?

->PoolName() == consumer.subject

consumer.selected =

;

recipient = &consumer.conn;

(conn_reusable &&

->IsOpeningFinished() &&

->IsValid()) {

(

->m_Pool.empty()) {

(

>=

->m_PoolMaxSize) {

(keep &&

->m_ReuseCount + 1 >

->m_PoolMaxConnUse) {

->m_CleanupTime = now +

->m_PoolIdleTimeParam;

(recipient !=

) {

(

!= 0 &&

->IsReusable()) {

server_name =

->GetServerName();

(

->Host() != 0 && server_name.find(

) ==

) {

(

->Port() != 0) {

(server_name <<

<<

<<

<<

->PoolName() <<

<< pool_count <<

<<

->GetRequestedServer() <<

<< service_count <<

);

& name,

* counts)

it = main_map.

(name);

(it == main_map.

()) {

*counts = it->second;

& pool_name,

max_closings)

( !srv_name.empty() && srv_name != con->ServerName()

&& srv_name != con->GetRequestedServer() )

((!pool_name.empty()) && pool_name.compare(con->PoolName()))

;

(--max_closings == 0) {

& pool_name)

((!svr_ref || !svr_ref->

()) && pool_name.empty()) {

(!server.empty()) {

(server != con->ServerName()

&& server != con->GetRequestedServer())

(host != 0) {

(host != con->Host() || port != con->Port())

((!pool_name.empty()) && pool_name.compare(con->PoolName()))

;

& pool_name)

.push_back(connection);

(params.

(

) ==

) {

pool_name (params.

(

)),

(

(t_con, pool_name, server_name)) {

pool_max_str(params.

(

));

(!pool_max_str.empty() && pool_max_str !=

) {

(

(t_con, pool_name, server_name)) {

(total_cnt >= pool_max) {

timeout_str(params.

(

));

timeout_val = 0.0;

( !timeout_str.empty() && timeout_str !=

) {

(pool_name.empty()) {

, !pool_name.empty()));

timed_out =

;

relocked =

;

(target->selected) {

(&it != &*target && it.selected) {

(*it == target->conn) {

t_con = target->conn;

(t_con !=

) {

(params.

(

)

=

(

<< pool_max <<

<< (pool_name.empty() ? server_name

(params.

(

) ==

) {

(!TDbapi_CanUseKerberos::GetDefault()

err_msg(

);

err_msg +=

;

err_msg +=

;

& dn,

& pass)

& db_name,

& password)

(!TDbapi_ConnUseEncryptData::GetDefault())

res_name = app_name;

(!user_name.empty()) {

res_name += user_name;

(!server_name.empty()) {

res_name += server_name;

(!db_name.empty()) {

password =

.GetValue();

TExtraMap::const_iterator TExtraMapIt;

TExtraMap& extra =

.GetExtraValues().GetPairs();

TExtraMapIt it = extra.find(

);

(it != extra.end())

server_name = it->second;

it = extra.find(

);

(it != extra.end())

user_name = it->second;

it = extra.find(

);

(it != extra.end())

db_name = it->second;

(server_name, user_name, db_name, password)).second)

, 100012);

(service_name.empty())

}

(

+ service_name);

<<

+ service_name);

params->

= service_name +

;

& section_name,

params->

= reg.

(section_name,

);

params->

= reg.

(section_name,

);

params->

= reg.

(section_name,

);

params->

= reg.

(section_name,

);

params->

= reg.

(section_name,

);

(reg.

(section_name,

,

params->

= reg.

(section_name,

);

params->

= reg.

(section_name,

);

params->

= reg.

(section_name,

);

(reg.

(section_name,

,

(reg.

(section_name,

,

(reg.

(section_name,

,

= reg.

(section_name,

);

(reg.

(section_name,

,

= reg.

(section_name,

);

(reg.

(section_name,

,

= reg.

(section_name,

);

(reg.

(section_name,

,

= reg.

(section_name,

);

params->

= reg.

(section_name,

);

pool_min_str = params.

(

);

(pool_min_str.empty() || pool_min_str ==

)

pool_name = params.

(

),

vector< AutoPtr<CDB_Connection> > conns(pool_min);

(

= total_cnt;

< pool_min; ++

) {

(1,

<< ex);

conf_params.

();

(params.

(

) !=

) {

unique_ptr<CDB_Connection> t_con;

timeout;

(cfactory !=

) {

(

==

) {

}

(!

.empty()) {

(timeout == 0 && cfactory !=

) {

(

==

) {

}

(!

.empty()) {

(cfactory !=

) {

validation_timeout = cfactory->GetConnectionTimeout();

(validation_timeout == 0) {

validation_timeout = timeout ? timeout : 30;

(

==

) {

(!

.empty()) {

act_params.

(

,

);

act_params.

(

,

(params.

(

) ==

) {

act_params.

(

,

);

act_params.

(

,

);

act_params.

(

,

(params.

(

) ==

) {

act_params.

(

,

);

(params.

(

) ==

) {

act_params.

(

,

);

(params.

(

) ==

) {

act_params.

(

,

);

(params.

(

) ==

) {

act_params.

(

,

);

(params.

(

) ==

) {

act_params.

(

,

);

act_params.

(

,

);

(

,

(params.

(

) ==

) {

act_params.

(

,

);

act_params.

(

,

(params.

(

) ==

) {

act_params.

(

,

);

act_params.

(

,

);

(

,

(params.

(

) ==

) {

act_params.

(

,

);

act_params.

(

,

);

(

,

(params.

(

) ==

) {

act_params.

(

,

);

(t_con.get() ==

) {

(act_params.

(

) ==

) {

err +=

+ act_params.

();

err +=

+ act_params.

() +

;

ex.AddPrevious(*it);

t_con->SetTimeout(timeout);

t_con.release();

invalidated_count = 0;

(t_con->

() != keep_host_ip || t_con->

() != keep_port) {

++invalidated_count;

(t_con->

() != keep_host_ip || t_con->

() != keep_port) {

invalidated_count;

& pool_name)

(max_closings == 0) {

& pool_name_2 = (*it)->PoolName();

= pool_name_2.

() ? at_min_by_server : at_min_by_pool;

(pool_name_2.empty()) {

( !pool_name.empty()

|| at_min.

((*it)->GetRequestedServer()) != at_min.

()) {

}

(( !pool_name.empty() && pool_name != pool_name_2)

|| at_min.

(pool_name_2) != at_min.

()) {

((*it)->m_CleanupTime.IsEmpty() || (*it)->m_CleanupTime > now) {

(pool_name_2.empty()) {

(

> (*it)->m_PoolMinSize) {

(--max_closings == 0) {

at_min.

(pool_name_2);

->ReleaseInterface();

(!t_con)

;

(!t_con)

;

(!t_con)

;

(!t_con)

;

(WSAStartup(MAKEWORD(1, 1), &wsaData) != 0)

unsigned int GetLoginTimeout(void) const

Uint2 GetPort(void) const

const string & GetName(void) const

Uint4 GetHost(void) const

CRef< IDBConnectionFactory > GetConnectionFactory(void) const

Retrieve a connection factory.

static CDbapiConnMgr & Instance(void)

Get access to the class instance.

void Guard(resource_type &resource)

Manually force the guard to protect some other resource.

void Release()

Manually force the resource to be released.

static CNcbiApplication * Instance(void)

Singleton method.

static bool IsEncrypted(const string &data)

Check if the string contains valid encrypted data.

static string Decrypt(const string &encrypted_string)

Decrypt a string using the matching key found in the NCBI keys files.

Class for handling resource info files.

static string GetDefaultFileName(void)

Get default resource info file location (/etc/ncbi/.info).

const CNcbiResourceInfo & GetResourceInfo(const string &res_name, const string &pwd) const

Get read-only resource info for the given name.

Class for storing encrypted resource information.

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

CTimeout – Timeout interval.

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

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

virtual void SetTimeout(size_t nof_secs)=0

virtual void SetBlobSize(size_t nof_bytes)

bool IsReusable(void) const

Check if this connection is a reusable one.

virtual bool IsAlive(void)=0

Check out if connection is alive (this function doesn't ping the server, it just checks the status of...

const string & PoolName(void) const

Find out which connection pool this connection belongs to.

impl::CDBConnParamsBase::

virtual string GetPassword(void) const

virtual string GetDatabaseName(void) const

virtual string GetUserName(void) const

void SetUserName(const string &name)

virtual string GetParam(const string &key) const

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

void SetParam(const string &key, const string &value)

void SetServerName(const string &name)

void SetPassword(const string &passwd)

virtual string GetServerName(void) const

void SetDatabaseName(const string &name)

void Pop(CDB_UserHandler *h, bool last=true)

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

virtual void PopDefConnMsgHandler(CDB_UserHandler *h)

Remove `per-connection' mess. handler "h" and all above it in the stack.

virtual void PushDefConnMsgHandler(CDB_UserHandler *h, EOwnership ownership=eNoOwnership)

Add `per-connection' err.message handler "h" to the stack of default handlers which are inherited by ...

CDBHandlerStack m_ConnHandlers

Stacks of `per-connection' err.message handlers.

void x_AdjustCounts(const CConnection *conn, int delta)

virtual CDB_Connection * MakeConnection(const CDBConnParams &params)

Create connection object using Load Balancer / connection factory.

size_t CloseConnsForPool(const string &pool_name, Uint4 keep_host_ip=0, Uint2 keep_port=0)

virtual void SetHostName(const string &host_name)

Set host name.

virtual void PushCntxMsgHandler(CDB_UserHandler *h, EOwnership ownership=eNoOwnership)

Add message handler "h" to process 'context-wide' (not bound to any particular connection) error mess...

list< SConsumer > m_PoolSemConsumers

void ReadDBConfParams(const string &service_name, SDBConfParams *params)

size_t GetMaxBlobSize(void) const

CDBHandlerStack m_CntxHandlers

Stack of `per-context' err.message handlers.

virtual string GetHostName(void) const

Get host name.

bool SatisfyPoolMinimum(const CDBConnParams &params)

void x_Recycle(CConnection *conn, bool conn_reusable)

Return unused connection "conn" to the driver context for future reuse (if "conn_reusable" is TRUE) o...

virtual unsigned int GetCancelTimeout(void) const

unsigned int m_LoginTimeout

unsigned int m_CancelTimeout

virtual unsigned int NofConnections(const string &srv_name="", const string &pool_name="") const

Return number of currently open connections in this context.

TCountsMap m_CountsByPool

virtual bool SetTimeout(unsigned int nof_secs=0)

Set connection timeout.

static void ResetEnvSybase(void)

virtual ~CDriverContext(void)

void UpdateConnMaxBlobSize(void) const

TConnPool m_NotInUse

Unused(reserve) connections.

virtual string GetApplicationName(void) const

Return application name.

virtual void PopCntxMsgHandler(CDB_UserHandler *h)

Remove message handler "h" and all handlers above it in the stack.

CDB_Connection * MakePooledConnection(const CDBConnParams &params)

Create connection object WITHOUT using of Load Balancer / connection factory.

virtual bool SetMaxBlobSize(size_t nof_bytes)

Set maximal size for BLOB data.

virtual void SetClientCharset(const string &charset)

virtual CRWLock & x_GetCtxLock(void) const

void CloseOldIdleConns(unsigned int max_closings, const string &pool_name=kEmptyStr)

virtual unsigned int GetLoginTimeout(void) const

Get login timeout.

virtual CConnection * MakeIConnection(const CDBConnParams &params)=0

void x_ReadDBConfParams(const IRegistry &reg, const string &section_name, SDBConfParams *params)

virtual void SetApplicationName(const string &app_name)

Set application name.

virtual bool SetLoginTimeout(unsigned int nof_secs=0)

Set login timeout.

CDB_Connection * MakeCDBConnection(CConnection *connection, int delta)

TConnPool m_InUse

Used connections.

EEncoding m_ClientEncoding

virtual unsigned int GetTimeout(void) const

Get connection timeout.

TCountsMap m_CountsByService

void UpdateConnTimeout(void) const

void x_GetCounts(const TCountsMap &main_map, const string &name, TCounts *counts) const

void CloseUnusedConnections(const string &srv_name=kEmptyStr, const string &pool_name=kEmptyStr, unsigned int max_closings=kMax_UInt)

close reusable deleted connections for specified server and/or pool

void DestroyConnImpl(CConnection *impl)

list< CConnection * > TConnPool

virtual bool SetCancelTimeout(unsigned int nof_secs)

virtual string GetUserName(void) const

virtual Uint4 GetProtocolVersion(void) const

virtual CRef< IConnValidator > GetConnValidator(void) const

~CMakeConnActualParams(void)

virtual string GetDatabaseName(void) const

const CDBConnParams & m_Other

virtual string GetPassword(void) const

virtual Uint2 GetPort(void) const

void SetUserName(const string &name)

virtual EEncoding GetEncoding(void) const

virtual string GetParam(const string &key) const

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

void SetParam(const string &key, const string &value)

virtual string GetServerName(void) const

virtual Uint4 GetHost(void) const

virtual EServerType GetServerType(void) const

void SetServerName(const string &name)

CMakeConnActualParams(const CDBConnParams &other)

void SetPassword(const string &passwd)

void SetDatabaseName(const string &name)

const_iterator end() const

const_iterator find(const key_type &key) const

iterator_bool insert(const value_type &val)

const_iterator find(const key_type &key) const

const_iterator end() const

NCBI_PARAM_DEF_EX(bool, dbapi, conn_use_encrypt_data, false, eParam_NoThread, NULL)

static CS_CONNECTION * conn

const CNcbiRegistry & GetConfig(void) const

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

constexpr size_t ArraySize(const Element(&)[Size])

#define ITERATE(Type, Var, Cont)

ITERATE macro to sequence through container elements.

#define ERASE_ITERATE(Type, Var, Cont)

Non-constant version with ability to erase current element, if container permits.

const string & GetProgramDisplayName(void) const

Get the application's "display" name.

#define NON_CONST_REVERSE_ITERATE(Type, Var, Cont)

Non constant version of REVERSE_ITERATE macro.

@ eRetriable_No

It makes no sense to retry the action.

@ eNegative

Value is negative.

@ eTakeOwnership

An object can take ownership of another.

void SetDatabaseName(const string &d)

#define DATABASE_DRIVER_ERROR(message, err_code)

static CDB_UserHandler & GetDefault(void)

static void ClearExceptions(TExceptions &expts)

deque< CDB_Exception * > TExceptions

Exception container type.

virtual EEncoding GetEncoding(void) const =0

virtual EServerType GetServerType(void) const =0

virtual string GetPassword(void) const =0

virtual Uint4 GetProtocolVersion(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 bool Refresh()

Reset the connection to the "ready" state (cancel all active commands)

#define DIAG_COMPILE_INFO

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

#define ERR_POST_X(err_subcode, message)

Error posting with default error code and given error subcode.

#define ERR_POST(message)

Error posting with file, line number information but without error codes.

@ eDiag_Error

Error message.

#define NCBI_CATCH(message)

Catch CExceptions as well This macro is deprecated - use *_X or *_XX variant instead of it.

#define STD_CATCH_ALL(message)

Standard handling of "exception"-derived exceptions; catches non-standard exceptions and generates "u...

void Warning(CExceptionArgs_Base &args)

#define FORMAT(message)

Format message using iostreams library.

TObjectType * GetPointerOrNull(void) THROWS_NONE

Get pointer value.

@ eParam_NoThread

Do not use per-thread values.

uint32_t Uint4

4-byte (32-bit) unsigned integer

uint16_t Uint2

2-byte (16-bit) unsigned integer

virtual const string & Get(const string &section, const string &name, TFlags flags=0) const

Get the parameter value.

virtual bool HasEntry(const string &section, const string &name=kEmptyStr, TFlags flags=0) const

@ fCountCleared

Let explicitly cleared entries stand.

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

static bool StringToBool(const CTempString str)

Convert string to bool.

static int CompareNocase(const CTempString s1, SIZE_TYPE pos, SIZE_TYPE n, const char *s2)

Case-insensitive compare of a substring with another string.

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

Convert string to int.

static double StringToDouble(const CTempStringEx str, TStringToNumFlags flags=0)

Convert string to double.

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

Convert string to a numeric value.

static const string BoolToString(bool value)

Convert bool to string.

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.

static bool Equal(const CTempString s1, SIZE_TYPE pos, SIZE_TYPE n, const char *s2, ECase use_case=eCase)

Test for equality of a substring with another string.

@ eEncoding_ISO8859_1

Note: From the point of view of the C++.

#define DEFINE_STATIC_MUTEX(id)

Define static mutex and initialize it.

bool TryWait(unsigned int timeout_sec=0, unsigned int timeout_nsec=0)

Timed wait.

void Post(unsigned int count=1)

Increment the semaphore by "count".

CTime & Clear(void)

Make the time "empty",.

@ eCurrent

Use current time. See also CCurrentTime.

enum ENcbiOwnership EOwnership

Ownership relations between objects.

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

string ConvertN2A(Uint4 host)

static bool s_Matches(CConnection *conn, const string &pool_name, const string &server_name)

static void s_TransformLoginData(string &server_name, string &user_name, string &db_name, string &password)

double value_type

The numeric datatype used by the parser.

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

const GenericPointer< typename T::ValueType > T2 value

CRef< CDBServer > TSvrRef

const char * NCBI_GetDefaultSybasePath(void)

Get default Sybase client installation path.

const char * NCBI_GetSybasePath(void)

Get Sybase client installation path.

Defines classes: CDirEntry, CFile, CDir, CSymLink, CMemoryFile, CFileUtil, CFileLock,...

Int4 delta(size_t dimension_, const Int4 *score_)

Defines NCBI C++ secure resources API.

static SLJIT_INLINE sljit_ins msg(sljit_gpr r, sljit_s32 d, sljit_gpr x, sljit_gpr b)

bool IsPoolIdleTimeSet(void)

string log_minor_messages

bool IsPoolMinSizeSet(void)

bool IsSingleServerSet(void)

bool IsPoolWaitTimeSet(void)

bool IsPoolMaxConnUseSet(void)

bool IsIOTimeoutSet(void)

bool IsPoolMaxSizeSet(void)

bool IsLogMinorMessagesSet(void)

string pool_allow_temp_overflow

bool IsContinueAfterRaiserrorSet(void)

bool IsPoolAllowTempOverflowSet(void)

bool IsCancelTimeoutSet(void)

string continue_after_raiserror

bool IsLoginTimeoutSet(void)

bool operator<(const SLoginData &right) const

SLoginData(const string &sn, const string &un, const string &dn, const string &pass)

void operator()(CDB_UserHandler::TExceptions &) const

void operator()(CDB_UserHandler::TExceptions &resource) const

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