nodePosMask = nodePosMask >> 1;

         }

         for ( Memory mem = smNodeMemories2.getFirst(); mem != null; ) {

             smNodeMemories2.remove(mem);

             smNodeMemories1.add(mem);

             mem.setSegmentMemory(sm1);

             // correct the NodePosMaskBit

        NodeMemories memories = wm.getNodeMemories();

        // only some of the node memories require special serialization handling

        // so we iterate over all of them and process only those that require it

        for ( int i = 0; i < memories.length(); i++ ) {

            // some nodes have no memory, so we need to check for nulls

            if ( memory != null ) {

                ProtobufMessages.NodeMemory _node = null;

                    case NodeTypeEnums.AccumulateNode : {

                        _node = writeAccumulateNodeMemory( i, memory );

                        break;

                    }

                    case NodeTypeEnums.RightInputAdaterNode : {

        ObjectSink[] sinks = riaNode.getSinkPropagator().getSinks();

        BetaNode betaNode = (BetaNode) sinks[0];

        if ( betaMemory == null ) {

            return null;

        }

        BetaMemory bm;

        if ( betaNode.getType() == NodeTypeEnums.AccumulateNode ) {

    }

    public Memory createNodeMemory(MemoryFactory memoryFactory,

                                   InternalWorkingMemory wm) {

        nodeMemories.add(memory);

        return memory;

    }

            smem.segmentPosMaskBit = segmentPosMaskBit;

            smem.pos = pos;

            int i = 0;

            for (NetworkNode node : smem.getNodesInSegment()) {

                smem.getNodeMemories().add(mem);

                MemoryPrototype proto = memories.get(i++);

                if (proto != null) {

                    proto.populateMemory(wm, mem);

                }

        NodeMemories memories = wm.getNodeMemories();

        // only some of the node memories require special serialization handling

        // so we iterate over all of them and process only those that require it

        for ( int i = 0; i < memories.length(); i++ ) {

            // some nodes have no memory, so we need to check for nulls

            if ( memory != null ) {

                ProtobufMessages.NodeMemory _node = null;

                    case NodeTypeEnums.AccumulateNode : {

                        _node = writeAccumulateNodeMemory( i, memory );

                        break;

                    }

                    case NodeTypeEnums.RightInputAdaterNode : {

        ObjectSink[] sinks = riaNode.getSinkPropagator().getSinks();

        BetaNode betaNode = (BetaNode) sinks[0];

        if ( betaMemory == null ) {

            return null;

        }

        BetaMemory bm;

        if ( betaNode.getType() == NodeTypeEnums.AccumulateNode ) {

                    } else {

                        // rtn or rian

                        // While not technically in a segment, we want to be able to iterate easily from the last node memory to the ria/rtn memory

                        // we don't use createNodeMemory, as these may already have been created by, but not added, by the method updateRiaAndTerminalMemory

                        if (sink.getType() == NodeTypeEnums.RightInputAdaterNode) {

                            PathMemory riaPmem = ((RiaNodeMemory)memory).getRiaPathMemory();

                            smem.getNodeMemories().add( riaPmem );

                            RightInputAdapterNode rian = ( RightInputAdapterNode ) sink;

                            ObjectSink[] nodes = rian.getSinkPropagator().getSinks();

                            for ( ObjectSink node : nodes ) {

                                if ( NodeTypeEnums.isLeftTupleSource(node) )  {

                                    createSegmentMemory( (LeftTupleSource) node, wm );

                                }

                            }

                        } else if (NodeTypeEnums.isTerminalNode(sink)) {

                            smem.getNodeMemories().add(memory);

                        }

                        smem.setTipNode(sink);

                        break;

                    }

                } else {

                    // not in same segment

            while (subnetworkLts.getLeftTupleSource() != riaNode.getStartTupleSource()) {

                subnetworkLts = subnetworkLts.getLeftTupleSource();

            }

            if (subNetworkSegmentMemory == null) {

                // we need to stop recursion here

                createSegmentMemory(subnetworkLts, wm);

            }

            if ( !smem.isEmpty() ) {

                  return; // this can happen when multiple threads are trying to initialize the segment

            }

            for (LeftTupleSinkNode sink = sinkProp.getFirstLeftTupleSink(); sink != null; sink = sink.getNextLeftTupleSinkNode()) {

                SegmentMemory childSmem = createChildSegment(wm, sink, memory);

                smem.add(childSmem);

            }

        }