{
return m_Events[0].m_Timestamp; }
351queue_timeout, queue_run_timeout,
353queue_pending_timeout,
367 void Dump(FILE * jobs_file)
const;
369 char* input_buf,
char* output_buf,
380 string&
dump)
const;
383 string&
dump)
const;
386 string&
dump)
const;
395 string&
dump)
const;
397 string&
dump)
const;
ncbi::TMaskedQueryRegions mask
CJobEvent & operator=(CJobEvent &&)=default
CJobEvent(CJobEvent &&)=default
CNSPreciseTime GetTimestamp() const
unsigned GetNodeAddr() const
void SetErrorMsg(const string &msg)
const string GetQuotedErrorMsg() const
TJobStatus GetStatus() const
void SetEvent(EJobEvent event)
EJobEvent GetEvent() const
static std::string EventToString(EJobEvent event)
void SetRetCode(int retcode)
CJobEvent(const CJobEvent &)=default
void SetNodeAddr(unsigned int node_ip)
const string & GetClientSession() const
const string & GetErrorMsg() const
CNSPreciseTime m_Timestamp
void SetClientNode(const string &client_node)
const string & GetClientNode() const
void SetStatus(TJobStatus status)
void SetTimestamp(const CNSPreciseTime &t)
CJobEvent & operator=(const CJobEvent &)=default
void SetClientSession(const string &cliet_session)
TJobStatus GetStatusBeforeReading(void) const
CJob & operator=(CJob &&)=default
const string & GetClientSID() const
CJob(const CJob &)=default
void SetListenerNotifAddr(unsigned int address)
void SetPassport(unsigned int passport)
unsigned GetRunCount() const
void x_AppendRunCounter(string &dump) const
void x_AppendReadExpiration(const CNSPreciseTime &read_timeout, const CNSPreciseTime &exp_time, string &dump) const
void SetListenerNotifPort(unsigned short port)
void x_AppendEraseTime(const CNSPreciseTime &timeout, const CNSPreciseTime &pending_timeout, const CNSPreciseTime &exp_time, string &dump) const
CNSPreciseTime GetTimeout() const
void x_AppendOutput(string &dump) const
bool GetSubmNeedProgressMsgNotif() const
void x_AppendRemoteClientIP(string &dump) const
void SetNCBIPHID(const string &ncbi_phid)
unsigned int GetPassport() const
CNSPreciseTime m_SubmNotifTimeout
CJob & operator=(const CJob &)=default
CNSPreciseTime m_ReadTimeout
void SetRunTimeout(const CNSPreciseTime &t)
void SetSubmNotifTimeout(const CNSPreciseTime &t)
unsigned GetSubmAddr() const
void SetClientIP(const string &client_ip)
bool ShouldNotifyListener(const CNSPreciseTime ¤t_time) const
void Dump(FILE *jobs_file) const
CNSPreciseTime GetLastEventTime(void) const
void x_AppendMask(string &dump) const
const string GetQuotedInput() const
void SetAffinityId(unsigned aff_id)
void SetLastTouch(const CNSPreciseTime &t)
EAuthTokenCompareResult CompareAuthToken(const string &auth_token) const
void SetOutput(const string &output)
bool m_NeedLsnrProgressMsgNotif
unsigned int GetListenerNotifAddr() const
void x_AppendNcbiPhid(string &dump) const
unsigned short GetSubmNotifPort() const
void SetRunCount(unsigned count)
const string & GetInput() const
void SetReadCount(unsigned count)
void SetProgressMsg(const string &msg)
unsigned GetGroupId() const
CNSPreciseTime GetRunTimeout() const
void x_AppendNeedSubmitProgressMsgNotif(string &dump) const
void x_AppendId(string &dump) const
void x_AppendListenerNotifExpiration(string &dump) const
CNSPreciseTime m_ListenerNotifAbsTime
void x_AppendSubmitNotifExpiration(string &dump) const
void SetGroupId(unsigned id)
void x_AppendEvents(string &dump) const
size_t GetLastEventIndex(void) const
const CJobEvent * GetLastEvent() const
const string & GetOutput() const
unsigned short GetListenerNotifPort() const
void x_AppendProgressMsg(string &dump) const
string Print(TDumpFields dump_fields, const CQueue &queue, const CNSAffinityRegistry &aff_registry, const CNSGroupsRegistry &group_registry) const
void SetNeedSubmProgressMsgNotif(bool need)
unsigned short m_SubmNotifPort
void SetStatus(TJobStatus status)
TJobStatus GetStatus() const
unsigned short m_ListenerNotifPort
CJobEvent & AppendEvent()
void x_AppendNeedListenerProgressMsgNotif(string &dump) const
CNSPreciseTime GetSubmitTime(void) const
void SetNeedLsnrProgressMsgNotif(bool need)
void SetNeedStolenNotif(bool need)
bool m_NeedSubmProgressMsgNotif
void x_AppendLastTouch(string &dump) const
string GetAuthToken() const
unsigned GetReadCount() const
void SetMask(unsigned mask)
void x_AppendRunExpiration(const CNSPreciseTime &run_timeout, const CNSPreciseTime &exp_time, string &dump) const
void SetReadTimeout(const CNSPreciseTime &t)
bool GetLsnrNeedProgressMsgNotif() const
void x_AppendNeedStolenNotif(string &dump) const
void SetEvents(const vector< CJobEvent > &events)
void SetTimeout(const CNSPreciseTime &t)
void SetListenerNotifAbsTime(const CNSPreciseTime &abs_time)
void SetInput(const string &input)
vector< CJobEvent > m_Events
bool ShouldNotifySubmitter(const CNSPreciseTime ¤t_time) const
void x_AppendReadCounter(string &dump) const
string GetErrorMsg() const
CNSPreciseTime m_LastTouch
const string & GetClientIP() const
unsigned GetAffinityId() const
const string & GetNCBIPHID() const
void x_AppendRemoteClientSID(string &dump) 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
void x_AppendGroup(const CNSGroupsRegistry &group_registry, string &dump) const
const string GetQuotedOutput() const
const string & GetProgressMsg() const
void SetClientSID(const string &client_sid)
bool GetNeedStolenNotif() const
void SetSubmNotifPort(unsigned short port)
void x_AppendStatus(string &dump) const
CNSPreciseTime GetLastTouch() const
void x_AppendSubmitNotifPort(string &dump) const
unsigned int m_ListenerNotifAddress
void x_AppendKey(const CQueue &queue, string &dump) const
CNSPreciseTime GetSubmNotifTimeout() const
void x_AppendInput(string &dump) const
CNSPreciseTime m_RunTimeout
const vector< CJobEvent > & GetEvents() const
void x_AppendAffinity(const CNSAffinityRegistry &aff_registry, string &dump) const
CNSPreciseTime GetReadTimeout() const
void x_AppendListenerNotif(string &dump) const
bool LoadFromDump(FILE *jobs_file, char *input_buf, char *output_buf, const SJobDumpHeader &header)
static SQLCHAR output[256]
EJobStatus
Job status codes.
#define END_NCBI_SCOPE
End previously defined NCBI scope.
#define BEGIN_NCBI_SCOPE
Define ncbi namespace.
static string PrintableString(const CTempString str, TPrintableMode mode=fNewLine_Quote|fNonAscii_Passthru)
Get a printable version of the specified string.
CNSPreciseTime GetJobExpirationTime(const CNSPreciseTime &last_touch, TJobStatus status, const CNSPreciseTime &job_submit_time, const CNSPreciseTime &job_timeout, const CNSPreciseTime &job_run_timeout, const CNSPreciseTime &job_read_timeout, const CNSPreciseTime &queue_timeout, const CNSPreciseTime &queue_run_timeout, const CNSPreciseTime &queue_read_timeout, const CNSPreciseTime &queue_pending_timeout, const CNSPreciseTime &event_time)
NetSchedule job status tracker.
NetSchedule client specs.
static SLJIT_INLINE sljit_ins msg(sljit_gpr r, sljit_s32 d, sljit_gpr x, sljit_gpr b)
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