src/NamingService/NamingService_WaitForServerReadiness.cxx

   1 // Copyright (C) 2007-2014  CEA/DEN, EDF R&D, OPEN CASCADE
   2 //
   3 // Copyright (C) 2003-2007  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, or (at your option) any later version.
  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.salome-platform.org/ or email : webmaster.salome@opencascade.com
  21 //
  22
  23 //  File   : NamingService_WaitForServerReadiness.cxx
  24 //  Author : Paul RASCLE (EDF)
  25 //  Module : KERNEL
  26 //  $Header$
  27 //
  28 #include "NamingService_WaitForServerReadiness.hxx"
  29 #include "utilities.h"
  30 #include <iostream>
  31 #include <ctime>
  32
  33 // ============================================================================
  34 /*!
  35  * Wait until a server is registered in naming service.
  36  * \param serverName name of the server to find.
  37  * \param NS SALOME_NamingService object
  38  * Wait until the given server is ready i.e. is name is found in namingService.
  39  * Try 40 times, with 500 ms sleep between each try.
  40  * If Logger is used for traces, it must be ready before this call, because
  41  * SALOME_NamingService client uses SALOME traces. So, Logger readiness must be
  42  * checked in Launch script before execution of WaitForServerReadiness.
  43  */
  44 // ============================================================================
  45
  46
  47 void NamingService_WaitForServerReadiness(SALOME_NamingService* NS,
  48                                           std::string serverName)
  49 {
  50   long TIMESleep = 500000000; // 500 ms.
  51   int NumberOfTries = 40;     // total wait = 20 s.
  52   int found = 0;
  53
  54   timespec ts_req;
  55   ts_req.tv_nsec=TIMESleep;
  56   ts_req.tv_sec=0;
  57   timespec ts_rem;
  58   ts_rem.tv_nsec=0;
  59   ts_rem.tv_sec=0;
  60
  61   ASSERT(NS);
  62   for (int itry=0; itry < NumberOfTries; itry++)
  63     {
  64       try
  65         {
  66           if (serverName.length() == 0)
  67             {
  68               CORBA::String_var dummyadr = NS->getIORaddr(); // to wait for naming service
  69               found = 1;
  70               break; // naming service found
  71             }
  72           else
  73             {
  74               CORBA::Object_var obj = NS->Resolve(serverName.c_str());
  75               if (! CORBA::is_nil(obj))
  76                 {
  77                   found =1;
  78                   break; // server found, no more try to do
  79                 }
  80               MESSAGE("Server "<< serverName <<" not yet ready, waiting...");
  81 #ifndef WIN32
  82               nanosleep(&ts_req,&ts_rem); // wait before retry
  83 #else
  84               Sleep(TIMESleep/1000000);
  85 #endif
  86             }
  87         }
  88       catch( ServiceUnreachable& )
  89         {
  90           MESSAGE("CORBA::COMM_FAILURE: Naming Service not yet ready, waiting...");
  91 #ifndef WIN32
  92           nanosleep(&ts_req,&ts_rem); // wait before retry
  93 #else
  94           Sleep(TIMESleep/1000000);
  95 #endif
  96         }
  97     }
  98   if (!found)
  99     {
 100     INFOS("Server "<< serverName <<" not found, abort...");
 101     exit(EXIT_FAILURE);
 102     }
 103 }