Branch data Line data Source code
1 : : /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
2 : : /*************************************************************************
3 : : *
4 : : * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
5 : : *
6 : : * Copyright 2000, 2010 Oracle and/or its affiliates.
7 : : *
8 : : * OpenOffice.org - a multi-platform office productivity suite
9 : : *
10 : : * This file is part of OpenOffice.org.
11 : : *
12 : : * OpenOffice.org is free software: you can redistribute it and/or modify
13 : : * it under the terms of the GNU Lesser General Public License version 3
14 : : * only, as published by the Free Software Foundation.
15 : : *
16 : : * OpenOffice.org is distributed in the hope that it will be useful,
17 : : * but WITHOUT ANY WARRANTY; without even the implied warranty of
18 : : * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
19 : : * GNU Lesser General Public License version 3 for more details
20 : : * (a copy is included in the LICENSE file that accompanied this code).
21 : : *
22 : : * You should have received a copy of the GNU Lesser General Public License
23 : : * version 3 along with OpenOffice.org. If not, see
24 : : * <http://www.openoffice.org/license.html>
25 : : * for a copy of the LGPLv3 License.
26 : : *
27 : : ************************************************************************/
28 : :
29 : :
30 : : #define THREADEX_IMPLEMENTATION
31 : : #include <vcl/threadex.hxx>
32 : : #include <vcl/svapp.hxx>
33 : :
34 : : using namespace vcl;
35 : :
36 : 0 : SolarThreadExecutor::SolarThreadExecutor()
37 : : :m_nReturn( 0 )
38 : 0 : ,m_bTimeout( false )
39 : : {
40 : 0 : m_aStart = osl_createCondition();
41 : 0 : m_aFinish = osl_createCondition();
42 : 0 : }
43 : :
44 : 0 : SolarThreadExecutor::~SolarThreadExecutor()
45 : : {
46 : 0 : osl_destroyCondition( m_aStart );
47 : 0 : osl_destroyCondition( m_aFinish );
48 [ # # ]: 0 : }
49 : :
50 : 0 : IMPL_LINK_NOARG(SolarThreadExecutor, worker)
51 : : {
52 [ # # ]: 0 : if ( !m_bTimeout )
53 : : {
54 : 0 : osl_setCondition( m_aStart );
55 : 0 : m_nReturn = doIt();
56 : 0 : osl_setCondition( m_aFinish );
57 : : }
58 : 0 : return m_nReturn;
59 : : }
60 : :
61 : 0 : long SolarThreadExecutor::impl_execute( const TimeValue* _pTimeout )
62 : : {
63 [ # # ]: 0 : if( ::osl::Thread::getCurrentIdentifier() == Application::GetMainThreadIdentifier() )
64 : : {
65 : 0 : osl_setCondition( m_aStart );
66 : 0 : m_nReturn = doIt();
67 : 0 : osl_setCondition( m_aFinish );
68 : : }
69 : : else
70 : : {
71 : 0 : osl_resetCondition( m_aStart );
72 : 0 : osl_resetCondition( m_aFinish );
73 : 0 : sal_uLong nSolarMutexCount = Application::ReleaseSolarMutex();
74 [ # # ]: 0 : sal_uLong nEvent = Application::PostUserEvent( LINK( this, SolarThreadExecutor, worker ) );
75 [ # # ]: 0 : if ( osl_cond_result_timeout == osl_waitCondition( m_aStart, _pTimeout ) )
76 : : {
77 : 0 : m_bTimeout = true;
78 : 0 : Application::RemoveUserEvent( nEvent );
79 : : }
80 : : else
81 : 0 : osl_waitCondition( m_aFinish, NULL );
82 [ # # ]: 0 : if( nSolarMutexCount )
83 : 0 : Application::AcquireSolarMutex( nSolarMutexCount );
84 : : }
85 : 0 : return m_nReturn;
86 : : }
87 : :
88 : : /* vim:set shiftwidth=4 softtabstop=4 expandtab: */
|