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

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

NCBI C++ ToolKit: src/connect/connection_pool.cpp Source File

;

m_MaxConnections(max_connections), m_ListeningStarted(

)

->expiration.AddNanoSecond(timeout->

* 1000);

->expiration.Clear();

->type_lock.Lock();

->type_lock.Unlock();

);

(listener->

() == port) {

->type_lock.Lock();

->type = new_type;

->type_lock.Unlock();

<<

->type_lock.Lock();

);

->type_lock.Unlock();

->type_lock.Unlock();

vector<CSocketAPI::SPoll>& polls,

vector<IServer_ConnectionBase*>& timer_requests,

vector<IServer_ConnectionBase*>& revived_conns,

vector<IServer_ConnectionBase*>& to_close_conns,

vector<IServer_ConnectionBase*>& to_delete_conns)

revived_conns.clear();

to_close_conns.clear();

to_delete_conns.clear();

alarm_time_defined =

;

port = listener->

();

vector<unsigned short>::iterator port_it =

to_delete_conns.push_back(conn_base);

to_close_conns.push_back(conn_base);

(alarm_time !=

) {

(!alarm_time_defined) {

alarm_time_defined =

;

min_alarm_time = *alarm_time > current_time? alarm_time:

;

timer_requests.clear();

timer_requests.push_back(conn_base);

}

(min_alarm_time ==

) {

(*alarm_time <= current_time)

timer_requests.push_back(conn_base);

}

(*alarm_time <= *min_alarm_time) {

(*alarm_time != *min_alarm_time) {

min_alarm_time = *alarm_time > current_time? alarm_time

timer_requests.clear();

timer_requests.push_back(conn_base);

revived_conns.push_back(conn_base);

(alarm_time_defined) {

(min_alarm_time ==

)

timer_timeout->

= timer_timeout->

= 0;

timer_timeout->

= timer_timeout->

= 0;

(vector<CSocketAPI::SPoll>, it, polls) {

(vector<IServer_ConnectionBase*>, it, conns) {

vector<unsigned short> ports;

port = listener->

();

ports.push_back(listener->

());

void Release()

Manually force the resource to be released.

iterator_bool insert(const value_type &val)

const_iterator find(const key_type &key) const

const_iterator end() const

Internal header for threaded server connection pools.

static CS_CONNECTION * conn

#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.

#define NON_CONST_ITERATE(Type, Var, Cont)

Non constant version of ITERATE macro.

#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.

void Critical(CExceptionArgs_Base &args)

void Warning(CExceptionArgs_Base &args)

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

const STimeout * GetTimeout(EIO_Event event) const

Get timeout for I/O in the specified direction.

EIO_Status Abort(void)

Abort socket connection.

void StartListening(void)

void CloseConnection(TConnBase *conn)

Close connection as if it was initiated by server (not by client).

std::string g_ServerConnTypeToString(enum EServerConnType conn_type)

void Erase(void)

Erase all connections.

void SetAllActive(const vector< CSocketAPI::SPoll > &polls)

unsigned int m_MaxConnections

virtual bool IsReadyToProcess(void)

CServer_ConnectionPool(unsigned max_connections)

volatile EServerConnType type

bool GetPollAndTimerVec(vector< CSocketAPI::SPoll > &polls, vector< IServer_ConnectionBase * > &timer_requests, STimeout *timer_timeout, vector< IServer_ConnectionBase * > &revived_conns, vector< IServer_ConnectionBase * > &to_close_conns, vector< IServer_ConnectionBase * > &to_delete_conns)

vector< unsigned short > GetListenerPorts(void)

Provides a list of ports on which the server is listening.

CTrigger m_ControlTrigger

~CServer_ConnectionPool()

unsigned short GetPort(void) const

bool Add(TConnBase *conn, EServerConnType type)

virtual EIO_Event GetEventsToPollFor(const CTime **) const

virtual bool IsOpen(void)

void Remove(TConnBase *conn)

void SetConnType(TConnBase *conn, EServerConnType type)

Guard connection from out-of-order packet processing by pulling eActiveSocket's from poll vector Rese...

bool RemoveListener(unsigned short port)

void OnSocketEvent(EServIO_Event event)

void x_UpdateExpiration(TConnBase *conn)

vector< unsigned short > m_ListenerPortsToStop

void PingControlConnection(void)

void Lock(void)

Acquire mutex for the current thread with no nesting checks.

void Unlock(void)

Release mutex with no owner or nesting checks.

long GetNanoSecondsAfterSecond(void) const

Get number of nanoseconds.

CTimeSpan DiffTimeSpan(const CTime &t) const

Difference in nanoseconds from specified time.

CTime GetFastLocalTime(void)

Quick and dirty getter of local time.

long GetCompleteSeconds(void) const

Get number of complete seconds.

@ eEmpty

Use "empty" time.

@ eIgnoreDaylight

Ignore daylight saving time.

unsigned int usec

microseconds (modulo 1,000,000)

const char * IO_StatusStr(EIO_Status status)

Get the text form of an enum status value.

@ eIO_Success

everything is fine, no error occurred

@ eIO_ReadWrite

eIO_Read | eIO_Write (also, eCONN_OnFlush)

Definition of all error codes used in connect library (xconnect.lib, xconnext.lib etc).

The polling structure m_Event can be either of eIO_Open, eIO_Read, eIO_Write, eIO_ReadWrite.

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