qadevOOo/tests/java/mod/_stm/Pump.java

   1 /*************************************************************************
   2  *
   3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   4  *
   5  * Copyright 2008 by Sun Microsystems, Inc.
   6  *
   7  * OpenOffice.org - a multi-platform office productivity suite
   8  *
   9  * $RCSfile: Pump.java,v $
  10  * $Revision: 1.5 $
  11  *
  12  * This file is part of OpenOffice.org.
  13  *
  14  * OpenOffice.org is free software: you can redistribute it and/or modify
  15  * it under the terms of the GNU Lesser General Public License version 3
  16  * only, as published by the Free Software Foundation.
  17  *
  18  * OpenOffice.org is distributed in the hope that it will be useful,
  19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21  * GNU Lesser General Public License version 3 for more details
  22  * (a copy is included in the LICENSE file that accompanied this code).
  23  *
  24  * You should have received a copy of the GNU Lesser General Public License
  25  * version 3 along with OpenOffice.org.  If not, see
  26  * <http://www.openoffice.org/license.html>
  27  * for a copy of the LGPLv3 License.
  28  *
  29  ************************************************************************/
  30
  31 package mod._stm;
  32
  33 import java.io.PrintWriter;
  34
  35 import lib.StatusException;
  36 import lib.TestCase;
  37 import lib.TestEnvironment;
  38 import lib.TestParameters;
  39
  40 import com.sun.star.io.NotConnectedException;
  41 import com.sun.star.io.XActiveDataSink;
  42 import com.sun.star.io.XActiveDataSource;
  43 import com.sun.star.io.XInputStream;
  44 import com.sun.star.io.XOutputStream;
  45 import com.sun.star.lang.XMultiServiceFactory;
  46 import com.sun.star.uno.UnoRuntime;
  47 import com.sun.star.uno.XInterface;
  48
  49 /**
  50 * Test for object which is represented by service
  51 * <code>com.sun.star.io.Pump</code>. <p>
  52 * Object implements the following interfaces :
  53 * <ul>
  54 *  <li> <code>com::sun::star::io::XActiveDataSource</code></li>
  55 *  <li> <code>com::sun::star::io::XActiveDataControl</code></li>
  56 *  <li> <code>com::sun::star::io::XActiveDataSink</code></li>
  57 * </ul>
  58 * @see com.sun.star.io.Pump
  59 * @see com.sun.star.io.XActiveDataSource
  60 * @see com.sun.star.io.XActiveDataControl
  61 * @see com.sun.star.io.XActiveDataSink
  62 * @see ifc.io._XActiveDataSource
  63 * @see ifc.io._XActiveDataControl
  64 * @see ifc.io._XActiveDataSink
  65 */
  66 public class Pump extends TestCase {
  67
  68     /**
  69     * Creating a Testenvironment for the interfaces to be tested.
  70     * Creates an instance of the service <code>com.sun.star.io.Pump</code>.
  71     * Settings up input and output streams for the created pump.
  72     * Object relations created :
  73     * <ul>
  74     *  <li> <code>'InputStream'</code> for
  75     *      {@link ifc.io._XActiveDataSource}(an input stream to set) </li>
  76     *  <li> <code>'OutputStream'</code> for
  77     *      {@link ifc.io._XActiveDataSource}(an output stream to set) </li>
  78     * </ul>
  79     * @see com.sun.star.io.Pump
  80     */
  81     public TestEnvironment createTestEnvironment(
  82         TestParameters Param, PrintWriter log) throws StatusException {
  83
  84         Object oInterface = null;
  85         XMultiServiceFactory xMSF = (XMultiServiceFactory)Param.getMSF();
  86         XInterface oPipe;
  87
  88         // creating an instance of stm.Pump
  89         try {
  90             oInterface = xMSF.createInstance( "com.sun.star.io.Pump" );
  91             oPipe = (XInterface) xMSF.createInstance( "com.sun.star.io.Pipe" );
  92         } catch (com.sun.star.uno.Exception e) {
  93             e.printStackTrace(log);
  94             throw new StatusException("Can't create the needed objects.", e) ;
  95         }
  96
  97
  98         XInterface oObj = (XInterface) oInterface;
  99
 100         // setting up input and output streams for pump
 101         XActiveDataSink xSink = (XActiveDataSink)
 102             UnoRuntime.queryInterface(XActiveDataSink.class, oObj);
 103         XActiveDataSource xSource = (XActiveDataSource)
 104             UnoRuntime.queryInterface(XActiveDataSource.class, oObj);
 105
 106         XInputStream xInput = new MyInput();
 107         XOutputStream xOutput = new MyOutput();
 108
 109         xSink.setInputStream(xInput);
 110         xSource.setOutputStream(xOutput);
 111
 112         log.println("creating a new environment for object");
 113         TestEnvironment tEnv = new TestEnvironment( oObj );
 114
 115         // add object relations for ActiveDataSource and XActiveDataSink
 116         tEnv.addObjRelation("InputStream", oPipe);
 117         tEnv.addObjRelation("OutputStream", oPipe);
 118
 119         return tEnv;
 120     } // finish method getTestEnvironment
 121
 122     /**
 123     * XInputStream implementation to use with the test. It returns bytes of
 124     * which a simple string consists.
 125     */
 126     private static class MyInput implements XInputStream  {
 127         String str = "Pump tesing string" ;
 128
 129         public int readBytes(byte[][] bytes, int len)
 130             throws NotConnectedException{
 131
 132             if (str == null)
 133                 throw new NotConnectedException("Input stream was closed");
 134
 135             int actual = 0 ;
 136             if (len <= str.length()) {
 137                 String resStr = str.substring(0, len-1) ;
 138                 bytes[0] = resStr.getBytes() ;
 139                 actual = len ;
 140                 str = str.substring(len) ;
 141             } else {
 142                 bytes[0] = str.getBytes() ;
 143                 actual = str.length() ;
 144             }
 145
 146             return actual;
 147         }
 148
 149         public int readSomeBytes(byte[][] bytes, int len)
 150             throws NotConnectedException{
 151             return readBytes(bytes, len);
 152         }
 153
 154         public void skipBytes(int len) throws NotConnectedException {
 155             if (str == null)
 156                 throw new NotConnectedException("Stream was closed.") ;
 157
 158             if (len >= str.length())
 159                 str = "" ;
 160             else
 161                 str = str.substring(len) ;
 162         }
 163
 164         public void closeInput() throws NotConnectedException {
 165             if (str == null)
 166                 throw new NotConnectedException("Stream was closed.") ;
 167
 168             str = null ;
 169         }
 170
 171         public int available() throws NotConnectedException {
 172             if (str == null)
 173                 throw new NotConnectedException("Stream was closed.") ;
 174
 175             return str.length();
 176         }
 177     }
 178
 179     /**
 180     * Dummy XOutputStream implementation to use with the test. Does nothing.
 181     */
 182     private static class MyOutput implements XOutputStream {
 183         public void writeBytes(byte[] bytes) {
 184         }
 185
 186         public void flush() {
 187         }
 188
 189         public void closeOutput() {
 190         }
 191     }
 192 }
 193