& conf_section =
kEmptyStr);
115 const string& conf_section =
kEmptyStr);
126 const string& conf_section =
kEmptyStr);
141 const string& client_name,
142 const string& queue_name);
150 voidSetProgramVersion(
const string& pv);
153 const string& GetProgramVersion()
const;
156 const string& GetQueueName()
const;
180 stringStatusToString(EJobStatus status);
192EJobStatus StringToStatus(
const CTempString& status_str);
203eOutOfOrder = (1 << 1),
205eForEachNode = (1 << 2),
208eSystemJob = (1 << 3),
210eUserMask = (1 << 16)
242 voidGetQueueParams(
const string& queue_name,
TQueueParams& queue_params);
248time_t* job_exptime =
NULL,
257{GetService().GetServerPool().SetCommunicationTimeout(to);}
259 voidSetClientNode(
const string& client_node);
261 voidSetClientSession(
const string& client_session);
271 voidSetClientType(EClientType client_type);
294 staticENetScheduleWarningType ExtractWarningType(
string& warn_msg);
295 static const char* WarningTypeToString(
296ENetScheduleWarningType warning_type);
405 voidSubmitJobBatch(vector<CNetScheduleJob>& jobs,
431 bool Read(
string* job_id,
434 unsignedtimeout = 0,
445 voidReadConfirm(
const string& job_id,
const string& auth_token);
455 voidReadRollback(
const string& job_id,
const string& auth_token);
470 voidReadFail(
const string& job_id,
const string& auth_token,
471 const string& error_message =
kEmptyStr);
515 voidCancelJob(
const string& job_key);
523 voidCancelJobGroup(
const string& job_group,
524 const string& job_statuses =
kEmptyStr);
552 const string& job_key,
553time_t* job_exptime =
NULL,
571time_t* job_exptime =
NULL,
603 voidSetAffinityPreference(EJobAffinityPreference aff_pref);
607 voidSetJobGroup(
const string& job_group);
634 const string& affinity_list =
kEmptyStr,
642 const string& affinity_list =
kEmptyStr);
691 voidPutFailure(
const CNetScheduleJob& job,
boolno_retries =
false);
717time_t* job_exptime =
NULL,
739 voidJobDelayExpiration(
const CNetScheduleJob& job,
unsignedruntime_inc);
750{ ChangePreferredAffinities(&affs_to_add,
NULL); }
753{ ChangePreferredAffinities(
NULL, &affs_to_del); }
755 voidChangePreferredAffinities(
constvector<string>* affs_to_add,
756 constvector<string>* affs_to_delete);
759 const string& GetQueueName();
760 const string& GetClientName();
761 const string& GetServiceName();
784eRNJ_Timeout = eRNJ_NotReady,
813 voidInterruptReading();
Client API for NCBI NetSchedule server.
Smart pointer to a part of the NetSchedule API that does job retrieval and processing on the worker n...
Smart pointer to a part of the NetSchedule API that allows to retrieve completed jobs.
Smart pointer to the job submission part of the NetSchedule API.
CTempString implements a light-weight string on top of a storage buffer whose lifetime management is ...
CTimeout â Timeout interval.
Declarations of CCompoundIDPool, CCompoundID, and CCompoundIDField.
void Read(CObjectIStream &in, TObjectPtr object, const CTypeRef &type)
void DeletePreferredAffinities(const vector< string > &affs_to_del)
EJobStatus
Job status codes.
CNetScheduleJob(const string &_input=kEmptyStr, const string &_affinity=kEmptyStr, CNetScheduleAPI::TJobMask _mask=CNetScheduleAPI::eEmptyMask)
string output
Job result data.
CNetScheduleAPI::TJobMask mask
void AddPreferredAffinities(const vector< string > &affs_to_add)
int ret_code
Job return code.
map< string, string > TQueueParams
CNetServer server
The server the job belongs to.
void SetCommunicationTimeout(const STimeout &to)
EJobAffinityPreference
Affinity matching modes.
EAppRegistry
Defines how this object must be initialized.
CNetScheduleNewJob(const string &_input=kEmptyStr, const string &_affinity=kEmptyStr, CNetScheduleAPI::TJobMask _mask=CNetScheduleAPI::eEmptyMask)
EReadNextJobResult
Possible outcomes of ReadNextJob() calls.
string job_id
Output job key.
CNetScheduleExecutor CNetScheduleExecuter
@ eExplicitAffinitiesOnly
@ eRNJ_NotReady
No matching jobs are ready for reading.
@ eRNJ_JobReady
A job is returned.
@ eRNJ_NoMoreJobs
No matching jobs.
@ eRNJ_Interrupt
ReadNextJob() has been interrupted.
@ eWarnAffinityAlreadyPreferred
@ eWarnAlertAlreadyAcknowledged
@ eWarnJobPassportOnlyMatch
@ eWarnConfigFileNotChanged
@ eWarnJobAlreadyCanceled
@ eWarnNoParametersChanged
@ eWarnAffinityNotPreferred
@ eWarnQueueAlreadyPaused
@ eWarnSubmitsDisabledForServer
#define END_NCBI_SCOPE
End previously defined NCBI scope.
#define BEGIN_NCBI_SCOPE
Define ncbi namespace.
#define NCBI_XCONNECT_EXPORT
#define NCBI_NET_COMPONENT(component)
ENetScheduleQueuePauseMode
Defines whether the job queue is paused, and if so, defines the pause mode set by the administrator.
Plugin manager (using class factory paradigm).
@ eCanceled
Request canceled.
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