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>
36 #include "Utils_SALOME_Exception.hxx"
37 #include "SALOMETraceCollector.hxx"
38 #include "TraceCollector_WaitForServerReadiness.hxx"
39 #include <SALOMEconfig.h>
40 #include CORBA_CLIENT_HEADER(Logger)
42 // ============================================================================
44 * This class is for use with CORBA, inside SALOME.
45 * Type of trace (and corresponding class) is chosen in LocalTraceBufferPool.
47 * Guarantees a unique object instance of the class (singleton thread safe)
48 * a separate thread for loop to print traces is launched.
50 // ============================================================================
52 BaseTraceCollector* SALOMETraceCollector::instance()
54 if (_singleton == 0) // no need of lock when singleton already exists
56 pthread_mutex_lock(&_singletonMutex); // acquire lock to be alone
57 if (_singleton == 0) // another thread may have got
58 { // the lock after the first test
59 BaseTraceCollector* myInstance = new SALOMETraceCollector();
61 sem_init(&_sem,0,0); // to wait until run thread is initialized
62 pthread_t traceThread;
64 pthread_create(&traceThread, NULL,
65 SALOMETraceCollector::run, &bid);
67 _singleton = myInstance; // _singleton known only when init done
69 pthread_mutex_unlock(&_singletonMutex); // release lock
74 // ============================================================================
76 * In a separate thread, loop to print traces.
77 * Mutex guarantees initialisation on instance method is done and only one run
78 * allowed (double check ...)
79 * Loop until there is no more buffer to print,
80 * and no ask for end from destructor.
81 * Get a buffer. If type = ABORT then exit application with message.
83 // ============================================================================
85 void* SALOMETraceCollector::run(void* /*bid*/)
87 _threadId = new pthread_t;
88 *_threadId = pthread_self();
89 sem_post(&_sem); // unlock instance
91 LocalTraceBufferPool* myTraceBuffer = LocalTraceBufferPool::instance();
92 LocalTrace_TraceInfo myTrace;
94 SALOME_Logger::Logger_var m_pInterfaceLogger;
95 CORBA::Object_var obj;
97 obj = TraceCollector_WaitForServerReadiness("Logger");
98 if (!CORBA::is_nil(obj))
99 m_pInterfaceLogger = SALOME_Logger::Logger::_narrow(obj);
100 if (CORBA::is_nil(m_pInterfaceLogger))
102 std::cerr << "Logger server not found ! Abort" << std::endl;
103 std::cerr << std::flush ;
108 CORBA::String_var LogMsg =
109 CORBA::string_dup("\n---Init logger trace---\n");
110 m_pInterfaceLogger->putMessage(LogMsg);
111 DEVTRACE("Logger server found");
114 // --- Loop until there is no more buffer to print,
115 // and no ask for end from destructor.
117 while ((!_threadToClose) || myTraceBuffer->toCollect() )
121 DEVTRACE("SALOMETraceCollector _threadToClose");
125 myTraceBuffer->retrieve(myTrace);
126 //if (!CORBA::is_nil(_orb))
129 if (myTrace.traceType == ABORT_MESS)
131 std::stringstream abortMessage("");
133 abortMessage << "INTERRUPTION from thread "
134 << myTrace.threadId << " : " << myTrace.trace;
136 abortMessage << "INTERRUPTION from thread "
137 << (void*)&myTrace.threadId
138 << " : " << myTrace.trace;
140 CORBA::String_var LogMsg =
141 CORBA::string_dup(abortMessage.str().c_str());
142 m_pInterfaceLogger->putMessage(LogMsg);
147 std::stringstream aMessage("");
149 aMessage << "th. " << myTrace.threadId
151 aMessage << "th. " << (void*)&myTrace.threadId
153 << " " << myTrace.trace;
154 CORBA::String_var LogMsg =
155 CORBA::string_dup(aMessage.str().c_str());
156 m_pInterfaceLogger->putMessage(LogMsg);
164 // ============================================================================
166 * Destructor: wait until printing thread ends (SALOMETraceCollector::run)
168 // ============================================================================
170 SALOMETraceCollector:: ~SALOMETraceCollector()
172 pthread_mutex_lock(&_singletonMutex); // acquire lock to be alone
175 DEVTRACE("SALOMETraceCollector:: ~SALOMETraceCollector()");
176 LocalTraceBufferPool* myTraceBuffer = LocalTraceBufferPool::instance();
178 myTraceBuffer->insert(NORMAL_MESS,"end of trace\n"); // to wake up thread
181 int ret = pthread_join(*_threadId, NULL);
182 if (ret) { std::cerr << "error close SALOMETraceCollector : "<< ret << std::endl; }
183 else { DEVTRACE("SALOMETraceCollector destruction OK") };
190 pthread_mutex_unlock(&_singletonMutex); // release lock
193 // ============================================================================
195 * Constructor: no need of LocalTraceBufferPool object initialization here,
196 * thread safe singleton used in LocalTraceBufferPool::instance()
198 // ============================================================================
200 SALOMETraceCollector::SALOMETraceCollector()
206 // ============================================================================
210 // ============================================================================
214 SALOMETRACECOLLECTOR_EXPORT
215 BaseTraceCollector *SingletonInstance(void)
217 BaseTraceCollector *instance = SALOMETraceCollector::instance();