|
| | PDG_Scheduler (const PDG_BaseType *type, const PDGT_ValueArgs &extra_args, const UT_StringHolder &name) |
| |
| | ~PDG_Scheduler () override |
| |
| const PDG_EventFilter & | 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...
|
| |
| PDGE_Dependency * | isSetupDep () |
| | 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 |
| |
| const PDG_NodeInterface * | templateInterface () const override |
| |
| const PDG_SchedulerType * | typeObject () const |
| | Returns the type object that defines the scheduler. More...
|
| |
| 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 bool | onSetupCook ()=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 PDG_WorkItem *work_item, const PDG_File &file, PDG_FileUtils::TransferType default_type, bool check_type, UT_WorkBuffer &errors) const |
| |
| bool | transferFile (const UT_StringHolder &file_path, PDG_FileUtils::TransferType default_type, bool check_type, UT_WorkBuffer &errors) const |
| |
| bool | transferFile (const UT_StringHolder &root_path, const UT_StringHolder &file_path, const UT_StringHolder &sub_path, PDG_FileUtils::TransferType default_type, bool check_type, UT_WorkBuffer &errors) const |
| |
| UT_StringHolder | formatTransferPath (const UT_StringHolder &local_path, PDG_FileUtils::TransferType default_type, bool local, bool check_type) const |
| |
| UT_StringHolder | formatTransferPath (const UT_StringHolder &root_path, const UT_StringHolder &local_path, const UT_StringHolder &sub_path, PDG_FileUtils::TransferType default_type, bool local, bool check_type) 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 scheduler. More...
|
| |
| bool | startCook (PDG_CookState &cook_state) |
| | Called when a cook begins with the cook state data for that cook. More...
|
| |
| void | stopCook () |
| | Called when a cook stops. More...
|
| |
| void | cancelCook (bool pause) |
| | Cancels an active cook. More...
|
| |
| bool | tick (PDG_Scheduler::TickResult &tick_result) |
| | Ticks the scheduler. More...
|
| |
| bool | cookWorkItem (PDG_WorkItem *work_item) |
| | Cooks a specific work item using it's internal cook method. More...
|
| |
| void | submitStatic () |
| | Submits a static cook with this scheduler. More...
|
| |
| virtual PDG_WorkItemState | queueWorkItem (PDG_WorkItem *work_item) |
| |
| void | removeWorkItem (const PDG_WorkItem *work_item) |
| | Removes a work item from any internal tracking lists. More...
|
| |
| bool | cancelWorkItem (PDG_WorkItem *work_item) |
| | Cancels a cook for a specific work tiem. More...
|
| |
| void | cancelNode (PDG_Node *node) |
| | Cancels a cook for a specific node. More...
|
| |
| 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, bool cancel) |
| | Stops a service that was started with this scheduler. More...
|
| |
| virtual bool | startServiceClient (UT_WorkBuffer &errors, PDG_Service *service, PDG_ServiceClient *client) |
| | Starts a job for the specified service client. More...
|
| |
| virtual bool | stopServiceClient (UT_WorkBuffer &errors, PDG_Service *service, PDG_ServiceClient *client) |
| | Stops the job associated with a specific client process. 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 | onWorkItemSetDictArray (PDG_WorkItemID work_item_id, int index, const UT_StringHolder &attribute_name, const UT_Array< UT_OptionsHolder > &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 | onWorkItemSetDict (PDG_WorkItemID work_item_id, int index, const UT_StringHolder &attribute_name, const UT_OptionsHolder &dict_repr, 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...
|
| |
| bool | asJSON (UT_JSONWriter &writer, bool skip_defaults) const |
| |
| virtual fpreal | tickPeriod () const |
| |
| virtual int | maxItemsPerTick () const |
| |
| virtual int | maxConcurrentTasks () const |
| |
| PDG_PathMappingMode | mapMode () const |
| |
| PDG_FileTransferType | transferType () const |
| |
| UT_StringHolder | transferRoot () 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 *event_queue, 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 PDG_EventFilter &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 &event, bool immediate=false) const |
| | Emit an event to all handlers. More...
|
| |
| void | eventHandlers (PDG_EventHandlerArray &handlers) const |
| |
| void | setEventQueue (PDG_EventQueue *event_queue) |
| |
| void | clearEventQueue () |
| |
| bool | shouldEmit (const PDG_Event &event) const |
| |
| | 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 |
| |