try_limit);
65 voidDisconnect(
void);
69 void SetArgs(
const string& args) { m_Args = args; }
72 const string&
GetArgs(
void)
const{
returnm_Args; }
74 const string&
GetService(
void)
const{
returnm_Service; }
75 void SetService(
const string& service) { m_Service = service; }
85 unsigned int GetTryLimit(
void)
const{
returnm_TryLimit; }
105 bool IsCanceled(
void)
const{
returnm_Canceler.NotNull() && m_Canceler->IsCanceled(); }
108 voidSetAffinity(
const string& affinity);
118 virtual voidx_Disconnect(
void);
144unique_ptr<CObjectIStream>
m_In;
156 virtual boolx_ShouldRetry(
unsigned inttries);
161 CTimeSpanx_GetRetryDelay(
doublemax_delay)
const;
175 virtual const char* GetErrCodeString(
void)
const override;
HTTP-specific retry context implementation.
Base class for CRPCClient template - defines methods independent of request and response types.
CRetryContext â Retry context.
Base class for all serializable objects.
Interface for testing cancellation request in a long lasting operation.
std::ofstream out("events_result.xml")
main entry point for tests
virtual void x_Assign(const CException &src)
Helper method for copying exception data.
EErrCode
Error types that an application can generate.
const string & GetService(void) const
void SetTryLimit(unsigned int n)
bool IsCanceled(void) const
CRef< CRetryContext > m_RetryCtx
unsigned int GetTryLimit(void) const
Get number of request attempts.
unsigned int GetRetryLimit(void) const
CConstIRef< ICanceled > m_Canceler
bool IsSetRetryContext(void) const
virtual void x_ReadReply(CObjectIStream &in, CSerialObject &reply)=0
void SetArgs(const CUrlArgs &args)
const string & GetArgs(void) const
Get additional connection arguments.
unique_ptr< CObjectIStream > m_In
void SetCanceledCallback(const ICanceled *canceled)
Set request canceler.
string m_Service
Used by default Connect().
void SetService(const string &service)
ESerialDataFormat m_Format
void SetRetryDelay(const CTimeSpan &ts)
void SetRetryLimit(unsigned int n)
CMutex m_Mutex
To allow sharing across threads.
void SetFormat(ESerialDataFormat fmt)
virtual void x_WriteRequest(CObjectOStream &out, const CSerialObject &request)=0
CRetryContext & GetRetryContext(void)
Read retry related data.
CRPCClient_Base(const CRPCClient_Base &)
Prohibit default copy constructor and assignment operator.
void SetArgs(const string &args)
Set additional connection arguments.
virtual void x_Assign(const CException &src) override
Helper method for copying exception data.
unique_ptr< CObjectOStream > m_Out
virtual string x_GetAffinity(const CSerialObject &request) const =0
NCBI_EXCEPTION_DEFAULT(CRPCClientException, CException)
virtual void x_Connect(void)=0
These run with m_Mutex already acquired.
unique_ptr< CNcbiIostream > m_Stream
CHttpRetryContext m_RetryCtx
ESerialDataFormat
Data file format.
void SetRetryContext(CRetryContext &ctx)
Set new retry context.
ESerialDataFormat GetFormat(void) const
const CTimeSpan GetRetryDelay(void) const
Get retry delay.
@ eArgs
Failed to send request arguments.
@ eRetry
Request failed, should be retried if possible.
@ eFailed
Request (or retry) failed.
#define END_NCBI_SCOPE
End previously defined NCBI scope.
#define BEGIN_NCBI_SCOPE
Define ncbi namespace.
IO_PREFIX::iostream CNcbiIostream
Portable alias for iostream.
string GetQueryString(EAmpEncoding amp_enc, NStr::EUrlEncode encode) const
Construct and return complete query string.
@ eAmp_Char
Use & to separate arguments.
#define NCBI_XSERIAL_EXPORT
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 PyObject * Connect(PyObject *self, PyObject *args, PyObject *kwargs)
Multi-threading â mutexes; rw-locks; semaphore.
std::istream & in(std::istream &in_, double &x_)
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