diff options
Diffstat (limited to 'qadevOOo/tests/java/mod/_stm/Pump.java')
| -rw-r--r-- | qadevOOo/tests/java/mod/_stm/Pump.java | 190 |
1 files changed, 190 insertions, 0 deletions
diff --git a/qadevOOo/tests/java/mod/_stm/Pump.java b/qadevOOo/tests/java/mod/_stm/Pump.java new file mode 100644 index 000000000000..982223d8dab1 --- /dev/null +++ b/qadevOOo/tests/java/mod/_stm/Pump.java @@ -0,0 +1,190 @@ +/************************************************************************* + * + * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. + * + * Copyright 2000, 2010 Oracle and/or its affiliates. + * + * OpenOffice.org - a multi-platform office productivity suite + * + * This file is part of OpenOffice.org. + * + * OpenOffice.org is free software: you can redistribute it and/or modify + * it under the terms of the GNU Lesser General Public License version 3 + * only, as published by the Free Software Foundation. + * + * OpenOffice.org is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU Lesser General Public License version 3 for more details + * (a copy is included in the LICENSE file that accompanied this code). + * + * You should have received a copy of the GNU Lesser General Public License + * version 3 along with OpenOffice.org. If not, see + * <http://www.openoffice.org/license.html> + * for a copy of the LGPLv3 License. + * + ************************************************************************/ + +package mod._stm; + +import java.io.PrintWriter; + +import lib.StatusException; +import lib.TestCase; +import lib.TestEnvironment; +import lib.TestParameters; + +import com.sun.star.io.NotConnectedException; +import com.sun.star.io.XActiveDataSink; +import com.sun.star.io.XActiveDataSource; +import com.sun.star.io.XInputStream; +import com.sun.star.io.XOutputStream; +import com.sun.star.lang.XMultiServiceFactory; +import com.sun.star.uno.UnoRuntime; +import com.sun.star.uno.XInterface; + +/** +* Test for object which is represented by service +* <code>com.sun.star.io.Pump</code>. <p> +* Object implements the following interfaces : +* <ul> +* <li> <code>com::sun::star::io::XActiveDataSource</code></li> +* <li> <code>com::sun::star::io::XActiveDataControl</code></li> +* <li> <code>com::sun::star::io::XActiveDataSink</code></li> +* </ul> +* @see com.sun.star.io.Pump +* @see com.sun.star.io.XActiveDataSource +* @see com.sun.star.io.XActiveDataControl +* @see com.sun.star.io.XActiveDataSink +* @see ifc.io._XActiveDataSource +* @see ifc.io._XActiveDataControl +* @see ifc.io._XActiveDataSink +*/ +public class Pump extends TestCase { + + /** + * Creating a Testenvironment for the interfaces to be tested. + * Creates an instance of the service <code>com.sun.star.io.Pump</code>. + * Settings up input and output streams for the created pump. + * Object relations created : + * <ul> + * <li> <code>'InputStream'</code> for + * {@link ifc.io._XActiveDataSource}(an input stream to set) </li> + * <li> <code>'OutputStream'</code> for + * {@link ifc.io._XActiveDataSource}(an output stream to set) </li> + * </ul> + * @see com.sun.star.io.Pump + */ + public TestEnvironment createTestEnvironment( + TestParameters Param, PrintWriter log) throws StatusException { + + Object oInterface = null; + XMultiServiceFactory xMSF = (XMultiServiceFactory)Param.getMSF(); + XInterface oPipe; + + // creating an instance of stm.Pump + try { + oInterface = xMSF.createInstance( "com.sun.star.io.Pump" ); + oPipe = (XInterface) xMSF.createInstance( "com.sun.star.io.Pipe" ); + } catch (com.sun.star.uno.Exception e) { + e.printStackTrace(log); + throw new StatusException("Can't create the needed objects.", e) ; + } + + + XInterface oObj = (XInterface) oInterface; + + // setting up input and output streams for pump + XActiveDataSink xSink = (XActiveDataSink) + UnoRuntime.queryInterface(XActiveDataSink.class, oObj); + XActiveDataSource xSource = (XActiveDataSource) + UnoRuntime.queryInterface(XActiveDataSource.class, oObj); + + XInputStream xInput = new MyInput(); + XOutputStream xOutput = new MyOutput(); + + xSink.setInputStream(xInput); + xSource.setOutputStream(xOutput); + + log.println("creating a new environment for object"); + TestEnvironment tEnv = new TestEnvironment( oObj ); + + // add object relations for ActiveDataSource and XActiveDataSink + tEnv.addObjRelation("InputStream", oPipe); + tEnv.addObjRelation("OutputStream", oPipe); + + return tEnv; + } // finish method getTestEnvironment + + /** + * XInputStream implementation to use with the test. It returns bytes of + * which a simple string consists. + */ + private static class MyInput implements XInputStream { + String str = "Pump tesing string" ; + + public int readBytes(byte[][] bytes, int len) + throws NotConnectedException{ + + if (str == null) + throw new NotConnectedException("Input stream was closed"); + + int actual = 0 ; + if (len <= str.length()) { + String resStr = str.substring(0, len-1) ; + bytes[0] = resStr.getBytes() ; + actual = len ; + str = str.substring(len) ; + } else { + bytes[0] = str.getBytes() ; + actual = str.length() ; + } + + return actual; + } + + public int readSomeBytes(byte[][] bytes, int len) + throws NotConnectedException{ + return readBytes(bytes, len); + } + + public void skipBytes(int len) throws NotConnectedException { + if (str == null) + throw new NotConnectedException("Stream was closed.") ; + + if (len >= str.length()) + str = "" ; + else + str = str.substring(len) ; + } + + public void closeInput() throws NotConnectedException { + if (str == null) + throw new NotConnectedException("Stream was closed.") ; + + str = null ; + } + + public int available() throws NotConnectedException { + if (str == null) + throw new NotConnectedException("Stream was closed.") ; + + return str.length(); + } + } + + /** + * Dummy XOutputStream implementation to use with the test. Does nothing. + */ + private static class MyOutput implements XOutputStream { + public void writeBytes(byte[] bytes) { + } + + public void flush() { + } + + public void closeOutput() { + } + } +} + |