ucb/source/ucp/file/filrec.cxx

   1 /*************************************************************************
   2  *
   3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   4  *
   5  * Copyright 2008 by Sun Microsystems, Inc.
   6  *
   7  * OpenOffice.org - a multi-platform office productivity suite
   8  *
   9  * $RCSfile: filrec.cxx,v $
  10  * $Revision: 1.3.22.1 $
  11  *
  12  * This file is part of OpenOffice.org.
  13  *
  14  * OpenOffice.org is free software: you can redistribute it and/or modify
  15  * it under the terms of the GNU Lesser General Public License version 3
  16  * only, as published by the Free Software Foundation.
  17  *
  18  * OpenOffice.org is distributed in the hope that it will be useful,
  19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21  * GNU Lesser General Public License version 3 for more details
  22  * (a copy is included in the LICENSE file that accompanied this code).
  23  *
  24  * You should have received a copy of the GNU Lesser General Public License
  25  * version 3 along with OpenOffice.org.  If not, see
  26  * <http://www.openoffice.org/license.html>
  27  * for a copy of the LGPLv3 License.
  28  *
  29  ************************************************************************/
  30
  31 // MARKER(update_precomp.py): autogen include statement, do not remove
  32 #include "precompiled_ucb.hxx"
  33
  34 #include "filrec.hxx"
  35
  36 namespace fileaccess {
  37
  38 void ReconnectingFile::disconnect()
  39 {
  40     m_aFile.close();
  41     m_bDisconnect = sal_True;
  42 }
  43
  44 sal_Bool ReconnectingFile::reconnect()
  45 {
  46     sal_Bool bResult = sal_False;
  47     if ( m_bFlagsSet )
  48     {
  49         disconnect();
  50         if ( m_aFile.open( m_nFlags ) == ::osl::FileBase::E_None
  51           || m_aFile.open( OpenFlag_Read ) == ::osl::FileBase::E_None )
  52         {
  53             m_bDisconnect = sal_False;
  54             bResult = sal_True;
  55         }
  56     }
  57
  58     return bResult;
  59 }
  60
  61 ::osl::FileBase::RC ReconnectingFile::open( sal_uInt32 uFlags )
  62 {
  63     ::osl::FileBase::RC nResult = m_aFile.open( uFlags );
  64     if ( nResult == ::osl::FileBase::E_None )
  65     {
  66         if ( uFlags & OpenFlag_Create )
  67             m_nFlags = (uFlags & ( ~OpenFlag_Create )) | OpenFlag_Write;
  68         else
  69             m_nFlags = uFlags;
  70
  71         m_bFlagsSet = sal_True;
  72     }
  73
  74     return nResult;
  75 }
  76
  77 ::osl::FileBase::RC ReconnectingFile::close()
  78 {
  79     m_nFlags = 0;
  80     m_bFlagsSet = sal_False;
  81     m_bDisconnect = sal_False;
  82
  83     return m_aFile.close();
  84 }
  85
  86 ::osl::FileBase::RC ReconnectingFile::setPos( sal_uInt32 uHow, sal_Int64 uPos )
  87 {
  88     ::osl::FileBase::RC nRes = ::osl::FileBase::E_NETWORK;
  89
  90     if ( uHow == Pos_Absolut && uPos > 0 )
  91     {
  92         if ( m_bDisconnect )
  93         {
  94             if ( reconnect() )
  95                 nRes = m_aFile.setPos( uHow, uPos );
  96         }
  97         else
  98         {
  99             // E_INVAL error code means in this case that
 100             // the file handler is invalid
 101             nRes = m_aFile.setPos( uHow, uPos );
 102             if ( ( nRes == ::osl::FileBase::E_NETWORK
 103                 || nRes == ::osl::FileBase::E_INVAL )
 104               && reconnect() )
 105                 nRes = m_aFile.setPos( uHow, uPos );
 106         }
 107     }
 108     else
 109     {
 110         if ( !m_bDisconnect )
 111             nRes = m_aFile.setPos( uHow, uPos );
 112     }
 113
 114     return nRes;
 115 }
 116
 117 ::osl::FileBase::RC ReconnectingFile::getPos( sal_uInt64& uPos )
 118 {
 119     if ( m_bDisconnect )
 120         return ::osl::FileBase::E_NETWORK;
 121
 122     return m_aFile.getPos( uPos );
 123 }
 124
 125 ::osl::FileBase::RC ReconnectingFile::setSize( sal_uInt64 uSize )
 126 {
 127     ::osl::FileBase::RC nRes = ::osl::FileBase::E_NETWORK;
 128
 129     if ( uSize == 0 )
 130     {
 131         if ( m_bDisconnect )
 132         {
 133             if ( reconnect() )
 134                 nRes = m_aFile.setSize( uSize );
 135         }
 136         else
 137         {
 138             // E_INVAL error code means in this case that
 139             // the file handler is invalid
 140             nRes = m_aFile.setSize( uSize );
 141             if ( ( nRes == ::osl::FileBase::E_NETWORK
 142                 || nRes == ::osl::FileBase::E_INVAL )
 143               && reconnect() )
 144                 nRes = m_aFile.setSize( uSize );
 145         }
 146     }
 147     else
 148     {
 149         if ( !m_bDisconnect )
 150             nRes = m_aFile.setSize( uSize );
 151     }
 152
 153     return nRes;
 154 }
 155
 156 ::osl::FileBase::RC ReconnectingFile::getSize( sal_uInt64 &rSize )
 157 {
 158     ::osl::FileBase::RC nRes = ::osl::FileBase::E_NETWORK;
 159
 160     if ( !m_bDisconnect )
 161         nRes = m_aFile.getSize( rSize );
 162
 163     // E_INVAL error code means in this case that
 164     // the file handler is invalid
 165     if ( ( nRes == ::osl::FileBase::E_NETWORK
 166         || nRes == ::osl::FileBase::E_INVAL )
 167       && reconnect() )
 168     {
 169         nRes = m_aFile.getSize( rSize );
 170
 171         // the repairing should be disconnected, since the position might be wrong
 172         // but the result should be retrieved
 173         disconnect();
 174     }
 175
 176     return nRes;
 177 }
 178
 179 ::osl::FileBase::RC ReconnectingFile::read( void *pBuffer, sal_uInt64 uBytesRequested, sal_uInt64& rBytesRead )
 180 {
 181     if ( m_bDisconnect )
 182         return ::osl::FileBase::E_NETWORK;
 183
 184     return m_aFile.read( pBuffer, uBytesRequested, rBytesRead );
 185 }
 186
 187 ::osl::FileBase::RC ReconnectingFile::write(const void *pBuffer, sal_uInt64 uBytesToWrite, sal_uInt64& rBytesWritten)
 188 {
 189     if ( m_bDisconnect )
 190         return ::osl::FileBase::E_NETWORK;
 191
 192     return m_aFile.write( pBuffer, uBytesToWrite, rBytesWritten );
 193 }
 194
 195 ::osl::FileBase::RC ReconnectingFile::sync() const
 196 {
 197     if ( m_bDisconnect )
 198         return ::osl::FileBase::E_NETWORK;
 199
 200     return m_aFile.sync();
 201 }
 202
 203 } // namespace fileaccess
 204