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

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

NCBI C++ ToolKit: src/connect/services/neticache_client.cpp Source File

&

,

&

,

* encoded_key)

encoded_key->push_back(

);

);

encoded_subkey;

blob_id.reserve(1 +

.length() + 3 +

.length() + 1);

blob_id.append(

, 3);

blob_id.append(encoded_subkey);

blob_id.push_back(

);

blob_id.reserve(1 +

.length() + 2 +

((

)

(

) * 1.5) + 2 +

.length() + 1);

blob_id.append(

, 2);

blob_id.append(

, 2);

blob_id.append(encoded_subkey);

blob_id.push_back(

);

& section,

& service_name,

& client_name,

& cache_name) :

registry_builder, sections);

(registry_builder, sections);

multiline_output,

(

* cmd_base,

& blob_id,

(

* cmd_base,

&

,

&

,

&

,

* blob_size_ptr,

max_age,

* actual_age,

,

part_size,

* blob_size_ptr,

(cache_name.empty()) cache_name =

.

(sections, {

,

},

);

.append(

);

.push_back(

);

.append(

);

, parameters).

;

& conf_section) :

& cache_name,

& client_name) :

host +

+

::UIntToString(port),

client_name, cache_name))

& service_name,

& cache_name,

& client_name) :

service_name, client_name, cache_name))

->m_Service->m_ServerPool.SetCommunicationTimeout(to);

->m_Service->m_ServerPool.GetCommunicationTimeout();

&

) :

multiline_output,

(!try_all_servers && selected_server) {

}

(selected_server) {

selected_server, server_check);

&service_traversal, try_all_servers ?

(server_last_used_ptr !=

)

->m_CacheFlags;

time_to_live,

parameters.

(time_to_live);

(

);

,

part_size,

* cmd_name;

(

== 0 && part_size == 0) {

cmd_name =

;

exec_result, blob_size_ptr, &parameters);

unique_ptr<IReader> rdr(

->GetReadStreamPart(

(rdr.get() ==

)

blob_descr->

.reset(

->ReadCurrentBlobNotOlderThan(

time_to_live,

response(

->ExecStdCmd(

,

, 0,

, &parameters));

time_t access_timeout)

(access_timeout) {

=

->MakeStdCmd(

,

+

+

, &

->m_DefaultParameters);

* blob_size_ptr,

0, 0, blob_size_ptr, optional);

* blob_size_ptr,

, part_size, blob_size_ptr, optional);

->ReadCurrentBlobNotOlderThan(

,

, blob_size_ptr,

* blob_size_ptr,

max_age,

* actual_age,

=

(

, blob_id, &parameters);

string::size_type pos = exec_result.

.find(

);

(pos == string::npos) {

);

exec_result.

.c_str() + pos +

(

) - 1,

pos = exec_result.

.find(

);

(pos == string::npos) {

);

(exec_result.

[pos +

(

) - 1]) {

:

:

:

:

:

:

:

:

);

(actual_age !=

)

*actual_age = e.

();

warning_handler = [&](

& m,

s) {

(ver_pos ==

)

= atoi(warn_msg.c_str() + ver_pos +

(

) - 1);

<<

->ChooseServerAndExec(

->MakeStdCmd(

,

&

->m_DefaultParameters),

&

->m_DefaultParameters));

(!exec_result.

.empty()) {

(

<<

<<

<<

->ChooseServerAndExec(

->MakeStdCmd(

,

->SetNetCacheCompatMode();

(

.ReadLine(line)) {

(

.ReadLine(line))

->m_Service;

& injection)

.append(cmd_base);

.push_back(

);

.append(blob_id);

(!injection.empty())

.append(injection);

->m_DefaultParameters.GetCacheName();

parameters = &

->m_DefaultParameters;

->AppendClientIPSessionIDPasswordAgeHitID(&ids, parameters);

oss <<

<< cache_name <<

<< expression + filter << ids;

->ChooseServerAndExec(

&

->m_DefaultParameters));

->SetNetCacheCompatMode();

vector<CNetICacheClient::CBlobInfo>

;

(

.ReadLine(line) && !line.empty()) {

.push_back(blob_info);

(

);

->AppendClientIPSessionIDHitID(&

);

& driver,

Utility class for ICache class factories.

Exception thrown when the requested blob is older than the requested age.

NetCache internal exception.

Class factory for NetCache implementation of ICache.

virtual ICache * x_CreateInstance(const string &driver=kEmptyStr, CVersionInfo version=NCBI_INTERFACE_VERSION(ICache), const TPluginManagerParamTree *params=0) const

CICacheCF< CNetICacheClient > TParent

Client to NetCache server (implements ICache interface)

SExecResult ExecWithRetry(const string &cmd, bool multiline_output=false)

Execute remote command 'cmd', wait for the reply, check if it starts with 'OK:', and return the remai...

CNetServiceIterator IterateByWeight(const string &key)

CSetValidWarningSuppressor(INetServerConnectionListener *listener, const string &key, const string &subkey, int version)

~CSetValidWarningSuppressor()

CRef< INetServerConnectionListener > m_Listener

bool OnWarning(const string &warn_msg, CNetServer server)

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

CTimeout – Timeout interval.

definition of a Culling tree

BLOB cache read/write/maintenance interface.

EKeepVersions

If to keep already cached versions of the BLOB when storing another version of it (not necessarily a ...

int TFlags

Bitwise OR of "EFlags" flags.

EBlobVersionValidity

BLOB version existence and validity – from the point of view of the underlying cache implementation.

@ eExpired

Validity of the BLOB version cannot be confirmed.

@ eCurrent

The returned BLOB's version is considered valid.

@ fBestReliability

Usually, it's not a problem if something fails to get cached sometimes.

int TTimeStampFlags

Holds a bitwise OR of "ETimeStampFlags".

A very basic data-read interface.

A very basic data-write interface.

CNetServiceIterator m_Iterator

SWeightedServiceTraversal(CNetService::TInstance service, const string &key)

virtual CNetServer BeginIteration()

virtual CNetServer NextServer()

static SQLCHAR output[256]

#define ERR_POST(message)

Error posting with file, line number information but without error codes.

TErrCode GetErrCode(void) const

Get error code.

#define NCBI_THROW(exception_class, err_code, message)

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

#define nc_caching_mode

Caching mode.

#define nc_actual_age

A pointer to an unsigned variable where the actual age of the blob must be stored.

#define nc_blob_ttl

Blob life span in seconds.

#define nc_max_age

Do not read the blob if its age is greater than the specified value.

virtual time_t GetAccessTime(const string &key, int version, const string &subkey)

Return last access time for the specified cache entry.

IReader * GetReadStream(const string &key, int version, const string &subkey, size_t *blob_size_ptr, const CNamedParameterList *optional=NULL)

Read a lengthy blob via the IReader interface.

ENetCacheResponseType GetResponseType() const

unsigned * GetActualBlobAgePtr() const

void SetCacheName(const string &cache_name)

const string & GetBlobID() const

virtual string GetCacheName(void) const

void RemoveBlob(const string &key, int version, const string &subkey, const CNamedParameterList *optional=NULL)

virtual void Store(const string &key, int version, const string &subkey, const void *data, size_t size, unsigned int time_to_live=0, const string &owner=kEmptyStr)

Add or replace BLOB.

virtual EKeepVersions GetVersionRetention() const

Get version retention.

virtual void SetBlobVersionAsCurrent(const string &key, const string &subkey, int version)

Set current valid version for a BLOB.

bool GetTryAllServers() const

CNetServerMultilineCmdOutput GetBlobInfo(const string &key, int version, const string &subkey, const CNamedParameterList *optional=NULL)

Return a CNetServerMultilineCmdOutput object for reading meta information about the specified blob.

virtual void Remove(const string &key, int version, const string &subkey)

Remove specific cache entry.

virtual void SetVersionRetention(EKeepVersions policy)

Set version retention policy.

virtual TTimeStampFlags GetTimeStampPolicy() const

Get timestamp policy.

virtual TFlags GetFlags()

Retrieve the effective combination of flags from the underlying storage.

bool GetServerCheck(ESwitch *server_check) const

grid::netcache::search::CBlobInfo CBlobInfo

void Cache_RegisterDriver_NetCache(void)

grid::netcache::search::CExpression CExpression

void RegisterSession(unsigned pid)

Send session registration command.

IReader * GetReadStreamPart(const string &key, int version, const string &subkey, size_t offset, size_t part_size, size_t *blob_size_ptr, const CNamedParameterList *optional=NULL)

Read data from the specified blob.

CNetServer * GetServerLastUsedPtr() const

STimeout GetCommunicationTimeout() const

bool ReadPart(const string &key, int version, const string &subkey, size_t offset, size_t part_size, void *buf, size_t buf_size)

void SetMaxBlobAge(unsigned max_age)

size_t GetBlobSize(const string &key, int version, const string &subkey, const CNamedParameterList *optional=NULL)

Returns the size of the BLOB identified by the "key", "version", and "subkey" parameters.

void SetTTL(unsigned blob_ttl)

void UnRegisterSession(unsigned pid)

Send session unregistration command.

virtual bool Read(const string &key, int version, const string &subkey, void *buf, size_t buf_size)

void LoadNamedParameters(const CNamedParameterList *optional)

size_t CheckBlobSize(Uint8 blob_size)

CNetRef< SNetICacheClientImpl > m_Impl

const char *const kNetICacheDriverName

vector< CBlobInfo > Search(CExpression expression, CFields fields=CFields())

Returns information for all blobs matching provided search expression.

void WriteBufferAndClose(const char *buf_ptr, size_t buf_size)

virtual int GetTimeout() const

Get expiration timeout.

EAppRegistry

Defines how this object must be initialized.

bool HasBlob(const string &key, const string &subkey, const CNamedParameterList *optional=NULL)

CNetServer GetServerToUse() const

void NCBI_EntryPoint_xcache_netcache(CPluginManager< ICache >::TDriverInfoList &info_list, CPluginManager< ICache >::EEntryPointRequest method)

virtual bool HasBlobs(const string &key, const string &subkey)

Check if any BLOB exists (any version)

IEmbeddedStreamWriter * GetNetCacheWriter(const string &key, int version, const string &subkey, const CNamedParameterList *optional=NULL)

Create or update the specified blob.

grid::netcache::search::CFields CFields

virtual IWriter * GetWriteStream(const string &key, int version, const string &subkey, unsigned int time_to_live=0, const string &owner=kEmptyStr)

Return sequential stream interface to write BLOB data.

unsigned GetMaxBlobAge() const

void PrintBlobInfo(const string &key, int version, const string &subkey)

Print meta information about the specified blob.

virtual void GetBlobOwner(const string &key, int version, const string &subkey, string *owner)

Retrieve BLOB owner.

virtual void SetFlags(TFlags flags)

Pass flags to the underlying storage.

void SetTryAllServers(bool try_all_servers)

virtual void GetBlobAccess(const string &key, int version, const string &subkey, SBlobAccessDescr *blob_descr)

Get BLOB access using BlobAccessDescr.

virtual bool SameCacheParams(const TCacheParams *params) const

virtual size_t GetSize(const string &key, int version, const string &subkey)

Check if BLOB exists, return BLOB size.

string GetCacheName() const

virtual void Purge(time_t access_timeout)

Delete all BLOBs older than specified.

virtual bool IsOpen() const

void SetCommunicationTimeout(const STimeout &to)

Set communication timeout.

virtual void SetTimeStampPolicy(TTimeStampFlags policy, unsigned int timeout, unsigned int max_timeout=0)

Set timestamp update policy.

const string & GetKey() const

void SetCachingMode(CNetCacheAPI::ECachingMode caching_mode)

@ eReadComplete

The whole BLOB has been read.

@ eBlobNotFound

Access denied.

static void NCBI_EntryPointImpl(TDriverInfoList &info_list, EEntryPointRequest method)

Entry point implementation.

#define NCBI_INTERFACE_VERSION(iface)

Macro to construct CVersionInfo class using interface name (relies on CInterfaceVersion class)

list< SDriverInfo > TDriverInfoList

List of driver information.

EEntryPointRequest

Actions performed by the entry point.

uint64_t Uint8

8-byte (64-bit) unsigned integer

virtual const string & Get(const string &section, const string &name, TFlags flags=0) const

Get the parameter value.

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

NCBI_NS_STD::string::size_type SIZE_TYPE

static string PrintableString(const CTempString str, TPrintableMode mode=fNewLine_Quote|fNonAscii_Passthru)

Get a printable version of the specified string.

static string IntToString(int value, TNumToStringFlags flags=0, int base=10)

Convert int to string.

static SIZE_TYPE FindCase(const CTempString str, const CTempString pattern, SIZE_TYPE start, SIZE_TYPE end, EOccurrence which=eFirst)

Find the pattern in the specified range of a string using a case sensitive search.

static string UIntToString(unsigned int value, TNumToStringFlags flags=0, int base=10)

Convert UInt to string.

static bool StartsWith(const CTempString str, const CTempString start, ECase use_case=eCase)

Check if a string starts with a specified prefix value.

static Uint8 StringToUInt8(const CTempString str, TStringToNumFlags flags=0, int base=10)

Convert string to Uint8.

static unsigned int StringToUInt(const CTempString str, TStringToNumFlags flags=0, int base=10)

Convert string to unsigned int.

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.

static string UInt8ToString(Uint8 value, TNumToStringFlags flags=0, int base=10)

Convert UInt8 to string.

@ fAllowTrailingSymbols

Ignore trailing non-numerics characters.

double GetAsDouble(void) const

Get as number of seconds (fractional value).

enum ENcbiSwitch ESwitch

Aux.

@ eNonCompatible

major, minor does not match

unsigned int

A callback function used to compare two keys in a database.

Definition of all error codes used in connect services library (xconnserv.lib and others).

const string version

version string

const struct ncbi::grid::netcache::search::fields::SIZE size

const struct ncbi::grid::netcache::search::fields::KEY key

const struct ncbi::grid::netcache::search::fields::SUBKEY subkey

Static variables safety - create on demand, destroy on application termination.

Defines: CTimeFormat - storage class for time format.

NetCache API exception declarations.

#define MAX_ICACHE_CACHE_NAME_LENGTH

#define MAX_ICACHE_SUBKEY_LENGTH

static string s_KeyVersionSubkeyToBlobID(const string &key, int version, const string &subkey)

static string s_KeySubkeyToBlobID(const string &key, const string &subkey)

#define MAX_ICACHE_KEY_LENGTH

static const char s_NetICacheAPIName[]

static string s_CheckKeySubkey(const string &key, const string &subkey, string *encoded_key)

NetCache ICache client specs.

Helper classes and templates to implement plugins.

Defines CRequestContext class for NCBI C++ diagnostic API.

IReader * GetReadStream(const string &key, int version, const string &subkey, size_t *blob_size_ptr, const CNamedParameterList *optional=NULL)

Read a lengthy blob via the IReader interface.

void ProlongBlobLifetime(const string &key, const string &subkey, const CTimeout &ttl, const CNamedParameterList *optional=NULL)

SNetCacheAPIImpl * GetNetCacheAPI()

CNetICacheClientExt GetServer(CNetServer::TInstance server)

CNetServerConnection conn

unsigned maximum_age

Set to a non-zero value to return a version not older than the specified value.

unsigned actual_age

If `maximum_age` is not zero, GetBlobAccess() will set this field to the actual blob version age upon...

unique_ptr< IReader > reader

EBlobVersionValidity current_version_validity

If `return_current_version` is set, the `current_version_validity` field will contain the validity of...

bool return_current_version_supported

If TRUE, the ICache instance supports return_current_version.

TBlobVersion current_version

If `return_current_version` is set, the current version number of the blob is stored in the `current_...

bool return_current_version

If TRUE, the `version` argument of GetBlobAccess() will be ignored and the `current_version` and `cur...

void SetWarningHandler(TEventHandler warning_handler)

void AppendClientIPSessionIDPasswordAgeHitID(string *cmd, const CNetCacheAPIParameters *parameters)

CNetCacheAPIParameters m_DefaultParameters

unsigned x_ExtractBlobAge(const CNetServer::SExecResult &exec_result, const char *cmd_name)

static CNetCacheAPI::EReadResult ReadBuffer(IReader &reader, char *buf_ptr, size_t buf_size, size_t *n_read, size_t blob_size)

void Init(CSynRegistry &registry, const SRegSynonyms &sections)

CNetServer::SExecResult ChooseServerAndExec(const string &cmd, const string &key, bool multiline_output, const CNetCacheAPIParameters *parameters)

void Init(CSynRegistry &registry, const SRegSynonyms &sections)

IReader * ReadCurrentBlobNotOlderThan(const string &key, const string &subkey, size_t *blob_size_ptr, int *version, ICache::EBlobVersionValidity *validity, unsigned max_age, unsigned *actual_age, const CNamedParameterList *optional=NULL)

ICache::TFlags m_CacheFlags

string MakeStdCmd(const char *cmd_base, const string &blob_id, const CNetCacheAPIParameters *parameters, const string &injection=kEmptyStr)

SNetICacheClientImpl(CSynRegistryBuilder registry_builder, const string &section, const string &service_name, const string &client_name, const string &cache_name)

IReader * GetReadStreamPart(const string &key, int version, const string &subkey, size_t offset, size_t part_size, size_t *blob_size_ptr, const CNamedParameterList *optional)

string ExecStdCmd(const char *cmd_base, const string &key, int version, const string &subkey, const CNetCacheAPIParameters *parameters)

SNetICacheClientImpl(SNetServerInPool *server, SNetICacheClientImpl *parent)

virtual CNetServerConnection InitiateWriteCmd(CNetCacheWriter *nc_writer, const CNetCacheAPIParameters *parameters)

CRef< SNetServerInPool > m_ServerInPool

@ eRethrowAllServerErrors

static SNetServiceImpl * Create(const string &api_name, const string &service_name, const string &client_name, INetServerConnectionListener *listener, CSynRegistry &registry, SRegSynonyms &sections, const string &ns_client_name=kEmptyStr)

void IterateUntilExecOK(const string &cmd, bool multiline_output, CNetServer::SExecResult &exec_result, IServiceTraversal *service_traversal, EServerErrorHandling error_handling)

Reader writer with transmission checking.

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