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