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

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

NCBI C++ ToolKit: src/serial/grpc_integration/grpc_integration.cpp Source File

CNCBILogSink :

absl::LogSink {

absl::InitializeLog();

absl::AddLogSink(

);

Send(

absl::LogEntry& entry)

{

ncbi::CDiagCompileInfo diag_info(

src.c_str(), entry.source_line(),

(entry.log_severity()) {

ncbi::CNcbiDiag(diag_info) << ncbi::Severity(sev) <<

<< ncbi::Endm;

CNCBILogSink s_NCBILogSink;

ncbi::CDiagCompileInfo diag_info(args->file, args->line, unk_func,

);

(args->severity) {

ncbi::CNcbiDiag(diag_info) << ncbi::Severity(sev) << args->message << ncbi::Endm;

(name ==

) {

}

(name ==

) {

}

(name ==

) {

(

& c :

) {

( !

((

) c) && kLegalPunct.

(c) ==

) {

(name ==

) {

}

(name ==

) {

}

(name ==

) {

unique_ptr<TGRPCBaseClientContext>

unique_ptr<TGRPCBaseClientContext>

(TGRPCBaseClientContext::FromServerContext(sctx, options));

make_unique<CGRPCClientContext>();

cctx.set_initial_metadata_corked(

);

cctx.AddMetadata(

, rctx.

());

cctx.AddMetadata(

, dctx.

());

need_filter = pass_through.

(

);

<<

);

([&](

& name,

&

) {

( !need_filter || name ==

cctx.AddMetadata(

,

);

(e400_BadRequest, INVALID_ARGUMENT),

(e401_Unauthorized, PERMISSION_DENIED),

(e402_PaymentRequired, PERMISSION_DENIED),

(e403_Forbidden, PERMISSION_DENIED),

(e404_NotFound, NOT_FOUND),

(e405_MethodNotAllowed, UNIMPLEMENTED),

(e406_NotAcceptable, UNIMPLEMENTED),

(e407_ProxyAuthRequired, PERMISSION_DENIED),

(e408_RequestTimeout, DEADLINE_EXCEEDED),

(e409_Conflict, ABORTED),

(e410_Gone, NOT_FOUND),

(e411_LengthRequired, UNIMPLEMENTED),

(e412_PreconditionFailed, FAILED_PRECONDITION),

(e413_RequestEntityTooLarge, RESOURCE_EXHAUSTED),

(e414_RequestURITooLong, RESOURCE_EXHAUSTED),

(e415_UnsupportedMediaType, UNIMPLEMENTED),

(e416_RangeNotSatisfiable, OUT_OF_RANGE),

(e417_ExpectationFailed, FAILED_PRECONDITION),

(e422_UnprocessableEntity, UNIMPLEMENTED),

(e499_BrokenConnection, CANCELLED),

(e500_InternalServerError, INTERNAL),

(e501_NotImplemented, UNIMPLEMENTED),

(e502_BadGateway, INTERNAL),

(e503_ServiceUnavailable, UNAVAILABLE),

(e504_GatewayTimeout, DEADLINE_EXCEEDED),

(e505_HTTPVerNotSupported, UNIMPLEMENTED)

(it != sc_ErrorCodeMap.end()) {

client_name, peer_ip, port;

pos = sctx->peer().find(

);

peer = sctx->peer().substr(pos + 1);

pos = peer.

(

);

(pos ==

|| peer[peer.size() - 1] ==

) {

port = peer.

(pos + 1);

host.

(peer, 0, pos);

(host[0] ==

&& host[pos - 1] ==

) {

host = host.

(1, pos - 2);

( !host.

() ) {

(

& metadata : sctx->client_metadata()) {

nm(metadata.first .data(), metadata.first .size());

vl(metadata.second.data(), metadata.second.size());

grpc_fields[name2] =

;

= sc_RCSetterMap.find(name.c_str());

(it != sc_RCSetterMap.end()) {

rcsettings[it->second][name] =

;

}

(metadata.first ==

) {

client_name =

;

(

& it : rcsettings) {

*

=

;

(it.second.size() == 1) {

= &it.second.begin()->second;

(it.second.size() == 2);

*old_name =

, *new_name =

;

(

& it2 : it.second) {

new_name = &it2.first;

old_name = &it2.first;

(old_name !=

);

<<

<< *old_name <<

<< *new_name);

(*(it.first))(rctx, *

);

( !client_name.empty() ) {

extra.

(

, client_name);

( !peer_ip.empty() ) {

extra.

(

, peer_ip);

( !port.empty() ) {

extra.

(

, port);

(app ==

) {

list<string> env_names;

->Enumerate(env_names);

(

& it : env_names) {

env_fields[name] =

->Get(it);

peer = sctx->peer();

(

& it : sctx->client_metadata()) {

name(it.first.data(), it.first.size());

* variable,

* env_var_name,

(

.empty() ) {

static grpc::Server::GlobalCallbacks *volatile sm_ServerCallbacks

static CNcbiApplication * Instance(void)

Singleton method.

Request context properties passed between tasks.

class CStaticArrayMap<> provides access to a static array in much the same way as CStaticArraySet<>,...

TBase::const_iterator const_iterator

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

const CNcbiEnvironment & GetEnvironment(void) const

Get the application's cached environment.

@ eNoOwnership

No ownership is assumed.

void PrintRequestStop(void)

Print request stop message (for request-driven applications)

CDiagContext_Extra & Print(const string &name, const string &value)

The method does not print the argument, but adds it to the string.

CDiagContext & GetDiagContext(void)

Get diag context instance.

void PrintRequestStart(const string &message)

Print request start message (for request-driven applications)

string GetSessionID(void) const

Session ID.

void SetRequestID(TCount rid)

Set request ID.

const string & GetNextSubHitID(CTempString prefix=CTempString())

Get current hit id appended with auto-incremented sub-hit id.

#define ERR_POST_X_ONCE(err_subcode, message)

Error posting only once during program execution with default error code and given error subcode.

void SetClientIP(const string &client)

bool IsSetSessionID(void) const

static CRequestContext & GetRequestContext(void)

Shortcut to CDiagContextThreadData::GetThreadData().GetRequestContext()

string GetClientIP(void) const

Client IP/hostname.

void Enumerate(TCallback callback)

Enumerate all properties.

bool IsSet(CTempString name) const

Check if the property is set.

const string & GetDtab(void) const

void Flush(void)

Print the message and reset object.

bool IsSetClientIP(void) const

void AddPassThroughProperty(const string &name, const string &value)

Add pass-through value if it matches a pattern from NCBI_CONTEXT_FIELDS.

void LogFields(const TEntries &entries) const

Log (as an extra) all names/values matching fields in NCBI_LOG_FIELDS.

const string & GetAppName(void) const

Get application name.

EDiagSev

Severity level for the posted diagnostics.

const char * g_DiagUnknownFunction(void)

@ eDiag_Trace

Trace message.

@ eDiag_Info

Informational message.

@ eDiag_Error

Error message.

@ eDiag_Warning

Warning message.

@ eDiag_Fatal

Fatal error – guarantees exit(or abort)

void Warning(CExceptionArgs_Base &args)

void Info(CExceptionArgs_Base &args)

static void AddStandardNCBIMetadata(TParent &cctx)

grpc::ClientContext TGRPCBaseClientContext

grpc::StatusCode g_AsGRPCStatusCode(CRequestStatus::ECode status_code)

static bool x_IsRealRequest(const TGRPCServerContext *sctx)

grpc::PropagationOptions TGRPCPropagationOptions

static void EndRequest(grpc::ServerContext *sctx)

grpc::ServerContext TGRPCServerContext

static unique_ptr< TParent > FromServerContext(const TGRPCServerContext &sc, TGRPCPropagationOptions opts=TGRPCPropagationOptions())

EInvocationType

How was BeginRequest or EndRequest called?

static bool IsImplemented(void)

string g_NCBI_GRPC_GetAddress(const char *section, const char *variable, const char *env_var_name, CParamBase::EParamSource *value_source)

Get "hostport" for the likes of "grpc::CreateChannel(hostport, ...)" trying (in order of priority):

static void BeginRequest(grpc::ServerContext *sctx)

@ eImplicit

From {Pre,Post}SynchronousRequest.

string g_GetConfigString(const char *section, const char *variable, const char *env_var_name, const char *default_value, CParamBase::EParamSource *src=nullptr)

Helper functions for getting values from registry/environment.

EParamSource

Source of the value returned by CParam::GetDefault().

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

NCBI_NS_STD::string::size_type SIZE_TYPE

size_type rfind(const CTempString match, size_type pos=npos) const

Find the first instance of the entire matching string within the current string in a backward directi...

CTempString & assign(const char *src_str, size_type len)

Assign new values to the content of the a string.

bool empty(void) const

Return true if the represented string is empty (i.e., the length is zero)

static string CParse(const CTempString str, EQuoted quoted=eQuoted)

Discard C-style backslash escapes.

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

Check if a string starts with a specified prefix value.

CTempString substr(size_type pos) const

Obtain a substring from this string, beginning at a given offset.

size_type find(const CTempString match, size_type pos=0) const

Find the first instance of the entire matching string within the current string, beginning at an opti...

static string CEncode(const CTempString str, EQuoted quoted=eQuoted)

Encode a string for C/C++.

static string & ReplaceInPlace(string &src, const string &search, const string &replace, SIZE_TYPE start_pos=0, SIZE_TYPE max_replace=0, SIZE_TYPE *num_replace=0)

Replace occurrences of a substring within a string.

static string & ToLower(string &str)

Convert string to lower case – string& version.

@ eNotQuoted

String is not quoted.

@ eNocase

Case insensitive compare.

static void s_SetHitID(CRequestContext &r, const string &s)

static void s_SetSessionID(CRequestContext &r, const string &s)

SStaticPair< CRequestStatus::ECode, grpc::StatusCode > TStatusCodePair

SStaticPair< const char *, FRCSetter > TRCSetterPair

static void s_SetClientIP(CRequestContext &r, const string &s)

#define GPR_SET_LOG_FUNCION

void(* FRCSetter)(CRequestContext &, const string &)

static string s_EncodeMetadataName(const string &name)

static string s_DecodeMetadataValue(const CTempString &value)

static CGRPCInitializer s_GRPCInitializer

static const TRCSetterPair sc_RCSetters[]

static void s_SetDtab(CRequestContext &r, const string &s)

CStaticArrayMap< CRequestStatus::ECode, grpc::StatusCode > TStatusCodeMap

static string s_EncodeMetadataValue(const string &value)

CStaticArrayMap< const char *, FRCSetter, PCase_CStr > TRCSetterMap

DEFINE_STATIC_ARRAY_MAP(TStatusCodeMap, sc_ErrorCodeMap, sc_ErrorCodes)

static const TStatusCodePair sc_ErrorCodes[]

static void s_NCBI_GPR_Log_Function(gpr_log_func_args *args)

static string s_DecodeMetadataName(const CTempString &name)

Definition of all error codes used in serial libraries (xser.lib, xcser.lib).

const GenericPointer< typename T::ValueType > T2 value

char * NcbiGetHostIP(char *buf, size_t bufsize)

Defines the CNcbiApplication and CAppException classes for creating NCBI applications.

double r(size_t dimension_, const Int4 *score_, const double *prob_, double theta_)

Glue for integrating gRPC into the C++ toolkit, to ensure logging and metadata propagation (sid,...

static SLJIT_INLINE sljit_ins msg(sljit_gpr r, sljit_s32 d, sljit_gpr x, sljit_gpr b)

Template structure SStaticPair is simlified replacement of STL pair<> Main reason of introducing this...

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