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

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

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

m_Generation(server->m_ServerInPool->m_CurrentConnectionGeneration.

()),

(TServConn_UserLinger2::GetDefault())

upper_limit = TServConn_MaxConnPoolSize::GetDefault();

m_FreeConnectionListSize < upper_limit) {

multiline_output)

);

);

* semicolon = strchr(reply,

);

(semicolon ==

) {

conn_listener->OnWarning(

(reply, reply + reply_len),

conn_listener->OnWarning(

(reply, semicolon),

);

reply_len -= semicolon - reply + 1;

reply = semicolon + 1;

}

(!multiline_output) {

(TServConn_ErrorOnUnexpectedReply::GetDefault()) {

conn_listener->OnError(

+

,

);

}

(TServConn_WarnOnUnexpectedReply::GetDefault()) {

conn_listener->OnWarning(

+

,

);

(line +

);

*

=

.data();

multiline_output,

->m_Socket.SetCork(

);

->m_Socket.GetOSHandle(&fd,

(fd));

setsockopt(fd, IPPROTO_TCP, TCP_QUICKACK, &

,

(

));

m_Address(std::move(address)),

m_ServerProperties(server_properties),

m_ThrottleStats(std::move(throttle_params))

rv = std::move(args.

());

*

= version_string.c_str();

* prev_part_end =

;

attr_name, attr_value;

memcmp(

+ 1,

, 6) == 0) {

* version_number =

+ 7;

attr_name.assign(prev_part_end, version_number);

attr_name[attr_name.size() - 7] =

;

(

(*version_number) ||

*version_number ==

|| *version_number ==

)

* version_number_end = version_number;

(

(*version_number_end) ||

*version_number_end ==

)

++version_number_end;

attr_value.assign(version_number, version_number_end);

prev_part_end = version_number_end;

(

(*prev_part_end) || *prev_part_end ==

)

memcmp(

+ 1,

, 3) == 0 &&

* build =

+ 5;

attr_name.assign(

, build);

attr_name[attr_name.size() - 5] =

;

(

(*build) || *build ==

|| *build ==

)

attr_value.assign(build);

(prev_part_end <

) {

(--

== prev_part_end)

,

(prev_part_end,

)));

m_NextAttribute(m_Attributes.begin())

->GetNextAttribute(attr_name, attr_value);

->m_ServerInPool->m_Address;

->m_Server = server;

->m_Generation !=

->m_Socket.GetSOCK(),

->m_Socket.Close();

(remaining.

())

;

(t1.

< t2.

)

t1;

(t1.

> t2.

)

t2;

(t1.

< t2.

)

t1;

& socket =

->m_Socket;

socket.SetDataLogging(TServConn_ConnDataLogging::GetDefault() ?

:

);

socket.DisableOSSendDelay();

socket.SetReuseAddress(

);

& throttle_stats = server_in_pool.m_ThrottleStats;

throttle_stats.Check(

);

server_in_pool.TryExec(

,

, timeout);

throttle_stats.Adjust(

, e.

());

throttle_stats.Adjust(

, -1);

multiline_output,

multiline_output,

exec_result, exec_listener);

(exec_handler, timeout);

op_result = err_code >= 0;

;

(reg[index] != op_result) {

reg[index] = op_result;

;

os <<

<< address.

() <<

<<

.AsString() <<

<<

multiline_output,

retry_on_exception)

attempt = 0;

(++attempt > max_retries ||

(

<<

(++attempt > max_retries ||

(

<<

warning +=

;

->ConnectAndExec(

, multiline_output,

);

(

);

{

,

}, 0);

error_rate =

.

(sections,

,

);

(error_rate.empty())

;

numerator_str, denominator_str;

(!

(error_rate,

, numerator_str, denominator_str))

;

void Release()

Manually force the resource to be released.

CNanoTimeout – Timeout interval, using nanoseconds.

NetSchedule internal exception.

CNetRef< SNetServerConnectionImpl > m_Impl

string Exec(const string &cmd, bool multiline_output=false, const STimeout *timeout=NULL)

Execute remote command 'cmd', wait for the reply, check that it starts with 'OK:',...

CNetServerExecHandler(const string &cmd, bool multiline_output, CNetServer::SExecResult &exec_result, INetServerExecListener *exec_listener)

INetServerExecListener * m_ExecListener

CNetServer::SExecResult & m_ExecResult

virtual void Exec(CNetServerConnection::TInstance conn_impl, const STimeout *timeout)

CNetRef< SNetServerInfoImpl > m_Impl

bool GetNextAttribute(string &attr_name, string &attr_value)

Return the next attribute.

CNetServerMultilineCmdOutput()

bool ReadLine(string &output)

CNetRef< SNetServerMultilineCmdOutputImpl > m_Impl

const SSocketAddress & GetAddress() const

CNetRef< SNetServerImpl > m_Impl

CNetServerInfo GetServerInfo()

Retrieve basic information about the server as attribute name-value pairs.

SExecResult ExecWithRetry(const string &cmd, bool multiline_output=false)

Execute remote command 'cmd', wait for the reply, check if it starts with 'OK:', and return the remai...

CTimeout – Timeout interval.

virtual void OnExec(CNetServerConnection::TInstance conn_impl, const string &cmd)=0

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

static CS_CONNECTION * conn

static SQLCHAR output[256]

static const char * str(char *buf, int n)

void Set(TValue new_value) THROWS_NONE

Set atomic counter value.

TValue Get(void) const THROWS_NONE

Get atomic counter value.

#define ERR_POST(message)

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

TErrCode GetErrCode(void) const

Get error code.

#define NCBI_THROW(exception_class, err_code, message)

Generic macro to throw an exception, given the exception class, error code and message string.

const string & GetMsg(void) const

Get message string.

bool Referenced(void) const THROWS_NONE

Check if object is referenced.

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

Get the parameter value.

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

EIO_Status Connect(const string &host, unsigned short port, const STimeout *timeout=kDefaultTimeout, TSOCK_Flags flags=fSOCK_LogDefault)

Connect to "host:port".

EIO_Status Close(void)

Close socket.

static unsigned short HostToNetShort(unsigned short value)

EIO_Status ReadLine(string &str)

Read a line from socket (up to CR-LF, LF, or null character, discarding any of the EOLs).

const STimeout * GetTimeout(EIO_Event event) const

Get timeout for I/O in the specified direction.

EIO_Status SetTimeout(EIO_Event event, const STimeout *timeout)

Set timeout for I/O in the specified direction.

EIO_Status Abort(void)

Abort socket connection.

static unsigned int NetToHostLong(unsigned int value)

EIO_Status GetStatus(EIO_Event direction) const

Return status of *last* I/O operation without making any actual I/O.

EIO_Status SOCK_Poll(size_t n, SSOCK_Poll polls[], const STimeout *timeout, size_t *n_ready)

Block until at least one of the sockets enlisted in "polls" array (of size "n") becomes available for...

EIO_Event revent

[in] one of: eIO_Open/Read/Write/ReadWrite

static string ntoa(const CNCBI_IPAddr &addr)

BSD-like API.

EIO_Status Write(const void *buf, size_t size, size_t *n_written=0, EIO_WriteMethod how=eIO_WritePersist)

Write to socket.

@ fSOCK_KeepAlive

keep socket alive (if supported by OS)

@ fSOCK_LogOff

NB: logging is inherited in accepted SOCK.

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

Convert string to int.

static string ParseEscapes(const CTempString str, EEscSeqRange mode=eEscSeqRange_Standard, char user_char='?')

Parse C-style escape sequences in the specified string.

static bool StartsWith(const CTempString str, const CTempString start, ECase use_case=eCase)

Check if a string starts with a specified prefix value.

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

@ fAllowTrailingSpaces

Ignore trailing whitespace characters.

@ fConvErr_NoThrow

Do not throw an exception on error.

@ fAllowLeadingSpaces

Ignore leading whitespace characters in converted string.

CNanoTimeout GetRemainingTime(void) const

Get time left to the expiration.

CTime & AddSecond(TSeconds seconds=1, EDaylight adl=eDaylightDefault)

Add specified seconds.

bool IsExpired(void) const

Check if the deadline is expired.

string AsString(const CTimeFormat &format=kEmptyStr, TSeconds out_tz=eCurrentTimeZone) const

Transform time to string.

double GetAsDouble(void) const

Get as number of seconds (fractional value).

CTime & SetCurrent(void)

Make the time current in the presently active time zone.

unsigned long GetAsMilliSeconds(void) const

Get as number of milliseconds.

CTime GetFastLocalTime(void)

Quick and dirty getter of local time.

void Get(unsigned int *sec, unsigned int *microsec) const

Get timeout in seconds and microseconds.

const TArgs & GetArgs(void) const

Get the const list of arguments.

unsigned long NcbiTimeoutToMs(const STimeout *timeout)

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_Timeout

timeout expired before any I/O succeeded

@ eIO_Success

everything is fine, no error occurred

@ eIO_ReadWrite

eIO_Read | eIO_Write (also, eCONN_OnFlush)

@ eIO_Open

also serves as no-event indicator in SOCK_Poll

@ eIO_Close

also serves as an error indicator in SOCK_Poll

Definition of all error codes used in connect services library (xconnserv.lib and others).

const TYPE & Get(const CNamedParameterList *param)

const string version

version string

chrono::system_clock::duration duration

void SleepMilliSec(unsigned long ml_sec, EInterruptOnSignal onsignal=eRestartOnSignal)

void g_AppendClientIPSessionIDHitID(string &cmd)

#define CONNSERV_THROW_FMT(exception_class, err_code, server, message)

CUrlArgs::TArgs s_GetAttributes(const string &version_string)

#define END_OF_MULTILINE_OUTPUT

#define WARNING_PREFIX_LEN

static const STimeout s_ZeroTimeout

CNetServerInfo g_ServerInfoFromString(const string &server_info)

CNetServerConnection conn

void OnError(const string &err_msg, CNetServer &server)

void SetErrorHandler(TEventHandler error_handler)

INetServerConnectionListener & operator=(const INetServerConnectionListener &)

virtual TPropCreator GetPropCreator() const

function< INetServerProperties *()> TPropCreator

virtual void OnErrorImpl(const string &err_msg, CNetServer &server)=0

CNetService::TEventHandler TEventHandler

virtual void OnConnected(CNetServerConnection &connection)=0

virtual void OnWarningImpl(const string &warn_msg, CNetServer &server)=0

void SetWarningHandler(TEventHandler warning_handler)

TEventHandler m_WarningHandler

INetServerConnectionListener()=default

TEventHandler m_ErrorHandler

void OnWarning(const string &warn_msg, CNetServer &server)

SNetServerConnectionImpl(SNetServerImpl *pool)

virtual ~SNetServerConnectionImpl()

SNetServerConnectionImpl * m_NextFree

CAtomicCounter::TValue m_Generation

void ReadCmdOutputLine(string &result, bool multiline_output)

void WriteLine(const string &line)

virtual void DeleteThis()

Virtual method "deleting" this object.

static const STimeout kMaxTryTimeout

SConnectDeadline(const STimeout &conn_timeout)

CTimeout GetTotal() const

static STimeout Min(const STimeout &t1, const STimeout &t2)

const STimeout * GetRemaining() const

CRef< SNetServerInPool > m_ServerInPool

static void ConnectImpl(CSocket &, SConnectDeadline &, const SSocketAddress &, const SSocketAddress &)

void TryExec(INetServerExecHandler &handler, const STimeout *timeout=NULL)

CNetServer::SExecResult ConnectAndExec(const string &cmd, bool multiline_output, bool retry_on_exception=false)

SNetServerInPool(SSocketAddress address, INetServerProperties *server_properties, SThrottleParams throttle_params)

virtual ~SNetServerInPool()

int m_FreeConnectionListSize

void TryExec(SNetServerImpl *server, INetServerExecHandler &handler, const STimeout *timeout)

SNetServerConnectionImpl * m_FreeConnectionListHead

CNetServerPool m_ServerPool

virtual void DeleteThis()

Virtual method "deleting" this object.

CNetServerConnection GetConnectionFromPool(SNetServerImpl *server)

CAtomicCounter m_CurrentConnectionGeneration

CFastMutex m_FreeConnectionListLock

CNetServerConnection Connect(SNetServerImpl *server, const STimeout *timeout)

bool GetNextAttribute(string &attr_name, string &attr_value)

SNetServerInfoImpl(const string &version_string)

TAttributes::const_iterator m_NextAttribute

virtual ~SNetServerMultilineCmdOutputImpl()

bool m_NetCacheCompatMode

CNetServerConnection m_Connection

bool ReadLine(string &output)

CRef< INetServerConnectionListener > m_Listener

unsigned GetConnectionMaxRetries() const

unsigned long GetConnectionRetryDelay() const

static void ConnectXSite(CSocket &, SNetServerImpl::SConnectDeadline &, const SSocketAddress &, const string &)

void Init(CSynRegistry &registry, const SRegSynonyms &sections)

constexpr static size_t kMaxDenominator

int max_consecutive_io_failures

bool throttle_until_discoverable

struct SThrottleParams::SIOFailureThreshold io_failure_threshold

bool connect_failures_only

void Init(CSynRegistry &registry, const SRegSynonyms &sections)

void Check(SNetServerImpl *server_impl)

bool m_DiscoveredAfterThrottling

CFastMutex m_ThrottleLock

const SThrottleParams m_Params

void Adjust(SNetServerImpl *server_impl, int err_code)

pair< bitset< SThrottleParams::SIOFailureThreshold::kMaxDenominator >, size_t > m_IOFailureRegister

int m_NumberOfConsecutiveIOFailures

int g(Seg_Gsm *spe, Seq_Mtf *psm, Thd_Gsm *tdg)

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