NCBI C++ ToolKit
Public Types | Public Member Functions | Private Member Functions | Private Attributes | List of all members
CJob Class Reference

Search Toolkit Book for CJob

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

+ Collaboration diagram for CJob:

Public Types

enum  EAuthTokenCompareResult { eCompleteMatch = 0 , ePassportOnlyMatch = 1 , eNoMatch = 2 , eInvalidTokenFormat = 3 }
 

Public Member Functions

 CJob ()
 
 CJob (const SNSCommandArguments &request)
 
 CJob (const CJob &)=default
 
CJoboperator= (const CJob &)=default
 
 CJob (CJob &&)=default
 
CJoboperator= (CJob &&)=default
 
unsigned GetId () const
 
unsigned int GetPassport () const
 
string GetAuthToken () const
 
TJobStatus GetStatus () const
 
CNSPreciseTime GetTimeout () const
 
CNSPreciseTime GetRunTimeout () const
 
CNSPreciseTime GetReadTimeout () const
 
unsigned GetSubmAddr () const
 
unsigned short GetSubmNotifPort () const
 
CNSPreciseTime GetSubmNotifTimeout () const
 
unsigned int GetListenerNotifAddr () const
 
unsigned short GetListenerNotifPort () const
 
unsigned GetRunCount () const
 
unsigned GetReadCount () const
 
const stringGetProgressMsg () const
 
unsigned GetAffinityId () const
 
unsigned GetMask () const
 
unsigned GetGroupId () const
 
CNSPreciseTime GetLastTouch () const
 
const stringGetClientIP () const
 
const stringGetClientSID () const
 
const stringGetNCBIPHID () const
 
bool GetSubmNeedProgressMsgNotif () const
 
bool GetLsnrNeedProgressMsgNotif () const
 
bool GetNeedStolenNotif () const
 
const vector< CJobEvent > & GetEvents () const
 
size_t GetLastEventIndex (void) const
 
const stringGetInput () const
 
const string GetQuotedInput () const
 
const stringGetOutput () const
 
const string GetQuotedOutput () const
 
string GetErrorMsg () const
 
int GetRetCode () const
 
void SetId (unsigned id)
 
void SetPassport (unsigned int passport)
 
void SetStatus (TJobStatus status)
 
void SetTimeout (const CNSPreciseTime &t)
 
void SetRunTimeout (const CNSPreciseTime &t)
 
void SetReadTimeout (const CNSPreciseTime &t)
 
void SetSubmNotifPort (unsigned short port)
 
void SetSubmNotifTimeout (const CNSPreciseTime &t)
 
void SetListenerNotifAddr (unsigned int address)
 
void SetListenerNotifPort (unsigned short port)
 
void SetListenerNotifAbsTime (const CNSPreciseTime &abs_time)
 
void SetRunCount (unsigned count)
 
void SetReadCount (unsigned count)
 
void SetProgressMsg (const string &msg)
 
void SetAffinityId (unsigned aff_id)
 
void SetMask (unsigned mask)
 
void SetGroupId (unsigned id)
 
void SetLastTouch (const CNSPreciseTime &t)
 
void SetClientIP (const string &client_ip)
 
void SetClientSID (const string &client_sid)
 
void SetNCBIPHID (const string &ncbi_phid)
 
void SetNeedSubmProgressMsgNotif (bool need)
 
void SetNeedLsnrProgressMsgNotif (bool need)
 
void SetNeedStolenNotif (bool need)
 
void SetEvents (const vector< CJobEvent > &events)
 
void SetInput (const string &input)
 
void SetOutput (const string &output)
 
CJobEventAppendEvent ()
 
const CJobEventGetLastEvent () const
 
CJobEventGetLastEvent ()
 
CNSPreciseTime GetSubmitTime (void) const
 
CNSPreciseTime GetLastEventTime (void) const
 
CNSPreciseTime GetExpirationTime (const CNSPreciseTime &queue_timeout, const CNSPreciseTime &queue_run_timeout, const CNSPreciseTime &queue_read_timeout, const CNSPreciseTime &queue_pending_timeout, const CNSPreciseTime &event_time) const
 
EAuthTokenCompareResult CompareAuthToken (const string &auth_token) const
 
bool ShouldNotifySubmitter (const CNSPreciseTime &current_time) const
 
bool ShouldNotifyListener (const CNSPreciseTime &current_time) const
 
string Print (TDumpFields dump_fields, const CQueue &queue, const CNSAffinityRegistry &aff_registry, const CNSGroupsRegistry &group_registry) const
 
TJobStatus GetStatusBeforeReading (void) const
 
void Dump (FILE *jobs_file) const
 
bool LoadFromDump (FILE *jobs_file, char *input_buf, char *output_buf, const SJobDumpHeader &header)
 

Private Member Functions

void x_AppendId (string &dump) const
 
void x_AppendKey (const CQueue &queue, string &dump) const
 
void x_AppendStatus (string &dump) const
 
void x_AppendLastTouch (string &dump) const
 
void x_AppendEraseTime (const CNSPreciseTime &timeout, const CNSPreciseTime &pending_timeout, const CNSPreciseTime &exp_time, string &dump) const
 
void x_AppendRunExpiration (const CNSPreciseTime &run_timeout, const CNSPreciseTime &exp_time, string &dump) const
 
void x_AppendReadExpiration (const CNSPreciseTime &read_timeout, const CNSPreciseTime &exp_time, string &dump) const
 
void x_AppendSubmitNotifPort (string &dump) const
 
void x_AppendSubmitNotifExpiration (string &dump) const
 
void x_AppendListenerNotif (string &dump) const
 
void x_AppendListenerNotifExpiration (string &dump) const
 
void x_AppendEvents (string &dump) const
 
void x_AppendRunCounter (string &dump) const
 
void x_AppendReadCounter (string &dump) const
 
void x_AppendAffinity (const CNSAffinityRegistry &aff_registry, string &dump) const
 
void x_AppendGroup (const CNSGroupsRegistry &group_registry, string &dump) const
 
void x_AppendMask (string &dump) const
 
void x_AppendInput (string &dump) const
 
void x_AppendOutput (string &dump) const
 
void x_AppendProgressMsg (string &dump) const
 
void x_AppendRemoteClientSID (string &dump) const
 
void x_AppendRemoteClientIP (string &dump) const
 
void x_AppendNcbiPhid (string &dump) const
 
void x_AppendNeedSubmitProgressMsgNotif (string &dump) const
 
void x_AppendNeedListenerProgressMsgNotif (string &dump) const
 
void x_AppendNeedStolenNotif (string &dump) const
 

Private Attributes

unsigned m_Id
 
unsigned int m_Passport
 
TJobStatus m_Status
 
CNSPreciseTime m_Timeout
 
CNSPreciseTime m_RunTimeout
 
CNSPreciseTime m_ReadTimeout
 
unsigned short m_SubmNotifPort
 
CNSPreciseTime m_SubmNotifTimeout
 
unsigned int m_ListenerNotifAddress
 
unsigned short m_ListenerNotifPort
 
CNSPreciseTime m_ListenerNotifAbsTime
 
unsigned m_RunCount
 
unsigned m_ReadCount
 
string m_ProgressMsg
 
unsigned m_AffinityId
 
unsigned m_Mask
 
unsigned m_GroupId
 
CNSPreciseTime m_LastTouch
 
string m_ClientIP
 
string m_ClientSID
 
string m_NCBIPHID
 
vector< CJobEventm_Events
 
string m_Input
 
string m_Output
 
bool m_NeedSubmProgressMsgNotif
 
bool m_NeedLsnrProgressMsgNotif
 
bool m_NeedStolenNotif
 

Detailed Description

Definition at line 182 of file job.hpp.

Member Enumeration Documentation

◆ EAuthTokenCompareResult

Enumerator
eCompleteMatch 
ePassportOnlyMatch 
eNoMatch 
eInvalidTokenFormat 

Definition at line 185 of file job.hpp.

Constructor & Destructor Documentation

◆ CJob() [1/4]

CJob::CJob ( )

Definition at line 153 of file job.cpp.

◆ CJob() [2/4]

CJob::CJob ( const SNSCommandArguments request)

◆ CJob() [3/4]

CJob::CJob ( const CJob )
default

◆ CJob() [4/4]

CJob::CJob ( CJob &&  )
default

Member Function Documentation

◆ AppendEvent()

CJobEvent & CJob::AppendEvent ( )

Definition at line 236 of file job.cpp.

References m_Events.

Referenced by CQueue::Submit(), and CQueue::SubmitBatch().

◆ CompareAuthToken()

CJob::EAuthTokenCompareResult CJob::CompareAuthToken ( const string auth_token) const

◆ Dump()

void CJob::Dump ( FILE *  jobs_file) const

Definition at line 752 of file job.cpp.

References SJobDump::aff_id, SJobDump::client_ip, SJobDump::client_ip_size, SJobEventsDump::client_node_size, SJobEventsDump::client_session_size, SJobDump::client_sid, SJobDump::client_sid_size, SJobEventsDump::err_msg_size, SJobEventsDump::event, SJobDump::group_id, SJobDump::id, SJobIODump::input_size, int, kMaxClientIpSize, kMaxHitIdSize, kMaxSessionIdSize, SJobDump::last_touch, SJobDump::listener_notif_abstime, SJobDump::listener_notif_addr, SJobDump::listener_notif_port, m_AffinityId, m_ClientIP, m_ClientSID, m_Events, m_GroupId, m_Id, m_Input, m_LastTouch, m_ListenerNotifAbsTime, m_ListenerNotifAddress, m_ListenerNotifPort, m_Mask, m_NCBIPHID, m_NeedLsnrProgressMsgNotif, m_NeedStolenNotif, m_NeedSubmProgressMsgNotif, m_Output, m_Passport, m_ProgressMsg, m_ReadCount, m_ReadTimeout, m_RunCount, m_RunTimeout, m_Status, m_SubmNotifPort, m_SubmNotifTimeout, m_Timeout, SJobDump::mask, min(), SJobDump::ncbi_phid, SJobDump::ncbi_phid_size, SJobDump::need_lsnr_progress_msg_notif, SJobDump::need_stolen_notif, SJobDump::need_subm_progress_msg_notif, SJobEventsDump::node_addr, SJobDump::number_of_events, SJobIODump::output_size, SJobDump::passport, SJobDump::progress_msg_size, SJobDump::read_counter, SJobDump::read_timeout, SJobEventsDump::ret_code, SJobDump::run_counter, SJobDump::run_timeout, SJobDump::status, SJobEventsDump::status, SJobDump::subm_notif_port, SJobDump::subm_notif_timeout, SJobDump::timeout, SJobEventsDump::timestamp, SJobEventsDump::Write(), SJobIODump::Write(), and SJobDump::Write().

◆ GetAffinityId()

unsigned CJob::GetAffinityId ( ) const
inline

◆ GetAuthToken()

string CJob::GetAuthToken ( ) const
inline

◆ GetClientIP()

const string& CJob::GetClientIP ( void  ) const
inline

◆ GetClientSID()

const string& CJob::GetClientSID ( ) const
inline

◆ GetErrorMsg()

string CJob::GetErrorMsg ( ) const

Definition at line 208 of file job.cpp.

References CJobEvent::GetErrorMsg(), GetLastEvent(), kEmptyStr, and m_Events.

Referenced by CNetScheduleHandler::x_ProcessStatus().

◆ GetEvents()

const vector<CJobEvent>& CJob::GetEvents ( ) const
inline

Definition at line 256 of file job.hpp.

References m_Events.

Referenced by g_DoErasePerfLogging(), g_DoPerfLogging(), and s_DoDonePerfLogging().

◆ GetExpirationTime()

CNSPreciseTime CJob::GetExpirationTime ( const CNSPreciseTime queue_timeout,
const CNSPreciseTime queue_run_timeout,
const CNSPreciseTime queue_read_timeout,
const CNSPreciseTime queue_pending_timeout,
const CNSPreciseTime event_time 
) const
inline

◆ GetGroupId()

unsigned CJob::GetGroupId ( ) const
inline

Definition at line 240 of file job.hpp.

References m_GroupId.

Referenced by CQueue::LoadFromDump().

◆ GetId()

unsigned CJob::GetId ( void  ) const
inline

◆ GetInput()

const string& CJob::GetInput ( ) const
inline

◆ GetLastEvent() [1/2]

CJobEvent * CJob::GetLastEvent ( )

Definition at line 251 of file job.cpp.

References m_Events.

◆ GetLastEvent() [2/2]

const CJobEvent * CJob::GetLastEvent ( ) const

Definition at line 243 of file job.cpp.

References m_Events.

Referenced by GetErrorMsg(), and GetRetCode().

◆ GetLastEventIndex()

size_t CJob::GetLastEventIndex ( void  ) const
inline

Definition at line 258 of file job.hpp.

References m_Events.

Referenced by CNSNotificationList::BuildJobChangedNotification(), and GetLastEventTime().

◆ GetLastEventTime()

CNSPreciseTime CJob::GetLastEventTime ( void  ) const
inline

Definition at line 338 of file job.hpp.

References GetLastEventIndex(), and m_Events.

Referenced by Print().

◆ GetLastTouch()

CNSPreciseTime CJob::GetLastTouch ( ) const
inline

Definition at line 242 of file job.hpp.

References m_LastTouch.

Referenced by CQueue::LoadFromDump().

◆ GetListenerNotifAddr()

unsigned int CJob::GetListenerNotifAddr ( ) const
inline

Definition at line 223 of file job.hpp.

References m_ListenerNotifAddress.

Referenced by CQueue::x_NotifyJobChanges().

◆ GetListenerNotifPort()

unsigned short CJob::GetListenerNotifPort ( ) const
inline

Definition at line 225 of file job.hpp.

References m_ListenerNotifPort.

Referenced by CQueue::x_NotifyJobChanges().

◆ GetLsnrNeedProgressMsgNotif()

bool CJob::GetLsnrNeedProgressMsgNotif ( ) const
inline

Definition at line 252 of file job.hpp.

References m_NeedLsnrProgressMsgNotif.

Referenced by CQueue::x_NotifyJobChanges().

◆ GetMask()

unsigned CJob::GetMask ( ) const
inline

Definition at line 238 of file job.hpp.

References m_Mask.

Referenced by CQueue::Submit(), and CNetScheduleHandler::x_PrintGetJobResponse().

◆ GetNCBIPHID()

const string& CJob::GetNCBIPHID ( ) const
inline

◆ GetNeedStolenNotif()

bool CJob::GetNeedStolenNotif ( ) const
inline

Definition at line 254 of file job.hpp.

References m_NeedStolenNotif.

◆ GetOutput()

const string& CJob::GetOutput ( void  ) const
inline

Definition at line 264 of file job.hpp.

References m_Output.

Referenced by CNetScheduleHandler::x_ProcessStatus().

◆ GetPassport()

unsigned int CJob::GetPassport ( ) const
inline

Definition at line 203 of file job.hpp.

References m_Passport.

◆ GetProgressMsg()

const string& CJob::GetProgressMsg ( ) const
inline

◆ GetQuotedInput()

const string CJob::GetQuotedInput ( ) const
inline

Definition at line 262 of file job.hpp.

References m_Input, and NStr::PrintableString().

◆ GetQuotedOutput()

const string CJob::GetQuotedOutput ( ) const
inline

Definition at line 266 of file job.hpp.

References m_Output, and NStr::PrintableString().

◆ GetReadCount()

unsigned CJob::GetReadCount ( ) const
inline

Definition at line 230 of file job.hpp.

References m_ReadCount.

Referenced by g_DoPerfLogging().

◆ GetReadTimeout()

CNSPreciseTime CJob::GetReadTimeout ( ) const
inline

Definition at line 213 of file job.hpp.

References m_ReadTimeout.

Referenced by CQueue::LoadFromDump().

◆ GetRetCode()

int CJob::GetRetCode ( ) const

Definition at line 216 of file job.cpp.

References GetLastEvent(), CJobEvent::GetRetCode(), and m_Events.

Referenced by CNetScheduleHandler::x_ProcessStatus().

◆ GetRunCount()

unsigned CJob::GetRunCount ( ) const
inline

Definition at line 228 of file job.hpp.

References m_RunCount.

Referenced by g_DoErasePerfLogging(), g_DoPerfLogging(), and CQueue::ReturnJob().

◆ GetRunTimeout()

CNSPreciseTime CJob::GetRunTimeout ( ) const
inline

Definition at line 211 of file job.hpp.

References m_RunTimeout.

Referenced by CQueue::LoadFromDump().

◆ GetStatus()

TJobStatus CJob::GetStatus ( void  ) const
inline

◆ GetStatusBeforeReading()

TJobStatus CJob::GetStatusBeforeReading ( void  ) const

Definition at line 734 of file job.cpp.

References CNetScheduleAPI::eReading, GetStatus(), m_Events, and NCBI_THROW.

Referenced by CNetScheduleHandler::x_ProcessReading().

◆ GetSubmAddr()

unsigned CJob::GetSubmAddr ( ) const
inline

Definition at line 216 of file job.hpp.

References m_Events.

Referenced by CQueue::x_NotifyJobChanges(), and CNetScheduleHandler::x_PrintGetJobResponse().

◆ GetSubmitTime()

CNSPreciseTime CJob::GetSubmitTime ( void  ) const
inline

Definition at line 336 of file job.hpp.

References m_Events.

Referenced by GetExpirationTime(), and CQueue::LoadFromDump().

◆ GetSubmNeedProgressMsgNotif()

bool CJob::GetSubmNeedProgressMsgNotif ( ) const
inline

Definition at line 250 of file job.hpp.

References m_NeedSubmProgressMsgNotif.

Referenced by CQueue::x_NotifyJobChanges().

◆ GetSubmNotifPort()

unsigned short CJob::GetSubmNotifPort ( ) const
inline

Definition at line 218 of file job.hpp.

References m_SubmNotifPort.

Referenced by CQueue::x_NotifyJobChanges(), and CNetScheduleHandler::x_PrintGetJobResponse().

◆ GetSubmNotifTimeout()

CNSPreciseTime CJob::GetSubmNotifTimeout ( ) const
inline

Definition at line 220 of file job.hpp.

References m_SubmNotifTimeout.

◆ GetTimeout()

CNSPreciseTime CJob::GetTimeout ( void  ) const
inline

Definition at line 209 of file job.hpp.

References m_Timeout.

Referenced by CQueue::LoadFromDump().

◆ LoadFromDump()

bool CJob::LoadFromDump ( FILE *  jobs_file,
char *  input_buf,
char *  output_buf,
const SJobDumpHeader header 
)

Definition at line 843 of file job.cpp.

References SJobDump::aff_id, SJobDump::client_ip, SJobDump::client_ip_size, SJobEventsDump::client_node_size, SJobEventsDump::client_session_size, SJobDump::client_sid, SJobDump::client_sid_size, SJobEventsDump::err_msg_size, SJobEventsDump::event, SJobDump::group_id, SJobDump::id, SJobIODump::input_size, SJobDumpHeader::job_event_fixed_size, SJobDumpHeader::job_io_fixed_size, SJobDumpHeader::job_props_fixed_size, kMaxClientIpSize, kMaxHitIdSize, kMaxSessionIdSize, kMaxWorkerNodeIdSize, kNetScheduleMaxDBDataSize, kNetScheduleMaxDBErrSize, SJobDump::last_touch, SJobDump::listener_notif_abstime, SJobDump::listener_notif_addr, SJobDump::listener_notif_port, m_AffinityId, m_ClientIP, m_ClientSID, CJobEvent::m_Event, m_Events, m_GroupId, m_Id, m_LastTouch, m_ListenerNotifAbsTime, m_ListenerNotifAddress, m_ListenerNotifPort, m_Mask, m_NCBIPHID, m_NeedLsnrProgressMsgNotif, m_NeedStolenNotif, m_NeedSubmProgressMsgNotif, m_Passport, m_ProgressMsg, m_ReadCount, m_ReadTimeout, m_RunCount, m_RunTimeout, CJobEvent::m_Status, m_Status, m_SubmNotifPort, m_SubmNotifTimeout, m_Timeout, SJobDump::mask, min(), SJobDump::ncbi_phid, SJobDump::ncbi_phid_size, SJobDump::need_lsnr_progress_msg_notif, SJobDump::need_stolen_notif, SJobDump::need_subm_progress_msg_notif, SJobEventsDump::node_addr, SJobDump::number_of_events, SJobIODump::output_size, SJobDump::passport, SJobDump::progress_msg_size, SJobEventsDump::Read(), SJobIODump::Read(), SJobDump::Read(), SJobDump::read_counter, SJobDump::read_timeout, SJobEventsDump::ret_code, SJobDump::run_counter, SJobDump::run_timeout, SetInput(), SetOutput(), SJobDump::status, SJobEventsDump::status, string, SJobDump::subm_notif_port, SJobDump::subm_notif_timeout, SJobDump::timeout, and SJobEventsDump::timestamp.

Referenced by CQueue::LoadFromDump().

◆ operator=() [1/2]

CJob& CJob::operator= ( CJob &&  )
default

◆ operator=() [2/2]

CJob& CJob::operator= ( const CJob )
default

◆ Print()

string CJob::Print ( TDumpFields  dump_fields,
const CQueue queue,
const CNSAffinityRegistry aff_registry,
const CNSGroupsRegistry group_registry 
) const

◆ SetAffinityId()

void CJob::SetAffinityId ( unsigned  aff_id)
inline

Definition at line 303 of file job.hpp.

References m_AffinityId.

Referenced by CQueue::Submit(), and CQueue::SubmitBatch().

◆ SetClientIP()

void CJob::SetClientIP ( const string client_ip)
inline

Definition at line 312 of file job.hpp.

References m_ClientIP.

Referenced by CJob(), and CNetScheduleHandler::x_ProcessMsgBatchJob().

◆ SetClientSID()

void CJob::SetClientSID ( const string client_sid)
inline

Definition at line 314 of file job.hpp.

References m_ClientSID.

Referenced by CJob(), and CNetScheduleHandler::x_ProcessMsgBatchJob().

◆ SetEvents()

void CJob::SetEvents ( const vector< CJobEvent > &  events)
inline

Definition at line 325 of file job.hpp.

References m_Events.

◆ SetGroupId()

void CJob::SetGroupId ( unsigned  id)
inline

Definition at line 307 of file job.hpp.

References m_GroupId.

Referenced by CQueue::Submit(), and CQueue::SubmitBatch().

◆ SetId()

void CJob::SetId ( unsigned  id)
inline

Definition at line 272 of file job.hpp.

References m_Id.

Referenced by CQueue::Submit(), and CQueue::SubmitBatch().

◆ SetInput()

void CJob::SetInput ( const string input)

Definition at line 224 of file job.cpp.

References input(), and m_Input.

Referenced by CJob(), LoadFromDump(), and CNetScheduleHandler::x_ProcessMsgBatchJob().

◆ SetLastTouch()

void CJob::SetLastTouch ( const CNSPreciseTime t)
inline

Definition at line 309 of file job.hpp.

References m_LastTouch, and t.

Referenced by CQueue::Submit(), and CQueue::SubmitBatch().

◆ SetListenerNotifAbsTime()

void CJob::SetListenerNotifAbsTime ( const CNSPreciseTime abs_time)
inline

Definition at line 294 of file job.hpp.

References m_ListenerNotifAbsTime.

◆ SetListenerNotifAddr()

void CJob::SetListenerNotifAddr ( unsigned int  address)
inline

Definition at line 290 of file job.hpp.

References m_ListenerNotifAddress.

◆ SetListenerNotifPort()

void CJob::SetListenerNotifPort ( unsigned short  port)
inline

Definition at line 292 of file job.hpp.

References m_ListenerNotifPort.

◆ SetMask()

void CJob::SetMask ( unsigned  mask)
inline

Definition at line 305 of file job.hpp.

References m_Mask, and mask.

Referenced by CNetScheduleHandler::x_ProcessMsgBatchJob().

◆ SetNCBIPHID()

void CJob::SetNCBIPHID ( const string ncbi_phid)
inline

Definition at line 316 of file job.hpp.

References m_NCBIPHID.

Referenced by CJob(), and CNetScheduleHandler::x_ProcessMsgBatchJob().

◆ SetNeedLsnrProgressMsgNotif()

void CJob::SetNeedLsnrProgressMsgNotif ( bool  need)
inline

Definition at line 320 of file job.hpp.

References m_NeedLsnrProgressMsgNotif.

◆ SetNeedStolenNotif()

void CJob::SetNeedStolenNotif ( bool  need)
inline

Definition at line 322 of file job.hpp.

References m_NeedStolenNotif.

◆ SetNeedSubmProgressMsgNotif()

void CJob::SetNeedSubmProgressMsgNotif ( bool  need)
inline

Definition at line 318 of file job.hpp.

References m_NeedSubmProgressMsgNotif.

◆ SetOutput()

void CJob::SetOutput ( const string output)

Definition at line 230 of file job.cpp.

References m_Output, and output.

Referenced by LoadFromDump().

◆ SetPassport()

void CJob::SetPassport ( unsigned int  passport)
inline

Definition at line 274 of file job.hpp.

References m_Passport.

Referenced by CQueue::Submit(), and CQueue::SubmitBatch().

◆ SetProgressMsg()

void CJob::SetProgressMsg ( const string msg)
inline

Definition at line 301 of file job.hpp.

References m_ProgressMsg.

◆ SetReadCount()

void CJob::SetReadCount ( unsigned  count)
inline

Definition at line 299 of file job.hpp.

References m_ReadCount.

◆ SetReadTimeout()

void CJob::SetReadTimeout ( const CNSPreciseTime t)
inline

Definition at line 282 of file job.hpp.

References m_ReadTimeout, and t.

◆ SetRunCount()

void CJob::SetRunCount ( unsigned  count)
inline

Definition at line 297 of file job.hpp.

References m_RunCount.

◆ SetRunTimeout()

void CJob::SetRunTimeout ( const CNSPreciseTime t)
inline

Definition at line 280 of file job.hpp.

References m_RunTimeout, and t.

◆ SetStatus()

void CJob::SetStatus ( TJobStatus  status)
inline

Definition at line 276 of file job.hpp.

References m_Status.

◆ SetSubmNotifPort()

void CJob::SetSubmNotifPort ( unsigned short  port)
inline

Definition at line 285 of file job.hpp.

References m_SubmNotifPort.

Referenced by CNetScheduleHandler::x_ProcessMsgBatchJob().

◆ SetSubmNotifTimeout()

void CJob::SetSubmNotifTimeout ( const CNSPreciseTime t)
inline

Definition at line 287 of file job.hpp.

References m_SubmNotifTimeout, and t.

Referenced by CNetScheduleHandler::x_ProcessMsgBatchJob().

◆ SetTimeout()

void CJob::SetTimeout ( const CNSPreciseTime t)
inline

Definition at line 278 of file job.hpp.

References m_Timeout, and t.

◆ ShouldNotifyListener()

bool CJob::ShouldNotifyListener ( const CNSPreciseTime current_time) const

Definition at line 291 of file job.cpp.

References m_ListenerNotifAbsTime, m_ListenerNotifAddress, and m_ListenerNotifPort.

Referenced by CQueue::x_NotifyJobChanges().

◆ ShouldNotifySubmitter()

bool CJob::ShouldNotifySubmitter ( const CNSPreciseTime current_time) const

Definition at line 281 of file job.cpp.

References m_Events, m_SubmNotifPort, and m_SubmNotifTimeout.

Referenced by CQueue::x_NotifyJobChanges().

◆ x_AppendAffinity()

void CJob::x_AppendAffinity ( const CNSAffinityRegistry aff_registry,
string dump 
) const
private

Definition at line 614 of file job.cpp.

References dump, CNSAffinityRegistry::GetTokenByID(), kNewLine(), m_AffinityId, prefix, and NStr::PrintableString().

Referenced by Print().

◆ x_AppendEraseTime()

void CJob::x_AppendEraseTime ( const CNSPreciseTime timeout,
const CNSPreciseTime pending_timeout,
const CNSPreciseTime exp_time,
string dump 
) const
private

◆ x_AppendEvents()

void CJob::x_AppendEvents ( string dump) const
private

◆ x_AppendGroup()

void CJob::x_AppendGroup ( const CNSGroupsRegistry group_registry,
string dump 
) const
private

Definition at line 632 of file job.cpp.

References dump, kNewLine(), m_GroupId, prefix, NStr::PrintableString(), and CNSGroupsRegistry::ResolveGroup().

Referenced by Print().

◆ x_AppendId()

void CJob::x_AppendId ( string dump) const
private

Definition at line 394 of file job.cpp.

References dump, kNewLine(), m_Id, and prefix.

Referenced by Print().

◆ x_AppendInput()

void CJob::x_AppendInput ( string dump) const
private

Definition at line 658 of file job.cpp.

References dump, kNewLine(), m_Input, prefix, and NStr::PrintableString().

Referenced by Print().

◆ x_AppendKey()

void CJob::x_AppendKey ( const CQueue queue,
string dump 
) const
private

Definition at line 402 of file job.cpp.

References dump, kNewLine(), m_Id, CQueue::MakeJobKey(), and prefix.

Referenced by Print().

◆ x_AppendLastTouch()

void CJob::x_AppendLastTouch ( string dump) const
private

Definition at line 418 of file job.cpp.

References dump, kNewLine(), m_LastTouch, NS_FormatPreciseTime(), and prefix.

Referenced by Print().

◆ x_AppendListenerNotif()

void CJob::x_AppendListenerNotif ( string dump) const
private

Definition at line 520 of file job.cpp.

References dump, CSocketAPI::gethostbyaddr(), kNewLine(), m_ListenerNotifAddress, m_ListenerNotifPort, and prefix.

Referenced by Print().

◆ x_AppendListenerNotifExpiration()

void CJob::x_AppendListenerNotifExpiration ( string dump) const
private

Definition at line 535 of file job.cpp.

References dump, kNewLine(), kTimeZero, m_ListenerNotifAbsTime, NS_FormatPreciseTime(), and prefix.

Referenced by Print().

◆ x_AppendMask()

void CJob::x_AppendMask ( string dump) const
private

Definition at line 650 of file job.cpp.

References dump, kNewLine(), m_Mask, and prefix.

Referenced by Print().

◆ x_AppendNcbiPhid()

void CJob::x_AppendNcbiPhid ( string dump) const
private

Definition at line 701 of file job.cpp.

References dump, kNewLine(), m_NCBIPHID, prefix, and NStr::PrintableString().

Referenced by Print().

◆ x_AppendNeedListenerProgressMsgNotif()

void CJob::x_AppendNeedListenerProgressMsgNotif ( string dump) const
private

Definition at line 717 of file job.cpp.

References NStr::BoolToString(), dump, kNewLine(), m_NeedLsnrProgressMsgNotif, and prefix.

Referenced by Print().

◆ x_AppendNeedStolenNotif()

void CJob::x_AppendNeedStolenNotif ( string dump) const
private

Definition at line 725 of file job.cpp.

References NStr::BoolToString(), dump, kNewLine(), m_NeedStolenNotif, and prefix.

Referenced by Print().

◆ x_AppendNeedSubmitProgressMsgNotif()

void CJob::x_AppendNeedSubmitProgressMsgNotif ( string dump) const
private

Definition at line 709 of file job.cpp.

References NStr::BoolToString(), dump, kNewLine(), m_NeedSubmProgressMsgNotif, and prefix.

Referenced by Print().

◆ x_AppendOutput()

void CJob::x_AppendOutput ( string dump) const
private

Definition at line 667 of file job.cpp.

References dump, kNewLine(), m_Output, prefix, and NStr::PrintableString().

Referenced by Print().

◆ x_AppendProgressMsg()

void CJob::x_AppendProgressMsg ( string dump) const
private

Definition at line 676 of file job.cpp.

References dump, kNewLine(), m_ProgressMsg, and prefix.

Referenced by Print().

◆ x_AppendReadCounter()

void CJob::x_AppendReadCounter ( string dump) const
private

Definition at line 606 of file job.cpp.

References dump, kNewLine(), m_ReadCount, and prefix.

Referenced by Print().

◆ x_AppendReadExpiration()

void CJob::x_AppendReadExpiration ( const CNSPreciseTime read_timeout,
const CNSPreciseTime exp_time,
string dump 
) const
private

◆ x_AppendRemoteClientIP()

void CJob::x_AppendRemoteClientIP ( string dump) const
private

Definition at line 693 of file job.cpp.

References dump, kNewLine(), m_ClientIP, prefix, and NStr::PrintableString().

Referenced by Print().

◆ x_AppendRemoteClientSID()

void CJob::x_AppendRemoteClientSID ( string dump) const
private

Definition at line 685 of file job.cpp.

References dump, kNewLine(), m_ClientSID, prefix, and NStr::PrintableString().

Referenced by Print().

◆ x_AppendRunCounter()

void CJob::x_AppendRunCounter ( string dump) const
private

Definition at line 598 of file job.cpp.

References dump, kNewLine(), m_RunCount, and prefix.

Referenced by Print().

◆ x_AppendRunExpiration()

void CJob::x_AppendRunExpiration ( const CNSPreciseTime run_timeout,
const CNSPreciseTime exp_time,
string dump 
) const
private

◆ x_AppendStatus()

void CJob::x_AppendStatus ( string dump) const
private

Definition at line 410 of file job.cpp.

References dump, kNewLine(), m_Status, prefix, and CNetScheduleAPI::StatusToString().

Referenced by Print().

◆ x_AppendSubmitNotifExpiration()

void CJob::x_AppendSubmitNotifExpiration ( string dump) const
private

◆ x_AppendSubmitNotifPort()

void CJob::x_AppendSubmitNotifPort ( string dump) const
private

Definition at line 492 of file job.cpp.

References dump, kNewLine(), m_SubmNotifPort, and prefix.

Referenced by Print().

Member Data Documentation

◆ m_AffinityId

unsigned CJob::m_AffinityId
private

Definition at line 427 of file job.hpp.

Referenced by Dump(), GetAffinityId(), LoadFromDump(), SetAffinityId(), and x_AppendAffinity().

◆ m_ClientIP

string CJob::m_ClientIP
private

Definition at line 432 of file job.hpp.

Referenced by Dump(), GetClientIP(), LoadFromDump(), SetClientIP(), and x_AppendRemoteClientIP().

◆ m_ClientSID

string CJob::m_ClientSID
private

Definition at line 433 of file job.hpp.

Referenced by Dump(), GetClientSID(), LoadFromDump(), SetClientSID(), and x_AppendRemoteClientSID().

◆ m_Events

vector<CJobEvent> CJob::m_Events
private

◆ m_GroupId

unsigned CJob::m_GroupId
private

Definition at line 429 of file job.hpp.

Referenced by Dump(), GetGroupId(), LoadFromDump(), SetGroupId(), and x_AppendGroup().

◆ m_Id

unsigned CJob::m_Id
private

Definition at line 410 of file job.hpp.

Referenced by Dump(), GetId(), LoadFromDump(), SetId(), x_AppendId(), and x_AppendKey().

◆ m_Input

string CJob::m_Input
private

Definition at line 438 of file job.hpp.

Referenced by Dump(), GetInput(), GetQuotedInput(), SetInput(), and x_AppendInput().

◆ m_LastTouch

CNSPreciseTime CJob::m_LastTouch
private

◆ m_ListenerNotifAbsTime

CNSPreciseTime CJob::m_ListenerNotifAbsTime
private

◆ m_ListenerNotifAddress

unsigned int CJob::m_ListenerNotifAddress
private

◆ m_ListenerNotifPort

unsigned short CJob::m_ListenerNotifPort
private

◆ m_Mask

unsigned CJob::m_Mask
private

Definition at line 428 of file job.hpp.

Referenced by Dump(), GetMask(), LoadFromDump(), SetMask(), and x_AppendMask().

◆ m_NCBIPHID

string CJob::m_NCBIPHID
private

Definition at line 434 of file job.hpp.

Referenced by Dump(), GetNCBIPHID(), LoadFromDump(), SetNCBIPHID(), and x_AppendNcbiPhid().

◆ m_NeedLsnrProgressMsgNotif

bool CJob::m_NeedLsnrProgressMsgNotif
private

◆ m_NeedStolenNotif

bool CJob::m_NeedStolenNotif
private

◆ m_NeedSubmProgressMsgNotif

bool CJob::m_NeedSubmProgressMsgNotif
private

◆ m_Output

string CJob::m_Output
private

Definition at line 439 of file job.hpp.

Referenced by Dump(), GetOutput(), GetQuotedOutput(), SetOutput(), and x_AppendOutput().

◆ m_Passport

unsigned int CJob::m_Passport
private

Definition at line 411 of file job.hpp.

Referenced by CompareAuthToken(), Dump(), GetAuthToken(), GetPassport(), LoadFromDump(), and SetPassport().

◆ m_ProgressMsg

string CJob::m_ProgressMsg
private

Definition at line 426 of file job.hpp.

Referenced by Dump(), GetProgressMsg(), LoadFromDump(), SetProgressMsg(), and x_AppendProgressMsg().

◆ m_ReadCount

unsigned CJob::m_ReadCount
private

Definition at line 425 of file job.hpp.

Referenced by Dump(), GetReadCount(), LoadFromDump(), SetReadCount(), and x_AppendReadCounter().

◆ m_ReadTimeout

CNSPreciseTime CJob::m_ReadTimeout
private

Definition at line 415 of file job.hpp.

Referenced by Dump(), GetExpirationTime(), GetReadTimeout(), LoadFromDump(), Print(), and SetReadTimeout().

◆ m_RunCount

unsigned CJob::m_RunCount
private

Definition at line 424 of file job.hpp.

Referenced by Dump(), GetRunCount(), LoadFromDump(), SetRunCount(), and x_AppendRunCounter().

◆ m_RunTimeout

CNSPreciseTime CJob::m_RunTimeout
private

Definition at line 414 of file job.hpp.

Referenced by Dump(), GetExpirationTime(), GetRunTimeout(), LoadFromDump(), Print(), and SetRunTimeout().

◆ m_Status

TJobStatus CJob::m_Status
private

◆ m_SubmNotifPort

unsigned short CJob::m_SubmNotifPort
private

◆ m_SubmNotifTimeout

CNSPreciseTime CJob::m_SubmNotifTimeout
private

◆ m_Timeout

CNSPreciseTime CJob::m_Timeout
private

Definition at line 413 of file job.hpp.

Referenced by Dump(), GetExpirationTime(), GetTimeout(), LoadFromDump(), Print(), and SetTimeout().


The documentation for this class was generated from the following files:
Modified on Mon Jun 03 05:25:33 2024 by modify_doxy.py rev. 669887