src/NamingService/NamingService_WaitForServerReadiness.cxx

   1 // Copyright (C) 2007-2023  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 "SALOME_NamingService.hxx"
  30
  31 #include "utilities.h"
  32 #include <iostream>
  33 #include <ctime>
  34
  35 // ============================================================================
  36 /*!
  37  * Wait until a server is registered in naming service.
  38  * \param serverName name of the server to find.
  39  * \param NS SALOME_NamingService object
  40  * Wait until the given server is ready i.e. is name is found in namingService.
  41  * Try 40 times, with 500 ms sleep between each try.
  42  * If Logger is used for traces, it must be ready before this call, because
  43  * SALOME_NamingService client uses SALOME traces. So, Logger readiness must be
  44  * checked in Launch script before execution of WaitForServerReadiness.
  45  */
  46 // ============================================================================
  47
  48
  49 void NamingService_WaitForServerReadiness(SALOME_NamingService* NS,
  50                                           std::string serverName)
  51 {
  52   long TIMESleep = 500000000; // 500 ms.
  53   int NumberOfTries = 40;     // total wait = 20 s.
  54   int found = 0;
  55
  56   timespec ts_req;
  57   ts_req.tv_nsec=TIMESleep;
  58   ts_req.tv_sec=0;
  59   timespec ts_rem;
  60   ts_rem.tv_nsec=0;
  61   ts_rem.tv_sec=0;
  62
  63   ASSERT(NS);
  64   for (int itry=0; itry < NumberOfTries; itry++)
  65     {
  66       try
  67         {
  68           if (serverName.length() == 0)
  69             {
  70               CORBA::String_var dummyadr = NS->getIORaddr(); // to wait for naming service
  71               found = 1;
  72               break; // naming service found
  73             }
  74           else
  75             {
  76               CORBA::Object_var obj = NS->Resolve(serverName.c_str());
  77               if (! CORBA::is_nil(obj))
  78                 {
  79                   found =1;
  80                   break; // server found, no more try to do
  81                 }
  82               MESSAGE("Server "<< serverName <<" not yet ready, waiting...");
  83 #ifndef WIN32
  84               nanosleep(&ts_req,&ts_rem); // wait before retry
  85 #else
  86               Sleep(TIMESleep/1000000);
  87 #endif
  88             }
  89         }
  90       catch( ServiceUnreachable& )
  91         {
  92           MESSAGE("CORBA::COMM_FAILURE: Naming Service not yet ready, waiting...");
  93 #ifndef WIN32
  94           nanosleep(&ts_req,&ts_rem); // wait before retry
  95 #else
  96           Sleep(TIMESleep/1000000);
  97 #endif
  98         }
  99     }
 100   if (!found)
 101     {
 102     INFOS("Server "<< serverName <<" not found, abort...");
 103     exit(EXIT_FAILURE);
 104     }
 105 }
 106
 107 /*!
 108  * Fake NS : no need to wait ;)
 109  */
 110 void NamingService_WaitForServerReadiness(SALOME_Fake_NamingService* NS, std::string serverName)
 111 {
 112 }