Examples of MarshalInputStream

com.sun.corba.se.impl.encoding.MarshalInputStream
net.jini.io.MarshalInputStream
An extension of ObjectInputStream that implements the dynamic class loading semantics of Java(TM) Remote Method Invocation (Java RMI) argument and result unmarshalling (using {@link RMIClassLoader}). A MarshalInputStream is intended to read data written by a corresponding {@link MarshalOutputStream}.
MarshalInputStream implements the input side of the dynamic class loading semantics by overriding {@link ObjectInputStream#resolveClass resolveClass} and {@link ObjectInputStream#resolveProxyClass resolveProxyClass} to resolveclass descriptors in the stream using {@link ClassLoading#loadClass ClassLoading.loadClass} and {@link ClassLoading#loadProxyClass ClassLoading.loadProxyClass} (which, in turn, use {@link RMIClassLoader#loadClass(String,String,ClassLoader) RMIClassLoader.loadClass} and {@link RMIClassLoader#loadProxyClass(String,String[],ClassLoader) RMIClassLoader.loadProxyClass}), optionally with codebase annotation strings written by a MarshalOutputStream.
By default, a MarshalInputStream ignores all codebase annotation strings, instead using a codebase value of null when loading classes. Codebase annotation strings will only be used by a MarshalInputStream after its {@link #useCodebaseAnnotations useCodebaseAnnotations}method has been invoked.
MarshalInputStream supports optional verification that all codebase annotation URLs that are used to load classes resolved by the stream provide content integrity (see {@link Security#verifyCodebaseIntegrity Security.verifyCodebaseIntegrity}). Whether or not a particular MarshalInputStream instance verifies that codebase annotation URLs provide content integrity is determined by the verifyCodebaseIntegrity constructor argument. See {@link ClassLoading#loadClass ClassLoading.loadClass} and {@link ClassLoading#loadProxyClass ClassLoading.loadProxyClass} fordetails of how codebase integrity verification is performed.
MarshalInputStream reads class annotations from its own stream; a subclass can override the {@link #readAnnotation readAnnotation} method to read the class annotations from adifferent location.
A MarshalInputStream is not guaranteed to be safe for concurrent use by multiple threads. @author Sun Microsystems, Inc. @since 2.0
sun.rmi.server.MarshalInputStream
MarshalInputStream is an extension of ObjectInputStream. When resolving a class, it reads an object from the stream written by a corresponding MarshalOutputStream. If the class to be resolved is not available locally, from the first class loader on the execution stack, or from the context class loader of the current thread, it will attempt to load the class from the location annotated by the sending MarshalOutputStream. This location object must be a string representing a path of URLs. A new MarshalInputStream should be created to deserialize remote objects or graphs containing remote objects. Objects are created from the stream using the ObjectInputStream.readObject method. @author Peter Jones

Examples of com.sun.corba.se.impl.encoding.MarshalInputStream

    {
        CorbaMessageMediator request = (CorbaMessageMediator) messageMediator;
        CorbaMessageMediator response = null;


        try {
            MarshalInputStream is = (MarshalInputStream)
                request.getInputObject();
            String method = request.getOperationName();
            response = request.getProtocolHandler().createResponse(request, null);
            MarshalOutputStream os = (MarshalOutputStream)
                response.getOutputObject();


            if (method.equals("get")) {
                // Get the name of the requested service
                String serviceKey = is.read_string();


                // Look it up
                org.omg.CORBA.Object serviceObject =
                    orb.getLocalResolver().resolve( serviceKey ) ;

View Full Code Here

Examples of com.sun.corba.se.impl.encoding.MarshalInputStream

    {
        CorbaMessageMediator request = (CorbaMessageMediator) messageMediator;
        CorbaMessageMediator response = null;


        try {
            MarshalInputStream is = (MarshalInputStream)
                request.getInputObject();
            String method = request.getOperationName();
            response = request.getProtocolHandler().createResponse(request, null);
            MarshalOutputStream os = (MarshalOutputStream)
                response.getOutputObject();


            if (method.equals("get")) {
                // Get the name of the requested service
                String serviceKey = is.read_string();


                // Look it up
                org.omg.CORBA.Object serviceObject =
                    orb.getLocalResolver().resolve( serviceKey ) ;

View Full Code Here

Examples of net.jini.io.MarshalInputStream

      s.writeObject(state);
      s.flush();
  }
  
  public void recover(InputStream in) throws Exception {
      MarshalInputStream s =
    new MarshalInputStream(in,
               ActLogHandler.class.getClassLoader(),
               false, null, Collections.EMPTY_LIST);
      s.useCodebaseAnnotations();
      state = (Activation) s.readObject();
  }

View Full Code Here

Examples of net.jini.io.MarshalInputStream

      s.writeObject(value);
      s.flush();
  }


  public void readUpdate(InputStream in) throws Exception {
      MarshalInputStream  s =
    new MarshalInputStream(in,
               ActLogHandler.class.getClassLoader(),
               false, null, Collections.EMPTY_LIST);
      s.useCodebaseAnnotations();
      applyUpdate(s.readObject());
  }

View Full Code Here

Examples of net.jini.io.MarshalInputStream

          boolean integrity,
          Collection context)
          throws IOException
      {
          ClassLoader loader = getClassLoader();
          return new MarshalInputStream(
        request.getRequestInputStream(),
        loader, integrity, loader,
        Collections.unmodifiableCollection(context));
          // useStreamCodebases() not invoked
      }

View Full Code Here

Examples of net.jini.io.MarshalInputStream

      }
      streamLoader = impl.getClass().getClassLoader();
  }
  
  Collection unmodContext = Collections.unmodifiableCollection(context);
  MarshalInputStream in =
      new MarshalInputStream(request.getRequestInputStream(),
           streamLoader, integrity,
           streamLoader, unmodContext);
  in.useCodebaseAnnotations();
  return in;
    }

View Full Code Here

Examples of net.jini.io.MarshalInputStream

  if (Proxy.getInvocationHandler(proxy) != this) {
      throw new IllegalArgumentException("not proxy for this");
  }
  ClassLoader proxyLoader = getProxyLoader(proxy.getClass());
  Collection unmodContext = Collections.unmodifiableCollection(context);
  MarshalInputStream in =
      new MarshalInputStream(request.getResponseInputStream(),
           proxyLoader, integrity, proxyLoader,
           unmodContext);
  in.useCodebaseAnnotations();
  return in;
    }

View Full Code Here

Examples of net.jini.io.MarshalInputStream

                        boolean integrity,
                        Collection context)
                        throws IOException
                    {
                        ClassLoader loader = getClassLoader();
                        return new MarshalInputStream(
                            request.getRequestInputStream(),
                            loader, integrity, loader,
                            Collections.unmodifiableCollection(context));
                        // useStreamCodebases() not invoked
                    }

View Full Code Here

Examples of net.jini.io.MarshalInputStream


    /**
     * This method performs all actions mentioned in class description.
     */
    public void run() throws Exception {
        MarshalInputStream stream;
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        ObjectOutputStream oos = new ObjectOutputStream(baos);
        oos.flush();
        ByteArrayInputStream bais = 
            new ByteArrayInputStream(baos.toByteArray());
        ArrayList al = new ArrayList();
        PipedInputStream pis = new PipedInputStream();


        logger.log(Level.FINE,"=================================");
        logger.log(Level.FINE,"test case 1: "
            + "MarshalInputStream(null,*,*,*,null)");
        logger.log(Level.FINE,"");


        try {
            stream = new MarshalInputStream(null,null,false,null,null);
            assertion(false);
        } catch (NullPointerException ignore) {
        }


        logger.log(Level.FINE,"=================================");
        logger.log(Level.FINE,"test case 2: "
            + "MarshalInputStream(InputStream,*,*,*,null)");
        logger.log(Level.FINE,"");


        try {
            stream = new MarshalInputStream(bais,null,false,null,null);
            assertion(false);
        } catch (NullPointerException ignore) {
        }


        logger.log(Level.FINE,"=================================");
        logger.log(Level.FINE,"test case 3: "
            + "MarshalInputStream(null,*,*,*,Collection)");
        logger.log(Level.FINE,"");


        try {
            stream = new MarshalInputStream(null,null,false,null,al);
            assertion(false);
        } catch (NullPointerException ignore) {
        }


        logger.log(Level.FINE,"=================================");
        logger.log(Level.FINE,"test case 4: "
            + "getObjectStreamContext method returns constructor arg");
        logger.log(Level.FINE,"");


        bais.reset();
        stream = new MarshalInputStream(bais,null,false,null,al);
        assertion(stream.getObjectStreamContext() == al);


        logger.log(Level.FINE,"=================================");
        logger.log(Level.FINE,"test case 5: "
            + "constructor throws IOException");
        logger.log(Level.FINE,"");


        try {
            stream = new MarshalInputStream(pis,null,false,null,al);
            assertion(false);
        } catch (IOException ignore) {
        }


        logger.log(Level.FINE,"=================================");

View Full Code Here

Examples of net.jini.io.MarshalInputStream


            // Attempt to read from MarshalInputStream


            ByteArrayInputStream bios = new ByteArrayInputStream(
                baos.toByteArray());
            MarshalInputStream input = new FakeMarshalInputStream(
                bios,readAnnotationException,null);


            // verify result


            try {
                System.out.println("readObject: " + input.readObject());
                throw new AssertionError("readObject() call should fail");
            } catch (Throwable caught) {
                assertion(readAnnotationException.equals(caught),
                    caught.toString());
            }

View Full Code Here

0 1 2

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.