#include "vault/gear/activity-term.hpp"

Description

A Term of the »Activity Language«, describing the steps necessary to perform the calculation of a single frame or similar tasks.

Definition at line 93 of file activity-term.hpp.

Public Types
enum	Template { CALC_JOB , LOAD_JOB , META_JOB }

Public Member Functions
	Term (AllocHandle &&allocHandle, Template kind, Time start, Time dead, Job job)

	operator std::string () const

Activity &	post ()

Activity &	callback ()

Term &	expectNotification (Activity &notificationSrc, bool unlimitedTime=false)
	Builder operation: block this Term waiting for prerequisite notification.

Term &	appendNotificationTo (Term &targetTerm, bool unlimitedTime=false)
	Builder operation: append a Notification link to the end of this Term's chain.

Term &	requireDirectActivation ()
	Insert a self-inhibition to enforce activation is possible only after the scheduled start time.

Private Types
using	AllocHandle = BlockFlowAlloc::AllocatorHandle

Private Member Functions
void	configureTemplate (Template kind)

Activity *	setupInvocation (Job &job)

Activity *	setupPost (Time start, Time dead, Activity *followUp)

void	setupGate ()

void	insertWorkBracket ()

void	severAsyncChain ()

Static Private Member Functions
static void	insert (Activity anchor, Activity target)

static Activity *	findTail (Activity *chain)

Private Attributes
AllocHandle	alloc_

Activity *	invoke_ {nullptr}

Activity *	post_ {nullptr}

Activity *	gate_ {nullptr}

Activity *	callback_ {nullptr}

Constructor & Destructor Documentation

◆ Term()

Term	(	AllocHandle &&	allocHandle,
		Template	kind,
		Time	start,
		Time	dead,
		Job	job
	)

inlineexplicit

Definition at line 114 of file activity-term.hpp.

References Term::configureTemplate().

Here is the call graph for this function:

Member Typedef Documentation

◆ AllocHandle

using AllocHandle = BlockFlowAlloc::AllocatorHandle

private

Definition at line 96 of file activity-term.hpp.

Member Enumeration Documentation

◆ Template

enum Template

Enumerator
CALC_JOB	scheme for a synchronous media calculation job
LOAD_JOB	scheme for an asynchronous data retrieval job
META_JOB	scheme for planning and organisational job

Definition at line 108 of file activity-term.hpp.

Member Function Documentation

◆ operator std::string()

operator std::string ( ) const

inline

Definition at line 124 of file activity-term.hpp.

References Term::invoke_, and Term::post_.

◆ post()

Activity & post ( )

inline

Returns: entrance point to this Activity-chain setup.

Remarks: use this call for instructing the Scheduler.

Definition at line 138 of file activity-term.hpp.

References Term::post_.

◆ callback()

Activity & callback ( )

inline

Returns: re-entrance point for completion after async IO.

Remarks: initiate follow-up processing by ActivityLang::dispatchChain().

Definition at line 149 of file activity-term.hpp.

References Term::callback_.

◆ expectNotification()

Term & expectNotification	(	Activity &	notificationSrc,
		bool	unlimitedTime = `false`
	)

inline

Builder operation: block this Term waiting for prerequisite notification.

Parameters

notificationSrc an NOTIFY-Activity to attach the notification-link

Note: using this feature implies to wire in a GATE-Activity (if not already present) and to increase the Gate's latch counter. Moreover, the Argument, must be a NOTIFY and will be modified to store the link to this receiving Gate; typically this function is actually invoked starting from the other Term — the prerequisite — by invoking #appendNotificationTo(targetTerm).

Definition at line 165 of file activity-term.hpp.

References Time::ANYTIME, Activity::data_, Term::gate_, Activity::incDependencies(), Activity::is(), Activity::TimeWindow::life, Activity::NOTIFY, Term::post_, Activity::setNotificationTarget(), Term::setupGate(), and Activity::ArgumentData::timeWindow.

Referenced by Term::appendNotificationTo(), and Term::requireDirectActivation().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ appendNotificationTo()

Term & appendNotificationTo	(	Term &	targetTerm,
		bool	unlimitedTime = `false`
	)

inline

Builder operation: append a Notification link to the end of this Term's chain.

Parameters

targetTerm another Term, which thereby becomes dependent on this Term.

Remarks: the targetTerm will be inhibited, until this Term's chain has been activated and processed up to emitting the inserted NOTIFY.

Definition at line 182 of file activity-term.hpp.

References Term::alloc_, Term::callback_, Term::expectNotification(), Term::findTail(), Term::insert(), Term::invoke_, and Activity::NOTIFY.

Here is the call graph for this function:

◆ requireDirectActivation()

Term & requireDirectActivation ( )

inline

Insert a self-inhibition to enforce activation is possible only after the scheduled start time.

Relevant for Jobs, which are to be triggered by external events, while the actual computation must not be start prior to activating the main chain, even if all prerequisites are already fulfilled.

Remarks: typical example is when a target buffer is known to be available only after the planned start time and until the planned deadline.

Note: the actual activation always goes through Activity::dispatch() and the primary chain is aborted with activity::SKIP. However, since the additional notification is inserted at a point executed holding the GroomingToken, the dispatch() actually happens synchronous and immediately processes the activated tail-chain in a nested call.

Deprecated:: 12/23 this feature seemed necessary in the first implementation, yet after integration and follow-up refactorings (NOTIFY-handling) it turned out both superfluous and potentially dangerous, since it creates additional management work and possible contention on the Grooming-Token. The way NOTIFY-activities are handled now already ensures that they are activated only after their target's start time.

Definition at line 210 of file activity-term.hpp.

References Term::alloc_, Term::expectNotification(), Term::insert(), Activity::NOTIFY, and Term::post_.

Here is the call graph for this function: