Ignore:
Timestamp:
06/25/19 16:14:54 (5 years ago)
Author:
yushan
Message:

MARK: Dynamic workflow graph developement. Branch up to date with trunk @1663.

File:
1 edited

Legend:

Unmodified
Added
Removed
  • XIOS/dev/dev_trunk_omp/src/filter/output_pin.cpp

    r1671 r1677  
    55namespace xios 
    66{ 
     7 
     8 
    79  COutputPin::COutputPin(CGarbageCollector& gc, bool manualTrigger /*= false*/, bool buildWorkflowGraph /* =false */) 
    810    : gc(gc) 
     
    1012    , buildWorkflowGraph(buildWorkflowGraph) 
    1113  { 
    12     if (buildWorkflowGraph) 
    13     { 
    14       filterId = InvalidableObject::count; 
    15       InvalidableObject::count++; 
    16     } 
     14    // parent_filter = new std::vector< void >(0); 
    1715  } 
    1816 
     
    4038            "The packet cannot be null."); 
    4139 
    42     if (buildWorkflowGraph) 
    43     { 
    44         if(CWorkflowGraph::mapFilterTimestamps_ptr==0) CWorkflowGraph::mapFilterTimestamps_ptr = new std::unordered_map <int, vector<Time> >; 
    45       if(CWorkflowGraph::timestamps_ptr==0) CWorkflowGraph::timestamps_ptr = new set<Time>; 
    46       (*CWorkflowGraph::mapFilterTimestamps_ptr)[this->getFilterId()].push_back(packet->timestamp); 
    47         CWorkflowGraph::timestamps_ptr->insert(packet->timestamp); 
    48     } 
     40    //if(CXios::isClient) std::cout<<"onOutputReady"<<std::endl;  
     41   
    4942 
    5043    if (manualTrigger) // Don't use canBeTriggered here, this function is virtual and can be overriden 
     
    123116  } 
    124117 
    125   int COutputPin::getFilterId(void) 
     118  void COutputPin::setParentFiltersTag() 
    126119  { 
    127     return filterId; 
     120    for(int i=0; i<parent_filters.size(); i++) 
     121    { 
     122      parent_filters[i]->tag += tag; 
     123      parent_filters[i]->setParentFiltersTag(); 
     124    } 
    128125  } 
    129126 
     127 
    130128} // namespace xios 
Note: See TracChangeset for help on using the changeset viewer.