Searched refs:SWorkerNodeJobContextImpl (Results 1 – 12 of 12) sorted by relevance
83 void RecycleJobContextAndCommitJob(SWorkerNodeJobContextImpl* job_context,89 typedef CRef<SWorkerNodeJobContextImpl> TEntry;95 bool x_CommitJob(SWorkerNodeJobContextImpl* job_context);
124 SWorkerNodeJobContextImpl::SWorkerNodeJobContextImpl( in SWorkerNodeJobContextImpl() function in SWorkerNodeJobContextImpl149 CNcbiIstream& SWorkerNodeJobContextImpl::GetIStream() in GetIStream()159 CNcbiOstream& SWorkerNodeJobContextImpl::GetOStream() in GetOStream()219 void SWorkerNodeJobContextImpl::PutProgressMessage(const string& msg, in PutProgressMessage()265 void SWorkerNodeJobContextImpl::JobDelayExpiration(unsigned runtime_inc) in JobDelayExpiration()286 CNetScheduleAdmin::EShutdownLevel SWorkerNodeJobContextImpl::GetShutdownLevel() in GetShutdownLevel()335 void SWorkerNodeJobContextImpl::CheckIfJobIsLost() in CheckIfJobIsLost()343 void SWorkerNodeJobContextImpl::ResetJobContext() in ResetJobContext()387 void SWorkerNodeJobContextImpl::x_PrintRequestStop() in x_PrintRequestStop()403 void SWorkerNodeJobContextImpl::x_RunJob() in x_RunJob()
73 return new SWorkerNodeJobContextImpl(m_WorkerNode); in AllocJobContext()83 SWorkerNodeJobContextImpl* job_context, in RecycleJobContextAndCommitJob()160 bool CJobCommitterThread::x_CommitJob(SWorkerNodeJobContextImpl* job_context) in x_CommitJob()
50 struct SWorkerNodeJobContextImpl : public CObject struct52 SWorkerNodeJobContextImpl(SGridWorkerNodeImpl* worker_node);320 CWorkerNodeRequest(SWorkerNodeJobContextImpl* context) : in CWorkerNodeRequest()
54 struct SOfflineJobContextImpl : public SWorkerNodeJobContextImpl60 SWorkerNodeJobContextImpl(worker_node), in SOfflineJobContextImpl()
124 SWorkerNodeJobContextImpl::SWorkerNodeJobContextImpl( in SWorkerNodeJobContextImpl() function in SWorkerNodeJobContextImpl149 CNcbiIstream& SWorkerNodeJobContextImpl::GetIStream() in GetIStream()159 CNcbiOstream& SWorkerNodeJobContextImpl::GetOStream() in GetOStream()219 void SWorkerNodeJobContextImpl::PutProgressMessage(const string& msg, in PutProgressMessage()265 void SWorkerNodeJobContextImpl::JobDelayExpiration(unsigned runtime_inc) in JobDelayExpiration()286 CNetScheduleAdmin::EShutdownLevel SWorkerNodeJobContextImpl::GetShutdownLevel() in GetShutdownLevel()335 void SWorkerNodeJobContextImpl::CheckIfJobIsLost() in CheckIfJobIsLost()343 void SWorkerNodeJobContextImpl::ResetJobContext() in ResetJobContext()386 void SWorkerNodeJobContextImpl::x_PrintRequestStop() in x_PrintRequestStop()402 void SWorkerNodeJobContextImpl::x_RunJob() in x_RunJob()
73 return new SWorkerNodeJobContextImpl(m_WorkerNode); in AllocJobContext()85 SWorkerNodeJobContextImpl* job_context, in RecycleJobContextAndCommitJob()162 bool CJobCommitterThread::x_CommitJob(SWorkerNodeJobContextImpl* job_context) in x_CommitJob()
186 struct SWorkerNodeJobContextImpl;