akka.stream.impl.fusing

Class Fusing.BuildStructuralInfo

java.lang.Object

akka.stream.impl.fusing.Fusing.BuildStructuralInfo

Enclosing class:

Fusing

public static final class Fusing.BuildStructuralInfo
extends java.lang.Object

INTERNAL API

Collect structural information about a module tree while descending into it and performing normalization.

Constructor Summary

Constructors

Constructor and Description
BuildStructuralInfo()

Method Summary

Modifier and Type	Method and Description
StreamLayout.Atomic	addModule(StreamLayout.Module m, java.util.Set<StreamLayout.Module> group, Attributes inheritedAttributes, int indent, Shape _oldShape) Add a module to the given group, performing normalization (i.e.
void	breakUpGroupsByDispatcher() Fusable groups may contain modules with differing dispatchers, in which case the group needs to be broken up.
java.util.Map<OutPort,InPort>	downstreams() The downstreams relationships of the original module rewritten in terms of the copied ports.
void	dump()
void	enterMatCtx()
scala.collection.immutable.List<StreamLayout.CopiedModule>	exitMatCtx()
java.util.Deque<java.util.Set<StreamLayout.Module>>	groups() the list of all groups of modules that are within each async boundary
java.lang.String	hash(java.lang.Object obj)
java.util.Map<InPort,StreamLayout.Module>	inOwners() The owner mapping for the copied InPorts.
java.util.Set<OutPort>	internalOuts() List of internal wirings of GraphModules that were incorporated.
java.util.Set<StreamLayout.Module>	modules() the set of all contained modules
java.util.Set<StreamLayout.Module>	newGroup(int indent) Create and return a new grouping (i.e.
scala.collection.immutable.Seq<Inlet<?>>	newInlets(scala.collection.immutable.Seq<Inlet<?>> old) Transform original into copied Inlets.
java.util.Map<InPort,scala.collection.immutable.List<InPort>>	newIns() A stack of mappings for a given non-copied InPort.
scala.collection.immutable.Seq<Outlet<?>>	newOutlets(scala.collection.immutable.Seq<Outlet<?>> old) Transform original into copied Inlets.
java.util.Map<OutPort,scala.collection.immutable.List<OutPort>>	newOuts() A stack of mappings for a given non-copied OutPort.
java.util.Map<OutPort,java.util.Set<StreamLayout.Module>>	outGroup() a mapping from OutPort to its containing group, needed when determining whether an upstream connection is internal or not
java.util.Map<OutPort,StreamLayout.Module>	outOwners() The owner mapping for the copied OutPorts.
java.lang.String	printShape(Shape s)
void	pushMatSrc(StreamLayout.CopiedModule m)
void	registerInternals(Shape s, int indent) Register the outlets of the given Shape as sources for internal connections within imported (and not dissolved) GraphModules.
void	removeInternalWires() Remove wirings that belong to the fused stages contained in GraphModules that were incorporated in this fusing run.
void	replace(StreamLayout.Module oldMod, StreamLayout.Module newMod, java.util.Set<StreamLayout.Module> localGroup)
void	rewire(Shape oldShape, Shape newShape, int indent) Replace all mappings for a given shape with its new (copied) form.
<S extends Shape> StreamLayout.StructuralInfoModule	toInfo(S shape, scala.collection.immutable.List<scala.Tuple2<StreamLayout.Module,StreamLayout.MaterializedValueNode>> matValues, Attributes attributes)
java.util.Map<InPort,OutPort>	upstreams() The upstreams relationships of the original module rewritten in terms of the copied ports.
void	wire(OutPort out, InPort in, int indent) Record a wiring between two copied ports, using (and reducing) the port mappings.

Methods inherited from class java.lang.Object

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

Constructor Detail

BuildStructuralInfo

public BuildStructuralInfo()

Method Detail

toInfo

public <S extends Shape> StreamLayout.StructuralInfoModule toInfo(S shape,
                                                                  scala.collection.immutable.List<scala.Tuple2<StreamLayout.Module,StreamLayout.MaterializedValueNode>> matValues,
                                                                  Attributes attributes)

modules

public java.util.Set<StreamLayout.Module> modules()

the set of all contained modules

Returns:

(undocumented)

groups

public java.util.Deque<java.util.Set<StreamLayout.Module>> groups()

the list of all groups of modules that are within each async boundary

Returns:

(undocumented)

breakUpGroupsByDispatcher

public void breakUpGroupsByDispatcher()

Fusable groups may contain modules with differing dispatchers, in which case the group needs to be broken up.

outGroup

public java.util.Map<OutPort,java.util.Set<StreamLayout.Module>> outGroup()

a mapping from OutPort to its containing group, needed when determining whether an upstream connection is internal or not

Returns:

(undocumented)

replace

public void replace(StreamLayout.Module oldMod,
                    StreamLayout.Module newMod,
                    java.util.Set<StreamLayout.Module> localGroup)

newIns

public java.util.Map<InPort,scala.collection.immutable.List<InPort>> newIns()

A stack of mappings for a given non-copied InPort.

Returns:

(undocumented)

newOuts

public java.util.Map<OutPort,scala.collection.immutable.List<OutPort>> newOuts()

A stack of mappings for a given non-copied OutPort.

Returns:

(undocumented)

enterMatCtx

public void enterMatCtx()

exitMatCtx

public scala.collection.immutable.List<StreamLayout.CopiedModule> exitMatCtx()

pushMatSrc

public void pushMatSrc(StreamLayout.CopiedModule m)

downstreams

public java.util.Map<OutPort,InPort> downstreams()

The downstreams relationships of the original module rewritten in terms of the copied ports.

Returns:

(undocumented)

upstreams

public java.util.Map<InPort,OutPort> upstreams()

The upstreams relationships of the original module rewritten in terms of the copied ports.

Returns:

(undocumented)

inOwners

public java.util.Map<InPort,StreamLayout.Module> inOwners()

The owner mapping for the copied InPorts.

Returns:

(undocumented)

outOwners

public java.util.Map<OutPort,StreamLayout.Module> outOwners()

The owner mapping for the copied OutPorts.

Returns:

(undocumented)

internalOuts

public java.util.Set<OutPort> internalOuts()

List of internal wirings of GraphModules that were incorporated.

Returns:

(undocumented)

registerInternals

public void registerInternals(Shape s,
                              int indent)

Register the outlets of the given Shape as sources for internal connections within imported (and not dissolved) GraphModules. See also the comment in addModule where this is partially undone.

Parameters:

s - (undocumented)

indent - (undocumented)

removeInternalWires

public void removeInternalWires()

Remove wirings that belong to the fused stages contained in GraphModules that were incorporated in this fusing run.

dump

public void dump()

hash

public java.lang.String hash(java.lang.Object obj)

printShape

public java.lang.String printShape(Shape s)

newGroup

public java.util.Set<StreamLayout.Module> newGroup(int indent)

Create and return a new grouping (i.e. an AsyncBoundary-delimited context)

Parameters:

indent - (undocumented)

Returns:

(undocumented)

addModule

public StreamLayout.Atomic addModule(StreamLayout.Module m,
                                     java.util.Set<StreamLayout.Module> group,
                                     Attributes inheritedAttributes,
                                     int indent,
                                     Shape _oldShape)

Add a module to the given group, performing normalization (i.e. giving it a unique port identity).

Parameters:

m - (undocumented)

group - (undocumented)

inheritedAttributes - (undocumented)

indent - (undocumented)

_oldShape - (undocumented)

Returns:

(undocumented)

wire

public void wire(OutPort out,
                 InPort in,
                 int indent)

Record a wiring between two copied ports, using (and reducing) the port mappings.

Parameters:

out - (undocumented)

in - (undocumented)

indent - (undocumented)

rewire

public void rewire(Shape oldShape,
                   Shape newShape,
                   int indent)

Replace all mappings for a given shape with its new (copied) form.

Parameters:

oldShape - (undocumented)

newShape - (undocumented)

indent - (undocumented)

newInlets

public scala.collection.immutable.Seq<Inlet<?>> newInlets(scala.collection.immutable.Seq<Inlet<?>> old)

Transform original into copied Inlets.

Parameters:

old - (undocumented)

Returns:

(undocumented)

newOutlets

public scala.collection.immutable.Seq<Outlet<?>> newOutlets(scala.collection.immutable.Seq<Outlet<?>> old)

Transform original into copied Inlets.

Parameters:

old - (undocumented)

Returns:

(undocumented)