#include <atomic>
#include <chrono>
#include <condition_variable>
#include <memory>
#include <mutex>
#include <deque>
#include <thread>
#include <corelib/ncbitime.hpp>
#include <corelib/ncbi_param.hpp>
#include <connect/impl/connect_misc.hpp>
#include <objtools/pubseq_gateway/client/psg_client.hpp>
Go to the source code of this file.
Go to the SVN repository for this file.
#define PSG_PARAM_TYPE(section, name) SPSG_Param<NCBI_PARAM_TYPE(section, name)> #define PSG_PARAM_VALUE_TYPE(section, name) SPSG_ParamValue<NCBI_PARAM_TYPE(section, name)> #define PSG_PARAM_VALUE_DECL_MIN(type, section, name) #define PSG_PARAM_VALUE_DEF_MIN(type, section, name, default_value, min_value) using TPSG_RdBufSize = SPSG_Param< NCBI_PARAM_TYPE(PSG, rd_buf_size)> using TPSG_WrBufSize = SPSG_Param< NCBI_PARAM_TYPE(PSG, wr_buf_size)> using TPSG_MaxConcurrentStreams = SPSG_Param< NCBI_PARAM_TYPE(PSG, max_concurrent_streams)> using TPSG_MaxConcurrentSubmits = SPSG_ParamValue< NCBI_PARAM_TYPE(PSG, max_concurrent_submits)> using TPSG_MaxSessions = SPSG_Param< NCBI_PARAM_TYPE(PSG, max_sessions)> using TPSG_MaxConcurrentRequestsPerServer = SPSG_ParamValue< NCBI_PARAM_TYPE(PSG, max_concurrent_requests_per_server)> using TPSG_NumIo = SPSG_Param< NCBI_PARAM_TYPE(PSG, num_io)> using TPSG_ReaderTimeout = SPSG_Param< NCBI_PARAM_TYPE(PSG, reader_timeout)> using TPSG_RebalanceTime = SPSG_Param< NCBI_PARAM_TYPE(PSG, rebalance_time)> using TPSG_IoTimerPeriod = SPSG_ParamValue< NCBI_PARAM_TYPE(PSG, io_timer_period)> using TPSG_RequestsPerIo = SPSG_ParamValue< NCBI_PARAM_TYPE(PSG, requests_per_io)> using TPSG_RequestRetries = SPSG_ParamValue< NCBI_PARAM_TYPE(PSG, request_retries)> using TPSG_RefusedStreamRetries = SPSG_ParamValue< NCBI_PARAM_TYPE(PSG, refused_stream_retries)> using TPSG_UserRequestIds = SPSG_ParamValue< NCBI_PARAM_TYPE(PSG, user_request_ids)> using TPSG_Service = NCBI_PARAM_TYPE(PSG, service) using TPSG_AuthTokenName = SPSG_ParamValue< NCBI_PARAM_TYPE(PSG, auth_token_name)> using TPSG_AuthToken = SPSG_ParamValue< NCBI_PARAM_TYPE(PSG, auth_token)> using TPSG_AdminAuthTokenName = SPSG_ParamValue< NCBI_PARAM_TYPE(PSG, admin_auth_token_name)> using TPSG_AdminAuthToken = SPSG_ParamValue< NCBI_PARAM_TYPE(PSG, admin_auth_token)> using TPSG_ThrottlePeriod = NCBI_PARAM_TYPE(PSG, throttle_relaxation_period) using TPSG_ThrottleMaxFailures = SPSG_ParamValue< NCBI_PARAM_TYPE(PSG, throttle_by_consecutive_connection_failures)> using TPSG_ThrottleUntilDiscovery = SPSG_ParamValue< NCBI_PARAM_TYPE(PSG, throttle_hold_until_active_in_lb)> using TPSG_ThrottleThreshold = NCBI_PARAM_TYPE(PSG, throttle_by_connection_error_rate) using TPSG_DebugPrintout = SPSG_ParamValue< NCBI_PARAM_TYPE(PSG, debug_printout)> using TPSG_UseCache = SPSG_ParamValue< NCBI_PARAM_TYPE(PSG, use_cache)> using TPSG_PsgClientMode = SPSG_ParamValue< NCBI_PARAM_TYPE(PSG, internal_psg_client_mode)> NCBI_PARAM_DECL (unsigned, PSG, rd_buf_size) NCBI_PARAM_DECL (size_t, PSG, wr_buf_size) NCBI_PARAM_DECL (unsigned, PSG, max_concurrent_streams) NCBI_PARAM_DECL (unsigned, PSG, max_concurrent_submits) NCBI_PARAM_DECL (unsigned, PSG, max_sessions) NCBI_PARAM_DECL (unsigned, PSG, max_concurrent_requests_per_server) NCBI_PARAM_DECL (unsigned, PSG, num_io) NCBI_PARAM_DECL (unsigned, PSG, reader_timeout) NCBI_PARAM_DECL (double, PSG, rebalance_time) NCBI_PARAM_DECL (double, PSG, io_timer_period) NCBI_PARAM_DECL (double, PSG, request_timeout) typedef NCBI_PARAM_TYPE (PSG, request_timeout) TPSG_RequestTimeout NCBI_PARAM_DECL (double, PSG, competitive_after) typedef NCBI_PARAM_TYPE (PSG, competitive_after) TPSG_CompetitiveAfter NCBI_PARAM_DECL (size_t, PSG, requests_per_io) NCBI_PARAM_DECL (unsigned, PSG, request_retries) NCBI_PARAM_DECL (unsigned, PSG, refused_stream_retries) NCBI_PARAM_DECL (string, PSG, request_user_args) typedef NCBI_PARAM_TYPE (PSG, request_user_args) TPSG_RequestUserArgs NCBI_PARAM_DECL (string, PSG, multivalued_user_args) typedef NCBI_PARAM_TYPE (PSG, multivalued_user_args) TPSG_MultivaluedUserArgs NCBI_PARAM_DECL (bool, PSG, user_request_ids) NCBI_PARAM_DECL (unsigned, PSG, localhost_preference) typedef NCBI_PARAM_TYPE (PSG, localhost_preference) TPSG_LocalhostPreference NCBI_PARAM_DECL (bool, PSG, fail_on_unknown_items) typedef NCBI_PARAM_TYPE (PSG, fail_on_unknown_items) TPSG_FailOnUnknownItems NCBI_PARAM_DECL (bool, PSG, fail_on_unknown_chunks) typedef NCBI_PARAM_TYPE (PSG, fail_on_unknown_chunks) TPSG_FailOnUnknownChunks NCBI_PARAM_DECL (bool, PSG, https) typedef NCBI_PARAM_TYPE (PSG, https) TPSG_Https NCBI_PARAM_DECL (double, PSG, no_servers_retry_delay) typedef NCBI_PARAM_TYPE (PSG, no_servers_retry_delay) TPSG_NoServersRetryDelay NCBI_PARAM_DECL (string, PSG, service) NCBI_PARAM_DECL (string, PSG, auth_token_name) NCBI_PARAM_DECL (string, PSG, auth_token) NCBI_PARAM_DECL (string, PSG, admin_auth_token_name) NCBI_PARAM_DECL (string, PSG, admin_auth_token) NCBI_PARAM_DECL (bool, PSG, stats) typedef NCBI_PARAM_TYPE (PSG, stats) TPSG_Stats NCBI_PARAM_DECL (double, PSG, stats_period) typedef NCBI_PARAM_TYPE (PSG, stats_period) TPSG_StatsPeriod NCBI_PARAM_DECL (double, PSG, throttle_relaxation_period) NCBI_PARAM_DECL (unsigned, PSG, throttle_by_consecutive_connection_failures) NCBI_PARAM_DECL (bool, PSG, throttle_hold_until_active_in_lb) NCBI_PARAM_DECL (string, PSG, throttle_by_connection_error_rate) NCBI_PARAM_ENUM_DECL (EPSG_DebugPrintout, PSG, debug_printout) NCBI_PARAM_ENUM_DECL (EPSG_UseCache, PSG, use_cache) NCBI_PARAM_ENUM_DECL (EPSG_PsgClientMode, PSG, internal_psg_client_mode) ◆ PSG_PARAM_TYPE ◆ PSG_PARAM_VALUE_DECL_MIN #define PSG_PARAM_VALUE_DECL_MIN ( type, section, name ) Value:template <> \
NCBI_PARAM_DECL(unsigned, PSG, rd_buf_size)
typedef NCBI_PARAM_TYPE(PSG, request_timeout) TPSG_RequestTimeout
#define PSG_PARAM_TYPE(section, name)
Definition at line 306 of file misc.hpp.
◆ PSG_PARAM_VALUE_DEF_MIN #define PSG_PARAM_VALUE_DEF_MIN ( type, section, name, default_value, min_value ) Value:#define NCBI_PARAM_DEF(type, section, name, default_value)
Parameter definition.
Definition at line 311 of file misc.hpp.
◆ PSG_PARAM_VALUE_TYPE ◆ TPSG_AdminAuthToken ◆ TPSG_AdminAuthTokenName ◆ TPSG_AuthToken ◆ TPSG_AuthTokenName ◆ TPSG_DebugPrintout ◆ TPSG_IoTimerPeriod ◆ TPSG_MaxConcurrentRequestsPerServer ◆ TPSG_MaxConcurrentStreams ◆ TPSG_MaxConcurrentSubmits ◆ TPSG_MaxSessions ◆ TPSG_NumIo ◆ TPSG_PsgClientMode ◆ TPSG_RdBufSize ◆ TPSG_ReaderTimeout ◆ TPSG_RebalanceTime ◆ TPSG_RefusedStreamRetries ◆ TPSG_RequestRetries ◆ TPSG_RequestsPerIo ◆ TPSG_Service ◆ TPSG_ThrottleMaxFailures ◆ TPSG_ThrottlePeriod ◆ TPSG_ThrottleThreshold ◆ TPSG_ThrottleUntilDiscovery ◆ TPSG_UseCache ◆ TPSG_UserRequestIds ◆ TPSG_WrBufSize ◆ EPSG_DebugPrintout Enumerator eNone eSome eFrames eAllDefinition at line 417 of file misc.hpp.
◆ EPSG_PsgClientMode Enumerator eOff ePerformanceDefinition at line 426 of file misc.hpp.
◆ EPSG_UseCache Enumerator eDefault eNo eYesDefinition at line 421 of file misc.hpp.
◆ NCBI_PARAM_DECL() [1/34] NCBI_PARAM_DECL ( bool , PSG , fail_on_unknown_chunks ) ◆ NCBI_PARAM_DECL() [2/34] NCBI_PARAM_DECL ( bool , PSG , fail_on_unknown_items ) ◆ NCBI_PARAM_DECL() [3/34] NCBI_PARAM_DECL ( bool , PSG , https ) ◆ NCBI_PARAM_DECL() [4/34] NCBI_PARAM_DECL ( bool , PSG , stats ) ◆ NCBI_PARAM_DECL() [5/34] NCBI_PARAM_DECL ( bool , PSG , throttle_hold_until_active_in_lb ) ◆ NCBI_PARAM_DECL() [6/34] NCBI_PARAM_DECL ( bool , PSG , user_request_ids ) ◆ NCBI_PARAM_DECL() [7/34] NCBI_PARAM_DECL ( double , PSG , competitive_after ) ◆ NCBI_PARAM_DECL() [8/34] NCBI_PARAM_DECL ( double , PSG , io_timer_period ) ◆ NCBI_PARAM_DECL() [9/34] NCBI_PARAM_DECL ( double , PSG , no_servers_retry_delay ) ◆ NCBI_PARAM_DECL() [10/34] NCBI_PARAM_DECL ( double , PSG , rebalance_time ) ◆ NCBI_PARAM_DECL() [11/34] NCBI_PARAM_DECL ( double , PSG , request_timeout ) ◆ NCBI_PARAM_DECL() [12/34] NCBI_PARAM_DECL ( double , PSG , stats_period ) ◆ NCBI_PARAM_DECL() [13/34] NCBI_PARAM_DECL ( double , PSG , throttle_relaxation_period ) ◆ NCBI_PARAM_DECL() [14/34] NCBI_PARAM_DECL ( size_t , PSG , requests_per_io ) ◆ NCBI_PARAM_DECL() [15/34] NCBI_PARAM_DECL ( size_t , PSG , wr_buf_size ) ◆ NCBI_PARAM_DECL() [16/34] NCBI_PARAM_DECL ( string , PSG , admin_auth_token ) ◆ NCBI_PARAM_DECL() [17/34] NCBI_PARAM_DECL ( string , PSG , admin_auth_token_name ) ◆ NCBI_PARAM_DECL() [18/34] NCBI_PARAM_DECL ( string , PSG , auth_token ) ◆ NCBI_PARAM_DECL() [19/34] NCBI_PARAM_DECL ( string , PSG , auth_token_name ) ◆ NCBI_PARAM_DECL() [20/34] NCBI_PARAM_DECL ( string , PSG , multivalued_user_args ) ◆ NCBI_PARAM_DECL() [21/34] NCBI_PARAM_DECL ( string , PSG , request_user_args ) ◆ NCBI_PARAM_DECL() [22/34] NCBI_PARAM_DECL ( string , PSG , service ) ◆ NCBI_PARAM_DECL() [23/34] NCBI_PARAM_DECL ( string , PSG , throttle_by_connection_error_rate ) ◆ NCBI_PARAM_DECL() [24/34] NCBI_PARAM_DECL ( unsigned , PSG , localhost_preference ) ◆ NCBI_PARAM_DECL() [25/34] NCBI_PARAM_DECL ( unsigned , PSG , max_concurrent_requests_per_server ) ◆ NCBI_PARAM_DECL() [26/34] NCBI_PARAM_DECL ( unsigned , PSG , max_concurrent_streams ) ◆ NCBI_PARAM_DECL() [27/34] NCBI_PARAM_DECL ( unsigned , PSG , max_concurrent_submits ) ◆ NCBI_PARAM_DECL() [28/34] NCBI_PARAM_DECL ( unsigned , PSG , max_sessions ) ◆ NCBI_PARAM_DECL() [29/34] NCBI_PARAM_DECL ( unsigned , PSG , num_io ) ◆ NCBI_PARAM_DECL() [30/34] NCBI_PARAM_DECL ( unsigned , PSG , rd_buf_size ) ◆ NCBI_PARAM_DECL() [31/34] NCBI_PARAM_DECL ( unsigned , PSG , reader_timeout ) ◆ NCBI_PARAM_DECL() [32/34] NCBI_PARAM_DECL ( unsigned , PSG , refused_stream_retries ) ◆ NCBI_PARAM_DECL() [33/34] NCBI_PARAM_DECL ( unsigned , PSG , request_retries ) ◆ NCBI_PARAM_DECL() [34/34] NCBI_PARAM_DECL ( unsigned , PSG , throttle_by_consecutive_connection_failures ) ◆ NCBI_PARAM_ENUM_DECL() [1/3] ◆ NCBI_PARAM_ENUM_DECL() [2/3] ◆ NCBI_PARAM_ENUM_DECL() [3/3] ◆ NCBI_PARAM_TYPE() [1/11] typedef NCBI_PARAM_TYPE ( PSG , competitive_after ) ◆ NCBI_PARAM_TYPE() [2/11] typedef NCBI_PARAM_TYPE ( PSG , fail_on_unknown_chunks ) ◆ NCBI_PARAM_TYPE() [3/11] typedef NCBI_PARAM_TYPE ( PSG , fail_on_unknown_items ) ◆ NCBI_PARAM_TYPE() [4/11] typedef NCBI_PARAM_TYPE ( PSG , https ) ◆ NCBI_PARAM_TYPE() [5/11] typedef NCBI_PARAM_TYPE ( PSG , localhost_preference ) ◆ NCBI_PARAM_TYPE() [6/11] typedef NCBI_PARAM_TYPE ( PSG , multivalued_user_args ) ◆ NCBI_PARAM_TYPE() [7/11] typedef NCBI_PARAM_TYPE ( PSG , no_servers_retry_delay ) ◆ NCBI_PARAM_TYPE() [8/11] typedef NCBI_PARAM_TYPE ( PSG , request_timeout ) ◆ NCBI_PARAM_TYPE() [9/11] typedef NCBI_PARAM_TYPE ( PSG , request_user_args ) ◆ NCBI_PARAM_TYPE() [10/11] typedef NCBI_PARAM_TYPE ( PSG , stats ) ◆ NCBI_PARAM_TYPE() [11/11] typedef NCBI_PARAM_TYPE ( PSG , stats_period )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