NCBI C++ ToolKit
Functions | Variables
ns_handler.cpp File Reference
#include <ncbi_pch.hpp>
#include <corelib/ncbi_system.hpp>
#include <corelib/resource_info.hpp>
#include "ns_handler.hpp"
#include "ns_server.hpp"
#include "ns_server_misc.hpp"
#include "ns_rollback.hpp"
#include "queue_database.hpp"
#include "ns_application.hpp"
#include "ns_restore_state.hpp"
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/tcp.h>
+ Include dependency graph for ns_handler.cpp:

Go to the source code of this file.

Go to the SVN repository for this file.

Functions

static size_t s_BufReadHelper (void *data, const void *ptr, size_t size)
 
static void s_ReadBufToString (BUF buf, string &str)
 

Variables

 USING_NCBI_SCOPE
 
const string kEndOfResponse = "\n"
 
const string kOKCompleteResponse = "OK:" + kEndOfResponse
 
const string kErrNoJobFoundResponse = "ERR:eJobNotFound:" + kEndOfResponse
 
const string kOKResponsePrefix = "OK:"
 
SNSProtoArgument s_BatchArgs []
 
static SNSProtoArgument s_AuthArgs []
 
static const unsigned int kMaxParserErrMsgLength = 128
 

Function Documentation

◆ s_BufReadHelper()

static size_t s_BufReadHelper ( void *  data,
const void *  ptr,
size_t  size 
)
static

Definition at line 592 of file ns_handler.cpp.

References ncbi::grid::netcache::search::fields::size.

Referenced by s_ReadBufToString().

◆ s_ReadBufToString()

static void s_ReadBufToString ( BUF  buf,
string str 
)
static

Variable Documentation

◆ kEndOfResponse

const string kEndOfResponse = "\n"

Definition at line 55 of file ns_handler.cpp.

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

◆ kErrNoJobFoundResponse

const string kErrNoJobFoundResponse = "ERR:eJobNotFound:" + kEndOfResponse

◆ kMaxParserErrMsgLength

const unsigned int kMaxParserErrMsgLength = 128
static

Definition at line 4519 of file ns_handler.cpp.

Referenced by CNetScheduleHandler::x_OnCmdParserError().

◆ kOKCompleteResponse

const string kOKCompleteResponse = "OK:" + kEndOfResponse

◆ kOKResponsePrefix

const string kOKResponsePrefix = "OK:"

◆ s_AuthArgs

SNSProtoArgument s_AuthArgs[]
static
Initial value:
= {
{ "client", eNSPT_Str, eNSPA_Optional, "Unknown client" },
{ "params", eNSPT_Str, eNSPA_Ellipsis },
{ NULL }
}
#define NULL
Definition: ncbistd.hpp:225

Definition at line 574 of file ns_handler.cpp.

Referenced by CNetScheduleHandler::x_ProcessMsgQueue().

◆ s_BatchArgs

SNSProtoArgument s_BatchArgs[]
Initial value:
= {
{ "input", eNSPT_Str, eNSPA_Required },
{ "aff", eNSPT_Str, eNSPA_Optional, "" },
{ "msk", eNSPT_Int, eNSPA_Optional, "0" },
{ NULL }
}

Definition at line 79 of file ns_handler.cpp.

Referenced by CNetScheduleHandler::x_ProcessMsgBatchJob().

◆ USING_NCBI_SCOPE

USING_NCBI_SCOPE

Definition at line 51 of file ns_handler.cpp.

Modified on Fri Mar 01 10:08:47 2024 by modify_doxy.py rev. 669887