Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Showing content from http://www.ncbi.nlm.nih.gov/IEB/ToolBox/CPP_DOC/doxyhtml/wn__commit__thread_8cpp_source.html below:

NCBI C++ ToolKit: src/connect/services/wn_commit_thread.cpp Source File

m_WorkerNode(worker_node),

m_ThreadName(worker_node->GetAppName() +

)

recycle_job_context =

;

recycle_job_context =

;

e.

().find(

) != string::npos) {

recycle_job_context =

;

(exception& e) {

recycle_job_context =

;

(!recycle_job_context) {

<< commit_interval <<

);

(recycle_job_context) {

recycle_job_context;

(exception& e) {

(9,

<< e.what());

);

void RequestShutdown(CNetScheduleAdmin::EShutdownLevel level)

Request node shutdown.

static CGridGlobals & GetInstance()

const string m_ThreadName

SGridWorkerNodeImpl * m_WorkerNode

CJobCommitterThread(SGridWorkerNodeImpl *worker_node)

CRef< SWorkerNodeJobContextImpl > TEntry

TCommitJobTimeline m_JobContextPool

void RecycleJobContextAndCommitJob(SWorkerNodeJobContextImpl *job_context, CRequestContextSwitcher &rctx_switcher)

virtual void * Main()

Derived (user-created) class must provide a real thread function.

CFastMutex m_TimelineMutex

TCommitJobTimeline m_Timeline

TCommitJobTimeline m_ImmediateActions

bool x_CommitJob(SWorkerNodeJobContextImpl *job_context)

CWorkerNodeJobContext AllocJobContext()

CNanoTimeout – Timeout interval, using nanoseconds.

@ eShutdownImmediate

Urgent shutdown was requested.

NetSchedule internal exception.

Worker Node Job interface.

#define ERR_POST_X(err_subcode, message)

Error posting with default error code and given error subcode.

#define LOG_POST(message)

This macro is deprecated and it's strongly recomended to move in all projects (except tests) to macro...

TErrCode GetErrCode(void) const

Get error code.

#define NCBI_THROW(exception_class, err_code, message)

Generic macro to throw an exception, given the exception class, error code and message string.

const string & GetMsg(void) const

Get message string.

void Warning(CExceptionArgs_Base &args)

virtual const char * what(void) const noexcept

Standard report (includes full backlog).

void ReturnJob(const CNetScheduleJob &job)

Switch the job back to the "Pending" status so that it can be run again on a different worker node.

void PutResult(const CNetScheduleJob &job)

Put job result (job should be received by GetJob() or WaitJob())

void Reschedule(const CNetScheduleJob &job)

Reschedule a job with new affinity and/or group information.

void PutFailure(const CNetScheduleJob &job, bool no_retries=false)

Submit job failure diagnostics.

string job_id

Output job key.

void AddReference(void) const

Add reference to object.

void RemoveReference(void) const

Remove reference to object.

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

void Wait(void)

Wait on semaphore.

static void SetCurrentThreadName(const CTempString &)

Set name for the current thread.

bool TryWait(unsigned int timeout_sec=0, unsigned int timeout_nsec=0)

Timed wait.

Definition of all error codes used in connect services library (xconnserv.lib and others).

Defines NCBI C++ exception handling.

void Update(CNetScheduleJob &job)

void Remove(const CNetScheduleJob &job)

IWorkerNodeJob * GetJobProcessor()

SJobsInProgress m_JobsInProgress

unsigned m_CommitJobInterval

unique_ptr< IWorkerNodeJobFactory > m_JobProcessorFactory

CFastMutex m_JobProcessorMutex

CNetScheduleExecutor m_NSExecutor

void x_PrintRequestStop()

CDeadline m_CommitExpiration

void ResetTimeout(unsigned seconds)

CRef< CRequestContext > m_RequestContext

const CDeadline GetTimeout() const

CWorkerNodeJobContext::ECommitStatus m_JobCommitStatus

bool m_FirstCommitAttempt

static CStaticTls< IWorkerNodeJob > s_tls

static void s_TlsCleanup(IWorkerNodeJob *p_value, void *)

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