|
| PDG_Scheduler (const PDG_BaseType *type, const PDGT_ValueArgs &extra_args, const UT_StringHolder &name) |
|
| ~PDG_Scheduler () override |
|
PDG_EventEmitter::Filter & | supportedEventTypes () const override |
| Returns the list of supported event types. More...
|
|
int64 | getMemoryUsage (bool inclusive) const override |
| Returns the memory usage of this owner instance. More...
|
|
UT_StringHolder | debugName () const override |
| Debug name method, required by PDGE_DependencyOwner. More...
|
|
void | resetOwner () override |
| Resets the dependency owner. More...
|
|
PDGE_Dependency * | isCookedDep () |
| Returns the is cooked dep for this scheduler. More...
|
|
const UT_StringHolder & | name () const |
| Returns the name of the shceudler. More...
|
|
bool | reloadInstance (UT_WorkBuffer &errors) override |
|
bool | canSchedule (const PDG_WorkItem *work_item) |
|
virtual void | onScheduleStatic (const PDG_WorkItemMap &dependencies, const PDG_WorkItemMap &dependents, const PDG_WorkItemArray &ready_items)=0 |
| Called when the scheduler should process a static dependency graph. More...
|
|
virtual ScheduleResult | onSchedule (PDG_WorkItem *work_item)=0 |
|
virtual void | onCancelWorkItems (const PDG_WorkItemArray &work_item, PDG_Node *node)=0 |
| Called when a specific work item should be canceled. More...
|
|
virtual bool | onStart ()=0 |
|
virtual bool | onStop ()=0 |
|
virtual bool | onStartCook (bool static_cook, const PDG_NodeSet &)=0 |
| Called when cooking begins. More...
|
|
virtual bool | onStopCook (bool cancel)=0 |
| Called when cooking completes or is canceled. More...
|
|
virtual void | onConfigureCook (PDG_CookOptions *cook_ptions)=0 |
|
virtual TickResult | onTick ()=0 |
| Called periodically during cooking to update state. More...
|
|
virtual AcceptResult | onAcceptWorkItem (const PDG_WorkItem *work_item)=0 |
|
virtual bool | onTransferFile (const UT_StringHolder &file_path) |
| Custom file transfer logic, implemented per-scheduler. More...
|
|
bool | transferFile (const UT_StringHolder &file_path, PDG_FileUtils::TransferType default_type, UT_WorkBuffer &errors) const |
|
UT_StringHolder | formatTransferPath (const UT_StringHolder &local_path, PDG_FileUtils::TransferType default_type, bool local) const |
|
UT_StringHolder | localizePath (const UT_StringHolder &deloc_path) const |
| Returns the local version of the given path. More...
|
|
UT_StringHolder | delocalizePath (const UT_StringHolder &local_path) const |
| Returns the delocalized (remote) version of the given local path. More...
|
|
UT_StringHolder | jobName (const PDG_WorkItem *work_item) const |
| Returns the job name for the specified work item. More...
|
|
virtual UT_StringHolder | expandCommandTokens (const UT_StringHolder &command, const PDG_WorkItem *work_item)=0 |
| Expands special tokens in the command string. More...
|
|
virtual UT_StringHolder | submitAsJob (const UT_StringHolder &graph_file, const UT_StringHolder &node_name)=0 |
| cook the output node in the graph context of the given file as a single job More...
|
|
void | setWorkingDir (const UT_StringHolder &local_path, const UT_StringHolder &remote_path) |
|
void | setTempDir (const UT_StringHolder &local_path, const UT_StringHolder &remote_path) |
|
void | setScriptDir (const UT_StringHolder &local_path, const UT_StringHolder &remote_path) |
|
void | setAcceptInProcess (bool in_process) |
| sets whether or not the scheduler accepts in-process work items More...
|
|
UT_StringHolder | workingDir (bool local) const |
|
UT_StringHolder | tempDir (bool local) const |
|
UT_StringHolder | scriptDir (bool local) const |
|
UT_StringHolder | logDir (bool local) const |
|
UT_StringHolder | dataDir (bool local) const |
|
virtual UT_StringHolder | applicationBin (const UT_StringHolder &name, const PDG_WorkItem *work_item) |
|
virtual UT_StringHolder | workItemResultServerAddr ()=0 |
|
virtual UT_StringHolder | getLogURI (const PDG_WorkItem *work_item)=0 |
| returns a URI for the workitem cook log (text file) More...
|
|
virtual UT_StringHolder | getStatusURI (const PDG_WorkItem *work_item)=0 |
| returns a URI for the workitem status page if relevant More...
|
|
virtual bool | endSharedServer (const UT_StringHolder &sharedserver_name)=0 |
| Terminate the give shared server. More...
|
|
virtual void | clearSharedServerInfo (const UT_StringHolder &sharedserver_name) |
| Clears metadata associated with the given shared server name. More...
|
|
virtual UT_StringHolder | setSharedServerInfo (const UT_StringHolder &sharedserver_name, const PDGT_ValueArgs &info) |
| Sets metadata associated with the given shared server name, returns full name. More...
|
|
PDGT_ValueArgs | getSharedServerInfo (const UT_StringHolder &sharedserver_name) |
| Gets metadata associated with the given shared server name. More...
|
|
UT_StringArray | getSharedServers () |
| Gets the list of shared servers. More...
|
|
virtual void | cleanTempDirectory () |
| Delete the temporary directory and all its contents. More...
|
|
void | stop (bool exiting) |
| Called to stop the running cook. More...
|
|
bool | startCook (PDG_CookState &cook_state) |
|
void | stopCook () |
|
void | cancelCook (bool pause) |
|
bool | tick (PDG_Scheduler::TickResult &tick_result) |
|
bool | cookWorkItem (PDG_WorkItem *work_item) |
|
void | submitStatic () |
|
virtual PDG_WorkItemState | queueWorkItem (PDG_WorkItem *work_item) |
|
void | removeWorkItem (const PDG_WorkItem *work_item) |
|
void | cancelWorkItem (PDG_WorkItem *work_item) |
|
void | cancelNode (PDG_Node *node) |
|
void | onWorkItemPriorityChanged (PDG_WorkItem *work_item) |
|
void | process (bool skip_ready_items) |
|
bool | isRunning (int count=0) |
|
bool | isRunning (const PDG_WorkItem *work_item) |
|
bool | isDefault () |
|
bool | isWaitForFailures () const |
|
bool | isValidateOutputFiles () const |
|
bool | isCheckExpectedOutputFiles () const |
|
bool | isCompressWorkItemData () const |
|
virtual
PDGN::PDGN_PollingClientNNG * | getPollingClient () |
|
WorkItemDataSource | workItemDataSource () const |
|
int | numRunningItems () const |
|
int | numFailedItems () const |
|
int | numQueuedItems () const |
|
void | setContext (PDG_GraphContext *context) |
|
PDG_GraphContext * | context () const |
|
void | dependencyGraph (PDG_WorkItemMap &dependencies, PDG_WorkItemMap &dependents, PDG_WorkItemArray &ready, bool expand) |
|
virtual bool | startService (UT_WorkBuffer &errors, PDG_Service *service) |
| Starts a service using this scheduler. More...
|
|
virtual bool | stopService (UT_WorkBuffer &errors, PDG_Service *service) |
| Stops a service that was started with this scheduler. More...
|
|
template<typename T , typename D = T> |
bool | evaluateOverride (T &result, PDG_NodeInterface *node, const UT_StringHolder &prefix, const UT_StringHolder &parm, PDG_WorkItem *work_item, const D &default_value, UT_WorkBuffer &errors) const |
|
void | onWorkItemSetStringArray (PDG_WorkItemID work_item_id, int index, const UT_StringHolder &attribute_name, const PDG_AttributeString::Array &value) |
|
void | onWorkItemSetFloatArray (PDG_WorkItemID work_item_id, int index, const UT_StringHolder &attribute_name, const PDG_AttributeFloat::Array &value) |
|
void | onWorkItemSetIntArray (PDG_WorkItemID work_item_id, int index, const UT_StringHolder &attribute_name, const PDG_AttributeInteger::Array &value) |
|
void | onWorkItemSetFileArray (PDG_WorkItemID work_item_id, int index, const UT_StringHolder &attribute_name, const PDG_AttributeFile::Array &value) |
|
void | onWorkItemSetPyObject (PDG_WorkItemID work_item_id, int index, const UT_StringHolder &attribute_name, const UT_StringHolder &pyobject_repr) |
|
void | onWorkItemSetString (PDG_WorkItemID work_item_id, int index, const UT_StringHolder &attribute_name, const UT_StringHolder &value, int attrib_index) |
|
void | onWorkItemSetFloat (PDG_WorkItemID work_item_id, int index, const UT_StringHolder &attribute_name, fpreal value, int attrib_index) |
|
void | onWorkItemSetInt (PDG_WorkItemID work_item_id, int index, const UT_StringHolder &attribute_name, exint value, int attrib_index) |
|
void | onWorkItemSetFile (PDG_WorkItemID work_item_id, int index, const UT_StringHolder &attribute_name, const PDG_AttributeFile::Data &value, int attrib_index) |
|
void | onWorkItemAddOutput (PDG_WorkItemID work_item_id, int index, const UT_StringHolder &path, const UT_StringHolder &tag, PDG_File::Hash hash_code, bool active_only) |
|
void | onWorkItemAddOutputs (PDG_WorkItemID work_item_id, int index, const UT_StringArray &paths, const UT_StringHolder &tags, const PDG_File::HashArray &hashes, bool active_only) |
|
void | onWorkItemAddOutputs (PDG_WorkItemID work_item_id, int index, const UT_StringArray &paths, const UT_StringArray &tags, const PDG_File::HashArray &hashes, bool active_only) |
|
void | onWorkItemInvalidateCache (PDG_WorkItemID work_item_id, int index) |
|
void | onWorkItemSucceeded (PDG_WorkItemID work_item_id, int index, fpreal cook_duration) |
|
void | onWorkItemFailed (PDG_WorkItemID work_item_id, int index) |
|
void | onWorkItemCanceled (PDG_WorkItemID work_item_id, int index) |
|
void | onWorkItemStartCook (PDG_WorkItemID work_item_id, int index, bool clear_outputs) |
|
void | onWorkItemSetCustomState (PDG_WorkItemID work_item_id, int index, const UT_StringHolder &custom_state) |
|
void | onWorkItemSetCookPercent (PDG_WorkItemID work_item_id, int index, fpreal &cook_percent) |
|
void | onWorkItemAppendLog (PDG_WorkItemID work_item_id, int index, const UT_StringHolder &log_data, PDG_WorkItemLogType log_type) |
|
PDG_WorkItemEvalState | isWorkItemReady (PDG_WorkItemID work_item_id, int index) |
|
void | addError (const UT_StringHolder &message) const override |
| Emits errors or warnings from the scheduler as PDG_Events. More...
|
|
void | addWarning (const UT_StringHolder &message) const override |
| Adds a warning to the node interface – implemented in subclasses. More...
|
|
virtual fpreal | tickPeriod () const |
|
virtual int | maxItemsPerTick () const |
|
virtual int | maxConcurrentTasks () const |
|
PathMappingMode | mapMode () const |
|
| PDG_NodeInterface (UT_StringHolder name="", UT_StringHolder data_type="") |
|
virtual | ~PDG_NodeInterface () |
|
int64 | getMemoryUsage (bool inclusive) const |
|
void | cloneFrom (const PDG_NodeInterface &interface) |
|
void | addBuiltinPorts (PDG_NodeType type, PDG_NodeSubtype sub_type) |
| Adds builtin ports for the specified node type and subtype. More...
|
|
PDG_WorkItemDataType * | workItemDataType () |
| Queries the work item data type associated with this node. More...
|
|
const PDG_WorkItemDataType * | workItemDataType () const |
|
bool | resolveWorkItemDataType (UT_WorkBuffer &errors) |
| Resolves and caches the work item data type. More...
|
|
const PDG_PortArray & | ports (PDG_PortType type) const |
| Returns the list of all ports of the specified type. More...
|
|
const PDG_PortArray & | inputPorts () const |
|
const PDG_PortArray & | outputPorts () const |
|
const PDG_PortArray & | parameters () const |
|
const ParameterGroupArray & | parameterGroups () const |
| Returns the list of parameter groups for the node. More...
|
|
bool | parametersForTag (const UT_StringHolder &tag, PDG_PortArray ¶meters) const |
| Returns the list of parameters with the specified tag. More...
|
|
const PDG_PortArray & | customParameters () const |
| Returns the list of custom parameter ports. More...
|
|
PDG_Port * | port (PDG_PortType type, int index) const |
|
PDG_Port * | port (PDG_PortType type, const UT_StringHolder &name) const |
|
PDG_Port * | port (const UT_StringHolder &name) const |
|
PDG_Port * | inputPort (int index) const |
| Specialized functions for finding input ports by name or index. More...
|
|
PDG_Port * | inputPort (const UT_StringHolder &name) const |
|
bool | inputPortsForNode (PDG_Node *node, PDG_PortArray &ports) const |
|
bool | inputPortsForWorkItem (const PDG_WorkItem *work_item, PDG_PortArray &ports) const |
|
bool | isWorkItemFromInputPort (const PDG_WorkItem *work_item, const UT_StringHolder &name) const |
|
PDG_Port * | outputPort (int index) const |
| Sepcialized functions for finding output ports by name or index. More...
|
|
PDG_Port * | outputPort (const UT_StringHolder &name) const |
|
PDG_Port * | parameter (const UT_StringHolder &name, int multi=-1) const |
|
PDGT_Value * | paramValue (const UT_StringHolder &name, int index=0) const |
|
PDGT_Value * | defaultParamValue (const UT_StringHolder &name, int index=0) const |
|
int | portCount (PDG_PortType type) const |
|
int | inputCount () const |
|
int | outputCount () const |
|
int | parameterCount () const |
|
bool | hasUnorderedPorts () const |
|
int | numOrderedPorts () const |
|
PDG_Port * | addPort (PDG_PortType type, const PDG_WorkItemDataType *data_type, const UT_StringHolder &name, const UT_StringHolder &label, const UT_StringArray &tags=UT_StringArray(), int size=0, bool ordered=true, bool custom=false) |
|
PDG_Port * | addParameter (PDGT_Value::DataType data_type, const UT_StringHolder &name, const UT_StringHolder &label, const UT_StringArray &tags, int size=1, bool custom=false) |
|
PDG_Port * | addParameter (PDGT_Value::DataType data_type, const UT_StringHolder &name, const UT_StringHolder &label, int size=1, bool custom=false) |
| Adds a parameter with a data type, name, label and optional size. More...
|
|
bool | removeParameter (const UT_StringHolder &name) |
|
void | addFileDependency (const UT_StringHolder &file_path) |
| Adds a new file dependency to the node interface. More...
|
|
void | addParameterGroup (const UT_StringHolder &name, bool root=true, bool multiparm=false) |
| Adds a new parameter group to the node interface. More...
|
|
void | endParameterGroup () |
| Ends the current parameter group. More...
|
|
const UT_StringHolder & | templateName () const |
|
bool | isValid () const |
| Returns true if the node interface is valid. More...
|
|
const DependencyArray & | autoDependencies () const |
| Returns the list of external files that this node depends on. More...
|
|
const PDG_Port::ExpressionVars & | commonVars () const |
|
PDG_ApplicationShim::Node * | appNode () const |
|
template<typename T , typename... Args> |
void | setAppNode (Args &&...args) |
| Sets the underlying app node. More...
|
|
const PDG_AttributeInfo & | attributeInfo () const |
|
void | setAttributeInfo (const PDG_AttributeInfo &info) |
| Clears and sets the attribute info for this interface. More...
|
|
const PDG_JobScriptInfo & | scriptInfo () const |
| Returns the script info for this node interface. More...
|
|
void | setScriptInfo (const PDG_JobScriptInfo &info) |
| Sets the script info for the interface. More...
|
|
void | setServiceCompatibility (const UT_StringHolder &service_type_name, bool compatible) |
|
template<typename... Args> |
void | addErrorFmt (const char *fmt, Args &&...args) const |
| Adds an error using a format string, instead of plain string. More...
|
|
template<typename... Args> |
void | addWarningFmt (const char *fmt, Args &&...args) const |
| Adds a warning using a format string, instead of plain string. More...
|
|
template<typename T > |
bool | evaluate (T &result, const UT_StringHolder &name, const PDG_WorkItem *work_item=nullptr, int index=0, int multi=-1) const |
| Evaluates a parameter and reports errors if desired. More...
|
|
bool | evaluateRaw (UT_StringHolder &result, const UT_StringHolder &name, const PDG_WorkItem *work_item=nullptr, int index=0, int multi=-1) const |
|
template<typename T > |
bool | evaluateArray (T &result, const UT_StringHolder &name, const PDG_WorkItem *work_item=nullptr, int multi=-1) const |
| Evaluates a parameter as an array and reports errors if desired. More...
|
|
| PDG_EventEmitter (PDG_EventQueue *eventQueue, bool block_destruction) |
|
virtual | ~PDG_EventEmitter () |
|
int64 | getMemoryUsage (bool inclusive) const |
| Returns memory usage for this event emitter instance. More...
|
|
bool | addEventHandler (PDG_EventHandler *handler) |
| Adds an event handlers that listens for all types of events. More...
|
|
bool | addEventHandler (PDG_EventHandler *handler, PDG_EventType event) |
| Adds an event handlers that listens for a specific event. More...
|
|
bool | addEventHandler (PDG_EventHandler *handler, const Filter &filter) |
|
void | removeEventHandler (PDG_EventHandler *handler) |
| Removes an event handler from this emitter. More...
|
|
void | removeAllEventHandlers (bool user_handler_only=false) |
|
void | emitEvent (const PDG_Event &evt) const |
| Emit an event to all handlers. More...
|
|
void | eventHandlers (HandlerArray &handlers) const |
|
void | setEventQueue (PDG_EventQueue *eventQueue) |
|
void | eventQueueDestroyed () |
|
| PDGT_TypeInstance () |
|
| PDGT_TypeInstance (const PDGT_BaseType< EnumType > *base_type, const PDGT_ValueArgs &extra_args) |
|
virtual | ~PDGT_TypeInstance () |
|
const BaseType * | type () const |
|
const UT_StringHolder & | typeName () const |
|
const PDGT_ValueArgs & | extraArgs () const |
|
bool | compareType (const BaseType *other_type, bool deep=true) const |
|
void | setReloading (bool is_reloading) |
|
bool | isReloading () const |
|
| PDGE_DependencyOwner () |
| Constructs a new dependency owner, which must have a string name. More...
|
|
virtual | ~PDGE_DependencyOwner () |
|
virtual UT_StringHolder | debugGroup () const |
|