diff options
author | Kurt Zenker <kz@openoffice.org> | 2003-09-11 09:15:03 +0000 |
---|---|---|
committer | Kurt Zenker <kz@openoffice.org> | 2003-09-11 09:15:03 +0000 |
commit | 40fcf586b7b18af230fbc01a0dc008180ee29f29 (patch) | |
tree | e260c2f9ef24cc98d1d4991abfad59b3046a408d /package | |
parent | 270ad7aa6499d01be881ca32a8f4724d39b4908a (diff) |
INTEGRATION: CWS mav05 (1.1.2); FILE ADDED
2003/07/22 15:00:28 mav 1.1.2.3: #i15929# streams should not use refcounting internally
2003/06/25 07:52:20 mav 1.1.2.2: #i15929# provide properties for substreams
2003/06/23 10:49:24 mav 1.1.2.1: #i15929# new storage implementation
Diffstat (limited to 'package')
-rw-r--r-- | package/source/xstor/oseekinstream.cxx | 209 |
1 files changed, 209 insertions, 0 deletions
diff --git a/package/source/xstor/oseekinstream.cxx b/package/source/xstor/oseekinstream.cxx new file mode 100644 index 000000000000..bf3293827ba7 --- /dev/null +++ b/package/source/xstor/oseekinstream.cxx @@ -0,0 +1,209 @@ +/************************************************************************* + * + * $RCSfile: oseekinstream.cxx,v $ + * + * $Revision: 1.2 $ + * + * last change: $Author: kz $ $Date: 2003-09-11 10:15:03 $ + * + * The Contents of this file are made available subject to the terms of + * either of the following licenses + * + * - GNU Lesser General Public License Version 2.1 + * - Sun Industry Standards Source License Version 1.1 + * + * Sun Microsystems Inc., October, 2000 + * + * GNU Lesser General Public License Version 2.1 + * ============================================= + * Copyright 2000 by Sun Microsystems, Inc. + * 901 San Antonio Road, Palo Alto, CA 94303, USA + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License version 2.1, as published by the Free Software Foundation. + * + * This library 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 for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the Free Software + * Foundation, Inc., 59 Temple Place, Suite 330, Boston, + * MA 02111-1307 USA + * + * + * Sun Industry Standards Source License Version 1.1 + * ================================================= + * The contents of this file are subject to the Sun Industry Standards + * Source License Version 1.1 (the "License"); You may not use this file + * except in compliance with the License. You may obtain a copy of the + * License at http://www.openoffice.org/license.html. + * + * Software provided under this License is provided on an "AS IS" basis, + * WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING, + * WITHOUT LIMITATION, WARRANTIES THAT THE SOFTWARE IS FREE OF DEFECTS, + * MERCHANTABLE, FIT FOR A PARTICULAR PURPOSE, OR NON-INFRINGING. + * See the License for the specific provisions governing your rights and + * obligations concerning the Software. + * + * The Initial Developer of the Original Code is: Sun Microsystems, Inc. + * + * Copyright: 2000 by Sun Microsystems, Inc. + * + * All Rights Reserved. + * + * Contributor(s): _______________________________________ + * + * + ************************************************************************/ + +#ifndef _COM_SUN_STAR_LANG_DISPOSEDEXCEPTION_HPP_ +#include <com/sun/star/lang/DisposedException.hpp> +#endif + +#ifndef _CPPUHELPER_TYPEPROVIDER_HXX_ +#include <cppuhelper/typeprovider.hxx> +#endif + +#ifndef _OSL_DIAGNOSE_H_ +#include <osl/diagnose.h> +#endif + +#include "oseekinstream.hxx" +#include "owriteablestream.hxx" + +using namespace ::com::sun::star; + +OInputSeekStream::OInputSeekStream( OWriteStream_Impl& pImpl, + uno::Reference < io::XStream > xStream, + const uno::Sequence< beans::PropertyValue >& aProps ) +: OInputCompStream( pImpl ) +{ + OSL_ENSURE( xStream.is(), "No stream is provided!\n" ); + + if ( xStream.is() ) + { + m_xStream = xStream->getInputStream(); + m_xSeekable = uno::Reference< io::XSeekable >( xStream, uno::UNO_QUERY ); + + OSL_ENSURE( m_xStream.is(), "No input stream is provided!\n" ); + OSL_ENSURE( m_xSeekable.is(), "No seeking support!\n" ); + } + + m_aProperties = aProps; +} + +OInputSeekStream::OInputSeekStream( OWriteStream_Impl& pImpl, + uno::Reference < io::XInputStream > xStream, + const uno::Sequence< beans::PropertyValue >& aProps ) +: OInputCompStream( pImpl, xStream, aProps ) +{ + if ( m_xStream.is() ) + { + m_xSeekable = uno::Reference< io::XSeekable >( m_xStream, uno::UNO_QUERY ); + OSL_ENSURE( m_xSeekable.is(), "No seeking support!\n" ); + } +} + +OInputSeekStream::~OInputSeekStream() +{ +} + +uno::Sequence< uno::Type > SAL_CALL OInputSeekStream::getTypes() + throw ( uno::RuntimeException ) +{ + static ::cppu::OTypeCollection* pTypeCollection = NULL ; + + if ( pTypeCollection == NULL ) + { + ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() ) ; + + if ( pTypeCollection == NULL ) + { + static ::cppu::OTypeCollection aTypeCollection( + ::getCppuType(( const uno::Reference< io::XSeekable >* )NULL ), + OInputCompStream::getTypes() ); + + pTypeCollection = &aTypeCollection ; + } + } + + return pTypeCollection->getTypes() ; + +} + +uno::Any SAL_CALL OInputSeekStream::queryInterface( const uno::Type& rType ) + throw( uno::RuntimeException ) +{ + // Attention: + // Don't use mutex or guard in this method!!! Is a method of XInterface. + + uno::Any aReturn( ::cppu::queryInterface( rType, + static_cast< io::XSeekable* >( this ) ) ); + + if ( aReturn.hasValue() == sal_True ) + { + return aReturn ; + } + + return OInputCompStream::queryInterface( rType ) ; +} + +void SAL_CALL OInputSeekStream::acquire() + throw() +{ + OInputCompStream::acquire(); +} + +void SAL_CALL OInputSeekStream::release() + throw() +{ + OInputCompStream::release(); +} + + +void SAL_CALL OInputSeekStream::seek( sal_Int64 location ) + throw ( lang::IllegalArgumentException, + io::IOException, + uno::RuntimeException ) +{ + ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() ); + if ( !m_pImpl ) + throw lang::DisposedException(); + + if ( !m_xSeekable.is() ) + throw uno::RuntimeException(); + + m_xSeekable->seek( location ); +} + +sal_Int64 SAL_CALL OInputSeekStream::getPosition() + throw ( io::IOException, + uno::RuntimeException) +{ + ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() ); + if ( !m_pImpl ) + throw lang::DisposedException(); + + if ( !m_xSeekable.is() ) + throw uno::RuntimeException(); + + return m_xSeekable->getPosition(); +} + +sal_Int64 SAL_CALL OInputSeekStream::getLength() + throw ( io::IOException, + uno::RuntimeException ) +{ + ::osl::MutexGuard aGuard( m_rMutexRef->GetMutex() ); + if ( !m_pImpl ) + throw lang::DisposedException(); + + if ( !m_xSeekable.is() ) + throw uno::RuntimeException(); + + return m_xSeekable->getLength(); +} + |