1*b1cdbd2cSJim Jagielski /**************************************************************
2*b1cdbd2cSJim Jagielski *
3*b1cdbd2cSJim Jagielski * Licensed to the Apache Software Foundation (ASF) under one
4*b1cdbd2cSJim Jagielski * or more contributor license agreements. See the NOTICE file
5*b1cdbd2cSJim Jagielski * distributed with this work for additional information
6*b1cdbd2cSJim Jagielski * regarding copyright ownership. The ASF licenses this file
7*b1cdbd2cSJim Jagielski * to you under the Apache License, Version 2.0 (the
8*b1cdbd2cSJim Jagielski * "License"); you may not use this file except in compliance
9*b1cdbd2cSJim Jagielski * with the License. You may obtain a copy of the License at
10*b1cdbd2cSJim Jagielski *
11*b1cdbd2cSJim Jagielski * http://www.apache.org/licenses/LICENSE-2.0
12*b1cdbd2cSJim Jagielski *
13*b1cdbd2cSJim Jagielski * Unless required by applicable law or agreed to in writing,
14*b1cdbd2cSJim Jagielski * software distributed under the License is distributed on an
15*b1cdbd2cSJim Jagielski * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16*b1cdbd2cSJim Jagielski * KIND, either express or implied. See the License for the
17*b1cdbd2cSJim Jagielski * specific language governing permissions and limitations
18*b1cdbd2cSJim Jagielski * under the License.
19*b1cdbd2cSJim Jagielski *
20*b1cdbd2cSJim Jagielski *************************************************************/
21*b1cdbd2cSJim Jagielski
22*b1cdbd2cSJim Jagielski
23*b1cdbd2cSJim Jagielski
24*b1cdbd2cSJim Jagielski // MARKER(update_precomp.py): autogen include statement, do not remove
25*b1cdbd2cSJim Jagielski #include "precompiled_connectivity.hxx"
26*b1cdbd2cSJim Jagielski #include "java/io/InputStream.hxx"
27*b1cdbd2cSJim Jagielski #include "java/tools.hxx"
28*b1cdbd2cSJim Jagielski
29*b1cdbd2cSJim Jagielski #include <string.h>
30*b1cdbd2cSJim Jagielski
31*b1cdbd2cSJim Jagielski using namespace connectivity;
32*b1cdbd2cSJim Jagielski //**************************************************************
33*b1cdbd2cSJim Jagielski //************ Class: java.io.InputStream
34*b1cdbd2cSJim Jagielski //**************************************************************
35*b1cdbd2cSJim Jagielski
36*b1cdbd2cSJim Jagielski jclass java_io_InputStream::theClass = 0;
java_io_InputStream(JNIEnv * pEnv,jobject myObj)37*b1cdbd2cSJim Jagielski java_io_InputStream::java_io_InputStream( JNIEnv * pEnv, jobject myObj )
38*b1cdbd2cSJim Jagielski : java_lang_Object( pEnv, myObj )
39*b1cdbd2cSJim Jagielski {
40*b1cdbd2cSJim Jagielski SDBThreadAttach::addRef();
41*b1cdbd2cSJim Jagielski }
~java_io_InputStream()42*b1cdbd2cSJim Jagielski java_io_InputStream::~java_io_InputStream()
43*b1cdbd2cSJim Jagielski {
44*b1cdbd2cSJim Jagielski SDBThreadAttach::releaseRef();
45*b1cdbd2cSJim Jagielski }
46*b1cdbd2cSJim Jagielski
getMyClass() const47*b1cdbd2cSJim Jagielski jclass java_io_InputStream::getMyClass() const
48*b1cdbd2cSJim Jagielski {
49*b1cdbd2cSJim Jagielski // die Klasse muss nur einmal geholt werden, daher statisch
50*b1cdbd2cSJim Jagielski if( !theClass )
51*b1cdbd2cSJim Jagielski theClass = findMyClass("java/io/InputStream");
52*b1cdbd2cSJim Jagielski return theClass;
53*b1cdbd2cSJim Jagielski }
54*b1cdbd2cSJim Jagielski
55*b1cdbd2cSJim Jagielski
readSomeBytes(::com::sun::star::uno::Sequence<sal_Int8> & aData,sal_Int32 nMaxBytesToRead)56*b1cdbd2cSJim Jagielski sal_Int32 SAL_CALL java_io_InputStream::readSomeBytes( ::com::sun::star::uno::Sequence< sal_Int8 >& aData, sal_Int32 nMaxBytesToRead ) throw(::com::sun::star::io::NotConnectedException, ::com::sun::star::io::BufferSizeExceededException, ::com::sun::star::io::IOException, ::com::sun::star::uno::RuntimeException)
57*b1cdbd2cSJim Jagielski {
58*b1cdbd2cSJim Jagielski return readBytes(aData,nMaxBytesToRead);
59*b1cdbd2cSJim Jagielski }
60*b1cdbd2cSJim Jagielski
skipBytes(sal_Int32 nBytesToSkip)61*b1cdbd2cSJim Jagielski void SAL_CALL java_io_InputStream::skipBytes( sal_Int32 nBytesToSkip ) throw(::com::sun::star::io::NotConnectedException, ::com::sun::star::io::BufferSizeExceededException, ::com::sun::star::io::IOException, ::com::sun::star::uno::RuntimeException)
62*b1cdbd2cSJim Jagielski {
63*b1cdbd2cSJim Jagielski static jmethodID mID(NULL);
64*b1cdbd2cSJim Jagielski callIntMethodWithIntArg("skip",mID,nBytesToSkip);
65*b1cdbd2cSJim Jagielski }
66*b1cdbd2cSJim Jagielski
available()67*b1cdbd2cSJim Jagielski sal_Int32 SAL_CALL java_io_InputStream::available( ) throw(::com::sun::star::io::NotConnectedException, ::com::sun::star::io::IOException, ::com::sun::star::uno::RuntimeException)
68*b1cdbd2cSJim Jagielski {
69*b1cdbd2cSJim Jagielski static jmethodID mID(NULL);
70*b1cdbd2cSJim Jagielski return callIntMethod("available",mID);
71*b1cdbd2cSJim Jagielski }
closeInput()72*b1cdbd2cSJim Jagielski void SAL_CALL java_io_InputStream::closeInput( ) throw(::com::sun::star::io::NotConnectedException, ::com::sun::star::io::IOException, ::com::sun::star::uno::RuntimeException)
73*b1cdbd2cSJim Jagielski {
74*b1cdbd2cSJim Jagielski static jmethodID mID(NULL);
75*b1cdbd2cSJim Jagielski callVoidMethod("close",mID);
76*b1cdbd2cSJim Jagielski }
77*b1cdbd2cSJim Jagielski // -----------------------------------------------------
readBytes(::com::sun::star::uno::Sequence<sal_Int8> & aData,sal_Int32 nBytesToRead)78*b1cdbd2cSJim Jagielski sal_Int32 SAL_CALL java_io_InputStream::readBytes( ::com::sun::star::uno::Sequence< sal_Int8 >& aData, sal_Int32 nBytesToRead ) throw(::com::sun::star::io::NotConnectedException, ::com::sun::star::io::BufferSizeExceededException, ::com::sun::star::io::IOException, ::com::sun::star::uno::RuntimeException)
79*b1cdbd2cSJim Jagielski {
80*b1cdbd2cSJim Jagielski if (nBytesToRead < 0)
81*b1cdbd2cSJim Jagielski throw ::com::sun::star::io::BufferSizeExceededException( ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( OSL_LOG_PREFIX ) ), *this );
82*b1cdbd2cSJim Jagielski
83*b1cdbd2cSJim Jagielski jint out(0);
84*b1cdbd2cSJim Jagielski SDBThreadAttach t; OSL_ENSURE(t.pEnv,"Java Enviroment geloescht worden!");
85*b1cdbd2cSJim Jagielski
86*b1cdbd2cSJim Jagielski {
87*b1cdbd2cSJim Jagielski jbyteArray pByteArray = t.pEnv->NewByteArray(nBytesToRead);
88*b1cdbd2cSJim Jagielski static const char * cSignature = "([BII)I";
89*b1cdbd2cSJim Jagielski static const char * cMethodName = "read";
90*b1cdbd2cSJim Jagielski // Java-Call absetzen
91*b1cdbd2cSJim Jagielski static jmethodID mID(NULL);
92*b1cdbd2cSJim Jagielski obtainMethodId(t.pEnv, cMethodName,cSignature, mID);
93*b1cdbd2cSJim Jagielski out = t.pEnv->CallIntMethod( object, mID, pByteArray, 0, nBytesToRead );
94*b1cdbd2cSJim Jagielski if ( !out )
95*b1cdbd2cSJim Jagielski ThrowSQLException(t.pEnv,*this);
96*b1cdbd2cSJim Jagielski if(out > 0)
97*b1cdbd2cSJim Jagielski {
98*b1cdbd2cSJim Jagielski jboolean p = sal_False;
99*b1cdbd2cSJim Jagielski aData.realloc ( out );
100*b1cdbd2cSJim Jagielski rtl_copyMemory(aData.getArray(),t.pEnv->GetByteArrayElements(pByteArray,&p),out);
101*b1cdbd2cSJim Jagielski }
102*b1cdbd2cSJim Jagielski t.pEnv->DeleteLocalRef((jbyteArray)pByteArray);
103*b1cdbd2cSJim Jagielski } //t.pEnv
104*b1cdbd2cSJim Jagielski return out;
105*b1cdbd2cSJim Jagielski }
106*b1cdbd2cSJim Jagielski
107