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

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

NCBI C++ ToolKit: src/app/netstorage/nst_handler.cpp Source File

std::placeholders;

need_progress_report) :

m_Handler(

), m_CommonArgs(common_args), m_Object(object),

m_NeedProgressReport(need_progress_report)

m_JSONWriter(m_UTTPWriter),

m_ObjectBeingWritten(

),

m_ByeReceived(

),

m_FirstMessage(

),

m_WriteCreateNeedMetaDBUpdate(

)

<<

<<

(status) <<

);

<<

<<

(status) <<

);

<<

<<

(status) <<

);

(

<< e <<

);

(

exception & ex) {

(

<<

(

);

(read_count > 0 || write_count > 0)) {

<< status <<

<<

(status));

(

);

(

);

(

);

(

);

(uttp_event) {

(

);

(

<< ex <<

);

,

);

,

);

,

NetStorageServer_ErrorCode);

error_client_message;

(this->*processor)(message, common_args);

(error_sub_code !=

error_client_message = ex.

();

error_client_message = ex.

();

&error_sub_code) ==

) {

(

std::exception & ex) {

(

<< ex);

error_client_message = ex.

();

error_client_message =

;

error_client_message,

error_scope, error_sub_code);

(

<< data_size <<

);

(

exception & ex) {

, start);

error_sub_code;

&error_code, &error_sub_code) ==

) {

, start);

message =

+

}

(

exception & ex) {

message =

+

error_sub_code;

&error_sub_code) ==

) {

(reply, error_code, message, error_scope, error_sub_code);

locator = object_loc_struct.

();

size_was_null =

;

}

(

exception & ex) {

message =

+

locator +

+ ex.what();

error_sub_code;

&error_sub_code) ==

) {

(reply, error_code, message, error_scope,

error_sub_code,

);

message =

+ locator +

;

size_was_null =

;

object_key, object_expiration,

individual_object_ttl);

individual_object_ttl),

object_expiration, size_was_null);

}

(

exception & ex) {

message =

+

locator +

+ ex.what();

error_sub_code;

&error_sub_code) ==

) {

(reply, error_code, message, error_scope,

error_sub_code,

);

message =

+ locator +

;

* output_buffer,

output_buffer_size)

+

(status) +

;

(output_buffer_size > 32) {

buffer_head(output_buffer, output_buffer_size);

(status != eIO_Closed) {

* output_buffer;

output_buffer_size;

bytes_written;

(output_buffer_size > 0) {

output_buffer, output_buffer_size);

output_buffer += bytes_written;

output_buffer_size -= bytes_written;

setsockopt(fd, IPPROTO_TCP, TCP_QUICKACK, &

,

(

));

.Print(

,

)

peer_addr;

);

.Print(

,

)

= it.GetKey();

(

==

)

(

==

)

(

==

||

==

)

ctxt_extra.

();

(!timing.empty())

protocol_version;

(!message.

(

)) {

);

);

SNetStorage::SLimits::Check<SNetStorage::SLimits::SClientName>(

);

(message.

(

))

application = message.

(

);

(message.

(

))

ticket = message.

(

);

(message.

(

)) {

protocol_version = ver.

();

);

(message.

(

))

reply.

(

,

(converter));

reply.

(

,

reply.

(

,

db_stat_node.

(

, connected);

ExecSP_GetGeneralDBInfo();

k != db_stat.

(); ++k)

db_stat_node.

(k->first, k->second);

k != db_stat.

(); ++k)

db_stat_node.

(k->first, k->second);

}

(

exception & ex) {

,

reply.

(

, db_stat_node);

=

;

(!message.

(

))

);

(!message.

(

))

);

(ack_result) {

,

,

=

vector<string> config_warnings;

(!config_warnings.empty()) {

(vector<string>::const_iterator k = config_warnings.begin();

k != config_warnings.end(); ++k) {

(!

.empty()) {

+

);

decrypt_warning;

params.

(candidate_reg,

, decrypt_warning);

(!decrypt_warning.empty()) {

vector<string> config_checksum_warnings;

(config_checksum_warnings.empty()) {

(vector<string>::const_iterator

k = config_checksum_warnings.begin();

k != config_checksum_warnings.end(); ++k)

(server_diff.

() &&

metadata_diff.

() &&

backend_diff.

() &&

,

(!server_diff.

())

total_changes.

(

, server_diff);

(!metadata_diff.

())

total_changes.

(

, metadata_diff);

(!backend_diff.

())

total_changes.

(

, backend_diff);

total_changes.

(

, db_diff);

reply.

(

, total_changes);

=

;

(!message.

(

)) {

);

(

!=

&&

!=

) {

);

(

==

)

vector<string> client_names;

reply.

(

,

);

,

(vector<string>::const_iterator

k = client_names.begin(); k != client_names.end(); ++k) {

reply.

(

, db_clients_node);

}

(

exception & ex) {

reply.

(

,

);

error_sub_code;

&error_sub_code) ==

)

+

(ex.what()),

error_scope, error_sub_code);

reply.

(

,

);

,

reply.

(

,

);

vector< pair<string, string> > users;

(vector< pair<string, string> >::const_iterator

k = users.begin(); k != users.end(); ++k) {

a_user.

(

, (*k).first);

a_user.

(

, (*k).second);

reply.

(

, u_list);

}

(

exception & ex) {

,

need_db_access =

;

service_properties);

(need_db_access) {

ExecSP_GetObjectFixedAttributes(

expiration, creation,

obj_read, obj_write,

attr_read, attr_write,

read_count, write_count,

user_namespace, user_name,

reply.

(

,

);

reply.

(

,

);

expiration.

.AsString());

reply.

(

,

);

reply.

(

,

);

reply.

(

,

);

reply.

(

, service_properties.

}

(

exception & ex) {

error_sub_code;

&error_sub_code) ==

)

+

(ex.

()), error_scope, error_sub_code);

,

remote_info_error =

;

= it.GetKey();

(

!=

)

reply.

(it.GetKey(), it.GetNode());

remote_info_error =

;

}

(

exception & ex) {

error_sub_code;

&error_sub_code) ==

)

+

(ex.what()), error_scope, error_sub_code);

=

;

need_client_update =

;

(need_db_access && user_name.

&& remote_info_error ==

) {

pair<string, string> ns_and_name = direct_object.

();

remote_client.

(ns_and_name.second);

reply.

(

, ns_and_name.first);

reply.

(

, ns_and_name.second);

need_client_update =

;

}

(

exception & ex) {

(

<< ex);

(

);

(need_client_update) {

}

(

exception & ex) {

(

<< ex);

(

);

& name,

(

.m_IsNull)

& name,

(

.m_IsNull)

& name,

(

.m_IsNull)

(!message.

(

) && !message.

(

))

);

);

vector<string> attr_names;

object_key, attr_names);

(vector<string>::const_iterator k = attr_names.begin();

k != attr_names.end(); ++k)

.AppendString(*k);

);

(!message.

(

))

);

(message.

(

)) {

);

);

vector<string> locators;

total_client_objects;

total_client_objects, locators);

(vector<string>::const_iterator k = locators.begin();

k != locators.end(); ++k)

reply.

(

, locators_node);

reply.

(

, total_client_objects);

+ client_name +

);

);

(!message.

(

))

);

(!message.

(

))

);

message.

(

));

(message.

(

)) {

);

);

vector<string> locators;

total_client_objects;

user_name, user_namespace, limit,

total_client_objects, locators);

(vector<string>::const_iterator k = locators.begin();

k != locators.end(); ++k)

reply.

(

, locators_node);

reply.

(

, total_client_objects);

);

);

(!message.

(

))

);

attr_name = message.

(

);

(attr_name.empty())

);

(!message.

(

) && !message.

(

))

);

);

object_key, attr_name,

);

eNetStorageAttributeValueNotFound,

);

);

(!message.

(

))

);

attr_name = message.

(

);

SNetStorage::SLimits::Check<SNetStorage::SLimits::SAttrName>(attr_name);

(!message.

(

))

);

SNetStorage::SLimits::Check<SNetStorage::SLimits::SAttrValue>(

);

(!message.

(

) && !message.

(

))

);

);

create_if_not_found =

;

(message.

(

))

create_if_not_found = message.

(

);

object_key, object_loc,

);

(!message.

(

))

);

attr_name = message.

(

);

(attr_name.empty())

);

(!message.

(

) && !message.

(

))

);

);

object_key, attr_name);

}

(status == -2) {

,

}

(status == -3) {

,

);

);

reply.

(

, locator);

.

(

, locator)

(!message.

(

) && !message.

(

))

);

);

locator = object_locator.

();

create_if_not_found =

;

(message.

(

)) {

create_if_not_found = message.

(

);

(create_if_not_found ==

) {

reply.

(

, locator);

(!message.

(

) && !message.

(

))

);

need_meta_db_update =

;

service_properties);

locator = object_locator.

();

allow_backend_fallback =

;

(message.

(

)) {

allow_backend_fallback = message.

(

);

(need_meta_db_update) {

(allow_backend_fallback ==

) {

total_bytes = 0;

(!direct_object.

()) {

total_bytes += bytes_read;

direct_object.

();

}

(

exception & ex) {

error_sub_code;

message =

+

(ex.what());

&error_sub_code) ==

)

error_code, message, error_scope, error_sub_code);

(need_meta_db_update)

need_meta_db_update =

;

.

(

, start);

(need_meta_db_update)

(need_meta_db_update) {

size_was_null =

;

individual_object_ttl);

service_properties.

(),

object_expiration, size_was_null);

}

(

exception & ex) {

error_sub_code;

&error_sub_code) ==

)

(reply, error_code, ex.what(), error_scope,

error_sub_code,

);

=

;

& object_key,

(

<< op);

individual_object_ttl);

(!object_expiration.

) {

(

<< op);

object_key, service_props.

(),

prolong, object_expiration);

}

(

std::exception & ex) {

<< ex);

(

<<

<<

);

(!message.

(

) && !message.

(

))

);

);

need_meta_db_update =

;

service_properties);

allow_backend_fallback =

;

(message.

(

)) {

allow_backend_fallback = message.

(

);

(need_meta_db_update) {

(allow_backend_fallback ==

) {

(!message.

(

)) {

);

);

need_meta_db_update =

;

service_properties);

create_if_not_found =

;

(message.

(

)) {

create_if_not_found = message.

(

);

need_progress_report =

;

(message.

(

)) {

need_progress_report = message.

(

);

(need_meta_db_update) {

(create_if_not_found ==

) {

new_object_loc;

need_progress_report);

new_object_loc = direct_object.

(new_location_flags, cb);

(

<< ex);

(need_meta_db_update)

service_properties);

(need_meta_db_update)

service_properties);

(need_meta_db_update)

service_properties);

(need_meta_db_update) {

individual_object_ttl);

object_key, new_object_loc,

individual_object_ttl),

}

(

exception & ex) {

error_sub_code;

&error_sub_code) ==

)

(reply, error_code, ex.what(), error_scope,

error_sub_code,

);

=

;

reply.

(

, new_object_loc);

.

(

, new_object_loc);

need_db_access =

service_properties);

locator_from_db;

(need_db_access) {

db_error =

;

object_size, object_locator);

locator_from_db = object_locator.

;

}

(

exception & ex) {

(

);

exists =

;

(message.

(

)) {

exists = storage.

(locator_from_db,

exists = storage.

(locator_from_db,

consult_backend_if_no_db_record =

;

(message.

(

)) {

consult_backend_if_no_db_record =

message.

(

);

object_size_is_null =

;

need_db_access =

service_properties);

(need_db_access) {

object_key, db_object_size);

object_size_is_null =

;

object_size = 0;

(object_size_is_null || consult_backend_if_no_db_record) {

object_size = direct_object.

();

(object_size_is_null) {

}

(

exception & ex) {

(

);

db_object_size.

= object_size;

object_key, db_object_size);

object_size = db_object_size.

;

}

(

exception & ex) {

(

);

(!message.

(

))

);

arg_val = message.

(

);

}

(

exception & ex) {

+

(ex.what()));

);

);

(!message.

(

) && !message.

(

))

);

);

db_update =

;

db_error =

;

create_if_not_found =

;

(message.

(

))

create_if_not_found = message.

(

);

create_if_not_found,

}

(

exception & ex) {

error_sub_code;

&error_sub_code) ==

)

(reply, error_code, ex.what(), error_scope,

,

(db_error ==

)

(ttl.

|| (db_update && !db_error))

}

(

exception & ex) {

error_sub_code;

&error_sub_code) ==

) {

=

;

(!message.

(

) && !message.

(

))

);

);

individual_object_ttl);

(!object_expiration.

) {

service_properties.

(),

individual_object_ttl),

}

(

std::exception & ex) {

(

<< ex);

(

);

.

(

, start);

warn_count = warnings_listener.

();

(

k = 0; k < warn_count; ++k) {

need_fake_write)

(message.

(

)) {

object_loc = message.

(

);

(need_fake_write) {

.Write(

, 0);

.

(

,

.Locator().GetUniqueKey());

new_loc =

.Locator().GetLocator();

(new_loc != object_loc)

.

(

,

.Locator().GetLocator());

(need_fake_write) {

.Write(

, 0);

.

(

,

.Locator().GetUniqueKey())

.

(

,

.Locator().GetLocator());

(object_loc.empty()) {

);

);

);

* output_buffer;

output_buffer_size;

(output_buffer_size > 0) {

().

(output_buffer, output_buffer_size, &written);

output_buffer, output_buffer_size);

(!message.

(

))

message =

;

(vector<string>::const_iterator k = valid.begin();

k != valid.end(); ++k) {

(k != valid.begin())

);

);

expect_object)

(expect_object && message.

(

)) {

object_loc = message.

(

);

);

(service.empty())

+ service +

);

+ service +

);

+ service +

);

(expect_object) {

);

+

+

);

+

+

);

+

+

);

(message.

(

)) {

object_loc = message.

(

);

(service.empty())

service_configured;

(!service_configured)

+ service +

);

(!service_configured)

+

+

);

service_configured;

(!service_configured)

+

+

);

service_configured;

(message.

(

)) {

object_loc = message.

(

);

(service.empty())

service_configured;

service_configured;

(!user_name.empty()) {

& user_message

}

(

exception & ex) {

(to_test_setexp_support != 0)

(to_test_setexp_support->

() ==

error_sub_code;

&error_sub_code) ==

)

(reply, error_code, ex.what(), error_scope,

error_sub_code,

);

=

+ user_message +

;

+ op);

CDirectNetStorageObject Open(const string &unique_key, TNetStorageFlags flags=0)

bool Exists(const string &db_loc, const string &key, TNetStorageFlags flags)

ENetStorageRemoveResult Remove()

const CNetStorageObjectLoc & Locator()

string Relocate(TNetStorageFlags flags, TNetStorageProgressCb cb=TNetStorageProgressCb())

pair< string, string > GetUserInfo()

CDirectNetStorageObject Open(const string &object_loc)

CDirectNetStorageObject Create(const string &service_name, TNetStorageFlags flags)

bool Exists(const string &db_loc, const string &client_loc)

Iterator for JSON arrays and objects.

Int8 AsInteger() const

Provided that this is a numeric node (that is, either an integer or a floating point node),...

bool IsNull() const

Return true for a null node. Return false otherwise.

static CJsonNode NewArrayNode()

Create a new JSON array node.

void SetDouble(const string &key, double value)

Set a JSON object element to the specified floating point value.

bool HasKey(const string &key) const

Check if an object node has an element accessible by the specified key.

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.

void AppendString(const string &value)

For an array node, add a string node at the end of the array.

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.

ENodeType GetNodeType() const

Return a ENodeType constant identifying the node type.

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.

bool GetBoolean(const string &key) const

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

bool IsObject() const

Return true for a JSON object. Return false otherwise.

ENodeType

JSON node type.

static CJsonNode NewObjectNode()

Create a new JSON object node.

void Append(CJsonNode::TInstance value)

For an array node, add a new element at the end of the array.

CJsonNode GetByKey(const string &key) const

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

Exception class for use by CJsonNode.

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)

~CMessageListenerResetter()

CMessageListenerResetter()

Default implementation of IMessageListener: collects all messages posted.

void AddBytesRead(const string &client, size_t count)

void AddObjectsWritten(const string &client, size_t count)

void AddObjectsRead(const string &client, size_t count)

void Touch(const string &client, const string &applications, const string &ticket, const string &service, const string &protocol_version, EMetadataOption metadataOption, unsigned int peer_address)

void AddObjectsDeleted(const string &client, size_t count)

void SetDBClientID(const string &client, Int8 id)

void AddBytesWritten(const string &client, size_t count)

CJsonNode Serialize(void) const

void RegisterSocketWriteError(const string &client)

void AppendType(const string &client, unsigned int type_to_append)

void AddObjectsRelocated(const string &client, size_t count)

int ExecSP_GetAttribute(const string &object_key, const string &attr_name, bool need_update, string &value)

int ExecSP_GetObjectExpiration(const string &object_key, TNSTDBValue< CTime > &expiration, TNSTDBValue< Int8 > &individual_object_ttl)

int ExecSP_GetClientObjects(const string &client_name, TNSTDBValue< Int8 > limit, Int8 &total, vector< string > &locators)

bool IsConnected(void) const

int ExecSP_UpdateObjectOnRead(const string &object_key, const string &object_loc, Int8 size, Int8 client_id, const TNSTDBValue< CTimeSpan > &ttl, const TNSTDBValue< CTimeSpan > &prolong_on_read, const TNSTDBValue< CTime > &object_expiration, bool &size_was_null)

int ExecSP_SetExpiration(const string &object_key, const TNSTDBValue< CTimeSpan > &ttl, bool create_if_not_found, const string &object_loc, Int8 client_id, TNSTDBValue< Int8 > &object_size)

int ExecSP_GetUsers(vector< pair< string, string > > &users)

int ExecSP_UpdateUserIDForObject(const string &object_key, Int8 user_id)

int ExecSP_GetClients(vector< string > &names)

int ExecSP_UpdateObjectOnRelocate(const string &object_key, const string &object_loc, Int8 client_id, const TNSTDBValue< CTimeSpan > &ttl, const TNSTDBValue< CTimeSpan > &prolong_on_relocate, const TNSTDBValue< CTime > &object_expiration)

int ExecSP_CreateClient(const string &client, Int8 &client_id)

map< string, string > ExecSP_GetStatDBInfo(void)

int ExecSP_GetUserObjects(const string &user_name, const string &user_name_space, TNSTDBValue< Int8 > limit, Int8 &total, vector< string > &locators)

int ExecSP_UpdateObjectOnWrite(const string &object_key, const string &object_loc, Int8 size, Int8 client_id, Int8 user_id, const TNSTDBValue< CTimeSpan > &ttl, const TNSTDBValue< CTimeSpan > &prolong_on_write, const TNSTDBValue< CTime > &object_expiration, bool &size_was_null)

int ExecSP_AddAttribute(const string &object_key, const string &object_loc, const string &attr_name, const string &attr_value, Int8 client_id, bool create_if_not_found, const TNSTDBValue< CTimeSpan > &ttl)

int UpdateExpirationIfExists(const string &object_key, const TNSTDBValue< CTimeSpan > &ttl, const TNSTDBValue< CTimeSpan > &prolong_on_read, const TNSTDBValue< CTime > &object_expiration)

int ExecSP_CreateObjectWithClientID(const string &object_key, const string &object_loc, Int8 size, Int8 client_id, Int8 user_id, const TNSTDBValue< CTimeSpan > ttl, bool &size_was_null)

int ExecSP_DoesObjectExist(const string &object_key)

int ExecSP_GetObjectSize(const string &object_key, TNSTDBValue< Int8 > &object_size)

CTimeout GetExecuteSPTimeout(void)

int ExecSP_GetObjectSizeAndLocator(const string &object_key, TNSTDBValue< Int8 > &object_size, TNSTDBValue< string > &object_locator)

int ExecSP_RemoveObject(const string &object_key)

int ExecSP_GetAttributeNames(const string &object_key, vector< string > &attr_names)

int ExecSP_DelAttribute(const string &object_key, const string &attr_name)

CJsonNode SetParameters(const IRegistry &reg)

int ExecSP_UpdateObjectSizeIfNULL(const string &object_key, TNSTDBValue< Int8 > &object_size)

int ExecSP_CreateUser(const CNSTUserID &user, Int8 &user_id)

static CNSTPreciseTime Current(void)

TNSTDBValue< CTimeSpan > GetProlongOnWrite(const TNSTDBValue< Int8 > &individual_obj_ttl) const

TNSTDBValue< CTimeSpan > GetTTL(void) const

TNSTDBValue< CTimeSpan > GetProlongOnRead(const TNSTDBValue< Int8 > &individual_obj_ttl) const

TNSTDBValue< CTimeSpan > GetProlongOnRelocate(const TNSTDBValue< Int8 > &individual_obj_ttl) const

string Serialize(CDiagContext_Extra extra)

void Append(const string &what, const CNSTPreciseTime &how_long)

Int8 GetDBUserID(const CNSTUserID &user) const

void SetDBUserID(const CNSTUserID &user, Int8 id)

void SetNamespace(const string &name_space_)

void SetName(const string &name_)

static CNcbiApplication * Instance(void)

Singleton method.

static void Reload(void)

Re-read key file locations and domain paths, reload encryption keys.

CNcbiOstrstreamToString class helps convert CNcbiOstrstream to a string Sample usage:

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

EIO_Status x_SendSyncMessage(const CJsonNode &message, ESocketTimeoutTreat timeout_treat=eTimeoutIsError)

string x_GetConnRef(void)

virtual void OnRead(void)

The client has just sent data.

void x_SetObjectInfoReply(CJsonNode &reply, const string &name, const TNSTDBValue< CTime > &value)

void x_ProcessHello(const CJsonNode &message, const SCommonRequestArguments &common_args)

void x_CheckExistanceStatus(int status)

void x_SendAsyncMessage(const CJsonNode &message)

virtual void OnOpen(void)

Runs in response to an external event [asynchronous].

void x_CheckNonAnonymousClient(const string &op) const

void x_ProcessConfiguration(const CJsonNode &message, const SCommonRequestArguments &common_args)

void x_ProcessSetExpTime(const CJsonNode &message, const SCommonRequestArguments &common_args)

bool x_DetectMetaDBNeedOnGetObjectInfo(const CJsonNode &message, CNSTServiceProperties &props) const

void x_PrintMessageRequestStart(const CJsonNode &message)

unsigned int x_GetPeerAddress(void)

void x_ProcessWrite(const CJsonNode &message, const SCommonRequestArguments &common_args)

void x_ProcessSetAttr(const CJsonNode &message, const SCommonRequestArguments &common_args)

void x_CheckUserKey(const SUserKey &user_key)

TNSTDBValue< CTimeSpan > m_CreateTTL

virtual EIO_Event GetEventsToPollFor(const CTime **alarm_time) const

Following three methods are guaranteed to be called NOT at the same time as On*, so if you implement ...

CDirectNetStorageObject x_CreateObjectStream(const SICacheSettings &icache_settings, TNetStorageFlags flags)

void x_ProcessGetSize(const CJsonNode &message, const SCommonRequestArguments &common_args)

EIO_Status x_SendOutputBuffer(ESocketTimeoutTreat timeout_treat)

void x_ProcessAckAlert(const CJsonNode &message, const SCommonRequestArguments &common_args)

void(CNetStorageHandler::* FProcessor)(const CJsonNode &, const SCommonRequestArguments &)

CRef< CRequestContext > m_ConnContext

void x_ProcessRead(const CJsonNode &message, const SCommonRequestArguments &common_args)

void x_CreateConnContext(void)

void x_ProcessGetClientObjects(const CJsonNode &message, const SCommonRequestArguments &comm_args)

void x_ProcessGetObjectInfo(const CJsonNode &message, const SCommonRequestArguments &common_args)

virtual void OnWrite(void)

The client is ready to receive data.

void x_ProcessShutdown(const CJsonNode &message, const SCommonRequestArguments &common_args)

void x_ProcessReconfigure(const CJsonNode &message, const SCommonRequestArguments &common_args)

CNetStorageHandler(CNetStorageServer *server)

void x_ProcessGetClientsInfo(const CJsonNode &message, const SCommonRequestArguments &common_args)

void x_SetConnRequestStatus(unsigned int status)

void x_SetQuickAcknowledge(void)

void x_CreateClient(void)

CNSTServiceProperties m_WriteServiceProps

void x_PrintMessageRequestStop(void)

void x_FillObjectInfo(CJsonNode &reply, const string &val)

void x_ProcessGetUsersInfo(const CJsonNode &message, const SCommonRequestArguments &common_args)

char m_WriteBuffer[kWriteBufferSize]

virtual void OnOverflow(EOverflowReason reason)

Runs when there are insufficient resources to queue a connection, prior to closing it.

void x_ProcessGetMetadataInfo(const CJsonNode &message, const SCommonRequestArguments &common_args)

virtual void OnTimeout(void)

Runs when a client has been idle for too long, prior to closing the connection [synchronous].

void x_ProcessDelAttr(const CJsonNode &message, const SCommonRequestArguments &common_args)

void x_OnSocketWriteError(EIO_Status status, size_t bytes_written, const char *output_buffer, size_t output_buffer_size)

void x_ProcessGetAttrList(const CJsonNode &message, const SCommonRequestArguments &common_args)

CFastMutex m_OutputQueueMutex

void x_CheckExpirationStatus(int status)

EMetadataOption x_ConvertMetadataArgument(const CJsonNode &message) const

CDirectNetStorageObject m_ObjectBeingWritten

void x_ProcessRelocate(const CJsonNode &message, const SCommonRequestArguments &common_args)

virtual void OnClose(IServer_ConnectionHandler::EClosePeer peer)

The connection has closed (with information on type of closing)

CNetStorageServer * m_Server

void x_ProcessBye(const CJsonNode &message, const SCommonRequestArguments &common_args)

void x_ProcessGetAttr(const CJsonNode &message, const SCommonRequestArguments &common_args)

EIO_Status x_SendOverUTTP()

CRef< CRequestContext > m_CmdContext

CDirectNetStorageObject x_GetObject(const CJsonNode &message, bool need_fake_write=false)

bool x_DetectMetaDBNeedUpdate(const CJsonNode &message, CNSTServiceProperties &props) const

void x_ProcessInfo(const CJsonNode &message, const SCommonRequestArguments &common_args)

bool m_WriteCreateNeedMetaDBUpdate

CJsonOverUTTPWriter m_JSONWriter

Int8 x_GetUserID(const CNSTUserID &user)

void x_ProcessLockFTPath(const CJsonNode &message, const SCommonRequestArguments &common_args)

void x_CheckICacheSettings(const SICacheSettings &icache_settings)

void x_OptionalExpirationUpdate(CDirectNetStorageObject &object, CJsonNode &reply, const string &user_message)

static SProcessorMap sm_Processors[]

bool x_DetectMetaDBNeedOnCreate(TNetStorageFlags flags)

EMetadataOption m_MetadataOption

void x_ProcessGetUserObjects(const CJsonNode &message, const SCommonRequestArguments &comm_args)

char m_ReadBuffer[kReadBufferSize]

Int8 x_GetClientID(const string &client)

void x_GetStorageParams(const CJsonNode &message, SICacheSettings *icache_settings, SUserKey *user_key, TNetStorageFlags *flags)

void x_SendWriteConfirmation()

vector< CJsonNode > m_OutputQueue

void x_ProlongObjectOnFailure(EOp operation, const string &object_key, const CNSTServiceProperties &service_props)

void x_ProcessCreate(const CJsonNode &message, const SCommonRequestArguments &common_args)

void x_ProcessDelete(const CJsonNode &message, const SCommonRequestArguments &common_args)

FProcessor x_FindProcessor(const SCommonRequestArguments &common_args)

void x_CheckObjectLoc(const string &object_loc) const

CJsonOverUTTPReader m_JSONReader

void x_OnData(const void *data, size_t data_size)

void x_ValidateWriteMetaDBAccess(const CJsonNode &message, bool expect_object=true) const

void x_OnMessage(const CJsonNode &message)

void x_ProcessHealth(const CJsonNode &message, const SCommonRequestArguments &common_args)

void x_ProcessExists(const CJsonNode &message, const SCommonRequestArguments &common_args)

void x_SetCmdRequestStatus(unsigned int status)

string GetLocator() const

bool IsMetaDataDisabled() const

string GetServiceName() const

string GetUniqueKey() const

@ eNetStorageAttributeValueNotFound

@ eNetStorageAttributeNotFound

unsigned int ErrCodeToHTTPStatusCode(void) const

CJsonNode SetParameters(const SNetStorageServerParameters &new_params, bool reconfigure)

CJsonNode GetBackendConfDiff(const CJsonNode &conf) const

void SetRAMConfigFileChecksum(const string &checksum)

CNSTDatabase & GetDb(void)

bool AnybodyCanReconfigure(void) const

void ResetDecryptCacheIfNeed(void)

enum EAlertAckResult AcknowledgeAlert(const string &id, const string &user)

string GetSessionID(void) const

unsigned int GetNetworkTimeout(void) const

void RegisterNetStorageAPIDecryptError(const string &message)

void SetAnybodyCanReconfigure(bool val)

CJsonNode SerializeAlerts(void) const

void ReportNetStorageAPIDecryptSuccess(void)

void RegisterAlert(EAlertType alert_type, const string &messge)

CNSTClientRegistry & GetClientRegistry(void)

bool IsAdminClientName(const string &name) const

CJsonNode GetBackendConfiguration(void) const

virtual bool ShutdownRequested(void)

Runs synchronously between iterations.

const CNSTPreciseTime & GetStartTime(void) const

void SetBackendConfiguration(const CJsonNode &conf)

EServiceMetadataPresence InMetadataServices(const string &service) const

bool GetServiceProperties(const string &service, CNSTServiceProperties &service_props) const

bool GetServiceTTL(const string &service, TNSTDBValue< CTimeSpan > &ttl) const

string GetCommandLine(void) const

CJsonNode ReadMetadataConfiguration(const IRegistry &reg)

CCompoundIDPool GetCompoundIDPool(void) const

void SetDiskConfigFileChecksum(const string &checksum)

bool IsLogTimingClientSocket() const

const bool & IsLog() const

bool IsLogTimingNSTAPI() const

CJsonNode SerializeMetadataInfo(void) const

CNSTUserCache & GetUserCache(void)

void SetShutdownFlag(int signum=0)

unsigned int GetHostNetAddr() const

const SCommonRequestArguments & m_CommonArgs

CNetStorageHandler & m_Handler

CRelocateCallback(CNetStorageHandler &handler, const SCommonRequestArguments &common_args, CDirectNetStorageObject &object, bool need_progress_report)

void Callback(CJsonNode info)

CDirectNetStorageObject & m_Object

bool m_NeedProgressReport

~CRequestContextResetter()

CRequestContextResetter()

Request context properties passed between tasks.

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

CTimeout – Timeout interval.

EStreamParsingEvent GetNextEvent()

Parse the input buffer until a parsing event occurs.

char GetControlSymbol() const

Return the control symbol that has been just read.

EStreamParsingEvent

Enumeration of the input stream parsing events.

@ 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.

const char * GetChunkPart() const

Return a pointer to the buffer that contains a part of the chunk currently being read.

void SetNewBuffer(const char *buffer, size_t buffer_size)

Start processing of the next chunk of data.

size_t GetChunkPartSize() const

Return the size of the buffer returned by the GetChunkPart() method.

bool SendControlSymbol(char symbol)

Send a control symbol over the output buffer.

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.

bool SendChunk(const char *chunk, size_t chunk_length, bool to_be_continued)

Send a chunk of data to the output buffer.

void Reset(char *buffer, size_t buffer_size)

Initialize or reinitialize this object.

const_iterator begin() const

const_iterator end() const

void(*)(CSeq_entry_Handle seh, IWorkbench *wb, const CSerialObject &obj) handler

static const struct name_t names[]

bool ReloadConfig(CMetaRegistry::TFlags flags=CMetaRegistry::fReloadIfChanged, IRegistry::TFlags reg_flags=IRegistry::fWithNcbirc)

Reload the configuration file.

const CNcbiRegistry & GetConfig(void) const

Get the application's cached configuration parameters (read-only).

const string & GetConfigPath(void) const

Get the full path to the configuration file (if any) we ended up using.

@ eNegative

Value is negative.

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.

void SetBytesWr(Int8 bytes)

int GetRequestStatus(void) const

Request exit status.

string GetStringUID(TUID uid=0) const

Return string representation of UID.

CDiagContext & GetDiagContext(void)

Get diag context instance.

static void SetRequestContext(CRequestContext *ctx)

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

void PrintRequestStart(const string &message)

Print request start message (for request-driven applications)

void SetRequestID(TCount rid)

Set request ID.

CDiagContext_Extra Extra(void) const

Create a temporary CDiagContext_Extra object.

void SetClientIP(const string &client)

const string & Get(CTempString name) const

Get current property value or empty string if it's not set;.

#define NCBI_ERRCODE_X_NAME(name)

Returns value of error code by its name defined by NCBI_DEFINE_ERRCODE_X.

TCount GetRequestID(void) const

Get request ID (or zero if not set).

static TPID GetPID(void)

Get cached PID (read real PID if not cached yet).

void SetRequestStatus(int status)

void SetHitID(const string &hit)

Set explicit hit id. The id is reset on request end.

void Flush(void)

Print the message and reset object.

void SetBytesRd(Int8 bytes)

#define ERR_POST(message)

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

virtual const char * GetType(void) const

Get class name as a string.

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)

virtual const char * what(void) const noexcept

Standard report (includes full backlog).

virtual int GetSubCode(void) const =0

Get error subcode. Zero = not set.

virtual size_t Count(void) const

Get total number of collected messages.

virtual string GetText(void) const =0

Get text message.

virtual const IMessage & GetMessage(size_t index) const

Get a previously collected message.

virtual int GetCode(void) const =0

Get error code. Zero = not set.

static size_t PushListener(IMessageListener &listener, EListenFlag flag=eListen_Unhandled)

Push a new listener to the stack in the current thread.

static void PopListener(size_t depth=0)

Remove listener(s) from the current thread's stack.

bool Eof(void)

Check if the last Read() has hit EOF.

string GetLoc(void) const

Return object locator.

unsigned TNetStorageFlags

Bitwise OR of ENetStorageFlags.

void Write(const void *buffer, size_t buf_size)

Write data to the object (starting at the current position)

size_t Read(void *buffer, size_t buf_size)

Read no more than 'buf_size' bytes of the object contents (starting at the current position)

void SetExpiration(const CTimeout &ttl)

Updates expiration on the object.

void Close(void)

Finalize and close the current object stream.

Uint8 GetSize(void)

Return size of the object.

CNetStorageObjectInfo GetInfo(void)

Return detailed information about the object.

CJsonNode ToJSON()

Pack the whole structure in a single JSON object.

function< void(CJsonNode)> TNetStorageProgressCb

Progress callback.

ENetStorageRemoveResult

Result returned by Remove() methods.

@ fNST_NoMetaData

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

@ eNotSupported

Feature is not supported.

@ eNotExists

Illegal op applied to non-existent object.

@ eInterrupted

Operation has been interrupted.

@ eNSTRR_NotFound

Removing failed due to object not found.

bool NotNull(void) const THROWS_NONE

Check if pointer is not null – same effect as NotEmpty().

void Reset(void)

Reset reference object.

bool IsNull(void) const THROWS_NONE

Check if pointer is null – same effect as Empty().

int64_t Int8

8-byte (64-bit) signed integer

uint64_t Uint8

8-byte (64-bit) unsigned integer

bool Write(CNcbiOstream &os, TFlags flags=0) const

Write the registry content to output stream.

@ eDecryptionFailed

Value looked encrypted, but decryption failed.

EIO_Status Shutdown(EIO_Event how)

Shutdown socket I/O in the specified direction.

virtual EIO_Status GetOSHandle(void *handle_buf, size_t handle_size, EOwnership ownership=eNoOwnership) const

Access to the system-specific socket handle.

static CNCBI_IPAddr GetLoopbackAddress(void)

Loopback address is in network byte order (when "unsigned int")

EIO_Status SetTimeout(EIO_Event event, const STimeout *timeout)

Set timeout for I/O in the specified direction.

void DisableOSSendDelay(bool on_off=true)

EIO_Status GetStatus(EIO_Event direction) const

Return status of *last* I/O operation without making any actual I/O.

TNCBI_BigCount GetCount(EIO_Event direction) const

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.

@ eSAF_IP

only numeric IP if INET socket, empty otherwise

IO_PREFIX::ifstream CNcbiIfstream

Portable alias for ifstream.

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

Get a printable version of the specified string.

static bool EqualNocase(const CTempString s1, SIZE_TYPE pos, SIZE_TYPE n, const char *s2)

Case-insensitive equality of a substring with another string.

TErrCode GetErrCode(void) const

Get error code.

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 TruncateSpaces(const string &str, ETrunc where=eTrunc_Both)

Truncate whitespace in a string.

static string & ToLower(string &str)

Convert string to lower case – string& version.

EClosePeer

Type of connection closing.

void WakeUpPollCycle(void)

Force poll cycle to make another iteration.

EOverflowReason

Error codes for OnOverflow method in IServer_ConnectionHandler.

void CloseConnection(CSocket *sock)

Close connection.

CSocket & GetSocket(void)

Get underlying socket.

@ eClientClose

Connection closed by other peer.

@ eOurClose

Connection closed by ourselves.

bool IsEmpty(void) const

Return TRUE is an object keep zero time span.

double GetAsDouble(void) const

Get as number of seconds (fractional value).

ESign GetSign(void) const

Get sign of time span.

CTime CurrentTime(CTime::ETimeZone tz=CTime::eLocal, CTime::ETimeZonePrecision tzp=CTime::eTZPrecisionDefault)

string AsSmartString(ESmartStringPrecision precision, ERound rounding, ESmartStringZeroMode zero_mode=eSSZ_SkipZero) const

Transform time span to "smart" string.

void Set(EType type)

Set special value.

@ eInfinite

Infinite timeout.

const char * IO_StatusStr(EIO_Status status)

Get the text form of an enum status value.

EIO_Event

I/O event (or direction).

uint64_t TNCBI_BigCount

Big unsigned integer for file size and position.

@ eIO_Timeout

timeout expired before any I/O succeeded

@ eIO_Interrupt

signal arrival prevented any I/O to succeed

@ eIO_NotSupported

operation is not supported or is not available

@ eIO_Success

everything is fine, no error occurred

@ eIO_ReadWrite

eIO_Read | eIO_Write (also, eCONN_OnFlush)

@ eIO_Open

also serves as no-event indicator in SOCK_Poll

operation

Bit operations.

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 struct ncbi::grid::netcache::search::fields::KEY key

const GenericPointer< typename T::ValueType > T2 value

IMessage/IMessageListener interfaces and basic implementations.

@ eVoid

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

const Int8 k_UndefinedClientID

CJsonNode NSTGetBackendConfiguration(const IRegistry &reg, CNetStorageServer *server, vector< string > &warnings)

void NSTValidateConfigFile(const IRegistry &reg, vector< string > &warnings, bool throw_port_exception)

const int kSPObjectExpired

const int kSPObjectNotFound

const string kObjectNotFound

const string kObjectExpired

const size_t kWriteBufferSize

string NST_FormatPreciseTime(const CNSTPreciseTime &t)

void AppendError(CJsonNode &message, Int8 code, const string &error_message, const string &scope, Int8 sub_code, bool update_status)

TNetStorageFlags ExtractStorageFlags(const CJsonNode &message)

bool GetReplyMessageProperties(const exception &ex, string *error_scope, Int8 *error_code, unsigned int *error_sub_code)

CJsonNode CreateResponseMessage(Int8 serial_number)

CJsonNode CreateErrorResponseMessage(Int8 serial_number, Int8 error_code, const string &error_message, const string &scope, Int8 sub_code)

SUserKey ExtractUserKey(const CJsonNode &message)

void AppendWarning(CJsonNode &message, Int8 code, const string &warning_message, const string &scope, Int8 sub_code)

void SetSessionAndIPAndPHID(const CJsonNode &message, const CSocket &peer)

SCommonRequestArguments ExtractCommonFields(const CJsonNode &message)

SICacheSettings ExtractICacheSettings(const CJsonNode &message)

const string kScopeIMessage

const string kScopeStdException

const string kScopeUnknownException

const CTimeSpan::TSmartStringFlags kTimeSpanFlags

const Int8 k_UndefinedUserID

string NST_GetConfigFileChecksum(const string &file_name, vector< string > &warnings)

#define NETSTORAGED_BUILD_DATE

#define NETSTORAGED_VERSION

#define NETSTORAGED_PROTOCOL_VERSION

@ eAttributeValueNotFoundWarning

@ eRemoteObjectInfoWarning

@ eAttributeNotFoundWarning

@ eConfigNotChangedWarning

@ eAlertUnknownAcknowledgeResultWarning

@ eAlertAlreadyAcknowledgedWarning

Defines NCBI C++ secure resources API.

const size_t kReadBufferSize

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

static CNamedPipeClient * client

void Read(const IRegistry &reg, const string &sname, string &decrypt_warning)

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