Salome HOME
ADD a end user module (services.py) to help the manipulation of SALOME KERNEL service...
[modules/kernel.git] / src / SALOMELocalTrace / LocalTraceCollector.cxx
index edaa246904ae72e6e056d18605f24fc7e7c7391b..f444953cf2cd1e33fbff191e7b23293cc2ca939b 100644 (file)
@@ -1,36 +1,35 @@
-//  Copyright (C) 2004  OPEN CASCADE, EADS/CCR, LIP6, CEA/DEN,
-//  CEDRAT, EDF R&D, LEG, PRINCIPIA R&D, BUREAU VERITAS 
-// 
-//  This library is free software; you can redistribute it and/or 
-//  modify it under the terms of the GNU Lesser General Public 
-//  License as published by the Free Software Foundation; either 
-//  version 2.1 of the License. 
-// 
-//  This library is distributed in the hope that it will be useful, 
-//  but WITHOUT ANY WARRANTY; without even the implied warranty of 
-//  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU 
-//  Lesser General Public License for more details. 
-// 
-//  You should have received a copy of the GNU Lesser General Public 
-//  License along with this library; if not, write to the Free Software 
-//  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307 USA 
-// 
-//  See http://www.opencascade.org/SALOME/ or email : webmaster.salome@opencascade.org 
+// Copyright (C) 2007-2011  CEA/DEN, EDF R&D, OPEN CASCADE
 //
+// Copyright (C) 2003-2007  OPEN CASCADE, EADS/CCR, LIP6, CEA/DEN,
+// CEDRAT, EDF R&D, LEG, PRINCIPIA R&D, BUREAU VERITAS
 //
+// This library is free software; you can redistribute it and/or
+// modify it under the terms of the GNU Lesser General Public
+// License as published by the Free Software Foundation; either
+// version 2.1 of the License.
 //
+// This library is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+// Lesser General Public License for more details.
+//
+// You should have received a copy of the GNU Lesser General Public
+// License along with this library; if not, write to the Free Software
+// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307 USA
+//
+// See http://www.salome-platform.org/ or email : webmaster.salome@opencascade.com
+//
+
 //  File   : LocalTraceCollector.cxx
 //  Author : Paul RASCLE (EDF)
 //  Module : KERNEL
 //  $Header$
-
+//
 #include <iostream>
 #include <sstream>
 #include <fstream>
 #include <cstdlib>
 
-using namespace std;
-
 #include "LocalTraceCollector.hxx"
 
 // ============================================================================
@@ -51,17 +50,16 @@ BaseTraceCollector* LocalTraceCollector::instance()
       int ret;
       ret = pthread_mutex_lock(&_singletonMutex); // acquire lock to be alone
       if (_singleton == 0)                     // another thread may have got
-       {                                      // the lock after the first test
-         BaseTraceCollector* myInstance = new LocalTraceCollector();
-
-         sem_init(&_sem,0,0); // to wait until run thread is initialized
-         pthread_t traceThread;
-         int bid;
-         int re2 = pthread_create(&traceThread, NULL,
-                                  LocalTraceCollector::run, (void *)bid);
-         sem_wait(&_sem);
-         _singleton = myInstance; // _singleton known only when init done
-       }
+        {                                      // the lock after the first test
+          BaseTraceCollector* myInstance = new LocalTraceCollector();
+
+          sem_init(&_sem,0,0); // to wait until run thread is initialized
+          pthread_t traceThread;
+          pthread_create(&traceThread, NULL,
+                                   LocalTraceCollector::run, NULL);
+          sem_wait(&_sem);
+          _singleton = myInstance; // _singleton known only when init done
+        }
       ret = pthread_mutex_unlock(&_singletonMutex); // release lock
     }
   return _singleton;
@@ -93,36 +91,36 @@ void* LocalTraceCollector::run(void *bid)
   while ((!_threadToClose) || myTraceBuffer->toCollect() )
     {
       if (_threadToClose)
-       {
-         DEVTRACE("FileTraceCollector _threadToClose");
-         //break;
-       }
+        {
+          DEVTRACE("FileTraceCollector _threadToClose");
+          //break;
+        }
 
-      int fullBuf = myTraceBuffer->retrieve(myTrace);
+      myTraceBuffer->retrieve(myTrace);
       if (myTrace.traceType == ABORT_MESS)
-       {
-         cout << flush ;
-#ifndef WNT
-         cerr << "INTERRUPTION from thread " << myTrace.threadId
-              << " : " <<  myTrace.trace;
+        {
+          std::cout << std::flush ;
+#ifndef WIN32
+          std::cerr << "INTERRUPTION from thread " << myTrace.threadId
+               << " : " <<  myTrace.trace;
 #else
-         cerr << "INTERRUPTION from thread " << (void*)(&myTrace.threadId)
-              << " : " <<  myTrace.trace;
+          std::cerr << "INTERRUPTION from thread " << (void*)(&myTrace.threadId)
+               << " : " <<  myTrace.trace;
 #endif
-         cerr << flush ; 
-         exit(1);     
-       }
+          std::cerr << std::flush ; 
+          exit(1);     
+        }
       else
-       {
-         cout << flush ;
-#ifndef WNT
-         cerr << "th. " << myTrace.threadId << " " << myTrace.trace;
+        {
+          std::cout << std::flush ;
+#ifndef WIN32
+          std::cerr << "th. " << myTrace.threadId << " " << myTrace.trace;
 #else
-         cerr << "th. " << (void*)(&myTrace.threadId)
-              << " " << myTrace.trace;
+          std::cerr << "th. " << (void*)(&myTrace.threadId)
+               << " " << myTrace.trace;
 #endif
-         cerr << flush ; 
-       }
+          std::cerr << std::flush ; 
+        }
     }
   pthread_exit(NULL);
   return NULL;
@@ -145,13 +143,14 @@ LocalTraceCollector:: ~LocalTraceCollector()
       _threadToClose = 1;
       myTraceBuffer->insert(NORMAL_MESS,"end of trace\n"); // to wake up thread
       if (_threadId)
-       {
-         int ret = pthread_join(*_threadId, NULL);
-         if (ret) cerr << "error close LocalTraceCollector : "<< ret << endl;
-         else DEVTRACE("LocalTraceCollector destruction OK");
-         _threadId = 0;
-         _threadToClose = 0;
-       }
+        {
+          int ret = pthread_join(*_threadId, NULL);
+          if (ret) std::cerr << "error close LocalTraceCollector : "<< ret << std::endl;
+          else DEVTRACE("LocalTraceCollector destruction OK");
+          delete _threadId;
+          _threadId = 0;
+          _threadToClose = 0;
+        }
       _singleton = 0;
     }
   ret = pthread_mutex_unlock(&_singletonMutex); // release lock