NCBI C++ ToolKit
|
Search Toolkit Book for NAutomation::SNetScheduleService
#include "ns_automation.hpp"
(Private to src/app/grid/grid_cli
.)
Public Types | |
using | TSelf = SNetScheduleService |
![]() | |
using | TSelf = SNetService |
![]() | |
using | TSelf = SNetServiceBase |
![]() | |
enum | EAllocFillMode { eAllocFillNone = 1 , eAllocFillZero , eAllocFillPattern } |
Control filling of newly allocated memory. More... | |
typedef CObjectCounterLocker | TLockerType |
Default locker type for CRef. More... | |
typedef atomic< Uint8 > | TCounter |
Counter type is CAtomiCounter. More... | |
typedef Uint8 | TCount |
Alias for value type of counter. More... | |
Public Member Functions | |
virtual const string & | GetType () const |
CNetService | GetService () |
void | ExecSetClientType (const TArguments &args, SInputOutput &io) |
void | ExecSetNodeSession (const TArguments &args, SInputOutput &io) |
void | ExecQueueInfo (const TArguments &args, SInputOutput &io) |
void | ExecQueueClassInfo (const TArguments &args, SInputOutput &io) |
void | ExecReconf (const TArguments &args, SInputOutput &io) |
void | ExecSuspend (const TArguments &args, SInputOutput &io) |
void | ExecResume (const TArguments &args, SInputOutput &io) |
void | ExecShutdown (const TArguments &args, SInputOutput &io) |
void | ExecParseKey (const TArguments &args, SInputOutput &io) |
void | ExecJobInfo (const TArguments &args, SInputOutput &io) |
void | ExecJobCounters (const TArguments &args, SInputOutput &io) |
void | ExecGetServers (const TArguments &args, SInputOutput &io) |
![]() | |
SNetService (CAutomationProc *automation_proc) | |
void | ExecServerInfo (const TArguments &args, SInputOutput &io) |
void | ExecExec (const TArguments &args, SInputOutput &io) |
![]() | |
SNetServiceBase (CAutomationProc *automation_proc) | |
CNetServer | GetServer () |
void | ExecGetName (const TArguments &args, SInputOutput &io) |
void | ExecGetAddress (const TArguments &args, SInputOutput &io) |
![]() | |
CAutomationObject (CAutomationProc *automation_proc) | |
void | SetID (TObjectID object_id) |
TObjectID | GetID () const |
![]() | |
CObject (void) | |
Constructor. More... | |
CObject (const CObject &src) | |
Copy constructor. More... | |
virtual | ~CObject (void) |
Destructor. More... | |
CObject & | operator= (const CObject &src) THROWS_NONE |
Assignment operator. More... | |
bool | CanBeDeleted (void) const THROWS_NONE |
Check if object can be deleted. More... | |
bool | IsAllocatedInPool (void) const THROWS_NONE |
Check if object is allocated in memory pool (not system heap) More... | |
bool | Referenced (void) const THROWS_NONE |
Check if object is referenced. More... | |
bool | ReferencedOnlyOnce (void) const THROWS_NONE |
Check if object is referenced only once. More... | |
void | AddReference (void) const |
Add reference to object. More... | |
void | RemoveReference (void) const |
Remove reference to object. More... | |
void | ReleaseReference (void) const |
Remove reference without deleting object. More... | |
virtual void | DoNotDeleteThisObject (void) |
Mark this object as not allocated in heap – do not delete this object. More... | |
virtual void | DoDeleteThisObject (void) |
Mark this object as allocated in heap – object can be deleted. More... | |
void * | operator new (size_t size) |
Define new operator for memory allocation. More... | |
void * | operator new[] (size_t size) |
Define new[] operator for 'array' memory allocation. More... | |
void | operator delete (void *ptr) |
Define delete operator for memory deallocation. More... | |
void | operator delete[] (void *ptr) |
Define delete[] operator for memory deallocation. More... | |
void * | operator new (size_t size, void *place) |
Define new operator. More... | |
void | operator delete (void *ptr, void *place) |
Define delete operator. More... | |
void * | operator new (size_t size, CObjectMemoryPool *place) |
Define new operator using memory pool. More... | |
void | operator delete (void *ptr, CObjectMemoryPool *place) |
Define delete operator. More... | |
virtual void | DebugDump (CDebugDumpContext ddc, unsigned int depth) const |
Define method for dumping debug information. More... | |
![]() | |
CDebugDumpable (void) | |
virtual | ~CDebugDumpable (void) |
void | DebugDumpText (ostream &out, const string &bundle, unsigned int depth) const |
void | DebugDumpFormat (CDebugDumpFormatter &ddf, const string &bundle, unsigned int depth) const |
void | DumpToConsole (void) const |
Static Public Member Functions | |
static CCommand | CallCommand () |
static TCommands | CallCommands () |
static CCommand | NewCommand () |
static CAutomationObject * | Create (const TArguments &args, CAutomationProc *automation_proc) |
![]() | |
static TCommands | CallCommands () |
![]() | |
static TCommands | CallCommands () |
![]() | |
template<class TDerived > | |
static void * | CheckCall (const string &name, SInputOutput &io, void *data) |
template<class TDerived > | |
static void | ExecNew (const TArguments &args, SInputOutput &io, void *data) |
template<class TClass , void(TClass::*)(const TArguments &, SInputOutput &io) Method> | |
static void | ExecMethod (const TArguments &args, SInputOutput &io, void *data) |
![]() | |
static NCBI_XNCBI_EXPORT void | ThrowNullPointerException (void) |
Define method to throw null pointer exception. More... | |
static NCBI_XNCBI_EXPORT void | ThrowNullPointerException (const type_info &type) |
static EAllocFillMode | GetAllocFillMode (void) |
static void | SetAllocFillMode (EAllocFillMode mode) |
static void | SetAllocFillMode (const string &value) |
Set mode from configuration parameter value. More... | |
![]() | |
static void | EnableDebugDump (bool on) |
Static Public Attributes | |
static const string | kName = "nssvc" |
![]() | |
static const TCount | eCounterBitsCanBeDeleted = 1 << 0 |
Define possible object states. More... | |
static const TCount | eCounterBitsInPlainHeap = 1 << 1 |
Heap signature was found. More... | |
static const TCount | eCounterBitsPlaceMask |
Mask for 'in heap' state flags. More... | |
static const int | eCounterStep = 1 << 2 |
Skip over the "in heap" bits. More... | |
static const TCount | eCounterValid = TCount(1) << (sizeof(TCount) * 8 - 2) |
Minimal value for valid objects (reference counter is zero) Must be a single bit value. More... | |
static const TCount | eCounterStateMask |
Valid object, and object in heap. More... | |
Protected Member Functions | |
SNetScheduleService (CAutomationProc *automation_proc, CNetScheduleAPI ns_api) | |
![]() | |
virtual void | DeleteThis (void) |
Virtual method "deleting" this object. More... | |
Protected Attributes | |
CNetScheduleAPIExt | m_NetScheduleAPI |
![]() | |
TObjectID | m_Id |
Additional Inherited Members | |
![]() | |
CAutomationProc * | m_AutomationProc |
Definition at line 42 of file ns_automation.hpp.
Definition at line 44 of file ns_automation.hpp.
|
protected |
Definition at line 43 of file ns_automation.cpp.
References GetService(), NAutomation::CAutomationObject::m_AutomationProc, m_NetScheduleAPI, NAutomation::CAutomationProc::ReturnNetScheduleServerObject(), NAutomation::CAutomationProc::SendWarning(), and CNetService::SetWarningHandler().
Referenced by Create().
|
static |
Definition at line 235 of file ns_automation.cpp.
References CallCommands(), and kName.
Referenced by NAutomation::CAutomationProc::CallCommands().
|
static |
Definition at line 240 of file ns_automation.cpp.
References NAutomation::SNetService::CallCommands(), and CJsonNode::eString.
Referenced by CallCommand(), and NAutomation::SNetScheduleServer::CallCommands().
|
static |
Definition at line 79 of file ns_automation.cpp.
References _ASSERT, CNetScheduleAPIExt::CreateNoCfgLoad(), and SNetScheduleService().
void SNetScheduleService::ExecGetServers | ( | const TArguments & | args, |
SInputOutput & | io | ||
) |
Definition at line 384 of file ns_automation.cpp.
References CJsonNode::AppendInteger(), CNetService::eIncludePenalized, NAutomation::CAutomationObject::GetID(), CNetScheduleAPI::GetService(), CNetService::Iterate(), NAutomation::CAutomationObject::m_AutomationProc, m_NetScheduleAPI, CJsonNode::NewArrayNode(), and NAutomation::SInputOutput::reply.
void SNetScheduleService::ExecJobCounters | ( | const TArguments & | args, |
SInputOutput & | io | ||
) |
Definition at line 367 of file ns_automation.cpp.
References _ASSERT, CNetScheduleAPI::GetAdmin(), ITERATE, m_NetScheduleAPI, CJsonNode::NewObjectNode(), NAutomation::SInputOutput::reply, CJsonNode::SetInteger(), and CNetScheduleAdmin::StatusSnapshot().
void SNetScheduleService::ExecJobInfo | ( | const TArguments & | args, |
SInputOutput & | io | ||
) |
Definition at line 355 of file ns_automation.cpp.
References _ASSERT, g_ProcessJobInfo(), CNetScheduleAPIExt::GetCompoundIDPool(), CJobInfoToJSON::GetRootNode(), m_NetScheduleAPI, and NAutomation::SInputOutput::reply.
void SNetScheduleService::ExecParseKey | ( | const TArguments & | args, |
SInputOutput & | io | ||
) |
Definition at line 344 of file ns_automation.cpp.
References _ASSERT, CNetScheduleAPIExt::GetCompoundIDPool(), CJobInfoToJSON::GetRootNode(), m_NetScheduleAPI, CJobInfoToJSON::ProcessJobMeta(), and NAutomation::SInputOutput::reply.
void SNetScheduleService::ExecQueueClassInfo | ( | const TArguments & | args, |
SInputOutput & | io | ||
) |
Definition at line 310 of file ns_automation.cpp.
References CJsonNode::Append(), g_QueueClassInfoToJson(), m_NetScheduleAPI, and NAutomation::SInputOutput::reply.
void SNetScheduleService::ExecQueueInfo | ( | const TArguments & | args, |
SInputOutput & | io | ||
) |
Definition at line 301 of file ns_automation.cpp.
References _ASSERT, g_QueueInfoToJson(), m_NetScheduleAPI, and NAutomation::SInputOutput::reply.
void SNetScheduleService::ExecReconf | ( | const TArguments & | args, |
SInputOutput & | io | ||
) |
Definition at line 316 of file ns_automation.cpp.
References CJsonNode::Append(), g_ReconfAndReturnJson(), m_NetScheduleAPI, and NAutomation::SInputOutput::reply.
void SNetScheduleService::ExecResume | ( | const TArguments & | args, |
SInputOutput & | io | ||
) |
Definition at line 330 of file ns_automation.cpp.
References g_ResumeNetSchedule(), and m_NetScheduleAPI.
void SNetScheduleService::ExecSetClientType | ( | const TArguments & | args, |
SInputOutput & | io | ||
) |
Definition at line 283 of file ns_automation.cpp.
References _ASSERT, m_NetScheduleAPI, and CNetScheduleAPI::SetClientType().
void SNetScheduleService::ExecSetNodeSession | ( | const TArguments & | args, |
SInputOutput & | io | ||
) |
Definition at line 291 of file ns_automation.cpp.
References _ASSERT, m_NetScheduleAPI, CNetScheduleAPIExt::ReSetClientNode(), and CNetScheduleAPIExt::ReSetClientSession().
void SNetScheduleService::ExecShutdown | ( | const TArguments & | args, |
SInputOutput & | io | ||
) |
Definition at line 335 of file ns_automation.cpp.
References _ASSERT, CNetScheduleAdmin::eDrain, CNetScheduleAdmin::eNormalShutdown, CNetScheduleAPI::GetAdmin(), m_NetScheduleAPI, and CNetScheduleAdmin::ShutdownServer().
void SNetScheduleService::ExecSuspend | ( | const TArguments & | args, |
SInputOutput & | io | ||
) |
Definition at line 322 of file ns_automation.cpp.
References _ASSERT, g_SuspendNetSchedule(), and m_NetScheduleAPI.
|
inlinevirtual |
Implements NAutomation::SNetServiceBase.
Definition at line 48 of file ns_automation.hpp.
References CNetScheduleAPI::GetService(), and m_NetScheduleAPI.
Referenced by NAutomation::SNetScheduleServer::SNetScheduleServer(), and SNetScheduleService().
Implements NAutomation::CAutomationObject.
Reimplemented in NAutomation::SNetScheduleServer.
Definition at line 46 of file ns_automation.hpp.
References kName.
|
static |
Definition at line 70 of file ns_automation.cpp.
References kName.
Referenced by NAutomation::CAutomationProc::NewCommands().
Definition at line 68 of file ns_automation.hpp.
Referenced by CallCommand(), GetType(), and NewCommand().
|
protected |
Definition at line 71 of file ns_automation.hpp.
Referenced by NAutomation::SNetScheduleServer::ExecChangePreferredAffinities(), ExecGetServers(), ExecJobCounters(), ExecJobInfo(), ExecParseKey(), ExecQueueClassInfo(), ExecQueueInfo(), ExecReconf(), ExecResume(), ExecSetClientType(), ExecSetNodeSession(), ExecShutdown(), ExecSuspend(), GetService(), and SNetScheduleService().