29da263935
2009-07-03 13:21:25 +0200 cd r273690 : #i102319# Use GetSelectedFiles() instead of GetMPath() to retrieve a set of selected files 2009-07-01 14:27:56 +0200 cd r273582 : #i64800# Use ParseDisplayName correctly and don't allocate memory for an output parameter 2009-07-01 10:47:47 +0200 cd r273553 : #i102701# Make P1 fix for CWS filepicker01, too. 2009-06-29 11:58:09 +0200 cd r273463 : i102319# File picker should NOT set multi selection as a default. 2009-06-29 11:49:10 +0200 cd r273461 : #i102319# Use XFilePicker2 interface to retrieve files from multi selection 2009-06-26 15:42:43 +0200 cd r273423 : #i99759# Release solar mutex before blocking on execute() when using system file picker 2009-06-26 15:35:50 +0200 cd r273422 : #i99759# Don't release solar mutex in shutdown(). Must be done before calling execute() 2009-06-23 11:40:02 +0200 cd r273267 : #i95425# Fixed wrong initialization of TimeValue members 2009-06-23 10:35:20 +0200 cd r273262 : #i99759# Fix deadlock on Windows XP/2000 because of removing Picker Thread from sfx2. Now CAsyncEventNotifierThread releases the solar mutex before blocking 2009-06-22 11:59:15 +0200 cd r273209 : #i102948# Remove links from toolbar object when using lazy delete as the toolbar manager is now destroyed before the toolbar 2009-06-22 11:22:14 +0200 cd r273204 : #i99759# Don't use a new thread to call the file picker. As a consequence this thread is also calling Application::Yield() and therefore is fighting with the main thread for messages 2009-06-22 11:13:32 +0200 cd r273203 : #i99759# Solar mutex must be locked before calling Application::Yield() 2009-06-19 15:23:01 +0200 cd r273161 : #i102948# Remove/add decorated window from/into old/new parent decorated window list 2009-06-19 12:49:37 +0200 cd r273156 : #i101843# Use new COM based dialog implementation from Windows Vista on
231 lines
6.4 KiB
C++
231 lines
6.4 KiB
C++
/*************************************************************************
|
|
*
|
|
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
|
|
*
|
|
* Copyright 2008 by Sun Microsystems, Inc.
|
|
*
|
|
* OpenOffice.org - a multi-platform office productivity suite
|
|
*
|
|
* $RCSfile: asyncrequests.cxx,v $
|
|
* $Revision: 1.4 $
|
|
*
|
|
* This file is part of OpenOffice.org.
|
|
*
|
|
* OpenOffice.org is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU Lesser General Public License version 3
|
|
* only, as published by the Free Software Foundation.
|
|
*
|
|
* OpenOffice.org is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU Lesser General Public License version 3 for more details
|
|
* (a copy is included in the LICENSE file that accompanied this code).
|
|
*
|
|
* You should have received a copy of the GNU Lesser General Public License
|
|
* version 3 along with OpenOffice.org. If not, see
|
|
* <http://www.openoffice.org/license.html>
|
|
* for a copy of the LGPLv3 License.
|
|
*
|
|
************************************************************************/
|
|
|
|
#include "asyncrequests.hxx"
|
|
#include <vcl/svapp.hxx>
|
|
#include <vos/mutex.hxx>
|
|
|
|
//-----------------------------------------------------------------------------
|
|
// namespace
|
|
//-----------------------------------------------------------------------------
|
|
|
|
namespace fpicker{
|
|
namespace win32{
|
|
namespace vista{
|
|
|
|
namespace css = ::com::sun::star;
|
|
|
|
//-----------------------------------------------------------------------------
|
|
void lcl_sleep(::osl::Condition& aCondition ,
|
|
::sal_Int32 nMilliSeconds)
|
|
{
|
|
ULONG nAcquireCount = Application::ReleaseSolarMutex();
|
|
|
|
if (nMilliSeconds < 1)
|
|
aCondition.wait(0);
|
|
else
|
|
{
|
|
TimeValue aTime;
|
|
aTime.Seconds = (nMilliSeconds / 1000);
|
|
aTime.Nanosec = (nMilliSeconds % 1000) * 1000000;
|
|
aCondition.wait(&aTime);
|
|
}
|
|
|
|
Application::AcquireSolarMutex( nAcquireCount );
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
void Request::wait(::sal_Int32 nMilliSeconds)
|
|
{
|
|
lcl_sleep(m_aJoiner, nMilliSeconds);
|
|
}
|
|
|
|
void Request::waitProcessMessages()
|
|
{
|
|
::vos::OGuard aGuard( Application::GetSolarMutex() );
|
|
while (!m_aJoiner.check())
|
|
Application::Yield();
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
void Request::notify()
|
|
{
|
|
m_aJoiner.set();
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
AsyncRequests::AsyncRequests(const RequestHandlerRef& rHandler)
|
|
: ::cppu::BaseMutex( )
|
|
, ::osl::Thread ( )
|
|
, m_bFinish (sal_False)
|
|
, m_rHandler (rHandler )
|
|
, m_lRequests ( )
|
|
{
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
AsyncRequests::~AsyncRequests()
|
|
{
|
|
// SYNCHRONIZED ->
|
|
::osl::ResettableMutexGuard aLock(m_aMutex);
|
|
m_bFinish = sal_True;
|
|
aLock.clear();
|
|
// <- SYNCHRONIZED
|
|
|
|
join();
|
|
}
|
|
|
|
void AsyncRequests::triggerRequestProcessMessages (const RequestRef& rRequest)
|
|
{
|
|
// SYNCHRONIZED ->
|
|
::osl::ResettableMutexGuard aLock(m_aMutex);
|
|
m_lRequests.push(rRequest);
|
|
aLock.clear();
|
|
// <- SYNCHRONIZED
|
|
|
|
if ( ! isRunning())
|
|
create();
|
|
|
|
rRequest->waitProcessMessages();
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
void AsyncRequests::triggerRequestBlocked(const RequestRef& rRequest)
|
|
{
|
|
// SYNCHRONIZED ->
|
|
::osl::ResettableMutexGuard aLock(m_aMutex);
|
|
m_lRequests.push(rRequest);
|
|
aLock.clear();
|
|
// <- SYNCHRONIZED
|
|
|
|
if ( ! isRunning())
|
|
create();
|
|
|
|
rRequest->wait(Request::WAIT_INFINITE);
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
void AsyncRequests::triggerRequestNonBlocked(const RequestRef& rRequest)
|
|
{
|
|
// SYNCHRONIZED ->
|
|
::osl::ResettableMutexGuard aLock(m_aMutex);
|
|
m_lRequests.push(rRequest);
|
|
aLock.clear();
|
|
// <- SYNCHRONIZED
|
|
|
|
if ( ! isRunning())
|
|
create();
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
void AsyncRequests::triggerRequestDirectly(const RequestRef& rRequest)
|
|
{
|
|
// SYNCHRONIZED ->
|
|
::osl::ResettableMutexGuard aLock(m_aMutex);
|
|
RequestHandlerRef rHandler = m_rHandler;
|
|
aLock.clear();
|
|
// <- SYNCHRONIZED
|
|
|
|
if (rHandler != NULL)
|
|
rHandler->doRequest(rRequest);
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
void AsyncRequests::triggerRequestThreadAware(const RequestRef& rRequest,
|
|
::sal_Int16 nWait )
|
|
{
|
|
oslThreadIdentifier nOurThreadId = getIdentifier();
|
|
oslThreadIdentifier nCallerThreadId = ::osl::Thread::getCurrentIdentifier();
|
|
if (nOurThreadId == nCallerThreadId)
|
|
triggerRequestDirectly(rRequest);
|
|
else if (nWait == BLOCKED)
|
|
triggerRequestBlocked(rRequest);
|
|
else if (nWait == PROCESS_MESSAGES)
|
|
triggerRequestProcessMessages(rRequest);
|
|
else
|
|
triggerRequestNonBlocked(rRequest);
|
|
}
|
|
|
|
//-----------------------------------------------------------------------------
|
|
|
|
|
|
//-----------------------------------------------------------------------------
|
|
void SAL_CALL AsyncRequests::run()
|
|
{
|
|
static const ::sal_Int32 TIME_TO_WAIT_FOR_NEW_REQUESTS = 250;
|
|
|
|
// SYNCHRONIZED ->
|
|
::osl::ResettableMutexGuard aLock(m_aMutex);
|
|
RequestHandlerRef rHandler = m_rHandler;
|
|
::sal_Bool bFinished = m_bFinish;
|
|
aLock.clear();
|
|
// <- SYNCHRONIZED
|
|
|
|
if (rHandler != NULL)
|
|
rHandler->before();
|
|
|
|
::osl::Condition aWait;
|
|
|
|
while ( ! bFinished)
|
|
{
|
|
// SYNCHRONIZED ->
|
|
aLock.reset();
|
|
|
|
RequestRef rRequest;
|
|
if ( ! m_lRequests.empty())
|
|
{
|
|
rRequest = m_lRequests.front();
|
|
m_lRequests.pop();
|
|
}
|
|
bFinished = m_bFinish;
|
|
|
|
aLock.clear();
|
|
// <- SYNCHRONIZED
|
|
|
|
if (rRequest == NULL)
|
|
{
|
|
lcl_sleep(aWait, TIME_TO_WAIT_FOR_NEW_REQUESTS);
|
|
continue;
|
|
}
|
|
|
|
if (rHandler != NULL)
|
|
{
|
|
rHandler->doRequest(rRequest);
|
|
rRequest->notify();
|
|
}
|
|
}
|
|
|
|
if (rHandler != NULL)
|
|
rHandler->after();
|
|
}
|
|
|
|
} // namespace vista
|
|
} // namespace win32
|
|
} // namespace fpicker
|