1*ef39d40dSAndrew Rist /************************************************************** 2cdf0e10cSrcweir * 3*ef39d40dSAndrew Rist * Licensed to the Apache Software Foundation (ASF) under one 4*ef39d40dSAndrew Rist * or more contributor license agreements. See the NOTICE file 5*ef39d40dSAndrew Rist * distributed with this work for additional information 6*ef39d40dSAndrew Rist * regarding copyright ownership. The ASF licenses this file 7*ef39d40dSAndrew Rist * to you under the Apache License, Version 2.0 (the 8*ef39d40dSAndrew Rist * "License"); you may not use this file except in compliance 9*ef39d40dSAndrew Rist * with the License. You may obtain a copy of the License at 10*ef39d40dSAndrew Rist * 11*ef39d40dSAndrew Rist * http://www.apache.org/licenses/LICENSE-2.0 12*ef39d40dSAndrew Rist * 13*ef39d40dSAndrew Rist * Unless required by applicable law or agreed to in writing, 14*ef39d40dSAndrew Rist * software distributed under the License is distributed on an 15*ef39d40dSAndrew Rist * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY 16*ef39d40dSAndrew Rist * KIND, either express or implied. See the License for the 17*ef39d40dSAndrew Rist * specific language governing permissions and limitations 18*ef39d40dSAndrew Rist * under the License. 19*ef39d40dSAndrew Rist * 20*ef39d40dSAndrew Rist *************************************************************/ 21*ef39d40dSAndrew Rist 22*ef39d40dSAndrew Rist 23cdf0e10cSrcweir 24cdf0e10cSrcweir package mod._streams.uno; 25cdf0e10cSrcweir 26cdf0e10cSrcweir import com.sun.star.io.NotConnectedException; 27cdf0e10cSrcweir import com.sun.star.io.XActiveDataSink; 28cdf0e10cSrcweir import com.sun.star.io.XActiveDataSource; 29cdf0e10cSrcweir import com.sun.star.io.XInputStream; 30cdf0e10cSrcweir import com.sun.star.io.XOutputStream; 31cdf0e10cSrcweir import com.sun.star.lang.XMultiServiceFactory; 32cdf0e10cSrcweir import com.sun.star.uno.UnoRuntime; 33cdf0e10cSrcweir import com.sun.star.uno.XInterface; 34cdf0e10cSrcweir import java.io.PrintWriter; 35cdf0e10cSrcweir import lib.StatusException; 36cdf0e10cSrcweir import lib.TestCase; 37cdf0e10cSrcweir import lib.TestEnvironment; 38cdf0e10cSrcweir import lib.TestParameters; 39cdf0e10cSrcweir 40cdf0e10cSrcweir /** 41cdf0e10cSrcweir * Test for object which is represented by service 42cdf0e10cSrcweir * <code>com.sun.star.io.Pump</code>. <p> 43cdf0e10cSrcweir * Object implements the following interfaces : 44cdf0e10cSrcweir * <ul> 45cdf0e10cSrcweir * <li> <code>com::sun::star::io::XActiveDataSource</code></li> 46cdf0e10cSrcweir * <li> <code>com::sun::star::io::XActiveDataControl</code></li> 47cdf0e10cSrcweir * <li> <code>com::sun::star::io::XActiveDataSink</code></li> 48cdf0e10cSrcweir * </ul> 49cdf0e10cSrcweir * @see com.sun.star.io.Pump 50cdf0e10cSrcweir * @see com.sun.star.io.XActiveDataSource 51cdf0e10cSrcweir * @see com.sun.star.io.XActiveDataControl 52cdf0e10cSrcweir * @see com.sun.star.io.XActiveDataSink 53cdf0e10cSrcweir * @see ifc.io._XActiveDataSource 54cdf0e10cSrcweir * @see ifc.io._XActiveDataControl 55cdf0e10cSrcweir * @see ifc.io._XActiveDataSink 56cdf0e10cSrcweir */ 57cdf0e10cSrcweir public class Pump extends TestCase { 58cdf0e10cSrcweir 59cdf0e10cSrcweir /** 60cdf0e10cSrcweir * Creating a Testenvironment for the interfaces to be tested. 61cdf0e10cSrcweir * Creates an instance of the service <code>com.sun.star.io.Pump</code>. 62cdf0e10cSrcweir * Settings up input and output streams for the created pump. 63cdf0e10cSrcweir * Object relations created : 64cdf0e10cSrcweir * <ul> 65cdf0e10cSrcweir * <li> <code>'InputStream'</code> for 66cdf0e10cSrcweir * {@link ifc.io._XActiveDataSource}(an input stream to set) </li> 67cdf0e10cSrcweir * <li> <code>'OutputStream'</code> for 68cdf0e10cSrcweir * {@link ifc.io._XActiveDataSource}(an output stream to set) </li> 69cdf0e10cSrcweir * </ul> 70cdf0e10cSrcweir * @see com.sun.star.io.Pump 71cdf0e10cSrcweir */ createTestEnvironment(TestParameters Param, PrintWriter log)72cdf0e10cSrcweir protected TestEnvironment createTestEnvironment(TestParameters Param, PrintWriter log) { 73cdf0e10cSrcweir 74cdf0e10cSrcweir Object oInterface = null; 75cdf0e10cSrcweir XMultiServiceFactory xMSF = (XMultiServiceFactory)Param.getMSF(); 76cdf0e10cSrcweir XInterface oPipe; 77cdf0e10cSrcweir 78cdf0e10cSrcweir // creating an instance of stm.Pump 79cdf0e10cSrcweir try { 80cdf0e10cSrcweir oInterface = xMSF.createInstance( "com.sun.star.io.Pump" ); 81cdf0e10cSrcweir oPipe = (XInterface) xMSF.createInstance( "com.sun.star.io.Pipe" ); 82cdf0e10cSrcweir } catch (com.sun.star.uno.Exception e) { 83cdf0e10cSrcweir e.printStackTrace(log); 84cdf0e10cSrcweir throw new StatusException("Can't create the needed objects.", e) ; 85cdf0e10cSrcweir } 86cdf0e10cSrcweir 87cdf0e10cSrcweir 88cdf0e10cSrcweir XInterface oObj = (XInterface) oInterface; 89cdf0e10cSrcweir 90cdf0e10cSrcweir // setting up input and output streams for pump 91cdf0e10cSrcweir XActiveDataSink xSink = (XActiveDataSink) 92cdf0e10cSrcweir UnoRuntime.queryInterface(XActiveDataSink.class, oObj); 93cdf0e10cSrcweir XActiveDataSource xSource = (XActiveDataSource) 94cdf0e10cSrcweir UnoRuntime.queryInterface(XActiveDataSource.class, oObj); 95cdf0e10cSrcweir 96cdf0e10cSrcweir XInputStream xInput = new MyInput(); 97cdf0e10cSrcweir XOutputStream xOutput = new MyOutput(); 98cdf0e10cSrcweir 99cdf0e10cSrcweir xSink.setInputStream(xInput); 100cdf0e10cSrcweir xSource.setOutputStream(xOutput); 101cdf0e10cSrcweir 102cdf0e10cSrcweir log.println("creating a new environment for object"); 103cdf0e10cSrcweir TestEnvironment tEnv = new TestEnvironment( oObj ); 104cdf0e10cSrcweir 105cdf0e10cSrcweir // add object relations for ActiveDataSource and XActiveDataSink 106cdf0e10cSrcweir tEnv.addObjRelation("InputStream", oPipe); 107cdf0e10cSrcweir tEnv.addObjRelation("OutputStream", oPipe); 108cdf0e10cSrcweir 109cdf0e10cSrcweir return tEnv; 110cdf0e10cSrcweir } // finish method getTestEnvironment 111cdf0e10cSrcweir 112cdf0e10cSrcweir /** 113cdf0e10cSrcweir * XInputStream implementation to use with the test. It returns bytes of 114cdf0e10cSrcweir * which a simple string consists. 115cdf0e10cSrcweir */ 116cdf0e10cSrcweir private static class MyInput implements XInputStream { 117cdf0e10cSrcweir String str = "Pump tesing string" ; 118cdf0e10cSrcweir readBytes(byte[][] bytes, int len)119cdf0e10cSrcweir public int readBytes(byte[][] bytes, int len) 120cdf0e10cSrcweir throws NotConnectedException{ 121cdf0e10cSrcweir 122cdf0e10cSrcweir if (str == null) 123cdf0e10cSrcweir throw new NotConnectedException("Input stream was closed"); 124cdf0e10cSrcweir 125cdf0e10cSrcweir int actual = 0 ; 126cdf0e10cSrcweir if (len <= str.length()) { 127cdf0e10cSrcweir String resStr = str.substring(0, len-1) ; 128cdf0e10cSrcweir bytes[0] = resStr.getBytes() ; 129cdf0e10cSrcweir actual = len ; 130cdf0e10cSrcweir str = str.substring(len) ; 131cdf0e10cSrcweir } else { 132cdf0e10cSrcweir bytes[0] = str.getBytes() ; 133cdf0e10cSrcweir actual = str.length() ; 134cdf0e10cSrcweir } 135cdf0e10cSrcweir 136cdf0e10cSrcweir return actual; 137cdf0e10cSrcweir } 138cdf0e10cSrcweir readSomeBytes(byte[][] bytes, int len)139cdf0e10cSrcweir public int readSomeBytes(byte[][] bytes, int len) 140cdf0e10cSrcweir throws NotConnectedException{ 141cdf0e10cSrcweir return readBytes(bytes, len); 142cdf0e10cSrcweir } 143cdf0e10cSrcweir skipBytes(int len)144cdf0e10cSrcweir public void skipBytes(int len) throws NotConnectedException { 145cdf0e10cSrcweir if (str == null) 146cdf0e10cSrcweir throw new NotConnectedException("Stream was closed.") ; 147cdf0e10cSrcweir 148cdf0e10cSrcweir if (len >= str.length()) 149cdf0e10cSrcweir str = "" ; 150cdf0e10cSrcweir else 151cdf0e10cSrcweir str = str.substring(len) ; 152cdf0e10cSrcweir } 153cdf0e10cSrcweir closeInput()154cdf0e10cSrcweir public void closeInput() throws NotConnectedException { 155cdf0e10cSrcweir if (str == null) 156cdf0e10cSrcweir throw new NotConnectedException("Stream was closed.") ; 157cdf0e10cSrcweir 158cdf0e10cSrcweir str = null ; 159cdf0e10cSrcweir } 160cdf0e10cSrcweir available()161cdf0e10cSrcweir public int available() throws NotConnectedException { 162cdf0e10cSrcweir if (str == null) 163cdf0e10cSrcweir throw new NotConnectedException("Stream was closed.") ; 164cdf0e10cSrcweir 165cdf0e10cSrcweir return str.length(); 166cdf0e10cSrcweir } 167cdf0e10cSrcweir } 168cdf0e10cSrcweir 169cdf0e10cSrcweir /** 170cdf0e10cSrcweir * Dummy XOutputStream implementation to use with the test. Does nothing. 171cdf0e10cSrcweir */ 172cdf0e10cSrcweir private static class MyOutput implements XOutputStream { writeBytes(byte[] bytes)173cdf0e10cSrcweir public void writeBytes(byte[] bytes) { 174cdf0e10cSrcweir } 175cdf0e10cSrcweir flush()176cdf0e10cSrcweir public void flush() { 177cdf0e10cSrcweir } 178cdf0e10cSrcweir closeOutput()179cdf0e10cSrcweir public void closeOutput() { 180cdf0e10cSrcweir } 181cdf0e10cSrcweir } 182cdf0e10cSrcweir } 183cdf0e10cSrcweir 184