1 // Copyright (C) 2007-2021 CEA/DEN, EDF R&D, OPEN CASCADE
3 // Copyright (C) 2003-2007 OPEN CASCADE, EADS/CCR, LIP6, CEA/DEN,
4 // CEDRAT, EDF R&D, LEG, PRINCIPIA R&D, BUREAU VERITAS
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.
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.
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
20 // See http://www.salome-platform.org/ or email : webmaster.salome@opencascade.com
23 // File : LocalTraceCollector.cxx
24 // Author : Paul RASCLE (EDF)
28 #include <SALOMEconfig.h>
34 #include <omniORB4/CORBA.h>
37 #include "Utils_SALOME_Exception.hxx"
38 #include "SALOMETraceCollector.hxx"
39 #include "TraceCollector_WaitForServerReadiness.hxx"
40 #include <SALOMEconfig.h>
41 #include CORBA_CLIENT_HEADER(Logger)
43 // Class attributes initialisation, for class method SALOMETraceCollector::run
45 CORBA::ORB_ptr SALOMETraceCollector::_orb = 0;
47 // ============================================================================
49 * This class is for use with CORBA, inside SALOME.
50 * Type of trace (and corresponding class) is chosen in LocalTraceBufferPool.
52 * Guarantees a unique object instance of the class (singleton thread safe)
53 * a separate thread for loop to print traces is launched.
55 // ============================================================================
57 BaseTraceCollector* SALOMETraceCollector::instance()
59 if (_singleton == 0) // no need of lock when singleton already exists
61 pthread_mutex_lock(&_singletonMutex); // acquire lock to be alone
62 if (_singleton == 0) // another thread may have got
63 { // the lock after the first test
64 BaseTraceCollector* myInstance = new SALOMETraceCollector();
65 _orb = KERNEL::GetRefToORB();
67 sem_init(&_sem,0,0); // to wait until run thread is initialized
68 pthread_t traceThread;
70 pthread_create(&traceThread, NULL,
71 SALOMETraceCollector::run, &bid);
73 _singleton = myInstance; // _singleton known only when init done
75 pthread_mutex_unlock(&_singletonMutex); // release lock
80 // ============================================================================
82 * In a separate thread, loop to print traces.
83 * Mutex guarantees initialisation on instance method is done and only one run
84 * allowed (double check ...)
85 * Loop until there is no more buffer to print,
86 * and no ask for end from destructor.
87 * Get a buffer. If type = ABORT then exit application with message.
89 // ============================================================================
91 void* SALOMETraceCollector::run(void* /*bid*/)
93 _threadId = new pthread_t;
94 *_threadId = pthread_self();
95 sem_post(&_sem); // unlock instance
97 LocalTraceBufferPool* myTraceBuffer = LocalTraceBufferPool::instance();
98 LocalTrace_TraceInfo myTrace;
100 SALOME_Logger::Logger_var m_pInterfaceLogger;
101 CORBA::Object_var obj;
103 obj = TraceCollector_WaitForServerReadiness(_orb,"Logger");
104 if (!CORBA::is_nil(obj))
105 m_pInterfaceLogger = SALOME_Logger::Logger::_narrow(obj);
106 if (CORBA::is_nil(m_pInterfaceLogger))
108 std::cerr << "Logger server not found ! Abort" << std::endl;
109 std::cerr << std::flush ;
114 CORBA::String_var LogMsg =
115 CORBA::string_dup("\n---Init logger trace---\n");
116 m_pInterfaceLogger->putMessage(LogMsg);
117 DEVTRACE("Logger server found");
120 // --- Loop until there is no more buffer to print,
121 // and no ask for end from destructor.
123 while ((!_threadToClose) || myTraceBuffer->toCollect() )
127 DEVTRACE("SALOMETraceCollector _threadToClose");
131 myTraceBuffer->retrieve(myTrace);
132 if (!CORBA::is_nil(_orb))
134 if (myTrace.traceType == ABORT_MESS)
136 std::stringstream abortMessage("");
138 abortMessage << "INTERRUPTION from thread "
139 << myTrace.threadId << " : " << myTrace.trace;
141 abortMessage << "INTERRUPTION from thread "
142 << (void*)&myTrace.threadId
143 << " : " << myTrace.trace;
145 CORBA::String_var LogMsg =
146 CORBA::string_dup(abortMessage.str().c_str());
147 m_pInterfaceLogger->putMessage(LogMsg);
152 std::stringstream aMessage("");
154 aMessage << "th. " << myTrace.threadId
156 aMessage << "th. " << (void*)&myTrace.threadId
158 << " " << myTrace.trace;
159 CORBA::String_var LogMsg =
160 CORBA::string_dup(aMessage.str().c_str());
161 m_pInterfaceLogger->putMessage(LogMsg);
169 // ============================================================================
171 * Destructor: wait until printing thread ends (SALOMETraceCollector::run)
173 // ============================================================================
175 SALOMETraceCollector:: ~SALOMETraceCollector()
177 pthread_mutex_lock(&_singletonMutex); // acquire lock to be alone
180 DEVTRACE("SALOMETraceCollector:: ~SALOMETraceCollector()");
181 LocalTraceBufferPool* myTraceBuffer = LocalTraceBufferPool::instance();
183 myTraceBuffer->insert(NORMAL_MESS,"end of trace\n"); // to wake up thread
186 int ret = pthread_join(*_threadId, NULL);
187 if (ret) { std::cerr << "error close SALOMETraceCollector : "<< ret << std::endl; }
188 else { DEVTRACE("SALOMETraceCollector destruction OK") };
195 pthread_mutex_unlock(&_singletonMutex); // release lock
198 // ============================================================================
200 * Constructor: no need of LocalTraceBufferPool object initialization here,
201 * thread safe singleton used in LocalTraceBufferPool::instance()
203 // ============================================================================
205 SALOMETraceCollector::SALOMETraceCollector()
211 // ============================================================================
215 // ============================================================================
219 SALOMETRACECOLLECTOR_EXPORT
220 BaseTraceCollector *SingletonInstance(void)
222 BaseTraceCollector *instance = SALOMETraceCollector::instance();