]> AND Private Git Repository - blast.git/blob - GroupBlock.cpp
Logo AND Algorithmique Numérique Distribuée

Private GIT Repository
modifying pattern methods to throw exceptions
[blast.git] / GroupBlock.cpp
1 #include "GroupBlock.h"
2 #include "BlockParameterGeneric.h"
3 #include "AbstractInterface.h"
4 #include "ConnectedInterface.h"
5 #include "string.h"
6 #include <sstream>
7
8 int GroupBlock::counter = 1;
9
10 GroupBlock::GroupBlock(GroupBlock *_parent) throw(Exception) :  AbstractBlock() {
11
12   // force topGroup to false if this group has a parent
13   if (_parent != NULL) {    
14     topGroup = false;
15     name = QString("sub_group")+"_"+QString::number(counter++);
16   }
17   else {
18     topGroup = true;
19     name = QString("top_group");
20   }
21   parent = _parent;
22   if (parent != NULL) {
23     // adding this to the child blocks of parent
24     AB_TO_GRP(parent)->addBlock(this);
25   }
26 }
27
28 GroupBlock::~GroupBlock() {
29   foreach(AbstractBlock* block, blocks) {
30     delete block;
31   }
32 }
33
34 bool GroupBlock::isGroupBlock() {
35   return true;
36 }
37
38 bool GroupBlock::isTopGroupBlock() {
39   return topGroup;
40 }
41
42 void GroupBlock::setParent(AbstractBlock *_parent) {
43   parent = _parent;
44   if (parent != NULL) {
45     topGroup = false;
46   }
47 }
48
49 void GroupBlock::removeAllBlocks() {
50   foreach(AbstractBlock* block, blocks) {
51     if (block->isGroupBlock()) {
52       GroupBlock* group = AB_TO_GRP(block);
53       group->removeAllBlocks();
54     }
55     removeBlock(block);
56   }
57 }
58
59 void GroupBlock::removeBlock(AbstractBlock* block) {
60   /* CAUTION: no check is done if the block has connected interface
61      or not. Thus, they must be deleted elsewhere.
62   */
63   blocks.removeAll(block);
64   delete block;
65 }
66
67 AbstractBlock *GroupBlock::getFunctionalBlockByName(QString name) {
68   foreach(AbstractBlock* block, blocks) {
69     if (block->isFunctionalBlock()) {
70       if (block->getName() == name) return block;
71     }
72   }
73   return NULL;
74 }
75
76 void GroupBlock::parametersValidation(QList<AbstractBlock *> *checkedBlocks, QList<AbstractBlock *> *blocksToConfigure) {
77
78   /*
79   checkedBlocks->append(this);
80
81   foreach(BlockParameter* param, params){
82     if(param->isUserParameter() && !param->isValueSet()){
83       if(!blocksToConfigure->contains(param->getOwner())){
84         blocksToConfigure->append(param->getOwner());
85       }
86     }
87   }
88   foreach(AbstractInterface *inter, outputs){
89     foreach(AbstractInterface *connectedInter, inter->getConnectedTo()){
90       if(!checkedBlocks->contains(connectedInter->getOwner())){
91         connectedInter->getOwner()->parametersValidation(checkedBlocks, blocksToConfigure);
92       }
93     }
94   }
95   */
96 }
97
98 void GroupBlock::addGenericParameter(QString name, QString type, QString value) {
99   BlockParameter* param = new BlockParameterGeneric(this, name, type, value);
100   params.append(param);
101 }
102
103 void GroupBlock::removeGenericParameter(QString name) {
104   BlockParameter* p = getParameterFromName(name);
105   if (p != NULL) params.removeAll(p);
106 }
107
108 void GroupBlock::createInputPattern() {
109   foreach(AbstractInterface* iface, getControlInputs()) {
110     ConnectedInterface* connIface = AI_TO_CON(iface);
111     QList<char>* pattern = new QList<char>(*(connIface->getConnectedFrom()->getOutputPattern()));    
112     connIface->setOutputPattern(pattern);    
113   }  
114 }
115
116 void GroupBlock::checkInputPatternCompatibility() throw(Exception){  
117 }
118
119 void GroupBlock::computeOutputPattern(int nbExec) throw(Exception) {
120
121   static QString fctName = "GroupBlock::computeOutputPattern()";
122 #ifdef DEBUG_FCTNAME
123   cout << "call to " << qPrintable(fctName) << endl;
124 #endif
125
126   cout << "computing output pattern of group " << qPrintable(name) << endl;
127   
128   bool canCompute = false;
129   bool compatible = false;
130   // get the input pattern on each inputs
131   createInputPattern();
132   
133   cout << "Input pattern OK" << endl;
134   // find blocks that are connected to that inputs and generators
135   QList<AbstractBlock*> fifo;
136   foreach(AbstractBlock* block, blocks) {
137         
138     bool addIt = false;
139     // if a block is a generator and has control outputs, add it
140     if (block->isGeneratorBlock()) {
141       if (block->getControlOutputs().size() > 0) addIt = true;
142     }
143     else {
144       // if the block has a control input connected from an intput of the group, add it too
145       foreach(AbstractInterface* iface, block->getControlInputs()) {
146         //cout << qPrintable(iface->getName()) << " of " << qPrintable(iface->getOwner()->getName()) << " connected to " << endl;       
147         ConnectedInterface* connFrom = ((ConnectedInterface*)iface)->getConnectedFrom();
148         //cout << qPrintable(connFrom->getName()) << " of " << qPrintable(connFrom->getOwner()->getName()) << endl;
149         
150         if (connFrom->getOwner() == this) {
151           addIt = true;
152           break;
153         }
154       }
155     }
156     if (addIt) {
157       cout << "adding " << qPrintable(block->getName()) << " to initialize the FIFO" << endl;
158       fifo.append(block);    
159     }
160   }
161   
162   while (!fifo.isEmpty()) {
163     AbstractBlock* block = fifo.takeFirst();
164     
165     if (block->getPatternComputed()) continue; // block has already been processed
166     
167     try {
168       block->checkInputPatternCompatibility();
169     }
170     catch(Exception e) {
171       cout << qPrintable(block->getName()) << " is not compatible with his input pattern" << endl;
172       throw(e);
173     }
174     compatible = true;
175     
176     try {
177       block->computeOutputPattern();
178     }
179     catch(Exception e) {    
180       cout << "cannot finalize output pattern computation of " << qPrintable(block->getName()) << endl;
181       throw(e);      
182     }
183     canCompute = true;
184     block->setPatternComputed(true);
185     // add other blocks connected from block to the fifo
186     foreach(AbstractInterface* iface, block->getControlOutputs()) {
187       ConnectedInterface* conn = (ConnectedInterface*)iface;
188       foreach(ConnectedInterface* connTo, conn->getConnectedTo()) {
189         /* if connTo is owned by a functional block
190            or by a group block that is within this, add the block to the fifo.
191          */
192         if (connTo->getOwner()->isFunctionalBlock()) {
193           fifo.append(connTo->getOwner());
194         }
195         else if (connTo->getOwner() != this) {
196           fifo.append(connTo->getOwner());
197         }      
198       }
199     }
200   }
201   
202   if (canCompute) {
203     foreach(AbstractInterface* iface, getControlOutputs()) {
204       ConnectedInterface* connIface = AI_TO_CON(iface);
205       QList<char>* pattern = new QList<char>(*(connIface->getConnectedFrom()->getOutputPattern()));
206       connIface->setOutputPattern(pattern);    
207     }
208     setPatternComputed(true);
209   }  
210 }