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

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

NCBI C++ ToolKit: include/serial/rpcbase.hpp Source File

<

TRequest,

TReply>

try_limit)

(

TRequest& request, TReply& reply)

{

(request, reply); }

(

TRequest&

(request));

<

TRequest,

TReply>

( !m_Args.empty() ) {

);

( m_RetryCtx.IsSetArgs() ) {

);

}

(x_extra !=

&& !m_Affinity.empty()) {

);

(x_extra ==

) {

memset(x_extra, 0,

(*x_extra));

x_extra->

= &m_RetryCtx;

* user_header = GetContentTypeHeader(

());

(user_header !=

&& *user_header !=

) {

);

<

TRequest,

TReply>

(m_AsyncStream.get() !=

) {

m_AsyncStream->SetTimeout(

, m_Timeout);

x_SetStream(m_AsyncStream.release());

}

( m_RetryCtx.IsSetUrl() ) {

x_ConnectURL(m_RetryCtx.GetUrl());

( !m_Service.empty() );

x_FillConnNetInfo(*net_info, &x_extra);

unique_ptr<CConn_ServiceStream> stream

( m_Canceler.NotNull() ) {

stream->SetCanceledCallback(m_Canceler.GetNonNullPointer());

x_SetStream(stream.release());

<

TRequest,

TReply>

x_FillConnNetInfo(*net_info,

);

( m_Canceler.NotNull() ) {

stream->SetCanceledCallback(m_Canceler.GetNonNullPointer());

x_SetStream(stream.release());

<

TRequest,

TReply>

* old_timeout = m_Timeout;

(sx_IsSpecial(timeout)) {

m_Timeout =

(*timeout);

( !sx_IsSpecial(old_timeout) ) {

*

(old_timeout);

conn_stream->

(direction, timeout);

}

( !m_Stream.get() ) {

<

TRequest,

TReply>

<

TRequest,

TReply>

( !m_Service.empty() );

x_FillConnNetInfo(*net_info, &x_extra);

( m_Canceler.NotNull() ) {

m_AsyncStream->SetCanceledCallback(m_Canceler.GetNonNullPointer());

(handle_buf !=

) {

= m_AsyncStream->GetCONN();

(

!=

) {

sock =

;

&& sock !=

) {

<

TRequest,

TReply>

<

TRequest,

TReply>

Helper hook-up class that installs default logging/registry/locking (but only if they have not yet be...

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

HTTP-specific retry context implementation.

Base class for CRPCClient template - defines methods independent of request and response types.

CRPCClient – prototype client for ASN.1/XML-based RPC.

Base class for all serializable objects.

std::ofstream out("events_result.xml")

main entry point for tests

static CS_CONNECTION * conn

element_type * get(void) const

Get pointer.

const STimeout * GetTimeout(EIO_Event direction) const

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

Set connection timeout for "direction".

FHTTP_ParseHeader parse_header

EHTTP_HeaderParse

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

EIO_Status CONN_GetSOCK(CONN conn, SOCK *sock)

Get an underlying SOCK handle for connection that is implemented as a socket.

@ fHTTP_NoAutoRetry

No auto-retries allowed.

@ fHTTP_AutoReconnect

See HTTP_CreateConnectorEx()

@ eHTTP_HeaderContinue

Parse succeeded, continue with body.

#define NCBI_THROW(exception_class, err_code, message)

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

CRPCClient(const string &service=kEmptyStr)

EIO_Status AsyncConnect(void *handle_buf, size_t handle_size)

virtual void x_WriteRequest(CObjectOStream &out, const CSerialObject &request) override

void x_ConnectURL(const string &url)

Connect to a URL.

CRPCClient(const string &service, ESerialDataFormat format)

virtual void ReadReply(CObjectIStream &in, TReply &reply)

static bool sx_IsSpecial(const STimeout *timeout)

CRPCClient(const string &service, ESerialDataFormat format, unsigned int try_limit)

static EHTTP_HeaderParse sx_ParseHeader(const char *http_header, void *user_data, int server_error)

virtual ~CRPCClient(void)

virtual void Ask(const TRequest &request, TReply &reply)

virtual void x_Connect(void) override

These run with m_Mutex already acquired.

virtual void WriteRequest(CObjectOStream &out, const TRequest &request)

const STimeout * GetTimeout(EIO_Event direction=eIO_Read) const

virtual void x_ReadReply(CObjectIStream &in, CSerialObject &reply) override

void x_FillConnNetInfo(SConnNetInfo &net_info, SSERVICE_Extra *x_extra)

static void Delete(SConnNetInfo *net_info)

virtual string GetAffinity(const TRequest &) const

unique_ptr< CConn_ServiceStream > m_AsyncStream

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

ESerialDataFormat

Data file format.

const STimeout * m_Timeout

Cloned if not special.

void x_Ask(const CSerialObject &request, CSerialObject &reply)

virtual string x_GetAffinity(const CSerialObject &request) const override

@ eSerial_AsnBinary

ASN.1 binary.

void ParseHeader(const char *http_header)

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

@ fSERV_DelayOpen

Don't open service until use.

EIO_Status SOCK_GetOSHandle(SOCK sock, void *handle_buf, size_t handle_size)

Same as SOCK_GetOSHandleEx(sock, handle_buf, handle_size, eNoOwnership).

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

int ConnNetInfo_ParseURL(SConnNetInfo *net_info, const char *url)

int ConnNetInfo_AppendArg(SConnNetInfo *net_info, const char *arg, const char *val)

int ConnNetInfo_PostOverrideArg(SConnNetInfo *net_info, const char *arg, const char *val)

SConnNetInfo * ConnNetInfo_Create(const char *service)

struct STimeoutTag STimeout

Timeout structure.

EIO_Event

I/O event (or direction).

void ConnNetInfo_Destroy(SConnNetInfo *net_info)

@ eIO_NotSupported

operation is not supported or is not available

@ 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

The blob sat and sat key Both must be positive integers</td > n< td > Non empty string The interpretation of the blob id depends on a processor Cassandra n processor expects the following format

static const STimeout kZeroTimeout

Multi-threading – mutexes; rw-locks; semaphore.

std::istream & in(std::istream &in_, double &x_)

ESerialDataFormat GetFormat(const string &name)

Functor template for deleting object.

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