job-ticket.cpp

Go to the documentation of this file.

/*
  JobTicket  -  execution plan for render jobs
 
   Copyright (C)
     2012,            Hermann Vosseler <Ichthyostega@web.de>
 
 **Lumiera** is free software; you can redistribute it and/or modify it
 under the terms of the GNU General Public License as published by the
 Free Software Foundation; either version 2 of the License, or (at your
 option) any later version. See the file COPYING for further details.
 
* *****************************************************************/
 
 
#include "steam/engine/job-ticket.hpp"
#include "vault/gear/nop-job-functor.hpp"
#include "lib/hash-combine.hpp"
#include "lib/depend.hpp"
#include "lib/util.hpp"
 
 
namespace steam {
namespace engine {
  
  using vault::gear::Job;
  using vault::gear::JobClosure;
  using lib::HashVal;
  using lib::unConst;
  using lib::time::FSecs;
  
  
  namespace { // Details...
    lib::Depend<vault::gear::NopJobFunctor> nopFunctor;
    
    /* ======== hard wired =================*/
    const FSecs JOB_MINIMUM_RUNTIME{1,1000};
    
  } // (END) Details...
  
  
  
  
  
  JobTicket JobTicket::NOP{};            
  
  JobTicket::JobTicket()
    : provision_{nopFunctor(), ExitNode::NIL}
  { }
 
  
  Job
  JobTicket::createJobFor (Time nominalTime)
  {
    if (this->empty())
      {                    
        return Job(nopFunctor(), InvocationInstanceID(), nominalTime);
      }
    else
      {
        REQUIRE (this->isValid(), "Attempt to generate render job for incomplete or unspecified render plan.");
        JobClosure& functor = static_cast<JobClosure&> (unConst(provision_.jobFunctor));      
        InvocationInstanceID invoKey{timeHash (nominalTime, provision_.invocationSeed)};
        
        return Job(functor, invoKey, nominalTime);
      }
  }
  
  
  Duration
  JobTicket::getExpectedRuntime()
  {
    if (this->empty())
      return Duration{JOB_MINIMUM_RUNTIME};
    else
      {
        REQUIRE (isValid(), "Attempt to determine timings for incomplete or unspecified render plan.");
        return provision_.exitNode.getUpperBoundRuntime();
      }
  }
  
  
  InvocationInstanceID
  JobTicket::timeHash (Time nominalTime, InvocationInstanceID const& seed)
  {
    InvocationInstanceID res{seed};
    HashVal timeMark = res.part.t;
    lib::hash::combine (timeMark, hash_value (nominalTime));
    res.part.t = timeMark;
    return res;
  }
  
  
  namespace {     
    inline bool
    operator== (InvocationInstanceID const& l, InvocationInstanceID const& r)
    {
      return lumiera_invokey_eq (unConst(&l), unConst(&r));
    }
  }
  
  bool
  JobTicket::verifyInstance (JobFunctor& functor, InvocationInstanceID const& invoKey, Time nominalTime)  const
  {
    return util::isSameObject (provision_.jobFunctor, functor)
       and invoKey == timeHash (nominalTime, provision_.invocationSeed);
  }
 
  
  
  
}} // namespace steam::engine