!
addr.empty();
121 ERR_POST_ONCE(
"CSnpPtisClient is disabled due to lack of GRPC support");
138 else if(
const CTextseq_id* text_id =
id.GetTextseq_Id() ) {
150grpc::ChannelArguments args;
153 channel= grpc::CreateCustomChannel(address, grpc::InsecureChannelCredentials(), args);
177 LOG_POST(
Info<<
"CSnpPtisClient: asking for gi "<<gi);
187 LOG_POST(
Info<<
"CSnpPtisClient: asking for acc_ver "<<acc_ver);
202std::chrono::system_clock::now() + std::chrono::microseconds(
Int8(cur_timeout*1e6));
203 context.set_deadline(deadline);
207 autostatus =
stub->ForSeqId(&
context, request, &reply);
216 if( status.error_code() == grpc::StatusCode::NOT_FOUND ) {
218 LOG_POST(
Info<<
"CSnpPtisClient: received NOT_FOUND");
224 LOG_POST(
Info<<
"CSnpPtisClient: failed: "<<status.error_message());
229 "CSnpPtisClient: failed : "<<status.error_message()<<
". " 230 "Waiting "<<cur_wait_time<<
" seconds before retry...");
CGRPCClientContext â client context for NCBI gRPC services.
virtual string GetPrimarySnpTrackForAccVer(const string &acc_ver)
shared_ptr< grpc::Channel > channel
virtual string GetPrimarySnpTrackForGi(TGi gi)
virtual ~CSnpPtisClient_Impl()
string x_GetPrimarySnpTrack(const TRequest &request)
unique_ptr< ncbi::grpcapi::dbsnp::primary_track::DbSnpPrimaryTrack::Stub > stub
virtual ~CSnpPtisClient()
static CRef< CSnpPtisClient > CreateClient()
virtual string GetPrimarySnpTrackForAccVer(const string &acc_ver)=0
virtual string GetPrimarySnpTrackForGi(TGi gi)=0
string GetPrimarySnpTrackForId(const string &id)
static std::unique_ptr< Stub > NewStub(const std::shared_ptr< ::grpc::ChannelInterface > &channel, const ::grpc::StubOptions &options=::grpc::StubOptions())
const std::string & na_track_acc_with_filter() const
void set_accver(Arg_ &&arg, Args_... args)
void set_gi(::uint64_t value)
#define ERR_POST_ONCE(message)
Error posting only once during program execution.
#define ERR_POST(message)
Error posting with file, line number information but without error codes.
#define LOG_POST(message)
This macro is deprecated and it's strongly recomended to move in all projects (except tests) to macro...
#define NCBI_THROW(exception_class, err_code, message)
Generic macro to throw an exception, given the exception class, error code and message string.
void Trace(CExceptionArgs_Base &args)
#define NCBI_THROW_FMT(exception_class, err_code, message)
The same as NCBI_THROW but with message processed as output to ostream.
void Info(CExceptionArgs_Base &args)
static bool IsImplemented(void)
string g_NCBI_GRPC_GetAddress(const char *section, const char *variable, const char *env_var_name=nullptr, CParamBase::EParamSource *value_source=nullptr)
Get "hostport" for the likes of "grpc::CreateChannel(hostport, ...)" trying (in order of priority):
int g_GetConfigInt(const char *section, const char *variable, const char *env_var_name, int default_value)
Get integer configuration value.
double g_GetConfigDouble(const char *section, const char *variable, const char *env_var_name, double default_value)
Get double configuration value.
#define NCBI_PARAM_TYPE(section, name)
Generate typename for a parameter from its {section, name} attributes.
EParamSource
Source of the value returned by CParam::GetDefault().
@ eSource_Default
Hardcoded default.
int64_t Int8
8-byte (64-bit) signed integer
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.
chrono::system_clock::time_point time_point
const CharType(& source)[N]
void SleepMicroSec(unsigned long mc_sec, EInterruptOnSignal onsignal=eRestartOnSignal)
Front end for a platform-specific configuration summary.
Glue for integrating gRPC into the C++ toolkit, to ensure logging and metadata propagation (sid,...
static CNamedPipeClient * client
const char *const kParam_TimeoutMax
const char *const kParam_Timeout
const char *const kParam_Retry
static int GetDebugLevel()
const char *const kParam_WaitTimeMul
const float kDefault_Timeout
const char *const kParam_PTISName
const char *const kParam_TimeoutInc
const float kDefault_WaitTimeMax
const char *const kSection
const char *const kParam_WaitTimeInc
const float kDefault_WaitTime
const char *const kParam_TimeoutMul
const float kDefault_TimeoutInc
const float kDefault_TimeoutMul
const char *const kParam_WaitTimeMax
const float kDefault_WaitTimeMul
NCBI_PARAM_DEF(int, ID2SNP, PTIS_DEBUG, kDefault_Debug)
const char *const kParam_WaitTime
const float kDefault_WaitTimeInc
const float kDefault_TimeoutMax
NCBI_PARAM_DECL(int, ID2SNP, PTIS_DEBUG)
static CS_CONTEXT * context
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