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

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

NCBI C++ ToolKit: CNetScheduleHandler Class Reference

Search Toolkit Book for CNetScheduleHandler

ConnectionHandler for NetScheduler. More...

#include "ns_handler.hpp"
(Private to src/app/netschedule.)

ConnectionHandler for NetScheduler.

Definition at line 78 of file ns_handler.hpp.

Definition at line 147 of file ns_handler.hpp.

Statuses of commands to be set in diagnostics' request context Additional statuses can be taken from http://www.w3.org/Protocols/rfc2616/rfc2616-sec10.html.

Command is ok and execution is good.

Command is incorrect.

Bad authorization token.

Job is not found.

Connection was closed due to inactivity timeout.

Invalid job status.

Routine test from systems.

Error writing to socket.

Internal server error.

Command is not implemented.

In refuse submits mode and received SUBMIT.

Server is shutting down.

Definition at line 96 of file ns_handler.hpp.

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

Reimplemented from IServer_ConnectionHandler.

Definition at line 658 of file ns_handler.cpp.

References CNetScheduleServer::DecrementCurrentSubmitsCounter(), IServer_ConnectionHandler::eClientClose, eIO_Read, eIO_ReadWrite, eIO_Success, eIO_Write, IServer_ConnectionHandler::eOurClose, ERR_POST, eStatus_SocketIOError, CSocket::GetCount(), GetDiagContext(), IServer_ConnectionHandler::GetSocket(), IO_StatusStr(), CRef< C, Locker >::IsNull(), m_CmdContext, m_ConnContext, m_Server, m_WithinBatchSubmit, CRef< C, Locker >::NotNull(), NULL, CDiagContext::PrintRequestStop(), CRef< C, Locker >::Reset(), CRequestContext::SetBytesRd(), CRequestContext::SetBytesWr(), CDiagContext::SetRequestContext(), CRequestContext::SetRequestStatus(), and CSocket::Shutdown().

Implements IServer_MessageHandler.

Definition at line 761 of file ns_handler.cpp.

References CServer::CloseConnection(), CNetScheduleException::eAuthenticationError, CNetServiceException::eCommunicationError, eIO_Success, ERR_POST, CNetScheduleException::ErrCodeToHTTPStatusCode(), eStatus_BadRequest, eStatus_OK, eStatus_ServerError, eStatus_ShuttingDown, eStatus_SocketIOError, CException::GetErrCode(), CNetScheduleException::GetErrCodeString(), CException::GetMsg(), IServer_ConnectionHandler::GetSocket(), kEndOfResponse, m_CmdContext, m_ConnContext, m_ProcessMessage, m_Server, CRef< C, Locker >::NotNull(), NStr::PrintableString(), CRequestContext::SetRequestStatus(), CNetScheduleServer::ShutdownRequested(), string, CException::what(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), x_SetRequestContext(), and x_WriteMessage().

Runs in response to an external event [asynchronous].

You can get socket by calling GetSocket(), if you close the socket this object will be destroyed. Individual events are: A client has just established this connection.

Implements IServer_ConnectionHandler.

Definition at line 635 of file ns_handler.cpp.

References CSocket::DisableOSSendDelay(), eIO_ReadWrite, CNetScheduleServer::GetInactivityTimeout(), IServer_ConnectionHandler::GetSocket(), CNetScheduleServer::IsLog(), m_ProcessMessage, m_Server, CSocket::SetTimeout(), x_CreateConnContext(), x_ProcessMsgAuth(), and x_SetQuickAcknowledge().

Definition at line 4385 of file ns_handler.cpp.

References x_ProcessCancel(), x_ProcessConfirm(), x_ProcessDump(), x_ProcessFastStatusS(), x_ProcessFastStatusW(), x_ProcessGetMessage(), x_ProcessJobDelayExpiration(), x_ProcessJobDelayReadExpiration(), x_ProcessJobExchange(), x_ProcessListenJob(), x_ProcessPut(), x_ProcessPutFailure(), x_ProcessPutMessage(), x_ProcessReadFailed(), x_ProcessReadRollback(), x_ProcessReschedule(), x_ProcessReturn(), and x_ProcessStatus().

Referenced by x_ProcessMsgRequest().

Definition at line 4108 of file ns_handler.cpp.

References CNSClientId::IsComplete(), m_ClientId, and NCBI_THROW.

Referenced by x_ProcessCancelWaitGet(), x_ProcessCancelWaitRead(), x_ProcessChangeAffinity(), x_ProcessConfirm(), x_ProcessGetJob(), x_ProcessPut(), x_ProcessPutFailure(), x_ProcessReadFailed(), x_ProcessReading(), x_ProcessReadRollback(), x_ProcessRedo(), x_ProcessReread(), x_ProcessReschedule(), x_ProcessReturn(), and x_ProcessSetAffinity().

Definition at line 4502 of file ns_handler.cpp.

References eSAF_IP, eStatus_OK, GetDiagContext(), CSocket::GetPeerAddress(), IServer_ConnectionHandler::GetSocket(), m_ConnContext, CDiagContext::PrintRequestStart(), CRef< C, Locker >::Reset(), CRequestContext::SetClientIP(), CDiagContext::SetRequestContext(), CRequestContext::SetRequestID(), CRequestContext::SetRequestStatus(), and x_GetConnRef().

Referenced by OnOpen(), and x_ProcessMsgQueue().

Definition at line 3908 of file ns_handler.cpp.

References command, CNetScheduleAPI::eJobNotFound, CNetScheduleAPI::eReading, ERR_POST, eStatus_InvalidJobStatus, eStatus_NotFound, SNSCommandArguments::job_key, kEndOfResponse, kErrNoJobFoundResponse, kOKCompleteResponse, m_CommandArguments, CNetScheduleAPI::StatusToString(), Warning(), x_LogCommandWithJob(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), and x_WriteMessage().

Referenced by x_ProcessConfirm(), x_ProcessReadFailed(), and x_ProcessReadRollback().

Definition at line 4603 of file ns_handler.cpp.

References NStr::BoolToString(), CNetScheduleServer::GetAdminClientNames(), CNetScheduleServer::GetAdminHosts(), CNetScheduleServer::GetAffRegistrySettings(), CNetScheduleAccessList::GetAsFromConfig(), CNetScheduleServer::GetDeleteBatchSize(), CNetScheduleServer::GetGroupRegistrySettings(), CNetScheduleServer::GetInactivityTimeout(), CNetScheduleServer::GetJobCountersInterval(), CNetScheduleServer::GetMarkdelBatchSize(), CNetScheduleServer::GetMaxClientData(), CServer::GetParameters(), CNetScheduleServer::GetPort(), CNetScheduleServer::GetPurgeTimeout(), CNetScheduleServer::GetReserveDumpSpace(), CNetScheduleServer::GetScanBatchSize(), CNetScheduleServer::GetScopeRegistrySettings(), CNetScheduleServer::GetStateTransitionPerfLogClasses(), CNetScheduleServer::GetStateTransitionPerfLogQueues(), CNetScheduleServer::GetStatInterval(), CNetScheduleServer::GetUseHostname(), SServer_Parameters::init_threads, CNetScheduleServer::IsLog(), CNetScheduleServer::IsLogBatchEachJob(), CNetScheduleServer::IsLogCleaningThread(), CNetScheduleServer::IsLogExecutionWatcherThread(), CNetScheduleServer::IsLogNotificationThread(), CNetScheduleServer::IsLogStatisticsThread(), m_Server, SServer_Parameters::max_connections, SServer_Parameters::max_threads, and SNSRegistryParameters::Serialize().

Referenced by x_ProcessGetConf().

Definition at line 967 of file ns_handler.cpp.

References CServer::CloseConnection(), ERR_POST, eStatus_OK, eStatus_SocketIOError, CSocket::GetPeerAddress(), CRef< C, Locker >::GetPointer(), GetQueue(), CRequestContext::GetRequestStatus(), IServer_ConnectionHandler::GetSocket(), IO_StatusStr(), m_ClientId, m_CmdContext, m_ConnContext, m_QueueName, m_Server, msg(), CRef< C, Locker >::NotNull(), CRequestContext::SetRequestStatus(), and x_ExecuteRollbackAction().

Referenced by x_WriteMessage().

Definition at line 4451 of file ns_handler.cpp.

References CDiagContext::Extra(), CJob::GetClientIP(), CJob::GetClientSID(), GetDiagContext(), CJob::GetNCBIPHID(), CDiagContext::GetRequestContext(), CDiagContext_Extra::Print(), CRequestContext::SetClientIP(), CRequestContext::SetSessionID(), x_NeedCmdLogging(), and x_WorkerNodeCommand().

Referenced by x_FinalizeReadCommand(), x_ProcessCancel(), x_ProcessFastStatusS(), x_ProcessFastStatusW(), x_ProcessGetJob(), x_ProcessGetMessage(), x_ProcessJobDelayExpiration(), x_ProcessJobDelayReadExpiration(), x_ProcessJobExchange(), x_ProcessListenJob(), x_ProcessPut(), x_ProcessPutFailure(), x_ProcessPutMessage(), x_ProcessReading(), x_ProcessRedo(), x_ProcessReread(), x_ProcessReschedule(), x_ProcessReturn(), and x_ProcessStatus().

Definition at line 4722 of file ns_handler.cpp.

References m_ConnContext, and CRef< C, Locker >::NotNull().

Referenced by x_LogCommandWithJob(), x_PrintGetJobResponse(), x_ProcessCancel(), x_ProcessCancelQueue(), x_ProcessChangeAffinity(), x_ProcessClearWorkerNode(), x_ProcessDropQueue(), x_ProcessDump(), x_ProcessGetJob(), x_ProcessJobExchange(), x_ProcessMsgBatchSubmit(), x_ProcessMsgQueue(), x_ProcessMsgRequest(), x_ProcessReading(), x_ProcessReloadConfig(), x_ProcessSetAffinity(), x_ProcessSetQueue(), x_ProcessSubmit(), and x_RemoveDuplicateStatuses().

Definition at line 4523 of file ns_handler.cpp.

References CServer::CloseConnection(), eIO_Success, ERR_POST, eSAF_IP, eStatus_BadRequest, CDiagContext::GetRequestContext(), IServer_ConnectionHandler::GetSocket(), kEndOfResponse, kMaxParserErrMsgLength, m_Server, msg(), CRequestContext::SetClientIP(), x_PrintCmdRequestStart(), x_SetCmdRequestStatus(), x_SetConnRequestStatus(), and x_WriteMessage().

Referenced by x_ProcessMsgBatchHeader(), x_ProcessMsgBatchJob(), x_ProcessMsgBatchSubmit(), and x_ProcessMsgRequest().

Definition at line 858 of file ns_handler.cpp.

References SErrorEmulatorParameter::as_bool, SErrorEmulatorParameter::as_double, CServer::CloseConnection(), eIO_Success, CNetScheduleServer::GetDebugConnDropBeforeWrite(), CNetScheduleServer::GetDebugGarbage(), CNetScheduleServer::GetDebugReplyWithGarbage(), CNetScheduleServer::GetDebugWriteDelay(), IServer_ConnectionHandler::GetSocket(), SErrorEmulatorParameter::IsActive(), kMessageBufferIncrement, m_ConnContext, m_MsgBuffer, m_MsgBufferSize, m_Server, msg(), CRef< C, Locker >::NotNull(), NULL, and rapidjson::value.

Referenced by x_WriteMessage().

Definition at line 4224 of file ns_handler.cpp.

References cmd, eSAF_IP, eStatus_OK, CDiagContext_Extra::Flush(), GetDiagContext(), CDiagContext::GetRequestContext(), IServer_ConnectionHandler::GetSocket(), ITERATE, m_CmdContext, m_QueueName, CRef< C, Locker >::NotNull(), CDiagContext_Extra::Print(), CDiagContext::PrintRequestStart(), CRequestContext::SetClientIP(), CDiagContext::SetRequestContext(), CRequestContext::SetRequestStatus(), CRequestContext::SetSessionID(), x_GetConnRef(), and x_WorkerNodeCommand().

Referenced by x_OnCmdParserError(), and x_ProcessMsgRequest().

Definition at line 4279 of file ns_handler.cpp.

References eSAF_IP, eStatus_OK, GetDiagContext(), IServer_ConnectionHandler::GetSocket(), m_CmdContext, m_QueueName, msg(), CRef< C, Locker >::NotNull(), CDiagContext::PrintRequestStart(), CDiagContext::SetRequestContext(), CRequestContext::SetRequestStatus(), and x_GetConnRef().

Definition at line 4301 of file ns_handler.cpp.

References GetDiagContext(), m_CmdContext, CRef< C, Locker >::NotNull(), CDiagContext::PrintRequestStop(), CRef< C, Locker >::Reset(), and CDiagContext::SetRequestContext().

Referenced by OnMessage(), x_CmdNotImplemented(), x_CmdObsolete(), x_FinalizeReadCommand(), x_ProcessAckAlert(), x_ProcessActiveCount(), x_ProcessBatchSequenceEnd(), x_ProcessCancel(), x_ProcessCancelQueue(), x_ProcessCancelWaitGet(), x_ProcessCancelWaitRead(), x_ProcessChangeAffinity(), x_ProcessClearWorkerNode(), x_ProcessCreateDynamicQueue(), x_ProcessDeleteDynamicQueue(), x_ProcessDropQueue(), x_ProcessDump(), x_ProcessFastStatusS(), x_ProcessFastStatusW(), x_ProcessGetConf(), x_ProcessGetConfiguration(), x_ProcessGetJob(), x_ProcessGetMessage(), x_ProcessGetParam(), x_ProcessHealth(), x_ProcessJobDelayExpiration(), x_ProcessJobDelayReadExpiration(), x_ProcessJobExchange(), x_ProcessListenJob(), x_ProcessMsgBatchHeader(), x_ProcessMsgBatchJob(), x_ProcessMsgBatchSubmit(), x_ProcessPause(), x_ProcessPut(), x_ProcessPutFailure(), x_ProcessPutMessage(), x_ProcessQList(), x_ProcessQueueInfo(), x_ProcessReading(), x_ProcessRedo(), x_ProcessRefuseSubmits(), x_ProcessReloadConfig(), x_ProcessReread(), x_ProcessReschedule(), x_ProcessResume(), x_ProcessReturn(), x_ProcessSetAffinity(), x_ProcessSetClientData(), x_ProcessSetQueue(), x_ProcessSetScope(), x_ProcessShutdown(), x_ProcessStatistics(), x_ProcessStatus(), x_ProcessSubmit(), x_ProcessSubmitBatch(), x_ProcessVersion(), and x_StatisticsNew().

Definition at line 4313 of file ns_handler.cpp.

References ERR_POST, CDiagContext::Extra(), CJob::GetAffinityId(), CQueue::GetAffinityTokenByID(), CJob::GetAuthToken(), CJob::GetClientIP(), CJob::GetClientSID(), GetDiagContext(), CJob::GetId(), CJob::GetInput(), CSocketAPI::GetLocalHostAddress(), CJob::GetMask(), CJob::GetNCBIPHID(), CJob::GetSubmAddr(), CJob::GetSubmNotifPort(), kEndOfResponse, kOKCompleteResponse, CQueue::MakeJobKey(), CSocketAPI::ntoa(), CDiagContext_Extra::Print(), NStr::PrintableString(), NStr::URLEncode(), Warning(), x_NeedCmdLogging(), and x_WriteMessage().

Referenced by x_ProcessGetJob(), and x_ProcessJobExchange().

Definition at line 3415 of file ns_handler.cpp.

References CNetScheduleServer::AcknowledgeAlert(), SNSCommandArguments::alert, eAlreadyAcknowledged, eNotFound, kEndOfResponse, kOKCompleteResponse, m_CommandArguments, m_Server, result, SNSCommandArguments::user, x_PrintCmdRequestStop(), and x_WriteMessage().

Definition at line 1919 of file ns_handler.cpp.

References SNSCommandArguments::affinity_token, CQueue::Cancel(), CQueue::CancelSelectedJobs(), count, CNetScheduleAPI::eCanceled, CNetScheduleAPI::eJobNotFound, ERR_POST, eStatus_BadRequest, eStatus_NotFound, SNSCommandArguments::group, SNSCommandArguments::job_id, SNSCommandArguments::job_key, SNSCommandArguments::job_statuses, SNSCommandArguments::job_statuses_string, kEndOfResponse, m_ClientId, m_CommandArguments, msg(), Warning(), x_LogCommandWithJob(), x_NeedCmdLogging(), x_PrintCmdRequestStop(), x_RemoveDuplicateStatuses(), x_SetCmdRequestStatus(), and x_WriteMessage().

Referenced by x_CanBeWithoutQueue().

Definition at line 1698 of file ns_handler.cpp.

References SNSCommandArguments::aff_to_add, SNSCommandArguments::aff_to_del, CQueue::ChangeAffinity(), SNSCommandArguments::cmd, eGet, eRead, ERR_POST, eStatus_BadRequest, CDiagContext::Extra(), GetDiagContext(), CNSClientId::GetNode(), CNSClientId::GetSession(), k_NoAffinityToken, kEndOfResponse, kOKCompleteResponse, kOKResponsePrefix, m_ClientId, m_ClientIdentificationPrinted, m_CommandArguments, msg(), CDiagContext_Extra::Print(), NStr::Split(), Warning(), x_CheckNonAnonymousClient(), x_NeedCmdLogging(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), and x_WriteMessage().

Definition at line 3972 of file ns_handler.cpp.

References CQueue::ClearWorkerNode(), CDiagContext::Extra(), GetDiagContext(), CNSClientId::GetNode(), CNSClientId::GetSession(), kOKCompleteResponse, m_ClientId, CDiagContext_Extra::Print(), x_NeedCmdLogging(), x_PrintCmdRequestStop(), and x_WriteMessage().

Definition at line 3127 of file ns_handler.cpp.

References SNSCommandArguments::affinity_token, SNSCommandArguments::count, SNSCommandArguments::dump_fields, CNetScheduleAPI::eJobNotFound, ERR_POST, eStatus_BadRequest, eStatus_NotFound, SNSCommandArguments::group, SNSCommandArguments::job_id, SNSCommandArguments::job_statuses, SNSCommandArguments::job_statuses_string, kEndOfResponse, kErrNoJobFoundResponse, m_ClientId, m_CommandArguments, SNSCommandArguments::order_first, CQueue::PrintAllJobDbStat(), CQueue::PrintJobDbStat(), SNSCommandArguments::start_after_job_id, Warning(), x_NeedCmdLogging(), x_PrintCmdRequestStop(), x_RemoveDuplicateStatuses(), x_SetCmdRequestStatus(), and x_WriteMessage().

Referenced by x_CanBeWithoutQueue().

Definition at line 1590 of file ns_handler.cpp.

References SNSCommandArguments::cmd, CNetScheduleAPI::eJobNotFound, CQueue::ePauseWithoutPullback, CQueue::ePauseWithPullback, ERR_POST, eStatus_NotFound, CQueue::GetPauseStatus(), CJob::GetProgressMsg(), CQueue::GetStatusAndLifetimeAndTouch(), SNSCommandArguments::job_id, SNSCommandArguments::job_key, kEndOfResponse, kErrNoJobFoundResponse, kOKResponsePrefix, m_CommandArguments, SNSCommandArguments::need_progress_msg, CNSPreciseTime::Sec(), CNetScheduleAPI::StatusToString(), NStr::URLEncode(), Warning(), x_LogCommandWithJob(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), and x_WriteMessage().

Referenced by x_CanBeWithoutQueue().

Definition at line 1642 of file ns_handler.cpp.

References SNSCommandArguments::cmd, CNetScheduleAPI::eJobNotFound, CQueue::ePauseWithoutPullback, CQueue::ePauseWithPullback, ERR_POST, eStatus_NotFound, CQueue::GetPauseStatus(), CQueue::GetStatusAndLifetime(), SNSCommandArguments::job_id, SNSCommandArguments::job_key, kEndOfResponse, kErrNoJobFoundResponse, kOKResponsePrefix, m_CommandArguments, SNSCommandArguments::need_progress_msg, CNSPreciseTime::Sec(), CNetScheduleAPI::StatusToString(), NStr::URLEncode(), Warning(), x_LogCommandWithJob(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), and x_WriteMessage().

Referenced by x_CanBeWithoutQueue().

Definition at line 3241 of file ns_handler.cpp.

References SNSCommandArguments::effective, CNcbiApplicationAPI::GetConfig(), CNetScheduleServer::GetLinkedSectionConfig(), CNetScheduleServer::GetQueueClassesConfig(), CNetScheduleServer::GetQueueConfig(), CNetScheduleServer::GetServiceToQueueSectionConfig(), CNcbiApplication::Instance(), kEndOfResponse, m_CommandArguments, m_Server, string, IRegistry::Write(), x_GetDiagSection(), x_GetLogSection(), x_GetServerSection(), x_PrintCmdRequestStop(), and x_WriteMessage().

Definition at line 2140 of file ns_handler.cpp.

References SNSCommandArguments::affinity_token, SNSCommandArguments::any_affinity, SNSCommandArguments::cmd, CQueue::eNoPause, CQueue::ePauseWithPullback, eStatus_BadRequest, SNSCommandArguments::exclusive_new_aff, CDiagContext::Extra(), CNSClientId::GetAddress(), GetDiagContext(), CJob::GetId(), CQueue::GetJobOrWait(), CNSClientId::GetNode(), CQueue::GetPauseStatus(), CNSClientId::GetSession(), SNSCommandArguments::group, kEndOfResponse, kOKCompleteResponse, m_ClientId, m_ClientIdentificationPrinted, m_CommandArguments, m_RollbackAction, SNSCommandArguments::port, CDiagContext_Extra::Print(), SNSCommandArguments::prioritized_aff, CQueue::RegisterQueueResumeNotification(), NStr::Split(), SNSCommandArguments::timeout, SNSCommandArguments::wnode_affinity, x_CheckGetParameters(), x_CheckNonAnonymousClient(), x_CheckPortAndTimeout(), x_ClearRollbackAction(), x_LogCommandWithJob(), x_NeedCmdLogging(), x_PrintCmdRequestStop(), x_PrintGetJobResponse(), x_SetCmdRequestStatus(), and x_WriteMessage().

Definition at line 2459 of file ns_handler.cpp.

References SNSCommandArguments::cmd, CNetScheduleAPI::eJobNotFound, ERR_POST, eStatus_NotFound, CJob::GetProgressMsg(), SNSCommandArguments::job_id, SNSCommandArguments::job_key, kEndOfResponse, kErrNoJobFoundResponse, m_CommandArguments, NStr::PrintableString(), CQueue::ReadAndTouchJob(), Warning(), x_LogCommandWithJob(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), and x_WriteMessage().

Referenced by x_CanBeWithoutQueue().

Definition at line 3659 of file ns_handler.cpp.

References map_checker< Container >::begin(), SNSCommandArguments::cmd, CQueue::GetMaxIOSizesAndLinkedSections(), kEndOfResponse, m_CommandArguments, NETSCHEDULED_FEATURES, result, string, NStr::URLEncode(), x_PrintCmdRequestStop(), and x_WriteMessage().

Definition at line 3288 of file ns_handler.cpp.

References SErrorEmulatorParameter::as_int, CTime::AsString(), CProcessBase::SMemoryUsage::data, CNetScheduleServer::GetAlerts(), CNcbiApplicationAPI::GetArguments(), CNcbiApplicationAPI::GetConfigPath(), CSystemInfo::GetCpuCount(), CNetScheduleServer::GetDebugFDCount(), CNetScheduleServer::GetDebugMemCount(), CCurrentProcess::GetFileDescriptorsCount(), CCurrentProcess::GetMemoryUsage(), CNetScheduleServer::GetNodeID(), CDiagContext::GetPID(), CNcbiApplicationAPI::GetProgramExecutablePath(), CNetScheduleServer::GetSessionID(), CNetScheduleServer::GetStartTime(), CCurrentProcess::GetThreadCount(), CCurrentProcess::GetTimes(), CSystemInfo::GetTotalPhysicalMemorySize(), CNcbiApplication::Instance(), SErrorEmulatorParameter::IsActive(), kEndOfResponse, CProcessBase::SMemoryUsage::lib, m_CmdContext, m_Server, CRef< C, Locker >::NotNull(), CProcessBase::SMemoryUsage::resident, CProcessBase::SMemoryUsage::resident_peak, CProcessBase::SMemoryUsage::shared, CNcbiArguments::Size(), CProcessBase::SMemoryUsage::stack, CProcessBase::SMemoryUsage::swap, CProcessBase::SMemoryUsage::text, CProcessBase::SMemoryUsage::total, CProcessBase::SMemoryUsage::total_peak, NStr::URLEncode(), x_PrintCmdRequestStop(), and x_WriteMessage().

Definition at line 2724 of file ns_handler.cpp.

References CNetScheduleAPI::eJobNotFound, ERR_POST, CNetScheduleAPI::eRunning, eStatus_BadRequest, eStatus_InvalidJobStatus, eStatus_NotFound, SNSCommandArguments::job_id, SNSCommandArguments::job_key, CQueue::JobDelayExpiration(), kEndOfResponse, kErrNoJobFoundResponse, kOKCompleteResponse, m_CommandArguments, CNetScheduleAPI::StatusToString(), SNSCommandArguments::timeout, Warning(), x_LogCommandWithJob(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), and x_WriteMessage().

Referenced by x_CanBeWithoutQueue().

Definition at line 2771 of file ns_handler.cpp.

References CNetScheduleAPI::eJobNotFound, CNetScheduleAPI::eReading, ERR_POST, eStatus_BadRequest, eStatus_InvalidJobStatus, eStatus_NotFound, SNSCommandArguments::job_id, SNSCommandArguments::job_key, CQueue::JobDelayReadExpiration(), kEndOfResponse, kErrNoJobFoundResponse, kOKCompleteResponse, m_CommandArguments, CNetScheduleAPI::StatusToString(), SNSCommandArguments::timeout, Warning(), x_LogCommandWithJob(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), and x_WriteMessage().

Referenced by x_CanBeWithoutQueue().

Definition at line 2331 of file ns_handler.cpp.

References SNSCommandArguments::affinity_token, SNSCommandArguments::any_affinity, SNSCommandArguments::auth_token, CNSPreciseTime::Current(), CNetScheduleAPI::eFailed, CNetScheduleAPI::eJobNotFound, CQueue::eNoPause, CQueue::ePauseWithPullback, CNetScheduleAPI::ePending, ERR_POST, CNetScheduleAPI::eRunning, eStatus_BadRequest, CDiagContext::Extra(), CNSClientId::GetAddress(), GetDiagContext(), CQueue::GetJobOrWait(), CNSClientId::GetNode(), CQueue::GetPauseStatus(), CNSClientId::GetSession(), SNSCommandArguments::job_id, SNSCommandArguments::job_key, SNSCommandArguments::job_return_code, kEndOfResponse, kOKCompleteResponse, m_ClientId, m_ClientIdentificationPrinted, m_CommandArguments, m_RollbackAction, NULL, SNSCommandArguments::output, SNSCommandArguments::port, CDiagContext_Extra::Print(), CQueue::PutResult(), CQueue::RegisterQueueResumeNotification(), NStr::Split(), SNSCommandArguments::timeout, Warning(), SNSCommandArguments::wnode_affinity, x_ClearRollbackAction(), x_LogCommandWithJob(), x_NeedCmdLogging(), x_PrintCmdRequestStop(), x_PrintGetJobResponse(), x_SetCmdRequestStatus(), and x_WriteMessage().

Referenced by x_CanBeWithoutQueue().

Definition at line 2819 of file ns_handler.cpp.

References CNetScheduleAPI::eJobNotFound, ERR_POST, eStatus_NotFound, CNSClientId::GetAddress(), CJob::GetProgressMsg(), SNSCommandArguments::job_id, SNSCommandArguments::job_key, kEndOfResponse, kErrNoJobFoundResponse, m_ClientId, m_CommandArguments, SNSCommandArguments::need_progress_msg, SNSCommandArguments::need_stolen, SNSCommandArguments::port, CQueue::SetJobListener(), CNetScheduleAPI::StatusToString(), SNSCommandArguments::timeout, NStr::URLEncode(), Warning(), x_LogCommandWithJob(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), and x_WriteMessage().

Referenced by x_CanBeWithoutQueue().

Definition at line 1023 of file ns_handler.cpp.

References buffer, CServer::CloseConnection(), eStatus_HTTPProbe, IServer_ConnectionHandler::GetSocket(), m_ProcessMessage, m_RawAuthString, m_Server, s_ReadBufToString(), util::strncmp(), x_ProcessMsgQueue(), x_SetConnRequestStatus(), and x_SetQuickAcknowledge().

Referenced by OnOpen().

Definition at line 1310 of file ns_handler.cpp.

References buffer, cmd, SNSProtoParsedCmd< Extra >::command, CNetScheduleServer::DecrementCurrentSubmitsCounter(), CTempString::empty(), ERR_POST, eStatus_BadRequest, SNSProtoCmdDef< Extra >::extra, CNSProtoParserException::GetErrCodeString(), CException::GetMsg(), kEndOfResponse, m_BatchHeaderParser, m_BatchJobs, m_BatchSize, m_ProcessMessage, m_Server, m_WithinBatchSubmit, msg(), CNetServProtoParser< Extra >::ParseCommand(), CNetScheduleHandler::SCommandExtra::processor, s_ReadBufToString(), NStr::StringToInt(), x_OnCmdParserError(), x_PrintCmdRequestStop(), x_ProcessMsgRequest(), x_SetCmdRequestStatus(), and x_WriteMessage().

Referenced by x_ProcessMsgBatchSubmit(), and x_ProcessSubmitBatch().

Definition at line 1371 of file ns_handler.cpp.

References SNSCommandArguments::affinity_token, SNSCommandArguments::AssignValues(), buffer, CNetScheduleServer::DecrementCurrentSubmitsCounter(), ERR_POST, eStatus_BadRequest, CNetScheduleServer::GetCompoundIDPool(), CNSProtoParserException::GetErrCodeString(), CException::GetMsg(), IServer_ConnectionHandler::GetSocket(), SNSCommandArguments::input, SNSCommandArguments::job_mask, k_NoAffinityToken, kEndOfResponse, m_BatchClientIP, m_BatchClientSID, m_BatchEndParser, m_BatchJobs, m_BatchNCBIPHID, m_BatchPos, m_BatchSize, m_BatchSubmPort, m_BatchSubmTimeout, m_CommandArguments, m_ProcessMessage, m_Server, m_WithinBatchSubmit, msg(), CNetServProtoParserBase::ParseArguments(), s_BatchArgs, s_ReadBufToString(), CJob::SetClientIP(), CJob::SetClientSID(), CJob::SetInput(), CJob::SetMask(), CJob::SetNCBIPHID(), CJob::SetSubmNotifPort(), CJob::SetSubmNotifTimeout(), x_OnCmdParserError(), x_PrintCmdRequestStop(), x_ProcessMsgBatchSubmit(), x_ProcessMsgRequest(), x_SetCmdRequestStatus(), and x_WriteMessage().

Referenced by x_ProcessBatchStart().

Definition at line 1462 of file ns_handler.cpp.

References BUF_Read(), BUF_Size(), buffer, ctx, CNetScheduleServer::DecrementCurrentSubmitsCounter(), NStr::DoubleToString(), CStopWatch::Elapsed(), ERR_POST, CStopWatch::eStart, eStatus_BadRequest, eStatus_OK, eStatus_ServerError, CDiagContext::Extra(), NStr::fDoubleFixed, GetDiagContext(), CNetScheduleServer::GetHost(), CException::GetMsg(), CNetScheduleServer::GetPort(), GetQueue(), CDiagContext::GetRequestContext(), CRequestContext::GetRequestID(), kEndOfResponse, m_BatchEndParser, m_BatchGroup, m_BatchJobs, m_BatchStopWatch, m_ClientId, m_CmdContext, m_ProcessMessage, m_QueueName, m_RollbackAction, m_Server, m_WithinBatchSubmit, msg(), CNetServProtoParser< Extra >::ParseCommand(), CDiagContext_Extra::Print(), CDiagContext::PrintRequestStart(), CDiagContext::PrintRequestStop(), s_ReadBufToString(), CDiagContext::SetRequestContext(), sw, x_ClearRollbackAction(), x_GetConnRef(), x_NeedCmdLogging(), x_OnCmdParserError(), x_PrintCmdRequestStop(), x_ProcessMsgBatchHeader(), x_ProcessMsgRequest(), x_SetCmdRequestStatus(), and x_WriteMessage().

Referenced by x_ProcessBatchStart(), and x_ProcessMsgBatchJob().

Definition at line 1045 of file ns_handler.cpp.

References CNetScheduleServer::AdminHostValid(), buffer, CServer::CloseConnection(), NStr::CompareNocase(), eIO_Success, eNS_Admin, ERR_POST, CNetScheduleException::ErrCodeToHTTPStatusCode(), eStatus_BadRequest, CNetScheduleException::eUnknownQueue, CDiagContext::Extra(), CNSClientId::GetAddress(), CNSClientId::GetClientName(), GetDiagContext(), CException::GetErrCode(), CNetScheduleException::GetErrCodeString(), CException::GetMsg(), CRef< C, Locker >::GetPointer(), IServer_ConnectionHandler::GetSocket(), CNetScheduleServer::IsAdminClientName(), CRef< C, Locker >::IsNull(), kEndOfResponse, m_ClientId, m_ConnContext, m_ProcessMessage, m_QueueName, m_QueueRef, m_RawAuthString, m_Server, m_SingleCmdParser, msg(), NULL, CNetScheduleServer::OpenQueue(), CNetServProtoParserBase::ParseArguments(), CDiagContext_Extra::Print(), CWeakRef< C, Locker >::Reset(), s_AuthArgs, s_ReadBufToString(), CNSClientId::SetPassedChecks(), string, CNSClientId::Update(), CException::what(), x_CreateConnContext(), x_GetPeerAddress(), x_NeedCmdLogging(), x_ProcessMsgRequest(), x_SetConnRequestStatus(), x_SetQuickAcknowledge(), x_UpdateClientPassedChecks(), and x_WriteMessage().

Referenced by x_ProcessMsgAuth().

Definition at line 1139 of file ns_handler.cpp.

References SNSCommandArguments::AssignValues(), buffer, CNSClientId::CheckAccess(), CNetScheduleHandler::SCommandExtra::checks, cmd, NStr::CompareNocase(), eNS_Queue, eStatus_OK, CDiagContext::Extra(), CNetScheduleServer::GetCompoundIDPool(), GetDiagContext(), CNSClientId::GetID(), CException::GetMsg(), CNSClientId::GetNode(), CNSClientId::GetPassedChecks(), CRef< C, Locker >::GetPointer(), GetQueue(), CNSClientId::GetSession(), IServer_ConnectionHandler::GetSocket(), m_ClientId, m_ClientIdentificationPrinted, m_CmdContext, m_CommandArguments, m_QueueName, m_Server, m_SingleCmdParser, msg(), NCBI_THROW, NULL, CNetScheduleServer::OpenQueue(), CNetServProtoParser< Extra >::ParseCommand(), CDiagContext_Extra::Print(), CNetScheduleHandler::SCommandExtra::processor, SNSCommandArguments::queue_from_job_key, CRef< C, Locker >::Reset(), s_ReadBufToString(), CNSClientId::SetID(), CNSClientId::SetPassedChecks(), CDiagContext::SetRequestContext(), CRequestContext::SetRequestID(), CRequestContext::SetRequestStatus(), CQueue::TouchClientsRegistry(), x_CanBeWithoutQueue(), x_NeedCmdLogging(), x_NeedToGeneratePHIDAndSID(), x_OnCmdParserError(), x_PrintCmdRequestStart(), x_ProcessQuitSession(), x_ProcessRefuseSubmits(), x_ProcessStatistics(), and x_UpdateClientPassedChecks().

Referenced by x_ProcessBatchSequenceEnd(), x_ProcessMsgBatchHeader(), x_ProcessMsgBatchJob(), x_ProcessMsgBatchSubmit(), x_ProcessMsgQueue(), and x_ProcessSubmitBatch().

Definition at line 4049 of file ns_handler.cpp.

References CQueue::eNoPause, CQueue::ePauseWithoutPullback, CQueue::ePauseWithPullback, CQueue::GetPauseStatus(), kEndOfResponse, kOKCompleteResponse, m_ClientId, m_CommandArguments, SNSCommandArguments::pullback, CQueue::SetPauseStatus(), x_PrintCmdRequestStop(), and x_WriteMessage().

Definition at line 2263 of file ns_handler.cpp.

References SNSCommandArguments::auth_token, SNSCommandArguments::cmd, CNSPreciseTime::Current(), CNetScheduleAPI::eDone, CNetScheduleAPI::eFailed, CNetScheduleAPI::eJobNotFound, CNetScheduleAPI::ePending, ERR_POST, CNetScheduleAPI::eRunning, eStatus_InvalidJobStatus, eStatus_NotFound, SNSCommandArguments::job_id, SNSCommandArguments::job_key, SNSCommandArguments::job_return_code, kEndOfResponse, kErrNoJobFoundResponse, kOKCompleteResponse, m_ClientId, m_CommandArguments, SNSCommandArguments::output, CQueue::PutResult(), CNetScheduleAPI::StatusToString(), Warning(), x_CheckAuthorizationToken(), x_CheckNonAnonymousClient(), x_LogCommandWithJob(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), and x_WriteMessage().

Referenced by x_CanBeWithoutQueue().

Definition at line 2480 of file ns_handler.cpp.

References SNSCommandArguments::auth_token, SNSCommandArguments::cmd, CNetScheduleAPI::eFailed, CNetScheduleAPI::eJobNotFound, SNSCommandArguments::err_msg, ERR_POST, CNetScheduleAPI::eRunning, eStatus_InvalidJobStatus, eStatus_NotFound, CQueue::FailJob(), SNSCommandArguments::job_id, SNSCommandArguments::job_key, SNSCommandArguments::job_return_code, kEndOfResponse, kErrNoJobFoundResponse, kOKCompleteResponse, m_ClientId, m_CommandArguments, SNSCommandArguments::no_retries, SNSCommandArguments::output, CNetScheduleAPI::StatusToString(), Warning(), x_CheckAuthorizationToken(), x_CheckNonAnonymousClient(), x_LogCommandWithJob(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), and x_WriteMessage().

Referenced by x_CanBeWithoutQueue().

Definition at line 2441 of file ns_handler.cpp.

References ERR_POST, eStatus_NotFound, SNSCommandArguments::job_id, SNSCommandArguments::job_key, kErrNoJobFoundResponse, kOKCompleteResponse, m_CommandArguments, SNSCommandArguments::progress_msg, CQueue::PutProgressMessage(), Warning(), x_LogCommandWithJob(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), and x_WriteMessage().

Referenced by x_CanBeWithoutQueue().

Definition at line 3472 of file ns_handler.cpp.

References map_checker< Container >::begin(), SNSCommandArguments::cmd, SQueueParameters::description, eStatus_NotFound, g_ValidJobStatuses, g_ValidJobStatusesSize, CQueue::GetJobsPerState(), CQueue::GetLinkedSections(), CRef< C, Locker >::GetPointer(), SQueueParameters::GetPrintableParameters(), kEndOfResponse, SQueueParameters::kind, m_ClientId, m_CommandArguments, m_Server, CNetScheduleServer::OpenQueue(), NStr::PrintableString(), SQueueParameters::qclass, SNSCommandArguments::qname, CNetScheduleServer::QueueInfo(), CRef< C, Locker >::Reset(), CNetScheduleServer::ResolveService(), SNSCommandArguments::service, CNetScheduleAPI::StatusToString(), string, NStr::URLEncode(), x_CheckQInf2Parameters(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), and x_WriteMessage().

Definition at line 3823 of file ns_handler.cpp.

References SNSCommandArguments::auth_token, SNSCommandArguments::err_msg, CQueue::FailReadingJob(), SNSCommandArguments::job_id, SNSCommandArguments::job_key, m_ClientId, m_CommandArguments, SNSCommandArguments::no_retries, x_CheckAuthorizationToken(), x_CheckNonAnonymousClient(), and x_FinalizeReadCommand().

Referenced by x_CanBeWithoutQueue().

Definition at line 3708 of file ns_handler.cpp.

References SNSCommandArguments::affinity_may_change, SNSCommandArguments::affinity_token, SNSCommandArguments::any_affinity, NStr::BoolToString(), SNSCommandArguments::cmd, eStatus_BadRequest, SNSCommandArguments::exclusive_new_aff, CDiagContext::Extra(), CJob::GetAffinityId(), CQueue::GetAffinityTokenByID(), CJob::GetAuthToken(), CJob::GetClientIP(), CJob::GetClientSID(), GetDiagContext(), CJob::GetId(), CQueue::GetJobForReadingOrWait(), CJob::GetNCBIPHID(), CNSClientId::GetNode(), CNSClientId::GetSession(), CJob::GetStatusBeforeReading(), SNSCommandArguments::group, SNSCommandArguments::group_may_change, kEndOfResponse, m_ClientId, m_ClientIdentificationPrinted, m_CommandArguments, m_RollbackAction, CQueue::MakeJobKey(), SNSCommandArguments::port, CDiagContext_Extra::Print(), SNSCommandArguments::prioritized_aff, SNSCommandArguments::reader_affinity, NStr::Split(), CNetScheduleAPI::StatusToString(), SNSCommandArguments::timeout, NStr::URLEncode(), x_CheckNonAnonymousClient(), x_CheckPortAndTimeout(), x_CheckReadParameters(), x_ClearRollbackAction(), x_LogCommandWithJob(), x_NeedCmdLogging(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), and x_WriteMessage().

Definition at line 3841 of file ns_handler.cpp.

References SNSCommandArguments::auth_token, SNSCommandArguments::blacklist, CNetScheduleAPI::eJobNotFound, SNSCommandArguments::job_id, SNSCommandArguments::job_key, m_ClientId, m_CommandArguments, CQueue::ReturnReadingJob(), x_CheckAuthorizationToken(), x_CheckNonAnonymousClient(), and x_FinalizeReadCommand().

Referenced by x_CanBeWithoutQueue().

Definition at line 2684 of file ns_handler.cpp.

References CNetScheduleAPI::eJobNotFound, CNetScheduleAPI::ePending, CNetScheduleAPI::eReading, ERR_POST, CNetScheduleAPI::eRunning, eStatus_InvalidJobStatus, eStatus_NotFound, SNSCommandArguments::job_id, SNSCommandArguments::job_key, kEndOfResponse, kErrNoJobFoundResponse, kOKCompleteResponse, m_ClientId, m_CommandArguments, CQueue::RedoJob(), CNetScheduleAPI::StatusToString(), Warning(), x_CheckNonAnonymousClient(), x_LogCommandWithJob(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), and x_WriteMessage().

Definition at line 4013 of file ns_handler.cpp.

References eStatus_BadRequest, CNetScheduleServer::GetRefuseSubmits(), CNetScheduleServer::IsDrainShutdown(), kEndOfResponse, kOKCompleteResponse, m_ClientId, m_CommandArguments, m_Server, CQueue::MarkClientAsAdmin(), SNSCommandArguments::mode, NULL, SerializeRefuseSubmitState(), CQueue::SetRefuseSubmits(), CNetScheduleServer::SetRefuseSubmits(), CNetScheduleServer::ShutdownRequested(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), and x_WriteMessage().

Referenced by x_ProcessMsgRequest().

Definition at line 3002 of file ns_handler.cpp.

References CNetScheduleServer::AcknowledgeAlert(), CNetScheduleServer::AnybodyCanReconfigure(), CNetScheduleServer::Configure(), eAccess, eConfigOutOfSync, eReconfigure, ERR_POST, eStatus_BadRequest, CDiagContext::Extra(), CMetaRegistry::fReloadIfChanged, CNSClientId::GetClientName(), CNcbiApplicationAPI::GetConfig(), CNcbiApplicationAPI::GetConfigPath(), GetDiagContext(), CJsonNode::GetSize(), CNcbiApplication::Instance(), CNetScheduleServer::IsAdminClientName(), CJsonNode::Iterate(), kEndOfResponse, m_ClientId, m_Server, msg(), NCBI_THROW, CJsonNode::NewObjectNode(), NS_GetConfigFileChecksum(), NS_ValidateConfigFile(), CDiagContext_Extra::Print(), SNS_Parameters::Read(), CNetScheduleServer::ReadServicesConfig(), CNetScheduleServer::RegisterAlert(), CNcbiEncrypt::Reload(), CNcbiApplicationAPI::ReloadConfig(), CJsonNode::Repr(), CNetScheduleServer::SetAnybodyCanReconfigure(), CJsonNode::SetByKey(), CNetScheduleServer::SetDiskConfigFileChecksum(), CNetScheduleServer::SetNSParameters(), CNetScheduleServer::SetRAMConfigFileChecksum(), x_NeedCmdLogging(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), and x_WriteMessage().

Definition at line 3860 of file ns_handler.cpp.

References CNetScheduleAPI::eJobNotFound, CNetScheduleAPI::ePending, CNetScheduleAPI::eReading, ERR_POST, CNetScheduleAPI::eRunning, eStatus_InvalidJobStatus, eStatus_NotFound, SNSCommandArguments::job_id, SNSCommandArguments::job_key, kEndOfResponse, kErrNoJobFoundResponse, kOKCompleteResponse, m_ClientId, m_CommandArguments, CQueue::RereadJob(), CNetScheduleAPI::StatusToString(), Warning(), x_CheckNonAnonymousClient(), x_LogCommandWithJob(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), and x_WriteMessage().

Definition at line 2619 of file ns_handler.cpp.

References SNSCommandArguments::affinity_token, SNSCommandArguments::auth_token, CNetScheduleAPI::eJobNotFound, ERR_POST, CNetScheduleAPI::eRunning, eStatus_BadAuth, eStatus_InvalidJobStatus, eStatus_NotFound, SNSCommandArguments::group, SNSCommandArguments::job_id, SNSCommandArguments::job_key, k_NoAffinityToken, k_NoGroupToken, kEndOfResponse, kErrNoJobFoundResponse, kOKCompleteResponse, m_ClientId, m_CommandArguments, CQueue::RescheduleJob(), CNetScheduleAPI::StatusToString(), Warning(), x_CheckAuthorizationToken(), x_CheckNonAnonymousClient(), x_LogCommandWithJob(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), and x_WriteMessage().

Referenced by x_CanBeWithoutQueue().

Definition at line 2561 of file ns_handler.cpp.

References SNSCommandArguments::auth_token, SNSCommandArguments::blacklist, SNSCommandArguments::cmd, CNetScheduleAPI::eJobNotFound, ERR_POST, CNetScheduleAPI::eRunning, eStatus_InvalidJobStatus, eStatus_NotFound, CQueue::eWithBlacklist, CQueue::eWithoutBlacklist, SNSCommandArguments::job_id, SNSCommandArguments::job_key, kEndOfResponse, kErrNoJobFoundResponse, kOKCompleteResponse, m_ClientId, m_CommandArguments, CQueue::ReturnJob(), CNetScheduleAPI::StatusToString(), Warning(), x_CheckAuthorizationToken(), x_CheckNonAnonymousClient(), x_LogCommandWithJob(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), and x_WriteMessage().

Referenced by x_CanBeWithoutQueue().

Definition at line 1767 of file ns_handler.cpp.

References SNSCommandArguments::affinity_token, SNSCommandArguments::cmd, eGet, eRead, CDiagContext::Extra(), GetDiagContext(), CNSClientId::GetNode(), CNSClientId::GetSession(), k_NoAffinityToken, kOKCompleteResponse, m_ClientId, m_ClientIdentificationPrinted, m_CommandArguments, CDiagContext_Extra::Print(), CQueue::SetAffinity(), NStr::Split(), x_CheckNonAnonymousClient(), x_NeedCmdLogging(), x_PrintCmdRequestStop(), and x_WriteMessage().

Definition at line 3945 of file ns_handler.cpp.

References SNSCommandArguments::client_data, SNSCommandArguments::client_data_version, ERR_POST, eStatus_BadRequest, CNetScheduleServer::GetMaxClientData(), kEndOfResponse, m_ClientId, m_CommandArguments, m_Server, CQueue::SetClientData(), Warning(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), and x_WriteMessage().

Definition at line 3556 of file ns_handler.cpp.

References NStr::CompareNocase(), eStatus_BadRequest, CDiagContext::Extra(), GetDiagContext(), CNSClientId::GetNode(), CRef< C, Locker >::GetPointer(), CNSClientId::GetSession(), kEndOfResponse, kOKCompleteResponse, m_ClientId, m_CommandArguments, m_QueueName, m_QueueRef, m_Server, NULL, CNetScheduleServer::OpenQueue(), CDiagContext_Extra::Print(), SNSCommandArguments::qname, CRef< C, Locker >::Reset(), CWeakRef< C, Locker >::Reset(), CNSClientId::ResetPassedCheck(), CQueue::TouchClientsRegistry(), x_NeedCmdLogging(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), x_UpdateClientPassedChecks(), and x_WriteMessage().

Definition at line 3637 of file ns_handler.cpp.

References ERR_POST, eStatus_BadRequest, CNetScheduleServer::GetScopeRegistrySettings(), CQueue::GetScopeSlotsUsed(), kEndOfResponse, kOKCompleteResponse, m_ClientId, m_CommandArguments, m_Server, SNSRegistryParameters::max_records, SNSCommandArguments::scope, CQueue::SetClientScope(), CNSClientId::SetScope(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), and x_WriteMessage().

Definition at line 3209 of file ns_handler.cpp.

References SNSCommandArguments::drain, eStatus_BadRequest, CNetScheduleServer::IsDrainShutdown(), kEndOfResponse, kOKCompleteResponse, m_CommandArguments, m_Server, CNetScheduleServer::SetDrainShutdown(), CNetScheduleServer::SetRefuseSubmits(), CNetScheduleServer::SetShutdownFlag(), CNetScheduleServer::ShutdownRequested(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), and x_WriteMessage().

Definition at line 2857 of file ns_handler.cpp.

References CTime::AsString(), map_checker< Container >::begin(), bm::bv_statistics::bit_blocks, count, CQueue::CountStatus(), CNSPreciseTime::Current(), CSocket::DisableOSSendDelay(), map_checker< Container >::end(), g_ValidJobStatuses, g_ValidJobStatusesSize, bm::bv_statistics::gap_blocks, CNetScheduleServer::GetQueueClassesInfo(), CNetScheduleServer::GetQueueInfo(), CNetScheduleServer::GetRefuseSubmits(), CQueue::GetRefuseSubmits(), CNetScheduleServer::GetServices(), IServer_ConnectionHandler::GetSocket(), CNetScheduleServer::GetStartTime(), info, CNetScheduleServer::IsDrainShutdown(), kEndOfResponse, m_ClientId, m_CommandArguments, m_Server, CQueue::MarkClientAsAdmin(), bm::bv_statistics::memory_used, NCBI_THROW, NULL, SNSCommandArguments::option, output, CNetScheduleServer::PrintJobsStat(), CNetScheduleServer::PrintTransitionCounters(), CQueue::PrintTransitionCounters(), CNetScheduleServer::SerializeAlerts(), st(), CQueue::StatusStatistics(), CNetScheduleAPI::StatusToString(), x_MakeSureSingleEOR(), x_PrintCmdRequestStop(), x_StatisticsNew(), and x_WriteMessage().

Referenced by x_ProcessMsgRequest().

Definition at line 2056 of file ns_handler.cpp.

References SNSCommandArguments::cmd, CNetScheduleAPI::eJobNotFound, CQueue::ePauseWithoutPullback, CQueue::ePauseWithPullback, ERR_POST, eStatus_NotFound, CJob::GetClientIP(), CJob::GetClientSID(), CJob::GetErrorMsg(), CJob::GetInput(), CJob::GetNCBIPHID(), CJob::GetOutput(), CQueue::GetPauseStatus(), CJob::GetProgressMsg(), CJob::GetRetCode(), CJob::GetStatus(), SNSCommandArguments::job_id, SNSCommandArguments::job_key, kEndOfResponse, kErrNoJobFoundResponse, kOKResponsePrefix, m_CommandArguments, SNSCommandArguments::need_progress_msg, NStr::PrintableString(), CQueue::ReadAndTouchJob(), CNSPreciseTime::Sec(), CNetScheduleAPI::StatusToString(), NStr::URLEncode(), Warning(), x_LogCommandWithJob(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), and x_WriteMessage().

Referenced by x_CanBeWithoutQueue().

Definition at line 1795 of file ns_handler.cpp.

References SNSCommandArguments::affinity_token, CNetScheduleServer::DecrementCurrentSubmitsCounter(), eStatus_SubmitRefused, CNetScheduleServer::GetRefuseSubmits(), CQueue::GetRefuseSubmits(), SNSCommandArguments::group, CNetScheduleServer::IncrementCurrentSubmitsCounter(), k_NoAffinityToken, k_NoGroupToken, kEndOfResponse, kOKResponsePrefix, kSubmitCounterInitialValue, m_ClientId, m_CommandArguments, m_RollbackAction, m_Server, CQueue::MakeJobKey(), CQueue::Submit(), x_ClearRollbackAction(), x_NeedCmdLogging(), x_PrintCmdRequestStop(), x_SetCmdRequestStatus(), and x_WriteMessage().

Referenced by x_NeedToGeneratePHIDAndSID().

Definition at line 1845 of file ns_handler.cpp.

References CNetScheduleServer::DecrementCurrentSubmitsCounter(), eStatus_SubmitRefused, CNetScheduleServer::GetRefuseSubmits(), CQueue::GetRefuseSubmits(), SNSCommandArguments::group, CNetScheduleServer::IncrementCurrentSubmitsCounter(), SNSCommandArguments::ip, k_NoGroupToken, kEndOfResponse, kSubmitCounterInitialValue, m_BatchClientIP, m_BatchClientSID, m_BatchGroup, m_BatchNCBIPHID, m_BatchSubmPort, m_BatchSubmTimeout, m_CommandArguments, m_ProcessMessage, m_Server, m_WithinBatchSubmit, SNSCommandArguments::ncbi_phid, SNSCommandArguments::port, SNSCommandArguments::sid, SNSCommandArguments::timeout, x_PrintCmdRequestStop(), x_ProcessMsgBatchHeader(), x_ProcessMsgRequest(), x_SetCmdRequestStatus(), and x_WriteMessage().

Referenced by x_NeedToGeneratePHIDAndSID().

Definition at line 3270 of file ns_handler.cpp.

References CNetScheduleServer::GetNodeID(), CDiagContext::GetPID(), CNetScheduleServer::GetSessionID(), kEndOfResponse, m_Server, NETSCHEDULED_BUILD_DATE, NETSCHEDULED_PROTOCOL_VERSION, NETSCHEDULED_STORAGE_VERSION, NETSCHEDULED_VERSION, NStr::URLEncode(), x_PrintCmdRequestStop(), and x_WriteMessage().

Definition at line 128 of file ns_handler.hpp.

References m_CmdContext, CRef< C, Locker >::NotNull(), and CRequestContext::SetRequestStatus().

Referenced by OnMessage(), x_CmdNotImplemented(), x_CmdObsolete(), x_FinalizeReadCommand(), x_OnCmdParserError(), x_ProcessCancel(), x_ProcessChangeAffinity(), x_ProcessDump(), x_ProcessFastStatusS(), x_ProcessFastStatusW(), x_ProcessGetJob(), x_ProcessGetMessage(), x_ProcessJobDelayExpiration(), x_ProcessJobDelayReadExpiration(), x_ProcessJobExchange(), x_ProcessListenJob(), x_ProcessMsgBatchHeader(), x_ProcessMsgBatchJob(), x_ProcessMsgBatchSubmit(), x_ProcessPut(), x_ProcessPutFailure(), x_ProcessPutMessage(), x_ProcessQueueInfo(), x_ProcessReading(), x_ProcessRedo(), x_ProcessRefuseSubmits(), x_ProcessReloadConfig(), x_ProcessReread(), x_ProcessReschedule(), x_ProcessReturn(), x_ProcessSetClientData(), x_ProcessSetQueue(), x_ProcessSetScope(), x_ProcessShutdown(), x_ProcessStatus(), x_ProcessSubmit(), and x_ProcessSubmitBatch().

Definition at line 4557 of file ns_handler.cpp.

References SNSCommandArguments::affinity_token, SNSCommandArguments::comment, SNSCommandArguments::group, info, kEndOfResponse, m_ClientId, m_CommandArguments, msg(), CQueue::PrintAffinitiesList(), CQueue::PrintClientsList(), CQueue::PrintGroupsList(), CQueue::PrintJobsStat(), CQueue::PrintNotificationsList(), CQueue::PrintScopesList(), x_MakeSureSingleEOR(), x_PrintCmdRequestStop(), and x_WriteMessage().

Referenced by x_ProcessStatistics().

Definition at line 1280 of file ns_handler.cpp.

References eNS_Program, eNS_Queue, eNS_Reader, eNS_Submitter, eNS_Worker, CNSClientId::GetAddress(), CNSClientId::GetProgramName(), CNSClientId::IsAdmin(), CQueue::IsProgramAllowed(), CQueue::IsReaderAllowed(), CQueue::IsSubmitAllowed(), CQueue::IsWorkerAllowed(), m_ClientId, NULL, CNSClientId::ResetPassedCheck(), CQueue::SetClientScope(), and CNSClientId::SetPassedChecks().

Referenced by x_ProcessMsgQueue(), x_ProcessMsgRequest(), and x_ProcessSetQueue().

Definition at line 920 of file ns_handler.cpp.

References SErrorEmulatorParameter::as_bool, CServer::CloseConnection(), CNSPreciseTime::Current(), eIO_Success, CNetScheduleServer::GetDebugConnDropAfterWrite(), IServer_ConnectionHandler::GetSocket(), SErrorEmulatorParameter::IsActive(), m_ConnContext, m_MsgBuffer, m_Server, msg(), CRef< C, Locker >::NotNull(), NULL, result, CSocket::Write(), x_HandleSocketErrorOnResponse(), and x_PrepareWriteBuffer().

Referenced by OnMessage(), x_CmdNotImplemented(), x_CmdObsolete(), x_FinalizeReadCommand(), x_OnCmdParserError(), x_PrintGetJobResponse(), x_ProcessAckAlert(), x_ProcessActiveCount(), x_ProcessBatchSequenceEnd(), x_ProcessCancel(), x_ProcessCancelQueue(), x_ProcessCancelWaitGet(), x_ProcessCancelWaitRead(), x_ProcessChangeAffinity(), x_ProcessClearWorkerNode(), x_ProcessCreateDynamicQueue(), x_ProcessDeleteDynamicQueue(), x_ProcessDropQueue(), x_ProcessDump(), x_ProcessFastStatusS(), x_ProcessFastStatusW(), x_ProcessGetConf(), x_ProcessGetConfiguration(), x_ProcessGetJob(), x_ProcessGetMessage(), x_ProcessGetParam(), x_ProcessHealth(), x_ProcessJobDelayExpiration(), x_ProcessJobDelayReadExpiration(), x_ProcessJobExchange(), x_ProcessListenJob(), x_ProcessMsgBatchHeader(), x_ProcessMsgBatchJob(), x_ProcessMsgBatchSubmit(), x_ProcessMsgQueue(), x_ProcessPause(), x_ProcessPut(), x_ProcessPutFailure(), x_ProcessPutMessage(), x_ProcessQList(), x_ProcessQueueInfo(), x_ProcessReading(), x_ProcessRedo(), x_ProcessRefuseSubmits(), x_ProcessReloadConfig(), x_ProcessReread(), x_ProcessReschedule(), x_ProcessResume(), x_ProcessReturn(), x_ProcessSetAffinity(), x_ProcessSetClientData(), x_ProcessSetQueue(), x_ProcessSetScope(), x_ProcessShutdown(), x_ProcessStatistics(), x_ProcessStatus(), x_ProcessSubmit(), x_ProcessSubmitBatch(), x_ProcessVersion(), and x_StatisticsNew().

Definition at line 277 of file ns_handler.hpp.

Referenced by x_CheckNonAnonymousClient(), x_HandleSocketErrorOnResponse(), x_ProcessCancel(), x_ProcessCancelQueue(), x_ProcessCancelWaitGet(), x_ProcessCancelWaitRead(), x_ProcessChangeAffinity(), x_ProcessClearWorkerNode(), x_ProcessConfirm(), x_ProcessCreateDynamicQueue(), x_ProcessDeleteDynamicQueue(), x_ProcessDropQueue(), x_ProcessDump(), x_ProcessGetJob(), x_ProcessJobExchange(), x_ProcessListenJob(), x_ProcessMsgBatchSubmit(), x_ProcessMsgQueue(), x_ProcessMsgRequest(), x_ProcessPause(), x_ProcessPut(), x_ProcessPutFailure(), x_ProcessQueueInfo(), x_ProcessReadFailed(), x_ProcessReading(), x_ProcessReadRollback(), x_ProcessRedo(), x_ProcessRefuseSubmits(), x_ProcessReloadConfig(), x_ProcessReread(), x_ProcessReschedule(), x_ProcessResume(), x_ProcessReturn(), x_ProcessSetAffinity(), x_ProcessSetClientData(), x_ProcessSetQueue(), x_ProcessSetScope(), x_ProcessStatistics(), x_ProcessSubmit(), x_StatisticsNew(), and x_UpdateClientPassedChecks().

Definition at line 282 of file ns_handler.hpp.

Referenced by x_CheckAuthorizationToken(), x_CheckGetParameters(), x_CheckPortAndTimeout(), x_CheckQInf2Parameters(), x_CheckReadParameters(), x_FinalizeReadCommand(), x_ProcessAckAlert(), x_ProcessCancel(), x_ProcessChangeAffinity(), x_ProcessConfirm(), x_ProcessCreateDynamicQueue(), x_ProcessDeleteDynamicQueue(), x_ProcessDump(), x_ProcessFastStatusS(), x_ProcessFastStatusW(), x_ProcessGetConf(), x_ProcessGetJob(), x_ProcessGetMessage(), x_ProcessGetParam(), x_ProcessJobDelayExpiration(), x_ProcessJobDelayReadExpiration(), x_ProcessJobExchange(), x_ProcessListenJob(), x_ProcessMsgBatchJob(), x_ProcessMsgRequest(), x_ProcessPause(), x_ProcessPut(), x_ProcessPutFailure(), x_ProcessPutMessage(), x_ProcessQueueInfo(), x_ProcessReadFailed(), x_ProcessReading(), x_ProcessReadRollback(), x_ProcessRedo(), x_ProcessRefuseSubmits(), x_ProcessReread(), x_ProcessReschedule(), x_ProcessReturn(), x_ProcessSetAffinity(), x_ProcessSetClientData(), x_ProcessSetQueue(), x_ProcessSetScope(), x_ProcessShutdown(), x_ProcessStatistics(), x_ProcessStatus(), x_ProcessSubmit(), x_ProcessSubmitBatch(), x_StatisticsNew(), and x_WorkerNodeCommand().

Definition at line 310 of file ns_handler.hpp.

Referenced by OnClose(), OnMessage(), OnTimeout(), x_CreateConnContext(), x_GetConnRef(), x_HandleSocketErrorOnResponse(), x_NeedCmdLogging(), x_PrepareWriteBuffer(), x_ProcessMsgQueue(), x_SetConnRequestStatus(), x_SetRequestContext(), and x_WriteMessage().

Definition at line 279 of file ns_handler.hpp.

Referenced by OnClose(), OnMessage(), OnOpen(), x_GetPeerAddress(), x_GetServerSection(), x_HandleSocketErrorOnResponse(), x_OnCmdParserError(), x_PrepareWriteBuffer(), x_ProcessAckAlert(), x_ProcessActiveCount(), x_ProcessBatchSequenceEnd(), x_ProcessCreateDynamicQueue(), x_ProcessDeleteDynamicQueue(), x_ProcessGetConf(), x_ProcessHealth(), x_ProcessMsgAuth(), x_ProcessMsgBatchHeader(), x_ProcessMsgBatchJob(), x_ProcessMsgBatchSubmit(), x_ProcessMsgQueue(), x_ProcessMsgRequest(), x_ProcessQList(), x_ProcessQueueInfo(), x_ProcessQuitSession(), x_ProcessRefuseSubmits(), x_ProcessReloadConfig(), x_ProcessSetClientData(), x_ProcessSetQueue(), x_ProcessSetScope(), x_ProcessShutdown(), x_ProcessStatistics(), x_ProcessSubmit(), x_ProcessSubmitBatch(), x_ProcessVersion(), and x_WriteMessage().

= {

}

void x_ProcessBatchSequenceEnd(CQueue *)

void x_ProcessBatchStart(CQueue *)

Definition at line 304 of file ns_handler.hpp.

The documentation for this class was generated from the following files:

• src/app/netschedule/ns_handler.hpp
• src/app/netschedule/ns_handler.cpp

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