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