LCOV - code coverage report
Current view: top level - connectivity/source/drivers/hsqldb - HStorageAccess.cxx (source / functions) Hit Total Coverage
Test: libreoffice_filtered.info Lines: 0 145 0.0 %
Date: 2012-08-25 Functions: 0 14 0.0 %
Legend: Lines: hit not hit | Branches: + taken - not taken # not executed Branches: 0 0 -

           Branch data     Line data    Source code
       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 "hsqldb/HStorageAccess.hxx"
      21                 :            : #include <comphelper/processfactory.hxx>
      22                 :            : #include <com/sun/star/embed/XStorage.hpp>
      23                 :            : #include <com/sun/star/embed/ElementModes.hpp>
      24                 :            : #include <com/sun/star/io/XStream.hpp>
      25                 :            : #include "hsqldb/HStorageMap.hxx"
      26                 :            : #include "hsqldb/StorageNativeInputStream.h"
      27                 :            : #include "accesslog.hxx"
      28                 :            : #include "diagnose_ex.h"
      29                 :            : 
      30                 :            : #include <string.h>
      31                 :            : 
      32                 :            : using namespace ::com::sun::star::container;
      33                 :            : using namespace ::com::sun::star::uno;
      34                 :            : using namespace ::com::sun::star::embed;
      35                 :            : using namespace ::com::sun::star::io;
      36                 :            : using namespace ::com::sun::star::lang;
      37                 :            : using namespace ::connectivity::hsqldb;
      38                 :            : 
      39                 :            : #define ThrowException(env, type, msg) { \
      40                 :            :     env->ThrowNew(env->FindClass(type), msg); }
      41                 :            : 
      42                 :            : /*
      43                 :            :  * Class:     com_sun_star_sdbcx_comp_hsqldb_NativeStorageAccess
      44                 :            :  * Method:    openStream
      45                 :            :  * Signature: (Ljava/lang/String;Ljava/lang/String;I)V
      46                 :            :  */
      47                 :          0 : SAL_DLLPUBLIC_EXPORT void JNICALL Java_com_sun_star_sdbcx_comp_hsqldb_NativeStorageAccess_openStream
      48                 :            :   (JNIEnv * env, jobject /*obj_this*/,jstring name, jstring key, jint mode)
      49                 :            : {
      50                 :            : #ifdef HSQLDB_DBG
      51                 :            :     {
      52                 :            :         OperationLogFile( env, name, "data" ).logOperation( "openStream" );
      53                 :            :         LogFile( env, name, "data" ).create();
      54                 :            :     }
      55                 :            : #endif
      56                 :            : 
      57                 :          0 :     StorageContainer::registerStream(env,name,key,mode);
      58                 :          0 : }
      59                 :            : // -----------------------------------------------------------------------------
      60                 :            : /*
      61                 :            :  * Class:     com_sun_star_sdbcx_comp_hsqldb_NativeStorageAccess
      62                 :            :  * Method:    close
      63                 :            :  * Signature: (Ljava/lang/String;Ljava/lang/String;)V
      64                 :            :  */
      65                 :          0 : SAL_DLLPUBLIC_EXPORT void JNICALL Java_com_sun_star_sdbcx_comp_hsqldb_NativeStorageAccess_close
      66                 :            :   (JNIEnv * env, jobject /*obj_this*/,jstring name, jstring key)
      67                 :            : {
      68                 :            : #ifdef HSQLDB_DBG
      69                 :            :     {
      70                 :            :         ::rtl::OUString sKey = StorageContainer::jstring2ustring(env,key);
      71                 :            :         ::rtl::OUString sName = StorageContainer::jstring2ustring(env,name);
      72                 :            :     }
      73                 :            : #endif
      74                 :          0 :     ::boost::shared_ptr<StreamHelper> pHelper = StorageContainer::getRegisteredStream(env,name,key);
      75                 :          0 :     Reference< XOutputStream> xFlush = pHelper.get() ? pHelper->getOutputStream() : Reference< XOutputStream>();
      76                 :          0 :     if ( xFlush.is() )
      77                 :            :         try
      78                 :            :         {
      79                 :          0 :             xFlush->flush();
      80                 :            :         }
      81                 :          0 :         catch(const Exception&)
      82                 :            :         {
      83                 :            :             OSL_FAIL( "NativeStorageAccess::close: caught an exception while flushing!" );
      84                 :            :         }
      85                 :            : #ifdef HSQLDB_DBG
      86                 :            :     {
      87                 :            :         OperationLogFile aOpLog( env, name, "data" );
      88                 :            :         aOpLog.logOperation( "close" );
      89                 :            :         aOpLog.close();
      90                 :            : 
      91                 :            :         LogFile aDataLog( env, name, "data" );
      92                 :            :         aDataLog.close();
      93                 :            :     }
      94                 :            : #endif
      95                 :            : 
      96                 :          0 :     StorageContainer::revokeStream(env,name,key);
      97                 :          0 : }
      98                 :            : // -----------------------------------------------------------------------------
      99                 :            : /*
     100                 :            :  * Class:     com_sun_star_sdbcx_comp_hsqldb_NativeStorageAccess
     101                 :            :  * Method:    getFilePointer
     102                 :            :  * Signature: (Ljava/lang/String;Ljava/lang/String;)J
     103                 :            :  */
     104                 :          0 : SAL_DLLPUBLIC_EXPORT jlong JNICALL Java_com_sun_star_sdbcx_comp_hsqldb_NativeStorageAccess_getFilePointer
     105                 :            :   (JNIEnv * env, jobject /*obj_this*/,jstring name, jstring key)
     106                 :            : {
     107                 :            : #ifdef HSQLDB_DBG
     108                 :            :     OperationLogFile aOpLog( env, name, "data" );
     109                 :            :     aOpLog.logOperation( "getFilePointer" );
     110                 :            : #endif
     111                 :            : 
     112                 :          0 :     ::boost::shared_ptr<StreamHelper> pHelper = StorageContainer::getRegisteredStream(env,name,key);
     113                 :            :     OSL_ENSURE(pHelper.get(),"No stream helper!");
     114                 :            : 
     115                 :          0 :     jlong nReturn = pHelper.get() ? pHelper->getSeek()->getPosition() : jlong(0);
     116                 :            : #ifdef HSQLDB_DBG
     117                 :            :     aOpLog.logReturn( nReturn );
     118                 :            : #endif
     119                 :          0 :     return nReturn;
     120                 :            : }
     121                 :            : // -----------------------------------------------------------------------------
     122                 :            : 
     123                 :            : /*
     124                 :            :  * Class:     com_sun_star_sdbcx_comp_hsqldb_NativeStorageAccess
     125                 :            :  * Method:    length
     126                 :            :  * Signature: (Ljava/lang/String;Ljava/lang/String;)J
     127                 :            :  */
     128                 :          0 : SAL_DLLPUBLIC_EXPORT jlong JNICALL Java_com_sun_star_sdbcx_comp_hsqldb_NativeStorageAccess_length
     129                 :            :   (JNIEnv * env, jobject /*obj_this*/,jstring name, jstring key)
     130                 :            : {
     131                 :            : #ifdef HSQLDB_DBG
     132                 :            :     OperationLogFile aOpLog( env, name, "data" );
     133                 :            :     aOpLog.logOperation( "length" );
     134                 :            : #endif
     135                 :            : 
     136                 :          0 :     ::boost::shared_ptr<StreamHelper> pHelper = StorageContainer::getRegisteredStream(env,name,key);
     137                 :            :     OSL_ENSURE(pHelper.get(),"No stream helper!");
     138                 :            : 
     139                 :          0 :     jlong nReturn = pHelper.get() ? pHelper->getSeek()->getLength() :jlong(0);
     140                 :            : #ifdef HSQLDB_DBG
     141                 :            :     aOpLog.logReturn( nReturn );
     142                 :            : #endif
     143                 :          0 :     return nReturn;
     144                 :            : }
     145                 :            : 
     146                 :            : // -----------------------------------------------------------------------------
     147                 :            : 
     148                 :          0 : jint read_from_storage_stream( JNIEnv * env, jobject /*obj_this*/, jstring name, jstring key, DataLogFile* logger )
     149                 :            : {
     150                 :            :     OSL_UNUSED( logger );
     151                 :          0 :     ::boost::shared_ptr<StreamHelper> pHelper = StorageContainer::getRegisteredStream(env,name,key);
     152                 :          0 :     Reference< XInputStream> xIn = pHelper.get() ? pHelper->getInputStream() : Reference< XInputStream>();
     153                 :            :     OSL_ENSURE(xIn.is(),"Input stream is NULL!");
     154                 :          0 :     if ( xIn.is() )
     155                 :            :     {
     156                 :          0 :         Sequence< ::sal_Int8 > aData(1);
     157                 :          0 :         sal_Int32 nBytesRead = -1;
     158                 :            :         try
     159                 :            :         {
     160                 :          0 :             nBytesRead = xIn->readBytes(aData,1);
     161                 :            :         }
     162                 :          0 :         catch(const Exception& e)
     163                 :            :         {
     164                 :          0 :             StorageContainer::throwJavaException(e,env);
     165                 :          0 :             return -1;
     166                 :            : 
     167                 :            :         }
     168                 :          0 :         if (nBytesRead <= 0)
     169                 :            :         {
     170                 :          0 :             return (-1);
     171                 :            :         }
     172                 :            :         else
     173                 :            :         {
     174                 :          0 :             sal_Int32 tmpInt = aData[0];
     175                 :          0 :             if (tmpInt < 0 )
     176                 :          0 :                 tmpInt = 256 +tmpInt;
     177                 :            : 
     178                 :            : #ifdef HSQLDB_DBG
     179                 :            :             if ( logger )
     180                 :            :                 logger->write( tmpInt );
     181                 :            : #endif
     182                 :          0 :             return(tmpInt);
     183                 :          0 :         }
     184                 :            :     }
     185                 :          0 :     return -1;
     186                 :            : }
     187                 :            : 
     188                 :            : // -----------------------------------------------------------------------------
     189                 :            : 
     190                 :            : /*
     191                 :            :  * Class:     com_sun_star_sdbcx_comp_hsqldb_NativeStorageAccess
     192                 :            :  * Method:    read
     193                 :            :  * Signature: (Ljava/lang/String;Ljava/lang/String;)I
     194                 :            :  */
     195                 :          0 : SAL_DLLPUBLIC_EXPORT jint JNICALL Java_com_sun_star_sdbcx_comp_hsqldb_NativeStorageAccess_read__Ljava_lang_String_2Ljava_lang_String_2
     196                 :            :   (JNIEnv* env, jobject obj_this, jstring name, jstring key)
     197                 :            : {
     198                 :            : #ifdef HSQLDB_DBG
     199                 :            :     OperationLogFile aOpLog( env, name, "data" );
     200                 :            :     aOpLog.logOperation( "read" );
     201                 :            : 
     202                 :            :     DataLogFile aDataLog( env, name, "data" );
     203                 :            :     return read_from_storage_stream( env, obj_this, name, key, &aDataLog );
     204                 :            : #else
     205                 :          0 :     return read_from_storage_stream( env, obj_this, name, key );
     206                 :            : #endif
     207                 :            : }
     208                 :            : 
     209                 :            : // -----------------------------------------------------------------------------
     210                 :            : 
     211                 :          0 : jint read_from_storage_stream_into_buffer( JNIEnv * env, jobject /*obj_this*/,jstring name, jstring key, jbyteArray buffer, jint off, jint len, DataLogFile* logger )
     212                 :            : {
     213                 :            :     OSL_UNUSED( logger );
     214                 :            : #ifdef HSQLDB_DBG
     215                 :            :     {
     216                 :            :         ::rtl::OUString sKey = StorageContainer::jstring2ustring(env,key);
     217                 :            :         ::rtl::OUString sName = StorageContainer::jstring2ustring(env,name);
     218                 :            :     }
     219                 :            : #endif
     220                 :          0 :     ::boost::shared_ptr<StreamHelper> pHelper = StorageContainer::getRegisteredStream(env,name,key);
     221                 :          0 :     Reference< XInputStream> xIn = pHelper.get() ? pHelper->getInputStream() : Reference< XInputStream>();
     222                 :            :     OSL_ENSURE(xIn.is(),"Input stream is NULL!");
     223                 :          0 :     if ( xIn.is() )
     224                 :            :     {
     225                 :          0 :         jsize nLen = env->GetArrayLength(buffer);
     226                 :          0 :         if ( nLen < len || len <= 0 )
     227                 :            :         {
     228                 :          0 :             ThrowException( env,
     229                 :            :                     "java/io/IOException",
     230                 :            :                     "len is greater or equal to the buffer size");
     231                 :          0 :             return -1;
     232                 :            :         }
     233                 :          0 :         sal_Int32 nBytesRead = -1;
     234                 :            : 
     235                 :          0 :         Sequence< ::sal_Int8 > aData(nLen);
     236                 :            :         try
     237                 :            :         {
     238                 :          0 :             nBytesRead = xIn->readBytes(aData, len);
     239                 :            :         }
     240                 :          0 :         catch(const Exception& e)
     241                 :            :         {
     242                 :          0 :             StorageContainer::throwJavaException(e,env);
     243                 :          0 :             return -1;
     244                 :            :         }
     245                 :            : 
     246                 :          0 :         if (nBytesRead <= 0)
     247                 :          0 :             return -1;
     248                 :          0 :         env->SetByteArrayRegion(buffer,off,nBytesRead,(jbyte*) &aData[0]);
     249                 :            : 
     250                 :            : #ifdef HSQLDB_DBG
     251                 :            :         if ( logger )
     252                 :            :             logger->write( aData.getConstArray(), nBytesRead );
     253                 :            : #endif
     254                 :          0 :         return nBytesRead;
     255                 :            :     }
     256                 :          0 :     ThrowException( env,
     257                 :            :                     "java/io/IOException",
     258                 :            :                     "Stream is not valid");
     259                 :          0 :     return -1;
     260                 :            : }
     261                 :            : // -----------------------------------------------------------------------------
     262                 :            : 
     263                 :            : /*
     264                 :            :  * Class:     com_sun_star_sdbcx_comp_hsqldb_NativeStorageAccess
     265                 :            :  * Method:    read
     266                 :            :  * Signature: (Ljava/lang/String;Ljava/lang/String;[BII)I
     267                 :            :  */
     268                 :          0 : SAL_DLLPUBLIC_EXPORT jint JNICALL Java_com_sun_star_sdbcx_comp_hsqldb_NativeStorageAccess_read__Ljava_lang_String_2Ljava_lang_String_2_3BII
     269                 :            :   (JNIEnv * env, jobject obj_this,jstring name, jstring key, jbyteArray buffer, jint off, jint len)
     270                 :            : {
     271                 :            : #ifdef HSQLDB_DBG
     272                 :            :     OperationLogFile aOpLog( env, name, "data" );
     273                 :            :     aOpLog.logOperation( "read( byte[], int, int )" );
     274                 :            : 
     275                 :            :     DataLogFile aDataLog( env, name, "data" );
     276                 :            :     return read_from_storage_stream_into_buffer( env, obj_this, name, key, buffer, off, len, &aDataLog );
     277                 :            : #else
     278                 :          0 :     return read_from_storage_stream_into_buffer( env, obj_this, name, key, buffer, off, len );
     279                 :            : #endif
     280                 :            : }
     281                 :            : 
     282                 :            : // -----------------------------------------------------------------------------
     283                 :            : 
     284                 :            : /*
     285                 :            :  * Class:     com_sun_star_sdbcx_comp_hsqldb_NativeStorageAccess
     286                 :            :  * Method:    readInt
     287                 :            :  * Signature: (Ljava/lang/String;Ljava/lang/String;)I
     288                 :            :  */
     289                 :          0 : SAL_DLLPUBLIC_EXPORT jint JNICALL Java_com_sun_star_sdbcx_comp_hsqldb_NativeStorageAccess_readInt
     290                 :            :   (JNIEnv * env, jobject /*obj_this*/,jstring name, jstring key)
     291                 :            : {
     292                 :            : #ifdef HSQLDB_DBG
     293                 :            :     OperationLogFile aOpLog( env, name, "data" );
     294                 :            :     aOpLog.logOperation( "readInt" );
     295                 :            : #endif
     296                 :            : 
     297                 :          0 :     ::boost::shared_ptr<StreamHelper> pHelper = StorageContainer::getRegisteredStream(env,name,key);
     298                 :          0 :     Reference< XInputStream> xIn = pHelper.get() ? pHelper->getInputStream() : Reference< XInputStream>();
     299                 :            :     OSL_ENSURE(xIn.is(),"Input stream is NULL!");
     300                 :          0 :     if ( xIn.is() )
     301                 :            :     {
     302                 :          0 :         Sequence< ::sal_Int8 > aData(4);
     303                 :          0 :         sal_Int32 nBytesRead = -1;
     304                 :            :         try
     305                 :            :         {
     306                 :          0 :             nBytesRead = xIn->readBytes(aData, 4);
     307                 :            :         }
     308                 :          0 :         catch(const Exception& e)
     309                 :            :         {
     310                 :          0 :             StorageContainer::throwJavaException(e,env);
     311                 :          0 :             return -1;
     312                 :            :         }
     313                 :            : 
     314                 :          0 :         if ( nBytesRead != 4 ) {
     315                 :          0 :             ThrowException( env,
     316                 :            :                             "java/io/IOException",
     317                 :            :                             "Bytes read != 4");
     318                 :          0 :             return -1;
     319                 :            :         }
     320                 :            : 
     321                 :          0 :         Sequence< sal_Int32 > ch(4);
     322                 :          0 :         for(sal_Int32 i = 0;i < 4; ++i)
     323                 :            :         {
     324                 :          0 :             ch[i] = aData[i];
     325                 :          0 :             if (ch[i] < 0 )
     326                 :          0 :                 ch[i] = 256 + ch[i];
     327                 :            :         }
     328                 :            : 
     329                 :          0 :         if ((ch[0] | ch[1] | ch[2] | ch[3]) < 0)
     330                 :            :         {
     331                 :          0 :             ThrowException( env,
     332                 :            :                             "java/io/IOException",
     333                 :            :                             "One byte is < 0");
     334                 :          0 :             return -1;
     335                 :            :         }
     336                 :          0 :         jint nRet = ((ch[0] << 24) + (ch[1] << 16) + (ch[2] << 8) + (ch[3] << 0));
     337                 :            : #ifdef HSQLDB_DBG
     338                 :            :         DataLogFile aDataLog( env, name, "data" );
     339                 :            :         aDataLog.write( nRet );
     340                 :            : 
     341                 :            :         aOpLog.logReturn( nRet );
     342                 :            : #endif
     343                 :          0 :         return nRet;
     344                 :            :     }
     345                 :          0 :     ThrowException( env,
     346                 :            :                     "java/io/IOException",
     347                 :            :                     "No InputStream");
     348                 :          0 :     return -1;
     349                 :            : }
     350                 :            : // -----------------------------------------------------------------------------
     351                 :            : 
     352                 :            : /*
     353                 :            :  * Class:     com_sun_star_sdbcx_comp_hsqldb_NativeStorageAccess
     354                 :            :  * Method:    seek
     355                 :            :  * Signature: (Ljava/lang/String;Ljava/lang/String;J)V
     356                 :            :  */
     357                 :          0 : SAL_DLLPUBLIC_EXPORT void JNICALL Java_com_sun_star_sdbcx_comp_hsqldb_NativeStorageAccess_seek
     358                 :            :   (JNIEnv * env, jobject /*obj_this*/,jstring name, jstring key, jlong position)
     359                 :            : {
     360                 :            : #ifdef HSQLDB_DBG
     361                 :            :     OperationLogFile aOpLog( env, name, "data" );
     362                 :            :     aOpLog.logOperation( "seek", position );
     363                 :            : #endif
     364                 :            : 
     365                 :          0 :     ::boost::shared_ptr<StreamHelper> pHelper = StorageContainer::getRegisteredStream(env,name,key);
     366                 :          0 :     Reference< XSeekable> xSeek = pHelper.get() ? pHelper->getSeek() : Reference< XSeekable>();
     367                 :            : 
     368                 :            :     OSL_ENSURE(xSeek.is(),"No Seekable stream!");
     369                 :          0 :     if ( xSeek.is() )
     370                 :            :     {
     371                 :            :     #ifdef HSQLDB_DBG
     372                 :            :         DataLogFile aDataLog( env, name, "data" );
     373                 :            :     #endif
     374                 :            : 
     375                 :          0 :         ::sal_Int64 nLen = xSeek->getLength();
     376                 :          0 :         if ( nLen < position)
     377                 :            :         {
     378                 :            :             static ::sal_Int64 BUFFER_SIZE = 9192;
     379                 :            :         #ifdef HSQLDB_DBG
     380                 :            :             aDataLog.seek( nLen );
     381                 :            :         #endif
     382                 :          0 :             xSeek->seek(nLen);
     383                 :          0 :             Reference< XOutputStream> xOut = pHelper->getOutputStream();
     384                 :            :             OSL_ENSURE(xOut.is(),"No output stream!");
     385                 :            : 
     386                 :          0 :             ::sal_Int64 diff = position - nLen;
     387                 :            :             sal_Int32 n;
     388                 :          0 :             while( diff != 0 )
     389                 :            :             {
     390                 :          0 :                 if ( BUFFER_SIZE < diff )
     391                 :            :                 {
     392                 :          0 :                     n = static_cast<sal_Int32>(BUFFER_SIZE);
     393                 :          0 :                     diff = diff - BUFFER_SIZE;
     394                 :            :                 }
     395                 :            :                 else
     396                 :            :                 {
     397                 :          0 :                     n = static_cast<sal_Int32>(diff);
     398                 :          0 :                     diff = 0;
     399                 :            :                 }
     400                 :          0 :                 Sequence< ::sal_Int8 > aData(n);
     401                 :          0 :                 memset(aData.getArray(),0,n);
     402                 :          0 :                 xOut->writeBytes(aData);
     403                 :            :             #ifdef HSQLDB_DBG
     404                 :            :                 aDataLog.write( aData.getConstArray(), n );
     405                 :            :             #endif
     406                 :          0 :             }
     407                 :            :         }
     408                 :          0 :         xSeek->seek(position);
     409                 :            :         OSL_ENSURE(xSeek->getPosition() == position,"Wrong position after seeking the stream");
     410                 :            : 
     411                 :            :     #ifdef HSQLDB_DBG
     412                 :            :         aDataLog.seek( position );
     413                 :            :         OSL_ENSURE( xSeek->getPosition() == aDataLog.tell(), "Wrong position after seeking the stream" );
     414                 :            :     #endif
     415                 :          0 :     }
     416                 :          0 : }
     417                 :            : // -----------------------------------------------------------------------------
     418                 :            : 
     419                 :          0 : void write_to_storage_stream_from_buffer( JNIEnv* env, jobject /*obj_this*/, jstring name, jstring key, jbyteArray buffer, jint off, jint len, DataLogFile* logger )
     420                 :            : {
     421                 :            :     OSL_UNUSED( logger );
     422                 :          0 :     ::boost::shared_ptr<StreamHelper> pHelper = StorageContainer::getRegisteredStream(env,name,key);
     423                 :          0 :     Reference< XOutputStream> xOut = pHelper.get() ? pHelper->getOutputStream() : Reference< XOutputStream>();
     424                 :            :     OSL_ENSURE(xOut.is(),"Stream is NULL");
     425                 :            : 
     426                 :            :     try
     427                 :            :     {
     428                 :          0 :         if ( xOut.is() )
     429                 :            :         {
     430                 :          0 :             jbyte *buf = env->GetByteArrayElements(buffer,NULL);
     431                 :          0 :             if (JNI_FALSE != env->ExceptionCheck())
     432                 :            :             {
     433                 :          0 :                 env->ExceptionClear();
     434                 :            :                 OSL_FAIL("ExceptionClear");
     435                 :            :             }
     436                 :            :             OSL_ENSURE(buf,"buf is NULL");
     437                 :          0 :             if ( buf && len > 0 && len <= env->GetArrayLength(buffer))
     438                 :            :             {
     439                 :          0 :                 Sequence< ::sal_Int8 > aData((const signed char*) buf + off,len);
     440                 :          0 :                 env->ReleaseByteArrayElements(buffer, buf, JNI_ABORT);
     441                 :          0 :                 xOut->writeBytes(aData);
     442                 :            : #ifdef HSQLDB_DBG
     443                 :            :                 if ( logger )
     444                 :            :                     logger->write( aData.getConstArray(), len );
     445                 :            : #endif
     446                 :            :             }
     447                 :            :         }
     448                 :            :         else
     449                 :            :         {
     450                 :          0 :             ThrowException( env,
     451                 :            :                     "java/io/IOException",
     452                 :            :                     "No OutputStream");
     453                 :            :         }
     454                 :            :     }
     455                 :          0 :     catch(const Exception& e)
     456                 :            :     {
     457                 :            :         OSL_FAIL("Exception caught! : write [BII)V");
     458                 :          0 :         StorageContainer::throwJavaException(e,env);
     459                 :          0 :     }
     460                 :          0 : }
     461                 :            : 
     462                 :            : // -----------------------------------------------------------------------------
     463                 :            : 
     464                 :            : /*
     465                 :            :  * Class:     com_sun_star_sdbcx_comp_hsqldb_NativeStorageAccess
     466                 :            :  * Method:    write
     467                 :            :  * Signature: (Ljava/lang/String;Ljava/lang/String;[BII)V
     468                 :            :  */
     469                 :          0 : SAL_DLLPUBLIC_EXPORT void JNICALL Java_com_sun_star_sdbcx_comp_hsqldb_NativeStorageAccess_write
     470                 :            :   (JNIEnv * env, jobject obj_this,jstring name, jstring key, jbyteArray buffer, jint off, jint len)
     471                 :            : {
     472                 :            : #ifdef HSQLDB_DBG
     473                 :            :     OperationLogFile aOpLog( env, name, "data" );
     474                 :            :     aOpLog.logOperation( "write( byte[], int, int )" );
     475                 :            : 
     476                 :            :     DataLogFile aDataLog( env, name, "data" );
     477                 :            :     write_to_storage_stream_from_buffer( env, obj_this, name, key, buffer, off, len, &aDataLog );
     478                 :            : #else
     479                 :          0 :     write_to_storage_stream_from_buffer( env, obj_this, name, key, buffer, off, len );
     480                 :            : #endif
     481                 :          0 : }
     482                 :            : // -----------------------------------------------------------------------------
     483                 :            : 
     484                 :          0 : void write_to_storage_stream( JNIEnv* env, jobject /*obj_this*/, jstring name, jstring key, jint v, DataLogFile* logger )
     485                 :            : {
     486                 :            :     OSL_UNUSED( logger );
     487                 :            : 
     488                 :          0 :     ::boost::shared_ptr<StreamHelper> pHelper = StorageContainer::getRegisteredStream(env,name,key);
     489                 :          0 :     Reference< XOutputStream> xOut = pHelper.get() ? pHelper->getOutputStream() : Reference< XOutputStream>();
     490                 :            :     OSL_ENSURE(xOut.is(),"Stream is NULL");
     491                 :            :     try
     492                 :            :     {
     493                 :          0 :         if ( xOut.is() )
     494                 :            :         {
     495                 :          0 :             Sequence< ::sal_Int8 > oneByte(4);
     496                 :          0 :             oneByte[0] = (sal_Int8) ((v >> 24) & 0xFF);
     497                 :          0 :             oneByte[1] = (sal_Int8) ((v >> 16) & 0xFF);
     498                 :          0 :             oneByte[2] = (sal_Int8) ((v >>  8) & 0xFF);
     499                 :          0 :             oneByte[3] = (sal_Int8) ((v >>  0) & 0xFF);
     500                 :            : 
     501                 :          0 :             xOut->writeBytes(oneByte);
     502                 :            : #ifdef HSQLDB_DBG
     503                 :            :             if ( logger )
     504                 :            :                 logger->write( oneByte.getConstArray(), 4 );
     505                 :            : #endif
     506                 :            :         }
     507                 :            :         else
     508                 :            :         {
     509                 :          0 :             ThrowException( env,
     510                 :            :                     "java/io/IOException",
     511                 :            :                     "No OutputStream");
     512                 :            :         }
     513                 :            :     }
     514                 :          0 :     catch(const Exception& e)
     515                 :            :     {
     516                 :            :         OSL_FAIL("Exception caught! : writeBytes(aData);");
     517                 :          0 :         StorageContainer::throwJavaException(e,env);
     518                 :          0 :     }
     519                 :          0 : }
     520                 :            : 
     521                 :            : // -----------------------------------------------------------------------------
     522                 :            : 
     523                 :            : /*
     524                 :            :  * Class:     com_sun_star_sdbcx_comp_hsqldb_NativeStorageAccess
     525                 :            :  * Method:    writeInt
     526                 :            :  * Signature: (Ljava/lang/String;Ljava/lang/String;I)V
     527                 :            :  */
     528                 :          0 : SAL_DLLPUBLIC_EXPORT void JNICALL Java_com_sun_star_sdbcx_comp_hsqldb_NativeStorageAccess_writeInt
     529                 :            :   (JNIEnv * env, jobject obj_this,jstring name, jstring key, jint v)
     530                 :            : {
     531                 :            : #ifdef HSQLDB_DBG
     532                 :            :     OperationLogFile aOpLog( env, name, "data" );
     533                 :            :     aOpLog.logOperation( "writeInt" );
     534                 :            : 
     535                 :            :     DataLogFile aDataLog( env, name, "data" );
     536                 :            :     write_to_storage_stream( env, obj_this, name, key, v, &aDataLog );
     537                 :            : #else
     538                 :          0 :     write_to_storage_stream( env, obj_this, name, key, v );
     539                 :            : #endif
     540                 :          0 : }
     541                 :            : 
     542                 :            : /* vim:set shiftwidth=4 softtabstop=4 expandtab: */

Generated by: LCOV version 1.10