1 // Copyright (C) 2007-2012 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.
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)
33 #include "LocalTraceCollector.hxx"
35 // ============================================================================
37 * This class is for use without CORBA, inside or outside SALOME.
38 * SALOME uses SALOMETraceCollector, to allow trace collection via CORBA.
39 * Type of trace (and corresponding class) is choosen in LocalTraceBufferPool.
41 * Guarantees a unique object instance of the class (singleton thread safe)
42 * a separate thread for loop to print traces is launched.
44 // ============================================================================
46 BaseTraceCollector* LocalTraceCollector::instance()
48 if (_singleton == 0) // no need of lock when singleton already exists
51 ret = pthread_mutex_lock(&_singletonMutex); // acquire lock to be alone
52 if (_singleton == 0) // another thread may have got
53 { // the lock after the first test
54 BaseTraceCollector* myInstance = new LocalTraceCollector();
56 sem_init(&_sem,0,0); // to wait until run thread is initialized
57 pthread_t traceThread;
58 pthread_create(&traceThread, NULL,
59 LocalTraceCollector::run, NULL);
61 _singleton = myInstance; // _singleton known only when init done
63 ret = pthread_mutex_unlock(&_singletonMutex); // release lock
68 // ============================================================================
70 * In a separate thread, loop to print traces.
71 * Mutex garantees intialisation on instance method is done and only one run
72 * allowed (double check ...)
73 * Loop until there is no more buffer to print,
74 * and no ask for end from destructor.
75 * Get a buffer. If type = ABORT then exit application with message.
77 // ============================================================================
79 void* LocalTraceCollector::run(void *bid)
81 _threadId = new pthread_t;
82 *_threadId = pthread_self();
83 sem_post(&_sem); // unlock instance
85 LocalTraceBufferPool* myTraceBuffer = LocalTraceBufferPool::instance();
86 LocalTrace_TraceInfo myTrace;
88 // --- Loop until there is no more buffer to print,
89 // and no ask for end from destructor.
91 while ((!_threadToClose) || myTraceBuffer->toCollect() )
95 DEVTRACE("FileTraceCollector _threadToClose");
99 myTraceBuffer->retrieve(myTrace);
100 if (myTrace.traceType == ABORT_MESS)
102 std::cout << std::flush ;
104 std::cerr << "INTERRUPTION from thread " << myTrace.threadId
105 << " : " << myTrace.trace;
107 std::cerr << "INTERRUPTION from thread " << (void*)(&myTrace.threadId)
108 << " : " << myTrace.trace;
110 std::cerr << std::flush ;
115 std::cout << std::flush ;
117 std::cerr << "th. " << myTrace.threadId << " " << myTrace.trace;
119 std::cerr << "th. " << (void*)(&myTrace.threadId)
120 << " " << myTrace.trace;
122 std::cerr << std::flush ;
129 // ============================================================================
131 * Destructor: wait until printing thread ends (LocalTraceCollector::run)
133 // ============================================================================
135 LocalTraceCollector:: ~LocalTraceCollector()
138 ret = pthread_mutex_lock(&_singletonMutex); // acquire lock to be alone
141 DEVTRACE("LocalTraceCollector:: ~LocalTraceCollector()");
142 LocalTraceBufferPool* myTraceBuffer = LocalTraceBufferPool::instance();
144 myTraceBuffer->insert(NORMAL_MESS,"end of trace\n"); // to wake up thread
147 int ret = pthread_join(*_threadId, NULL);
148 if (ret) std::cerr << "error close LocalTraceCollector : "<< ret << std::endl;
149 else DEVTRACE("LocalTraceCollector destruction OK");
156 ret = pthread_mutex_unlock(&_singletonMutex); // release lock
159 // ============================================================================
161 * Constructor: no need of LocalTraceBufferPool object initialization here,
162 * thread safe singleton used in LocalTraceBufferPool::instance()
164 // ============================================================================
166 LocalTraceCollector::LocalTraceCollector()