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

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

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

* output_buffer,

output_buffer_size)

(output_buffer_size > 0) {

output_buffer_size, &bytes_written);

(output_buffer_size > 32) {

message_start +=

;

buffer_head(output_buffer, output_buffer_size);

<<

<<

<< message_start);

output_buffer += bytes_written;

output_buffer_size -= bytes_written;

* output_buffer;

output_buffer_size;

* output_buffer;

output_buffer_size;

<

TContiguousContainer>

<<

(builder.GetCode()),

(builder.GetMessage()),

<

TOstream>

TOstream&

(TOstream& os)

os <<

<<

<<

;

.AsString();

issue.

(diag);

issue.

(os);

status = reply.

(

);

status_ok = status ==

;

(!status_ok || issues) {

listener.

(issue, server);

ostringstream errors;

* prefix =

;

errors << prefix << issue;

prefix =

;

err_msg =

(

<<

<<

<< errors.str());

<< request.

() <<

<< reply.

() <<

);

<<

server_address <<

<<

storage_flags.

(

,

);

storage_flags.

(

,

);

storage_flags.

(

,

);

storage_flags.

(

,

);

storage_flags.

(

,

);

storage_flags.

(

,

);

node.

(

, storage_flags);

<< err_msg);

<< warn_msg);

(netstorage_rpc->m_Config.err_mode),

()

;

()

;

()

;

()

;

()

;

& object_loc);

()

;

()

;

()

;

(

& attr_name)

;

(

& attr_name,

& attr_value)

;

builder,

& object_loc) :

m_NetStorageRPC(netstorage_rpc),

m_OwnService(service),

m_Context(netstorage_rpc, object_loc),

m_IState(fsm, m_Context),

m_OState(fsm, m_Context)

<<

<<

);

(name ==

)

(name ==

)

default_storage = GetDefaultStorage(

);

(name ==

)

(name ==

)

(name ==

)

(name ==

)

(name ==

)

(name ==

)

client_name =

;

(name ==

)

err_mode = GetErrMode(

);

(name ==

)

(name ==

)

hello_service =

;

SNetStorage::SLimits::Check<SNetStorage::SLimits::SNamespace>(app_domain);

(client_name.empty()) {

&path, &client_name);

path.erase(path.length() - 1);

(!parent_dir.empty()) {

client_name += parent_dir;

(client_name.empty()) {

);

(default_storage) {

(service.empty()) {

init_string <<

);

(nc_service.empty()) {

init_string <<

);

(hello_service.empty()) hello_service = service;

m_DefaultFlags(default_flags),

registry_builder, sections);

m_DefaultFlags(parent->m_DefaultFlags),

m_Config(parent->m_Config),

m_CompoundIDPool(parent->m_CompoundIDPool),

m_NetCacheAPI(parent->m_NetCacheAPI),

m_ServiceMap(parent->m_ServiceMap)

SNetStorageObjectImpl::CreateAndStart<SNetStorage_NetCacheBlob>(

);

object_loc = reply.GetString(

);

builder = [

](

&

,

&

) {

(

,

); };

SNetStorageObjectImpl::CreateAndStart<SNetStorageObjectRPC>(starter,

, service, builder, object_loc);

SNetStorageObjectImpl::Create<SNetStorage_NetCacheBlob>(

, object_loc);

builder = [

](

&

,

&

) {

(

,

); };

SNetStorageObjectImpl::Create<SNetStorageObjectRPC>(

, service, builder, object_loc);

server->

(json_over_uttp_sender);

(object_loc)

object_loc.

();

(cb) cb(progress_info);

reply.GetBoolean(

);

= reply.GetByKeyOrNull(

);

server->

(json_over_uttp_sender);

(pconn) *pconn =

;

new_request.

(

, request_type);

(!ncbi_context.empty()) {

new_request.

(

, ncbi_context);

& object_loc)

new_request.

(

, object_loc);

user_key.

(

, unique_key);

new_request.

(

, user_key);

(service_name.empty())

* bytes_read)

server->

(json_over_uttp_sender);

m_UTTPReader.Reset();

m_CurrentChunk =

;

m_CurrentChunkSize = 0;

}

(!json_reader.

(m_UTTPReader));

(bytes_read) *bytes_read = 0;

(!m_CurrentChunkSize && m_EOF)

;

(!m_CurrentChunkSize) {

(m_UTTPReader.GetNextEvent()) {

m_CurrentChunk = m_UTTPReader.GetChunkPart();

m_CurrentChunkSize = m_UTTPReader.GetChunkPartSize();

(

bytes_copied =

(m_CurrentChunkSize, buf_size)) {

memcpy(buf_pos, m_CurrentChunk, bytes_copied);

m_CurrentChunk += bytes_copied;

m_CurrentChunkSize -= bytes_copied;

(bytes_read) *bytes_read = bytes_copied;

m_CurrentChunkSize == 0 && m_EOF;

* bytes_written)

.Write(buf_pos, buf_size, bytes_written);

* chunk =

*

(buf_pos);

= [&](

& w) { w.SendChunk(chunk, buf_size,

); };

(bytes_written !=

)

*bytes_written = buf_size;

(exception&) {

.push_back((*it).AsString());

& attr_value)

m_UTTPReader.Reset();

m_UTTPReader.Reset();

);

builder = [=](

&

,

&) {

rpc->MkObjectRequest(

, unique_key,

);

SNetStorageObjectImpl::Create<SNetStorageObjectRPC>(rpc, rpc->m_Service, builder,

);

m_Impl->m_NetStorageRPC->m_Service;

m_Impl->m_NetStorageRPC->MkStdRequest(request_type);

m_Impl->m_NetStorageRPC->Exchange(m_Impl->m_NetStorageRPC->m_Service,

request,

, server_to_use);

m_Impl->m_NetStorageRPC->Open(object_loc);

CCompoundID FromString(const string &cid)

Unpack the base64-encoded ID and return a CCompoundID object for field extraction.

Base64-encoded ID string that contains extractable typed fields.

ECompoundIDClass GetClass() const

One of the registered ID classes.

Iterator for JSON arrays and objects.

string Repr(TReprFlags flags=0) const

Return a string representation of this node.

SJsonIteratorImpl * Iterate(EIterationMode mode=eNatural) const

For a container node (that is, either an array or an object), begin iteration over its elements.

void SetString(const string &key, const string &value)

Set a JSON object element to the specified string value.

Int8 GetInteger(const string &key) const

For a JSON object node, return the integer referred to by the specified key.

const string AsString() const

Provided that this is a string node, return the string value of this node.

string GetString(const string &key) const

For a JSON object node, return the string referred to by the specified key.

void SetBoolean(const string &key, bool value)

Set a JSON object element to the specified boolean value.

void SetInteger(const string &key, Int8 value)

Set a JSON object element to the specified integer value.

void SetByKey(const string &key, CJsonNode::TInstance value)

For a JSON object node, insert a new element or update an existing element.

static CJsonNode NewObjectNode()

Create a new JSON object node.

CJsonNode GetByKeyOrNull(const string &key) const

For a JSON object node, return the value associated with the specified key.

virtual void Exec(CNetServerConnection::TInstance conn_impl, const STimeout *timeout)

CNetServerConnection GetConnection() const

CNetServerConnection m_Connection

CJsonOverUTTPExecHandler(const CJsonNode &request)

const CJsonNode GetMessage() const

bool ReadMessage(CUTTPReader &reader)

bool WriteMessage(const CJsonNode &root_node)

void GetOutputBuffer(const char **output_buffer, size_t *output_buffer_size)

static CNcbiApplication * Instance(void)

Singleton method.

Client API for NetCache server.

CNetServiceIterator Iterate(EIterationMode mode=eSortByLoad)

CNetService Clone(const string &name)

CNetStorageAdmin GetServer(CNetServer::TInstance server)

CNetStorageObject Open(const string &object_loc)

CNetStorageAdmin(CNetStorage::TInstance netstorage_impl)

CJsonNode MkNetStorageRequest(const string &request_type)

CJsonNode ExchangeJson(const CJsonNode &request, CNetServer::TInstance server_to_use=NULL, CNetServerConnection *conn=NULL)

Exception class for use by CNetStorage, CNetStorageByKey, and CNetStorageObject.

Detailed information about a CNetStorage object.

string GetServiceName() const

Basic network-based data object I/O.

@ eNetStorageObjectExpired

@ eNetStorageObjectNotFound

INetServerConnectionListener * Clone() override

void OnErrorImpl(const string &err_msg, CNetServer &server) override

CNetStorageServerListener(const CJsonNode &hello, SNetStorage::SConfig::EErrMode err_mode)

const SNetStorage::SConfig::EErrMode m_ErrMode

void OnConnected(CNetServerConnection &connection) override

void OnWarningImpl(const string &warn_msg, CNetServer &server) override

Request context properties passed between tasks.

CJsonOverUTTPWriter m_JSONWriter

void x_SendOutputBuffer()

void SendMessage(const CJsonNode &message)

CSendJsonOverSocket(CSocket &sock)

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

CTimeout – Timeout interval.

Class for reading series of chunks sent by a CUTTPWriter instance as a stream of bytes.

EStreamParsingEvent GetNextEvent()

Parse the input buffer until a parsing event occurs.

char GetControlSymbol() const

Return the control symbol that has been just read.

@ eChunk

Notify that the last part of the chunk has been read.

@ eEndOfBuffer

Notify that the end of the input buffer has been reached.

@ eChunkPart

Notify that a part of a chunk has been read and can be fetched by a call to the GetChunkPart() method...

@ eControlSymbol

Notify that a control symbol has been read.

void SetNewBuffer(const char *buffer, size_t buffer_size)

Start processing of the next chunk of data.

Class that serializes series of chunks of data for sending over binary streams.

void GetOutputBuffer(const char **output_buffer, size_t *output_buffer_size)

Return data to be sent over the output stream and extend internal pointers to the next buffer.

bool NextOutputBuffer()

Proceed to the next output buffer.

void Reset(char *buffer, size_t buffer_size)

Initialize or reinitialize this object.

const_iterator end() const

iterator_bool insert(const value_type &val)

const_iterator find(const key_type &key) const

static CS_CONNECTION * conn

static const struct name_t names[]

const string & GetProgramExecutablePath(EFollowLinks follow_links=eIgnoreLinks) const

Get the application's executable path.

static CNcbiApplicationGuard InstanceGuard(void)

Singleton method.

void Set(TValue new_value) THROWS_NONE

Set atomic counter value.

TValue Add(int delta) THROWS_NONE

Atomically add value (=delta), and return new counter value.

string GetSessionID(void) const

Session ID.

#define DIAG_COMPILE_INFO

Make compile time diagnostic information object to use in CNcbiDiag and CException.

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

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

bool IsSetSessionID(void) const

static CRequestContext & GetRequestContext(void)

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

string GetClientIP(void) const

Client IP/hostname.

bool IsSetClientIP(void) const

#define ERR_POST(message)

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

@ eFormat_UrlEncoded

name=value pairs URL-encoded and separated with '&'

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.

void Warning(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.

virtual const char * GetErrCodeString(void) const

Get error code interpreted as text.

#define FORMAT(message)

Format message using iostreams library.

static char GetPathSeparator(void)

Get path separator symbol specific for the current platform.

static void SplitPath(const string &path, string *dir=0, string *base=0, string *ext=0)

Split a path string into its basic components.

#define nc_use_compound_id

Whether to return NetCache keys in CompoundID format.

static bool ParseBlobKey(const char *key_str, size_t key_len, CNetCacheKey *key_obj, CCompoundIDPool::TInstance id_pool=NULL)

Parse blob key string into a CNetCacheKey structure.

void SetCompoundIDPool(CCompoundIDPool::TInstance compound_id_pool)

void SetDefaultParameters(const CNamedParameterList *parameters)

Override defaults used by this object.

unsigned TNetStorageFlags

Bitwise OR of ENetStorageFlags.

function< void(CJsonNode)> TNetStorageProgressCb

Progress callback.

virtual const char * GetErrCodeString() const override

Get error code interpreted as text.

ENetStorageRemoveResult

Result returned by Remove() methods.

@ fNST_NoMetaData

Do not use NetStorage relational database to track ownership & changes.

@ fNST_Cacheable

Has no effect at the moment.

@ fNST_NetCache

Use NetCache as the primary storage.

@ fNST_FileTrack

Use FileTrack as the primary storage.

@ fNST_Movable

Allow the object to move between storages.

@ eNotSupported

Feature is not supported.

@ eServerError

NetStorage server error.

@ eUnknown

Unknown error.

@ eIOError

I/O error encountered while performing an op.

@ eExpired

Object has expired on server.

@ eInvalidArg

Caller passed invalid arguments to the API.

@ eNotExists

Illegal op applied to non-existent object.

@ eAuthError

Authentication error (e.g. no FileTrack API key)

@ eTimeout

Timeout encountered while performing an op.

@ eInterrupted

Operation has been interrupted.

@ eNSTRR_Removed

Object has been removed successfully.

@ eNSTRR_NotFound

Removing failed due to object not found.

int64_t Int8

8-byte (64-bit) signed integer

uint64_t Uint8

8-byte (64-bit) unsigned integer

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

EIO_Status Close(void)

Close socket.

void GetPeerAddress(unsigned int *host, unsigned short *port, ENH_ByteOrder byte_order) const

Get peer address.

EIO_Status Write(const void *buf, size_t size, size_t *n_written=0, EIO_WriteMethod how=eIO_WritePersist)

Write to socket.

EIO_Status Read(void *buf, size_t size, size_t *n_read=0, EIO_ReadMethod how=eIO_ReadPlain)

Read from socket.

ERW_Result

Result codes for I/O operations.

@ eRW_Eof

End of data, should be considered permanent.

@ eRW_Success

Everything is okay, I/O completed.

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

Get a printable version of the specified string.

static int CompareNocase(const CTempString s1, SIZE_TYPE pos, SIZE_TYPE n, const char *s2)

Case-insensitive compare of a substring with another string.

static bool EndsWith(const CTempString str, const CTempString end, ECase use_case=eCase)

Check if a string ends with a specified suffix value.

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.

CTimeSpan GetAsTimeSpan(void) const

Convert to CTimeSpan.

string AsString(const CTimeFormat &fmt=kEmptyStr) const

Transform time span to string.

bool IsFinite() const

Check if timeout holds a numeric value.

const char * IO_StatusStr(EIO_Status status)

Get the text form of an enum status value.

@ eIO_Interrupt

signal arrival prevented any I/O to succeed

@ eIO_Success

everything is fine, no error occurred

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

The blob sat and sat key Both must be positive integers</td > n< td > Non empty string The interpretation of the blob id depends on a processor Cassandra n processor expects the following format

const GenericPointer< typename T::ValueType > T2 value

EVoid

To create a void (uninitialized) component instance.

@ eVoid

To create a void (uninitialized) instance of a component.

CNetStorageObjectInfo g_CreateNetStorageObjectInfo(const string &object_loc, ENetStorageObjectLocation location, const CNetStorageObjectLoc *object_loc_struct, Uint8 file_size, CJsonNode::TInstance storage_specific_info)

const CNcbiDiag & operator<<(const CNcbiDiag &diag, const SIssue &issue)

void s_ReadSocket(CSocket &sock, TContiguousContainer &buffer, CUTTPReader &uttp_reader)

CJsonNode s_ReadMessage(const CJsonNode &request, CNetServerConnection &conn, SNetStorage::SConfig::EErrMode err_mode, INetServerConnectionListener &listener)

void s_TrapErrors(const CJsonNode &request, const CJsonNode &reply, CNetServerConnection &conn, SNetStorage::SConfig::EErrMode err_mode, INetServerConnectionListener &listener)

#define WRITE_BUFFER_SIZE

#define NST_PROTOCOL_VERSION

void s_SetStorageFlags(CJsonNode &node, TNetStorageFlags flags)

void s_ThrowError(Int8 code, Int8 sub_code, const string &err_msg)

static void s_WriteToSocket(CSocket &sock, const char *output_buffer, size_t output_buffer_size)

void s_SendUTTP(CSocket &sock, function< void(CUTTPWriter &)> f)

#define END_OF_DATA_MARKER

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

Defines CRequestContext class for NCBI C++ diagnostic API.

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

void OnError(const string &err_msg, CNetServer &server)

void OnWarning(const string &warn_msg, CNetServer &server)

void EnterState(INetStorageObjectState *state)

SConnReset(CNetServerConnection &c)

CNetServerConnection & conn

SBuilder(const CJsonNode &node)

string GetMessage() const

TOstream & Print(TOstream &os) const

static const Int8 kEmptySubCode

CRef< SNetServerInPool > m_ServerInPool

void TryExec(INetServerExecHandler &handler, const STimeout *timeout=NULL)

CRef< INetServerConnectionListener > m_Listener

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)

CNetRef< SNetStorageRPC > m_NetStorageRPC

SNetStorageAdminImpl(CNetStorage::TInstance netstorage_impl)

CNetRef< SNetStorageRPC > m_NetStorageRPC

SNetStorageByKeyRPC(const TConfig &config, TNetStorageFlags default_flags)

SNetStorageObjectImpl * Open(const string &unique_key, TNetStorageFlags flags) override

CRef< INetServerConnectionListener > m_Listener

void TrapErrors(const CJsonNode &reply)

CJsonNode m_OriginalRequest

SContext(SNetStorageRPC *netstorage_rpc, const string &object_loc)

CNetServerConnection m_Connection

const SNetStorage::SConfig::EErrMode m_ErrMode

ERW_Result Read(void *buf, size_t count, size_t *read) override

Read as many as "count" bytes into a buffer pointed to by the "buf" argument.

vector< char > m_ReadBuffer

SIState(SContext &context)

const char * m_CurrentChunk

ERW_Result PendingCount(size_t *count) override

Via parameter "count" (which is guaranteed to be supplied non-NULL) return the number of bytes that a...

size_t m_CurrentChunkSize

string GetLoc() const override

string GetLoc() const override

ERW_Result Flush() override

Flush pending data (if any) down to the output device.

SOState(SContext &context)

ERW_Result Write(const void *buf, size_t count, size_t *written) override

Write up to "count" bytes from the buffer pointed to by the "buf" argument onto the output device.

void SetAttribute(const string &attr_name, const string &attr_value) override

list< string > GetAttributeList() const override

CJsonNode Exchange() const

void StartWriting(CJsonNode::TInstance request, CNetServerConnection::TInstance conn)

void MkRequest(const string &request_type) const

ENetStorageRemoveResult Remove() override

string GetAttribute(const string &attr_name) const override

CNetRef< SNetStorageRPC > m_NetStorageRPC

string GetLoc() const override

ERW_Result Flush() override

Flush pending data (if any) down to the output device.

void SetExpiration(const CTimeout &) override

SNetStorageObjectState< SIState > m_IState

SNetStorageObjectState< SOState > m_OState

string Relocate(TNetStorageFlags flags, TNetStorageProgressCb cb) override

CNetStorageObjectInfo GetInfo() override

SNetStorageObjectRPC(SNetStorageObjectImpl &fsm, SNetStorageRPC *netstorage_rpc, CNetService service, TBuilder builder, const string &object_loc)

ERW_Result Read(void *buf, size_t count, size_t *bytes_read) override

Read as many as "count" bytes into a buffer pointed to by the "buf" argument.

string FileTrack_Path() override

function< CJsonNode(const string &, const string &)> TBuilder

ERW_Result PendingCount(size_t *count) override

Via parameter "count" (which is guaranteed to be supplied non-NULL) return the number of bytes that a...

ERW_Result Write(const void *buf, size_t count, size_t *bytes_written) override

Write up to "count" bytes from the buffer pointed to by the "buf" argument onto the output device.

SNetStorageObjectImpl * Open(const string &object_loc) override

SNetStorageObjectImpl * Create(TNetStorageFlags flags) override

CJsonNode MkStdRequest(const string &request_type) const

TNetStorageFlags GetFlags(TNetStorageFlags flags) const

map< string, CNetService > m_ServiceMap

CNetService GetServiceIfLocator(const string &object_loc)

CNetCacheAPI m_NetCacheAPI

CCompoundIDPool m_CompoundIDPool

CJsonNode MkObjectRequest(const string &request_type, const string &object_loc) const

CJsonNode Exchange(CNetService service, const CJsonNode &request, CNetServerConnection *conn=NULL, CNetServer::TInstance server_to_use=NULL) const

EVoid x_InitNetCacheAPI()

CAtomicCounter m_RequestNumber

SNetStorageRPC(const TConfig &config, TNetStorageFlags default_flags)

static EErrMode GetErrMode(const string &)

void ParseArg(const string &, const string &)

static EDefaultStorage GetDefaultStorage(const string &)

void Validate(const string &)

EDefaultStorage default_storage

static SNetStorageImpl * CreateImpl(const SConfig &, TNetStorageFlags)

static SNetStorageByKeyImpl * CreateByKeyImpl(const SConfig &, TNetStorageFlags)

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