1*cdf0e10cSrcweir /************************************************************************* 2*cdf0e10cSrcweir * 3*cdf0e10cSrcweir * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. 4*cdf0e10cSrcweir * 5*cdf0e10cSrcweir * Copyright 2000, 2010 Oracle and/or its affiliates. 6*cdf0e10cSrcweir * 7*cdf0e10cSrcweir * OpenOffice.org - a multi-platform office productivity suite 8*cdf0e10cSrcweir * 9*cdf0e10cSrcweir * This file is part of OpenOffice.org. 10*cdf0e10cSrcweir * 11*cdf0e10cSrcweir * OpenOffice.org is free software: you can redistribute it and/or modify 12*cdf0e10cSrcweir * it under the terms of the GNU Lesser General Public License version 3 13*cdf0e10cSrcweir * only, as published by the Free Software Foundation. 14*cdf0e10cSrcweir * 15*cdf0e10cSrcweir * OpenOffice.org is distributed in the hope that it will be useful, 16*cdf0e10cSrcweir * but WITHOUT ANY WARRANTY; without even the implied warranty of 17*cdf0e10cSrcweir * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 18*cdf0e10cSrcweir * GNU Lesser General Public License version 3 for more details 19*cdf0e10cSrcweir * (a copy is included in the LICENSE file that accompanied this code). 20*cdf0e10cSrcweir * 21*cdf0e10cSrcweir * You should have received a copy of the GNU Lesser General Public License 22*cdf0e10cSrcweir * version 3 along with OpenOffice.org. If not, see 23*cdf0e10cSrcweir * <http://www.openoffice.org/license.html> 24*cdf0e10cSrcweir * for a copy of the LGPLv3 License. 25*cdf0e10cSrcweir * 26*cdf0e10cSrcweir ************************************************************************/ 27*cdf0e10cSrcweir 28*cdf0e10cSrcweir // no include "precompiled_tools.hxx" because this file is included in strmsys.cxx 29*cdf0e10cSrcweir 30*cdf0e10cSrcweir #include <stdio.h> 31*cdf0e10cSrcweir #include <string.h> 32*cdf0e10cSrcweir #include <sys/stat.h> 33*cdf0e10cSrcweir #include <fcntl.h> 34*cdf0e10cSrcweir #include <errno.h> 35*cdf0e10cSrcweir #include <unistd.h> 36*cdf0e10cSrcweir #include <limits.h> 37*cdf0e10cSrcweir #include <stdlib.h> // fuer getenv() 38*cdf0e10cSrcweir 39*cdf0e10cSrcweir #include <tools/debug.hxx> 40*cdf0e10cSrcweir #include <tools/fsys.hxx> 41*cdf0e10cSrcweir #include <tools/stream.hxx> 42*cdf0e10cSrcweir 43*cdf0e10cSrcweir #include <vos/mutex.hxx> 44*cdf0e10cSrcweir #include <osl/thread.h> // osl_getThreadTextEncoding 45*cdf0e10cSrcweir 46*cdf0e10cSrcweir // class FileBase 47*cdf0e10cSrcweir #include <osl/file.hxx> 48*cdf0e10cSrcweir #include <rtl/instance.hxx> 49*cdf0e10cSrcweir 50*cdf0e10cSrcweir using namespace osl; 51*cdf0e10cSrcweir 52*cdf0e10cSrcweir // ----------------------------------------------------------------------- 53*cdf0e10cSrcweir 54*cdf0e10cSrcweir // ---------------- 55*cdf0e10cSrcweir // - InternalLock - 56*cdf0e10cSrcweir // ---------------- 57*cdf0e10cSrcweir 58*cdf0e10cSrcweir class InternalStreamLock; 59*cdf0e10cSrcweir DECLARE_LIST( InternalStreamLockList, InternalStreamLock* ) 60*cdf0e10cSrcweir namespace { struct LockList : public rtl::Static< InternalStreamLockList, LockList > {}; } 61*cdf0e10cSrcweir 62*cdf0e10cSrcweir #ifndef BOOTSTRAP 63*cdf0e10cSrcweir namespace { struct LockMutex : public rtl::Static< vos::OMutex, LockMutex > {}; } 64*cdf0e10cSrcweir #endif 65*cdf0e10cSrcweir 66*cdf0e10cSrcweir class InternalStreamLock 67*cdf0e10cSrcweir { 68*cdf0e10cSrcweir sal_Size m_nStartPos; 69*cdf0e10cSrcweir sal_Size m_nEndPos; 70*cdf0e10cSrcweir SvFileStream* m_pStream; 71*cdf0e10cSrcweir struct stat m_aStat; 72*cdf0e10cSrcweir 73*cdf0e10cSrcweir InternalStreamLock( sal_Size, sal_Size, SvFileStream* ); 74*cdf0e10cSrcweir ~InternalStreamLock(); 75*cdf0e10cSrcweir public: 76*cdf0e10cSrcweir static sal_Bool LockFile( sal_Size nStart, sal_Size nEnd, SvFileStream* ); 77*cdf0e10cSrcweir static void UnlockFile( sal_Size nStart, sal_Size nEnd, SvFileStream* ); 78*cdf0e10cSrcweir }; 79*cdf0e10cSrcweir 80*cdf0e10cSrcweir InternalStreamLock::InternalStreamLock( 81*cdf0e10cSrcweir sal_Size nStart, 82*cdf0e10cSrcweir sal_Size nEnd, 83*cdf0e10cSrcweir SvFileStream* pStream ) : 84*cdf0e10cSrcweir m_nStartPos( nStart ), 85*cdf0e10cSrcweir m_nEndPos( nEnd ), 86*cdf0e10cSrcweir m_pStream( pStream ) 87*cdf0e10cSrcweir { 88*cdf0e10cSrcweir ByteString aFileName(m_pStream->GetFileName(), osl_getThreadTextEncoding()); 89*cdf0e10cSrcweir stat( aFileName.GetBuffer(), &m_aStat ); 90*cdf0e10cSrcweir LockList::get().Insert( this, LIST_APPEND ); 91*cdf0e10cSrcweir #if OSL_DEBUG_LEVEL > 1 92*cdf0e10cSrcweir fprintf( stderr, "locked %s", aFileName.GetBuffer() ); 93*cdf0e10cSrcweir if( m_nStartPos || m_nEndPos ) 94*cdf0e10cSrcweir fprintf(stderr, " [ %ld ... %ld ]", m_nStartPos, m_nEndPos ); 95*cdf0e10cSrcweir fprintf( stderr, "\n" ); 96*cdf0e10cSrcweir #endif 97*cdf0e10cSrcweir } 98*cdf0e10cSrcweir 99*cdf0e10cSrcweir InternalStreamLock::~InternalStreamLock() 100*cdf0e10cSrcweir { 101*cdf0e10cSrcweir LockList::get().Remove( this ); 102*cdf0e10cSrcweir #if OSL_DEBUG_LEVEL > 1 103*cdf0e10cSrcweir ByteString aFileName(m_pStream->GetFileName(), osl_getThreadTextEncoding()); 104*cdf0e10cSrcweir fprintf( stderr, "unlocked %s", aFileName.GetBuffer() ); 105*cdf0e10cSrcweir if( m_nStartPos || m_nEndPos ) 106*cdf0e10cSrcweir fprintf(stderr, " [ %ld ... %ld ]", m_nStartPos, m_nEndPos ); 107*cdf0e10cSrcweir fprintf( stderr, "\n" ); 108*cdf0e10cSrcweir #endif 109*cdf0e10cSrcweir } 110*cdf0e10cSrcweir 111*cdf0e10cSrcweir sal_Bool InternalStreamLock::LockFile( sal_Size nStart, sal_Size nEnd, SvFileStream* pStream ) 112*cdf0e10cSrcweir { 113*cdf0e10cSrcweir #ifndef BOOTSTRAP 114*cdf0e10cSrcweir vos:: OGuard aGuard( LockMutex::get() ); 115*cdf0e10cSrcweir #endif 116*cdf0e10cSrcweir ByteString aFileName(pStream->GetFileName(), osl_getThreadTextEncoding()); 117*cdf0e10cSrcweir struct stat aStat; 118*cdf0e10cSrcweir if( stat( aFileName.GetBuffer(), &aStat ) ) 119*cdf0e10cSrcweir return sal_False; 120*cdf0e10cSrcweir 121*cdf0e10cSrcweir if( S_ISDIR( aStat.st_mode ) ) 122*cdf0e10cSrcweir return sal_True; 123*cdf0e10cSrcweir 124*cdf0e10cSrcweir InternalStreamLock* pLock = NULL; 125*cdf0e10cSrcweir InternalStreamLockList &rLockList = LockList::get(); 126*cdf0e10cSrcweir for( sal_uIntPtr i = 0; i < rLockList.Count(); ++i ) 127*cdf0e10cSrcweir { 128*cdf0e10cSrcweir pLock = rLockList.GetObject( i ); 129*cdf0e10cSrcweir if( aStat.st_ino == pLock->m_aStat.st_ino ) 130*cdf0e10cSrcweir { 131*cdf0e10cSrcweir sal_Bool bDenyByOptions = sal_False; 132*cdf0e10cSrcweir StreamMode nLockMode = pLock->m_pStream->GetStreamMode(); 133*cdf0e10cSrcweir StreamMode nNewMode = pStream->GetStreamMode(); 134*cdf0e10cSrcweir 135*cdf0e10cSrcweir if( nLockMode & STREAM_SHARE_DENYALL ) 136*cdf0e10cSrcweir bDenyByOptions = sal_True; 137*cdf0e10cSrcweir else if( ( nLockMode & STREAM_SHARE_DENYWRITE ) && 138*cdf0e10cSrcweir ( nNewMode & STREAM_WRITE ) ) 139*cdf0e10cSrcweir bDenyByOptions = sal_True; 140*cdf0e10cSrcweir else if( ( nLockMode & STREAM_SHARE_DENYREAD ) && 141*cdf0e10cSrcweir ( nNewMode & STREAM_READ ) ) 142*cdf0e10cSrcweir bDenyByOptions = sal_True; 143*cdf0e10cSrcweir 144*cdf0e10cSrcweir if( bDenyByOptions ) 145*cdf0e10cSrcweir { 146*cdf0e10cSrcweir if( pLock->m_nStartPos == 0 && pLock->m_nEndPos == 0 ) // whole file is already locked 147*cdf0e10cSrcweir return sal_False; 148*cdf0e10cSrcweir if( nStart == 0 && nEnd == 0) // cannot lock whole file 149*cdf0e10cSrcweir return sal_False; 150*cdf0e10cSrcweir 151*cdf0e10cSrcweir if( ( nStart < pLock->m_nStartPos && nEnd > pLock->m_nStartPos ) || 152*cdf0e10cSrcweir ( nStart < pLock->m_nEndPos && nEnd > pLock->m_nEndPos ) ) 153*cdf0e10cSrcweir return sal_False; 154*cdf0e10cSrcweir } 155*cdf0e10cSrcweir } 156*cdf0e10cSrcweir } 157*cdf0e10cSrcweir pLock = new InternalStreamLock( nStart, nEnd, pStream ); 158*cdf0e10cSrcweir return sal_True; 159*cdf0e10cSrcweir } 160*cdf0e10cSrcweir 161*cdf0e10cSrcweir void InternalStreamLock::UnlockFile( sal_Size nStart, sal_Size nEnd, SvFileStream* pStream ) 162*cdf0e10cSrcweir { 163*cdf0e10cSrcweir #ifndef BOOTSTRAP 164*cdf0e10cSrcweir vos:: OGuard aGuard( LockMutex::get() ); 165*cdf0e10cSrcweir #endif 166*cdf0e10cSrcweir InternalStreamLock* pLock = NULL; 167*cdf0e10cSrcweir InternalStreamLockList &rLockList = LockList::get(); 168*cdf0e10cSrcweir if( nStart == 0 && nEnd == 0 ) 169*cdf0e10cSrcweir { 170*cdf0e10cSrcweir for( sal_uIntPtr i = 0; i < rLockList.Count(); ++i ) 171*cdf0e10cSrcweir { 172*cdf0e10cSrcweir if( ( pLock = rLockList.GetObject( i ) )->m_pStream == pStream ) 173*cdf0e10cSrcweir { 174*cdf0e10cSrcweir delete pLock; 175*cdf0e10cSrcweir i--; 176*cdf0e10cSrcweir } 177*cdf0e10cSrcweir } 178*cdf0e10cSrcweir return; 179*cdf0e10cSrcweir } 180*cdf0e10cSrcweir for( sal_uIntPtr i = 0; i < rLockList.Count(); ++i ) 181*cdf0e10cSrcweir { 182*cdf0e10cSrcweir if( ( pLock = rLockList.GetObject( i ) )->m_pStream == pStream && 183*cdf0e10cSrcweir nStart == pLock->m_nStartPos && nEnd == pLock->m_nEndPos ) 184*cdf0e10cSrcweir { 185*cdf0e10cSrcweir delete pLock; 186*cdf0e10cSrcweir return; 187*cdf0e10cSrcweir } 188*cdf0e10cSrcweir } 189*cdf0e10cSrcweir } 190*cdf0e10cSrcweir 191*cdf0e10cSrcweir // -------------- 192*cdf0e10cSrcweir // - StreamData - 193*cdf0e10cSrcweir // -------------- 194*cdf0e10cSrcweir 195*cdf0e10cSrcweir class StreamData 196*cdf0e10cSrcweir { 197*cdf0e10cSrcweir public: 198*cdf0e10cSrcweir int nHandle; 199*cdf0e10cSrcweir 200*cdf0e10cSrcweir StreamData() { nHandle = 0; } 201*cdf0e10cSrcweir }; 202*cdf0e10cSrcweir 203*cdf0e10cSrcweir // ----------------------------------------------------------------------- 204*cdf0e10cSrcweir 205*cdf0e10cSrcweir static sal_uInt32 GetSvError( int nErrno ) 206*cdf0e10cSrcweir { 207*cdf0e10cSrcweir static struct { int nErr; sal_uInt32 sv; } errArr[] = 208*cdf0e10cSrcweir { 209*cdf0e10cSrcweir { 0, SVSTREAM_OK }, 210*cdf0e10cSrcweir { EACCES, SVSTREAM_ACCESS_DENIED }, 211*cdf0e10cSrcweir { EBADF, SVSTREAM_INVALID_HANDLE }, 212*cdf0e10cSrcweir #if defined( RS6000 ) || defined( ALPHA ) || defined( HP9000 ) || defined( NETBSD ) || defined(FREEBSD) || defined(MACOSX) || defined(__FreeBSD_kernel__) 213*cdf0e10cSrcweir { EDEADLK, SVSTREAM_LOCKING_VIOLATION }, 214*cdf0e10cSrcweir #else 215*cdf0e10cSrcweir { EDEADLOCK, SVSTREAM_LOCKING_VIOLATION }, 216*cdf0e10cSrcweir #endif 217*cdf0e10cSrcweir { EINVAL, SVSTREAM_INVALID_PARAMETER }, 218*cdf0e10cSrcweir { EMFILE, SVSTREAM_TOO_MANY_OPEN_FILES }, 219*cdf0e10cSrcweir { ENFILE, SVSTREAM_TOO_MANY_OPEN_FILES }, 220*cdf0e10cSrcweir { ENOENT, SVSTREAM_FILE_NOT_FOUND }, 221*cdf0e10cSrcweir { EPERM, SVSTREAM_ACCESS_DENIED }, 222*cdf0e10cSrcweir { EROFS, SVSTREAM_ACCESS_DENIED }, 223*cdf0e10cSrcweir { EAGAIN, SVSTREAM_LOCKING_VIOLATION }, 224*cdf0e10cSrcweir { EISDIR, SVSTREAM_PATH_NOT_FOUND }, 225*cdf0e10cSrcweir { ELOOP, SVSTREAM_PATH_NOT_FOUND }, 226*cdf0e10cSrcweir #if ! defined( RS6000 ) && ! defined( ALPHA ) && ! defined( NETBSD ) && ! defined (FREEBSD) && ! defined (MACOSX) && ! defined(__FreeBSD_kernel__) 227*cdf0e10cSrcweir { EMULTIHOP, SVSTREAM_PATH_NOT_FOUND }, 228*cdf0e10cSrcweir { ENOLINK, SVSTREAM_PATH_NOT_FOUND }, 229*cdf0e10cSrcweir #endif 230*cdf0e10cSrcweir { ENOTDIR, SVSTREAM_PATH_NOT_FOUND }, 231*cdf0e10cSrcweir { ETXTBSY, SVSTREAM_ACCESS_DENIED }, 232*cdf0e10cSrcweir { EEXIST, SVSTREAM_CANNOT_MAKE }, 233*cdf0e10cSrcweir { ENOSPC, SVSTREAM_DISK_FULL }, 234*cdf0e10cSrcweir { (int)0xFFFF, SVSTREAM_GENERALERROR } 235*cdf0e10cSrcweir }; 236*cdf0e10cSrcweir 237*cdf0e10cSrcweir sal_uInt32 nRetVal = SVSTREAM_GENERALERROR; // Standardfehler 238*cdf0e10cSrcweir int i=0; 239*cdf0e10cSrcweir do 240*cdf0e10cSrcweir { 241*cdf0e10cSrcweir if ( errArr[i].nErr == nErrno ) 242*cdf0e10cSrcweir { 243*cdf0e10cSrcweir nRetVal = errArr[i].sv; 244*cdf0e10cSrcweir break; 245*cdf0e10cSrcweir } 246*cdf0e10cSrcweir ++i; 247*cdf0e10cSrcweir } 248*cdf0e10cSrcweir while( errArr[i].nErr != 0xFFFF ); 249*cdf0e10cSrcweir return nRetVal; 250*cdf0e10cSrcweir } 251*cdf0e10cSrcweir 252*cdf0e10cSrcweir /************************************************************************* 253*cdf0e10cSrcweir |* 254*cdf0e10cSrcweir |* SvFileStream::SvFileStream() 255*cdf0e10cSrcweir |* 256*cdf0e10cSrcweir |* Beschreibung STREAM.SDW 257*cdf0e10cSrcweir |* Ersterstellung OV 08.06.94 258*cdf0e10cSrcweir |* Letzte Aenderung OV 08.06.94 259*cdf0e10cSrcweir |* 260*cdf0e10cSrcweir *************************************************************************/ 261*cdf0e10cSrcweir 262*cdf0e10cSrcweir SvFileStream::SvFileStream( const String& rFileName, StreamMode nOpenMode ) 263*cdf0e10cSrcweir { 264*cdf0e10cSrcweir bIsOpen = sal_False; 265*cdf0e10cSrcweir nLockCounter = 0; 266*cdf0e10cSrcweir bIsWritable = sal_False; 267*cdf0e10cSrcweir pInstanceData = new StreamData; 268*cdf0e10cSrcweir 269*cdf0e10cSrcweir SetBufferSize( 1024 ); 270*cdf0e10cSrcweir // convert URL to SystemPath, if necessary 271*cdf0e10cSrcweir ::rtl::OUString aSystemFileName; 272*cdf0e10cSrcweir if( FileBase::getSystemPathFromFileURL( rFileName , aSystemFileName ) 273*cdf0e10cSrcweir != FileBase::E_None ) 274*cdf0e10cSrcweir { 275*cdf0e10cSrcweir aSystemFileName = rFileName; 276*cdf0e10cSrcweir } 277*cdf0e10cSrcweir Open( aSystemFileName, nOpenMode ); 278*cdf0e10cSrcweir } 279*cdf0e10cSrcweir 280*cdf0e10cSrcweir /************************************************************************* 281*cdf0e10cSrcweir |* 282*cdf0e10cSrcweir |* SvFileStream::SvFileStream() 283*cdf0e10cSrcweir |* 284*cdf0e10cSrcweir |* Beschreibung STREAM.SDW 285*cdf0e10cSrcweir |* Ersterstellung OV 22.11.94 286*cdf0e10cSrcweir |* Letzte Aenderung OV 22.11.94 287*cdf0e10cSrcweir |* 288*cdf0e10cSrcweir *************************************************************************/ 289*cdf0e10cSrcweir 290*cdf0e10cSrcweir SvFileStream::SvFileStream() 291*cdf0e10cSrcweir { 292*cdf0e10cSrcweir bIsOpen = sal_False; 293*cdf0e10cSrcweir nLockCounter = 0; 294*cdf0e10cSrcweir bIsWritable = sal_False; 295*cdf0e10cSrcweir pInstanceData = new StreamData; 296*cdf0e10cSrcweir SetBufferSize( 1024 ); 297*cdf0e10cSrcweir } 298*cdf0e10cSrcweir 299*cdf0e10cSrcweir /************************************************************************* 300*cdf0e10cSrcweir |* 301*cdf0e10cSrcweir |* SvFileStream::~SvFileStream() 302*cdf0e10cSrcweir |* 303*cdf0e10cSrcweir |* Beschreibung STREAM.SDW 304*cdf0e10cSrcweir |* Ersterstellung OV 22.11.94 305*cdf0e10cSrcweir |* Letzte Aenderung OV 22.11.94 306*cdf0e10cSrcweir |* 307*cdf0e10cSrcweir *************************************************************************/ 308*cdf0e10cSrcweir 309*cdf0e10cSrcweir SvFileStream::~SvFileStream() 310*cdf0e10cSrcweir { 311*cdf0e10cSrcweir Close(); 312*cdf0e10cSrcweir 313*cdf0e10cSrcweir InternalStreamLock::UnlockFile( 0, 0, this ); 314*cdf0e10cSrcweir 315*cdf0e10cSrcweir if (pInstanceData) 316*cdf0e10cSrcweir delete pInstanceData; 317*cdf0e10cSrcweir } 318*cdf0e10cSrcweir 319*cdf0e10cSrcweir /************************************************************************* 320*cdf0e10cSrcweir |* 321*cdf0e10cSrcweir |* SvFileStream::GetFileHandle() 322*cdf0e10cSrcweir |* 323*cdf0e10cSrcweir |* Beschreibung STREAM.SDW 324*cdf0e10cSrcweir |* Ersterstellung OV 22.11.94 325*cdf0e10cSrcweir |* Letzte Aenderung OV 22.11.94 326*cdf0e10cSrcweir |* 327*cdf0e10cSrcweir *************************************************************************/ 328*cdf0e10cSrcweir 329*cdf0e10cSrcweir sal_uInt32 SvFileStream::GetFileHandle() const 330*cdf0e10cSrcweir { 331*cdf0e10cSrcweir return (sal_uInt32)pInstanceData->nHandle; 332*cdf0e10cSrcweir } 333*cdf0e10cSrcweir 334*cdf0e10cSrcweir /************************************************************************* 335*cdf0e10cSrcweir |* 336*cdf0e10cSrcweir |* SvFileStream::IsA() 337*cdf0e10cSrcweir |* 338*cdf0e10cSrcweir |* Beschreibung STREAM.SDW 339*cdf0e10cSrcweir |* Ersterstellung OV 14.06.94 340*cdf0e10cSrcweir |* Letzte Aenderung OV 14.06.94 341*cdf0e10cSrcweir |* 342*cdf0e10cSrcweir *************************************************************************/ 343*cdf0e10cSrcweir 344*cdf0e10cSrcweir sal_uInt16 SvFileStream::IsA() const 345*cdf0e10cSrcweir { 346*cdf0e10cSrcweir return ID_FILESTREAM; 347*cdf0e10cSrcweir } 348*cdf0e10cSrcweir 349*cdf0e10cSrcweir /************************************************************************* 350*cdf0e10cSrcweir |* 351*cdf0e10cSrcweir |* SvFileStream::GetData() 352*cdf0e10cSrcweir |* 353*cdf0e10cSrcweir |* Beschreibung STREAM.SDW 354*cdf0e10cSrcweir |* Ersterstellung OV 15.06.94 355*cdf0e10cSrcweir |* Letzte Aenderung OV 15.06.94 356*cdf0e10cSrcweir |* 357*cdf0e10cSrcweir *************************************************************************/ 358*cdf0e10cSrcweir 359*cdf0e10cSrcweir sal_Size SvFileStream::GetData( void* pData, sal_Size nSize ) 360*cdf0e10cSrcweir { 361*cdf0e10cSrcweir #ifdef DBG_UTIL 362*cdf0e10cSrcweir ByteString aTraceStr( "SvFileStream::GetData(): " ); 363*cdf0e10cSrcweir aTraceStr += ByteString::CreateFromInt64(nSize); 364*cdf0e10cSrcweir aTraceStr += " Bytes from "; 365*cdf0e10cSrcweir aTraceStr += ByteString(aFilename, osl_getThreadTextEncoding()); 366*cdf0e10cSrcweir DBG_TRACE( aTraceStr.GetBuffer() ); 367*cdf0e10cSrcweir #endif 368*cdf0e10cSrcweir 369*cdf0e10cSrcweir int nRead = 0; 370*cdf0e10cSrcweir if ( IsOpen() ) 371*cdf0e10cSrcweir { 372*cdf0e10cSrcweir nRead = read(pInstanceData->nHandle,pData,(unsigned)nSize); 373*cdf0e10cSrcweir if ( nRead == -1 ) 374*cdf0e10cSrcweir SetError( ::GetSvError( errno )); 375*cdf0e10cSrcweir } 376*cdf0e10cSrcweir return (sal_Size)nRead; 377*cdf0e10cSrcweir } 378*cdf0e10cSrcweir 379*cdf0e10cSrcweir /************************************************************************* 380*cdf0e10cSrcweir |* 381*cdf0e10cSrcweir |* SvFileStream::PutData() 382*cdf0e10cSrcweir |* 383*cdf0e10cSrcweir |* Beschreibung STREAM.SDW 384*cdf0e10cSrcweir |* Ersterstellung OV 15.06.94 385*cdf0e10cSrcweir |* Letzte Aenderung OV 15.06.94 386*cdf0e10cSrcweir |* 387*cdf0e10cSrcweir *************************************************************************/ 388*cdf0e10cSrcweir 389*cdf0e10cSrcweir sal_Size SvFileStream::PutData( const void* pData, sal_Size nSize ) 390*cdf0e10cSrcweir { 391*cdf0e10cSrcweir #ifdef DBG_UTIL 392*cdf0e10cSrcweir ByteString aTraceStr( "SvFileStrean::PutData: " ); 393*cdf0e10cSrcweir aTraceStr += ByteString::CreateFromInt64(nSize); 394*cdf0e10cSrcweir aTraceStr += " Bytes to "; 395*cdf0e10cSrcweir aTraceStr += ByteString(aFilename, osl_getThreadTextEncoding()); 396*cdf0e10cSrcweir DBG_TRACE( aTraceStr.GetBuffer() ); 397*cdf0e10cSrcweir #endif 398*cdf0e10cSrcweir 399*cdf0e10cSrcweir int nWrite = 0; 400*cdf0e10cSrcweir if ( IsOpen() ) 401*cdf0e10cSrcweir { 402*cdf0e10cSrcweir nWrite = write(pInstanceData->nHandle,pData,(unsigned)nSize); 403*cdf0e10cSrcweir if ( nWrite == -1 ) 404*cdf0e10cSrcweir SetError( ::GetSvError( errno ) ); 405*cdf0e10cSrcweir else if( !nWrite ) 406*cdf0e10cSrcweir SetError( SVSTREAM_DISK_FULL ); 407*cdf0e10cSrcweir } 408*cdf0e10cSrcweir return (sal_Size)nWrite; 409*cdf0e10cSrcweir } 410*cdf0e10cSrcweir 411*cdf0e10cSrcweir /************************************************************************* 412*cdf0e10cSrcweir |* 413*cdf0e10cSrcweir |* SvFileStream::SeekPos() 414*cdf0e10cSrcweir |* 415*cdf0e10cSrcweir |* Beschreibung STREAM.SDW 416*cdf0e10cSrcweir |* Ersterstellung OV 15.06.94 417*cdf0e10cSrcweir |* Letzte Aenderung OV 15.06.94 418*cdf0e10cSrcweir |* 419*cdf0e10cSrcweir *************************************************************************/ 420*cdf0e10cSrcweir 421*cdf0e10cSrcweir sal_Size SvFileStream::SeekPos( sal_Size nPos ) 422*cdf0e10cSrcweir { 423*cdf0e10cSrcweir if ( IsOpen() ) 424*cdf0e10cSrcweir { 425*cdf0e10cSrcweir long nNewPos; 426*cdf0e10cSrcweir if ( nPos != STREAM_SEEK_TO_END ) 427*cdf0e10cSrcweir nNewPos = lseek( pInstanceData->nHandle, (long)nPos, SEEK_SET ); 428*cdf0e10cSrcweir else 429*cdf0e10cSrcweir nNewPos = lseek( pInstanceData->nHandle, 0L, SEEK_END ); 430*cdf0e10cSrcweir 431*cdf0e10cSrcweir if ( nNewPos == -1 ) 432*cdf0e10cSrcweir { 433*cdf0e10cSrcweir SetError( SVSTREAM_SEEK_ERROR ); 434*cdf0e10cSrcweir return 0L; 435*cdf0e10cSrcweir } 436*cdf0e10cSrcweir // langsam aber sicherer als return nNewPos 437*cdf0e10cSrcweir return lseek(pInstanceData->nHandle,0L,SEEK_CUR); 438*cdf0e10cSrcweir // return nNewPos; 439*cdf0e10cSrcweir } 440*cdf0e10cSrcweir SetError( SVSTREAM_GENERALERROR ); 441*cdf0e10cSrcweir return 0L; 442*cdf0e10cSrcweir } 443*cdf0e10cSrcweir 444*cdf0e10cSrcweir 445*cdf0e10cSrcweir /************************************************************************* 446*cdf0e10cSrcweir |* 447*cdf0e10cSrcweir |* SvFileStream::FlushData() 448*cdf0e10cSrcweir |* 449*cdf0e10cSrcweir |* Beschreibung STREAM.SDW 450*cdf0e10cSrcweir |* Ersterstellung OV 15.06.94 451*cdf0e10cSrcweir |* Letzte Aenderung OV 15.06.94 452*cdf0e10cSrcweir |* 453*cdf0e10cSrcweir *************************************************************************/ 454*cdf0e10cSrcweir 455*cdf0e10cSrcweir void SvFileStream::FlushData() 456*cdf0e10cSrcweir { 457*cdf0e10cSrcweir // lokal gibt es nicht 458*cdf0e10cSrcweir } 459*cdf0e10cSrcweir 460*cdf0e10cSrcweir static char *pFileLockEnvVar = (char*)1; 461*cdf0e10cSrcweir 462*cdf0e10cSrcweir /************************************************************************* 463*cdf0e10cSrcweir |* 464*cdf0e10cSrcweir |* SvFileStream::LockRange() 465*cdf0e10cSrcweir |* 466*cdf0e10cSrcweir |* Beschreibung STREAM.SDW 467*cdf0e10cSrcweir |* Ersterstellung OV 15.06.94 468*cdf0e10cSrcweir |* Letzte Aenderung OV 15.06.94 469*cdf0e10cSrcweir |* 470*cdf0e10cSrcweir *************************************************************************/ 471*cdf0e10cSrcweir 472*cdf0e10cSrcweir sal_Bool SvFileStream::LockRange( sal_Size nByteOffset, sal_Size nBytes ) 473*cdf0e10cSrcweir { 474*cdf0e10cSrcweir struct flock aflock; 475*cdf0e10cSrcweir aflock.l_start = nByteOffset; 476*cdf0e10cSrcweir aflock.l_whence = SEEK_SET; 477*cdf0e10cSrcweir aflock.l_len = nBytes; 478*cdf0e10cSrcweir 479*cdf0e10cSrcweir int nLockMode = 0; 480*cdf0e10cSrcweir 481*cdf0e10cSrcweir if ( ! IsOpen() ) 482*cdf0e10cSrcweir return sal_False; 483*cdf0e10cSrcweir 484*cdf0e10cSrcweir if ( eStreamMode & STREAM_SHARE_DENYALL ) 485*cdf0e10cSrcweir { 486*cdf0e10cSrcweir if (bIsWritable) 487*cdf0e10cSrcweir nLockMode = F_WRLCK; 488*cdf0e10cSrcweir else 489*cdf0e10cSrcweir nLockMode = F_RDLCK; 490*cdf0e10cSrcweir } 491*cdf0e10cSrcweir 492*cdf0e10cSrcweir if ( eStreamMode & STREAM_SHARE_DENYREAD ) 493*cdf0e10cSrcweir { 494*cdf0e10cSrcweir if (bIsWritable) 495*cdf0e10cSrcweir nLockMode = F_WRLCK; 496*cdf0e10cSrcweir else 497*cdf0e10cSrcweir { 498*cdf0e10cSrcweir SetError(SVSTREAM_LOCKING_VIOLATION); 499*cdf0e10cSrcweir return sal_False; 500*cdf0e10cSrcweir } 501*cdf0e10cSrcweir } 502*cdf0e10cSrcweir 503*cdf0e10cSrcweir if ( eStreamMode & STREAM_SHARE_DENYWRITE ) 504*cdf0e10cSrcweir { 505*cdf0e10cSrcweir if (bIsWritable) 506*cdf0e10cSrcweir nLockMode = F_WRLCK; 507*cdf0e10cSrcweir else 508*cdf0e10cSrcweir nLockMode = F_RDLCK; 509*cdf0e10cSrcweir } 510*cdf0e10cSrcweir 511*cdf0e10cSrcweir if (!nLockMode) 512*cdf0e10cSrcweir return sal_True; 513*cdf0e10cSrcweir 514*cdf0e10cSrcweir if( ! InternalStreamLock::LockFile( nByteOffset, nByteOffset+nBytes, this ) ) 515*cdf0e10cSrcweir { 516*cdf0e10cSrcweir #if OSL_DEBUG_LEVEL > 1 517*cdf0e10cSrcweir fprintf( stderr, "InternalLock on %s [ %ld ... %ld ] failed\n", 518*cdf0e10cSrcweir ByteString(aFilename, osl_getThreadTextEncoding()).GetBuffer(), nByteOffset, nByteOffset+nBytes ); 519*cdf0e10cSrcweir #endif 520*cdf0e10cSrcweir return sal_False; 521*cdf0e10cSrcweir } 522*cdf0e10cSrcweir 523*cdf0e10cSrcweir // HACK: File-Locking nur via Environmentvariable einschalten 524*cdf0e10cSrcweir // um einen Haenger im Zusammenspiel mit einem Linux 525*cdf0e10cSrcweir // NFS-2-Server (kein Lockdaemon) zu verhindern. 526*cdf0e10cSrcweir // File-Locking ?ber NFS ist generell ein Performancekiller. 527*cdf0e10cSrcweir // HR, 22.10.1997 fuer SOLARIS 528*cdf0e10cSrcweir // CP, 30.11.1997 fuer HPUX 529*cdf0e10cSrcweir // ER, 18.12.1997 fuer IRIX 530*cdf0e10cSrcweir // HR, 18.05.1998 Environmentvariable 531*cdf0e10cSrcweir 532*cdf0e10cSrcweir if ( pFileLockEnvVar == (char*)1 ) 533*cdf0e10cSrcweir pFileLockEnvVar = getenv("STAR_ENABLE_FILE_LOCKING"); 534*cdf0e10cSrcweir if ( ! pFileLockEnvVar ) 535*cdf0e10cSrcweir return sal_True; 536*cdf0e10cSrcweir 537*cdf0e10cSrcweir aflock.l_type = nLockMode; 538*cdf0e10cSrcweir if (fcntl(pInstanceData->nHandle, F_GETLK, &aflock) == -1) 539*cdf0e10cSrcweir { 540*cdf0e10cSrcweir #if ( defined HPUX && defined BAD_UNION ) 541*cdf0e10cSrcweir #ifdef DBG_UTIL 542*cdf0e10cSrcweir fprintf( stderr, "***** FCNTL(lock):errno = %d\n", errno ); 543*cdf0e10cSrcweir #endif 544*cdf0e10cSrcweir if ( errno == EINVAL || errno == ENOSYS ) 545*cdf0e10cSrcweir return sal_True; 546*cdf0e10cSrcweir #endif 547*cdf0e10cSrcweir #if defined SINIX 548*cdf0e10cSrcweir if (errno == EINVAL) 549*cdf0e10cSrcweir return sal_True; 550*cdf0e10cSrcweir #endif 551*cdf0e10cSrcweir #if defined SOLARIS 552*cdf0e10cSrcweir if (errno == ENOSYS) 553*cdf0e10cSrcweir return sal_True; 554*cdf0e10cSrcweir #endif 555*cdf0e10cSrcweir SetError( ::GetSvError( errno )); 556*cdf0e10cSrcweir return sal_False; 557*cdf0e10cSrcweir } 558*cdf0e10cSrcweir if (aflock.l_type != F_UNLCK) 559*cdf0e10cSrcweir { 560*cdf0e10cSrcweir SetError(SVSTREAM_LOCKING_VIOLATION); 561*cdf0e10cSrcweir return sal_False; 562*cdf0e10cSrcweir } 563*cdf0e10cSrcweir 564*cdf0e10cSrcweir aflock.l_type = nLockMode; 565*cdf0e10cSrcweir if (fcntl(pInstanceData->nHandle, F_SETLK, &aflock) == -1) 566*cdf0e10cSrcweir { 567*cdf0e10cSrcweir SetError( ::GetSvError( errno )); 568*cdf0e10cSrcweir return sal_False; 569*cdf0e10cSrcweir } 570*cdf0e10cSrcweir return sal_True; 571*cdf0e10cSrcweir } 572*cdf0e10cSrcweir 573*cdf0e10cSrcweir /************************************************************************* 574*cdf0e10cSrcweir |* 575*cdf0e10cSrcweir |* SvFileStream::UnlockRange() 576*cdf0e10cSrcweir |* 577*cdf0e10cSrcweir |* Beschreibung STREAM.SDW 578*cdf0e10cSrcweir |* Ersterstellung OV 15.06.94 579*cdf0e10cSrcweir |* Letzte Aenderung OV 15.06.94 580*cdf0e10cSrcweir |* 581*cdf0e10cSrcweir *************************************************************************/ 582*cdf0e10cSrcweir 583*cdf0e10cSrcweir sal_Bool SvFileStream::UnlockRange( sal_Size nByteOffset, sal_Size nBytes ) 584*cdf0e10cSrcweir { 585*cdf0e10cSrcweir 586*cdf0e10cSrcweir struct flock aflock; 587*cdf0e10cSrcweir aflock.l_type = F_UNLCK; 588*cdf0e10cSrcweir aflock.l_start = nByteOffset; 589*cdf0e10cSrcweir aflock.l_whence = SEEK_SET; 590*cdf0e10cSrcweir aflock.l_len = nBytes; 591*cdf0e10cSrcweir 592*cdf0e10cSrcweir if ( ! IsOpen() ) 593*cdf0e10cSrcweir return sal_False; 594*cdf0e10cSrcweir 595*cdf0e10cSrcweir InternalStreamLock::UnlockFile( nByteOffset, nByteOffset+nBytes, this ); 596*cdf0e10cSrcweir 597*cdf0e10cSrcweir if ( ! (eStreamMode & 598*cdf0e10cSrcweir (STREAM_SHARE_DENYALL | STREAM_SHARE_DENYREAD | STREAM_SHARE_DENYWRITE))) 599*cdf0e10cSrcweir return sal_True; 600*cdf0e10cSrcweir 601*cdf0e10cSrcweir // wenn File Locking ausgeschaltet, siehe SvFileStream::LockRange 602*cdf0e10cSrcweir if ( ! pFileLockEnvVar ) 603*cdf0e10cSrcweir return sal_True; 604*cdf0e10cSrcweir 605*cdf0e10cSrcweir if (fcntl(pInstanceData->nHandle, F_SETLK, &aflock) != -1) 606*cdf0e10cSrcweir return sal_True; 607*cdf0e10cSrcweir 608*cdf0e10cSrcweir #if ( defined HPUX && defined BAD_UNION ) 609*cdf0e10cSrcweir #ifdef DBG_UTIL 610*cdf0e10cSrcweir fprintf( stderr, "***** FCNTL(unlock):errno = %d\n", errno ); 611*cdf0e10cSrcweir #endif 612*cdf0e10cSrcweir if ( errno == EINVAL || errno == ENOSYS ) 613*cdf0e10cSrcweir return sal_True; 614*cdf0e10cSrcweir #endif 615*cdf0e10cSrcweir #if ( defined SINIX ) 616*cdf0e10cSrcweir if (errno == EINVAL) 617*cdf0e10cSrcweir return sal_True; 618*cdf0e10cSrcweir #endif 619*cdf0e10cSrcweir 620*cdf0e10cSrcweir SetError( ::GetSvError( errno )); 621*cdf0e10cSrcweir return sal_False; 622*cdf0e10cSrcweir } 623*cdf0e10cSrcweir 624*cdf0e10cSrcweir /************************************************************************* 625*cdf0e10cSrcweir |* 626*cdf0e10cSrcweir |* SvFileStream::LockFile() 627*cdf0e10cSrcweir |* 628*cdf0e10cSrcweir |* Beschreibung STREAM.SDW 629*cdf0e10cSrcweir |* Ersterstellung OV 15.06.94 630*cdf0e10cSrcweir |* Letzte Aenderung OV 15.06.94 631*cdf0e10cSrcweir |* 632*cdf0e10cSrcweir *************************************************************************/ 633*cdf0e10cSrcweir 634*cdf0e10cSrcweir sal_Bool SvFileStream::LockFile() 635*cdf0e10cSrcweir { 636*cdf0e10cSrcweir return LockRange( 0UL, 0UL ); 637*cdf0e10cSrcweir } 638*cdf0e10cSrcweir 639*cdf0e10cSrcweir /************************************************************************* 640*cdf0e10cSrcweir |* 641*cdf0e10cSrcweir |* SvFileStream::UnlockFile() 642*cdf0e10cSrcweir |* 643*cdf0e10cSrcweir |* Beschreibung STREAM.SDW 644*cdf0e10cSrcweir |* Ersterstellung OV 15.06.94 645*cdf0e10cSrcweir |* Letzte Aenderung OV 15.06.94 646*cdf0e10cSrcweir |* 647*cdf0e10cSrcweir *************************************************************************/ 648*cdf0e10cSrcweir 649*cdf0e10cSrcweir sal_Bool SvFileStream::UnlockFile() 650*cdf0e10cSrcweir { 651*cdf0e10cSrcweir return UnlockRange( 0UL, 0UL ); 652*cdf0e10cSrcweir } 653*cdf0e10cSrcweir 654*cdf0e10cSrcweir /************************************************************************* 655*cdf0e10cSrcweir |* 656*cdf0e10cSrcweir |* SvFileStream::Open() 657*cdf0e10cSrcweir |* 658*cdf0e10cSrcweir |* Beschreibung STREAM.SDW 659*cdf0e10cSrcweir |* Ersterstellung OV 15.06.94 660*cdf0e10cSrcweir |* Letzte Aenderung OV 15.06.94 661*cdf0e10cSrcweir |* 662*cdf0e10cSrcweir *************************************************************************/ 663*cdf0e10cSrcweir 664*cdf0e10cSrcweir void SvFileStream::Open( const String& rFilename, StreamMode nOpenMode ) 665*cdf0e10cSrcweir { 666*cdf0e10cSrcweir int nAccess, nAccessRW; 667*cdf0e10cSrcweir int nMode; 668*cdf0e10cSrcweir int nHandleTmp; 669*cdf0e10cSrcweir struct stat buf; 670*cdf0e10cSrcweir sal_Bool bStatValid = sal_False; 671*cdf0e10cSrcweir 672*cdf0e10cSrcweir Close(); 673*cdf0e10cSrcweir errno = 0; 674*cdf0e10cSrcweir eStreamMode = nOpenMode; 675*cdf0e10cSrcweir eStreamMode &= ~STREAM_TRUNC; // beim ReOpen nicht cutten 676*cdf0e10cSrcweir 677*cdf0e10cSrcweir // !!! NoOp: Ansonsten ToAbs() verwendern 678*cdf0e10cSrcweir // !!! DirEntry aDirEntry( rFilename ); 679*cdf0e10cSrcweir // !!! aFilename = aDirEntry.GetFull(); 680*cdf0e10cSrcweir aFilename = rFilename; 681*cdf0e10cSrcweir #ifndef BOOTSTRAP 682*cdf0e10cSrcweir FSysRedirector::DoRedirect( aFilename ); 683*cdf0e10cSrcweir #endif 684*cdf0e10cSrcweir ByteString aLocalFilename(aFilename, osl_getThreadTextEncoding()); 685*cdf0e10cSrcweir 686*cdf0e10cSrcweir #ifdef DBG_UTIL 687*cdf0e10cSrcweir ByteString aTraceStr( "SvFileStream::Open(): " ); 688*cdf0e10cSrcweir aTraceStr += aLocalFilename; 689*cdf0e10cSrcweir DBG_TRACE( aTraceStr.GetBuffer() ); 690*cdf0e10cSrcweir #endif 691*cdf0e10cSrcweir 692*cdf0e10cSrcweir if ( lstat( aLocalFilename.GetBuffer(), &buf ) == 0 ) 693*cdf0e10cSrcweir { 694*cdf0e10cSrcweir bStatValid = sal_True; 695*cdf0e10cSrcweir // SvFileStream soll kein Directory oeffnen 696*cdf0e10cSrcweir if( S_ISDIR( buf.st_mode ) ) 697*cdf0e10cSrcweir { 698*cdf0e10cSrcweir SetError( ::GetSvError( EISDIR ) ); 699*cdf0e10cSrcweir return; 700*cdf0e10cSrcweir } 701*cdf0e10cSrcweir } 702*cdf0e10cSrcweir 703*cdf0e10cSrcweir 704*cdf0e10cSrcweir if ( !( nOpenMode & STREAM_WRITE ) ) 705*cdf0e10cSrcweir nAccessRW = O_RDONLY; 706*cdf0e10cSrcweir else if ( !( nOpenMode & STREAM_READ ) ) 707*cdf0e10cSrcweir nAccessRW = O_WRONLY; 708*cdf0e10cSrcweir else 709*cdf0e10cSrcweir nAccessRW = O_RDWR; 710*cdf0e10cSrcweir 711*cdf0e10cSrcweir nAccess = 0; 712*cdf0e10cSrcweir // Fix (MDA, 18.01.95): Bei RD_ONLY nicht mit O_CREAT oeffnen 713*cdf0e10cSrcweir // Wichtig auf Read-Only-Dateisystemen (wie CDROM) 714*cdf0e10cSrcweir if ( (!( nOpenMode & STREAM_NOCREATE )) && ( nAccessRW != O_RDONLY ) ) 715*cdf0e10cSrcweir nAccess |= O_CREAT; 716*cdf0e10cSrcweir if ( nOpenMode & STREAM_TRUNC ) 717*cdf0e10cSrcweir nAccess |= O_TRUNC; 718*cdf0e10cSrcweir 719*cdf0e10cSrcweir nMode = S_IREAD | S_IROTH | S_IRGRP; 720*cdf0e10cSrcweir if ( nOpenMode & STREAM_WRITE) 721*cdf0e10cSrcweir { 722*cdf0e10cSrcweir nMode |= (S_IWRITE | S_IWOTH | S_IWGRP); 723*cdf0e10cSrcweir 724*cdf0e10cSrcweir if ( nOpenMode & STREAM_COPY_ON_SYMLINK ) 725*cdf0e10cSrcweir { 726*cdf0e10cSrcweir if ( bStatValid && S_ISLNK( buf.st_mode ) < 0 ) 727*cdf0e10cSrcweir { 728*cdf0e10cSrcweir char *pBuf = new char[ 1024+1 ]; 729*cdf0e10cSrcweir if ( readlink( aLocalFilename.GetBuffer(), pBuf, 1024 ) > 0 ) 730*cdf0e10cSrcweir { 731*cdf0e10cSrcweir if ( unlink(aLocalFilename.GetBuffer()) == 0 ) 732*cdf0e10cSrcweir { 733*cdf0e10cSrcweir #ifdef DBG_UTIL 734*cdf0e10cSrcweir fprintf( stderr, 735*cdf0e10cSrcweir "Copying file on symbolic link (%s).\n", 736*cdf0e10cSrcweir aLocalFilename.GetBuffer() ); 737*cdf0e10cSrcweir #endif 738*cdf0e10cSrcweir String aTmpString( pBuf, osl_getThreadTextEncoding() ); 739*cdf0e10cSrcweir const DirEntry aSourceEntry( aTmpString ); 740*cdf0e10cSrcweir const DirEntry aTargetEntry( aFilename ); 741*cdf0e10cSrcweir FileCopier aFileCopier( aSourceEntry, aTargetEntry ); 742*cdf0e10cSrcweir aFileCopier.Execute(); 743*cdf0e10cSrcweir } 744*cdf0e10cSrcweir } 745*cdf0e10cSrcweir delete [] pBuf; 746*cdf0e10cSrcweir } 747*cdf0e10cSrcweir } 748*cdf0e10cSrcweir } 749*cdf0e10cSrcweir 750*cdf0e10cSrcweir 751*cdf0e10cSrcweir nHandleTmp = open(aLocalFilename.GetBuffer(),nAccessRW|nAccess, nMode ); 752*cdf0e10cSrcweir 753*cdf0e10cSrcweir if ( nHandleTmp == -1 ) 754*cdf0e10cSrcweir { 755*cdf0e10cSrcweir if ( nAccessRW != O_RDONLY ) 756*cdf0e10cSrcweir { 757*cdf0e10cSrcweir // auf Lesen runterschalten 758*cdf0e10cSrcweir nAccessRW = O_RDONLY; 759*cdf0e10cSrcweir nAccess = 0; 760*cdf0e10cSrcweir nMode = S_IREAD | S_IROTH | S_IRGRP; 761*cdf0e10cSrcweir nHandleTmp =open( aLocalFilename.GetBuffer(), 762*cdf0e10cSrcweir nAccessRW|nAccess, 763*cdf0e10cSrcweir nMode ); 764*cdf0e10cSrcweir } 765*cdf0e10cSrcweir } 766*cdf0e10cSrcweir if ( nHandleTmp != -1 ) 767*cdf0e10cSrcweir { 768*cdf0e10cSrcweir pInstanceData->nHandle = nHandleTmp; 769*cdf0e10cSrcweir bIsOpen = sal_True; 770*cdf0e10cSrcweir if ( nAccessRW != O_RDONLY ) 771*cdf0e10cSrcweir bIsWritable = sal_True; 772*cdf0e10cSrcweir 773*cdf0e10cSrcweir if ( !LockFile() ) // ganze Datei 774*cdf0e10cSrcweir { 775*cdf0e10cSrcweir close( nHandleTmp ); 776*cdf0e10cSrcweir bIsOpen = sal_False; 777*cdf0e10cSrcweir bIsWritable = sal_False; 778*cdf0e10cSrcweir pInstanceData->nHandle = 0; 779*cdf0e10cSrcweir } 780*cdf0e10cSrcweir } 781*cdf0e10cSrcweir else 782*cdf0e10cSrcweir SetError( ::GetSvError( errno ) ); 783*cdf0e10cSrcweir } 784*cdf0e10cSrcweir 785*cdf0e10cSrcweir /************************************************************************* 786*cdf0e10cSrcweir |* 787*cdf0e10cSrcweir |* SvFileStream::ReOpen() 788*cdf0e10cSrcweir |* 789*cdf0e10cSrcweir |* Beschreibung STREAM.SDW 790*cdf0e10cSrcweir |* Ersterstellung OV 15.06.94 791*cdf0e10cSrcweir |* Letzte Aenderung OV 15.06.94 792*cdf0e10cSrcweir |* 793*cdf0e10cSrcweir *************************************************************************/ 794*cdf0e10cSrcweir 795*cdf0e10cSrcweir void SvFileStream::ReOpen() 796*cdf0e10cSrcweir { 797*cdf0e10cSrcweir if ( !bIsOpen && aFilename.Len() ) 798*cdf0e10cSrcweir Open( aFilename, eStreamMode ); 799*cdf0e10cSrcweir } 800*cdf0e10cSrcweir 801*cdf0e10cSrcweir /************************************************************************* 802*cdf0e10cSrcweir |* 803*cdf0e10cSrcweir |* SvFileStream::Close() 804*cdf0e10cSrcweir |* 805*cdf0e10cSrcweir |* Beschreibung STREAM.SDW 806*cdf0e10cSrcweir |* Ersterstellung OV 15.06.94 807*cdf0e10cSrcweir |* Letzte Aenderung OV 15.06.94 808*cdf0e10cSrcweir |* 809*cdf0e10cSrcweir *************************************************************************/ 810*cdf0e10cSrcweir 811*cdf0e10cSrcweir void SvFileStream::Close() 812*cdf0e10cSrcweir { 813*cdf0e10cSrcweir InternalStreamLock::UnlockFile( 0, 0, this ); 814*cdf0e10cSrcweir 815*cdf0e10cSrcweir if ( IsOpen() ) 816*cdf0e10cSrcweir { 817*cdf0e10cSrcweir #ifdef DBG_UTIL 818*cdf0e10cSrcweir ByteString aTraceStr( "SvFileStream::Close(): " ); 819*cdf0e10cSrcweir aTraceStr += ByteString(aFilename, osl_getThreadTextEncoding()); 820*cdf0e10cSrcweir DBG_TRACE( aTraceStr.GetBuffer() ); 821*cdf0e10cSrcweir #endif 822*cdf0e10cSrcweir 823*cdf0e10cSrcweir Flush(); 824*cdf0e10cSrcweir close( pInstanceData->nHandle ); 825*cdf0e10cSrcweir pInstanceData->nHandle = 0; 826*cdf0e10cSrcweir } 827*cdf0e10cSrcweir 828*cdf0e10cSrcweir bIsOpen = sal_False; 829*cdf0e10cSrcweir bIsWritable = sal_False; 830*cdf0e10cSrcweir SvStream::ClearBuffer(); 831*cdf0e10cSrcweir SvStream::ClearError(); 832*cdf0e10cSrcweir } 833*cdf0e10cSrcweir 834*cdf0e10cSrcweir /************************************************************************* 835*cdf0e10cSrcweir |* 836*cdf0e10cSrcweir |* SvFileStream::ResetError() 837*cdf0e10cSrcweir |* 838*cdf0e10cSrcweir |* Beschreibung STREAM.SDW; Setzt Filepointer auf Dateianfang 839*cdf0e10cSrcweir |* Ersterstellung OV 15.06.94 840*cdf0e10cSrcweir |* Letzte Aenderung OV 15.06.94 841*cdf0e10cSrcweir |* 842*cdf0e10cSrcweir *************************************************************************/ 843*cdf0e10cSrcweir 844*cdf0e10cSrcweir void SvFileStream::ResetError() 845*cdf0e10cSrcweir { 846*cdf0e10cSrcweir SvStream::ClearError(); 847*cdf0e10cSrcweir } 848*cdf0e10cSrcweir 849*cdf0e10cSrcweir 850*cdf0e10cSrcweir /************************************************************************* 851*cdf0e10cSrcweir |* 852*cdf0e10cSrcweir |* SvFileStream::SetSize() 853*cdf0e10cSrcweir |* 854*cdf0e10cSrcweir |* Beschreibung STREAM.SDW; 855*cdf0e10cSrcweir |* Ersterstellung OV 15.06.94 856*cdf0e10cSrcweir |* Letzte Aenderung OV 15.06.94 857*cdf0e10cSrcweir |* 858*cdf0e10cSrcweir *************************************************************************/ 859*cdf0e10cSrcweir 860*cdf0e10cSrcweir void SvFileStream::SetSize (sal_Size nSize) 861*cdf0e10cSrcweir { 862*cdf0e10cSrcweir if (IsOpen()) 863*cdf0e10cSrcweir { 864*cdf0e10cSrcweir int fd = pInstanceData->nHandle; 865*cdf0e10cSrcweir if (::ftruncate (fd, (off_t)nSize) < 0) 866*cdf0e10cSrcweir { 867*cdf0e10cSrcweir // Save original error. 868*cdf0e10cSrcweir sal_uInt32 nErr = ::GetSvError (errno); 869*cdf0e10cSrcweir 870*cdf0e10cSrcweir // Check against current size. Fail upon 'shrink'. 871*cdf0e10cSrcweir struct stat aStat; 872*cdf0e10cSrcweir if (::fstat (fd, &aStat) < 0) 873*cdf0e10cSrcweir { 874*cdf0e10cSrcweir SetError (nErr); 875*cdf0e10cSrcweir return; 876*cdf0e10cSrcweir } 877*cdf0e10cSrcweir if ((sal::static_int_cast< sal_sSize >(nSize) <= aStat.st_size)) 878*cdf0e10cSrcweir { 879*cdf0e10cSrcweir // Failure upon 'shrink'. Return original error. 880*cdf0e10cSrcweir SetError (nErr); 881*cdf0e10cSrcweir return; 882*cdf0e10cSrcweir } 883*cdf0e10cSrcweir 884*cdf0e10cSrcweir // Save current position. 885*cdf0e10cSrcweir sal_Size nCurPos = (sal_Size)::lseek (fd, (off_t)0, SEEK_CUR); 886*cdf0e10cSrcweir if (nCurPos == (sal_Size)(-1)) 887*cdf0e10cSrcweir { 888*cdf0e10cSrcweir SetError (nErr); 889*cdf0e10cSrcweir return; 890*cdf0e10cSrcweir } 891*cdf0e10cSrcweir 892*cdf0e10cSrcweir // Try 'expand' via 'lseek()' and 'write()'. 893*cdf0e10cSrcweir if (::lseek (fd, (off_t)(nSize - 1), SEEK_SET) < 0) 894*cdf0e10cSrcweir { 895*cdf0e10cSrcweir SetError (nErr); 896*cdf0e10cSrcweir return; 897*cdf0e10cSrcweir } 898*cdf0e10cSrcweir if (::write (fd, (char*)"", (size_t)1) < 0) 899*cdf0e10cSrcweir { 900*cdf0e10cSrcweir // Failure. Restore saved position. 901*cdf0e10cSrcweir if (::lseek (fd, (off_t)nCurPos, SEEK_SET) < 0) 902*cdf0e10cSrcweir { 903*cdf0e10cSrcweir // Double failure. 904*cdf0e10cSrcweir } 905*cdf0e10cSrcweir 906*cdf0e10cSrcweir SetError (nErr); 907*cdf0e10cSrcweir return; 908*cdf0e10cSrcweir } 909*cdf0e10cSrcweir 910*cdf0e10cSrcweir // Success. Restore saved position. 911*cdf0e10cSrcweir if (::lseek (fd, (off_t)nCurPos, SEEK_SET) < 0) 912*cdf0e10cSrcweir { 913*cdf0e10cSrcweir SetError (nErr); 914*cdf0e10cSrcweir return; 915*cdf0e10cSrcweir } 916*cdf0e10cSrcweir } 917*cdf0e10cSrcweir } 918*cdf0e10cSrcweir } 919*cdf0e10cSrcweir 920*cdf0e10cSrcweir 921