ucb/source/ucp/file/filstr.cxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
   2 /*
   3  * This file is part of the LibreOffice project.
   4  *
   5  * This Source Code Form is subject to the terms of the Mozilla Public
   6  * License, v. 2.0. If a copy of the MPL was not distributed with this
   7  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
   8  *
   9  * This file incorporates work covered by the following license notice:
  10  *
  11  *   Licensed to the Apache Software Foundation (ASF) under one or more
  12  *   contributor license agreements. See the NOTICE file distributed
  13  *   with this work for additional information regarding copyright
  14  *   ownership. The ASF licenses this file to you under the Apache
  15  *   License, Version 2.0 (the "License"); you may not use this file
  16  *   except in compliance with the License. You may obtain a copy of
  17  *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
  18  */
  19
  20 #include "com/sun/star/io/IOException.hpp"
  21 #include "com/sun/star/uno/RuntimeException.hpp"
  22 #include "osl/diagnose.h"
  23 #include "filstr.hxx"
  24 #include "shell.hxx"
  25 #include "prov.hxx"
  26 #include <boost/scoped_array.hpp>
  27
  28 using namespace fileaccess;
  29 using namespace com::sun::star;
  30 using namespace com::sun::star::ucb;
  31
  32 #if OSL_DEBUG_LEVEL > 0
  33 #define THROW_WHERE SAL_WHERE
  34 #else
  35 #define THROW_WHERE ""
  36 #endif
  37
  38 /******************************************************************************/
  39 /*                                                                            */
  40 /*               XStream_impl implementation                                  */
  41 /*                                                                            */
  42 /******************************************************************************/
  43
  44 XStream_impl::XStream_impl( shell* pMyShell,const OUString& aUncPath, bool bLock )
  45     : m_bInputStreamCalled( false ),
  46       m_bOutputStreamCalled( false ),
  47       m_pMyShell( pMyShell ),
  48       m_xProvider( m_pMyShell->m_pProvider ),
  49       m_aFile( aUncPath ),
  50       m_nErrorCode( TASKHANDLER_NO_ERROR ),
  51       m_nMinorErrorCode( TASKHANDLER_NO_ERROR )
  52 {
  53     sal_uInt32 nFlags = ( osl_File_OpenFlag_Read | osl_File_OpenFlag_Write );
  54     if ( !bLock )
  55         nFlags |= osl_File_OpenFlag_NoLock;
  56
  57     osl::FileBase::RC err = m_aFile.open( nFlags );
  58     if(  err != osl::FileBase::E_None )
  59     {
  60         m_nIsOpen = false;
  61         m_aFile.close();
  62
  63         m_nErrorCode = TASKHANDLING_OPEN_FOR_STREAM;
  64         m_nMinorErrorCode = err;
  65     }
  66     else
  67         m_nIsOpen = true;
  68 }
  69
  70
  71 XStream_impl::~XStream_impl()
  72 {
  73     try
  74     {
  75         closeStream();
  76     }
  77     catch (const io::IOException&)
  78     {
  79         OSL_FAIL("unexpected situation");
  80     }
  81     catch (const uno::RuntimeException&)
  82     {
  83         OSL_FAIL("unexpected situation");
  84     }
  85 }
  86
  87
  88
  89
  90
  91
  92
  93
  94 uno::Reference< io::XInputStream > SAL_CALL
  95 XStream_impl::getInputStream(  )
  96     throw( uno::RuntimeException, std::exception)
  97 {
  98     {
  99         osl::MutexGuard aGuard( m_aMutex );
 100         m_bInputStreamCalled = true;
 101     }
 102     return uno::Reference< io::XInputStream >( this );
 103 }
 104
 105
 106 uno::Reference< io::XOutputStream > SAL_CALL
 107 XStream_impl::getOutputStream(  )
 108     throw( uno::RuntimeException, std::exception )
 109 {
 110     {
 111         osl::MutexGuard aGuard( m_aMutex );
 112         m_bOutputStreamCalled = true;
 113     }
 114     return uno::Reference< io::XOutputStream >( this );
 115 }
 116
 117
 118 void SAL_CALL XStream_impl::truncate()
 119     throw( io::IOException, uno::RuntimeException, std::exception )
 120 {
 121     if (osl::FileBase::E_None != m_aFile.setSize(0))
 122         throw io::IOException( THROW_WHERE );
 123
 124     if (osl::FileBase::E_None != m_aFile.setPos(osl_Pos_Absolut,sal_uInt64(0)))
 125         throw io::IOException( THROW_WHERE );
 126 }
 127
 128
 129
 130
 131 // XStream_impl private non interface methods
 132
 133
 134 sal_Int32 SAL_CALL
 135 XStream_impl::readBytes(
 136     uno::Sequence< sal_Int8 >& aData,
 137     sal_Int32 nBytesToRead )
 138     throw( io::NotConnectedException,
 139            io::BufferSizeExceededException,
 140            io::IOException,
 141            uno::RuntimeException, std::exception)
 142 {
 143     if( ! m_nIsOpen )
 144         throw io::IOException( THROW_WHERE );
 145
 146     boost::scoped_array<sal_Int8> buffer;
 147     try
 148     {
 149         buffer.reset(new sal_Int8[nBytesToRead]);
 150     }
 151     catch (const std::bad_alloc&)
 152     {
 153         if( m_nIsOpen ) m_aFile.close();
 154         throw io::BufferSizeExceededException( THROW_WHERE );
 155     }
 156
 157     sal_uInt64 nrc(0);
 158     if(m_aFile.read( buffer.get(),sal_uInt64(nBytesToRead),nrc )
 159        != osl::FileBase::E_None)
 160     {
 161         throw io::IOException( THROW_WHERE );
 162     }
 163     aData = uno::Sequence< sal_Int8 > ( buffer.get(), (sal_uInt32)nrc );
 164     return ( sal_Int32 ) nrc;
 165 }
 166
 167
 168 sal_Int32 SAL_CALL
 169 XStream_impl::readSomeBytes(
 170     uno::Sequence< sal_Int8 >& aData,
 171     sal_Int32 nMaxBytesToRead )
 172     throw( io::NotConnectedException,
 173            io::BufferSizeExceededException,
 174            io::IOException,
 175            uno::RuntimeException, std::exception)
 176 {
 177     return readBytes( aData,nMaxBytesToRead );
 178 }
 179
 180
 181 void SAL_CALL
 182 XStream_impl::skipBytes(
 183     sal_Int32 nBytesToSkip )
 184     throw( io::NotConnectedException,
 185            io::BufferSizeExceededException,
 186            io::IOException,
 187            uno::RuntimeException, std::exception )
 188 {
 189     m_aFile.setPos( osl_Pos_Current, sal_uInt64( nBytesToSkip ) );
 190 }
 191
 192
 193 sal_Int32 SAL_CALL
 194 XStream_impl::available(
 195     void )
 196     throw( io::NotConnectedException,
 197            io::IOException,
 198            uno::RuntimeException, std::exception)
 199 {
 200     return 0;
 201 }
 202
 203
 204 void SAL_CALL
 205 XStream_impl::writeBytes( const uno::Sequence< sal_Int8 >& aData )
 206     throw( io::NotConnectedException,
 207            io::BufferSizeExceededException,
 208            io::IOException,
 209            uno::RuntimeException, std::exception)
 210 {
 211     sal_uInt32 length = aData.getLength();
 212     if(length)
 213     {
 214         sal_uInt64 nWrittenBytes(0);
 215         const sal_Int8* p = aData.getConstArray();
 216         if(osl::FileBase::E_None != m_aFile.write(((void*)(p)),sal_uInt64(length),nWrittenBytes) ||
 217            nWrittenBytes != length )
 218             throw io::IOException( THROW_WHERE );
 219     }
 220 }
 221
 222
 223 void SAL_CALL
 224 XStream_impl::closeStream(
 225     void )
 226     throw( io::NotConnectedException,
 227            io::IOException,
 228            uno::RuntimeException )
 229 {
 230     if( m_nIsOpen )
 231     {
 232         osl::FileBase::RC err = m_aFile.close();
 233
 234         if( err != osl::FileBase::E_None ) {
 235             io::IOException ex;
 236             ex.Message = "could not close file";
 237             throw ex;
 238         }
 239
 240         m_nIsOpen = false;
 241     }
 242 }
 243
 244 void SAL_CALL
 245 XStream_impl::closeInput(
 246     void )
 247     throw( io::NotConnectedException,
 248            io::IOException,
 249            uno::RuntimeException, std::exception )
 250 {
 251     osl::MutexGuard aGuard( m_aMutex );
 252     m_bInputStreamCalled = false;
 253
 254     if( ! m_bOutputStreamCalled )
 255         closeStream();
 256 }
 257
 258
 259 void SAL_CALL
 260 XStream_impl::closeOutput(
 261     void )
 262     throw( io::NotConnectedException,
 263            io::IOException,
 264            uno::RuntimeException, std::exception )
 265 {
 266     osl::MutexGuard aGuard( m_aMutex );
 267     m_bOutputStreamCalled = false;
 268
 269     if( ! m_bInputStreamCalled )
 270         closeStream();
 271 }
 272
 273
 274 void SAL_CALL
 275 XStream_impl::seek(
 276     sal_Int64 location )
 277     throw( lang::IllegalArgumentException,
 278            io::IOException,
 279            uno::RuntimeException, std::exception )
 280 {
 281     if( location < 0 )
 282         throw lang::IllegalArgumentException( THROW_WHERE, uno::Reference< uno::XInterface >(), 0 );
 283     if( osl::FileBase::E_None != m_aFile.setPos( osl_Pos_Absolut, sal_uInt64( location ) ) )
 284         throw io::IOException( THROW_WHERE );
 285 }
 286
 287
 288 sal_Int64 SAL_CALL
 289 XStream_impl::getPosition(
 290     void )
 291     throw( io::IOException,
 292            uno::RuntimeException, std::exception )
 293 {
 294     sal_uInt64 uPos;
 295     if( osl::FileBase::E_None != m_aFile.getPos( uPos ) )
 296         throw io::IOException( THROW_WHERE );
 297     return sal_Int64( uPos );
 298 }
 299
 300 sal_Int64 SAL_CALL
 301 XStream_impl::getLength(
 302     void )
 303     throw( io::IOException,
 304            uno::RuntimeException, std::exception )
 305 {
 306         sal_uInt64 uEndPos;
 307         if ( m_aFile.getSize(uEndPos) != osl::FileBase::E_None )
 308                 throw io::IOException( THROW_WHERE );
 309         else
 310                 return sal_Int64( uEndPos );
 311 }
 312
 313 void SAL_CALL
 314 XStream_impl::flush()
 315     throw( io::NotConnectedException,
 316            io::BufferSizeExceededException,
 317            io::IOException,
 318            uno::RuntimeException, std::exception )
 319 {}
 320
 321 void XStream_impl::waitForCompletion()
 322     throw (io::IOException, uno::RuntimeException, std::exception)
 323 {
 324     // At least on UNIX, to reliably learn about any errors encountered by
 325     // asynchronous NFS write operations, without closing the file directly
 326     // afterwards, there appears to be no cheaper way than to call fsync:
 327     if (m_nIsOpen && m_aFile.sync() != osl::FileBase::E_None) {
 328         throw io::IOException(
 329             OUString( "could not synchronize file to disc"),
 330             static_cast< OWeakObject * >(this));
 331     }
 332 }
 333
 334 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */