ucb/source/ucp/webdav/SerfInputStream.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 "SerfInputStream.hxx"
  21
  22 #include <cppuhelper/queryinterface.hxx>
  23
  24 #include <string.h>
  25
  26 using namespace cppu;
  27 using namespace com::sun::star::io;
  28 using namespace com::sun::star::uno;
  29 using namespace http_dav_ucp;
  30
  31
  32
  33 // Constructor
  34
  35 SerfInputStream::SerfInputStream()
  36 : mLen( 0 ),
  37   mPos( 0 )
  38 {
  39 }
  40
  41
  42 // Destructor
  43
  44 SerfInputStream::~SerfInputStream()
  45 {
  46 }
  47
  48
  49 // AddToStream
  50 // Allows the caller to add some data to the "end" of the stream
  51
  52 void SerfInputStream::AddToStream( const char * inBuf, sal_Int32 inLen )
  53 {
  54     mInputBuffer.realloc( sal::static_int_cast<sal_Int32>(mLen) + inLen );
  55     memcpy( mInputBuffer.getArray() + mLen, inBuf, inLen );
  56     mLen += inLen;
  57 }
  58
  59
  60 // queryInterface
  61
  62 Any SerfInputStream::queryInterface( const Type &type )
  63                         throw( RuntimeException )
  64 {
  65     Any aRet = ::cppu::queryInterface( type,
  66                                        static_cast< XInputStream * >( this ),
  67                                        static_cast< XSeekable * >( this ) );
  68     return aRet.hasValue() ? aRet : OWeakObject::queryInterface( type );
  69 }
  70
  71
  72 // readBytes
  73 // "Reads" the specified number of bytes from the stream
  74
  75 sal_Int32 SAL_CALL SerfInputStream::readBytes(
  76   ::com::sun::star::uno::Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead )
  77         throw( ::com::sun::star::io::NotConnectedException,
  78                ::com::sun::star::io::BufferSizeExceededException,
  79                ::com::sun::star::io::IOException,
  80                ::com::sun::star::uno::RuntimeException )
  81 {
  82     // Work out how much we're actually going to write
  83     sal_Int32 theBytes2Read = nBytesToRead;
  84     sal_Int32 theBytesLeft  = sal::static_int_cast<sal_Int32>(mLen - mPos);
  85     if ( theBytes2Read > theBytesLeft )
  86         theBytes2Read = theBytesLeft;
  87
  88     // Realloc buffer.
  89     aData.realloc( theBytes2Read );
  90
  91     // Write the data
  92     memcpy(
  93         aData.getArray(), mInputBuffer.getConstArray() + mPos, theBytes2Read );
  94
  95     // Update our stream position for next time
  96     mPos += theBytes2Read;
  97
  98     return theBytes2Read;
  99 }
 100
 101
 102 // readSomeBytes
 103
 104 sal_Int32 SAL_CALL SerfInputStream::readSomeBytes(
 105  ::com::sun::star::uno::Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead )
 106         throw( ::com::sun::star::io::NotConnectedException,
 107                ::com::sun::star::io::BufferSizeExceededException,
 108                ::com::sun::star::io::IOException,
 109                ::com::sun::star::uno::RuntimeException )
 110 {
 111     // Warning: What should this be doing ?
 112     return readBytes( aData, nMaxBytesToRead );
 113 }
 114
 115
 116 // skipBytes
 117 // Moves the current stream position forward
 118
 119 void SAL_CALL SerfInputStream::skipBytes( sal_Int32 nBytesToSkip )
 120         throw( ::com::sun::star::io::NotConnectedException,
 121                ::com::sun::star::io::BufferSizeExceededException,
 122                ::com::sun::star::io::IOException,
 123                ::com::sun::star::uno::RuntimeException )
 124 {
 125     mPos += nBytesToSkip;
 126     if ( mPos >= mLen )
 127         mPos = mLen;
 128 }
 129
 130
 131 // available
 132 // Returns the number of unread bytes currently remaining on the stream
 133
 134 sal_Int32 SAL_CALL SerfInputStream::available(  )
 135         throw( ::com::sun::star::io::NotConnectedException,
 136                ::com::sun::star::io::IOException,
 137                ::com::sun::star::uno::RuntimeException )
 138 {
 139     return sal::static_int_cast<sal_Int32>(mLen - mPos);
 140 }
 141
 142
 143 // closeInput
 144
 145 void SAL_CALL SerfInputStream::closeInput()
 146         throw( ::com::sun::star::io::NotConnectedException,
 147                ::com::sun::star::io::IOException,
 148                ::com::sun::star::uno::RuntimeException )
 149 {
 150 }
 151
 152
 153 // seek
 154
 155 void SAL_CALL SerfInputStream::seek( sal_Int64 location )
 156         throw( ::com::sun::star::lang::IllegalArgumentException,
 157                ::com::sun::star::io::IOException,
 158                ::com::sun::star::uno::RuntimeException )
 159 {
 160     if ( location < 0 )
 161         throw ::com::sun::star::lang::IllegalArgumentException();
 162
 163     if ( location <= mLen )
 164         mPos = location;
 165     else
 166         throw ::com::sun::star::lang::IllegalArgumentException();
 167 }
 168
 169
 170 // getPosition
 171
 172 sal_Int64 SAL_CALL SerfInputStream::getPosition()
 173         throw( ::com::sun::star::io::IOException,
 174                ::com::sun::star::uno::RuntimeException )
 175 {
 176     return mPos;
 177 }
 178
 179
 180 // getLength
 181
 182 sal_Int64 SAL_CALL SerfInputStream::getLength()
 183         throw( ::com::sun::star::io::IOException,
 184                ::com::sun::star::uno::RuntimeException )
 185 {
 186     return mLen;
 187 }
 188
 189 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */