1*b1cdbd2cSJim Jagielski /**************************************************************
2*b1cdbd2cSJim Jagielski *
3*b1cdbd2cSJim Jagielski * Licensed to the Apache Software Foundation (ASF) under one
4*b1cdbd2cSJim Jagielski * or more contributor license agreements. See the NOTICE file
5*b1cdbd2cSJim Jagielski * distributed with this work for additional information
6*b1cdbd2cSJim Jagielski * regarding copyright ownership. The ASF licenses this file
7*b1cdbd2cSJim Jagielski * to you under the Apache License, Version 2.0 (the
8*b1cdbd2cSJim Jagielski * "License"); you may not use this file except in compliance
9*b1cdbd2cSJim Jagielski * with the License. You may obtain a copy of the License at
10*b1cdbd2cSJim Jagielski *
11*b1cdbd2cSJim Jagielski * http://www.apache.org/licenses/LICENSE-2.0
12*b1cdbd2cSJim Jagielski *
13*b1cdbd2cSJim Jagielski * Unless required by applicable law or agreed to in writing,
14*b1cdbd2cSJim Jagielski * software distributed under the License is distributed on an
15*b1cdbd2cSJim Jagielski * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16*b1cdbd2cSJim Jagielski * KIND, either express or implied. See the License for the
17*b1cdbd2cSJim Jagielski * specific language governing permissions and limitations
18*b1cdbd2cSJim Jagielski * under the License.
19*b1cdbd2cSJim Jagielski *
20*b1cdbd2cSJim Jagielski *************************************************************/
21*b1cdbd2cSJim Jagielski
22*b1cdbd2cSJim Jagielski
23*b1cdbd2cSJim Jagielski #include "precompiled_sw.hxx"
24*b1cdbd2cSJim Jagielski #include <finalthreadmanager.hxx>
25*b1cdbd2cSJim Jagielski
26*b1cdbd2cSJim Jagielski #ifndef _OSL_THREAD_HXX_
27*b1cdbd2cSJim Jagielski #include <osl/thread.hxx>
28*b1cdbd2cSJim Jagielski #endif
29*b1cdbd2cSJim Jagielski #include <errhdl.hxx>
30*b1cdbd2cSJim Jagielski #include <pausethreadstarting.hxx>
31*b1cdbd2cSJim Jagielski #include <swthreadjoiner.hxx>
32*b1cdbd2cSJim Jagielski
33*b1cdbd2cSJim Jagielski #include <com/sun/star/frame/XDesktop.hpp>
34*b1cdbd2cSJim Jagielski #include <rtl/ustring.hxx>
35*b1cdbd2cSJim Jagielski #include <com/sun/star/frame/XFramesSupplier.hpp>
36*b1cdbd2cSJim Jagielski
37*b1cdbd2cSJim Jagielski namespace css = ::com::sun::star;
38*b1cdbd2cSJim Jagielski
39*b1cdbd2cSJim Jagielski /** thread to cancel a give list of cancellable jobs
40*b1cdbd2cSJim Jagielski
41*b1cdbd2cSJim Jagielski helper class for FinalThreadManager
42*b1cdbd2cSJim Jagielski
43*b1cdbd2cSJim Jagielski @author OD
44*b1cdbd2cSJim Jagielski */
45*b1cdbd2cSJim Jagielski class CancelJobsThread : public osl::Thread
46*b1cdbd2cSJim Jagielski {
47*b1cdbd2cSJim Jagielski public:
CancelJobsThread(std::list<css::uno::Reference<css::util::XCancellable>> aJobs)48*b1cdbd2cSJim Jagielski CancelJobsThread( std::list< css::uno::Reference< css::util::XCancellable > > aJobs )
49*b1cdbd2cSJim Jagielski : osl::Thread(),
50*b1cdbd2cSJim Jagielski maMutex(),
51*b1cdbd2cSJim Jagielski maJobs( aJobs ),
52*b1cdbd2cSJim Jagielski mbAllJobsCancelled( false ),
53*b1cdbd2cSJim Jagielski mbStopped( false )
54*b1cdbd2cSJim Jagielski {
55*b1cdbd2cSJim Jagielski }
56*b1cdbd2cSJim Jagielski
~CancelJobsThread()57*b1cdbd2cSJim Jagielski virtual ~CancelJobsThread() {}
58*b1cdbd2cSJim Jagielski
59*b1cdbd2cSJim Jagielski void addJobs( std::list< css::uno::Reference< css::util::XCancellable > >& rJobs );
60*b1cdbd2cSJim Jagielski
61*b1cdbd2cSJim Jagielski bool allJobsCancelled() const;
62*b1cdbd2cSJim Jagielski
63*b1cdbd2cSJim Jagielski void stopWhenAllJobsCancelled();
64*b1cdbd2cSJim Jagielski
65*b1cdbd2cSJim Jagielski private:
66*b1cdbd2cSJim Jagielski
67*b1cdbd2cSJim Jagielski bool existJobs() const;
68*b1cdbd2cSJim Jagielski
69*b1cdbd2cSJim Jagielski css::uno::Reference< css::util::XCancellable > getNextJob();
70*b1cdbd2cSJim Jagielski
71*b1cdbd2cSJim Jagielski bool stopped() const;
72*b1cdbd2cSJim Jagielski
73*b1cdbd2cSJim Jagielski virtual void SAL_CALL run();
74*b1cdbd2cSJim Jagielski
75*b1cdbd2cSJim Jagielski mutable osl::Mutex maMutex;
76*b1cdbd2cSJim Jagielski
77*b1cdbd2cSJim Jagielski std::list< css::uno::Reference< css::util::XCancellable > > maJobs;
78*b1cdbd2cSJim Jagielski
79*b1cdbd2cSJim Jagielski bool mbAllJobsCancelled;
80*b1cdbd2cSJim Jagielski bool mbStopped;
81*b1cdbd2cSJim Jagielski };
82*b1cdbd2cSJim Jagielski
addJobs(std::list<css::uno::Reference<css::util::XCancellable>> & rJobs)83*b1cdbd2cSJim Jagielski void CancelJobsThread::addJobs( std::list< css::uno::Reference< css::util::XCancellable > >& rJobs )
84*b1cdbd2cSJim Jagielski {
85*b1cdbd2cSJim Jagielski osl::MutexGuard aGuard(maMutex);
86*b1cdbd2cSJim Jagielski
87*b1cdbd2cSJim Jagielski maJobs.insert( maJobs.end(), rJobs.begin(), rJobs.end() );
88*b1cdbd2cSJim Jagielski mbAllJobsCancelled = !maJobs.empty();
89*b1cdbd2cSJim Jagielski }
90*b1cdbd2cSJim Jagielski
existJobs() const91*b1cdbd2cSJim Jagielski bool CancelJobsThread::existJobs() const
92*b1cdbd2cSJim Jagielski {
93*b1cdbd2cSJim Jagielski osl::MutexGuard aGuard(maMutex);
94*b1cdbd2cSJim Jagielski
95*b1cdbd2cSJim Jagielski return !maJobs.empty();
96*b1cdbd2cSJim Jagielski }
97*b1cdbd2cSJim Jagielski
allJobsCancelled() const98*b1cdbd2cSJim Jagielski bool CancelJobsThread::allJobsCancelled() const
99*b1cdbd2cSJim Jagielski {
100*b1cdbd2cSJim Jagielski osl::MutexGuard aGuard(maMutex);
101*b1cdbd2cSJim Jagielski
102*b1cdbd2cSJim Jagielski return maJobs.empty() && mbAllJobsCancelled;
103*b1cdbd2cSJim Jagielski }
stopWhenAllJobsCancelled()104*b1cdbd2cSJim Jagielski void CancelJobsThread::stopWhenAllJobsCancelled()
105*b1cdbd2cSJim Jagielski {
106*b1cdbd2cSJim Jagielski osl::MutexGuard aGuard(maMutex);
107*b1cdbd2cSJim Jagielski
108*b1cdbd2cSJim Jagielski mbStopped = true;
109*b1cdbd2cSJim Jagielski }
110*b1cdbd2cSJim Jagielski
getNextJob()111*b1cdbd2cSJim Jagielski css::uno::Reference< css::util::XCancellable > CancelJobsThread::getNextJob()
112*b1cdbd2cSJim Jagielski {
113*b1cdbd2cSJim Jagielski css::uno::Reference< css::util::XCancellable > xRet;
114*b1cdbd2cSJim Jagielski
115*b1cdbd2cSJim Jagielski {
116*b1cdbd2cSJim Jagielski osl::MutexGuard aGuard(maMutex);
117*b1cdbd2cSJim Jagielski
118*b1cdbd2cSJim Jagielski if ( !maJobs.empty() )
119*b1cdbd2cSJim Jagielski {
120*b1cdbd2cSJim Jagielski xRet = maJobs.front();
121*b1cdbd2cSJim Jagielski maJobs.pop_front();
122*b1cdbd2cSJim Jagielski }
123*b1cdbd2cSJim Jagielski }
124*b1cdbd2cSJim Jagielski
125*b1cdbd2cSJim Jagielski return xRet;
126*b1cdbd2cSJim Jagielski }
127*b1cdbd2cSJim Jagielski
stopped() const128*b1cdbd2cSJim Jagielski bool CancelJobsThread::stopped() const
129*b1cdbd2cSJim Jagielski {
130*b1cdbd2cSJim Jagielski osl::MutexGuard aGuard(maMutex);
131*b1cdbd2cSJim Jagielski
132*b1cdbd2cSJim Jagielski return mbStopped;
133*b1cdbd2cSJim Jagielski }
134*b1cdbd2cSJim Jagielski
run()135*b1cdbd2cSJim Jagielski void SAL_CALL CancelJobsThread::run()
136*b1cdbd2cSJim Jagielski {
137*b1cdbd2cSJim Jagielski while ( !stopped() )
138*b1cdbd2cSJim Jagielski {
139*b1cdbd2cSJim Jagielski while ( existJobs() )
140*b1cdbd2cSJim Jagielski {
141*b1cdbd2cSJim Jagielski css::uno::Reference< css::util::XCancellable > aJob( getNextJob() );
142*b1cdbd2cSJim Jagielski if ( aJob.is() )
143*b1cdbd2cSJim Jagielski {
144*b1cdbd2cSJim Jagielski aJob->cancel();
145*b1cdbd2cSJim Jagielski }
146*b1cdbd2cSJim Jagielski }
147*b1cdbd2cSJim Jagielski
148*b1cdbd2cSJim Jagielski mbAllJobsCancelled = true;
149*b1cdbd2cSJim Jagielski
150*b1cdbd2cSJim Jagielski {
151*b1cdbd2cSJim Jagielski TimeValue aSleepTime;
152*b1cdbd2cSJim Jagielski aSleepTime.Seconds = 1;
153*b1cdbd2cSJim Jagielski aSleepTime.Nanosec = 0;
154*b1cdbd2cSJim Jagielski osl_waitThread( &aSleepTime );
155*b1cdbd2cSJim Jagielski }
156*b1cdbd2cSJim Jagielski }
157*b1cdbd2cSJim Jagielski }
158*b1cdbd2cSJim Jagielski
159*b1cdbd2cSJim Jagielski /** thread to terminate office, when all jobs are cancelled.
160*b1cdbd2cSJim Jagielski
161*b1cdbd2cSJim Jagielski helper class for FinalThreadManager
162*b1cdbd2cSJim Jagielski
163*b1cdbd2cSJim Jagielski @author OD
164*b1cdbd2cSJim Jagielski */
165*b1cdbd2cSJim Jagielski class TerminateOfficeThread : public osl::Thread
166*b1cdbd2cSJim Jagielski {
167*b1cdbd2cSJim Jagielski public:
TerminateOfficeThread(CancelJobsThread & rCancelJobsThread,css::uno::Reference<css::uno::XComponentContext> const & xContext)168*b1cdbd2cSJim Jagielski TerminateOfficeThread( CancelJobsThread& rCancelJobsThread,
169*b1cdbd2cSJim Jagielski css::uno::Reference< css::uno::XComponentContext > const & xContext )
170*b1cdbd2cSJim Jagielski : osl::Thread(),
171*b1cdbd2cSJim Jagielski maMutex(),
172*b1cdbd2cSJim Jagielski mrCancelJobsThread( rCancelJobsThread ),
173*b1cdbd2cSJim Jagielski mbStopOfficeTermination( false ),
174*b1cdbd2cSJim Jagielski mxContext( xContext )
175*b1cdbd2cSJim Jagielski {
176*b1cdbd2cSJim Jagielski }
177*b1cdbd2cSJim Jagielski
~TerminateOfficeThread()178*b1cdbd2cSJim Jagielski virtual ~TerminateOfficeThread() {}
179*b1cdbd2cSJim Jagielski
180*b1cdbd2cSJim Jagielski void StopOfficeTermination();
181*b1cdbd2cSJim Jagielski
182*b1cdbd2cSJim Jagielski private:
183*b1cdbd2cSJim Jagielski
184*b1cdbd2cSJim Jagielski virtual void SAL_CALL run();
185*b1cdbd2cSJim Jagielski virtual void SAL_CALL onTerminated();
186*b1cdbd2cSJim Jagielski
187*b1cdbd2cSJim Jagielski bool OfficeTerminationStopped();
188*b1cdbd2cSJim Jagielski
189*b1cdbd2cSJim Jagielski void PerformOfficeTermination();
190*b1cdbd2cSJim Jagielski
191*b1cdbd2cSJim Jagielski osl::Mutex maMutex;
192*b1cdbd2cSJim Jagielski
193*b1cdbd2cSJim Jagielski const CancelJobsThread& mrCancelJobsThread;
194*b1cdbd2cSJim Jagielski
195*b1cdbd2cSJim Jagielski bool mbStopOfficeTermination;
196*b1cdbd2cSJim Jagielski
197*b1cdbd2cSJim Jagielski css::uno::Reference< css::uno::XComponentContext > mxContext;
198*b1cdbd2cSJim Jagielski };
199*b1cdbd2cSJim Jagielski
StopOfficeTermination()200*b1cdbd2cSJim Jagielski void TerminateOfficeThread::StopOfficeTermination()
201*b1cdbd2cSJim Jagielski {
202*b1cdbd2cSJim Jagielski osl::MutexGuard aGuard(maMutex);
203*b1cdbd2cSJim Jagielski
204*b1cdbd2cSJim Jagielski mbStopOfficeTermination = true;
205*b1cdbd2cSJim Jagielski }
206*b1cdbd2cSJim Jagielski
OfficeTerminationStopped()207*b1cdbd2cSJim Jagielski bool TerminateOfficeThread::OfficeTerminationStopped()
208*b1cdbd2cSJim Jagielski {
209*b1cdbd2cSJim Jagielski osl::MutexGuard aGuard(maMutex);
210*b1cdbd2cSJim Jagielski
211*b1cdbd2cSJim Jagielski return mbStopOfficeTermination;
212*b1cdbd2cSJim Jagielski }
213*b1cdbd2cSJim Jagielski
run()214*b1cdbd2cSJim Jagielski void SAL_CALL TerminateOfficeThread::run()
215*b1cdbd2cSJim Jagielski {
216*b1cdbd2cSJim Jagielski while ( !OfficeTerminationStopped() )
217*b1cdbd2cSJim Jagielski {
218*b1cdbd2cSJim Jagielski osl::MutexGuard aGuard(maMutex);
219*b1cdbd2cSJim Jagielski
220*b1cdbd2cSJim Jagielski if ( mrCancelJobsThread.allJobsCancelled() )
221*b1cdbd2cSJim Jagielski {
222*b1cdbd2cSJim Jagielski break;
223*b1cdbd2cSJim Jagielski }
224*b1cdbd2cSJim Jagielski }
225*b1cdbd2cSJim Jagielski
226*b1cdbd2cSJim Jagielski if ( !OfficeTerminationStopped() )
227*b1cdbd2cSJim Jagielski {
228*b1cdbd2cSJim Jagielski PerformOfficeTermination();
229*b1cdbd2cSJim Jagielski }
230*b1cdbd2cSJim Jagielski }
231*b1cdbd2cSJim Jagielski
PerformOfficeTermination()232*b1cdbd2cSJim Jagielski void TerminateOfficeThread::PerformOfficeTermination()
233*b1cdbd2cSJim Jagielski {
234*b1cdbd2cSJim Jagielski css::uno::Reference< css::frame::XFramesSupplier > xTasksSupplier(
235*b1cdbd2cSJim Jagielski mxContext->getServiceManager()->createInstanceWithContext(
236*b1cdbd2cSJim Jagielski ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.frame.Desktop") ),
237*b1cdbd2cSJim Jagielski mxContext ),
238*b1cdbd2cSJim Jagielski css::uno::UNO_QUERY );
239*b1cdbd2cSJim Jagielski if ( !xTasksSupplier.is() )
240*b1cdbd2cSJim Jagielski {
241*b1cdbd2cSJim Jagielski ASSERT( false, "<TerminateOfficeThread::PerformOfficeTermination()> - no XFramesSupplier!" );
242*b1cdbd2cSJim Jagielski return;
243*b1cdbd2cSJim Jagielski }
244*b1cdbd2cSJim Jagielski
245*b1cdbd2cSJim Jagielski css::uno::Reference< css::container::XElementAccess > xList( xTasksSupplier->getFrames(), css::uno::UNO_QUERY );
246*b1cdbd2cSJim Jagielski if ( !xList.is() )
247*b1cdbd2cSJim Jagielski {
248*b1cdbd2cSJim Jagielski ASSERT( false, "<TerminateOfficeThread::PerformOfficeTermination()> - no XElementAccess!" );
249*b1cdbd2cSJim Jagielski return;
250*b1cdbd2cSJim Jagielski }
251*b1cdbd2cSJim Jagielski
252*b1cdbd2cSJim Jagielski if ( !xList->hasElements() )
253*b1cdbd2cSJim Jagielski {
254*b1cdbd2cSJim Jagielski css::uno::Reference< css::frame::XDesktop > xDesktop( xTasksSupplier, css::uno::UNO_QUERY );
255*b1cdbd2cSJim Jagielski if ( xDesktop.is() && !OfficeTerminationStopped() )
256*b1cdbd2cSJim Jagielski {
257*b1cdbd2cSJim Jagielski xDesktop->terminate();
258*b1cdbd2cSJim Jagielski }
259*b1cdbd2cSJim Jagielski }
260*b1cdbd2cSJim Jagielski }
261*b1cdbd2cSJim Jagielski
onTerminated()262*b1cdbd2cSJim Jagielski void SAL_CALL TerminateOfficeThread::onTerminated()
263*b1cdbd2cSJim Jagielski {
264*b1cdbd2cSJim Jagielski if ( OfficeTerminationStopped() )
265*b1cdbd2cSJim Jagielski {
266*b1cdbd2cSJim Jagielski delete this;
267*b1cdbd2cSJim Jagielski }
268*b1cdbd2cSJim Jagielski }
269*b1cdbd2cSJim Jagielski
270*b1cdbd2cSJim Jagielski
271*b1cdbd2cSJim Jagielski /** class FinalThreadManager
272*b1cdbd2cSJim Jagielski
273*b1cdbd2cSJim Jagielski @author OD
274*b1cdbd2cSJim Jagielski */
FinalThreadManager(css::uno::Reference<css::uno::XComponentContext> const & context)275*b1cdbd2cSJim Jagielski FinalThreadManager::FinalThreadManager(css::uno::Reference< css::uno::XComponentContext > const & context)
276*b1cdbd2cSJim Jagielski : m_xContext(context),
277*b1cdbd2cSJim Jagielski maMutex(),
278*b1cdbd2cSJim Jagielski maThreads(),
279*b1cdbd2cSJim Jagielski mpCancelJobsThread( 0 ),
280*b1cdbd2cSJim Jagielski mpTerminateOfficeThread( 0 ),
281*b1cdbd2cSJim Jagielski mpPauseThreadStarting( 0 ),
282*b1cdbd2cSJim Jagielski mbRegisteredAtDesktop( false )
283*b1cdbd2cSJim Jagielski {
284*b1cdbd2cSJim Jagielski
285*b1cdbd2cSJim Jagielski }
286*b1cdbd2cSJim Jagielski
registerAsListenerAtDesktop()287*b1cdbd2cSJim Jagielski void FinalThreadManager::registerAsListenerAtDesktop()
288*b1cdbd2cSJim Jagielski {
289*b1cdbd2cSJim Jagielski css::uno::Reference< css::frame::XDesktop > xDesktop(
290*b1cdbd2cSJim Jagielski m_xContext->getServiceManager()->createInstanceWithContext(
291*b1cdbd2cSJim Jagielski ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM("com.sun.star.frame.Desktop") ),
292*b1cdbd2cSJim Jagielski m_xContext ),
293*b1cdbd2cSJim Jagielski css::uno::UNO_QUERY );
294*b1cdbd2cSJim Jagielski
295*b1cdbd2cSJim Jagielski if ( xDesktop.is() )
296*b1cdbd2cSJim Jagielski {
297*b1cdbd2cSJim Jagielski xDesktop->addTerminateListener( css::uno::Reference< css::frame::XTerminateListener >( static_cast< cppu::OWeakObject* >( this ), css::uno::UNO_QUERY ) );
298*b1cdbd2cSJim Jagielski }
299*b1cdbd2cSJim Jagielski }
300*b1cdbd2cSJim Jagielski
~FinalThreadManager()301*b1cdbd2cSJim Jagielski FinalThreadManager::~FinalThreadManager()
302*b1cdbd2cSJim Jagielski {
303*b1cdbd2cSJim Jagielski if ( mpPauseThreadStarting != 0 )
304*b1cdbd2cSJim Jagielski {
305*b1cdbd2cSJim Jagielski delete mpPauseThreadStarting;
306*b1cdbd2cSJim Jagielski mpPauseThreadStarting = 0;
307*b1cdbd2cSJim Jagielski }
308*b1cdbd2cSJim Jagielski
309*b1cdbd2cSJim Jagielski if ( mpTerminateOfficeThread != 0 )
310*b1cdbd2cSJim Jagielski {
311*b1cdbd2cSJim Jagielski mpTerminateOfficeThread->StopOfficeTermination(); // thread kills itself.
312*b1cdbd2cSJim Jagielski mpTerminateOfficeThread = 0;
313*b1cdbd2cSJim Jagielski }
314*b1cdbd2cSJim Jagielski
315*b1cdbd2cSJim Jagielski if ( !maThreads.empty() )
316*b1cdbd2cSJim Jagielski {
317*b1cdbd2cSJim Jagielski ASSERT( false, "<FinalThreadManager::~FinalThreadManager()> - still registered jobs are existing -> perform cancellation" );
318*b1cdbd2cSJim Jagielski cancelAllJobs();
319*b1cdbd2cSJim Jagielski }
320*b1cdbd2cSJim Jagielski
321*b1cdbd2cSJim Jagielski if ( mpCancelJobsThread != 0 )
322*b1cdbd2cSJim Jagielski {
323*b1cdbd2cSJim Jagielski if ( !mpCancelJobsThread->allJobsCancelled() )
324*b1cdbd2cSJim Jagielski {
325*b1cdbd2cSJim Jagielski ASSERT( false, "<FinalThreadManager::~FinalThreadManager()> - cancellation of registered jobs not yet finished -> wait for its finish" );
326*b1cdbd2cSJim Jagielski }
327*b1cdbd2cSJim Jagielski
328*b1cdbd2cSJim Jagielski mpCancelJobsThread->stopWhenAllJobsCancelled();
329*b1cdbd2cSJim Jagielski mpCancelJobsThread->join();
330*b1cdbd2cSJim Jagielski delete mpCancelJobsThread;
331*b1cdbd2cSJim Jagielski mpCancelJobsThread = 0;
332*b1cdbd2cSJim Jagielski }
333*b1cdbd2cSJim Jagielski }
334*b1cdbd2cSJim Jagielski
335*b1cdbd2cSJim Jagielski // com.sun.star.uno.XServiceInfo:
getImplementationName()336*b1cdbd2cSJim Jagielski ::rtl::OUString SAL_CALL FinalThreadManager::getImplementationName() throw (css::uno::RuntimeException)
337*b1cdbd2cSJim Jagielski {
338*b1cdbd2cSJim Jagielski return comp_FinalThreadManager::_getImplementationName();
339*b1cdbd2cSJim Jagielski }
340*b1cdbd2cSJim Jagielski
supportsService(::rtl::OUString const & serviceName)341*b1cdbd2cSJim Jagielski ::sal_Bool SAL_CALL FinalThreadManager::supportsService(::rtl::OUString const & serviceName) throw (css::uno::RuntimeException)
342*b1cdbd2cSJim Jagielski {
343*b1cdbd2cSJim Jagielski css::uno::Sequence< ::rtl::OUString > serviceNames = comp_FinalThreadManager::_getSupportedServiceNames();
344*b1cdbd2cSJim Jagielski for (::sal_Int32 i = 0; i < serviceNames.getLength(); ++i) {
345*b1cdbd2cSJim Jagielski if (serviceNames[i] == serviceName)
346*b1cdbd2cSJim Jagielski return sal_True;
347*b1cdbd2cSJim Jagielski }
348*b1cdbd2cSJim Jagielski return sal_False;
349*b1cdbd2cSJim Jagielski }
350*b1cdbd2cSJim Jagielski
getSupportedServiceNames()351*b1cdbd2cSJim Jagielski css::uno::Sequence< ::rtl::OUString > SAL_CALL FinalThreadManager::getSupportedServiceNames() throw (css::uno::RuntimeException)
352*b1cdbd2cSJim Jagielski {
353*b1cdbd2cSJim Jagielski return comp_FinalThreadManager::_getSupportedServiceNames();
354*b1cdbd2cSJim Jagielski }
355*b1cdbd2cSJim Jagielski
356*b1cdbd2cSJim Jagielski // ::com::sun::star::util::XJobManager:
registerJob(const css::uno::Reference<css::util::XCancellable> & Job)357*b1cdbd2cSJim Jagielski void SAL_CALL FinalThreadManager::registerJob(const css::uno::Reference< css::util::XCancellable > & Job) throw (css::uno::RuntimeException)
358*b1cdbd2cSJim Jagielski {
359*b1cdbd2cSJim Jagielski osl::MutexGuard aGuard(maMutex);
360*b1cdbd2cSJim Jagielski
361*b1cdbd2cSJim Jagielski maThreads.push_back( Job );
362*b1cdbd2cSJim Jagielski
363*b1cdbd2cSJim Jagielski if ( !mbRegisteredAtDesktop )
364*b1cdbd2cSJim Jagielski {
365*b1cdbd2cSJim Jagielski registerAsListenerAtDesktop();
366*b1cdbd2cSJim Jagielski mbRegisteredAtDesktop = true;
367*b1cdbd2cSJim Jagielski }
368*b1cdbd2cSJim Jagielski }
369*b1cdbd2cSJim Jagielski
releaseJob(const css::uno::Reference<css::util::XCancellable> & Job)370*b1cdbd2cSJim Jagielski void SAL_CALL FinalThreadManager::releaseJob(const css::uno::Reference< css::util::XCancellable > & Job) throw (css::uno::RuntimeException)
371*b1cdbd2cSJim Jagielski {
372*b1cdbd2cSJim Jagielski osl::MutexGuard aGuard(maMutex);
373*b1cdbd2cSJim Jagielski
374*b1cdbd2cSJim Jagielski maThreads.remove( Job );
375*b1cdbd2cSJim Jagielski }
376*b1cdbd2cSJim Jagielski
cancelAllJobs()377*b1cdbd2cSJim Jagielski void SAL_CALL FinalThreadManager::cancelAllJobs() throw (css::uno::RuntimeException)
378*b1cdbd2cSJim Jagielski {
379*b1cdbd2cSJim Jagielski std::list< css::uno::Reference< css::util::XCancellable > > aThreads;
380*b1cdbd2cSJim Jagielski {
381*b1cdbd2cSJim Jagielski osl::MutexGuard aGuard(maMutex);
382*b1cdbd2cSJim Jagielski
383*b1cdbd2cSJim Jagielski aThreads.insert( aThreads.end(), maThreads.begin(), maThreads.end() );
384*b1cdbd2cSJim Jagielski maThreads.clear();
385*b1cdbd2cSJim Jagielski }
386*b1cdbd2cSJim Jagielski
387*b1cdbd2cSJim Jagielski if ( !aThreads.empty() )
388*b1cdbd2cSJim Jagielski {
389*b1cdbd2cSJim Jagielski osl::MutexGuard aGuard(maMutex);
390*b1cdbd2cSJim Jagielski
391*b1cdbd2cSJim Jagielski if ( mpCancelJobsThread == 0 )
392*b1cdbd2cSJim Jagielski {
393*b1cdbd2cSJim Jagielski mpCancelJobsThread = new CancelJobsThread( aThreads );;
394*b1cdbd2cSJim Jagielski if ( !mpCancelJobsThread->create() )
395*b1cdbd2cSJim Jagielski {
396*b1cdbd2cSJim Jagielski // error handling
397*b1cdbd2cSJim Jagielski // ASSERT( false, "<FinalThreadManager::cancelAllJobs()> - thread to cancel jobs can't be setup --> synchron cancellation of jobs" );
398*b1cdbd2cSJim Jagielski delete mpCancelJobsThread;
399*b1cdbd2cSJim Jagielski mpCancelJobsThread = 0;
400*b1cdbd2cSJim Jagielski while ( !aThreads.empty() )
401*b1cdbd2cSJim Jagielski {
402*b1cdbd2cSJim Jagielski aThreads.front()->cancel();
403*b1cdbd2cSJim Jagielski aThreads.pop_front();
404*b1cdbd2cSJim Jagielski }
405*b1cdbd2cSJim Jagielski }
406*b1cdbd2cSJim Jagielski }
407*b1cdbd2cSJim Jagielski else
408*b1cdbd2cSJim Jagielski {
409*b1cdbd2cSJim Jagielski mpCancelJobsThread->addJobs( aThreads );
410*b1cdbd2cSJim Jagielski }
411*b1cdbd2cSJim Jagielski }
412*b1cdbd2cSJim Jagielski }
413*b1cdbd2cSJim Jagielski
414*b1cdbd2cSJim Jagielski // ::com::sun::star::frame::XTerminateListener
queryTermination(const css::lang::EventObject &)415*b1cdbd2cSJim Jagielski void SAL_CALL FinalThreadManager::queryTermination( const css::lang::EventObject& ) throw (css::frame::TerminationVetoException, css::uno::RuntimeException)
416*b1cdbd2cSJim Jagielski {
417*b1cdbd2cSJim Jagielski osl::MutexGuard aGuard(maMutex);
418*b1cdbd2cSJim Jagielski
419*b1cdbd2cSJim Jagielski cancelAllJobs();
420*b1cdbd2cSJim Jagielski // Sleep 1 second to give the thread for job cancellation some time.
421*b1cdbd2cSJim Jagielski // Probably, all started threads have already finished its work.
422*b1cdbd2cSJim Jagielski if ( mpCancelJobsThread != 0 &&
423*b1cdbd2cSJim Jagielski !mpCancelJobsThread->allJobsCancelled() )
424*b1cdbd2cSJim Jagielski {
425*b1cdbd2cSJim Jagielski TimeValue aSleepTime;
426*b1cdbd2cSJim Jagielski aSleepTime.Seconds = 1;
427*b1cdbd2cSJim Jagielski aSleepTime.Nanosec = 0;
428*b1cdbd2cSJim Jagielski osl_waitThread( &aSleepTime );
429*b1cdbd2cSJim Jagielski }
430*b1cdbd2cSJim Jagielski
431*b1cdbd2cSJim Jagielski if ( mpCancelJobsThread != 0 &&
432*b1cdbd2cSJim Jagielski !mpCancelJobsThread->allJobsCancelled() )
433*b1cdbd2cSJim Jagielski {
434*b1cdbd2cSJim Jagielski if ( mpTerminateOfficeThread != 0 )
435*b1cdbd2cSJim Jagielski {
436*b1cdbd2cSJim Jagielski if ( mpTerminateOfficeThread->isRunning() )
437*b1cdbd2cSJim Jagielski {
438*b1cdbd2cSJim Jagielski mpTerminateOfficeThread->StopOfficeTermination(); // thread kills itself.
439*b1cdbd2cSJim Jagielski }
440*b1cdbd2cSJim Jagielski else
441*b1cdbd2cSJim Jagielski {
442*b1cdbd2cSJim Jagielski delete mpTerminateOfficeThread;
443*b1cdbd2cSJim Jagielski }
444*b1cdbd2cSJim Jagielski mpTerminateOfficeThread = 0;
445*b1cdbd2cSJim Jagielski }
446*b1cdbd2cSJim Jagielski mpTerminateOfficeThread = new TerminateOfficeThread( *mpCancelJobsThread,
447*b1cdbd2cSJim Jagielski m_xContext );
448*b1cdbd2cSJim Jagielski if ( !mpTerminateOfficeThread->create() )
449*b1cdbd2cSJim Jagielski {
450*b1cdbd2cSJim Jagielski // ASSERT( false, "FinalThreadManager::queryTermination(..) - thread to terminate office can't be started!" );
451*b1cdbd2cSJim Jagielski delete mpTerminateOfficeThread;
452*b1cdbd2cSJim Jagielski mpTerminateOfficeThread = 0;
453*b1cdbd2cSJim Jagielski }
454*b1cdbd2cSJim Jagielski
455*b1cdbd2cSJim Jagielski throw css::frame::TerminationVetoException();
456*b1cdbd2cSJim Jagielski }
457*b1cdbd2cSJim Jagielski
458*b1cdbd2cSJim Jagielski mpPauseThreadStarting = new SwPauseThreadStarting();
459*b1cdbd2cSJim Jagielski
460*b1cdbd2cSJim Jagielski return;
461*b1cdbd2cSJim Jagielski }
462*b1cdbd2cSJim Jagielski
cancelTermination(const css::lang::EventObject &)463*b1cdbd2cSJim Jagielski void SAL_CALL FinalThreadManager::cancelTermination( const css::lang::EventObject& ) throw (css::uno::RuntimeException)
464*b1cdbd2cSJim Jagielski {
465*b1cdbd2cSJim Jagielski if ( mpPauseThreadStarting != 0 )
466*b1cdbd2cSJim Jagielski {
467*b1cdbd2cSJim Jagielski delete mpPauseThreadStarting;
468*b1cdbd2cSJim Jagielski mpPauseThreadStarting = 0;
469*b1cdbd2cSJim Jagielski }
470*b1cdbd2cSJim Jagielski
471*b1cdbd2cSJim Jagielski return;
472*b1cdbd2cSJim Jagielski }
473*b1cdbd2cSJim Jagielski
notifyTermination(const css::lang::EventObject &)474*b1cdbd2cSJim Jagielski void SAL_CALL FinalThreadManager::notifyTermination( const css::lang::EventObject& ) throw (css::uno::RuntimeException)
475*b1cdbd2cSJim Jagielski {
476*b1cdbd2cSJim Jagielski if ( mpTerminateOfficeThread != 0 )
477*b1cdbd2cSJim Jagielski {
478*b1cdbd2cSJim Jagielski if ( mpTerminateOfficeThread->isRunning() )
479*b1cdbd2cSJim Jagielski {
480*b1cdbd2cSJim Jagielski // ASSERT( false, "<FinalThreadManager::notifyTermination()> - office termination thread still running!" );
481*b1cdbd2cSJim Jagielski mpTerminateOfficeThread->StopOfficeTermination(); // thread kills itself.
482*b1cdbd2cSJim Jagielski }
483*b1cdbd2cSJim Jagielski else
484*b1cdbd2cSJim Jagielski {
485*b1cdbd2cSJim Jagielski delete mpTerminateOfficeThread;
486*b1cdbd2cSJim Jagielski }
487*b1cdbd2cSJim Jagielski mpTerminateOfficeThread = 0;
488*b1cdbd2cSJim Jagielski }
489*b1cdbd2cSJim Jagielski
490*b1cdbd2cSJim Jagielski if ( !maThreads.empty() )
491*b1cdbd2cSJim Jagielski {
492*b1cdbd2cSJim Jagielski // ASSERT( false, "<FinalThreadManager::notifyTermination()> - still registered jobs are existing" );
493*b1cdbd2cSJim Jagielski cancelAllJobs();
494*b1cdbd2cSJim Jagielski }
495*b1cdbd2cSJim Jagielski
496*b1cdbd2cSJim Jagielski if ( mpCancelJobsThread != 0 )
497*b1cdbd2cSJim Jagielski {
498*b1cdbd2cSJim Jagielski if ( !mpCancelJobsThread->allJobsCancelled() )
499*b1cdbd2cSJim Jagielski {
500*b1cdbd2cSJim Jagielski // ASSERT( false, "<FinalThreadManager::notifyTermination()> - cancellation of registered jobs not yet finished -> wait for its finish" );
501*b1cdbd2cSJim Jagielski }
502*b1cdbd2cSJim Jagielski
503*b1cdbd2cSJim Jagielski mpCancelJobsThread->stopWhenAllJobsCancelled();
504*b1cdbd2cSJim Jagielski mpCancelJobsThread->join();
505*b1cdbd2cSJim Jagielski delete mpCancelJobsThread;
506*b1cdbd2cSJim Jagielski mpCancelJobsThread = 0;
507*b1cdbd2cSJim Jagielski }
508*b1cdbd2cSJim Jagielski
509*b1cdbd2cSJim Jagielski // get reference of this
510*b1cdbd2cSJim Jagielski css::uno::Reference< css::uno::XInterface > aOwnRef( static_cast< cppu::OWeakObject* >( this ));
511*b1cdbd2cSJim Jagielski // notify <SwThreadJoiner> to release its reference
512*b1cdbd2cSJim Jagielski SwThreadJoiner::ReleaseThreadJoiner();
513*b1cdbd2cSJim Jagielski }
514*b1cdbd2cSJim Jagielski
515*b1cdbd2cSJim Jagielski // ::com::sun:star::lang::XEventListener (inherited via com::sun::star::frame::XTerminateListener)
disposing(const css::lang::EventObject &)516*b1cdbd2cSJim Jagielski void SAL_CALL FinalThreadManager::disposing( const css::lang::EventObject& ) throw (css::uno::RuntimeException)
517*b1cdbd2cSJim Jagielski {
518*b1cdbd2cSJim Jagielski // nothing to do, because instance doesn't hold any references of observed objects
519*b1cdbd2cSJim Jagielski }
520*b1cdbd2cSJim Jagielski
521*b1cdbd2cSJim Jagielski // component helper namespace
522*b1cdbd2cSJim Jagielski namespace comp_FinalThreadManager {
523*b1cdbd2cSJim Jagielski
_getImplementationName()524*b1cdbd2cSJim Jagielski ::rtl::OUString SAL_CALL _getImplementationName()
525*b1cdbd2cSJim Jagielski {
526*b1cdbd2cSJim Jagielski return ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM(
527*b1cdbd2cSJim Jagielski "com.sun.star.util.comp.FinalThreadManager"));
528*b1cdbd2cSJim Jagielski }
529*b1cdbd2cSJim Jagielski
_getSupportedServiceNames()530*b1cdbd2cSJim Jagielski css::uno::Sequence< ::rtl::OUString > SAL_CALL _getSupportedServiceNames()
531*b1cdbd2cSJim Jagielski {
532*b1cdbd2cSJim Jagielski css::uno::Sequence< ::rtl::OUString > s(1);
533*b1cdbd2cSJim Jagielski s[0] = ::rtl::OUString(RTL_CONSTASCII_USTRINGPARAM(
534*b1cdbd2cSJim Jagielski "com.sun.star.util.JobManager"));
535*b1cdbd2cSJim Jagielski return s;
536*b1cdbd2cSJim Jagielski }
537*b1cdbd2cSJim Jagielski
_create(const css::uno::Reference<css::uno::XComponentContext> & context)538*b1cdbd2cSJim Jagielski css::uno::Reference< css::uno::XInterface > SAL_CALL _create(
539*b1cdbd2cSJim Jagielski const css::uno::Reference< css::uno::XComponentContext > & context)
540*b1cdbd2cSJim Jagielski SAL_THROW((css::uno::Exception))
541*b1cdbd2cSJim Jagielski {
542*b1cdbd2cSJim Jagielski return static_cast< ::cppu::OWeakObject * >(new FinalThreadManager(context));
543*b1cdbd2cSJim Jagielski }
544*b1cdbd2cSJim Jagielski
545*b1cdbd2cSJim Jagielski } // closing component helper namespace
546