cwScoreFollowTest.cpp : Added _gen_synced_perf_files() and call to sf_analysis::gen_analysis().

cwScoreFollowTest.cpp

@@ -19,6 +19,7 @@
 #include "cwScoreFollower.h"
 #include "cwScoreFollowTest.h"
 
+#include "cwSfAnalysis.h"
 #include "cwSvgScoreFollow.h"
 
 namespace cw
@@ -37,7 +38,8 @@ namespace cw
       const object_t* dynRefDict;
 
       const object_t* perfL;
-      
+      const object_t* gen_synced_cfg;
+      bool            print_rt_events_fl; // print real-time score follow events from cwScoreFollowTest.cpp
       bool            pre_test_fl;     // insert a dummy note prior to the first perf. note to test the 'pre' functionality of the SVG generation
       bool            show_muid_fl;    // true = show perf. note 'muid' in SVG file, false=show sequence id
       
@@ -51,6 +53,9 @@ namespace cw
       bool            write_perf_meas_json_fl;
       const char*     out_perf_meas_json_fname;
 
+      bool            write_sf_analysis_csv_fl;
+      const char*     out_sf_analysis_csv_fname;
+      
       bool            write_svg_file_fl;
       const char*     out_svg_fname;
       
@@ -83,12 +88,14 @@ namespace cw
                          "dyn_ref",         p->dynRefDict,
 
                          "perfL",        p->perfL,
+                         "gen_synced_perf_files", p->gen_synced_cfg,
                          
                          "score_wnd_locN",  p->sf_args.scoreWndLocN,
                          "midi_wnd_locN",   p->sf_args.midiWndLocN,
                          "track_print_fl",  p->sf_args.trackPrintFl,
                          "track_results_backtrack_fl", p->sf_args.trackResultsBacktrackFl,
 
+                         "print_rt_events_fl", p->print_rt_events_fl,
                          "pre_test_fl",  p->pre_test_fl,
                          "show_muid_fl", p->show_muid_fl,
 
@@ -100,6 +107,9 @@ namespace cw
                          "write_perf_meas_json_fl",  p->write_perf_meas_json_fl,
                          "out_perf_meas_json_fname", p->out_perf_meas_json_fname,
 
+                         "write_sf_analysis_csv_fl", p->write_sf_analysis_csv_fl,
+                         "out_sf_analysis_csv_fname",    p->out_sf_analysis_csv_fname,
+                         
                          "write_svg_file_fl",   p->write_svg_file_fl,
                          "out_svg_fname",       p->out_svg_fname,
                          
@@ -133,91 +143,38 @@ namespace cw
       return rc;
     }
 
-
+    rc_t _score_follow_midi_file( const char*              midi_fname,
-    rc_t _score_follow_one_perf( test_t* p,
+                                  sfscore::handle_t        scoreH,
-                                 score_follower::handle_t sfH,
+                                  score_follower::handle_t sfH,
-                                 sfscore::handle_t       scoreH,
+                                  perf_meas::handle_t      perfMeasH, // perfMeasH is optional
-                                 perf_meas::handle_t     perfMeasH,
+                                  unsigned                 beg_loc,
-                                 unsigned                perf_idx )
+                                  unsigned                 end_loc,
+                                  double                   srate,
+                                  bool                     print_rt_events_fl,                                  
+                                  bool                     pre_test_fl = false,
+                                  const char*              synced_perf_fname = nullptr)
     {
-      rc_t                           rc             = kOkRC;
+      rc_t                           rc   = kOkRC;
-      bool                           pre_test_fl    = p->pre_test_fl;
+      unsigned                       msgN = 0;
-      bool                           enable_fl      = true;
+      const midi::file::trackMsg_t** msgA = nullptr;
-      const char*                    perf_label     = nullptr;
-      const char*                    player_name    = nullptr;
-      const char*                    perf_date      = nullptr;
-      unsigned                       perf_take_numb = kInvalidId;
-      const char*                    midi_fname     = nullptr;
-      char*                          out_dir        = nullptr;
-      char*                          fname          = nullptr;
-      unsigned                       start_loc      = 0;
-      const object_t*                perf           = nullptr;
-      unsigned                       msgN           = 0;
-      const midi::file::trackMsg_t** msgA           = nullptr;
       midi::file::handle_t           mfH;
             
-      // get the perf. record
-      if((perf = p->perfL->child_ele(perf_idx)) == nullptr )
-      {
-        rc = cwLogError(kSyntaxErrorRC,"Error accessing the cfg record for perf. record index:%i.",perf_idx);
-        goto errLabel;
-      }
-
-      // parse the performance record
-      if((rc = perf->getv("label",perf_label,
-                          "enable_fl",enable_fl,
-                          "player",player_name,
-                          "perf_date",perf_date,
-                          "take",perf_take_numb,
-                          "start_loc", start_loc,
-                          "midi_fname", midi_fname)) != kOkRC )
-      {
-        rc = cwLogError(kSyntaxErrorRC,"Error parsing cfg record for perf. record index:%i.",perf_idx);
-        goto errLabel;
-      }
-
-      if( !enable_fl )
-        goto errLabel;
-          
-      // create the output directory
-      if((out_dir = filesys::makeFn(p->out_dir,perf_label,nullptr,nullptr)) == nullptr )
-      {
-        rc = cwLogError(kOpFailRC,"Directory name formation failed on '%s'.",cwStringNullGuard(out_dir));
-        goto errLabel;        
-      }
-
-      // create the output directory
-      if((rc = filesys::makeDir(out_dir)) != kOkRC )
-      {
-        rc = cwLogError(kOpFailRC,"mkdir failed on '%s'.",cwStringNullGuard(out_dir));
-        goto errLabel;        
-      }
-
-      // expand the MIDI filename
-      if((fname = filesys::expandPath( midi_fname )) == nullptr )
-      {
-        rc = cwLogError(kOpFailRC,"The MIDI file path expansion failed.");
-        goto errLabel;
-      }
-      
       // open the midi file
-      if((rc = midi::file::open( mfH, fname )) != kOkRC )
+      if((rc = midi::file::open( mfH, midi_fname )) != kOkRC )
       {
-        rc = cwLogError(rc,"MIDI file open failed on '%s'.",cwStringNullGuard(fname));
+        rc = cwLogError(rc,"MIDI file open failed on '%s'.",cwStringNullGuard(midi_fname));
         goto errLabel;
       }
 
-      mem::release(fname);
-
       // set the score follower to the start location
-      if((rc = reset( sfH, start_loc)) != kOkRC )
+      if((rc = reset( sfH, beg_loc)) != kOkRC )
       {
         cwLogError(rc,"Score follower reset failed.");
         goto errLabel;
       }
       
-      // set the score follower to the start location
+      // set the perf meas obj to the start location
-      if((rc = reset( perfMeasH, start_loc)) != kOkRC )
+      if((rc = reset( perfMeasH, beg_loc)) != kOkRC )
       {
         cwLogError(rc,"Perf meas. unit reset failed.");
         goto errLabel;
@@ -226,7 +183,7 @@ namespace cw
       // get a pointer to a time sorted list of MIDI messages in the file
       if(((msgN = msgCount( mfH )) == 0) || ((msgA = midi::file::msgArray( mfH )) == nullptr) )
       {
-        rc = cwLogError(rc,"MIDI file msg array is empty or corrupp->");
+        rc = cwLogError(rc,"MIDI file msg array is empty or corrupt");
         goto errLabel;    
       }
 
@@ -239,7 +196,7 @@ namespace cw
         if( midi::file::isNoteOn( m ) )
         {
           double        sec        = (double)m->amicro/1e6;      
-          unsigned long smpIdx     = (unsigned long)(p->srate * m->amicro/1e6);
+          unsigned long smpIdx     = (unsigned long)(srate * m->amicro/1e6);
           bool          newMatchFl = false;
 
           if( pre_test_fl )
@@ -277,7 +234,7 @@ namespace cw
                 // store the performance data in the score
                 set_perf( scoreH, r->scEvtIdx, r->sec, r->pitch, r->vel, r->cost );
 
-                if( p->meas_enable_fl )
+                if( perfMeasH.isValid() )
                 {
                   perf_meas::result_t pmr = {0};
 
@@ -288,17 +245,22 @@ namespace cw
                     for(unsigned i=0; i<perf_meas::kValCnt; ++i)
                       v[i] = pmr.valueA[i] == std::numeric_limits<double>::max() ? -1 : pmr.valueA[i];
 
-                    cwLogInfo("Section '%s' triggered loc:%i : dyn:%f even:%f tempo:%f cost:%f",
+                    if( print_rt_events_fl )
-                              cwStringNullGuard(pmr.sectionLabel),
+                      cwLogInfo("Section '%s' triggered loc:%i : dyn:%f even:%f tempo:%f cost:%f",
-                              pmr.sectionLoc,
+                                cwStringNullGuard(pmr.sectionLabel),
-                              v[ perf_meas::kDynValIdx ],
+                                pmr.sectionLoc,
-                              v[ perf_meas::kEvenValIdx ],
+                                v[ perf_meas::kDynValIdx ],
-                              v[ perf_meas::kTempoValIdx ],
+                                v[ perf_meas::kEvenValIdx ],
-                              v[ perf_meas::kMatchCostValIdx ] );
+                                v[ perf_meas::kTempoValIdx ],
+                                v[ perf_meas::kMatchCostValIdx ] );
                   }
                 }
 
-                cwLogInfo("Match:%i %i %i :  %i",resultIdxN,perfN,resN,resultIdxA[i]);
+                if(print_rt_events_fl)
+                {
+                  const sfscore::event_t* e = event(scoreH, r->scEvtIdx );
+                  cwLogInfo("Match:%i %i %i :  %i : %i %s",resultIdxN,perfN,resN,resultIdxA[i],e->oLocId,e->sciPitch);
+                }
               }
             
             clear_result_index_array( sfH );
@@ -306,6 +268,208 @@ namespace cw
         }
       }
 
+
+      if( (rc==kOkRC) and (synced_perf_fname != nullptr) )
+      {
+        if((rc = write_sync_perf_csv( sfH, synced_perf_fname, msgA, msgN )) != kOkRC )
+        {
+          rc = cwLogError(rc,"Sync-perf file generation failed on '%s'.", synced_perf_fname);
+          goto errLabel;
+        }
+      }
+
+    errLabel:
+      if(rc != kOkRC )
+        rc = cwLogError(rc,"Score follow of '%s' failed.",cwStringNullGuard(midi_fname));
+
+      close(mfH);
+      
+      return rc;
+    }
+
+    rc_t _gen_synced_perf_files( test_t* p,
+                                 sfscore::handle_t        scoreH,
+                                 score_follower::handle_t sfH,
+                                 perf_meas::handle_t      perfMeasH )
+    {
+      rc_t            rc        = kOkRC;
+      const object_t* jobL      = nullptr;
+      const char*     out_fname = nullptr;
+      bool            enable_fl = false;
+
+      // parse the cfg record
+      if((rc = p->gen_synced_cfg->getv("enable_fl",enable_fl,
+                                       "jobL",jobL,
+                                       "out_fname",out_fname)) != kOkRC )
+      {
+        rc = cwLogError(rc,"Sync perf file arg. parse failed.");
+        goto errLabel;
+      }
+
+      if( !enable_fl )
+        goto errLabel;
+      
+      
+      // for each job
+      for(unsigned i=0; i<jobL->child_count() && rc == kOkRC; ++i)
+      {
+        const object_t*      job_obj = nullptr;
+        const char*          dir           = nullptr;
+        filesys::dirEntry_t* dirEntryArray = nullptr;
+        unsigned             dirEntryCnt   = 0;
+
+        
+        if((job_obj = jobL->child_ele(i)) == nullptr || !job_obj->is_dict()  )
+        {
+          rc = cwLogError(kSyntaxErrorRC,"The jobL entry at index %i could not be parsed.",i);
+          goto errLabel;
+        }
+
+
+        if((rc = job_obj->getv("dir",dir)) != kOkRC )
+        {
+          rc = cwLogError(rc,"The jobL entry at index '%i' parse failed.",i);
+          goto errLabel;
+        }
+
+        if(( dirEntryArray = filesys::dirEntries( dir, filesys::kDirFsFl | filesys::kFullPathFsFl, &dirEntryCnt )) == nullptr )
+          goto errLabel;
+
+        for(unsigned i=0; i<dirEntryCnt and rc==kOkRC; ++i)
+        {
+          char*     meta_fname           = filesys::makeFn(  dirEntryArray[i].name, "meta", "cfg", NULL);
+          char*     midi_fname           = filesys::makeFn(  dirEntryArray[i].name, "midi", "mid", NULL);
+          char*     sync_perf_fname      = filesys::makeFn(  dirEntryArray[i].name, out_fname, NULL, NULL);
+          object_t* meta_obj             = nullptr;
+          unsigned  beg_loc              = kInvalidId;
+          unsigned  end_loc              = kInvalidId;
+          bool      skip_score_follow_fl = false;
+                    
+          // read the meta object
+          if((rc = objectFromFile( meta_fname, meta_obj)) != kOkRC )
+            rc = cwLogError(rc,"An object could not be formed from the meta data file '%s'.",cwStringNullGuard(meta_fname));
+          else
+          // parse the meta object
+            if((rc = meta_obj->getv("beg_loc",beg_loc,"end_loc",end_loc,"skip_score_follow_fl",skip_score_follow_fl)) != kOkRC )
+              rc = cwLogError(rc,"The meta data file '%s' could not be parsed.",cwStringNullGuard(meta_fname));
+            else
+              if( skip_score_follow_fl )
+                cwLogInfo("The `skip_score_follow_fl` is set in '%s'.",cwStringNullGuard(meta_fname));
+              else
+                if((rc = _score_follow_midi_file( midi_fname,
+                                                  scoreH,
+                                                  sfH,
+                                                  perfMeasH,
+                                                  beg_loc,
+                                                  end_loc,
+                                                  p->srate,
+                                                  p->print_rt_events_fl,
+                                                  false,
+                                                  sync_perf_fname)) != kOkRC )
+                {
+                  rc = cwLogError(rc,"The score follower failed on '%s'. Consider setting the 'skip_score_follow_fl' in '%s'.",cwStringNullGuard(midi_fname),cwStringNullGuard(meta_fname));
+                }
+          
+          mem::release(midi_fname);
+          mem::release(sync_perf_fname);
+          mem::release(meta_fname);
+          meta_obj->free();
+        }
+
+        mem::release(dirEntryArray);
+      }
+    errLabel:
+
+      if( rc != kOkRC )
+        rc = cwLogError(rc,"Synced performance file generation failed.");
+  
+      return rc;
+  
+    }
+
+    
+    rc_t _score_follow_one_perf( test_t* p,
+                                 score_follower::handle_t sfH,
+                                 sfscore::handle_t       scoreH,
+                                 perf_meas::handle_t     perfMeasH,
+                                 unsigned                perf_idx )
+    {
+      rc_t                           rc             = kOkRC;
+      bool                           enable_fl      = true;
+      const char*                    perf_label     = nullptr;
+      const char*                    player_name    = nullptr;
+      const char*                    perf_date      = nullptr;
+      unsigned                       perf_take_numb = kInvalidId;
+      const char*                    midi_fname     = nullptr;
+      char*                          out_dir        = nullptr;
+      char*                          fname          = nullptr;
+      unsigned                       start_loc      = 0;
+      unsigned                       end_loc        = 0;
+      const object_t*                perf           = nullptr;
+      midi::file::handle_t           mfH;      
+
+      // get the perf. record
+      if((perf = p->perfL->child_ele(perf_idx)) == nullptr )
+      {
+        rc = cwLogError(kSyntaxErrorRC,"Error accessing the cfg record for perf. record index:%i.",perf_idx);
+        goto errLabel;
+      }
+
+      // parse the performance record
+      if((rc = perf->getv("label",perf_label,
+                          "enable_fl",enable_fl,
+                          "player",player_name,
+                          "perf_date",perf_date,
+                          "take",perf_take_numb,
+                          "start_loc", start_loc,
+                          "end_loc", end_loc,
+                          "midi_fname", midi_fname)) != kOkRC )
+      {
+        rc = cwLogError(kSyntaxErrorRC,"Error parsing cfg record for perf. record index:%i.",perf_idx);
+        goto errLabel;
+      }
+
+      if( !enable_fl )
+        goto errLabel;
+          
+      // create the output directory
+      if((out_dir = filesys::makeFn(p->out_dir,perf_label,nullptr,nullptr)) == nullptr )
+      {
+        rc = cwLogError(kOpFailRC,"Directory name formation failed on '%s'.",cwStringNullGuard(out_dir));
+        goto errLabel;        
+      }
+
+      // create the output directory
+      if((rc = filesys::makeDir(out_dir)) != kOkRC )
+      {
+        rc = cwLogError(kOpFailRC,"mkdir failed on '%s'.",cwStringNullGuard(out_dir));
+        goto errLabel;        
+      }
+
+      /*
+      // expand the MIDI filename
+      if((fname = filesys::expandPath( midi_fname )) == nullptr )
+      {
+        rc = cwLogError(kOpFailRC,"The MIDI file path expansion failed.");
+        goto errLabel;
+      }
+      */
+      
+      if((rc = _score_follow_midi_file( midi_fname,
+                                        scoreH,
+                                        sfH,
+                                        perfMeasH,
+                                        start_loc,
+                                        end_loc,
+                                        p->srate,
+                                        p->print_rt_events_fl,
+                                        p->pre_test_fl )) != kOkRC )
+      {
+        goto errLabel;
+      }
+      
+      //mem::release(fname);      
+
       if( p->write_perf_meas_json_fl )
       {
         // create the JSON output filename
@@ -327,6 +491,33 @@ namespace cw
         
       }
 
+      // Write the score following results to a CSV
+      if( p->write_sf_analysis_csv_fl )
+      {
+        // create the JSON output filename
+        if((fname = filesys::makeFn(out_dir,p->out_sf_analysis_csv_fname,nullptr,nullptr)) == nullptr )
+        {
+          cwLogError(kOpFailRC,"The output SF analysis CSV filename formation failed.");
+          goto errLabel;
+        }
+
+        cwLogInfo("Writing SF analysis result to:%s",cwStringNullGuard(fname));
+
+        if((rc = sf_analysis::gen_analysis( scoreH,
+                                            track_result(sfH),
+                                            track_result_count(sfH),
+                                            start_loc,
+                                            end_loc,
+                                            fname )) != kOkRC )
+        {
+          rc = cwLogError(rc,"SF analysis CSV report failed.");
+          goto errLabel;
+        }
+      
+        mem::release(fname);
+        
+      }
+
 
       // write the score following result SVG
       if( p->write_svg_file_fl )
@@ -392,6 +583,7 @@ cw::rc_t cw::score_follow_test::test( const object_t* cfg )
   dyn_ref_tbl::handle_t    dynRefH;
   score_parse::handle_t    scParseH;
   perf_meas::handle_t      perfMeasH;
+  perf_meas::params_t perf_meas_params;
   
   test_t t = {0};
 
@@ -428,7 +620,8 @@ cw::rc_t cw::score_follow_test::test( const object_t* cfg )
   }
 
   // Create a Perf Measurement object
-  if((rc = create( perfMeasH, t.sf_args.scoreH )) != kOkRC )
+  perf_meas_params.print_rt_events_fl = t.print_rt_events_fl;
+  if((rc = create( perfMeasH, t.sf_args.scoreH, perf_meas_params )) != kOkRC )
   {
     rc = cwLogError(rc,"Perf. Measurement unit create failed.");
     goto errLabel;
@@ -459,6 +652,8 @@ cw::rc_t cw::score_follow_test::test( const object_t* cfg )
   for(unsigned perf_idx=0; perf_idx<t.perfL->child_count(); ++perf_idx)
     _score_follow_one_perf(&t,sfH,t.sf_args.scoreH,perfMeasH,perf_idx);
 
+  // score follow and generate synced performance files
+  rc = _gen_synced_perf_files(&t,t.sf_args.scoreH,sfH,perfMeasH);
   
  errLabel:
   mem::release(fname);
@@ -471,3 +666,4 @@ cw::rc_t cw::score_follow_test::test( const object_t* cfg )
   
   return rc;
 }
+