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

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

NCBI C++ ToolKit: include/connect/services/grid_worker.hpp Source File

& GetJobKey()

;

& GetJobInput()

;

SetJobOutput(

&

);

SetJobRetCode(

ret_code);

GetInputBlobSize()

;

PutProgressMessage(

&

,

send_immediately =

,

overwrite =

);

CommitJobWithFailure(

& err_msg,

no_retries =

);

RescheduleJob(

& affinity,

& group =

);

& GetQueueName()

;

& GetClientName()

;

JobDelayExpiration(

runtime_inc);

IsLogRequested()

;

RequestExclusiveMode();

& GetJobOutput()

;

GetJobNumber()

;

IsJobCommitted()

;

ECommitStatus GetCommitStatus()

;

* GetCommitStatusDescription(ECommitStatus commit_status);

IsJobLost()

;

RequestShutdown();

IsShutdownRequested()

;

<

TWorkerNodeJob>

<

TWorkerNodeJob,

TWorkerNodeIdleTask>

}

(exception& ex) {

<< ex.what());

NCBI_AS_STRING(Version); \

const char* const CSimpleJobFactory<TWorkerNodeJob>::m_AppName = \

procinfo_file_name =

());

RequestShutdown();

ForceSingleThread();

GetMaxThreads()

;

GetTotalMemoryLimit()

;

GetTotalTimeLimit()

;

time_t GetStartupTime()

;

GetQueueTimeout()

;

IsHostInAdminHostsList(

& host)

;

GetCommitJobInterval()

;

GetCheckStatusPeriod()

;

GetServerOutputSize();

& GetQueueName()

;

& GetClientName()

;

GetAppName()

;

& GetServiceName()

;

DisableDefaultRequestEventLogging(

EDisabledRequestEvents disabled_events = eDisableStartStop);

Suspend(

pullback,

timeout);

IsSuspended()

;

eExclusiveModeIsAlreadySet

(GetErrCode())

ePortBusy:

;

eJobIsLost:

;

eJobFactoryIsNotSet:

;

eExclusiveModeIsAlreadySet:

;

Client API for NetCache server.

Client API for NCBI NetSchedule server.

EShutdownLevel

Shutdown level.

Smart pointer to a part of the NetSchedule API that does job retrieval and processing on the worker n...

Worker Node Idle Task Context.

Listener of events generated by CGridWorkerNodeApp.

Clean-up event source for the worker node.

Worker Node Idle Task Interface.

Worker Node initialize context.

Worker Node Job Factory interface.

Worker Node Job interface.

static SQLCHAR output[256]

#define ERR_POST_XX(error_name, err_subcode, message)

Error posting with error code having given name and with given error subcode.

virtual const char * GetErrCodeString(void) const

Get error code interpreted as text.

virtual void HandleEvent(EWorkerNodeCleanupEvent cleanup_event)=0

CWorkerNodeIdleThread & m_Thread

virtual void Init(const IWorkerNodeInitContext &context)

Initialize a worker node factory.

virtual void Init(const IWorkerNodeInitContext &context)

Initialize a worker node factory.

static const char *const m_AppName

virtual int Do(CWorkerNodeJobContext &context)=0

Execute the job.

unique_ptr< TWorkerNodeIdleTask > m_IdleTask

virtual ~IWorkerNodeJob()

virtual void AddListener(IWorkerNodeCleanupEventListener *listener)=0

virtual const CNcbiEnvironment & GetEnvironment() const =0

Get environment variables.

bool NeedRunAgain() const

virtual CNetCacheAPI GetNetCacheAPI() const =0

Get the shared NetCacheAPI object used by the worker node framework.

virtual IWorkerNodeJob * CreateInstance(void)

Create a job.

virtual void Init(const IWorkerNodeInitContext &)

Initialize a worker node factory.

virtual ~IWorkerNodeJobFactory()

static const char *const m_JobVersion

pair< string, SBuildInfo > TVersion

virtual void Run(CWorkerNodeIdleTaskContext &)=0

Do the Idle task here.

virtual void Notify(const CWorkerNodeJobContext &job, EEvent event)=0

EDisabledRequestEvents

Disable the automatic logging of request-start and request-stop events by the framework itself.

virtual string GetJobVersion() const

Get the job version.

virtual IWorkerNodeIdleTask * GetIdleTask()

Get the Idle task.

virtual IWorkerNodeJob * CreateInstance(void)=0

Create a job.

const IWorkerNodeInitContext * m_WorkerNodeInitContext

virtual ~IWorkerNodeInitBaseContext()

virtual CNetScheduleAPI GetNetScheduleAPI() const =0

Get the shared NetScheduleAPI object used by the worker node framework.

virtual string GetJobVersion() const =0

Get the job version.

CWorkerNodeIdleTaskContext(const CWorkerNodeIdleTaskContext &)

virtual void RemoveListener(IWorkerNodeCleanupEventListener *listener)=0

NCBI_EXCEPTION_DEFAULT(CGridWorkerNodeException, CException)

virtual string GetAppVersion() const

virtual ~IWorkerNodeCleanupEventListener()

virtual const char * GetErrCodeString(void) const override

Get error code interpreted as text.

virtual string GetAppName() const

virtual const CArgs & GetArgs() const =0

Get command line arguments.

virtual const IRegistry & GetConfig() const =0

Get a config file registry.

virtual void CallEventHandlers()=0

CWorkerNodeIdleTaskContext & operator=(const CWorkerNodeIdleTaskContext &)

EWorkerNodeCleanupEvent

Event notifying of a safe clean-up point.

virtual IWorkerNodeIdleTask * GetIdleTask()

Get the Idle task.

virtual IWorkerNodeCleanupEventSource * GetCleanupEventSource() const =0

Get interface for registering clean-up event listeners.

virtual string GetAppName() const

virtual ~IWorkerNodeIdleTask()

@ eRegularCleanup

For jobs – run from the same thread after Do() is done; for the whole WN – run from a separate (clean...

@ eOnHardExit

Called on emergency shutdown, always from a different (clean-up) thread, even for the jobs.

uint64_t Uint8

8-byte (64-bit) unsigned integer

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

IO_PREFIX::ostream CNcbiOstream

Portable alias for ostream.

IO_PREFIX::istream CNcbiIstream

Portable alias for istream.

void Run(void)

Enter the main loop.

enum ENcbiSwitch ESwitch

Aux.

#define NCBI_XCONNECT_EXPORT

Pool of generic task-executing threads.

Miscellaneous common-use basic types and functionality.

Process information in the NCBI Registry, including working with configuration files.

NCBI C++ stream class wrappers for triggering between "new" and "old" C++ stream libraries.

Multi-threading – classes, functions, and features.

#define NCBI_NET_COMPONENT(component)

NetSchedule client specs.

Defines CRequestContext class for NCBI C++ diagnostic API.

static SLJIT_INLINE sljit_ins msg(sljit_gpr r, sljit_s32 d, sljit_gpr x, sljit_gpr b)

static CS_CONTEXT * context

unique_ptr< CObjectIStream > GetIStream(string path, ESerialDataFormat serial_format)

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