1*cdf0e10cSrcweir /************************************************************************* 2*cdf0e10cSrcweir * 3*cdf0e10cSrcweir * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. 4*cdf0e10cSrcweir * 5*cdf0e10cSrcweir * Copyright 2000, 2010 Oracle and/or its affiliates. 6*cdf0e10cSrcweir * 7*cdf0e10cSrcweir * OpenOffice.org - a multi-platform office productivity suite 8*cdf0e10cSrcweir * 9*cdf0e10cSrcweir * This file is part of OpenOffice.org. 10*cdf0e10cSrcweir * 11*cdf0e10cSrcweir * OpenOffice.org is free software: you can redistribute it and/or modify 12*cdf0e10cSrcweir * it under the terms of the GNU Lesser General Public License version 3 13*cdf0e10cSrcweir * only, as published by the Free Software Foundation. 14*cdf0e10cSrcweir * 15*cdf0e10cSrcweir * OpenOffice.org is distributed in the hope that it will be useful, 16*cdf0e10cSrcweir * but WITHOUT ANY WARRANTY; without even the implied warranty of 17*cdf0e10cSrcweir * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 18*cdf0e10cSrcweir * GNU Lesser General Public License version 3 for more details 19*cdf0e10cSrcweir * (a copy is included in the LICENSE file that accompanied this code). 20*cdf0e10cSrcweir * 21*cdf0e10cSrcweir * You should have received a copy of the GNU Lesser General Public License 22*cdf0e10cSrcweir * version 3 along with OpenOffice.org. If not, see 23*cdf0e10cSrcweir * <http://www.openoffice.org/license.html> 24*cdf0e10cSrcweir * for a copy of the LGPLv3 License. 25*cdf0e10cSrcweir * 26*cdf0e10cSrcweir ************************************************************************/ 27*cdf0e10cSrcweir 28*cdf0e10cSrcweir #include "asyncrequests.hxx" 29*cdf0e10cSrcweir #include <vcl/svapp.hxx> 30*cdf0e10cSrcweir #include <vos/mutex.hxx> 31*cdf0e10cSrcweir 32*cdf0e10cSrcweir //----------------------------------------------------------------------------- 33*cdf0e10cSrcweir // namespace 34*cdf0e10cSrcweir //----------------------------------------------------------------------------- 35*cdf0e10cSrcweir 36*cdf0e10cSrcweir namespace fpicker{ 37*cdf0e10cSrcweir namespace win32{ 38*cdf0e10cSrcweir namespace vista{ 39*cdf0e10cSrcweir 40*cdf0e10cSrcweir namespace css = ::com::sun::star; 41*cdf0e10cSrcweir 42*cdf0e10cSrcweir //----------------------------------------------------------------------------- 43*cdf0e10cSrcweir void lcl_sleep(::osl::Condition& aCondition , 44*cdf0e10cSrcweir ::sal_Int32 nMilliSeconds) 45*cdf0e10cSrcweir { 46*cdf0e10cSrcweir sal_uLong nAcquireCount = Application::ReleaseSolarMutex(); 47*cdf0e10cSrcweir 48*cdf0e10cSrcweir if (nMilliSeconds < 1) 49*cdf0e10cSrcweir aCondition.wait(0); 50*cdf0e10cSrcweir else 51*cdf0e10cSrcweir { 52*cdf0e10cSrcweir TimeValue aTime; 53*cdf0e10cSrcweir aTime.Seconds = (nMilliSeconds / 1000); 54*cdf0e10cSrcweir aTime.Nanosec = (nMilliSeconds % 1000) * 1000000; 55*cdf0e10cSrcweir aCondition.wait(&aTime); 56*cdf0e10cSrcweir } 57*cdf0e10cSrcweir 58*cdf0e10cSrcweir Application::AcquireSolarMutex( nAcquireCount ); 59*cdf0e10cSrcweir } 60*cdf0e10cSrcweir 61*cdf0e10cSrcweir //----------------------------------------------------------------------------- 62*cdf0e10cSrcweir void Request::wait(::sal_Int32 nMilliSeconds) 63*cdf0e10cSrcweir { 64*cdf0e10cSrcweir lcl_sleep(m_aJoiner, nMilliSeconds); 65*cdf0e10cSrcweir } 66*cdf0e10cSrcweir 67*cdf0e10cSrcweir void Request::waitProcessMessages() 68*cdf0e10cSrcweir { 69*cdf0e10cSrcweir ::vos::OGuard aGuard( Application::GetSolarMutex() ); 70*cdf0e10cSrcweir while (!m_aJoiner.check()) 71*cdf0e10cSrcweir Application::Yield(); 72*cdf0e10cSrcweir } 73*cdf0e10cSrcweir 74*cdf0e10cSrcweir //----------------------------------------------------------------------------- 75*cdf0e10cSrcweir void Request::notify() 76*cdf0e10cSrcweir { 77*cdf0e10cSrcweir m_aJoiner.set(); 78*cdf0e10cSrcweir } 79*cdf0e10cSrcweir 80*cdf0e10cSrcweir //----------------------------------------------------------------------------- 81*cdf0e10cSrcweir AsyncRequests::AsyncRequests(const RequestHandlerRef& rHandler) 82*cdf0e10cSrcweir : ::cppu::BaseMutex( ) 83*cdf0e10cSrcweir , ::osl::Thread ( ) 84*cdf0e10cSrcweir , m_bFinish (sal_False) 85*cdf0e10cSrcweir , m_rHandler (rHandler ) 86*cdf0e10cSrcweir , m_lRequests ( ) 87*cdf0e10cSrcweir { 88*cdf0e10cSrcweir } 89*cdf0e10cSrcweir 90*cdf0e10cSrcweir //----------------------------------------------------------------------------- 91*cdf0e10cSrcweir AsyncRequests::~AsyncRequests() 92*cdf0e10cSrcweir { 93*cdf0e10cSrcweir // SYNCHRONIZED -> 94*cdf0e10cSrcweir ::osl::ResettableMutexGuard aLock(m_aMutex); 95*cdf0e10cSrcweir m_bFinish = sal_True; 96*cdf0e10cSrcweir aLock.clear(); 97*cdf0e10cSrcweir // <- SYNCHRONIZED 98*cdf0e10cSrcweir 99*cdf0e10cSrcweir join(); 100*cdf0e10cSrcweir } 101*cdf0e10cSrcweir 102*cdf0e10cSrcweir void AsyncRequests::triggerRequestProcessMessages (const RequestRef& rRequest) 103*cdf0e10cSrcweir { 104*cdf0e10cSrcweir // SYNCHRONIZED -> 105*cdf0e10cSrcweir ::osl::ResettableMutexGuard aLock(m_aMutex); 106*cdf0e10cSrcweir m_lRequests.push(rRequest); 107*cdf0e10cSrcweir aLock.clear(); 108*cdf0e10cSrcweir // <- SYNCHRONIZED 109*cdf0e10cSrcweir 110*cdf0e10cSrcweir if ( ! isRunning()) 111*cdf0e10cSrcweir create(); 112*cdf0e10cSrcweir 113*cdf0e10cSrcweir rRequest->waitProcessMessages(); 114*cdf0e10cSrcweir } 115*cdf0e10cSrcweir 116*cdf0e10cSrcweir //----------------------------------------------------------------------------- 117*cdf0e10cSrcweir void AsyncRequests::triggerRequestBlocked(const RequestRef& rRequest) 118*cdf0e10cSrcweir { 119*cdf0e10cSrcweir // SYNCHRONIZED -> 120*cdf0e10cSrcweir ::osl::ResettableMutexGuard aLock(m_aMutex); 121*cdf0e10cSrcweir m_lRequests.push(rRequest); 122*cdf0e10cSrcweir aLock.clear(); 123*cdf0e10cSrcweir // <- SYNCHRONIZED 124*cdf0e10cSrcweir 125*cdf0e10cSrcweir if ( ! isRunning()) 126*cdf0e10cSrcweir create(); 127*cdf0e10cSrcweir 128*cdf0e10cSrcweir rRequest->wait(Request::WAIT_INFINITE); 129*cdf0e10cSrcweir } 130*cdf0e10cSrcweir 131*cdf0e10cSrcweir //----------------------------------------------------------------------------- 132*cdf0e10cSrcweir void AsyncRequests::triggerRequestNonBlocked(const RequestRef& rRequest) 133*cdf0e10cSrcweir { 134*cdf0e10cSrcweir // SYNCHRONIZED -> 135*cdf0e10cSrcweir ::osl::ResettableMutexGuard aLock(m_aMutex); 136*cdf0e10cSrcweir m_lRequests.push(rRequest); 137*cdf0e10cSrcweir aLock.clear(); 138*cdf0e10cSrcweir // <- SYNCHRONIZED 139*cdf0e10cSrcweir 140*cdf0e10cSrcweir if ( ! isRunning()) 141*cdf0e10cSrcweir create(); 142*cdf0e10cSrcweir } 143*cdf0e10cSrcweir 144*cdf0e10cSrcweir //----------------------------------------------------------------------------- 145*cdf0e10cSrcweir void AsyncRequests::triggerRequestDirectly(const RequestRef& rRequest) 146*cdf0e10cSrcweir { 147*cdf0e10cSrcweir // SYNCHRONIZED -> 148*cdf0e10cSrcweir ::osl::ResettableMutexGuard aLock(m_aMutex); 149*cdf0e10cSrcweir RequestHandlerRef rHandler = m_rHandler; 150*cdf0e10cSrcweir aLock.clear(); 151*cdf0e10cSrcweir // <- SYNCHRONIZED 152*cdf0e10cSrcweir 153*cdf0e10cSrcweir if (rHandler != NULL) 154*cdf0e10cSrcweir rHandler->doRequest(rRequest); 155*cdf0e10cSrcweir } 156*cdf0e10cSrcweir 157*cdf0e10cSrcweir //----------------------------------------------------------------------------- 158*cdf0e10cSrcweir void AsyncRequests::triggerRequestThreadAware(const RequestRef& rRequest, 159*cdf0e10cSrcweir ::sal_Int16 nWait ) 160*cdf0e10cSrcweir { 161*cdf0e10cSrcweir oslThreadIdentifier nOurThreadId = getIdentifier(); 162*cdf0e10cSrcweir oslThreadIdentifier nCallerThreadId = ::osl::Thread::getCurrentIdentifier(); 163*cdf0e10cSrcweir if (nOurThreadId == nCallerThreadId) 164*cdf0e10cSrcweir triggerRequestDirectly(rRequest); 165*cdf0e10cSrcweir else if (nWait == BLOCKED) 166*cdf0e10cSrcweir triggerRequestBlocked(rRequest); 167*cdf0e10cSrcweir else if (nWait == PROCESS_MESSAGES) 168*cdf0e10cSrcweir triggerRequestProcessMessages(rRequest); 169*cdf0e10cSrcweir else 170*cdf0e10cSrcweir triggerRequestNonBlocked(rRequest); 171*cdf0e10cSrcweir } 172*cdf0e10cSrcweir 173*cdf0e10cSrcweir //----------------------------------------------------------------------------- 174*cdf0e10cSrcweir 175*cdf0e10cSrcweir 176*cdf0e10cSrcweir //----------------------------------------------------------------------------- 177*cdf0e10cSrcweir void SAL_CALL AsyncRequests::run() 178*cdf0e10cSrcweir { 179*cdf0e10cSrcweir static const ::sal_Int32 TIME_TO_WAIT_FOR_NEW_REQUESTS = 250; 180*cdf0e10cSrcweir 181*cdf0e10cSrcweir // SYNCHRONIZED -> 182*cdf0e10cSrcweir ::osl::ResettableMutexGuard aLock(m_aMutex); 183*cdf0e10cSrcweir RequestHandlerRef rHandler = m_rHandler; 184*cdf0e10cSrcweir ::sal_Bool bFinished = m_bFinish; 185*cdf0e10cSrcweir aLock.clear(); 186*cdf0e10cSrcweir // <- SYNCHRONIZED 187*cdf0e10cSrcweir 188*cdf0e10cSrcweir if (rHandler != NULL) 189*cdf0e10cSrcweir rHandler->before(); 190*cdf0e10cSrcweir 191*cdf0e10cSrcweir ::osl::Condition aWait; 192*cdf0e10cSrcweir 193*cdf0e10cSrcweir while ( ! bFinished) 194*cdf0e10cSrcweir { 195*cdf0e10cSrcweir // SYNCHRONIZED -> 196*cdf0e10cSrcweir aLock.reset(); 197*cdf0e10cSrcweir 198*cdf0e10cSrcweir RequestRef rRequest; 199*cdf0e10cSrcweir if ( ! m_lRequests.empty()) 200*cdf0e10cSrcweir { 201*cdf0e10cSrcweir rRequest = m_lRequests.front(); 202*cdf0e10cSrcweir m_lRequests.pop(); 203*cdf0e10cSrcweir } 204*cdf0e10cSrcweir bFinished = m_bFinish; 205*cdf0e10cSrcweir 206*cdf0e10cSrcweir aLock.clear(); 207*cdf0e10cSrcweir // <- SYNCHRONIZED 208*cdf0e10cSrcweir 209*cdf0e10cSrcweir if (rRequest == NULL) 210*cdf0e10cSrcweir { 211*cdf0e10cSrcweir lcl_sleep(aWait, TIME_TO_WAIT_FOR_NEW_REQUESTS); 212*cdf0e10cSrcweir continue; 213*cdf0e10cSrcweir } 214*cdf0e10cSrcweir 215*cdf0e10cSrcweir if (rHandler != NULL) 216*cdf0e10cSrcweir { 217*cdf0e10cSrcweir rHandler->doRequest(rRequest); 218*cdf0e10cSrcweir rRequest->notify(); 219*cdf0e10cSrcweir } 220*cdf0e10cSrcweir } 221*cdf0e10cSrcweir 222*cdf0e10cSrcweir if (rHandler != NULL) 223*cdf0e10cSrcweir rHandler->after(); 224*cdf0e10cSrcweir } 225*cdf0e10cSrcweir 226*cdf0e10cSrcweir } // namespace vista 227*cdf0e10cSrcweir } // namespace win32 228*cdf0e10cSrcweir } // namespace fpicker 229