Searched refs:AbstractProcessNode (Results 1 – 8 of 8) sorted by relevance
22 AbstractProcessNode::AbstractProcessNode(AbstractProcess* process) in AbstractProcessNode() function in AbstractProcessNode31 AbstractProcessNode::~AbstractProcessNode() in ~AbstractProcessNode()38 AbstractProcessNode::Process() const in Process()45 AbstractProcessNode::IsRunning() in IsRunning()52 AbstractProcessNode::SetListener(ProcessListener* listener) in SetListener()66 AbstractProcessNode::_SpinUntilProcessState( in _SpinUntilProcessState()89 AbstractProcessNode::AddPredecessor(AbstractProcessNode *node) in AddPredecessor()97 AbstractProcessNode::CountPredecessors() const in CountPredecessors()103 AbstractProcessNode*104 AbstractProcessNode::PredecessorAt(int32 index) const in PredecessorAt()[all …]
25 class AbstractProcessNode {27 AbstractProcessNode(AbstractProcess* process);28 virtual ~AbstractProcessNode();35 void AddPredecessor(AbstractProcessNode* node);37 AbstractProcessNode*42 AbstractProcessNode*59 void _AddSuccessor(AbstractProcessNode* node);62 BObjectList<AbstractProcessNode>64 BObjectList<AbstractProcessNode>
50 AbstractProcessNode* node = new ThreadedProcessNode( in CreateIncrementViewCounter()64 AbstractProcessNode* userDetailVerifier = new ThreadedProcessNode( in CreateUserDetailVerifierCoordinator()82 AbstractProcessNode *localRepositoryUpdate = in CreateBulkLoadCoordinator()87 AbstractProcessNode *localPkgDataLoad = in CreateBulkLoadCoordinator()94 AbstractProcessNode *serverIconExportUpdate = in CreateBulkLoadCoordinator()100 AbstractProcessNode *serverRepositoryDataUpdate = in CreateBulkLoadCoordinator()106 AbstractProcessNode *serverReferenceDataUpdate = in CreateBulkLoadCoordinator()116 AbstractProcessNode* populatePkgSizes = in CreateBulkLoadCoordinator()133 AbstractProcessNode* processNode = new ThreadedProcessNode( in CreateBulkLoadCoordinator()213 AbstractProcessNode *processNode = in _CreateInstallPackageActionCoordinator()[all …]
157 AbstractProcessNode* node = fNodes.ItemAt(i); in ~ProcessCoordinator()179 ProcessCoordinator::AddNode(AbstractProcessNode* node) in AddNode()200 AbstractProcessNode* node = fNodes.ItemAt(i); in IsRunning()224 AbstractProcessNode* node = fNodes.ItemAt(i); in RequestStop()398 AbstractProcessNode* node = fNodes.ItemAt(i); in _Coordinate()423 AbstractProcessNode* node = fNodes.ItemAt(i); in _StopSuccessorNodesToErroredOrStoppedNodes()435 ProcessCoordinator::_StopSuccessorNodes(AbstractProcessNode* predecessorNode) in _StopSuccessorNodes()438 AbstractProcessNode* node = predecessorNode->SuccessorAt(i); in _StopSuccessorNodes()473 AbstractProcessNode* node = fNodes.ItemAt(i); in LogReport()
98 void AddNode(AbstractProcessNode* nodes);126 void _StopSuccessorNodes(AbstractProcessNode* node);133 BObjectList<AbstractProcessNode>
23 AbstractProcessNode(process), in ThreadedProcessNode()32 AbstractProcessNode(process), in ThreadedProcessNode()51 if (!AbstractProcessNode::IsRunning()) { in IsRunning()
11 class ThreadedProcessNode : public AbstractProcessNode {
196 AbstractProcessNode.cpp