Package org.jenkinsci.plugins.workflow.support.pickles.serialization

Class RiverReader

java.lang.Object

org.jenkinsci.plugins.workflow.support.pickles.serialization.RiverReader

All Implemented Interfaces:

Closeable, AutoCloseable

public class RiverReader
extends Object
implements Closeable

Reads program data file that stores the object graph of the CPS-transformed program.

The file consists of two separate object streams. The first stream contains a list of Pickles, which are used to restore stateful objects. The second stream is the main stream that contains the main program state, which includes references to DryCapsule (which gets replaced to their respective stateful objects.

Author:

Kohsuke Kawaguchi

Field Summary

Fields

Modifier and Type	Field	Description
static org.jboss.marshalling.ObjectResolver	customResolver

Constructor Summary

Constructors

Constructor	Description
RiverReader(File f, ClassLoader classLoader, org.jenkinsci.plugins.workflow.flow.FlowExecutionOwner owner)

Method Summary

Modifier and Type	Method	Description
void	close()
com.google.common.util.concurrent.ListenableFuture<org.jboss.marshalling.Unmarshaller>	restorePickles()	Deprecated.
com.google.common.util.concurrent.ListenableFuture<org.jboss.marshalling.Unmarshaller>	restorePickles(Collection<com.google.common.util.concurrent.ListenableFuture<?>> pickleFutures)	Step 1.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

customResolver

@Restricted(org.kohsuke.accmod.restrictions.NoExternalUse.class)
@CheckForNull
public static org.jboss.marshalling.ObjectResolver customResolver

Constructor Detail

RiverReader

public RiverReader(File f,
                   ClassLoader classLoader,
                   org.jenkinsci.plugins.workflow.flow.FlowExecutionOwner owner)
            throws IOException

Throws:

IOException

Method Detail

restorePickles

@Deprecated
public com.google.common.util.concurrent.ListenableFuture<org.jboss.marshalling.Unmarshaller> restorePickles()
                                                                                                      throws IOException

Deprecated.

Throws:

IOException

restorePickles

public com.google.common.util.concurrent.ListenableFuture<org.jboss.marshalling.Unmarshaller> restorePickles(Collection<com.google.common.util.concurrent.ListenableFuture<?>> pickleFutures)
                                                                                                      throws IOException

Step 1. Start unmarshalling pickles in the persisted stream, and return the future that will signal when that is all complete. Once the pickles are restored, the future yields Unmarshaller that can be then used to load the objects persisted by RiverWriter.

Throws:

IOException

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable