350 lines
10 KiB
C++
350 lines
10 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.
|
|
*
|
|
************************************************************************/
|
|
|
|
#include "sal/config.h"
|
|
|
|
#include <cassert>
|
|
#include <vector>
|
|
|
|
#include "com/sun/star/lang/DisposedException.hpp"
|
|
#include "com/sun/star/lang/EventObject.hpp"
|
|
#include "com/sun/star/lang/WrappedTargetException.hpp"
|
|
#include "com/sun/star/uno/Any.hxx"
|
|
#include "com/sun/star/uno/Reference.hxx"
|
|
#include "com/sun/star/uno/RuntimeException.hpp"
|
|
#include "com/sun/star/uno/Type.hxx"
|
|
#include "com/sun/star/uno/XInterface.hpp"
|
|
#include "com/sun/star/util/ChangesEvent.hpp"
|
|
#include "com/sun/star/util/ChangesSet.hpp"
|
|
#include "com/sun/star/util/ElementChange.hpp"
|
|
#include "com/sun/star/util/XChangesBatch.hpp"
|
|
#include "com/sun/star/util/XChangesListener.hpp"
|
|
#include "com/sun/star/util/XChangesNotifier.hpp"
|
|
#include "comphelper/sequenceasvector.hxx"
|
|
#include "cppu/unotype.hxx"
|
|
#include "cppuhelper/queryinterface.hxx"
|
|
#include "cppuhelper/weak.hxx"
|
|
#include "osl/mutex.hxx"
|
|
#include "rtl/ref.hxx"
|
|
#include "rtl/ustring.h"
|
|
#include "rtl/ustring.hxx"
|
|
|
|
#include "broadcaster.hxx"
|
|
#include "childaccess.hxx"
|
|
#include "components.hxx"
|
|
#include "data.hxx"
|
|
#include "lock.hxx"
|
|
#include "modifications.hxx"
|
|
#include "node.hxx"
|
|
#include "path.hxx"
|
|
#include "rootaccess.hxx"
|
|
|
|
namespace configmgr {
|
|
|
|
namespace {
|
|
|
|
namespace css = com::sun::star;
|
|
|
|
}
|
|
|
|
RootAccess::RootAccess(
|
|
Components & components, rtl::OUString const & pathRepresentation,
|
|
rtl::OUString const & locale, bool update):
|
|
Access(components), pathRepresentation_(pathRepresentation),
|
|
locale_(locale), update_(update), finalized_(false), alive_(true)
|
|
{
|
|
lock_ = lock();
|
|
}
|
|
|
|
Path RootAccess::getAbsolutePath() {
|
|
getNode();
|
|
return path_;
|
|
}
|
|
|
|
void RootAccess::initBroadcaster(
|
|
Modifications::Node const & modifications, Broadcaster * broadcaster)
|
|
{
|
|
assert(broadcaster != 0);
|
|
comphelper::SequenceAsVector< css::util::ElementChange > changes;
|
|
initBroadcasterAndChanges(
|
|
modifications, broadcaster, changesListeners_.empty() ? 0 : &changes);
|
|
if (!changes.empty()) {
|
|
css::util::ChangesSet set(changes.getAsConstList());
|
|
for (ChangesListeners::iterator i(changesListeners_.begin());
|
|
i != changesListeners_.end(); ++i)
|
|
{
|
|
cppu::OWeakObject* pSource = static_cast< cppu::OWeakObject * >(this);
|
|
css::uno::Reference< css::uno::XInterface > xBase( pSource, css::uno::UNO_QUERY );
|
|
broadcaster->addChangesNotification(
|
|
*i,
|
|
css::util::ChangesEvent(
|
|
pSource, makeAny( xBase ), set));
|
|
}
|
|
}
|
|
}
|
|
|
|
void RootAccess::acquire() throw () {
|
|
Access::acquire();
|
|
}
|
|
|
|
void RootAccess::release() throw () {
|
|
Access::release();
|
|
}
|
|
|
|
rtl::OUString RootAccess::getAbsolutePathRepresentation() {
|
|
getNode(); // turn pathRepresentation_ into canonic form
|
|
return pathRepresentation_;
|
|
}
|
|
|
|
rtl::OUString RootAccess::getLocale() const {
|
|
return locale_;
|
|
}
|
|
|
|
bool RootAccess::isUpdate() const {
|
|
return update_;
|
|
}
|
|
|
|
void RootAccess::setAlive(bool b) {
|
|
alive_ = b;
|
|
}
|
|
|
|
RootAccess::~RootAccess()
|
|
{
|
|
osl::MutexGuard g(*lock_);
|
|
if (alive_)
|
|
getComponents().removeRootAccess(this);
|
|
}
|
|
|
|
Path RootAccess::getRelativePath() {
|
|
return Path();
|
|
}
|
|
|
|
rtl::OUString RootAccess::getRelativePathRepresentation() {
|
|
return rtl::OUString();
|
|
}
|
|
|
|
rtl::Reference< Node > RootAccess::getNode() {
|
|
if (!node_.is()) {
|
|
rtl::OUString canonic;
|
|
int finalizedLayer;
|
|
node_ = getComponents().resolvePathRepresentation(
|
|
pathRepresentation_, &canonic, &path_, &finalizedLayer);
|
|
if (!node_.is()) {
|
|
throw css::uno::RuntimeException(
|
|
(rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("cannot find ")) +
|
|
pathRepresentation_),
|
|
0);
|
|
// RootAccess::queryInterface indirectly calls
|
|
// RootAccess::getNode, so if this RootAccess were passed out in
|
|
// RuntimeException.Context, client code that called
|
|
// queryInterface on it would cause trouble; therefore,
|
|
// RuntimeException.Context is left null here
|
|
}
|
|
pathRepresentation_ = canonic;
|
|
assert(!path_.empty());
|
|
name_ = path_.back();
|
|
finalized_ = finalizedLayer != Data::NO_LAYER;
|
|
}
|
|
return node_;
|
|
}
|
|
|
|
bool RootAccess::isFinalized() {
|
|
getNode();
|
|
return finalized_;
|
|
}
|
|
|
|
rtl::OUString RootAccess::getNameInternal() {
|
|
getNode();
|
|
return name_;
|
|
}
|
|
|
|
rtl::Reference< RootAccess > RootAccess::getRootAccess() {
|
|
return this;
|
|
}
|
|
|
|
rtl::Reference< Access > RootAccess::getParentAccess() {
|
|
return rtl::Reference< Access >();
|
|
}
|
|
|
|
void RootAccess::addTypes(std::vector< css::uno::Type > * types) const {
|
|
assert(types != 0);
|
|
types->push_back(cppu::UnoType< css::util::XChangesNotifier >::get());
|
|
types->push_back(cppu::UnoType< css::util::XChangesBatch >::get());
|
|
}
|
|
|
|
void RootAccess::addSupportedServiceNames(
|
|
std::vector< rtl::OUString > * services)
|
|
{
|
|
assert(services != 0);
|
|
services->push_back(
|
|
rtl::OUString(
|
|
RTL_CONSTASCII_USTRINGPARAM(
|
|
"com.sun.star.configuration.AccessRootElement")));
|
|
if (update_) {
|
|
services->push_back(
|
|
rtl::OUString(
|
|
RTL_CONSTASCII_USTRINGPARAM(
|
|
"com.sun.star.configuration.UpdateRootElement")));
|
|
}
|
|
}
|
|
|
|
void RootAccess::initDisposeBroadcaster(Broadcaster * broadcaster) {
|
|
assert(broadcaster != 0);
|
|
for (ChangesListeners::iterator i(changesListeners_.begin());
|
|
i != changesListeners_.end(); ++i)
|
|
{
|
|
broadcaster->addDisposeNotification(
|
|
i->get(),
|
|
css::lang::EventObject(static_cast< cppu::OWeakObject * >(this)));
|
|
}
|
|
Access::initDisposeBroadcaster(broadcaster);
|
|
}
|
|
|
|
void RootAccess::clearListeners() throw() {
|
|
changesListeners_.clear();
|
|
Access::clearListeners();
|
|
}
|
|
|
|
css::uno::Any RootAccess::queryInterface(css::uno::Type const & aType)
|
|
throw (css::uno::RuntimeException)
|
|
{
|
|
assert(thisIs(IS_ANY));
|
|
osl::MutexGuard g(*lock_);
|
|
checkLocalizedPropertyAccess();
|
|
css::uno::Any res(Access::queryInterface(aType));
|
|
if (res.hasValue()) {
|
|
return res;
|
|
}
|
|
res = cppu::queryInterface(
|
|
aType, static_cast< css::util::XChangesNotifier * >(this));
|
|
if (res.hasValue()) {
|
|
return res;
|
|
}
|
|
if (!res.hasValue() && update_) {
|
|
res = cppu::queryInterface(
|
|
aType, static_cast< css::util::XChangesBatch * >(this));
|
|
}
|
|
return res;
|
|
}
|
|
|
|
void RootAccess::addChangesListener(
|
|
css::uno::Reference< css::util::XChangesListener > const & aListener)
|
|
throw (css::uno::RuntimeException)
|
|
{
|
|
assert(thisIs(IS_ANY));
|
|
{
|
|
osl::MutexGuard g(*lock_);
|
|
checkLocalizedPropertyAccess();
|
|
if (!aListener.is()) {
|
|
throw css::uno::RuntimeException(
|
|
rtl::OUString(RTL_CONSTASCII_USTRINGPARAM("null listener")),
|
|
static_cast< cppu::OWeakObject * >(this));
|
|
}
|
|
if (!isDisposed()) {
|
|
changesListeners_.insert(aListener);
|
|
return;
|
|
}
|
|
}
|
|
try {
|
|
aListener->disposing(
|
|
css::lang::EventObject(static_cast< cppu::OWeakObject * >(this)));
|
|
} catch (css::lang::DisposedException &) {}
|
|
}
|
|
|
|
void RootAccess::removeChangesListener(
|
|
css::uno::Reference< css::util::XChangesListener > const & aListener)
|
|
throw (css::uno::RuntimeException)
|
|
{
|
|
assert(thisIs(IS_ANY));
|
|
osl::MutexGuard g(*lock_);
|
|
checkLocalizedPropertyAccess();
|
|
ChangesListeners::iterator i(changesListeners_.find(aListener));
|
|
if (i != changesListeners_.end()) {
|
|
changesListeners_.erase(i);
|
|
}
|
|
}
|
|
|
|
void RootAccess::commitChanges()
|
|
throw (css::lang::WrappedTargetException, css::uno::RuntimeException)
|
|
{
|
|
assert(thisIs(IS_UPDATE));
|
|
if (!alive_)
|
|
{
|
|
return;
|
|
}
|
|
Broadcaster bc;
|
|
{
|
|
osl::MutexGuard g(*lock_);
|
|
|
|
checkLocalizedPropertyAccess();
|
|
int finalizedLayer;
|
|
Modifications globalMods;
|
|
commitChildChanges(
|
|
((getComponents().resolvePathRepresentation(
|
|
pathRepresentation_, 0, 0, &finalizedLayer)
|
|
== node_) &&
|
|
finalizedLayer == Data::NO_LAYER),
|
|
&globalMods);
|
|
getComponents().writeModifications();
|
|
getComponents().initGlobalBroadcaster(globalMods, this, &bc);
|
|
}
|
|
bc.send();
|
|
}
|
|
|
|
sal_Bool RootAccess::hasPendingChanges() throw (css::uno::RuntimeException) {
|
|
assert(thisIs(IS_UPDATE));
|
|
osl::MutexGuard g(*lock_);
|
|
checkLocalizedPropertyAccess();
|
|
//TODO: Optimize:
|
|
std::vector< css::util::ElementChange > changes;
|
|
reportChildChanges(&changes);
|
|
return !changes.empty();
|
|
}
|
|
|
|
css::util::ChangesSet RootAccess::getPendingChanges()
|
|
throw (css::uno::RuntimeException)
|
|
{
|
|
assert(thisIs(IS_UPDATE));
|
|
osl::MutexGuard g(*lock_);
|
|
checkLocalizedPropertyAccess();
|
|
comphelper::SequenceAsVector< css::util::ElementChange > changes;
|
|
reportChildChanges(&changes);
|
|
return changes.getAsConstList();
|
|
}
|
|
|
|
rtl::OUString RootAccess::getImplementationName() throw (css::uno::RuntimeException)
|
|
{
|
|
assert(thisIs(IS_ANY));
|
|
osl::MutexGuard g(*lock_);
|
|
checkLocalizedPropertyAccess();
|
|
return rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( "configmgr.RootAccess" ) );
|
|
}
|
|
|
|
}
|
|
|
|
/* vim:set shiftwidth=4 softtabstop=4 expandtab: */
|