Go to the source code of this file.
Go to the SVN repository for this file.
static void s_WriteToSocket (CSocket &sock, const char *output_buffer, size_t output_buffer_size) void s_SendUTTP (CSocket &sock, function< void(CUTTPWriter &)> f) template<class TContiguousContainer > void s_ReadSocket (CSocket &sock, TContiguousContainer &buffer, CUTTPReader &uttp_reader) const CNcbiDiag & operator<< (const CNcbiDiag &diag, const SIssue &issue) ostream & operator<< (ostream &os, const SIssue &issue) void s_ThrowError (Int8 code, Int8 sub_code, const string &err_msg) void s_TrapErrors (const CJsonNode &request, const CJsonNode &reply, CNetServerConnection &conn, SNetStorage::SConfig::EErrMode err_mode, INetServerConnectionListener &listener) CJsonNode s_ReadMessage (const CJsonNode &request, CNetServerConnection &conn, SNetStorage::SConfig::EErrMode err_mode, INetServerConnectionListener &listener) void s_SetStorageFlags (CJsonNode &node, TNetStorageFlags flags) ◆ END_OF_DATA_MARKER ◆ NCBI_USE_ERRCODE_X ◆ NST_PROTOCOL_VERSION ◆ READ_BUFFER_SIZE ◆ WRITE_BUFFER_SIZE ◆ operator<<() [1/2] ◆ operator<<() [2/2] ostream& operator<< ( ostream & os, const SIssue & issue ) ◆ s_ReadMessage()Definition at line 373 of file netstorage_rpc.cpp.
References CSocket::Close(), conn, CUTTPReader::eEndOfBuffer, CJsonOverUTTPReader::GetMessage(), CUTTPReader::GetNextEvent(), CSocket::GetPeerAddress(), NCBI_THROW_FMT, CJsonOverUTTPReader::ReadMessage(), CJsonNode::Repr(), s_ReadSocket(), and s_TrapErrors().
Referenced by SNetStorageRPC::Exchange(), CNetStorageServerListener::OnConnected(), and SNetStorageObjectRPC::SContext::ReadMessage().
◆ s_ReadSocket()template<class TContiguousContainer >
void s_ReadSocket ( CSocket & sock, TContiguousContainer & buffer, CUTTPReader & uttp_reader ) ◆ s_SendUTTP() ◆ s_SetStorageFlags()Definition at line 406 of file netstorage_rpc.cpp.
References flags, fNST_Cacheable, fNST_Fast, fNST_FileTrack, fNST_Movable, fNST_NetCache, fNST_NoMetaData, fNST_Persistent, CJsonNode::NewObjectNode(), CJsonNode::SetBoolean(), and CJsonNode::SetByKey().
Referenced by SNetStorageRPC::Create(), SNetStorageRPC::MkObjectRequest(), and SNetStorageObjectRPC::Relocate().
◆ s_ThrowError() ◆ s_TrapErrors()Definition at line 307 of file netstorage_rpc.cpp.
References SIssue::code, conn, SNetStorage::SConfig::eLog, SNetStorage::SConfig::eThrow, CNetStorageServerError::eUnknownError, FORMAT, CJsonNode::GetByKeyOrNull(), CJsonNode::GetInteger(), CSocket::GetPeerAddress(), CJsonNode::GetString(), CJsonNode::Iterate(), SIssue::kEmptySubCode, NCBI_THROW_FMT, INetServerConnectionListener::OnError(), INetServerConnectionListener::OnWarning(), CJsonNode::Repr(), s_ThrowError(), and SIssue::sub_code.
Referenced by s_ReadMessage(), and SNetStorageObjectRPC::SContext::TrapErrors().
◆ s_WriteToSocket() static void s_WriteToSocket ( CSocket & sock, const char * output_buffer, size_t output_buffer_size ) staticRetroSearch 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