Module xl.impl

Package de.grogra.xl.impl.base

Class GraphQueueImpl

java.lang.Object

java.io.OutputStream

de.grogra.util.OutputQueue

de.grogra.util.HierarchicalQueue

de.grogra.xl.impl.base.GraphQueue

de.grogra.xl.impl.base.GraphQueueImpl

All Implemented Interfaces:

Queue, ObjectConsumer, Closeable, DataOutput, Flushable, ObjectOutput, AutoCloseable, Executor

public class GraphQueueImpl
extends GraphQueue
implements ObjectConsumer

Nested Class Summary

Nested classes/interfaces inherited from class de.grogra.xl.impl.base.GraphQueue

GraphQueue.AddEdgeDescriptor, GraphQueue.AddNodeDescriptor, GraphQueue.AddUndirectedEdgeDescriptor, GraphQueue.ConnectDescriptor, GraphQueue.DeleteEdgeDescriptor, GraphQueue.DeleteNodeDescriptor, GraphQueue.ExecuteDescriptor, GraphQueue.Processor

Nested classes/interfaces inherited from class de.grogra.util.HierarchicalQueue

HierarchicalQueue.Cursor, HierarchicalQueue.Data, HierarchicalQueue.Reader

Field Summary

Fields

Modifier and Type	Field	Description
static final int	INCOMING
static final int	OUTGOING

Fields inherited from class de.grogra.xl.impl.base.GraphQueue

ADD_EDGE_DESCRIPTOR, ADD_NODE_DESCRIPTOR, ADD_UNDIRECTED_EDGE_DESCRIPTOR, CONNECT_DESCRIPTOR, DELETE_EDGE_DESCRIPTOR, DELETE_NODE_DESCRIPTOR, EXECUTE_DESCRIPTOR, FIRST_QUEUE, LAST_QUEUE

Fields inherited from class de.grogra.util.HierarchicalQueue

BEGIN_LEVEL, IS_FINISHED, ITEM_AND_BITS_MASK, ITEM_MASK, MAX_UNUSED_BIT, MIN_UNUSED_BIT, MIN_UNUSED_ITEM, NEXT_EXISTS, out

Constructor Summary

Constructors

Constructor	Description
GraphQueueImpl(QueueDescriptor descr, QueueCollection qc)

Method Summary

Modifier and Type	Method	Description
void	addEdgeBits(Object source, Object target, int edges)
void	addNode(Object node)
void	addUndirectedEdgeBits(Object source, Object target, int edges)
void	clearSegmentsToExclude(int[] segs)
void	connect(Object from, Object to, Object param, Connector c)
void	connectAdjacent(Object start, Object end, int edges)
void	connectIncoming(Object source, Object target, Operator op)
void	connectOutgoing(Object source, Object target, Operator op)
void	consume(Object v)	Receives a value of type T.
void	copyIncoming(Object source, Object target, int edges)
void	copyIncoming(Object source, Object target, int edges, int copyMask, int addMask)
void	copyOutgoing(Object source, Object target, int edges)
void	copyOutgoing(Object source, Object target, int edges, int copyMask, int addMask)
protected GraphQueue.Processor	createProcessor()
void	deleteCurrentEdges(Object node, int edges, boolean outgoing)
void	deleteEdgeBits(Object source, Object target, int edges)
void	deleteNode(Object node)
void	embedInterpretive(Object interpreted, Object start, Object end)
void	execute(Runnable task)
protected RuntimeModel	getModel()
protected TypeLoader	getTypeLoader()
protected int	maskConnectionEdges(int edges)
void	moveIncoming(Object source, Object target, int edges)
void	moveOutgoing(Object source, Object target, int edges)
boolean	process(int[] segs)	Processes all queued tasks.

Methods inherited from class de.grogra.xl.impl.base.GraphQueue

clear, clearSegmentsToExcludeImpl, getDescriptor, markSegment, resetToSegment

Methods inherited from class de.grogra.util.HierarchicalQueue

beginLevel, beginSkipBlock, cloneData, createData, discardLevel, endLevel, endSkipBlock, getCursor, getData, hasItems, hasItemsInCurrentLevel, moveTo, restore, setItemSize, writeItem, writeObject, writeObjectInStream

Methods inherited from class de.grogra.util.OutputQueue

close, dump, flush, write, write, write, writeBoolean, writeByte, writeBytes, writeChar, writeChars, writeDouble, writeFloat, writeInt, writeLong, writeObjectInQueue, writeShort, writeUTF

Methods inherited from class java.io.OutputStream

nullOutputStream

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.DataOutput

writeBoolean, writeByte, writeBytes, writeChar, writeChars, writeDouble, writeFloat, writeInt, writeLong, writeShort, writeUTF

Methods inherited from interface java.io.ObjectOutput

close, flush, write, write, write

Field Details

INCOMING

public static final int INCOMING

See Also:

• Constant Field Values

OUTGOING

public static final int OUTGOING

See Also:

• Constant Field Values

Constructor Details

GraphQueueImpl

public GraphQueueImpl(QueueDescriptor descr,
 QueueCollection qc)

Method Details

getModel

protected RuntimeModel getModel()

Specified by:

getModel in class GraphQueue

addNode

public void addNode(Object node)

Specified by:

addNode in class GraphQueue

addEdgeBits

public void addEdgeBits(Object source,
 Object target,
 int edges)

Specified by:

addEdgeBits in class GraphQueue

addUndirectedEdgeBits

public void addUndirectedEdgeBits(Object source,
 Object target,
 int edges)

Specified by:

addUndirectedEdgeBits in class GraphQueue

deleteEdgeBits

public void deleteEdgeBits(Object source,
 Object target,
 int edges)

Specified by:

deleteEdgeBits in class GraphQueue

deleteCurrentEdges

public void deleteCurrentEdges(Object node,
 int edges,
 boolean outgoing)

Specified by:

deleteCurrentEdges in class GraphQueue

deleteNode

public void deleteNode(Object node)

Specified by:

deleteNode in class GraphQueue

copyIncoming

public void copyIncoming(Object source,
 Object target,
 int edges)

Specified by:

copyIncoming in class GraphQueue

moveIncoming

public void moveIncoming(Object source,
 Object target,
 int edges)

Specified by:

moveIncoming in class GraphQueue

copyIncoming

public void copyIncoming(Object source,
 Object target,
 int edges,
 int copyMask,
 int addMask)

Specified by:

copyIncoming in class GraphQueue

copyOutgoing

public void copyOutgoing(Object source,
 Object target,
 int edges)

Specified by:

copyOutgoing in class GraphQueue

moveOutgoing

public void moveOutgoing(Object source,
 Object target,
 int edges)

Specified by:

moveOutgoing in class GraphQueue

copyOutgoing

public void copyOutgoing(Object source,
 Object target,
 int edges,
 int copyMask,
 int addMask)

Specified by:

copyOutgoing in class GraphQueue

connectIncoming

public void connectIncoming(Object source,
 Object target,
 Operator op)

Specified by:

connectIncoming in class GraphQueue

connectOutgoing

public void connectOutgoing(Object source,
 Object target,
 Operator op)

Specified by:

connectOutgoing in class GraphQueue

connect

public void connect(Object from,
 Object to,
 Object param,
 Connector c)

Specified by:

connect in class GraphQueue

connectAdjacent

public void connectAdjacent(Object start,
 Object end,
 int edges)

Specified by:

connectAdjacent in class GraphQueue

embedInterpretive

public void embedInterpretive(Object interpreted,
 Object start,
 Object end)

Specified by:

embedInterpretive in class GraphQueue

execute

public void execute(Runnable task)

Specified by:

execute in interface Executor

maskConnectionEdges

protected int maskConnectionEdges(int edges)

getTypeLoader

protected TypeLoader getTypeLoader()

clearSegmentsToExclude

public void clearSegmentsToExclude(int[] segs)

Specified by:

clearSegmentsToExclude in interface Queue

createProcessor

protected GraphQueue.Processor createProcessor()

Specified by:

createProcessor in class GraphQueue

consume

public void consume(Object v)

Description copied from interface: ObjectConsumer

Receives a value of type T.

Specified by:

consume in interface ObjectConsumer

process

public boolean process(int[] segs)
                throws RuntimeModelException

Description copied from interface: Queue

Processes all queued tasks. This method is invoked by QueueCollection.process(int[]).

Specified by:

process in interface Queue

Overrides:

process in class GraphQueue

Returns:

true iff the execution of tasks resulted in modifications to the Graph

Throws:

RuntimeModelException - if some error occurs during execution