ucbhelper/source/provider/fd_inputstream.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 <ucbhelper/fd_inputstream.hxx>
  21
  22 #include <com/sun/star/io/IOException.hpp>
  23 #include <rtl/alloc.h>
  24 #include <osl/diagnose.h>
  25 #include <sal/log.hxx>
  26 #include <algorithm>
  27
  28 using namespace com::sun::star::uno;
  29 using namespace com::sun::star::lang;
  30 using namespace com::sun::star::io;
  31
  32 namespace ucbhelper
  33 {
  34     FdInputStream::FdInputStream( oslFileHandle tmpfl )
  35         : m_tmpfl(tmpfl)
  36         , m_nLength( 0 )
  37     {
  38         if ( !m_tmpfl )
  39             osl_createTempFile( nullptr, &m_tmpfl, nullptr );
  40         OSL_ENSURE( m_tmpfl, "input stream without tempfile!" );
  41
  42         if ( osl_setFilePos( m_tmpfl, osl_Pos_End, 0 ) == osl_File_E_None )
  43         {
  44             sal_uInt64 nFileSize = 0;
  45             if ( osl_getFilePos( m_tmpfl, &nFileSize ) == osl_File_E_None )
  46                 m_nLength = nFileSize;
  47             oslFileError rc = osl_setFilePos( m_tmpfl, osl_Pos_Absolut, 0 );
  48             SAL_WARN_IF(rc != osl_File_E_None, "ucbhelper", "osl_setFilePos failed");
  49         }
  50     }
  51
  52     FdInputStream::~FdInputStream()
  53     {
  54         if ( nullptr != m_tmpfl)
  55             osl_closeFile(m_tmpfl);
  56     }
  57
  58     sal_Int32 SAL_CALL FdInputStream::readBytes(Sequence< sal_Int8 >& aData,
  59                                                  sal_Int32 nBytesToRead)
  60     {
  61         osl::MutexGuard aGuard(m_aMutex);
  62
  63         sal_uInt64 nBeforePos( 0 );
  64         sal_uInt64 nBytesRequested( nBytesToRead );
  65         sal_uInt64 nBytesRead( 0 );
  66
  67         osl_getFilePos( m_tmpfl, &nBeforePos );
  68
  69         if ( 0 == ( nBytesRequested = std::min< sal_uInt64 >( m_nLength - nBeforePos, nBytesRequested ) ) )
  70             return 0;
  71
  72         if ( 0 <= nBytesToRead && aData.getLength() < nBytesToRead )
  73             aData.realloc( nBytesToRead );
  74
  75         if ( osl_readFile( m_tmpfl, aData.getArray(), nBytesRequested, &nBytesRead ) != osl_File_E_None )
  76             throw IOException();
  77
  78         return sal_Int32( nBytesRead );
  79     }
  80
  81
  82     sal_Int32 SAL_CALL FdInputStream::readSomeBytes( Sequence< sal_Int8 >& aData,
  83                                                       sal_Int32 nMaxBytesToRead )
  84     {
  85         return readBytes(aData,nMaxBytesToRead);
  86     }
  87
  88
  89     void SAL_CALL FdInputStream::skipBytes(sal_Int32 nBytesToSkip)
  90     {
  91         osl::MutexGuard aGuard(m_aMutex);
  92         if(!m_tmpfl)
  93             throw IOException();
  94
  95         oslFileError rc = osl_setFilePos( m_tmpfl, osl_Pos_Current, nBytesToSkip );
  96         SAL_WARN_IF(rc != osl_File_E_None, "ucbhelper", "osl_setFilePos failed");
  97     }
  98
  99
 100     sal_Int32 SAL_CALL FdInputStream::available()
 101     {
 102         return std::min<sal_Int64>(SAL_MAX_INT32, m_nLength - getPosition());
 103     }
 104
 105
 106     void SAL_CALL FdInputStream::closeInput()
 107     {
 108         osl::MutexGuard aGuard(m_aMutex);
 109         if(m_tmpfl)
 110         {
 111             osl_closeFile(m_tmpfl);
 112             m_tmpfl = nullptr;
 113         }
 114     }
 115
 116
 117     void SAL_CALL FdInputStream::seek(sal_Int64 location)
 118     {
 119         osl::MutexGuard aGuard(m_aMutex);
 120         if(!m_tmpfl)
 121             throw IOException();
 122
 123         oslFileError rc = osl_setFilePos( m_tmpfl, osl_Pos_Absolut, location );
 124         SAL_WARN_IF(rc != osl_File_E_None, "ucbhelper", "osl_setFilePos failed");
 125     }
 126
 127
 128     sal_Int64 SAL_CALL
 129     FdInputStream::getPosition()
 130     {
 131         osl::MutexGuard aGuard(m_aMutex);
 132         if(!m_tmpfl)
 133             throw IOException();
 134
 135         sal_uInt64 nFilePos = 0;
 136         osl_getFilePos( m_tmpfl, &nFilePos );
 137         return nFilePos;
 138     }
 139
 140
 141     sal_Int64 SAL_CALL FdInputStream::getLength()
 142     {
 143         return m_nLength;
 144     }
 145 }
 146
 147 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */