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

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

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

) \

;

: m_Output(

), m_Width(width),

((status = (this->*check[s])(reason)) !=

) {

}

(

(s++) < stage);

(

);

+=

;

+ (!

.empty() && !

.empty() ?

:

) +

status = r_status > w_status ? r_status : w_status;

*

,

server_error)

*

,

server_error)

auxdata->

= server_error != 301 && server_error != 302;

*

,

server_error)

*((

*) auxdata->

) =

{

, 0 },

,

);

net_info->timeout = timeout;

net_info->max_try = 0;

nanosec;

::sprintf(net_info->path,

,

(

) sec, (

) nanosec);

vector< AutoPtr<CConn_HttpStream> > http;

(

= 0;

<

(kTests) /

(kTests[0]); ++

) {

user_header[80];

net_info->scheme = kTests[

].scheme;

* host = kTests[

].host;

* vhost = kTests[

].vhost;

(::strlen(host) <

(net_info->host) - 1);

::strcpy(net_info->host, host);

(::strlen(vhost) + 6 <

(user_header) - 1);

::sprintf(user_header,

, vhost);

*user_header =

;

http.back()->SetCanceledCallback(

);

(status < readst && (*h)->GetStatusCode() != 404)

);

);

(!net_info || !net_info->http_proxy_host[0]) {

=

;

+

(net_info->http_proxy_host) +

);

=

+

(net_info->http_proxy_host) +

;

);

,

);

(net_info->http_proxy_host[0] && net_info->http_proxy_port)

temp +=

;

temp +=

;

port = net_info->port != 0;

temp +=

;

temp += net_info->host;

temp += port ?

:

;

temp +=

> 1 ?

:

;

temp +=

;

temp +=

;

temp += net_info->http_proxy_host;

temp +=

;

(net_info->http_proxy_mask) {

temp +=

;

temp +=

;

temp +=

;

temp +=

;

(!net_info->http_proxy_mask && net_info->http_proxy_skip

&& (getenv(

) || getenv(

))) {

temp +=

;

temp +=

;

(net_info->http_proxy_mask) {

temp +=

(net_info->http_proxy_host[0] || net_info->http_proxy_port) {

temp +=

;

(net_info->http_proxy_port) {

temp +=

temp +=

+

(net_info->http_proxy_host) +

;

}

(net_info->http_proxy_skip

&& (getenv(

) || getenv(

))) {

temp +=

;

temp +=

;

temp +=

(*net_info->user || *net_info->pass) {

temp +=

;

temp +=

;

);

http.read(

,

(

));

temp =

temp +=

temp +=

;

temp +=

;

kBounceTest[] =

;

);

net_info->lb_disable = 1

;

responded = temp.size() > 0 ?

:

;

temp =

?

:

;

temp +=

;

temp = responded ?

:

;

temp +=

;

temp +=

?

:

;

temp +=

;

temp +=

;

temp +=

+

+

;

temp +=

(!mapper.empty() && mapper != (x_mapper ? x_mapper :

)){

temp +=

+ mapper +

;

kFWDUrl[] =

;

fwdurl,

(fwdurl), kFWDUrl)) {

responded =

;

(fwdcgi.getline(line,

(line))) {

.push_back(cp);

(!responded || (fwdcgi.fail() && !fwdcgi.eof()), &fwdcgi);

* user_header;

(net_info->firewall) {

user_header =

;

user_header =

;

(net_info->stateless)

temp(

?

:

);

temp +=

;

temp +=

temp +=

;

fwbset[256] = {

};

(net_info->firewall) {

temp +=

;

temp +=

;

temp +=

;

(*fwbset &&

(fwbset,

) != 0) {

temp +=

temp +=

;

temp +=

temp +=

;

temp +=

;

temp +=

temp += net_info->http_proxy_host;

(net_info->http_proxy_leak) {

temp +=

;

+

(

?

:

));

temp += up == 1 ?

:

;

temp =

;

temp +=

;

temp +=

;

temp +=

+

;

);

firewall =

;

+

;

temp +=

;

temp.insert(0,

);

temp =

temp =

;

temp += firewall ?

:

;

temp +=

+

;

kZeroTmo = { 0, 0 };

temp(

);

temp +=

;

?

:

,

temp +=

;

net_info->path[0] =

;

(

= 0; net_info &&

<

(fwd) /

(fwd[0]); ++

) {

pair<AutoPtr<CConn_IOStream>,

*> CFWCheck;

vector<CFWCheck> fwck;

net_info->port = cp->port;

fwck.push_back(make_pair(fw, &*cp));

valid = 0;

line[

(

) + 2

];

(!fw->getline(line,

(line)))

vector<CSocketAPI::SPoll>

;

(vector<CFWCheck>, ck, fwck) {

(vector<CFWCheck>, ck, fwck)

(cp->status) {

distance(fwd[

]->begin(), cp, k);

k = distance(fwd[

]->begin(), cp);

(!fwck[k].

)

=

;

temp +=

;

temp += net_info->http_proxy_host;

temp +=

;

temp +=

?

:

;

temp +=

temp +=

;

temp +=

;

temp +=

;

temp +=

;

temp +=

;

temp =

;

temp =

?

:

;

temp +=

;

temp =

;

temp +=

;

fwbset[256] = {

};

(net_info->firewall));

(*fwbset &&

(fwbset,

) != 0) {

temp +=

?

:

) +

;

(time_t one, time_t two)

(

)(one > two ? one - two : two - one);

(

minimal,

maximal)

minimal <= maximal ? minimal + rand() % (maximal - minimal + 1) : 0;

);

send[(1 << 10) + (8 + 1)];

recv[

(send)];

sprintf(send,

, (

)

);

=

(2, (

(send) - (8 + 1)) >> 3);

(

= 1;

<

; ++

)

sprintf(send + (

<< 3),

, (

) rand());

memset(&send[

<<= 3], 0, 8);

send[

+= 8] =

;

iofail = !echo.write(send,

) || !echo.flush()

(

< (streamsize)

) {

(!echo.read(recv +

, (streamsize)

-

))

(

== (streamsize)

) {

(

= 8;

<

; ++

) {

(send[

] != recv[

])

time_t now = (time_t) NStr::StringToNumeric<unsigned int>

temp =

?

:

;

temp +=

;

temp +=

;

temp =

?

:

;

temp +=

;

(

|| (net_info && net_info->stateless)) {

temp +=

;

}

(!

) {

temp +=

+

+

;

}

(

.empty() && net_info

temp +=

temp +=

+

+

;

}

(!

) {

temp +=

;

(!net_info->firewall)

temp +=

;

temp +=

;

(net_info &&

&& !net_info->http_proxy_leak

temp +=

temp += net_info->http_proxy_host;

temp +=

;

temp +=

;

temp +=

?

:

;

temp +=

& title)

(!

.empty()) {

->append(1,

);

(list<string>, line, par) {

(reason.empty()) {

(!

.empty())

(!

.empty())

->append(1,

);

pfx1.assign(

, ::sprintf(

,

, ++

));

(list<string>, line, par) {

kFast = { 2, 0 };

(http.getline(line,

(line))

&& ::sscanf(line,

, &

) >= 1

This stream exchanges data with an HTTP server located at the URL: http[s]://host[:port]/path[?...

Base class, inherited from "std::iostream", does both input and output, using the specified CONNECTOR...

This stream exchanges data with a named service, in a constraint that the service is implemented as o...

This stream exchanges data in a TCP channel, using the SOCK socket API.

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

Interface for testing cancellation request in a long lasting operation.

static CS_CONNECTION * conn

static DLIST_TYPE *DLIST_NAME() first(DLIST_LIST_TYPE *list)

static SQLCHAR output[256]

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

#define poll(fds, nfds, timeout)

static const STimeout kTimeout

void reset(element_type *p=0, EOwnership ownership=eTakeOwnership)

Reset will delete the old pointer (if owned), set content to the new value, and assume the ownership ...

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

element_type * get(void) const

Get pointer.

#define VECTOR_ERASE(Var, Cont)

Use this macro inside body of ERASE_ITERATE cycle to erase from vector-like container.

#define NON_CONST_ITERATE(Type, Var, Cont)

Non constant version of ITERATE macro.

EIO_Status SetCanceledCallback(const ICanceled *canceled)

Cancellation support.

EIO_Status SetTimeout(EIO_Event direction, const STimeout *timeout) const

Set connection timeout for "direction".

string GetType(void) const

EIO_Status Status(EIO_Event direction=eIO_Close) const

string GetDescription(void) const

CSocket & GetSocket(void)

Get CSocket, if available (else empty).

EIO_Status CONN_Read(CONN conn, void *buf, size_t size, size_t *n_read, EIO_ReadMethod how)

EIO_Status CONN_SetTimeout(CONN conn, EIO_Event event, const STimeout *timeout)

Specify timeout for the connection I/O, including "Connect" (aka "Open") and "Close".

EIO_Status CONN_Wait(CONN conn, EIO_Event event, const STimeout *timeout)

Block on the connection until it becomes available for either reading or writing (depending on "event...

EHTTP_HeaderParse

The extended version HTTP_CreateConnectorEx() is able to track the HTTP response chain and also chang...

const STimeout g_NcbiDefConnTimeout

DEF_CONN_TIMEOUT as STimeout.

@ fHTTP_AdjustOnRedirect

Call adjust routine for redirects, too.

@ fHTTP_NoAutoRetry

No auto-retries allowed.

@ fHTTP_KeepHeader

Keep HTTP header (see limitations)

@ eHTTP_HeaderSuccess

Parse succeeded, retain server status.

@ eHTTP_HeaderContinue

Parse succeeded, continue with body.

#define THROWS_NONE

Do not use 'throw' dynamic exception specification for C++11 compilers.

bool NotNull(void) const THROWS_NONE

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

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

#define NCBI_AS_STRING(value)

Convert some value to string even if this value is macro itself.

SSERV_InfoCPtr SERV_GetNextInfo(SERV_ITER iter)

Same as "SERV_GetNextInfoEx(., 0)" – i.e.

void SERV_Close(SERV_ITER iter)

Deallocate the iterator.

SERV_ITER SERV_OpenSimple(const char *service)

Allocate an iterator and consult either local databases (if any present), or network database,...

@ fSERV_Stateless

Stateless servers only.

static CNCBI_IPAddr gethostbyname(const string &host, ESwitch log=eOff)

Return 0 or empty address on error.

static EIO_Status Poll(vector< SPoll > &polls, const STimeout *timeout, size_t *n_ready=0)

Poll a vector of CPollable objects for I/O readiness.

static size_t StringToHostPort(const string &str, unsigned int *host, unsigned short *port)

Return number of characters parsed (0 if cannot detect "host:port"), and string::npos on error ("host...

static string HostPortToString(const CNCBI_IPAddr &addr, unsigned short port)

See SOCK_HostPortToString[6], return empty when failed.

static string ntoa(const CNCBI_IPAddr &addr)

BSD-like API.

virtual bool IsCanceled(void) const =0

IO_PREFIX::ostream CNcbiOstream

Portable alias for ostream.

static streamsize Readsome(CNcbiIstream &is, CT_CHAR_TYPE *buf, streamsize buf_size)

NCBI_NS_STD::string::size_type SIZE_TYPE

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 list< string > & Split(const CTempString str, const CTempString delim, list< string > &arr, TSplitFlags flags=0, vector< SIZE_TYPE > *token_pos=NULL)

Split a string using specified delimiters.

static SIZE_TYPE FindNoCase(const CTempString str, const CTempString pattern, SIZE_TYPE start, SIZE_TYPE end, EOccurrence which=eFirst)

Find the pattern in the specified range of a string using a case insensitive search.

static bool EndsWith(const CTempString str, const CTempString end, ECase use_case=eCase)

Check if a string ends with a specified suffix value.

static int strncasecmp(const char *s1, const char *s2, size_t n)

Case-insensitive comparison of two zero-terminated strings, narrowed to the specified number of chara...

static void TruncateSpacesInPlace(string &str, ETrunc where=eTrunc_Both)

Truncate whitespace in a string (in-place)

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

Compare of a substring with another string.

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 list< string > & Justify(const CTempString str, SIZE_TYPE width, list< string > &par, const CTempString *pfx=0, const CTempString *pfx1=0)

Justify the specified string into a series of lines of the same width.

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 string & ToUpper(string &str)

Convert string to upper case – string& version.

static string UInt8ToString(Uint8 value, TNumToStringFlags flags=0, int base=10)

Convert UInt8 to string.

@ fConvErr_NoThrow

Do not throw an exception on error.

@ fSplit_MergeDelimiters

Merge adjacent delimiters.

bool IsExpired(void) const

Check if the deadline is expired.

time_t GetTimeT(void) const

Get time in time_t format.

CTime & SetTimeT(const time_t t)

Set time using time_t time value.

const long kMicroSecondsPerSecond

Number of microseconds in one second.

const long kNanoSecondsPerSecond

Number of nanoseconds in one second.

void GetExpirationTime(time_t *sec, unsigned int *nanosec) const

Get the number of seconds and nanoseconds (since 1/1/1970).

@ eCurrent

Use current time. See also CCurrentTime.

int ConnNetInfo_SetupStandardArgs(SConnNetInfo *net_info, const char *service)

int ConnNetInfo_OverrideUserHeader(SConnNetInfo *net_info, const char *header)

int ConnNetInfo_SetArgs(SConnNetInfo *net_info, const char *args)

#define REG_CONN_STATELESS

unsigned int usec

microseconds (modulo 1,000,000)

#define REG_CONN_FIREWALL

#define REG_CONN_HTTP_PROXY_LEAK

const char * IO_StatusStr(EIO_Status status)

Get the text form of an enum status value.

int ConnNetInfo_SetUserHeader(SConnNetInfo *net_info, const char *header)

#define DEF_CONN_REG_SECTION

#define REG_CONN_DISPD_DISABLE

#define REG_CONN_HTTP_PROXY_SKIP

#define REG_CONN_SERVICE_NAME

EBDebugPrintout debug_printout

void ConnNetInfo_Destroy(SConnNetInfo *net_info)

@ eIO_Timeout

timeout expired before any I/O succeeded

@ eIO_Interrupt

signal arrival prevented any I/O to succeed

@ eIO_NotSupported

operation is not supported or is not available

@ eIO_Success

everything is fine, no error occurred

@ eIO_Unknown

unknown I/O error (likely fatal but can retry)

@ eIO_InvalidArg

bad argument / parameter value(s) supplied

@ fProxy_Http

$http_proxy used

@ fProxy_Https

$https_proxy used

@ eFWMode_Firewall

Regular firewall ports only, no fallback.

@ eFWMode_Adaptive

Regular firewall ports first, then fallback.

@ eFWMode_Fallback

Fallback ports only (w/o trying any regular)

@ eIO_ReadPlain

read readily available data only, wait if none

@ eIO_Open

also serves as no-event indicator in SOCK_Poll

@ eIO_Close

also serves as an error indicator in SOCK_Poll

const STimeout * m_Timeout

As supplied in constructor.

virtual EIO_Status GetFWConnections(string *reason)

virtual EIO_Status StatefulOkay(string *reason)

EStage

Note that each stage has a previous one as a prerequisite, with the only exception for the stateful s...

virtual EIO_Status Execute(EStage &stage, string *reason=0)

Execute the test suite from the very first (eHttp) up to and including the requested "stage".

virtual void PostCheck(EStage stage, unsigned int step, EIO_Status status, const string &reason)

PostCheck gets called upon successful ("status" contains eIO_Success) or unsuccessful (otherwise) com...

virtual void PreCheck(EStage stage, unsigned int step, const string &title)

User-defined rendering callbacks: PreCheck() and PostCheck().

bool m_HttpProxy

Certain properties of communication as determined by configuration.

virtual EIO_Status HttpOkay(string *reason)

virtual EIO_Status CheckFWConnections(string *reason)

CConnTest(const STimeout *timeout=kDefaultTimeout, CNcbiOstream *output=0, SIZE_TYPE width=72)

Create test suite.

bool m_End

Check step start (false) / stop (true) indicator.

virtual EIO_Status ExtraCheckOnFailure(void)

Last resort check.

EIO_Status x_CheckTrap(string *reason)

Pretect from runaway stage argument.

vector< CFWConnPoint > m_FwdFB

Fallback connection points.

virtual EIO_Status ConnStatus(bool failure, CConn_IOStream *io)

Helper function that assures to return eIO_Success if the predicate "failure" is false; and other cod...

virtual EIO_Status ServiceOkay(string *reason)

vector< CFWConnPoint > m_Fwd

Firewall daemon configuration as obtained from NCBI.

const string & GetCheckPoint(void) const

Extended info of the last step IO.

EDebugPrintout m_DebugPrintout

CConstIRef< ICanceled > m_Canceled

Cancellation support.

virtual EIO_Status DnsOkay(string *reason)

User-redefinable checks for each stage.

EIO_Status x_GetFirewallConfiguration(const SConnNetInfo *net_info, bool fwbports)

Obtain and populate FWD connection points from NCBI.

virtual EIO_Status DispatcherOkay(string *reason)

EIO_Status status

Check result.

void SetTimeout(const STimeout *timeout=kDefaultTimeout)

string x_TimeoutMsg(void)

Return verbal timeout suggestion.

static bool IsNcbiInhouseClient(void) THROWS_NONE

Return TRUE if the client is inside NCBI, FALSE otherwise.

@ eStatelessService

Check whether simplest NCBI service works.

@ eFirewallConnPoints

Obtain all FW ports for stateful services.

@ eHttp

Check whether HTTP works.

@ eStatefulService

Check whether NCBI stateful service works.

@ eDispatcher

Check whether NCBI dispatcher works.

@ eFirewallConnections

Check all FW ports, falling back if needed.

@ eNone

Zero placeholder.

if(yy_accept[yy_current_state])

static void text(MDB_val *v)

constexpr bool empty(list< Ts... >) noexcept

const struct ncbi::grid::netcache::search::fields::SIZE size

int strcmp(const char *str1, const char *str2)

#define CONN_FWD_PORT_MAX

#define CONN_FWD_PORT_MIN

static const char kTestService[]

static bool operator>(const STimeout *t1, const STimeout &t2)

static bool x_IsFatalError(int error)

static const char kCanceled[]

static const char kEchoService[]

static EHTTP_HeaderParse s_SvcHeader(const char *header, void *data, int server_error)

static size_t rnd(size_t minimal, size_t maximal)

static unsigned int ud(time_t one, time_t two)

static const SIZE_TYPE kParIndent

static int s_Adjust(SConnNetInfo *, void *data, unsigned int count)

static bool x_Large(const STimeout *t)

static SConnNetInfo * ConnNetInfo_Create(const char *svc_name, EDebugPrintout dbg_printout)

static EHTTP_HeaderParse s_GoodHeader(const char *, void *data, int server_error)

static const char kBounceService[]

static void s_Cleanup(void *data)

static const char kFWSign[]

static EHTTP_HeaderParse s_AnyHeader(const char *, void *data, int server_error)

const char * ConnNetInfo_GetValueInternal(const char *service, const char *param, char *value, size_t value_size, const char *def_value)

void SERV_PrintFirewallPorts(char *buf, size_t bufsize, EFWMode mode)

void SERV_InitFirewallPorts(void)

int SERV_IsFirewallPort(unsigned short port)

int SERV_AddFirewallPort(unsigned short port)

char * SERV_ServiceName(const char *service)

const char * SERV_MapperName(SERV_ITER iter)

Useful/utility classes and methods.

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

Auxiliary class to hold FWDaemon CP(connection point) information and its current status.

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

static void Delete(SConnNetInfo *net_info)

Functor template for deleting object.

const ICanceled * m_Canceled

SAuxData(const ICanceled *canceled, void *data)

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