Job-Planning: rework of dispatcher and pipeline builder complete (see #1301)

An extended series of refactoring and partial rewrites resulted
in a new definition of the `Dispatcher` interface and completes
the buildup of a Job-Planning pipeline, including the ability
to discover prerequisites and compute scheduling deadlines.

At this point, I am about to ''switch to the topic'' of the `Scheduler`,
''postponing'' the completion of the `RenderDrive` until the related
questions regarding memory management and Scheduler interface are settled.
This commit is contained in:
Fischlurch 2023-06-22 03:55:09 +02:00
parent 8c78e50730
commit 42f4e403ac
4 changed files with 157 additions and 248 deletions

View file

@ -40,7 +40,7 @@ PLANNED "Engine calculation streams" CalcStream_test <<END
END
PLANNED "Frame Dispatcher Interface" DispatcherInterface_test <<END
TEST "Frame Dispatcher Interface" DispatcherInterface_test <<END
END

View file

@ -22,37 +22,18 @@
/** @file dispatcher-interface-test.cpp
** unit test \ref DispatcherInterface_test
**
** @warning as of 4/2023 a complete rework of the Dispatcher is underway ///////////////////////////////////////////TICKET #1275
*/
#include "lib/test/run.hpp"
#include "lib/error.hpp"
//#include "steam/engine/procnode.hpp"
#include "steam/play/dummy-play-connection.hpp"
#include "steam/mobject/model-port.hpp"
#include "steam/engine/dispatcher.hpp"
#include "steam/engine/time-anchor.hpp"
#include "steam/engine/mock-dispatcher.hpp"
#include "steam/play/timings.hpp"
#include "lib/time/timevalue.hpp"
//#include "lib/time/timequant.hpp"
//#include "lib/format-cout.hpp"
#include "lib/depend.hpp"
#include "lib/itertools.hpp"
#include "lib/util-coll.hpp"
#include "lib/util.hpp"
#include <functional>
#include <vector>
#include <utility>
using test::Test;
using util::isnil;
using util::last;
using std::vector;
using std::function;
//using std::rand;
namespace steam {
@ -60,89 +41,15 @@ namespace engine{
namespace test {
using lib::time::FrameRate;
using lib::time::Duration;
using lib::time::Offset;
using lib::time::TimeVar;
using lib::time::Time;
using mobject::ModelPort;
using play::Timings;
namespace { // used internally
using play::test::PlayTestFrames_Strategy;
using play::test::ModelPorts;
using DummyPlaybackSetup = play::test::DummyPlayConnection<PlayTestFrames_Strategy>;
/////////////////////////////////////////////////////////////////////////////////////////////////////////TICKET #1274 replace by MockDispatcher !!!!
class MockDispatcherTable
: public Dispatcher
{
DummyPlaybackSetup dummySetup_;
/* == mock Dispatcher implementation == */
#if false /////////////////////////////////////////////////////////////////////////////////////////////////////////////TICKET #1301 : obsoleted by rework of Dispatcher-Pipeline
FrameCoord
locateRelative (FrameCoord const&, FrameCnt frameOffset) override
{
UNIMPLEMENTED ("dummy implementation of the core dispatch operation");
}
bool
isEndOfChunk (FrameCnt, ModelPort port) override
{
UNIMPLEMENTED ("determine when to finish a planning chunk");
}
#endif /////////////////////////////////////////////////////////////////////////////////////////////////////////////TICKET #1301 : obsoleted by rework of Dispatcher-Pipeline
size_t
resolveModelPort (ModelPort modelPort) override
{
UNIMPLEMENTED ("some Map lookup in a prepared table to find out the actual slot number");
}
using asset::Pipe;
using PID = asset::ID<Pipe>;
using mobject::ModelPort;
using lumiera::error::LUMIERA_ERROR_LOGIC;
JobTicket&
getJobTicketFor (size_t, TimeValue nominalTime) override
{
UNIMPLEMENTED ("dummy implementation of the model backbone / segmentation");
}
public:
ModelPort
provideMockModelPort()
{
ModelPorts mockModelPorts = dummySetup_.getAllModelPorts();
return *mockModelPorts; // using just the first dummy port
}
};
lib::Depend<MockDispatcherTable> mockDispatcher;
/////////////////////////////////////////////////////////////////////////////////////////////////////////TICKET #1274 replace by MockDispatcher !!!!
#if false /////////////////////////////////////////////////////////////////////////////////////////////////////////////UNIMPLEMENTED :: TICKET #880
#endif /////////////////////////////////////////////////////////////////////////////////////////////////////////////UNIMPLEMENTED :: TICKET #890
ModelPort
getTestPort()
{
return mockDispatcher().provideMockModelPort();
}
/* == test parameters == */
const uint START_FRAME(10);
const uint CHANNEL(0);
bool continuation_has_been_triggered = false;
} // (End) internal defs
@ -154,166 +61,124 @@ namespace test {
* This test covers the definition of the interface itself,
* together with the supporting types and the default
* implementation of the basic operations.
* It creates and uses a mock Dispatcher implementation.
* It uses a mock Dispatcher implementation.
* @see JobPlanningPipeline_test
*/
class DispatcherInterface_test : public Test
{
virtual void
run (Arg)
run (Arg)
{
verify_basicDispatch();
verify_standardDispatcherUsage();
check_ContinuationBuilder();
resolveModelPort();
accessJobTicket();
pipelineBuilder();
}
/** @test perform the basic dispatch step
* and verify the generated frame coordinates
/** @test the dispatcher can resolve a known ModelPort
* into the internal index number used on the Segmentation
* for the corresponding timeline (which exposes this ModelPort)
*/
void
verify_basicDispatch()
resolveModelPort()
{
Dispatcher& dispatcher = mockDispatcher();
ModelPort modelPort (getTestPort());
Timings timings (FrameRate::PAL);
ENSURE (START_FRAME == 10);
MockDispatcher dispatcher;
auto [port,sink] = dispatcher.getDummyConnection(1);
CHECK (1 == dispatcher.resolveModelPort (port));
TimeAnchor refPoint(timings, START_FRAME);
CHECK (refPoint == Time::ZERO + Duration(10, FrameRate::PAL));
#if false /////////////////////////////////////////////////////////////////////////////////////////////////////////////UNIMPLEMENTED :: TICKET #1301
FrameCoord coordinates = dispatcher.onCalcStream (modelPort,CHANNEL)
.relativeFrameLocation (refPoint, 15);
CHECK (coordinates.absoluteNominalTime == Time(0,1));
CHECK (coordinates.absoluteFrameNumber == 25);
CHECK (refPoint.remainingRealTimeFor(coordinates) < Time(FSecs(25,25)));
CHECK (refPoint.remainingRealTimeFor(coordinates) >= Time(FSecs(24,25)));
CHECK (coordinates.modelPort == modelPort);
CHECK (coordinates.channelNr == CHANNEL);
JobTicket& executionPlan = dispatcher.getJobTicketFor (coordinates);
CHECK (executionPlan.isValid());
Job frameJob = executionPlan.createJobFor (coordinates);
CHECK (frameJob.getNominalTime() == coordinates.absoluteNominalTime);
#endif /////////////////////////////////////////////////////////////////////////////////////////////////////////////UNIMPLEMENTED :: TICKET #1301
// but when using some arbitrary unrelated ModelPort...
PID dazedPipe = Pipe::query ("id(dazed)");
ModelPort evil = reinterpret_cast<ModelPort&> (dazedPipe);
VERIFY_ERROR (LOGIC, dispatcher.resolveModelPort(evil));
}
/** @test the standard invocation sequence
* used within the engine for planning new jobs.
* The actual implementation is mocked.
/** @test the dispatcher knows how to pick the right JobTicket
* for each point on the timeline, and thus how to access
* the proper part of the render nodes responsible for
* rendering this part of the timeline
*/
void
verify_standardDispatcherUsage()
accessJobTicket()
{
#if false /////////////////////////////////////////////////////////////////////////////////////////////////////////////UNIMPLEMENTED :: TICKET #1301
Dispatcher& dispatcher = mockDispatcher();
ModelPort modelPort (getTestPort());
Timings timings (FrameRate::PAL);
MockDispatcher dispatcher{MakeRec() // a first active segment
.attrib("start", Time{0,10}) // covering the time [10s ... 20s[
.attrib("after", Time{0,20})
.attrib("mark", 23) // pipeline-Hash used as marker to verify proper access
.genNode()
,MakeRec() // add a second Segment
.attrib("start", Time{0,20}) // covering the rest of the timeline from 20s on
.attrib("mark", 45)
.genNode()};
size_t portIDX = 1;
// Dispatcher-Interface: access JobTicket
JobTicket& ticket0 = dispatcher.getJobTicketFor (portIDX, -Time{0,5});
JobTicket& ticket1 = dispatcher.getJobTicketFor (portIDX, Time{0,15});
JobTicket& ticket2 = dispatcher.getJobTicketFor (portIDX, Time{0,25});
TimeAnchor refPoint = TimeAnchor(timings, START_FRAME);
CHECK ( ticket0.empty()); // this ticket was drawn from an undefined part of the timeline
CHECK (not ticket1.empty()); // while this ticket belongs to the first segment
CHECK (not ticket2.empty()); // and this to the second segment
Job job0 = ticket0.createJobFor(-Time{0,5});
Job job1 = ticket1.createJobFor(Time{0,15});
Job job2 = ticket2.createJobFor(Time{0,25});
JobPlanningSequence jobs = dispatcher.onCalcStream(modelPort,CHANNEL)
.establishNextJobs(refPoint);
CHECK (MockJob::isNopJob(job0));
// Verify the planned Jobs
CHECK (Time(0,15) == job1.parameter.nominalTime);
CHECK (23 == job1.parameter.invoKey.part.a); // proof that this job is connected to segment #1
CHECK (!isnil (jobs));
vector<Job> plannedChunk;
lib::append_all (jobs, plannedChunk);
Duration coveredTime (Offset(refPoint, last(plannedChunk).getNominalTime()));
CHECK (coveredTime >= timings.getPlanningChunkDuration());
#endif /////////////////////////////////////////////////////////////////////////////////////////////////////////////UNIMPLEMENTED :: TICKET #1301
///TODO nachfolgendes muß komplett umgeschrieben werden
///TODO definieren, wie das scheduler-interface angesprochen wird
///TODO dann stub dafür bauen
#if false /////////////////////////////////////////////////////////////////////////////////////////////////////////////UNIMPLEMENTED :: TICKET #903
TimeVar frameStart (refPoint);
InvocationInstanceID prevInvocationID(0); ///////////////////////////////////////////////////////TICKET #1138 : C++17 requires explicit ctor for initialisation of union
Offset expectedTimeIncrement (1, FrameRate::PAL);
for (uint i=0; i < plannedChunk.size(); ++i )
{
Job& thisJob = plannedChunk[i];
CHECK (prevInvocationID < thisJob.getInvocationInstanceID());
prevInvocationID = thisJob.getInvocationInstanceID();
if (frameStart != thisJob.getNominalTime())
{
frameStart += expectedTimeIncrement;
CHECK (frameStart == thisJob.getNominalTime());
}
}
// now, after having passed over the whole planned chunk
CHECK (frameStart == Time(refPoint) + coveredTime);
CHECK (frameStart >= Time(refPoint) + timings.getPlanningChunkDuration());
CHECK (frameStart + expectedTimeIncrement > Time(refPoint) + timings.getPlanningChunkDuration());
#endif /////////////////////////////////////////////////////////////////////////////////////////////////////////////UNIMPLEMENTED :: TICKET #903
CHECK (Time(0,25) == job2.parameter.nominalTime);
CHECK (45 == job2.parameter.invoKey.part.a); // and this one to segment #2
}
/** @test usually at the end of each standard invocation,
* after scheduling a chunk of new Jobs, an additional
* continuation job is created to re-invoke this
* scheduling step.
* - the refPoint gets bumped beyond the planned segment
* - the continuation job embodies a suitable closure,
* usable for self-re-invocation
/** @test for the actual use case, the dispatcher acts as entrance point
* to a job-planning pipeline builder, which in the end is an iterator
* to pull render jobs from
* @see JobPlanningPipeline_test for in-depth coverage of this complex topic
*/
void
check_ContinuationBuilder()
pipelineBuilder()
{
#if false /////////////////////////////////////////////////////////////////////////////////////////////////////////////UNIMPLEMENTED :: TICKET #903
Dispatcher& dispatcher = mockDispatcher();
ModelPort modelPort (getTestPort());
Timings timings (FrameRate::PAL);
MockDispatcher dispatcher{MakeRec() // a single segment covering the complete time-axis
.attrib("mark", 555) // marker to demonstrate proper connectivity
.genNode()};
// prepare the rest of this test to be invoked as "continuation"
function<void(TimeAnchor)> testFunc = verify_invocation_of_Continuation;
play::Timings timings (FrameRate::PAL);
auto [port,sink] = dispatcher.getDummyConnection(1);
TimeAnchor refPoint = TimeAnchor::build (timings, START_FRAME);
JobPlanningSequence jobs = dispatcher.onCalcStream(modelPort,CHANNEL)
.establishNextJobs(refPoint)
.prepareContinuation(testFunc);
// Dispatcher-Interface: pipeline builder...
auto pipeline = dispatcher.forCalcStream (timings)
.timeRange(Time{200,0}, Time{300,0})
.pullFrom (port)
.feedTo (sink);
// an additional "continuation" Job has been prepared....
Job continuation = lib::pull_last(jobs);
CHECK (META_JOB == continuation.getKind());
CHECK (not isnil (pipeline));
CHECK (5 == pipeline.currFrameNr()); // 5 * 1/25sec = 200ms
// the Continuation will be scheduled sufficiently ahead of the currently planned chunk's end
CHECK (continuation.getNominalTime() < Time(refPoint) + timings.getPlanningChunkDuration());
Job job = pipeline.buildJob(); // invoke the JobPlanning to build a Job for the first frame
CHECK (Time(200,0) == job.parameter.nominalTime);
CHECK (555 == job.parameter.invoKey.part.a); // the marker shows that this job is connected properly
// now invoke the rest of this test, which has been embedded into the continuation job.
// Since we passed testFunc as action for the continuation, we expect the invocation
// of the function verify_invocation_of_Continuation()
continuation_has_been_triggered = false;
++pipeline; // iterate to advance to the next frame
CHECK (not isnil (pipeline));
CHECK (6 == pipeline.currFrameNr());
job = pipeline.buildJob(); // build job for the next frame
CHECK (Time(240,0) == job.parameter.nominalTime);
CHECK (555 == job.parameter.invoKey.part.a);
continuation.triggerJob();
CHECK (continuation_has_been_triggered);
#endif /////////////////////////////////////////////////////////////////////////////////////////////////////////////UNIMPLEMENTED :: TICKET #903
}
/** action used as "continuation" in #check_ContinuationBuilder
* This function expects to be invoked with a time anchor bumped up
* to point exactly behind the end of the previously planned chunk of Jobs
*/
static void
verify_invocation_of_Continuation (TimeAnchor nextRefPoint)
{
Timings timings (FrameRate::PAL);
Duration frameDuration (1, FrameRate::PAL);
Time startAnchor = Time::ZERO + START_FRAME*frameDuration;
Duration time_to_cover = timings.getPlanningChunkDuration();
++pipeline;
CHECK (7 == pipeline.currFrameNr());
job = pipeline.buildJob();
CHECK (Time(280,0) == job.parameter.nominalTime);
CHECK (Time(nextRefPoint) >= startAnchor + time_to_cover);
CHECK (Time(nextRefPoint) < startAnchor + time_to_cover + 1*frameDuration);
continuation_has_been_triggered = true;
++pipeline; // iterate beyond end point
CHECK (isnil (pipeline)); // pipeline exhausted
}
};

View file

@ -258,6 +258,7 @@ namespace test {
/** @test Job-planning pipeline integration test
* - use the MockDispatcher to define a fake model setup
* - define three levels of prerequisites
* - also define a second segment with different structure
* - build a complete Job-Planning pipeline
* - define a visualisation to expose generated job parameters
* - iterate the Job-Planning pipeline and apply the visualisation
@ -265,7 +266,7 @@ namespace test {
void
integration()
{
MockDispatcher dispatcher{MakeRec() // define a single segment for the complete time axis
MockDispatcher dispatcher{MakeRec() // start with defining a first segment...
.attrib("mark", 11) // the »master job« for each frame has pipeline-ID ≔ 11
.attrib("runtime", Duration{Time{10,0}})
.scope(MakeRec()
@ -276,6 +277,19 @@ namespace test {
.attrib("runtime", Duration{Time{30,0}})
.genNode())
.genNode())
.genNode()
,MakeRec() // add a second Segment with different calculation structure
.attrib("start", Time{250,0}) // partitioning the timeline at 250ms
.attrib("mark", 44)
.attrib("runtime", Duration{Time{70,0}})
.scope(MakeRec() // on 2nd level we have two independent prerequisites here
.attrib("mark", 55) // ...both will line up before the deadline of ticket No.44
.attrib("runtime", Duration{Time{60,0}})
.genNode()
,MakeRec()
.attrib("mark", 66)
.attrib("runtime", Duration{Time{50,0}})
.genNode())
.genNode()};
@ -315,9 +329,9 @@ namespace test {
treeExplore(move(pipeline))
.transform(visualise)
)
== "J(11|200ms⧐1s180ms)-J(22|200ms⧐1s150ms)-J(33|200ms⧐1s110ms)-" // ... -(10+10) | -(10+10)-(10+20) | -(10+10)-(10+20)-(10+30)
== "J(11|200ms⧐1s180ms)-J(22|200ms⧐1s150ms)-J(33|200ms⧐1s110ms)-" // ... -(10+10) | -(10+10)-(10+20) | -(10+10)-(10+20)-(10+30)
"J(11|240ms⧐1s220ms)-J(22|240ms⧐1s190ms)-J(33|240ms⧐1s150ms)-"
"J(11|280ms⧐1s260ms)-J(22|280ms⧐1s230ms)-J(33|280ms⧐1s190ms)"_expect);
"J(44|280ms⧐1s200ms)-J(66|280ms⧐1s140ms)-J(55|280ms⧐1s130ms)"_expect); // ... these call into the 2nd Segment
}
};

View file

@ -69719,7 +69719,7 @@
<edge COLOR="#725330"/>
<icon BUILTIN="full-1"/>
</node>
<node BACKGROUND_COLOR="#eee5c3" COLOR="#990000" CREATED="1681424351736" ID="ID_141256625" MODIFIED="1681424826119" STYLE="bubble" TEXT="JobPlanning bleibt als Front-End/Strategy/StateCore erhalten (sp&#xe4;ter zu pr&#xfc;fen)">
<node COLOR="#435e98" CREATED="1681424351736" ID="ID_141256625" MODIFIED="1687393283879" STYLE="bubble" TEXT="JobPlanning bleibt als Front-End/Strategy/StateCore erhalten (sp&#xe4;ter zu pr&#xfc;fen)">
<edge COLOR="#725330"/>
<icon BUILTIN="full-2"/>
</node>
@ -70199,8 +70199,8 @@ Date:&#160;&#160;&#160;Thu Apr 20 18:53:17 2023 +0200<br/>
</node>
</node>
</node>
<node BACKGROUND_COLOR="#eee5c3" COLOR="#990000" CREATED="1684869703449" ID="ID_842973451" MODIFIED="1684869779446" TEXT="Frame Dispatch">
<icon BUILTIN="stop"/>
<node BACKGROUND_COLOR="#eee5c3" COLOR="#990000" CREATED="1684869703449" ID="ID_842973451" MODIFIED="1687398733423" TEXT="Frame Dispatch">
<icon BUILTIN="prepare"/>
<node BACKGROUND_COLOR="#eee5c3" COLOR="#990000" CREATED="1681425423695" ID="ID_1928295133" MODIFIED="1683836443972" TEXT="Reorganisation : RenderDrive verwenden">
<linktarget COLOR="#f4fec9" DESTINATION="ID_1928295133" ENDARROW="Default" ENDINCLINATION="-1068;-69;" ID="Arrow_ID_362199078" SOURCE="ID_1888344503" STARTARROW="None" STARTINCLINATION="1381;58;"/>
<linktarget COLOR="#fed5d7" DESTINATION="ID_1928295133" ENDARROW="Default" ENDINCLINATION="-463;400;" ID="Arrow_ID_1972838231" SOURCE="ID_580321819" STARTARROW="None" STARTINCLINATION="-412;-64;"/>
@ -70351,7 +70351,7 @@ Date:&#160;&#160;&#160;Thu Apr 20 18:53:17 2023 +0200<br/>
</node>
</node>
</node>
<node BACKGROUND_COLOR="#f0d5c5" COLOR="#990033" CREATED="1681689961426" ID="ID_1735556854" MODIFIED="1681690034338" TEXT="was wird dann aber aus dem Dispatcher?">
<node COLOR="#435e98" CREATED="1681689961426" ID="ID_1735556854" MODIFIED="1687398710704" TEXT="was wird dann aber aus dem Dispatcher?">
<linktarget COLOR="#fd4259" DESTINATION="ID_1735556854" ENDARROW="Default" ENDINCLINATION="20;-71;" ID="Arrow_ID_91051045" SOURCE="ID_1384696790" STARTARROW="None" STARTINCLINATION="-206;16;"/>
<icon BUILTIN="help"/>
<node CREATED="1681689971576" ID="ID_497495407" MODIFIED="1681690040742">
@ -70379,30 +70379,50 @@ Date:&#160;&#160;&#160;Thu Apr 20 18:53:17 2023 +0200<br/>
</html></richcontent>
</node>
<node CREATED="1681690087200" ID="ID_14312341" MODIFIED="1681690107889" TEXT="folglich wird dieser Teil komplett entkoppelt von &#xbb;der Engine&#xab;"/>
<node CREATED="1681690260176" ID="ID_1829278703" MODIFIED="1681690292694" TEXT="aber er sollte per DependencyInjection eingebracht werden (&#x2023; EngineService)"/>
<node BACKGROUND_COLOR="#d2beaf" COLOR="#692e51" CREATED="1681690260176" ID="ID_1829278703" MODIFIED="1687398699759" TEXT="aber er sollte per DependencyInjection eingebracht werden (&#x2023; EngineService)">
<icon BUILTIN="bell"/>
</node>
<node BACKGROUND_COLOR="#eee5c3" COLOR="#990000" CREATED="1681741481500" ID="ID_384450703" MODIFIED="1681741489593" TEXT="Dispatcher-Interface neu definieren">
<icon BUILTIN="flag-yellow"/>
</node>
<node COLOR="#338800" CREATED="1681741481500" ID="ID_384450703" MODIFIED="1687398665498" TEXT="Dispatcher-Interface neu definieren">
<icon BUILTIN="button_ok"/>
<node COLOR="#435e98" CREATED="1681741493272" ID="ID_1834962194" MODIFIED="1687304951551" TEXT="der Builder wird durch einen Pipeline-Builder ersetzt">
<icon BUILTIN="yes"/>
</node>
<node BACKGROUND_COLOR="#eee5c3" COLOR="#990000" CREATED="1681741503343" ID="ID_852301467" MODIFIED="1681741508391" TEXT="Services">
<icon BUILTIN="flag-yellow"/>
<node BACKGROUND_COLOR="#eee5c3" COLOR="#990000" CREATED="1681741523181" ID="ID_1358920776" MODIFIED="1681741643557" TEXT="FrameCoord locateRelative (FrameCoord, frameOffset)">
<icon BUILTIN="flag-yellow"/>
<node BACKGROUND_COLOR="#bdb5cb" COLOR="#435e98" CREATED="1681741503343" ID="ID_852301467" MODIFIED="1687398622818" TEXT="Services">
<icon BUILTIN="info"/>
<node COLOR="#5b280f" CREATED="1681741523181" ID="ID_1358920776" MODIFIED="1687393566356" TEXT="FrameCoord locateRelative (FrameCoord, frameOffset)">
<icon BUILTIN="button_cancel"/>
<node COLOR="#338800" CREATED="1681741644460" ID="ID_498811202" MODIFIED="1681741652180" TEXT="schon implementiert">
<icon BUILTIN="button_ok"/>
</node>
<node BACKGROUND_COLOR="#f0d5c5" COLOR="#990033" CREATED="1681741652742" ID="ID_615819221" MODIFIED="1686586961674" TEXT="&#xfc;berpr&#xfc;fen">
<node COLOR="#435e98" CREATED="1681741652742" ID="ID_615819221" MODIFIED="1687393534811" TEXT="&#xfc;berpr&#xfc;fen">
<icon BUILTIN="help"/>
</node>
<node CREATED="1687393536846" ID="ID_763423492" MODIFIED="1687393543030" TEXT="f&#xe4;llt weg">
<icon BUILTIN="stop-sign"/>
</node>
<node BACKGROUND_COLOR="#f0d5c5" COLOR="#990033" CREATED="1681741589427" ID="ID_1281351405" MODIFIED="1681741634102" TEXT="bool isEndOfChunk (frame, ModelPort)">
</node>
<node COLOR="#5b280f" CREATED="1681741589427" ID="ID_1281351405" MODIFIED="1687393563710" TEXT="bool isEndOfChunk (frame, ModelPort)">
<icon BUILTIN="button_cancel"/>
<node COLOR="#435e98" CREATED="1681741635654" ID="ID_1118664905" MODIFIED="1687393555611" TEXT="fraglich ob noch ben&#xf6;tigt">
<icon BUILTIN="help"/>
<node CREATED="1681741635654" ID="ID_1118664905" MODIFIED="1681741641217" TEXT="fraglich ob noch ben&#xf6;tigt"/>
</node>
<node BACKGROUND_COLOR="#eee5c3" COLOR="#990000" CREATED="1681741688503" ID="ID_1430371522" MODIFIED="1681741803819" TEXT="JobTicket&amp; accessJobTicket (TimeValue nominalTime, ModelPort, channel)">
<icon BUILTIN="flag-yellow"/>
<node CREATED="1687393536846" ID="ID_1434969503" MODIFIED="1687393543030" TEXT="f&#xe4;llt weg">
<icon BUILTIN="stop-sign"/>
</node>
</node>
<node BACKGROUND_COLOR="#bdb5cb" COLOR="#435e98" CREATED="1681741688503" ID="ID_1430371522" MODIFIED="1687398658430">
<richcontent TYPE="NODE"><html>
<head>
</head>
<body>
<p>
<font face="Monospaced">JobTicket&amp; <b>accessJobTicket</b>&#160;(TimeValue nominalTime, ModelPort, channel)</font>
</p>
</body>
</html></richcontent>
<icon BUILTIN="info"/>
<node COLOR="#338800" CREATED="1681741883229" ID="ID_15002134" MODIFIED="1681741890812" TEXT="Front-End: getJobTicketFor (FrameCoord)">
<icon BUILTIN="button_ok"/>
</node>
@ -70410,8 +70430,18 @@ Date:&#160;&#160;&#160;Thu Apr 20 18:53:17 2023 +0200<br/>
<icon BUILTIN="flag-yellow"/>
</node>
</node>
<node BACKGROUND_COLOR="#eee5c3" COLOR="#990000" CREATED="1686695464553" ID="ID_260036671" MODIFIED="1686695470854" TEXT="size_t resolveModelPort (ModelPort)">
<icon BUILTIN="flag-yellow"/>
<node BACKGROUND_COLOR="#bdb5cb" COLOR="#435e98" CREATED="1686695464553" ID="ID_260036671" MODIFIED="1687398646974">
<richcontent TYPE="NODE"><html>
<head>
</head>
<body>
<p>
<font face="Monospaced">size_t <b>resolveModelPort</b>&#160;(ModelPort)</font>
</p>
</body>
</html></richcontent>
<icon BUILTIN="info"/>
<node CREATED="1686695480435" ID="ID_1246751606" MODIFIED="1686695551021" TEXT="&#x201e;irgendwo dahinter&#x201c; mu&#xdf; es eine Mapping-Tabelle geben">
<icon BUILTIN="idea"/>
</node>
@ -76510,8 +76540,8 @@ Date:&#160;&#160;&#160;Thu Apr 20 18:53:17 2023 +0200<br/>
<icon BUILTIN="button_ok"/>
</node>
</node>
<node BACKGROUND_COLOR="#eef0c5" COLOR="#990000" CREATED="1687226442603" HGAP="-25" ID="ID_1588706779" MODIFIED="1687312226495" TEXT="JobPlanningPIpeline_test::integration()" VSHIFT="17">
<icon BUILTIN="pencil"/>
<node COLOR="#338800" CREATED="1687226442603" HGAP="-25" ID="ID_1588706779" MODIFIED="1687393224652" TEXT="JobPlanningPIpeline_test::integration()" VSHIFT="17">
<icon BUILTIN="button_ok"/>
<node COLOR="#338800" CREATED="1687226500123" ID="ID_667484740" MODIFIED="1687226507025" TEXT="3-stufige Prerequisites">
<icon BUILTIN="button_ok"/>
</node>
@ -76561,8 +76591,8 @@ Date:&#160;&#160;&#160;Thu Apr 20 18:53:17 2023 +0200<br/>
</node>
</node>
</node>
<node BACKGROUND_COLOR="#eee5c3" COLOR="#990000" CREATED="1687312289435" ID="ID_269400382" MODIFIED="1687312303347" TEXT="use multiple Segments with different config">
<icon BUILTIN="flag-yellow"/>
<node COLOR="#338800" CREATED="1687312289435" ID="ID_269400382" MODIFIED="1687393222723" TEXT="use multiple Segments with different config">
<icon BUILTIN="button_ok"/>
</node>
</node>
</node>
@ -76646,7 +76676,7 @@ Date:&#160;&#160;&#160;Thu Apr 20 18:53:17 2023 +0200<br/>
</node>
<node CREATED="1512925253328" ID="ID_922277724" MODIFIED="1686620124221" TEXT="JobTicket">
<linktarget COLOR="#82597c" DESTINATION="ID_922277724" ENDARROW="Default" ENDINCLINATION="43;-81;" ID="Arrow_ID_941233317" SOURCE="ID_946385163" STARTARROW="None" STARTINCLINATION="-124;34;"/>
<icon BUILTIN="prepare"/>
<icon BUILTIN="go"/>
<node CREATED="1681166276225" HGAP="5" ID="ID_877524227" MODIFIED="1686873733037" TEXT="ein Execution-Plan g&#xfc;litg f&#xfc;r ein Segment + ModelPort" VSHIFT="-7">
<icon BUILTIN="idea"/>
</node>