Salome HOME
Restore IsLoading (CVS problem)
[modules/superv.git] / src / SUPERVGUI / SUPERVGUI_Main.cxx
1 //  SUPERV SUPERVGUI : GUI for Supervisor component
2 //
3 //  Copyright (C) 2003  OPEN CASCADE, EADS/CCR, LIP6, CEA/DEN,
4 //  CEDRAT, EDF R&D, LEG, PRINCIPIA R&D, BUREAU VERITAS 
5 // 
6 //  This library is free software; you can redistribute it and/or 
7 //  modify it under the terms of the GNU Lesser General Public 
8 //  License as published by the Free Software Foundation; either 
9 //  version 2.1 of the License. 
10 // 
11 //  This library is distributed in the hope that it will be useful, 
12 //  but WITHOUT ANY WARRANTY; without even the implied warranty of 
13 //  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU 
14 //  Lesser General Public License for more details. 
15 // 
16 //  You should have received a copy of the GNU Lesser General Public 
17 //  License along with this library; if not, write to the Free Software 
18 //  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307 USA 
19 // 
20 //  See http://www.opencascade.org/SALOME/ or email : webmaster.salome@opencascade.org 
21 //
22 //
23 //
24 //  File   : SUPERVGUI_Main.cxx
25 //  Author : Francis KLOSS
26 //  Module : SUPERV
27
28 using namespace std;
29
30 #include "QAD_Splitter.h"
31 #include "QAD_LeftFrame.h"
32 #include "QAD_ObjectBrowser.h"
33 #include "QAD_ObjectBrowserItem.h"
34 #include "QAD_PyEditor.h"
35 #include "QAD_Message.h"
36 #include "QAD_FileDlg.h"
37 #include "QAD_Application.h"
38 #include "QAD_RightFrame.h"
39 #include "QAD_SpinBoxDbl.h"
40
41 #include "NOTIFICATION.hxx"
42 #include "SALOME_Event.hxx"
43 #include "SALOMEGUI_ImportOperation.h"
44 #include "SUPERVGraph_ViewFrame.h"
45
46 #include "SUPERVGUI.h"
47 #include "SUPERVGUI_Def.h"
48 #include "SUPERVGUI_Main.h"
49 #include "SUPERVGUI_Notification.h"
50 #include "SUPERVGUI_Information.h"
51 #include "SUPERVGUI_CanvasControlNode.h"
52
53 #include <qvalidator.h>
54 #include <qlayout.h>
55 #include <qfile.h>
56 #include <qlineedit.h>
57 #include <qcombobox.h>
58
59
60 SUPERVGUI_Main::SUPERVGUI_Main(SUPERVGraph_ViewFrame* theParent, QAD_Desktop* theDesktop, SUPERV_Graph theDataFlow )
61      : SUPERVGraph_View(theParent),
62        myLogged( false ),
63        myFiltered( false ),
64        myLogFileName( QString::null ),
65        myLogFile( NULL ),
66        myWarning( false ),
67        myStep( false ),
68        myTrace( false ),
69        myVerbose( false ),
70        myGUIEventLoopFinished( true )
71 {
72   Trace("SUPERVGUI_Main::SUPERVGUI_Main (copy)");
73   theParent->setViewWidget(this);  
74   dataflow = theDataFlow;
75   if (SUPERV_isNull(dataflow)) {
76     QMessageBox::warning(0, tr("ERROR"), tr("MSG_CANT_COPY"));
77     close();
78   } else {
79     init(theDesktop);
80   }
81 }
82
83 void SUPERVGUI_Main::init(QAD_Desktop* theDesktop) {
84   Trace("SUPERVGUI_Main::init");
85   if (theDesktop) myNService = theDesktop->getNameService();
86   myHashCode = "New";
87   myCopyNum = 0;
88   choosing  = false;
89   myIsLocked = false;
90
91   myThread = new SUPERVGUI_Thread();
92   myThread->setMain(this);
93
94   myIsKilled = false;
95   myCurrentView = CANVAS;
96   myIsFromStudy = false;
97   myLastGraph = 0;
98   study     = theDesktop->getActiveStudy();
99   
100   SALOMEDS::Study_var studyDoc = study->getStudyDocument();
101   bool aLocked = studyDoc->GetProperties()->IsLocked();
102   SALOMEDS::StudyBuilder_var builder = studyDoc->NewBuilder();
103   SALOMEDS::SComponent_var father = studyDoc->FindComponent(STUDY_SUPERVISION);
104   SALOMEDS::GenericAttribute_var anAttr;
105   SALOMEDS::AttributeName_var    aName;
106   SALOMEDS::AttributePixMap_var  aPixmap;
107   if (father->_is_nil()) {
108     QAD_Operation* op = new SALOMEGUI_ImportOperation( study );
109     op->start();
110     if (aLocked) studyDoc->GetProperties()->SetLocked(false);
111     father = builder->NewComponent(STUDY_SUPERVISION);
112     anAttr = builder->FindOrCreateAttribute(father, "AttributeName");
113     aName = SALOMEDS::AttributeName::_narrow(anAttr);
114     aName->SetValue(QAD_Application::getDesktop()->getComponentUserName( "SUPERV" ) );
115     
116     anAttr = builder->FindOrCreateAttribute(father, "AttributePixMap");
117     aPixmap = SALOMEDS::AttributePixMap::_narrow(anAttr);
118     aPixmap->SetPixMap( "ICON_OBJBROWSER_Supervision" );
119     
120     builder->DefineComponentInstance(father, Supervision.getEngine());
121     if (aLocked) studyDoc->GetProperties()->SetLocked(true);
122     op->finish();
123   };
124
125   objectBrowser = study->getActiveStudyFrame()->getLeftFrame()->getObjectBrowser();
126     
127   myArray = new SUPERVGUI_CanvasArray(this);
128   myArrayView = new SUPERVGUI_ArrayView(myArray, this);
129
130   myCanvas = new SUPERVGUI_Canvas(this);
131   myCanvasView = new SUPERVGUI_CanvasView(myCanvas, this);
132   
133   message = study->getActiveStudyFrame()->getRightFrame()->getMessage();
134   notification = new NOTIFICATION_Consumer();
135
136   QBoxLayout * layout = new QVBoxLayout(this);
137   layout->setMargin(0);
138   layout->setSpacing(0);
139   layout->addWidget(myCanvasView);
140   layout->addWidget(myArrayView);
141
142   if (myCurrentView == CANVAS || myCurrentView == CONTROLFLOW) {
143     myCanvas->merge();
144   }
145   sync();
146   show();
147   if ( myLogged && !myLogFileName.isEmpty() && QFile::exists( myLogFileName ) ) {
148     myLogFile = fopen( myLogFileName.latin1(), "a" );
149     if (  myLogFile == NULL )
150       myLogged = false;
151   }
152   myTimer = new QTimer( this );
153   connect( myTimer, SIGNAL(timeout()), this, SLOT(checkExecution()) );
154 }
155
156 SUPERVGUI_Main::~SUPERVGUI_Main() {
157   Trace("SUPERVGUI_Main::~SUPERVGUI_Main");
158
159   // close all opened SubGraphs 
160   QMap<QString, QAD_StudyFrame*>::iterator it;
161   for (it = mySubGraphs.begin(); it != mySubGraphs.end(); ++it) {
162     it.data()->removeEventFilter(this);
163     it.data()->disconnect();
164     it.data()->close();
165
166     QAD_Study* aStudy = it.data()->getStudy();
167     aStudy->removeStudyFrame(it.data());
168   }
169   mySubGraphs.clear();
170   mySubGraphMap.clear();
171   /*
172   QAD_StudyFrame* aSubGraph;
173   for (aSubGraph = mySubGraphs.first(); aSubGraph; aSubGraph = mySubGraphs.next()) {
174     aSubGraph->removeEventFilter(this);
175     aSubGraph->close();
176   }
177   */
178
179   if ( myLogFile != NULL) {
180     fclose( myLogFile );
181   }
182   
183   //delete myCanvas;
184   //  delete notification; // kloss : nota bene : quand un datalow est detruit : verifier que les canaux de notification sont aussi detruit
185   notification->_remove_ref();  // kloss : nota bene : quand un datalow est detruit : verifier que les canaux de notification sont aussi detruit
186
187   delete myCanvas;
188   delete myArray;
189 }
190
191 void SUPERVGUI_Main::filterNotification() {
192   Trace("SUPERVGUI_Main::filterNotification");
193   SUPERVGUI_Notification* dlg = new SUPERVGUI_Notification(this);
194   dlg->setFiltered( myFiltered );
195   dlg->setLogged( myLogged, myLogFileName );
196   dlg->setWarning( myWarning );
197   dlg->setStep( myStep );
198   dlg->setTrace( myTrace );
199   dlg->setVerbose( myVerbose );
200   if ( dlg->exec() == QDialog::Accepted ) {
201     myLogged      = dlg->getLogged();
202     myLogFileName = dlg->getLogFile();
203     myFiltered    = dlg->getFiltered();
204     myWarning     = dlg->getWarning();
205     myStep        = dlg->getStep();
206     myTrace       = dlg->getTrace();
207     myVerbose     = dlg->getVerbose();
208     delete dlg;
209     if ( myLogFile != NULL) {
210       fclose( myLogFile );
211     }
212     myLogFile = NULL;
213     if ( myLogged && !myLogFileName.isEmpty() && QFile::exists( myLogFileName ) ) {
214       myLogFile = fopen( myLogFileName.latin1(), "a" );
215       if (  myLogFile == NULL ) {
216         myLogged = false;
217         QMessageBox::warning( QAD_Application::getDesktop(), tr("ERROR"), tr( "ERR_CANT_OPEN_LOG_FILE" ) );
218       }
219     }
220   }
221 }
222
223 void SUPERVGUI_Main::syncAsync() {
224     Trace("SUPERVGUI_Main::syncAsync")
225     QTimer::singleShot(1, this, SLOT(sync()));
226 }
227
228
229 /**
230  * Called by thread when dataflow is executing
231  */
232 void SUPERVGUI_Main::execute(char *  theNodeName, SUPERV::GraphState theNodeState) {
233   if (myCurrentView == CANVAS || myCurrentView == CONTROLFLOW) {
234     SUPERVGUI_CanvasNode* aNode = (SUPERVGUI_CanvasNode*) myCanvas->child(theNodeName, "SUPERVGUI_CanvasNode");
235     if ( aNode ) {
236       aNode->sync();
237     }
238   }
239   else if (myCurrentView == CANVASTABLE) {
240     SUPERVGUI_CanvasCellNode* aNode = (SUPERVGUI_CanvasCellNode*) myArray->child(theNodeName, "SUPERVGUI_CanvasCellNode");
241     if (aNode) aNode->sync();
242   }
243 }
244
245
246 void SUPERVGUI_Main::sync() {
247   Trace("SUPERVGUI_Main::sync")
248   if ((SUPERV_isNull(dataflow))) 
249     return;
250   QString t = tr("GRAPH_TITLE");
251   
252   t += dataflow->Name();
253   setCaption(t);
254
255   study->updateObjBrowser();
256   if (myCurrentView == CANVASTABLE) {
257     myArray->sync();
258     myArray->update();
259   } else {
260     myCanvas->sync();
261     myCanvas->update();
262   }
263 }
264
265 void SUPERVGUI_Main::showCanvasTable() {
266   if (myCurrentView == CANVASTABLE) 
267     return;
268
269   if (myArray->create()) {
270     myCanvasView->hide();
271     myArrayView->show();
272     myCurrentView = CANVASTABLE;
273   }
274   sync();
275 }
276
277 void SUPERVGUI_Main::showContolFlow() {
278   bool merge = false;
279   if (myCurrentView == CANVASTABLE) {
280     myArrayView->hide();
281     myArray->destroy();
282     merge = true;
283   }
284   myCurrentView = CONTROLFLOW;
285   myCanvas->setControlView();
286   if (merge) {
287     myCanvas->merge();
288     myCanvasView->show();
289   }
290 }
291
292 void SUPERVGUI_Main::showCanvas() {
293   if (myCurrentView == CANVAS) 
294     return;
295
296   bool merge = false;
297   if (myCurrentView == CANVASTABLE) {
298     myArrayView->hide();
299     myArray->destroy();
300     merge = true;
301   }
302   myCurrentView = CANVAS;
303   myCanvas->setFullView();
304   if (merge) {
305     myCanvas->merge();
306     myCanvasView->show();
307   }
308 }
309
310 void SUPERVGUI_Main::insertFile() {
311     Trace("SUPERVGUI_Main::insertFile")
312     if ((SUPERV_isNull(dataflow))) return;
313
314     QString f = QAD_FileDlg::getFileName(QAD_Application::getDesktop(),
315                                          "",
316                                          "*.xml",
317                                          tr("MSG_GRAPH_INSERT"),
318                                          true);
319     if (!f.isEmpty()) {
320         if (dataflow->Import(f.latin1())) {
321           if (myCurrentView == CANVASTABLE) {
322             myArray->destroy();
323             myArray->create();
324           }
325           else { // (myCurrentView == CANVAS || myCurrentView == CONTROLFLOW) {
326             myCanvas->merge();
327           }
328           sync();
329         } else {
330             QMessageBox::warning(QAD_Application::getDesktop(), tr("ERROR"), tr("MSG_BAD_FILE").arg(f));
331         };
332     };
333 }
334
335 void SUPERVGUI_Main::copy() {
336   Trace("SUPERVGUI_Main::copy");
337   if (dataflow->ThreadsMax() == 0) {
338     QMessageBox::warning(QAD_Application::getDesktop(), tr("WARNING"), tr("MSG_NOTHING_COPY"));
339     return;
340   }
341   QAD_StudyFrame* aStudyFrame = Supervision.createGraph();
342   SUPERVGraph_ViewFrame* aViewFrame = dynamic_cast<SUPERVGraph_ViewFrame*>
343     (aStudyFrame->getRightFrame()->getViewFrame());
344   if(aViewFrame){
345     SUPERV_Graph aNewGraph; //  = dataflow->StreamCopy();
346     if (dataflow->IsStreamGraph()) {
347       SUPERV_StreamGraph aSGraph = dataflow->ToStreamGraph();
348       if (SUPERV_isNull(aSGraph)) {
349         QMessageBox::warning(QAD_Application::getDesktop(), tr("WARNING"), tr("MSG_CANT_COPY"));
350         return;
351       }
352       aNewGraph = aSGraph->StreamCopy();
353     }
354     else {
355       aNewGraph = dataflow->Copy();
356     }
357     QString aNewName(tr("MSG_COPY_PREFIX").arg(++myCopyNum));
358     aNewName += dataflow->Name();
359     aNewGraph->SetName(aNewName);
360     /*SUPERVGUI_Main* m = */new SUPERVGUI_Main(aViewFrame, 
361                                            Supervision.getDesktop(), 
362                                            aNewGraph);
363     study->showFrame(aStudyFrame);
364   }
365 }
366
367 void SUPERVGUI_Main::openSubGraph(SUPERV_CNode theNode, bool correct)
368 {
369   if (theNode->IsMacro()) {
370     // get SubGraph from MacroNode
371     SUPERV_Graph aMacro = SUPERV::Graph::_narrow(theNode);
372     SUPERV_Graph aGraph;
373     if (aMacro->IsStreamMacro())
374       aGraph = aMacro->StreamObjRef();
375     else
376       aGraph = aMacro->FlowObjRef();
377
378     // display SubGraph
379     if (SUPERV_isNull(aGraph)) {
380       QMessageBox::warning(QAD_Application::getDesktop(), tr("WARNING"), tr("MSG_NOACCESS"));
381       return;
382     }
383     else {
384       QString aGraphName = aGraph->Name();
385       QAD_StudyFrame* aStudyFrame;
386       if (mySubGraphs.contains(aGraphName)) {
387         aStudyFrame = mySubGraphs[aGraphName];
388         aStudyFrame->setActiveWindow();
389         aStudyFrame->setFocus();
390       }
391       else {
392         aStudyFrame = Supervision.createGraph();
393         if (aStudyFrame) {
394           SUPERVGraph_ViewFrame* aViewFrame = dynamic_cast<SUPERVGraph_ViewFrame*>
395             (aStudyFrame->getRightFrame()->getViewFrame());
396           if(aViewFrame) {
397             /*SUPERVGUI_Main* m = */new SUPERVGUI_Main(aViewFrame, 
398                                                    Supervision.getDesktop(), 
399                                                    aGraph);
400             //    connect(aStudyFrame, SIGNAL(sfStudyFrameClosing(QAD_StudyFrame*)), 
401             //            this,  SLOT(onSubGraphClosed(QAD_StudyFrame*)));
402             connect(aStudyFrame, SIGNAL(sfStudyFrameActivated(QAD_StudyFrame*)), 
403                     this,  SLOT(onSubGraphActivated(QAD_StudyFrame*)));
404             aStudyFrame->installEventFilter(this);
405
406             mySubGraphs.insert(aGraphName, aStudyFrame);
407             mySubGraphMap.insert(aGraphName, theNode->Name());
408
409           }
410         }
411       }
412       study->showFrame(aStudyFrame);
413       if (!correct) myLastGraph = aStudyFrame;
414     }
415   }
416 }
417
418 bool SUPERVGUI_Main::eventFilter( QObject* o, QEvent* e)
419 {
420   // workaround to get close event
421   if (o->inherits("QAD_StudyFrame") && e->type() == QEvent::Close) {
422     QAD_StudyFrame* aFrame = (QAD_StudyFrame*) o;
423     onSubGraphClosed(aFrame);
424   }
425   return SUPERVGraph_View::eventFilter(o, e);
426 }
427
428 // workaround to fix PAL6255 -> opened SubGraph is not on top
429 void SUPERVGUI_Main::onSubGraphActivated(QAD_StudyFrame* theStudyFrame)
430 {
431   if (myLastGraph) {
432     QAD_StudyFrame* aFrame = myLastGraph;
433     myLastGraph = 0;
434     aFrame->setActiveWindow();
435     aFrame->setFocus();
436   }
437 }
438
439 void SUPERVGUI_Main::onSubGraphClosed(QAD_StudyFrame* theStudyFrame)
440 {
441   QAD_ViewFrame* viewFrame = theStudyFrame->getRightFrame()->getViewFrame();
442   if(SUPERVGraph_ViewFrame* supervFrame = dynamic_cast<SUPERVGraph_ViewFrame*>(viewFrame)){
443     theStudyFrame->removeEventFilter(this);
444     disconnect(theStudyFrame, 0, this, 0);
445
446     SUPERVGraph_View* view = supervFrame->getViewWidget();
447     SUPERVGUI_Main* aGraph = dynamic_cast<SUPERVGUI_Main*>(view);
448     if (aGraph) {
449       QString aGraphName = aGraph->getDataflow()->Name();
450       QMap<QString, QString>::iterator it = mySubGraphMap.find(aGraphName);
451       if (it != mySubGraphMap.end()) {
452         QString aNodeName = it.data();
453         SUPERVGUI_CanvasNode* aNode = (SUPERVGUI_CanvasNode*) 
454           myCanvas->child(aNodeName, "SUPERVGUI_CanvasNode");
455         if (aNode) {
456           aNode->merge();
457           myCanvas->update();
458         }
459         mySubGraphMap.remove(it);
460       }
461       mySubGraphs.remove(aGraphName);
462     }
463   }
464 }
465
466 void SUPERVGUI_Main::run() {
467   Trace("SUPERVGUI_Main::run")
468     if ((SUPERV_isNull(dataflow))) return;
469   
470   if (dataflow->IsEditing()) {
471     if (!dataflow->IsValid()) {
472       QMessageBox::warning(QAD_Application::getDesktop(), tr("ERROR"), tr("MSG_DF_NOTVALID"));
473     } else if (!dataflow->IsExecutable()) {
474       QMessageBox::warning(QAD_Application::getDesktop(), tr("ERROR"), tr("MSG_DF_NOTEXECUTABLE"));
475     } else if (myCanvasView->isAnyLinkCreating()) {
476       QMessageBox::warning(QAD_Application::getDesktop(), tr("ERROR"), tr("MSG_CRL_NOTCOMPLETE"));
477     } else {
478       myRunTime = QDateTime::currentDateTime();
479       if (myIsKilled) {
480       //if (myIsRunned) {
481         if (!dataflow->ReRun()) {
482           QMessageBox::warning(QAD_Application::getDesktop(), tr("ERROR"), tr("MSG_DF_BADEXECUTE"));
483           if (dataflow->State() == SUPERV::ErrorState) {
484             kill();
485           }
486         } else {
487           myThread->startThread(tr("MSG_GRAPH_STARTED"));
488           //sync();
489         }
490       } else {
491         if (!dataflow->Run()) {
492           QMessageBox::warning(QAD_Application::getDesktop(), tr("ERROR"), tr("MSG_DF_BADEXECUTE"));
493           if (dataflow->State() == SUPERV::ErrorState) {
494             kill();
495           }
496         } else {
497           myThread->startThread(tr("MSG_GRAPH_STARTED"));
498           //sync();
499         }
500       }
501     }
502   } else {
503     QMessageBox::warning(QAD_Application::getDesktop(), tr("ERROR"), tr("MSG_DF_RUNNING"));
504   }
505 }
506
507
508
509 void SUPERVGUI_Main::startExecute() {
510   Trace("SUPERVGUI_Main::startExecute")
511   if ((SUPERV_isNull(dataflow))) return;
512   
513   if (dataflow->IsEditing()) {
514     if (!dataflow->IsValid()) {
515       QMessageBox::warning(QAD_Application::getDesktop(), tr("ERROR"), tr("MSG_DF_NOTVALID"));
516     } else if (!dataflow->IsExecutable()) {
517       QMessageBox::warning(QAD_Application::getDesktop(), tr("ERROR"), tr("MSG_DF_NOTEXECUTABLE"));
518     } else if (myCanvasView->isAnyLinkCreating()) {
519       QMessageBox::warning(QAD_Application::getDesktop(), tr("ERROR"), tr("MSG_CRL_NOTCOMPLETE"));
520     } else {
521       myRunTime = QDateTime::currentDateTime();
522       if (myIsKilled) {
523       //if (myIsRunned) {
524         if (!dataflow->ReStart()) {
525           QMessageBox::warning(QAD_Application::getDesktop(), tr("ERROR"), tr("MSG_DF_BADEXECUTE"));
526         } else {
527           myThread->startThread(tr("MSG_GRAPH_STARTED"));
528         }
529       }
530       else {
531         if (!dataflow->Start()) {
532           QMessageBox::warning(QAD_Application::getDesktop(), tr("ERROR"), tr("MSG_DF_BADEXECUTE"));
533         } else {
534           myThread->startThread(tr("MSG_GRAPH_STARTED"));
535         }
536       }
537     }
538   } else {
539     QMessageBox::warning(QAD_Application::getDesktop(), tr("ERROR"), tr("MSG_DF_RUNNING"));
540   }
541 }
542
543
544 void SUPERVGUI_Main::kill() {
545     Trace("SUPERVGUI_Main::kill")
546     if ((SUPERV_isNull(dataflow))) return;
547
548     if (dataflow->IsEditing()) {
549       QMessageBox::warning(QAD_Application::getDesktop(), tr("ERROR"), tr("MSG_DF_NOTRUNNING"));
550     } else if (dataflow->Kill()) {
551       myIsKilled = true;
552       myThread->stopThread(tr("MSG_GRAPH_KILLED"));
553       sync();
554     } else {
555       QMessageBox::warning(QAD_Application::getDesktop(), tr("ERROR"), tr("MSG_CANTKILL_DF"));
556     }
557 }
558
559 void SUPERVGUI_Main::suspendResume() {
560     Trace("SUPERVGUI_Main::suspendResume")
561     if ((SUPERV_isNull(dataflow))) return;
562
563     if (dataflow->IsEditing()) {
564         QMessageBox::warning(QAD_Application::getDesktop(), tr("ERROR"), tr("MSG_DF_NOTRUNNING"));
565     } else if (dataflow->State() == SUPERV_Suspend) {
566       if (dataflow->Resume()) {
567         myThread->startThread(tr("MSG_DF_RESUMED"));
568       } else {
569         QMessageBox::warning(QAD_Application::getDesktop(), tr("ERROR"), tr("MSG_CANT_RESUME"));
570       }
571     } else {
572       if (dataflow->Suspend()) {
573         sync();
574         myThread->stopThread(tr("MSG_GRAPH_SUSPENDED"));
575       } else {
576         QMessageBox::warning(QAD_Application::getDesktop(), tr("ERROR"), tr("MSG_CANT_SUSPEND"));
577       }
578     }
579 }
580
581 void SUPERVGUI_Main::stopRestart() { // kloss : a reviser et a connecter dans le popup du dataflow (pas de creation de bouton)
582     Trace("SUPERVGUI_Main::stopRestart")
583     if ((SUPERV_isNull(dataflow))) return;
584
585     if (dataflow->IsEditing()) {
586         QMessageBox::warning(0, tr("ERROR"),  tr("MSG_DF_NOTRUNNING"));
587     } else if (dataflow->State() == SUPERV_Stop) {
588         if (dataflow->ReStart()) {
589             message->setMessage(tr("MSG_DF_RESTARTED"));
590             sync();
591         } else {
592             QMessageBox::warning(QAD_Application::getDesktop(), tr("ERROR"), tr("MSG_CANT_RESTART"));
593         };
594     } else {
595         if (dataflow->Stop()) {
596             sync();
597         } else {
598             QMessageBox::warning(QAD_Application::getDesktop(), tr("ERROR"), tr("MSG_CANT_STOP"));
599         };
600     };
601 }
602
603 void SUPERVGUI_Main::addNode() {
604   Trace("SUPERVGUI_Main::addNode");
605   if (SUPERV_isNull(dataflow)) return;
606
607   if (dataflow->IsExecuting()) {
608     if (QMessageBox::warning(QAD_Application::getDesktop(), 
609                              tr("WARNING"), tr("MSG_GRAPH_ISRUN"),
610                              QMessageBox::Yes, QMessageBox::No) == QMessageBox::No) {
611       return;        
612     } else {
613       kill();
614     }
615   }
616   Supervision.getBrowser()->choose();
617 }
618
619 /**
620  * Add Computation node
621  */
622 void SUPERVGUI_Main::addComputeNode(SUPERV_CNode theNode) {
623   switch (myCurrentView) {
624   case CANVASTABLE:
625     myArray->destroy();
626     myArray->create();
627     break;  
628   case CANVAS:
629   case CONTROLFLOW: 
630     {
631       SUPERVGUI_CanvasNode* aNode = new SUPERVGUI_CanvasComputeNode(myCanvas, this, theNode);
632       aNode->move(theNode->X(), theNode->Y());
633       if (myCurrentView == CONTROLFLOW) aNode->hideAll();
634       aNode->show();
635       myCanvas->update();
636     }
637     break;
638   }
639 }
640
641 /**
642  * Add GOTO node
643  */
644 void SUPERVGUI_Main::addGOTONode(SUPERV_CNode theNode) {
645   switch (myCurrentView) {
646   case CANVASTABLE:
647     myArray->destroy();
648     myArray->create();
649     break;
650   case CANVAS:
651   case CONTROLFLOW: 
652     {
653       SUPERVGUI_CanvasNode* aNode = new SUPERVGUI_CanvasGotoNode(myCanvas, this, theNode);
654       aNode->move(theNode->X(), theNode->Y());
655       if (myCurrentView == CONTROLFLOW) aNode->hideAll();
656       aNode->show();
657       myCanvas->update();
658     }
659     break;
660   }
661 }
662
663 /**
664  * Add Control node
665  */
666 void SUPERVGUI_Main::addControlNode(SUPERV_CNode theStartNode, SUPERV_CNode theEndNode, bool Update) {
667   switch (myCurrentView) {
668   case CANVASTABLE:
669     myArray->destroy();
670     myArray->create();
671     break;
672   case CANVAS:
673   case CONTROLFLOW: 
674     {
675       SUPERVGUI_CanvasStartNode* aStartNode = new SUPERVGUI_CanvasStartNode(myCanvas, this, theStartNode);
676       aStartNode->move(theStartNode->X(), theStartNode->Y());
677       if (myCurrentView == CONTROLFLOW) aStartNode->hideAll();
678
679       SUPERVGUI_CanvasEndNode* aEndNode = new SUPERVGUI_CanvasEndNode(myCanvas, this, theEndNode, aStartNode);
680       aEndNode->move(theEndNode->X(), theEndNode->Y());
681       if (myCurrentView == CONTROLFLOW) aEndNode->hideAll();
682
683       aStartNode->show();
684       aEndNode->show();
685       myCanvas->update();
686     }
687     break;
688   }
689 }
690
691
692 /**
693  * Add Macro node
694  */
695 void SUPERVGUI_Main::addMacroNode(SUPERV_CNode theNode) {
696   switch (myCurrentView) {
697   case CANVASTABLE:
698     myArray->destroy();
699     myArray->create();
700     break;
701   case CANVAS:
702   case CONTROLFLOW: 
703     {
704       SUPERVGUI_CanvasNode* aNode = new SUPERVGUI_CanvasMacroNode(myCanvas, this, theNode);
705       aNode->move(theNode->X(), theNode->Y());
706       if (myCurrentView == CONTROLFLOW) aNode->hideAll();
707       aNode->show();
708       myCanvas->update();
709     }
710     break;
711   }
712 }
713
714 SUPERVGUI_CanvasArray*  SUPERVGUI_Main::getCanvasArray() {
715     Trace("SUPERVGUI_Main::getCanvasArray")
716     return(myArray);
717 }
718
719 SUPERVGUI_ArrayView* SUPERVGUI_Main::getArrayView() {
720     Trace("SUPERVGUI_Main::getArrayView")
721       return(myArrayView);
722 }
723
724 SUPERVGUI_Canvas* SUPERVGUI_Main::getCanvas() {
725     Trace("SUPERVGUI_Main::getCanvas")
726     return(myCanvas);
727 }
728
729 SUPERVGUI_CanvasView* SUPERVGUI_Main::getCanvasView() {
730     Trace("SUPERVGUI_Main::getCanvasView")
731       return(myCanvasView);
732 }
733
734 SUPERV_Graph SUPERVGUI_Main::getDataflow() {
735     Trace("SUPERVGUI_Main::getDataflow")
736     return(dataflow);
737 }
738
739 QAD_Message* SUPERVGUI_Main::getMessage() {
740     Trace("SUPERVGUI_Main::getMessage")
741     return(message);
742 }
743
744 QAD_Study* SUPERVGUI_Main::getStudy() {
745     Trace("SUPERVGUI_Main::getStudy")
746     return(study);
747 }
748
749 bool SUPERVGUI_Main::isArrayShown() {
750     Trace("SUPERVGUI_Main::isArrayShown")
751     return(myCurrentView == CANVASTABLE);  
752 }
753
754 void SUPERVGUI_Main::showPopup(QPopupMenu* p, QMouseEvent* e) {
755   Trace("SUPERVGUI_Main::showPopup");
756   // To check is Supervision active?
757   if (myIsLocked) return;
758   //if (dataflow->IsExecuting()) return;
759
760   //if (QAD_Application::getDesktop()->getActiveComponent().compare(STUDY_SUPERVISION) !=0) return;
761   if (QAD_Application::getDesktop()->getActiveComponent().compare(QAD_Application::getDesktop()->getComponentUserName( "SUPERV" ) ) !=0) return;
762
763   checkIsInStudy();
764   if (e->button() == RightButton) {
765     p->exec(e->globalPos());
766   }
767 }
768
769
770
771 void SUPERVGUI_Main::changeInformation() {
772   SUPERVGUI_Information* aDlg = new SUPERVGUI_Information(SUPERV::CNode::_narrow(dataflow), dataflow->IsReadOnly());
773   if (aDlg->exec() )
774     sync();
775   delete aDlg;
776 }
777
778 // returns false, if can't add dataflow into the study
779 bool SUPERVGUI_Main::addStudy() {
780   Trace("SUPERVGUI_Main::addStudy");
781   if (myIsFromStudy) return false;
782   if ((SUPERV_isNull(dataflow))) return false;
783
784   SALOMEDS::Study_var            aStudy = study->getStudyDocument();
785   bool                           aLocked = aStudy->GetProperties()->IsLocked();
786   // asv : 23.11.04 : if the study is locked -- then we can't put anything in it.
787   //       fix for PAL6852.
788   if ( aLocked ) 
789     return false;
790   
791   SALOMEDS::StudyBuilder_var     aBuilder  = aStudy->NewBuilder();
792   SALOMEDS::GenericAttribute_var anAttr;
793   SALOMEDS::AttributeName_var    aName;
794   SALOMEDS::AttributeIOR_var     anIORAttr;
795   SALOMEDS::AttributePixMap_var  aPixmap;
796   QAD_Operation*                 op = new SALOMEGUI_ImportOperation( study );
797   
798   // searching dataflow
799   SALOMEDS::SObject_var aSO = aStudy->FindObjectIOR(dataflow->getIOR());
800   if (aSO->_is_nil()) { // create new dataflow SObject
801     SALOMEDS::SComponent_ptr aComponent = aStudy->FindComponent(STUDY_SUPERVISION);
802     if (aComponent->_is_nil()) { // is supervision component not found, then create it
803       QAD_Operation* anOperation = new SALOMEGUI_ImportOperation( study );
804       anOperation->start();
805       //if (aLocked) aStudy->GetProperties()->SetLocked(false);
806       aComponent = aBuilder->NewComponent(STUDY_SUPERVISION);
807       anAttr = aBuilder->FindOrCreateAttribute(aComponent, "AttributeName");
808       aName = SALOMEDS::AttributeName::_narrow(anAttr);
809       //aName->SetValue(STUDY_SUPERVISION);
810       aName->SetValue(QAD_Application::getDesktop()->getComponentUserName( "SUPERV" ) );
811       anAttr = aBuilder->FindOrCreateAttribute(aComponent, "AttributePixMap");
812       aPixmap = SALOMEDS::AttributePixMap::_narrow(anAttr);
813       aPixmap->SetPixMap( "ICON_OBJBROWSER_Supervision" );
814       aBuilder->DefineComponentInstance(aComponent, Supervision.getEngine());
815       //if (aLocked) aStudy->GetProperties()->SetLocked(true);
816       anOperation->finish();
817     }
818     op->start();
819     aSO = aBuilder->NewObject(aComponent);
820     anAttr =  aBuilder->FindOrCreateAttribute(aSO, "AttributeName");
821     aName = SALOMEDS::AttributeName::_narrow(anAttr);
822     aName->SetValue(dataflow->Name());
823     anAttr =  aBuilder->FindOrCreateAttribute(aSO, "AttributeIOR");
824     anIORAttr = SALOMEDS::AttributeIOR::_narrow(anAttr);
825     anIORAttr->SetValue(dataflow->getIOR());
826     op->finish();
827     //if (aLocked) return false;
828   }
829
830   sync();
831   Supervision.unregisterGraph(this);
832   Supervision.registerGraph(dataflow->getIOR(), this);
833   myIsFromStudy = true;
834   return true;
835 }
836
837
838 void SUPERVGUI_Main::chooseData(QListViewItem* item) {
839     Trace("SUPERVGUI_Main::chooseData")
840     if (choosing) {
841         QString id = ((QAD_ObjectBrowserItem*)item)->getEntry();
842         if (!id.isEmpty()) {
843             SALOMEDS::SObject_var object = study->getStudyDocument()->FindObjectID(id.latin1());
844             SALOMEDS::GenericAttribute_var anAttr;
845             SALOMEDS::AttributeIOR_var     anIOR;
846             Standard_CString      ior    = "";
847             if (object->FindAttribute(anAttr, "AttributeIOR")) {
848               anIOR = SALOMEDS::AttributeIOR::_narrow(anAttr);
849               ior = anIOR->Value();
850               
851               // asv : 13.12.04 : commented out use of portIn field, but it seems that it 
852               // should be replaced with some analogious code... selection of IOR was done -
853               // put its value into port.
854               //portIn->setValue(ior);
855
856               // stop selection
857               choosing = false;
858               setCursor(Supervision.getCursor());
859               objectBrowser->setCursor(Supervision.getCursor());
860               Supervision.putInfo("");
861             }
862         }
863     }
864 }
865
866 SALOMEDS::SObject_var SearchOrCreateSOWithName(const SALOMEDS::Study_var theStudy,
867                                                const SALOMEDS::SObject_var theSO,
868                                                const char* theName,
869                                                //QAD_Operation* theOperation,
870                                                bool* theStarted) {
871   SALOMEDS::SObject_var aResult;
872   SALOMEDS::AttributeName_var aName;
873   SALOMEDS::GenericAttribute_var anAttr;
874   if (!*theStarted) { // optimisation
875     SALOMEDS::ChildIterator_var anIterator = theStudy->NewChildIterator(theSO);
876     for (; anIterator->More(); anIterator->Next()) {
877       if (anIterator->Value()->FindAttribute(anAttr, "AttributeName")) {
878         aName = SALOMEDS::AttributeName::_narrow(anAttr);
879         if (strcmp(aName->Value(), theName) == 0) {
880           aResult = anIterator->Value();
881           break;
882         }
883       }
884     }
885   }
886   if (!aResult->_is_nil()) return aResult;
887   // add new SObject
888   SALOMEDS::StudyBuilder_var aBuilder = theStudy->NewBuilder();
889   if (!*theStarted) {
890     *theStarted = true;
891     //theOperation->start();
892     aBuilder->NewCommand();
893   }
894   aResult = aBuilder->NewObject(theSO);
895   anAttr = aBuilder->FindOrCreateAttribute(aResult, "AttributeName");
896   aName = SALOMEDS::AttributeName::_narrow(anAttr);
897   aName->SetValue(theName);
898   return aResult;
899 }
900
901 bool SUPERVGUI_Main::putDataStudy(SUPERV_Port p, const char* inout) {
902   Trace("SUPERVGUI_Main::putDataStudy");
903
904   // static variable to ensure that only one instance (thread) is executing this function 
905   static bool isIn = false;
906   if (isIn) 
907     return true; 
908   else 
909     isIn = true;
910
911   SALOMEDS::Study_var            aStudy = study->getStudyDocument();
912   bool                           aLocked = aStudy->GetProperties()->IsLocked();
913   // asv : 23.11.04 : if the study is locked -- then we can't put anything in it.
914   //       fix for PAL6852.
915   if ( aLocked ) {
916     isIn = false;
917     return false;
918   }
919
920   SALOMEDS::StudyBuilder_var     aBuilder  = aStudy->NewBuilder();
921   SALOMEDS::GenericAttribute_var anAttr;
922   SALOMEDS::AttributeName_var    aName;
923   SALOMEDS::AttributeIOR_var     anIORAttr;
924   SALOMEDS::AttributePixMap_var  aPixmap;
925   bool                           aTransaction = false;
926   
927   // searching dataflow
928   SALOMEDS::SObject_var aSO = aStudy->FindObjectIOR(dataflow->getIOR());
929   if (aSO->_is_nil()) { // create new dataflow SObject
930     SALOMEDS::SComponent_ptr aComponent = aStudy->FindComponent(STUDY_SUPERVISION);
931     if (aComponent->_is_nil()) { // is supervision component not found, then create it
932       aBuilder->NewCommand();
933       //if (aLocked) aStudy->GetProperties()->SetLocked(false);
934       aComponent = aBuilder->NewComponent(STUDY_SUPERVISION);
935       anAttr = aBuilder->FindOrCreateAttribute(aComponent, "AttributeName");
936       aName = SALOMEDS::AttributeName::_narrow(anAttr);
937       //aName->SetValue(STUDY_SUPERVISION);
938       aName->SetValue(QAD_Application::getDesktop()->getComponentUserName( "SUPERV" ) );
939         
940       anAttr = aBuilder->FindOrCreateAttribute(aComponent, "AttributePixMap");
941       aPixmap = SALOMEDS::AttributePixMap::_narrow(anAttr);
942       aPixmap->SetPixMap( "ICON_OBJBROWSER_Supervision" );
943       aBuilder->DefineComponentInstance(aComponent, Supervision.getEngine());
944       //if (aLocked) aStudy->GetProperties()->SetLocked(true);
945       aBuilder->CommitCommand();
946     }
947     aTransaction = true;
948     aBuilder->NewCommand();
949     aSO = aBuilder->NewObject(aComponent);
950     anAttr =  aBuilder->FindOrCreateAttribute(aSO, "AttributeName");
951     aName = SALOMEDS::AttributeName::_narrow(anAttr);
952     aName->SetValue(dataflow->Name());
953     anAttr =  aBuilder->FindOrCreateAttribute(aSO, "AttributeIOR");
954     anIORAttr = SALOMEDS::AttributeIOR::_narrow(anAttr);
955     anIORAttr->SetValue(dataflow->getIOR());
956   }
957
958   aSO = SearchOrCreateSOWithName(aStudy, aSO,  // get run time SO
959                                  QString("Run ") + myRunTime.toString(), &aTransaction);
960   aSO = SearchOrCreateSOWithName(aStudy, aSO, p->Node()->Name(), &aTransaction); // get node SO
961   aSO = SearchOrCreateSOWithName(aStudy, aSO, inout, &aTransaction); // get in/out SO
962   aSO = SearchOrCreateSOWithName(aStudy, aSO, p->Name(), &aTransaction); // get port SO
963
964   if (aTransaction) aBuilder->CommitCommand();
965
966   anAttr = aBuilder->FindOrCreateAttribute(aSO, "AttributeIOR");
967   anIORAttr  = SALOMEDS::AttributeIOR::_narrow(anAttr);
968   if (!aTransaction && strcmp(anIORAttr->Value(), p->ToString()) == 0) {
969     isIn = false;
970     return true;
971   }
972   // set object value to the study: if object is external, then put it with
973   //                                 help of the specific component - owner
974   if (p->IsIOR()) {
975     // get according component driver for result object
976     SALOME_LifeCycleCORBA aLCC(myNService);
977     SUPERV_FNode aFNode = SUPERV::FNode::_narrow(p->Node());
978     if (!aFNode->_is_nil()) {
979       Engines::Component_var aComponent = aLCC.FindOrLoad_Component(aFNode->GetContainer(),
980                                                                     aFNode->GetComponentName());
981       SALOMEDS::Driver_var aDriver = SALOMEDS::Driver::_narrow(aComponent);
982       if (!CORBA::is_nil(aDriver)) { // if driver was found, publish object
983         CORBA::Object_ptr anObject = new CORBA::Object();
984         CORBA::Any* anAny = p->ToAny();
985         (*anAny) >>= anObject;
986         
987         if (aDriver->CanPublishInStudy(anObject)) {
988           SALOMEDS::SObject_var aTmpSO;
989           if (!aTransaction) {
990             aTmpSO = aSO;
991             aTransaction = true;
992             aBuilder->NewCommand();
993           }
994             aTmpSO = aDriver->PublishInStudy(aStudy, aTmpSO, anObject, /*anObject->Name()*/"");
995           aBuilder->Addreference(aSO, aTmpSO);
996         } else { // can't publish object: abort transaction
997           if (aTransaction) aBuilder->AbortCommand();
998           isIn = false;
999           return false;
1000         }
1001       } else { // component has no drivel, but could store IORs (like Calculator)
1002         SALOMEDS::SObject_var anIORSO = aStudy->FindObjectIOR(p->ToString());
1003         if (!CORBA::is_nil(anIORSO)) aBuilder->Addreference(aSO, anIORSO);
1004       }
1005     }
1006   } else {
1007     if (!aTransaction) {
1008       aTransaction = true;
1009       aBuilder->NewCommand();
1010     }
1011     anIORAttr->SetValue(p->ToString()); // ior attribute already set for the prevoius condition
1012   }
1013   
1014   if (aTransaction) 
1015     aBuilder->CommitCommand();
1016   if (!myThread->running())
1017     study->updateObjBrowser();
1018   isIn = false;
1019   return true;
1020 }
1021
1022
1023 void SUPERVGUI_Main::ActivatePanning()
1024 {
1025   if (myCanvasView->isVisible()) {
1026     myCanvasView->ActivatePanning();
1027   } else if (myArrayView->isVisible()) {
1028     myArrayView->ActivatePanning();
1029   }
1030 }
1031
1032
1033 void SUPERVGUI_Main::ResetView()
1034 {
1035   if (myCanvasView->isVisible()) {
1036     myCanvasView->ResetView();
1037   } else if (myArrayView->isVisible()) {
1038     myArrayView->ResetView();
1039   }
1040 }
1041
1042
1043 void SUPERVGUI_Main::setAsFromStudy(bool theToStudy) {
1044   myIsFromStudy = theToStudy;
1045   myCanvas->setAsFromStudy(theToStudy);
1046 }
1047
1048 void SUPERVGUI_Main::checkIsInStudy() {
1049   if (!myIsFromStudy) return;
1050
1051   SALOMEDS::Study_var aStudyDoc = study->getStudyDocument();
1052   SALOMEDS::SComponent_var aFatherLbl = aStudyDoc->FindComponent(STUDY_SUPERVISION);
1053   SALOMEDS::ChildIterator_var aChildIterator = aStudyDoc->NewChildIterator(aFatherLbl);
1054   SALOMEDS::SObject_var aDataflowLbl;
1055   SALOMEDS::GenericAttribute_var anAttr;
1056
1057   for (; aChildIterator->More(); aChildIterator->Next()) {
1058     aDataflowLbl = aChildIterator->Value();
1059     if (!aDataflowLbl->FindAttribute(anAttr, "AttributeIOR"))
1060       continue;
1061
1062     SALOMEDS::AttributeIOR_var anIOR = SALOMEDS::AttributeIOR::_narrow(anAttr);
1063     if (strcmp(anIOR->Value(), dataflow->getIOR()) == 0) return;
1064   }
1065   // This Graph considered as in study but in study it is not exists
1066   Supervision.unregisterGraph(this);
1067   setAsFromStudy(false);
1068 }
1069
1070 void SUPERVGUI_Main::syncNotification() {
1071   char* graph;
1072   char* node;
1073   char* type;
1074   char* message;
1075   char* sender;
1076   long  counter;
1077   char* date;
1078   long  stamp;
1079   
1080   while (notification->Receive(&graph, &node, &type, &message, &sender, &counter, &date, &stamp)) {
1081     if (isFiltered(graph, node, type, message, sender, counter, date, stamp)) {
1082       QString mess("");
1083       mess += "NOTIF: "; mess += graph;
1084       mess += " / "    ; mess += node;
1085       mess += " / "    ; mess += type;
1086       mess += " / "    ; mess += message;
1087       getMessage()->setMessage(mess.latin1());
1088     };
1089   };
1090 }
1091   
1092 bool SUPERVGUI_Main::isFiltered(char* graph,  char* node,   char* type, char* message, 
1093                                 char* sender, long counter, char* date, long stamp) {
1094   Trace("SUPERVGUI_Main::isFiltered");
1095   bool b = false;
1096   if (strcmp(getDataflow()->Name(), graph) == 0) {
1097     SUPERVGUI_CanvasNode* n;
1098     QObjectList* nodes = queryList("SUPERVGUI_CanvasNode");
1099     QObjectListIt i(*nodes);
1100     while ((n=(SUPERVGUI_CanvasNode*)i.current()) != 0) {
1101       ++i;
1102       if (strcmp(n->name(), node) == 0) {
1103         if (strcmp(type, NOTIF_WARNING) == 0) {
1104           b = n->isWarning();
1105         } else if (strcmp(type, NOTIF_STEP) == 0) {
1106           b = n->isStep();
1107         } else if (strcmp(type, NOTIF_TRACE) == 0) {
1108           b = n->isTrace();
1109         } else if (strcmp(type, NOTIF_VERBOSE) == 0) {
1110           b = n->isVerbose();
1111         };
1112         break;
1113       };
1114     };
1115     delete nodes;
1116     if ( myLogged && myLogFile && ( ( !myFiltered ) || b ) ) {
1117       fprintf( myLogFile, "NOTIF %ld\t%s\t%s\t%ld\t%s\t%s\t%s\t%s\n", stamp, date, sender, counter, graph, node, type, message );
1118       fflush( myLogFile );
1119     };
1120   };
1121   return( b );
1122 }
1123
1124 void SUPERVGUI_Main::closeEvent(QCloseEvent* e) {
1125   e->accept();
1126 }
1127
1128
1129 void SUPERVGUI_Main::setPaletteBackgroundColor(const QColor& color) { 
1130
1131   myCanvas->setBackgroundColor(color);
1132   myCanvasView->setPaletteBackgroundColor(color.light());
1133   myArray->setBackgroundColor(color);
1134   myArrayView->setPaletteBackgroundColor(color.light());
1135   
1136   SUPERVGraph_View::setPaletteBackgroundColor(color); 
1137 }
1138
1139 QPtrList< char * > SUPERVGUI_Main::getEventNodes() {
1140   return myEventNodes;
1141 }
1142
1143 void SUPERVGUI_Main::setEventNodes(QPtrList< char * > theEventNodes) {
1144   myEventNodes = theEventNodes;
1145 }
1146
1147 QPtrList< SUPERV::GraphState > SUPERVGUI_Main::getStates() {
1148   return myStates;
1149 }
1150
1151 void SUPERVGUI_Main::setStates(QPtrList< SUPERV::GraphState > theStates) {
1152   myStates = theStates;
1153 }
1154
1155 int SUPERVGUI_Main::getNodesNumber() {
1156   //create a list of nodes of the graph
1157   SUPERV_Nodes nodes = getDataflow()->Nodes();
1158   int RetVal = nodes->CNodes.length() + nodes->FNodes.length() +
1159                nodes->INodes.length() + nodes->GNodes.length() +
1160                nodes->LNodes.length() + nodes->SNodes.length();
1161   return RetVal;
1162 }
1163
1164 SUPERVGUI_Thread* SUPERVGUI_Main::getMyThread() {
1165   return myThread;
1166 }
1167
1168 void SUPERVGUI_Main::startTimer() {
1169   myTimer->start(500);
1170 }
1171
1172 void SUPERVGUI_Main::executionFinished() {
1173   getStudy()->updateObjBrowser();
1174   myCanvas->update();
1175   myArray->update();
1176 }
1177
1178 void SUPERVGUI_Main::checkExecution() {
1179   if (myThread->finished()) {
1180     myTimer->stop();
1181     executionFinished();
1182   }
1183 }
1184
1185 void SUPERVGUI_Main::Editing() {
1186   if ( !SUPERV_isNull( dataflow ) )
1187     dataflow->Editing();
1188 }
1189
1190 /******************************* SUPERVGUI_Thread class ****************************************/
1191 SUPERVGUI_Thread::SUPERVGUI_Thread()
1192      :QThread()
1193 {
1194   myIsActive = false;
1195 }
1196
1197 SUPERVGUI_Thread::~SUPERVGUI_Thread()
1198 {
1199   //it is a virtual destructor and needs to be determine here
1200 }
1201
1202 void SUPERVGUI_Thread::startThread(const char* m)
1203 {
1204   if (!myIsActive) {
1205     myIsActive = true;
1206     //QThread::start();
1207     this->start();
1208     myMain->getMessage()->setMessage(m); 
1209     myMain->sync();
1210   }
1211 }
1212
1213 void SUPERVGUI_Thread::stopThread(const char* m)
1214 {
1215   myMain->getMessage()->setMessage(m);
1216 }
1217
1218 void SUPERVGUI_Thread::setMain(SUPERVGUI_Main* theMain)
1219 {
1220   myMain = theMain;
1221 }
1222
1223 void SUPERVGUI_Thread::KillThread(bool theValue)
1224 {
1225   myMutex.lock();
1226   myIsActive = !(theValue);
1227   myMutex.unlock();
1228 }
1229
1230 typedef TVoidMemFun2ArgEvent<SUPERVGUI_Main, char*, SUPERV::GraphState> TNodeSyncEvent;
1231
1232 void SUPERVGUI_Thread::run()
1233 {
1234   SUPERV_CNode aNode = NULL;
1235   SUPERV::GraphEvent aEvent = SUPERV::UndefinedEvent ;
1236   SUPERV::GraphState aState = SUPERV::UndefinedState ;
1237
1238   SUPERV_CNode aPrevNode = NULL;
1239   SUPERV::GraphEvent aPrevEvent = SUPERV::UndefinedEvent ;
1240   SUPERV::GraphState aPrevState = SUPERV::UndefinedState ;
1241
1242   char * aName;
1243   char * aPrevName;
1244
1245   QPtrList< char * > anEventNodes;
1246   QPtrList< SUPERV::GraphState > aStates;
1247
1248   myMain->startTimer();
1249
1250   myMain->myGUIEventLoopFinished = false;
1251
1252   while(myIsActive) {
1253     myMain->getDataflow()->Event(aNode, aEvent, aState);
1254     
1255     if (aEvent == SUPERV::UndefinedEvent && aState == SUPERV::UndefinedState
1256         ||
1257         aEvent == SUPERV::NoEvent && aState == SUPERV::NoState
1258         ||
1259         aEvent == SUPERV::KillEvent && aState == SUPERV::KillState) {
1260
1261       if (myMain->getEventNodes().count()) {
1262         myMain->removeEventNodes();
1263       }    
1264       if (myMain->getStates().count()) {
1265         myMain->removeStates();
1266       }    
1267       myIsActive = false;
1268     }
1269     else {    
1270       if ( aNode != NULL && !CORBA::is_nil( aNode ) ) {
1271         aName = aNode->Name();
1272       }
1273
1274       if ( aPrevNode == NULL || CORBA::is_nil( aPrevNode ) ) {  //first initialize aPrev... variables
1275         anEventNodes = myMain->getEventNodes();
1276         anEventNodes.append( &aName ) ;
1277         myMain->setEventNodes(anEventNodes);
1278         
1279         aStates = myMain->getStates();
1280         aStates.append( &aState ) ;
1281         myMain->setStates(aStates);
1282       }
1283       else {
1284         if ( aEvent == aPrevEvent && aState == aPrevState) {
1285           QString aNameStr = aName;
1286           QString aPrevNameStr = aPrevName;
1287           if ( aNameStr != aPrevNameStr ) {
1288             anEventNodes = myMain->getEventNodes();
1289             anEventNodes.append( &aName ) ;
1290             myMain->setEventNodes(anEventNodes);
1291             
1292             aStates = myMain->getStates();
1293             aStates.append( &aState ) ;
1294             myMain->setStates(aStates);
1295           }
1296         }
1297         else {
1298           anEventNodes = myMain->getEventNodes();
1299           anEventNodes.append( &aName ) ;
1300           myMain->setEventNodes(anEventNodes);
1301           
1302           aStates = myMain->getStates();
1303           aStates.append( &aState ) ;
1304           myMain->setStates(aStates);
1305         }
1306       }
1307     }      
1308     if (!myIsActive) {
1309       switch (myMain->getDataflow()->State()) {
1310       case SUPERV_Editing :     
1311         stopThread(myMain->getDataflow()->IsReadOnly()? tr("MSG_GRAPH_READONLY"): tr("MSG_GRAPH_EDITING"));
1312         break;
1313         
1314       case SUPERV_Suspend : 
1315         stopThread(tr("MSG_GRAPH_SUSPENDED"));
1316         break;
1317  
1318       case SUPERV_Done : 
1319         stopThread(tr("MSG_GRAPH_FINISHED"));
1320         break;
1321         
1322       case SUPERV_Error :
1323         stopThread(tr("MSG_GRAPH_ABORTED"));
1324         break;
1325         
1326       case SUPERV_Kill:
1327         stopThread(tr("MSG_GRAPH_KILLED"));
1328         break;
1329       }
1330
1331       break;
1332     }
1333     if ( myMain->getEventNodes().count() ) {    
1334       //if list not empty call execute() -> sync()
1335       char * aNodeName = *(myMain->getEventNodes().getFirst());
1336       SUPERV::GraphState aNodeState = *(myMain->getStates().getFirst());
1337
1338       // It is PROHIBITED to deal with widgets in a secondary thread, so event posting is used here
1339       ProcessVoidEvent( new TNodeSyncEvent( myMain, &SUPERVGUI_Main::execute, aNodeName, aNodeState ) );
1340
1341       myMain->removeFirstEN();
1342       myMain->removeFirstS();
1343     }
1344
1345     aPrevNode = aNode;
1346     aPrevEvent = aEvent;
1347     aPrevState = aState;
1348
1349     if ( aPrevNode == NULL || CORBA::is_nil( aPrevNode ) ) 
1350       aPrevName = "";
1351     else 
1352       aPrevName = aPrevNode->Name();
1353     
1354     //usleep(10);
1355     //msleep(5);
1356   }
1357   // VSR: 04/12/03 ---> update object browser ufter finishing
1358 //   qApp->lock();
1359 //   myMain->getStudy()->updateObjBrowser();
1360 //   qApp->unlock();
1361   // VSR: 04/12/03 <---    
1362
1363   myMain->myGUIEventLoopFinished = true;
1364
1365   QThread::exit();
1366 }
1367
1368 /******************************* SUPERVGUI_DSGraphParameters class ****************************************/
1369 /*!
1370   Constructor
1371 */
1372 SUPERVGUI_DSGraphParameters::SUPERVGUI_DSGraphParameters(SUPERV_Graph theGraph, bool isReadOnly)
1373      : QDialog( QAD_Application::getDesktop(), "", true, WStyle_Customize | WStyle_NormalBorder | WStyle_Title | WStyle_SysMenu ) 
1374 {
1375   Trace("SUPERVGUI_DSGraphParameters::SUPERVGUI_DSGraphParameters");
1376   setCaption( tr( "TLT_DSGRAPHPARAMS" ) );
1377   setSizeGripEnabled( true );
1378   myGraph = theGraph;
1379
1380   QGridLayout* TopLayout = new QGridLayout( this );
1381   TopLayout->setSpacing( 6 );
1382   TopLayout->setMargin( 11 );
1383     
1384   QGroupBox* TopGroup = new QGroupBox( this, "TopGroup" );
1385   TopGroup->setColumnLayout(0, Qt::Vertical );
1386   TopGroup->layout()->setSpacing( 0 );
1387   TopGroup->layout()->setMargin( 0 );
1388   QGridLayout* TopGroupLayout = new QGridLayout( TopGroup->layout() );
1389   TopGroupLayout->setAlignment( Qt::AlignTop );
1390   TopGroupLayout->setSpacing( 6 );
1391   TopGroupLayout->setMargin( 11 );
1392
1393   // DeltaTime
1394   QLabel* DeltaTimeL = new QLabel( tr( "DELTATIME_LBL" ), TopGroup );  
1395   TopGroupLayout->addWidget( DeltaTimeL, 0, 0 );
1396   
1397   myDeltaTime = new QAD_SpinBoxDbl( TopGroup, 0.0, 1.0, 0.1);
1398   myDeltaTime->setSizePolicy( QSizePolicy( QSizePolicy::Expanding, QSizePolicy::Fixed ) );
1399   TopGroupLayout->addWidget( myDeltaTime, 0, 1 );
1400
1401   // TimeOut
1402   QLabel* TimeOutL = new QLabel( tr( "TIMEOUT_LBL" ), TopGroup); 
1403   TopGroupLayout->addWidget( TimeOutL, 1, 0 );
1404
1405   myTimeOut = new QLineEdit( TopGroup );
1406   myTimeOut->setSizePolicy( QSizePolicy( QSizePolicy::Expanding, QSizePolicy::Fixed ) );
1407   myTimeOut->setValidator( new QIntValidator(this) );
1408   myTimeOut->setMinimumSize( 100, 0 );
1409   myTimeOut->setReadOnly( isReadOnly );
1410   TopGroupLayout->addWidget( myTimeOut, 1, 1 );
1411
1412   // DataStreamTrace
1413   QLabel* DataStreamTraceL = new QLabel( tr( "DATASTREAMTRACE_LBL" ), TopGroup); 
1414   TopGroupLayout->addWidget( DataStreamTraceL, 2, 0 );
1415
1416   myDataStreamTrace = new QComboBox( TopGroup );
1417   myDataStreamTrace->setSizePolicy( QSizePolicy( QSizePolicy::Expanding, QSizePolicy::Fixed ) );
1418   myDataStreamTrace->insertItem("WithoutTrace");
1419   myDataStreamTrace->insertItem("SummaryTrace");
1420   myDataStreamTrace->insertItem("DetailedTrace");
1421   TopGroupLayout->addWidget( myDataStreamTrace, 2, 1 );
1422
1423   QGroupBox* GroupButtons = new QGroupBox( this, "GroupButtons" );
1424   GroupButtons->setColumnLayout(0, Qt::Vertical );
1425   GroupButtons->layout()->setSpacing( 0 );
1426   GroupButtons->layout()->setMargin( 0 );
1427   QGridLayout* GroupButtonsLayout = new QGridLayout( GroupButtons->layout() );
1428   GroupButtonsLayout->setAlignment( Qt::AlignTop );
1429   GroupButtonsLayout->setSpacing( 6 );
1430   GroupButtonsLayout->setMargin( 11 );
1431   
1432   QPushButton* okB     = new QPushButton( tr( "BUT_OK" ),     GroupButtons );
1433   QPushButton* cancelB = new QPushButton( tr( "BUT_CANCEL" ), GroupButtons );
1434
1435   GroupButtonsLayout->addWidget( okB, 0, 0 );
1436   GroupButtonsLayout->addItem  ( new QSpacerItem( 5, 5, QSizePolicy::Expanding, QSizePolicy::Minimum ), 0, 1 );
1437   GroupButtonsLayout->addWidget( cancelB, 0, 2 );
1438
1439   TopLayout->addWidget( TopGroup,     0, 0 );
1440   TopLayout->addWidget( GroupButtons, 1, 0 );
1441
1442   connect( okB,     SIGNAL( clicked() ), this, SLOT( accept() ) );
1443   connect( cancelB, SIGNAL( clicked() ), this, SLOT( reject() ) );
1444
1445   setData();
1446 }
1447
1448 /*!
1449   Destructor
1450 */
1451 SUPERVGUI_DSGraphParameters::~SUPERVGUI_DSGraphParameters() {
1452   Trace("SUPERVGUI_DSGraphParameters::~SUPERVGUI_DSGraphParameters");
1453 }
1454
1455 /*!
1456   Sets data function
1457 */
1458 void SUPERVGUI_DSGraphParameters::setData() {
1459   double aDeltaTime;
1460   long aTimeOut;
1461   SUPERV::KindOfDataStreamTrace aDataStreamTrace;
1462
1463 //  myGraph->StreamParams(aTimeOut, aDataStreamTrace, aDeltaTime);
1464   if (myGraph->IsStreamGraph()) {
1465     SUPERV_StreamGraph aSGraph = myGraph->ToStreamGraph();
1466     if (!SUPERV_isNull(aSGraph)) 
1467       aSGraph->StreamParams(aTimeOut, aDataStreamTrace, aDeltaTime);
1468   }
1469
1470   myDeltaTime->setValue(aDeltaTime);
1471   myTimeOut->setText(QString("%1").arg(aTimeOut));
1472   myDataStreamTrace->setCurrentItem((int)aDataStreamTrace);
1473 }
1474
1475 /*!
1476   <OK> button slot
1477 */
1478 void SUPERVGUI_DSGraphParameters::accept() {
1479 //   myGraph->SetStreamParams( myTimeOut->text().toLong(),
1480 //                          (SUPERV::KindOfDataStreamTrace) myDataStreamTrace->currentItem(),
1481 //                          myDeltaTime->value());
1482   if (myGraph->IsStreamGraph()) {
1483     SUPERV_StreamGraph aSGraph = myGraph->ToStreamGraph();
1484     if (!SUPERV_isNull(aSGraph)) 
1485       aSGraph->SetStreamParams( myTimeOut->text().toLong(),
1486                                 (SUPERV::KindOfDataStreamTrace) myDataStreamTrace->currentItem(),
1487                                 myDeltaTime->value());
1488   }
1489   QDialog::accept();
1490 }