special-job-fun-test.cpp

Go to the documentation of this file.

/*
  SpecialJobFun(Test)  -  verify a disposable configurable job functor

   Copyright (C)
     2023,            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 "lib/test/run.hpp"
#include "lib/test/test-helper.hpp"
//#include "vault/real-clock.hpp"
//#include "lib/time/timevalue.hpp"
#include "vault/gear/special-job-fun.hpp"
#include "lib/format-cout.hpp" 
#include "lib/test/diagnostic-output.hpp"
#include "lib/test/tracking-dummy.hpp"
//#include "lib/util.hpp"

//#include <array>
//#include <functional>

//using lib::time::Time;
//using lib::time::FSecs;

//using util::isnil;
//using util::isSameObject;
//using lib::test::randStr;
//using lib::test::randTime;
using lib::test::Dummy;
//using std::array;


namespace vault{
namespace gear {
namespace test {
  
  namespace { // shorthands and parameters for test...
    
    
  }//(End)test definitions
  
  
  
  
  /*****************************************************************/
  class SpecialJobFun_test : public Test
    {
      
      virtual void
      run (Arg)
        {
          simpleUsage();
          verifyLifecycle();
        }
      
      
      void
      simpleUsage()
        {
          bool hit{false};         // create directly from λ
          SpecialJobFun specialFun{[&](JobParameter){ hit=true; }};
          
          CHECK (specialFun);
          Job funJob{specialFun
                    ,InvocationInstanceID()
                    ,Time::ANYTIME
                    };
          
          funJob.triggerJob();
          CHECK (hit);
          CHECK (not specialFun);
        }
      
      
      
      void
      verifyLifecycle()
        {
          CHECK (0 == Dummy::checksum());
          {                        //  Note: ▽▽▽ tracker in λ-closure
            SpecialJobFun funTrack{[tracker=Dummy(23)]
                                   (JobParameter param) mutable
                                    {
                                      int mark = param.invoKey.part.a;
                                      tracker.setVal (mark);
                                    }};    // △△△ invocation should alter checksum
            
            // one Dummy instance was implanted
            CHECK (23 == Dummy::checksum());
            InvocationInstanceID hiddenMessage;
            hiddenMessage.part.a = 55;
            Job funJob{funTrack
                      ,hiddenMessage
                      ,Time::ANYTIME
                      };
            
            CHECK (23 == Dummy::checksum());
            funJob.triggerJob();
            CHECK (55 == Dummy::checksum());                             // the `funJob` front-end handle still keeps it alive
          }                                                              // but when this front-end goes out of scope...
          CHECK (0 == Dummy::checksum());                                // the implanted tracker is also gone
          
          {                                                              // another investigation with the same technique...
            auto trackingLambda = [tracker=Dummy(23)]
                                   (JobParameter param) mutable
                                    {
                                      int mark = param.invoKey.part.a;
                                      tracker.setVal (mark);
                                    };
            CHECK (23 == Dummy::checksum());
            
            SpecialJobFun frontEnd{move(trackingLambda)};                // this time the λ is moved in..
            CHECK (23 == Dummy::checksum());                             // the embedded tracker was copied into the Functor in heap memory
            CHECK (2 == frontEnd.use_count());                           // Note: both the front-end and the Functor in heap hold a use-reference
            
            auto otherHandle = frontEnd;                                 // copy of front-end...
            CHECK (3 == frontEnd.use_count());                           // ...so there are three usages of the front-end handle now
            CHECK (23 == Dummy::checksum());                             // ...but only one tracker instance (in heap)
            
            frontEnd = SpecialJobFun();                                  // re-assign one front-end handle with an empty instance
            CHECK (0 == frontEnd.use_count());                           // thus `frontEnd` is no longer attached to the active instance
            CHECK (2 == otherHandle.use_count());                        // but the other copy still is
            CHECK (not frontEnd);
            CHECK (otherHandle);
            
            InvocationInstanceID hiddenMessage;
            hiddenMessage.part.a = 55;
            Job funJob{otherHandle                                       // Note: don't pass the handle here, rather a JobFunctor& is extracted
                      ,hiddenMessage
                      ,Time::ANYTIME
                      };

            CHECK (2 == otherHandle.use_count());
            CHECK (23 == Dummy::checksum());
            
            otherHandle = SpecialJobFun();                               // now kill even the last front-end handle we had
            CHECK (0 == otherHandle.use_count());                        // thus _we_ have no way to reach the Functor in heap
            CHECK (23 == Dummy::checksum());                             // yet it stays alive, since it was not invoked yet
            
            funJob.triggerJob();                                         // after invocation, the Functor in heap memory self-destructs
            CHECK (0 == Dummy::checksum());                              // since it did hold the last reference
          }
          CHECK (0 == Dummy::checksum());
        }
    };
  
  
  LAUNCHER (SpecialJobFun_test, "unit engine");
  
  
  
}}} // namespace vault::gear::test