org.processmining.eventstream.authors.cpn.implementations

Class CPNModelToXSEventStreamAuthorImpl

java.lang.Object

java.lang.Thread

org.processmining.stream.core.abstracts.AbstractXSRunnable

org.processmining.stream.core.abstracts.AbstractXSRunnableXSWriter<D>

org.processmining.stream.core.abstracts.AbstractXSAuthor<XSEvent,java.lang.String>

org.processmining.eventstream.authors.cpn.implementations.CPNModelToXSEventStreamAuthorImpl

All Implemented Interfaces:

java.lang.Runnable, org.processmining.stream.core.interfaces.XSAuthor<XSEvent>, org.processmining.stream.core.interfaces.XSRunnable, org.processmining.stream.core.interfaces.XSStronglyTyped<XSEvent>, org.processmining.stream.core.interfaces.XSVisualizable, org.processmining.stream.core.interfaces.XSWriter<XSEvent>

public class CPNModelToXSEventStreamAuthorImpl
extends org.processmining.stream.core.abstracts.AbstractXSAuthor<XSEvent,java.lang.String>

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected int	currentRepetition
protected long	currentStep
protected org.cpntools.accesscpn.engine.highlevel.instance.State	initialState
protected long	lastSend
protected java.math.BigInteger	lastStep
protected CPN2XSEventStreamParameters	parameters
protected org.cpntools.accesscpn.model.PetriNet	pn
protected org.cpntools.accesscpn.engine.highlevel.HighLevelSimulator	simulator
protected long	waitTimeNs
protected org.deckfour.xes.factory.XFactory	xfact

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
CPNModelToXSEventStreamAuthorImpl(org.cpntools.accesscpn.model.PetriNet pn, org.cpntools.accesscpn.engine.highlevel.instance.State iState, org.cpntools.accesscpn.engine.highlevel.HighLevelSimulator sim, CPN2XSEventStreamParameters parameters)

Method Summary

Modifier and Type	Method and Description
protected XSEvent	addData(XSEvent event, org.cpntools.accesscpn.engine.highlevel.instance.Binding binding)
protected boolean	allowedToComputeNewBinding()
protected void	delayEmission()
java.lang.Class<XSEvent>	getTopic()
protected org.deckfour.xes.model.XAttribute	identifyCase(org.cpntools.accesscpn.engine.highlevel.instance.Binding binding)
protected void	initializeSimulator()
protected boolean	mayEmitBinding(org.cpntools.accesscpn.engine.highlevel.instance.Binding binding)
protected void	processAndEmitBinding(org.cpntools.accesscpn.engine.highlevel.instance.Binding binding)
protected void	workPackage()

Methods inherited from class org.processmining.stream.core.abstracts.AbstractXSAuthor

getVisualization, interrupt, pause, pauseXSRunnable, start, startXSRunnable, stopXSRunnable

Methods inherited from class org.processmining.stream.core.abstracts.AbstractXSRunnableXSWriter

connect, disconnect, getNumberOfPacketsSend, getWritables, run, write

Methods inherited from class org.processmining.stream.core.abstracts.AbstractXSRunnable

isPaused, isRunning, isStarted, isStopped

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.processmining.stream.core.interfaces.XSRunnable

getName, isPaused, isRunning, isStarted, isStopped, stop

Methods inherited from interface java.lang.Runnable

run

Methods inherited from interface org.processmining.stream.core.interfaces.XSWriter

connect, disconnect, getNumberOfPacketsSend, getWritables, write

Field Detail

pn

protected final org.cpntools.accesscpn.model.PetriNet pn

initialState

protected final org.cpntools.accesscpn.engine.highlevel.instance.State initialState

simulator

protected final org.cpntools.accesscpn.engine.highlevel.HighLevelSimulator simulator

parameters

protected final CPN2XSEventStreamParameters parameters

lastStep

protected java.math.BigInteger lastStep

xfact

protected final org.deckfour.xes.factory.XFactory xfact

currentStep

protected long currentStep

currentRepetition

protected int currentRepetition

lastSend

protected long lastSend

waitTimeNs

protected final long waitTimeNs

Constructor Detail

CPNModelToXSEventStreamAuthorImpl

public CPNModelToXSEventStreamAuthorImpl(org.cpntools.accesscpn.model.PetriNet pn,
                                         org.cpntools.accesscpn.engine.highlevel.instance.State iState,
                                         org.cpntools.accesscpn.engine.highlevel.HighLevelSimulator sim,
                                         CPN2XSEventStreamParameters parameters)

Method Detail

workPackage

protected void workPackage()

Specified by:

workPackage in class org.processmining.stream.core.abstracts.AbstractXSRunnable

allowedToComputeNewBinding

protected boolean allowedToComputeNewBinding()

mayEmitBinding

protected boolean mayEmitBinding(org.cpntools.accesscpn.engine.highlevel.instance.Binding binding)

processAndEmitBinding

protected void processAndEmitBinding(org.cpntools.accesscpn.engine.highlevel.instance.Binding binding)

delayEmission

protected void delayEmission()

addData

protected XSEvent addData(XSEvent event,
                          org.cpntools.accesscpn.engine.highlevel.instance.Binding binding)

identifyCase

protected org.deckfour.xes.model.XAttribute identifyCase(org.cpntools.accesscpn.engine.highlevel.instance.Binding binding)

initializeSimulator

protected void initializeSimulator()

getTopic

public java.lang.Class<XSEvent> getTopic()