src/Loader/InquireServersQThread.cxx

   1 //  Copyright (C) 2003  CEA/DEN, EDF R&D
   2 //
   3 //
   4 //
   5 //  File   : InquireServersQThread.cxx
   6 //  Author : Vasily RUSYAEV
   7 //  Module : SALOME
   8 //  $Header$
   9
  10 using namespace std;
  11 #include "InquireServersQThread.h"
  12
  13 #include <qlabel.h>
  14 #include <qpushbutton.h>
  15 #include <qabstractlayout.h>
  16 #include <qlayout.h>
  17 #include <qevent.h>
  18 #include <qfont.h>
  19 #include <qmessagebox.h>
  20 #include <qdir.h>
  21 #include <qfileinfo.h>
  22 #include <qstringlist.h>
  23
  24 //VRV: porting on Qt 3.0.5
  25 #if QT_VERSION >= 0x030005
  26 #include <qdesktopwidget.h>
  27 #endif
  28 //VRV: porting on Qt 3.0.5
  29
  30 #include <qsize.h>
  31
  32 #include <SALOMEconfig.h>
  33
  34 #include "Utils_ORB_INIT.hxx"
  35 #include "Utils_SINGLETON.hxx"
  36 #include "SALOME_NamingService.hxx"
  37 #include "utilities.h"
  38 #include "OpUtil.hxx"
  39
  40 #include CORBA_CLIENT_HEADER(SALOME_Session)
  41 #include CORBA_CLIENT_HEADER(SALOME_Registry)
  42 #include CORBA_CLIENT_HEADER(SALOMEDS)
  43 #include CORBA_CLIENT_HEADER(SALOME_ModuleCatalog)
  44 #include CORBA_CLIENT_HEADER(SALOME_Component)
  45
  46 #define MARGIN_SIZE  5
  47 #define SPACING_SIZE 3
  48
  49 static QString findFile( QString filename );
  50 static QString addSlash( const QString& path );
  51
  52 InquireServersGUI::InquireServersGUI()
  53      : QVBox(0, "SFA splash", Qt::WDestructiveClose | Qt::WStyle_Customize | Qt::WStyle_NoBorder )
  54 {
  55   myGUI = false;
  56   myThread = new InquireServersQThread(this);
  57
  58   // 1. Polish the appearance
  59   setMargin( MARGIN_SIZE );
  60   setSpacing( SPACING_SIZE );
  61   setFrameStyle( QFrame::Plain | QFrame::Box );
  62   setLineWidth( 2 );
  63   setMinimumSize( 200, 150 );
  64
  65   // 2. Splash image
  66   QFrame* frm = new QFrame( this );
  67   frm->setFrameStyle( QFrame::Box | QFrame::Raised );
  68   QHBoxLayout* frmLayout = new QHBoxLayout( frm );
  69   frmLayout->setMargin( MARGIN_SIZE );
  70   QLabel* splash = 0;
  71   splash = new QLabel( frm, "splash" );
  72   frmLayout->addWidget( splash );
  73   // setting pixmap
  74   QString path = findFile( "Application-Splash.png" );
  75   splash->setPixmap( QPixmap( path )  );
  76
  77   // 3. Progress bar
  78   myPrgBar = new QProgressBar( this, "QProgressBar" );
  79   myPrgBar->setFixedWidth( splash->pixmap()->isNull() ? 180 : splash->sizeHint().width() );
  80   //Sets the total number of steps .
  81   myPrgBar->setTotalSteps ( myThread->getInquiredServers() );
  82   myPrgBar->setProgress( 0 );
  83
  84   // 4. Info label
  85   QWidget* aWgt1 = new QWidget( this );
  86   QHBoxLayout* aHBoxLayout1 = new QHBoxLayout( aWgt1 );
  87   myLabel = new QLabel( tr( "Loading:" ), aWgt1 );
  88   myLabel->setFixedWidth( splash->pixmap()->isNull() ? 180 : splash->sizeHint().width() );
  89   myLabel->setAlignment( AlignLeft );
  90   QFont theFont = myLabel->font();
  91   theFont.setBold(true);
  92   myLabel->setFont( theFont );
  93   aHBoxLayout1->addItem( new QSpacerItem( 0, 0, QSizePolicy::Expanding, QSizePolicy::Minimum ) );
  94   aHBoxLayout1->addWidget( myLabel );
  95   aHBoxLayout1->addItem( new QSpacerItem( 0, 0, QSizePolicy::Expanding, QSizePolicy::Minimum ) );
  96
  97   // 5. <Cancel> button
  98   QWidget* aWgt = new QWidget( this );
  99   QHBoxLayout* aHBoxLayout = new QHBoxLayout( aWgt );
 100   QPushButton* myCancelBtn = new QPushButton( tr( "Cancel" ), aWgt );
 101   connect( myCancelBtn, SIGNAL( clicked() ), this, SLOT( ClickOnCancel() ) ) ;
 102   aHBoxLayout->addItem( new QSpacerItem( 0, 0, QSizePolicy::Expanding, QSizePolicy::Minimum )  );
 103   aHBoxLayout->addWidget( myCancelBtn );
 104   aHBoxLayout->addItem( new QSpacerItem( 0, 0, QSizePolicy::Expanding, QSizePolicy::Minimum )  );
 105
 106   //Center widget
 107 #if QT_VERSION >= 0x030005
 108   QDesktopWidget *d = QApplication::desktop();
 109 #else
 110   QWidget *d = QApplication::desktop();
 111 #endif
 112 //VRV: porting on Qt 3.0.5
 113
 114   int w = d->width();         // returns desktop width
 115   int h = d->height();        // returns desktop height
 116   QSize mySize = sizeHint (); // returns widget size
 117   int Xc = ( w - mySize.width() )  / 2;
 118   int Yc = ( h - mySize.height() ) / 2;
 119   move( Xc, Yc );
 120
 121   myThread->start();
 122 }
 123
 124 InquireServersGUI::~InquireServersGUI()
 125 {
 126   delete myThread;
 127 }
 128
 129 void InquireServersGUI::getArgs( int& _argc, char *** _argv)
 130 {
 131   _argc = qApp->argc();
 132   *_argv = qApp->argv();
 133 }
 134
 135 //=================================================================================
 136 // function : ClickOnCancel()
 137 // purpose  : cancel loading of SALOME
 138 //=================================================================================
 139 void InquireServersGUI::ClickOnCancel()
 140 {
 141   //it's necessary to stop asking servers
 142   myThread->stop();
 143   myGUI = false;
 144   //Also we should send QCloseEvent in order to close this widget (and remove from screen)
 145   //QThread::postEvent ( this, new QCloseEvent() );
 146   qApp->exit(1);
 147 }
 148
 149 void InquireServersGUI::closeEvent ( QCloseEvent * pe)
 150 {
 151   //default implementation calls e->accept(), which hides this widget.
 152   //See the QCloseEvent documentation for more details.
 153   pe->accept();
 154   QApplication::flushX ();
 155   QApplication::syncX ();
 156   qApp->exit();
 157 }
 158
 159 void InquireServersGUI::customEvent( QCustomEvent* pe )
 160 {
 161   switch( pe->type() )
 162     {
 163         case InquireEvent::ProgressEvent:
 164         {
 165             int* value = ( int* )(( InquireEvent*)pe)->data();
 166             myPrgBar->setProgress( *value );
 167             break;
 168         }
 169         case InquireEvent::ProgressEventLabel:
 170         {
 171             QString* myString = ( QString* )(( InquireEvent*)pe)->data();
 172             myLabel->setText( *myString );
 173             break;
 174         }
 175         case InquireEvent::ProgressEventError:
 176         {
 177             QString* myErrDesc = ( QString* )(( InquireEvent*)pe)->data();
 178             QString  appName = "SALOME Professional";
 179             QString  error = "An internal error occurred.\n"+ *myErrDesc + "\n";
 180             QMessageBox myMsgBox(appName,error,QMessageBox::Critical,QMessageBox::Ok,QMessageBox::NoButton,
 181                                         QMessageBox::NoButton,0,"MY",TRUE,WStyle_DialogBorder|WStyle_StaysOnTop);
 182             myMsgBox.exec();
 183             ClickOnCancel();
 184             break;
 185         }
 186       default:
 187         {
 188           ;
 189         }
 190     }
 191 }
 192
 193 int InquireServersGUI::getExitStatus()
 194 {
 195   myThread->getExitStatus();
 196 }
 197
 198 InquireServersQThread::InquireServersQThread( InquireServersGUI* r )
 199      : receiver(r),  myExitStatus(0)
 200 {
 201   char* cenv;
 202
 203   IsChecking = true;
 204   myServersCount = 5;
 205   //how many times we should repeat attempts to get response from all needed for launching SALOME servers
 206   myRepeat = 30; // default value, user can change it by setting CSF_RepeatServerRequest env.variable
 207   cenv = getenv( "CSF_RepeatServerRequest" );
 208   if ( cenv ) {
 209     int val = atoi( cenv );
 210     if ( val > 0 )
 211       myRepeat = val;
 212   }
 213   //define delay time between two attempts
 214   myDelay = 1000000; // 1 second
 215   QString str = "Loading: ";
 216   myMessages[0] = "Checking naming service...";
 217   myMessages[1] = str + "SALOME_Registry_Server" + "...";
 218   myMessages[2] = str + "SALOMEDS_Server" + "...";
 219   myMessages[3] = str + "SALOME_ModuleCatalog_Server" + "...";
 220   myMessages[4] = str + "SALOME_Session_Server" + "...";
 221   myMessages[5] = "";
 222   myMessages[6] = "";
 223   myMessages[7] = "";
 224
 225   r->getArgs( _argc, &_argv);
 226
 227   // NRI : Temporary solution for SuperVisionContainer
 228   for ( int i=1; i<=(_argc-1); i++) {
 229     if (strcmp(_argv[i],"CPP")==0) {
 230       myMessages[5] = str + "SALOME_Container FactoryServer" + "...";
 231       myServersCount++;
 232     }
 233     if (strcmp(_argv[i],"PYTHON")==0) {
 234       myMessages[6] = str + "SALOME_ContainerPy.py FactoryServerPy" + "...";
 235       myServersCount++;
 236     }
 237     if (strcmp(_argv[i],"SUPERV")==0) {
 238       myMessages[7] = str + "SALOME_Container SuperVisionContainer" + "...";
 239       myServersCount++;
 240     }
 241     if (strcmp(_argv[i],"GUI")==0) {
 242       r->withGUI(true);
 243     }
 244   }
 245 }
 246
 247 void InquireServersQThread::run()
 248 {
 249 while (IsChecking)
 250   {
 251     for (int i=1; i<=8; i++)
 252       {
 253         if ( myMessages[i-1].isEmpty() ) {
 254           if (i==8) {
 255             IsChecking = false;
 256             //myExitStatus should be 0 because all servers exist and work
 257             myExitStatus = 0;
 258             //we should send QCloseEvent in order to close this widget (and remove from screen)
 259             QThread::postEvent ( receiver , new QCloseEvent() );
 260           } else
 261             continue;
 262         }
 263         QString *message = new QString(myMessages[i-1]);
 264         QThread::postEvent( receiver, new InquireEvent( ( QEvent::Type )InquireEvent::ProgressEventLabel, message ) );
 265         QThread::usleep(200000);
 266         QString *errMsg;
 267         bool result = AskServer(i,&errMsg);
 268         if (result)
 269           {
 270             QThread::postEvent( receiver, new InquireEvent( ( QEvent::Type )InquireEvent::ProgressEvent, new int( i ) ) );
 271             if (i==8)
 272               {
 273                 IsChecking = false;
 274                 //myExitStatus should be 0 because all servers exist and work
 275                 myExitStatus = 0;
 276                 //we should send QCloseEvent in order to close this widget (and remove from screen)
 277                 QThread::postEvent ( receiver , new QCloseEvent() );
 278               }
 279           }
 280         else
 281           {
 282             QThread::postEvent( receiver, new InquireEvent( ( QEvent::Type )InquireEvent::ProgressEventError, errMsg ) );
 283             //myExitStatus should be 1 because we didn't receive response from server
 284             myExitStatus = 1;
 285             return;
 286           }
 287       }
 288   }
 289 }
 290
 291 bool InquireServersQThread::AskServer(int iteration, QString ** errMessage)
 292 {
 293   ASSERT(iteration<=myServersCount);
 294   //will be set true if we get response from server
 295   bool IsPassed = false;
 296   QString errDescription;
 297   switch (iteration)
 298     {
 299     case 1:
 300       //First checking - existence of Naming Service
 301       for (int i = myRepeat; i ; i--)
 302         {
 303           try
 304             {
 305               CORBA::ORB_var orb = CORBA::ORB_init(_argc,_argv) ;
 306               CORBA::Object_var obj = orb->resolve_initial_references("NameService");
 307               CosNaming::NamingContext_var _root_context = CosNaming::NamingContext::_narrow(obj);
 308               if (CORBA::is_nil(_root_context))
 309                 continue;
 310               else
 311                 IsPassed = true;
 312               break;
 313             }
 314           catch(CORBA::COMM_FAILURE&)
 315             {
 316               MESSAGE("CORBA::COMM_FAILURE: unable to contact the naming service");
 317             }
 318           catch(...)
 319             {
 320               MESSAGE("Unknown Exception: unable to contact the naming service");
 321             }
 322           QThread::usleep(myDelay);
 323         }
 324       if (!IsPassed)
 325         *errMessage = new QString("unable to contact the naming service");
 326       break;
 327     case 2:
 328       //checking - existence of SALOME_Registry_Server
 329     case 3:
 330       //checking - existence of SALOMEDS_Server
 331     case 4:
 332       //checking - existence of SALOME_ModuleCatalog_Server
 333     case 5:
 334       //checking - existence of SALOME_Session_Server
 335     case 6:
 336       //checking - existence of SALOME_Container FactoryServer
 337     case 7:
 338       //checking - existence of SALOME_ContainerPy.py FactoryServerPy
 339     case 8:
 340       //checking - existence of SALOME_Container SuperVisionContainer
 341
 342
 343       IsPassed = pingServer(iteration, errDescription);
 344       if (!IsPassed)
 345         *errMessage = new QString(errDescription);
 346       break;
 347     }
 348 return IsPassed;
 349 }
 350
 351 bool InquireServersQThread::pingServer(int iteration, QString& errMessage)
 352 {
 353   ASSERT(iteration<=myServersCount);
 354   bool result = false;
 355   QString errorDescr;
 356   for (int i = myRepeat; i ; i--)
 357     {
 358       try
 359         {
 360           CORBA::ORB_var orb = CORBA::ORB_init(_argc,_argv) ;
 361           SALOME_NamingService &NS = *SINGLETON_<SALOME_NamingService>::Instance() ;
 362           ASSERT(SINGLETON_<SALOME_NamingService>::IsAlreadyExisting()) ;
 363           NS.init_orb( orb ) ;
 364           switch (iteration)
 365             {
 366             case 2:
 367               {
 368                 CORBA::Object_var obj = NS.Resolve("/Registry");
 369                 Registry::Components_var registry = Registry::Components::_narrow(obj) ;
 370                 if (!CORBA::is_nil(registry))
 371                   {
 372                     MESSAGE("/Registry is found");
 373                     registry->ping();
 374                     result = true;
 375                     MESSAGE("Registry was activated");
 376                     return result;
 377                   }
 378               }
 379               break;
 380             case 3:
 381               {
 382                 CORBA::Object_var obj = NS.Resolve("/myStudyManager");
 383                 SALOMEDS::StudyManager_var studyManager = SALOMEDS::StudyManager::_narrow(obj) ;
 384                 if (!CORBA::is_nil(studyManager))
 385
 386
 387
 388
 389
 390                   {
 391                     MESSAGE("/myStudyManager is found");
 392                     studyManager->ping();
 393                     result = true;
 394                     MESSAGE("StudyManager was activated");
 395                     return result;
 396                   }
 397               }
 398               break;
 399             case 4:
 400               {
 401                 CORBA::Object_var obj = NS.Resolve("Kernel/ModulCatalog");
 402                 SALOME_ModuleCatalog::ModuleCatalog_var catalog = SALOME_ModuleCatalog::ModuleCatalog::_narrow(obj) ;
 403                 if (!CORBA::is_nil(catalog))
 404                   {
 405                     MESSAGE("/Kernel/ModulCatalog is found");
 406                     catalog->ping();
 407                     result = true;
 408                     MESSAGE("ModuleCatalog was activated");
 409                     return result;
 410                   }
 411               }
 412               break;
 413             case 5:
 414               {
 415                 CORBA::Object_var obj = NS.Resolve("Kernel/Session");
 416                 SALOME::Session_var session = SALOME::Session::_narrow(obj) ;
 417                 if (!CORBA::is_nil(session))
 418                   {
 419                     MESSAGE("/Kernel/Session is found");
 420                     session->ping();
 421                     result = true;
 422                     MESSAGE("SALOME_Session was activated");
 423                     return result;
 424                   }
 425               }
 426               break;
 427             case 6:
 428               {
 429                 string hostname = GetHostname();
 430                 string containerName = "/Containers/";
 431                 containerName += hostname;
 432                 containerName += "/FactoryServer";
 433
 434                 CORBA::Object_var obj = NS.Resolve(containerName.c_str());
 435                 Engines::Container_var FScontainer = Engines::Container::_narrow(obj) ;
 436                 if (!CORBA::is_nil(FScontainer))
 437                   {
 438                     FScontainer->ping();
 439                     result = true;
 440                     MESSAGE("FactoryServer container was activated");
 441                     return result;
 442                   }
 443               }
 444               break;
 445             case 7:
 446               {
 447                 string hostname = GetHostname();
 448                 string containerName = "/Containers/";
 449                 containerName += hostname;
 450                 containerName += "/FactoryServerPy";
 451
 452                 CORBA::Object_var obj = NS.Resolve(containerName.c_str());
 453                 Engines::Container_var FSPcontainer = Engines::Container::_narrow(obj) ;
 454                 if (!CORBA::is_nil(FSPcontainer))
 455                   {
 456                     FSPcontainer->ping();
 457                     result = true;
 458                     MESSAGE("FactoryServerPy container was activated");
 459                     return result;
 460                   }
 461               }
 462               break;
 463             case 8:
 464               {
 465                 string hostname = GetHostname();
 466                 string containerName = "/Containers/";
 467                 containerName += hostname;
 468                 containerName += "/SuperVisionContainer";
 469
 470                 CORBA::Object_var obj = NS.Resolve(containerName.c_str());
 471                 Engines::Container_var SVcontainer = Engines::Container::_narrow(obj) ;
 472                 if (!CORBA::is_nil(SVcontainer))
 473                   {
 474                     SVcontainer->ping();
 475
 476                     result = true;
 477                     MESSAGE("SuperVisionContainer container was activated");
 478                     return result;
 479                   }
 480               }
 481               break;
 482             }
 483          }
 484       catch (ServiceUnreachable&)
 485         {
 486           MESSAGE("Caught exception: Naming Service Unreachable");
 487           errorDescr = "Caught exception: Naming Service Unreachable";
 488         }
 489       catch (CORBA::COMM_FAILURE&)
 490         {
 491           MESSAGE("Caught CORBA::SystemException CommFailure.");
 492           errorDescr = "Caught CORBA::SystemException CommFailure";
 493         }
 494       catch (CORBA::SystemException&)
 495         {
 496           MESSAGE("Caught CORBA::SystemException.");
 497           errorDescr = "Caught CORBA::SystemException";
 498         }
 499       catch (CORBA::Exception&)
 500         {
 501           MESSAGE("Caught CORBA::Exception.");
 502           errorDescr = "Caught CORBA::Exception";
 503         }
 504       catch (...)
 505         {
 506           MESSAGE("Caught unknown exception.");
 507           errorDescr = "Caught unknown exception";
 508         }
 509       QThread::usleep(myDelay);
 510     }
 511   if (!result)
 512     {
 513       QString serverName;
 514       switch (iteration)
 515         {
 516         case 2:
 517           serverName = "SALOME_Registry_Server is not loaded. ";
 518           break;
 519         case 3:
 520           serverName = "SALOMEDS_Server is not loaded. ";
 521           break;
 522         case 4:
 523           serverName = "SALOME_ModuleCatalog_Server is not loaded. ";
 524           break;
 525         case 5:
 526           serverName = "SALOME_Session_Server is not loaded. ";
 527           break;
 528         case 6:
 529           serverName = "SALOME_Container FactoryServer is not loaded. ";
 530           break;
 531         case 7:
 532           serverName = "SALOME_ContainerPy.py FactoryServerPy is not loaded. ";
 533           break;
 534         case 8:
 535           serverName = "SALOME_Container SuperVisionContainer is not loaded. ";
 536           break;
 537         }
 538       errMessage = serverName + errorDescr;
 539     }
 540   return result;
 541 }
 542
 543 static const char* SEPARATOR    = ":";
 544
 545 QString findFile( QString filename )
 546 {
 547   QString dir;
 548   char* cenv;
 549
 550   // Try ${KERNEL_ROOT_DIR}/share/salome/resources directory
 551   cenv = getenv( "KERNEL_ROOT_DIR" );
 552   if ( cenv ) {
 553     dir.sprintf( "%s", cenv );
 554     if ( !dir.isEmpty() ) {
 555       dir = addSlash(dir) ;
 556       dir = dir + "share" ;
 557       dir = addSlash(dir) ;
 558       dir = dir + "salome" ;
 559       dir = addSlash(dir) ;
 560       dir = dir + "resources" ;
 561       dir = addSlash(dir) ;
 562       QFileInfo fileInfo( dir + filename );
 563       if ( fileInfo.isFile() && fileInfo.exists() )
 564         return fileInfo.filePath();
 565     }
 566   }
 567   // Try CSF_ResourcesDefaults env.var directory ( or directory list )
 568   cenv = getenv( "CSF_ResourcesDefaults" );
 569   if ( cenv ) {
 570     dir.sprintf( "%s", cenv );
 571     if ( !dir.isEmpty() ) {
 572       QStringList dirList = QStringList::split( SEPARATOR, dir, false ); // skip empty entries
 573       for ( int i = 0; i < dirList.count(); i++ ) {
 574         QFileInfo fileInfo( addSlash( dirList[ i ] ) + filename );
 575         if ( fileInfo.isFile() && fileInfo.exists() )
 576           return fileInfo.filePath();
 577       }
 578     }
 579   }
 580   // Try ${HOME}/.salome/resources directory
 581   cenv = getenv( "HOME" );
 582   if ( cenv ) {
 583     dir.sprintf( "%s", cenv );
 584     if ( !dir.isEmpty() ) {
 585       dir = addSlash(dir) ;
 586       dir = dir + ".salome" ;
 587       dir = addSlash(dir) ;
 588       dir = dir + "resources" ;
 589       dir = addSlash(dir) ;
 590       QFileInfo fileInfo( dir + filename );
 591       if ( fileInfo.isFile() && fileInfo.exists() )
 592         return fileInfo.filePath();
 593     }
 594   }
 595   return filename;
 596 }
 597 QString addSlash( const QString& path )
 598 {
 599   if (!path.isNull()) {
 600 #ifdef WNT
 601     QChar slash ('\\');
 602 #else
 603     QChar slash ('/');
 604 #endif
 605     if ( path.at(path.length()-1) != slash )
 606       return path + slash;
 607   }
 608   return path;
 609 }