#include <util/ncbi_url.hpp>
#include <tuple>

Include dependency graph for netschedule_api_int.hpp:

This graph shows which files directly or indirectly include this file:

Classes
struct	SNetScheduleOutputParser

struct	SNetScheduleNotificationReceiver

class	CNetScheduleNotificationHandler

struct	CNetScheduleAPIExt

class	CNetScheduleAdmin

struct	CNetScheduleAdmin::SWorkerNodeInfo

struct	CNetScheduleAdmin::SServerQueueList

Enumerations
enum	ENetScheduleStatTopic { eNetScheduleStatJobGroups , eNetScheduleStatClients , eNetScheduleStatNotifications , eNetScheduleStatAffinities , eNumberOfNetStheduleStatTopics }

Functions
	NCBI_DECLARE_INTERFACE_VERSION (SNetScheduleAPIImpl, "xnetschedule_api", 1, 0, 0)

NCBI_XCONNECT_EXPORT int	g_ParseNSOutput (const string &attr_string, const char const attr_names, string *attr_values, size_t attr_count)

void	NCBI_EntryPoint_xnetscheduleapi (CPluginManager< SNetScheduleAPIImpl >::TDriverInfoList &info_list, CPluginManager< SNetScheduleAPIImpl >::EEntryPointRequest method)

CJsonNode	g_GetWorkerNodeInfo (CNetScheduleAPI api)

string	g_UnquoteIfQuoted (const CTempString &str)

string	g_GetNetScheduleStatCommand (ENetScheduleStatTopic topic)

CJsonNode	g_GenericStatToJson (CNetServer server, ENetScheduleStatTopic topic, bool verbose)

bool	g_FixMisplacedPID (CJsonNode &stat_info, CTempString &executable_path, const char *pid_key)

CJsonNode	g_ServerInfoToJson (CNetServerInfo server_info, bool server_version_key)

CJsonNode	g_WorkerNodeInfoToJson (CNetServer worker_node)

Variables
const unsigned int	kNetScheduleMaxDBDataSize = 2048

const unsigned int	kNetScheduleMaxDBErrSize = 4096

const char *const	kNetScheduleAPIDriverName

Enumeration Type Documentation

◆ ENetScheduleStatTopic

enum ENetScheduleStatTopic

Enumerator
eNetScheduleStatJobGroups
eNetScheduleStatClients
eNetScheduleStatNotifications
eNetScheduleStatAffinities
eNumberOfNetStheduleStatTopics

Definition at line 327 of file netschedule_api_int.hpp.

Function Documentation

◆ g_FixMisplacedPID()

bool g_FixMisplacedPID	(	CJsonNode &	stat_info,
		CTempString &	executable_path,
		const char *	pid_key
	)

Definition at line 173 of file netschedule_api_wn_info.cpp.

References CTempString::data(), CTempString::erase(), NStr::Find(), CTempString::length(), NPOS, CJsonNode::SetInteger(), and NStr::StringToInt8().

Referenced by g_LegacyStatToJson(), and g_WorkerNodeInfoToJson().

◆ g_GenericStatToJson()

CJsonNode g_GenericStatToJson	(	CNetServer	server,
		ENetScheduleStatTopic	topic,
		bool	verbose
	)

Definition at line 191 of file netschedule_api_wn_info.cpp.

References CJsonNode::Append(), CJsonNode::AppendString(), command, eNetScheduleStatClients, entity_name, NStr::eTrunc_Begin, CNetServer::ExecWithRetry(), g_AppendClientIPSessionIDHitID(), g_UnquoteIfQuoted(), CJsonNode::GuessType(), ncbi::grid::netcache::search::fields::key, CTempString::length(), CJsonNode::NewArrayNode(), CJsonNode::NewObjectNode(), CJsonNode::NewStringNode(), NormalizeStatKeyName(), NULL, output, record_prefix, s_StatTopics, CJsonNode::SetByKey(), CJsonNode::SetString(), NStr::SplitInTwo(), NStr::StartsWith(), NStr::TruncateSpaces(), NStr::TruncateSpaces_Unsafe(), and rapidjson::value.

Referenced by NAutomation::SNetScheduleServer::ExecAffinityInfo(), NAutomation::SNetScheduleServer::ExecClientInfo(), NAutomation::SNetScheduleServer::ExecJobGroupInfo(), NAutomation::SNetScheduleServer::ExecNotificationInfo(), g_GetWorkerNodes(), and CGridCommandLineInterfaceApp::PrintNetScheduleStats_Generic().

◆ g_GetNetScheduleStatCommand()

string g_GetNetScheduleStatCommand ( ENetScheduleStatTopic topic )

Definition at line 126 of file netschedule_api_wn_info.cpp.

References s_StatTopics.

Referenced by CGridCommandLineInterfaceApp::PrintNetScheduleStats_Generic().

◆ g_GetWorkerNodeInfo()

CJsonNode g_GetWorkerNodeInfo ( CNetScheduleAPI api )

Definition at line 85 of file netschedule_api_wn_info.cpp.

References ERR_POST, g_GetWorkerNodes(), g_WorkerNodeInfoToJson(), SNetServiceImpl::GetClientName(), CNetServiceIterator::GetServer(), CNetScheduleAPI::GetService(), CNetService::Iterate(), ITERATE, kEmptyStr, SNetScheduleAPIImpl::m_Service, CJsonNode::NewObjectNode(), NStr::NumericToString(), and result.

◆ g_ParseNSOutput()

NCBI_XCONNECT_EXPORT int g_ParseNSOutput	(	const string &	attr_string,
		const char const	attr_names,
		string *	attr_values,
		size_t	attr_count
	)

Deprecated:: , use SNetScheduleOutputParser instead

Definition at line 129 of file netschedule_api.cpp.

References CUrlArgs::FindFirst(), and CUrlArgs::GetArgs().

◆ g_ServerInfoToJson()

CJsonNode g_ServerInfoToJson	(	CNetServerInfo	server_info,
		bool	server_version_key
	)

Definition at line 250 of file netschedule_api_wn_info.cpp.

References eDefault, NStr::EndsWith(), eOff, eOn, CNetServerInfo::GetNextAttribute(), CJsonNode::NewObjectNode(), NStr::ReplaceInPlace(), CJsonNode::SetString(), and NStr::ToLower().

Referenced by CGridCommandLineInterfaceApp::Cmd_ServerInfo(), NAutomation::SNetService::ExecServerInfo(), NAutomation::SWorkerNode::ExecVersion(), and g_WorkerNodeInfoToJson().

◆ g_UnquoteIfQuoted()

string g_UnquoteIfQuoted ( const CTempString & str )

Definition at line 134 of file netschedule_api_wn_info.cpp.

References NStr::ParseQuoted(), and str().

Referenced by g_GenericStatToJson(), and CJobInfoToJSON::ProcessJobMeta().

◆ g_WorkerNodeInfoToJson()

CJsonNode g_WorkerNodeInfoToJson ( CNetServer worker_node )

Definition at line 331 of file netschedule_api_wn_info.cpp.

References CJsonNode::Append(), NStr::eNocase, NStr::eReverseSearch, CNetServer::ExecWithRetry(), NStr::fAllowLeadingSpaces, NStr::fAllowTrailingSymbols, NStr::fConvErr_NoThrow, NStr::Find(), g_FixMisplacedPID(), g_ServerInfoFromString(), g_ServerInfoToJson(), CJsonNode::GetSize(), CJsonNode::GuessType(), CJsonNode::HasKey(), isspace(), kEmptyStr, ncbi::grid::netcache::search::fields::key, CJsonNode::NewArrayNode(), CJsonNode::NewObjectNode(), NPOS, output, s_ExtractKey(), s_WordsToJsonArray(), CJsonNode::SetByKey(), CJsonNode::SetInteger(), CJsonNode::SetString(), NStr::StartsWith(), NStr::StringToInt(), NStr::StringToInt8(), NStr::StringToUInt8(), TEMP_STRING_CTOR, and rapidjson::value.

Referenced by CGridCommandLineInterfaceApp::Cmd_Stats(), NAutomation::SWorkerNode::ExecWnInfo(), and g_GetWorkerNodeInfo().

◆ NCBI_DECLARE_INTERFACE_VERSION()

NCBI_DECLARE_INTERFACE_VERSION	(	SNetScheduleAPIImpl	,
		"xnetschedule_api"	,
		1	,
		0	,
		0
	)

◆ NCBI_EntryPoint_xnetscheduleapi()

void NCBI_EntryPoint_xnetscheduleapi	(	CPluginManager< SNetScheduleAPIImpl >::TDriverInfoList &	info_list,
		CPluginManager< SNetScheduleAPIImpl >::EEntryPointRequest	method
	)

Definition at line 1319 of file netschedule_api.cpp.

References CHostEntryPointImpl< TClassFactory >::NCBI_EntryPointImpl().

Referenced by CNetScheduleClientFactory::CNetScheduleClientFactory().

Variable Documentation

◆ kNetScheduleAPIDriverName

const char* const kNetScheduleAPIDriverName

extern

Definition at line 710 of file netschedule_api.cpp.

Referenced by CNetScheduleClientFactory::CreateInstance(), SGridWorkerNodeImpl::Run(), and SNetScheduleAPIImpl::SNetScheduleAPIImpl().

◆ kNetScheduleMaxDBDataSize

const unsigned int kNetScheduleMaxDBDataSize = 2048

Definition at line 43 of file netschedule_api_int.hpp.

Referenced by SNSCommandArguments::AssignValues(), CJob::LoadFromDump(), SNetScheduleAPIImpl::SServerParamsSync::operator()(), CNetScheduleExecutor::PutProgressMsg(), SAffinityDictDump::Read(), SGroupDictDump::Read(), SJobDump::Read(), SQueueParameters::ReadMaxInputSize(), SQueueParameters::ReadMaxOutputSize(), SNSCommandArguments::x_CheckAffinityList(), and SNSCommandArguments::x_CheckGroupList().

◆ kNetScheduleMaxDBErrSize

const unsigned int kNetScheduleMaxDBErrSize = 4096

Definition at line 45 of file netschedule_api_int.hpp.

Referenced by CJob::LoadFromDump(), CNetScheduleExecutor::PutFailure(), SJobEventsDump::Read(), and SNSCommandArguments::x_NormalizeErrorMessage().

Classes

Enumerations

Functions

Variables