1bfd08df8SAndrew Rist /**************************************************************
2cdf0e10cSrcweir *
3bfd08df8SAndrew Rist * Licensed to the Apache Software Foundation (ASF) under one
4bfd08df8SAndrew Rist * or more contributor license agreements. See the NOTICE file
5bfd08df8SAndrew Rist * distributed with this work for additional information
6bfd08df8SAndrew Rist * regarding copyright ownership. The ASF licenses this file
7bfd08df8SAndrew Rist * to you under the Apache License, Version 2.0 (the
8bfd08df8SAndrew Rist * "License"); you may not use this file except in compliance
9bfd08df8SAndrew Rist * with the License. You may obtain a copy of the License at
10bfd08df8SAndrew Rist *
11bfd08df8SAndrew Rist * http://www.apache.org/licenses/LICENSE-2.0
12bfd08df8SAndrew Rist *
13bfd08df8SAndrew Rist * Unless required by applicable law or agreed to in writing,
14bfd08df8SAndrew Rist * software distributed under the License is distributed on an
15bfd08df8SAndrew Rist * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16bfd08df8SAndrew Rist * KIND, either express or implied. See the License for the
17bfd08df8SAndrew Rist * specific language governing permissions and limitations
18bfd08df8SAndrew Rist * under the License.
19bfd08df8SAndrew Rist *
20bfd08df8SAndrew Rist *************************************************************/
21bfd08df8SAndrew Rist
22bfd08df8SAndrew Rist
23cdf0e10cSrcweir
24cdf0e10cSrcweir // MARKER(update_precomp.py): autogen include statement, do not remove
25cdf0e10cSrcweir #include "precompiled_embeddedobj.hxx"
26cdf0e10cSrcweir
27cdf0e10cSrcweir #include "xexecutor.hxx"
28cdf0e10cSrcweir #include <vcl/svapp.hxx>
29cdf0e10cSrcweir #include <osl/thread.hxx>
30cdf0e10cSrcweir
31cdf0e10cSrcweir using namespace ::com::sun::star;
32cdf0e10cSrcweir
execute()33cdf0e10cSrcweir void MainThreadExecutor_Impl::execute()
34cdf0e10cSrcweir {
35cdf0e10cSrcweir Application::PostUserEvent( LINK( this, MainThreadExecutor_Impl, executor ), NULL );
36cdf0e10cSrcweir }
37cdf0e10cSrcweir
IMPL_LINK(MainThreadExecutor_Impl,executor,void *,pDummyParam)38cdf0e10cSrcweir IMPL_LINK( MainThreadExecutor_Impl, executor, void*, pDummyParam )
39cdf0e10cSrcweir {
40cdf0e10cSrcweir if ( m_xJob.is() )
41cdf0e10cSrcweir {
42cdf0e10cSrcweir try {
43cdf0e10cSrcweir m_xJob->execute( m_aArgs );
44cdf0e10cSrcweir } catch( uno::Exception& ) {}
45cdf0e10cSrcweir }
46cdf0e10cSrcweir
47cdf0e10cSrcweir m_bExecuted = sal_True;
48cdf0e10cSrcweir delete this;
49cdf0e10cSrcweir
50cdf0e10cSrcweir return 0;
51cdf0e10cSrcweir }
52cdf0e10cSrcweir
MainThreadExecutor_Impl(const uno::Reference<task::XJob> & xJob,const uno::Sequence<beans::NamedValue> & aArguments)53cdf0e10cSrcweir MainThreadExecutor_Impl::MainThreadExecutor_Impl( const uno::Reference< task::XJob >& xJob,
54cdf0e10cSrcweir const uno::Sequence< beans::NamedValue >& aArguments )
55cdf0e10cSrcweir : m_xJob( xJob )
56cdf0e10cSrcweir , m_aArgs( aArguments )
57cdf0e10cSrcweir , m_bExecuted( sal_False )
58cdf0e10cSrcweir {
59cdf0e10cSrcweir }
60cdf0e10cSrcweir
61cdf0e10cSrcweir //-------------------------------------------------------------------------
execute(const uno::Sequence<beans::NamedValue> & aArguments)62cdf0e10cSrcweir uno::Any SAL_CALL UNOMainThreadExecutor::execute( const uno::Sequence< beans::NamedValue >& aArguments )
63cdf0e10cSrcweir throw ( lang::IllegalArgumentException,
64cdf0e10cSrcweir uno::Exception,
65cdf0e10cSrcweir uno::RuntimeException )
66cdf0e10cSrcweir {
67cdf0e10cSrcweir uno::Reference< task::XJob > xJob;
68cdf0e10cSrcweir
69cdf0e10cSrcweir if ( aArguments.getLength() > 0 && aArguments[0].Name.equalsAscii( "JobToExecute" ) )
70cdf0e10cSrcweir aArguments[0].Value >>= xJob;
71cdf0e10cSrcweir
72cdf0e10cSrcweir if ( !xJob.is() )
73cdf0e10cSrcweir throw lang::IllegalArgumentException();
74cdf0e10cSrcweir
75cdf0e10cSrcweir uno::Sequence< beans::NamedValue > aArgsForJob;
76cdf0e10cSrcweir if ( aArguments.getLength() > 1 )
77cdf0e10cSrcweir aArgsForJob = uno::Sequence< beans::NamedValue >( aArguments.getConstArray() + 1, aArguments.getLength() - 1 );
78cdf0e10cSrcweir
79cdf0e10cSrcweir MainThreadExecutor_Impl* pExecutor = new MainThreadExecutor_Impl( xJob, aArgsForJob );
80cdf0e10cSrcweir pExecutor->execute();
81cdf0e10cSrcweir
82cdf0e10cSrcweir // it is not a main thread, so it can be blocked
83cdf0e10cSrcweir // while( !pExecutor->isExecuted() )
84cdf0e10cSrcweir // ::osl::Thread::yield();
85cdf0e10cSrcweir
86*07a3d7f1SPedro Giffuni // TODO: implement transferring of the return values and exceptions
87cdf0e10cSrcweir
88cdf0e10cSrcweir return uno::Any();
89cdf0e10cSrcweir }
90cdf0e10cSrcweir
91cdf0e10cSrcweir //-------------------------------------------------------------------------
impl_staticGetSupportedServiceNames()92cdf0e10cSrcweir uno::Sequence< ::rtl::OUString > SAL_CALL UNOMainThreadExecutor::impl_staticGetSupportedServiceNames()
93cdf0e10cSrcweir {
94cdf0e10cSrcweir uno::Sequence< ::rtl::OUString > aRet(1);
95cdf0e10cSrcweir aRet[0] = ::rtl::OUString::createFromAscii( "com.sun.star.comp.thread.MainThreadExecutor" );
96cdf0e10cSrcweir return aRet;
97cdf0e10cSrcweir }
98cdf0e10cSrcweir
99cdf0e10cSrcweir //-------------------------------------------------------------------------
impl_staticGetImplementationName()100cdf0e10cSrcweir ::rtl::OUString SAL_CALL UNOMainThreadExecutor::impl_staticGetImplementationName()
101cdf0e10cSrcweir {
102cdf0e10cSrcweir return ::rtl::OUString::createFromAscii( "com.sun.star.comp.thread.MainThreadExecutor" );
103cdf0e10cSrcweir }
104cdf0e10cSrcweir
105cdf0e10cSrcweir //-------------------------------------------------------------------------
impl_staticCreateSelfInstance(const uno::Reference<lang::XMultiServiceFactory> & xServiceManager)106cdf0e10cSrcweir uno::Reference< uno::XInterface > SAL_CALL UNOMainThreadExecutor::impl_staticCreateSelfInstance(
107cdf0e10cSrcweir const uno::Reference< lang::XMultiServiceFactory >& xServiceManager )
108cdf0e10cSrcweir {
109cdf0e10cSrcweir return uno::Reference< uno::XInterface >( *new UNOMainThreadExecutor( xServiceManager ) );
110cdf0e10cSrcweir }
111cdf0e10cSrcweir
112cdf0e10cSrcweir //-------------------------------------------------------------------------
getImplementationName()113cdf0e10cSrcweir ::rtl::OUString SAL_CALL UNOMainThreadExecutor::getImplementationName()
114cdf0e10cSrcweir throw ( uno::RuntimeException )
115cdf0e10cSrcweir {
116cdf0e10cSrcweir return impl_staticGetImplementationName();
117cdf0e10cSrcweir }
118cdf0e10cSrcweir
119cdf0e10cSrcweir //-------------------------------------------------------------------------
supportsService(const::rtl::OUString & ServiceName)120cdf0e10cSrcweir sal_Bool SAL_CALL UNOMainThreadExecutor::supportsService( const ::rtl::OUString& ServiceName )
121cdf0e10cSrcweir throw ( uno::RuntimeException )
122cdf0e10cSrcweir {
123cdf0e10cSrcweir uno::Sequence< ::rtl::OUString > aSeq = impl_staticGetSupportedServiceNames();
124cdf0e10cSrcweir
125cdf0e10cSrcweir for ( sal_Int32 nInd = 0; nInd < aSeq.getLength(); nInd++ )
126cdf0e10cSrcweir if ( ServiceName.compareTo( aSeq[nInd] ) == 0 )
127cdf0e10cSrcweir return sal_True;
128cdf0e10cSrcweir
129cdf0e10cSrcweir return sal_False;
130cdf0e10cSrcweir }
131cdf0e10cSrcweir
132cdf0e10cSrcweir //-------------------------------------------------------------------------
getSupportedServiceNames()133cdf0e10cSrcweir uno::Sequence< ::rtl::OUString > SAL_CALL UNOMainThreadExecutor::getSupportedServiceNames()
134cdf0e10cSrcweir throw ( uno::RuntimeException )
135cdf0e10cSrcweir {
136cdf0e10cSrcweir return impl_staticGetSupportedServiceNames();
137cdf0e10cSrcweir }
138cdf0e10cSrcweir
139