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._stm; 25cdf0e10cSrcweir 26cdf0e10cSrcweir import java.io.PrintWriter; 27cdf0e10cSrcweir import java.util.Vector; 28cdf0e10cSrcweir 29cdf0e10cSrcweir import lib.StatusException; 30cdf0e10cSrcweir import lib.TestCase; 31cdf0e10cSrcweir import lib.TestEnvironment; 32cdf0e10cSrcweir import lib.TestParameters; 33cdf0e10cSrcweir 34cdf0e10cSrcweir import com.sun.star.io.XActiveDataSink; 35cdf0e10cSrcweir import com.sun.star.io.XActiveDataSource; 36cdf0e10cSrcweir import com.sun.star.io.XInputStream; 37cdf0e10cSrcweir import com.sun.star.io.XObjectInputStream; 38cdf0e10cSrcweir import com.sun.star.io.XObjectOutputStream; 39cdf0e10cSrcweir import com.sun.star.io.XOutputStream; 40cdf0e10cSrcweir import com.sun.star.io.XPersistObject; 41cdf0e10cSrcweir import com.sun.star.lang.XMultiServiceFactory; 42cdf0e10cSrcweir import com.sun.star.registry.CannotRegisterImplementationException; 43cdf0e10cSrcweir import com.sun.star.registry.XImplementationRegistration; 44cdf0e10cSrcweir import com.sun.star.registry.XSimpleRegistry; 45cdf0e10cSrcweir import com.sun.star.uno.UnoRuntime; 46cdf0e10cSrcweir import com.sun.star.uno.XInterface; 47cdf0e10cSrcweir 48cdf0e10cSrcweir /** 49cdf0e10cSrcweir * Test for object which is represented by service 50cdf0e10cSrcweir * <code>com.sun.star.io.ObjectInputStream</code>. <p> 51cdf0e10cSrcweir * Object implements the following interfaces : 52cdf0e10cSrcweir * <ul> 53cdf0e10cSrcweir * <li> <code>com::sun::star::io::XInputStream</code></li> 54cdf0e10cSrcweir * <li> <code>com::sun::star::io::XMarkableStream</code></li> 55cdf0e10cSrcweir * <li> <code>com::sun::star::io::XDataInputStream</code></li> 56cdf0e10cSrcweir * <li> <code>com::sun::star::io::XConnectable</code></li> 57cdf0e10cSrcweir * <li> <code>com::sun::star::io::XActiveDataSink</code></li> 58cdf0e10cSrcweir * <li> <code>com::sun::star::io::XObjectInputStream</code></li> 59cdf0e10cSrcweir * </ul> 60cdf0e10cSrcweir * The following files used by this test : 61cdf0e10cSrcweir * <ul> 62cdf0e10cSrcweir * <li><b> MyPersistObjectImpl.jar </b> : the implementation of the persist 63cdf0e10cSrcweir * object</li> 64cdf0e10cSrcweir * </ul> <p> 65cdf0e10cSrcweir * @see com.sun.star.io.ObjectInputStream 66cdf0e10cSrcweir * @see com.sun.star.io.XInputStream 67cdf0e10cSrcweir * @see com.sun.star.io.XMarkableStream 68cdf0e10cSrcweir * @see com.sun.star.io.XDataInputStream 69cdf0e10cSrcweir * @see com.sun.star.io.XConnectable 70cdf0e10cSrcweir * @see com.sun.star.io.XActiveDataSink 71cdf0e10cSrcweir * @see com.sun.star.io.XObjectInputStream 72cdf0e10cSrcweir * @see ifc.io._XInputStream 73cdf0e10cSrcweir * @see ifc.io._XMarkableStream 74cdf0e10cSrcweir * @see ifc.io._XDataInputStream 75cdf0e10cSrcweir * @see ifc.io._XConnectable 76cdf0e10cSrcweir * @see ifc.io._XActiveDataSink 77cdf0e10cSrcweir * @see ifc.io._XObjectInputStream 78cdf0e10cSrcweir */ 79cdf0e10cSrcweir public class ObjectInputStream extends TestCase { 80cdf0e10cSrcweir 81cdf0e10cSrcweir /** 82cdf0e10cSrcweir * Register the implementation of service 83cdf0e10cSrcweir * <code>com.sun.star.cmp.PersistObject</code> if not yet registered. 84cdf0e10cSrcweir * @see com.sun.star.cmp.PersistObject 85cdf0e10cSrcweir */ initialize(TestParameters tParam, PrintWriter log)86cdf0e10cSrcweir public void initialize(TestParameters tParam, PrintWriter log) { 87cdf0e10cSrcweir XMultiServiceFactory xMSF = (XMultiServiceFactory)tParam.getMSF(); 88cdf0e10cSrcweir Object oPersObj = null; 89cdf0e10cSrcweir // test first if object is already registered 90cdf0e10cSrcweir try { 91cdf0e10cSrcweir oPersObj = xMSF.createInstance("com.sun.star.cmp.PersistObject"); 92cdf0e10cSrcweir } 93cdf0e10cSrcweir catch( com.sun.star.uno.Exception e ) { 94cdf0e10cSrcweir log.println("Could not create instance of PersistObject"); 95cdf0e10cSrcweir e.printStackTrace(log); 96cdf0e10cSrcweir log.println("Going on with test..."); 97cdf0e10cSrcweir } 98cdf0e10cSrcweir if ( oPersObj == null ) { 99cdf0e10cSrcweir // object is not available: it has to be registered 100cdf0e10cSrcweir String url = util.utils.getFullTestURL 101cdf0e10cSrcweir ("qadevlibs/MyPersistObjectImpl.jar"); 102cdf0e10cSrcweir XImplementationRegistration xir; 103cdf0e10cSrcweir try { 104cdf0e10cSrcweir Object o = xMSF.createInstance( 105cdf0e10cSrcweir "com.sun.star.registry.ImplementationRegistration"); 106cdf0e10cSrcweir xir = (XImplementationRegistration) 107cdf0e10cSrcweir UnoRuntime.queryInterface( 108cdf0e10cSrcweir XImplementationRegistration.class, o); 109cdf0e10cSrcweir 110cdf0e10cSrcweir } 111cdf0e10cSrcweir catch (com.sun.star.uno.Exception e) { 112cdf0e10cSrcweir System.err.println( 113cdf0e10cSrcweir "Couldn't create implementation registration"); 114cdf0e10cSrcweir e.printStackTrace(); 115cdf0e10cSrcweir throw new StatusException("Couldn't create ImplReg", e); 116cdf0e10cSrcweir } 117cdf0e10cSrcweir 118cdf0e10cSrcweir XSimpleRegistry xReg = null; 119cdf0e10cSrcweir try { 120cdf0e10cSrcweir System.out.println("Register library: " + url); 121cdf0e10cSrcweir xir.registerImplementation( 122cdf0e10cSrcweir "com.sun.star.loader.Java2", url, xReg); 123cdf0e10cSrcweir System.out.println("...done"); 124cdf0e10cSrcweir } catch (CannotRegisterImplementationException e) { 125cdf0e10cSrcweir System.err.println("Name: " + url + " msg: " + 126cdf0e10cSrcweir e.getMessage()); 127cdf0e10cSrcweir e.printStackTrace(); 128cdf0e10cSrcweir throw new StatusException( 129cdf0e10cSrcweir "Couldn't register MyPersistObject", e); 130cdf0e10cSrcweir } 131cdf0e10cSrcweir } 132cdf0e10cSrcweir } 133cdf0e10cSrcweir 134cdf0e10cSrcweir /** 135cdf0e10cSrcweir * Creating a Testenvironment for the interfaces to be tested. 136cdf0e10cSrcweir * Creates an instances of services 137cdf0e10cSrcweir * <code>com.sun.star.io.ObjectInputStream</code>, 138cdf0e10cSrcweir * <code>com.sun.star.io.ObjectOutputStream</code>, 139cdf0e10cSrcweir * <code>com.sun.star.io.Pipe</code>, 140cdf0e10cSrcweir * <code>com.sun.star.io.MarkableInputStream</code> and 141cdf0e10cSrcweir * <code>com.sun.star.io.MarkableOutputStream</code>. Plugs the created 142cdf0e10cSrcweir * markable output stream as output stream for the created 143cdf0e10cSrcweir * <code>ObjectOutputStream</code>. Plugs the created pipe as output stream 144cdf0e10cSrcweir * for the created <code>MarkableOutputStream</code>. Plugs the created 145cdf0e10cSrcweir * markable input stream as input stream for the created 146cdf0e10cSrcweir * <code>ObjectInputStream</code>. Plugs the created pipe as input stream 147cdf0e10cSrcweir * for the created <code>MarkableInputStream</code>. Creates an instance 148cdf0e10cSrcweir * of the service <code>com.sun.star.cmp.PersistObject</code> and writes 149cdf0e10cSrcweir * the created object to the object output stream. 150cdf0e10cSrcweir * Object relations created : 151cdf0e10cSrcweir * <ul> 152cdf0e10cSrcweir * <li> <code>'PersistObject'</code> for 153cdf0e10cSrcweir * {@link ifc.io._XObjectInputStream}(the created instance of the 154cdf0e10cSrcweir * persist object ) </li> 155cdf0e10cSrcweir * <li> <code>'StreamData'</code> for 156cdf0e10cSrcweir * {@link ifc.io._XDataInputStream}(the data that should be written into 157cdf0e10cSrcweir * the stream) </li> 158cdf0e10cSrcweir * <li> <code>'ByteData'</code> for 159cdf0e10cSrcweir * {@link ifc.io._XInputStream}(the data that should be written into 160cdf0e10cSrcweir * the stream) </li> 161cdf0e10cSrcweir * <li> <code>'StreamWriter'</code> for 162cdf0e10cSrcweir * {@link ifc.io._XDataInputStream} 163cdf0e10cSrcweir * {@link ifc.io._XObjectInputStream} 164cdf0e10cSrcweir * {@link ifc.io._XInputStream}(a stream to write data to) </li> 165cdf0e10cSrcweir * <li> <code>'Connectable'</code> for 166cdf0e10cSrcweir * {@link ifc.io._XConnectable} 167cdf0e10cSrcweir * (another object that can be connected) </li> 168cdf0e10cSrcweir * <li> <code>'InputStream'</code> for 169cdf0e10cSrcweir * {@link ifc.io._XActiveDataSink}(an input stream to set and get) </li> 170cdf0e10cSrcweir * </ul> 171cdf0e10cSrcweir * @see com.sun.star.io.ObjectInputStream 172cdf0e10cSrcweir * @see com.sun.star.io.ObjectOutputStream 173cdf0e10cSrcweir * @see com.sun.star.io.Pipe 174cdf0e10cSrcweir * @see com.sun.star.io.MarkableInputStream 175cdf0e10cSrcweir * @see com.sun.star.io.MarkableOutputStream 176cdf0e10cSrcweir * @see com.sun.star.cmp.PersistObject 177cdf0e10cSrcweir */ createTestEnvironment( TestParameters Param, PrintWriter log)178cdf0e10cSrcweir public TestEnvironment createTestEnvironment( 179cdf0e10cSrcweir TestParameters Param, PrintWriter log) throws StatusException { 180cdf0e10cSrcweir 181cdf0e10cSrcweir System.out.println("create TestEnvironment started."); 182cdf0e10cSrcweir XMultiServiceFactory xMSF = (XMultiServiceFactory)Param.getMSF(); 183cdf0e10cSrcweir Object ostream = null; 184cdf0e10cSrcweir Object aPipe = null; 185cdf0e10cSrcweir Object mostream = null; 186cdf0e10cSrcweir Object mistream = null; 187cdf0e10cSrcweir Object istream = null; 188cdf0e10cSrcweir Object xConnect = null; 189cdf0e10cSrcweir try { 190cdf0e10cSrcweir istream = xMSF.createInstance 191cdf0e10cSrcweir ("com.sun.star.io.ObjectInputStream"); 192cdf0e10cSrcweir ostream = xMSF.createInstance 193cdf0e10cSrcweir ("com.sun.star.io.ObjectOutputStream"); 194cdf0e10cSrcweir aPipe = xMSF.createInstance 195cdf0e10cSrcweir ("com.sun.star.io.Pipe"); 196cdf0e10cSrcweir mistream = xMSF.createInstance 197cdf0e10cSrcweir ("com.sun.star.io.MarkableInputStream"); 198cdf0e10cSrcweir mostream = xMSF.createInstance 199cdf0e10cSrcweir ("com.sun.star.io.MarkableOutputStream"); 200cdf0e10cSrcweir xConnect = (XInterface)xMSF.createInstance 201cdf0e10cSrcweir ("com.sun.star.io.DataInputStream") ; 202cdf0e10cSrcweir 203cdf0e10cSrcweir } catch( com.sun.star.uno.Exception e ) { 204cdf0e10cSrcweir e.printStackTrace(log); 205cdf0e10cSrcweir throw new StatusException("Couldn't create instance", e); 206cdf0e10cSrcweir } 207cdf0e10cSrcweir // Creating construction : 208cdf0e10cSrcweir // ObjectOutputStream -> MarkableOutputStream -> Pipe -> 209cdf0e10cSrcweir // -> MarkableInputStream -> ObjectInputStream 210cdf0e10cSrcweir XActiveDataSource xdSo = (XActiveDataSource) 211cdf0e10cSrcweir UnoRuntime.queryInterface(XActiveDataSource.class, ostream); 212cdf0e10cSrcweir 213cdf0e10cSrcweir XActiveDataSource xdSmo = (XActiveDataSource) 214cdf0e10cSrcweir UnoRuntime.queryInterface(XActiveDataSource.class, mostream); 215cdf0e10cSrcweir 216cdf0e10cSrcweir XOutputStream moStream = (XOutputStream) 217cdf0e10cSrcweir UnoRuntime.queryInterface(XOutputStream.class, mostream); 218cdf0e10cSrcweir 219cdf0e10cSrcweir XOutputStream PipeOut = (XOutputStream) 220cdf0e10cSrcweir UnoRuntime.queryInterface(XOutputStream.class, aPipe); 221cdf0e10cSrcweir XInputStream PipeIn = (XInputStream) 222cdf0e10cSrcweir UnoRuntime.queryInterface(XInputStream.class, aPipe); 223cdf0e10cSrcweir 224cdf0e10cSrcweir xdSo.setOutputStream(moStream); 225cdf0e10cSrcweir xdSmo.setOutputStream(PipeOut); 226cdf0e10cSrcweir 227cdf0e10cSrcweir XObjectInputStream iStream = (XObjectInputStream) 228cdf0e10cSrcweir UnoRuntime.queryInterface(XObjectInputStream.class, istream); 229cdf0e10cSrcweir XObjectOutputStream oStream = null; 230cdf0e10cSrcweir oStream = (XObjectOutputStream) 231cdf0e10cSrcweir UnoRuntime.queryInterface(XObjectOutputStream.class, ostream); 232cdf0e10cSrcweir 233cdf0e10cSrcweir XActiveDataSink xmSi = (XActiveDataSink) 234cdf0e10cSrcweir UnoRuntime.queryInterface(XActiveDataSink.class, mistream); 235cdf0e10cSrcweir XInputStream xmIstream = (XInputStream) 236cdf0e10cSrcweir UnoRuntime.queryInterface(XInputStream.class, mistream); 237cdf0e10cSrcweir 238cdf0e10cSrcweir XActiveDataSink xdSi = (XActiveDataSink) UnoRuntime.queryInterface 239cdf0e10cSrcweir (XActiveDataSink.class, istream); 240cdf0e10cSrcweir xdSi.setInputStream(xmIstream); 241cdf0e10cSrcweir xmSi.setInputStream(PipeIn); 242cdf0e10cSrcweir 243cdf0e10cSrcweir // creating Persist object which has to be written 244cdf0e10cSrcweir XPersistObject xPersObj = null; 245cdf0e10cSrcweir try { 246cdf0e10cSrcweir Object oPersObj = xMSF.createInstance 247cdf0e10cSrcweir ("com.sun.star.cmp.PersistObject"); 248cdf0e10cSrcweir xPersObj = (XPersistObject) 249cdf0e10cSrcweir UnoRuntime.queryInterface(XPersistObject.class, oPersObj); 250cdf0e10cSrcweir } catch (com.sun.star.uno.Exception e) { 251cdf0e10cSrcweir e.printStackTrace(log); 252cdf0e10cSrcweir throw new StatusException("Can't write persist object.", e); 253cdf0e10cSrcweir } 254cdf0e10cSrcweir 255cdf0e10cSrcweir 256cdf0e10cSrcweir 257cdf0e10cSrcweir // all data types for writing to an XDataInputStream 258cdf0e10cSrcweir Vector data = new Vector() ; 259cdf0e10cSrcweir data.add(new Boolean(true)) ; 260cdf0e10cSrcweir data.add(new Byte((byte)123)) ; 261cdf0e10cSrcweir data.add(new Character((char)1234)) ; 262cdf0e10cSrcweir data.add(new Short((short)1234)) ; 263cdf0e10cSrcweir data.add(new Integer(123456)) ; 264cdf0e10cSrcweir data.add(new Float(1.234)) ; 265cdf0e10cSrcweir data.add(new Double(1.23456)) ; 266cdf0e10cSrcweir data.add("DataInputStream") ; 267cdf0e10cSrcweir // information for writing to the pipe 268cdf0e10cSrcweir byte[] byteData = new byte[] { 269cdf0e10cSrcweir 1, 2, 3, 4, 5, 6, 7, 8 } ; 270cdf0e10cSrcweir 271cdf0e10cSrcweir 272cdf0e10cSrcweir System.out.println("create environment"); 273cdf0e10cSrcweir XInterface oObj = iStream; 274cdf0e10cSrcweir log.println( "creating a new environment for object" ); 275cdf0e10cSrcweir TestEnvironment tEnv = new TestEnvironment( oObj ); 276cdf0e10cSrcweir 277cdf0e10cSrcweir // adding persistent object 278cdf0e10cSrcweir tEnv.addObjRelation("PersistObject", xPersObj); 279cdf0e10cSrcweir // add a connectable 280cdf0e10cSrcweir tEnv.addObjRelation("Connectable", xConnect); 281cdf0e10cSrcweir tEnv.addObjRelation("StreamWriter", oStream); 282cdf0e10cSrcweir // for XActiveDataSink 283cdf0e10cSrcweir tEnv.addObjRelation("InputStream", aPipe); 284cdf0e10cSrcweir // adding sequence of data that must be read 285cdf0e10cSrcweir // by XDataInputStream interface methods 286cdf0e10cSrcweir tEnv.addObjRelation("StreamData", data) ; 287cdf0e10cSrcweir // and by XInputStream interface methods 288cdf0e10cSrcweir tEnv.addObjRelation("ByteData", byteData) ; 289cdf0e10cSrcweir 290cdf0e10cSrcweir System.out.println("create TestEnvironment finished."); 291cdf0e10cSrcweir return tEnv; 292cdf0e10cSrcweir } // finish method getTestEnvironment 293cdf0e10cSrcweir 294cdf0e10cSrcweir } 295cdf0e10cSrcweir 296