334 lines
12 KiB
C++
334 lines
12 KiB
C++
/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
|
|
/*************************************************************************
|
|
*
|
|
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
|
|
*
|
|
* Copyright 2000, 2010 Oracle and/or its affiliates.
|
|
*
|
|
* OpenOffice.org - a multi-platform office productivity suite
|
|
*
|
|
* 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.
|
|
*
|
|
************************************************************************/
|
|
|
|
|
|
// must be first
|
|
#include <canvas/debug.hxx>
|
|
#include <tools/diagnose_ex.h>
|
|
#include <canvas/verbosetrace.hxx>
|
|
|
|
#include <comphelper/anytostring.hxx>
|
|
#include <cppuhelper/exc_hlp.hxx>
|
|
|
|
#include <event.hxx>
|
|
#include <eventqueue.hxx>
|
|
#include <slideshowexceptions.hxx>
|
|
|
|
#include <boost/shared_ptr.hpp>
|
|
#include <limits>
|
|
|
|
|
|
using namespace ::com::sun::star;
|
|
|
|
namespace slideshow
|
|
{
|
|
namespace internal
|
|
{
|
|
bool EventQueue::EventEntry::operator<( const EventEntry& rEvent ) const
|
|
{
|
|
// negate comparison, we want priority queue to be sorted
|
|
// in increasing order of activation times
|
|
return this->nTime > rEvent.nTime;
|
|
}
|
|
|
|
|
|
EventQueue::EventQueue(
|
|
boost::shared_ptr<canvas::tools::ElapsedTime> const & pPresTimer )
|
|
: maMutex(),
|
|
maEvents(),
|
|
maNextEvents(),
|
|
maNextNextEvents(),
|
|
mpTimer( pPresTimer )
|
|
{
|
|
}
|
|
|
|
EventQueue::~EventQueue()
|
|
{
|
|
// add in all that have been added explicitly for this round:
|
|
EventEntryVector::const_iterator const iEnd( maNextEvents.end() );
|
|
for ( EventEntryVector::const_iterator iPos( maNextEvents.begin() );
|
|
iPos != iEnd; ++iPos )
|
|
{
|
|
maEvents.push(*iPos);
|
|
}
|
|
EventEntryVector().swap( maNextEvents );
|
|
|
|
// dispose event queue
|
|
while( !maEvents.empty() )
|
|
{
|
|
try
|
|
{
|
|
maEvents.top().pEvent->dispose();
|
|
}
|
|
catch (uno::Exception &)
|
|
{
|
|
OSL_FAIL( rtl::OUStringToOString(
|
|
comphelper::anyToString(
|
|
cppu::getCaughtException() ),
|
|
RTL_TEXTENCODING_UTF8 ).getStr() );
|
|
}
|
|
maEvents.pop();
|
|
}
|
|
}
|
|
|
|
bool EventQueue::addEvent( const EventSharedPtr& rEvent )
|
|
{
|
|
::osl::MutexGuard aGuard( maMutex );
|
|
|
|
#if OSL_DEBUG_LEVEL > 1 && defined (SLIDESHOW_ADD_DESCRIPTIONS_TO_EVENTS)
|
|
OSL_TRACE("adding at %f event [%s] at %x with delay %f\r",
|
|
mpTimer->getElapsedTime(),
|
|
OUStringToOString(rEvent->GetDescription(), RTL_TEXTENCODING_UTF8).getStr(),
|
|
rEvent.get(),
|
|
rEvent->getActivationTime(0.0));
|
|
#endif
|
|
ENSURE_OR_RETURN_FALSE( rEvent,
|
|
"EventQueue::addEvent: event ptr NULL" );
|
|
|
|
// prepare entry
|
|
|
|
// A seemingly obvious optimization cannot be used here,
|
|
// because it breaks assumed order of notification: zero
|
|
// timeout events could be fired() immediately, but that
|
|
// would not unwind the stack and furthermore changes
|
|
// order of notification
|
|
|
|
// add entry
|
|
maEvents.push( EventEntry( rEvent, rEvent->getActivationTime(
|
|
mpTimer->getElapsedTime()) ) );
|
|
return true;
|
|
}
|
|
|
|
bool EventQueue::addEventForNextRound( EventSharedPtr const& rEvent )
|
|
{
|
|
::osl::MutexGuard aGuard( maMutex );
|
|
|
|
#if OSL_DEBUG_LEVEL > 1 && defined (SLIDESHOW_ADD_DESCRIPTIONS_TO_EVENTS)
|
|
OSL_TRACE("adding at %f event [%s] at %x for next round with delay %f\r",
|
|
mpTimer->getElapsedTime(),
|
|
OUStringToOString(rEvent->GetDescription(), RTL_TEXTENCODING_UTF8).getStr(),
|
|
rEvent.get(),
|
|
rEvent->getActivationTime(0.0));
|
|
#endif
|
|
|
|
ENSURE_OR_RETURN_FALSE( rEvent.get() != NULL,
|
|
"EventQueue::addEvent: event ptr NULL" );
|
|
maNextEvents.push_back(
|
|
EventEntry( rEvent, rEvent->getActivationTime(
|
|
mpTimer->getElapsedTime()) ) );
|
|
return true;
|
|
}
|
|
|
|
bool EventQueue::addEventWhenQueueIsEmpty (const EventSharedPtr& rpEvent)
|
|
{
|
|
::osl::MutexGuard aGuard( maMutex );
|
|
|
|
#if OSL_DEBUG_LEVEL > 1 && defined (SLIDESHOW_ADD_DESCRIPTIONS_TO_EVENTS)
|
|
OSL_TRACE("adding at %f event [%s] at %x for execution when queue is empty with delay %f\r",
|
|
mpTimer->getElapsedTime(),
|
|
OUStringToOString(rpEvent->GetDescription(), RTL_TEXTENCODING_UTF8).getStr(),
|
|
rpEvent.get(),
|
|
rpEvent->getActivationTime(0.0));
|
|
#endif
|
|
|
|
ENSURE_OR_RETURN_FALSE(
|
|
rpEvent.get() != NULL,
|
|
"EventQueue::addEvent: event ptr NULL");
|
|
|
|
maNextNextEvents.push(
|
|
EventEntry(
|
|
rpEvent,
|
|
rpEvent->getActivationTime(mpTimer->getElapsedTime())));
|
|
|
|
return true;
|
|
}
|
|
|
|
void EventQueue::forceEmpty()
|
|
{
|
|
::osl::MutexGuard aGuard( maMutex );
|
|
|
|
process_(true);
|
|
}
|
|
|
|
void EventQueue::process()
|
|
{
|
|
::osl::MutexGuard aGuard( maMutex );
|
|
|
|
process_(false);
|
|
}
|
|
|
|
void EventQueue::process_( bool bFireAllEvents )
|
|
{
|
|
VERBOSE_TRACE( "EventQueue: heartbeat" );
|
|
|
|
// add in all that have been added explicitly for this round:
|
|
EventEntryVector::const_iterator const iEnd( maNextEvents.end() );
|
|
for ( EventEntryVector::const_iterator iPos( maNextEvents.begin() );
|
|
iPos != iEnd; ++iPos ) {
|
|
maEvents.push(*iPos);
|
|
}
|
|
EventEntryVector().swap( maNextEvents );
|
|
|
|
// perform topmost, ready-to-execute event
|
|
// =======================================
|
|
|
|
const double nCurrTime( mpTimer->getElapsedTime() );
|
|
|
|
// When maEvents does not contain any events that are due now
|
|
// then process one event from maNextNextEvents.
|
|
if (!maNextNextEvents.empty()
|
|
&& !bFireAllEvents
|
|
&& (maEvents.empty() || maEvents.top().nTime > nCurrTime))
|
|
{
|
|
const EventEntry aEvent (maNextNextEvents.top());
|
|
maNextNextEvents.pop();
|
|
maEvents.push(aEvent);
|
|
}
|
|
|
|
// process ready/elapsed events. Note that the 'perceived'
|
|
// current time remains constant for this loop, thus we're
|
|
// processing only those events which where ready when we
|
|
// entered this method.
|
|
while( !maEvents.empty() &&
|
|
(bFireAllEvents || maEvents.top().nTime <= nCurrTime) )
|
|
{
|
|
EventEntry event( maEvents.top() );
|
|
maEvents.pop();
|
|
|
|
// only process event, if it is still 'charged',
|
|
// i.e. the fire() call effects something. This is
|
|
// used when e.g. having events registered at multiple
|
|
// places, which should fire only once: after the
|
|
// initial fire() call, those events become inactive
|
|
// and return false on isCharged. This frees us from
|
|
// the need to prune queues of those inactive shells.
|
|
if( event.pEvent->isCharged() )
|
|
{
|
|
try
|
|
{
|
|
#if OSL_DEBUG_LEVEL > 0
|
|
VERBOSE_TRACE( "Firing event: unknown (0x%X), timeout was: %f",
|
|
event.pEvent.get(),
|
|
event.pEvent->getActivationTime(0.0) );
|
|
#endif
|
|
#if OSL_DEBUG_LEVEL > 1 && defined (SLIDESHOW_ADD_DESCRIPTIONS_TO_EVENTS)
|
|
OSL_TRACE("firing at %f event [%s] at %x with delay %f\r",
|
|
mpTimer->getElapsedTime(),
|
|
OUStringToOString(event.pEvent->GetDescription(),
|
|
RTL_TEXTENCODING_UTF8).getStr(),
|
|
event.pEvent.get(),
|
|
event.pEvent->getActivationTime(0.0));
|
|
#endif
|
|
|
|
event.pEvent->fire();
|
|
}
|
|
catch( uno::RuntimeException& )
|
|
{
|
|
throw;
|
|
}
|
|
catch( uno::Exception& )
|
|
{
|
|
// catch anything here, we don't want
|
|
// to leave this scope under _any_
|
|
// circumstance. Although, do _not_
|
|
// reinsert an activity that threw
|
|
// once.
|
|
|
|
// NOTE: we explicitly don't catch(...) here,
|
|
// since this will also capture segmentation
|
|
// violations and the like. In such a case, we
|
|
// still better let our clients now...
|
|
OSL_FAIL( rtl::OUStringToOString(
|
|
comphelper::anyToString( cppu::getCaughtException() ),
|
|
RTL_TEXTENCODING_UTF8 ).getStr() );
|
|
}
|
|
catch( SlideShowException& )
|
|
{
|
|
// catch anything here, we don't want
|
|
// to leave this scope under _any_
|
|
// circumstance. Although, do _not_
|
|
// reinsert an activity that threw
|
|
// once.
|
|
|
|
// NOTE: we explicitly don't catch(...) here,
|
|
// since this will also capture segmentation
|
|
// violations and the like. In such a case, we
|
|
// still better let our clients now...
|
|
OSL_TRACE( "::presentation::internal::EventQueue: Event threw a SlideShowException, action might not have been fully performed" );
|
|
}
|
|
}
|
|
else
|
|
{
|
|
#if OSL_DEBUG_LEVEL > 0
|
|
VERBOSE_TRACE( "Ignoring discharged event: unknown (0x%X), timeout was: %f",
|
|
event.pEvent.get(),
|
|
event.pEvent->getActivationTime(0.0) );
|
|
#endif
|
|
}
|
|
}
|
|
}
|
|
|
|
bool EventQueue::isEmpty() const
|
|
{
|
|
::osl::MutexGuard aGuard( maMutex );
|
|
|
|
return maEvents.empty() && maNextEvents.empty() && maNextNextEvents.empty();
|
|
}
|
|
|
|
double EventQueue::nextTimeout() const
|
|
{
|
|
::osl::MutexGuard aGuard( maMutex );
|
|
|
|
// return time for next entry (if any)
|
|
double nTimeout (::std::numeric_limits<double>::max());
|
|
const double nCurrentTime (mpTimer->getElapsedTime());
|
|
if ( ! maEvents.empty())
|
|
nTimeout = maEvents.top().nTime - nCurrentTime;
|
|
if ( ! maNextEvents.empty())
|
|
nTimeout = ::std::min(nTimeout, maNextEvents.front().nTime - nCurrentTime);
|
|
if ( ! maNextNextEvents.empty())
|
|
nTimeout = ::std::min(nTimeout, maNextNextEvents.top().nTime - nCurrentTime);
|
|
|
|
return nTimeout;
|
|
}
|
|
|
|
void EventQueue::clear()
|
|
{
|
|
::osl::MutexGuard aGuard( maMutex );
|
|
|
|
// TODO(P1): Maybe a plain vector and vector.swap will
|
|
// be faster here. Profile.
|
|
maEvents = ImplQueueType();
|
|
|
|
maNextEvents.clear();
|
|
maNextNextEvents = ImplQueueType();
|
|
}
|
|
}
|
|
}
|
|
|
|
/* vim:set shiftwidth=4 softtabstop=4 expandtab: */
|