RetroSearch Browse

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

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

NCBI C++ ToolKit: src/app/pubseq_gateway/server/pubseq_gateway.hpp Source File

1 #ifndef PUBSEQ_GATEWAY__HPP 2 #define PUBSEQ_GATEWAY__HPP 80 virtual void Init

(

void

);

96 if

(keyspace.has_value())

97 return

keyspace->IsSecureSat();

177 virtual int Run

(

void

);

266

shared_ptr<CPSGS_Reply> reply,

268 const string

& message,

273

shared_ptr<CPSGS_Reply> reply,

277 bool

seq_id_is_optional=

false

);

282

shared_ptr<CPSGS_Reply> reply,

286

vector<string> & enabled_processors,

287

vector<string> & disabled_processors,

288 bool

& processor_events);

293

shared_ptr<CPSGS_Reply> reply);

300 const string

& name)

const

;

302

shared_ptr<CPSGS_Reply> reply,

304 int

& send_blob_if_small);

307 string

& err_msg)

const

;

311 string

& err_msg)

const

;

315 string

& err_msg)

const

;

319 string

& err_msg)

const

;

321

shared_ptr<CPSGS_Reply> reply,

325

shared_ptr<CPSGS_Reply> reply,

332

shared_ptr<CPSGS_Reply> reply,

336

shared_ptr<CPSGS_Reply> reply,

340

shared_ptr<CPSGS_Reply> reply,

344

shared_ptr<CPSGS_Reply> reply,

348

shared_ptr<CPSGS_Reply> reply,

352

shared_ptr<CPSGS_Reply> reply,

357

shared_ptr<CPSGS_Reply> reply,

361

shared_ptr<CPSGS_Reply> reply,

365

shared_ptr<CPSGS_Reply> reply,

367 bool

& processor_events);

369

shared_ptr<CPSGS_Reply> reply,

371

optional<bool> & include_hup);

373

shared_ptr<CPSGS_Reply> reply,

377

shared_ptr<CPSGS_Reply> reply,

379 double

& resend_timeout);

381

shared_ptr<CPSGS_Reply> reply,

383 bool

& auto_blob_skipping);

385

shared_ptr<CPSGS_Reply> reply,

387

vector<string> & enabled_processors,

388

vector<string> & disabled_processors);

390

shared_ptr<CPSGS_Reply> reply,

392

vector<string> &

names

);

394

shared_ptr<CPSGS_Reply> reply,

396

optional<string> & protein);

398

shared_ptr<CPSGS_Reply> reply,

402

shared_ptr<CPSGS_Reply> reply,

404

optional<string> & nucleotide);

406

shared_ptr<CPSGS_Reply> reply,

408

vector<pair<int, int>> & time_series);

410

shared_ptr<CPSGS_Reply> reply,

412

optional<CSeq_id::ESNPScaleLimit> & snp_scale_limit);

414

shared_ptr<CPSGS_Reply> reply,

418

shared_ptr<CPSGS_Reply> reply,

420

vector<string> & exclude_checks);

422

shared_ptr<CPSGS_Reply> reply,

424 string

& peer_user_agent);

426

shared_ptr<CPSGS_Reply> reply,

438 const string

& err_msg);

441 const string

& err_msg);

445 const string

& err_msg);

456

shared_ptr<CPSGS_Request> request,

457

shared_ptr<CPSGS_Reply> reply);

462

shared_ptr<CPSGS_Reply> reply,

477

shared_ptr<CPSGS_Reply> reply);

481 const string

& check_id,

483 const string

& check_description,

485 const string

& health_command,

490 const

vector<string> & exclude_checks,

493

shared_ptr<CPSGS_Reply> reply,

494 const string

& health_command);

496

shared_ptr<CPSGS_Reply> reply,

497 const string

* payload);

509

shared_ptr<CPSGS_Reply> reply,

510 const string

& peer_ip,

511 const string

& peer_id,

512 const string

& user_agent);

515 unsigned int

worker_id,

int64_t

conn_id);

Checksum and hash calculation classes.

Based on various attributes of the request: {{seq_id}}; NA name; {{blob_id}}; etc (or a combination t...

shared_ptr< void > TApiLock

Get an API lock.

unique_ptr< CExcludeBlobCache > m_ExcludeBlobCache

void x_Finish500(shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, EPSGS_PubseqGatewayErrorCode code, const string &err_msg)

bool x_GetAccessionSubstitutionOption(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, SPSGS_RequestBase::EPSGS_AccSubstitutioOption &acc_subst_option)

void x_InitialzeZEndPointData(void)

CPubseqGatewayCache * GetLookupCache(void)

int OnConfig(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

int OnReadyzConnections(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

unique_ptr< CHttpDaemon > m_HttpDaemon

void x_RegisterProcessors(void)

unique_ptr< CMyNCBIErrorCache > m_MyNCBIErrorCache

int OnGet(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

CMyNCBINotFoundCache * GetMyNCBINotFoundCache(void)

void x_SendZEndPointReply(CRequestStatus::ECode http_status, shared_ptr< CPSGS_Reply > reply, const string *payload)

bool x_GetIPG(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, int64_t &ipg)

bool m_ThrottlingDataInProgress

void NotifyRequestFinished(size_t request_id)

vector< SSatInfoEntry > GetBioseqNAKeyspaces(void) const

bool x_GetPeerUserAgentParameter(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, string &peer_user_agent)

map< uv_thread_t, unique_ptr< CPSGS_UvLoopBinder > > m_ThreadToBinder

CRequestStatus::ECode x_SelfZEndPointCheckImpl(CRef< CRequestContext > &context, const string &check_id, const string &check_name, const string &check_description, bool verbose, const string &health_command, const CTimeout &health_timeout, CJsonNode &node)

bool x_GetExcludeChecks(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, vector< string > &exclude_checks)

bool x_GetId2Info(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, string &id2_info)

bool x_IsBoolParamValid(const string &param_name, const CTempString &param_value, string &err_msg) const

IPSGS_Processor::EPSGS_StartProcessing SignalStartProcessing(IPSGS_Processor *processor)

int OnHealthz(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

CNcbiLogFields m_LogFields

int OnShutdown(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

void x_MalformedArguments(shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, const string &err_msg)

bool x_GetIntrospectionFormat(CHttpRequest &req, string &fmt, string &err_msg)

EPSGS_ThrottlingDecision x_CheckThrottling(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const string &peer_ip, const string &peer_id, const string &user_agent)

int OnConnectionsStatus(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

atomic< bool > m_ThrottlingDataLock

int OnGetBlob(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

bool x_GetLastModified(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, int64_t &last_modified)

shared_ptr< SThrottlingData > m_ThrottlingData

bool x_GetHops(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, int &hops)

int OnReadyzCassandra(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

bool x_GetIncludeHUPParameter(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, optional< bool > &include_hup)

void DoMyNCBIDnsResolve(void)

bool x_DispatchRequest(CRef< CRequestContext > &context, shared_ptr< CPSGS_Request > request, shared_ptr< CPSGS_Reply > reply)

CPSG_Queue::TApiLock m_PSGAPILock

int OnGetAlerts(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

int x_SelfZEndPointCheck(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const string &health_command)

bool x_GetNames(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, vector< string > &names)

void x_PrintRequestStop(CRef< CRequestContext > &context, CPSGS_Request::EPSGS_Type request_type, CRequestStatus::ECode status, size_t bytes_sent)

void UnregisterUVLoop(uv_thread_t uv_thread)

void x_InsufficientArguments(shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, const string &err_msg)

bool x_CheckAuthorization(const string &request_name, CRef< CRequestContext > context, CHttpRequest &http_req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now)

bool x_GetTSEOption(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, SPSGS_BlobRequestBase::EPSGS_TSEOption &tse_option)

uv_loop_t * GetUVLoop(void)

SPubseqGatewaySettings m_Settings

optional< SSatInfoEntry > SatToKeyspace(int32_t sat)

int OnReadyzWGS(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

void x_CloseThrottledConnection(shared_ptr< CPSGS_Reply > reply, unsigned int worker_id, int64_t conn_id)

void RegisterDaemonUVLoop(uv_thread_t uv_thread, uv_loop_t *uv_loop)

void CreateMyNCBIFactory(void)

bool x_GetSeqIdResolveParameter(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, bool &auto_blob_skipping)

void MaintainSplitInfoBlobCache(void)

int OnStatistics(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

psg_time_point_t m_ThrottlingDataTimestamp

int OnTestIO(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

CPSGSCounters & GetCounters(void)

void SignalConnectionCanceled(size_t request_id)

bool x_GetProcessorEventsParameter(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, bool &processor_events)

int OnAckAlert(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

int OnGetNA(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

bool m_LastMyNCBIResolveOK

bool x_NeedReadyZCheckPerform(const string &check_name, bool verbose, const vector< string > &exclude_checks, bool &is_critical)

unique_ptr< COperationTiming > m_Timing

int OnGetSatMapping(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

bool x_GetNucleotide(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, optional< string > &nucleotide)

CMyNCBIErrorCache * GetMyNCBIErrorCache(void)

void TestMyNCBI(uv_loop_t *loop)

string x_GetCmdLineArguments(void) const

bool x_GetSNPScaleLimit(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, optional< CSeq_id::ESNPScaleLimit > &snp_scale_limit)

unique_ptr< CMyNCBIOKCache > m_MyNCBIOKCache

shared_ptr< CSatInfoSchemaProvider > m_CassSchemaProvider

void x_FixIntrospectionVersion(void)

void CancelAllProcessors(void)

bool x_ProcessCommonGetAndResolveParams(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, CTempString &seq_id, int &seq_id_type, SPSGS_RequestBase::EPSGS_CacheAndDbUse &use_cache, bool seq_id_is_optional=false)

bool x_GetResendTimeout(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, double &resend_timeout)

unique_ptr< CMyNCBINotFoundCache > m_MyNCBINotFoundCache

bool x_GetEnabledAndDisabledProcessors(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, vector< string > &enabled_processors, vector< string > &disabled_processors)

void x_FixIntrospectionBuildDate(void)

int OnGetTSEChunk(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

mutex m_ThreadToBinderGuard

unique_ptr< CPSGS_Dispatcher > m_RequestDispatcher

static CPubseqGatewayApp * sm_PubseqApp

optional< SSatInfoEntry > GetIPGKeyspace(void) const

int OnHealth(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

int OnStatus(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

void x_SendMessageAndCompletionChunks(shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, const string &message, CRequestStatus::ECode status, int code, EDiagSev severity)

void SignalFinishProcessing(IPSGS_Processor *processor, CPSGS_Dispatcher::EPSGS_SignalSource signal_source)

int OnReadyzLMDB(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

CMyNCBIOKCache * GetMyNCBIOKCache(void)

CRef< CRequestContext > x_CreateRequestContext(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

bool x_GetResolveFlags(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, SPSGS_ResolveRequest::TPSGS_BioseqIncludeData &include_data_flags)

unique_ptr< CPSGSCounters > m_Counters

EPSGS_StartupDataState GetStartupDataState(void) const

bool x_GetPeerIdParameter(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, string &peer_id)

unique_ptr< char[]> m_IOTestBuffer

int x_ReadyzHealthzImplementation(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

bool x_GetCommonIDRequestParams(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, SPSGS_RequestBase::EPSGS_Trace &trace, int &hops, vector< string > &enabled_processors, vector< string > &disabled_processors, bool &processor_events)

void RegisterUVLoop(uv_thread_t uv_thread, uv_loop_t *uv_loop)

CExcludeBlobCache * GetExcludeBlobCache(void)

bool x_GetOutputFormat(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, SPSGS_ResolveRequest::EPSGS_OutputFormat &output_format)

bool x_ConvertIntParameter(const string &param_name, const CTempString &param_value, int &converted, string &err_msg) const

void CheckCassMapping(void)

COperationTiming & GetTiming(void)

shared_ptr< CPSGMessages > GetPublicCommentsMapping(void)

int OnDeepHealth(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

bool x_IsShuttingDown(shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now)

int OnInfo(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

bool x_IsConnectionAboveSoftLimitForZEndPoints(shared_ptr< CPSGS_Reply > reply, bool verbose)

static CPubseqGatewayApp * GetInstance(void)

bool x_IsConnectionAboveSoftLimit(shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &create_timestamp)

shared_ptr< CPSG_MyNCBIFactory > m_MyNCBIFactory

SRequestParameter x_GetParam(CHttpRequest &req, const string &name) const

shared_ptr< CCassConnectionFactory > m_CassConnectionFactory

vector< string > x_GetExcludeBlobs(CHttpRequest &req) const

bool x_IsShuttingDownForZEndPoints(shared_ptr< CPSGS_Reply > reply, bool verbose)

bool x_GetTimeSeries(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, vector< pair< int, int >> &time_series)

map< uv_thread_t, uv_loop_t * > m_ThreadToUVLoop

bool x_GetId2Chunk(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, int64_t &id2_chunk)

int OnIPGResolve(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

int OnHello(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

bool x_GetVerboseParameter(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, bool &verbose)

bool PopulateCassandraMapping(bool initialization)

EPSGS_StartupDataState m_StartupDataState

bool IsSecureSat(int32_t sat)

bool x_GetTraceParameter(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, SPSGS_RequestBase::EPSGS_Trace &trace)

CPSGS_Dispatcher * GetProcessorDispatcher(void)

CPSGAlerts & GetAlerts(void)

shared_ptr< CCassConnection > m_CassConnection

shared_ptr< CPSG_MyNCBIFactory > GetMyNCBIFactory(void)

bool x_GetBlobId(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, SPSGS_BlobId &blob_id)

int OnAccessionVersionHistory(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

int OnReadyzSNP(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

unique_ptr< CPubseqGatewayCache > m_LookupCache

bool x_ConvertDoubleParameter(const string &param_name, const CTempString &param_value, double &converted, string &err_msg) const

int OnResolve(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

int OnReadyzCDD(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

bool x_GetUseCacheParameter(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, SPSGS_RequestBase::EPSGS_CacheAndDbUse &use_cache)

size_t GetProcessorMaxConcurrency(const string &processor_id)

CSplitInfoCache * GetSplitInfoCache(void)

int OnLivez(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

void x_RebuildThrottlingData(void)

void MaintainMyNCBICaches(void)

bool x_GetProtein(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, optional< string > &protein)

CPSGS_UvLoopBinder & GetUvLoopBinder(uv_thread_t uv_thread_id)

int OnBadURL(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

bool x_GetSendBlobIfSmallParameter(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply, const psg_time_point_t &now, int &send_blob_if_small)

string x_PrepareConfigJson(void)

int OnReadyz(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

int OnDispatcherStatus(CHttpRequest &req, shared_ptr< CPSGS_Reply > reply)

unique_ptr< CSplitInfoCache > m_SplitInfoCache

const SPubseqGatewaySettings & Settings(void) const

SSatInfoEntry GetBioseqKeyspace(void) const

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

CTimeout â Timeout interval.

Interface class (and self-factory) for request processor objects that can retrieve data from a given ...

EPSGS_StartProcessing

Tells wether to continue or not after a processor called SignalStartProcessing() method.

static const struct name_t names[]

EDiagSev

Severity level for the posted diagnostics.

Defines the CNcbiApplication and CAppException classes for creating NCBI applications.

const long kMaxTestIOSize

EPSGS_PubseqGatewayErrorCode

psg_clock_t::time_point psg_time_point_t

static bool check_name(const char *name)

EPSGS_AccSubstitutioOption

int TPSGS_BioseqIncludeData

size_t GetProcessorMaxConcurrency(const CNcbiRegistry &registry, const string &processor_id)

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